diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsManifestEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsManifestEOServiceImpl.java index d9b838895..ab57f651d 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsManifestEOServiceImpl.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsManifestEOServiceImpl.java @@ -241,10 +241,10 @@ public class ParamsManifestEOServiceImpl extends ServiceImpl updateEs() { + this.problemKnowledgeBaseEOService.updateEs(); + return Result.OK("更新成功!"); + } + } diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/IProblemKnowledgeBaseEOService.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/IProblemKnowledgeBaseEOService.java index 276f32100..7306bc8a0 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/IProblemKnowledgeBaseEOService.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/IProblemKnowledgeBaseEOService.java @@ -17,6 +17,13 @@ import java.util.List; */ public interface IProblemKnowledgeBaseEOService extends IService { + /** + * 知识分享更新ES + * + * @return + */ + void updateEs(); + /** * 保存 * diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/impl/ProblemKnowledgeBaseEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/impl/ProblemKnowledgeBaseEOServiceImpl.java index dbf4ed2dc..cb7cba3b0 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/impl/ProblemKnowledgeBaseEOServiceImpl.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/problemKnowledgeBase/service/impl/ProblemKnowledgeBaseEOServiceImpl.java @@ -115,6 +115,27 @@ public class ProblemKnowledgeBaseEOServiceImpl extends ServiceImpl list = this.list(); + log.error("知识分享更新ES==开始==总数:" + list.size()); + for (ProblemKnowledgeBaseEO problemKnowledgeBaseEO : list) { + if (StringUtils.equals(problemKnowledgeBaseEO.getReleaseStatus(), ReleaseStatusEnum.HAVE_RELEASED.getValue())) { + this.addOrUpdateElasticsearch(problemKnowledgeBaseEO); + index++; + } + } + log.error("知识分享更新ES==结束==更新数量:" + index); + } + + /** * 保存 * diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/controller/LawsMonthlyReportManageEOController.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/controller/LawsMonthlyReportManageEOController.java index dcaf92ed1..3b3a516db 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/controller/LawsMonthlyReportManageEOController.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/controller/LawsMonthlyReportManageEOController.java @@ -190,4 +190,12 @@ public class LawsMonthlyReportManageEOController extends JeroController updateES() { + lawsMonthlyReportManageEOService.updateES(); + return Result.OK("操作成功"); + } + + + } diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/service/ILawsMonthlyReportManageEOService.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/service/ILawsMonthlyReportManageEOService.java index cc0d078a2..165392bb5 100644 --- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/service/ILawsMonthlyReportManageEOService.java +++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/report/service/ILawsMonthlyReportManageEOService.java @@ -72,6 +72,6 @@ public interface ILawsMonthlyReportManageEOService extends IService list = this.list(); + log.error("法规月报更新ES==开始==总数:" + list.size()); + for (LawsMonthlyReportManageEO lmr : list) { + if (ObjectUtils.isNotEmpty(lmr) && "1".equals(lmr.getIssueStatus())) { + syncElasticsearch(lmr.getId(),"2",lmr.getUpdateTime()); + syncElasticsearch(lmr.getId(),"1",lmr.getUpdateTime()); + index++; + } + } + log.error("法规月报更新ES==结束==更新数量:" + index); + } + + + private void syncElasticsearch(String id, String issueStatus, Date issueTime) { LawsMonthlyReportManageEO monthlyReportManageEO = getById(id);