FT/foton-slrs-system-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

重置索引

Browse Source
This commit is contained in:
zhangjun
2022-10-13 09:28:38 +08:00
parent d0e7a5f96f
commit 3f1e3f71aa
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
adc-da-slrs/src/main/java/com/adc/da/search/server/ResetSearchCenterService.java
+8 -8
View File
@@ -642,7 +642,7 @@ public class ResetSearchCenterService {
for(SarStandardsInfo sarStandardsInfoEO : updList){ for(SarStandardsInfo sarStandardsInfoEO : updList){
countUpdateSuccess++; countUpdateSuccess++;
standFunc(sarStandardsInfoEO); standFunc(sarStandardsInfoEO);
// createStandMQService.sendStandMQ(sarStandardsInfoEO,"update"); createStandMQService.sendStandMQ(sarStandardsInfoEO,"update");
} }
} }
@@ -653,12 +653,12 @@ public class ResetSearchCenterService {
if (sarStandardsInfoEO.getAttrInfoMap() != null) { if (sarStandardsInfoEO.getAttrInfoMap() != null) {
sarStandardsInfoEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarStandardsInfoEO.getAttrInfoMap())); 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()))){ if(!delList.isEmpty() && !"sync".equals(page.getSyncParam()) && ("DEL".equals(searchCenter.getExecType().toUpperCase()) || "ALL".equals(searchCenter.getExecType().toUpperCase()))){
// elasticsearchService.deleteBatchId(delList,"stand"); elasticsearchService.deleteBatchId(delList,"stand");
// elasticsearchService.deleteBatchId(delList,"fulltextserch"); elasticsearchService.deleteBatchId(delList,"fulltextserch");
logger.info("重置国内外标准：删除-共"+delList.size()+"条数据"); logger.info("重置国内外标准：删除-共"+delList.size()+"条数据");
}else{ }else{
logger.info("重置国内外标准：没有删除数据，但应该删除"+delList.size()+"条数据"); logger.info("重置国内外标准：没有删除数据，但应该删除"+delList.size()+"条数据");
@@ -1206,7 +1206,7 @@ public class ResetSearchCenterService {
if (sarLawsInfoEO.getAttrInfoMap() != null) { if (sarLawsInfoEO.getAttrInfoMap() != null) {
sarLawsInfoEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarLawsInfoEO.getAttrInfoMap())); 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) { if (sarLawsInfoEO.getAttrInfoMap() != null) {
sarLawsInfoEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarLawsInfoEO.getAttrInfoMap())); 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()))){ if(!delList.isEmpty() && !"sync".equals(sarLawsInfoEOPage.getSyncParam()) && ("DEL".equals(searchCenter.getExecType().toUpperCase()) || "ALL".equals(searchCenter.getExecType().toUpperCase()))){
// elasticsearchService.deleteBatchId(delList,"laws"); elasticsearchService.deleteBatchId(delList,"laws");
// elasticsearchService.deleteBatchId(delList,"fulltextserch"); elasticsearchService.deleteBatchId(delList,"fulltextserch");
logger.info("重置国内外政策：删除-共"+delList.size()+"条数据"); logger.info("重置国内外政策：删除-共"+delList.size()+"条数据");
}else{ }else{
logger.info("重置国内外政策：没有删除数据，但应该删除"+delList.size()+"条数据"); logger.info("重置国内外政策：没有删除数据，但应该删除"+delList.size()+"条数据");