Package org.flowable.task.service.impl.persistence.entity

Class TaskEntityManagerImpl

java.lang.Object

org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager<EntityImpl,DM>

org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager<TaskServiceConfiguration,EntityImpl,DM>

org.flowable.task.service.impl.persistence.entity.AbstractTaskServiceEntityManager<TaskEntity,TaskDataManager>

org.flowable.task.service.impl.persistence.entity.TaskEntityManagerImpl

All Implemented Interfaces:

EntityManager<TaskEntity>, TaskEntityManager

public class TaskEntityManagerImpl
extends AbstractTaskServiceEntityManager<TaskEntity,TaskDataManager>
implements TaskEntityManager

Author:

Tom Baeyens, Joram Barrez

Field Summary

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager

serviceConfiguration

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

dataManager, engineType

Constructor Summary

Constructors

Constructor	Description
TaskEntityManagerImpl(TaskServiceConfiguration taskServiceConfiguration, TaskDataManager taskDataManager)

Method Summary

Modifier and Type	Method	Description
void	changeTaskAssignee(TaskEntity taskEntity, String assignee)
void	changeTaskOwner(TaskEntity taskEntity, String owner)
TaskEntity	create()
protected HistoricTaskLogEntryBuilder	createHistoricTaskLogEntryBuilder(TaskInfo task, HistoricTaskLogEntryType userTaskCreated)
TaskEntity	createTask(TaskBuilder taskBuilder)	Creates TaskEntity according to TaskInfo template
void	deleteTasksByExecutionId(String executionId)
long	findTaskCountByNativeQuery(Map<String,Object> parameterMap)
long	findTaskCountByQueryCriteria(TaskQueryImpl taskQuery)
List<TaskEntity>	findTasksByExecutionId(String executionId)
List<Task>	findTasksByNativeQuery(Map<String,Object> parameterMap)
List<Task>	findTasksByParentTaskId(String parentTaskId)
List<TaskEntity>	findTasksByProcessInstanceId(String processInstanceId)
List<Task>	findTasksByQueryCriteria(TaskQueryImpl taskQuery)
List<TaskEntity>	findTasksByScopeIdAndScopeType(String scopeId, String scopeType)
List<TaskEntity>	findTasksBySubScopeIdAndScopeType(String subScopeId, String scopeType)
List<Task>	findTasksWithRelatedEntitiesByQueryCriteria(TaskQueryImpl taskQuery)
protected Object	getOriginalState(TaskEntity task, String stateKey)
void	insert(TaskEntity taskEntity, boolean fireCreatedEvent)
protected void	logAssigneeChanged(TaskEntity taskEntity, String previousAssignee, String newAssignee)
protected void	logDueDateChanged(TaskEntity taskEntity, Date previousDueDate, Date newDueDate)
protected void	logNameChanged(TaskEntity taskEntity, String previousName, String newName)
protected void	logOwnerChanged(TaskEntity taskEntity, String previousOwner, String newOwner)
protected void	logPriorityChanged(TaskEntity taskEntity, Integer previousPriority, int newPriority)
protected void	logTaskCreatedEvent(TaskInfo task)
protected void	logTaskUpdateEvents(TaskEntity task)
protected void	recordHistoryUserTaskLog(HistoricTaskLogEntryType logEntryType, TaskInfo task, com.fasterxml.jackson.databind.node.ObjectNode dataNode)
TaskEntity	update(TaskEntity taskEntity, boolean fireUpdateEvents)
void	updateAllTaskRelatedEntityCountFlags(boolean configProperty)
void	updateTaskTenantIdForDeployment(String deploymentId, String newTenantId)
protected boolean	wasPersisted(TaskEntity task)

Methods inherited from class org.flowable.task.service.impl.persistence.entity.AbstractTaskServiceEntityManager

createEntityEvent

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager

getClock, getEventDispatcher, getServiceConfiguration

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

delete, delete, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, insert, setDataManager, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.EntityManager

delete, delete, delete, findById, insert, update

Constructor Details

TaskEntityManagerImpl

public TaskEntityManagerImpl(TaskServiceConfiguration taskServiceConfiguration,
 TaskDataManager taskDataManager)

Method Details

create

public TaskEntity create()

Specified by:

create in interface EntityManager<TaskEntity>

Overrides:

create in class AbstractEntityManager<TaskEntity,TaskDataManager>

createTask

public TaskEntity createTask(TaskBuilder taskBuilder)

Description copied from interface: TaskEntityManager

Creates TaskEntity according to TaskInfo template

Specified by:

createTask in interface TaskEntityManager

Parameters:

taskBuilder - template to use when the task is created

Returns:

created task entity

insert

public void insert(TaskEntity taskEntity,
 boolean fireCreatedEvent)

Specified by:

insert in interface EntityManager<TaskEntity>

Overrides:

insert in class AbstractEntityManager<TaskEntity,TaskDataManager>

update

public TaskEntity update(TaskEntity taskEntity,
 boolean fireUpdateEvents)

Specified by:

update in interface EntityManager<TaskEntity>

Overrides:

update in class AbstractEntityManager<TaskEntity,TaskDataManager>

changeTaskAssignee

public void changeTaskAssignee(TaskEntity taskEntity,
 String assignee)

Specified by:

changeTaskAssignee in interface TaskEntityManager

changeTaskOwner

public void changeTaskOwner(TaskEntity taskEntity,
 String owner)

Specified by:

changeTaskOwner in interface TaskEntityManager

findTasksByExecutionId

public List<TaskEntity> findTasksByExecutionId(String executionId)

Specified by:

findTasksByExecutionId in interface TaskEntityManager

findTasksByProcessInstanceId

public List<TaskEntity> findTasksByProcessInstanceId(String processInstanceId)

Specified by:

findTasksByProcessInstanceId in interface TaskEntityManager

findTasksByScopeIdAndScopeType

public List<TaskEntity> findTasksByScopeIdAndScopeType(String scopeId,
 String scopeType)

Specified by:

findTasksByScopeIdAndScopeType in interface TaskEntityManager

findTasksBySubScopeIdAndScopeType

public List<TaskEntity> findTasksBySubScopeIdAndScopeType(String subScopeId,
 String scopeType)

Specified by:

findTasksBySubScopeIdAndScopeType in interface TaskEntityManager

findTasksByQueryCriteria

public List<Task> findTasksByQueryCriteria(TaskQueryImpl taskQuery)

Specified by:

findTasksByQueryCriteria in interface TaskEntityManager

findTasksWithRelatedEntitiesByQueryCriteria

public List<Task> findTasksWithRelatedEntitiesByQueryCriteria(TaskQueryImpl taskQuery)

Specified by:

findTasksWithRelatedEntitiesByQueryCriteria in interface TaskEntityManager

findTaskCountByQueryCriteria

public long findTaskCountByQueryCriteria(TaskQueryImpl taskQuery)

Specified by:

findTaskCountByQueryCriteria in interface TaskEntityManager

findTasksByNativeQuery

public List<Task> findTasksByNativeQuery(Map<String,Object> parameterMap)

Specified by:

findTasksByNativeQuery in interface TaskEntityManager

findTaskCountByNativeQuery

public long findTaskCountByNativeQuery(Map<String,Object> parameterMap)

Specified by:

findTaskCountByNativeQuery in interface TaskEntityManager

findTasksByParentTaskId

public List<Task> findTasksByParentTaskId(String parentTaskId)

Specified by:

findTasksByParentTaskId in interface TaskEntityManager

updateTaskTenantIdForDeployment

public void updateTaskTenantIdForDeployment(String deploymentId,
 String newTenantId)

Specified by:

updateTaskTenantIdForDeployment in interface TaskEntityManager

updateAllTaskRelatedEntityCountFlags

public void updateAllTaskRelatedEntityCountFlags(boolean configProperty)

Specified by:

updateAllTaskRelatedEntityCountFlags in interface TaskEntityManager

deleteTasksByExecutionId

public void deleteTasksByExecutionId(String executionId)

Specified by:

deleteTasksByExecutionId in interface TaskEntityManager

logAssigneeChanged

protected void logAssigneeChanged(TaskEntity taskEntity,
 String previousAssignee,
 String newAssignee)

logOwnerChanged

protected void logOwnerChanged(TaskEntity taskEntity,
 String previousOwner,
 String newOwner)

logPriorityChanged

protected void logPriorityChanged(TaskEntity taskEntity,
 Integer previousPriority,
 int newPriority)

logDueDateChanged

protected void logDueDateChanged(TaskEntity taskEntity,
 Date previousDueDate,
 Date newDueDate)

logNameChanged

protected void logNameChanged(TaskEntity taskEntity,
 String previousName,
 String newName)

logTaskCreatedEvent

protected void logTaskCreatedEvent(TaskInfo task)

createHistoricTaskLogEntryBuilder

protected HistoricTaskLogEntryBuilder createHistoricTaskLogEntryBuilder(TaskInfo task,
 HistoricTaskLogEntryType userTaskCreated)

logTaskUpdateEvents

protected void logTaskUpdateEvents(TaskEntity task)

wasPersisted

protected boolean wasPersisted(TaskEntity task)

getOriginalState

protected Object getOriginalState(TaskEntity task,
 String stateKey)

recordHistoryUserTaskLog

protected void recordHistoryUserTaskLog(HistoricTaskLogEntryType logEntryType,
 TaskInfo task,
 com.fasterxml.jackson.databind.node.ObjectNode dataNode)