From 80387fa6f34f9d79ee47c0c9d86d054cbc72a5c9 Mon Sep 17 00:00:00 2001 From: "583641232@qq.com" <583641232@qq.com> Date: Wed, 31 Jul 2024 11:43:39 +0800 Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E6=95=B0=E6=8D=AE=E7=BB=9F?= =?UTF-8?q?=E4=B8=80=E5=88=A0=E9=99=A4=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datacenter/service/QueryCenterService.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) 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 6622559..b783f09 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 @@ -581,7 +581,7 @@ public class QueryCenterService { // if(null == query.getCaseId()){ // throw new RuntimeException("案件id不能为空！"); // } -// String indexName = query.getIndex(); + String index = query.getIndex(); // if(StrUtil.isEmpty(indexName)){ // throw new RuntimeException("[业务模块]不能为空！"); // } @@ -596,19 +596,19 @@ public class QueryCenterService { }else if(StrUtil.isNotEmpty(query.getAnalysisResultId())){ queryBuilder = QueryBuilders.termQuery("analysisResultId", query.getAnalysisResultId()); } - DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest(indexName); + DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest(index); deleteRequest.setQuery(queryBuilder); // 启用刷新操作 deleteRequest.setRefresh(true); BulkByScrollResponse response = restHighLevelClient.deleteByQuery(deleteRequest, RequestOptions.DEFAULT); long deletedCount = response.getDeleted(); - if(!unNeedDeleteMysql.contains(indexName)){ - this.deleteMysqlData(indexName,query.getCaseId()); + if(!unNeedDeleteMysql.contains(index)){ + this.deleteMysqlData(index,query.getCaseId()); } - if(indexName.equals("dc_other_information")){ + if(index.equals("dc_other_information")){ sysOssService.deleteByCaseIdAndBusinessModule(query.getCaseId(),"OTHER_INFORMATION"); - }else if(indexName.equals("dc_other_assets")){ + }else if(index.equals("dc_other_assets")){ sysOssService.deleteByCaseIdAndBusinessModule(query.getCaseId(),"OTHER_ASSETS"); }