From 9110119a4c3fe671742571c0afed5193b7e75dbb Mon Sep 17 00:00:00 2001 From: hehongyu Date: Sat, 12 Aug 2023 20:12:22 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B6=85=E6=A0=87=E6=8E=92=E6=94=BE=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=20=E9=99=84=E5=9B=BE=E9=99=84=E4=BB=B6-=E8=87=AA?= =?UTF-8?q?=E8=A1=8C=E7=9B=91=E6=B5=8B=E5=B8=83=E7=82=B9=E5=9B=BE=20?= =?UTF-8?q?=E6=B1=A1=E6=9F=93=E7=89=A9=E5=AE=9E=E9=99=85=E6=8E=92=E6=94=BE?= =?UTF-8?q?=E8=AE=A1=E7=AE=97=E8=BF=87=E7=A8=8B=20=E5=8F=B0=E8=B4=A6?= =?UTF-8?q?=E7=AE=A1=E7=90=86=E6=83=85=E5=86=B5=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../audit/ExecuteReportAuditService.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) 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