4/28 ljc 修改postprocess路径,新增返回类result

This commit is contained in:
Hope Li 2025-04-28 11:25:09 +08:00
parent becd7a6a6d
commit 538806785c
10 changed files with 191 additions and 10 deletions

View File

@ -0,0 +1,73 @@
package cd.casic.ci.commons.bean.utils;
import lombok.Data;
import java.io.Serial;
import java.io.Serializable;
/**
* @ClassName Result
* @Author hopeli
* @Date 2025/4/28 10:51
* @Version 1.0
**/
@Data
public class Result<T> implements Serializable {
@Serial
private static final long serialVersionUID = -3654582015538398741L;
private int code;
private T data;
private String msg;
private String detailMsg;
public Result() {
}
public Result(T data) {
this.code = 0;
this.data = data;
}
public Result(T data, String msg) {
this.code = 0;
this.data = data;
this.msg = msg;
}
public Result(int code, String msg) {
this.code = code;
this.msg = msg;
}
public Result(int code, String msg, String detailMsg) {
this.code = code;
this.msg = msg;
this.detailMsg = detailMsg;
}
public static Result ok() {
return new Result();
}
public static <T> Result ok(T data) {
return new Result(data);
}
public static <T> Result ok(T data, String msg) {
return new Result(data, msg);
}
public static Result error(int code, String msg) {
return new Result(code, msg);
}
public static Result error(int code, String msg, String detailMsg) {
return new Result(code, msg, detailMsg);
}
public String toString() {
int var10000 = this.code;
return "Result{code=" + var10000 + ", data=" + String.valueOf(this.data) + ", msg='" + this.msg + "', detailMsg='" + this.detailMsg + "'}";
}
}

View File

@ -15,7 +15,7 @@ import cd.casic.framework.commons.exception.ServiceException;
import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants;
import cd.casic.module.process.engine.execute.PipelineExecService;
import cd.casic.module.process.engine.postprocess.PostprocessExecService;
import cd.casic.module.process.support.postprocess.service.PostprocessExecService;
import cd.casic.module.process.engine.task.TasksExecService;
import cd.casic.module.process.pipeline.instance.service.PipelineInstanceServiceImpl;
import cd.casic.module.process.process.definition.PipelineService;

View File

@ -0,0 +1,108 @@
package cd.casic.module.process.support.postprocess.controller;
import cd.casic.ci.commons.bean.engine.postprocess.Postprocess;
import cd.casic.ci.commons.bean.utils.Result;
import cd.casic.module.process.support.postprocess.service.PostprocessService;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import jakarta.validation.constraints.NotNull;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import java.util.List;
/**
* @ClassName PostprocessController
* @Author hopeli
* @Date 2025/4/28 10:43
* @Version 1.0
**/
public class PostprocessController {
@Resource
PostprocessService postServer;
/**
* @Author hopeli
* @Description //TODO
* @Date 10:47 2025/4/28
* @Param postprocess
* @return String
*/
@RequestMapping(path="/createPost",method = RequestMethod.POST)
public Result<String> createPost(@RequestBody @NotNull @Valid Postprocess postprocess){
String postId = postServer.createPostTask(postprocess);
return Result.ok(postId);
}
/**
* @Author hopeli
* @Description
* @Date 11:17 2025/4/28
* @Param postprocess
* @return void
*/
@RequestMapping(path="/updatePost",method = RequestMethod.POST)
public Result<Void> updatePost(@RequestBody @NotNull @Valid Postprocess postprocess){
postServer.updatePostTask(postprocess);
return Result.ok();
}
/**
* @Author hopeli
* @Description
* @Date 11:17 2025/4/28
* @Param
* @return
*/
@RequestMapping(path="/findPipelinePost",method = RequestMethod.POST)
public Result<List<Postprocess>> findAllPipelinePostTask(@NotNull String pipelineId) {
List<Postprocess> list = postServer.findAllPipelinePostTask(pipelineId);
return Result.ok(list);
}
/**
* @Author hopeli
* @Description
* @Date 11:22 2025/4/28
* @Param
* @return
*/
@RequestMapping(path="/findTaskPost",method = RequestMethod.POST)
public Result< List<Postprocess>> findAllTaskPostTask(@NotNull String taskId) {
List<Postprocess> list = postServer.findAllTaskPostTask(taskId);
return Result.ok(list);
}
/**
* @Author hopeli
* @Description
* @Date 11:22 2025/4/28
* @Param
* @return
*/
@RequestMapping(path="/deletePost",method = RequestMethod.POST)
public Result<Void> deletePost(@NotNull String postId) {
postServer.deletePostTask(postId);
return Result.ok();
}
/**
* @Author hopeli
* @Description
* @Date 11:22 2025/4/28
* @Param
* @return
*/
@RequestMapping(path="/findOnePost",method = RequestMethod.POST)
public Result<Postprocess> findOnePostOrTask(@NotNull String postId) {
Postprocess postOrTask = postServer.findOnePostOrTask(postId);
return Result.ok(postOrTask);
}
}

View File

@ -1,7 +1,7 @@
package cd.casic.module.process.engine.postprocess.dao;
package cd.casic.module.process.support.postprocess.dao;
import cd.casic.framework.mybatis.core.mapper.BaseMapperX;
import cd.casic.module.process.engine.postprocess.dataobject.PostprocessDo;
import cd.casic.module.process.support.postprocess.entity.PostprocessDo;
import org.apache.ibatis.annotations.Mapper;
/**

View File

@ -1,7 +1,7 @@
package cd.casic.module.process.engine.postprocess.dao;
package cd.casic.module.process.support.postprocess.dao;
import cd.casic.framework.mybatis.core.mapper.BaseMapperX;
import cd.casic.module.process.engine.postprocess.dataobject.PostprocessInstanceDo;
import cd.casic.module.process.support.postprocess.entity.PostprocessInstanceDo;
import org.apache.ibatis.annotations.Mapper;
/**

View File

@ -1,4 +1,4 @@
package cd.casic.module.process.engine.postprocess.dataobject;
package cd.casic.module.process.support.postprocess.entity;
import cd.casic.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.TableId;

View File

@ -1,4 +1,4 @@
package cd.casic.module.process.engine.postprocess.dataobject;
package cd.casic.module.process.support.postprocess.entity;
import cd.casic.framework.mybatis.core.dataobject.BaseDO;
import com.baomidou.mybatisplus.annotation.TableId;

View File

@ -1,4 +1,4 @@
package cd.casic.module.process.engine.postprocess;
package cd.casic.module.process.support.postprocess.service;
import cd.casic.ci.commons.bean.engine.postprocess.Postprocess;

View File

@ -1,4 +1,4 @@
package cd.casic.module.process.engine.postprocess;
package cd.casic.module.process.support.postprocess.service;
import cd.casic.ci.commons.bean.engine.postprocess.PostprocessInstance;

View File

@ -1,4 +1,4 @@
package cd.casic.module.process.engine.postprocess;
package cd.casic.module.process.support.postprocess.service;
import cd.casic.ci.commons.bean.engine.postprocess.Postprocess;