parent
d7ccc8a74c
commit
9110119a4c
|
@ -30,12 +30,11 @@ public class ExecuteReportAuditService {
|
||||||
final LedgerManagementStatusTableService ledgerManagementStatusTableService;
|
final LedgerManagementStatusTableService ledgerManagementStatusTableService;
|
||||||
|
|
||||||
public void audit(List<String> executeReportIds){
|
public void audit(List<String> executeReportIds){
|
||||||
//执行报表分批次进行
|
//执行报表分批次进行 暂定10个报告一批
|
||||||
List<List<String>> partitionIds = Lists.partition(executeReportIds, 10);
|
List<List<String>> partitionIds = Lists.partition(executeReportIds, 10);
|
||||||
for (List<String> partitionExecuteReportIds : partitionIds) {
|
for (List<String> partitionExecuteReportIds : partitionIds) {
|
||||||
//执行所有审核任务
|
//执行所有审核任务
|
||||||
try {
|
try {
|
||||||
//TODO 性能 可以利用线程池同时执行 策略为CallerRunsPolicy
|
|
||||||
execute(partitionExecuteReportIds);
|
execute(partitionExecuteReportIds);
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
log.error("执行审核相关任务错误 executeReportIds:{}", executeReportIds, e);
|
log.error("执行审核相关任务错误 executeReportIds:{}", executeReportIds, e);
|
||||||
|
@ -45,7 +44,16 @@ public class ExecuteReportAuditService {
|
||||||
|
|
||||||
|
|
||||||
public void execute(List<String> reportIds){
|
public void execute(List<String> reportIds){
|
||||||
|
//TODO 性能 可以利用线程池同时执行 策略为CallerRunsPolicy 用来执行比较耗时的任务
|
||||||
|
|
||||||
//所有的审核任务 需要将方法手动添加到此处!!!
|
//所有的审核任务 需要将方法手动添加到此处!!!
|
||||||
|
//序号 67 超标排放信息
|
||||||
|
excessiveEmissionsService.execute(reportIds); //比较耗时
|
||||||
|
//序号 68 附图附件-自行监测布点图
|
||||||
selfMonitoringLayoutMapService.execute(reportIds);
|
selfMonitoringLayoutMapService.execute(reportIds);
|
||||||
|
//序号 69 污染物实际排放计算过程
|
||||||
|
pollutantEmissionsCalculationProcessService.execute(reportIds);
|
||||||
|
//序号 70 台账管理情况表
|
||||||
|
ledgerManagementStatusTableService.execute(reportIds);
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue