From 4062c0d9d4b7bc8e1d9e866a86c98db5c51f4fa0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 15 十一月 2023 16:12:47 +0800
Subject: [PATCH] K线形态加入计算
---
huaxin_client/l2_data_manager.py | 43 +++++++++++++++++++++----------------------
1 files changed, 21 insertions(+), 22 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 313c4d5..20344a9 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -158,23 +158,23 @@
upload_queue = queue_info[1]
while True:
try:
- if len(q) > 0:
+ while len(q) > 0:
data = q.popleft()
# 鍓嶇疆鏁版嵁澶勭悊锛岃繃婊ゆ帀鏃犵敤鐨勬暟鎹�
data = self.__filter_order(data)
if data:
temp_list.append(data)
+
+ if temp_list:
+ # 涓婁紶鏁版嵁
+ self.__upload_l2_data(code, upload_queue, temp_list)
+ temp_list = []
else:
- if temp_list:
- # 涓婁紶鏁版嵁
- self.__upload_l2_data(code, upload_queue, temp_list)
- temp_list = []
- else:
- if code not in self.temp_order_queue_dict:
- self.l2_order_codes.discard(code)
- break
- self.l2_order_codes.add(code)
- time.sleep(0.001)
+ if code not in self.temp_order_queue_dict:
+ self.l2_order_codes.discard(code)
+ break
+ self.l2_order_codes.add(code)
+ time.sleep(0.001)
except Exception as e:
logging.exception(e)
@@ -189,22 +189,21 @@
temp_list = []
while True:
try:
- if len(q) > 0:
+ while len(q) > 0:
data = q.popleft()
data = self.__filter_transaction(data)
if data:
temp_list.append(data)
+ if temp_list:
+ # 涓婁紶鏁版嵁
+ self.__upload_l2_data(code, upload_queue, temp_list)
+ temp_list = []
else:
- if temp_list:
- # 涓婁紶鏁版嵁
- self.__upload_l2_data(code, upload_queue, temp_list)
- temp_list = []
- else:
- if code not in self.temp_transaction_queue_dict:
- self.l2_transaction_codes.discard(code)
- break
- self.l2_transaction_codes.add(code)
- time.sleep(0.002)
+ if code not in self.temp_transaction_queue_dict:
+ self.l2_transaction_codes.discard(code)
+ break
+ self.l2_transaction_codes.add(code)
+ time.sleep(0.002)
except:
pass
finally:
--
Gitblit v1.8.0