Versions in this module Expand all Collapse all v0 v0.0.2 Dec 16, 2024 v0.0.1 Dec 16, 2024 Changes in this version + type ActHiProcinstDTO struct + ProcessDefinitionName string + type DeploymentDataManager struct + func GetDeploymentDataManager() *DeploymentDataManager + type ExecutionDataManager struct + func GetExecutionDataManager() *ExecutionDataManager + func (executionDataManager *ExecutionDataManager) CreateProcessInstance(processInstance *model.ActRuExecution) error + func (executionDataManager *ExecutionDataManager) GetProcessInstance(processInstanceId string) (model.ActRuExecution, error) + func (executionDataManager *ExecutionDataManager) MigrateExecutionActID(procDefId, oldActivityId, newActivityId string) error + func (executionDataManager *ExecutionDataManager) MigrateExecutionProcDefID(oldProcDefId, newProcDefId string) error + func (executionDataManager *ExecutionDataManager) MigrateProcessInstance(oldProcDefId, newProcDefId, startActId string) error + func (executionDataManager *ExecutionDataManager) MigrateProcessInstanceBusinessStatus(procDefId, oldActivityId, newActivityId string) error + func (executionDataManager *ExecutionDataManager) RecordBusinessStatus(processInstanceId, businessStatus string) error + func (executionDataManager ExecutionDataManager) DeleteProcessInstance(execution delegate.DelegateExecution, deleteReason *string) error + func (executionDataManager ExecutionDataManager) List(listRequest execution.ListRequest) ([]model.ActRuExecution, error) + type HistoricActinstDataManager struct + func GetHistoricActinstDataManager() *HistoricActinstDataManager + func (historicActinstManager HistoricActinstDataManager) ChangeTaskAssignee(taskId string, userId *string) (err error) + func (historicActinstManager HistoricActinstDataManager) DeleteByExecutionId(executionId string) error + func (historicActinstManager HistoricActinstDataManager) DeleteByProcessInstanceId(processInstanceId, actId string) error + func (historicActinstManager HistoricActinstDataManager) List(listRequest historicactinst.ListRequest) ([]model.ActHiActinst, error) + func (historicActinstManager HistoricActinstDataManager) MigrateAct(procDefId, oldActivityId, newActivityId, newName, newType string) error + func (historicActinstManager HistoricActinstDataManager) MigrateProcDefID(oldProcDefId, newProcDefId string) error + func (historicActinstManager HistoricActinstDataManager) RecordActEndByExecutionId(executionId string, actId string, deleteReason *string) error + func (historicActinstManager HistoricActinstDataManager) RecordActEndByProcessInstanceId(processInstanceId string, deleteReason *string) error + func (historicActinstManager HistoricActinstDataManager) RecordTaskId(task model.ActRuTask) error + type HistoricIdentityLinkDataManager struct + func GetHistoricIdentityLinkDataManager() *HistoricIdentityLinkDataManager + func (historicIdentityLinkDataManager HistoricIdentityLinkDataManager) SelectByProcessInstanceId(processInstanceId string) ([]model.ActHiIdentitylink, error) + type HistoricProcessDataManager struct + func GetHistoricProcessDataManager() *HistoricProcessDataManager + func (historicProcessManager HistoricProcessDataManager) List(listRequest historicprocess.ListRequest) ([]ActHiProcinstDTO, error) + func (historicProcessManager HistoricProcessDataManager) MarkEnded(processInstanceId string, endActID *string, deleteReason *string) (err error) + func (historicProcessManager HistoricProcessDataManager) Migrate(oldProcDefId, newProcDefId, startActId string) error + func (historicProcessManager HistoricProcessDataManager) MigrateBusinessStatus(procDefId, oldActivityId, newActivityId string) error + func (historicProcessManager HistoricProcessDataManager) RecordBusinessStatus(processInstanceId, businessStatus string) error + type HistoricTaskDataManager struct + func GetHistoricTaskDataManager() *HistoricTaskDataManager + func (historicTaskManager HistoricTaskDataManager) ChangeTaskAssignee(task model.ActRuTask) error + func (historicTaskManager HistoricTaskDataManager) List(listRequest historictask.ListRequest) ([]model.ActHiTaskinst, error) + func (historicTaskManager HistoricTaskDataManager) MigrateNameAndTaskDefKey(procDefId, oldActivityId, newActivityId, newName string) error + func (historicTaskManager HistoricTaskDataManager) RecordTaskEnd(id string, deleteReason *string) error + type HistoricVariableDataManager struct + func GetHistoricVariableDataManager() *HistoricVariableDataManager + func (historicVariableDataManager HistoricVariableDataManager) Upsert(varinst variable.HistoricVariable) error + type IdentityLinkDataManager struct + func GetIdentityLinkDataManager() *IdentityLinkDataManager + func (identityLinkManager IdentityLinkDataManager) DeleteByProcessInstanceId(processInstanceId string) error + func (identityLinkManager IdentityLinkDataManager) SelectByProcessInstanceId(processInstanceId string) ([]ActRuIdentitylink, error) + func (identityLinkManager IdentityLinkDataManager) SelectByTaskId(taskId string) ([]ActRuIdentitylink, error) + type ProcessDefinitionDataManager struct + func GetProcessDefinitionDataManager() *ProcessDefinitionDataManager + func (define ProcessDefinitionDataManager) FindDeployedProcessDefinitionByDeploymentId(deploymentId string) (model.ActReProcdef, error) + func (define ProcessDefinitionDataManager) FindDeployedProcessDefinitionByKey(key string) (model.ActReProcdef, error) + type ResourceDataManager struct + func GetResourceDataManager() *ResourceDataManager + func (define ResourceDataManager) FindResourceByDeploymentIdAndResourceName(deploymentId, resourceName string) (ActGeBytearray, error) + type TaskDataManager struct + func GetTaskDataManager() *TaskDataManager + func (taskManager TaskDataManager) ChangeTaskAssignee(task model.ActRuTask) error + func (taskManager TaskDataManager) FindByProcessInstanceId(processInstanceId string) ([]model.ActRuTask, error) + func (taskManager TaskDataManager) GetById(id int64) (model.ActRuTask, error) + func (taskManager TaskDataManager) List(listRequest task.ListRequest) ([]model.ActRuTask, error) + func (taskManager TaskDataManager) MigrateNameAndTaskDefKey(procDefId, oldActivityId, newActivityId, newName string) error + func (taskManager TaskDataManager) MigrateProcDefID(oldProcDefId, newProcDefId string) error + func (taskManager TaskDataManager) QueryUndoTask(userId, groupId string) (taskResult []task.TaskDTO, err error) + type VariableDataManager struct + func GetVariableDataManager() *VariableDataManager + func (defineManager VariableDataManager) SelectByProcessInstanceIdAndName(name string, processInstanceId string) (variable.Variable, error) + func (variableManager VariableDataManager) Delete(variableId string) error + func (variableManager VariableDataManager) DeleteByExecutionId(executionId string) error + func (variableManager VariableDataManager) DeleteByProcessInstanceId(processInstanceId string) error + func (variableManager VariableDataManager) SelectByProcessInstanceId(processInstanceId string) ([]variable.Variable, error) + func (variableManager VariableDataManager) SelectByTaskId(taskId string) ([]variable.Variable, error) + func (variableManager VariableDataManager) SelectTaskId(name string, taskId string) (variable.Variable, error) + func (variableManager VariableDataManager) Upsert(varinst variable.Variable) error