From fb47d36048e94b9a506d5c153e3dd19a01e37df1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 30 十月 2023 16:30:27 +0800
Subject: [PATCH] bug修复
---
huaxin_client/l2_data_manager.py | 15 +++++++--------
1 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index f854c2c..9a4ae30 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -55,7 +55,7 @@
# 娣诲姞濮旀墭璇︽儏
-def add_l2_order_detail(data, istransaction=False):
+def add_l2_order_detail(data, start_time, istransaction=False):
code = data["SecurityID"]
# 寮傛鏃ュ織璁板綍
if code not in tmep_order_detail_queue_dict:
@@ -79,7 +79,7 @@
tmep_order_detail_queue_dict[code].put(
(data['SecurityID'], data['Price'], data['Volume'], data['Side'], data['OrderType'], data['OrderTime'],
- data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], int(time.time() * 1000)))
+ data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], time.time(), start_time))
# 娣诲姞閫愮瑪鎴愪氦
@@ -196,23 +196,22 @@
try:
if code not in target_codes:
break
- # 鎵撳紑鍏变韩鍐呭瓨
order_detail_upload_active_time_dict[code] = time.time()
udatas = []
while not tmep_order_detail_queue_dict[code].empty():
temp = tmep_order_detail_queue_dict[code].get()
udatas.append(temp)
if udatas:
- start_time = time.time()
+ # start_time = time.time()
# upload_data(code, "l2_order", udatas)
l2_data_callback.OnL2Order(code, udatas, int(time.time() * 1000))
# l2_data_transaction_protocol.send_l2_order_detail(pipe, _mmap, code, udatas)
- use_time = int((time.time() - start_time) * 1000)
- if use_time > 10:
- async_log_util.info(logger_local_huaxin_l2_upload, f"{code}-涓婁紶浠ｇ爜鑰楁椂锛歿use_time}ms")
+ # use_time = int((time.time() - start_time) * 1000)
+ # if use_time > 10:
+ # async_log_util.info(logger_local_huaxin_l2_upload, f"{code}-涓婁紶浠ｇ爜鑰楁椂锛歿use_time}ms")
else:
# 娌℃湁鏁版嵁鐨勬椂鍊欓渶绛夊緟锛屾湁鏁版嵁鏃朵笉闇�绛夊緟
- time.sleep(0.004)
+ time.sleep(0.001)
except Exception as e:
hx_logger_contact_debug.exception(e)
logger_local_huaxin_l2_error.error(f"涓婁紶璁㈠崟鏁版嵁鍑洪敊锛歿str(e)}")
--
Gitblit v1.8.0