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,6 +350,7 @@


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

@@ -358,8 +358,7 @@
    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)

@@ -370,3 +369,5 @@
                 middle_api_protocol.SERVER_PORT,
                 OutsideApiCommandCallback())
    manager.run(blocking=True)
    except Exception as e:
        logger_system.exception(e)