feat(assistant,ai-gateway,db): 创新目录三/四/五部分增强落地

A1 情绪感知分级干预: behaviorMetrics 行为信号采集与三级模板规则

A2 语音对话闭环: useVoiceInput 拾音链路 + ChatInput 麦克风交互

A3 微进展叙述者: 网关 progress_narrative chain/router + Electron handler + 周统计聚合与离线降级

A4 实施意图教练: schema v6 implementation_intentions + 仓储 + 启动仪式 intention 步骤 + 定时提醒

A5 认知负荷监控: cognitiveLoad EMA 评估与 overload 事件规则

F2/F4/F5: 黄金错误周报、错误模式分析、中断恢复包; 仪式跳过菜单与杂项修复

Author: Aparencia

client/electron/ai/handlers/progressNarratorHandler.ts

@@ -0,0 +1,99 @@
+/**
+ * A3 微进展叙述 Handler
+ *
+ * 处理 ai_progress_narrate IPC 请求，调用 AI 网关把本周学习统计
+ * 叙述成一句温暖的进展文本；网关不可达时由渲染层离线模板兜底。
+ *
+ * @ai-context: A3 micro-progress narrator IPC handler——AIFeatureDef 注册表模式，
+ * authToken 由渲染进程从 supabase session 显式注入透传（主进程不自动注入）。
+ * 请求响应契约与网关 progress_narrative 路由的 Pydantic model 对齐。
+ */
+
+import { safeHandle } from '../../ipcUtils.js';
+import { logger } from '../../logger.js';
+import { callWithLocalFallback, gatewayUrl, type AIFeatureDef } from '../utils.js';
+import { generateText } from '../ollama/OllamaProvider.js';
+
+// ================================================================
+// IPC Handler
+// ================================================================
+
+/**
+ * ai_progress_narrate — POST /api/v1/ai/progress-narrative
+ */
+function register(): void {
+  safeHandle(
+    'ai_progress_narrate',
+    async (
+      _event,
+      args: {
+        statsText: string;
+        authToken?: string;
+      },
+    ) => {
+      const startMs = Date.now();
+      logger.info(`[AI] [progress-narrative] IPC received: stats_length=${args.statsText?.length ?? 0}, hasAuth=${!!args.authToken}`);
+
+      // 前端 camelCase → 后端 snake_case
+      const reqBody = {
+        stats_text: args.statsText ?? '',
+      };
+
+      logger.info(`[AI] [progress-narrative] Target: ${gatewayUrl()}/api/v1/ai/progress-narrative`);
+
+      interface NarrativeGenResp {
+        narrative: string;
+        status: string;
+        model: string;
+        tokens_used: number;
+        latency_ms: number;
+      }
+
+      try {
+        // 本地优先：Ollama 可用时本地生成（离线降级路径之一）
+        const localHandler = async (): Promise<NarrativeGenResp> => {
+          const prompt = `以下是用户本周的学习统计：\n${reqBody.stats_text}\n\n请把这段统计写成一句温暖、具体的微进展叙述（不超过两句话，正向语言），返回JSON: {"narrative": "..."}`;
+          const result = await generateText(prompt, '你是一位温暖的学习教练，擅长把学习统计讲述成看得见的进步。请仅返回JSON。', { temperature: 0.7, maxTokens: 256 });
+          const parsed = JSON.parse(result.content);
+          return { narrative: parsed.narrative ?? '', status: 'success', model: result.model, tokens_used: result.tokens_used, latency_ms: result.latency_ms };
+        };
+
+        const { data: resp, source, requestId } = await callWithLocalFallback<typeof reqBody, NarrativeGenResp>(
+          '/api/v1/ai/progress-narrative',
+          reqBody,
+          localHandler,
+          args.authToken,
+          30000,
+        );
+
+        const elapsed = Date.now() - startMs;
+        logger.info(`[AI] [progress-narrative] ✔ Success (${source}): status=${resp.status}, model=${resp.model}, tokens=${resp.tokens_used}, total=${elapsed}ms, reqId=${requestId ?? 'N/A'}`);
+        return {
+          narrative: resp.narrative,
+          status: resp.status,
+          model: resp.model,
+          tokensUsed: resp.tokens_used,
+          latencyMs: resp.latency_ms,
+          requestId,
+          source,
+        };
+      } catch (err) {
+        const elapsed = Date.now() - startMs;
+        const error = err instanceof Error ? err : new Error(String(err));
+        logger.error(`[AI] [progress-narrative] ✖ Failed after ${elapsed}ms: ${error.message}`);
+        throw error;
+      }
+    },
+  );
+}
+
+// ================================================================
+// 功能定义导出
+// ================================================================
+
+export const feature: AIFeatureDef = {
+  id: 'ai_progress_narrate',
+  name: 'A3 微进展叙述',
+  version: '1.0.0',
+  register,
+};

client/electron/ai/index.ts

@@ -32,6 +32,8 @@ import { feature as visionExtractFeature } from './handlers/visionExtractHandler
 import { feature as sessionAnalyzeFeature } from './handlers/sessionAnalyzeHandler.js';
 import { feature as videoAnalyzeFeature } from './handlers/videoAnalyzeHandler.js';
 import { feature as mergeNotesFeature } from './handlers/mergeNotesHandler.js';
+import { feature as errorPatternFeature } from './handlers/errorPatternHandler.js';
+import { feature as progressNarrativeFeature } from './handlers/progressNarratorHandler.js';
 
 // ================================================================
 // 功能注册表
@@ -54,6 +56,8 @@ const features: AIFeatureDef[] = [
   sessionAnalyzeFeature,
   videoAnalyzeFeature,
   mergeNotesFeature,
+  errorPatternFeature,
+  progressNarrativeFeature,
 ];
 
 // ================================================================

client/electron/db/dbIpcHandlers.ts

@@ -38,6 +38,8 @@ const ALLOWED_TABLES = new Set([
   'crdt_docs',
   // crdt_changes — CRDT 同步引擎变更日志（v3 迁移新增）
   'crdt_changes',
+  // implementation_intentions — A4 实施意图（v6 迁移新增）
+  'implementation_intentions',
 ]);
 
 /** camelCase → snake_case（用于表名映射） */
@@ -71,6 +73,8 @@ const TABLE_NAME_MAP: Record<string, string> = {
   assistantTriggers: 'assistant_triggers',
   crdtDocs: 'crdt_docs',
   crdtChanges: 'crdt_changes',
+  // v6 新增：A4 实施意图
+  implementationIntentions: 'implementation_intentions',
 };
 
 function resolveTable(table: string): string {

client/electron/db/schema.ts

@@ -6,7 +6,7 @@
  */
 import type Database from 'better-sqlite3';
 
-export const SCHEMA_VERSION = 5;
+export const SCHEMA_VERSION = 6;
 
 export const SCHEMA_DDL = /* sql */ `
 CREATE TABLE IF NOT EXISTS pomodoro_sessions (
@@ -180,6 +180,15 @@ CREATE TABLE IF NOT EXISTS assistant_triggers (
 CREATE INDEX IF NOT EXISTS idx_asst_msg_session ON assistant_messages(session_id, created_at);
 CREATE INDEX IF NOT EXISTS idx_asst_sess_active ON assistant_sessions(is_archived, updated_at DESC);
 CREATE INDEX IF NOT EXISTS idx_asst_trig_rule ON assistant_triggers(rule_id, triggered_at);
+CREATE TABLE IF NOT EXISTS implementation_intentions (
+  id TEXT PRIMARY KEY,
+  if_clause TEXT NOT NULL DEFAULT '',
+  then_clause TEXT NOT NULL DEFAULT '',
+  trigger_at TEXT,
+  status TEXT NOT NULL DEFAULT 'active' CHECK (status IN ('active','completed','skipped')),
+  created_at TEXT NOT NULL
+);
+CREATE INDEX IF NOT EXISTS idx_impl_intention_status ON implementation_intentions(status, trigger_at);
 `;
 
 /** v3 迁移 DDL：CRDT 同步引擎元数据表（条件执行） */
@@ -234,5 +243,8 @@ export function initializeSchema(db: Database.Database): void {
   // v5 迁移：AI 助手会话/消息/触发表（CREATE IF NOT EXISTS 幂等）
   // 表 DDL 已包含在 SCHEMA_DDL 中，此处无需额外操作
 
+  // v6 迁移：A4 实施意图表 implementation_intentions
+  // 表 DDL 已包含在 SCHEMA_DDL 中（CREATE IF NOT EXISTS 幂等），此处无需额外操作
+
   db.pragma(`user_version = ${SCHEMA_VERSION}`);
 }

client/electron/preload.ts

@@ -26,10 +26,13 @@ const ALLOWED_CHANNELS = [
   'ai_socratic_deepening',
   'ai_predict',
   'ai_rescue',
+  'ai_error_pattern',
   'ai_vision_extract',
   'ai_session_analyze',
   'ai_video_analyze',
   'ai_merge_notes',
+  // A3 微进展叙述（每周一次的统计叙述生成）
+  'ai_progress_narrate',
   'ai:set-gateway-url',
   // AI 学伴对话 IPC channel
   'ai:chat:send',
@@ -45,6 +48,8 @@ const ALLOWED_CHANNELS = [
   'audio_list_sources',
   'audio_capture_start',
   'audio_capture_stop',
+  // A2 语音对话：启动前查询是否已有活跃采集（互斥保护，避免误伤课堂采集）
+  'audio_capture_status',
   'get-app-version',
   'dialog:selectDirectory',
   'get-default-storage-path',

client/src/env.d.ts

@@ -77,6 +77,23 @@ declare global {
         deleteModel: (modelName: string) => Promise<{ success: boolean }>;
         onPullProgress: (callback: (progress: OllamaPullProgress) => void) => () => void;
       };
+      // ── A2 语音输入（新增） ──
+      audio_capture_status: () => Promise<{ active: boolean }>;
+      local_asr_stream_available: () => Promise<{ available: boolean }>;
+      audio_capture_start: (options: { microphone: boolean; chunkDurationMs?: number; sampleRate?: number; channels?: number }) => Promise<{ success: boolean; error?: string }>;
+      local_asr_stream_start: (options: { sampleRate?: number }) => Promise<{ success: boolean; error?: string }>;
+      local_asr_stream_stop: () => Promise<{ success: boolean }>;
+      audio_capture_stop: () => Promise<{ success: boolean }>;
+      // ── A3 微进展叙述（新增） ──
+      ai_progress_narrate: (args: { statsText: string; authToken?: string }) => Promise<{
+        narrative: string;
+        status: string;
+        model: string;
+        tokensUsed: number;
+        latencyMs: number;
+        requestId?: string;
+        source?: string;
+      }>;
     };
   }
 }

client/src/features/assistant/AssistantRoot.tsx

@@ -10,6 +10,9 @@ import { useAssistantStore } from './store/useAssistantStore';
 import { useChat } from './hooks/useChat';
 import { useProactiveEngine, reportBubbleDismissed, reportBubbleResponded } from './hooks/useProactiveEngine';
 import { useAssistantAudio } from './hooks/useAssistantAudio';
+import { useBehaviorSignals } from './hooks/useBehaviorSignals';
+import { useBedtimeReminder } from './hooks/useBedtimeReminder';
+import { useIntentionCoach } from './hooks/useIntentionCoach';
 import { CreatureAvatar } from './components/CreatureAvatar';
 import { ConversationPanel } from './components/ConversationPanel';
 
@@ -22,6 +25,12 @@ export function AssistantRoot() {
   const { sendMessage, retryLastMessage, dismissError } = useChat();
   const { playSound } = useAssistantAudio();
   useProactiveEngine();
+  // A1/A5 行为信号源：情绪分级与认知负荷共用，只发事件不干预
+  useBehaviorSignals();
+  // F3 睡前复习推荐：晚间窗口检测到期卡，只发事件由引擎决策是否触发
+  useBedtimeReminder();
+  // A4 实施意图教练：周期扫描到期意图，发 intention:due 事件
+  useIntentionCoach();
 
   if (!enabled) return null;
 

client/src/features/assistant/components/ChatInput.tsx

@@ -5,8 +5,9 @@
  * 设计原则：可逆 > 不可逆——TTS 开关随时可切换。
  */
 import { useState, useRef } from 'react';
-import { Volume2, VolumeX } from 'lucide-react';
+import { Volume2, VolumeX, Mic, MicOff } from 'lucide-react';
 import { useAssistantStore } from '../store/useAssistantStore';
+import { useVoiceInput } from '../hooks/useVoiceInput';
 
 interface Props {
   onSend: (text: string) => void;
@@ -20,6 +21,15 @@ export function ChatInput({ onSend }: Props) {
   const preferences = useAssistantStore(s => s.preferences);
   const inputRef = useRef<HTMLTextAreaElement>(null);
 
+  // A2 语音输入：麦克风按钮状态与控制
+  const { listening, partialText, error, toggle, clearError } = useVoiceInput({
+    onFinalText: (final) => {
+      if (final.trim()) onSend(final);
+      clearError();
+      inputRef.current?.focus();
+    },
+  });
+
   const handleSend = () => {
     const trimmed = text.trim();
     if (!trimmed || isStreaming) return;
@@ -42,42 +52,67 @@ export function ChatInput({ onSend }: Props) {
   };
 
   return (
-    <div className="border-t border-border/50 px-3 py-2.5 flex items-end gap-2">
-      <textarea
-        ref={inputRef}
-        value={text}
-        onChange={e => setText(e.target.value)}
-        onKeyDown={handleKeyDown}
-        placeholder="输入消息..."
-        rows={1}
-        className="flex-1 resize-none rounded-xl bg-bg-tertiary/50 px-3 py-2 text-sm text-text-primary
-          placeholder:text-text-tertiary outline-none focus:ring-1 focus:ring-cyber/40
-          max-h-[100px] overflow-y-auto"
-      />
-      {/* TTS 开关：图标 + 文字标签 + aria-pressed，状态一目了然 */}
-      <button
-        onClick={toggleTts}
-        className={`flex items-center gap-1 px-2 py-1.5 rounded-lg text-xs font-medium transition-colors flex-shrink-0
-          ${ttsEnabled
-            ? 'bg-cyber/15 text-cyber ring-1 ring-cyber/40'
-            : 'bg-bg-tertiary/50 text-text-tertiary hover:text-text-secondary'}`}
-        title={ttsEnabled ? '语音朗读已开启（点击关闭）' : '语音朗读已关闭（点击开启）'}
-        aria-pressed={ttsEnabled}
-        aria-label={ttsEnabled ? '关闭语音朗读' : '开启语音朗读'}
-      >
-        {ttsEnabled ? <Volume2 className="w-3.5 h-3.5" strokeWidth={1.5} /> : <VolumeX className="w-3.5 h-3.5" strokeWidth={1.5} />}
-        {ttsEnabled ? '朗读开' : '朗读关'}
-      </button>
-      {/* 发送 */}
-      <button
-        onClick={handleSend}
-        disabled={isStreaming || !text.trim()}
-        className="p-2 rounded-lg bg-brand-600/80 text-white text-sm disabled:opacity-40
-          hover:bg-brand-500/80 transition-colors"
-        aria-label="发送消息"
-      >
-        ➤
-      </button>
+    <div className="border-t border-border/50 px-3 py-2.5">
+      {/* A2 语音输入错误提示（互斥/模型缺失等）——可关闭时自动消失 */}
+      {error && (
+        <div className="mb-1.5 text-xs text-orange-400 flex items-center justify-between gap-2">
+          <span>{error}</span>
+          <button onClick={clearError} className="text-text-tertiary hover:text-text-secondary flex-shrink-0" aria-label="关闭提示">✕</button>
+        </div>
+      )}
+      <div className="flex items-end gap-2">
+        <textarea
+          ref={inputRef}
+          // A2 语音输入：拾音时输入框展示实时 partial 转写（受控态不覆盖已键入文本）
+          value={listening ? partialText : text}
+          onChange={e => setText(e.target.value)}
+          onKeyDown={handleKeyDown}
+          placeholder={listening ? '正在听你说…' : '输入消息...'}
+          rows={1}
+          className="flex-1 resize-none rounded-xl bg-bg-tertiary/50 px-3 py-2 text-sm text-text-primary
+            placeholder:text-text-tertiary outline-none focus:ring-1 focus:ring-cyber/40
+            max-h-[100px] overflow-y-auto"
+        />
+        {/* TTS 开关：图标 + 文字标签 + aria-pressed，状态一目了然 */}
+        <button
+          onClick={toggleTts}
+          className={`flex items-center gap-1 px-2 py-1.5 rounded-lg text-xs font-medium transition-colors flex-shrink-0
+            ${ttsEnabled
+              ? 'bg-cyber/15 text-cyber ring-1 ring-cyber/40'
+              : 'bg-bg-tertiary/50 text-text-tertiary hover:text-text-secondary'}`}
+          title={ttsEnabled ? '语音朗读已开启（点击关闭）' : '语音朗读已关闭（点击开启）'}
+          aria-pressed={ttsEnabled}
+          aria-label={ttsEnabled ? '关闭语音朗读' : '开启语音朗读'}
+        >
+          {ttsEnabled ? <Volume2 className="w-3.5 h-3.5" strokeWidth={1.5} /> : <VolumeX className="w-3.5 h-3.5" strokeWidth={1.5} />}
+          {ttsEnabled ? '朗读开' : '朗读关'}
+        </button>
+        {/* A2 语音输入：麦克风按钮（拾音中脉冲高亮，防回声：流式回复中禁用） */}
+        <button
+          onClick={toggle}
+          disabled={isStreaming}
+          className={`flex items-center gap-1 px-2 py-1.5 rounded-lg text-xs font-medium transition-colors flex-shrink-0
+            ${listening
+              ? 'bg-orange-500/15 text-orange-500 ring-1 ring-orange-500/40 animate-pulse'
+              : 'bg-bg-tertiary/50 text-text-tertiary hover:text-text-secondary'}`}
+          title={listening ? '正在录音中（点击停止）' : '语音输入（点击开始）'}
+          aria-pressed={listening}
+          aria-label={listening ? '停止录音' : '开始录音'}
+        >
+          {listening ? <MicOff className="w-3.5 h-3.5" strokeWidth={1.5} /> : <Mic className="w-3.5 h-3.5" strokeWidth={1.5} />}
+          {listening ? '录音中' : '说话'}
+        </button>
+        {/* 发送 */}
+        <button
+          onClick={handleSend}
+          disabled={isStreaming || !text.trim() || listening}
+          className="p-2 rounded-lg bg-brand-600/80 text-white text-sm disabled:opacity-40
+            hover:bg-brand-500/80 transition-colors"
+          aria-label="发送消息"
+        >
+          ➤
+        </button>
+      </div>
     </div>
   );
 }