From dde40bed2653bacfdaebc576ec739d3a322867a1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 06 三月 2024 18:33:46 +0800
Subject: [PATCH] 真实下单位寻找优化/延迟虚拟单的撤单
---
huaxin_client/trade_client.py | 15 ++++++++-------
1 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/huaxin_client/trade_client.py b/huaxin_client/trade_client.py
index 755b211..20dbdd4 100644
--- a/huaxin_client/trade_client.py
+++ b/huaxin_client/trade_client.py
@@ -20,8 +20,6 @@
from log_module.log import logger_local_huaxin_trade_debug, logger_system, logger_trade
from utils import tool
-
-
########B绫�########
UserID = '388000013349'
# 鐧婚檰瀵嗙爜
@@ -208,9 +206,11 @@
# 褰卞瓙璁㈠崟鎾ゅ崟
# 鎾ゆ帀褰卞瓙鍗�
shadow_cancel_order_ref = shadow_order_ref + 1
+ # 娣辫瘉鍋滅暀50ms涓婅瘉鍋滅暀200ms
+ delay_s = 0.05 if code.find("00") == 0 else 0.2
self.cancel_buy(code, f"s_c_{shadow_order_ref}", order_sys_id=None,
order_ref=shadow_order_ref,
- order_action_ref=None, delay_s=0.05)
+ order_action_ref=None, delay_s=delay_s)
return ret
@@ -756,9 +756,10 @@
pRspInfoField: "CTORATstpRspInfoField", nRequestID: "int",
bIsLast: "bool") -> "void":
if bIsLast != 1:
- logger_local_huaxin_trade_debug.info('OnRspQryShareholderAccount[%d]: InvestorID[%s] ExchangeID[%s] ShareholderID[%s]'
- % (nRequestID, pShareholderAccountField.InvestorID, pShareholderAccountField.ExchangeID,
- pShareholderAccountField.ShareholderID))
+ logger_local_huaxin_trade_debug.info(
+ 'OnRspQryShareholderAccount[%d]: InvestorID[%s] ExchangeID[%s] ShareholderID[%s]'
+ % (nRequestID, pShareholderAccountField.InvestorID, pShareholderAccountField.ExchangeID,
+ pShareholderAccountField.ShareholderID))
else:
logger.info('鏌ヨ鑲′笢璐︽埛缁撴潫[%d] ErrorID[%d] ErrorMsg[%s]'
% (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
@@ -1147,7 +1148,7 @@
def run(trade_response_: TradeResponse = None, queue_other_w_l2_r_: multiprocessing.Queue = None,
queue_strategy_trade_write_=None,
- queue_strategy_trade_read=None,queue_strategy_trade_read_for_read=None):
+ queue_strategy_trade_read=None, queue_strategy_trade_read_for_read=None):
try:
logger_system.info("浜ゆ槗杩涚▼ID锛歿}", os.getpid())
logger_system.info(f"trade 绾跨▼ID:{tool.get_thread_id()}")
--
Gitblit v1.8.0