send.go

package wechat

import (
	"encoding/json"
	"fmt"
	"unicode/utf8"

	"github.com/esap/wechat/util"
)

// AddMsg 添加队列消息
func (s *Server) AddMsg(v interface{}) {
	s.MsgQueue <- v
}

// SendMsg 发送消息
func (s *Server) SendMsg(v interface{}) *WxErr {
	url := s.MsgUrl + s.GetAccessToken()
	body, err := util.PostJson(url, v)
	if err != nil {
		return &WxErr{-1, err.Error()}
	}
	rst := new(WxErr)
	err = json.Unmarshal(body, rst)
	if err != nil {
		return &WxErr{-1, err.Error()}
	}
	Printf("[*] 发送消息:%+v\n[*] 回执:%+v", v, *rst)
	return rst
}

// SendText 发送客服text消息,过长时按500长度自动拆分
func (s *Server) SendText(to, msg string) (e *WxErr) {
	leng := utf8.RuneCountInString(msg)
	n := leng/500 + 1

	if n == 1 {
		return s.SendMsg(s.NewText(to, msg))
	}
	for i := 0; i < n; i++ {
		e = s.SendMsg(s.NewText(to, fmt.Sprintf("%s\n(%v/%v)", util.Substr(msg, i*500, (i+1)*500), i+1, n)))
	}

	return
}

// SendImage 发送客服Image消息
func (s *Server) SendImage(to string, mediaId string) *WxErr {
	return s.SendMsg(s.NewImage(to, mediaId))
}

// SendVoice 发送客服Voice消息
func (s *Server) SendVoice(to string, mediaId string) *WxErr {
	return s.SendMsg(s.NewVoice(to, mediaId))
}

// SendFile 发送客服File消息
func (s *Server) SendFile(to string, mediaId string) *WxErr {
	return s.SendMsg(s.NewFile(to, mediaId))
}

// SendVideo 发送客服Video消息
func (s *Server) SendVideo(to string, mediaId, title, desc string) *WxErr {
	return s.SendMsg(s.NewVideo(to, mediaId, title, desc))
}

// SendTextcard 发送客服extcard消息
func (s *Server) SendTextcard(to string, title, desc, url, btntxt string) *WxErr {
	return s.SendMsg(s.NewTextcard(to, title, desc, url, btntxt))
}

// SendMusic 发送客服Music消息
func (s *Server) SendMusic(to string, mediaId, title, desc, musicUrl, qhMusicUrl string) *WxErr {
	return s.SendMsg(s.NewMusic(to, mediaId, title, desc, musicUrl, qhMusicUrl))
}

// SendNews 发送客服news消息
func (s *Server) SendNews(to string, arts ...Article) *WxErr {
	return s.SendMsg(s.NewNews(to, arts...))
}

// SendMpNews 发送加密新闻mpnews消息(仅企业号可用)
func (s *Server) SendMpNews(to string, arts ...MpArticle) *WxErr {
	return s.SendMsg(s.NewMpNews(to, arts...))
}

// SendMpNewsId 发送加密新闻mpnews消息(直接使用mediaId)
func (s *Server) SendMpNewsId(to string, mediaId string) *WxErr {
	return s.SendMsg(s.NewMpNewsId(to, mediaId))
}

// SendMarkDown 发送加密新闻mpnews消息(直接使用mediaId)
func (s *Server) SendMarkDown(to string, content string) *WxErr {
	return s.SendMsg(s.NewMarkDown(to, content))
}

// SendTaskCard 发送任务卡片taskcard消息
func (s *Server) SendTaskCard(to string, Title, Desc, Url, TaskId, Btn string) *WxErr {
	return s.SendMsg(s.NewTaskCard(to, Title, Desc, Url, TaskId, Btn))
}