class CabinCO2Monitor:
    """
    车内 CO₂ 监测模块
    
    与 DMS 疲劳检测协同：
    - CO₂ > 1500ppm → 预防性通风
    - CO₂ > 2500ppm → 疲劳预警
    - CO₂ > 4000ppm → 强制通风+停车建议
    """
    
    def __init__(self):
        self.thresholds = {
            'normal': 1000,
            'elevated': 1500,
            'warning': 2500,
            'critical': 4000
        }
        self.hvac_active = False
    
    def process(self, co2_ppm: float, dms_fatigue: float) -> dict:
        """处理 CO₂ + DMS 融合"""
        
        if co2_ppm > self.thresholds['critical']:
            action = 'FORCE_FRESH_AIR + SUGGEST_REST'
            level = 3
        elif co2_ppm > self.thresholds['warning']:
            action = 'FRESH_AIR + FATIGUE_ALERT'
            level = 2
        elif co2_ppm > self.thresholds['elevated']:
            # CO₂升高 + DMS疲劳 → 提前预警
            if dms_fatigue > 0.3:
                action = 'FRESH_AIR + SOFT_ALERT'
                level = 1
            else:
                action = 'INCREASE_VENTILATION'
                level = 0
        else:
            action = 'NORMAL'
            level = 0
        
        return {
            'co2_level': co2_ppm,
            'hvac_action': action,
            'alert_level': level,
            'dms_fatigue': dms_fatigue,
            'fusion_flag': co2_ppm > 1500 and dms_fatigue > 0.3
        }


if __name__ == "__main__":
    monitor = CabinCO2Monitor()
    
    scenarios = [
        ("正常", 800, 0.1),
        ("CO₂偏高", 1800, 0.2),
        ("CO₂+疲劳", 2800, 0.5),
        ("高危", 4500, 0.7),
    ]
    
    for name, co2, fatigue in scenarios:
        result = monitor.process(co2, fatigue)
        print(f"{name}: CO₂={co2}ppm, 疲劳={fatigue}, "
              f"动作={result['hvac_action']}, 等级={result['alert_level']}")