日志调整

Administrator

2025-03-20 2b24be0f3293479e534d5e050c681747b18e4e78

日志调整

 l2/l2_transaction_data_processor.py

@@ -116,7 +116,7 @@

        limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)

        if len(fdatas) > 100:
        if False and len(fdatas) > 100:
            # 并行处理买单与卖单
            # 超过100条数据才需要并行处理
            f1 = dask.delayed(statistic_big_buy_data)()

 trade/buy_radical/radical_buy_data_manager.py

@@ -1829,7 +1829,7 @@
            if r not in deal_reason_codes:
                deal_reason_codes[r] = set()
            deal_reason_codes[r].add(dc)
    async_log_util.info(logger_l2_radical_buy, f"已经成交的板块：{code}-{deal_reason_codes.keys()}")
    # async_log_util.info(logger_l2_radical_buy, f"已经成交的板块：{code}-{deal_reason_codes.keys()}")

    f_buy_blocks = set()
    for b in radical_buy_blocks:
@@ -1856,7 +1856,7 @@
                if not is_front:
                    continue
        f_buy_blocks.add(b)
    async_log_util.info(logger_l2_radical_buy, f"还可以买入的板块：{code}-{f_buy_blocks}")
    # async_log_util.info(logger_l2_radical_buy, f"还可以买入的板块：{code}-{f_buy_blocks}")
    return f_buy_blocks