‘功能完善

Administrator

4 天以前 39e36db75d8cece9c5235ba65fde78dc9a4e591a

 main.py

@@ -1,5 +1,6 @@
import json
import multiprocessing
import pickle
import threading
import time

@@ -26,6 +27,7 @@
        while True:
            try:
                data = queue_l1_w_strategy_r.get()
                data = pickle.loads(data)
                if data.get("type") == 'set_target_codes':
                    # [(代码, 时间戳, 价格, 总交易量, 总交易额, 买5, 卖5)]
                    market_data_list = data["data"]["data"]
@@ -106,13 +108,16 @@

    # ----初始化------------
    __init()

    # 初始化数据
    strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str())
    logger_system.info("初始化策略对象成功")


    try:
        strategy_manager.low_suction_strtegy.load_data()
        logger_system.info("加载策略数据成功")
    except Exception as e:
        logger_system.error(f"加载策略数据失败：{str(e)}")
        logger_system.exception(e)

    # -------启动L2 market订阅------
    __run_l2_market_subscript()
    print("启动完成")
    logger_system.info("系统结束")