feat: There is no way the, UPDNONEXISTENT_nameEn (只支持文本查询接口,维护ES 英文字段不存在的数据)

2022-06-28 14:35:06 +08:00
parent 0ea7f77dba
commit bd487d08ad
2 changed files with 11 additions and 1 deletions
@@ -24,7 +24,8 @@ public class SearchCenter {
    @NotNull
    @ApiModelProperty(value = "执行参数 ALL 存在更新 不存在新增 ,UPD 只 更新存在 es 里的标准 ,ADD 只新增不存在 es 的标准," +
            " DEL 只删除不存在标准库的数据（删除只能用DEL 减少自动错删）," +
-            "UPDNONEXISTENT (只支持文本查询接口)更新不存在字段业务数据（其他任务导致ES不同步）, UPDNONEXISTENT_TEXTSTATUS (只支持文本查询接口,文本状态高亮字段不同步重置)")
+            "UPDNONEXISTENT (只支持文本查询接口)更新不存在字段业务数据（其他任务导致ES不同步）, UPDNONEXISTENT_TEXTSTATUS (只支持文本查询接口,文本状态高亮字段不同步重置)," +
+            "UPDNONEXISTENT_nameEn (只支持文本查询接口,维护ES 英文字段不存在的数据)")
    private String execType;

    @NotNull
@@ -1165,6 +1165,15 @@ public class ResetSearchCenterService {
                }
            }).collect(Collectors.toList());
            esIdList = filterList.stream().map(stringObjectMap -> stringObjectMap.get("id").toString()).collect(Collectors.toList());
+        }else if("UPDNONEXISTENT_nameEn".equals(searchCenter.getExecType().toUpperCase())){
+            List<Map<String, Object>> filterList = searchListData.stream().filter(stringObjectMap -> {
+                if(stringObjectMap.get("nameEnTitle") == null){
+                    return true;
+                }else {
+                    return false;
+                }
+            }).collect(Collectors.toList());
+            esIdList = filterList.stream().map(stringObjectMap -> stringObjectMap.get("id").toString()).collect(Collectors.toList());
        }else {
            esIdList = searchListData.stream().map(stringObjectMap -> stringObjectMap.get("id").toString()).collect(Collectors.toList());
        }