wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-2616) - 新增业务节点定时回调的事件

Browse Source
This commit is contained in:
wangli 2024-08-20 17:54:19 +08:00
parent f9573d06bf
commit 5575380783
1 changed files with 2 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineActivityCallbackEventListener.java
View File

@ -17,12 +17,9 @@ import java.util.List;
import java.util.Set; import java.util.Set;
import static cn.axzo.workflow.core.engine.event.BizCallbackEventImpl.BizCallbackEventType.CALLBACK; import static cn.axzo.workflow.core.engine.event.BizCallbackEventImpl.BizCallbackEventType.CALLBACK;
import static cn.axzo.workflow.core.engine.event.BizSpecifyAssigneeEventType.ADD_ASSIGNEE;
import static cn.axzo.workflow.core.engine.event.BizSpecifyAssigneeEventType.REMOVE_ASSIGNEE;
import static cn.axzo.workflow.core.engine.event.BizSpecifyAssigneeEventType.UPDATE_ASSIGNEE;
/** /**
* TODO * 业务节点回调事件
* *
* @author wangli * @author wangli
* @since 2024-08-20 17:47 * @since 2024-08-20 17:47
@ -45,13 +42,9 @@ public class EngineActivityCallbackEventListener extends AbstractFlowableEventLi
BizCallbackEventImpl.BizCallbackEventType type = (BizCallbackEventImpl.BizCallbackEventType) event.getType(); BizCallbackEventImpl.BizCallbackEventType type = (BizCallbackEventImpl.BizCallbackEventType) event.getType();
if (BIZ_CALLBACK_EVENTS.contains(type)) { if (BIZ_CALLBACK_EVENTS.contains(type)) {
switch (type) { switch (type) {
case ADD_ASSIGNEE: case CALLBACK:
getOrderedListeners().forEach(i -> i.onCallback(event)); getOrderedListeners().forEach(i -> i.onCallback(event));
break; break;
case UPDATE_ASSIGNEE:
break;
case REMOVE_ASSIGNEE:
break;
default: default:
} }
} }