toolchaintechnologycenter/spdm-backend
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1、修改下发任务报错信息

Browse Source
This commit is contained in:
lidongyang
2026-03-03 11:33:51 +08:00
parent 661f26645e
commit a8b2ccfc9a
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
project/src/main/java/com/sdm/project/service/impl/TaskServiceImpl.java
View File

@@ -161,6 +161,10 @@ public class TaskServiceImpl implements ITaskService {
// 利元亨工号位数（五位数）
private static final int LYRIC_JOB_NUMBER_LENGTH = 5;
private static final String CREATE_DIR_ERROR_MSG_DIR_EXIST = "目录已存在";
private static final String CONVERT_CREATE_DIR_ERROR_MSG_DIR_EXIST = "任务已存在";
/**
* 预处理请求参数
@@ -2521,7 +2525,7 @@ public class TaskServiceImpl implements ITaskService {
createDirReq.setDirType(DirTypeEnum.PROJECT_NODE_DIR.getValue());
log.info("批量修改任务时调用创建文件夹的参数为：{}", createDirReq);
SdmResponse response = dataClientFeignClient.createDir(createDirReq);
log.info("批量修改任务时同步CID调用创建文件夹的返回值为：{}", response);
log.info("批量修改任务时调用创建文件夹的返回值为：{}", response);
return response;
}
@@ -4178,15 +4182,15 @@ public class TaskServiceImpl implements ITaskService {
String maxNonEmptyTag = getMaxNonEmptyTag(spdmBatchTaskOprTagReq);
log.info("maxNonEmptyTag为：{}",maxNonEmptyTag);
if (StringUtils.isBlank(maxNonEmptyTag)) {
log.error("新建任务：{}的文件夹失败，原因为：{}", task.getTaskName(), "未查询到任务上层节点");
log.error("{}创建失败，原因为：{}", task.getTaskName(), "未查询到任务上层节点");
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return SdmResponse.failed("新建任务:" + task.getTaskName() + "的文件夹失败，原因：" + "未查询到任务上层节点");
return SdmResponse.failed(task.getTaskName() + "创建失败，原因：未查询到任务上层节点");
}
SdmResponse taskCreateDirResponse = createDirNew(task.getUuid(), NodeTypeEnum.TASK.getValue(), maxNonEmptyTag, task.getTaskName());
if (ObjectUtils.isEmpty(taskCreateDirResponse) || taskCreateDirResponse.getCode() != ResultCode.SUCCESS.getCode()) {
log.error("新建任务：{}的文件夹失败，原因为：{}", task.getTaskName(), taskCreateDirResponse.getMessage());
log.error("{}创建失败，原因为：{}", task.getTaskName(), convertErrorMsg(taskCreateDirResponse.getMessage()));
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return SdmResponse.failed("新建任务:" + task.getTaskName() + "的文件夹失败，原因：" + taskCreateDirResponse.getMessage());
return SdmResponse.failed(task.getTaskName() + "创建失败，原因：" + convertErrorMsg(taskCreateDirResponse.getMessage()));
}
}
}
@@ -4199,6 +4203,12 @@ public class TaskServiceImpl implements ITaskService {
return SdmResponse.success();
}
private String convertErrorMsg(String message) {
if (CREATE_DIR_ERROR_MSG_DIR_EXIST.equals(message)){
return CONVERT_CREATE_DIR_ERROR_MSG_DIR_EXIST;
}
return message;
}
@Override