bug修复

Administrator

2023-07-24 8a0047de489c59864350854f1aedf3087ca6eaaa

bug修复

 trade/huaxin/trade_server.py

@@ -155,6 +155,7 @@
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
                    elif data_json["type"] == "l2_order":
                        try:
                        # L2逐笔委托
                        data = data_json["data"]
                        code = data["code"]
@@ -162,9 +163,11 @@
                        hx_logger_l2_orderdetail.info(f"{code}#{datas}")
                        l2_log.threadIds[code] = random.randint(0, 100000)
                        l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas)
                        finally:
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))

                    elif data_json["type"] == "l2_trans":
                        try:
                        data = data_json["data"]
                        code = data["code"]
                        datas = data["data"]
@@ -225,7 +228,7 @@
                                    dask.compute(f1, f2, f3)
                        except Exception as e:
                            hx_logger_l2_transaction.exception(e)

                        finally:
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                    elif data_json["type"] == "l2_market_data":
                        try: