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

Administrator

2023-08-15 5fdd432fac1e807a74c6af72a5055836749540fd

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

 huaxin_api/l2_client.py

@@ -517,8 +517,8 @@
                    volume = data["data"]["volume"]
                    code = data["data"]["code"]
                    spi.set_code_special_watch_volume(code, volume)
        except:
            pass
        except Exception as e:
            logging.exception(e)


def __receive_from_pipe_strategy(pipe):
@@ -526,13 +526,14 @@
        try:
            value = pipe.recv()
            if value:
                print("__receive_from_pipe_strategy:",value)
                value = value.decode("utf-8")
                data = json.loads(value)
                if data["type"] == "set_l2_codes":
                    data = data["data"]
                    l2CommandManager.process_command(command_manager.CLIENT_TYPE_CMD_L2, None, data)
        except:
            pass
        except Exception as e:
            logging.exception(e)


def run(pipe_trade=None, pipe_strategy=None):

 trade/huaxin/huaxin_trade_api.py

@@ -198,7 +198,7 @@
                     "data": data,
                     "request_id": request_id}
        root_data = socket_util.encryp_client_params_sign(root_data)
        pipe_trade.send(json.dumps(root_data))
        pipe_trade.send(json.dumps(root_data).encode("utf-8"))
        hx_logger_trade_loop.info("请求发送成功：request_id-{}", request_id)
    except BrokenPipeError as e:
        hx_logger_trade_loop.info("请求发送异常：request_id-{} error-{}", request_id, str(e))

 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))
                    pipe_l2.send(json.dumps(root_data).encode('utf-8'))
                    print("设置L2代码结束")
        except Exception as e:
            logging.exception(e)