Tag驱动动态承运商选择引擎 — 基于实时标签的末程承运商智能匹配与成本优化

"""
Tag驱动动态承运商选择引擎
功能：多承运商评分 / 实时Tag影响调整 / 成本vs时效优化 / 自动切换触发
输入：订单Tags + 承运商实时状态Tags + SKU Tags
输出：最优承运商选择 + 评分明细 + 成本预估
"""
import numpy as np
from dataclasses import dataclass, field
from typing import Optional
import warnings
warnings.filterwarnings('ignore')


@dataclass
class CarrierProfile:
    carrier_id: str
    name: str
    service_types: list      # express / ground / freight / postal
    coverage_zones: list     # domestic / international / rural
    hazmat_capable: bool
    oversized_capable: bool
    base_cost: dict          # zone → cost
    transit_days: dict       # zone → days
    reliability_score: float
    # Real-time Tags
    delay_active: bool = False
    capacity_warning: bool = False
    current_surcharge: float = 0.0


@dataclass
class CarrierSelection:
    order_id: str
    selected_carrier: str
    carrier_name: str
    final_score: float
    time_score: float
    cost_score: float
    reliability_score: float
    estimated_cost: float
    estimated_transit_days: float
    exclusion_reasons: dict = field(default_factory=dict)
    tag_adjustments: list = field(default_factory=list)


class DynamicCarrierSelectionEngine:

    PRIORITY_WEIGHTS = {
        "PRIME":    {"time": 0.60, "cost": 0.20, "reliability": 0.20},
        "STANDARD": {"time": 0.35, "cost": 0.40, "reliability": 0.25},
        "ECONOMY":  {"time": 0.15, "cost": 0.65, "reliability": 0.20},
    }

    def __init__(self, carriers: list):
        self.carriers = {c.carrier_id: c for c in carriers}

    def select_carrier(self, order_id: str, priority: str, destination_zone: str,
                        sku_tags: dict, sla_days: float) -> CarrierSelection:
        weights = self.PRIORITY_WEIGHTS.get(priority, self.PRIORITY_WEIGHTS["STANDARD"])
        feasible = {}