battery-business/src/main/java/com/battery/business/mapper/TDeviceIngestRecordMapper.java
@@ -19,6 +19,13 @@ /** 心跳行按来源唯一,用 upsert 覆盖接收时间:它承载"取数程序还在推"这一条事实。 */ int upsertHeartbeat(TDeviceIngestRecord record); /** * 拓扑行是**声明**而不是设备事实,按来源通道唯一并刷新声明内容: * 重复上报补上来源自己的通道号时不追加新行,也不需要把已声明过的通道清掉重来。 * 设备数据行(SAMPLE)仍然只追加、不改写。 */ int upsertTopology(TDeviceIngestRecord record); /** 返回该来源行已落库的内容摘要(小写十六进制);没有这一行时为空。 */ String selectIngestRecordHashByKey(@Param("adapterCode") String adapterCode, @Param("payloadKind") String payloadKind, @Param("recordKey") String recordKey);