From e312c5da8afc4e517c2c146df357bb95fcec64ce Mon Sep 17 00:00:00 2001 From: bruce Date: Mon, 25 May 2026 00:39:20 +0800 Subject: [PATCH] =?UTF-8?q?refactor(rag):=20=E6=B8=85=E7=90=86=E8=A7=A3?= =?UTF-8?q?=E6=9E=90=E5=88=87=E7=89=87=E6=97=A7=E5=85=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dto/request/RagDocumentParseRequest.java | 12 ------- .../rag/event/RagDocumentUploadedEvent.java | 9 ------ .../RagDocumentUploadedEventListener.java | 32 ------------------- 3 files changed, 53 deletions(-) delete mode 100644 src/main/java/com/bruce/rag/event/RagDocumentUploadedEvent.java delete mode 100644 src/main/java/com/bruce/rag/event/RagDocumentUploadedEventListener.java diff --git a/src/main/java/com/bruce/rag/dto/request/RagDocumentParseRequest.java b/src/main/java/com/bruce/rag/dto/request/RagDocumentParseRequest.java index e29a0c8..407bc7c 100644 --- a/src/main/java/com/bruce/rag/dto/request/RagDocumentParseRequest.java +++ b/src/main/java/com/bruce/rag/dto/request/RagDocumentParseRequest.java @@ -11,16 +11,4 @@ public class RagDocumentParseRequest { @Schema(description = "文档ID列表") private List documentIds; - - @Schema(description = "切片方式枚举值") - private Integer chunkStrategy; - - @Schema(description = "切片长度") - private Integer chunkSize; - - @Schema(description = "重叠长度") - private Integer chunkOverlap; - - @Schema(description = "分隔符") - private String delimiter; } diff --git a/src/main/java/com/bruce/rag/event/RagDocumentUploadedEvent.java b/src/main/java/com/bruce/rag/event/RagDocumentUploadedEvent.java deleted file mode 100644 index 7aa9fa9..0000000 --- a/src/main/java/com/bruce/rag/event/RagDocumentUploadedEvent.java +++ /dev/null @@ -1,9 +0,0 @@ -package com.bruce.rag.event; - -import java.util.List; - -/** - * 文档上传完成事件，用于异步触发自动解析。 - */ -public record RagDocumentUploadedEvent(List documentIds) { -} diff --git a/src/main/java/com/bruce/rag/event/RagDocumentUploadedEventListener.java b/src/main/java/com/bruce/rag/event/RagDocumentUploadedEventListener.java deleted file mode 100644 index 4f46649..0000000 --- a/src/main/java/com/bruce/rag/event/RagDocumentUploadedEventListener.java +++ /dev/null @@ -1,32 +0,0 @@ -package com.bruce.rag.event; - -import com.bruce.rag.service.IRagDocumentParseService; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.context.event.EventListener; -import org.springframework.scheduling.annotation.Async; -import org.springframework.stereotype.Component; - -@Slf4j -@Component -@RequiredArgsConstructor -public class RagDocumentUploadedEventListener { - - private final IRagDocumentParseService ragDocumentParseService; - - @Async - @EventListener - public void onUploaded(RagDocumentUploadedEvent event) { - if (event == null || event.documentIds() == null) { - return; - } - for (Long documentId : event.documentIds()) { - try { - ragDocumentParseService.parse(documentId); - } catch (RuntimeException e) { - log.warn("RagDocumentUploadedEventListener.onUploaded parse failed, documentId={}, message={}", - documentId, e.getMessage()); - } - } - } -}