供应链采购策略师

import numpy as np
from dataclasses import dataclass
from typing import Optional

@dataclass
class InventoryParameters:
    annual_demand: float       # 年需求量
    order_cost: float          # 单次订货成本
    holding_cost_rate: float   # 库存持有成本率（占单价百分比）
    unit_price: float          # 单价
    lead_time_days: int        # 采购提前期（天）
    demand_std_dev: float      # 需求标准差
    service_level: float       # 服务水平（如 0.95 代表 95%）

class InventoryManager:
    def __init__(self, params: InventoryParameters):
        self.params = params

    def calculate_eoq(self) -> float:
        """
        计算经济订货量（EOQ）
        EOQ = sqrt(2 * D * S / H)
        """
        d = self.params.annual_demand
        s = self.params.order_cost
        h = self.params.unit_price * self.params.holding_cost_rate
        eoq = np.sqrt(2 * d * s / h)
        return round(eoq)

    def calculate_safety_stock(self) -> float:
        """
        计算安全库存
        SS = Z * σ_dLT
        Z: 服务水平对应的 Z 值
        σ_dLT: 提前期内需求的标准差
        """
        from scipy.stats import norm
        z = norm.ppf(self.params.service_level)
        lead_time_factor = np.sqrt(self.params.lead_time_days / 365)
        sigma_dlt = self.params.demand_std_dev * lead_time_factor
        safety_stock = z * sigma_dlt
        return round(safety_stock)

    def calculate_reorder_point(self) -> float:
        """
        计算再订货点（ROP）
        ROP = 日均需求 × 提前期 + 安全库存
        """
        daily_demand = self.params.annual_demand / 365
        rop = daily_demand * self.params.lead_time_days + self.calculate_safety_stock()
        return round(rop)

    def analyze_dead_stock(self, inventory_df):
        """
        呆滞物料分析与处理建议
        """
        dead_stock = inventory_df[
            (inventory_df['last_movement_days'] > 180) |
            (inventory_df['turnover_rate'] < 1.0)
        ]

        recommendations = []
        for _, item in dead_stock.iterrows():
            if item['last_movement_days'] > 365:
                action = '建议报废或折价处理'
                urgency = '高'
            elif item['last_movement_days'] > 270:
                action = '联系供应商退货或调换'
                urgency = '中'
            else:
                action = '降价促销或内部调拨消化'
                urgency = '低'

            recommendations.append({
                'sku': item['sku'],
                'quantity': item['quantity'],
                'value': item['quantity'] * item['unit_price'],       # 库存金额
                'idle_days': item['last_movement_days'],              # 呆滞天数
                'action': action,                                      # 处理建议
                'urgency': urgency                                     # 紧急程度
            })

        return recommendations

    def inventory_strategy_report(self):
        """
        生成库存策略报告
        """
        eoq = self.calculate_eoq()
        safety_stock = self.calculate_safety_stock()
        rop = self.calculate_reorder_point()
        annual_orders = round(self.params.annual_demand / eoq)
        total_cost = (
            self.params.annual_demand * self.params.unit_price +                    # 采购成本
            annual_orders * self.params.order_cost +                                 # 订货成本
            (eoq / 2 + safety_stock) * self.params.unit_price *
            self.params.holding_cost_rate                                             # 持有成本
        )

        return {
            'eoq': eoq,                           # 经济订货量
            'safety_stock': safety_stock,          # 安全库存
            'reorder_point': rop,                  # 再订货点
            'annual_orders': annual_orders,        # 年订货次数
            'total_annual_cost': round(total_cost, 2),  # 年度总成本
            'avg_inventory': round(eoq / 2 + safety_stock),  # 平均库存量
            'inventory_turns': round(self.params.annual_demand / (eoq / 2 + safety_stock), 1)  # 库存周转次数
        }

class SupplyChainDigitalization:
    """
    供应链数字化成熟度评估与路径规划
    """

    # 国内主流 ERP 系统对比
    ERP_SYSTEMS = {
        'SAP': {
            'target': '大型集团企业/外资企业',
            'modules': ['MM（物料管理）', 'PP（生产计划）', 'SD（销售分销）', 'WM（仓储管理）'],
            'cost': '百万级起步',
            'implementation': '6-18 个月',
            'strength': '功能全面、行业最佳实践丰富',
            'weakness': '实施成本高、定制化复杂'
        },
        '用友U8+/YonBIP': {
            'target': '中大型民营企业',
            'modules': ['采购管理', '库存管理', '供应链协同', '智能制造'],
            'cost': '十万至百万级',
            'implementation': '3-9 个月',
            'strength': '本土化程度高、税务对接好',
            'weakness': '大型项目经验偏少'
        },
        '金蝶云星空/星瀚': {
            'target': '中型成长企业',
            'modules': ['采购管理', '仓储物流', '供应链协同', '质量管理'],
            'cost': '十万至百万级',
            'implementation': '2-6 个月',
            'strength': 'SaaS 部署快、移动端体验好',
            'weakness': '深度定制能力有限'
        }
    }

    # SRM 采购管理系统
    SRM_PLATFORMS = {
        '甄云科技': '全流程数字化采购，适合制造业',
        '企企通': '供应商协同平台，侧重中小企业',
        '筑集采': '建筑行业专业采购平台',
        '用友采购云': '与用友 ERP 深度集成',
        'SAP Ariba': '全球化采购网络，适合跨国企业'
    }

    def assess_digital_maturity(self, company_profile: dict) -> dict:
        """
        评估企业供应链数字化成熟度（1-5 级）
        """
        dimensions = {
            '采购数字化': self._assess_procurement(company_profile),
            '库存可视化': self._assess_inventory(company_profile),
            '供应商协同': self._assess_supplier_collab(company_profile),
            '物流追踪': self._assess_logistics(company_profile),
            '数据分析': self._assess_analytics(company_profile)
        }

        avg_score = sum(dimensions.values()) / len(dimensions)

        roadmap = []
        if avg_score < 2:
            roadmap = ['先上 ERP 基础模块', '建立主数据标准', '推行电子审批流程']
        elif avg_score < 3:
            roadmap = ['部署 SRM 系统', '打通 ERP 与 SRM 数据', '建立供应商门户']
        elif avg_score < 4:
            roadmap = ['供应链可视化大屏', '智能补货预警', '供应商协同平台']
        else:
            roadmap = ['AI 需求预测', '供应链数字孪生', '自动化采购决策']

        return {
            'dimensions': dimensions,
            'overall_score': round(avg_score, 1),
            'maturity_level': self._get_level_name(avg_score),
            'roadmap': roadmap
        }

    def _get_level_name(self, score):
        if score < 1.5: return 'L1-手工阶段'
        elif score < 2.5: return 'L2-信息化阶段'
        elif score < 3.5: return 'L3-数字化阶段'
        elif score < 4.5: return 'L4-智能化阶段'
        else: return 'L5-自治化阶段'

## 降本策略矩阵

### 短期降本（0-3 个月见效）
- **商务谈判**：利用竞争报价压价，争取账期优化（月结 30 → 月结 60）
- **集中采购**：合并同类需求，利用批量效应降低单价（通常可降 5-15%）
- **付款条件优化**：提前付款换折扣（2/10 net 30），或延长账期改善现金流

### 中期降本（3-12 个月见效）
- **VA/VE 价值工程**：分析产品功能与成本，在不影响功能的前提下优化设计
- **材料替代**：寻找同等性能的低成本替代材料（如工程塑料替代金属件）
- **工艺优化**：与供应商联合改进生产工艺，提升良率、降低加工成本
- **供应商整合**：减少供应商数量，集中份额给优质供应商换取更好价格

### 长期降本（12 个月以上见效）
- **垂直整合**：关键零部件自制 vs. 外购决策（Make or Buy）
- **供应链重构**：产能转移到低成本区域，优化物流网络
- **联合开发**：与供应商共同开发新产品/新工艺，分享降本收益
- **数字化采购**：通过电子化采购流程降低交易成本和人工成本

class SupplyChainRiskManager:
    """
    供应链风险识别、评估与应对
    """

    RISK_CATEGORIES = {
        '供应中断风险': {
            'indicators': ['供应商集中度', '单一来源物料占比', '供应商财务健康度'],
            'mitigation': ['多源采购策略', '安全库存储备', '备选供应商开发']
        },
        '质量风险': {
            'indicators': ['来料不良率趋势', '客户投诉率', '质量体系认证状态'],
            'mitigation': ['加强进货检验', '供应商质量改进计划', '质量问题追溯体系']
        },
        '价格波动风险': {
            'indicators': ['大宗商品价格指数', '汇率波动幅度', '供应商涨价预警'],
            'mitigation': ['长期锁价合同', '期货/期权对冲', '替代材料储备']
        },
        '地缘政治风险': {
            'indicators': ['贸易政策变化', '关税调整', '出口管制清单'],
            'mitigation': ['供应链多元化布局', '近岸/友岸采购', '国产替代方案']
        },
        '物流风险': {
            'indicators': ['运力紧张指数', '港口拥堵程度', '极端天气预警'],
            'mitigation': ['多式联运方案', '提前备货', '区域分仓策略']
        }
    }

    def risk_assessment(self, supplier_data: dict) -> dict:
        """
        供应商风险综合评估
        """
        risk_scores = {}

        # 供应集中度风险
        if supplier_data.get('spend_share', 0) > 0.3:
            risk_scores['concentration_risk'] = '高'
        elif supplier_data.get('spend_share', 0) > 0.15:
            risk_scores['concentration_risk'] = '中'
        else:
            risk_scores['concentration_risk'] = '低'

        # 单一来源风险
        if supplier_data.get('alternative_suppliers', 0) == 0:
            risk_scores['single_source_risk'] = '高'
        elif supplier_data.get('alternative_suppliers', 0) == 1:
            risk_scores['single_source_risk'] = '中'
        else:
            risk_scores['single_source_risk'] = '低'

        # 财务健康度风险
        credit_score = supplier_data.get('credit_score', 50)
        if credit_score < 40:
            risk_scores['financial_risk'] = '高'
        elif credit_score < 60:
            risk_scores['financial_risk'] = '中'
        else:
            risk_scores['financial_risk'] = '低'

        # 综合风险等级
        high_count = list(risk_scores.values()).count('高')
        if high_count >= 2:
            overall = '红色预警 - 需要立即制定应急方案'
        elif high_count == 1:
            overall = '橙色关注 - 需要制定改进计划'
        else:
            overall = '绿色正常 - 持续监控即可'

        return {
            'detail_scores': risk_scores,
            'overall_risk': overall,
            'recommended_actions': self._get_actions(risk_scores)
        }

    def _get_actions(self, scores):
        actions = []
        if scores.get('concentration_risk') == '高':
            actions.append('立即启动备选供应商开发，目标 3 个月内完成认证')
        if scores.get('single_source_risk') == '高':
            actions.append('单一来源物料必须在 6 个月内开发至少 1 家替代供应商')
        if scores.get('financial_risk') == '高':
            actions.append('缩短付款账期至预付或货到付款，增加到货检验频次')
        return actions

# 梳理现有供应商清单和采购支出分析
# 评估供应链风险热点和瓶颈环节
# 盘点库存健康度和呆滞物料

# [期间] 供应链管理报告

## 摘要

### 核心运营指标
**采购总额**：¥[金额]（同比 [+/-]%，预算偏差 [+/-]%）
**供应商数量**：[数量]（新增 [数量]，淘汰 [数量]）
**来料合格率**：[%]（目标 [%]，趋势 [↑/↓]）
**交付准时率**：[%]（目标 [%]，趋势 [↑/↓]）

### 库存健康度
**库存总额**：¥[金额]（周转天数 [天]，目标 [天]）
**呆滞物料**：¥[金额]（占比 [%]，处理进度 [%]）
**缺料预警**：[项数]（影响生产订单 [项数]）

### 降本成果
**累计降本金额**：¥[金额]（目标完成率 [%]）
**降本项目数**：[已完成/进行中/计划中]
**主要降本手段**：[商务谈判/材料替代/工艺优化/集中采购]

### 风险预警
**高风险供应商**：[数量]（附清单和应对方案）
**原材料价格趋势**：[主要物料价格走势和对冲策略]
**供应中断事件**：[事件数]（影响评估和处理结果）

## 待办事项
1. **紧急**：[行动、影响和时间线]
2. **短期**：[30 天内的改进举措]
3. **战略**：[长期供应链优化方向]

---
**供应链采购策略师**：[姓名]
**报告日期**：[日期]
**覆盖期间**：[期间]
**下次评审**：[计划评审日期]