lixu
/
tang_shan_task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

2.废水污染物排放浓度监测数据统计表
3.（正常监测时段）超标率
main
Frank 2023-08-13 17:25:27 +08:00
parent fed1645e31
commit 477fb56289
2 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -75,14 +75,15 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
}
for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
Map<String, BigDecimal> emissionDataMap = getGasEmissionDataMap(factoryIdList, dataList);
checkExceededData(dataList, resultList, queryActionReportsAuditResult, emissionDataMap,"根据有组织废气污染物超标时段小时均值报表中填报的数据");
checkExceededData(dataList, resultList, queryActionReportsAuditResult, emissionDataMap,"根据有组织废气污染物超标时段小时均值报表中填报的数据",false);
}
return resultList;
}
private void checkExceededData(List<BStatTableZxbgGasEmission> dataList, List<SRaActionReportsAuditResult> resultList,
SRaActionReportsAuditResult queryActionReportsAuditResult, Map<String, BigDecimal> emissionDataMap,String message) {
SRaActionReportsAuditResult queryActionReportsAuditResult, Map<String, BigDecimal> emissionDataMap,
String message,boolean isWater) {
for (BStatTableZxbgGasEmission statTableZxbgGasEmission : dataList) {
String pollutantName = statTableZxbgGasEmission.getPollutantName();
String exceededData = statTableZxbgGasEmission.getExceededData();
@ -93,8 +94,13 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
if (new BigDecimal(exceededData).compareTo(multiply) != 0) {
SRaActionReportsAuditResult sRaActionReportsAuditResult = new SRaActionReportsAuditResult();
sRaActionReportsAuditResult.setId(queryActionReportsAuditResult.getId());
if (isWater) {
sRaActionReportsAuditResult.setWaterMonitoringData(message + "，" + statTableZxbgGasEmission.getOutletCode() +
pollutantName + "超标数据数量应为" + multiply + ",企业填报数据为" + exceededData + "数据不符。");
} else {
sRaActionReportsAuditResult.setOrganizedGasMonitoringData(message + "，" + statTableZxbgGasEmission.getOutletCode() +
pollutantName + "超标数据数量应为" + multiply + ",企业填报数据为" + exceededData + "数据不符。");
}
resultList.add(sRaActionReportsAuditResult);
}
}
@ -136,7 +142,7 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
}
SRaActionReportsAuditResult sRaActionReportsAuditResult = new SRaActionReportsAuditResult();
sRaActionReportsAuditResult.setId(queryActionReportsAuditResult.getId());
sRaActionReportsAuditResult.setWaterPreventionFacilities(allMessage.toString());
sRaActionReportsAuditResult.setOrganizedGasMonitoringData(allMessage.toString());
resultList.add(sRaActionReportsAuditResult);
}
}
@ -159,7 +165,7 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
}
for (SRaActionReportsAuditResult queryActionReportsAuditResult : queryActionReportsAuditResults) {
Map<String, BigDecimal> emissionDataMap = getGasEmissionDataMap(factoryIdList, dataList);
checkExceededData(dataList, resultList, queryActionReportsAuditResult, emissionDataMap,"根据废水污染物超标时段日均值报表中填报的数据");
checkExceededData(dataList, resultList, queryActionReportsAuditResult, emissionDataMap,"根据废水污染物超标时段日均值报表中填报的数据",true);
}
return resultList;
@ -197,7 +203,7 @@ public class ExhaustExceedingProcessImpl implements ExhaustExceedingProcessServi
}
SRaActionReportsAuditResult sRaActionReportsAuditResult = new SRaActionReportsAuditResult();
sRaActionReportsAuditResult.setId(queryActionReportsAuditResult.getId());
sRaActionReportsAuditResult.setWaterPreventionFacilities(allMessage.toString());
sRaActionReportsAuditResult.setWaterMonitoringData(allMessage.toString());
resultList.add(sRaActionReportsAuditResult);
}
}

4
szhpt-fixed-task/src/main/java/cn/cecep/talroad/task/ExecuteReportController.java
View File

@ -35,8 +35,8 @@ public class ExecuteReportController {
@Autowired
private AnomalyAnalysisService anomalyAnalysisService;
private final ExhaustExceedingProcessService exhaustExceedingProcessService;
@Autowired
private ExhaustExceedingProcessService exhaustExceedingProcessService;