package tech.powerjob.common.model;
|
|
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
|
import com.google.common.collect.Lists;
|
import lombok.Data;
|
import lombok.NoArgsConstructor;
|
import lombok.experimental.Accessors;
|
import tech.powerjob.common.enums.WorkflowNodeType;
|
|
import javax.annotation.Nonnull;
|
import javax.annotation.Nullable;
|
import java.io.Serializable;
|
import java.util.List;
|
|
/**
|
* Points & edges for DAG, making it easier to describe or transfer.
|
*
|
* @author tjq
|
* @since 2020/5/26
|
*/
|
@Data
|
@NoArgsConstructor
|
public class PEWorkflowDAG implements Serializable {
|
|
/**
|
* Nodes of DAG diagram.
|
*/
|
private List<Node> nodes;
|
/**
|
* Edges of DAG diagram.
|
*/
|
private List<Edge> edges;
|
|
/**
|
* Point.
|
*/
|
@Data
|
@Accessors(chain = true)
|
@NoArgsConstructor
|
public static class Node implements Serializable {
|
/**
|
* node id
|
*
|
* @since 20210128
|
*/
|
private Long nodeId;
|
/* Instance running param, which is not required by DAG. */
|
|
/**
|
* note type
|
*
|
* @see WorkflowNodeType
|
* @since 20210316
|
*/
|
private Integer nodeType;
|
/**
|
* job id or workflow id (if this Node type is a nested workflow)
|
*
|
* @see WorkflowNodeType#NESTED_WORKFLOW
|
*/
|
private Long jobId;
|
/**
|
* node name
|
*/
|
private String nodeName;
|
|
@JsonSerialize(using = ToStringSerializer.class)
|
private Long instanceId;
|
/**
|
* for decision node, it is JavaScript code
|
*/
|
private String nodeParams;
|
|
private Integer status;
|
/**
|
* for decision node, it only be can "true" or "false"
|
*/
|
private String result;
|
/**
|
* instanceId will be null if disable .
|
*/
|
private Boolean enable;
|
/**
|
* mark node which disable by control node.
|
*/
|
private Boolean disableByControlNode;
|
|
private Boolean skipWhenFailed;
|
|
private String startTime;
|
|
private String finishedTime;
|
|
public Node(Long nodeId) {
|
this.nodeId = nodeId;
|
this.nodeType = WorkflowNodeType.JOB.getCode();
|
}
|
|
public Node(Long nodeId, Integer nodeType) {
|
this.nodeId = nodeId;
|
this.nodeType = nodeType;
|
}
|
}
|
|
/**
|
* Edge formed by two node ids.
|
*/
|
@Data
|
@NoArgsConstructor
|
public static class Edge implements Serializable {
|
|
private Long from;
|
|
private Long to;
|
/**
|
* property,support for complex flow control
|
* for decision node , it can be "true" or "false"
|
*/
|
private String property;
|
|
private Boolean enable;
|
|
public Edge(long from, long to) {
|
this.from = from;
|
this.to = to;
|
}
|
|
public Edge(long from, long to, String property) {
|
this.from = from;
|
this.to = to;
|
this.property = property;
|
}
|
}
|
|
public PEWorkflowDAG(@Nonnull List<Node> nodes, @Nullable List<Edge> edges) {
|
this.nodes = nodes;
|
this.edges = edges == null ? Lists.newLinkedList() : edges;
|
}
|
}
|
