新题材修改/取消回踩不够拉黑

Administrator

2025-03-06 3ff0120707ada32fb25012e1d0e8bc9a5c3df07c

新题材修改/取消回踩不够拉黑

 code_attribute/first_target_code_data_processor.py

@@ -150,10 +150,10 @@
                        l2_trade_util.forbidden_trade(code, "昨日炸板")
                        continue

                    if code_nature_analyse.is_continue_limit_up_not_enough_fall_dwon(code, volumes_data):
                        # 判断是否太高
                        l2_trade_util.forbidden_trade(code, "回踩不够")
                        continue
                    # if code_nature_analyse.is_continue_limit_up_not_enough_fall_dwon(code, volumes_data):
                    #     # 判断是否太高
                    #     l2_trade_util.forbidden_trade(code, "回踩不够")
                    #     continue
                    try:
                        if not __is_normal_in_5d(code):
                            l2_trade_util.forbidden_trade(code, "最近5天有ST/非正常状态")

 servers/data_server.py

@@ -596,11 +596,11 @@
            # 涨停数据
            fdatas = {"limit_up_list": codes_info}
            # 辨识度票
            fdatas["speical_codes"] =  [(x, gpcode_manager.get_code_name(x)) for x in special_codes]
            fdatas["speical_codes"] = [(x, gpcode_manager.get_code_name(x)) for x in special_codes]
            forbidden_refer_codes = KPLPlateForbiddenManager().get_watch_high_codes_by_block(plate)
            if forbidden_refer_codes is None:
                forbidden_refer_codes = set()
            fdatas["forbidden_refer_codes"]= [(x, gpcode_manager.get_code_name(x)) for x in forbidden_refer_codes]
            fdatas["forbidden_refer_codes"] = [(x, gpcode_manager.get_code_name(x)) for x in forbidden_refer_codes]
            response_data = json.dumps({"code": 0, "data": fdatas})
        elif url.path == "/kpl/get_open_limit_up_count_rank":
            # 获取炸板次数排行
@@ -1090,14 +1090,16 @@

                    try:
                        records = KPLLimitUpDataRecordManager.total_datas

                        # 计算今日新增的题材概念
                        block_codes = {}
                        for x in records:
                            b = kpl_util.filter_block(x[2])
                            if b not in block_codes:
                                block_codes[b] = set()
                            block_codes[b].add(x[3])
                            bs = {kpl_util.filter_block(x[2])}
                            if x[6]:
                                bs |= set(x[6].split("、"))
                            for b in bs:
                                if b not in block_codes:
                                    block_codes[b] = set()
                                block_codes[b].add(x[3])
                        reasons = set(block_codes.keys())
                        reasons -= constant.KPL_INVALID_BLOCKS
                        reasons -= LimitUpCodesBlockRecordManager().get_total_before_blocks()
@@ -1107,7 +1109,6 @@
                                    LimitUpCodesBlockRecordManager().add_new_blocks(c, r)
                    except:
                        pass

                    self.__kplDataManager.save_data(type_, result_list_)
            except Exception as e:
                logger_debug.exception(e)

 trade/current_price_process_manager.py

@@ -69,7 +69,7 @@
    # 想买单
    if gpcode_manager.WantBuyCodesManager().is_in_cache(code):
        return 0
    # 隔夜单拍一
    # 隔夜单排一
    if gpcode_manager.BuyOpenLimitUpCodeManager().is_in_cache(code):
        return 0