diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/SynProjectCollectionTask.java b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/SynProjectCollectionTask.java index 7b2d8de..b4b415d 100644 --- a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/SynProjectCollectionTask.java +++ b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/task/SynProjectCollectionTask.java @@ -121,23 +121,12 @@ public class SynProjectCollectionTask { log.info("项目归集库存转换PDF任务开始====="); StopWatch stopWatch = new StopWatch(); stopWatch.start(); - ProjectListReq req = new ProjectListReq(); - req.setPageNumber(1); - req.setPageSize(BizConst.MAX_EXPORT_COUNT); - List projects = applyService.list(Wrappers.lambdaQuery(GovBizProjectApply.class) - .eq(GovBizProjectApply::getDeleted,Boolean.FALSE) - .eq(StringUtils.isNotBlank(projId),GovBizProjectApply::getBaseProjId,projId) - .isNotNull(GovBizProjectApply::getBaseProjBasisFile) - .isNull(GovBizProjectApply::getBaseProjBasisFilePdf)); - - if(CollUtil.isEmpty(projects)){ - log.info("没有项目归集 任务终止"); - return; - } - for(GovBizProjectApply project : projects){ + GovBizProjectBaseinfo base = baseinfoService.getOne(Wrappers.lambdaQuery(GovBizProjectBaseinfo.class) + .eq(GovBizProjectBaseinfo::getBaseProjId, projId)); + if(Objects.nonNull(base)){ //开始转换PDF - convertPdfVo(project.getBaseProjId()); + convertPdfVo(projId); } stopWatch.stop();