diff --git a/src/modules/rag/Application/RagQA/Handlers/RAGQueryCommandHandler.cs b/src/modules/rag/Application/RagQA/Handlers/RagQueryCommandHandler.cs similarity index 95% rename from src/modules/rag/Application/RagQA/Handlers/RAGQueryCommandHandler.cs rename to src/modules/rag/Application/RagQA/Handlers/RagQueryCommandHandler.cs index f6fd07a..b3d00be 100644 --- a/src/modules/rag/Application/RagQA/Handlers/RAGQueryCommandHandler.cs +++ b/src/modules/rag/Application/RagQA/Handlers/RagQueryCommandHandler.cs @@ -12,7 +12,7 @@ namespace BuildFlow.Application.RagQA.Handlers; /// /// RAG检索问答查询Command处理器(基于 MAF ChatMessage)。 /// -public class RAGQueryCommandHandler( +public class RagQueryCommandHandler( RagDbContext db, IRagRetrievalService retrievalService, IAIChatAgent chatAgent) @@ -21,7 +21,7 @@ public class RAGQueryCommandHandler( public async Task Handle(RAGQueryCommand request, CancellationToken ct) { var kb = await db.KnowledgeBases.FindAsync([request.KnowledgeBaseId], ct) - ?? throw new NotFoundException("知识库不存在"); + ?? throw new NotFoundException("知识库不存在"); // 检索流水线:向量化 -> 混合召回 -> 重排 -> 回填上下文 var hits = await retrievalService.RetrieveAsync(kb, request.Question, ct); @@ -52,4 +52,4 @@ public class RAGQueryCommandHandler( var answer = await chatAgent.RunAsync(ragMessages, ct); return new RAGQueryResponse(answer, sources); } -} +} \ No newline at end of file