Administrator
2024-05-21 f5ed64ec931d56a74d334d07e72f78bbd095ab97
huaxin_client/trade_client_for_cb.py
@@ -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)