预警阈值相关 单位问题处理

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

 package com.yeejoin.equipmanage.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.equipmanage.common.entity.EquipmentSpecificIndex;
@@ -76,7 +78,7 @@ public class MqttWarningReceiveServiceImpl implements MqttWaringReceiveService {
             List<EquipmentSpecificIndex> indexList = equipmentSpecificIndexService
                     .getEquipmentSpeIndexBySpeIotCode(messageObj.get("iot_code").toString());
             List<EquipmentSpecificIndex> collect = indexList.stream().filter(item -> !ObjectUtils.isEmpty(item.getNameKey()) && item.getNameKey().equalsIgnoreCase(messageObj.get(REALTIME_IOT_INDEX_KEY).toString())).collect(Collectors.toList());
-            equipmentSpeIndex.setUnit(CollUtil.isNotEmpty(collect) ? collect.get(0).getUnit() : "m");
+            equipmentSpeIndex.setUnit(CollUtil.isNotEmpty(collect) && ObjectUtil.isNotEmpty(collect.get(0)) && StrUtil.isNotEmpty(collect.get(0).getUnit()) ? collect.get(0).getUnit() : "m");
             isAlarmFlag(equipmentSpeIndex, iotDataVO);
         } catch (Exception e) {
             e.printStackTrace();