Skip to content

Commit 4900cdb

Browse files
authored
Update WorkFlowEngine.java
1 parent 820b5b0 commit 4900cdb

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/main/java/com/lnwazg/workflow/engine/WorkFlowEngine.java

+6-2
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import org.springframework.util.StringUtils;
1212

1313
import java.lang.reflect.Method;
14-
import java.util.HashMap;
1514
import java.util.LinkedHashMap;
1615
import java.util.Map;
1716

@@ -51,7 +50,7 @@ public void runWorkFlow(String workFlowName, WorkFlowContext workFlowContext) {
5150
flowNodeMap.put(m.getName(), m);
5251
}
5352
}
54-
logger.info("起始节点:" + startNodeMethod.getName() + ",后续可选节点:" + flowNodeMap.keySet());
53+
logger.info("流程【" + workFlowName + "】开始运行。起始节点:" + startNodeMethod.getName() + ",后续可选节点:" + flowNodeMap.keySet());
5554
try {
5655
//若未指定第一个节点的名称,则默认从首节点开始执行
5756
if (StringUtils.isEmpty(workFlowContext.getNextNodeName())) {
@@ -67,10 +66,15 @@ public void runWorkFlow(String workFlowName, WorkFlowContext workFlowContext) {
6766
workFlowContext.setNextNodeName(null);
6867
logger.info("开始执行节点【" + nextMethod.getName() + "】");
6968
nextMethod.invoke(workFlow, workFlowContext);
69+
} else {
70+
//指定了下个节点名称,但实际节点不存在,则直接结束整个流程。
71+
break;
7072
}
7173
}
7274
} catch (Exception e) {
7375
logger.error(workFlowName + "执行工作流出现异常", e);
76+
} finally {
77+
logger.info("流程【" + workFlowName + "】运行完毕。");
7478
}
7579
}
7680
}

0 commit comments

Comments
 (0)