From 2dbddafe6d7fb1e99cabe1a8c7e215d87e58ef9b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 八月 2025 11:29:02 +0800
Subject: [PATCH] 增加本地更新时间
---
huaxin_client/trade_client.py | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/huaxin_client/trade_client.py b/huaxin_client/trade_client.py
index 6b50d0f..8544193 100644
--- a/huaxin_client/trade_client.py
+++ b/huaxin_client/trade_client.py
@@ -367,13 +367,14 @@
@return:
"""
for i in range(len(order_infos)):
- order_ref, order_sys_id = order_infos[i][0], order_infos[i][1]
+ order_ref, order_sys_id = order_infos[i][0], order_infos[i][1]
sinfo = sinfos[i]
order_action_ref = order_action_refs[i]
if order_sys_id:
- self.cancel_buy(code, sinfo, order_sys_id=order_sys_id, order_action_ref=order_action_ref, delay_s=delay_s)
+ self.cancel_buy(code, sinfo, order_sys_id=order_sys_id, order_action_ref=order_action_ref,
+ delay_s=delay_s)
else:
- self.cancel_buy(code, sinfo, order_ref=order_ref, order_action_ref=order_action_ref, delay_s=delay_s)
+ self.cancel_buy(code, sinfo, order_ref=order_ref, order_action_ref=order_action_ref, delay_s=delay_s)
return
# 鍗�
@@ -813,7 +814,8 @@
"volume": pOrderField.VolumeTotalOriginal, "volumeTraded": pOrderField.VolumeTraded,
"orderStatus": pOrderField.OrderStatus,
"orderSubmitStatus": pOrderField.OrderSubmitStatus,
- "statusMsg": pOrderField.StatusMsg}
+ "statusMsg": pOrderField.StatusMsg, "volumeCanceled": pOrderField.VolumeCanceled,
+ "localUpdateTime": int(time.time()*1000)}
self.call_back_thread_pool.submit(self.__data_callback, TYPE_ORDER, 0, order_data)
except Exception as e:
async_log_util.error(logger_local_huaxin_trade_debug, "OnRtnOrder 鍑洪敊")
@@ -929,7 +931,8 @@
"turnover": pOrderField.Turnover, "orderRef": pOrderField.OrderRef,
"volume": pOrderField.VolumeTotalOriginal,
"volumeTraded": pOrderField.VolumeTraded, "orderStatus": pOrderField.OrderStatus,
- "orderSubmitStatus": pOrderField.OrderSubmitStatus, "statusMsg": pOrderField.StatusMsg,"sinfo": pOrderField.SInfo
+ "orderSubmitStatus": pOrderField.OrderSubmitStatus, "statusMsg": pOrderField.StatusMsg,
+ "sinfo": pOrderField.SInfo
})
else:
# logger.info('鏌ヨ鎶ュ崟缁撴潫[%d] ErrorID[%d] ErrorMsg[%s]'
@@ -1108,7 +1111,8 @@
req_rid_dict[sinfo] = (client_id, request_id, sk)
self.trade_thread_pool.submit(
lambda: self.__tradeSimpleApi.cancel_buy(code, sinfo, order_sys_id=orderSysID,
- order_ref=orderRef, order_action_ref=orderActionRef))
+ order_ref=orderRef,
+ order_action_ref=orderActionRef))
async_log_util.info(logger_local_huaxin_trade_debug,
f"鎾ゅ崟缁撴潫锛歝ode-{code} order_sys_id-{orderSysID} sinfo-{sinfo}")
except Exception as e:
--
Gitblit v1.8.0