From 1ce9035fa89764c80e2764f877b6eef7efae8266 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 12 六月 2024 13:38:16 +0800
Subject: [PATCH] bug修复
---
main.py | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/main.py b/main.py
index ce32901..445561d 100644
--- a/main.py
+++ b/main.py
@@ -260,7 +260,6 @@
# print("涓嬪崟锛�", huaxin_trade_api.order(1, "127075", 10, 140.5, blocking=True))
-
def read_l2_results(trade_call_back_queue):
while True:
try:
@@ -269,11 +268,12 @@
async_log_util.info(logger_trade, f"姝ｈ偂娑ㄥ仠锛屽噯澶囦拱鍏ュ彲杞�猴細{result}")
# 鑾峰彇鍙互涔扮殑浠ｇ爜
code, trade_time = result[0], result[1]
- if CodeTradeStateManager().get_trade_state(code) == CodeTradeStateManager.TRADE_STATE_ALREADY_BUY:
- async_log_util.info(logger_trade, f"宸茬粡涓嬪崟杩囷細{result}")
- continue
+
# 鑾峰彇鑲＄エ浠ｇ爜鐨勫彲杞�轰唬鐮�
cb_code = target_codes_manager.get_cb_code(code)
+ if CodeTradeStateManager().get_trade_state(cb_code) == CodeTradeStateManager.TRADE_STATE_ALREADY_BUY:
+ async_log_util.info(logger_trade, f"宸茬粡涓嬪崟杩囷細{result}")
+ continue
# 鑾峰彇鍙浆鍊虹殑娑ㄥ仠浠�
market_info = code_market_manager.get_market_info(cb_code)
limit_up_price = target_codes_manager.get_limit_up_price(cb_code)
--
Gitblit v1.8.0