bug修复/策略完善

Administrator

4 天以前 245979e3907d34bcd88ac0c4547f399bf33a44de

 main.py

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

@@ -11,7 +12,7 @@
from db.redis_manager_delegate import RedisUtils
from huaxin_client import l2_market_client, trade_client, l1_subscript_codes_manager
from log_module import async_log_util
from log_module.log import logger_debug
from log_module.log import logger_debug, logger_system
from server import data_server
from strategy import strategy_manager
from strategy.env_info import RealTimeEnvInfo
@@ -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"]
@@ -57,7 +59,7 @@
        codes |= set([x.decode() for x in codes_sh])
        codes |= set([x.decode() for x in codes_sz])
        day = tool.get_now_date_str()
        schedule.every().day.at("11:08:00").do(lambda: KPLCodeJXBlocksManager(day, codes).start_download_blocks())
        schedule.every().day.at("08:05:00").do(lambda: KPLCodeJXBlocksManager(day, codes).start_download_blocks())
        while True:
            try:
                schedule.run_pending()
@@ -106,12 +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("系统结束")