feat: There is no way the, UPDNONEXISTENT_nameEn (只支持文本查询接口,维护ES 英文字段不存在的数据)
This commit is contained in:
@@ -25,7 +25,7 @@ public class SearchCenter {
|
|||||||
@ApiModelProperty(value = "执行参数 ALL 存在更新 不存在新增 ,UPD 只 更新存在 es 里的标准 ,ADD 只新增不存在 es 的标准," +
|
@ApiModelProperty(value = "执行参数 ALL 存在更新 不存在新增 ,UPD 只 更新存在 es 里的标准 ,ADD 只新增不存在 es 的标准," +
|
||||||
" DEL 只删除不存在标准库的数据(删除只能用DEL 减少自动错删)," +
|
" DEL 只删除不存在标准库的数据(删除只能用DEL 减少自动错删)," +
|
||||||
"UPDNONEXISTENT (只支持文本查询接口)更新不存在字段业务数据(其他任务导致ES不同步), UPDNONEXISTENT_TEXTSTATUS (只支持文本查询接口,文本状态高亮字段不同步重置)," +
|
"UPDNONEXISTENT (只支持文本查询接口)更新不存在字段业务数据(其他任务导致ES不同步), UPDNONEXISTENT_TEXTSTATUS (只支持文本查询接口,文本状态高亮字段不同步重置)," +
|
||||||
"UPDNONEXISTENT_nameEn (只支持文本查询接口,维护ES 英文字段不存在的数据)")
|
"UPDNONEXISTENT_NAMEEN (只支持文本查询接口,维护ES 英文字段不存在的数据)")
|
||||||
private String execType;
|
private String execType;
|
||||||
|
|
||||||
@NotNull
|
@NotNull
|
||||||
|
|||||||
@@ -1165,7 +1165,7 @@ public class ResetSearchCenterService {
|
|||||||
}
|
}
|
||||||
}).collect(Collectors.toList());
|
}).collect(Collectors.toList());
|
||||||
esIdList = filterList.stream().map(stringObjectMap -> stringObjectMap.get("id").toString()).collect(Collectors.toList());
|
esIdList = filterList.stream().map(stringObjectMap -> stringObjectMap.get("id").toString()).collect(Collectors.toList());
|
||||||
}else if("UPDNONEXISTENT_nameEn".equals(searchCenter.getExecType().toUpperCase())){
|
}else if("UPDNONEXISTENT_NAMEEN".equals(searchCenter.getExecType().toUpperCase())){
|
||||||
List<Map<String, Object>> filterList = searchListData.stream().filter(stringObjectMap -> {
|
List<Map<String, Object>> filterList = searchListData.stream().filter(stringObjectMap -> {
|
||||||
if(stringObjectMap.get("nameEnTitle") == null){
|
if(stringObjectMap.get("nameEnTitle") == null){
|
||||||
return true;
|
return true;
|
||||||
@@ -1221,7 +1221,8 @@ public class ResetSearchCenterService {
|
|||||||
|
|
||||||
if(!updList.isEmpty() && ("ALL".equals(searchCenter.getExecType().toUpperCase()) || "UPD".equals(searchCenter.getExecType().toUpperCase())
|
if(!updList.isEmpty() && ("ALL".equals(searchCenter.getExecType().toUpperCase()) || "UPD".equals(searchCenter.getExecType().toUpperCase())
|
||||||
|| "UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase())
|
|| "UPDNONEXISTENT".equals(searchCenter.getExecType().toUpperCase())
|
||||||
|| "UPDNONEXISTENT_TEXTSTATUS".equals(searchCenter.getExecType().toUpperCase()))){
|
|| "UPDNONEXISTENT_TEXTSTATUS".equals(searchCenter.getExecType().toUpperCase())
|
||||||
|
|| "UPDNONEXISTENT_NAMEEN".equals(searchCenter.getExecType().toUpperCase()))){
|
||||||
for(SarBussionessStand sarBussionessStandEO : updList){
|
for(SarBussionessStand sarBussionessStandEO : updList){
|
||||||
countUpdateSuccess++;
|
countUpdateSuccess++;
|
||||||
bussAttrInfoShowSearchDetails(sarBussionessStandEO);
|
bussAttrInfoShowSearchDetails(sarBussionessStandEO);
|
||||||
|
|||||||
Reference in New Issue
Block a user