From 55e5c06843ac8fa4b59d259457a7e6c09725ced4 Mon Sep 17 00:00:00 2001
From: lilin <succ_secret@163.com>
Date: Wed, 16 Jul 2025 15:32:25 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=8E=8B=E7=BC=A9=E4=BB=A5=E5=90=8E?=
 =?UTF-8?q?=E6=B8=85=E7=A9=BA=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/TsFilesServiceImpl.java               | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsFilesServiceImpl.java b/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsFilesServiceImpl.java
index 50b70a9..a0b7463 100644
--- a/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsFilesServiceImpl.java
+++ b/java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsFilesServiceImpl.java
@@ -1904,6 +1904,8 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
             taskStatusHolder.finishTask(extractKey);
             extractTaskStatus.removeTask(id);
             WebSocketServer.sendMessageTo(tsfilesName + "解压缩完成", "id_extract_" + taskId);
+            // 确保在方法结束前执行清空操作
+            clearCurrentRedisDatabase();
             TableNameContextHolder.clear();
         }
     }
@@ -2078,6 +2080,14 @@ public class TsFilesServiceImpl extends ServiceImpl<TsFilesMapper, TsFiles> impl
         }
     }
 
+    // 清空当前连接的 Redis 数据库
+    private void clearCurrentRedisDatabase() {
+        redisTemplate.execute((connection) -> {
+            connection.flushDb();  // 清空当前数据库
+            return null;
+        }, true);  // 第二个参数确保使用同一连接
+    }
+
 
     /**
      * 创建文件记录