bll

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2023 License: GPL-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Flow 

type Flow struct {
	sync.RWMutex
	FlowModel *model.Flow `inject:""`
}

Flow 流程管理

func (*Flow) CheckFlowInstanceTodo 

func (a *Flow) CheckFlowInstanceTodo(flowInstanceID string) (bool, error)

CheckFlowInstanceTodo 检查流程实例待办事项

func (*Flow) CheckNodeCandidate 

func (a *Flow) CheckNodeCandidate(nodeInstanceID, userID string) (bool, error)

CheckNodeCandidate 检查节点候选人

func (*Flow) CreateFlow 

func (a *Flow) CreateFlow(flow *schema.Flow, nodes *schema.NodeOperating, forms *schema.FormOperating) error

CreateFlow 创建流程数据

func (*Flow) CreateNodeInstance 

func (a *Flow) CreateNodeInstance(flowInstanceID, nodeID string, inputData []byte, candidates []string) (string, error)

CreateNodeInstance 创建节点实例

func (*Flow) CreateNodeTiming 

func (a *Flow) CreateNodeTiming(item *schema.NodeTiming) error

CreateNodeTiming 创建定时节点

func (*Flow) DeleteFlow 

func (a *Flow) DeleteFlow(flowID string) error

DeleteFlow 删除流程

func (*Flow) DeleteNodeTiming 

func (a *Flow) DeleteNodeTiming(nodeInstanceID string) error

DeleteNodeTiming 删除定时节点

func (*Flow) DoneFlowInstance 

func (a *Flow) DoneFlowInstance(flowInstanceID string) error

DoneFlowInstance 完成流程实例

func (*Flow) DoneNodeInstance 

func (a *Flow) DoneNodeInstance(nodeInstanceID, processor string, outData []byte) error

DoneNodeInstance 完成节点实例

func (*Flow) GetDoneByID 

func (a *Flow) GetDoneByID(nodeInstanceID string) (*schema.FlowDoneResult, error)

GetDoneByID 根据ID获取已办

func (*Flow) GetDoneCount 

func (a *Flow) GetDoneCount(userID string) (int64, error)

GetDoneCount 获取已办数量

func (*Flow) GetFlow 

func (a *Flow) GetFlow(recordID string) (*schema.Flow, error)

GetFlow 获取流程数据

func (*Flow) GetFlowByCode 

func (a *Flow) GetFlowByCode(code string) (*schema.Flow, error)

GetFlowByCode 根据编号查询流程数据

func (*Flow) GetFlowFormByNodeID 

func (a *Flow) GetFlowFormByNodeID(nodeID string) (*schema.Form, error)

GetFlowFormByNodeID 获取流程节点表单

func (*Flow) GetFlowInstance 

func (a *Flow) GetFlowInstance(recordID string) (*schema.FlowInstance, error)

GetFlowInstance 获取流程实例

func (*Flow) GetFlowInstanceByNode 

func (a *Flow) GetFlowInstanceByNode(nodeInstanceID string) (*schema.FlowInstance, error)

GetFlowInstanceByNode 根据节点实例获取流程实例

func (*Flow) GetForm 

func (a *Flow) GetForm(formID string) (*schema.Form, error)

GetForm 获取流程表单

func (*Flow) GetNode 

func (a *Flow) GetNode(recordID string) (*schema.Node, error)

GetNode 获取流程节点

func (*Flow) GetNodeByFlowAndTypeCode 

func (a *Flow) GetNodeByFlowAndTypeCode(flowID, typeCode string) (*schema.Node, error)

GetNodeByFlowAndTypeCode 根据流程ID和节点类型获取节点数据

func (*Flow) GetNodeInstance 

func (a *Flow) GetNodeInstance(recordID string) (*schema.NodeInstance, error)

GetNodeInstance 获取流程节点实例

func (*Flow) GetNodeProperty 

func (a *Flow) GetNodeProperty(nodeID string) (map[string]string, error)

GetNodeProperty 获取节点属性

func (*Flow) GetTodoByID 

func (a *Flow) GetTodoByID(nodeInstanceID string) (*schema.FlowTodoResult, error)

GetTodoByID 根据ID获取待办

func (*Flow) LaunchFlowInstance 

func (a *Flow) LaunchFlowInstance(flowCode, nodeCode, launcher string, inputData []byte) (*schema.NodeInstance, error)

LaunchFlowInstance 发起流程实例

func (*Flow) LaunchFlowInstance2 

func (a *Flow) LaunchFlowInstance2(flowID, userID string, status int, inputData []byte) (*schema.FlowInstance, *schema.NodeInstance, error)

LaunchFlowInstance2 发起流程实例（基于流程ID），返回流程实例、开始事件节点实例

func (*Flow) QueryAllFlowPage 

func (a *Flow) QueryAllFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error)

QueryAllFlowPage 查询流程分页数据

func (*Flow) QueryDone 

func (a *Flow) QueryDone(typeCode, flowCode, userID string, lastTime int64, count int) ([]*schema.FlowDoneResult, error)

QueryDone 查询用户的已办数据

func (*Flow) QueryDoneIDs 

func (a *Flow) QueryDoneIDs(flowCode, userID string) ([]string, error)

QueryDoneIDs 查询已办理的流程实例ID列表

func (*Flow) QueryExpiredNodeTiming 

func (a *Flow) QueryExpiredNodeTiming() ([]*schema.NodeTiming, error)

QueryExpiredNodeTiming 查询到期的定时节点

func (*Flow) QueryFlowByCode 

func (a *Flow) QueryFlowByCode(flowCode string) ([]*schema.Flow, error)

QueryFlowByCode 根据流程编号查询流程数据

func (*Flow) QueryFlowByIDs 

func (a *Flow) QueryFlowByIDs(flowIDs []string) ([]*schema.FlowQueryResult, error)

QueryFlowByIDs 根据流程ID查询流程数据

func (*Flow) QueryFlowIDsByType 

func (a *Flow) QueryFlowIDsByType(typeCodes ...string) ([]string, error)

QueryFlowIDsByType 根据类型查询流程ID列表

func (*Flow) QueryFlowVersion 

func (a *Flow) QueryFlowVersion(recordID string) ([]*schema.FlowQueryResult, error)

QueryFlowVersion 查询流程版本数据

func (*Flow) QueryGroupFlowPage 

func (a *Flow) QueryGroupFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error)

QueryGroupFlowPage 查询流程分组分页数据

func (*Flow) QueryHandleFlowInstanceResult 

func (a *Flow) QueryHandleFlowInstanceResult(processor, typeCode, flowCode string, lastID int64, count int) ([]*schema.FlowInstanceResult, error)

QueryHandleFlowInstanceResult 查询处理的流程实例结果

func (*Flow) QueryHistory 

func (a *Flow) QueryHistory(flowInstanceID string) ([]*schema.FlowHistoryResult, error)

QueryHistory 查询流程实例历史数据

func (*Flow) QueryLastNodeInstance 

func (a *Flow) QueryLastNodeInstance(flowInstanceID string) (*schema.NodeInstance, error)

QueryLastNodeInstance 查询节点实例

func (*Flow) QueryLastNodeInstances 

func (a *Flow) QueryLastNodeInstances(flowInstanceIDs []string) (map[string]*schema.NodeInstance, error)

QueryLastNodeInstances 查询流程实例的最后一个节点实例

func (*Flow) QueryLaunchFlowInstanceResult 

func (a *Flow) QueryLaunchFlowInstanceResult(launcher, typeCode, flowCode string, lastID int64, count int) ([]*schema.FlowInstanceResult, error)

QueryLaunchFlowInstanceResult 查询发起的流程实例数据

func (*Flow) QueryNodeAssignments 

func (a *Flow) QueryNodeAssignments(nodeID string) ([]*schema.NodeAssignment, error)

QueryNodeAssignments 查询节点指派

func (*Flow) QueryNodeByTypeCodeAndFlowIDs 

func (a *Flow) QueryNodeByTypeCodeAndFlowIDs(typeCode string, flowIDs ...string) ([]*schema.Node, error)

QueryNodeByTypeCodeAndFlowIDs 根据节点类型和流程ID列表查询节点数据

func (*Flow) QueryNodeCandidates 

func (a *Flow) QueryNodeCandidates(nodeInstanceID string) ([]*schema.NodeCandidate, error)

QueryNodeCandidates 查询节点候选人

func (*Flow) QueryNodeRouters 

func (a *Flow) QueryNodeRouters(sourceNodeID string) ([]*schema.NodeRouter, error)

QueryNodeRouters 查询节点路由

func (*Flow) QueryTodo 

func (a *Flow) QueryTodo(typeCode, flowCode, userID string, count int) ([]*schema.FlowTodoResult, error)

QueryTodo 查询用户的待办节点实例数据

func (*Flow) QueryTodoFlowInstanceResult 

func (a *Flow) QueryTodoFlowInstanceResult(userID, typeCode, flowCode string, lastID int64, count int) ([]*schema.FlowInstanceResult, error)

QueryTodoFlowInstanceResult 查询待办的流程实例数据

func (*Flow) QueryTodoPaginate 

func (a *Flow) QueryTodoPaginate(typeCode string, flowCode string, userID string, page int, pageSize int) (int, []*schema.FlowTodoResult, error)

QueryTodoPaginate 分页查询用户待办节点实例数据

func (*Flow) StopFlowInstance 

func (a *Flow) StopFlowInstance(flowInstanceID string) error

StopFlowInstance 停止流程实例

func (*Flow) UpdateFlowInfo 

func (a *Flow) UpdateFlowInfo(recordID string, info map[string]interface{}) error

UpdateFlowInfo 更新流程

func (*Flow) UpdateFlowStatus 

func (a *Flow) UpdateFlowStatus(recordID string, status int) error

UpdateFlowStatus 更新流程状态

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.