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

Administrator

2023-08-15 420a4ebc068a59a0a874b1fa3024711843d962ab

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

 main.py

@@ -14,6 +14,8 @@
# 交易服务
from third_data import data_server
from trade.huaxin import trade_server, trade_api_server


# from huaxin_api import trade_client, l2_client, l1_client


@@ -64,6 +66,13 @@

    serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,))
    serverProcess.start()

    tradeServerProcess = multiprocessing.Process(target=createTradeServer, args=(pss_strategy, pst_strategy, pl1t_trade,))
    tradeServerProcess.start()

    # 等待服务器启动
    time.sleep(2)

    # 交易进程与L2进程
    tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run, args=(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=huaxin_api.l2_client.run, args=(ptl2_l2,))
@@ -72,4 +81,4 @@
    # L1订阅数据
    huaxin_api.l1_client.run_async(pl1t_l1)
    # 将tradeServer作为主进程
    createTradeServer(pss_strategy, pst_strategy, pl1t_trade)
    input()

 trade/huaxin/trade_server.py

@@ -151,7 +151,7 @@
                    elif data_json["type"] == "response":
                        # 主动触发的响应
                        try:
                            client_id = data_json["client_id"]
                            client_id = data_json.get("client_id")
                            hx_logger_trade_callback.info(f"response：request_id-{data_json['request_id']}")
                            # 设置响应内容
                            trade_api.set_response(data_json["request_id"], data_json['data'])