L2净流入订阅修改/买流入前几修改/创业板大单数量要求修改/将市场强度纳入策略

Administrator

2024-12-05 091c8c8eccb8d78390cd8f2b962ade31016fdd5b

 third_data/kpl_data_manager.py

@@ -499,6 +499,12 @@
        #     # 大于20s就需要更新
        #     threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()

        key = "market_strong"
        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_strong, daemon=True).start()

    @classmethod
    def run_limit_up_task(cls):
        # 关闭log
@@ -559,6 +565,23 @@
                time.sleep(3)

    @classmethod
    def run_market_strong(cls):
        """
        精选流出
        @return:
        """
        while True:
            try:
                if tool.is_trade_time() or True:
                    strong_value = kpl_api.getMarketStrong()
                    cls.__upload_data("market_strong", strong_value)
            except:
                pass
            finally:
                cls.__latest_update_time_dict["market_strong"] = time.time()
                time.sleep(3)

    @classmethod
    # 运行拉取任务
    def run_pull_task(cls):
        def get_bidding_money():
@@ -600,6 +623,7 @@
                    time.sleep(3)

        threading.Thread(target=cls.run_limit_up_task, daemon=True).start()
        threading.Thread(target=cls.run_market_strong, 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()