node

package

v1.8.0 Latest Latest Go to latest Published: Mar 19, 2025 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Duke1616/ecmdb

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type AutomationNotification
- func NewAutomationNotification(taskSvc task.Service, userSvc user.Service, ...) (*AutomationNotification, error)
- func (n *AutomationNotification) Send(ctx context.Context, nOrder order.Order, wf workflow.Workflow, instanceId int, ...) (bool, error)
type StartNotification
- func NewStartNotification(userSvc user.Service, templateSvc template.Service, ...) (*StartNotification, error)
- func (s *StartNotification) Send(ctx context.Context, nOrder order.Order, wf workflow.Workflow, instanceId int, ...) (bool, error)
type UserNotification
- func NewUserNotification(engineSvc engineSvc.Service, templateSvc templateSvc.Service, ...) (*UserNotification, error)
- func (n *UserNotification) Send(ctx context.Context, nOrder order.Order, wf workflow.Workflow, instanceId int, ...) (bool, error)
- func (n *UserNotification) Unmarshal(wf workflow.Workflow) ([]easyflow.Node, error)

Constants ¶

View Source

const (
	// ProcessEndSend 流程结束后发送
	ProcessEndSend = 1
	// ProcessNowSend 当前节点通过直接发送
	ProcessNowSend = 2
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AutomationNotification ¶

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

func NewAutomationNotification ¶

func NewAutomationNotification(taskSvc task.Service, userSvc user.Service, integrations []method.NotifyIntegration) (*AutomationNotification, error)

func (*AutomationNotification) Send ¶

func (n *AutomationNotification) Send(ctx context.Context, nOrder order.Order, wf workflow.Workflow,
	instanceId int, currentNode *model.Node) (bool, error)

type StartNotification ¶ added in v1.8.0

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

func NewStartNotification ¶ added in v1.8.0

func NewStartNotification(userSvc user.Service, templateSvc template.Service, integrations []method.NotifyIntegration) (*StartNotification, error)

func (*StartNotification) Send ¶ added in v1.8.0

func (s *StartNotification) Send(ctx context.Context, nOrder order.Order, wf workflow.Workflow,
	instanceId int, currentNode *model.Node) (bool, error)

type UserNotification ¶

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

func NewUserNotification ¶

func NewUserNotification(engineSvc engineSvc.Service, templateSvc templateSvc.Service, orderSvc order.Service,
	userSvc user.Service, taskSvc task.Service, departMentSvc department.Service,
	integrations []method.NotifyIntegration) (*UserNotification, error)

func (*UserNotification) Send ¶

func (n *UserNotification) Send(ctx context.Context, nOrder order.Order, wf workflow.Workflow,
	instanceId int, currentNode *model.Node) (bool, error)

func (*UserNotification) Unmarshal ¶ added in v1.8.0

func (n *UserNotification) Unmarshal(wf workflow.Workflow) ([]easyflow.Node, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL