diff --git a/src/renderer/src/components/ChatPanel.vue b/src/renderer/src/components/ChatPanel.vue
index 6f9f915..a3f8bfc 100644
--- a/src/renderer/src/components/ChatPanel.vue
+++ b/src/renderer/src/components/ChatPanel.vue
@@ -1,5 +1,5 @@
 <script setup lang="ts">
-import { ref, computed, onMounted, onUnmounted, nextTick, watch } from 'vue'
+import { ref, computed, onMounted, onUnmounted, nextTick } from 'vue'
 import { NModal, NCard, NScrollbar, useMessage } from 'naive-ui'
 import { marked } from 'marked'
 import { useRagStore } from '../stores/rag'
@@ -199,13 +199,16 @@ async function sendQuery(): Promise<void> {
   const onContext = (data: unknown) => { store.chunks = (data as { chunks: Chunk[] }).chunks }
   const onDelta = (data: unknown) => {
     if (firstDelta) { firstDelta = false; stopWaitTimer() }
-    store.rawAnswer += (data as { delta: string }).delta
+    const delta = (data as { delta: string }).delta
+    store.rawAnswer += delta
+    if (ttsEnabled.value) ttsPlayer.append(delta)
     scrollToBottom()
   }
   const onDone = (data: unknown) => {
     stopWaitTimer()
     store.querying = false
     queryStage.value = ''
+    if (ttsEnabled.value) ttsPlayer.flush()
     const stats = (data as { stats?: InferStats | null }).stats
     if (stats) inferStats.value = stats
     cleanup()
@@ -214,6 +217,7 @@ async function sendQuery(): Promise<void> {
     stopWaitTimer()
     store.querying = false
     queryStage.value = ''
+    if (ttsEnabled.value) ttsPlayer.flush()
     message.error((data as { message: string }).message)
     cleanup()
   }
@@ -255,13 +259,16 @@ async function sendVisionQuery(): Promise<void> {
 
   const onDelta = (data: unknown) => {
     if (firstDelta) { firstDelta = false; stopWaitTimer() }
-    store.rawAnswer += (data as { delta: string }).delta
+    const delta = (data as { delta: string }).delta
+    store.rawAnswer += delta
+    if (ttsEnabled.value) ttsPlayer.append(delta)
     scrollToBottom()
   }
   const onDone = (data: unknown) => {
     stopWaitTimer()
     store.querying = false
     queryStage.value = ''
+    if (ttsEnabled.value) ttsPlayer.flush()
     const stats = (data as { stats?: InferStats | null }).stats
     if (stats) inferStats.value = stats
     cleanup()
@@ -270,6 +277,7 @@ async function sendVisionQuery(): Promise<void> {
     stopWaitTimer()
     store.querying = false
     queryStage.value = ''
+    if (ttsEnabled.value) ttsPlayer.flush()
     message.error((data as { message: string }).message)
     cleanup()
   }
@@ -545,13 +553,6 @@ onMounted(() => {
   }
 })
 
-watch(() => store.querying, (querying) => {
-  // 答案流式生成结束后，整段朗读（先播"开始播报"）
-  if (!querying && ttsEnabled.value && store.rawAnswer) {
-    ttsPlayer.speakWithAnnouncement(store.rawAnswer)
-  }
-})
-
 onUnmounted(() => {
   stopWaitTimer()
   if (hoverTimer) clearTimeout(hoverTimer)