From c6610e97f011d67c0592dfbedc2cf13ef41952b1 Mon Sep 17 00:00:00 2001
From: lzh <sickone075@gmail.com>
Date: Sun, 1 Feb 2026 02:26:47 +0800
Subject: [PATCH] =?UTF-8?q?fix(ops):=20=E4=BF=AE=E5=A4=8D=20TtsQueueConsum?=
 =?UTF-8?q?er=20=E4=B8=AD=20Set/List=20=E7=B1=BB=E5=9E=8B=E4=B8=8D?=
 =?UTF-8?q?=E5=8C=B9=E9=85=8D=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修复了 redisTemplate.keys() 返回 Set<String> 但代码声明为 List<String> 的类型不匹配问题

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../ops/environment/service/voice/TtsQueueConsumer.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java
index 6e60f9b..0426ff2 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/voice/TtsQueueConsumer.java
@@ -17,6 +17,7 @@ import org.springframework.stereotype.Service;
 
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
 
@@ -212,7 +213,7 @@ public class TtsQueueConsumer {
         try {
             // 获取所有队列 key
             String pattern = QUEUE_KEY_PREFIX + "*";
-            List<String> keys = redisTemplate.keys(pattern);
+            Set<String> keys = redisTemplate.keys(pattern);
 
             if (keys == null || keys.isEmpty()) {
                 return 0;
@@ -339,7 +340,7 @@ public class TtsQueueConsumer {
      */
     public void clearAllQueues() {
         String pattern = QUEUE_KEY_PREFIX + "*";
-        List<String> keys = redisTemplate.keys(pattern);
+        Set<String> keys = redisTemplate.keys(pattern);
         if (keys != null && !keys.isEmpty()) {
             redisTemplate.delete(keys);
             deviceBroadcastLock.clear();
@@ -354,7 +355,7 @@ public class TtsQueueConsumer {
         Map<String, Object> status = new ConcurrentHashMap<>();
 
         String pattern = QUEUE_KEY_PREFIX + "*";
-        List<String> keys = redisTemplate.keys(pattern);
+        Set<String> keys = redisTemplate.keys(pattern);
 
         if (keys != null && !keys.isEmpty()) {
             for (String key : keys) {