智慧档案安防融合：温湿度监测与门禁、视频监控联动开发实录

环境系统 → 融合平台（MQTT）
  主题：archive/env/event
  载荷：{room_id, event_type, value, timestamp, severity}

门禁系统 → 融合平台（WebSocket）
  主题：archive/access/event
  载荷：{room_id, person_id, person_name, card_no, direction, timestamp}

视频系统 → 融合平台（ONVIF事件订阅）
  主题：archive/video/event
  载荷：{camera_id, room_id, event_type, timestamp, snapshot_url}

{
  "event_id": "E-20250115-001",
  "correlation_id": "C-20250115-001",
  "timestamp": "2025-01-15T10:30:15.123Z",
  "source": "env_monitor",
  "source_id": "S-03-A2",
  "room_id": "R201",
  "event_type": "temp_high",
  "severity": "warning",
  "payload": {
    "value": 25.3,
    "threshold": 24.0,
    "unit": "°C"
  },
  "related_events": []
}

class EventCorrelator:
    def __init__(self, time_window=300, space_map=None):
        self.time_window = time_window  # 秒
        self.space_map = space_map       # room_id → [sensor_ids, camera_ids, door_ids]
        self.event_buffer = []

    def ingest(self, event):
        """接收事件，尝试与缓冲区内事件关联"""
        self.event_buffer.append(event)
        self._cleanup_old_events()

        # 查找同一空间+时间窗口内的相关事件
        related = []
        for e in self.event_buffer:
            if e.event_id == event.event_id:
                continue
            if e.room_id != event.room_id:
                continue
            if abs((e.timestamp - event.timestamp).total_seconds()) > self.time_window:
                continue
            related.append(e)

        if related:
            correlation_id = self._generate_correlation_id(event, related)
            event.correlation_id = correlation_id
            for r in related:
                r.correlation_id = correlation_id
                event.related_events.append(r.event_id)

        return event

    def _cleanup_old_events(self):
        now = datetime.utcnow()
        self.event_buffer = [
            e for e in self.event_buffer
            if (now - e.timestamp).total_seconds() <= self.time_window * 2
        ]

def handle_access_event(access_event, env_state, fusion_engine):
    if access_event.direction == "enter":
        # 记录开门事件
        fusion_engine.record_event(access_event)

        # 标记后续5分钟内的温湿度变化为"人员扰动"
        fusion_engine.set_annotation(
            room_id=access_event.room_id,
            annotation_type="person_disturbance",
            start_time=access_event.timestamp,
            end_time=access_event.timestamp + timedelta(minutes=5),
            metadata={"person": access_event.person_name}
        )

        # 通知环境系统：此期间温湿度波动可放宽阈值
        env_system.set_threshold_override(
            room_id=access_event.room_id,
            temp_deadband=±2.5,  # 正常±1.5
            humi_deadband=±8,    # 正常±5
            duration=300
        )

def handle_temp_alarm(alarm_event, video_system, fusion_engine):
    room_id = alarm_event.room_id

    # 查找该库房关联的摄像头
    cameras = fusion_engine.space_map.get_cameras(room_id)

    # 对每个摄像头：截图 + 标记录像
    snapshots = []
    for cam in cameras:
        # 截图
        snapshot = video_system.snapshot(cam.camera_id)
        snapshots.append(snapshot)

        # 标记录像片段（前后各2分钟）
        video_system.set_bookmark(
            camera_id=cam.camera_id,
            start_time=alarm_event.timestamp - timedelta(minutes=2),
            end_time=alarm_event.timestamp + timedelta(minutes=2),
            label=f"temp_alarm_{alarm_event.event_id}"
        )

    # 推送告警卡片
    alert_card = {
        "type": "temp_alarm_with_video",
        "alarm": alarm_event,
        "snapshots": snapshots,
        "cameras": [c.camera_id for c in cameras],
        "related_access": fusion_engine.find_recent_access(room_id, minutes=30)
    }
    notification.push(alert_card)

def handle_after_hours_access(access_event, env_system, video_system):
    if not is_working_hours(access_event.timestamp):
        room_id = access_event.room_id

        # 1. 记录环境基线
        env_baseline = env_system.get_current_state(room_id)
        fusion_engine.record_baseline(room_id, env_baseline)

        # 2. 视频联动：相关摄像头切换到连续录像模式
        cameras = fusion_engine.space_map.get_cameras(room_id)
        for cam in cameras:
            video_system.start_continuous_recording(
                camera_id=cam.camera_id,
                duration=3600  # 最长1小时
            )

        # 3. 环境系统进入"高灵敏度"模式
        env_system.set_high_sensitivity(room_id)

        # 4. 告警升级
        notification.escalate(
            level="critical",
            message=f"非工作时间人员进入 {room_id}",
            detail={
                "person": access_event.person_name,
                "card_no": access_event.card_no,
                "env_baseline": env_baseline
            }
        )

        # 5. 注册"人员离开"回调
        fusion_engine.on_next_access_exit(room_id, lambda: handle_person_exit(room_id))

def handle_motion_event(motion_event, env_system, video_system):
    room_id = motion_event.room_id

    # 获取当前环境数据
    env_data = env_system.get_fused_readings(room_id)

    # 通过ONVIF向摄像头推送文本叠加（OSD）
    video_system.set_osd_text(
        camera_id=motion_event.camera_id,
        text=f"T:{env_data['avg_temp']:.1f}℃ H:{env_data['avg_humi']:.0f}%RH",
        position="top-right",
        duration=60
    )

    # 同时记录：移动侦测 + 环境快照
    fusion_engine.record_correlated_event({
        "motion": motion_event,
        "env_snapshot": env_data,
        "timestamp": motion_event.timestamp
    })

时间轴：━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━

10:28:00  [门禁] 张三 刷卡进入 R201 ─────────────┐
                                                  │ 人员扰动窗口
10:28:30  [环境] R201 温度开始上升（0.3℃/min）   │
                                                  │
10:30:15  [环境] R201 温度 25.3℃ > 上限 24℃ ⚠️  │
                                                  │
10:30:16  [视频] 自动截图 → 推送告警卡片          │
                                                  │
10:32:00  [视频] 移动侦测 → 叠加温湿度OSD        │
                                                  │
10:33:00  [门禁] 张三 刷卡离开 R201 ─────────────┘

10:33:30  [环境] R201 温度开始回落
10:35:00  [环境] R201 温度恢复正常（21.8℃）