public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

支持在NodeComponent里自定义beforeProcess和afterProcess,没有覆盖方式时，默认读取aspect里的方法

Browse Source
This commit is contained in:
陈秀信
2021-10-15 10:53:42 +08:00
parent 36c8b9a35e
commit 1b8e19d063
1 changed files with 21 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java
View File

@@ -73,17 +73,9 @@ public abstract class NodeComponent {
StopWatch stopWatch = new StopWatch();
stopWatch.start();
// process前置处理
if (ObjectUtil.isNotNull(ComponentScanner.cmpAroundAspect)) {
ComponentScanner.cmpAroundAspect.beforeProcess(this.getNodeId(), slot);
}
self.beforeProcess(this.getNodeId(), slot);
self.process();
// process后置处理
if (ObjectUtil.isNotNull(ComponentScanner.cmpAroundAspect)) {
ComponentScanner.cmpAroundAspect.afterProcess(this.getNodeId(), slot);
}
self.afterProcess(this.getNodeId(), slot);
stopWatch.stop();
@@ -109,6 +101,25 @@ public abstract class NodeComponent {
public abstract void process() throws Exception;
/**
* process前置处理
*/
public void beforeProcess(String nodeId, Slot slot) {
if (ObjectUtil.isNotNull(ComponentScanner.cmpAroundAspect)) {
ComponentScanner.cmpAroundAspect.beforeProcess(nodeId, slot);
}
}
/**
* process后置处理
*/
public void afterProcess(String nodeId, Slot slot) {
if (ObjectUtil.isNotNull(ComponentScanner.cmpAroundAspect)) {
ComponentScanner.cmpAroundAspect.afterProcess(nodeId, slot);
}
}
/**
* 是否进入该节点
* @return boolean