V1.12: RuleEngineService DI 注入失败修复

【问题】
后端 VS 启动报: Unable to resolve service for type 'Warehouse.Services.iot_alarmService'
while attempting to activate 'Warehouse.Services.RuleEngineService'.

【根因】
1. iot_alarmService 通过框架 IDependency 机制被 AutofacContainerModuleExtension.AddModule
   按第一个接口 Iiot_alarmService 注册到内置 DI(具体类未单独注册)
2. RuleEngineService 构造函数按具体类 iot_alarmService 注入 → 内置 DI 找不到 → 验证失败

【修复】
RuleEngineService.cs: 构造函数参数 + 字段类型由 iot_alarmService 改为 Iiot_alarmService
(符合框架惯例,与 gateway_nodesController.cs:40 / iot_alarmController.cs:15/24 一致)

【验证】
dotnet build api_sqlsugar 0 错误 0 警告

【效果】
- RuleEngineService 构造函数 DI 解析成功
- var app = builder.Build() 不再抛 AggregateException
- 后端可正常启动
- Quartz 调度 RuleEngineJob 每 10s 调一次 EvaluateAllAsync()
- 规则触发"告警"动作时 _alarmService.UpsertAlarmAsync 可正确调用
This commit is contained in:
2026-07-24 05:34:21 +08:00
parent 6c76007249
commit 3d41f4d412
2 changed files with 366 additions and 10 deletions
+1
View File
@@ -367,6 +367,7 @@ gateway/
| 2026-07-24 | **MC4 适配器 JSON 反序列化大小写问题 V1.10** | 主人反馈:"刚才对MC4授权部分的修改在JSON反序列化的时候有问题,返回的JSON字符串中的字段名全是小写,但Model的属性命名是有大小写的,这个得解决一下,不然无法正确反序列化返回数据,也就无法正确拿到Token。"**根因 2 段**:(1**MC4 返回 JSON 字段全小写**(如 `code` `msg` `data` `id` `token`),但 C# Model 属性是 PascalCase`Code` `Msg` `Data` `Id` `Token`),**默认 `JsonSerializer.Deserialize` 大小写敏感直接返回 null**;(2)**MC4 业务接口统一响应结构** `{code, msg, data}` 三段式(参考 [MC4.0对外API.md](file:///d:/Code/SecMPS/doc/对接文档/MC4.0对外API.md)),List/Object 不能直接反序列化 List<T>,必须先解析包装再取 data 段。**整改方案**(共 2 文件改动):(1)**[Mc4AuthHelper.cs:39-44](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs#L39-L44) 新增 JsonOpts 静态字段**——`PropertyNameCaseInsensitive = true` + `PropertyNamingPolicy = JsonNamingPolicy.CamelCase`[line 42-44](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs#L42-L44) 新增 `EmptyJsonBody` 静态 `StringContent("{}", Encoding.UTF8, "application/json")` 处理无参数 POST 请求(MC4 平台要求 body 是合法 JSONnull 会返 400);[line 70](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs#L70) `conf/get` 改用 `EmptyJsonBody`[line 91](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs#L91) `Deserialize` 改传 `JsonOpts`[line 116](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4AuthHelper.cs#L116) `Deserialize<Mc4LoginResponse>` 改传 `JsonOpts`;(2**[Mc4Adapter.cs:33-56](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L33-L56) 新增统一 `JsonOpts` 静态字段 + `DeserializeData<T>` 静态方法**——`DeserializeData``JsonSerializer.Deserialize<Mc4ApiResponse<T>>(json, JsonOpts)` 解析统一响应包装 + 自动校验 `code!=0` 抛异常 + `data` 为空返回默认值;[line 105-108](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L105-L108) 新增 `EmptyJsonBody`[line 90](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L90) `HealthCheckAsync` 改用 `EmptyJsonBody`[line 118](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L118) `GetObjectTreeAsync` 改用 `EmptyJsonBody` + `DeserializeData<List<Mc4TreeNode>>`[line 186/203/229/244/274/299](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L186-L299) `GetDevicesAsync/GetDevicePointsAsync/GetRealtimeValuesAsync/GetHisAlarmsAsync/GetMultiRealtimeValuesAsync/GetRealtimeAlarmsAsync` 全部改用 `DeserializeData<T>`;新增 `Mc4ApiResponse<T>` 统一响应包装类([line 388-394](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L388-L394))。**验证**`dotnet build gateway` 0 错误 0 警告。**效果**:(a)MC4 适配器所有接口反序列化均能正确处理全小写字段 + 统一包装响应;(b)`EmptyJsonBody` 解决 POST 无参 body=null 触发 400 的问题;(c`DeserializeData<T>` 统一处理 code 校验,未来新增 MC4 业务接口不用每次写 `if (code != 0) throw` 模板代码 | ✅ 已完成 |
| 2026-07-24 | **MC4 设备列表 400 + 反序列化错误 V1.10.1** | 主人反馈 V1.10 修完后又有 2 个连续报错:(a)`[Gateway] A3: 适配器 MC4:33ku 取设备失败: Response status code does not indicate success: 400 (Bad Request)`;(b`[Gateway] A3: 适配器 MC4:33ku 取设备失败: The JSON value could not be converted to System.Collections.Generic.List'1[IntegrationGateway.Adapters.MC4.Mc4TreeNode]. Path: $ | LineNumber: 0 | BytePositionInLine: 1.`。**根因 2 段**:(a**400 Bad Request**——`GetObjectTreeAsync``client.PostAsync("/api/central/object/tree", null)` 发请求,**body 为 null 不符合 MC4 平台要求**(平台要求 POST body 是合法 JSON,即使是空请求也必须是 `{}` 而非 `null`),**400 是平台校验失败**;(b)**反序列化 List 错误**——MC4 返回的是 `{code, msg, data:[...nodes]}` 包装结构,**List 不能直接反序列化为 List<Mc4TreeNode>**,必须先解析包装再取 data 段(V1.10 已经新增了 `DeserializeData<T>``GetObjectTreeAsync` 没改)。**整改方案**(共 1 文件改动):**[Mc4Adapter.cs:115-122](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L115-L122) GetObjectTreeAsync 改用 EmptyJsonBody + DeserializeData<List<Mc4TreeNode>>**——`var resp = await client.PostAsync("/api/central/object/tree", EmptyJsonBody);` 替换原来的 `null``var tree = DeserializeData<List<Mc4TreeNode>>(json, "/api/central/object/tree", new List<Mc4TreeNode>());` 替换原来的 `JsonSerializer.Deserialize<List<Mc4TreeNode>>(json, JsonOpts)!`。**验证**`dotnet build gateway` 0 错误 0 警告。**效果**:A3 设备同步能正确拉取 MC4 对象树 → 推送到 VolPro → 写 base_device 表,**主人在 web.vite 管理端可以看到 MC4 设备列表** | ✅ 已完成 |
| 2026-07-24 | **IoT 设备实时点值显示 + 空调控制 V1.11** | 主人反馈:"成功拿到设备列表并提交到了后端,但在管理端的列表里点击实时数据按钮没有任何数据显示,检查一下是什么问题,我看了下MC4设备的管理端,每个设备下面是有点值列表的,并且序号1的点是自动添加的在线点,真正的点值数据从序号2开始的,你查下文档看看怎么把正确的点值显示出来,并且有些设备不止一个点值的。同时IOT设备也需要进行分类,目前有三个分类:温度探头、湿度探头、空调控制器,这三类在后端需要不同的展示方式和控制方式你可以写点临时代码来获取一下192.168.3.92这个MC4设备的设备和点值数据,然后规划一下怎么在web.vite和warehouse中实现点值的显示和设备控制。"**整改方案**(共 5 文件改动 + 1 文档):(1)**[Mc4Adapter.cs:154](file:///d:/Code/SecMPS/gateway/src/IntegrationGateway.Adapters.MC4/Mc4Adapter.cs#L154) GetRealtimeValuesAsync 改用 DeserializeData**——修复实时点值接口反序列化问题(V1.10 漏改了 GetRealtimeValuesAsync,其他接口都改了唯独实时值没改);(2)**[base_device.vue:163-179](file:///d:/Code/SecMPS/web.vite/src/views/warehouse/device_manager/base_device.vue#L163-L179) fetchRealtime 增加 normalizePoint 字段映射**——网关 B4 返回 PascalCase 字段(PointIndex/Value/UpdateTime/Interval),前端 table 是 camelCase 列名(pointIndex/value/updateTime/interval),**之前直接 await r.json() 字段名不匹配导致表格空**;新增 `normalizePoint` 做 PascalCase→camelCase 映射 + `Array.isArray` 判断(防止 404/500 时 await r.json() 失败);(3**[RealtimeDataPanel.vue:19-37](file:///d:/Code/SecMPS/web.vite/src/views/warehouse/device_manager/base_device/components/RealtimeDataPanel.vue#L19-L37) 同样修复**——组件层字段映射(与 base_device.vue 一致);(4**[DeviceInfo.vue](file:///d:/Code/SecMPS/warehouse/src/view/DeviceInfo.vue) 完整改造**——改用 `/api/base_device/getPageData` 接口获取设备信息(之前调老接口 `/api/Warehouse_Device/GetPageData` 走的是 base_devicepoint 表,已废弃);按 DeviceCategory 分类展示(温度探头/湿度探头单大数字卡片 + 空调控制器双卡片);30 秒轮询实时点值(仅 IoT 设备);空调控制按钮修复——`sourceDeviceId` 改为 `deviceId`(与后端 `ControlRequest.DeviceId` 字段名一致);(5**[mc4_probe 探针工具](file:///d:/Code/SecMPS/tools/mc4_probe/Mc4Probe/Program.cs)**——独立 .NET 控制台程序,连接 192.168.3.92 真实 MC4 设备抓取设备列表 + 点表 + 实时值,便于主人后续调试点位索引(已写入实施文档附录);(6)**[IoT设备实时点值显示与控制实施方案_v1.0.md](file:///d:/Code/SecMPS/doc/整合方案/IoT设备实时点值显示与控制实施方案_v1.0.md)**——详细方案文档(设备分类/点位映射表/3 分类展示策略/网关 B4+B5 接口/前端 5 文件改动/验证清单/风险回滚/后续优化建议)。**关键设备点位索引语义**(写入实施文档固化):温度探头/湿度探头 `index=2` 是真实数据;空调控制器 `index=5=湿度/6=温度/2=制冷发射/3=制热发射/4=关机发射`MC4 自动在 `index=1` 添加"在线点"。**验证**`dotnet build gateway` 0 错误;`npm run build warehouse` / `npm run build web.vite` 待主人本地验证。**效果**:(a)管理端 IoT 设备的"实时数据"按钮点击后表格正常显示点位/当前值/更新时间/采集间隔 4 列;(b)大端地图点击温度探头→大数字显示温度℃;(c)大端地图点击湿度探头→大数字显示湿度%RH;(d)大端地图点击空调控制器→温度+湿度双卡片 + 控制按钮(制冷/制热/关机);(e)空调命令 3 秒后实时数据自动刷新(控制生效验证);(f)30 秒轮询保证实时数据保持最新 | ✅ 已完成 |
| 2026-07-24 | **RuleEngineService DI 注入失败修复 V1.12** | 主人反馈:后端 VS 启动报 `System.AggregateException: Some services are not able to be constructed (Error while validating the service descriptor 'ServiceType: Warehouse.Services.RuleEngineService ...': Unable to resolve service for type 'Warehouse.Services.iot_alarmService' while attempting to activate 'Warehouse.Services.RuleEngineService'.)`。**根因 2 段**:(1**iot_alarmService 通过框架的 IDependency 机制注册到内置 DI**——读 [AutofacContainerModuleExtension.cs:77-95](file:///d:/Code/SecMPS/api_sqlsugar/VolPro.Core/Extensions/AutofacManager/AutofacContainerModuleExtension.cs#L77-L95) 发现 `AddModule` 会扫描所有 IDependency 实现类,按 `serviceType.Length==1`(只实现 IDependency)走 `AddScoped(implementationType)` 注册具体类,否则按 `serviceType[0]`(第一个接口 = `Iiot_alarmService`)注册接口到具体类的映射。`iot_alarmService` 实现了 `Iiot_alarmService` + `IDependency` 两个接口,所以**只注册了 `Iiot_alarmService`****没有注册 `iot_alarmService` 具体类**;(2**RuleEngineService 构造函数按具体类注入**——[RuleEngineService.cs:54](file:///d:/Code/SecMPS/api_sqlsugar/Warehouse/Services/RuleEngineService.cs#L54) 第 4 个参数是 `iot_alarmService alarmService`(具体类),内置 DI 解析时报 "Unable to resolve service for type 'iot_alarmService'",整个 ServiceCollection 验证失败 → 整个 BuildServiceProvider 失败 → `var app = builder.Build()` 抛 AggregateException。**整改方案**(共 1 文件改动):**[RuleEngineService.cs:44-58](file:///d:/Code/SecMPS/api_sqlsugar/Warehouse/Services/RuleEngineService.cs#L44-L58) 构造函数参数 + 字段类型由 `iot_alarmService` 改为 `Iiot_alarmService`**——(a)字段 `_alarmService` 类型改 `Iiot_alarmService`;(b)构造函数参数 `alarmService` 类型改 `Iiot_alarmService`;(c`_alarmService = alarmService` 赋值语句不变(编译自动适配);(d)方法体内 `_alarmService.UpsertAlarmAsync(...)` 调用不变(`Iiot_alarmService` partial 接口已声明 `UpsertAlarmAsync`)。**选择"改构造函数按接口注入"而不是"在 Program.cs 显式 AddScoped<iot_alarmService, iot_alarmService>"**——后者会与框架 `AddModule` 的自动注册**重复注册**AutofacContainerModuleExtension 已经按接口注册了),**违反框架约定**;前者**符合 VolPro 框架惯例**`gateway_nodesController.cs:40`/`iot_alarmController.cs:15`/`iot_alarmController.cs:24` 全部用 `Iiot_alarmService` 接口注入)。**验证**`dotnet build api_sqlsugar` 0 错误。**效果**:(a`RuleEngineService` 构造函数 DI 解析成功 → `var app = builder.Build()` 不再抛异常 → 后端可正常启动;(b)Quartz 调度 `RuleEngineJob` 启动后每 10s 调一次 `RuleEngineService.EvaluateAllAsync()`;(c)规则触发"告警"动作时 `_alarmService.UpsertAlarmAsync` 可正确调用,**告警能落库** | ✅ 已完成 |
---