gp-cb-server.git

			@@ -66,14 +66,14 @@
			self.call_back_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)

			def OnFrontConnected(self) -> "void":
			logger_info.debug('Trader OnFrontConnected')
			logger_system.info('Trader OnFrontConnected')

			# 获取终端信息
			TradeSimpleApi.req_id += 1

			ret = self.__api.ReqGetConnectionInfo(TradeSimpleApi.req_id)
			if ret != 0:
			printlog('ReqGetConnectionInfo fail, ret[%d]' % ret)
			logger_system.info('ReqGetConnectionInfo fail, ret[%d]' % ret)

			def OnFrontDisconnected(self, nReason: "int") -> "void":
			printlog('OnFrontDisconnected: [%d]' % nReason)
			@@ -137,7 +137,7 @@
			def OnRspUserLogin(self, pRspUserLoginField: "CTORATstpRspUserLoginField", pRspInfoField: "CTORATstpRspInfoField",
			nRequestID: "int") -> "void":
			if pRspInfoField.ErrorID == 0:
			printlog('Login success! [%d]' % nRequestID)
			logger_system.info('Login success! [%d]' % nRequestID)
			self.__front_id = pRspUserLoginField.FrontID
			self.__session_id = pRspUserLoginField.SessionID
			# TradeSimpleApi.set_login_info(self.__session_id, self.__front_id)
			@@ -155,7 +155,7 @@
			# logger_info.info('ReqQryShareholderAccount fail, ret[%d]' % ret)

			else:
			logger_info.info('Login fail!!! [%d] [%d] [%s]'
			logger_system.info('Login fail!!! [%d] [%d] [%s]'
			% (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))

			def OnRspUserPasswordUpdate(self, pUserPasswordUpdateField: "CTORATstpUserPasswordUpdateField",
			@@ -459,6 +459,7 @@
			:param queue_strategy_w_trade_r:
			:return:
			"""
			logger_system.info("交易初始化")
			# -----------初始化交易环境---------------------
			trade_manager.set_result_read_queue(queue_result)
			api = traderapi.CTORATstpTraderApi.CreateTstpTraderApi('./flow', False)

			@@ -148,10 +148,8 @@

			def test():
			time.sleep(5)
			while True:
			print("获取持仓：", huaxin_trade_data_update.add_position_list())
			time.sleep(3)
			# print("获取资金：", huaxin_trade_api.get_money())

			print("获取资金：", huaxin_trade_api.get_money())
			# print("获取成交：", huaxin_trade_api.get_deal_list())
			# print("下单：", huaxin_trade_api.order(1, "127075", 10, 140.5, blocking=True))

			@@ -210,7 +208,7 @@
			command_callback, [("trade_cb", 50)])
			manager.run(blocking=False)

			# threading.Thread(target=test, daemon=True).start()
			threading.Thread(target=test, daemon=True).start()
			# ===========读取根据L2制定的买入策略==========
			threading.Thread(target=read_l2_results, args=(trade_call_back_queue,), daemon=True).start()
			# ===========异步日志持久化==========

	huaxin_client/trade_client_for_cb.py	9 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	main.py	8 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史