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:
CD
2022-12-22 13:32:42 +08:00
parent 9e55631f4c
commit 09864c36f9
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
adc-da-slrs/src/main/java/com/adc/da/search/server/ResetSearchCenterServiceTemp.java
+4 -4
View File
@@ -238,7 +238,7 @@ public class ResetSearchCenterServiceTemp {
for(SarStandardsInfo sarStandardsInfoEO : updList){
countUpdateSuccess++;
standFunc(sarStandardsInfoEO);
// createStandMQService.sendStandMQ(sarStandardsInfoEO,"update");
createStandMQService.sendStandMQ(sarStandardsInfoEO,"update");
}
}
@@ -249,7 +249,7 @@ public class ResetSearchCenterServiceTemp {
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()))){
@@ -544,7 +544,7 @@ public class ResetSearchCenterServiceTemp {
if (sarBussionessStandEO.getAttrInfoMap() != null) {
sarBussionessStandEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarBussionessStandEO.getAttrInfoMap()));
}
// createStandMQService.sendBussStandMQ(sarBussionessStandEO,"update");
createStandMQService.sendBussStandMQ(sarBussionessStandEO,"update");
}
}
@@ -555,7 +555,7 @@ public class ResetSearchCenterServiceTemp {
if (sarBussionessStandEO.getAttrInfoMap() != null) {
sarBussionessStandEO.setSarStandAttrEOStr(JSONObject.toJSONString(sarBussionessStandEO.getAttrInfoMap()));
}
// createStandMQService.sendBussStandMQ(sarBussionessStandEO,"add");
createStandMQService.sendBussStandMQ(sarBussionessStandEO,"add");
}
}