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); }