Commit e66c69932f873709fd85df62ccbbcf5662cf2cf4
1 parent
824a801b
【功能完善】IoT: 更新设备属性映射逻辑,新增对 device_key 字段的处理
Showing
1 changed file
with
1 additions
and
1 deletions
yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/dal/tdengine/IotDevicePropertyMapper.java
| @@ -34,7 +34,7 @@ public interface IotDevicePropertyMapper { | @@ -34,7 +34,7 @@ public interface IotDevicePropertyMapper { | ||
| 34 | List<TDengineTableField> newFields) { | 34 | List<TDengineTableField> newFields) { |
| 35 | // TODO @芋艿:需要处理 device_key,重新发布的时候 | 35 | // TODO @芋艿:需要处理 device_key,重新发布的时候 |
| 36 | oldFields.removeIf(field -> StrUtil.equalsAny(field.getField(), | 36 | oldFields.removeIf(field -> StrUtil.equalsAny(field.getField(), |
| 37 | - TDengineTableField.FIELD_TS, "report_time")); | 37 | + TDengineTableField.FIELD_TS, "report_time", "device_key")); |
| 38 | List<TDengineTableField> addFields = newFields.stream().filter( // 新增的字段 | 38 | List<TDengineTableField> addFields = newFields.stream().filter( // 新增的字段 |
| 39 | newField -> oldFields.stream().noneMatch(oldField -> oldField.getField().equals(newField.getField()))) | 39 | newField -> oldFields.stream().noneMatch(oldField -> oldField.getField().equals(newField.getField()))) |
| 40 | .collect(Collectors.toList()); | 40 | .collect(Collectors.toList()); |