From 9fe04a46d2b208508658e3e5421c9c9832bbee63 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 24 八月 2023 10:13:49 +0800
Subject: [PATCH] 异步日志bug修改
---
l2/l2_log.py | 43 +++++++++++++++++++++++++++----------------
1 files changed, 27 insertions(+), 16 deletions(-)
diff --git a/l2/l2_log.py b/l2/l2_log.py
index dca9f37..c1ebfed 100644
--- a/l2/l2_log.py
+++ b/l2/l2_log.py
@@ -1,42 +1,53 @@
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_s_cancel, logger_l2_h_cancel, logger_l2_l_cancel, logger_l2_error
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):
- async_log_util.debug(logger_l2_trade,
- ("thread-id={} code={} ".format(threadIds.get(code), code) + content).format(*args))
+ __add_async_log(logger_l2_trade, code, content, *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))
+ __add_async_log(logger_l2_trade_buy, code, content, *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))
+ __add_async_log(logger_l2_trade_cancel, code, content, *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))
+ __add_async_log(logger_l2_s_cancel, code, content, *args)
def h_cancel_debug(code, content, *args):
- async_log_util.debug(logger_l2_h_cancel,
- ("thread-id={} code={} ".format(threadIds.get(code), code) + content).format(*args))
+ __add_async_log(logger_l2_h_cancel, code, content, *args)
def l_cancel_debug(code, content, *args):
- async_log_util.debug(logger_l2_l_cancel,
- ("thread-id={} code={} ".format(threadIds.get(code), code) + content).format(*args))
+ __add_async_log(logger_l2_l_cancel, code, content, *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))
+ 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)
--
Gitblit v1.8.0