✨ 数据统一删除接口

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