build-flow/build-flow.api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(rag): 重构RAG查询命令处理器类名和代码格式

Browse Source 
- 将RAGQueryCommandHandler重命名为RagQueryCommandHandler
- 调整代码缩进格式
- 优化空行布局以提高代码可读性
This commit is contained in:
xiangning 2026-07-03 17:14:13 +08:00
parent 7e8623730b
commit 1e0844800e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/modules/rag/Application/RagQA/Handlers/RAGQueryCommandHandler.cs → src/modules/rag/Application/RagQA/Handlers/RagQueryCommandHandler.cs
View File

@ -12,7 +12,7 @@ namespace BuildFlow.Application.RagQA.Handlers;
/// <summary> /// <summary>
/// RAG检索问答查询Command处理器（基于 MAF ChatMessage）。 /// RAG检索问答查询Command处理器（基于 MAF ChatMessage）。
/// </summary> /// </summary>
public class RAGQueryCommandHandler( public class RagQueryCommandHandler(
RagDbContext db, RagDbContext db,
IRagRetrievalService retrievalService, IRagRetrievalService retrievalService,
IAIChatAgent chatAgent) IAIChatAgent chatAgent)
@ -21,7 +21,7 @@ public class RAGQueryCommandHandler(
public async Task<RAGQueryResponse> Handle(RAGQueryCommand request, CancellationToken ct) public async Task<RAGQueryResponse> Handle(RAGQueryCommand request, CancellationToken ct)
{ {
var kb = await db.KnowledgeBases.FindAsync([request.KnowledgeBaseId], 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); var hits = await retrievalService.RetrieveAsync(kb, request.Question, ct);
@ -52,4 +52,4 @@ public class RAGQueryCommandHandler(
var answer = await chatAgent.RunAsync(ragMessages, ct); var answer = await chatAgent.RunAsync(ragMessages, ct);
return new RAGQueryResponse(answer, sources); return new RAGQueryResponse(answer, sources);
} }
} }