Skip to content

Commit 3dd9244

Browse files
author
qq_62395577
committed
修改后端代码,实现条件流程校验阶段对多节点的支持
1 parent 6a6942e commit 3dd9244

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/flowsengine/domain/flows/validators/rules/nodes/ParallelNodeRule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,6 @@ public class ParallelNodeRule implements NodeRule {
2525
*/
2626
@Override
2727
public void apply(FlowNode flowNode) {
28-
Validation.same(flowNode.getEvents().size(), EXPECT_EVENT_SIZE, exception("parallel node event size"));
28+
Validation.greaterThanOrEquals(flowNode.getEvents().size(), EXPECT_EVENT_SIZE, exception("parallel node event size"));
2929
}
3030
}

app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/flowsengine/domain/flows/validators/rules/nodes/StartNodeRule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ public class StartNodeRule implements NodeRule {
2727
*/
2828
@Override
2929
public void apply(FlowNode flowNode) {
30-
Validation.same(flowNode.getEvents().size(), EXPECT_EVENT_SIZE,
30+
Validation.greaterThanOrEquals(flowNode.getEvents().size(), EXPECT_EVENT_SIZE,
3131
() -> new WaterflowParamException(INVALID_START_NODE_EVENT_SIZE));
3232
validateNull(flowNode.getJober(), "start node jober should be null");
3333
validateTriggerMode(flowNode, "start node trigger mode");

app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/flowsengine/domain/flows/validators/rules/nodes/StateNodeRule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ public class StateNodeRule implements NodeRule {
2727
*/
2828
@Override
2929
public void apply(FlowNode flowNode) {
30-
Validation.same(flowNode.getEvents().size(), EXPECT_EVENT_SIZE,
30+
Validation.greaterThanOrEquals(flowNode.getEvents().size(), MINIMUM_EVENT_SIZE,
3131
() -> new WaterflowParamException(INVALID_STATE_NODE_EVENT_SIZE));
3232
if (!flowNode.getTriggerMode().isAuto()) {
3333
Validation.notNull(flowNode.getTask(), exception("Flow node task error"));

0 commit comments

Comments
 (0)