From 3f1e3f71aa5830fd3d73d2018d537e1d8453806d Mon Sep 17 00:00:00 2001
From: zhangjun <879913833@qq.com>
Date: Thu, 13 Oct 2022 09:28:38 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E7=BD=AE=E7=B4=A2=E5=BC=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../search/server/ResetSearchCenterService.java  | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

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()+"条数据");