feat: There is no way the, xxx
This commit is contained in:
@@ -24,7 +24,7 @@ public class SearchCenter {
|
||||
@NotNull
|
||||
@ApiModelProperty(value = "执行参数 ALL 存在更新 不存在新增 ,UPD 只 更新存在 es 里的标准 ,ADD 只新增不存在 es 的标准," +
|
||||
" DEL 只删除不存在标准库的数据(删除只能用DEL 减少自动错删)," +
|
||||
"UPDATENONEXISTENT (只支持文本查询接口)更新不存在字段业务数据(其他任务导致ES不同步)")
|
||||
"UPDNONEXISTENT (只支持文本查询接口)更新不存在字段业务数据(其他任务导致ES不同步)")
|
||||
private String execType;
|
||||
|
||||
@NotNull
|
||||
|
||||
@@ -264,7 +264,7 @@ public class ResetSearchCenterService {
|
||||
|
||||
List<Map<String, Object>> searchListData = elasticsearchService.searchAll("fulltextserch",search);
|
||||
List<String> esIdList = new ArrayList<>();
|
||||
if("UPDATENONEXISTENT".equals(searchCenter.getExecType().toUpperCase())){
|
||||
if("UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase())){
|
||||
List<Map<String, Object>> filterList = searchListData.stream().filter(stringObjectMap -> {
|
||||
if(stringObjectMap.get("standTypeOrder") == null){
|
||||
return true;
|
||||
@@ -315,7 +315,7 @@ public class ResetSearchCenterService {
|
||||
}
|
||||
|
||||
if(!updList.isEmpty() && ("ALL".equals(searchCenter.getExecType().toUpperCase()) || "UPD".equals(searchCenter.getExecType().toUpperCase())
|
||||
|| "UPDATENONEXISTENT".equals(searchCenter.getExecType().toUpperCase()))){
|
||||
|| "UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase()))){
|
||||
for(SarStandardsInfo sarStandardsInfoEO : updList){
|
||||
countUpdateSuccess++;
|
||||
standFunc(sarStandardsInfoEO);
|
||||
@@ -536,7 +536,7 @@ public class ResetSearchCenterService {
|
||||
List<Map<String, Object>> searchListData = elasticsearchService.searchAll("fulltextserch",search);
|
||||
|
||||
List<String> esIdList = new ArrayList<>();
|
||||
if("UPDATENONEXISTENT".equals(searchCenter.getExecType().toUpperCase())){
|
||||
if("UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase())){
|
||||
List<Map<String, Object>> filterList = searchListData.stream().filter(stringObjectMap -> {
|
||||
if(stringObjectMap.get("standTypeOrder") == null){
|
||||
return true;
|
||||
@@ -587,7 +587,7 @@ public class ResetSearchCenterService {
|
||||
}
|
||||
|
||||
if(!updList.isEmpty() && ("ALL".equals(searchCenter.getExecType().toUpperCase()) || "UPD".equals(searchCenter.getExecType().toUpperCase())
|
||||
|| "UPDATENONEXISTENT".equals(searchCenter.getExecType().toUpperCase()))){
|
||||
|| "UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase()))){
|
||||
for(SarLawsStandInfo sarLawsInfoEO : updList){
|
||||
countUpdateSuccess++;
|
||||
lawsAttrInfoShowSearchDetails(sarLawsInfoEO);
|
||||
@@ -868,7 +868,7 @@ public class ResetSearchCenterService {
|
||||
List<Map<String, Object>> searchListData = elasticsearchService.searchAll("fulltextserch",search);
|
||||
|
||||
List<String> esIdList = new ArrayList<>();
|
||||
if("UPDATENONEXISTENT".equals(searchCenter.getExecType().toUpperCase())){
|
||||
if("UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase())){
|
||||
List<Map<String, Object>> filterList = searchListData.stream().filter(stringObjectMap -> {
|
||||
if(stringObjectMap.get("standTypeOrder") == null){
|
||||
return true;
|
||||
@@ -923,7 +923,7 @@ public class ResetSearchCenterService {
|
||||
}
|
||||
|
||||
if(!updList.isEmpty() && ("ALL".equals(searchCenter.getExecType().toUpperCase()) || "UPD".equals(searchCenter.getExecType().toUpperCase())
|
||||
|| "UPDATENONEXISTENT".equals(searchCenter.getExecType().toUpperCase()))){
|
||||
|| "UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase()))){
|
||||
for(SarBussionessStand sarBussionessStandEO : updList){
|
||||
countUpdateSuccess++;
|
||||
bussAttrInfoShowSearchDetails(sarBussionessStandEO);
|
||||
|
||||
Reference in New Issue
Block a user