From 850d74eb78ddd431d052893dff57800a3a7bc8ff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=A2=81=E7=90=A6=E6=B6=9B?= Date: Fri, 8 Dec 2023 14:16:44 +0800 Subject: [PATCH] fix:79161 --- .../laws/home/service/impl/LawsHomeSearchServiceImpl.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/laws-modules/src/main/java/com/jero/modules/laws/home/service/impl/LawsHomeSearchServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/laws/home/service/impl/LawsHomeSearchServiceImpl.java index ccf44be0..3d49b73e 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/home/service/impl/LawsHomeSearchServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/laws/home/service/impl/LawsHomeSearchServiceImpl.java @@ -941,6 +941,12 @@ public class LawsHomeSearchServiceImpl implements ILawsHomeSearchService { log.info("================ES更新数据开始================="); ForkJoinPool pool = new ForkJoinPool(); CompletableFuture.runAsync(()->{ + try { + Thread.sleep(3000); + } catch (InterruptedException e) { + e.printStackTrace(); + Thread.currentThread().interrupt(); + } try{ switch (resourceType){ case LawsHomeSearchCommon.LAWS_DOMESTIC_STANDARD: @@ -1356,6 +1362,7 @@ public class LawsHomeSearchServiceImpl implements ILawsHomeSearchService { JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(map, SerializerFeature.WriteMapNullValue)); try { jeroElasticsearchTemplate.saveOrUpdate(HomeSearchEnum.INDEX_NAME_DOCUMENT_ZQ.getValue(), HomeSearchEnum.TYPE_NAME_DOCUMENT_ZQ.getValue(), idTemp, jsonObject); + log.info("==============更新es成功================"); } catch (Exception e) { log.error("文档库添加es失败",e); }