From 8a8cefbd8c7218a5c9ef8894e31ec496375a0483 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 18 八月 2023 11:12:51 +0800
Subject: [PATCH] bug修改
---
trade/trade_manager.py | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/trade/trade_manager.py b/trade/trade_manager.py
index 4e24240..276efbe 100644
--- a/trade/trade_manager.py
+++ b/trade/trade_manager.py
@@ -384,6 +384,9 @@
RedisUtils.realse(redis)
+__CodesTradeStateManager = CodesTradeStateManager()
+
+
# 寮�濮嬩氦鏄�
def start_buy(code, capture_timestamp, last_data, last_data_index):
# @dask.delayed
@@ -394,7 +397,7 @@
# @dask.delayed
def is_state_right(code):
- trade_state = CodesTradeStateManager().get_trade_state_cache(code)
+ trade_state = __CodesTradeStateManager.get_trade_state_cache(code)
if trade_state != TRADE_STATE_NOT_TRADE and trade_state != TRADE_STATE_BUY_CANCEL_SUCCESS and trade_state != TRADE_STATE_BUY_CANCEL_ING:
return Exception("浠ｇ爜澶勪簬涓嶅彲浜ゆ槗鐘舵��"), trade_state
return None, trade_state
@@ -433,7 +436,7 @@
print("寮�濮嬩拱鍏�")
logger_trade.info("{}寮�濮嬩拱鍏�".format(code))
- CodesTradeStateManager().set_trade_state(code, TRADE_STATE_BUY_PLACE_ORDER)
+ __CodesTradeStateManager.set_trade_state(code, TRADE_STATE_BUY_PLACE_ORDER)
# _start_time = l2_data_log.l2_time(code, tool.get_now_timestamp() - _start_time, "涔板叆鍒ゆ柇鏃堕棿", force=True)
__buy(code, price, trade_state, capture_timestamp, last_data, last_data_index)
# l2_data_log.l2_time(code, tool.get_now_timestamp() - _start_time, "寮傛涔板叆鏃堕棿", force=True)
@@ -471,7 +474,6 @@
def __place_order_success(code, capture_timestamp, last_data, last_data_index):
# 涔板叆缁撴潫鐐�
use_time = round(time.time() * 1000) - capture_timestamp
- logger_trade.info("{}-浠庢埅鍥惧埌涓嬪崟鎴愬姛鎬昏垂鏃讹細{}".format(code, use_time))
# 涓嬪崟鎴愬姛锛屽姞鍏ュ浐瀹氫唬鐮佸簱
if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_THS:
l2_data_manager.add_to_l2_fixed_codes(code)
--
Gitblit v1.8.0