gp-server.git - Gitblit

			@@ -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()}")