Phase0_6tables_ExtraData_DGroup

2026-05-16 11:42:23 +08:00
parent d669b56569
commit bf3cbc71ae
2 changed files with 161 additions and 210 deletions
--- a/doc/整合方案/SecMPS_最终整合方案_v2.0.md
+++ b/doc/整合方案/SecMPS_最终整合方案_v2.0.md
@@ -3,7 +3,6 @@
 > **版本**: v2.0  
 > **日期**: 2026-05-16  
 > **状态**: 待实施  
-> **替代**: v1.0 系列方案文档

 ---

@@ -12,12 +11,12 @@
 ```
 前端层
  web.vite 管理端（设备管理+网关管理）  warehouse 大屏（Map/Live/IoT/Alarm）
-         | HTTP REST                                   | HTTP REST + SignalR
+         | HTTP REST                                 | HTTP REST + SignalR
         v                                              v
 Vol.Pro 后端 (api_sqlsugar)
  DeviceManagerController / GatewayNodeController / SignalR Hubs
  Quartz: SyncDevicesJob / RealtimePollJob / AlarmPollJob
-  数据库: 8 张表 (base_device / gateway_nodes / 扩展表...)
+  数据库: 6 张表 (base_device / video_channel / video_record / iot_devicedata / iot_alarm / gateway_nodes)
         | 注册/下发设备/心跳/同步数据
         v
 IntegrationGateway 实例A (:5100)       IntegrationGateway 实例B (:5101)
@@ -28,59 +27,33 @@ IntegrationGateway 实例A (:5100)       IntegrationGateway 实例B (:5101)
 MC4.0 (:3000)  Owl (:80)            MC4.0 (:3000)  海康ISC (:80)
 ```

-### 网关多实例架构（方案 C+）
+### 核心设计原则

- Vol.Pro 管理网关实例：gateway_nodes 表注册所有网关节点
- 网关启动时主动注册：POST /api/gateway/register 上报 NodeCode/Token/AdapterTypes/BaseUrl
- Vol.Pro 下发顶层设备：Base_Device.GatewayNodeId 关联设备归属
- 网关无状态：配置只有 3 个值（NodeCode/Token/VolProUrl），挂了重装即恢复
- AdapterCode 双段标识："mc4:31号库房" 区分同类型多实例
- 心跳机制：网关每 15s 上报心跳，Vol.Pro 超 30s 无心跳级联设备离线
+- **网关无状态**：配置仅 NodeCode/Token/VolProUrl，挂了重装即恢复
+- **AdapterCode 双段标识**："mc4:31号库房" 区分同类型多实例
+- **DeviceGroup 路由**：基类表用字典字段决定适配器和行为，不依赖扩展表
+- **ExtraData JSON**：所有适配器特有字段存入 ExtraData，新增适配器不增表
+- **心跳机制**：网关 15s 心跳，Vol.Pro 超 30s 级联设备离线

 ---

-## 二、IntegrationGateway 设计
+## 二、网关架构（方案 C+）

-### 2.1 项目结构（位于 gateway/ 独立文件夹）
+### 2.1 网关注册与心跳流程

 ```
-gateway/
-├── IntegrationGateway.sln
-└── src/
-    ├── IntegrationGateway.Host/       # WebAPI (:5100)
-    |   ├── Controllers/
-    |   |   ├── HealthController.cs
-    |   |   ├── DevicesController.cs
-    |   |   ├── PointsController.cs
-    |   |   ├── StreamsController.cs
-    |   |   ├── AlarmsController.cs
-    |   |   ├── SyncController.cs
-    |   |   └── RegisterController.cs  # 网关注册/心跳
-    |   ├── appsettings.json           # { NodeCode, Token, VolProUrl }
-    |   └── Program.cs
-    ├── IntegrationGateway.Core/
-    |   ├── Abstractions/ → 7 个分型接口
-    |   ├── Models/       → 10 个标准化模型
-    |   └── Infrastructure/ → AdapterRegistry / TokenManager / RateLimiter
-    ├── IntegrationGateway.Adapters.Owl/
-    └── IntegrationGateway.Adapters.MC4/
+管理端: gateway_nodes 表新增 → 生成 NodeCode + Token
+网关配置: { NodeCode, Token, VolProUrl }
+网关启动 → POST /register { nodeCode,token,adapterTypes,baseUrl }
+Vol.Pro 校验 → 更新 AdapterTypes/BaseUrl/IsOnline=在线
+响应: { gatewayNodeId, devices: [base_device WHERE GatewayNodeId=当前] }
+网关按 AdapterCode 分流 → Adapter 连接第三方 → 发现子设备
+网关 → POST /sync → Vol.Pro 写入 base_device（含 ExtraData)
+网关每 15s → POST /heartbeat { nodeCode, token }
+Vol.Pro Job: IsOnline=在线 且 LastHeartbeat < now-30s → IsOnline=离线 → 级联设备离线
 ```

-### 2.2 网关注册与心跳流程
-
-```
-管理端: gateway_nodes 表新增记录 → 生成 NodeCode + Token
-网关配置: appsettings.json { NodeCode, Token, VolProUrl }
-网关启动 → POST /api/gateway/register { nodeCode,token,adapterTypes,baseUrl }
-Vol.Pro 校验 Token → 更新 AdapterTypes/BaseUrl/IsOnline=1
-响应: { gatewayNodeId, devices: [Base_Device WHERE GatewayNodeId=当前网关] }
-网关根据 AdapterCode 分流 → Adapter 连接第三方 → 发现子设备
-网关 → POST /api/gateway/sync → Vol.Pro 写入 Base_Device 及子设备
-网关每 15s → POST /api/gateway/heartbeat { nodeCode, token }
-Vol.Pro 后台任务: IsOnline=1 且 LastHeartbeat < now-30s → IsOnline=0 → 级联设备离线
-```
-
-### 2.3 网关配置
+### 2.2 网关配置

 ```json
 {
@@ -90,9 +63,7 @@ Vol.Pro 后台任务: IsOnline=1 且 LastHeartbeat < now-30s → IsOnline=0 →
 }
 ```

-适配器类型由网关启动时扫描已注册的 Adapter 类自动获取，无需在配置中声明。
-
-### 2.4 适配器能力矩阵
+### 2.3 适配器能力矩阵

 | 接口 | Owl | MC4.0 | 门禁(未来) |
 |------|:---:|:-----:|:----------:|
@@ -103,7 +74,7 @@ Vol.Pro 后台任务: IsOnline=1 且 LastHeartbeat < now-30s → IsOnline=0 →
 | IHasAlarms | ⚠️ | ✅ | ✅ |
 | IAcceptsMetadataPush | ✅ | ❌ | ⚠️ |

-### 2.5 双向同步引擎
+### 2.4 双向同步引擎

 | 方向 | 说明 | MC4.0 | Owl |
 |------|------|-------|-----|
@@ -111,7 +82,7 @@ Vol.Pro 后台任务: IsOnline=1 且 LastHeartbeat < now-30s → IsOnline=0 →
 | PushToSource | Vol.Pro→第三方 | 告警确认/控制 | 元数据/PTZ |
 | Bidirectional | 先写第三方再更新本地 | 告警确认 | — |

-### 2.6 Gateway API
+### 2.5 Gateway API

 ```
 # 注册与心跳
@@ -132,7 +103,7 @@ GET  /api/gateway/health

 ---

-## 三、数据模型（8 张表）
+## 三、数据模型（6 张表）

 ### 3.1 区域表 warehouse_regions（现有）

@@ -142,7 +113,7 @@ GET  /api/gateway/health
 | RegionName | nvarchar(255) |
 | ParentId | int? (自引用树) |

-### 3.2 网关节点表 gateway_nodes（新建）
+### 3.2 网关节点表 gateway_nodes

 | 字段 | 类型 | 说明 |
 |------|------|------|
@@ -153,126 +124,151 @@ GET  /api/gateway/health
 | AdapterTypes | NVARCHAR(200) | 适配器类型（网关上报） |
 | BaseUrl | NVARCHAR(200) | 网关地址（网关上报） |
 | LastHeartbeat | DATETIME | 上次心跳时间 |
-| IsOnline | TINYINT DEFAULT 0 | 在线状态 |
-| Enable | TINYINT DEFAULT 1 | 启用 |
+| IsOnline | NVARCHAR(20) | 在线状态(字典: 在线/离线) |
+| Enable | NVARCHAR(20) | 启用状态(字典: 启用/禁用) |

-### 3.3 统一设备主表 Base_Device
+### 3.3 统一设备主表 base_device

 | 字段 | 类型 | 说明 |
 |------|------|------|
 | DeviceId | INT AUTO_INCREMENT | Vol.Pro内部ID |
-| DeviceName | NVARCHAR(100) | 本地名称 |
+| DeviceName | NVARCHAR(100) | 设备名称 |
 | AdapterCode | NVARCHAR(50) | "mc4:31号库房"（类型:实例） |
-| SourceId | NVARCHAR(100) | 第三方原始ID |
-| DeviceCategory | NVARCHAR(50) | Video/IoT/Access/Barrier/Alarm（字典） |
+| SourceId | NVARCHAR(100) | 源系统设备ID |
+| **DeviceCategory** | NVARCHAR(50) | 设备种类(字典: 摄像机/温湿度变送器/...) |
+| **DeviceGroup** | NVARCHAR(20) | 设备分组(字典: 视频设备/IoT设备/门禁设备/道闸设备/报警设备) |
 | RegionId | INT? | 所属区域ID |
 | GatewayNodeId | INT? | 所属网关节点ID |
-| IsParent | TINYINT | 是否父设备 |
+| IsParent | NVARCHAR(20) | 是否父设备(字典: 是/否) |
 | ParentDeviceId | INT? | 父设备自引用 |
-| IsOnline | TINYINT | 在线状态 |
+| IsOnline | NVARCHAR(20) | 在线状态(字典: 在线/离线) |
 | MapModelId | NVARCHAR(100) | VgoMap模型ID |
 | MapModelScale | FLOAT | |
 | MapModelRotation | NVARCHAR(100) | |
-| Lat/Lng | DOUBLE | WGS84 |
-| ExtraData | TEXT | 适配器原始JSON |
+| **ExtraData** | TEXT | ★ 适配器扩展JSON(Owl/MC4/门禁字段均存于此) |
 | LocalOverrides | TEXT | 本地覆盖JSON |
 | SyncVersion | BIGINT | 乐观锁 |
 | LastSyncTime | DATETIME | |
+| Enable | NVARCHAR(20) | 启用状态(字典: 启用/禁用) |

 唯一约束: (AdapterCode, SourceId)

-### 3.4 扩展表
+### 3.4 DeviceGroup 分组规则

- Device_Video_Ext: 视频设备扩展（OwlDeviceId, Protocol, ChannelCount）
- Video_Channel: 视频通道扩展（OwlChannelId, DeviceId, OwlStreamApp/Name, HasPtz, SnapshotUrl）
- Video_Record: 录像记录（ChannelId, OwlRecordId, StartedAt, FilePath）
- Device_IoT_Ext: IoT设备扩展（Mc4DeviceId, PointIndex, Unit, IsControlPoint, ObjectType）
- IoT_DeviceData: 历史归档（DeviceId→子设备, PointValue, 仅存快照）
- IoT_Alarm: 通用告警（SourceAlarmId, DeviceId, AlarmLevel, State）
+Vol.Pro 同步接口通过 DeviceGroup 路由，无需硬编码：

-### 3.5 层级示例
+| DeviceGroup | 网关适配器 | 前端按钮组 | 同步模式 |
+|:---:|------|------|:---:|
+| 视频设备 | OwlAdapter → IHasStreams | 实时预览/云台/回放/快照 | Merge |
+| IoT设备 | Mc4Adapter → IHasPoints | 实时数据/控制/告警 | FullReplace |
+| 门禁设备 | AccessAdapter | 远程开门/记录/告警 | Merge |
+| 道闸设备 | BarrierAdapter | 抬杆/落杆/记录 | Merge |
+| 报警设备 | AlarmAdapter | 查看告警/布防撤防 | Merge |
+
+### 3.5 ExtraData 格式示例
+
+```json
+// 摄像机 (Owl)
+{ "owlDeviceId": "gb_xxx", "protocol": "GB28181", "manufacturer": "海康" }
+
+// 温湿度变送器 (MC4子设备)
+{ "mc4DeviceId": 1001, "pointIndex": 0, "unit": "℃", "isControlPoint": false }
+
+// 空调控制器 (MC4子设备)
+{ "mc4DeviceId": 1002, "pointIndex": 2, "unit": null, "isControlPoint": true }
+
+// 未来门禁
+{ "hikDeviceId": "door_01", "doorType": "单门", "readerType": "IC卡" }
+```
+
+### 3.6 层级示例

 ```
-gateway_nodes: gw-31ku (32号库房网关, MC4+Owl)
+gateway_nodes: gw-31ku

 warehouse_regions: 厂区 → 新库区 → 31号库房

-Base_Device (RegionId=3, GatewayNodeId=gw-31ku.NodeId):
-  东北角高位摄像机          (Category=1, Device_Video_Ext)
-  人员计数摄像机            (Category=1, Device_Video_Ext)
-  动环采集器               (Category=2, IsParent=1, Device_IoT_Ext)
-  ├── 温湿度探头            (ParentDeviceId=采集器, Device_IoT_Ext.PointIndex=0)
-  ├── 空调控制器            (ParentDeviceId=采集器, Device_IoT_Ext.IsControlPoint=1)
-  ├── 除湿机                (ParentDeviceId=采集器)
-  └── 紧急报警按钮          (ParentDeviceId=采集器)
+base_device (RegionId=3, GatewayNodeId=gw-31ku.NodeId):
+  东北角高位摄像机    (DeviceGroup=视频设备, ExtraData={owlDeviceId,...})
+  人员计数摄像机      (DeviceGroup=视频设备)
+  动环采集器         (DeviceGroup=IoT设备, IsParent=是)
+  ├── 温湿度变送器    (ParentDeviceId=采集器, ExtraData={pointIndex:0,unit:"℃"})
+  ├── 空调控制器      (ParentDeviceId=采集器, ExtraData={pointIndex:2,isControlPoint:true})
+  ├── 除湿/恒湿机     (ParentDeviceId=采集器)
+  └── 紧急报警按钮    (ParentDeviceId=采集器, DeviceGroup=报警设备)
 ```

 ---

-## 四、管理端统一设备页面
+## 四、Vol.Pro 同步接口（新增适配器零改动）

-### 4.1 布局
+```csharp
+// POST /api/gateway/sync
+public async Task SyncDevices(string nodeCode, List<StandardDevice> devices)
+{
+    var node = await _db.gateway_nodes.FirstAsync(n => n.NodeCode == nodeCode);
+    foreach (var d in devices)
+    {
+        var entity = await _db.base_device
+            .FirstOrDefaultAsync(x => x.AdapterCode == d.AdapterCode && x.SourceId == d.SourceId)
+            ?? new base_device();

+        entity.DeviceName = d.Name;
+        entity.DeviceGroup = d.Group;          // 字典: 视频设备/IoT设备/...
+        entity.DeviceCategory = d.Category;     // 字典: 摄像机/温湿度变送器/...
+        entity.IsOnline = d.IsOnline ? "在线" : "离线";
+        entity.IsParent = d.IsParent ? "是" : "否";
+        entity.ParentDeviceId = d.ParentSourceId; // 网关同步过来的父级关系
+        entity.GatewayNodeId = node.NodeId;
+        entity.ExtraData = d.ExtraDataJson;     // ★ 一行，适配器字段全在这里
+        // ... 公共字段赋值 ...
+
+        _db.base_device.Upsert(entity);
+    }
+    await _db.SaveChangesAsync();
+}
 ```
-+------------------+---------------------------------------+
-|  顶部工具栏       |                                       |
-+------------------+---------------------------------------+
-|  左侧区域树       |  右侧设备列表                           |
-|                  |                                       |
-|  📁 厂区         |  区域:31号库房  最后同步:05-15          |
-|   📁 新库区      |  +---------------------------------+  |
-|    📁 31号库房 ● |  | ▸动环采集器   MC4.0  █在线    |  |
-|    📁 11号库房   |  | 东北角摄像机  Owl    █在线    |  |
-|                  |  +---------------------------------+  |
-|  [+新建区域]     |                                       |
-+------------------+---------------------------------------+
-```
-
-### 4.2 前端文件
-
-```
-web.vite/src/views/warehouse/DeviceManager/
-├── index.vue                  # 主页面
-├── components/
-│   ├── RegionTree.vue         # el-tree 区域树
-│   ├── DeviceTable.vue        # el-table 可展开行
-│   ├── DeviceEditDialog.vue   # 编辑弹框
-│   ├── MapBindingPanel.vue    # 地图绑定面板
-│   ├── VideoDeviceActions.vue # 视频按钮组
-│   └── IoTDeviceActions.vue   # IoT按钮组
-└── api/deviceManager.js
-```
-
-### 4.3 后端 API
-
-| 接口 | 说明 |
-|------|------|
-| GET /api/DeviceManager/GetRegionTree | 区域树+设备数量 |
-| GET /api/DeviceManager/GetDevicesByRegion | 区域设备列表(含子设备) |
-| PUT /api/DeviceManager/{deviceId} | 更新设备(含地图绑定) |
-| POST /api/DeviceManager/SyncFromGateway | 手动同步 |
-
-### 4.4 操作按钮矩阵
-
-| Category | 按钮 |
-|----------|------|
-| 1-视频 | 实时预览/云台控制/查看回放/获取快照/同步通道 |
-| 2-IoT | 查看实时数据/设备控制/刷新点位/查看告警 |
-| 3-门禁 | 远程开门/查看记录/查看告警 |
-| 4-道闸 | 抬杆/落杆/查看记录 |

 ---

-## 五、同步策略
+## 五、管理端统一设备页面
+
+### 5.1 操作按钮矩阵（按 DeviceGroup 路由）
+
+| DeviceGroup | 操作按钮 |
+|:---:|------|
+| 视频设备 | 实时预览 / 云台控制 / 查看回放 / 获取快照 / 同步通道 |
+| IoT设备 | 查看实时数据 / 设备控制 / 刷新点位 / 查看告警 |
+| 门禁设备 | 远程开门 / 查看记录 / 查看告警 |
+| 道闸设备 | 抬杆 / 落杆 / 查看记录 |
+| 报警设备 | 查看告警 / 布防撤防 |
+
+### 5.2 前端按钮路由
+
+```javascript
+// DeviceTable.vue
+const actionMap = {
+  '视频设备': VideoDeviceActions,
+  'IoT设备':  IoTDeviceActions,
+  '门禁设备': AccessDeviceActions,
+  '道闸设备': BarrierDeviceActions,
+  '报警设备': AlarmDeviceActions,
+}
+// 渲染: actionMap[device.DeviceGroup]
+```
+
+---
+
+## 六、同步策略

 ### MC4.0 → 区域树+设备
 - type=1 节点 → 名称匹配 warehouse_regions → 绑区或新建
- type=2 节点 → Upsert Base_Device, RegionId=叶子区域, GatewayNodeId=当前网关
+- type=2 节点 → Upsert base_device, DeviceGroup=IoT设备, ExtraData 存点位属性
 - 模式: FullReplace, 频率限制: 2次/秒

 ### Owl → 设备
- GET /devices → Upsert Base_Device (Category=1, IsParent=1)
- GET /channels → Upsert Base_Device (ParentDeviceId=NVR)
+- GET /devices → Upsert base_device (DeviceGroup=视频设备, IsParent=是)
+- GET /channels → Upsert base_device (ParentDeviceId=NVR) + video_channel
 - Owl 无区域概念 → RegionId=NULL, 管理员手动分配
 - 模式: Merge

@@ -286,7 +282,7 @@ web.vite/src/views/warehouse/DeviceManager/

 ---

-## 六、部署拓扑
+## 七、部署拓扑

 ```
 Docker: Owl+ZLM (:80)    MC4.0-1 (:3000)   MC4.0-2 (:3000)
@@ -311,11 +307,11 @@ Docker: Owl+ZLM (:80)    MC4.0-1 (:3000)   MC4.0-2 (:3000)

 ---

-## 七、实施路线
+## 八、实施路线

 | 阶段 | 工期 | 内容 |
 |------|------|------|
-| Phase 0 | Day 1-2 | Gateway骨架 + 8张表建表 + 代码生成 |
+| Phase 0 | Day 1-2 | Gateway骨架 + 6张表建表 + 代码生成 |
 | Phase 1 | Day 3-6 | OwlAdapter + 管理端视频设备页 |
 | Phase 2 | Day 7-11 | Mc4Adapter + IoT管理 + 区域树匹配 + SignalR |
 | Phase 3 | Day 12-17 | warehouse端改造 + 全链路联调 |
@@ -325,19 +321,19 @@ Docker: Owl+ZLM (:80)    MC4.0-1 (:3000)   MC4.0-2 (:3000)

 ---

-## 八、新增整合流程
+## 九、新增整合流程

 以接入「海康门禁」为例：
 1. 新建 IntegrationGateway.Adapters.HikvisionAccess 项目
-2. 实现 IHasFlatDevices + IHasAlarms
-3. 注册到 Host → 网关启动时自动上报到 Vol.Pro
-4. 前端新增 AccessDeviceActions.vue (~80行)
-5. Vol.Pro 后端零改动
+2. 实现 IHasFlatDevices + IHasAlarms → 设备同步时填充 DeviceGroup=门禁设备
+3. 管理端字典加一条"门禁设备"分组 → 按钮自动出现
+4. Vol.Pro 同步接口零改动（ExtraData 承载门禁字段）
+5. 前端新增 AccessDeviceActions.vue (~80行)
 总工作量: 1-2 天

 ---

-## 九、代码组织规范
+## 十、代码组织规范

 | 代码类型 | 路径 | 被覆盖? |
 |----------|------|:---:|