From a2e89ccf08cdc5a39bfeda7e3d769ca99456dc31 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 03 六月 2025 13:09:20 +0800
Subject: [PATCH] 日志修改/委托记录增加字段
---
trade/current_price_process_manager.py | 2 +-
huaxin_client/trade_client.py | 3 ++-
trade/huaxin/huaxin_trade_record_manager.py | 9 ++++++---
3 files changed, 9 insertions(+), 5 deletions(-)
diff --git a/huaxin_client/trade_client.py b/huaxin_client/trade_client.py
index 292d037..6b50d0f 100644
--- a/huaxin_client/trade_client.py
+++ b/huaxin_client/trade_client.py
@@ -929,7 +929,8 @@
"turnover": pOrderField.Turnover, "orderRef": pOrderField.OrderRef,
"volume": pOrderField.VolumeTotalOriginal,
"volumeTraded": pOrderField.VolumeTraded, "orderStatus": pOrderField.OrderStatus,
- "orderSubmitStatus": pOrderField.OrderSubmitStatus, "statusMsg": pOrderField.StatusMsg})
+ "orderSubmitStatus": pOrderField.OrderSubmitStatus, "statusMsg": pOrderField.StatusMsg,"sinfo": pOrderField.SInfo
+ })
else:
# logger.info('鏌ヨ鎶ュ崟缁撴潫[%d] ErrorID[%d] ErrorMsg[%s]'
# % (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
diff --git a/trade/current_price_process_manager.py b/trade/current_price_process_manager.py
index 2fda7fc..f11f30b 100644
--- a/trade/current_price_process_manager.py
+++ b/trade/current_price_process_manager.py
@@ -270,7 +270,7 @@
tool.get_buy_volume(limit_up_price), list(special_volumes)))
huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.push(add_datas, request_id)
except Exception as e:
- logging.exception(e)
+ logger_debug.exception(e)
else:
pass
diff --git a/trade/huaxin/huaxin_trade_record_manager.py b/trade/huaxin/huaxin_trade_record_manager.py
index 4ee9e7d..a48f811 100644
--- a/trade/huaxin/huaxin_trade_record_manager.py
+++ b/trade/huaxin/huaxin_trade_record_manager.py
@@ -72,12 +72,12 @@
nameDict = HistoryKDatasUtils.get_gp_codes_names([d['securityID']])
name = nameDict.get(d['securityID'])
cls.mysqldb.execute(
- "insert into hx_trade_delegate_record values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s', '%s')" % (
+ "insert into hx_trade_delegate_record values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s', '%s', '%s')" % (
_id, d["orderLocalID"], d["securityID"], name, d["direction"],
d["orderSysID"], d["insertTime"], d["insertDate"], d["acceptTime"], d["cancelTime"],
d["limitPrice"], d["turnover"], d["volume"], d["volumeTraded"], d["orderStatus"],
d["orderSubmitStatus"], d["statusMsg"], tool.get_now_datetime_str(),
- tool.get_now_datetime_str(), d["accountID"],d["orderRef"]))
+ tool.get_now_datetime_str(), d["accountID"], d["orderRef"], d["sinfo"]))
else:
# 淇敼鏁版嵁
updateDict = {}
@@ -99,6 +99,8 @@
updateDict['statusMsg'] = d['statusMsg']
if result[20] != d['orderRef']:
updateDict['orderRef'] = d['orderRef']
+ if result[21] != d['sinfo']:
+ updateDict['sinfo'] = d['sinfo']
if updateDict:
# 鏈夋洿鏂版暟鎹�
updateDict['updateTime'] = tool.get_now_datetime_str()
@@ -126,7 +128,8 @@
# 杞琩ict
key_list = ["id", "orderLocalID", "securityID", "securityName", "direction", "orderSysID", "insertTime",
"insertDate", "acceptTime", "cancelTime", "limitPrice", "turnover", "volume", "volumeTraded",
- "orderStatus", "orderSubmitStatus", "statusMsg", "createTime", "updateTime", "accountID", "orderRef"]
+ "orderStatus", "orderSubmitStatus", "statusMsg", "createTime", "updateTime", "accountID",
+ "orderRef", "sinfo"]
fresults = []
max_update_time = None
if results:
--
Gitblit v1.8.0