event

Documentation

Index

• Constants
• type WechatApprovalCallbackConsumer
  • func NewWechatApprovalCallbackConsumer(svc service.Service, q mq.MQ, p WechatOrderEventProducer, ...) (*WechatApprovalCallbackConsumer, error)
  • func (c *WechatApprovalCallbackConsumer) Consume(ctx context.Context) error
  • func (c *WechatApprovalCallbackConsumer) Start(ctx context.Context)
  • func (c *WechatApprovalCallbackConsumer) Stop(_ context.Context) error
• type WechatOrderEventProducer
  • func NewWechatOrderEventProducer(q mq.MQ) (WechatOrderEventProducer, error)

Constants

const (
	// WechatOrderEventName 自动创建工单
	WechatOrderEventName = "wechat_order_events"

	// WechatCallbackEventName 接收来自企业微信审批通过消息
	WechatCallbackEventName = "wechat_callback_events"
)

Types

type WechatApprovalCallbackConsumer

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

func NewWechatApprovalCallbackConsumer

func NewWechatApprovalCallbackConsumer(svc service.Service, q mq.MQ, p WechatOrderEventProducer, workApp *workwx.WorkwxApp) (*WechatApprovalCallbackConsumer, error)

func (*WechatApprovalCallbackConsumer) Consume

func (c *WechatApprovalCallbackConsumer) Consume(ctx context.Context) error

func (*WechatApprovalCallbackConsumer) Start

func (c *WechatApprovalCallbackConsumer) Start(ctx context.Context)

func (*WechatApprovalCallbackConsumer) Stop

func (c *WechatApprovalCallbackConsumer) Stop(_ context.Context) error

type WechatOrderEventProducer

type WechatOrderEventProducer interface {
	Produce(ctx context.Context, evt *workwx.OAApprovalDetail) error
}

func NewWechatOrderEventProducer

func NewWechatOrderEventProducer(q mq.MQ) (WechatOrderEventProducer, error)