From e9682dcb61f94ac544ab4ad62ff6f02449b61da9 Mon Sep 17 00:00:00 2001 From: "liu.zixi" Date: Fri, 31 Oct 2025 10:44:50 +0800 Subject: [PATCH] =?UTF-8?q?[DAT]=20=E4=B8=9A=E5=8A=A1=E5=A4=84=E7=90=86?= =?UTF-8?q?=E6=8C=A1=E6=9D=BF=E5=8F=AA=E4=BF=9D=E7=95=99=E6=9B=B4=E6=94=B9?= =?UTF-8?q?=E6=97=B6=E4=B8=8A=E4=BC=A0=E6=8C=A1=E6=9D=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/CaseKnowledgeServiceImpl.java | 29 ++++++++----------- 1 file changed, 12 insertions(+), 17 deletions(-) diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java index e163c676..119cf72a 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java @@ -183,12 +183,9 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { String taskId = data.getString("taskId"); // 保存成功的CaseDocumentLog记录 -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, -// requestBody.toJSONString(), responseBody, -// CaseDocumentLogRunStatusEnum.RUNNING.getCode(), null, null, taskId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), responseBody, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), taskId); + CaseDocumentLogRunStatusEnum.RUNNING.getCode(), null, null, taskId); log.info("上传案例文档成功,等待文档状态变更. caseId: {}, taskId: {}, 尝试次数: {}", caseId, taskId, attempt); return true; @@ -321,9 +318,8 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { // 接口调用成功,检查业务处理结果 JSONObject data = result.getJSONObject("data"); Boolean deleteSuccess = data.getBoolean(taskId); -// int caseStatus = (deleteSuccess != null && deleteSuccess) ? -// CaseDocumentLogCaseStatusEnum.SUCCESS.getCode() : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); - int caseStatus = CaseDocumentLogCaseStatusEnum.FAILED.getCode(); + int caseStatus = (deleteSuccess != null && deleteSuccess) ? + CaseDocumentLogCaseStatusEnum.SUCCESS.getCode() : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, responseBody, @@ -602,22 +598,21 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { // 接口调用成功,检查业务处理结果 JSONObject data = result.getJSONObject("data"); Boolean deleteSuccess = data.getBoolean(deleteTaskId); -// int caseStatus = (deleteSuccess != null && deleteSuccess) ? -// CaseDocumentLogCaseStatusEnum.SUCCESS.getCode() : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); - int caseStatus = CaseDocumentLogCaseStatusEnum.FAILED.getCode(); + int caseStatus = (deleteSuccess != null && deleteSuccess) ? + CaseDocumentLogCaseStatusEnum.SUCCESS.getCode() : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, responseBody, CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), caseStatus, null); -// if (deleteSuccess != null && deleteSuccess) { -// log.info("删除案例文档成功,caseId: {}, taskId: {}, 尝试次数: {}", caseId, deleteTaskId, attempt); -// break; // 删除成功,跳出重试循环 -// } else { -// // 业务处理失败,不重试 -// log.error("删除案例文档业务处理失败,不重试,caseId: {}, taskId: {}", caseId, deleteTaskId); + if (deleteSuccess != null && deleteSuccess) { + log.info("删除案例文档成功,caseId: {}, taskId: {}, 尝试次数: {}", caseId, deleteTaskId, attempt); + break; // 删除成功,跳出重试循环 + } else { + // 业务处理失败,不重试 + log.error("删除案例文档业务处理失败,不重试,caseId: {}, taskId: {}", caseId, deleteTaskId); return false; -// } + } } else { // 业务处理失败,不重试 log.error("删除案例文档业务处理失败,不重试,response: {}", responseBody);