From 257bb8ce781ec0ef582092ea8e453ae9aec2a2c4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 23 四月 2025 17:48:45 +0800
Subject: [PATCH] 多余日志删除
---
huaxin_client/l2_data_manager.py | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 730f3cf..bdb1bb2 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -16,7 +16,7 @@
from log_module import async_log_util
from log_module.async_log_util import huaxin_l2_log
from log_module.log import logger_local_huaxin_l2_error, logger_system, logger_local_huaxin_l2_subscript, \
- logger_local_huaxin_l2_special_volume, logger_debug
+ logger_local_huaxin_l2_special_volume, logger_debug, logger_local_huaxin_l2_orderdetail
from utils import tool
import collections
import zmq
@@ -55,8 +55,8 @@
# (鏈�灏忕殑閲�, 娑ㄥ仠浠锋牸, 褰卞瓙鍗曚环鏍�, 涔扮殑閲�, 搴熷純浣跨敤, 鐗规畩鐨勯噺闆嗗悎)
self.filter_order_condition_dict[code] = [(min_volume, limit_up_price, shadow_price, buy_volume,
int(min_volume) // 50, set(special_volumes))]
- huaxin_l2_log.info(logger_local_huaxin_l2_subscript,
- f"({code})甯歌杩囨护鏉′欢璁剧疆锛歿self.filter_order_condition_dict[code]}")
+ # huaxin_l2_log.info(logger_local_huaxin_l2_subscript,
+ # f"({code})甯歌杩囨护鏉′欢璁剧疆锛歿self.filter_order_condition_dict[code]}")
except Exception as e:
logger_debug.error(f"{str(e)} - min_volume-{min_volume}")
@@ -192,6 +192,7 @@
def __run_upload_order_task(self, code):
q: collections.deque = self.temp_order_queue_dict.get(code)
temp_list = []
+ filter_condition = self.filter_order_condition_dict.get(code)
while True:
try:
while len(q) > 0:
@@ -213,6 +214,11 @@
if use_time > 0.01:
# 璁板綍10ms浠ヤ笂鐨勬暟鎹�
huaxin_l2_log.info(logger_local_huaxin_l2_error, f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿last_data}")
+
+ # 璁板綍鎵�鏈夌殑璁㈠崟鍙�
+ if filter_condition:
+ huaxin_l2_log.info(logger_local_huaxin_l2_orderdetail,
+ f"{[(x[0], x[1], x[2], x[4], x[8]) for x in temp_list if x[2] >= filter_condition[0][0]]}")
temp_list = []
else:
if code not in self.temp_order_queue_dict:
--
Gitblit v1.8.0