From 6a796e036a4e19b4cb80dfe306192198c3f06de6 Mon Sep 17 00:00:00 2001
From: liao <liao@syxysoft.com>
Date: Wed, 29 Nov 2023 09:08:39 +0800
Subject: [PATCH] =?UTF-8?q?update=20asms=E5=90=8C=E6=AD=A5es=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../asms/service/impl/LawsAsmsOpenApiServiceImpl.java     | 7 +++++++
 .../asms/service/impl/SynchronizationAsmsService.java     | 8 ++++++++
 2 files changed, 15 insertions(+)

diff --git a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
index 10be01c8..1a122485 100644
--- a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
+++ b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
@@ -20,6 +20,8 @@ import com.jero.modules.docking.asms.util.AlphanumericComparator;
 import com.jero.modules.docking.asms.util.AsmsPostUtil;
 import com.jero.modules.laws.documenttool.entity.LawsDocumentSplit;
 import com.jero.modules.laws.documenttool.mapper.LawsDocumentSplitMapper;
+import com.jero.modules.laws.home.common.LawsHomeSearchCommon;
+import com.jero.modules.laws.home.service.ILawsHomeSearchService;
 import com.jero.modules.laws.standard.entity.LawsDomesticStandard;
 import com.jero.modules.laws.standard.service.ILawsDomesticStandardService;
 import com.jero.modules.laws.standard.service.ILawsReplacedStandardService;
@@ -49,6 +51,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import java.io.InputStream;
 import java.text.ParseException;
@@ -99,6 +102,8 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
 	private IOSSFileService ossFileService;
 	@Autowired
 	private ISysDictService sysDictService;
+	@Resource
+	private ILawsHomeSearchService lawsHomeSearchService;
 
 	private final static String filePath = "asms/";
 	private static SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
@@ -508,6 +513,8 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
 					// 更新时间
 					lawsDomesticStandard.setUpdateTime(getSimpleDate2(lawsAsmsDomestic.getUpdateTimeString()));
 					lawsDomesticStandardService.saveOrUpdate(lawsDomesticStandard);
+					// 同步es数据库
+					lawsHomeSearchService.updateEsData(LawsHomeSearchCommon.LAWS_DOMESTIC_STANDARD, lawsDomesticStandard.getId(), LawsHomeSearchCommon.LAWS_ES_ADD);
 				});
 				// 状态设置为已同步
 				lawsAsmsOpenApi.setStatus("1");
diff --git a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/SynchronizationAsmsService.java b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/SynchronizationAsmsService.java
index ea1c8c4e..6c06afc8 100644
--- a/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/SynchronizationAsmsService.java
+++ b/laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/SynchronizationAsmsService.java
@@ -14,6 +14,8 @@ import com.jero.modules.laws.common.util.DateUtil;
 import com.jero.modules.laws.documenttool.entity.LawsDocumentSplit;
 import com.jero.modules.laws.documenttool.mapper.LawsDocumentSplitMapper;
 import com.jero.modules.laws.documenttool.service.IDocumentSplitService;
+import com.jero.modules.laws.home.common.LawsHomeSearchCommon;
+import com.jero.modules.laws.home.service.ILawsHomeSearchService;
 import com.jero.modules.laws.standard.entity.LawsDomesticStandard;
 import com.jero.modules.laws.standard.service.ILawsDomesticStandardService;
 import com.jero.modules.laws.standard.service.ILawsReplacedStandardService;
@@ -41,6 +43,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
+import javax.annotation.Resource;
 import java.io.InputStream;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
@@ -83,6 +86,8 @@ public class SynchronizationAsmsService {
     private ISarFileSplitItemsValEOService sarFileSplitItemsValEOService;
     @Autowired
     private ILawsReplacedStandardService lawsReplacedStandardService;
+    @Resource
+    private ILawsHomeSearchService lawsHomeSearchService;
     @Autowired
     private IOSSFileService ossFileService;
     @Autowired
@@ -243,6 +248,9 @@ public class SynchronizationAsmsService {
         });
         // 插入国内法规标准数据库
         lawsDomesticStandardService.saveBatch(insertDomesticList, insertDomesticList.size());
+        // 同步es数据库
+        insertDomesticList.forEach(e ->
+                lawsHomeSearchService.updateEsData(LawsHomeSearchCommon.LAWS_DOMESTIC_STANDARD, e.getId(), LawsHomeSearchCommon.LAWS_ES_ADD));
         long time1 = System.currentTimeMillis();
         log.info("=====================同步国内法规标准数据：{}条，耗时：{}毫秒=====================", insertDomesticList.size(), time1 - start);