From 46f51dfb83f6e6a2784676bde64577e5f6f28cf0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 11 三月 2025 14:31:34 +0800
Subject: [PATCH] 新版L2订阅/L2成交处理时间日志
---
servers/huaxin_trade_server.py | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/servers/huaxin_trade_server.py b/servers/huaxin_trade_server.py
index 0dc2e9d..656cc8b 100644
--- a/servers/huaxin_trade_server.py
+++ b/servers/huaxin_trade_server.py
@@ -868,6 +868,26 @@
my_trade_response = MyTradeResponse()
+def run_l2_market_info_reciever(queues: list):
+ """
+ 鎺ユ敹L2 market鏁版嵁
+ @param queues:
+ @return:
+ """
+ def recieve_data(queue):
+ while True:
+ try:
+ d = queue.get()
+ # {"type": "l2_market", "data": (code, data)}
+ if d["type"] == "l2_market":
+ code, market_data = d["data"]
+ my_l2_data_callback.OnMarketData(code, market_data)
+ except:
+ pass
+ for q in queues:
+ threading.Thread(target=recieve_data, args=(q,), daemon=True).start()
+
+
# 棰勫煁鍗�
def __test_pre_place_order():
codes = gpcode_manager.BuyOpenLimitUpCodeManager().get_codes()
--
Gitblit v1.8.0