程序包 net.sohelp.boot.engine.workflow.impl

类 RuntimeServiceImpl

java.lang.Object

net.sohelp.boot.engine.workflow.impl.RuntimeServiceImpl

所有已实现的接口:

RuntimeService

public class RuntimeServiceImpl
extends Object
implements RuntimeService

流程实例运行业务类

从以下版本开始:

1.0

字段概要

字段

修饰符和类型	字段	说明
protected final FlwExtInstanceDao	extInstanceDao
protected final FlowIdGenerator	flowLongIdGenerator
protected final FlwHisInstanceDao	hisInstanceDao
protected final FlwInstanceDao	instanceDao
protected final InstanceListener	instanceListener
protected final QueryService	queryService
protected final TaskService	taskService

构造器概要

构造器

构造器	说明
RuntimeServiceImpl(InstanceListener instanceListener, FlowIdGenerator flowLongIdGenerator, QueryService queryService, TaskService taskService, FlwInstanceDao instanceDao, FlwHisInstanceDao hisInstanceDao, FlwExtInstanceDao extInstanceDao)

方法概要

修饰符和类型	方法	说明
boolean	activeInstanceById(Long instanceId, FlowCreator flowCreator)	激活流程实例 InstanceState.active
boolean	addVariable(Long instanceId, Map<String,Object> args, Function<FlwInstance,FlwInstance> function)	根据 流程实例ID 更新流程实例全局变量
void	appendNodeModel(Long taskId, NodeModel nodeModel, boolean beforeAfter)	追加节点模型（不执行任务跳转）
void	cascadeRemoveByInstanceId(Long instanceId)	级联删除表 flw_his_task_actor, flw_his_task, flw_task_actor, flw_task, flw_instance, flw_his_instance
void	cascadeRemoveByProcessId(Long processId)	级联删除指定流程实例的所有数据
FlwInstance	createInstance(FlwProcess flwProcess, FlowCreator flowCreator, Map<String,Object> args, NodeModel nodeModel, boolean saveAsDraft, Supplier<FlwInstance> supplier)	创建活动实例
boolean	destroyByInstanceId(Long instanceId, Map<String,Object> args)	根据 流程实例ID 作废流程
boolean	endInstance(Execution execution, Long instanceId, NodeModel endNode, InstanceState instanceState)	删除活动流程实例数据，更新历史流程实例的状态、结束时间
protected boolean	forceComplete(Long instanceId, FlwTask currentFlwTask, FlowCreator flowCreator, InstanceEventType instanceEventType, InstanceState instanceState, TaskEventType eventType)	强制完成流程实例
protected void	forceCompleteAll(FlwInstance flwInstance, FlwTask currentFlwTask, FlowCreator flowCreator, InstanceEventType instanceEventType, InstanceState instanceState, TaskEventType eventType)	强制完成流程所有实例
protected FlwHisInstance	getFlwHisInstance(Long instanceId, NodeModel endNode, FlwInstance flwInstance, InstanceState instanceState)
ProcessModel	getProcessModelByInstanceId(Long instanceId)	根据流程实例ID获取流程实例模型
protected void	instanceNotify(InstanceEventType eventType, Supplier<FlwHisInstance> supplier, NodeModel nodeModel, FlowCreator flowCreator)
boolean	reject(Long instanceId, FlwTask currentFlwTask, FlowCreator flowCreator)	流程实例拒绝审批强制终止（用于后续审核人员认为该审批不再需要继续，拒绝审批强行终止）
boolean	removeNodeModel(Long instanceId, String nodeKey, Function<NodeModel,Boolean> checkFunc)	删除节点模型某个临时节点
boolean	revoke(Long instanceId, FlwTask currentFlwTask, FlowCreator flowCreator)	流程实例撤销（用于错误发起审批申请，发起人主动撤销）
void	saveInstance(FlwInstance flwInstance, FlwProcess flwProcess, boolean saveAsDraft, FlowCreator flowCreator)	流程实例数据会保存至活动实例表、历史实例表
boolean	suspendInstanceById(Long instanceId, FlowCreator flowCreator)	暂停流程实例 InstanceState.suspend
boolean	terminate(Long instanceId, FlwTask currentFlwTask, FlowCreator flowCreator)	强制终止活动实例,并强制完成活动任务
boolean	timeout(Long instanceId, FlwTask currentFlwTask, FlowCreator flowCreator)	流程实例超时（设定审批时间超时，自动结束）
void	updateInstance(FlwInstance flwInstance)	更新活动实例
boolean	updateInstanceModelById(Long instanceId, ProcessModel processModel)	根据 流程实例ID 更新流程实例模型内容
protected boolean	updateInstanceState(FlwHisInstance dbFhi, InstanceState instanceState, FlowCreator flowCreator)	更新流程实例状态
protected boolean	updateInstanceStateById(Long instanceId, InstanceState instanceState, FlowCreator flowCreator)	根据流程实例ID更新流程实例状态
protected void	updateModelContent(FlwExtInstance flwExtInstance, ProcessModel processModel)

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

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

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

addVariable, getNodeModel, reject, revoke, terminate, timeout, timeout

字段详细资料

instanceListener

protected final InstanceListener instanceListener

flowLongIdGenerator

protected final FlowIdGenerator flowLongIdGenerator

queryService

protected final QueryService queryService

taskService

protected final TaskService taskService

instanceDao

protected final FlwInstanceDao instanceDao

hisInstanceDao

protected final FlwHisInstanceDao hisInstanceDao

extInstanceDao

protected final FlwExtInstanceDao extInstanceDao

构造器详细资料

RuntimeServiceImpl

public RuntimeServiceImpl(InstanceListener instanceListener,
 FlowIdGenerator flowLongIdGenerator,
 QueryService queryService,
 TaskService taskService,
 FlwInstanceDao instanceDao,
 FlwHisInstanceDao hisInstanceDao,
 FlwExtInstanceDao extInstanceDao)

方法详细资料

createInstance

public FlwInstance createInstance(FlwProcess flwProcess,
 FlowCreator flowCreator,
 Map<String,Object> args,
 NodeModel nodeModel,
 boolean saveAsDraft,
 Supplier<FlwInstance> supplier)

创建活动实例

指定者:

createInstance 在接口中 RuntimeService

参数:

flwProcess - 流程定义对象

flowCreator - 流程实例任务创建者

args - 参数列表

nodeModel - 当前所在节点

saveAsDraft - 暂存草稿

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

返回:

活动流程实例对象

getProcessModelByInstanceId

public ProcessModel getProcessModelByInstanceId(Long instanceId)

根据流程实例ID获取流程实例模型

指定者:

getProcessModelByInstanceId 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

返回:

ProcessModel

addVariable

public boolean addVariable(Long instanceId,
 Map<String,Object> args,
 Function<FlwInstance,FlwInstance> function)

从接口复制的说明: RuntimeService

根据 流程实例ID 更新流程实例全局变量

指定者:

addVariable 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

args - 流程实例参数

function - 待更新实例回调处理函数

endInstance

public boolean endInstance(Execution execution,
 Long instanceId,
 NodeModel endNode,
 InstanceState instanceState)

删除活动流程实例数据，更新历史流程实例的状态、结束时间

指定者:

endInstance 在接口中 RuntimeService

参数:

execution - Execution

instanceId - 流程实例ID

endNode - 结束节点

instanceState - 实例状态

返回:

true 成功 false 失败

getFlwHisInstance

protected FlwHisInstance getFlwHisInstance(Long instanceId,
 NodeModel endNode,
 FlwInstance flwInstance,
 InstanceState instanceState)

instanceNotify

protected void instanceNotify(InstanceEventType eventType,
 Supplier<FlwHisInstance> supplier,
 NodeModel nodeModel,
 FlowCreator flowCreator)

saveInstance

public void saveInstance(FlwInstance flwInstance,
 FlwProcess flwProcess,
 boolean saveAsDraft,
 FlowCreator flowCreator)

流程实例数据会保存至活动实例表、历史实例表

指定者:

saveInstance 在接口中 RuntimeService

参数:

flwInstance - 流程实例对象

flwProcess - 流程定义对象

saveAsDraft - 暂存草稿

flowCreator - 处理人员

suspendInstanceById

public boolean suspendInstanceById(Long instanceId,
 FlowCreator flowCreator)

从接口复制的说明: RuntimeService

暂停流程实例 InstanceState.suspend

指定者:

suspendInstanceById 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

flowCreator - 处理人员

返回:

true 成功 false 失败

activeInstanceById

public boolean activeInstanceById(Long instanceId,
 FlowCreator flowCreator)

从接口复制的说明: RuntimeService

激活流程实例 InstanceState.active

指定者:

activeInstanceById 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

flowCreator - 处理人员

返回:

true 成功 false 失败

updateInstanceStateById

protected boolean updateInstanceStateById(Long instanceId,
 InstanceState instanceState,
 FlowCreator flowCreator)

根据流程实例ID更新流程实例状态

参数:

instanceId - 流程实例ID

instanceState - 流程实例状态

flowCreator - 流程创建者

updateInstanceState

protected boolean updateInstanceState(FlwHisInstance dbFhi,
 InstanceState instanceState,
 FlowCreator flowCreator)

更新流程实例状态

参数:

dbFhi - 数据库流程实例历史对象

instanceState - 流程实例状态

flowCreator - 流程创建者

reject

public boolean reject(Long instanceId,
 FlwTask currentFlwTask,
 FlowCreator flowCreator)

从接口复制的说明: RuntimeService

流程实例拒绝审批强制终止（用于后续审核人员认为该审批不再需要继续，拒绝审批强行终止）

指定者:

reject 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

currentFlwTask - 当前任务

flowCreator - 处理人员

revoke

public boolean revoke(Long instanceId,
 FlwTask currentFlwTask,
 FlowCreator flowCreator)

从接口复制的说明: RuntimeService

流程实例撤销（用于错误发起审批申请，发起人主动撤销）

指定者:

revoke 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

currentFlwTask - 当前任务

flowCreator - 处理人员

timeout

public boolean timeout(Long instanceId,
 FlwTask currentFlwTask,
 FlowCreator flowCreator)

从接口复制的说明: RuntimeService

流程实例超时（设定审批时间超时，自动结束）

指定者:

timeout 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

currentFlwTask - 当前任务

flowCreator - 处理人员

terminate

public boolean terminate(Long instanceId,
 FlwTask currentFlwTask,
 FlowCreator flowCreator)

强制终止活动实例,并强制完成活动任务

指定者:

terminate 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

currentFlwTask - 当前任务

flowCreator - 处理人员

forceComplete

protected boolean forceComplete(Long instanceId,
 FlwTask currentFlwTask,
 FlowCreator flowCreator,
 InstanceEventType instanceEventType,
 InstanceState instanceState,
 TaskEventType eventType)

强制完成流程实例

参数:

instanceId - 流程实例ID

currentFlwTask - 当前任务

flowCreator - 处理人员

instanceState - 流程实例最终状态

eventType - 监听事件类型

forceCompleteAll

protected void forceCompleteAll(FlwInstance flwInstance,
 FlwTask currentFlwTask,
 FlowCreator flowCreator,
 InstanceEventType instanceEventType,
 InstanceState instanceState,
 TaskEventType eventType)

强制完成流程所有实例

updateInstance

public void updateInstance(FlwInstance flwInstance)

更新活动实例

指定者:

updateInstance 在接口中 RuntimeService

参数:

flwInstance - 流程实例对象

updateInstanceModelById

public boolean updateInstanceModelById(Long instanceId,
 ProcessModel processModel)

从接口复制的说明: RuntimeService

根据 流程实例ID 更新流程实例模型内容

指定者:

updateInstanceModelById 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

processModel - 流程模型

返回:

true 成功 false 失败

cascadeRemoveByProcessId

public void cascadeRemoveByProcessId(Long processId)

级联删除指定流程实例的所有数据

删除表 flw_his_task_actor, flw_his_task, flw_task_actor, flw_task, flw_his_instance, flw_ext_instance, flw_instance

指定者:

cascadeRemoveByProcessId 在接口中 RuntimeService

参数:

processId - 流程ID

cascadeRemoveByInstanceId

public void cascadeRemoveByInstanceId(Long instanceId)

从接口复制的说明: RuntimeService

级联删除表 flw_his_task_actor, flw_his_task, flw_task_actor, flw_task, flw_instance, flw_his_instance

指定者:

cascadeRemoveByInstanceId 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

destroyByInstanceId

public boolean destroyByInstanceId(Long instanceId,
 Map<String,Object> args)

从接口复制的说明: RuntimeService

根据 流程实例ID 作废流程

指定者:

destroyByInstanceId 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

args - 流程实例参数

返回:

true 成功 false 失败

appendNodeModel

public void appendNodeModel(Long taskId,
 NodeModel nodeModel,
 boolean beforeAfter)

从接口复制的说明: RuntimeService

追加节点模型（不执行任务跳转）

执行追加节点模型调用 FlowEngine.executeAppendNodeModel(Long, NodeModel, FlowCreator, boolean)

指定者:

appendNodeModel 在接口中 RuntimeService

参数:

taskId - 任务ID

nodeModel - 节点模型

beforeAfter - true 前置 false 后置

updateModelContent

protected void updateModelContent(FlwExtInstance flwExtInstance,
 ProcessModel processModel)

removeNodeModel

public boolean removeNodeModel(Long instanceId,
 String nodeKey,
 Function<NodeModel,Boolean> checkFunc)

从接口复制的说明: RuntimeService

删除节点模型某个临时节点

指定者:

removeNodeModel 在接口中 RuntimeService

参数:

instanceId - 流程实例ID

nodeKey - 节点KEY

checkFunc - 节点检查函数