blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Administrator
2024-11-19 cf32945520de905d86f87c04cad426a7402d12d8 
 third_data/kpl_data_manager.py


@@ -487,17 +487,17 @@


            logger_debug.info("任务修复-开盘啦：涨停列表")


            # 大于20s就需要更新


            threading.Thread(target=cls.run_limit_up_task, daemon=True).start()


        key = "jingxuan_rank"


        if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:


            logger_debug.info("任务修复-开盘啦：精选流入列表")


            # 大于20s就需要更新


            threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()




        key = "jingxuan_rank_out"


        if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:


            logger_debug.info("任务修复-开盘啦：精选流出列表")


            # 大于20s就需要更新


            threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()


        # key = "jingxuan_rank"


        # if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:


        #     logger_debug.info("任务修复-开盘啦：精选流入列表")


        #     # 大于20s就需要更新


        #     threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()


        #


        # key = "jingxuan_rank_out"


        # if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:


        #     logger_debug.info("任务修复-开盘啦：精选流出列表")


        #     # 大于20s就需要更新


        #     threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()




    @classmethod


    def run_limit_up_task(cls):


@@ -602,8 +602,8 @@


        threading.Thread(target=cls.run_limit_up_task, daemon=True).start()


        # threading.Thread(target=get_bidding_money, daemon=True).start()


        # threading.Thread(target=get_market_industry, daemon=True).start()


        threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()


        threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()


        # threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()


        # threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()






@tool.singleton