From 67afdbf867be1d00e23a91f8ce533310cd08fae6 Mon Sep 17 00:00:00 2001 From: Hope Li <1278288511@qq.com> Date: Sat, 10 May 2025 23:55:04 +0800 Subject: [PATCH] 0510 ljc --- .../framework/commons/dataobject/Group.java | 30 +++ .../commons/dataobject/PatchUser.java | 15 ++ .../framework/commons/dataobject/User.java | 26 ++ .../framework/commons/pojo/CommonResult.java | 4 + .../common/pipeline/req/env/EnvQueryReq.java | 24 ++ .../ci/common/pipeline/req/env/EnvReq.java | 27 +++ .../pipeline/req/group/GroupQueryReq.java | 22 ++ .../common/pipeline/req/group/GroupReq.java | 28 +++ .../req/pipeline/PipelineQueryReq.java | 48 ++++ .../pipeline/req/pipeline/PipelineReq.java | 169 +++++++++++++ .../ci/common/pipeline/resp/env/EnvResp.java | 27 +++ .../common/pipeline/resp/group/GroupResp.java | 28 +++ .../pipeline/resp/pipeline/PipelineResp.java | 169 +++++++++++++ .../server/controller/EnvController.java | 85 +++++++ .../server/controller/GroupController.java | 85 +++++++ .../server/controller/PipelineController.java | 225 ++++++++++++++++++ 16 files changed, 1012 insertions(+) create mode 100644 framework/commons/src/main/java/cd/casic/framework/commons/dataobject/Group.java create mode 100644 framework/commons/src/main/java/cd/casic/framework/commons/dataobject/PatchUser.java create mode 100644 framework/commons/src/main/java/cd/casic/framework/commons/dataobject/User.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvQueryReq.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvReq.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupQueryReq.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupReq.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineQueryReq.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineReq.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/env/EnvResp.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/group/GroupResp.java create mode 100644 modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/pipeline/PipelineResp.java create mode 100644 ops-server/src/main/java/cd/casic/server/controller/EnvController.java create mode 100644 ops-server/src/main/java/cd/casic/server/controller/GroupController.java create mode 100644 ops-server/src/main/java/cd/casic/server/controller/PipelineController.java diff --git a/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/Group.java b/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/Group.java new file mode 100644 index 0000000..218d165 --- /dev/null +++ b/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/Group.java @@ -0,0 +1,30 @@ +package cd.casic.framework.commons.dataobject; + +import lombok.Data; + +/** + * @ClassName group + * @Author hopeli + * @Date 2025/5/10 10:20 + * @Version 1.0 + */ +@Data +public class Group { + // id + private String id; + + // 环境名称 + private String groupName; + + // 创建时间 + private String createTime; + + /** + * @pi.model:User + * @pi.desc:用户 + */ + private User user; + + // 说明 + private String detail; +} diff --git a/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/PatchUser.java b/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/PatchUser.java new file mode 100644 index 0000000..21fee7b --- /dev/null +++ b/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/PatchUser.java @@ -0,0 +1,15 @@ +package cd.casic.framework.commons.dataobject; + +import lombok.Data; + +/** + * @ClassName PatchUser + * @Author hopeli + * @Date 2025/5/10 10:21 + * @Version 1.0 + */ +@Data +public class PatchUser { + private String userId; + private Integer roleType = 0; +} diff --git a/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/User.java b/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/User.java new file mode 100644 index 0000000..bc370e3 --- /dev/null +++ b/framework/commons/src/main/java/cd/casic/framework/commons/dataobject/User.java @@ -0,0 +1,26 @@ +package cd.casic.framework.commons.dataobject; + +import lombok.Data; + +/** + * @ClassName User + * @Author hopeli + * @Date 2025/5/10 10:19 + * @Version 1.0 + */ +@Data +public class User { + private String id; + private String name; + private String phone; + private String email; + private String avatar; + private String nickname; + private String dirId; + private String password; + private Integer status; + private Integer type; + private String openId; + private String newPassword; + +} diff --git a/framework/commons/src/main/java/cd/casic/framework/commons/pojo/CommonResult.java b/framework/commons/src/main/java/cd/casic/framework/commons/pojo/CommonResult.java index 1c08ce8..4c90fd0 100644 --- a/framework/commons/src/main/java/cd/casic/framework/commons/pojo/CommonResult.java +++ b/framework/commons/src/main/java/cd/casic/framework/commons/pojo/CommonResult.java @@ -82,6 +82,10 @@ public class CommonResult implements Serializable { return Objects.equals(code, GlobalErrorCodeConstants.SUCCESS.getCode()); } + public static CommonResult ok() { + return new CommonResult(); + } + @JsonIgnore // 避免 jackson 序列化 public boolean isSuccess() { return isSuccess(code); diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvQueryReq.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvQueryReq.java new file mode 100644 index 0000000..5135ebe --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvQueryReq.java @@ -0,0 +1,24 @@ +package cd.casic.ci.common.pipeline.req.env; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import lombok.Data; + +/** + * @ClassName EnvQueryReq + * @Author hopeli + * @Date 2025/5/10 11:03 + * @Version 1.0 + */ +@Data +public class EnvQueryReq { + // 环境名称 + private String envName; + + + // 用户ID + private String userId; + + + //@ApiProperty(name ="pageParam",desc = "分页参数") + private Page pageParam= new Page(); +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvReq.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvReq.java new file mode 100644 index 0000000..19e86c4 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/env/EnvReq.java @@ -0,0 +1,27 @@ +package cd.casic.ci.common.pipeline.req.env; + +import cd.casic.framework.commons.dataobject.User; +import lombok.Data; + +/** + * @ClassName EnvReq + * @Author hopeli + * @Date 2025/5/10 11:00 + * @Version 1.0 + */ +@Data +public class EnvReq { + // id + private String id; + + // 环境名称 + private String envName; + + // 创建时间 + private String createTime; + + private User user; + + // 说明 + private String detail; +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupQueryReq.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupQueryReq.java new file mode 100644 index 0000000..59fde49 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupQueryReq.java @@ -0,0 +1,22 @@ +package cd.casic.ci.common.pipeline.req.group; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import lombok.Data; + +/** + * @ClassName GroupQueryReq + * @Author hopeli + * @Date 2025/5/10 11:50 + * @Version 1.0 + */ +@Data +public class GroupQueryReq { + // 环境名称 + private String groupName; + + // 用户ID + private String userId; + + //@ApiProperty(name ="pageParam",desc = "分页参数") + private Page pageParam= new Page(); +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupReq.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupReq.java new file mode 100644 index 0000000..9a01ea6 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/group/GroupReq.java @@ -0,0 +1,28 @@ +package cd.casic.ci.common.pipeline.req.group; + +import cd.casic.framework.commons.dataobject.User; +import lombok.Data; + +/** + * @ClassName GroupReq + * @Author hopeli + * @Date 2025/5/10 11:47 + * @Version 1.0 + */ +@Data +public class GroupReq { + // id + private String id; + + // 环境名称 + private String groupName; + + // 创建时间 + private String createTime; + + + private User user; + + // 说明 + private String detail; +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineQueryReq.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineQueryReq.java new file mode 100644 index 0000000..67f12a5 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineQueryReq.java @@ -0,0 +1,48 @@ +package cd.casic.ci.common.pipeline.req.pipeline; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import lombok.Data; + +/** + * @ClassName PipelineQueryReq + * @Author hopeli + * @Date 2025/5/10 9:54 + * @Version 1.0 + */ +@Data +public class PipelineQueryReq { + private String userId; + + // 创建人 + private String createUserId; + + private String pipelineName; + + /** + * 流水线状态 1.运行中 2.未运行,3.等待执行 + */ + private Integer pipelineState; + + /** + * 流水线类型 1.多任务 2.多阶段 + */ + private Integer pipelineType; + + private Integer pipelinePower; + + private Integer pipelineFollow; + + private String[] idString; + + private boolean eqName; + + // 环境 + private String envId; + + // 分组 + private String groupId; + + + private Page pageParam= new Page(); + +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineReq.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineReq.java new file mode 100644 index 0000000..d98c9ba --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/req/pipeline/PipelineReq.java @@ -0,0 +1,169 @@ +package cd.casic.ci.common.pipeline.req.pipeline; + +import cd.casic.framework.commons.dataobject.Group; +import cd.casic.framework.commons.dataobject.PatchUser; +import cd.casic.framework.commons.dataobject.User; +import lombok.Data; +import org.springframework.boot.autoconfigure.couchbase.CouchbaseProperties; + +import java.util.List; + +/** + * @ClassName PipelineReq + * @Author hopeli + * @Date 2025/5/10 10:53 + * @Version 1.0 + */ +@Data +public class PipelineReq { + + /** + * @pi.name:id + * @pi.dataType:string + * @pi.desc:流水线id + * @pi.value:11111 + */ + private String id; + + /** + * @pi.name:name + * @pi.dataType:string + * @pi.desc:流水线名称 + * @pi.value:name + */ + private String name; + + /** + * @pi.model:User + * @pi.desc:用户 + */ + private User user; + + + /** + * @pi.model:Env + * @pi.desc:流水线环境 + */ + private CouchbaseProperties.Env env; + + /** + * @pi.model:Env + * @pi.desc:流水线组 + */ + private Group group; + + /** + * @pi.name:createTime + * @pi.dataType:string + * @pi.desc:流水线创建时间 + * @pi.value:createTime + */ + private String createTime; + + /** + * @pi.name:type + * @pi.dataType:Integer + * @pi.desc:流水线类型 1.多任务 2.多阶段 + * @pi.value: 1 + */ + private int type; + + /** + * @pi.name:state + * @pi.dataType:Integer + * @pi.desc:运行状态 1.未运行 2.运行中 + * @pi.value:1 + */ + private int state; + + /** + * @pi.name:power + * @pi.dataType:Integer + * @pi.desc:项目作用域 1.全局 2.项目 + * @pi.value:1 + */ + private int power; + + /** + * @pi.name:color + * @pi.dataType:Integer + * @pi.desc:颜色 1~5随机生成 + * @pi.value:2 + */ + private int color; + + /** + * @pi.name:template + * @pi.dataType:string + * @pi.desc:流水线模板 + * @pi.value:template + */ + private String template; + + /** + * @pi.name:collect + * @pi.dataType:Integer + * @pi.desc:收藏 0.未收藏 1.收藏 + * @pi.value:2 + */ + private int collect; + + /** + * @pi.model:userList + * @pi.desc:流水线成员 + */ + private List userList; + + + // 以下为统计信息 + + + /** + * @pi.model:execUser + * @pi.desc:用户(执行人) + */ + private User execUser; + + /** + * @pi.name:number + * @pi.dataType:Integer + * @pi.desc:执行次数 + * @pi.value:2 + */ + private Integer number; + + /** + * @pi.name:instanceId + * @pi.dataType:string + * @pi.desc:实例id + * @pi.value:instanceId + */ + private String instanceId; + + + /** + * @pi.name:buildStatus + * @pi.dataType:string + * @pi.desc:最近构建状态 + * @pi.value:buildStatus + */ + private String buildStatus; + + + /** + * @pi.name:lastBuildTime + * @pi.dataType:string + * @pi.desc:最近构建时间 + * @pi.value:lastBuildTime + */ + private String lastBuildTime; + + + /** + * @pi.name:isExec + * @pi.dataType:boolean + * @pi.desc:是否可以执行 + * @pi.value:true + */ + private Boolean isExec; +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/env/EnvResp.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/env/EnvResp.java new file mode 100644 index 0000000..5e2b166 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/env/EnvResp.java @@ -0,0 +1,27 @@ +package cd.casic.ci.common.pipeline.resp.env; + +import cd.casic.framework.commons.dataobject.User; +import lombok.Data; + +/** + * @ClassName EnvReq + * @Author hopeli + * @Date 2025/5/10 11:00 + * @Version 1.0 + */ +@Data +public class EnvResp { + // id + private String id; + + // 环境名称 + private String envName; + + // 创建时间 + private String createTime; + + private User user; + + // 说明 + private String detail; +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/group/GroupResp.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/group/GroupResp.java new file mode 100644 index 0000000..090f111 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/group/GroupResp.java @@ -0,0 +1,28 @@ +package cd.casic.ci.common.pipeline.resp.group; + +import cd.casic.framework.commons.dataobject.User; +import lombok.Data; + +/** + * @ClassName GroupResp + * @Author hopeli + * @Date 2025/5/10 11:47 + * @Version 1.0 + */ +@Data +public class GroupResp { + // id + private String id; + + // 环境名称 + private String groupName; + + // 创建时间 + private String createTime; + + + private User user; + + // 说明 + private String detail; +} diff --git a/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/pipeline/PipelineResp.java b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/pipeline/PipelineResp.java new file mode 100644 index 0000000..cfafb14 --- /dev/null +++ b/modules/module-ci-common-pipeline/src/main/java/cd/casic/ci/common/pipeline/resp/pipeline/PipelineResp.java @@ -0,0 +1,169 @@ +package cd.casic.ci.common.pipeline.resp.pipeline; + +import cd.casic.framework.commons.dataobject.Group; +import cd.casic.framework.commons.dataobject.PatchUser; +import cd.casic.framework.commons.dataobject.User; +import lombok.Data; +import org.springframework.boot.autoconfigure.couchbase.CouchbaseProperties; + +import java.util.List; + +/** + * @ClassName PipelineResp + * @Author hopeli + * @Date 2025/5/10 10:53 + * @Version 1.0 + */ +@Data +public class PipelineResp { + + /** + * @pi.name:id + * @pi.dataType:string + * @pi.desc:流水线id + * @pi.value:11111 + */ + private String id; + + /** + * @pi.name:name + * @pi.dataType:string + * @pi.desc:流水线名称 + * @pi.value:name + */ + private String name; + + /** + * @pi.model:User + * @pi.desc:用户 + */ + private User user; + + + /** + * @pi.model:Env + * @pi.desc:流水线环境 + */ + private CouchbaseProperties.Env env; + + /** + * @pi.model:Env + * @pi.desc:流水线组 + */ + private Group group; + + /** + * @pi.name:createTime + * @pi.dataType:string + * @pi.desc:流水线创建时间 + * @pi.value:createTime + */ + private String createTime; + + /** + * @pi.name:type + * @pi.dataType:Integer + * @pi.desc:流水线类型 1.多任务 2.多阶段 + * @pi.value: 1 + */ + private int type; + + /** + * @pi.name:state + * @pi.dataType:Integer + * @pi.desc:运行状态 1.未运行 2.运行中 + * @pi.value:1 + */ + private int state; + + /** + * @pi.name:power + * @pi.dataType:Integer + * @pi.desc:项目作用域 1.全局 2.项目 + * @pi.value:1 + */ + private int power; + + /** + * @pi.name:color + * @pi.dataType:Integer + * @pi.desc:颜色 1~5随机生成 + * @pi.value:2 + */ + private int color; + + /** + * @pi.name:template + * @pi.dataType:string + * @pi.desc:流水线模板 + * @pi.value:template + */ + private String template; + + /** + * @pi.name:collect + * @pi.dataType:Integer + * @pi.desc:收藏 0.未收藏 1.收藏 + * @pi.value:2 + */ + private int collect; + + /** + * @pi.model:userList + * @pi.desc:流水线成员 + */ + private List userList; + + + // 以下为统计信息 + + + /** + * @pi.model:execUser + * @pi.desc:用户(执行人) + */ + private User execUser; + + /** + * @pi.name:number + * @pi.dataType:Integer + * @pi.desc:执行次数 + * @pi.value:2 + */ + private Integer number; + + /** + * @pi.name:instanceId + * @pi.dataType:string + * @pi.desc:实例id + * @pi.value:instanceId + */ + private String instanceId; + + + /** + * @pi.name:buildStatus + * @pi.dataType:string + * @pi.desc:最近构建状态 + * @pi.value:buildStatus + */ + private String buildStatus; + + + /** + * @pi.name:lastBuildTime + * @pi.dataType:string + * @pi.desc:最近构建时间 + * @pi.value:lastBuildTime + */ + private String lastBuildTime; + + + /** + * @pi.name:isExec + * @pi.dataType:boolean + * @pi.desc:是否可以执行 + * @pi.value:true + */ + private Boolean isExec; +} diff --git a/ops-server/src/main/java/cd/casic/server/controller/EnvController.java b/ops-server/src/main/java/cd/casic/server/controller/EnvController.java new file mode 100644 index 0000000..151a6ff --- /dev/null +++ b/ops-server/src/main/java/cd/casic/server/controller/EnvController.java @@ -0,0 +1,85 @@ +package cd.casic.server.controller; + +import cd.casic.ci.common.pipeline.req.env.EnvQueryReq; +import cd.casic.ci.common.pipeline.req.env.EnvReq; +import cd.casic.ci.common.pipeline.resp.env.EnvResp; +import cd.casic.framework.commons.pojo.CommonResult; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import jakarta.validation.Valid; +import org.jetbrains.annotations.NotNull; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.ArrayList; +import java.util.List; + +/** + * @ClassName EnvController + * @Author hopeli + * @Date 2025/5/10 10:57 + * @Version 1.0 + */ + +@RestController +@RequestMapping("/env") +public class EnvController { + + @PostMapping(path="/createEnv") + public CommonResult createEnv(@RequestBody @NotNull @Valid EnvReq envReq){ + +// String pipelineAuthHostId = envService.createEnv(env); + + String envId = "1"; + return CommonResult.success(envId); + } + + + @PostMapping(path="/deleteEnv") + public CommonResult deleteEnv(@NotNull String envId){ + +// envService.deleteEnv(envId); + + return CommonResult.ok(); + } + + @PostMapping(path="/findEnvList") + public CommonResult> findOnePipeline(@NotNull EnvQueryReq query){ + +// List envList = envService.findEnvList(envQuery); + List envRespList = new ArrayList<>(0); + EnvResp envResp = new EnvResp(); + envResp.setId("1"); + envResp.setEnvName("test数据交互测试"); + envRespList.add(envResp); + + return CommonResult.success(envRespList); + } + + + + @PostMapping(path="/updateEnv") + public CommonResult updateEnv(@RequestBody @NotNull @Valid EnvReq envReq){ + +// this.envService.updateEnv(env); + + return CommonResult.ok(); + } + + + @PostMapping(path="/findEnvPage") + public CommonResult> findEnvPage(@RequestBody @NotNull @Valid EnvQueryReq query){ + +// Pagination envPage = envService.findEnvPage(envQuery); + Page envRespPage = new Page<>(); + List envRespList = new ArrayList<>(0); + EnvResp envResp = new EnvResp(); + envResp.setId("1"); + envResp.setEnvName("test数据交互测试"); + envRespList.add(envResp); + envRespPage.setRecords(envRespList); + return CommonResult.success(envRespPage); + } + +} diff --git a/ops-server/src/main/java/cd/casic/server/controller/GroupController.java b/ops-server/src/main/java/cd/casic/server/controller/GroupController.java new file mode 100644 index 0000000..1ebdb5d --- /dev/null +++ b/ops-server/src/main/java/cd/casic/server/controller/GroupController.java @@ -0,0 +1,85 @@ +package cd.casic.server.controller; + +import cd.casic.ci.common.pipeline.req.group.GroupQueryReq; +import cd.casic.ci.common.pipeline.req.group.GroupReq; +import cd.casic.ci.common.pipeline.resp.group.GroupResp; +import cd.casic.framework.commons.pojo.CommonResult; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import jakarta.validation.Valid; +import org.jetbrains.annotations.NotNull; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.ArrayList; +import java.util.List; + +/** + * @ClassName GroupController + * @Author hopeli + * @Date 2025/5/10 10:57 + * @Version 1.0 + */ + +@RestController +@RequestMapping("/group") +public class GroupController { + + @PostMapping(path="/createGroup") + public CommonResult createGroup(@RequestBody @NotNull @Valid GroupReq groupReq){ + +// String pipelineAuthHostId = groupService.createGroup(group); + + String envId = "1"; + return CommonResult.success(envId); + } + + + @PostMapping(path="/deleteGroup") + public CommonResult deleteGroup(@NotNull String groupId){ + +// groupService.deleteGroup(groupId); + + return CommonResult.ok(); + } + + @PostMapping(path="/findGroupList") + public CommonResult> findGroupList(@NotNull GroupQueryReq query){ + +// List groupList = groupService.findGroupList(groupQuery); + List groupRespList = new ArrayList<>(0); + GroupResp groupResp = new GroupResp(); + groupResp.setId("1"); + groupResp.setGroupName("test数据交互测试"); + groupRespList.add(groupResp); + + return CommonResult.success(groupRespList); + } + + + + @PostMapping(path="/updateGroup") + public CommonResult updateGroup(@RequestBody @NotNull @Valid GroupReq groupReq){ + +// this.groupService.updateGroup(group); + + return CommonResult.ok(); + } + + + @PostMapping(path="/findGroupPage") + public CommonResult> findGroupPage(@RequestBody @NotNull @Valid GroupQueryReq query){ + +// Pagination groupPage = groupService.findGroupPage(groupQuery); + Page groupRespPage = new Page<>(); + List groupRespList = new ArrayList<>(0); + GroupResp groupResp = new GroupResp(); + groupResp.setId("1"); + groupResp.setGroupName("test数据交互测试"); + groupRespList.add(groupResp); + groupRespPage.setRecords(groupRespList); + return CommonResult.success(groupRespPage); + } + +} diff --git a/ops-server/src/main/java/cd/casic/server/controller/PipelineController.java b/ops-server/src/main/java/cd/casic/server/controller/PipelineController.java new file mode 100644 index 0000000..090aaf9 --- /dev/null +++ b/ops-server/src/main/java/cd/casic/server/controller/PipelineController.java @@ -0,0 +1,225 @@ +package cd.casic.server.controller; + +import cd.casic.ci.common.pipeline.req.pipeline.PipelineQueryReq; +import cd.casic.ci.common.pipeline.req.pipeline.PipelineReq; +import cd.casic.ci.common.pipeline.resp.pipeline.PipelineResp; +import cd.casic.framework.commons.dataobject.User; +import cd.casic.framework.commons.pojo.CommonResult; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import jakarta.validation.Valid; +import org.jetbrains.annotations.NotNull; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.ArrayList; +import java.util.List; + +/** + * @ClassName PipelineController + * @Author hopeli + * @Date 2025/5/10 10:28 + * @Version 1.0 + */ + +@RestController +@RequestMapping("/pipeline") +public class PipelineController { + + @PostMapping(path="/createPipeline") + public CommonResult createPipeline(@RequestBody @NotNull @Valid PipelineReq pipelineReq){ + +// String pipelineId = pipelineService.createPipeline(pipeline); + + String pipelineId = "1"; + return CommonResult.success(pipelineId); + } + + + @PostMapping(path="/findAllPipeline") + public CommonResult> findAllPipeline(){ + +// List selectAllPipeline = pipelineService.findAllPipeline(); + + List selectAllPipeline = new ArrayList<>(0); + return CommonResult.success(selectAllPipeline); + } + + @PostMapping(path="/deletePipeline") + public CommonResult deletePipeline(@NotNull String pipelineId){ + +// pipelineService.deletePipeline(pipelineId); + + return CommonResult.ok(); + } + + @PostMapping(path="/findOnePipeline") + public CommonResult> findOnePipeline(@NotNull String pipelineId){ + +// Pipeline pipeline = pipelineService.findOnePipeline(pipelineId); + List pipelineRespList = new ArrayList<>(0); + PipelineResp pipeline = new PipelineResp(); + pipeline.setId("1"); + pipeline.setName("test数据交互测试"); + pipelineRespList.add(pipeline); + + return CommonResult.success(pipelineRespList); + } + + @PostMapping(path="/findPipelineNoQuery") + public CommonResult findPipelineNoQuery(@NotNull String pipelineId){ + +// Pipeline pipeline = pipelineService.findPipelineNoQuery(pipelineId); + + PipelineResp pipeline = new PipelineResp(); + pipeline.setId("1"); + pipeline.setName("test数据交互测试"); + + return CommonResult.success(pipeline); + } + +// @RequestMapping(path="/updatePipelineRootUser",method = RequestMethod.POST) +// // @ApiMethod(name = "updatePipelineRootUser",desc = "更新流水线负责人") +// // @ApiParam(name = "dmRolePatch",desc = "流水线负责人信息",required = true) +// public Result updatePipelineRootUser(@RequestBody @NotNull @Valid DmRolePatch dmRolePatch){ +// +// pipelineService.updatePipelineRootUser(dmRolePatch); +// +// return Result.ok(); +// } + + + @PostMapping(path="/updatePipeline") + public CommonResult updatePipeline(@RequestBody @NotNull @Valid PipelineReq pipeline){ + +// pipelineService.updatePipeline(pipeline); + + return CommonResult.ok(); + } + + + @PostMapping(path="/findUserPipelinePage") + public CommonResult> findUserPipelinePage(@RequestBody @NotNull @Valid PipelineQueryReq query){ + +// Pagination userPipeline = pipelineService.findUserPipelinePage(query); + Page pipelineRespPage = new Page<>(); + List pipelineRespList = new ArrayList<>(0); + PipelineResp pipeline = new PipelineResp(); + pipeline.setId("1"); + pipeline.setName("test数据交互测试"); + pipelineRespList.add(pipeline); + pipelineRespPage.setRecords(pipelineRespList); + return CommonResult.success(pipelineRespPage); + } + + + + @PostMapping(path="/findUserPipeline") + public CommonResult> findAllUserPipeline(@RequestBody @NotNull @Valid PipelineQueryReq query){ +// List userPipeline = pipelineService.findUserPipeline(query); + + List pipelineRespList = new ArrayList<>(0); + PipelineResp pipeline = new PipelineResp(); + pipeline.setId("1"); + pipeline.setName("test数据交互测试"); + pipelineRespList.add(pipeline); + return CommonResult.success(pipelineRespList); + } + + + @PostMapping(path="/findPipelineUser") + public CommonResult> findPipelineUser(@NotNull String pipelineId){ + +// List dmUser = pipelineService.findPipelineUser(pipelineId); + List userList = new ArrayList<>(0); + User user = new User(); + user.setId("1"); + user.setName("test数据交互测试"); + userList.add(user); + return CommonResult.success(userList); + } + + + + + @PostMapping(path="/pipelineClone") + public CommonResult pipelineClone(@NotNull String pipelineId,@NotNull String pipelineName){ + +// pipelineService.pipelineClone(pipelineId,pipelineName); + + return CommonResult.ok(); + } + + @PostMapping(path="/findPipelineCloneName") + public CommonResult findPipelineCloneName(@NotNull String pipelineId){ + +// String name = pipelineService.findPipelineCloneName(pipelineId); + String name = "test"; + + return CommonResult.success(name); + } + + +// /** +// * @pi.name:获取最近打开的流水线 +// * @pi.url:/findRecentlyPipeline +// * @pi.methodType:post +// * @pi.request-type: formdata +// * @pi.param: name=number;dataType=Integer;value=查询数量; +// * @pi.param: name=pipelineId;dataType=String;value=流水线id; +// */ +// @RequestMapping(path="/findRecentlyPipeline",method = RequestMethod.POST) +// public Result findRecentlyPipeline(@NotNull Integer number,@NotNull String pipelineId){ +// +// List pipelineList = pipelineService.findRecentlyPipeline(number,pipelineId); +// +// return Result.ok(pipelineList); +// } + + +// /** +// * @pi.name:流水线导出为Yaml格式 +// * @pi.url:/importPipelineYaml +// * @pi.methodType:post +// * @pi.request-type: formdata +// * @pi.param: name=request;dataType=HttpServletResponse;value=请求; +// * @pi.param: name=response;dataType=HttpServletRequest;value=请求体; +// */ +// @RequestMapping(path="/importPipelineYaml",method = RequestMethod.POST) +// public ResponseEntity importPipelineYaml(HttpServletRequest request, HttpServletResponse response) { +// try { +// Map parameterMap = request.getParameterMap(); +// +// String pipelineId = Arrays.toString(parameterMap.get("pipelineId")).replace("[","").replace("]",""); +// +// String yamlString = yamlService.importPipelineYaml(pipelineId); +// +// Pipeline pipeline = pipelineService.findPipelineById(pipelineId); +// +// String tempFile = PipelineFileUtil.createTempFile(yamlString, ".yaml"); +// File file = new File(tempFile); +// BufferedInputStream in = new BufferedInputStream(new FileInputStream(file)); +// +// ServletOutputStream outputStream = response.getOutputStream(); +// response.setHeader("Content-Disposition", "attachment; filename="+pipeline.getName()); +// response.setContentLength((int) file.length()); +// +// int buf_size = 1024; +// byte[] buffer = new byte[buf_size]; +// int len = 0; +// while (-1 != (len = in.read(buffer, 0, buf_size))) { +// outputStream.write(buffer,0,len); +// } +// in.close(); +// outputStream.close(); +// +// file.delete(); +// +// return ResponseEntity.ok().build(); +// } catch (Exception e) { +// e.printStackTrace(); +// return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(Result.error(1000,"下载失败")); +// } +// } +}