档案馆数字孪生对接：十防环境监测数据采集与可视化平台搭建实战

{
  "sensor_id": "S-03-A2",
  "position": {
    "building": "B1",
    "floor": "F2",
    "room": "R201",
    "x": 12.5,
    "y": 3.8,
    "z": 1.4,
    "mount_type": "wall",
    "facing": "south"
  },
  "coverage_radius": 4.0,
  "sensor_type": "temp_humi",
  "protocol": "modbus_tcp",
  "update_interval": 30
}

原始采集 → 边缘网关
  ├── 协议转换（Modbus/RTU→TCP、SNMP→MQTT）
  ├── 数据融合（多测点聚合、异常剔除）
  ├── 空间标注（绑定坐标、区域标签）
  ├── 质量标记（valid/suspect/invalid）
  └── 统一时间戳（NTP对齐，含采集时间+上报时间）
       ↓
   MQTT/HTTP → 数字孪生平台

档案馆（Archives）
 ├── 建筑（Building）
 │    ├── 楼层（Floor）
 │    │    ├── 库房（Room）
 │    │    │    ├── 区域（Zone）
 │    │    │    │    ├── 测点（Sensor）
 │    │    │    │    └── 设备（Equipment）
 │    │    │    │         ├── 恒温恒湿机组
 │    │    │    │         ├── 除湿机
 │    │    │    │         └── 新风机

{
  "entity_id": "R201",
  "entity_type": "room",
  "static_attrs": {
    "area": 120.5,
    "height": 3.2,
    "volume": 385.6,
    "orientation": "south-west",
    "wall_type": "concrete",
    "insulation": "50mm_polyurethane",
    "door_count": 2,
    "window_count": 0
  },
  "dynamic_attrs": {
    "avg_temp": {"value": 21.3, "timestamp": "2025-01-15T10:30:00Z", "quality": "valid"},
    "avg_humi": {"value": 52.1, "timestamp": "2025-01-15T10:30:00Z", "quality": "valid"},
    "temp_uniformity": {"value": 1.8, "timestamp": "2025-01-15T10:30:00Z"},
    "dewing_risk": {"value": "low", "timestamp": "2025-01-15T10:30:00Z"},
    "active_alarms": [],
    "unit_mode": "auto",
    "unit_sp_temp": 22.0,
    "unit_sp_humi": 50.0
  },
  "relations": [
    {"target": "HVAC-01", "type": "controlled_by"},
    {"target": "S-03-A*", "type": "monitored_by", "count": 6},
    {"target": "F2", "type": "located_in"}
  ]
}

IoT物模型属性 → 孪生实体动态属性（1:1映射）
IoT事件 → 孪生实体状态变更+事件日志
IoT行为 → 孪生实体控制指令下发

IoT Explorer → 规则引擎 → 消息队列(CKafka/CMQ) → 孪生平台
                                                    ↓
                                             实时数据库(InfluxDB/TDengine)
                                                    ↓
                                             三维引擎(WebSocket推送)

def downsample_for_visualization(raw_readings, level):
    """
    level: overview(全馆概览) / floor(楼层) / room(单库) / detail(点位)
    """
    if level == "overview":
        return aggregate_by_building(raw_readings, interval="5min")
    elif level == "floor":
        return aggregate_by_room(raw_readings, interval="1min")
    elif level == "room":
        return aggregate_by_zone(raw_readings, interval="30s")
    else:  # detail
        return raw_readings  # 原始数据

数据输入：各测点坐标 + 实时温湿度值
插值算法：反距离加权(IDW) 或 克里金(Kriging)
渲染方式：WebGL Shader，颜色映射

// 热力图片元着色器核心逻辑
uniform sampler2D sensors;  // 测点数据纹理
uniform vec3 colorCold;     // 低温颜色 (蓝)
uniform vec3 colorHot;      // 高温颜色 (红)
uniform float minTemp;      // 16℃
uniform float maxTemp;      // 26℃

void main() {
    float temp = interpolateIDW(vPosition, sensors);
    float t = clamp((temp - minTemp) / (maxTemp - minTemp), 0.0, 1.0);
    vec3 color = mix(colorCold, colorHot, t);
    gl_FragColor = vec4(color, 0.7);
}

def simulate_strategy(room_model, strategy, duration_hours=24):
    """
    输入：库房物理模型 + 联动策略 + 仿真时长
    输出：温湿度变化曲线、设备运行时长、能耗估算
    """
    env = EnvironmentSimulator(room_model)
    env.set_strategy(strategy)
    
    # 加载历史气象数据或设定工况
    weather = load_weather_data(room_model.location, duration_hours)
    
    results = []
    for t in range(0, duration_hours * 3600, 60):  # 1分钟步长
        env.step(t, weather.at(t))
        results.append({
            "time": t,
            "temp": env.temp,
            "humi": env.humi,
            "unit_mode": env.unit_mode,
            "energy": env.energy_consumed,
            "alarms": env.active_alarms
        })
    
    return results

场景库：
  - 通信中断：指定设备/网关离线，观察兜底逻辑
  - 传感器失效：指定测点数据冻结/跳变，观察融合算法
  - 机组故障：压缩机/加湿器/风机故障，观察备用切换
  - 电源中断：整库掉电，观察恢复后自启动
  - 水浸事件：指定区域漏水，观察联动响应

# 孪生平台对外API
/v1/entities/{entity_id}/state:        # 获取实体当前状态
/v1/entities/{entity_id}/history:       # 历史数据查询
/v1/entities/{entity_id}/control:       # 下发控制指令
/v1/scenes/{scene_id}/snapshot:         # 场景快照
/v1/simulation/run:                     # 启动仿真
/v1/simulation/{sim_id}/result:         # 仿真结果
/v1/alarms/active:                      # 活跃告警列表
/v1/alarms/{alarm_id}/timeline:         # 告警时间线
/v1/models/import:                      # 导入BIM/CAD模型
/v1/models/{model_id}/bind:             # 绑定传感器到模型

{
  "rule_name": "twin_data_forward",
  "condition": "topic: $thing/up/property",
  "actions": [
    {
      "type": "ckafka",
      "topic": "twin-realtime",
      "payload": {
        "entity_id": "${ProductId}:${DeviceName}",
        "properties": "${State.Reported}",
        "timestamp": "${Timestamp}"
      }
    }
  ]
}