解压缩以后清空缓存

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);  // 第二个参数确保使用同一连接
+    }
+
 
     /**
      * 创建文件记录