S撤日志改为异步

Administrator

2023-08-23 91e7f80fc55282f26b8db007ffedd03899ff4804

S撤日志改为异步

 l2/cancel_buy_strategy.py

@@ -182,7 +182,7 @@
                               buy_exec_time) > constant.S_CANCEL_EXPIRE_TIME:
            return False, None
        l2_log.cancel_debug(code, "S级是否需要撤单，数据范围：{}-{} ", start_index, end_index)
        logger_l2_s_cancel.debug(f"code-{code} S级是否需要撤单，数据范围：{start_index}-{end_index}")
        l2_log.s_cancel_debug(code, "S级是否需要撤单，数据范围：{}-{} ", start_index, end_index)

        if tool.trade_time_sub(total_data[end_index]["val"]["time"],
                               total_data[buy_exec_index]["val"]["time"]) > constant.S_CANCEL_EXPIRE_TIME:

 l2/l2_log.py

@@ -1,5 +1,6 @@
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
from log_module.log import logger_l2_trade_cancel, logger_l2_trade_buy, logger_trade_record, logger_l2_trade, \
    logger_l2_s_cancel

threadIds = {}

@@ -19,6 +20,13 @@
                         ("thread-id={} code={}  ".format(threadIds.get(code), code) + content).format(*args))


def s_cancel_debug(code, content, *args):
    async_log_util.debug(logger_l2_s_cancel,
                         ("thread-id={} code={}  ".format(threadIds.get(code), code) + content).format(*args))




# 交易记录
def trade_record(code, type, content, *args):
    async_log_util.debug(logger_trade_record,