交易通道备用

Administrator

2023-08-25 f9c8c7c7528b75a968dc0dae3e8ed8d325d178b8

 huaxin_client/command_manager.py

@@ -79,6 +79,12 @@

    @classmethod
    def process_command(cls, _type, client_id, result_json, sk=None):
        # 查看是否是设置L2的代码
        if _type == CLIENT_TYPE_CMD_L2:
            cls.pipe_l2.send(
                json.dumps({"type": "set_l2_codes", "data": result_json["data"]}))
            return

        try:
            data = result_json["data"]
            print("接收内容", result_json)
@@ -123,12 +129,6 @@
                        val = json.loads(val)
                        print("run_process_command", val)
                        _type = val["type"]
                        _data = val["data"]
                        # 查看是否是设置L2的代码
                        if _type == CLIENT_TYPE_CMD_L2:
                            cls.pipe_l2.send(
                                json.dumps({"type": "set_l2_codes", "data": _data}))
                        else:
                            threading.Thread(target=lambda: cls.process_command(_type, None, val), daemon=True).start()
                except Exception as e:
                    logger_local_huaxin_trade_debug.exception(e)