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

0716 ljc 修改pipeline新增接口逻辑，使用雪花算法生成id

Browse Source
This commit is contained in:
HopeLi 2025-07-16 09:59:23 +08:00
parent b953dc1228
commit 296c2211ab
1 changed files with 0 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/pipeline/impl/PipelineServiceImpl.java
View File

@ -100,7 +100,6 @@ public class PipelineServiceImpl extends ServiceImpl<PipelineDao, PipPipeline> i
List<PipStage> pipStageList = new ArrayList<>(0);
List<PipTask> pipTaskList = new ArrayList<>(0);
Map<PipStage,Map<PipStage,List<PipTask>>> templateCopyPipelineMap = new HashMap<>();
PipPipeline pipeline = pipelineConverter.reqToDO(pipelineReq);
// 随机颜色
@ -170,7 +169,6 @@ public class PipelineServiceImpl extends ServiceImpl<PipelineDao, PipPipeline> i
//则代表大阶段下存在阶段子节点
childStageList.forEach(j->{
PipStage childStage = templateConverter.respToStage(j);
Map<PipStage,List<PipTask>> stageTaskMap = new HashMap<>();
childStage.setId(idWork.nextUUID(null));
childStage.setPipelineId(pipeline.getId());
@ -196,10 +194,8 @@ public class PipelineServiceImpl extends ServiceImpl<PipelineDao, PipPipeline> i
pipTask.setCreator(String.valueOf(WebFrameworkUtils.getLoginUserId()));
taskList.add(pipTask);
});
stageTaskMap.put(childStage,taskList);
pipTaskList.addAll(taskList);
}
templateCopyPipelineMap.put(pipStage,stageTaskMap);
});
}
});
@ -208,29 +204,6 @@ public class PipelineServiceImpl extends ServiceImpl<PipelineDao, PipPipeline> i
}
pipStageDao.insertBatch(pipStageList);
pipTaskDao.insertBatch(pipTaskList);
//清空数组
// pipStageList.clear();
// pipTaskList.clear();
//
// templateCopyPipelineMap.forEach((parentStage, childStages) -> {
//
// childStages.forEach((childStage, tasks) -> {
// childStage.setParentId(parentStage.getId());
// pipStageList.add(childStage);
//
// tasks.forEach(task -> {
// task.setStageId(childStage.getId());
// pipTaskList.add(task);
// });
// });
// });
// if (!CollectionUtils.isEmpty(pipStageList)){
// pipStageDao.updateBatch(pipStageList);
// }
// if (!CollectionUtils.isEmpty(pipTaskList)){
// pipTaskDao.updateBatch(pipTaskList);
// }
}
return pipeline.getId();