easyflow

Documentation

Index

• Variables
• type ProcessEvent
  • func NewProcessEvent(producer producer.OrderStatusModifyEventProducer, engineSvc engineSvc.Service, ...) *ProcessEvent
  • func (e *ProcessEvent) EventAutomation(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error
  • func (e *ProcessEvent) EventClose(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error
  • func (e *ProcessEvent) EventEnd(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error
  • func (e *ProcessEvent) EventNotify(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error
  • func (e *ProcessEvent) EventRevoke(ProcessInstanceID int, RevokeUserID string) error
  • func (e *ProcessEvent) EventStart(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error
  • func (e *ProcessEvent) EventTaskInclusionNodePass(TaskID int, CurrentNode *model.Node, PrevNode model.Node) error
  • func (e *ProcessEvent) EventTaskParallelNodePass(TaskID int, CurrentNode *model.Node, PrevNode model.Node) error

Variables

var RoleUser = make(map[string][]string)

RoleUser 这里创建了一个角色-用户的人员库，用来模拟数据库中存储的角色-用户对应关系

Types

type ProcessEvent

type ProcessEvent struct {
	// contains filtered or unexported fields
}

func NewProcessEvent

func NewProcessEvent(producer producer.OrderStatusModifyEventProducer, engineSvc engineSvc.Service,
	taskSvc task.Service) *ProcessEvent

func (*ProcessEvent) EventAutomation

func (e *ProcessEvent) EventAutomation(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error

EventAutomation 自动化任务处理（创建任务）

func (*ProcessEvent) EventClose

func (e *ProcessEvent) EventClose(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error

EventClose 流程结束，修改 Order 状态为已完成

func (*ProcessEvent) EventEnd

func (e *ProcessEvent) EventEnd(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error

EventEnd 节点结束事件

func (*ProcessEvent) EventNotify

func (e *ProcessEvent) EventNotify(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error

EventNotify 通知

func (*ProcessEvent) EventRevoke

func (e *ProcessEvent) EventRevoke(ProcessInstanceID int, RevokeUserID string) error

EventRevoke 流程撤销

func (*ProcessEvent) EventStart

func (e *ProcessEvent) EventStart(ProcessInstanceID int, CurrentNode *model.Node, PrevNode model.Node) error

EventStart 节点结束事件

func (*ProcessEvent) EventTaskInclusionNodePass

func (e *ProcessEvent) EventTaskInclusionNodePass(TaskID int, CurrentNode *model.Node, PrevNode model.Node) error

EventTaskInclusionNodePass 用户任务并行包容处理事件 当处于并行 或 包容网关的时候，其中一个节点驳回，其余并行节点并不会修改状态

func (*ProcessEvent) EventTaskParallelNodePass

func (e *ProcessEvent) EventTaskParallelNodePass(TaskID int, CurrentNode *model.Node, PrevNode model.Node) error

EventTaskParallelNodePass 用户任务并行处理事件 当处于并行 或 包容网关的时候，其中一个节点驳回，其余并行节点并不会修改状态