异常保护

admin

2025-03-18 cbebc3f5485c3bb1d29e94fb43f71ac5aabf9ce1

异常保护

 main.py

@@ -10,7 +10,7 @@
import constant
# 引入掘金桥梁API
import utils.juejin_api
from log_module.log import logger_common, logger_kpl_jingxuan_in
from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_system
# 引入开盘啦API模块
# 引入全局变量模块
# 引入定时器模块
@@ -115,14 +115,23 @@
    # 初始化get_current_data方法函数，下单买逻辑才会运行中。。。【核心主线程，随时考虑其启动顺序】>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>
    # threading.Thread(target=lambda: instant_time_market.get_current_data(), daemon=True).start()

    # 计算开盘啦昨日拉取的概念数据中为空的股票数量
    kpl_api.get_have_no_plate_num()
    try:
        # 计算开盘啦昨日拉取的概念数据中为空的股票数量
        kpl_api.get_have_no_plate_num()
    except Exception as e:
        logger_system.exception(e)

    # 获取历史涨停信息数据并整理
    kpl_api.get_handling_limit_up_info()
    try:
        kpl_api.get_handling_limit_up_info()
    except Exception as e:
        logger_system.exception(e)

    # 检查K线昨日涨停是否正确
    all_K_line.check_limit_up_attribute()
    try:
        # 检查K线昨日涨停是否正确
        all_K_line.check_limit_up_attribute()
    except Exception as e:
        logger_system.exception(e)

    # # 获取所有个股的板块概念并写入文件【耗时较长应该放在 核心主线程 和 仓位管理 后面】
    # kpl_api.get_all_stocks_plate_dict(data_cache.min_stocks)
@@ -161,8 +170,11 @@
    # 等待5s，等其他线程/进程启动完毕
    time.sleep(5)

    # 初始化数据
    init()
    try:
        # 初始化数据
        init()
    except Exception as e:
        logger_system.exception(e)

    # 需要订阅的目标代码
    target_codes = [x["sec_id"] for x in data_cache.DataCache().all_stocks]