| | |
| | | daemon=True).start() |
| | | self.__temp_order_list_dict.pop(nRequestID) |
| | | |
| | | |
| | | # 获取响应发送socket |
| | | global req_rid_dict |
| | | req_rid_dict = {} |
| | |
| | | def OnTest(self, client_id, request_id, data): |
| | | send_response( |
| | | json.dumps({"type": "response", "data": {"code": 0, "data": data}, "client_id": client_id, |
| | | "request_id": request_id}), type, client_id, request_id,show_log=False) |
| | | "request_id": request_id}), type, client_id, request_id, show_log=False) |
| | | |
| | | |
| | | def __init_trade_data_server(): |
| | |
| | | sk.close() |
| | | |
| | | |
| | | def send_response(data, type, _client_id, _request_id,show_log=True): |
| | | logger_local_huaxin_trade_debug.debug(f"回调返回内容:{data}") |
| | | def send_response(data, type, _client_id, _request_id, show_log=True): |
| | | if show_log: |
| | | logger_local_huaxin_trade_debug.debug(f"回调返回内容:{data}") |
| | | strategy_pipe.send(data) |
| | | |
| | | |