1.有组织废气污染物排放浓度监测数据统计表

2.废水污染物排放浓度监测数据统计表
3.（正常监测时段）超标率

szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/month/ExhaustExceedingProcessImpl.java

@@ -48,6 +48,8 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
     @Override
     public void exceededRateProcess() {
         List<SRaActionReportsAuditResult> queryActionReportsAuditResults = getAuditResultData();
+        if(CollUtil.isEmpty(queryActionReportsAuditResults)) return ;
+
         List<SRaActionReportsAuditResult> resultList = Lists.newArrayList();
         resultList.addAll(exhaustGasExceededRateProcess(queryActionReportsAuditResults));
         resultList.addAll(exhaustWaterExceededRateProcess(queryActionReportsAuditResults));
@@ -59,6 +61,7 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
     @Override
     public void exhaustGasEmissionProcess() {
         List<SRaActionReportsAuditResult> queryActionReportsAuditResults = getAuditResultData();
+        if(CollUtil.isEmpty(queryActionReportsAuditResults)) return;
         auditResultChange(gasEmissionProcess(queryActionReportsAuditResults));
     }
 
@@ -66,15 +69,19 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
         List<SRaActionReportsAuditResult> resultList = Lists.newArrayList();
         List<String> factoryIdList = queryActionReportsAuditResults.stream().map(SRaActionReportsAuditResult::getFactoryId).collect(Collectors.toList());
         List<BStatTableZxbgGasEmission> dataList = getDataList(factoryIdList);
+        if(CollUtil.isEmpty(dataList)) return Lists.newArrayList();
         Set<String> outletCodes = dataList.stream().map(BStatTableZxbgGasEmission::getOutletCode).collect(Collectors.toSet());
         List<SEnvGasMonRealVo.EmissionAvgAndMax> emissionAvgAndMaxes = sEnvGasMonRealMapper.selectEmissionAvgAndMax(DateUtil.format(DateUtil.getFirstDayOfMonth(-1), "yyyy-MM-dd HH:mm:ss")
                 , DateUtil.format(DateUtil.getLastDayOfMonth(-1), "yyyy-MM-dd HH:mm:ss"), outletCodes);
+        if(CollUtil.isEmpty(emissionAvgAndMaxes)) return Lists.newArrayList();
         Map<String, SEnvGasMonRealVo.EmissionAvgAndMax> emissionAvgAndMaxMap = emissionAvgAndMaxes.stream().collect(Collectors.toMap(SEnvGasMonRealVo.EmissionAvgAndMax::getOutletId, o -> o));
         for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
             checkGasMaxAndAvg(emissionAvgAndMaxMap, dataList, resultList, queryActionReportsAuditResult);
         }
         for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
             Map<String, BigDecimal> emissionDataMap = getGasEmissionDataMap(factoryIdList, dataList);
+            if(CollUtil.isEmpty(emissionDataMap))break;
+
             checkExceededData(dataList, resultList, queryActionReportsAuditResult, emissionDataMap,"根据有组织废气污染物超标时段小时均值报表中填报的数据",false);
         }
 
@@ -156,15 +163,20 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
         List<SRaActionReportsAuditResult> resultList = Lists.newArrayList();
         List<String> factoryIdList = queryActionReportsAuditResults.stream().map(SRaActionReportsAuditResult::getFactoryId).collect(Collectors.toList());
         List<BStatTableZxbgGasEmission> dataList = getDataList(factoryIdList);
+        if(CollUtil.isEmpty(dataList)) return Lists.newArrayList();
+
         Set<String> outletCodes = dataList.stream().map(BStatTableZxbgGasEmission::getOutletCode).collect(Collectors.toSet());
         List<FactoryOutletStaticsVo.EmissionAvgAndMax> emissionAvgAndMaxes = sEnvWaterMonDayMapper.selectEmissionAvgAndMax(DateUtil.format(DateUtil.getFirstDayOfMonth(-1), "yyyy-MM-dd HH:mm:ss")
                 , DateUtil.format(DateUtil.getLastDayOfMonth(-1), "yyyy-MM-dd HH:mm:ss"), outletCodes);
+        if(CollUtil.isEmpty(emissionAvgAndMaxes)) return Lists.newArrayList();
+
         Map<String, FactoryOutletStaticsVo.EmissionAvgAndMax> emissionAvgAndMaxMap = emissionAvgAndMaxes.stream().collect(Collectors.toMap(FactoryOutletStaticsVo.EmissionAvgAndMax::getOutletId, o -> o));
         for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
             checkWaterMaxAndAvg(emissionAvgAndMaxMap, dataList, resultList, queryActionReportsAuditResult);
         }
         for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
             Map<String, BigDecimal> emissionDataMap = getGasEmissionDataMap(factoryIdList, dataList);
+            if(CollUtil.isEmpty(emissionDataMap))break;
             checkExceededData(dataList, resultList, queryActionReportsAuditResult, emissionDataMap,"根据废水污染物超标时段日均值报表中填报的数据",true);
         }
 
@@ -234,6 +246,7 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
     @Override
     public void exhaustWaterEmissionProcess() {
         List<SRaActionReportsAuditResult> queryActionReportsAuditResults = getAuditResultData();
+        if(CollUtil.isEmpty(queryActionReportsAuditResults)) return;
         auditResultChange(waterEmissionProcess(queryActionReportsAuditResults));
     }
 
@@ -256,7 +269,12 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
     private List<SRaActionReportsAuditResult> exhaustWaterExceededRateProcess(List<SRaActionReportsAuditResult> queryActionReportsAuditResults) {
         List<String> factoryIdList = queryActionReportsAuditResults.stream().map(SRaActionReportsAuditResult::getFactoryId).collect(Collectors.toList());
         List<BStatTableZxbgGasEmission> dataList = getDataList(factoryIdList);
+        if(CollUtil.isEmpty(dataList)) return Lists.newArrayList();
+
         Map<String, BigDecimal> emissionDataMap = getWaterEmissionDataMap(factoryIdList, dataList);
+
+        if(CollUtil.isEmpty(emissionDataMap)) return Lists.newArrayList();
+
         List<SRaActionReportsAuditResult> resultList = Lists.newArrayList();
         for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
             fifterExceedingData(queryActionReportsAuditResult, dataList, resultList, emissionDataMap);
@@ -267,7 +285,12 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
     private List<SRaActionReportsAuditResult> exhaustGasExceededRateProcess(List<SRaActionReportsAuditResult> queryActionReportsAuditResults) {
         List<String> factoryIdList = queryActionReportsAuditResults.stream().map(SRaActionReportsAuditResult::getFactoryId).collect(Collectors.toList());
         List<BStatTableZxbgGasEmission> dataList = getDataList(factoryIdList);
+        if(CollUtil.isEmpty(dataList)) return Lists.newArrayList();
+
         Map<String, BigDecimal> emissionDataMap = getGasEmissionDataMap(factoryIdList, dataList);
+
+        if(CollUtil.isEmpty(emissionDataMap)) return Lists.newArrayList();
+
         List<SRaActionReportsAuditResult> resultList = Lists.newArrayList();
         for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
             fifterExceedingData(queryActionReportsAuditResult, dataList, resultList, emissionDataMap);