mianbin/ops-pro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

方法字段添加

Browse Source
This commit is contained in:
even 2025-05-15 10:35:21 +08:00
parent 9e50fea94f
commit 2459515c98
2 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/stage/StageUpdateReq.java Normal file
View File

@ -0,0 +1,8 @@
package cd.casic.ci.common.pipeline.req.stage;
import lombok.Data;
@Data
public class StageUpdateReq {
private
}

14
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/stage/impl/StageServiceImpl.java
View File

@ -14,6 +14,7 @@ import cd.casic.ci.process.process.service.task.TaskService;
import cd.casic.framework.commons.exception.ServiceException; import cd.casic.framework.commons.exception.ServiceException;
import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants; import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants;
import cd.casic.framework.commons.util.object.BeanUtils; import cd.casic.framework.commons.util.object.BeanUtils;
import cd.casic.framework.commons.util.util.WebFrameworkUtils;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@ -52,6 +53,7 @@ public class StageServiceImpl extends ServiceImpl<PipStageDao, PipStage> impleme
String taskType = task.getTaskType(); String taskType = task.getTaskType();
Integer taskSort = task.getTaskSort(); Integer taskSort = task.getTaskSort();
String pipelineId = task.getPipelineId(); String pipelineId = task.getPipelineId();
Long loginUserId = WebFrameworkUtils.getLoginUserId();
PipStage firstStage = null; PipStage firstStage = null;
// 判断是否需要新建阶段,如果没有传第一级tageId而传了sort就是需要创建阶段 // 判断是否需要新建阶段,如果没有传第一级tageId而传了sort就是需要创建阶段
if (StringUtils.isEmpty(firstStageId)) { if (StringUtils.isEmpty(firstStageId)) {
@ -65,6 +67,10 @@ public class StageServiceImpl extends ServiceImpl<PipStageDao, PipStage> impleme
firstStage.setCreateTime(LocalDateTime.now()); firstStage.setCreateTime(LocalDateTime.now());
firstStage.setParentId("-1"); firstStage.setParentId("-1");
firstStage.setPipelineId(pipelineId); firstStage.setPipelineId(pipelineId);
firstStage.setCreateUserId(loginUserId);
firstStage.setUpdateUserId(loginUserId);
firstStage.setUpdateTime(LocalDateTime.now());
PipStage stageQuery = new PipStage(); PipStage stageQuery = new PipStage();
stageQuery.setPipelineId(pipelineId); stageQuery.setPipelineId(pipelineId);
stageQuery.setParentId("-1"); stageQuery.setParentId("-1");
@ -104,6 +110,11 @@ public class StageServiceImpl extends ServiceImpl<PipStageDao, PipStage> impleme
secondStage.setStageSort(pipStageList.size()+1); secondStage.setStageSort(pipStageList.size()+1);
} }
secondStage.setCreateTime(LocalDateTime.now()); secondStage.setCreateTime(LocalDateTime.now());
secondStage.setUpdateTime(LocalDateTime.now());
secondStage.setCreateUserId(loginUserId);
secondStage.setParentId(firstStageId);
secondStage.setPipelineId(pipelineId);
secondStage.setUpdateUserId(loginUserId);
save(secondStage); save(secondStage);
taskSort=1; taskSort=1;
secondStageId = secondStage.getStageId(); secondStageId = secondStage.getStageId();
@ -122,6 +133,9 @@ public class StageServiceImpl extends ServiceImpl<PipStageDao, PipStage> impleme
pipTask.setCreateTime(LocalDateTime.now()); pipTask.setCreateTime(LocalDateTime.now());
pipTask.setTaskProperties(taskProperties); pipTask.setTaskProperties(taskProperties);
pipTask.setPipelineId(pipelineId); pipTask.setPipelineId(pipelineId);
pipTask.setUpdateTime(LocalDateTime.now());
pipTask.setCreateUserId(loginUserId);
pipTask.setUpdateUserId(loginUserId);
taskService.save(pipTask); taskService.save(pipTask);
return pipTask.getTaskId(); return pipTask.getTaskId();
} }