Class MigrationService
java.lang.Object
com.flowable.platform.edorasone.migration.MigrationService
- Direct Known Subclasses:
CaseMigrationService
,ProcessMigrationService
,TaskMigrationService
public abstract class MigrationService
extends java.lang.Object
-
Field Summary
Fields Modifier and Type Field Description protected static java.lang.String
DUE_TIME
protected static java.lang.String
EXTERNAL_ID
protected static java.lang.String
ID_VARIABLE_NAME
protected static java.lang.String
INITIAL_ASSIGNED_GROUP_ID
protected static java.lang.String
PATH
protected static java.lang.String
PRIORITY
protected static java.lang.String
PROVIDER_ID
protected static java.lang.String
RESUBMISSION_TIME
protected static java.lang.String
STATE_UPDATE_TIME
protected static java.lang.String
SUB_STATE
protected static java.lang.String
SUB_STATE_UPDATE_TIME
static java.lang.String
TRASFORMER_VERSION
static java.lang.String
VERSION_VALUE
transformer versions -
Constructor Summary
Constructors Constructor Description MigrationService()
-
Method Summary
Modifier and Type Method Description protected void
convertToHistoricEntityFromWorkObjectTemplate(WorkObject inactiveWorkObject)
protected abstract java.lang.String
createHistoricEntityFromTemplate(WorkObject inactiveWorkObject)
protected abstract void
createHistoricEntityVariable(java.lang.String historicCaseEntityId, java.lang.String variableName, java.lang.Object variableValue)
protected void
createHistoricIdentityLinksFromTemplate(WorkObject inactiveWorkObject, java.lang.String historicEntityId)
protected void
createVariablesFromTemplate(WorkObject inactiveWorkObject, java.lang.String historicEntityId)
protected void
fetchAndConvert(WorkObject workObjectWithoutVariables)
protected abstract java.util.Date
getCurrentTime()
protected abstract java.util.List<org.flowable.identitylink.service.impl.persistence.entity.HistoricIdentityLinkEntity>
getHistoricIdentityLinks(java.lang.String id)
protected abstract java.util.List<org.flowable.variable.api.history.HistoricVariableInstance>
getHistoricVariables(java.lang.String historicCaseEntityId)
protected abstract WorkObjectQuery
getWorkObjectQuery()
protected WorkObjectService
getWorkObjectService()
protected abstract void
insertHistoricIdentityLink(java.lang.String historicEntityId, java.lang.String userId, java.lang.String groupId, java.util.Date createTime, java.lang.String identityLinkType)
int
migrate(int batchSize)
int
validate(int offset, int size)
protected void
validate(WorkObject workObjectWithoutVariables)
protected abstract void
validateHistoricEntityWithWorkObject(WorkObject inactiveWorkObject)
protected void
validateHistoricIdentityLink(java.util.List<org.flowable.identitylink.service.impl.persistence.entity.HistoricIdentityLinkEntity> historicIdentityLinks, java.lang.String userId, java.lang.String groupId, java.util.Date createTime, java.lang.String identityLinkType)
protected void
validateHistoricIdentityLinks(WorkObject inactiveWorkObject)
protected void
validateVariable(java.util.List<org.flowable.variable.api.history.HistoricVariableInstance> historicVariables, java.lang.String variableName, java.lang.Object variableValue)
protected void
validateVariables(WorkObject inactiveWorkObject)
protected void
validateVariables(java.util.List<org.flowable.variable.api.history.HistoricVariableInstance> historicVariables, WorkObject inactiveWorkObject)
protected void
validateWorkObjectConversion(WorkObject inactiveWorkObject)
-
Field Details
-
VERSION_VALUE
public static final java.lang.String VERSION_VALUEtransformer versions- See Also:
- Constant Field Values
-
TRASFORMER_VERSION
public static final java.lang.String TRASFORMER_VERSION- See Also:
- Constant Field Values
-
ID_VARIABLE_NAME
protected static final java.lang.String ID_VARIABLE_NAME- See Also:
- Constant Field Values
-
EXTERNAL_ID
protected static final java.lang.String EXTERNAL_ID- See Also:
- Constant Field Values
-
PROVIDER_ID
protected static final java.lang.String PROVIDER_ID- See Also:
- Constant Field Values
-
PRIORITY
protected static final java.lang.String PRIORITY- See Also:
- Constant Field Values
-
RESUBMISSION_TIME
protected static final java.lang.String RESUBMISSION_TIME- See Also:
- Constant Field Values
-
DUE_TIME
protected static final java.lang.String DUE_TIME- See Also:
- Constant Field Values
-
PATH
protected static final java.lang.String PATH- See Also:
- Constant Field Values
-
SUB_STATE
protected static final java.lang.String SUB_STATE- See Also:
- Constant Field Values
-
STATE_UPDATE_TIME
protected static final java.lang.String STATE_UPDATE_TIME- See Also:
- Constant Field Values
-
SUB_STATE_UPDATE_TIME
protected static final java.lang.String SUB_STATE_UPDATE_TIME- See Also:
- Constant Field Values
-
INITIAL_ASSIGNED_GROUP_ID
protected static final java.lang.String INITIAL_ASSIGNED_GROUP_ID- See Also:
- Constant Field Values
-
-
Constructor Details
-
MigrationService
public MigrationService()
-
-
Method Details
-
migrate
public int migrate(int batchSize) -
validate
public int validate(int offset, int size) -
fetchAndConvert
-
validate
-
convertToHistoricEntityFromWorkObjectTemplate
-
createHistoricIdentityLinksFromTemplate
protected void createHistoricIdentityLinksFromTemplate(WorkObject inactiveWorkObject, java.lang.String historicEntityId) -
validateHistoricIdentityLinks
-
getHistoricIdentityLinks
protected abstract java.util.List<org.flowable.identitylink.service.impl.persistence.entity.HistoricIdentityLinkEntity> getHistoricIdentityLinks(java.lang.String id) -
createVariablesFromTemplate
protected void createVariablesFromTemplate(WorkObject inactiveWorkObject, java.lang.String historicEntityId) -
validateVariables
-
validateVariables
protected void validateVariables(java.util.List<org.flowable.variable.api.history.HistoricVariableInstance> historicVariables, WorkObject inactiveWorkObject) -
validateVariable
protected void validateVariable(java.util.List<org.flowable.variable.api.history.HistoricVariableInstance> historicVariables, java.lang.String variableName, java.lang.Object variableValue) -
validateWorkObjectConversion
-
getWorkObjectService
-
createHistoricEntityVariable
protected abstract void createHistoricEntityVariable(java.lang.String historicCaseEntityId, java.lang.String variableName, java.lang.Object variableValue) -
getHistoricVariables
protected abstract java.util.List<org.flowable.variable.api.history.HistoricVariableInstance> getHistoricVariables(java.lang.String historicCaseEntityId) -
insertHistoricIdentityLink
protected abstract void insertHistoricIdentityLink(java.lang.String historicEntityId, java.lang.String userId, java.lang.String groupId, java.util.Date createTime, java.lang.String identityLinkType) -
validateHistoricIdentityLink
protected void validateHistoricIdentityLink(java.util.List<org.flowable.identitylink.service.impl.persistence.entity.HistoricIdentityLinkEntity> historicIdentityLinks, java.lang.String userId, java.lang.String groupId, java.util.Date createTime, java.lang.String identityLinkType) -
getCurrentTime
protected abstract java.util.Date getCurrentTime() -
createHistoricEntityFromTemplate
protected abstract java.lang.String createHistoricEntityFromTemplate(WorkObject inactiveWorkObject) -
validateHistoricEntityWithWorkObject
-
getWorkObjectQuery
-