新题材bug修复

Administrator

2025-04-11 f87fbed04bcdc8ae928dc3ec2c09922fd340204d

新题材bug修复

 servers/data_server.py

@@ -1129,6 +1129,7 @@

                    try:
                        # 新题材
                        new_block_processor.process_limit_up_list({x[0]: x[5] for x in result_list_})
                        new_block_codes = new_block_processor.screen_new_blocks_with_limit_up_datas([(x[0], x[5]) for x in result_list_])
                        if new_block_codes:
                            # 统计板块的代码
@@ -1149,8 +1150,8 @@
                                # 需要获取板块下的代码
                                self.__new_blocks_codes_request_thread_pool.submit(
                                    lambda: request_new_blocks_codes(update_new_block_plates, new_block_codes.keys()))
                    except:
                        pass
                    except Exception as e:
                        logger_debug.exception(e)
                    self.__kplDataManager.save_data(type_, result_list_)
            except Exception as e:
                logger_debug.exception(e)

 trade/buy_radical/new_block_processor.py

@@ -124,9 +124,21 @@
    return True


def process_limit_up_list(code_block_dict):
    # 删除变了的原因
    for code in code_block_dict:
        if kpl_data_constant.limit_up_code_new_block_dict.get(code, code_block_dict.get(code)) != code_block_dict.get(
                code):
            # 删除变之前的原因
            if code in kpl_data_constant.limit_up_code_new_block_dict:
                kpl_data_constant.limit_up_code_new_block_dict.pop(code)
                __sync_data_to_special_codes(code)


def process_new_block_by_limit_up_list(code, block):
    """
    根据涨停列表处理新题材
    @param code_block_dict: 代码涨停原因字典
    @param code:
    @param block:
    @return:
@@ -191,7 +203,8 @@
        trade_record_log_util.add_common_msg(code, "新题材移黑", f"{blocks}")
    # 新板块
    if constant.TEST:
        print(code,kpl_data_constant.limit_up_code_new_block_dict.get(code),  kpl_data_constant.limit_up_component_code_new_blocks_dict.get(code))
        print(code, kpl_data_constant.limit_up_code_new_block_dict.get(code),
              kpl_data_constant.limit_up_component_code_new_blocks_dict.get(code))
    BlockSpecialCodesManager().set_code_blocks_for_temp(code, blocks)


@@ -207,4 +220,4 @@
        if k_format and k_format[1][0]:
            # 突破形态
            return False
    return True
    return True