bug修改

Administrator

2024-03-22 ff3130c7ed30a05377770dffa23d354119f71907

bug修改

 huaxin_client/trade_client.py

@@ -1120,8 +1120,6 @@

        global queue_strategy_trade_write
        queue_strategy_trade_write = queue_strategy_r_trade_w
        # 运行日志同步
        threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True).start()

        global tradeCommandManager
        tradeCommandManager = command_manager.TradeCommandManager()

 trade/trade_strategy.py

@@ -7,7 +7,6 @@
import schedule

from code_atrribute import gpcode_manager
from code_atrribute.history_k_data_util import HistoryKDatasUtils
from huaxin_client.client_network import SendResponseSkManager
from log_module import async_log_util
from log_module.log import logger_trade, logger_debug, logger_system, logger_local_huaxin_l1_trade_info, \
@@ -351,22 +350,24 @@


def run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w, queue_strategy_r_trade_w, queue_strategy_w_trade_r):
    # 初始化
    __init()
    try:
        # 初始化
        __init()

    # 监听l1交易那边传过来的代码
    t1 = threading.Thread(target=lambda: __recv_pipe_l1_trade(queue_l1_trade_w_strategy_r), daemon=True)
    t1.start()
        # 监听l1交易那边传过来的代码
        t1 = threading.Thread(target=lambda: __recv_pipe_l1_trade(queue_l1_trade_w_strategy_r), daemon=True)
        t1.start()

    t2 = threading.Thread(target=lambda: async_log_util.run_sync, daemon=True)
    t2.start()
        threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True).start()

    huaxin_trade_data_update.run(queue_l1_trade_r_strategy_w)
        huaxin_trade_data_update.run(queue_l1_trade_r_strategy_w)

    huaxin_trade_api.run_pipe_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r)
        huaxin_trade_api.run_pipe_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r)

    manager = outside_api_command_manager.ApiCommandManager()
    manager.init(middle_api_protocol.SERVER_HOST,
                 middle_api_protocol.SERVER_PORT,
                 OutsideApiCommandCallback())
    manager.run(blocking=True)
        manager = outside_api_command_manager.ApiCommandManager()
        manager.init(middle_api_protocol.SERVER_HOST,
                     middle_api_protocol.SERVER_PORT,
                     OutsideApiCommandCallback())
        manager.run(blocking=True)
    except Exception as e:
        logger_system.exception(e)