public class AsyncIndexingCmmnHistoryManager
extends org.flowable.cmmn.engine.impl.history.async.AbstractAsyncCmmnHistoryManager
Modifier and Type | Field and Description |
---|---|
protected List<PlatformIndexedDataEnhancer> |
indexedDataEnhancers |
protected IndexingManagerHelperImpl |
indexHelper |
static String |
TASK_ASSIGNEE_IDENTITY_LINK_ID_PREFIX |
static String |
TASK_OWNER_IDENTITY_LINK_ID_PREFIX |
Constructor and Description |
---|
AsyncIndexingCmmnHistoryManager(org.flowable.cmmn.engine.CmmnEngineConfiguration cmmnEngineConfiguration,
IndexManager indexManager,
IndexVariableTypes indexVariableTypes) |
Modifier and Type | Method and Description |
---|---|
protected void |
addCaseDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data,
org.flowable.cmmn.api.repository.CaseDefinition caseDefinition,
String key) |
protected void |
addCommonRootCaseInstanceFields(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addCommonTaskFields(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addCreatedIdentityLink(String id,
String type,
String userId,
String groupId,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
addCreatedUserIdentityLink(String id,
String type,
String userId,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
createAndAddPlanItemInstanceHistoricData(String tenantId) |
void |
deleteHistoricUserTaskLogEntry(long logNumber) |
List<PlatformIndexedDataEnhancer> |
getIndexedDataEnhancers() |
protected org.flowable.job.service.JobServiceConfiguration |
getJobServiceConfiguration() |
protected com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddPlanItemInstanceData(String planItemInstanceId,
String tenantId) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingPlanItemInstanceData(String planItemInstanceId) |
protected void |
handleRecordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
handleRecordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink,
com.fasterxml.jackson.databind.node.ObjectNode data) |
void |
recordCaseInstanceEnd(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
String state,
Date endTime) |
void |
recordCaseInstanceStart(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance) |
void |
recordEntityLinkCreated(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink) |
void |
recordEntityLinkDeleted(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink) |
void |
recordHistoricCaseInstanceDeleted(String caseInstanceId,
String tenantId) |
void |
recordHistoricUserTaskLogEntry(org.flowable.task.api.history.HistoricTaskLogEntryBuilder taskLogEntryBuilder) |
void |
recordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink) |
void |
recordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink) |
void |
recordMilestoneReached(org.flowable.cmmn.engine.impl.persistence.entity.MilestoneInstanceEntity milestoneInstance) |
void |
recordPlanItemInstanceAvailable(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceCompleted(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceCreated(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceDisabled(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceEnabled(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceExit(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceOccurred(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceStarted(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceSuspended(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceTerminated(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
void |
recordPlanItemInstanceUpdated(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance) |
protected void |
recordRootCaseInstanceEnd(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
String state,
Date endTime,
Long duration) |
protected void |
recordRootCaseInstanceStart(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance) |
void |
recordTaskCreated(org.flowable.task.service.impl.persistence.entity.TaskEntity task) |
void |
recordTaskEnd(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
String deleteReason,
Date endTime) |
void |
recordTaskInfoChange(org.flowable.task.service.impl.persistence.entity.TaskEntity task,
Date changeTime) |
void |
recordUpdateBusinessKey(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
String businessKey) |
void |
recordUpdateCaseInstanceName(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
String name) |
protected void |
recordUpdateRootCaseInstanceBusinessKey(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
String businessKey) |
protected void |
recordUpdateRootCaseInstanceName(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance,
String name) |
void |
recordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
Date createTime) |
void |
recordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable) |
void |
recordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
Date updateTime) |
protected void |
removeIdentityLink(com.fasterxml.jackson.databind.node.ObjectNode data,
String id) |
void |
setIndexedDataEnhancers(List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
protected boolean |
shouldIndexIdentityLink(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
updatePlanItemInstanceTimestamp(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance,
Date time,
String timeField) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
updatePlanItemInstanceTimestamp(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance,
Date time,
String timeField,
boolean isEndTime) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
updatePlanItemInstanceTimestampEnded(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance,
Date time,
String timeField) |
addCaseDefinitionFields, addCommonCaseInstanceFields, addCommonEntityLinkFields, addCommonHistoricCaseInstanceFields, addCommonHistoricTaskLogEntryFields, addCommonIdentityLinkFields, addCommonMilestoneInstanceFields, addCommonPlanItemInstanceFields, addCommonVariableFields, evaluateShowInOverview, getCaseDefinition
public static final String TASK_OWNER_IDENTITY_LINK_ID_PREFIX
public static final String TASK_ASSIGNEE_IDENTITY_LINK_ID_PREFIX
protected IndexingManagerHelperImpl indexHelper
protected List<PlatformIndexedDataEnhancer> indexedDataEnhancers
public AsyncIndexingCmmnHistoryManager(org.flowable.cmmn.engine.CmmnEngineConfiguration cmmnEngineConfiguration, IndexManager indexManager, IndexVariableTypes indexVariableTypes)
protected org.flowable.job.service.JobServiceConfiguration getJobServiceConfiguration()
public void recordCaseInstanceStart(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance)
protected void recordRootCaseInstanceStart(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance)
protected void addCommonRootCaseInstanceFields(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void addCaseDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data, org.flowable.cmmn.api.repository.CaseDefinition caseDefinition, String key)
public void recordCaseInstanceEnd(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, String state, Date endTime)
protected void recordRootCaseInstanceEnd(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, String state, Date endTime, Long duration)
public void recordUpdateCaseInstanceName(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, String name)
protected void recordUpdateRootCaseInstanceName(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, String name)
public void recordMilestoneReached(org.flowable.cmmn.engine.impl.persistence.entity.MilestoneInstanceEntity milestoneInstance)
public void recordHistoricCaseInstanceDeleted(String caseInstanceId, String tenantId)
public void recordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected void handleRecordIdentityLinkCreated(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void addCreatedUserIdentityLink(String id, String type, String userId, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void addCreatedIdentityLink(String id, String type, String userId, String groupId, com.fasterxml.jackson.databind.node.ObjectNode data)
public void recordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected void handleRecordIdentityLinkDeleted(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink, com.fasterxml.jackson.databind.node.ObjectNode data)
protected void removeIdentityLink(com.fasterxml.jackson.databind.node.ObjectNode data, String id)
public void recordEntityLinkCreated(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink)
public void recordEntityLinkDeleted(org.flowable.entitylink.service.impl.persistence.entity.EntityLinkEntity entityLink)
public void recordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, Date createTime)
public void recordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, Date updateTime)
public void recordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable)
public void recordTaskCreated(org.flowable.task.service.impl.persistence.entity.TaskEntity task)
public void recordTaskEnd(org.flowable.task.service.impl.persistence.entity.TaskEntity task, String deleteReason, Date endTime)
public void recordTaskInfoChange(org.flowable.task.service.impl.persistence.entity.TaskEntity task, Date changeTime)
protected void addCommonTaskFields(org.flowable.task.service.impl.persistence.entity.TaskEntity task, com.fasterxml.jackson.databind.node.ObjectNode data)
addCommonTaskFields
in class org.flowable.cmmn.engine.impl.history.async.AbstractAsyncCmmnHistoryManager
public void recordPlanItemInstanceCreated(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceUpdated(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceAvailable(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceEnabled(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceDisabled(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceStarted(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceSuspended(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceCompleted(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceOccurred(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceTerminated(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordPlanItemInstanceExit(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance)
public void recordUpdateBusinessKey(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, String businessKey)
protected void recordUpdateRootCaseInstanceBusinessKey(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance, String businessKey)
protected com.fasterxml.jackson.databind.node.ObjectNode updatePlanItemInstanceTimestamp(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance, Date time, String timeField)
protected com.fasterxml.jackson.databind.node.ObjectNode updatePlanItemInstanceTimestampEnded(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance, Date time, String timeField)
protected com.fasterxml.jackson.databind.node.ObjectNode updatePlanItemInstanceTimestamp(org.flowable.cmmn.engine.impl.persistence.entity.PlanItemInstanceEntity planItemInstance, Date time, String timeField, boolean isEndTime)
public void recordHistoricUserTaskLogEntry(org.flowable.task.api.history.HistoricTaskLogEntryBuilder taskLogEntryBuilder)
public void deleteHistoricUserTaskLogEntry(long logNumber)
protected boolean shouldIndexIdentityLink(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddPlanItemInstanceData(String planItemInstanceId, String tenantId)
protected com.fasterxml.jackson.databind.node.ObjectNode getMatchingPlanItemInstanceData(String planItemInstanceId)
protected com.fasterxml.jackson.databind.node.ObjectNode createAndAddPlanItemInstanceHistoricData(String tenantId)
public List<PlatformIndexedDataEnhancer> getIndexedDataEnhancers()
public void setIndexedDataEnhancers(List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
Copyright © 2019. All rights reserved.