From dedc534816213a31b0ff61ff5e979030da9447e1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 15 四月 2024 15:16:50 +0800
Subject: [PATCH] L2本地数据载入之前不能接收新的L2逐笔委托数据

---
 test/test_l2.py |   33 +++++++++++++++++++++------------
 1 files changed, 21 insertions(+), 12 deletions(-)

diff --git a/test/test_l2.py b/test/test_l2.py
index 2febe84..a43d908 100644
--- a/test/test_l2.py
+++ b/test/test_l2.py
@@ -1,14 +1,23 @@
-import threading
-
-from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager
-from log_module import log_export, async_log_util
+from l2 import l2_data_util
 
 if __name__ == "__main__":
-    code = "603363"
-    threading.Thread(target=async_log_util.run_sync, daemon=True).start()
-    map_ = log_export.load_huaxin_transaction_map()
-    for datas in map_[code]:
-        total_sell_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, datas)
-        if total_sell_info[0] > 0 and total_sell_info[1]:
-            print(total_sell_info)
-    input()
+    codes = ["600603"]
+    for code in codes:
+        l2_data_util.load_l2_data(code)
+        total_datas = l2_data_util.local_today_datas.get(code)
+        latest_index = -1
+        for d in total_datas:
+            if d["index"] - latest_index != 1:
+                print(d["index"], d)
+            latest_index = d["index"]
+        # print(total_datas[0])
+        # print(len(total_datas))
+        # print(l2_data_util.l2_data_is_normal(code))
+
+    # threading.Thread(target=async_log_util.run_sync, daemon=True).start()
+    # map_ = log_export.load_huaxin_transaction_map()
+    # for datas in map_[code]:
+    #     total_sell_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, datas)
+    #     if total_sell_info[0] > 0 and total_sell_info[1]:
+    #         print(total_sell_info)
+    # input()

--
Gitblit v1.8.0