From 3443d4dcd4f23a22e854da21024f438d7e3fcaa4 Mon Sep 17 00:00:00 2001
From: lzh <sickone075@gmail.com>
Date: Tue, 3 Feb 2026 22:18:57 +0800
Subject: [PATCH] =?UTF-8?q?fix(ops):=20=E5=A2=9E=E5=BC=BA=20TTS=20?=
 =?UTF-8?q?=E9=98=9F=E5=88=97=E6=97=A5=E5=BF=97=E7=BA=A7=E5=88=AB=EF=BC=8C?=
 =?UTF-8?q?=E6=96=B9=E4=BE=BF=E6=8E=92=E6=9F=A5=E8=AF=AD=E9=9F=B3=E6=92=AD?=
 =?UTF-8?q?=E6=8A=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- TtsQueueProcessJob: 添��� info 级别日志输出处理结果
- TtsQueueConsumer: 将播报成功日志改为 info 级别
- 添加队列发现日志，便于追踪

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../module/ops/environment/job/TtsQueueProcessJob.java   | 4 ++++
 .../ops/environment/service/voice/TtsQueueConsumer.java  | 9 ++++++---
 2 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/job/TtsQueueProcessJob.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/job/TtsQueueProcessJob.java
index a11dc26..e8854b9 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/job/TtsQueueProcessJob.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/job/TtsQueueProcessJob.java
@@ -39,11 +39,15 @@ public class TtsQueueProcessJob {
     @TenantJob
     public String execute() {
         if (!ttsQueueConsumer.isEnabled()) {
+            log.warn("[TTS队列Job] TTS队列未启用");
             return "TTS队列未启用";
         }
 
         try {
             int processedCount = ttsQueueConsumer.processAllQueues();
+            if (processedCount > 0) {
+                log.info("[TTS队列Job] 处理完成: 处理 {} 条消��", processedCount);
+            }
             return String.format("TTS队列处理完成: 处理 %d 条消息", processedCount);
         } catch (Exception e) {
             log.error("[TTS队列Job] 处理失败", e);
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 0426ff2..80cd9f9 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
@@ -48,7 +48,7 @@ public class TtsQueueConsumer {
     @Value("${ops.tts.queue.enabled:true}")
     private boolean queueEnabled;
 
-    @Value("${ops.tts.queue.interval-ms:1500}")
+    @Value("${ops.tts.queue.interval-ms:3000}")
     private long broadcastIntervalMs;
 
     @Value("${ops.tts.queue.max-queue-size:50}")
@@ -153,6 +153,7 @@ public class TtsQueueConsumer {
         Long lastBroadcastTime = deviceBroadcastLock.get(deviceId);
         if (lastBroadcastTime != null && now - lastBroadcastTime < broadcastIntervalMs) {
             // 距离上次播报时间太短，跳过
+            log.debug("[TTS队列] 间隔太近跳过: deviceId={}, 间隔={}ms", deviceId, now - lastBroadcastTime);
             return false;
         }
 
@@ -172,7 +173,7 @@ public class TtsQueueConsumer {
 
             // 检查消息是否过期
             if (message.isExpired()) {
-                log.debug("[TTS队列] 消息已过期，跳过: deviceId={}, text={}",
+                log.info("[TTS队列] 消息已过期: deviceId={}, text={}",
                         deviceId, message.getText());
                 return false;
             }
@@ -183,7 +184,7 @@ public class TtsQueueConsumer {
             if (success) {
                 // 播报成功，更新锁时间
                 deviceBroadcastLock.put(deviceId, now);
-                log.debug("[TTS队列] 播报成功: deviceId={}, text={}",
+                log.info("[TTS队列] 播报成功: deviceId={}, text={}",
                         deviceId, message.getText());
                 return true;
             } else {
@@ -219,6 +220,8 @@ public class TtsQueueConsumer {
                 return 0;
             }
 
+            log.info("[TTS队列] 发现 {} 个设备队列", keys.size());
+
             // 处理每个队列
             for (String key : keys) {
                 try {