diff --git a/adc-da-slrs/src/main/java/com/adc/da/search/ResetSearchCenterController.java b/adc-da-slrs/src/main/java/com/adc/da/search/ResetSearchCenterController.java index e7f6f901..76c49725 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/search/ResetSearchCenterController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/search/ResetSearchCenterController.java @@ -86,21 +86,19 @@ public class ResetSearchCenterController extends BaseController indexstate = elasticsearchService.searchDataById("stand","stand",standId,null); + if(!indexstate.isEmpty()){ createStandMQService.sendStandMQ(sarStandardsInfo,"update"); + }else{ + createStandMQService.sendStandMQ(sarStandardsInfo,"add"); } } } @@ -326,7 +327,7 @@ public class ResetSearchCenterService { * 同步添加企业标准搜索中心数据内容 * @param standId */ - public void syncBussStandSearchCenterData(String standId,boolean addOrUp) throws Exception { + public void syncBussStandSearchCenterData(String standId) throws Exception { if(StringUtils.isNotBlank(standId)){ SarBussionessStand sarBussionessStand = iSarBussionessStandService.selectStandardsInfoByKey(standId); logger.debug("本次处理的标准信息:"+JSONObject.toJSONString(sarBussionessStand)); @@ -334,10 +335,11 @@ public class ResetSearchCenterService { if (sarBussionessStand.getAttrInfoMap() != null) { sarBussionessStand.setSarStandAttrEOStr(JSONObject.toJSONString(sarBussionessStand.getAttrInfoMap())); } - if(addOrUp){ - createStandMQService.sendBussStandMQ(sarBussionessStand,"add"); - }else{ + Map indexstate = elasticsearchService.searchDataById("bussstand","bussstand",standId,null); + if(!indexstate.isEmpty()){ createStandMQService.sendBussStandMQ(sarBussionessStand,"update"); + }else{ + createStandMQService.sendBussStandMQ(sarBussionessStand,"add"); } } }