From a2e78e738db30f71ffedcbf7987391c63584aee0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 四月 2025 13:44:13 +0800
Subject: [PATCH] 丢数据测试
---
huaxin_client/l2_data_manager_v2.py | 15 ++++++++++-----
1 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/huaxin_client/l2_data_manager_v2.py b/huaxin_client/l2_data_manager_v2.py
index bc40cbe..3f32c5c 100644
--- a/huaxin_client/l2_data_manager_v2.py
+++ b/huaxin_client/l2_data_manager_v2.py
@@ -19,7 +19,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, shared_memery_util
import collections
import zmq
@@ -76,8 +76,8 @@
logger_debug.error(f"{str(e)} - min_volume-{min_volume}")
# 杩囨护璁㈠崟
- def __filter_order(self, item):
- filter_condition = self.filter_order_condition_dict.get(item[0])
+ def __filter_order(self, item, filter_condition):
+
if filter_condition:
# item[2]涓洪噺
if item[2] >= filter_condition[0][0]:
@@ -203,10 +203,11 @@
temp_list = []
while True:
try:
+ filter_condition = self.filter_order_condition_dict.get(code)
while len(q) > 0:
data = q.popleft()
# 鍓嶇疆鏁版嵁澶勭悊锛岃繃婊ゆ帀鏃犵敤鐨勬暟鎹�
- data = self.__filter_order(data)
+ data = self.__filter_order(data, filter_condition)
if data:
temp_list.append(data)
@@ -230,7 +231,11 @@
use_time = time.time() - __start_time
if use_time > 0.01:
# 璁板綍10ms浠ヤ笂鐨勬暟鎹�
- huaxin_l2_log.info(logger_local_huaxin_l2_error, f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿last_data} 鏁版嵁鏁伴噺锛歿len(temp_list)}")
+ huaxin_l2_log.info(logger_local_huaxin_l2_error,
+ f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿last_data} 鏁版嵁鏁伴噺锛歿len(temp_list)}")
+ # TODO娴嬭瘯 锛岃褰曟墍鏈夌殑璁㈠崟鍙�
+ 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]}")
temp_list = []
else:
if code not in self.temp_order_queue_dict:
--
Gitblit v1.8.0