From acabf336db0e36846aab914770bde7c71941a6ed Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 23 五月 2024 23:31:00 +0800
Subject: [PATCH] bug修复
---
main.py | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/main.py b/main.py
index 961836a..c6d9337 100644
--- a/main.py
+++ b/main.py
@@ -127,7 +127,7 @@
for r in results:
cb_code = r["securityID"]
underlying_code = target_codes_manager.get_underlying_code(cb_code)
- cb_market = code_market_manager.get_market_info(code)
+ cb_market = code_market_manager.get_market_info(cb_code)
underlying_market = code_market_manager.get_market_info(underlying_code)
if cb_market:
r["marketInfo"] = {"code": cb_market.code, "name": r["securityName"],
@@ -180,6 +180,8 @@
# print("涓嬪崟锛�", huaxin_trade_api.order(1, "127075", 10, 140.5, blocking=True))
+__deal_codes = set()
+
def read_l2_results(trade_call_back_queue):
while True:
try:
@@ -188,6 +190,9 @@
async_log_util.info(logger_trade, f"姝ｈ偂娑ㄥ仠锛屽噯澶囦拱鍏ュ彲杞�猴細{result}")
# 鑾峰彇鍙互涔扮殑浠ｇ爜
code, trade_time = result[0], result[1]
+ if code in __deal_codes:
+ async_log_util.info(logger_trade, f"宸茬粡涓嬪崟杩囷細{result}")
+ continue
# 鑾峰彇鑲＄エ浠ｇ爜鐨勫彲杞�轰唬鐮�
cb_code = target_codes_manager.get_cb_code(code)
# 鑾峰彇鍙浆鍊虹殑娑ㄥ仠浠�
@@ -196,6 +201,7 @@
async_log_util.info(logger_trade, f"鍑嗗涓嬪崟锛歿cb_code}-{limit_up_price}")
# 涔板叆20鑲�
result = huaxin_trade_api.order(1, cb_code, 20, round(float(limit_up_price), 3), blocking=True)
+ __deal_codes.add(code)
async_log_util.info(logger_trade, f"鍙浆鍊轰笅鍗曠粨鏋滐細{result}")
except Exception as e:
logger_debug.exception(e)
--
Gitblit v1.8.0