优化笔录拆分逻辑

topo_dev
liu 9 months ago
parent 055dc7a237
commit bc1efcba5c

@ -11,6 +11,8 @@ import org.springframework.web.service.annotation.GetExchange;
import org.springframework.web.service.annotation.HttpExchange; import org.springframework.web.service.annotation.HttpExchange;
import org.springframework.web.service.annotation.PostExchange; import org.springframework.web.service.annotation.PostExchange;
import java.util.List;
@HttpExchange @HttpExchange
public interface LangChainChatService { public interface LangChainChatService {
@ -20,7 +22,7 @@ public interface LangChainChatService {
* @return * @return
*/ */
@PostExchange(url = "create_knowledge_base", contentType = MediaType.APPLICATION_JSON_VALUE) @PostExchange(url = "create_knowledge_base", contentType = MediaType.APPLICATION_JSON_VALUE)
LangChainChatRes createBase(@RequestBody CreateBaseDTO createBaseDTO); LangChainChatRes<Object> createBase(@RequestBody CreateBaseDTO createBaseDTO);
/** /**
* *
@ -37,7 +39,7 @@ public interface LangChainChatService {
* @return * @return
*/ */
@PostExchange(url = "upload_docs", contentType = MediaType.MULTIPART_FORM_DATA_VALUE) @PostExchange(url = "upload_docs", contentType = MediaType.MULTIPART_FORM_DATA_VALUE)
LangChainChatRes uploadFile(@RequestPart String knowledge_base_name, LangChainChatRes<Object> uploadFile(@RequestPart String knowledge_base_name,
@RequestPart MultipartFile files, @RequestPart MultipartFile files,
@RequestPart String text_splitter_type, @RequestPart String text_splitter_type,
@RequestPart Boolean to_vector_store, @RequestPart Boolean to_vector_store,
@ -54,13 +56,13 @@ public interface LangChainChatService {
* @return * @return
*/ */
@PostExchange(url = "delete_docs", contentType = MediaType.APPLICATION_JSON_VALUE) @PostExchange(url = "delete_docs", contentType = MediaType.APPLICATION_JSON_VALUE)
LangChainChatRes deleteFile(@RequestBody DeleteFileDTO deleteFileDTO); LangChainChatRes<Object> deleteFile(@RequestBody DeleteFileDTO deleteFileDTO);
@GetExchange(url = "list_files") @GetExchange(url = "list_files")
LangChainChatRes queryFileList(@RequestParam String knowledge_base_name); LangChainChatRes<List<String>> queryFileList(@RequestParam String knowledge_base_name);
@PostExchange(url = "/delete_knowledge_base", contentType = MediaType.APPLICATION_JSON_VALUE) @PostExchange(url = "/delete_knowledge_base", contentType = MediaType.APPLICATION_JSON_VALUE)
LangChainChatRes deleteBase(@RequestBody String knowledge_base_name); LangChainChatRes<Object> deleteBase(@RequestBody String knowledge_base_name);
} }

@ -3,11 +3,11 @@ package com.supervision.chat.client.dto;
import lombok.Data; import lombok.Data;
@Data @Data
public class LangChainChatRes { public class LangChainChatRes <T> {
private Integer code; private Integer code;
private String msg; private String msg;
private Object data; private T data;
} }

@ -51,11 +51,11 @@ public class NoteRecordServiceImpl extends ServiceImpl<NoteRecordMapper, NoteRec
return; return;
} }
// 查询知识库中已经存在的文件 // 查询知识库中已经存在的文件
LangChainChatRes queryFileListRes = langChainChatService.queryFileList(modelCase.getCaseNo()); LangChainChatRes<List<String>> queryFileListRes = langChainChatService.queryFileList(modelCase.getCaseNo());
if (!queryFileListRes.getCode().equals(200)) { if (!queryFileListRes.getCode().equals(200)) {
log.info("获取知识库已存在的文件失败"); log.info("获取知识库已存在的文件失败");
} }
HashSet<String> knowledgeFileNameSet = new HashSet<>(JSONUtil.toList((String) queryFileListRes.getData(), String.class)); HashSet<String> knowledgeFileNameSet = new HashSet<>(queryFileListRes.getData());
Set<String> databaseFileNameSet = new HashSet<>(); Set<String> databaseFileNameSet = new HashSet<>();
for (NoteRecord record : recordList) { for (NoteRecord record : recordList) {
for (String fileId : record.getFileIds().split(",")) { for (String fileId : record.getFileIds().split(",")) {

Loading…
Cancel
Save