From d9a3b754d14f93375cd3d91afa49be8deb07975c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 26 六月 2024 16:37:15 +0800
Subject: [PATCH] 订阅bug修改
---
huaxin_client/l2_client.py | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index aabb5a1..8aee8e7 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -148,6 +148,7 @@
codes.add(code)
self.codes_volume_and_price_dict[code] = (d[1], d[2], d[3], d[4])
self.l2_data_upload_manager.set_order_fileter_condition(code, d[1], round(float(d[2]), 2), d[3], d[4])
+ logger_l2_codes_subscript.info("鍗庨懌L2璁㈤槄鎬绘暟锛歿}", len(codes))
add_codes = codes - self.subscripted_codes
del_codes = self.subscripted_codes - codes
print("add del codes", add_codes, del_codes)
@@ -156,7 +157,7 @@
self.l2_data_upload_manager.release_distributed_upload_queue(c)
l2_data_manager.del_target_code(c)
for c in codes:
- self.l2_data_upload_manager.distribute_upload_queue(c)
+ self.l2_data_upload_manager.distribute_upload_queue(c, codes)
l2_data_manager.add_target_code(c)
except Exception as e: # TODO 娓呴櫎鍘熸潵杩樻病閲婃斁鎺夌殑鏁版嵁
logger_system.error(f"L2浠ｇ爜鍒嗛厤涓婁紶闃熷垪鍑洪敊:{str(e)}")
--
Gitblit v1.8.0