扫入策略调整

Administrator

2025-01-16 e0ad6d1a69e5976c7c1968393c8c3f639f57c816

扫入策略调整

 code_attribute/first_target_code_data_processor.py

@@ -143,6 +143,9 @@
                        l2_trade_util.forbidden_trade(code, "6天内股价长得太高")
                        continue

                    if tool.is_ge_code(code) and float(limit_up_price) < 10:
                        l2_trade_util.forbidden_trade(code, "创业板股价10块内")

                    if len(k_format) > 14 and k_format[14]:
                        l2_trade_util.forbidden_trade(code, "昨日炸板")
                        continue

 third_data/kpl_limit_up_data_manager.py

@@ -232,8 +232,8 @@
        block_codes_dict = {}
        for day in self.__block_day_datas:
            for b in self.__block_day_datas[day]:
                total_limit_up_count = self.__block_day_datas[day][b][0] + self.__block_day_datas[day][b][1]
                if total_limit_up_count < 3:
                finally_limit_up_count = self.__block_day_datas[day][b][0]
                if finally_limit_up_count < 3:
                    continue
                # 板块涨停个数
                if b not in block_count_dict:
@@ -257,10 +257,10 @@
                if day not in self.__block_day_datas:
                    continue
                if b in self.__block_day_datas[day]:
                    total_limit_up_count = self.__block_day_datas[day][b][0] + self.__block_day_datas[day][b][1]
                    finally_limit_up_count = self.__block_day_datas[day][b][0]
                else:
                    total_limit_up_count = 0
                if b in self.__block_day_datas[day] and total_limit_up_count >= 3:
                    finally_limit_up_count = 0
                if b in self.__block_day_datas[day] and finally_limit_up_count >= 3:
                    # 板块代码数量>=3个
                    temp.append(day)
                else:

 trade/buy_radical/radical_buy_data_manager.py

@@ -797,6 +797,9 @@
            #             return False, f"开1数量：{count}，前排代码未下过单：{pre_code}"
            #         return True, f"开1数量：{count}，前排代码尚未成交：{history_before_codes_info[0]}"
            # return True, f"开1数量：{count}，前排代码不可买：{history_before_codes_info[0]}，历史前排-{history_before_codes_info}，开1代码-{open_limit_up_block_codes}"
        # 曾涨停有后排才能买
        if not cls.__is_have_back_codes(code, block):
            return False, f"【{block}】无后排"
        return True, f"开1数量：{count}，历史-{history_index + 1} 实时-{current_index + 1}， 前排代码-{current_before_codes_info},开1代码-{open_limit_up_block_codes}"

    @classmethod
@@ -849,6 +852,26 @@
        if code_ in BlockPlaceOrderRecordManager().get_codes() and code_ not in deal_codes:
            return True
        return False

    @classmethod
    def __is_have_back_codes(cls, code, block):
        """
        板块是否有后排代码
        @param code:
        @param block:
        @return:
        """
        codes = LimitUpDataConstant.get_history_limit_up_block_codes(block)
        has_back = False
        limit_up_timestamp = cls.__get_limit_up_timestamp(code)
        if codes:
            for c in codes:
                if c == code:
                    continue
                if cls.__get_limit_up_timestamp(c) > limit_up_timestamp:
                    has_back = True
                    break
        return has_back

    @classmethod
    def __is_radical_buy_with_block_up(cls, code, block, yesterday_limit_up_codes):
@@ -951,6 +974,8 @@
                deal_codes = RadicalBuyDealCodesManager().get_deal_codes()
                if pre_code in deal_codes:
                    return False, f"前排代码已成交：{pre_code}"
                if not cls.__is_have_back_codes(code, block):
                    return False, f"【{block}】无后排"
                return True, f"被顺位代码({pre_code}) 尚未成交"

                # pre_code不能买，才能买
@@ -982,6 +1007,8 @@
        else:
            # 代码为目标代码
            pass
        if not cls.__is_have_back_codes(code, block):
            return False, f"【{block}】无后排"
        return True, f"满足买入需求: 实时前排代码-{current_before_codes_info} 历史前排代码-{history_before_codes_info}"

    @classmethod
@@ -1138,7 +1165,7 @@
        if codes and len(codes) >= 5:
            return True, False
        else:
            codes = LimitUpDataConstant.get_history_limit_up_block_codes(code)
            codes = LimitUpDataConstant.get_history_limit_up_block_codes(block)
            if codes and len(codes) >= 3:
                # 10点之后净流入是正才能订阅
                in_money = RealTimeKplMarketData.get_jx_block_in_money(block)
@@ -1442,7 +1469,8 @@
        else:
            current_big_order_deal_money = current_big_order_deal_money_info[0]
    current_lack_money = max(0, int(current_threshold_money - current_big_order_deal_money))
    if for_buy:
    if for_buy and not tool.is_ge_code(code):
        # 要下单的且不是创业版的目标代码大单数量打8折
        total_lack_money = int(total_threshold_money * 0.8 - total_deal_money)
        if total_lack_money < 0:
            total_lack_money = 0