bug修复

Administrator

2023-07-21 7c01414eb0210f1cf9e995a99da98700b42a202e

bug修复

 trade/huaxin/trade_server.py

@@ -141,17 +141,20 @@
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
                    elif data_json["type"] == "trade_callback":
                        # 交易回调
                        data_json = data_json["data"]
                        type_ = data_json["type"]
                        # 记录交易反馈日志
                        hx_logger_trade_callback.info(data_json)
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                        # 重新请求委托列表与资金
                        trade_api_server.trade_data_request_queue.put_nowait({"type": "delegate_list"})
                        trade_api_server.trade_data_request_queue.put_nowait({"type": "money"})
                        trade_api_server.trade_data_request_queue.put_nowait({"type": "deal_list"})
                        # print("响应结果：", data_json['data'])
                        try:
                            # 交易回调
                            data_json = data_json["data"]
                            type_ = data_json["type"]
                            # 记录交易反馈日志
                            hx_logger_trade_callback.info(data_json)
                            sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                            # 重新请求委托列表与资金
                            trade_api_server.trade_data_request_queue.put_nowait({"type": "delegate_list"})
                            trade_api_server.trade_data_request_queue.put_nowait({"type": "money"})
                            trade_api_server.trade_data_request_queue.put_nowait({"type": "deal_list"})
                            # print("响应结果：", data_json['data'])
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
                    elif data_json["type"] == "l2_order":
                        # L2逐笔委托
                        data = data_json["data"]