feat: 更新指标时同时更新单位

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -440,6 +440,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         Map<Object, Object> equipmentIndexKeyMap = redisUtils.hmget(RedisKey.EQUIP_INDEX_ADDRESS_KEY);
         if (equipmentIndexKeyMap.get(indexAddress) != null) {
             EquipmentSpecificIndex equipmentSpeIndex = equipmentSpecificIndexService.getEquipmentSpeIndexByAddress(indexAddress, null, null);
+            EquipmentIndex equipmentIndex = equipmentIndexService.getById(equipmentSpeIndex.getEquipmentIndexId());
 
             equipmentSpeIndex.setValue(value);
             equipmentSpeIndex.setValueLabel(valueTranslate(value, equipmentSpeIndex.getValueEnum()));
@@ -449,6 +450,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
             equipmentSpeIndex.setDataType(dataType);
             equipmentSpeIndex.setTimeStamp(timeStamp);
             equipmentSpeIndex.setUUID(UUIDUtils.getUUID());
+            equipmentSpeIndex.setUnit(Objects.nonNull(equipmentIndex.getUnit()) ? equipmentIndex.getUnit() : equipmentIndex.getUnitName());
 
             IotDataVO iotDataVO = new IotDataVO();
             iotDataVO.setKey(equipmentSpeIndex.getNameKey());
@@ -997,6 +999,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                     String value = iotDataVO.getValue().toString();
                     String traceId = iotDataVO.getTraceId();
                     equipmentSpeIndex.setValue(value);
+                    equipmentSpeIndex.setUnit(equipmentSpecificIndex.getIndexUnitName());
                     equipmentSpeIndex.setTraceId(traceId);
                     equipmentSpeIndex.setValueLabel(valueTranslate(value, equipmentSpecificIndex.getValueEnum()));
                     equipmentSpeIndex.setUpdateDate(new Date());