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 b783f09..dbb26d9 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 @@ -602,7 +602,7 @@ public class QueryCenterService { deleteRequest.setRefresh(true); BulkByScrollResponse response = restHighLevelClient.deleteByQuery(deleteRequest, RequestOptions.DEFAULT); long deletedCount = response.getDeleted(); - if(!unNeedDeleteMysql.contains(index)){ + if(!unNeedDeleteMysql.contains(index) && StrUtil.isNotEmpty(query.getCaseId())){ this.deleteMysqlData(index,query.getCaseId()); } diff --git a/cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java b/cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java index 8a8c5d5..ee0e8c8 100644 --- a/cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java +++ b/cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java @@ -1552,7 +1552,10 @@ public class BankServiceImpl implements BankService { // 等待任务完成 sw.stop(); sw.getTotalTimeSeconds(); - log.error("流水导入结束耗时【"+sw.getTotalTimeSeconds()+"】秒"); + long sizeInBytes = mf.getSize(); // 获取文件大小,单位为字节 + double sizeInMB = (double) sizeInBytes / (1024 * 1024); // 转换为兆字节 + + log.error("流水文件大小【{}】MB,导入结束耗时【{}】秒",sizeInMB,sw.getTotalTimeSeconds()); int total = execVo.getTotal(); rollbackProcess(execVo.getErrorItem(),caseId);