From aa5c13598de2d7368a58a04433ba7825fc148dab Mon Sep 17 00:00:00 2001 From: "liu.zixi" Date: Thu, 30 Oct 2025 14:10:58 +0800 Subject: [PATCH] =?UTF-8?q?[DAT]=20=E6=95=B0=E6=8D=AE=E6=8C=A1=E6=9D=BF?= =?UTF-8?q?=EF=BC=9A=E4=B8=9A=E5=8A=A1=E5=A4=84=E7=90=86=E5=A4=B1=E8=B4=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/CaseKnowledgeServiceImpl.java | 29 +++++++++++++------ 1 file changed, 20 insertions(+), 9 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 40f4cec7..bfdf42aa 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,9 +183,12 @@ 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.RUNNING.getCode(), null, null, taskId); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), taskId); log.info("上传案例文档成功，等待文档状态变更. caseId: {}, taskId: {}, 尝试次数: {}", caseId, taskId, attempt); return true; @@ -318,8 +321,9 @@ 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 = (deleteSuccess != null && deleteSuccess) ? +// CaseDocumentLogCaseStatusEnum.SUCCESS.getCode() : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); + int caseStatus = CaseDocumentLogCaseStatusEnum.FAILED.getCode(); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, responseBody, @@ -453,7 +457,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId); try (CloseableHttpClient httpClient = HttpClients.createDefault()) { - HttpPut httpPost = new HttpPut(uploadUrl); + HttpPost httpPost = new HttpPost(uploadUrl); httpPost.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode()); httpPost.setHeader("access_token", accessToken); @@ -472,9 +476,12 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { String taskId = data.getString("taskId"); // 保存成功的CaseDocumentLog记录 +// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, +// requestBody.toJSONString(), responseBody, +// CaseDocumentLogRunStatusEnum.RUNNING.getCode(), null, null, taskId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), responseBody, - CaseDocumentLogRunStatusEnum.RUNNING.getCode(), null, null, taskId); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), taskId); log.info("上传案例文档成功，等待文档状态变更. caseId: {}, taskId: {}, 尝试次数: {}", caseId, taskId, attempt); return true; @@ -595,8 +602,9 @@ 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 = (deleteSuccess != null && deleteSuccess) ? +// CaseDocumentLogCaseStatusEnum.SUCCESS.getCode() : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); + int caseStatus = CaseDocumentLogCaseStatusEnum.FAILED.getCode(); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, responseBody, @@ -714,7 +722,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId); try (CloseableHttpClient httpClient = HttpClients.createDefault()) { - HttpPut httpPost = new HttpPut(uploadUrl); + HttpPost httpPost = new HttpPost(uploadUrl); httpPost.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode()); httpPost.setHeader("access_token", accessToken); @@ -733,9 +741,12 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { String taskId = data.getString("taskId"); // 保存成功的CaseDocumentLog记录 +// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, +// requestBody.toJSONString(), responseBody, +// CaseDocumentLogRunStatusEnum.RUNNING.getCode(), null, null, taskId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), responseBody, - CaseDocumentLogRunStatusEnum.RUNNING.getCode(), null, null, taskId); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), taskId); log.info("上传案例文档成功，等待文档状态变更. caseId: {}, taskId: {}, 尝试次数: {}", caseId, taskId, attempt); return true;