fix(assistant,dashboard): 修复 A3/A4 使用中高概率缺陷

A4: 意图无完成入口导致每4h无限循环提醒+队头阻塞——每条意图至多提醒一次(localStorage持久化), findDueIntention 支持排除已提醒ID

A3: 叙述增强异步竞态守卫——仅当气泡仍在展示本规则时才覆盖, 不抢占已展开面板; 启动时叙述延迟8s展示避免瞬间覆盖问候, 延迟期间用户关闭气泡则放弃

A4: 提醒时刻已过顺延到明天, 避免创建后立即提醒

Author: Aparencia

client/src/features/assistant/constants.ts

@@ -45,6 +45,13 @@ export const EDIT_BURST_RATIO = 0.7;
 export const PROGRESS_NARRATIVE_STORAGE_KEY = 'assistant_progress_narrative_at';
 /** 叙述节奏：每 7 天一次 */
 export const PROGRESS_NARRATIVE_INTERVAL_MS = 7 * 24 * 60 * 60 * 1000;
+/** 叙述气泡延迟（ms）：与问候同批触发时延迟展示，避免瞬间覆盖问候语 */
+export const PROGRESS_NARRATIVE_DELAY_MS = 8 * 1000;
+
+// ── A4 实施意图 ────────────────────────────────────────────
+
+/** 已提醒意图 ID 列表的 localStorage 键（每条意图至多提醒一次） */
+export const INTENTION_REMINDED_STORAGE_KEY = 'assistant_intention_reminded_ids';
 
 // ── A2 语音对话 ────────────────────────────────────────────────
 

client/src/features/assistant/hooks/useIntentionCoach.ts

@@ -5,24 +5,53 @@
  * @ai-context: 挂载后周期扫描 implementation_intentions 表（本地 SQLite），
  * 发现到期意图时向事件总线发射 intention:due，由 ProactiveEngine 按
  * intention-reminder 规则决策是否弹气泡（冷却 4h + 频率上限天然防打扰）。
+ * 每条意图至多提醒一次（localStorage 持久化已提醒 ID）——应用暂无
+ * 意图完成入口，若允许重复提醒会导致到期意图每 4h 无限循环提醒，
+ * 且 findDueIntention 只返回最新一条会阻塞后续新意图（队头阻塞）。
  * 觉察 > 管控：只发事件不强制；检测失败静默跳过。
  * @ai-context: Emits intention:due when a stored intention falls due;
- * the proactive engine decides whether to surface a bubble.
+ * each intention reminds at most once (persisted in localStorage) since
+ * there is no completion UI yet. The proactive engine decides whether to
+ * surface a bubble.
  */
 import { useEffect } from 'react';
 import { assistantEventBus } from '../lib/eventBus';
 import { findDueIntention } from '../lib/intentionRepository';
+import { INTENTION_REMINDED_STORAGE_KEY } from '../constants';
 
 /** 检测间隔：5 分钟一次，重复打扰由规则冷却与频率上限兜底 */
 const CHECK_INTERVAL_MS = 5 * 60 * 1000;
+/** 已提醒 ID 列表保留上限（防 localStorage 无限增长） */
+const MAX_REMINDED_IDS = 100;
+
+/** 读取已提醒意图 ID 列表（损坏/不可用时降级为空集） */
+function readRemindedIds(): Set<string> {
+  try {
+    const raw = localStorage.getItem(INTENTION_REMINDED_STORAGE_KEY);
+    const arr = raw ? (JSON.parse(raw) as unknown) : [];
+    return new Set(Array.isArray(arr) ? arr.filter((x): x is string => typeof x === 'string') : []);
+  } catch {
+    return new Set();
+  }
+}
+
+/** 记录已提醒意图 ID（超出上限截断旧条目） */
+function markReminded(id: string): void {
+  try {
+    const ids = [...readRemindedIds(), id].slice(-MAX_REMINDED_IDS);
+    localStorage.setItem(INTENTION_REMINDED_STORAGE_KEY, JSON.stringify(ids));
+  } catch { /* localStorage 不可用时降级为会话内去重 */ }
+}
 
 export function useIntentionCoach(): void {
   useEffect(() => {
     const check = async () => {
       try {
         const now = new Date();
-        const due = await findDueIntention(now);
+        // 已提醒过的意图直接跳过（否则最新一条会队头阻塞后续意图）
+        const due = await findDueIntention(now, readRemindedIds());
         if (!due) return;
+        markReminded(due.id);
 
         assistantEventBus.emit('intention:due', {
           currentHour: now.getHours(),

client/src/features/assistant/hooks/useProactiveEngine.ts

@@ -12,7 +12,7 @@ import { PROACTIVE_RULES } from '../lib/proactiveRules';
 import { pickTemplate } from '../lib/messageTemplates';
 import { getStatsCacheText, refreshStatsCache } from '../lib/progressStats';
 import { useAssistantStore } from '../store/useAssistantStore';
-import { MAX_TRIGGERS_PER_HOUR, MAX_CONSECUTIVE_IGNORES, PROGRESS_NARRATIVE_STORAGE_KEY } from '../constants';
+import { MAX_TRIGGERS_PER_HOUR, MAX_CONSECUTIVE_IGNORES, PROGRESS_NARRATIVE_STORAGE_KEY, PROGRESS_NARRATIVE_DELAY_MS } from '../constants';
 import { getAuthToken } from '@/lib/ai/aiPluginProvider';
 import type { TriggerContext, ProactiveRule } from '../types';
 
@@ -21,6 +21,8 @@ const lastTriggeredMap = new Map<string, number>();
 let hourlyCount = 0;
 let hourlyResetAt = Date.now() + 60 * 60 * 1000;
 let consecutiveIgnores = 0;
+/** 最近一次气泡被关闭的时刻（延迟展示类规则用它判断用户是否已表达不想被打扰） */
+let lastDismissedAt = 0;
 
 /** A3 {stats} 占位符缓存未就绪时的通用正向兜底文案 */
 const FALLBACK_STATS_TEXT = '你的每一点坚持都算数';
@@ -47,8 +49,12 @@ async function enhanceNarrative(statsText: string, ruleId: string): Promise<void
       authToken: authToken ?? undefined,
     }) as { narrative?: string; status?: string };
     if (res?.narrative && res.status === 'success') {
-      // getState 读取避免闭包捕获旧的 showBubble 引用
-      useAssistantStore.getState().showBubble(res.narrative, ruleId);
+      // 竞态守卫：AI 返回时用户可能已展开面板或关闭气泡——
+      // 仅当当前仍在展示本规则的气泡时才覆盖，不抢占用户当前状态
+      const s = useAssistantStore.getState();
+      if (s.panelState === 'bubble' && s.bubbleTriggerId === ruleId) {
+        s.showBubble(res.narrative, ruleId);
+      }
     }
   } catch { /* 静默降级：保留离线模板拼装的统计气泡 */ }
 }
@@ -108,19 +114,31 @@ export function useProactiveEngine(): void {
     // 缓存未就绪（非 Electron/采集失败）时用通用正向文案兜底
     const statsText = getStatsCacheText() ?? FALLBACK_STATS_TEXT;
     const message = pickTemplate(rule.id).replace('{stats}', statsText);
-    showBubble(message, rule.id);
+    // progress-narrative 走下方延迟展示分支，其余规则立即展示
+    if (rule.id !== 'progress-narrative') {
+      showBubble(message, rule.id);
+    }
 
-    // A3 微进展叙述：记录节奏 + 异步 AI 增强（成功后覆盖气泡）
+    // A3 微进展叙述：同步记录节奏；气泡延迟展示——app:startup 同批的
+    // 问候语先曝光，避免叙述瞬间覆盖问候；延迟期间用户已展开面板
+    // 或关闭过气泡则放弃展示（奖赏回来 ≠ 抢回注意力）
     if (rule.id === 'progress-narrative') {
       markNarrativeShown();
-      void enhanceNarrative(statsText, rule.id);
+      const scheduleAt = Date.now();
+      window.setTimeout(() => {
+        const s = useAssistantStore.getState();
+        if (s.panelState === 'expanded' || lastDismissedAt > scheduleAt) return;
+        s.showBubble(message, rule.id);
+        void enhanceNarrative(statsText, rule.id);
+      }, PROGRESS_NARRATIVE_DELAY_MS);
     }
   }
 }
 
 /** 外部调用：标记用户忽略了气泡 */
 export function reportBubbleDismissed(): void {
   consecutiveIgnores++;
+  lastDismissedAt = Date.now();
 }
 
 /** 外部调用：标记用户回应了气泡（奖赏回来——重置退让计数） */

client/src/features/assistant/lib/intentionRepository.ts

@@ -70,10 +70,14 @@ export async function getActiveIntentions(): Promise<ImplementationIntention[]>
 /**
  * 找出当前到期可提醒的意图（active 且 trigger_at 已到/未设）。
  * 觉察 > 管控：只返回最近一条，避免多意图同时打扰。
+ * @param excludeIds 需跳过的意图 ID（如已提醒过的），避免队头阻塞后续意图
  */
-export async function findDueIntention(now: Date = new Date()): Promise<ImplementationIntention | undefined> {
+export async function findDueIntention(
+  now: Date = new Date(),
+  excludeIds?: ReadonlySet<string>,
+): Promise<ImplementationIntention | undefined> {
   const actives = await getActiveIntentions();
-  return actives.find(i => isIntentionDue(i.trigger_at, now));
+  return actives.find(i => !excludeIds?.has(i.id) && isIntentionDue(i.trigger_at, now));
 }
 
 /**

client/src/features/dashboard/components/StartupRitual.tsx

@@ -64,13 +64,15 @@ export default function StartupRitual(props: Props) {
 
   const { onPhaseChange, onCycleComplete } = useBreathGuideSound(sound);
 
-  /** A4：HH:mm 提醒时间 → 当日 ISO 时间戳（留空则不设定时提醒） */
+  /** A4：HH:mm 提醒时间 → ISO 时间戳（留空则不设定时提醒；时刻已过则顺延到明天） */
   const buildTriggerAt = useCallback((): string | undefined => {
     if (!triggerTime) return undefined;
     const [h, m] = triggerTime.split(':').map(Number);
     if (Number.isNaN(h) || Number.isNaN(m)) return undefined;
     const d = new Date();
     d.setHours(h, m, 0, 0);
+    // 下午补做仪式时选的早间时刻已过去——顺延到明天而非创建后立即提醒
+    if (d.getTime() <= Date.now()) d.setDate(d.getDate() + 1);
     return d.toISOString();
   }, [triggerTime]);