dtm_python/app/services/insights_generator_service.py

"""
策略建议生成模块
"""


def generate_stage_insights(stage_statistics, current_stage, is_complete):
    """根据各生命周期阶段的统计数据生成现状分析和策略建议"""
    insights = {
        'current_status': [],
        'recommendations': [],
        'stage_analysis': {}
    }
    
    # 分析各阶段表现
    for stage_name, stats in stage_statistics.items():
        stage_insight = {
            'stage': stage_name,
            'performance': '',
            'issues': [],
            'opportunities': []
        }
        
        duration = stats.get('durationDays', 0)
        avg_revenue = stats.get('avgDailyRevenue', 0)
        revenue_pct = stats.get('revenuePercentage', 0)
        
        # 引入期分析
        if '引入期' in stage_name:
            if duration < 30:
                stage_insight['issues'].append('引入期时间过短，市场认知度可能不足')
                stage_insight['opportunities'].append('加大初期市场推广投入，延长引入期以积累用户')
            elif duration > 90:
                stage_insight['issues'].append('引入期过长，市场接受度较慢')
                stage_insight['opportunities'].append('优化产品定位或价格策略，加速进入成长期')
            else:
                stage_insight['performance'] = '引入期表现正常'
            
            if avg_revenue < 100:
                stage_insight['opportunities'].append('初期销售较弱，建议通过试用活动或小规模促销提升认知')
        
        # 成长期分析
        elif '成长期' in stage_name:
            if duration < 45:
                stage_insight['issues'].append('成长期时间较短，增长势头可能不够强劲')
                stage_insight['opportunities'].append('加大广告投放和渠道拓展，延长成长期红利')
            elif duration > 120:
                stage_insight['performance'] = '成长期持续时间长，市场表现优秀'
            
            if revenue_pct > 40:
                stage_insight['performance'] = '成长期贡献超过40%销售额，是核心增长阶段'
                stage_insight['opportunities'].append('在成长期高峰时扩大供应链备货，避免断货')
            else:
                stage_insight['issues'].append('成长期销售贡献不足，增长动力需要加强')
                stage_insight['opportunities'].append('优化营销策略，提升成长期转化效率')
        
        # 成熟期分析
        elif '成熟期' in stage_name:
            if duration > 150:
                stage_insight['performance'] = '成熟期持续时间长，产品生命力强'
                stage_insight['opportunities'].append('在成熟期中后段推出产品升级或变种，延续生命周期')
            elif duration < 60:
                stage_insight['issues'].append('成熟期较短，产品稳定性不足')
            
            if revenue_pct > 35:
                stage_insight['performance'] = '成熟期贡献稳定，是主要利润来源'
            
            stage_insight['opportunities'].append('在成熟期维持稳定供应，优化成本结构提升利润率')
        
        # 衰退期分析
        elif '衰退期' in stage_name:
            if duration < 30:
                stage_insight['issues'].append('衰退期过短，可能需要及时清库存')
                stage_insight['opportunities'].append('快速推出促销清仓，避免库存积压')
            
            decline_rate = 100 - revenue_pct
            if decline_rate > 70:
                stage_insight['issues'].append('衰退迅速，需要谨慎评估后续产品规划')
                stage_insight['opportunities'].append('分析衰退原因，为新品开发提供借鉴')
            
            stage_insight['opportunities'].append('在衰退期尾声准备替代产品或新品上市')
        
        insights['stage_analysis'][stage_name] = stage_insight
    
    # 基于当前阶段的综合建议
    if current_stage == '引入期':
        insights['current_status'].append('当前处于引入期，需要快速建立市场认知')
        insights['recommendations'].extend([
            '建议投入适度的市场推广费用，重点在种子用户培养',
            '可以通过限时折扣、试用装等方式降低用户尝试门槛',
            '密切监控用户反馈，及时优化产品和服务'
        ])
    
    elif current_stage == '成长期':
        insights['current_status'].append('当前处于成长期，是快速扩张的最佳时机')
        insights['recommendations'].extend([
            '加大广告投放力度，扩大市场覆盖面',
            '优化供应链和库存管理，确保充足货源',
            '考虑推出组合套餐或会员计划，提升客单价和复购率',
            '此阶段是建立品牌忠诚度的关键期，注重用户体验'
        ])
    
    elif current_stage == '成熟期':
        insights['current_status'].append('当前处于成熟期，应注重稳定和利润优化')
        insights['recommendations'].extend([
            '维持稳定的市场投入，避免大幅波动',
            '优化运营成本，提升利润率',
            '考虑产品升级或推出衍生产品，延长生命周期',
            '关注竞品动态，防止市场份额流失'
        ])
    
    elif current_stage == '衰退期':
        insights['current_status'].append('当前处于衰退期，需要制定退出或转型策略')
        insights['recommendations'].extend([
            '合理控制库存，避免积压',
            '可推出清仓促销活动，加速库存周转',
            '分析衰退原因，为新产品开发提供参考',
            '准备替代产品或新品上市，平滑过渡'
        ])
    
    # 不完整生命周期的额外建议
    if not is_complete:
        insights['current_status'].append('该SKU生命周期尚未完整，建议持续观察')
        insights['recommendations'].append('继续跟踪数据，待生命周期更完整后再做长期决策')
    
    return insights