交易日志格式化处理

Administrator

2023-10-10 21b84025d0d2543b5f6dc8c22859d25ce0e5de30

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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
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
 
threadIds = {}
 
 
def __add_async_log(logger_, code, content, *args):
    try:
        if len(args) > 0:
            async_log_util.debug(logger_,
                                 ("thread-id={} code={}  ".format(threadIds.get(code), code) + content).format(*args))
        else:
            async_log_util.debug(logger_,
                                 "thread-id={} code={}  ".format(threadIds.get(code), code) + content)
    except Exception as e:
        logger_l2_error.exception(e)
 
 
def debug(code, content, *args):
    __add_async_log(logger_l2_trade, code, content, *args)
 
 
def buy_debug(code, content, *args):
    __add_async_log(logger_l2_trade_buy, code, content, *args)
 
 
def cancel_debug(code, content, *args):
    __add_async_log(logger_l2_trade_cancel, code, content, *args)
 
 
def s_cancel_debug(code, content, *args):
    __add_async_log(logger_l2_s_cancel, code, content, *args)
 
 
def h_cancel_debug(code, content, *args):
    __add_async_log(logger_l2_h_cancel, code, content, *args)
 
 
def l_cancel_debug(code, content, *args):
    __add_async_log(logger_l2_l_cancel, code, content, *args)
 
 
def d_cancel_debug(code, content, *args):
    __add_async_log(logger_l2_d_cancel, code, content, *args)
 
 
# 交易记录
def trade_record(code, type, content, *args):
    if len(args) > 0:
        async_log_util.debug(logger_trade_record,
                             ("thread-id={} code={} type={} data=".format(threadIds.get(code), code,
                                                                          type) + content).format(*args))
    else:
        async_log_util.debug(logger_trade_record,
                             "thread-id={} code={} type={} data=".format(threadIds.get(code), code,
                                                                         type) + content)