Documentation
¶
Index ¶
- Constants
- type 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
Constants ¶
View Source
const ( SystemPass = 3 SystemReject = 4 UserRevoke = 5 SystemPassComment = "其余节点审批通过，系统判定无法继续审批" SystemRejectComment = "其余节点进行驳回，系统判定无法继续审批" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProcessEvent ¶
type ProcessEvent struct {
// contains filtered or unexported fields
}
ProcessEvent easy-workflow 流程引擎事件处理
func NewProcessEvent ¶
func NewProcessEvent(producer producer.OrderStatusModifyEventProducer, engineSvc engineSvc.Service, taskSvc task.Service, orderSvc order.Service, workflowSvc workflow.Service, strategy strategy.SendStrategy) (*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) 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 用户任务并行处理事件 当处于并行 或 包容网关的时候，其中一个节点驳回，其余并行节点并不会修改状态
Source Files
Click to show internal directories.
Click to hide internal directories.