update:单流式tts聊天记录上报优化

This commit is contained in:
hrz
2025-06-08 11:59:06 +08:00
parent ac1e254eed
commit 1d57e75d28
@@ -173,6 +173,8 @@ class TTSProvider(TTSProviderBase):
self.pcm_buffer.clear()
opus_datas_cache = []
self.tts_audio_queue.put((SentenceType.FIRST, [], text))
# 兼容 iter_chunked / iter_chunks / iter_any
async for chunk in resp.content.iter_any():
data = chunk[0] if isinstance(chunk, (list, tuple)) else chunk
@@ -193,7 +195,7 @@ class TTSProvider(TTSProviderBase):
if opus:
if self.segment_count < 10: # 前10个片段直接发送
self.tts_audio_queue.put(
(SentenceType.MIDDLE, opus, text)
(SentenceType.MIDDLE, opus, None)
)
self.segment_count += 1
else:
@@ -208,7 +210,7 @@ class TTSProvider(TTSProviderBase):
if self.segment_count < 10: # 前10个片段直接发送
# 直接发送
self.tts_audio_queue.put(
(SentenceType.MIDDLE, opus, text)
(SentenceType.MIDDLE, opus, None)
)
self.segment_count += 1
else:
@@ -219,7 +221,7 @@ class TTSProvider(TTSProviderBase):
# 如果不是前10个片段,发送缓存的数据
if self.segment_count >= 10 and opus_datas_cache:
self.tts_audio_queue.put(
(SentenceType.MIDDLE, opus_datas_cache, text)
(SentenceType.MIDDLE, opus_datas_cache, None)
)
# 如果是最后一段,输出音频获取完毕