From 204737d37f10473f261b979b1a607d5d345f6b05 Mon Sep 17 00:00:00 2001
From: "583641232@qq.com" <583641232@qq.com>
Date: Wed, 31 Jul 2024 12:08:54 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E6=8C=87=E5=AE=9A=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../inscloudtech/datacenter/service/QueryCenterService.java  | 2 +-
 .../datacenter/service/impl/BankServiceImpl.java             | 5 ++++-
 2 files changed, 5 insertions(+), 2 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 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);