net.sohelp.boot.engine.workflow.core

类 FlowEngineImpl

java.lang.Object

net.sohelp.boot.engine.workflow.core.FlowEngineImpl

所有已实现的接口:

FlowEngine

public class FlowEngineImpl
extends Object
implements FlowEngine

基本的流程引擎实现类

从以下版本开始:

2025/02/03 10:26

字段概要

字段

限定符和类型	字段和说明
protected FlowContext	flowLongContext 配置对象

构造器概要

构造器

构造器和说明
FlowEngineImpl()

方法概要

限定符和类型	方法和说明
boolean	autoCompleteTask(Long taskId, Map<String,Object> args, FlowCreator flowCreator) 自动完成任务
boolean	autoJumpTask(Long taskId, Map<String,Object> args, FlowCreator flowCreator) 自动跳转任务
boolean	autoRejectTask(FlwTask flwTask, Map<String,Object> args, FlowCreator flowCreator) 自动拒绝任务
FlowEngine	configure(FlowContext flowLongContext) 根据Configuration对象配置实现类
protected Execution	createExecution(ProcessModel processModel, FlwInstance flwInstance, FlwTask flwTask, FlowCreator flowCreator, Map<String,Object> args)
List<FlwTask>	createNewTask(Long taskId, TaskType taskType, PerformType performType, List<FlwTaskActor> taskActors, FlowCreator flowCreator, Map<String,Object> args) 根据已有任务、参与者创建新的任务 适用于动态转派，动态协办等处理且流程图中不体现节点情况
boolean	executeAppendNodeModel(Long taskId, NodeModel nodeModel, FlowCreator flowCreator, Map<String,Object> args, boolean beforeAfter) 执行追加节点模型
Optional<FlwTask>	executeJumpTask(Long taskId, String nodeKey, FlowCreator flowCreator, Map<String,Object> args, TaskType taskTye)
Optional<FlwTask>	executeRejectTask(FlwTask currentFlwTask, String nodeKey, FlowCreator flowCreator, Map<String,Object> args) 根据当前任务对象驳回至指定 nodeKey 节点，如果 nodeKey 为空默认为上一步处理
boolean	executeTask(Long taskId, FlowCreator flowCreator, Map<String,Object> args) 根据任务ID，创建人，参数列表执行任务
protected boolean	executeTask(Long taskId, FlowCreator flowCreator, Map<String,Object> args, TaskState taskState, TaskEventType eventType)
FlowContext	getContext()
protected FlwInstance	getFlwInstance(Long instanceId, String updateBy) 获取流程实例
void	restartProcessInstance(Long id, String currentNodeKey, Execution execution) 重启流程实例（从当前所在节点currentNode位置开始）
Optional<FlwInstance>	startInstanceById(Long id, FlowCreator flowCreator, Map<String,Object> args, Supplier<FlwInstance> supplier) 根据流程定义ID，创建人，参数列表启动流程实例
Optional<FlwInstance>	startInstanceByProcessKey(String processKey, Integer version, FlowCreator flowCreator, Map<String,Object> args, Supplier<FlwInstance> supplier) 根据流程定义key、版本号、创建人、参数列表启动流程实例
Optional<FlwInstance>	startProcessInstance(FlwProcess process, FlowCreator flowCreator, Map<String,Object> args, Supplier<FlwInstance> supplier) 根据流程对象启动流程实例

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 net.sohelp.boot.engine.workflow.FlowEngine

autoCompleteTask, autoCompleteTask, autoJumpTask, autoRejectTask, autoRejectTask, executeAppendNodeModel, executeJumpTask, executeJumpTask, executeRejectTask, executeTask, processService, queryService, runtimeService, startInstanceById, startInstanceById, startInstanceById, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, taskService

字段详细资料

flowLongContext

protected FlowContext flowLongContext

配置对象

构造器详细资料

FlowEngineImpl

public FlowEngineImpl()

方法详细资料

configure

public FlowEngine configure(FlowContext flowLongContext)

从接口复制的说明: FlowEngine

根据Configuration对象配置实现类

指定者:

configure 在接口中 FlowEngine

参数:

flowLongContext - 全局配置对象

返回:

FlowEngine 流程引擎

getContext

public FlowContext getContext()

指定者:

getContext 在接口中 FlowEngine

startInstanceById

public Optional<FlwInstance> startInstanceById(Long id,
                                               FlowCreator flowCreator,
                                               Map<String,Object> args,
                                               Supplier<FlwInstance> supplier)

根据流程定义ID，创建人，参数列表启动流程实例

指定者:

startInstanceById 在接口中 FlowEngine

参数:

id - 流程定义ID

flowCreator - 流程实例任务创建者

args - 参数列表

supplier - 初始化流程实例提供者

返回:

FlwInstance 流程实例

startInstanceByProcessKey

public Optional<FlwInstance> startInstanceByProcessKey(String processKey,
                                                       Integer version,
                                                       FlowCreator flowCreator,
                                                       Map<String,Object> args,
                                                       Supplier<FlwInstance> supplier)

根据流程定义key、版本号、创建人、参数列表启动流程实例

指定者:

startInstanceByProcessKey 在接口中 FlowEngine

参数:

processKey - 流程定义key

version - 版本号

flowCreator - 流程实例任务创建者

args - 参数列表

supplier - 初始化流程实例提供者

返回:

FlwInstance 流程实例

startProcessInstance

public Optional<FlwInstance> startProcessInstance(FlwProcess process,
                                                  FlowCreator flowCreator,
                                                  Map<String,Object> args,
                                                  Supplier<FlwInstance> supplier)

根据流程对象启动流程实例

指定者:

startProcessInstance 在接口中 FlowEngine

参数:

process - 流程定义对象

flowCreator - 流程创建者

args - 执行参数

supplier - 初始化流程实例提供者

返回:

FlwInstance 流程实例

restartProcessInstance

public void restartProcessInstance(Long id,
                                   String currentNodeKey,
                                   Execution execution)

重启流程实例（从当前所在节点currentNode位置开始）

指定者:

restartProcessInstance 在接口中 FlowEngine

参数:

id - 流程定义ID

currentNodeKey - 当前所在节点

execution - Execution

executeTask

public boolean executeTask(Long taskId,
                           FlowCreator flowCreator,
                           Map<String,Object> args)

根据任务ID，创建人，参数列表执行任务

指定者:

executeTask 在接口中 FlowEngine

参数:

taskId - 任务ID

flowCreator - 任务创建者

args - 参数列表

返回:

true 成功 false 失败

autoJumpTask

public boolean autoJumpTask(Long taskId,
                            Map<String,Object> args,
                            FlowCreator flowCreator)

自动跳转任务

指定者:

autoJumpTask 在接口中 FlowEngine

参数:

taskId - 任务ID

args - 任务参数

flowCreator - 任务创建者

返回:

true 成功 false 失败

executeTask

protected boolean executeTask(Long taskId,
                              FlowCreator flowCreator,
                              Map<String,Object> args,
                              TaskState taskState,
                              TaskEventType eventType)

autoCompleteTask

public boolean autoCompleteTask(Long taskId,
                                Map<String,Object> args,
                                FlowCreator flowCreator)

自动完成任务

指定者:

autoCompleteTask 在接口中 FlowEngine

参数:

taskId - 任务ID

args - 任务参数

flowCreator - 任务创建者

返回:

true 成功 false 失败

autoRejectTask

public boolean autoRejectTask(FlwTask flwTask,
                              Map<String,Object> args,
                              FlowCreator flowCreator)

自动拒绝任务

指定者:

autoRejectTask 在接口中 FlowEngine

参数:

flwTask - 任务对象

args - 任务参数

flowCreator - 任务创建者

返回:

true 成功 false 失败

executeJumpTask

public Optional<FlwTask> executeJumpTask(Long taskId,
                                         String nodeKey,
                                         FlowCreator flowCreator,
                                         Map<String,Object> args,
                                         TaskType taskTye)

指定者:

executeJumpTask 在接口中 FlowEngine

executeRejectTask

public Optional<FlwTask> executeRejectTask(FlwTask currentFlwTask,
                                           String nodeKey,
                                           FlowCreator flowCreator,
                                           Map<String,Object> args)

从接口复制的说明: FlowEngine

根据当前任务对象驳回至指定 nodeKey 节点，如果 nodeKey 为空默认为上一步处理

指定者:

executeRejectTask 在接口中 FlowEngine

参数:

currentFlwTask - 当前任务对象

nodeKey - 跳转的节点key

flowCreator - 任务创建者

args - 任务参数

返回:

Task 任务对象

createNewTask

public List<FlwTask> createNewTask(Long taskId,
                                   TaskType taskType,
                                   PerformType performType,
                                   List<FlwTaskActor> taskActors,
                                   FlowCreator flowCreator,
                                   Map<String,Object> args)

从接口复制的说明: FlowEngine

根据已有任务、参与者创建新的任务

适用于动态转派，动态协办等处理且流程图中不体现节点情况

指定者:

createNewTask 在接口中 FlowEngine

参数:

taskId - 主办任务ID

taskType - 任务类型

performType - 参与类型

taskActors - 参与者集合

flowCreator - 任务创建者

args - 任务参数

返回:

创建任务集合

executeAppendNodeModel

public boolean executeAppendNodeModel(Long taskId,
                                      NodeModel nodeModel,
                                      FlowCreator flowCreator,
                                      Map<String,Object> args,
                                      boolean beforeAfter)

从接口复制的说明: FlowEngine

执行追加节点模型

指定者:

executeAppendNodeModel 在接口中 FlowEngine

参数:

taskId - 当前任务ID

nodeModel - 加签节点模型

flowCreator - 任务创建者

args - 任务参数

beforeAfter - true 前置 false 后置

返回:

true 成功 false 失败

getFlwInstance

protected FlwInstance getFlwInstance(Long instanceId,
                                     String updateBy)

获取流程实例

参数:

instanceId - 流程实例ID

updateBy - 更新人

返回:

FlwInstance

createExecution

protected Execution createExecution(ProcessModel processModel,
                                    FlwInstance flwInstance,
                                    FlwTask flwTask,
                                    FlowCreator flowCreator,
                                    Map<String,Object> args)