hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-07 01:46:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

[DAT] 接口失败时，业务状态设为null

Browse Source
This commit is contained in:
liu.zixi
2025-10-24 10:23:49 +08:00
parent 0e2e0861de
commit cf069a9700
1 changed files with 24 additions and 162 deletions
Download Patch File Download Diff File Expand all files Collapse all files

186
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java
View File

@@ -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<CaseDocumentLog> 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