diff --git a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/ExecuteReportAuditService.java b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/ExecuteReportAuditService.java index d132944..bde3a88 100644 --- a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/ExecuteReportAuditService.java +++ b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/ExecuteReportAuditService.java @@ -30,12 +30,11 @@ public class ExecuteReportAuditService { final LedgerManagementStatusTableService ledgerManagementStatusTableService; public void audit(List executeReportIds){ - //执行报表分批次进行 + //执行报表分批次进行 暂定10个报告一批 List> partitionIds = Lists.partition(executeReportIds, 10); for (List partitionExecuteReportIds : partitionIds) { //执行所有审核任务 try { - //TODO 性能 可以利用线程池同时执行 策略为CallerRunsPolicy execute(partitionExecuteReportIds); }catch (Exception e){ log.error("执行审核相关任务错误 executeReportIds:{}", executeReportIds, e); @@ -45,7 +44,16 @@ public class ExecuteReportAuditService { public void execute(List reportIds){ + //TODO 性能 可以利用线程池同时执行 策略为CallerRunsPolicy 用来执行比较耗时的任务 + //所有的审核任务 需要将方法手动添加到此处!!! + //序号 67 超标排放信息 + excessiveEmissionsService.execute(reportIds); //比较耗时 + //序号 68 附图附件-自行监测布点图 selfMonitoringLayoutMapService.execute(reportIds); + //序号 69 污染物实际排放计算过程 + pollutantEmissionsCalculationProcessService.execute(reportIds); + //序号 70 台账管理情况表 + ledgerManagementStatusTableService.execute(reportIds); } } \ No newline at end of file