语音播报基础功能

Author: lzy98276

.gitignore

@@ -191,3 +191,4 @@ cython_debug/
 /data/history
 /data/list
 /data/audio
+/data/TEMP

app/Language/modules/voice_settings.py

@@ -12,10 +12,6 @@
             "description": "选择语音合成引擎类型",
         },
         "volume_group": {"name": "音量设置", "description": "调整语音播报音量大小"},
-        "system_volume_group": {
-            "name": "系统音量控制",
-            "description": "选择要控制的系统音量类型",
-        },
         "voice_engine": {
             "name": "语音引擎",
             "description": "选择语音合成引擎类型",

app/common/voice/edge_tts_worker.py

@@ -0,0 +1,136 @@
+# ==================================================
+# 导入库
+# ==================================================
+import asyncio
+import edge_tts
+from loguru import logger
+from PySide6.QtCore import QThread, Signal
+
+
+class EdgeTTSWorker(QThread):
+    """Edge TTS语音列表获取线程"""
+
+    voices_fetched = Signal(list)
+    error_occurred = Signal(str)
+
+    def run(self):
+        """运行线程，获取Edge TTS语音列表"""
+        try:
+            # 获取语音列表
+            voices = self.get_voices()
+            self.voices_fetched.emit(voices)
+        except Exception as e:
+            logger.error(f"获取Edge TTS语音列表失败: {e}")
+            self.error_occurred.emit(str(e))
+
+    def get_voices(self):
+        """获取Edge TTS语音列表"""
+        try:
+            # 同步获取语音列表
+            loop = asyncio.new_event_loop()
+            asyncio.set_event_loop(loop)
+            voices = loop.run_until_complete(edge_tts.list_voices())
+            loop.close()
+
+            logger.debug(f"Edge TTS API返回原始语音数量: {len(voices)}")
+
+            # 调试：打印前几个语音的结构
+            if voices:
+                logger.debug(f"第一个语音的结构: {voices[0]}")
+                logger.debug(f"第一个语音的键: {list(voices[0].keys())}")
+
+            # 简化过滤逻辑
+            filtered_voices = []
+            total_processed = 0
+            passed_filter = 0
+
+            for v in voices:
+                try:
+                    total_processed += 1
+                    # 检查必要字段 - 注意：API返回的是Name而不是FriendlyName
+                    if "Name" in v and "ShortName" in v and "Locale" in v:
+                        passed_filter += 1
+                        name = v["Name"]  # 使用Name字段
+                        display_name = v.get("DisplayName", name)  # 优先使用DisplayName
+                        short_name = v["ShortName"]
+                        locale = v["Locale"]
+                        gender = v.get("Gender", "Unknown")
+                        voice_type = v.get("VoiceType", "Unknown")
+
+                        # 直接使用short_name作为ID
+                        voice_id = short_name
+
+                        filtered_voices.append(
+                            {
+                                "name": display_name,  # 使用更友好的显示名称
+                                "id": voice_id,
+                                "languages": locale.replace("_", "-"),
+                                "full_info": f"{gender} | {locale} | Type: {voice_type}",
+                            }
+                        )
+                except Exception as e:
+                    logger.warning(f"处理语音 {v} 时出错: {e}")
+                    if total_processed <= 5:  # 只显示前5个出错的语音
+                        logger.debug(f"出错语音结构: {v}")
+                    continue
+
+            logger.debug(f"成功获取Edge TTS语音列表，共{len(filtered_voices)}个语音")
+            logger.debug(
+                f"处理统计: 总共{total_processed}个, 通过过滤{passed_filter}个, 最终{len(filtered_voices)}个"
+            )
+
+            # 如果过滤后列表为空，返回默认语音列表
+            if not filtered_voices:
+                logger.warning("过滤后语音列表为空，返回默认语音")
+                return self.get_default_voices()
+
+            # 按语言排序，优先显示中文语音
+            filtered_voices.sort(
+                key=lambda x: ("zh-CN" not in x["languages"], x["name"])
+            )
+            logger.debug(
+                f"语音列表已排序，中文语音优先显示，共{len(filtered_voices)}个语音"
+            )
+
+            return filtered_voices
+        except Exception as e:
+            logger.error(f"获取Edge TTS语音列表失败: {e}")
+            # 返回默认语音列表
+            return self.get_default_voices()
+
+    def get_default_voices(self):
+        """获取默认语音列表"""
+        default_voices = [
+            {
+                "name": "Xiaoxiao (Chinese Female)",
+                "id": "zh-CN-XiaoxiaoNeural",
+                "languages": "zh-CN",
+                "full_info": "Female | zh-CN | Type: Neural",
+            },
+            {
+                "name": "Yunxi (Chinese Male)",
+                "id": "zh-CN-YunxiNeural",
+                "languages": "zh-CN",
+                "full_info": "Male | zh-CN | Type: Neural",
+            },
+            {
+                "name": "Xiaoyi (Chinese Female)",
+                "id": "zh-CN-XiaoyiNeural",
+                "languages": "zh-CN",
+                "full_info": "Female | zh-CN | Type: Neural",
+            },
+            {
+                "name": "Jenny (English Female)",
+                "id": "en-US-JennyNeural",
+                "languages": "en-US",
+                "full_info": "Female | en-US | Type: Neural",
+            },
+            {
+                "name": "Guy (English Male)",
+                "id": "en-US-GuyNeural",
+                "languages": "en-US",
+                "full_info": "Male | en-US | Type: Neural",
+            },
+        ]
+        logger.info("使用默认语音列表")
+        return default_voices

app/common/voice/voice.py

@@ -96,38 +96,19 @@ def start(self) -> None:
 
     def _playback_worker(self) -> None:
         """播放线程主循环"""
-        last_queue_adjust_time = 0
-        queue_adjust_interval = 5.0  # 队列大小调整间隔，单位：秒
-        idle_interval = 60.0  # 队列为空时的检测间隔，单位：秒
-
         while not self._stop_flag.is_set():
             try:
-                current_time = time.time()
-                is_queue_empty = self.play_queue.empty()
-
-                # 根据队列状态调整检测频率
-                if is_queue_empty:
-                    # 队列为空时，降低检测频率
-                    adjust_interval = idle_interval
-                else:
-                    # 队列不为空时，正常检测频率
-                    adjust_interval = queue_adjust_interval
-
-                # 只有当满足时间间隔或队列不为空时，才调整队列大小
-                if current_time - last_queue_adjust_time >= adjust_interval:
-                    # 动态调整队列大小
-                    new_queue_size = self._load_balancer.get_optimal_queue_size()
-                    if self.play_queue.maxsize != new_queue_size:
-                        self.play_queue.maxsize = new_queue_size
-                        logger.debug(f"队列大小调整为: {new_queue_size}")
-                    last_queue_adjust_time = current_time
-
                 # 非阻塞获取任务，设置超时时间避免无限等待
-                # 根据队列状态调整超时时间
-                timeout = 0.1 if is_queue_empty else 1.0
+                timeout = 0.1  # 短暂超时，平衡响应速度和CPU占用
                 task = self.play_queue.get(timeout=timeout)
                 logger.debug(f"获取到播放任务: {type(task).__name__}")
 
+                # 只有在有实际播放任务时，才进行系统负载检测和队列大小调整
+                new_queue_size = self._load_balancer.get_optimal_queue_size()
+                if self.play_queue.maxsize != new_queue_size:
+                    self.play_queue.maxsize = new_queue_size
+                    logger.debug(f"队列大小调整为: {new_queue_size}")
+
                 # 处理两种任务格式：文件路径或内存数据
                 if isinstance(task, tuple):  # 内存数据
                     data, fs = task