diff --git a/adc-da-slrs/src/main/java/com/adc/da/search/server/ResetSearchCenterService.java b/adc-da-slrs/src/main/java/com/adc/da/search/server/ResetSearchCenterService.java index fd7cd9e0..eeb2ec26 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/search/server/ResetSearchCenterService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/search/server/ResetSearchCenterService.java @@ -642,7 +642,7 @@ public class ResetSearchCenterService { for(SarStandardsInfo sarStandardsInfoEO : updList){ countUpdateSuccess++; standFunc(sarStandardsInfoEO); -// createStandMQService.sendStandMQ(sarStandardsInfoEO,"update"); + createStandMQService.sendStandMQ(sarStandardsInfoEO,"update"); } } @@ -653,12 +653,12 @@ public class ResetSearchCenterService { if (sarStandardsInfoEO.getAttrInfoMap() != null) { sarStandardsInfoEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarStandardsInfoEO.getAttrInfoMap())); } -// createStandMQService.sendStandMQ(sarStandardsInfoEO,"add"); + createStandMQService.sendStandMQ(sarStandardsInfoEO,"add"); } } if(!delList.isEmpty() && !"sync".equals(page.getSyncParam()) && ("DEL".equals(searchCenter.getExecType().toUpperCase()) || "ALL".equals(searchCenter.getExecType().toUpperCase()))){ -// elasticsearchService.deleteBatchId(delList,"stand"); -// elasticsearchService.deleteBatchId(delList,"fulltextserch"); + elasticsearchService.deleteBatchId(delList,"stand"); + elasticsearchService.deleteBatchId(delList,"fulltextserch"); logger.info("重置国内外标准:删除-共"+delList.size()+"条数据"); }else{ logger.info("重置国内外标准:没有删除数据,但应该删除"+delList.size()+"条数据"); @@ -1206,7 +1206,7 @@ public class ResetSearchCenterService { if (sarLawsInfoEO.getAttrInfoMap() != null) { sarLawsInfoEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarLawsInfoEO.getAttrInfoMap())); } -// createStandMQService.sendLawsMQ(sarLawsInfoEO,"update"); + createStandMQService.sendLawsMQ(sarLawsInfoEO,"update"); } } @@ -1236,13 +1236,13 @@ public class ResetSearchCenterService { if (sarLawsInfoEO.getAttrInfoMap() != null) { sarLawsInfoEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarLawsInfoEO.getAttrInfoMap())); } -// createStandMQService.sendLawsMQ(sarLawsInfoEO,"add"); + createStandMQService.sendLawsMQ(sarLawsInfoEO,"add"); } } if(!delList.isEmpty() && !"sync".equals(sarLawsInfoEOPage.getSyncParam()) && ("DEL".equals(searchCenter.getExecType().toUpperCase()) || "ALL".equals(searchCenter.getExecType().toUpperCase()))){ -// elasticsearchService.deleteBatchId(delList,"laws"); -// elasticsearchService.deleteBatchId(delList,"fulltextserch"); + elasticsearchService.deleteBatchId(delList,"laws"); + elasticsearchService.deleteBatchId(delList,"fulltextserch"); logger.info("重置国内外政策:删除-共"+delList.size()+"条数据"); }else{ logger.info("重置国内外政策:没有删除数据,但应该删除"+delList.size()+"条数据");