diff --git a/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/http/RagHttpService.java b/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/http/RagHttpService.java index 8c2db4cae..4f5e00c1e 100644 --- a/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/http/RagHttpService.java +++ b/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/http/RagHttpService.java @@ -310,18 +310,24 @@ public class RagHttpService { // 检查响应状态 String responseBody = response.getBody(); log.info(" ========= String Response Body Result: {}", responseBody); - JSONObject parseObject = JSON.parseObject(responseBody); - log.info(" ========= JSON Response Body Result: {}", responseBody); + try { + JSONObject parseObject = JSON.parseObject(responseBody); + log.info(" ========= JSON Response Body Result: {}", responseBody); - if (parseObject.containsKey("status") && parseObject.getBoolean("status")) { - // 修改状态为 上传成功 - updateFileState(documents, KnowledgeStatusEnum.UPLOAD_SUCCESS); - } else { - // 修改状态为 上传失败 - updateFileState(documents, KnowledgeStatusEnum.UPLOAD_FAILED); - throw exception(new ErrorCode(10047, responseBody)); + if (parseObject.containsKey("status") && parseObject.getBoolean("status")) { + // 修改状态为 上传成功 + updateFileState(documents, KnowledgeStatusEnum.UPLOAD_SUCCESS); + } else { + // 修改状态为 上传失败 + updateFileState(documents, KnowledgeStatusEnum.UPLOAD_FAILED); + throw exception(new ErrorCode(10047, responseBody)); + } + } catch (Exception e) { + log.error("返回结果 解析为 JSON格式错误: {}", e.getMessage()); + throw new RuntimeException("返回结果 解析为 JSON格式错误: " + e.getMessage(), e); } + } catch (UnirestException e) { if (isSocketClosedException(e)) { log.warn("knowledgeEmbed Socket 连接已关闭,尝试重新上传...");