Package org.flowable.engine.impl.persistence.entity

Class ActivityInstanceEntityManagerImpl

java.lang.Object

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

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

org.flowable.engine.impl.persistence.entity.AbstractProcessEngineEntityManager<ActivityInstanceEntity,ActivityInstanceDataManager>

org.flowable.engine.impl.persistence.entity.ActivityInstanceEntityManagerImpl

All Implemented Interfaces:

EntityManager<ActivityInstanceEntity>, ActivityInstanceEntityManager

public class ActivityInstanceEntityManagerImpl
extends AbstractProcessEngineEntityManager<ActivityInstanceEntity,ActivityInstanceDataManager>
implements ActivityInstanceEntityManager

Author:

martin.grofcik

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.slf4j.Logger	logger
protected static final String	NO_ACTIVITY_ID_PREFIX
protected static final String	NO_ACTIVITY_ID_SEPARATOR
protected final boolean	usePrefixId

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

engineConfiguration

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

dataManager, engineType

Constructor Summary

Constructors

Constructor	Description
ActivityInstanceEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration, ActivityInstanceDataManager activityInstanceDataManager)

Method Summary

Modifier and Type	Method	Description
protected ActivityInstanceEntity	createActivityInstance(HistoricActivityInstance historicActivityInstance)
protected ActivityInstance	createActivityInstance(ExecutionEntity executionEntity)
protected ActivityInstanceEntity	createActivityInstanceEntity(ExecutionEntity execution)
void	deleteActivityInstancesByProcessInstanceId(String processInstanceId)
ActivityInstanceEntity	findActivityInstanceByTaskId(String taskId)
long	findActivityInstanceCountByNativeQuery(Map<String,Object> parameterMap)
long	findActivityInstanceCountByQueryCriteria(ActivityInstanceQueryImpl historicActivityInstanceQuery)
List<ActivityInstanceEntity>	findActivityInstancesByExecutionAndActivityId(String executionId, String activityId)
List<ActivityInstance>	findActivityInstancesByNativeQuery(Map<String,Object> parameterMap)
List<ActivityInstanceEntity>	findActivityInstancesByProcessInstanceId(String processInstanceId, boolean includeDeleted)
List<ActivityInstance>	findActivityInstancesByQueryCriteria(ActivityInstanceQueryImpl historicActivityInstanceQuery)
ActivityInstanceEntity	findUnfinishedActivityInstance(ExecutionEntity execution)
protected ActivityInstanceEntity	findUnfinishedActivityInstance(ExecutionEntity execution, boolean returnNotFinishedFromCacheIfNothingInDb)
protected List<ActivityInstanceEntity>	findUnfinishedActivityInstancesByExecutionAndActivityId(String executionId, String activityId)
protected String	getActivityIdForExecution(ExecutionEntity execution)
protected ActivityInstanceEntity	getActivityInstanceFromCache(String executionId, String activityId, boolean endTimeMustBeNull)
protected String	getArtificialSequenceFlowId(SequenceFlow sequenceFlow)
protected ExecutionEntityManager	getExecutionEntityManager()
protected HistoryManager	getHistoryManager()
protected Object	getOriginalAssignee(TaskEntity taskEntity)
protected int	getTransactionOrderFromCache(String processInstanceId)
protected ActivityInstanceEntity	internalFindOrCreateActivityInstance(TaskEntity taskEntity, ExecutionEntity executionEntity)
protected String	parseActivityType(FlowElement element)
void	recordActivityEnd(ExecutionEntity executionEntity, String deleteReason)	Record Activity end, if activity event logging is enabled.
protected ActivityInstance	recordActivityInstanceEnd(ExecutionEntity executionEntity, String deleteReason)
void	recordActivityStart(ExecutionEntity executionEntity)	Record the start of an activity, if activity event logging is enabled.
protected void	recordActivityTaskCreated(TaskEntity task, ExecutionEntity execution)
void	recordActivityTaskEnd(TaskEntity task, ExecutionEntity execution, String completerUserId, String deleteReason, Date endTime)	Record a user task was completed
protected ActivityInstanceEntity	recordActivityTaskInfoChange(TaskEntity taskEntity)
protected ActivityInstance	recordRuntimeActivityStart(ExecutionEntity executionEntity)
void	recordSequenceFlowTaken(ExecutionEntity executionEntity)	record that sequence flow was taken
void	recordSubProcessInstanceStart(ExecutionEntity parentExecution, ExecutionEntity subProcessInstance)	Record the sub process instance start
void	recordTaskCreated(TaskEntity task, ExecutionEntity execution)	Record task created
void	recordTaskInfoChange(TaskEntity taskEntity, Date changeTime)	Record task information change
void	syncUserTaskExecution(ExecutionEntity executionEntity, FlowElement newFlowElement, String oldActivityId, TaskEntity task)	Synchronize data with the new user task execution
protected void	syncUserTaskExecutionActivityInstance(ExecutionEntity childExecution, String oldActivityId, FlowElement newFlowElement)
void	updateActivityInstancesProcessDefinitionId(String newProcessDefinitionId, String processInstanceId)	Update process definition reference in all activity instances for a given process instance

Methods inherited from class org.flowable.engine.impl.persistence.entity.AbstractProcessEngineEntityManager

createEntityEvent

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

getClock, getCommandExecutor, getEngineConfiguration, getEventDispatcher

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

create, delete, delete, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, insert, insert, setDataManager, update, 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

create, delete, delete, delete, findById, insert, insert, update, update

Field Details

NO_ACTIVITY_ID_PREFIX

protected static final String NO_ACTIVITY_ID_PREFIX

See Also:

• Constant Field Values

NO_ACTIVITY_ID_SEPARATOR

protected static final String NO_ACTIVITY_ID_SEPARATOR

See Also:

• Constant Field Values

logger

protected final org.slf4j.Logger logger

usePrefixId

protected final boolean usePrefixId

Constructor Details

ActivityInstanceEntityManagerImpl

public ActivityInstanceEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration,
 ActivityInstanceDataManager activityInstanceDataManager)

Method Details

findUnfinishedActivityInstancesByExecutionAndActivityId

protected List<ActivityInstanceEntity> findUnfinishedActivityInstancesByExecutionAndActivityId(String executionId,
 String activityId)

findActivityInstancesByExecutionAndActivityId

public List<ActivityInstanceEntity> findActivityInstancesByExecutionAndActivityId(String executionId,
 String activityId)

Specified by:

findActivityInstancesByExecutionAndActivityId in interface ActivityInstanceEntityManager

findActivityInstancesByProcessInstanceId

public List<ActivityInstanceEntity> findActivityInstancesByProcessInstanceId(String processInstanceId,
 boolean includeDeleted)

Specified by:

findActivityInstancesByProcessInstanceId in interface ActivityInstanceEntityManager

findActivityInstanceByTaskId

public ActivityInstanceEntity findActivityInstanceByTaskId(String taskId)

Specified by:

findActivityInstanceByTaskId in interface ActivityInstanceEntityManager

deleteActivityInstancesByProcessInstanceId

public void deleteActivityInstancesByProcessInstanceId(String processInstanceId)

Specified by:

deleteActivityInstancesByProcessInstanceId in interface ActivityInstanceEntityManager

findActivityInstanceCountByQueryCriteria

public long findActivityInstanceCountByQueryCriteria(ActivityInstanceQueryImpl historicActivityInstanceQuery)

Specified by:

findActivityInstanceCountByQueryCriteria in interface ActivityInstanceEntityManager

findActivityInstancesByQueryCriteria

public List<ActivityInstance> findActivityInstancesByQueryCriteria(ActivityInstanceQueryImpl historicActivityInstanceQuery)

Specified by:

findActivityInstancesByQueryCriteria in interface ActivityInstanceEntityManager

findActivityInstancesByNativeQuery

public List<ActivityInstance> findActivityInstancesByNativeQuery(Map<String,Object> parameterMap)

Specified by:

findActivityInstancesByNativeQuery in interface ActivityInstanceEntityManager

findActivityInstanceCountByNativeQuery

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

Specified by:

findActivityInstanceCountByNativeQuery in interface ActivityInstanceEntityManager

recordActivityStart

public void recordActivityStart(ExecutionEntity executionEntity)

Description copied from interface: ActivityInstanceEntityManager

Record the start of an activity, if activity event logging is enabled.

Specified by:

recordActivityStart in interface ActivityInstanceEntityManager

Parameters:

executionEntity - execution which is starting activity

recordActivityEnd

public void recordActivityEnd(ExecutionEntity executionEntity,
 String deleteReason)

Description copied from interface: ActivityInstanceEntityManager

Record Activity end, if activity event logging is enabled.

Specified by:

recordActivityEnd in interface ActivityInstanceEntityManager

Parameters:

executionEntity - execution entity during which execution activity was ended

deleteReason - the reason why activity was ended

recordSequenceFlowTaken

public void recordSequenceFlowTaken(ExecutionEntity executionEntity)

Description copied from interface: ActivityInstanceEntityManager

record that sequence flow was taken

Specified by:

recordSequenceFlowTaken in interface ActivityInstanceEntityManager

Parameters:

executionEntity - execution which executed sequence flow

recordSubProcessInstanceStart

public void recordSubProcessInstanceStart(ExecutionEntity parentExecution,
 ExecutionEntity subProcessInstance)

Description copied from interface: ActivityInstanceEntityManager

Record the sub process instance start

Specified by:

recordSubProcessInstanceStart in interface ActivityInstanceEntityManager

recordTaskCreated

public void recordTaskCreated(TaskEntity task,
 ExecutionEntity execution)

Description copied from interface: ActivityInstanceEntityManager

Record task created

Specified by:

recordTaskCreated in interface ActivityInstanceEntityManager

Parameters:

task - the task which was created

execution - execution which created the task

recordActivityTaskCreated

protected void recordActivityTaskCreated(TaskEntity task,
 ExecutionEntity execution)

recordActivityTaskEnd

public void recordActivityTaskEnd(TaskEntity task,
 ExecutionEntity execution,
 String completerUserId,
 String deleteReason,
 Date endTime)

Description copied from interface: ActivityInstanceEntityManager

Record a user task was completed

Specified by:

recordActivityTaskEnd in interface ActivityInstanceEntityManager

Parameters:

task - the task which was completed

execution - execution which related to the task

completerUserId - the id of the user completion the task, which not necessarily the same as the assignee

recordTaskInfoChange

public void recordTaskInfoChange(TaskEntity taskEntity,
 Date changeTime)

Description copied from interface: ActivityInstanceEntityManager

Record task information change

Specified by:

recordTaskInfoChange in interface ActivityInstanceEntityManager

Parameters:

taskEntity - task entity which was changed

changeTime - the time of the change

syncUserTaskExecution

public void syncUserTaskExecution(ExecutionEntity executionEntity,
 FlowElement newFlowElement,
 String oldActivityId,
 TaskEntity task)

Description copied from interface: ActivityInstanceEntityManager

Synchronize data with the new user task execution

Specified by:

syncUserTaskExecution in interface ActivityInstanceEntityManager

Parameters:

executionEntity - execution which executes user task

newFlowElement - user task flow element

oldActivityId - previous activity id

task - the user task

updateActivityInstancesProcessDefinitionId

public void updateActivityInstancesProcessDefinitionId(String newProcessDefinitionId,
 String processInstanceId)

Description copied from interface: ActivityInstanceEntityManager

Update process definition reference in all activity instances for a given process instance

Specified by:

updateActivityInstancesProcessDefinitionId in interface ActivityInstanceEntityManager

Parameters:

newProcessDefinitionId - new process definition id

processInstanceId - process instance which activities are transformed

syncUserTaskExecutionActivityInstance

protected void syncUserTaskExecutionActivityInstance(ExecutionEntity childExecution,
 String oldActivityId,
 FlowElement newFlowElement)

recordActivityTaskInfoChange

protected ActivityInstanceEntity recordActivityTaskInfoChange(TaskEntity taskEntity)

internalFindOrCreateActivityInstance

protected ActivityInstanceEntity internalFindOrCreateActivityInstance(TaskEntity taskEntity,
 ExecutionEntity executionEntity)

getOriginalAssignee

protected Object getOriginalAssignee(TaskEntity taskEntity)

recordRuntimeActivityStart

protected ActivityInstance recordRuntimeActivityStart(ExecutionEntity executionEntity)

createActivityInstance

protected ActivityInstance createActivityInstance(ExecutionEntity executionEntity)

recordActivityInstanceEnd

protected ActivityInstance recordActivityInstanceEnd(ExecutionEntity executionEntity,
 String deleteReason)

findUnfinishedActivityInstance

public ActivityInstanceEntity findUnfinishedActivityInstance(ExecutionEntity execution)

Specified by:

findUnfinishedActivityInstance in interface ActivityInstanceEntityManager

findUnfinishedActivityInstance

protected ActivityInstanceEntity findUnfinishedActivityInstance(ExecutionEntity execution,
 boolean returnNotFinishedFromCacheIfNothingInDb)

createActivityInstanceEntity

protected ActivityInstanceEntity createActivityInstanceEntity(ExecutionEntity execution)

getActivityInstanceFromCache

protected ActivityInstanceEntity getActivityInstanceFromCache(String executionId,
 String activityId,
 boolean endTimeMustBeNull)

getTransactionOrderFromCache

protected int getTransactionOrderFromCache(String processInstanceId)

parseActivityType

protected String parseActivityType(FlowElement element)

getActivityIdForExecution

protected String getActivityIdForExecution(ExecutionEntity execution)

createActivityInstance

protected ActivityInstanceEntity createActivityInstance(HistoricActivityInstance historicActivityInstance)

getArtificialSequenceFlowId

protected String getArtificialSequenceFlowId(SequenceFlow sequenceFlow)

getHistoryManager

protected HistoryManager getHistoryManager()

getExecutionEntityManager

protected ExecutionEntityManager getExecutionEntityManager()