easyflow

Documentation

Index

• Constants
• type FeishuNotify
  • func NewFeishuNotify(lark *lark.Client) (*FeishuNotify, error)
• type NotificationService
• type NotifierIntegration
• type Notify
  • func NewNotify(engineSvc engineSvc.Service, templateSvc templateSvc.Service, ...) (*Notify, error)
  • func (n *Notify) Send(ctx context.Context, instanceId int, userIDs []string) (bool, error)
• type NotifyIntegration
  • func BuildReceiverIntegrations(larkC *lark.Client) ([]NotifyIntegration, error)
  • func NewNotifyIntegration(n NotifierIntegration, name string) NotifyIntegration
• 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
• type Rule
• type Rules

Constants

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

Types

type FeishuNotify

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

func NewFeishuNotify

func NewFeishuNotify(lark *lark.Client) (*FeishuNotify, error)

type NotificationService

type NotificationService interface {
	Send(ctx context.Context, instanceId int, userIDs []string) (bool, error)
}

type NotifierIntegration

type NotifierIntegration interface {
	// contains filtered or unexported methods
}

type Notify

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

func NewNotify

func NewNotify(engineSvc engineSvc.Service, templateSvc templateSvc.Service, orderSvc order.Service,
	userSvc user.Service, workflowSvc workflow.Service, integrations []NotifyIntegration) (*Notify, error)

func (*Notify) Send

func (n *Notify) Send(ctx context.Context, instanceId int, userIDs []string) (bool, error)

type NotifyIntegration

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

func BuildReceiverIntegrations

func BuildReceiverIntegrations(larkC *lark.Client) ([]NotifyIntegration, error)

BuildReceiverIntegrations 整合消息通知渠道

func NewNotifyIntegration

func NewNotifyIntegration(n NotifierIntegration, name string) NotifyIntegration

type ProcessEvent

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

func NewProcessEvent

func NewProcessEvent(producer producer.OrderStatusModifyEventProducer, engineSvc engineSvc.Service,
	taskSvc task.Service, notify NotificationService, orderSvc order.Service) (*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 通知

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

type Rule

type Rule struct {
	Type  string `json:"type"`
	Field string `json:"field"`
	Title string `json:"title"`
}

type Rules

type Rules []Rule