net.sohelp.boot.engine.workflow.impl

类 TaskServiceImpl

java.lang.Object

net.sohelp.boot.engine.workflow.impl.TaskServiceImpl

所有已实现的接口:

TaskService

public class TaskServiceImpl
extends Object
implements TaskService

任务执行业务类

从以下版本开始:

2025/02/03 10:26

构造器概要

构造器

构造器和说明
TaskServiceImpl(TaskAccessStrategy taskAccessStrategy, TaskListener taskListener, TaskTrigger taskTrigger, FlwInstanceDao instanceDao, FlwExtInstanceDao extInstanceDao, FlwHisInstanceDao hisInstanceDao, FlwTaskDao taskDao, FlwTaskActorDao taskActorDao, FlwHisTaskDao hisTaskDao, FlwHisTaskActorDao hisTaskActorDao)

方法概要

限定符和类型	方法和说明
boolean	addTaskActor(Long taskId, PerformType performType, List<FlwTaskActor> flwTaskActors, FlowCreator flowCreator) 向指定的任务ID添加参与者
protected int	assignActorType(int actorType, Integer dbActorType) 优先使用数据库参与者类型
boolean	assigneeTask(Long taskId, TaskType taskType, FlowCreator flowCreator, List<FlowCreator> assigneeFlowCreators, Function<FlwTask,Boolean> check) 根据 任务ID 分配任务给指定办理人、重置任务类型
protected void	assignTask(Long instanceId, Long taskId, int actorType, FlwTaskActor taskActor) 对指定的任务分配参与者。
boolean	cascadeRemoveByInstanceIds(List<Long> instanceIds) 级联删除表 flw_his_task_actor, flw_his_task, flw_task_actor, flw_task
protected FlwTask	claim(Long taskId, AgentType agentType, TaskEventType eventType, FlowCreator flowCreator) 根据 任务ID 认领任务，删除其它任务参与者
FlwTask	claimDepartment(Long taskId, FlowCreator flowCreator) 部门根据 任务ID 认领任务，删除其它任务参与者
FlwTask	claimRole(Long taskId, FlowCreator flowCreator) 角色根据 任务ID 认领任务，删除其它任务参与者
boolean	completeActiveTasksByInstanceId(Long instanceId, FlowCreator flowCreator) 完成指定实例ID活动任务
List<FlwTask>	createNewTask(Long taskId, TaskType taskType, PerformType performType, List<FlwTaskActor> taskActors, FlowCreator flowCreator, Function<FlwTask,Execution> executionFunction) 根据已有任务、参与者创建新的任务 适用于动态转派，动态协办等处理且流程图中不体现节点情况
List<FlwTask>	createTask(NodeModel nodeModel, Execution execution, Function<FlwTask,FlwTask> taskFunction) 创建 task 根据 model 决定是否分配参与者
void	endCallProcessTask(Long callProcessId, Long callInstanceId) 结束调用外部流程任务
Optional<FlwTask>	executeJumpTask(Long taskId, String nodeKey, FlowCreator flowCreator, Map<String,Object> args, Function<FlwTask,Execution> executionFunction, TaskType taskTye) 执行节点跳转任务
FlwTask	executeTask(Long taskId, FlowCreator flowCreator, Map<String,Object> args, TaskState taskState, TaskEventType eventType) 执行任务
boolean	executeTaskTrigger(Execution execution, FlwTask flwTask) 执行触发器任务
boolean	forceCompleteAllTask(Long instanceId, FlowCreator flowCreator, InstanceState instanceState, TaskEventType eventType) 强制完成所有任务
protected FlwTask	getAllowedFlwTask(Long taskId, FlowCreator flowCreator, Map<String,Object> args, TaskState taskState) 获取执行任务并验证合法性
protected FlwTaskActor	getAllowedFlwTaskActor(Long taskId, FlowCreator flowCreator) 获取指定 任务ID 合法参与者对象
protected List<FlwTaskActor>	getTaskActorsByTaskId(Long taskId)
NodeModel	getTaskModel(Long taskId) 获取任务模型
List<FlwTask>	getTimeoutOrRemindTasks() 获取超时或者提醒的任务
FlwTaskActor	isAllowed(FlwTask flwTask, String userId) 根据 taskId、createId 判断创建人是否允许执行任务
protected boolean	moveToHisTask(FlwTask flwTask, TaskState taskState, FlowCreator flowCreator) 迁移任务至历史表
protected void	moveToHisTaskActor(List<FlwTaskActor> taskActors) 迁移任务参与者至历史表
Optional<FlwTask>	reclaimTask(Long taskId, FlowCreator flowCreator) 拿回任务、根据历史任务ID撤回下一个节点的任务、恢复历史任务
Optional<FlwTask>	rejectTask(FlwTask currentFlwTask, FlowCreator flowCreator, Map<String,Object> args) 根据当前任务对象驳回至上一步处理
boolean	removeTaskActor(Long taskId, List<String> actorIds, FlowCreator flowCreator) 对指定的任务ID删除参与者【减签】
boolean	resolveTask(Long taskId, FlowCreator flowCreator) 根据 任务ID 解决委派任务
FlwTask	resume(Long taskId, FlowCreator flowCreator) 唤醒指定的历史任务
protected List<FlwTask>	saveTask(FlwTask flwTask, PerformType performType, List<FlwTaskActor> taskActors, Execution execution, NodeModel nodeModel) 保存任务及参与者信息
void	saveTaskCc(NodeModel nodeModel, FlwTask flwTask, FlowCreator flowCreator) 保存抄送任务
protected void	taskNotify(TaskEventType eventType, Supplier<FlwTask> supplier, NodeModel nodeModel, FlowCreator flowCreator)
boolean	transferTask(FlowCreator flowCreator, FlowCreator assigneeFlowCreator) 参与者的所有任务【离职转办】给指定办理人 用于任务参与者离职
protected Optional<FlwTask>	undoHisTask(Long hisTaskId, FlowCreator flowCreator, TaskType taskType, Consumer<FlwHisTask> hisTaskConsumer) 撤回历史任务
protected void	updateCurrentNode(FlwTask flwTask) 更新当前执行节点信息
void	updateTaskById(FlwTask flwTask, FlowCreator flowCreator) 更新任务对象的 finishTime、createBy、expireTime、version、variable
boolean	viewTask(Long taskId, FlwTaskActor taskActor) 查看任务设置为已阅状态
Optional<FlwTask>	withdrawTask(Long taskId, FlowCreator flowCreator) 撤回指定的任务

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

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

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

addTaskActor, agentTask, assigneeTask, complete, complete, createTask, delegateTask, executeJumpTask, executeJumpTask, rejectTask, removeTaskActor, transferTask

构造器详细资料

TaskServiceImpl

public TaskServiceImpl(TaskAccessStrategy taskAccessStrategy,
                       TaskListener taskListener,
                       TaskTrigger taskTrigger,
                       FlwInstanceDao instanceDao,
                       FlwExtInstanceDao extInstanceDao,
                       FlwHisInstanceDao hisInstanceDao,
                       FlwTaskDao taskDao,
                       FlwTaskActorDao taskActorDao,
                       FlwHisTaskDao hisTaskDao,
                       FlwHisTaskActorDao hisTaskActorDao)

方法详细资料

updateCurrentNode

protected void updateCurrentNode(FlwTask flwTask)

更新当前执行节点信息

参数:

flwTask - 当前所在执行任务

executeTask

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

执行任务

指定者:

executeTask 在接口中 TaskService

参数:

taskId - 任务ID

flowCreator - 任务创建者

args - 执行参数

taskState - 任务状态

eventType - 执行事件

返回:

FlwTask

forceCompleteAllTask

public boolean forceCompleteAllTask(Long instanceId,
                                    FlowCreator flowCreator,
                                    InstanceState instanceState,
                                    TaskEventType eventType)

强制完成所有任务

指定者:

forceCompleteAllTask 在接口中 TaskService

参数:

instanceId - 流程实例ID

flowCreator - 处理人员

instanceState - 流程实例最终状态

eventType - 监听事件类型

返回:

true 成功 false 失败

executeJumpTask

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

执行节点跳转任务

指定者:

executeJumpTask 在接口中 TaskService

参数:

taskId - 任务ID

nodeKey - 跳转至目标节点key

flowCreator - 任务创建者

args - 任务参数

executionFunction - 执行函数

taskTye - 任务类型，仅支持 jump rejectJump routeJump

返回:

当前 flowCreator 所在的任务

getAllowedFlwTask

protected FlwTask getAllowedFlwTask(Long taskId,
                                    FlowCreator flowCreator,
                                    Map<String,Object> args,
                                    TaskState taskState)

获取执行任务并验证合法性

参数:

taskId - 任务ID

flowCreator - 任务创建者

args - 执行参数

taskState - TaskState

返回:

流程任务

moveToHisTask

protected boolean moveToHisTask(FlwTask flwTask,
                                TaskState taskState,
                                FlowCreator flowCreator)

迁移任务至历史表

参数:

flwTask - 执行任务

taskState - 任务状态

flowCreator - 任务创建者

返回:

true 成功 false 失败

moveToHisTaskActor

protected void moveToHisTaskActor(List<FlwTaskActor> taskActors)

迁移任务参与者至历史表

参数:

taskActors - 任务参与者列表

taskNotify

protected void taskNotify(TaskEventType eventType,
                          Supplier<FlwTask> supplier,
                          NodeModel nodeModel,
                          FlowCreator flowCreator)

executeTaskTrigger

public boolean executeTaskTrigger(Execution execution,
                                  FlwTask flwTask)

从接口复制的说明: TaskService

执行触发器任务

指定者:

executeTaskTrigger 在接口中 TaskService

参数:

execution - Execution

flwTask - 触发器任务

返回:

true 成功 false 失败

completeActiveTasksByInstanceId

public boolean completeActiveTasksByInstanceId(Long instanceId,
                                               FlowCreator flowCreator)

完成指定实例ID活动任务

指定者:

completeActiveTasksByInstanceId 在接口中 TaskService

参数:

instanceId - 实例ID

flowCreator - 处理人员

返回:

true 成功 false 失败

updateTaskById

public void updateTaskById(FlwTask flwTask,
                           FlowCreator flowCreator)

更新任务对象的 finishTime、createBy、expireTime、version、variable

指定者:

updateTaskById 在接口中 TaskService

参数:

flwTask - 任务对象

flowCreator - 处理人员

viewTask

public boolean viewTask(Long taskId,
                        FlwTaskActor taskActor)

查看任务设置为已阅状态

指定者:

viewTask 在接口中 TaskService

参数:

taskId - 任务ID

taskActor - 任务参与者

返回:

true 成功 false 失败

claimRole

public FlwTask claimRole(Long taskId,
                         FlowCreator flowCreator)

从接口复制的说明: TaskService

角色根据 任务ID 认领任务，删除其它任务参与者

指定者:

claimRole 在接口中 TaskService

参数:

taskId - 任务ID

flowCreator - 任务认领者

返回:

Task 任务对象

claimDepartment

public FlwTask claimDepartment(Long taskId,
                               FlowCreator flowCreator)

从接口复制的说明: TaskService

部门根据 任务ID 认领任务，删除其它任务参与者

指定者:

claimDepartment 在接口中 TaskService

参数:

taskId - 任务ID

flowCreator - 任务认领者

返回:

Task 任务对象

claim

protected FlwTask claim(Long taskId,
                        AgentType agentType,
                        TaskEventType eventType,
                        FlowCreator flowCreator)

根据 任务ID 认领任务，删除其它任务参与者

参数:

taskId - 任务ID

agentType - 代理人类型

eventType - 流程引擎监听类型

flowCreator - 任务认领者

返回:

Task 任务对象

transferTask

public boolean transferTask(FlowCreator flowCreator,
                            FlowCreator assigneeFlowCreator)

从接口复制的说明: TaskService

参与者的所有任务【离职转办】给指定办理人

用于任务参与者离职

指定者:

transferTask 在接口中 TaskService

参数:

flowCreator - 任务参与者

assigneeFlowCreator - 指定办理人

返回:

true 成功 false 失败

assigneeTask

public boolean assigneeTask(Long taskId,
                            TaskType taskType,
                            FlowCreator flowCreator,
                            List<FlowCreator> assigneeFlowCreators,
                            Function<FlwTask,Boolean> check)

根据 任务ID 分配任务给指定办理人、重置任务类型

指定者:

assigneeTask 在接口中 TaskService

参数:

taskId - 任务ID

taskType - 任务类型

flowCreator - 任务参与者

assigneeFlowCreators - 指定办理人列表

check - 校验函数，可以根据 dbFlwTask.getAssignorId() 是否存在判断为重发分配

返回:

true 成功 false 失败

getAllowedFlwTaskActor

protected FlwTaskActor getAllowedFlwTaskActor(Long taskId,
                                              FlowCreator flowCreator)

获取指定 任务ID 合法参与者对象

参数:

taskId - 任务ID

flowCreator - 任务参与者

返回:

任务参与者

resolveTask

public boolean resolveTask(Long taskId,
                           FlowCreator flowCreator)

根据 任务ID 解决委派任务

指定者:

resolveTask 在接口中 TaskService

参数:

taskId - 任务ID

flowCreator - 任务参与者

返回:

true 成功 false 失败

reclaimTask

public Optional<FlwTask> reclaimTask(Long taskId,
                                     FlowCreator flowCreator)

拿回任务、根据历史任务ID撤回下一个节点的任务、恢复历史任务

指定者:

reclaimTask 在接口中 TaskService

参数:

taskId - 任务ID（当前节点的父任务ID属于历史任务）

flowCreator - 任务创建者

返回:

拿回任务

resume

public FlwTask resume(Long taskId,
                      FlowCreator flowCreator)

唤醒指定的历史任务

指定者:

resume 在接口中 TaskService

参数:

taskId - 历史任务ID

flowCreator - 任务唤醒者

返回:

FlwTask 唤醒后的任务对象

withdrawTask

public Optional<FlwTask> withdrawTask(Long taskId,
                                      FlowCreator flowCreator)

撤回指定的任务

指定者:

withdrawTask 在接口中 TaskService

参数:

taskId - 待撤回历史任务ID

flowCreator - 任务创建者

返回:

Task 任务对象

rejectTask

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

从接口复制的说明: TaskService

根据当前任务对象驳回至上一步处理

指定者:

rejectTask 在接口中 TaskService

参数:

currentFlwTask - 当前任务对象

flowCreator - 任务创建者

args - 任务参数

返回:

Task 任务对象

undoHisTask

protected Optional<FlwTask> undoHisTask(Long hisTaskId,
                                        FlowCreator flowCreator,
                                        TaskType taskType,
                                        Consumer<FlwHisTask> hisTaskConsumer)

撤回历史任务

参数:

hisTaskId - 历史任务ID

flowCreator - 任务创建者

taskType - 任务类型

hisTaskConsumer - 历史任务业务处理

返回:

任务参与者

assignTask

protected void assignTask(Long instanceId,
                          Long taskId,
                          int actorType,
                          FlwTaskActor taskActor)

对指定的任务分配参与者。参与者可以为用户、部门、角色

参数:

instanceId - 实例ID

taskId - 任务ID

actorType - 参与者类型 0，用户 1，角色 2，部门

taskActor - 任务参与者

createNewTask

public List<FlwTask> createNewTask(Long taskId,
                                   TaskType taskType,
                                   PerformType performType,
                                   List<FlwTaskActor> taskActors,
                                   FlowCreator flowCreator,
                                   Function<FlwTask,Execution> executionFunction)

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

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

指定者:

createNewTask 在接口中 TaskService

参数:

taskId - 主办任务ID

taskType - 任务类型

performType - 参与类型

taskActors - 参与者集合

flowCreator - 任务创建者

executionFunction - 执行函数

返回:

创建任务集合

getTimeoutOrRemindTasks

public List<FlwTask> getTimeoutOrRemindTasks()

获取超时或者提醒的任务

指定者:

getTimeoutOrRemindTasks 在接口中 TaskService

返回:

任务列表

getTaskModel

public NodeModel getTaskModel(Long taskId)

获取任务模型

指定者:

getTaskModel 在接口中 TaskService

参数:

taskId - 任务ID

返回:

节点模型

createTask

public List<FlwTask> createTask(NodeModel nodeModel,
                                Execution execution,
                                Function<FlwTask,FlwTask> taskFunction)

创建 task 根据 model 决定是否分配参与者

指定者:

createTask 在接口中 TaskService

参数:

nodeModel - 节点模型

execution - 执行对象

taskFunction - 任务处理函数，如果自定义 CreateTaskHandler 可用于控制任务创建属性设置

返回:

任务列表

saveTaskCc

public void saveTaskCc(NodeModel nodeModel,
                       FlwTask flwTask,
                       FlowCreator flowCreator)

保存抄送任务

参数:

nodeModel - 节点模型

flwTask - 流程任务对象

flowCreator - 处理人

saveTask

protected List<FlwTask> saveTask(FlwTask flwTask,
                                 PerformType performType,
                                 List<FlwTaskActor> taskActors,
                                 Execution execution,
                                 NodeModel nodeModel)

保存任务及参与者信息

参数:

flwTask - 流程任务对象

performType - 参与类型 PerformType

taskActors - 参与者ID集合

execution - 流程执行处理类 Execution

nodeModel - 流程节点模型对象 NodeModel

返回:

流程任务列表

assignActorType

protected int assignActorType(int actorType,
                              Integer dbActorType)

优先使用数据库参与者类型

isAllowed

public FlwTaskActor isAllowed(FlwTask flwTask,
                              String userId)

根据 taskId、createId 判断创建人是否允许执行任务

指定者:

isAllowed 在接口中 TaskService

参数:

flwTask - 流程任务

userId - 用户ID

返回:

true 允许 false 不允许

addTaskActor

public boolean addTaskActor(Long taskId,
                            PerformType performType,
                            List<FlwTaskActor> flwTaskActors,
                            FlowCreator flowCreator)

向指定的任务ID添加参与者

指定者:

addTaskActor 在接口中 TaskService

参数:

taskId - 任务ID

flwTaskActors - 参与者列表

performType - 参与类型 PerformType

flowCreator - 执行操作人员

返回:

true 成功 false 失败

getTaskActorsByTaskId

protected List<FlwTaskActor> getTaskActorsByTaskId(Long taskId)

removeTaskActor

public boolean removeTaskActor(Long taskId,
                               List<String> actorIds,
                               FlowCreator flowCreator)

从接口复制的说明: TaskService

对指定的任务ID删除参与者【减签】

指定者:

removeTaskActor 在接口中 TaskService

参数:

taskId - 任务ID

actorIds - 参与者ID列表

flowCreator - 执行操作人员

返回:

true 成功 false 失败

endCallProcessTask

public void endCallProcessTask(Long callProcessId,
                               Long callInstanceId)

从接口复制的说明: TaskService

结束调用外部流程任务

指定者:

endCallProcessTask 在接口中 TaskService

参数:

callProcessId - 调用外部流程定义ID

callInstanceId - 调用外部流程实例ID

cascadeRemoveByInstanceIds

public boolean cascadeRemoveByInstanceIds(List<Long> instanceIds)

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

指定者:

cascadeRemoveByInstanceIds 在接口中 TaskService

参数:

instanceIds - 流程实例ID列表