ZQ/laws-sinotruk-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update asms同步es数据库

Browse Source
This commit is contained in:
liao
2023-11-29 09:08:39 +08:00
parent 6a0aac55a3
commit 6a796e036a
2 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/LawsAsmsOpenApiServiceImpl.java
+7
View File
@@ -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");
laws-modules-docking/src/main/java/com/jero/modules/docking/asms/service/impl/SynchronizationAsmsService.java
+8
View File
@@ -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);