AQBot-Desktop
diff --git a/‎src-tauri/crates/core/src/rag.rs‎
Lines changed: 34 additions & 1 deletion b/‎src-tauri/crates/core/src/rag.rs‎
Lines changed: 34 additions & 1 deletion
diff --git a/‎src-tauri/crates/core/src/types.rs‎
Lines changed: 14 additions & 0 deletions b/‎src-tauri/crates/core/src/types.rs‎
Lines changed: 14 additions & 0 deletions
@@ -8,10 +8,22 @@ use async_trait::async_trait;
 use sea_orm::DatabaseConnection;
 
 use crate::error::{AQBotError, Result};
-use crate::types::{RagContextResult, RagRetrievedItem, RagSourceResult};
+use crate::types::{RagContextResult, RagRetrievedItem, RagSourceError, RagSourceResult};
 use crate::vector_store::{EmbeddingRecord, VectorSearchResult, VectorStore};
 use crate::{document_parser, text_chunker};
 
+fn format_rag_failure_message(reason: impl AsRef<str>) -> String {
+    const PREFIX: &str = "检索失败";
+    let reason = reason.as_ref().trim();
+    if reason.is_empty() {
+        return PREFIX.to_string();
+    }
+    if reason.starts_with(PREFIX) {
+        return reason.to_string();
+    }
+    format!("{PREFIX}：{reason}")
+}
+
 // ── Trait ────────────────────────────────────────────────────────────────────
 
 /// A source of RAG content that can be searched and indexed.
@@ -314,6 +326,7 @@ pub async fn collect_rag_context(
 
     let mut context_parts = Vec::new();
     let mut source_results = Vec::new();
+    let mut errors = Vec::new();
 
     for src_ref in &sources {
         let source = src_ref.source();
@@ -426,6 +439,16 @@ pub async fn collect_rag_context(
                                 src_ref.container_id,
                                 e
                             );
+                            let source_type_str = match src_ref.source_type {
+                                RAGSourceType::Knowledge => "knowledge",
+                                RAGSourceType::Memory => "memory",
+                            };
+                            errors.push(RagSourceError {
+                                source_type: source_type_str.to_string(),
+                                container_id: src_ref.container_id.clone(),
+                                message: format_rag_failure_message(format!("重排序失败：{e}")),
+                            });
+                            continue;
                         }
                     }
                 }
@@ -475,6 +498,15 @@ pub async fn collect_rag_context(
                     src_ref.container_id,
                     e
                 );
+                let source_type_str = match src_ref.source_type {
+                    RAGSourceType::Knowledge => "knowledge",
+                    RAGSourceType::Memory => "memory",
+                };
+                errors.push(RagSourceError {
+                    source_type: source_type_str.to_string(),
+                    container_id: src_ref.container_id.clone(),
+                    message: format_rag_failure_message(format!("向量检索失败：{e}")),
+                });
             }
         }
     }
@@ -511,6 +543,7 @@ pub async fn collect_rag_context(
     RagContextResult {
         context_parts,
         source_results,
+        errors,
     }
 }
 
 
@@ -1042,13 +1042,25 @@ pub struct RagSourceResult {
     pub items: Vec<RagRetrievedItem>,
 }
 
+/// Retrieval failure for a single RAG source.
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct RagSourceError {
+    /// "knowledge" or "memory"
+    pub source_type: String,
+    pub container_id: String,
+    pub message: String,
+}
+
 /// Combined results of RAG context collection.
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct RagContextResult {
     /// Formatted context parts for injection into system prompt.
     pub context_parts: Vec<String>,
     /// Structured results for frontend display.
     pub source_results: Vec<RagSourceResult>,
+    /// Structured failures for frontend display.
+    #[serde(default, skip_serializing_if = "Vec::is_empty")]
+    pub errors: Vec<RagSourceError>,
 }
 
 /// Tauri event emitted after RAG context retrieval completes.
@@ -1057,6 +1069,8 @@ pub struct RagContextRetrievedEvent {
     pub conversation_id: String,
     pub message_id: Option<String>,
     pub sources: Vec<RagSourceResult>,
+    #[serde(default, skip_serializing_if = "Vec::is_empty")]
+    pub errors: Vec<RagSourceError>,
 }
 
 // === Embedding Types ===