Add TTS generation error handling and `is_task_interrupted` helper function

- Log errors during TTS audio generation to improve debugging.
- Abstract task interruption check into `is_task_interrupted` method for better readability and reuse.

src/voice_dialogue/services/audio/generator.py

@@ -6,6 +6,7 @@ from voice_dialogue.core.base import BaseThread
 from voice_dialogue.core.constants import dropped_audio_cache, user_still_speaking_event, voice_state_manager, \
     session_manager
 from voice_dialogue.models.voice_task import VoiceTask
+from voice_dialogue.utils.logger import logger
 from .generators import tts_manager, BaseTTSConfig
 
 
@@ -77,16 +78,35 @@ class TTSAudioGenerator(BaseThread):
             if answer_id in dropped_audio_cache:
                 continue
 
-            if voice_task.id != voice_state_manager.interrupt_task_id:
+            if self.is_task_interrupted(voice_task):
                 continue
 
             if voice_task.session_id != session_manager.current_id:
                 continue
 
             voice_task.tts_start_time = time.time()
-            tts_generated_sentence_audio = self.tts_instance.synthesize(voice_task.answer_sentence)
+            try:
+                tts_generated_sentence_audio = self.tts_instance.synthesize(voice_task.answer_sentence)
+            except Exception as e:
+                logger.error(f"TTS 音频生成失败: {e}")
+                voice_state_manager.reset_task_id()
+                continue
+            
             voice_task.tts_generated_sentence_audio = tts_generated_sentence_audio
             voice_task.tts_end_time = time.time()
             # print(f'生成音频：{voice_task.answer_sentence}')
 
             self.audio_output_queue.put(voice_task)
+
+    def is_task_interrupted(self, voice_task: VoiceTask) -> bool:
+        """
+        检查语音任务是否被中断
+
+        Args:
+            voice_task: 当前处理的语音任务
+
+        Returns:
+            bool: 如果任务被中断返回True，否则返回False
+        """
+        return (voice_state_manager.interrupt_task_id and
+                voice_task.id != voice_state_manager.interrupt_task_id)