bug修复

Administrator

2023-07-24 0304e71a1c82f6274c4af744a5284b3f1cbc0f57

bug修复

 trade/huaxin/trade_server.py

@@ -228,6 +228,7 @@

                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                    elif data_json["type"] == "l2_market_data":
                        try:
                        data = data_json["data"]
                        code = data["code"]
                        data = data["data"]
@@ -245,14 +246,17 @@
                            code_price_manager.Buy1PriceManager.process(code, buy_1_price, time_str, limit_up_price,
                                                                        sell_1_price, sell_1_volume // 100)
                        hx_logger_l2_market_data.info(f"{code}#{data}")
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
                    elif data_json["type"] == "l2_subscript_codes":
                        try:
                        data = data_json["data"]
                        datas = data["data"]
                        print("l2_subscript_codes", data_json)
                        # 订阅的代码
                        huaxin_target_codes_manager.save_subscript_codes(datas)
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
                else:
                    # 断开连接
                    break