From c09dd858ba2d6894d1ded8e8da5a46b9b16b05d5 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 31 五月 2024 07:50:18 +0800
Subject: [PATCH] bug修复
---
huaxin_client/l2_client_for_cb.py | 25 ++++++++++++++-----------
1 files changed, 14 insertions(+), 11 deletions(-)
diff --git a/huaxin_client/l2_client_for_cb.py b/huaxin_client/l2_client_for_cb.py
index 26d5809..11f5877 100644
--- a/huaxin_client/l2_client_for_cb.py
+++ b/huaxin_client/l2_client_for_cb.py
@@ -240,19 +240,20 @@
logger_local_huaxin_l2_transaction.info(f"{item}")
- l2_transaction_price_queue.put_nowait(
- (pTransaction['SecurityID'], pTransaction['TradePrice'], pTransaction['TradeTime']))
huaxin_l2_log.info(logger_local_huaxin_l2_transaction, f"{item}")
- # if pTransaction['TradePrice'] == self.limit_up_price_dict.get(pTransaction['SecurityID']):
- # # TODO 鎴愪氦浠锋槸娑ㄥ仠浠锋墠杈撳嚭
- # huaxin_l2_log.info(logger_local_huaxin_l2_transaction, f"{item}")
- # if not self.__is_limit_up_dict.get(pTransaction['SecurityID']):
- # huaxin_l2_log.info(logger_local_huaxin_l2_upload,
- # f"{pTransaction['TradeTime']} {pTransaction['SecurityID']} 涓嬪崟")
- # self.__is_limit_up_dict[pTransaction['SecurityID']] = True
- # else:
- # self.__is_limit_up_dict[pTransaction['SecurityID']] = False
+ if pTransaction['TradePrice'] == self.limit_up_price_dict.get(pTransaction['SecurityID']):
+ # TODO 鎴愪氦浠锋槸娑ㄥ仠浠锋墠杈撳嚭
+ #huaxin_l2_log.info(logger_local_huaxin_l2_transaction, f"{item}")
+ if not self.__is_limit_up_dict.get(pTransaction['SecurityID']):
+ huaxin_l2_log.info(logger_local_huaxin_l2_upload,
+ f"{pTransaction['TradeTime']} {pTransaction['SecurityID']} 涓嬪崟")
+ l2_transaction_price_queue.put_nowait(
+ (pTransaction['SecurityID'], pTransaction['TradePrice'], pTransaction['TradeTime']))
+
+ self.__is_limit_up_dict[pTransaction['SecurityID']] = True
+ else:
+ self.__is_limit_up_dict[pTransaction['SecurityID']] = False
except Exception as e:
logger_local_huaxin_l2_error.exception(e)
@@ -468,6 +469,8 @@
try:
# 浠ｇ爜, 鎴愪氦浠锋牸, 鎴愪氦鏃堕棿
result = l2_transaction_price_queue.get()
+ trade_call_back_queue.put_nowait(result)
+ continue
code = result[0]
if code not in __latest_transaction_price_dict:
__latest_transaction_price_dict[code] = []
--
Gitblit v1.8.0