yu/real_trader
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add more log

Browse Source
This commit is contained in:
zhiyong 2025-05-14 11:47:20 +08:00
parent e80125140b
commit 0880d66abe
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/real/xt_trader.py
View File

@ -45,6 +45,8 @@ class MyXtQuantTraderCallback:
self.trader_instance.connection_failed = True self.trader_instance.connection_failed = True
self.trader_instance.last_reconnect_time = time.time() self.trader_instance.last_reconnect_time = time.time()
self.trader_instance.notify_connection_failure() self.trader_instance.notify_connection_failure()
else:
logger.error("重连失败: trader_instance为空")
def on_account_status(self, status): def on_account_status(self, status):
pass pass
def on_stock_asset(self, asset): def on_stock_asset(self, asset):
@ -454,8 +456,11 @@ class XtTrader(BaseTrader):
Returns: Returns:
bool: 重连是否成功 bool: 重连是否成功
""" """
logger.info("尝试重新连接交易系统")
# 关闭旧连接 # 关闭旧连接
if self.started: if self.started:
logger.info("关闭旧连接")
self.xt_trader.stop() self.xt_trader.stop()
self.started = False self.started = False
self.connected = False self.connected = False