日志修改/委托记录增加字段

Administrator

2025-06-03 a2e89ccf08cdc5a39bfeda7e3d769ca99456dc31

日志修改/委托记录增加字段

 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))

 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


 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 @@
            # 转dict
            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: