1.引入有意购买列表进入次数逻辑

admin

2025-05-29 319b108827e42caf4c368331cf62af1af17332b3

1.引入有意购买列表进入次数逻辑

 strategy/basic_methods.py

@@ -210,7 +210,7 @@

# 充分交易量公式 用于计算日内涨幅段理论的安全交易量值
def sufficient_volume(current_volume, yesterday_volume, today_growth):
    if today_growth > 0:
    if today_growth > 0 and round(current_volume / yesterday_volume / 100, 2) >= 0.01:
        if current_volume > yesterday_volume * 0.5 * today_growth:
            return True
        else:
@@ -259,3 +259,9 @@
    else:
        buying_ratio = 0.01
    return buying_ratio


# 统计有意买股票出现次数函数
def count_willing_buy_times(sec_name):
    willing_buy_times = data_cache.willing_buy_list.count(sec_name)
    return willing_buy_times

 strategy/buying_strategy.py

@@ -313,9 +313,7 @@
                                    intersection_plate = bought_plate_set.intersection(limit_up_plate_included)
                                    if len(intersection_plate) > 0:
                                        logger_info(f"重复相交概念==={intersection_plate}")
                                    # 调用充分交易量函数
                                    sufficient_volume = basic_methods.sufficient_volume(current_volume, k_line_data[0]['volume'], today_growth)
                                    logger_info(f"【{k_line_data[0]['sec_name']}】当日当时量是否相对涨幅充足？===【{sufficient_volume}】 ！当时与昨日成交率占比:{round(current_volume/k_line_data[0]['volume']/100, 2)}%，当日当时总成交量：{round(current_volume / 10000, 2)}万，昨日的总成交量{round(k_line_data[0]['volume'] / 10000, 2)}万，当日当时涨幅：{today_growth}%。")

                                    logger_info(f"【有概念】(涨停列表中包含自身概念 且 不是唯一包含概念不可用) ！最新价: {current_price}，，当日当时涨幅：{today_growth}%。")
                                    # 有概念有强度视界
                                    if strength_list_have_it is True:
@@ -350,6 +348,10 @@
                                        if k_line_data[0]['attribute'] in data_cache.limit_down_type:
                                            logger_info(f"【不利】昨日跌停！不买！！")
                                            return
                                        # 调用充分交易量函数
                                        sufficient_volume = basic_methods.sufficient_volume(current_volume, k_line_data[0]['volume'], today_growth)
                                        logger_info(
                                            f"【{k_line_data[0]['sec_name']}】当日当时量是否相对涨幅充足？===【{sufficient_volume}】 ！当时与昨日成交率占比:{round(current_volume / k_line_data[0]['volume'] / 100, 2)}%，当日当时总成交量：{round(current_volume / 10000, 2)}万，昨日的总成交量{round(k_line_data[0]['volume'] / 10000, 2)}万，当日当时涨幅：{today_growth}%。")
                                        # elif k_line_data[0]['attribute'] == 'up_down' and k_line_data[0]['today_volume_shape'] == 'increases_down':
                                        #     logger_info(f"【不利】昨日高开低走 且 放量下跌，不买！！")
                                        if k_line_data[0]['attribute'] == 'down_down' and k_line_data[0]['today_volume_shape'] == 'increases_down':
@@ -384,11 +386,12 @@
                                            logger_info(
                                                f"【不利】当日成交量小于昨日成交量的{ratios}倍！不买！！公司名称：{k_line_data[0]['sec_name']}，当日当时总成交量:{current_volume},最新价: {current_price}")
                                            return
                                        willing_buy_times = basic_methods.count_willing_buy_times(k_line_data[0]['sec_name'])
                                        if data_cache.have_plate_buy_times >= 1 and willing_buy_times < 2:
                                            logger_info(
                                                f"【不利】有概念买入已经 1 次,且进入有意购买列表次数<2，不买了！！公司名称：{k_line_data[0]['sec_name']}，")
                                        data_cache.willing_buy_list.append(k_line_data[0]['sec_name'])
                                        logger_info(f"当前有意购买：{k_line_data[0]['sec_name']}，有意购买列表：{data_cache.willing_buy_list}")
                                        if data_cache.have_plate_buy_times >= 1 and k_line_data[0]['sec_name'] not in data_cache.willing_buy_list:
                                            logger_info(
                                                f"【不利】有概念买入已经 1 次,且未曾进入过有意购买列表！不买了！！公司名称：{k_line_data[0]['sec_name']}，")
                                        if len(intersection_plate) > 0:
                                            logger_info(
                                                f"【不利】同概念只买一次，不买了，公司名称：{k_line_data[0]['sec_name']}，重复相交概念==={intersection_plate}")
@@ -472,6 +475,10 @@
                                            if k_line_data[0]['attribute'] in data_cache.limit_down_type:
                                                logger_info(f"【不利】昨日跌停！不买！！")
                                                return
                                            # 调用充分交易量函数
                                            sufficient_volume = basic_methods.sufficient_volume(current_volume,k_line_data[0]['volume'],today_growth)
                                            logger_info(
                                                f"【{k_line_data[0]['sec_name']}】当日当时量是否相对涨幅充足？===【{sufficient_volume}】 ！当时与昨日成交率占比:{round(current_volume / k_line_data[0]['volume'] / 100, 2)}%，当日当时总成交量：{round(current_volume / 10000, 2)}万，昨日的总成交量{round(k_line_data[0]['volume'] / 10000, 2)}万，当日当时涨幅：{today_growth}%。")
                                            if k_line_data[0]['attribute'] == 'up_down' and k_line_data[0]['today_volume_shape'] == 'increases_down':
                                                logger_info(f"【不利】昨日高开低走 且 放量下跌，不买！！")
                                                return
@@ -551,12 +558,6 @@
                                        intersection_plate = bought_plate_set.intersection(strength_plate_set)
                                        if len(intersection_plate) > 0:
                                            logger_info(f"重复相交强度==={intersection_plate}")
                                        # 调用充分交易量函数
                                        sufficient_volume = basic_methods.sufficient_volume(current_volume,
                                                                                            k_line_data[0]['volume'],
                                                                                            today_growth)
                                        logger_info(
                                            f"【{k_line_data[0]['sec_name']}】当日当时量是否相对涨幅充足？===【{sufficient_volume}】 ！当时与昨日成交率占比:{round(current_volume/k_line_data[0]['volume']/100, 2)}%，当日当时总成交量：{round(current_volume / 10000, 2)}万，昨日的总成交量{round(k_line_data[0]['volume'] / 10000, 2)}万，当日当时涨幅：{today_growth}%。")
                                        if last_volume_to_growth_ratio < 1:
                                            logger_info(
                                                f"【有强度 有小量换大涨幅】瞬时量幅比< 1 ！瞬时量幅比：{round(last_volume_to_growth_ratio, 2)}%，最新价: {current_price}，瞬时涨幅：{round(tick_growth, 2)}%，当日当时涨幅：{today_growth}%,当前时间：{current_created_at}。")
@@ -583,6 +584,10 @@
                                                if k_line_data[0]['attribute'] in data_cache.limit_down_type:
                                                    logger_info(f"【不利】昨日跌停！不买！！")
                                                    return
                                                # 调用充分交易量函数
                                                sufficient_volume = basic_methods.sufficient_volume(current_volume, k_line_data[0]['volume'], today_growth)
                                                logger_info(
                                                    f"【{k_line_data[0]['sec_name']}】当日当时量是否相对涨幅充足？===【{sufficient_volume}】 ！当时与昨日成交率占比:{round(current_volume / k_line_data[0]['volume'] / 100, 2)}%，当日当时总成交量：{round(current_volume / 10000, 2)}万，昨日的总成交量{round(k_line_data[0]['volume'] / 10000, 2)}万，当日当时涨幅：{today_growth}%。")
                                                # if k_line_data[0]['attribute'] == 'up_down' and k_line_data[0]['today_volume_shape'] == 'increases_down':
                                                #     logger_info(
                                                #         f"【不利】昨日高开低走 且 放量下跌，不买！！")