easyflow

Documentation

Index

• Constants
• type ProcessEvent
  • func NewProcessEvent(producer producer.OrderStatusModifyEventProducer, engineSvc engineSvc.Service, ...) (*ProcessEvent, error)
  • 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) EventNotifyV1(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

Constants

const (
	SystemPass          = 3
	SystemReject        = 4
	UserRevoke          = 5
	SystemPassComment   = "其余节点审批通过，系统判定无法继续审批"
	SystemRejectComment = "其余节点进行驳回，系统判定无法继续审批"
)

Types

type ProcessEvent

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

func NewProcessEvent

func NewProcessEvent(producer producer.OrderStatusModifyEventProducer, engineSvc engineSvc.Service,
	taskSvc task.Service, orderSvc order.Service, workflowSvc workflow.Service,
	notification map[string]notification.Notification) (*ProcessEvent, error)

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 状态为已完成 Deprecated 废弃 不再通过 Kafka 修改状态，使用 EventNotify 直接调用接口进行修改

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 通知 中间有 Error 通过日志记录，保证不影响主体程序运行

func (*ProcessEvent) EventNotifyV1

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

EventNotifyV1 通知

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