bug修复

Administrator

2024-11-19 71164e33c8a579e551ca63e8c026d81059302a2c

bug修复

 third_data/code_plate_key_manager.py

@@ -361,18 +361,23 @@
        #     blocks.add(data[1])
        # cls.__top_jx_blocks = blocks
        blocks = set()
        count = 0
        for data in datas:
            if data[1] in constant.KPL_INVALID_BLOCKS:
                continue
            if data[3] < 5e7:
                continue
            blocks.add(data[1])
            if len(blocks) >= 10:
            # 过滤出来为同一个板块就只算1个数量
            fb = BlockMapManager().filter_blocks({data[1]})
            if blocks & fb:
                continue
            blocks |= fb
            count += 1
            if count >= 10:
                break
            blocks.add(kpl_util.filter_block(data[1]))
        # 记录精选流出日志
        async_log_util.info(logger_kpl_jx_in, f"原数据：{datas[:20]} 板块：{blocks}")
        cls.__top_jx_blocks = BlockMapManager().filter_blocks(blocks)
        cls.__top_jx_blocks = blocks

    @classmethod
    def set_market_jingxuan_out_blocks(cls, datas):
@@ -381,6 +386,7 @@
        @param datas:
        @return:
        """
        count = 0
        blocks = set()
        for data in datas:
            if data[1] in constant.KPL_INVALID_BLOCKS:
@@ -388,13 +394,17 @@
            if data[3] > -5e7:
                # 过滤5千万以上的
                break
            blocks.add(data[1])
            if len(blocks) >= 10:
            # 过滤出来为同一个板块就只算1个数量
            fb = BlockMapManager().filter_blocks({data[1]})
            if blocks & fb:
                continue
            blocks |= fb
            count += 1
            if count >= 10:
                break
            blocks.add(kpl_util.filter_block(data[1]))
        # 记录精选流出日志
        async_log_util.info(logger_kpl_jx_out, f"原数据：{datas[:10]} 板块：{blocks}")
        cls.__top_jx_out_blocks = BlockMapManager().filter_blocks(blocks)
        cls.__top_jx_out_blocks = blocks

    @classmethod
    def get_top_market_jingxuan_blocks(cls):