程序包 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

基本的流程引擎实现类

从以下版本开始:

1.0

字段概要

字段

修饰符和类型	字段	说明
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对象配置实现类
boolean	createCcTask(NodeModel taskModel, FlwTask flwTask, List<NodeAssignee> ccUserList, FlowCreator flowCreator)	创建抄送任务
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)	执行追加节点模型
boolean	executeFinishTrigger(Long taskId, FlowCreator flowCreator, Map<String,Object> args)	根据 触发器任务ID，创建人信息，参数列表执行完成触发器任务
Optional<List<FlwTask>>	executeJumpTask(Long taskId, String nodeKey, FlowCreator flowCreator, Map<String,Object> args, TaskType taskType)
Optional<List<FlwTask>>	executeRejectTask(FlwTask currentFlwTask, String nodeKey, FlowCreator flowCreator, Map<String,Object> args, boolean termination)	根据当前任务对象驳回至指定 nodeKey 节点，如果 nodeKey 为空默认为上一步处理
protected Optional<List<FlwTask>>	executeRejectTask(FlwTask currentFlwTask, String nodeKey, FlowCreator flowCreator, Map<String,Object> args, boolean termination, Supplier<Optional<List<FlwTask>>> terminateProcess)
boolean	executeRemoveNodeModel(Long instanceId, String nodeKey)	执行删除临时节点模型
boolean	executeResumeTask(Long instanceId, FlowCreator flowCreator, Map<String,Object> args)	执行唤醒撤回或拒绝终止历史任务（只有实例发起人可操作）
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)
protected FlwInstance	getFlwInstance(Long instanceId, String updateBy, Consumer<FlwInstance> instanceConsumer)	获取流程实例
void	restartProcessInstance(Long id, String currentNodeKey, Execution execution)	重启流程实例（从当前所在节点currentNode位置开始）
Optional<FlwInstance>	startInstanceById(Long id, FlowCreator flowCreator, Map<String,Object> args, boolean saveAsDraft, Supplier<FlwInstance> supplier)	根据流程定义ID，创建人，参数列表启动流程实例
Optional<FlwInstance>	startInstanceByProcessKey(String processKey, Integer version, FlowCreator flowCreator, Map<String,Object> args, boolean saveAsDraft, Supplier<FlwInstance> supplier)	根据流程定义key、版本号、创建人、参数列表启动流程实例
Optional<FlwInstance>	startProcessInstance(FlwProcess process, FlowCreator flowCreator, Map<String,Object> args, boolean saveAsDraft, 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, createCcTask, executeAppendNodeModel, executeFinishTrigger, executeJumpTask, executeJumpTask, executeRejectTask, executeRejectTask, executeRejectTask, executeRejectTask, executeResumeTask, executeTask, processService, queryService, runtimeService, startInstanceById, startInstanceById, startInstanceById, startInstanceById, startInstanceById, startInstanceById, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, startInstanceByProcessKey, taskService

字段详细资料

flowLongContext

protected FlowContext flowLongContext

配置对象

构造器详细资料

FlowEngineImpl

public FlowEngineImpl()

方法详细资料

configure

public FlowEngine configure(FlowContext flowLongContext)

从接口复制的说明: FlowEngine

根据Configuration对象配置实现类

指定者:

configure 在接口中 FlowEngine

参数:

flowLongContext - 全局配置对象

返回:

FlowLongEngine 流程引擎

getContext

public FlowContext getContext()

指定者:

getContext 在接口中 FlowEngine

startInstanceById

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

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

指定者:

startInstanceById 在接口中 FlowEngine

参数:

id - 流程定义ID

flowCreator - 流程实例任务创建者

args - 参数列表

saveAsDraft - 暂存草稿

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

返回:

FlwInstance 流程实例

startInstanceByProcessKey

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

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

指定者:

startInstanceByProcessKey 在接口中 FlowEngine

参数:

processKey - 流程定义key

version - 版本号

flowCreator - 流程实例任务创建者

args - 参数列表

saveAsDraft - 暂存草稿

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

返回:

FlwInstance 流程实例

startProcessInstance

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

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

指定者:

startProcessInstance 在接口中 FlowEngine

参数:

process - 流程定义对象

flowCreator - 流程创建者

args - 执行参数

saveAsDraft - 暂存草稿

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 失败

executeFinishTrigger

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

根据 触发器任务ID，创建人信息，参数列表执行完成触发器任务

指定者:

executeFinishTrigger 在接口中 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<List<FlwTask>> executeJumpTask(Long taskId,
 String nodeKey,
 FlowCreator flowCreator,
 Map<String,Object> args,
 TaskType taskType)

指定者:

executeJumpTask 在接口中 FlowEngine

executeRejectTask

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

从接口复制的说明: FlowEngine

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

指定者:

executeRejectTask 在接口中 FlowEngine

参数:

currentFlwTask - 当前任务对象

nodeKey - 跳转的节点key

flowCreator - 任务创建者

args - 任务参数

termination - 是否终止流程，该参数为 true 时，其它驳回策略无效

返回:

Task 任务对象

executeRejectTask

protected Optional<List<FlwTask>> executeRejectTask(FlwTask currentFlwTask,
 String nodeKey,
 FlowCreator flowCreator,
 Map<String,Object> args,
 boolean termination,
 Supplier<Optional<List<FlwTask>>> terminateProcess)

executeResumeTask

public boolean executeResumeTask(Long instanceId,
 FlowCreator flowCreator,
 Map<String,Object> args)

从接口复制的说明: FlowEngine

执行唤醒撤回或拒绝终止历史任务（只有实例发起人可操作）

指定者:

executeResumeTask 在接口中 FlowEngine

参数:

instanceId - 历史实例ID

flowCreator - 任务唤醒者

args - 任务参数

返回:

true 成功 false 失败

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 - 任务参数

返回:

创建任务集合

createCcTask

public boolean createCcTask(NodeModel taskModel,
 FlwTask flwTask,
 List<NodeAssignee> ccUserList,
 FlowCreator flowCreator)

创建抄送任务

默认不校验是否重复抄送

指定者:

createCcTask 在接口中 FlowEngine

参数:

taskModel - 任务模型

flwTask - 当前任务

ccUserList - 抄送任务分配到任务的人或角色列表

flowCreator - 任务创建者

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 失败

executeRemoveNodeModel

public boolean executeRemoveNodeModel(Long instanceId,
 String nodeKey)

从接口复制的说明: FlowEngine

执行删除临时节点模型

指定者:

executeRemoveNodeModel 在接口中 FlowEngine

参数:

instanceId - 流程实例ID

nodeKey - 节点KEY

getFlwInstance

protected FlwInstance getFlwInstance(Long instanceId,
 String updateBy,
 Consumer<FlwInstance> instanceConsumer)

获取流程实例

参数:

instanceId - 流程实例ID

updateBy - 更新人

instanceConsumer - 流程实例处理函数

返回:

FlwInstance

getFlwInstance

protected FlwInstance getFlwInstance(Long instanceId,
 String updateBy)

createExecution

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