mq

type Consumer struct {
	Conn       *amqp.Connection
	Channel    *amqp.Channel
	Tag        string
	Done       chan error
	Deliveries <-chan amqp.Delivery
}

type DingTalkBody struct {
	StaffId string `json:"staffId"`
	*DingTalkNoticeBody
	MessageId string `json:"messageId"`
}

type DingTalkMsgLinkInput struct {
	MessageUrl string `json:"messageUrl"`
	PicUrl     string `json:"picUrl"`
	Title      string `json:"title"`
	Text       string `json:"text"`
}

type DingTalkMsgMarkdownInput struct {
	Title string `json:"title"` // 这个是点进推送列表前显示的简短的消息（进入后不可见）
	Text  string `json:"text"`  // 这个是进入后显示的详细的消息
}

type DingTalkMsgPlainTextInput struct {
	Content string `json:"content"`
}

type DingTalkNoticeBody struct {
	MsgType  string                     `json:"msgtype"`
	Text     *DingTalkMsgPlainTextInput `json:"text,omitempty"`
	Link     *DingTalkMsgLinkInput      `json:"link,omitempty"`
	Markdown *DingTalkMsgMarkdownInput  `json:"markdown,omitempty"`
}

type NoticeTemplate struct {
	StaffID  []string            `json:"StaffID"`
	WeChat   *WeChatNoticeBody   `json:"template,omitempty"`
	DingTalk *DingTalkNoticeBody `json:"dingtalk,omitempty"`
	// contains filtered or unexported fields
}

type Producer struct {
	Conn    *amqp.Connection
	Channel *amqp.Channel
	// contains filtered or unexported fields
}

type RabbitMQHeaderCarrier amqp.Table

type UniNotifyInput struct {
	Title    string
	SubTitle string
	Content  string
	Extra    string
}

type WeChatNoticeBody struct {
	Data       map[string]*message.TemplateDataItem `json:"data"`
	TemplateID string                               `json:"template_id"`
	ToUser     string                               `json:"touser"`
	URL        string                               `json:"url"`
}

type WechatBody struct {
	StaffId string `json:"staffId"`
	*WeChatNoticeBody
	MessageId string `json:"messageId"`
}