feat: implement conversation review feature with IPC integration

- Added ReviewService to handle conversation reviews, including generation and retrieval of review data.
- Enhanced IPC handlers to support new review-related commands for generating and fetching reviews.
- Updated LLMSuggestionService to save action suggestions to the database, linking them to conversations for review purposes.
- Introduced new UI components for displaying and generating conversation reviews, improving user interaction and experience.
- Created database schema for storing conversation reviews and added seed data for testing.
- Implemented hooks and pages in the renderer for managing and displaying review data effectively.

Author: Chen-speculation

desktop/src/core/modules/ipc-handlers.js

@@ -3,11 +3,13 @@ import DatabaseManager from '../../db/database.js';
 import ASRManager from '../../asr/asr-manager.js';
 import ASRModelManager from '../../asr/model-manager.js';
 import LLMSuggestionService from './llm-suggestion-service.js';
+import ReviewService from './review-service.js';
 import MemoryService from './memory-service.js';
 import { registerWindowHandlers } from './ipc-handlers/window-handlers.js';
 import { registerDatabaseHandlers } from './ipc-handlers/database-handlers.js';
 import { registerLLMHandlers } from './ipc-handlers/llm-handlers.js';
 import { registerSuggestionHandlers } from './ipc-handlers/suggestion-handlers.js';
+import { registerReviewHandlers } from './ipc-handlers/review-handlers.js';
 import { registerMemoryHandlers } from './ipc-handlers/memory-handlers.js';
 import { registerASRModelHandlers } from './ipc-handlers/asr-model-handlers.js';
 import { registerASRAudioHandlers } from './ipc-handlers/asr-audio-handlers.js';
@@ -23,6 +25,7 @@ export class IPCManager {
     this.modelManager = null;
     this.asrManager = null;
     this.llmSuggestionService = null;
+    this.reviewService = null;
     this.memoryService = null;
     this.asrModelPreloading = false;
     this.asrModelPreloaded = false;
@@ -78,6 +81,14 @@ export class IPCManager {
       this.memoryService = new MemoryService();
     }
   }
+  /**
+   * 初始化 Review Service
+   */
+  initReviewService() {
+    if (!this.reviewService) {
+      this.reviewService = new ReviewService(() => this.db);
+    }
+  }
 
   /**
    * 注册所有 IPC 处理器
@@ -88,11 +99,13 @@ export class IPCManager {
     this.initDatabase();
     this.initModelManager();
     this.initLLMSuggestionService();
+    this.initReviewService();
     this.initMemoryService();
     this.setupWindowHandlers();
     this.setupDatabaseHandlers();
     this.setupLLMHandlers();
     this.setupSuggestionHandlers();
+    this.setupReviewHandlers();
     this.setupMemoryHandlers();
     this.setupASRModelHandlers();
     this.setupASRAudioHandlers();
@@ -101,6 +114,15 @@ export class IPCManager {
     console.log('[IPCHandlers] All IPC handlers registered successfully');
   }
 
+  /**
+   * 设置复盘相关 IPC 处理器
+   */
+  setupReviewHandlers() {
+    registerReviewHandlers({
+      reviewService: this.reviewService
+    });
+  }
+
   /**
    * 设置窗口相关 IPC 处理器
    */

desktop/src/core/modules/ipc-handlers/database-handlers.js

@@ -127,6 +127,15 @@ export function registerDatabaseHandlers({ db }) {
     }
   });
 
+  ipcMain.handle('db-get-conversation-by-id', (event, conversationId) => {
+    try {
+      return db.getConversationById(conversationId);
+    } catch (error) {
+      console.error('Error getting conversation by id:', error);
+      return null;
+    }
+  });
+
   ipcMain.handle('db-update-message', (event, messageId, updates) => {
     try {
       return db.updateMessage(messageId, updates);

desktop/src/core/modules/ipc-handlers/review-handlers.js

@@ -0,0 +1,42 @@
+
+import { ipcMain } from 'electron';
+
+export function registerReviewHandlers({ reviewService }) {
+    if (!reviewService) {
+        console.error('[IPC] ReviewService is required for review handlers');
+        return;
+    }
+
+    // 生成复盘
+    ipcMain.handle('review:generate', async (event, payload) => {
+        try {
+            const { conversationId, force = false } =
+                typeof payload === 'object' && payload !== null
+                    ? payload
+                    : { conversationId: payload, force: false };
+
+            if (!conversationId) {
+                throw new Error('conversationId is required');
+            }
+
+            console.log(`[IPC] Handling review:generate for conversation ${conversationId}, force=${force}`);
+            const review = await reviewService.generateReview(conversationId, { force });
+            return { success: true, data: review };
+        } catch (error) {
+            console.error(`[IPC] review:generate failed:`, error);
+            return { success: false, error: error.message };
+        }
+    });
+
+    // 获取复盘
+    ipcMain.handle('review:get', async (event, conversationId) => {
+        try {
+            console.log(`[IPC] Handling review:get for conversation ${conversationId}`);
+            const review = reviewService.getExistingReview(conversationId);
+            return { success: true, data: review };
+        } catch (error) {
+            console.error(`[IPC] review:get failed:`, error);
+            return { success: false, error: error.message };
+        }
+    });
+}

desktop/src/core/modules/llm-suggestion-service.js

@@ -159,6 +159,14 @@ export default class LLMSuggestionService {
     let totalContentLength = 0;
     let rawStreamContent = '';
 
+    // 记录批次时间戳，同一批次的所有建议使用相同的时间戳
+    const batchTimestamp = Date.now();
+
+    // 获取最新的消息ID（用于关联suggestion）
+    const latestMessageId = context.history && context.history.length > 0 
+      ? context.history[context.history.length - 1]?.id || null
+      : null;
+
     console.log('[LLMSuggestionService] Creating TOON parser');
     const parser = createToonSuggestionStreamParser({
       onHeader: (header) => {
@@ -174,10 +182,22 @@ export default class LLMSuggestionService {
       onSuggestion: (item) => {
         console.log(`[LLMSuggestionService] Parser received suggestion #${emittedCount + 1}:`, item);
         const suggestionIndex = emittedCount;
-        const suggestion = this.decorateSuggestion(item, emittedCount, { trigger, reason });
+        const suggestion = this.decorateSuggestion(item, emittedCount, { trigger, reason }, batchTimestamp);
         suggestion.index = suggestionIndex;
         console.log(`[LLMSuggestionService] Decorated suggestion:`, suggestion);
         emittedCount += 1;
+        
+        // 保存suggestion到数据库
+        if (conversationId && this.db.saveActionSuggestion) {
+          try {
+            this.db.saveActionSuggestion(suggestion, conversationId, latestMessageId);
+            console.log(`[LLMSuggestionService] Saved suggestion to database: ${suggestion.id}`);
+          } catch (error) {
+            console.error('[LLMSuggestionService] Failed to save suggestion to database:', error);
+            // 不阻断流程，继续执行
+          }
+        }
+        
         handlers.onSuggestion?.(suggestion);
       },
       onError: (error) => {
@@ -406,8 +426,11 @@ export default class LLMSuggestionService {
     }
   }
 
-  decorateSuggestion(item, index, { trigger, reason }) {
-    const suggestionId = `llm-suggestion-${Date.now()}-${index}`;
+  decorateSuggestion(item, index, { trigger, reason }, batchTimestamp = null) {
+    // 使用批次时间戳，确保同一批次的所有建议使用相同的时间戳
+    // 如果没有提供批次时间戳，则使用当前时间（向后兼容）
+    const timestamp = batchTimestamp || Date.now();
+    const suggestionId = `llm-suggestion-${timestamp}-${index}`;
     const tags = Array.isArray(item.tags)
       ? item.tags.slice(0, 3)
       : typeof item.tags === 'string'
@@ -421,7 +444,8 @@ export default class LLMSuggestionService {
       tags,
       // affinity_hint: item.affinity_hint || null,
       trigger,
-      reason
+      reason,
+      created_at: timestamp // 使用批次时间戳，确保同一批次的所有建议使用相同的时间戳
     };
   }