diff --git a/laws-modules/src/main/java/com/jero/modules/laws/home/job/HomeSearchCheckEsPlanJob.java b/laws-modules/src/main/java/com/jero/modules/laws/home/job/HomeSearchCheckEsPlanJob.java index 5708727d..38715cb3 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/home/job/HomeSearchCheckEsPlanJob.java +++ b/laws-modules/src/main/java/com/jero/modules/laws/home/job/HomeSearchCheckEsPlanJob.java @@ -62,6 +62,16 @@ public class HomeSearchCheckEsPlanJob implements Job { List listType = getList(resourceType); Map mapHash = getTypeCount(); listType.parallelStream().forEach(p->{ + // 删除数据 + JSONObject jsonQuery = new JSONObject(); + JSONObject jsonTerm = new JSONObject(); + JSONObject jsonField = new JSONObject(); + JSONObject jsonValue = new JSONObject(); + jsonValue.put("value",p); + jsonField.put("resource_type",jsonValue); + jsonTerm.put("term",jsonField); + jsonQuery.put("query",jsonTerm); + jeroElasticsearchTemplate.delete(HomeSearchEnum.INDEX_NAME_DOCUMENT_ZQ.getValue(), HomeSearchEnum.TYPE_NAME_DOCUMENT_ZQ.getValue(), jsonQuery); switch (p){ // 比对国内标准 case LawsHomeSearchCommon.LAWS_DOMESTIC_STANDARD: