From cf069a97000d0c1b4014d8d5892f50126f0129f5 Mon Sep 17 00:00:00 2001 From: "liu.zixi" Date: Fri, 24 Oct 2025 10:23:49 +0800 Subject: [PATCH] =?UTF-8?q?[DAT]=20=E6=8E=A5=E5=8F=A3=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E6=97=B6=EF=BC=8C=E4=B8=9A=E5=8A=A1=E7=8A=B6=E6=80=81=E8=AE=BE?= =?UTF-8?q?=E4=B8=BAnull?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/CaseKnowledgeServiceImpl.java | 186 +++--------------- 1 file changed, 24 insertions(+), 162 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 2769f4e0..9c942d26 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 @@ -104,7 +104,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，未找到有效的案例记录，caseId: {}", caseId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，未找到有效的案例记录", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -113,7 +113,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，案例文件路径为空，caseId: {}", caseId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，案例文件路径为空", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -124,7 +124,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，案例文件不存在，filePath: {}", filePath); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，案例文件不存在，filePath: " + filePath, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -161,7 +161,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，获取access_token失败"); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，获取access_token失败", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } for (int attempt = 1; attempt <= maxRetries; attempt++) { @@ -206,7 +206,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档接口调用失败，第{}次尝试，status: {}, response: {}", attempt, statusCode, responseBody); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), responseBody, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == maxRetries) { // 最后一次尝试仍然失败 return false; @@ -219,7 +219,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档接口调用异常，第{}次尝试", attempt, e); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.CREATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "接口调用异常: " + e.getMessage(), - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == maxRetries) { // 最后一次尝试仍然异常 log.error("上传案例文档最终失败，已重试{}次", maxRetries); @@ -253,7 +253,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档失败，未找到案例记录，caseId: {}", caseId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, "", "删除案例文档失败，未找到案例记录", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -268,7 +268,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档失败，未找到相关的日志记录，caseId: {}", caseId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, "", "删除案例文档失败，未找到相关的日志记录", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -279,7 +279,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, "kId=" + caseAiProperties.getCaseKnowledgeId() + "&taskIds=", "删除案例文档失败，日志记录中taskId为空", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } // 构建请求参数 @@ -292,7 +292,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档失败，获取access_token失败"); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, "删除案例文档失败，获取access_token失败", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -322,14 +322,12 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { // 接口调用成功，检查业务处理结果 JSONObject data = result.getJSONObject("data"); Boolean deleteSuccess = data.getBoolean(taskId); - - int optStatus = CaseDocumentLogOptStatusEnum.SUCCESS.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, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), optStatus, caseStatus, null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), caseStatus, null); if (deleteSuccess != null && deleteSuccess) { log.info("删除案例文档成功，caseId: {}, taskId: {}, 尝试次数: {}", caseId, taskId, attempt); @@ -352,7 +350,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档接口调用失败，第{}次尝试，status: {}, response: {}", attempt, statusCode, responseBody); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, responseBody, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == maxRetries) { // 最后一次尝试仍然失败 return false; @@ -365,7 +363,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档接口调用异常，第{}次尝试", attempt, e); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.DELETE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, "接口调用异常: " + e.getMessage(), - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == maxRetries) { // 最后一次尝试仍然异常 log.error("删除案例文档最终失败，已重试{}次", maxRetries); @@ -399,7 +397,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档失败，未找到案例记录，caseId: {}", caseId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, "", "删除案例文档失败，未找到案例记录", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -425,7 +423,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, "kId=" + caseAiProperties.getCaseKnowledgeId() + "&taskIds=", "删除案例文档失败，日志记录中taskId为空", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } // 构建请求参数 @@ -438,7 +436,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档失败，获取access_token失败"); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, "删除案例文档失败，获取access_token失败", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -468,14 +466,12 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { // 接口调用成功，检查业务处理结果 JSONObject data = result.getJSONObject("data"); Boolean deleteSuccess = data.getBoolean(deleteTaskId); - - int optStatus = CaseDocumentLogOptStatusEnum.SUCCESS.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(), optStatus, caseStatus, null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.SUCCESS.getCode(), caseStatus, null); if (deleteSuccess != null && deleteSuccess) { log.info("删除案例文档成功，caseId: {}, taskId: {}, 尝试次数: {}", caseId, deleteTaskId, attempt); @@ -498,7 +494,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档接口调用失败，第{}次尝试，status: {}, response: {}", attempt, statusCode, responseBody); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, responseBody, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == deleteMaxRetries) { // 最后一次尝试仍然失败 return false; @@ -511,7 +507,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("删除案例文档接口调用异常，第{}次尝试", attempt, e); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME, params, "接口调用异常: " + e.getMessage(), - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == deleteMaxRetries) { // 最后一次尝试仍然异常 log.error("删除案例文档最终失败，已重试{}次", deleteMaxRetries); @@ -532,7 +528,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，案例文件路径为空，caseId: {}", caseId); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，案例文件路径为空", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -543,7 +539,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，案例文件不存在，filePath: {}", filePath); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，案例文件不存在，filePath: " + filePath, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } @@ -582,7 +578,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档失败，获取access_token失败"); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "上传案例文档失败，获取access_token失败", - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); return false; } for (int attempt = 1; attempt <= uploadMaxRetries; attempt++) { @@ -627,7 +623,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档接口调用失败，第{}次尝试，status: {}, response: {}", attempt, statusCode, responseBody); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), responseBody, - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == uploadMaxRetries) { // 最后一次尝试仍然失败 return false; @@ -640,7 +636,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { log.error("上传案例文档接口调用异常，第{}次尝试", attempt, e); saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME, requestBody.toJSONString(), "接口调用异常: " + e.getMessage(), - CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); + CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), null, null); if (attempt == uploadMaxRetries) { // 最后一次尝试仍然异常 log.error("上传案例文档最终失败，已重试{}次", uploadMaxRetries); @@ -651,140 +647,6 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService { } return false; -// String requestBody = ""; -// String requestUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete"; -// String interfaceName = CaseAiConstants.CASE_DOC_DELETE_INTERFACE_NAME; -// -// String caseId = cases.getId(); -// if (cases == null) { -// log.error("更新案例文档失败，未找到案例记录，caseId: {}", caseId); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "更新案例文档失败，未找到案例记录", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// log.info("开始更新案例文档，caseId: {}", caseId); -// -// // 获取access_token -// String accessToken = aiAccessTokenService.getAccessToken(); -// if (StringUtil.isBlank(accessToken)) { -// log.error("更新案例文档失败，获取access_token失败"); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "更新案例文档失败，获取access_token失败", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// // 1. 根据案例ID查询最新一条CaseDocumentLog数据 -// List logList = caseDocumentLogDao.getGenericDao() -// .findList(CaseDocumentLog.class, 1, -// OrderCondition.desc("sysCreateTime"), -// FieldFilters.eq("caseId", caseId)); -// -// if (logList.isEmpty()) { -// log.error("调用删除接口时未找到相关的日志记录，caseId: {}", caseId); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "调用删除接口时未找到相关的日志记录", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// CaseDocumentLog latestLog = logList.get(0); -// String oldTaskId = latestLog.getTaskId(); -// if (StringUtil.isBlank(oldTaskId)) { -// log.error("调用删除接口时日志记录中taskId为空，caseId: {}", caseId); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "调用删除接口时日志记录中taskId为空", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// try { -// // 2. 先调用删除接口 -// String deleteParam = "kId=" + caseAiProperties.getCaseKnowledgeId() + "taskId=" + oldTaskId; -// requestUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete?" + deleteParam; -// requestBody = deleteParam; -// boolean deleteSuccess = callDeleteInterface(caseId, cases, accessToken); -// if (!deleteSuccess) { -// log.error("更新案例文档失败，删除接口调用失败，不继续执行上传操作，caseId: {}", caseId); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// deleteParam, "删除接口:失败，上传接口:未执行", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// // 3. 删除成功后，再调用上传接口 -// requestUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload"; -// interfaceName = CaseAiConstants.CASE_DOC_UPLOAD_INTERFACE_NAME; -// // 1. 检查文件路径 -// if (StringUtil.isBlank(cases.getFilePath())) { -// log.error("调用上传接口失败，案例文件路径为空，caseId: {}", caseId); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "调用上传接口失败，案例文件路径为空", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// String savePath = fileUploader.getSavePath(); -// String filePath = savePath + cases.getFilePath(); -// File file = new File(filePath); -// if (!file.exists()) { -// log.error("调用上传接口失败，案例文件不存在，filePath: {}", filePath); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "调用上传接口失败，案例文件不存在", -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } -// -// // 2. 构建上传参数 -// String fileName = cases.getFileName(); -// if (StringUtil.isBlank(fileName)) { -// fileName = file.getName(); -// } -// -// String fileType = getFileType(fileName); -// String userId = getCurrentUserId(); -// JSONObject uploadRequestBody = new JSONObject(); -// uploadRequestBody.put("userId", userId); -// uploadRequestBody.put("kId", caseAiProperties.getCaseKnowledgeId()); -// uploadRequestBody.put("fileName", fileName); -// uploadRequestBody.put("fileType", fileType); -// uploadRequestBody.put("parseType", "AUTO"); -// if (caseAiProperties.isFileUploadUseCallback()) { -// uploadRequestBody.put("callbackUrl", caseAiProperties.getFileUploadCallbackUrl()); -// } -// requestBody = uploadRequestBody.toJSONString(); -// -// String taskId = callUploadInterface(caseId, file, fileName, fileType, userId, accessToken, requestUrl); -// boolean uploadSuccess = StringUtil.isNotBlank(taskId); -// -// // 4. 根据结果保存一条CaseDocumentLog数据 -// int runStatus = uploadSuccess ? CaseDocumentLogRunStatusEnum.RUNNING.getCode() : CaseDocumentLogRunStatusEnum.COMPLETED.getCode(); -// Integer optStatus = uploadSuccess ? null : CaseDocumentLogOptStatusEnum.SUCCESS.getCode(); -// Integer caseStatus = uploadSuccess ? null : CaseDocumentLogCaseStatusEnum.FAILED.getCode(); -// String result = String.format("删除接口:成功，上传接口:%s", -// uploadSuccess ? "成功" : "失败"); -// -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, result, -// runStatus, optStatus, caseStatus, taskId); -// -// if (uploadSuccess) { -// log.info("更新案例文档成功，caseId: {}, taskId: {}", caseId, taskId); -// } else { -// log.error("更新案例文档失败，上传接口调用失败，caseId: {}", caseId); -// } -// -// return uploadSuccess; -// -// } catch (Exception e) { -// log.error("更新案例文档异常", e); -// saveCaseDocumentLog(caseId, cases.getTitle(), CaseDocumentLogOptTypeEnum.UPDATE.getCode(), interfaceName, -// requestBody, "更新异常: " + e.getMessage(), -// CaseDocumentLogRunStatusEnum.COMPLETED.getCode(), CaseDocumentLogOptStatusEnum.FAILED.getCode(), CaseDocumentLogCaseStatusEnum.FAILED.getCode(), null); -// return false; -// } } @Override