From 2819969c3da6f37e926f670f6a05ce1f664a2e3c Mon Sep 17 00:00:00 2001 From: "583641232@qq.com" <583641232@qq.com> Date: Tue, 30 Jul 2024 18:16:28 +0800 Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E6=97=A5=E5=B8=B8=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E5=AD=97=E6=AE=B5=E6=9F=A5=E8=AF=A2=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=EF=BC=8C=E6=A1=88=E4=BB=B6=E5=90=88=E5=B9=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../inscloudtech/datacenter/service/QueryCenterService.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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()); }