# 软件定义座舱感知架构

class SoftwareDefinedCabinSensing:
    """
    软件定义座舱感知架构
    
    借鉴NXP思路：
    - 传感器作为数据源
    - AI编排动态分配资源
    - 复用已有传感资产
    """
    
    def __init__(self):
        # 传感器资产注册
        self.sensors = {
            'front_camera': {'type': 'RGB-IR', 'resolution': '1.1MP', 
                           'power': '2.5W', 'active': True},
            'rear_camera': {'type': 'RGB', 'resolution': '0.5MP',
                          'power': '1.5W', 'active': False},  # 按需激活
            'uwb_front': {'type': 'UWB-radar', 'channels': '2T4R',
                         'power': '0.3W', 'active': True},
            'uwb_rear': {'type': 'UWB-radar', 'channels': '2T4R',
                        'power': '0.3W', 'active': False},
            'pressure_fl': {'type': 'pressure_mat', 'density': '64x64',
                           'power': '0.1W', 'active': True},
            'pressure_fr': {'type': 'pressure_mat', 'density': '64x64',
                           'power': '0.1W', 'active': True},
            'mic_array': {'type': 'microphone', 'channels': 4,
                         'power': '0.05W', 'active': True},
        }
        
        # 功能定义
        self.functions = {
            'driver_drowsiness': {
                'sensors': ['front_camera'],
                'processing': 'edge',  # 时延关键
                'latency_budget': 3000,  # ms
                'active': True
            },
            'driver_distraction': {
                'sensors': ['front_camera'],
                'processing': 'edge',
                'latency_budget': 3000,
                'active': True
            },
            'cpd_rear': {
                'sensors': ['uwb_rear'],
                'processing': 'zonal',
                'latency_budget': 10000,
                'active': True
            },
            'occupant_classification': {
                'sensors': ['pressure_fl', 'pressure_fr', 'uwb_front'],
                'processing': 'central',  # 跨模态融合
                'latency_budget': 200,
                'active': True
            },
            'oop_detection': {
                'sensors': ['front_camera', 'pressure_fl'],
                'processing': 'edge',  # 碰撞前时延关键
                'latency_budget': 500,
                'active': True
            },
            'voice_emotion': {
                'sensors': ['mic_array'],
                'processing': 'central',
                'latency_budget': 500,
                'active': False  # 按需激活
            }
        }
    
    def orchestrate(self, driving_context):
        """
        根据驾驶上下文动态编排感知资源
        
        Args:
            driving_context: {'speed': 60, 'scenario': 'highway', 
                            'time': 'night', 'passengers': 2}
        """
        # 高速+夜间 → 激活全部疲劳/分心检测
        if driving_context['speed'] > 80 and driving_context['time'] == 'night':
            self._activate('driver_drowsiness')
            self._activate('driver_distraction')
            self._activate('cpd_rear')
        
        # 城市低速 → 激活乘员分类
        elif driving_context['speed'] < 30:
            self._activate('occupant_classification')
            self._activate('voice_emotion')  # 语音交互场景
        
        # 碰撞预警 → 紧急激活OOP
        if driving_context.get('pre_crash'):
            self._activate('oop_detection')
            # 降级其他功能释放计算资源
            self._deactivate('voice_emotion')
    
    def _activate(self, func_name):
        if func_name in self.functions:
            self.functions[func_name]['active'] = True
            for s in self.functions[func_name]['sensors']:
                self.sensors[s]['active'] = True
    
    def _deactivate(self, func_name):
        if func_name in self.functions:
            self.functions[func_name]['active'] = False
            # 检查传感器是否被其他功能使用
            for s in self.functions[func_name]['sensors']:
                still_needed = any(
                    s in self.functions[f]['sensors'] and self.functions[f]['active']
                    for f in self.functions if f != func_name
                )
                if not still_needed:
                    self.sensors[s]['active'] = False
    
    def get_power_consumption(self):
        """计算当前功耗"""
        total = 0
        for name, sensor in self.sensors.items():
            if sensor['active']:
                total += float(sensor['power'].replace('W', ''))
        return total


# 测试
if __name__ == "__main__":
    system = SoftwareDefinedCabinSensing()
    
    # 高速夜间场景
    system.orchestrate({'speed': 100, 'scenario': 'highway', 'time': 'night', 'passengers': 2})
    print(f"高速夜间功耗: {system.get_power_consumption()}W")
    
    # 城市低速场景
    system.orchestrate({'speed': 20, 'scenario': 'urban', 'time': 'day', 'passengers': 2})
    print(f"城市低速功耗: {system.get_power_consumption()}W")
    
    # 碰撞前场景
    system.orchestrate({'speed': 60, 'scenario': 'highway', 'time': 'day', 'pre_crash': True})
    print(f"碰撞前功耗: {system.get_power_consumption()}W")