diff --git a/web/src/router/index.ts b/web/src/router/index.ts
index e4daaed..10ee4a9 100644
--- a/web/src/router/index.ts
+++ b/web/src/router/index.ts
@@ -2,7 +2,8 @@ import { createRouter, createWebHistory } from "vue-router";
import BasicLayout from "@/layouts/BasicLayout.vue";
import { resetDescription, setTitle } from "@/utils";
-import community from "@/views/CommunityView.vue";
+import ChatLLM from "@/views/ChatLLMView.vue";
+import VoiceView from "@/views/VoiceView.vue";
const router = createRouter({
history: createWebHistory(import.meta.env.BASE_URL),
@@ -13,11 +14,19 @@ const router = createRouter({
children: [
{
path: "",
- name: "community",
- component: community,
+ name: "ChatLLM",
+ component: ChatLLM,
meta: {
title: "对话"
}
+ },
+ {
+ path: "/voice",
+ name: "Voice",
+ component: VoiceView,
+ meta: {
+ title: "语音对话"
+ }
}
]
}
diff --git a/web/src/services/websocket.ts b/web/src/services/websocket.ts
index 489ec21..115ba05 100644
--- a/web/src/services/websocket.ts
+++ b/web/src/services/websocket.ts
@@ -1,4 +1,4 @@
-import { useChatStore, useTtsStore } from "@/stores";
+import { useChatStore, useTtsStore,useVoiceStore } from "@/stores";
// WebSocket
export const useWebSocketStore = defineStore("websocket", () => {
@@ -6,6 +6,8 @@ export const useWebSocketStore = defineStore("websocket", () => {
const connected = ref(false);
const chatStore = useChatStore();
const ttsStore = useTtsStore();
+ const voiceStore = useVoiceStore();
+ const router = useRouter();
const { onlineCount } = storeToRefs(chatStore);
@@ -31,7 +33,14 @@ export const useWebSocketStore = defineStore("websocket", () => {
onlineCount.value = data.online_count;
break;
case "asr_result":
- chatStore.addMessageToHistory(data.result);
+ if (router.currentRoute.value.path === "/") {
+ chatStore.addMessageToHistory(data.result);
+ } else if (router.currentRoute.value.path === "/voice") {
+ // 在语音页面，使用VoiceStore处理
+ voiceStore.handleASRResult(data.result);
+ } else {
+ console.warn(data);
+ }
break;
// 新的TTS消息格式处理
@@ -76,7 +85,6 @@ export const useWebSocketStore = defineStore("websocket", () => {
ttsStore.finishConversion(data.messageId);
} else {
console.log("TTS音频传输完成（无messageId）");
- // 兜底处理，可能是旧格式
ttsStore.finishConversion(data.messageId);
}
break;
@@ -85,7 +93,6 @@ export const useWebSocketStore = defineStore("websocket", () => {
// TTS会话结束
if (data.messageId) {
console.log(`TTS会话结束 [${data.messageId}]`);
- // 可以添加额外的清理逻辑
} else {
console.log("TTS会话结束");
}
@@ -98,19 +105,10 @@ export const useWebSocketStore = defineStore("websocket", () => {
ttsStore.handleError(data.message, data.messageId);
} else {
console.error("TTS错误:", data.message);
- // 兜底处理，可能是旧格式
ttsStore.handleError(data.message, data.messageId || "unknown");
}
break;
- // 保留旧的消息类型作为兜底处理
- case "tts_audio_complete_legacy":
- case "tts_complete_legacy":
- case "tts_error_legacy":
- console.log("收到旧格式TTS消息:", data.type);
- // 可以选择处理或忽略
- break;
-
default:
console.log("未知消息类型:", data.type, data);
}
diff --git a/web/src/stores/index.ts b/web/src/stores/index.ts
index 9647e3d..e40c7b1 100644
--- a/web/src/stores/index.ts
+++ b/web/src/stores/index.ts
@@ -1,4 +1,5 @@
export * from "./asr_store";
export * from "./chat_store";
export * from "./layout_store";
-export * from "./tts_store";
\ No newline at end of file
+export * from "./tts_store";
+export * from "./voice_store";
diff --git a/web/src/stores/voice_store.ts b/web/src/stores/voice_store.ts
new file mode 100644
index 0000000..442607e
--- /dev/null
+++ b/web/src/stores/voice_store.ts
@@ -0,0 +1,293 @@
+import { useWebSocketStore } from "@/services";
+import { useChatStore, useTtsStore } from "@/stores";
+
+export const useVoiceStore = defineStore("voice", () => {
+ // 状态管理
+ const isListening = ref(false); // 是否正在监听语音输入
+ const isProcessing = ref(false); // 是否正在处理（包括ASR、LLM、TTS全流程）
+ const currentSessionId = ref
(null); // 当前会话ID
+
+ // 依赖的其他store
+ const chatStore = useChatStore();
+ const ttsStore = useTtsStore();
+ const wsStore = useWebSocketStore();
+
+ // 语音消息历史
+ const voiceMessages = ref<
+ {
+ id: string;
+ type: "user" | "assistant";
+ text: string;
+ audioId?: string;
+ timestamp: number;
+ isProcessing?: boolean;
+ }[]
+ >([]);
+
+ // ASR缓冲区状态
+ const isRecording = ref(false);
+ const recordingStartTime = ref(null);
+ const recordingMaxDuration = 60 * 1000; // 最大录音时长 60 秒
+
+ /**
+ * 开始语音输入
+ */
+ const startListening = async () => {
+ if (isListening.value) return;
+
+ try {
+ await wsStore.connect();
+
+ // 创建新的会话ID
+ currentSessionId.value = new Date().getTime().toString();
+ isListening.value = true;
+ isRecording.value = true;
+ recordingStartTime.value = Date.now();
+
+ // 开始录音 - 假设我们有一个 startRecording 方法
+ // 这里通常会调用浏览器的 MediaRecorder API
+ await startRecording();
+
+ console.log("开始语音输入");
+ } catch (error) {
+ console.error("启动语音输入失败:", error);
+ stopListening();
+ }
+ };
+
+ /**
+ * 停止语音输入
+ */
+ const stopListening = async () => {
+ if (!isListening.value) return;
+
+ try {
+ // 停止录音
+ if (isRecording.value) {
+ await stopRecording();
+ isRecording.value = false;
+ }
+
+ isListening.value = false;
+ recordingStartTime.value = null;
+
+ // 发送结束信号
+ wsStore.send(JSON.stringify({ type: "asr_end" }));
+ console.log("停止语音输入，等待ASR结果");
+ } catch (error) {
+ console.error("停止语音输入失败:", error);
+ }
+ };
+
+ /**
+ * 录音时间检查
+ */
+ const checkRecordingTime = () => {
+ if (isRecording.value && recordingStartTime.value) {
+ const currentTime = Date.now();
+ const duration = currentTime - recordingStartTime.value;
+
+ if (duration >= recordingMaxDuration) {
+ console.log("录音达到最大时长，自动停止");
+ stopListening();
+ }
+ }
+ };
+
+ // 定时检查录音时间
+ let recordingTimer: any = null;
+ watch(isRecording, (newVal) => {
+ if (newVal) {
+ recordingTimer = setInterval(checkRecordingTime, 1000);
+ } else if (recordingTimer) {
+ clearInterval(recordingTimer);
+ recordingTimer = null;
+ }
+ });
+
+ /**
+ * 处理ASR结果
+ */
+ const handleASRResult = async (text: string) => {
+ if (!text.trim()) return;
+
+ console.log("收到ASR结果:", text);
+ isProcessing.value = true;
+
+ // 添加用户消息
+ const userMessageId = new Date().getTime().toString();
+ voiceMessages.value.push({
+ id: userMessageId,
+ type: "user",
+ text,
+ timestamp: Date.now()
+ });
+
+ // 添加助手消息占位
+ const assistantMessageId = new Date().getTime().toString();
+ voiceMessages.value.push({
+ id: assistantMessageId,
+ type: "assistant",
+ text: "",
+ timestamp: Date.now(),
+ isProcessing: true
+ });
+
+ // 调用LLM生成回复
+ await generateLLMResponse(text, assistantMessageId);
+ };
+
+ /**
+ * 生成LLM回复
+ */
+ const generateLLMResponse = async (userInput: string, responseId: string) => {
+ try {
+ console.log("生成LLM回复...");
+
+ // 构建消息历史
+ const messages = [
+ ...voiceMessages.value
+ .filter((msg) => !msg.isProcessing)
+ .map((msg) => ({
+ role: msg.type === "user" ? "user" : "assistant",
+ content: msg.text
+ })),
+ { role: "user", content: userInput }
+ ];
+
+ let responseText = "";
+
+ // 调用ChatStore的聊天方法
+ await chatStore.chatWithLLM(
+ {
+ messages,
+ model: chatStore.modelInfo?.model_id || ""
+ },
+ // 处理流式回复
+ (content) => {
+ responseText = content;
+ // 更新助手消息
+ const index = voiceMessages.value.findIndex(
+ (msg) => msg.id === responseId
+ );
+ if (index !== -1) {
+ voiceMessages.value[index].text = content;
+ }
+ }
+ );
+
+ // LLM生成完成，转换为语音
+ console.log("LLM回复生成完成:", responseText);
+ await synthesizeSpeech(responseText, responseId);
+ } catch (error) {
+ console.error("生成LLM回复失败:", error);
+ const index = voiceMessages.value.findIndex(
+ (msg) => msg.id === responseId
+ );
+ if (index !== -1) {
+ voiceMessages.value[index].text = "抱歉，生成回复时出错";
+ voiceMessages.value[index].isProcessing = false;
+ }
+ isProcessing.value = false;
+ }
+ };
+
+ /**
+ * 转换文本为语音
+ */
+ const synthesizeSpeech = async (text: string, messageId: string) => {
+ try {
+ console.log("转换文本为语音...");
+
+ // 调用TTS生成语音
+ await ttsStore.convertText(text, messageId);
+
+ // 注意：TTS音频生成完成后会自动播放
+ // 这部分逻辑在TTS Store的finishConversion方法中处理
+
+ // 更新消息状态
+ const index = voiceMessages.value.findIndex(
+ (msg) => msg.id === messageId
+ );
+ if (index !== -1) {
+ voiceMessages.value[index].audioId = messageId;
+ voiceMessages.value[index].isProcessing = false;
+ }
+ } catch (error) {
+ console.error("转换文本为语音失败:", error);
+ const index = voiceMessages.value.findIndex(
+ (msg) => msg.id === messageId
+ );
+ if (index !== -1) {
+ voiceMessages.value[index].isProcessing = false;
+ }
+ } finally {
+ isProcessing.value = false;
+ }
+ };
+
+ /**
+ * 清除所有消息
+ */
+ const clearMessages = () => {
+ voiceMessages.value = [];
+ };
+
+ /**
+ * 播放指定消息的语音
+ */
+ const playMessageAudio = async (messageId: string) => {
+ const message = voiceMessages.value.find((msg) => msg.id === messageId);
+ if (message && message.audioId) {
+ await ttsStore.play(message.audioId);
+ }
+ };
+
+ /**
+ * 暂停当前播放的语音
+ */
+ const pauseAudio = () => {
+ ttsStore.pauseAll();
+ };
+
+ // 录音相关方法 - 这里需要根据实际情况实现
+ // 通常会使用MediaRecorder API
+ const startRecording = async () => {
+ // 实现录音开始逻辑
+ // 1. 获取麦克风权限
+ // 2. 创建MediaRecorder
+ // 3. 监听数据可用事件，发送到WebSocket
+ console.log("开始录音...");
+ };
+
+ const stopRecording = async () => {
+ // 实现录音停止逻辑
+ console.log("停止录音...");
+ };
+
+ // 在组件卸载时清理资源
+ onUnmounted(() => {
+ if (isRecording.value) {
+ stopRecording();
+ }
+ if (recordingTimer) {
+ clearInterval(recordingTimer);
+ }
+ });
+
+ return {
+ // 状态
+ isListening,
+ isProcessing,
+ isRecording,
+ voiceMessages,
+
+ // 方法
+ startListening,
+ stopListening,
+ handleASRResult,
+ clearMessages,
+ playMessageAudio,
+ pauseAudio
+ };
+});
diff --git a/web/src/views/CommunityView.vue b/web/src/views/ChatLLMView.vue
similarity index 100%
rename from web/src/views/CommunityView.vue
rename to web/src/views/ChatLLMView.vue
diff --git a/web/src/views/VoiceView.vue b/web/src/views/VoiceView.vue
new file mode 100644
index 0000000..3d3ee1d
--- /dev/null
+++ b/web/src/views/VoiceView.vue
@@ -0,0 +1,254 @@
+
+
+
+
+
+
+
+
+
+
+
+ 助手：
+ 你好，我是你的智能助手，请问有什么可以帮助你的吗？
+
+
+
+
+
+
+
+
+
+
+
+
+
{{
+ msg.role === "user" ? "你：" : "助手："
+ }}
+
+
+ Tokens: {{ msg.usage?.total_tokens }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 正在语音输入...
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 清除历史
+
+
+
+ 确定要清除历史消息吗？
+
+
+
+
+ {{ isRecording ? "停止输入" : "语音输入" }}
+
+
+
+
+
+