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

fix: 修复同步搜索中心数据同步接口BUG

Browse Source
This commit is contained in:
zhangyanduan
2022-03-18 15:37:14 +08:00
parent a6bef4be76
commit 3c8cb14e32
1 changed files with 2 additions and 2 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
+2 -2
View File
@@ -313,7 +313,7 @@ public class ResetSearchCenterService {
sarStandardsInfo.setSarStandAttrEOStr(JSONObject.toJSONString(sarStandardsInfo.getAttrInfoMap())); sarStandardsInfo.setSarStandAttrEOStr(JSONObject.toJSONString(sarStandardsInfo.getAttrInfoMap()));
} }
Map<String, Object> indexstate = elasticsearchService.searchDataById("stand","stand",standId,null); Map<String, Object> indexstate = elasticsearchService.searchDataById("stand","stand",standId,null);
if(!indexstate.isEmpty()){ if(indexstate!=null && !indexstate.isEmpty()){
createStandMQService.sendStandMQ(sarStandardsInfo,"update"); createStandMQService.sendStandMQ(sarStandardsInfo,"update");
}else{ }else{
createStandMQService.sendStandMQ(sarStandardsInfo,"add"); createStandMQService.sendStandMQ(sarStandardsInfo,"add");
@@ -336,7 +336,7 @@ public class ResetSearchCenterService {
sarBussionessStand.setSarStandAttrEOStr(JSONObject.toJSONString(sarBussionessStand.getAttrInfoMap())); sarBussionessStand.setSarStandAttrEOStr(JSONObject.toJSONString(sarBussionessStand.getAttrInfoMap()));
} }
Map<String, Object> indexstate = elasticsearchService.searchDataById("bussstand","bussstand",standId,null); Map<String, Object> indexstate = elasticsearchService.searchDataById("bussstand","bussstand",standId,null);
if(!indexstate.isEmpty()){ if(indexstate!=null && !indexstate.isEmpty()){
createStandMQService.sendBussStandMQ(sarBussionessStand,"update"); createStandMQService.sendBussStandMQ(sarBussionessStand,"update");
}else{ }else{
createStandMQService.sendBussStandMQ(sarBussionessStand,"add"); createStandMQService.sendBussStandMQ(sarBussionessStand,"add");