entitymanager

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2025 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsIntegral added in v0.0.3 

func IsIntegral(val float64) bool

Types

type AbstractEntity 

type AbstractEntity struct {
	Id string `json:"id"`
}

func (*AbstractEntity) GetId 

func (entity *AbstractEntity) GetId() string

func (*AbstractEntity) SetId 

func (entity *AbstractEntity) SetId(id string)

type AbstractVariableScopeImpl 

type AbstractVariableScopeImpl interface {
	GetSourceActivityExecution() ExecutionEntity
}

type DefaultHistoryManager 

type DefaultHistoryManager struct {
}

type DeploymentEntity 

type DeploymentEntity struct {
	Name           string
	Key            string
	ProcessId      string
	TenantId       string
	DeploymentTime time.Time
	IsNew          bool
	ResourceEntity ResourceEntity
}

func (*DeploymentEntity) AddResource 

func (deploymentEntity *DeploymentEntity) AddResource(resource ResourceEntity)

func (*DeploymentEntity) GetKey 

func (deploymentEntity *DeploymentEntity) GetKey() string

func (*DeploymentEntity) GetName 

func (deploymentEntity *DeploymentEntity) GetName() string

func (*DeploymentEntity) GetResources 

func (deploymentEntity *DeploymentEntity) GetResources() ResourceEntity

func (*DeploymentEntity) SetDeploymentTime 

func (deploymentEntity *DeploymentEntity) SetDeploymentTime(deploymentTime time.Time)

func (*DeploymentEntity) SetKey 

func (deploymentEntity *DeploymentEntity) SetKey(key string)

func (*DeploymentEntity) SetName 

func (deploymentEntity *DeploymentEntity) SetName(name string)

func (*DeploymentEntity) SetResources 

func (deploymentEntity *DeploymentEntity) SetResources(resourceEntity ResourceEntity)

func (*DeploymentEntity) SetTenantId 

func (deploymentEntity *DeploymentEntity) SetTenantId(tenantId string)

type DeploymentEntityManager 

type DeploymentEntityManager struct {
}

func GetDeploymentEntityManager 

func GetDeploymentEntityManager() *DeploymentEntityManager

func (DeploymentEntityManager) FindById 

func (deploymentEntityManager DeploymentEntityManager) FindById(deploymentId string) (DeploymentEntity, error)

type Entity 

type Entity interface {
	GetId() string
	SetId(id string)
}

type EntityManager 

type EntityManager interface {
	Insert(interface{}) error

	GetById(id string, data interface{}) interface{}

	Delete(entity Entity)
}

type ExecutionEntity 

type ExecutionEntity struct {
	AbstractEntity
	*VariableScopeImpl
	BusinessKey        string
	CurrentFlowElement delegate.FlowElement
	DeploymentId       string
	ProcessInstanceId  string
	CurrentActivityId  string

	BusinessStatus               string    `json:"businessStatus"`
	Suspended                    bool      `json:"suspended"`
	Ended                        bool      `json:"ended"`
	ProcessDefinitionId          string    `json:"processDefinitionId"`
	ProcessDefinitionName        string    `json:"processDefinitionName"`
	ProcessDefinitionDescription string    `json:"processDefinitionDescription"`
	ActivityId                   string    `json:"activityId"`
	StartUserId                  string    `json:"startUserId"`
	StartTime                    time.Time `json:"StartTime"`
	CallbackId                   string    `json:"callbackId"`
	CallbackType                 string    `json:"callbackType"`
	ReferenceId                  string    `json:"referenceId"`
	ReferenceType                string    `json:"referenceType"`
	TenantId                     *string   `json:"tenantId"`
}

func (ExecutionEntity) GetCurrentActivityId 

func (execution ExecutionEntity) GetCurrentActivityId() string

func (ExecutionEntity) GetCurrentFlowElement 

func (execution ExecutionEntity) GetCurrentFlowElement() delegate.FlowElement

func (ExecutionEntity) GetDeploymentId 

func (execution ExecutionEntity) GetDeploymentId() string

func (*ExecutionEntity) GetExecutionId 

func (execution *ExecutionEntity) GetExecutionId() string

func (ExecutionEntity) GetProcessDefinitionId 

func (execution ExecutionEntity) GetProcessDefinitionId() string

func (ExecutionEntity) GetProcessInstanceId 

func (execution ExecutionEntity) GetProcessInstanceId() string

func (ExecutionEntity) GetProcessVariable 

func (execution ExecutionEntity) GetProcessVariable() map[string]interface{}

func (ExecutionEntity) GetSourceActivityExecution 

func (execution ExecutionEntity) GetSourceActivityExecution() ExecutionEntity

func (ExecutionEntity) GetSpecificVariable 

func (execution ExecutionEntity) GetSpecificVariable(variableName string) (Variable, error)

func (*ExecutionEntity) GetTenantId 

func (execution *ExecutionEntity) GetTenantId() *string

func (ExecutionEntity) GetVariable 

func (execution ExecutionEntity) GetVariable() map[string]interface{}

func (ExecutionEntity) HandleVariable 

func (execution ExecutionEntity) HandleVariable(variables []Variable) map[string]interface{}

func (*ExecutionEntity) SetBusinessKey 

func (execution *ExecutionEntity) SetBusinessKey(businessKey string)

func (*ExecutionEntity) SetCurrentActivityId 

func (execution *ExecutionEntity) SetCurrentActivityId(currentActivityId string)

func (*ExecutionEntity) SetCurrentFlowElement 

func (execution *ExecutionEntity) SetCurrentFlowElement(flow delegate.FlowElement)

func (*ExecutionEntity) SetDeploymentId 

func (execution *ExecutionEntity) SetDeploymentId(deploymentId string)

func (*ExecutionEntity) SetProcessDefinitionId 

func (execution *ExecutionEntity) SetProcessDefinitionId(processDefineId string)

func (*ExecutionEntity) SetProcessInstanceId 

func (execution *ExecutionEntity) SetProcessInstanceId(processInstanceId string)

type ExecutionEntityManager 

type ExecutionEntityManager struct {
}

func GetExecutionEntityManager 

func GetExecutionEntityManager() *ExecutionEntityManager

func (ExecutionEntityManager) CreateExecution 

func (executionEntityManager ExecutionEntityManager) CreateExecution(executionEntity *ExecutionEntity) error

func (ExecutionEntityManager) DeleteExecution 

func (executionEntityManager ExecutionEntityManager) DeleteExecution(executionId string) error

func (ExecutionEntityManager) FindById 

func (executionEntityManager ExecutionEntityManager) FindById(executionId string) (ExecutionEntity, error)

func (ExecutionEntityManager) List 

func (executionEntityManager ExecutionEntityManager) List(listRequest execution.ListRequest) ([]ExecutionEntity, error)

func (ExecutionEntityManager) MigrateExecutionActID 

func (executionEntityManager ExecutionEntityManager) MigrateExecutionActID(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, newActivityId string) error

func (ExecutionEntityManager) MigrateExecutionProcDefID 

func (executionEntityManager ExecutionEntityManager) MigrateExecutionProcDefID(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error

func (ExecutionEntityManager) MigrateProcessInstanceBusinessStatus 

func (executionEntityManager ExecutionEntityManager) MigrateProcessInstanceBusinessStatus(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, newActivityId string) error

func (ExecutionEntityManager) MigrateProcessInstanceProcDefIdAndStartActId 

func (executionEntityManager ExecutionEntityManager) MigrateProcessInstanceProcDefIdAndStartActId(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error

func (ExecutionEntityManager) RecordBusinessStatus 

func (executionEntityManager ExecutionEntityManager) RecordBusinessStatus(delegateExecution delegate.DelegateExecution) error

type HistoricActivityInstanceEntity 

type HistoricActivityInstanceEntity struct {
	AbstractEntity
	ActivityId              string     `json:"activityId"`
	ActivityName            string     `json:"activityName"`
	ActivityType            string     `json:"activityType"`
	ProcessDefinitionId     string     `json:"processDefinitionId"`
	ProcessInstanceId       string     `json:"processInstanceId"`
	ExecutionId             string     `json:"executionId"`
	TaskId                  string     `json:"taskId"`
	CalledProcessInstanceId string     `json:"calledProcessInstanceId"`
	Assignee                string     `json:"assignee"`
	StartTime               time.Time  `json:"startTime"`
	EndTime                 *time.Time `json:"endTime"`
	DurationInMillis        int        `json:"durationInMillis"`
	TenantId                *string    `json:"tenantId"`
	DeleteReason            *string    `json:"deleteReason"`
	BusinessResult          *string    `json:"businessResult"`
	BusinessParameter       *string    `json:"businessParameter"`
}

type HistoricActivityInstanceEntityManager 

type HistoricActivityInstanceEntityManager struct {
	DefaultHistoryManager
}

func GetHistoricActivityInstanceEntityManager 

func GetHistoricActivityInstanceEntityManager() *HistoricActivityInstanceEntityManager

func (HistoricActivityInstanceEntityManager) DeleteByExecutionId 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) DeleteByExecutionId(entity delegate.DelegateExecution) error

func (HistoricActivityInstanceEntityManager) DeleteByProcessInstanceId 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) DeleteByProcessInstanceId(processInstanceId, actId string) error

func (HistoricActivityInstanceEntityManager) List 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) List(listRequest historicactinst.ListRequest) ([]HistoricActivityInstanceEntity, error)

func (HistoricActivityInstanceEntityManager) MigrateAct 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) MigrateAct(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, newActivityId string, newName string, newType string) error

func (HistoricActivityInstanceEntityManager) MigrateProcDefID 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) MigrateProcDefID(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error

func (HistoricActivityInstanceEntityManager) RecordActEndByExecutionId 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActEndByExecutionId(element delegate.FlowElement, entity delegate.DelegateExecution, deleteReason *string) error

func (HistoricActivityInstanceEntityManager) RecordActEndByExecutionIdAndActId 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActEndByExecutionIdAndActId(executionId, activityId string, deleteReason *string) error

func (HistoricActivityInstanceEntityManager) RecordActEndByProcessInstanceId 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActEndByProcessInstanceId(processInstanceId string, deleteReason *string) error

func (HistoricActivityInstanceEntityManager) RecordActivityStart 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordActivityStart(entity delegate.DelegateExecution) error

func (HistoricActivityInstanceEntityManager) RecordBusinessDataByExecutionId added in v0.0.3 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordBusinessDataByExecutionId(entity delegate.DelegateExecution, businessParameter, businessResult string) error

func (HistoricActivityInstanceEntityManager) RecordSequenceFlow 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordSequenceFlow(entity delegate.DelegateExecution) error

func (HistoricActivityInstanceEntityManager) RecordTaskId 

func (historicActivityInstanceEntityManager HistoricActivityInstanceEntityManager) RecordTaskId(task model.ActRuTask) error

type HistoricIdentityLinkEntity 

type HistoricIdentityLinkEntity struct {
	AbstractEntity
	GroupID    *string
	Type       *string
	UserID     *string
	TaskID     *string
	ProcInstID *string
}

type HistoricIdentityLinkEntityManager 

type HistoricIdentityLinkEntityManager struct {
}

func GetHistoricIdentityLinkEntityManager 

func GetHistoricIdentityLinkEntityManager() *HistoricIdentityLinkEntityManager

func (HistoricIdentityLinkEntityManager) SelectByProcessInstanceId 

func (historicIdentityLinkEntityManager HistoricIdentityLinkEntityManager) SelectByProcessInstanceId(processInstanceId string) ([]*HistoricIdentityLinkEntity, error)

type HistoricProcessInstanceEntity 

type HistoricProcessInstanceEntity struct {
	AbstractEntity
	BusinessKey            string              `json:"businessKey"`
	BusinessStatus         string              `json:"businessStatus"`
	ProcessDefinitionId    string              `json:"processDefinitionId"`
	ProcessDefinitionUrl   string              `json:"processDefinitionUrl"`
	StartTime              *time.Time          `json:"StartTime"`
	EndTime                *time.Time          `json:"endTime"`
	DurationInMillis       int                 `json:"durationInMillis"`
	StartUserId            string              `json:"startUserId"`
	StartActivityId        string              `json:"startActivityId"`
	EndActivityId          string              `json:"endActivityId"`
	DeleteReason           string              `json:"deleteReason"`
	SuperProcessInstanceId string              `json:"superProcessInstanceId"`
	Url                    string              `json:"url"`
	Variables              []variable.Variable `json:"variable"`
	TenantId               string              `json:"tenantId"`
	ProcessDefinitionName  string              `json:"processDefinitionName"`
}

func (HistoricProcessInstanceEntity) GetProcessDefinitionId 

func (historicProcessInstanceEntity HistoricProcessInstanceEntity) GetProcessDefinitionId() string

func (*HistoricProcessInstanceEntity) SetProcessDefinitionId 

func (historicProcessInstanceEntity *HistoricProcessInstanceEntity) SetProcessDefinitionId(processDefinitionId string)

type HistoricProcessInstanceEntityManager 

type HistoricProcessInstanceEntityManager struct {
}

func GetHistoricProcessInstanceEntityManager 

func GetHistoricProcessInstanceEntityManager() *HistoricProcessInstanceEntityManager

func (HistoricProcessInstanceEntityManager) FindById 

func (historicProcessInstanceEntityManager HistoricProcessInstanceEntityManager) FindById(historicProcessInstanceId string) (HistoricProcessInstanceEntity, error)

func (HistoricProcessInstanceEntityManager) List 

func (historicProcessInstanceEntityManager HistoricProcessInstanceEntityManager) List(listRequest historicprocess.ListRequest) ([]HistoricProcessInstanceEntity, error)

type HistoricTaskInstanceEntity 

type HistoricTaskInstanceEntity struct {
	AbstractEntity
	ProcessDefinitionId  string              `json:"processDefinitionId"`
	ProcessDefinitionUrl string              `json:"processDefinitionUrl"`
	ProcessInstanceId    string              `json:"processInstanceId"`
	ProcessInstanceUrl   string              `json:"processInstanceUrl"`
	ExecutionId          string              `json:"executionId"`
	Name                 string              `json:"name"`
	Description          string              `json:"description"`
	DeleteReason         string              `json:"deleteReason"`
	Owner                string              `json:"owner"`
	Assignee             string              `json:"Assignee"`
	StartTime            time.Time           `json:"StartTime"`
	EndTime              *time.Time          `json:"endTime"`
	DurationInMillis     int                 `json:"durationInMillis"`
	WorkTimeInMillis     int                 `json:"workTimeInMillis"`
	ClaimTime            *time.Time          `json:"claimTime"`
	TaskDefinitionKey    string              `json:"taskDefinitionKey"`
	FormKey              string              `json:"formKey"`
	Priority             int                 `json:"priority"`
	DueDate              *time.Time          `json:"dueDate"`
	ParentTaskId         string              `json:"parentTaskId"`
	Url                  string              `json:"url"`
	Variables            []variable.Variable `json:"variables"`
	TenantId             string              `json:"tenantId"`
	Category             string              `json:"category"`
}

func (HistoricTaskInstanceEntity) SetAssignee 

func (historicTaskInstanceEntity HistoricTaskInstanceEntity) SetAssignee(assignee string)

type HistoricTaskInstanceEntityManager 

type HistoricTaskInstanceEntityManager struct {
	DefaultHistoryManager
}

func GetHistoricTaskInstanceEntityManager 

func GetHistoricTaskInstanceEntityManager() *HistoricTaskInstanceEntityManager

func (HistoricTaskInstanceEntityManager) List 

func (historicTaskInstanceEntityManager HistoricTaskInstanceEntityManager) List(listRequest historictask.ListRequest) ([]HistoricTaskInstanceEntity, error)

func (HistoricTaskInstanceEntityManager) RecordTaskEnd 

func (historicTaskInstanceEntityManager HistoricTaskInstanceEntityManager) RecordTaskEnd(taskId string, deleteReason *string) error

type IdentityLinkEntity 

type IdentityLinkEntity struct {
	AbstractEntity
	Rev        *int32
	GroupID    *string
	Type       *string
	UserID     *string
	TaskID     *string
	ProcInstID *string
	ProcDefID  *string
}

type IdentityLinkEntityManager 

type IdentityLinkEntityManager struct {
}

func GetIdentityLinkManager 

func GetIdentityLinkManager() *IdentityLinkEntityManager
func (identityLinkEntityManager IdentityLinkEntityManager) CreateIdentityLink(identityLink model.ActRuIdentitylink) (err error)

func (IdentityLinkEntityManager) DeleteByProcessInstanceId 

func (identityLinkEntityManager IdentityLinkEntityManager) DeleteByProcessInstanceId(processInstanceId string) error

func (IdentityLinkEntityManager) DeleteIdentityLinksByTaskId 

func (identityLinkEntityManager IdentityLinkEntityManager) DeleteIdentityLinksByTaskId(taskId string) error

func (IdentityLinkEntityManager) SelectByProcessInstanceId 

func (identityLinkEntityManager IdentityLinkEntityManager) SelectByProcessInstanceId(processInstanceId string) ([]*IdentityLinkEntity, error)

type ProcessDefinitionEntity 

type ProcessDefinitionEntity struct {
	AbstractEntity
	Name            string
	Description     string
	Key             string
	Version         int
	Category        string
	DeploymentId    string
	ResourceName    string
	ResourceContent []byte
}

func (*ProcessDefinitionEntity) GetDeploymentId 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetDeploymentId() string

func (*ProcessDefinitionEntity) GetDescription 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetDescription() string

func (*ProcessDefinitionEntity) GetKey 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetKey() string

func (*ProcessDefinitionEntity) GetName 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetName() string

func (*ProcessDefinitionEntity) GetResourceName 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetResourceName() string

func (*ProcessDefinitionEntity) GetVersion 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) GetVersion() int

func (*ProcessDefinitionEntity) SetCategory 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetCategory(category string)

func (*ProcessDefinitionEntity) SetDeploymentId 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetDeploymentId(deploymentId string)

func (*ProcessDefinitionEntity) SetDescription 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetDescription(description string)

func (*ProcessDefinitionEntity) SetKey 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetKey(key string)

func (*ProcessDefinitionEntity) SetName 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetName(name string)

func (*ProcessDefinitionEntity) SetResourceName 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetResourceName(resourceName string)

func (*ProcessDefinitionEntity) SetVersion 

func (processDefinitionEntityImpl *ProcessDefinitionEntity) SetVersion(version int)

type ProcessDefinitionEntityManager 

type ProcessDefinitionEntityManager struct {
}

func GetProcessDefinitionEntityManager 

func GetProcessDefinitionEntityManager() *ProcessDefinitionEntityManager

func (ProcessDefinitionEntityManager) FindByDeploymentId 

func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindByDeploymentId(deploymentId string) (ProcessDefinitionEntity, error)

func (ProcessDefinitionEntityManager) FindLatestProcessDefinitionByKey 

func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindLatestProcessDefinitionByKey(processDefinitionKey string) (ProcessDefinitionEntity, error)

func (ProcessDefinitionEntityManager) FindProcessDefinitionById 

func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindProcessDefinitionById(processDefinitionId string) (ProcessDefinitionEntity, error)

func (ProcessDefinitionEntityManager) FindResourceEntityByProcessDefinitionById 

func (processDefinitionEntityManager ProcessDefinitionEntityManager) FindResourceEntityByProcessDefinitionById(processDefinitionId string) (ResourceEntity, error)

func (ProcessDefinitionEntityManager) Insert 

func (processDefinitionEntityManager ProcessDefinitionEntityManager) Insert(processDefinition *model.ActReProcdef) (ProcessDefinitionEntity, error)

type ResourceEntity 

type ResourceEntity struct {
	Name         string
	Bytes        []byte
	DeploymentId string
}

func (ResourceEntity) GetBytes 

func (resourceEntity ResourceEntity) GetBytes() []byte

func (*ResourceEntity) GetDeploymentId 

func (resourceEntity *ResourceEntity) GetDeploymentId() string

func (*ResourceEntity) GetName 

func (resourceEntity *ResourceEntity) GetName() string

func (*ResourceEntity) SetBytes 

func (resourceEntity *ResourceEntity) SetBytes(bytes []byte)

func (*ResourceEntity) SetDeploymentId 

func (resourceEntity *ResourceEntity) SetDeploymentId(deploymentId string)

func (*ResourceEntity) SetName 

func (resourceEntity *ResourceEntity) SetName(name string)

type ResourceEntityManager 

type ResourceEntityManager struct {
}

func GetResourceEntityManager 

func GetResourceEntityManager() *ResourceEntityManager

func (ResourceEntityManager) FindResourceByDeploymentIdAndResourceName 

func (resourceEntityManager ResourceEntityManager) FindResourceByDeploymentIdAndResourceName(deploymentId, resourceName string) (ResourceEntity, error)

type TaskEntity 

type TaskEntity struct {
	AbstractEntity
	ExecutionEntity
	VariableScopeImpl
	Assignee       *string
	StartTime      time.Time
	TaskDefineName string
	ClaimTime      *time.Time
	Variables      map[string]interface{}

	Url                       string     `json:"url"`
	Owner                     string     `json:"owner"`
	DelegationState           string     `json:"delegationState"`
	Description               string     `json:"description"`
	DueDate                   *time.Time `json:"dueDate"`
	Priority                  int        `json:"priority"`
	Suspended                 bool       `json:"suspended"`
	TaskDefinitionKey         string     `json:"taskDefinitionKey"`
	ScopeDefinitionId         string     `json:"scopeDefinitionId"`
	ScopeId                   string     `json:"scopeId"`
	SubScopeId                string     `json:"subScopeId"`
	ScopeType                 string     `json:"scopeType"`
	PropagatedStageInstanceId string     `json:"propagatedStageInstanceId"`
	TenantId                  *string    `json:"tenantId"`
	Category                  string     `json:"category"`
	FormKey                   *string    `json:"formKey"`
	ParentTaskId              string     `json:"parentTaskId"`
	ParentTaskUrl             string     `json:"parentTaskUrl"`
	ExecutionId               string     `json:"executionId"`
	ExecutionUrl              string     `json:"executionUrl"`
	ProcessInstanceId         string     `json:"processInstanceId"`
	ProcessInstanceUrl        string     `json:"processInstanceUrl"`
	ProcessDefinitionId       string     `json:"processDefinitionId"`
	ProcessDefinitionUrl      string     `json:"processDefinitionUrl"`
}

func NewTaskEntity 

func NewTaskEntity(execution delegate.DelegateExecution, userTask bpmn_model.UserTask) TaskEntity

func (*TaskEntity) GetAssignee 

func (taskEntiy *TaskEntity) GetAssignee() *string

func (*TaskEntity) GetClaimTime 

func (taskEntiy *TaskEntity) GetClaimTime() *time.Time

func (*TaskEntity) GetExecutionId 

func (taskEntiy *TaskEntity) GetExecutionId() string

func (TaskEntity) GetSpecificVariable 

func (taskEntiy TaskEntity) GetSpecificVariable(variableName string) (variable.Variable, error)

func (*TaskEntity) GetTaskDefineKey 

func (taskEntiy *TaskEntity) GetTaskDefineKey() string

func (TaskEntity) GetVariable 

func (taskEntiy TaskEntity) GetVariable() map[string]interface{}

func (*TaskEntity) SetAssignee 

func (taskEntiy *TaskEntity) SetAssignee(assignee *string)

func (*TaskEntity) SetClaimTime 

func (taskEntiy *TaskEntity) SetClaimTime(claimTime *time.Time)

func (*TaskEntity) SetExecutionId 

func (taskEntiy *TaskEntity) SetExecutionId(executionId string)

func (*TaskEntity) SetStartTime 

func (taskEntiy *TaskEntity) SetStartTime(startTime time.Time)

func (*TaskEntity) SetTaskDefineKey 

func (taskEntiy *TaskEntity) SetTaskDefineKey(taskDefineKey string)

func (*TaskEntity) SetTaskDefineName 

func (taskEntiy *TaskEntity) SetTaskDefineName(taskDefineName string)

type TaskEntityManager 

type TaskEntityManager struct {
}

func GetTaskEntityManager 

func GetTaskEntityManager() *TaskEntityManager

func (TaskEntityManager) ChangeTaskAssignee 

func (taskEntityManager TaskEntityManager) ChangeTaskAssignee(taskEntity TaskEntity, userId *string) error

func (TaskEntityManager) DeleteTask 

func (taskEntityManager TaskEntityManager) DeleteTask(task TaskEntity, deleteReason *string) error

func (TaskEntityManager) FindById 

func (taskEntityManager TaskEntityManager) FindById(id string) (TaskEntity, error)

func (TaskEntityManager) FindByProcessInstanceId 

func (taskEntityManager TaskEntityManager) FindByProcessInstanceId(processInstanceId string) ([]TaskEntity, error)

func (TaskEntityManager) InsertTask 

func (taskEntityManager TaskEntityManager) InsertTask(taskEntity *TaskEntity) error

func (TaskEntityManager) List 

func (taskEntityManager TaskEntityManager) List(listRequest task.ListRequest) ([]TaskEntity, error)

func (TaskEntityManager) MigrateNameAndTaskDefKey 

func (taskEntityManager TaskEntityManager) MigrateNameAndTaskDefKey(processDefinitionEntity ProcessDefinitionEntity, oldActivityId string, newActivityId string, newName string) error

func (TaskEntityManager) MigrateProcDefID 

func (taskEntityManager TaskEntityManager) MigrateProcDefID(oldProcessDefinitionEntity, newProcessDefinitionEntity ProcessDefinitionEntity) error

type VariableEntity 

type VariableEntity struct {
	AbstractEntity
	Type   string
	Delete bool
}

func (VariableEntity) GetType 

func (variableEntity VariableEntity) GetType() string

func (VariableEntity) SetDeleted 

func (variableEntity VariableEntity) SetDeleted(b bool)

type VariableEntityManager 

type VariableEntityManager struct {
}

func GetVariableEntityManager 

func GetVariableEntityManager() *VariableEntityManager

func (VariableEntityManager) DeleteByProcessInstanceId 

func (variableEntityManager VariableEntityManager) DeleteByProcessInstanceId(processInstanceId string) error

func (VariableEntityManager) DeleteVariableInstanceByTask 

func (variableEntityManager VariableEntityManager) DeleteVariableInstanceByTask(taskId string)

func (VariableEntityManager) UpsertHistoricVariable 

func (variableEntityManager VariableEntityManager) UpsertHistoricVariable(v variable.Variable) (err error)

func (VariableEntityManager) UpsertVariable 

func (variableEntityManager VariableEntityManager) UpsertVariable(v variable.Variable) error

type VariableScopeImpl 

type VariableScopeImpl struct {
	AbstractVariableScopeImpl
	ExecutionEntity ExecutionEntity
}

func (VariableScopeImpl) GetVariableLocal 

func (variableScope VariableScopeImpl) GetVariableLocal() (variables map[string]interface{})

func (VariableScopeImpl) SetVariable 

func (variableScope VariableScopeImpl) SetVariable(execution delegate.DelegateExecution, variables map[string]interface{}) error

SetVariable 保存流程变量

func (VariableScopeImpl) SetVariableLocal 

func (variableScope VariableScopeImpl) SetVariableLocal(variables map[string]interface{}) error

Source Files

View all Source files

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.