feat: update dialogue orchestrator and digital human store

Author: shijiashuai

src/core/dialogue/dialogueOrchestrator.ts

@@ -15,6 +15,8 @@ export interface DialogueTurnOptions extends DialogueHandleOptions {
   setLoading?: (loading: boolean) => void;
 }
 
+let pendingTurn: Promise<ChatResponsePayload | undefined> | null = null;
+
 export async function runDialogueTurn(
   userText: string,
   options: DialogueTurnOptions = {}
@@ -24,6 +26,11 @@ export async function runDialogueTurn(
     return undefined;
   }
 
+  if (pendingTurn) {
+    console.warn('对话请求被忽略：上一轮对话仍在进行中');
+    return undefined;
+  }
+
   const store = useDigitalHumanStore.getState();
   const {
     sessionId = store.sessionId,
@@ -43,28 +50,34 @@ export async function runDialogueTurn(
   setLoading?.(true);
   store.setBehavior('thinking');
 
-  try {
-    const response = await sendUserInput({
-      sessionId,
-      userText: content,
-      meta,
-    });
-
-    await handleDialogueResponse(response, {
-      isMuted,
-      speakWith,
-      addAssistantMessage,
-    });
-
-    return response;
-  } finally {
-    store.setLoading(false);
-    setLoading?.(false);
-
-    if (useDigitalHumanStore.getState().currentBehavior === 'thinking') {
-      useDigitalHumanStore.getState().setBehavior('idle');
+  const execute = async (): Promise<ChatResponsePayload | undefined> => {
+    try {
+      const response = await sendUserInput({
+        sessionId,
+        userText: content,
+        meta,
+      });
+
+      await handleDialogueResponse(response, {
+        isMuted,
+        speakWith,
+        addAssistantMessage,
+      });
+
+      return response;
+    } finally {
+      store.setLoading(false);
+      setLoading?.(false);
+      pendingTurn = null;
+
+      if (useDigitalHumanStore.getState().currentBehavior === 'thinking') {
+        useDigitalHumanStore.getState().setBehavior('idle');
+      }
     }
-  }
+  };
+
+  pendingTurn = execute();
+  return pendingTurn;
 }
 
 export async function handleDialogueResponse(

src/store/digitalHumanStore.ts

@@ -82,6 +82,8 @@ const generateSessionId = (): string => {
 let nextChatMessageId = 0;
 let recordingTimeoutId: ReturnType<typeof setTimeout> | null = null;
 
+const ERROR_THROTTLE_MS = 2000;
+
 const generateChatMessageId = (): number => {
   nextChatMessageId += 1;
   return Date.now() + nextChatMessageId;
@@ -158,7 +160,18 @@ export const useDigitalHumanStore = create<DigitalHumanState>((set, get) => ({
     isConnected: status === 'connected'
   }),
   setLoading: (loading) => set({ isLoading: loading }),
-  setError: (error) => set({ error, lastErrorTime: error ? Date.now() : null }),
+  setError: (error) => {
+    if (!error) {
+      set({ error: null, lastErrorTime: null });
+      return;
+    }
+    const { error: prevError, lastErrorTime } = get();
+    const now = Date.now();
+    if (prevError === error && lastErrorTime && now - lastErrorTime < ERROR_THROTTLE_MS) {
+      return;
+    }
+    set({ error, lastErrorTime: now });
+  },
   clearError: () => set({ error: null, lastErrorTime: null }),
 
   // 会话管理
@@ -168,7 +181,15 @@ export const useDigitalHumanStore = create<DigitalHumanState>((set, get) => ({
     if (storage) {
       storage.setItem('metahuman_session_id', newId);
     }
-    set({ sessionId: newId, chatHistory: [] });
+    set({
+      sessionId: newId,
+      chatHistory: [],
+      error: null,
+      lastErrorTime: null,
+      connectionStatus: 'connected',
+      isConnected: true,
+      isLoading: false,
+    });
   },
 
   addChatMessage: (role, text) => set((state) => {