perf(storage): P2-14 采集片段拆分独立表（addSegment 原子追加，旧数据回退兼容）

Author: Aparencia

client/src/lib/storage/captureStore.ts

@@ -1,8 +1,10 @@
 /**
  * 采集会话存储
  *
- * @ai-context: segments 以整数组覆盖方式追加（Dexie 不支持数组原子
- * push），高频调用 addSegment 存在读改写竞态，调用方需串行化。
+ * @ai-context: P2-14——segments 拆至独立表 windowCaptureSegments：addSegment
+ * 由原来的整数组读改写（Dexie 不支持原子 push，O(n)+高频竞态）变为单行原子
+ * 追加。getSegments 优先读独立表，空则回退旧会话内嵌 segments（向后兼容，
+ * 无数据迁移）。
  */
 import { db } from './database';
 import type { WindowCapture, ExtractedSegment } from '@/types/models';
@@ -41,20 +43,13 @@ export const captureStore = {
   },
 
   /**
-   * 添加提取片段到会话
-   * 将 segment 追加到 segments 数组
+   * 添加提取片段到会话（P2-14：写入独立表，原子追加，无读改写竞态）
    */
   async addSegment(
     sessionId: string,
     segment: ExtractedSegment
   ): Promise<void> {
-    const session = await db.windowCaptures.get(sessionId);
-    if (!session) {
-      throw new Error(`[captureStore] Session not found: ${sessionId}`);
-    }
-    await db.windowCaptures.update(sessionId, {
-      segments: [...session.segments, segment],
-    });
+    await db.windowCaptureSegments.add({ ...segment, sessionId });
   },
 
   /**
@@ -69,17 +64,20 @@ export const captureStore = {
   },
 
   /**
-   * 获取会话的所有片段
+   * 获取会话的所有片段（P2-14：独立表优先，空则回退旧会话内嵌 segments）
    */
   async getSegments(sessionId: string): Promise<ExtractedSegment[]> {
+    const rows = await db.windowCaptureSegments.where('sessionId').equals(sessionId).toArray();
+    if (rows.length > 0) return rows;
     const session = await db.windowCaptures.get(sessionId);
     return session?.segments ?? [];
   },
 
   /**
-   * 删除会话（及其关联的所有片段）
+   * 删除会话（及其关联的所有片段：独立表 + 内嵌）
    */
   async deleteSession(id: string): Promise<void> {
+    await db.windowCaptureSegments.where('sessionId').equals(id).delete();
     await db.windowCaptures.delete(id);
   },
 

client/src/lib/storage/database.ts

@@ -4,9 +4,10 @@ import type {
   FlashcardDeck, Flashcard, FlashcardReview,
   FeynmanNote, FeynmanSummary, FeynmanWeakPoint,
   OperationLog, AppSettings, SyncConflict, OfflineQueueItem,
-  StudyCheckIn, Achievement, PomodoroGoal, WindowCapture,
+  StudyCheckIn, Achievement, PomodoroGoal, WindowCapture, WindowCaptureSegment,
   Consent, UserProfile, Inspiration, SearchIndexEntry, RitualRecord
 } from '@/types/models';
+import type { DeepSeaDiscovery, CoralRecord, StreakState } from '@/features/retention/types';
 import type { ClassroomNote } from './classroomNoteStore';
 import type { CRDTDocRecord, CRDTChangeRecord } from '@/lib/sync/crdtEngine';
 
@@ -49,6 +50,10 @@ export class EntropyDecreaseDatabase extends Dexie {
   crdtChanges!: Table<CRDTChangeRecord, number>;
   ritualRecords!: Table<RitualRecord, string>;
   pomodoroPresets!: Table<PomodoroPreset, string>;
+  deepSeaDiscoveries!: Table<DeepSeaDiscovery, string>;
+  coralEcosystem!: Table<CoralRecord, string>;
+  streakState!: Table<StreakState, string>;
+  windowCaptureSegments!: Table<WindowCaptureSegment, string>;
 
   constructor() {
     // 数据库名 'keban' 不可修改（存量用户数据），见文件头 @ai-context
@@ -277,6 +282,20 @@ export class EntropyDecreaseDatabase extends Dexie {
     this.version(17).stores({
       pomodoroPresets: 'id, sortOrder, builtin, createdAt',
     });
+
+    // v0.29.0: 留存机制 — 深海发现 / 珊瑚生态 / 防断裂 streak
+    this.version(18).stores({
+      deepSeaDiscoveries: 'id, type, rarity, discoveredAt, sourceType',
+      coralEcosystem: 'id, type, health, plantedAt, depth',
+      streakState: 'id, lastActiveDate',
+    });
+
+    // P2-14: 采集片段独立表 — 将 segments 从 windowCaptures 内嵌数组拆出，
+    // addSegment 由全量读改写（O(n)+竞态）变为原子追加；旧会话内嵌 segments
+    // 仍可读（captureStore.getSegments 回退），无需数据迁移。
+    this.version(19).stores({
+      windowCaptureSegments: 'id, sessionId, timestamp',
+    });
   }
 }
 

client/src/lib/storage/fullExport.ts

@@ -4,7 +4,7 @@ import type {
   PomodoroSession, PomodoroSettings, Note, NoteFolder,
   FlashcardReview, FeynmanNote, FeynmanSummary, FeynmanWeakPoint,
   OperationLog, AppSettings, StudyCheckIn, Achievement,
-  PomodoroGoal, SyncConflict, OfflineQueueItem, WindowCapture,
+  PomodoroGoal, SyncConflict, OfflineQueueItem, WindowCapture, WindowCaptureSegment,
   RitualRecord,
 } from '@/types/models';
 
@@ -42,6 +42,8 @@ export interface ExportData {
     syncConflicts: SyncConflict[];
     offlineQueue: OfflineQueueItem[];
     windowCaptures: WindowCapture[];
+    // P2-14: 采集片段独立表（旧备份无此字段时导入安全跳过）
+    windowCaptureSegments: WindowCaptureSegment[];
     // v0.26.0 A1 补全：
     ritualRecords: RitualRecord[];
   };
@@ -54,6 +56,7 @@ const EXPORT_TABLES = [
   'feynmanNotes', 'feynmanSummaries', 'feynmanWeakPoints',
   'operationLog', 'appSettings', 'studyCheckIns', 'achievements',
   'pomodoroGoals', 'syncConflicts', 'offlineQueue', 'windowCaptures',
+  'windowCaptureSegments',
   'ritualRecords',
 ] as const;
 

client/src/pages/settings/hooks/useClearData.ts

@@ -44,7 +44,7 @@ export function useClearData() {
         db.operationLog, db.appSettings,
         db.studyCheckIns, db.achievements,
         db.pomodoroGoals, db.syncConflicts, db.offlineQueue,
-        db.windowCaptures,
+        db.windowCaptures, db.windowCaptureSegments,
       ], async () => {
         await db.pomodoroSessions.clear();
         await db.pomodoroSettings.clear();
@@ -64,6 +64,7 @@ export function useClearData() {
         await db.syncConflicts.clear();
         await db.offlineQueue.clear();
         await db.windowCaptures.clear();
+        await db.windowCaptureSegments.clear();
       });
       localStorage.clear();
       toast({ type: 'success', message: '所有数据已清除，即将刷新' });

client/src/types/capture.ts

@@ -31,6 +31,14 @@ export interface ExtractedSegment {
   metadata?: SegmentMetadata;   // 附加元数据
 }
 
+/**
+ * 采集片段独立表行（P2-14）——在 ExtractedSegment 基础上绑定所属会话 ID，
+ * 存储于 windowCaptureSegments 表（'id, sessionId, timestamp'）。
+ */
+export interface WindowCaptureSegment extends ExtractedSegment {
+  sessionId: string;            // 所属采集会话 ID
+}
+
 // 片段元数据
 export interface SegmentMetadata {
   startTime?: number;           // 音频/视频起始时间（秒）