修改动环设备面板接口

soc-modules/soc-modules-iot/src/main/java/com/xunmei/iot/service/impl/IotBoardServiceImpl.java

@@ -29,6 +29,8 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.stream.Collectors;
 
+import static com.xunmei.system.api.enums.ElectricityMeterAttributes.METER_ATTRIBUTES_4;
+
 @Service
 public class IotBoardServiceImpl implements IotBoardService {
     @Autowired
@@ -145,21 +147,20 @@ public class IotBoardServiceImpl implements IotBoardService {
         List<Map<String, Object>> resultList = new ArrayList<>();
         SysOrg org = remoteOrgService.selectOrgById(orgId, SecurityConstants.INNER);
         List<IotSensor> list = sensorService.selectSensorListByOrgPath(org.getPath());
+        HashMap<String, Object> map = new HashMap<>();
+        dataMap.put("sensor", map);
+        dataMap.put("resultData", resultList);
         if (ObjectUtil.isEmpty(list)) {
+            map.put("key", "传感器设备");
+            map.put("sensorNums", list.size());
+            map.put("normal", 0);
+            map.put("alarm", 0);
             return dataMap;
         }
-        //默认为正常
-        list.forEach(r -> {
-            if (ObjectUtil.isNull(r.getState())) {
-                r.setState(0);
-            }
-        });
-        HashMap<String, Object> map = new HashMap<>();
         map.put("key", "传感器设备");
         map.put("sensorNums", list.size());
         map.put("normal", 0);
         map.put("alarm", 0);
-        dataMap.put("sensor", map);
         Map<Integer, Long> collect = list.stream().collect(Collectors.groupingBy(IotSensor::getState, Collectors.counting()));
         collect.forEach((k, v) -> {
             if (ObjectUtil.equal(0, k)) {
@@ -170,6 +171,8 @@ public class IotBoardServiceImpl implements IotBoardService {
             }
         });
         List<IotAlarmData> alarmDataList = alarmDataService.selectAlarmDataListByOrgPath(org.getPath(), 0);
+        //屏蔽红外
+        alarmDataList.removeIf(d ->ObjectUtil.equal(METER_ATTRIBUTES_4.getText(),d.getSourceTypeDes()));
         Map<Object, List<IotAlarmData>> dataList = alarmDataList.stream().collect(Collectors.groupingBy(IotAlarmData::getSourceType));
         for (Map.Entry<Object, List<IotAlarmData>> listEntry : dataList.entrySet()) {
             List<IotAlarmData> value = listEntry.getValue();
@@ -182,7 +185,6 @@ public class IotBoardServiceImpl implements IotBoardService {
             hashMap.put("unDealAlarm", unDealAlarm);
             resultList.add(hashMap);
         }
-        dataMap.put("resultData", resultList);
         return dataMap;
     }
 }

soc-modules/soc-modules-iot/src/main/resources/mapper/IotSensorMapper.xml

@@ -132,7 +132,7 @@
 
     <select id="selectListSensor" resultType="com.xunmei.common.core.domain.iot.domain.IotSensor">
         SELECT
-        *
+        *,ifnull(a.state,0) as state
         FROM
         iot_sensor a
         where  a.org_path like  concat(#{orgPath},'%') and a.deleted=0