third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add workflow context info into fetching workflow instance api

Browse Source
This commit is contained in:
Echo009 2021-02-26 10:34:34 +08:00
parent cea2c0cc87
commit 539d31007c
2 changed files with 45 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/response/WorkflowInstanceInfoDTO.java
View File

@ -19,19 +19,33 @@ public class WorkflowInstanceInfoDTO {
private Long wfInstanceId; private Long wfInstanceId;
private Long workflowId; private Long workflowId;
// workflow 状态（WorkflowInstanceStatus） /**
* workflow 状态（WorkflowInstanceStatus）
*/
private Integer status; private Integer status;
// 工作流启动参数 /**
* 工作流启动参数
*/
private String wfInitParams; private String wfInitParams;
/**
* 工作流上下文
*/
private String wfContext;
private String dag; private String dag;
private String result; private String result;
// 预计触发时间 /**
* 预计触发时间
*/
private Long expectedTriggerTime; private Long expectedTriggerTime;
// 实际触发时间 /**
* 实际触发时间
*/
private Long actualTriggerTime; private Long actualTriggerTime;
// 结束时间 /**
* 结束时间
*/
private Long finishedTime; private Long finishedTime;
private Date gmtCreate; private Date gmtCreate;

33
powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/WorkflowInstanceInfoVO.java
View File

@ -17,26 +17,45 @@ import org.springframework.beans.BeanUtils;
@Data @Data
public class WorkflowInstanceInfoVO { public class WorkflowInstanceInfoVO {
// workflowInstanceId（任务实例表都使用单独的ID作为主键以支持潜在的分表需求） /**
* workflowInstanceId（任务实例表都使用单独的ID作为主键以支持潜在的分表需求）
*/
private String wfInstanceId; private String wfInstanceId;
private String workflowId; private String workflowId;
// 工作流名称，通过 workflowId 查询获取 /**
* 工作流名称，通过 workflowId 查询获取
*/
private String workflowName; private String workflowName;
// workflow 状态（WorkflowInstanceStatus） /**
* workflow 状态（WorkflowInstanceStatus）
*/
private Integer status; private Integer status;
// 工作流启动参数 /**
* 工作流启动参数
*/
private String wfInitParams; private String wfInitParams;
/**
* 工作流上下文
*/
private String wfContext;
private PEWorkflowDAG pEWorkflowDAG; private PEWorkflowDAG pEWorkflowDAG;
private String result; private String result;
// 预计触发时间 /**
* 预计触发时间
*/
private String expectedTriggerTime; private String expectedTriggerTime;
// 实际触发时间（需要格式化为人看得懂的时间） /**
* 实际触发时间（需要格式化为人看得懂的时间）
*/
private String actualTriggerTime; private String actualTriggerTime;
// 结束时间（同理，需要格式化） /**
* 结束时间（同理，需要格式化）
*/
private String finishedTime; private String finishedTime;
public static WorkflowInstanceInfoVO from(WorkflowInstanceInfoDO wfInstanceDO, String workflowName) { public static WorkflowInstanceInfoVO from(WorkflowInstanceInfoDO wfInstanceDO, String workflowName) {