|
|
@ -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()); |
|
|
|
} |
|
|
|
|
|
|
|