diff --git a/cas-system/src/main/java/com/inscloudtech/datacenter/service/QueryCenterService.java b/cas-system/src/main/java/com/inscloudtech/datacenter/service/QueryCenterService.java index 37cf082..ef6fed4 100644 --- a/cas-system/src/main/java/com/inscloudtech/datacenter/service/QueryCenterService.java +++ b/cas-system/src/main/java/com/inscloudtech/datacenter/service/QueryCenterService.java @@ -573,6 +573,9 @@ public class QueryCenterService { return searchSourceBuilder; } + + String unNeedDeleteMysql = "dc_plate_number,dc_collection_information"; + @SneakyThrows public Long deleteDataByCondition(QueryCenterQuery query) { if(null == query.getCaseId()){ @@ -595,7 +598,7 @@ public class QueryCenterService { deleteRequest.setRefresh(true); BulkByScrollResponse response = restHighLevelClient.deleteByQuery(deleteRequest, RequestOptions.DEFAULT); long deletedCount = response.getDeleted(); - if(!indexName.equals("dc_plate_number") || !indexName.equals("dc_collection_information")){ + if(!unNeedDeleteMysql.contains(indexName)){ this.deleteMysqlData(indexName,query.getCaseId()); }