Skip to content

Commit 3cd1214

Browse files
committed
[waterflow] 增加判断节点终态的方法
1 parent 46adec9 commit 3cd1214

1 file changed

Lines changed: 17 additions & 2 deletions

File tree

  • framework/waterflow/java/waterflow-core/src/main/java/modelengine/fit/waterflow/domain/enums

framework/waterflow/java/waterflow-core/src/main/java/modelengine/fit/waterflow/domain/enums/FlowNodeStatus.java

Lines changed: 17 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,10 @@
66

77
package modelengine.fit.waterflow.domain.enums;
88

9+
import java.util.Arrays;
10+
import java.util.HashSet;
11+
import java.util.Set;
12+
913
/**
1014
* 流程实例节点状态
1115
* 状态流转顺序:NEW -> PENDING(停留在EVENT边上) -> READY(进入到节点) -> PROCESSING(开始处理) -> ARCHIVED(处理完成)
@@ -54,13 +58,24 @@ public enum FlowNodeStatus {
5458
*/
5559
RETRYABLE;
5660

61+
private static final Set<FlowNodeStatus> END_STATUS = new HashSet<>(Arrays.asList(ARCHIVED, ERROR, TERMINATE));
62+
private static final Set<FlowNodeStatus> RUNNING_STATUS = new HashSet<>(Arrays.asList(NEW, PENDING, READY, PROCESSING));
63+
5764
/**
5865
* 判断是否在运行中的状态。
5966
*
6067
* @return 是否在运行中的状态。
6168
*/
6269
public boolean isRunningStatus() {
63-
return FlowNodeStatus.NEW.equals(this) || FlowNodeStatus.PENDING.equals(this)
64-
|| FlowNodeStatus.READY.equals(this) || FlowNodeStatus.PROCESSING.equals(this);
70+
return RUNNING_STATUS.contains(this);
71+
}
72+
73+
/**
74+
* 是否是终态。
75+
*
76+
* @return 是否是终态。
77+
*/
78+
public boolean isEndStatus() {
79+
return END_STATUS.contains(this);
6580
}
6681
}

0 commit comments

Comments
 (0)