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

变更目标

• 在 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 = '...' 条件回退。