报错兜底

frontend-web/src/open-canvas/api/ai-writing-sessions.ts

@@ -59,15 +59,29 @@ export async function deleteAIWritingSession(id: string): Promise<void> {
   if (!resp.ok) throw new Error(`删除失败: ${resp.status}`);
 }
 
-/** 保存会话的完整对话时间线，供历史回显出与实时对话一致的富时间线。 */
+/**
+ * 保存会话的完整对话时间线，供历史回显出与实时对话一致的富时间线。
+ *
+ * 该功能属于「锦上添花」：保存失败不应影响写作主流程，因此本函数永不抛错，
+ * 内部捕获所有异常（网络错误 / 接口 500 等），仅打印告警并返回是否成功。
+ */
 export async function saveAIWritingTranscript(
   id: string,
   transcript: AIWritingTranscript,
-): Promise<void> {
-  const resp = await apiFetch(`${BASE()}/${id}/transcript`, {
-    method: 'PUT',
-    headers: { 'Content-Type': 'application/json' },
-    body: JSON.stringify({ transcript }),
-  });
-  if (!resp.ok) throw new Error(`保存对话时间线失败: ${resp.status}`);
+): Promise<boolean> {
+  try {
+    const resp = await apiFetch(`${BASE()}/${id}/transcript`, {
+      method: 'PUT',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ transcript }),
+    });
+    if (!resp.ok) {
+      console.warn(`[ai-writing] 保存对话时间线失败: HTTP ${resp.status}（已忽略，不影响写作流程）`);
+      return false;
+    }
+    return true;
+  } catch (err) {
+    console.warn('[ai-writing] 保存对话时间线异常（已忽略，不影响写作流程）:', err);
+    return false;
+  }
 }

frontend-web/src/open-canvas/hooks/useAIWriting.ts

@@ -295,15 +295,19 @@ export function useAIWriting() {
     async (payload: UserInterventionPayload) => {
       if (!state.sessionId || !state.currentPause) return;
 
-      // 若处于暂停状态，先重连 SSE 再提交，实现"干预即续接"
+      // 提交干预前始终重连 SSE：
+      // - 正常流程下旧连接仍在，abort 后重建无副作用（后端通过 _session_pending_pause
+      //   重发 await_user，前端 handleEvent 对同一暂停点有去重）；
+      // - 若旧连接已因服务重启 / 反向代理空闲超时而断开，这一步能确保后端恢复出的
+      //   会话有消费者，否则 resume 后的进度事件会堆在队列里无人接收。
+      abortRef.current?.abort();
+      abortRef.current = new AbortController();
+      unsubRef.current = subscribeToProgress(
+        state.sessionId,
+        handleEvent,
+        abortRef.current.signal,
+      );
       if (state.isPaused) {
-        abortRef.current?.abort();
-        abortRef.current = new AbortController();
-        unsubRef.current = subscribeToProgress(
-          state.sessionId,
-          handleEvent,
-          abortRef.current.signal,
-        );
         setState((prev) => ({ ...prev, isPaused: false }));
       }