diff --git a/securitycontrol-commons/securitycontrol-commons-core/src/main/java/com/securitycontrol/common/core/constant/Constant.java b/securitycontrol-commons/securitycontrol-commons-core/src/main/java/com/securitycontrol/common/core/constant/Constant.java index a4e37cb..400c43e 100644 --- a/securitycontrol-commons/securitycontrol-commons-core/src/main/java/com/securitycontrol/common/core/constant/Constant.java +++ b/securitycontrol-commons/securitycontrol-commons-core/src/main/java/com/securitycontrol/common/core/constant/Constant.java @@ -58,6 +58,13 @@ public class Constant { public final static String TG = "停工"; public final static String ONLINE = "1"; + public final static String AIR_QUALITY = "PM2.5,PM10"; + public final static String NOISE_LEVEL= "噪声"; + public final static String GRAY_LAYER = "二氧化碳"; + public final static String WARN = "1"; + public final static String NOT_WARN = "0"; + + public final static String[] BUILD_ARR = {"12A0,合肥","12B0,马鞍山","12C0,芜湖","12D0,安庆","12F0,淮南", diff --git a/securitycontrol-model/securitycontrol-background/src/main/java/com/securitycontrol/background/service/impl/DeviceOfBdServiceImpl.java b/securitycontrol-model/securitycontrol-background/src/main/java/com/securitycontrol/background/service/impl/DeviceOfBdServiceImpl.java index b73a7ee..8a716a7 100644 --- a/securitycontrol-model/securitycontrol-background/src/main/java/com/securitycontrol/background/service/impl/DeviceOfBdServiceImpl.java +++ b/securitycontrol-model/securitycontrol-background/src/main/java/com/securitycontrol/background/service/impl/DeviceOfBdServiceImpl.java @@ -216,10 +216,6 @@ public class DeviceOfBdServiceImpl implements IDeviceOfBdService { if (StringUtils.isNotBlank(validResult)) { return AjaxResult.error(validResult); } - int result = mapper.isBdDeviceDetailExist(vo); - if (result > 0) { - return AjaxResult.error("设备级联编码不能重复"); - } if (StringUtils.isEmpty(vo.getId())) { String id = IdUtils.getUUId(); vo.setId(id); diff --git a/securitycontrol-model/securitycontrol-screen/src/main/java/com/securitycontrol/screen/service/impl/ScIndexServiceImpl.java b/securitycontrol-model/securitycontrol-screen/src/main/java/com/securitycontrol/screen/service/impl/ScIndexServiceImpl.java index 4b4ca6c..f8041aa 100644 --- a/securitycontrol-model/securitycontrol-screen/src/main/java/com/securitycontrol/screen/service/impl/ScIndexServiceImpl.java +++ b/securitycontrol-model/securitycontrol-screen/src/main/java/com/securitycontrol/screen/service/impl/ScIndexServiceImpl.java @@ -6,6 +6,7 @@ import com.securitycontrol.common.core.web.domain.AjaxResult; import com.securitycontrol.entity.screen.dto.ScreenParamDto; import com.securitycontrol.entity.screen.vo.ConstrQuality; import com.securitycontrol.entity.screen.vo.MapRiskVo; +import com.securitycontrol.entity.system.SystemGlobal; import com.securitycontrol.screen.mapper.IScIndexMapper; import com.securitycontrol.screen.service.IScIndexService; import lombok.extern.slf4j.Slf4j; @@ -138,23 +139,46 @@ public class ScIndexServiceImpl implements IScIndexService { @Override public AjaxResult environmentDetection(ScreenParamDto dto) { + Map map = new HashMap<>(6); List> list = new ArrayList<>(); + List> dataMapList = new ArrayList<>(); + // 空气质量 正常/异常 噪声水平 正常/异常 灰层浓度 正常/异常 + int aqiNormalNum = 0, aqiErrorNum = 0, dbNormalNum = 0, dbErrorNum = 0, hcNormalNum = 0, hcErrorNum = 0; try { + dto.setTypeCode(SystemGlobal.HJ_TYPE); list = mapper.environmentDetection(dto); - if (CollectionUtils.isEmpty(list)) { - Map map = new HashMap<>(6); - map.put("aqiNormalNum", 0); - map.put("aqiErrorNum", 0); - map.put("dbNormalNum", 0); - map.put("dbErrorNum", 0); - map.put("hcNormalNum", 0); - map.put("hcErrorNum", 0); - list.add(map); + if (CollectionUtils.isNotEmpty(list)) { + for (Map dataMap : list) { + if (Objects.nonNull(dataMap.get("modelName"))) { + String modelName = String.valueOf(dataMap.get("modelName")); + String warn = String.valueOf(dataMap.get("warn")); + if (Constant.NOISE_LEVEL.contains(modelName) && Objects.equals(warn, Constant.NOT_WARN)) { + dbNormalNum++; + } else if (Constant.NOISE_LEVEL.contains(modelName) && Objects.equals(warn, Constant.WARN)) { + dbErrorNum++; + }else if (Constant.AIR_QUALITY.contains(modelName) && Objects.equals(warn, Constant.NOT_WARN)) { + aqiNormalNum++; + }else if (Constant.AIR_QUALITY.contains(modelName) && Objects.equals(warn, Constant.WARN)) { + aqiErrorNum++; + }else if (Constant.GRAY_LAYER.contains(modelName) && Objects.equals(warn, Constant.NOT_WARN)) { + hcNormalNum++; + }else if (Constant.GRAY_LAYER.contains(modelName) && Objects.equals(warn, Constant.WARN)) { + hcErrorNum++; + } + } + } } } catch (Exception e) { log.error("环境监测分析", e); } - return AjaxResult.success(list); + map.put("aqiNormalNum", aqiNormalNum); + map.put("aqiErrorNum", aqiErrorNum); + map.put("dbNormalNum", dbNormalNum); + map.put("dbErrorNum", dbErrorNum); + map.put("hcNormalNum", hcNormalNum); + map.put("hcErrorNum", hcErrorNum); + dataMapList.add(map); + return AjaxResult.success(dataMapList); } @Override diff --git a/securitycontrol-model/securitycontrol-screen/src/main/resources/mapper/ScIndexMapper.xml b/securitycontrol-model/securitycontrol-screen/src/main/resources/mapper/ScIndexMapper.xml index faaa6cc..ce517c9 100644 --- a/securitycontrol-model/securitycontrol-screen/src/main/resources/mapper/ScIndexMapper.xml +++ b/securitycontrol-model/securitycontrol-screen/src/main/resources/mapper/ScIndexMapper.xml @@ -56,24 +56,19 @@