‘功能完善

Administrator

5 天以前 c05044c53a5d0213ef33b2b3bdbb57a328300ad2

 main.py

@@ -11,7 +11,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
@@ -57,7 +57,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:05: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 +106,12 @@

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

    # 初始化数据
    strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str())


    logger_system.info("初始化策略对象成功")
    strategy_manager.low_suction_strtegy.load_data()
    logger_system.info("加载策略数据成功")

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