Files
sipaiis_datacollector/.trae/documents/在GIS_Job中加入和达流量计计算点位推送.md

56 lines
1.9 KiB
Markdown
Raw Permalink Normal View History

2026-01-29 17:06:01 +08:00
## 变更目标
*`com.sipai.schedule.GIS_Job.jobGIS` 的 SQL WHERE 过滤中,加入 6 个新计算点位的精确匹配,使其随既有点位一起下发到管网平台。
* 新增点位:`KCGW_53564_A8``KCGW_53564_A7``KCGW_53564_P1``KCGW_53581_A8``KCGW_53581_A7``KCGW_53581_P1`
## 代码位置
* 文件:`src/main/java/com/sipai/schedule/GIS_Job.java`
* 方法:`jobGIS`
* 现有 SQL 拼接区间:`GIS_Job.java:427-436`
## 具体改动
* 在现有两条和达设备前缀过滤之后、分号之前,按既有格式追加以下条件:
```
" OR id = 'KCGW_53564_A8'\n" +
" OR id = 'KCGW_53564_A7'\n" +
" OR id = 'KCGW_53564_P1'\n" +
" OR id = 'KCGW_53581_A8'\n" +
" OR id = 'KCGW_53581_A7'\n" +
" OR id = 'KCGW_53581_P1'\n" +
```
* 保持原有 `LIKE 'KCGW_22008_53564_%'``LIKE 'KCGW_22029_53581_%'` 不变,避免影响既有轮询点位推送。
## 实现步骤
* 编辑 `sql` 字符串,追加上述 6 行 `OR id = '...'` 条件,保留末尾分号。
* 不改动其他逻辑(查询、组装 JSON、MQTT 发送)。
## 校验与验证
* 在本地运行 `jobGIS` 定时任务或手动触发同路径查询,确认 `mPointService.selectListByWhere(sql)` 返回集合包含新增 6 点位(可在日志或调试中检视)。
* 观察 MQTT 推送内容(主题 `CommString.Mqtt_Topic_DATA`)是否包含对应 `mpcode` 与最新值/时间。
* 关注日志输出与异常堆栈,确保无 SQL 拼接格式错误。
## 兼容性与命名一致性
* 新增 ID 与 `HD_Job` 中计算点位编码一致:`KCGW_<meterId>_<A8/A7/P1>`
* 不影响既有 `SignalTag``P1_DAY/HOUR``KCGW_15001_A1_*` 等过滤。
## 风险与回退
* 若后续计算点位命名规范调整,需同步更新此处精确匹配。
* 若管网平台不需要这 6 个点位,可直接移除新增的 `OR id = '...'` 条件回退。