From 3ddb32c12a37985f00c3cc372a82c0fdfeaf2034 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 14 三月 2024 14:35:07 +0800
Subject: [PATCH] 测试
---
huaxin_client/l2_data_manager.py | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index ec5e72f..1b325da 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -97,8 +97,9 @@
# log_queue.put_nowait(data)
q: collections.deque = self.temp_order_queue_dict.get(code)
+ # TODO 娴嬭瘯绾跨▼
q.append((data['SecurityID'], data['Price'], data['Volume'], data['Side'], data['OrderType'], data['OrderTime'],
- data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], time.time(), start_time))
+ data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], time.time(), tool.get_thread_id()))
# 娣诲姞閫愮瑪鎴愪氦
def add_transaction_detail(self, data):
@@ -113,9 +114,10 @@
# data['SellNo'], data['ExecType']))
q: collections.deque = self.temp_transaction_queue_dict.get(code)
+ # TODO 娴嬭瘯绾跨▼
q.append((data['SecurityID'], data['TradePrice'], data['TradeVolume'],
data['OrderTime'], data['MainSeq'], data['SubSeq'], data['BuyNo'],
- data['SellNo'], data['ExecType']))
+ data['SellNo'], data['ExecType'], tool.get_thread_id()))
def add_market_data(self, data):
# 鍔犲叆涓婁紶闃熷垪
--
Gitblit v1.8.0