datamanager

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActHiProcinstDTO 

type ActHiProcinstDTO struct {
	model.ActHiProcinst
	ProcessDefinitionName string
}

type DeploymentDataManager 

type DeploymentDataManager struct {
	abstract.DataManager
}

func GetDeploymentDataManager 

func GetDeploymentDataManager() *DeploymentDataManager

type ExecutionDataManager 

type ExecutionDataManager struct {
	abstract.DataManager
}

func GetExecutionDataManager 

func GetExecutionDataManager() *ExecutionDataManager

func (*ExecutionDataManager) CreateProcessInstance 

func (executionDataManager *ExecutionDataManager) CreateProcessInstance(processInstance *model.ActRuExecution) error

创建流程实例

func (ExecutionDataManager) DeleteProcessInstance 

func (executionDataManager ExecutionDataManager) DeleteProcessInstance(execution delegate.DelegateExecution, deleteReason *string) error

DeleteProcessInstance 删除流程实例

func (*ExecutionDataManager) GetProcessInstance 

func (executionDataManager *ExecutionDataManager) GetProcessInstance(processInstanceId string) (model.ActRuExecution, error)

查询流程实例

func (ExecutionDataManager) List 

func (executionDataManager ExecutionDataManager) List(listRequest execution.ListRequest) ([]model.ActRuExecution, error)

func (*ExecutionDataManager) MigrateExecutionActID 

func (executionDataManager *ExecutionDataManager) MigrateExecutionActID(procDefId, oldActivityId, newActivityId string) error

func (*ExecutionDataManager) MigrateExecutionProcDefID 

func (executionDataManager *ExecutionDataManager) MigrateExecutionProcDefID(oldProcDefId, newProcDefId string) error

func (*ExecutionDataManager) MigrateProcessInstance 

func (executionDataManager *ExecutionDataManager) MigrateProcessInstance(oldProcDefId, newProcDefId, startActId string) error

func (*ExecutionDataManager) MigrateProcessInstanceBusinessStatus 

func (executionDataManager *ExecutionDataManager) MigrateProcessInstanceBusinessStatus(procDefId, oldActivityId, newActivityId string) error

func (*ExecutionDataManager) RecordBusinessStatus 

func (executionDataManager *ExecutionDataManager) RecordBusinessStatus(processInstanceId, businessStatus string) error

RecordBusinessStatus records business status of a process instance

type HistoricActinstDataManager 

type HistoricActinstDataManager struct {
	abstract.DataManager
}

func GetHistoricActinstDataManager 

func GetHistoricActinstDataManager() *HistoricActinstDataManager

func (HistoricActinstDataManager) ChangeTaskAssignee 

func (historicActinstManager HistoricActinstDataManager) ChangeTaskAssignee(taskId string, userId *string) (err error)

func (HistoricActinstDataManager) DeleteByExecutionId 

func (historicActinstManager HistoricActinstDataManager) DeleteByExecutionId(executionId string) error

func (HistoricActinstDataManager) DeleteByProcessInstanceId 

func (historicActinstManager HistoricActinstDataManager) DeleteByProcessInstanceId(processInstanceId, actId string) error

func (HistoricActinstDataManager) List 

func (historicActinstManager HistoricActinstDataManager) List(listRequest historicactinst.ListRequest) ([]model.ActHiActinst, error)

func (HistoricActinstDataManager) MigrateAct 

func (historicActinstManager HistoricActinstDataManager) MigrateAct(procDefId, oldActivityId, newActivityId, newName, newType string) error

func (HistoricActinstDataManager) MigrateProcDefID 

func (historicActinstManager HistoricActinstDataManager) MigrateProcDefID(oldProcDefId, newProcDefId string) error

func (HistoricActinstDataManager) RecordActEndByExecutionId 

func (historicActinstManager HistoricActinstDataManager) RecordActEndByExecutionId(executionId string, actId string, deleteReason *string) error

func (HistoricActinstDataManager) RecordActEndByProcessInstanceId 

func (historicActinstManager HistoricActinstDataManager) RecordActEndByProcessInstanceId(processInstanceId string, deleteReason *string) error

func (HistoricActinstDataManager) RecordTaskId 

func (historicActinstManager HistoricActinstDataManager) RecordTaskId(task model.ActRuTask) error

type HistoricIdentityLinkDataManager 

type HistoricIdentityLinkDataManager struct {
	abstract.DataManager
}

func GetHistoricIdentityLinkDataManager 

func GetHistoricIdentityLinkDataManager() *HistoricIdentityLinkDataManager

func (HistoricIdentityLinkDataManager) SelectByProcessInstanceId 

func (historicIdentityLinkDataManager HistoricIdentityLinkDataManager) SelectByProcessInstanceId(processInstanceId string) ([]model.ActHiIdentitylink, error)

type HistoricProcessDataManager 

type HistoricProcessDataManager struct {
	abstract.DataManager
}

func GetHistoricProcessDataManager 

func GetHistoricProcessDataManager() *HistoricProcessDataManager

func (HistoricProcessDataManager) List 

func (historicProcessManager HistoricProcessDataManager) List(listRequest historicprocess.ListRequest) ([]ActHiProcinstDTO, error)

func (HistoricProcessDataManager) MarkEnded 

func (historicProcessManager HistoricProcessDataManager) MarkEnded(processInstanceId string, endActID *string, deleteReason *string) (err error)

func (HistoricProcessDataManager) Migrate 

func (historicProcessManager HistoricProcessDataManager) Migrate(oldProcDefId, newProcDefId, startActId string) error

func (HistoricProcessDataManager) MigrateBusinessStatus 

func (historicProcessManager HistoricProcessDataManager) MigrateBusinessStatus(procDefId, oldActivityId, newActivityId string) error

func (HistoricProcessDataManager) RecordBusinessStatus 

func (historicProcessManager HistoricProcessDataManager) RecordBusinessStatus(processInstanceId, businessStatus string) error

type HistoricTaskDataManager 

type HistoricTaskDataManager struct {
	abstract.DataManager
}

func GetHistoricTaskDataManager 

func GetHistoricTaskDataManager() *HistoricTaskDataManager

func (HistoricTaskDataManager) ChangeTaskAssignee 

func (historicTaskManager HistoricTaskDataManager) ChangeTaskAssignee(task model.ActRuTask) error

func (HistoricTaskDataManager) List 

func (historicTaskManager HistoricTaskDataManager) List(listRequest historictask.ListRequest) ([]model.ActHiTaskinst, error)

func (HistoricTaskDataManager) MigrateNameAndTaskDefKey 

func (historicTaskManager HistoricTaskDataManager) MigrateNameAndTaskDefKey(procDefId, oldActivityId, newActivityId, newName string) error

func (HistoricTaskDataManager) RecordTaskEnd 

func (historicTaskManager HistoricTaskDataManager) RecordTaskEnd(id string, deleteReason *string) error

type HistoricVariableDataManager 

type HistoricVariableDataManager struct {
	abstract.DataManager
}

func GetHistoricVariableDataManager 

func GetHistoricVariableDataManager() *HistoricVariableDataManager

func (HistoricVariableDataManager) Upsert 

func (historicVariableDataManager HistoricVariableDataManager) Upsert(varinst variable.HistoricVariable) error

type IdentityLinkDataManager 

type IdentityLinkDataManager struct {
	abstract.DataManager
}

func GetIdentityLinkDataManager 

func GetIdentityLinkDataManager() *IdentityLinkDataManager

func (IdentityLinkDataManager) DeleteByProcessInstanceId 

func (identityLinkManager IdentityLinkDataManager) DeleteByProcessInstanceId(processInstanceId string) error

func (IdentityLinkDataManager) SelectByProcessInstanceId 

func (identityLinkManager IdentityLinkDataManager) SelectByProcessInstanceId(processInstanceId string) ([]ActRuIdentitylink, error)

func (IdentityLinkDataManager) SelectByTaskId 

func (identityLinkManager IdentityLinkDataManager) SelectByTaskId(taskId string) ([]ActRuIdentitylink, error)

type ProcessDefinitionDataManager 

type ProcessDefinitionDataManager struct {
	abstract.DataManager
}

func GetProcessDefinitionDataManager 

func GetProcessDefinitionDataManager() *ProcessDefinitionDataManager

func (ProcessDefinitionDataManager) FindDeployedProcessDefinitionByDeploymentId 

func (define ProcessDefinitionDataManager) FindDeployedProcessDefinitionByDeploymentId(deploymentId string) (model.ActReProcdef, error)

func (ProcessDefinitionDataManager) FindDeployedProcessDefinitionByKey 

func (define ProcessDefinitionDataManager) FindDeployedProcessDefinitionByKey(key string) (model.ActReProcdef, error)

type ResourceDataManager 

type ResourceDataManager struct {
	abstract.DataManager
}

func GetResourceDataManager 

func GetResourceDataManager() *ResourceDataManager

func (ResourceDataManager) FindResourceByDeploymentIdAndResourceName 

func (define ResourceDataManager) FindResourceByDeploymentIdAndResourceName(deploymentId, resourceName string) (ActGeBytearray, error)

type TaskDataManager 

type TaskDataManager struct {
	abstract.DataManager
}

func GetTaskDataManager 

func GetTaskDataManager() *TaskDataManager

func (TaskDataManager) ChangeTaskAssignee 

func (taskManager TaskDataManager) ChangeTaskAssignee(task model.ActRuTask) error

func (TaskDataManager) FindByProcessInstanceId 

func (taskManager TaskDataManager) FindByProcessInstanceId(processInstanceId string) ([]model.ActRuTask, error)

func (TaskDataManager) GetById 

func (taskManager TaskDataManager) GetById(id int64) (model.ActRuTask, error)

func (TaskDataManager) List 

func (taskManager TaskDataManager) List(listRequest task.ListRequest) ([]model.ActRuTask, error)

func (TaskDataManager) MigrateNameAndTaskDefKey 

func (taskManager TaskDataManager) MigrateNameAndTaskDefKey(procDefId, oldActivityId, newActivityId, newName string) error

func (TaskDataManager) MigrateProcDefID 

func (taskManager TaskDataManager) MigrateProcDefID(oldProcDefId, newProcDefId string) error

func (TaskDataManager) QueryUndoTask 

func (taskManager TaskDataManager) QueryUndoTask(userId, groupId string) (taskResult []task.TaskDTO, err error)

type VariableDataManager 

type VariableDataManager struct {
	abstract.DataManager
}

func GetVariableDataManager 

func GetVariableDataManager() *VariableDataManager

func (VariableDataManager) Delete 

func (variableManager VariableDataManager) Delete(variableId string) error

func (VariableDataManager) DeleteByExecutionId 

func (variableManager VariableDataManager) DeleteByExecutionId(executionId string) error

func (VariableDataManager) DeleteByProcessInstanceId 

func (variableManager VariableDataManager) DeleteByProcessInstanceId(processInstanceId string) error

func (VariableDataManager) SelectByProcessInstanceId 

func (variableManager VariableDataManager) SelectByProcessInstanceId(processInstanceId string) ([]variable.Variable, error)

func (VariableDataManager) SelectByProcessInstanceIdAndName 

func (defineManager VariableDataManager) SelectByProcessInstanceIdAndName(name string, processInstanceId string) (variable.Variable, error)

func (VariableDataManager) SelectByTaskId 

func (variableManager VariableDataManager) SelectByTaskId(taskId string) ([]variable.Variable, error)

func (VariableDataManager) SelectTaskId 

func (variableManager VariableDataManager) SelectTaskId(name string, taskId string) (variable.Variable, error)

func (VariableDataManager) Upsert 

func (variableManager VariableDataManager) Upsert(varinst variable.Variable) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.