边缘端规则引擎设计：在断网环境下实现恒湿机本地自治的轻量级方案

[输入层]
  传感器数据（温湿度/水浸/烟感/门禁）
  ├─ 数据清洗（去抖、滤波）
  ├─ 质量位打标（good/doubtful/invalid）
  └─ 时间戳对齐（本地高精度时钟）
        │
        ▼
[规则匹配层]（轻量 Rete 变种）
  规则加载 → 条件评估 → 动作触发
        │
        ▼
[执行层]
  ├─ PID 控制（恒湿机）
  ├─ 设备保护（最小启停）
  ├─ 联动控制（关阀、停空调）
  ├─ 告警生成（本地缓存）
        │
        ▼
[存储层]
  ├─ 时序数据（LevelDB / SQLite）
  ├─ 事件日志（追加写，顺序IO）
  ├─ 规则快照（当前生效规则）
        │
        ▼
[同步层]（网络恢复后）
  增量上传 + 冲突消解 + 审计对齐

{
  "rule_id": "EDGE-MOIST-001",
  "rule_name": "A3区湿度超标本地处置",
  "version": "20260901",
  "priority": 100,
  "enabled": true,
  "domain": "防潮",
  "condition": {
    "logic": "AND",
    "items": [
      {"metric": "humidity", "operator": ">", "value": 60},
      {"metric": "humidity_quality", "operator": "==", "value": "good"},
      {"metric": "device_status:DH-A3-01", "operator": "==", "value": "online"}
    ]
  },
  "actions": [
    {
      "type": "control_device",
      "device": "DH-A3-01",
      "command": "start_dehumidify",
      "params": {"power": 80},
      "verify": true,
      "timeout": 5
    },
    {
      "type": "log_event",
      "level": "warning",
      "message": "湿度超标，启动本地除湿"
    }
  ],
  "constraints": {
    "min_run_time": 300,
    "min_stop_time": 180,
    "max_daily_runs": 48
  },
  "source": "cloud_sync",
  "sync_time": "2026-09-01T10:00:00+08:00"
}

condition ::= atomic_condition | composite_condition
atomic_condition ::= metric operator value
composite_condition ::= { "logic": "AND|OR", "items": [condition, ...] }
operator ::= ">" | ">=" | "<" | "<=" | "==" | "!=" | "between"

{
  "logic": "AND",
  "items": [
    {"metric": "humidity", "operator": ">", "value": 60},
    {"metric": "temperature", "operator": "between", "min": 18, "max": 28}
  ]
}

loop every 10 seconds:
  humidity = read_sensor("humidity")
  if humidity.quality != "good":
    log("sensor doubtful, keep last action")
    continue

  error = humidity.value - target_humidity
  delta = pid.compute(error)

  if delta > 0:  // 需要除湿
    if can_start_device("DH-A3-01"):
      start_dehumidify(power=min(delta, 100))
  else:  // 接近目标
    if can_stop_device("DH-A3-01"):
      stop_dehumidify()

  log_event("pid_adjust", {error, delta, action})

// 伪代码：设备保护内核逻辑
if (device == COMPRESSOR) {
    if (runtime < MIN_RUNTIME) {
        block_stop("最小运行时间保护");
        return;
    }
    if (stoptime < MIN_STOPTIME) {
        block_start("最小停机时间保护");
        return;
    }
}

{
  "rule_id": "EDGE-FIRE-001",
  "priority": 1000,
  "condition": {
    "logic": "OR",
    "items": [
      {"metric": "smoke_density", "operator": ">", "value": 0.5},
      {"metric": "temp_rate_of_rise", "operator": ">", "value": 3}
    ]
  },
  "actions": [
    {"type": "stop_device", "device": "AC-A3-01"},
    {"type": "stop_device", "device": "AHU"},
    {"type": "open_valve", "valve": "smoke_valve"},
    {"type": "unlock_door", "door": "emergency_exit"},
    {"type": "log_event", "level": "critical", "message": "本地火险联动"}
  ]
}

{
  "rule_id": "EDGE-WATER-001",
  "priority": 900,
  "condition": {
    "items": [
      {"metric": "water_leak", "operator": "==", "value": 1}
    ]
  },
  "actions": [
    {"type": "close_valve", "valve": "water_valve_A3"},
    {"type": "start_device", "device": "drain_pump"},
    {"type": "stop_device", "device": "DH-A3-01"},
    {"type": "log_event", "level": "warning", "message": "本地漏水联动"}
  ]
}

{
  "rule_id": "EDGE-MOIST-001",
  "priority": 500,
  "condition": {
    "items": [
      {"metric": "humidity", "operator": ">", "value": 60}
    ]
  },
  "actions": [
    {"type": "control_device", "device": "DH-A3-01", "command": "start_dehumidify"},
    {"type": "log_event", "level": "info", "message": "本地湿度调控"}
  ]
}

{
  "event_id": "EVT-20260918-143000-001",
  "ts": "2026-09-18T14:30:00.123+08:00",
  "rule_id": "EDGE-MOIST-001",
  "rule_version": "20260901",
  "trigger": {
    "metric": "humidity",
    "value": 61.2,
    "threshold": 60
  },
  "action": {
    "type": "control_device",
    "device": "DH-A3-01",
    "command": "start_dehumidify",
    "params": {"power": 80},
    "result": "success",
    "verify_value": 1
  },
  "edge_status": "offline",
  "sync_status": "pending"
}

网络恢复
  ↓
边缘上报“断网时间段 + 规则版本”
  ↓
云平台比对规则版本
  ↓
版本一致 → 接收边缘数据，标记为 backfilled
版本不一致 → 下发最新规则，边缘重新计算（如有必要）
  ↓
云平台生成“断网期间合规报告”
  ↓
边缘清理已同步数据（保留审计日志）