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"); }