++++++++++++++++ bug修复-

Administrator

2023-08-15 5a28abc3f829eba092ebc87578a65d09f38fe262

++++++++++++++++
bug修复-

 huaxin_api/l2_client.py

@@ -524,11 +524,10 @@
def __receive_from_pipe_strategy(pipe):
    while True:
        try:
            value = pipe.recv()
            if value:
                print("__receive_from_pipe_strategy:",value)
                value = value.decode("utf-8")
                data = json.loads(value)
            val = pipe.recv()
            if val:
                print("L2客户端接受到数据：:", val)
                data = json.loads(val)
                if data["type"] == "set_l2_codes":
                    data = data["data"]
                    l2CommandManager.process_command(command_manager.CLIENT_TYPE_CMD_L2, None, data)
@@ -536,7 +535,7 @@
            logging.exception(e)


def run(pipe_trade=None, pipe_strategy=None):
def run(pipe_trade, pipe_strategy):
    __init_l2()
    if pipe_trade is not None:
        t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True)
@@ -553,6 +552,6 @@


if __name__ == "__main__":
    run()
    run(None,None)
    # spi.set_codes_data([("000333", 12000)])
    input()

 trade/huaxin/trade_api_server.py

@@ -438,7 +438,7 @@
                                 "data": datas,
                                 "request_id": f"{ ClientSocketManager.CLIENT_TYPE_CMD_L2}_{round(time.time()*1000)}"}
                    root_data = socket_util.encryp_client_params_sign(root_data)
                    pipe_l2.send(json.dumps(root_data).encode('utf-8'))
                    pipe_l2.send(json.dumps(root_data))
                    print("设置L2代码结束")
        except Exception as e:
            logging.exception(e)