bug修复

Administrator

2024-11-21 998db6c2a508fbe0df34f16be0b644f5d4250fee

bug修复

 l2/l2_log.py

@@ -1,10 +1,11 @@
import logging
import threading

import constant
from log_module import async_log_util
from log_module.log import logger_l2_trade_cancel, logger_l2_trade_buy, logger_trade_record, logger_l2_trade, \
    logger_l2_s_cancel, logger_l2_h_cancel, logger_l2_l_cancel, logger_l2_error, logger_l2_d_cancel, logger_l2_f_cancel, \
    logger_l2_g_cancel, logger_l2_j_cancel
    logger_l2_g_cancel, logger_l2_j_cancel, logger_debug


# 日志队列分配管理器
@@ -37,13 +38,17 @@
    # 设置L2订阅代码
    def set_l2_subscript_codes(self, codes):
        codes = set(codes)
        now_codes = set([code for code in self.distributed_log_dict])
        del_codes = now_codes - codes
        add_codes = codes - now_codes
        old_codes = set([code for code in self.distributed_log_dict])
        del_codes = old_codes - codes
        add_codes = codes - old_codes
        for c in del_codes:
            self.realase_log_manager(c)
        for c in add_codes:
            self.distribute_log_manager(c)
            try:
                self.distribute_log_manager(c)
            except Exception as e:
                logging.exception(e)
                logger_debug.error(f"L2日志分配出错：新代码总数{len(codes)}")

    def get_log_manager(self, code):
        if code in self.distributed_log_dict:

 log_module/log.py

@@ -503,9 +503,6 @@


def close_print():
    # TODO 测试
    if True:
        return
    logging.basicConfig(level=logging.ERROR)
    if not constant.is_windows():
        os.close(1)

 servers/huaxin_trade_server.py

@@ -395,7 +395,6 @@
        cls.__save_l1_current_price(datas)
        cls.__process_buy_open_limit_up_datas(datas)
        # 9:30之前采用非线程
        # TODO 测试
        if int(tool.get_now_time_str().replace(":", "")) < int("093000") or True:
            HuaXinL1TargetCodesManager.set_level_1_codes_datas(datas, request_id=request_id)
        else: