S撤日志改为异步

Administrator

2023-08-23 91e7f80fc55282f26b8db007ffedd03899ff4804

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
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
 
threadIds = {}
 
 
def debug(code, content, *args):
    async_log_util.debug(logger_l2_trade,
                         ("thread-id={} code={}  ".format(threadIds.get(code), code) + content).format(*args))
 
 
def buy_debug(code, content, *args):
    async_log_util.debug(logger_l2_trade_buy,
                         ("thread-id={} code={}  ".format(threadIds.get(code), code) + content).format(*args))
 
 
def cancel_debug(code, content, *args):
    async_log_util.debug(logger_l2_trade_cancel,
                         ("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,
                         ("thread-id={} code={} type={} data=".format(threadIds.get(code), code,
                                                                      type) + content).format(*args))