From c0fdc418ff1022a6ff9e6de88798fb057eda714d Mon Sep 17 00:00:00 2001 From: yuance <182865460@qq.com> Date: Wed, 27 May 2026 10:36:08 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=B8=8A=E4=BC=A0=E8=BF=94?= =?UTF-8?q?=E5=9B=9E=E6=8A=A5=E9=94=99=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/gxwebsoft/ai/service/KnowledgeBaseService.java | 4 ++-- .../gxwebsoft/ai/service/impl/KnowledgeBaseServiceImpl.java | 5 ++--- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/gxwebsoft/ai/service/KnowledgeBaseService.java b/src/main/java/com/gxwebsoft/ai/service/KnowledgeBaseService.java index 3f59a7f..2209ac3 100644 --- a/src/main/java/com/gxwebsoft/ai/service/KnowledgeBaseService.java +++ b/src/main/java/com/gxwebsoft/ai/service/KnowledgeBaseService.java @@ -61,9 +61,9 @@ public interface KnowledgeBaseService { List uploadDocuments(String kbId, MultipartFile[] files); /** - * 知识库追加导入已解析的文档 + * 知识库追加导入已解析的文档（异步） */ - boolean submitDocuments(String kbId, String fileId); + void submitDocuments(String kbId, String fileId); /** * 知识库追加导入已解析的文档 diff --git a/src/main/java/com/gxwebsoft/ai/service/impl/KnowledgeBaseServiceImpl.java b/src/main/java/com/gxwebsoft/ai/service/impl/KnowledgeBaseServiceImpl.java index 41acd13..9c1d53c 100644 --- a/src/main/java/com/gxwebsoft/ai/service/impl/KnowledgeBaseServiceImpl.java +++ b/src/main/java/com/gxwebsoft/ai/service/impl/KnowledgeBaseServiceImpl.java @@ -193,12 +193,11 @@ public class KnowledgeBaseServiceImpl implements KnowledgeBaseService { @Async @Override - public boolean submitDocuments(String kbId, String fileId) { + public void submitDocuments(String kbId, String fileId) { String workspaceId = config.getWorkspaceId(); try { Client client = clientFactory.createClient(); - boolean result = AiCloudKnowledgeBaseUtil.submitIndexAddDocumentsJob(client, workspaceId, kbId, fileId).getBody().getSuccess(); - return result; + AiCloudKnowledgeBaseUtil.submitIndexAddDocumentsJob(client, workspaceId, kbId, fileId).getBody().getSuccess(); } catch (Exception e) { throw new RuntimeException("添加文档到知识库失败: " + e.getMessage(), e); }