bug修复/策略完善

Administrator

2025-06-23 ed08960c1190b132a0de3ea22a60227dc9d55bdc

 main.py

@@ -16,7 +16,9 @@
from server import data_server
from strategy import strategy_manager
from strategy.env_info import RealTimeEnvInfo
from strategy.strategy_variable_factory import DataLoader
from third_data import hx_qc_value_util
from third_data.history_k_data_manager import TradeDateManager
from third_data.kpl_block_manager import KPLCodeJXBlocksManager
from trade.huaxin import huaxin_trade_api
from utils import tool, middle_api_protocol
@@ -51,6 +53,28 @@
    @return:
    """

    def update_leading_limit_up_datas():
        """
        更新领涨代码信息
        @return:
        """

        def update():
            plates = __DataLoader.get_limit_up_reasons_with_plate_code()
            for p in plates:
                print(p)
                __DataLoader.load_plate_codes(p[0], p[1])

        if tool.get_now_time_str() < '16:00:00':
            # 如果在16:00之前采用当前日期
            day = tool.get_now_date_str()
        else:
            # 如果在16:00之后采用下一个交易日
            day = TradeDateManager().get_next_trade_day(tool.get_now_date_str())
        __DataLoader = DataLoader(day)
        threading.Thread(target=lambda: update(), daemon=True).start()
        return {"code": 0}

    # 定时更新代码精选板块
    def run_pending():
        # 更新今日代码精选板块
@@ -60,6 +84,8 @@
        codes |= set([x.decode() for x in codes_sz])
        day = tool.get_now_date_str()
        schedule.every().day.at("08:05:00").do(lambda: KPLCodeJXBlocksManager(day, codes).start_download_blocks())
        schedule.every().day.at("08:10:00").do(lambda: update_leading_limit_up_datas())

        while True:
            try:
                schedule.run_pending()