订单履约率与发货及时率 — 全链路订单从下单到签收的履约质量量化体系

"""
订单履约率与发货及时率全链路量化体系
基于《全链路管理》陈凤霞 + 行业最佳实践
完整履约漏斗 + 根因分解 + 风险预警
"""
import numpy as np
import pandas as pd
from typing import Dict, List, Optional
from dataclasses import dataclass
import warnings
warnings.filterwarnings('ignore')


@dataclass
class OrderRecord:
    """订单记录"""
    order_id: str
    sku_id: str
    platform: str
    order_time: str
    promised_dispatch_time: str    # 承诺发货时间
    actual_dispatch_time: Optional[str]  # 实际发货时间（None=未发货）
    promised_delivery_time: Optional[str]  # 承诺到达时间
    actual_delivery_time: Optional[str]
    has_stock: bool                # 下单时是否有库存
    delivery_success: bool         # 是否成功签收
    has_damage: bool               # 是否有破损
    has_complaint: bool            # 是否有投诉


class FulfillmentRateAnalyzer:
    """订单履约率分析引擎"""

    # 平台发货时效标准（小时）
    DISPATCH_STANDARDS = {
        'Amazon': 24,
        'Shopee': 48,
        'TikTok_Shop': 48,
        'Own_Store': 72,
    }

    def compute_fulfillment_funnel(self, orders: List[OrderRecord]) -> Dict:
        """计算完整履约漏斗"""
        n = len(orders)
        if n == 0:
            return {}

        # 各层次统计
        with_stock = sum(1 for o in orders if o.has_stock)
        dispatched_on_time = sum(1 for o in orders
                                  if o.has_stock and o.actual_dispatch_time is not None
                                  and o.actual_dispatch_time <= o.promised_dispatch_time)
        delivered_success = sum(1 for o in orders if o.delivery_success)
        no_issues = sum(1 for o in orders
                         if o.delivery_success and not o.has_damage and not o.has_complaint)

        return {
            'total_orders': n,
            'funnel': {
                '1_order_fill_rate': {