From 6a0d3ff5832e57ee1b1374d086f24b3c1679b332 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 05 九月 2025 18:22:24 +0800
Subject: [PATCH] bug修复/降低测撤单率
---
l2/l2_log.py | 16 +++++++++++-----
1 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/l2/l2_log.py b/l2/l2_log.py
index 5cfdf3d..71df443 100644
--- a/l2/l2_log.py
+++ b/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,18 @@
# 璁剧疆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:
+ pass
+ # logging.exception(e)
+ # logger_debug.error(f"L2鏃ュ織鍒嗛厤鍑洪敊锛氭柊浠ｇ爜鎬绘暟{len(codes)}")
def get_log_manager(self, code):
if code in self.distributed_log_dict:
--
Gitblit v1.8.0