| | |
| | | nRequestID: "int") -> "void": |
| | | try: |
| | | if pRspInfoField.ErrorID == 0: |
| | | # logger.info('[%d] OnRspOrderInsert: OK! [%d]' % (round(time.time() * 1000), nRequestID)) |
| | | pass |
| | | async_log_util.info(logger_local_huaxin_trade_debug, '[%d] OnRspOrderInsert: OK! [%d]' % (round(time.time() * 1000), nRequestID)) |
| | | else: |
| | | # logger.info('OnRspOrderInsert: Error! [%d] [%d] [%s]' |
| | | # % (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg)) |
| | | async_log_util.error(logger_local_huaxin_trade_debug, |
| | | f"OnRspOrderInsert 报单出错:{pRspInfoField.ErrorID}-{pRspInfoField.ErrorMsg}") |
| | | self.call_back_thread_pool.submit(self.__data_callback, TYPE_ORDER, nRequestID, |
| | | {"sinfo": pInputOrderField.SInfo, |
| | | "orderStatus": -1, |
| | |
| | | |
| | | def set_response(request_id, response): |
| | | if request_id: |
| | | hx_logger_trade_loop.info("请求响应: request_id-{}", request_id) |
| | | hx_logger_trade_loop.info(f"请求响应: request_id-{request_id} 内容-{response}") |
| | | # 主动触发 |
| | | __request_response_dict[request_id] = response |
| | | try: |