From dff11f5dd0af74009895f2b56e38ca0d438dbcee Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 24 八月 2023 10:35:02 +0800
Subject: [PATCH] 异步日志bug修改
---
huaxin_client/l2_data_manager.py | 12 +++++++-----
1 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index d47971e..7257f10 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -23,12 +23,12 @@
# 涔板叆璁㈠崟鍙风殑瀛楀吀
buy_order_nos_dict = {}
# 鏈�杩戠殑澶у崟鎴愪氦鍗曞彿
-latest_big_order_transaction_order_dict = {}
+latest_big_order_transaction_orders_dict = {}
# 鑾峰彇鏈�杩戠殑澶у崟鎴愪氦璁㈠崟鍙�
-def get_latest_transaction_order_no(code):
- return latest_big_order_transaction_order_dict.get(code)
+def get_latest_transaction_order_nos(code):
+ return latest_big_order_transaction_orders_dict.get(code)
# 姝ｅ湪鎴愪氦鐨勮鍗曟挙鍗曚簡
@@ -79,7 +79,9 @@
code = data['SecurityID']
if code in buy_order_nos_dict:
if data['BuyNo'] in buy_order_nos_dict[code]:
- latest_big_order_transaction_order_dict[code] = data['BuyNo']
+ if code not in latest_big_order_transaction_orders_dict:
+ latest_big_order_transaction_orders_dict[code] = set()
+ latest_big_order_transaction_orders_dict[code].add(data['BuyNo'])
tmep_transaction_queue_dict[code].put((data['SecurityID'], data['TradePrice'], data['TradeVolume'],
data['OrderTime'], data['MainSeq'], data['SubSeq'], data['BuyNo'],
data['SellNo'], data['ExecType']))
@@ -168,7 +170,7 @@
if udatas:
start_time = time.time()
upload_data(code, "l2_order", udatas)
- use_time = int((time.time() - start_time)*1000)
+ use_time = int((time.time() - start_time) * 1000)
if use_time > 20:
logger_local_huaxin_l2_upload.info(f"{code}-涓婁紶浠ｇ爜鑰楁椂锛歿use_time}ms")
--
Gitblit v1.8.0