采购异常处理工作流 — PO延误/取消/变更的Tag驱动自动处置与升级机制

"""
采购异常处理工作流
功能：异常类型识别 / Tag生成 / 自动处置 / 升级规则 / 处置日志
"""
from dataclasses import dataclass, field
from datetime import datetime
import warnings
warnings.filterwarnings('ignore')


EXCEPTION_HANDLERS = {
    "delay_minor":    {"auto_action": "system_reminder", "escalate": False},
    "delay_major":    {"auto_action": "notify_procurement+find_backup", "escalate": True},
    "cancelled":      {"auto_action": "emergency_supplier_search", "escalate": True},
    "qty_significant": {"auto_action": "recalculate_safety_stock", "escalate": True},
    "quality_reject": {"auto_action": "return+rework_notice", "escalate": True},
}


@dataclass
class POException:
    po_id: str
    supplier_id: str
    sku_id: str
    exception_type: str
    severity: str           # MINOR / MAJOR / CRITICAL
    details: dict = field(default_factory=dict)
    detected_at: datetime = field(default_factory=datetime.now)
    tags: dict = field(default_factory=dict)
    actions_taken: list = field(default_factory=list)


def handle_po_exception(exception: POException) -> dict:
    """处理采购异常"""
    handler = EXCEPTION_HANDLERS.get(exception.exception_type, {})

    # 生成Tags
    exception.tags = {
        f"po.{exception.exception_type}": True,
        "po.exception_severity": exception.severity,
        "po.exception_requires_action": exception.severity != "MINOR",
    }

    # 执行自动Actions
    auto_action = handler.get("auto_action", "log_and_monitor")
    exception.actions_taken.append({
        "action": auto_action,
        "timestamp": datetime.now().strftime("%H:%M:%S"),
        "automated": True,
    })

    # 升级决策
    should_escalate = handler.get("escalate", False) and exception.severity in ["MAJOR", "CRITICAL"]
    if should_escalate:
        exception.actions_taken.append({
            "action": "escalate_to_manager",
            "notification": f"PO异常升级: [{exception.po_id}] {exception.exception_type}",
            "timestamp": datetime.now().strftime("%H:%M:%S"),
            "automated": True,
        })