diff --git a/message.go b/message.go
index c6025de..f5ac5eb 100644
--- a/message.go
+++ b/message.go
@@ -1,634 +1,649 @@
package openwechat
import (
- "context"
- "encoding/xml"
- "errors"
- "fmt"
- "html"
- "net/http"
- "os"
- "strconv"
- "strings"
- "sync"
- "time"
- "unicode"
+ "context"
+ "encoding/xml"
+ "errors"
+ "fmt"
+ "html"
+ "net/http"
+ "os"
+ "strconv"
+ "strings"
+ "sync"
+ "time"
+ "unicode"
)
type Message struct {
- IsAt bool
- AppInfo struct {
- Type int
- AppID string
- }
- AppMsgType AppMessageType
- HasProductId int
- ImgHeight int
- ImgStatus int
- ImgWidth int
- ForwardFlag int
- MsgType MessageType
- Status int
- StatusNotifyCode int
- SubMsgType int
- VoiceLength int
- CreateTime int64
- NewMsgId int64
- PlayLength int64
- MediaId string
- MsgId string
- EncryFileName string
- FileName string
- FileSize string
- Content string
- FromUserName string
- OriContent string
- StatusNotifyUserName string
- Ticket string
- ToUserName string
- Url string
- senderInGroupUserName string
- RecommendInfo RecommendInfo
- Bot *Bot
- mu sync.RWMutex
- Context context.Context
- item map[string]interface{}
+ IsAt bool
+ AppInfo struct {
+ Type int
+ AppID string
+ }
+ AppMsgType AppMessageType
+ HasProductId int
+ ImgHeight int
+ ImgStatus int
+ ImgWidth int
+ ForwardFlag int
+ MsgType MessageType
+ Status int
+ StatusNotifyCode int
+ SubMsgType int
+ VoiceLength int
+ CreateTime int64
+ NewMsgId int64
+ PlayLength int64
+ MediaId string
+ MsgId string
+ EncryFileName string
+ FileName string
+ FileSize string
+ Content string
+ FromUserName string
+ OriContent string
+ StatusNotifyUserName string
+ Ticket string
+ ToUserName string
+ Url string
+ senderInGroupUserName string
+ RecommendInfo RecommendInfo
+ Bot *Bot
+ mu sync.RWMutex
+ Context context.Context
+ item map[string]interface{}
}
// Sender 获取消息的发送者
func (m *Message) Sender() (*User, error) {
- if m.FromUserName == m.Bot.self.User.UserName {
- return m.Bot.self.User, nil
- }
- user := &User{Self: m.Bot.self, UserName: m.FromUserName}
- return user.Detail()
+ if m.FromUserName == m.Bot.self.User.UserName {
+ return m.Bot.self.User, nil
+ }
+ user := &User{Self: m.Bot.self, UserName: m.FromUserName}
+ return user.Detail()
}
// SenderInGroup 获取消息在群里面的发送者
func (m *Message) SenderInGroup() (*User, error) {
- if !m.IsSendByGroup() {
- return nil, errors.New("message is not from group")
- }
- group, err := m.Sender()
- if err != nil {
- return nil, err
- }
- group, err = group.Detail()
- if err != nil {
- return nil, err
- }
- users := group.MemberList.SearchByUserName(1, m.senderInGroupUserName)
- if users == nil {
- return nil, ErrNoSuchUserFoundError
- }
- users.init(m.Bot.self)
- return users.First(), nil
+ if !m.IsComeFromGroup() {
+ return nil, errors.New("message is not from group")
+ }
+ // 拍一拍系列的系统消息
+ // https://github.com/eatmoreapple/openwechat/issues/66
+ if m.IsSystem() {
+ // 判断是否有自己发送
+ if m.FromUserName == m.Bot.self.User.UserName {
+ return m.Bot.self.User, nil
+ }
+ return nil, errors.New("can not found sender from system message")
+ }
+ group, err := m.Sender()
+ if err != nil {
+ return nil, err
+ }
+ group, err = group.Detail()
+ if err != nil {
+ return nil, err
+ }
+ users := group.MemberList.SearchByUserName(1, m.senderInGroupUserName)
+ if users == nil {
+ return nil, ErrNoSuchUserFoundError
+ }
+ users.init(m.Bot.self)
+ return users.First(), nil
}
// Receiver 获取消息的接收者
func (m *Message) Receiver() (*User, error) {
- if m.IsSendByGroup() {
- if sender, err := m.Sender(); err != nil {
- return nil, err
- } else {
- users := sender.MemberList.SearchByUserName(1, m.ToUserName)
- if users == nil {
- return nil, ErrNoSuchUserFoundError
- }
- return users.First(), nil
- }
- } else {
- users := m.Bot.self.MemberList.SearchByUserName(1, m.ToUserName)
- if users == nil {
- return nil, ErrNoSuchUserFoundError
- }
- return users.First(), nil
- }
+ if m.IsSendByGroup() {
+ if sender, err := m.Sender(); err != nil {
+ return nil, err
+ } else {
+ users := sender.MemberList.SearchByUserName(1, m.ToUserName)
+ if users == nil {
+ return nil, ErrNoSuchUserFoundError
+ }
+ return users.First(), nil
+ }
+ } else {
+ users := m.Bot.self.MemberList.SearchByUserName(1, m.ToUserName)
+ if users == nil {
+ return nil, ErrNoSuchUserFoundError
+ }
+ return users.First(), nil
+ }
}
// IsSendBySelf 判断消息是否由自己发送
func (m *Message) IsSendBySelf() bool {
- return m.FromUserName == m.Bot.self.User.UserName
+ return m.FromUserName == m.Bot.self.User.UserName
}
// IsSendByFriend 判断消息是否由好友发送
func (m *Message) IsSendByFriend() bool {
- return !m.IsSendByGroup() && strings.HasPrefix(m.FromUserName, "@") && !m.IsSendBySelf()
+ return !m.IsSendByGroup() && strings.HasPrefix(m.FromUserName, "@") && !m.IsSendBySelf()
}
// IsSendByGroup 判断消息是否由群组发送
func (m *Message) IsSendByGroup() bool {
- return strings.HasPrefix(m.FromUserName, "@@")
+ return strings.HasPrefix(m.FromUserName, "@@")
}
// Reply 回复消息
func (m *Message) Reply(msgType MessageType, content, mediaId string) (*SentMessage, error) {
- msg := NewSendMessage(msgType, content, m.Bot.self.User.UserName, m.FromUserName, mediaId)
- info := m.Bot.Storage.LoginInfo
- request := m.Bot.Storage.Request
- sentMessage, err := m.Bot.Caller.WebWxSendMsg(msg, info, request)
- if err != nil {
- return nil, err
- }
- sentMessage.Self = m.Bot.self
- return sentMessage, nil
+ msg := NewSendMessage(msgType, content, m.Bot.self.User.UserName, m.FromUserName, mediaId)
+ info := m.Bot.Storage.LoginInfo
+ request := m.Bot.Storage.Request
+ sentMessage, err := m.Bot.Caller.WebWxSendMsg(msg, info, request)
+ if err != nil {
+ return nil, err
+ }
+ sentMessage.Self = m.Bot.self
+ return sentMessage, nil
}
// ReplyText 回复文本消息
func (m *Message) ReplyText(content string) (*SentMessage, error) {
- return m.Reply(MsgTypeText, content, "")
+ return m.Reply(MsgTypeText, content, "")
}
// ReplyImage 回复图片消息
func (m *Message) ReplyImage(file *os.File) (*SentMessage, error) {
- info := m.Bot.Storage.LoginInfo
- request := m.Bot.Storage.Request
- return m.Bot.Caller.WebWxSendImageMsg(file, request, info, m.Bot.self.UserName, m.FromUserName)
+ info := m.Bot.Storage.LoginInfo
+ request := m.Bot.Storage.Request
+ return m.Bot.Caller.WebWxSendImageMsg(file, request, info, m.Bot.self.UserName, m.FromUserName)
}
// ReplyFile 回复文件消息
func (m *Message) ReplyFile(file *os.File) (*SentMessage, error) {
- info := m.Bot.Storage.LoginInfo
- request := m.Bot.Storage.Request
- return m.Bot.Caller.WebWxSendFile(file, request, info, m.Bot.self.UserName, m.FromUserName)
+ info := m.Bot.Storage.LoginInfo
+ request := m.Bot.Storage.Request
+ return m.Bot.Caller.WebWxSendFile(file, request, info, m.Bot.self.UserName, m.FromUserName)
}
func (m *Message) IsText() bool {
- return m.MsgType == MsgTypeText && m.Url == ""
+ return m.MsgType == MsgTypeText && m.Url == ""
}
func (m *Message) IsMap() bool {
- return m.MsgType == MsgTypeText && m.Url != ""
+ return m.MsgType == MsgTypeText && m.Url != ""
}
func (m *Message) IsPicture() bool {
- return m.MsgType == MsgTypeImage
+ return m.MsgType == MsgTypeImage
}
// IsEmoticon 是否为表情包消息
func (m *Message) IsEmoticon() bool {
- return m.MsgType == MsgTypeEmoticon
+ return m.MsgType == MsgTypeEmoticon
}
func (m *Message) IsVoice() bool {
- return m.MsgType == MsgTypeVoice
+ return m.MsgType == MsgTypeVoice
}
func (m *Message) IsFriendAdd() bool {
- return m.MsgType == MsgTypeVerify && m.FromUserName == "fmessage"
+ return m.MsgType == MsgTypeVerify && m.FromUserName == "fmessage"
}
func (m *Message) IsCard() bool {
- return m.MsgType == MsgTypeShareCard
+ return m.MsgType == MsgTypeShareCard
}
func (m *Message) IsVideo() bool {
- return m.MsgType == MsgTypeVideo || m.MsgType == MsgTypeMicroVideo
+ return m.MsgType == MsgTypeVideo || m.MsgType == MsgTypeMicroVideo
}
func (m *Message) IsMedia() bool {
- return m.MsgType == MsgTypeApp
+ return m.MsgType == MsgTypeApp
}
// IsRecalled 判断是否撤回
func (m *Message) IsRecalled() bool {
- return m.MsgType == MsgTypeRecalled
+ return m.MsgType == MsgTypeRecalled
}
func (m *Message) IsSystem() bool {
- return m.MsgType == MsgTypeSys
+ return m.MsgType == MsgTypeSys
}
func (m *Message) IsNotify() bool {
- return m.MsgType == 51 && m.StatusNotifyCode != 0
+ return m.MsgType == 51 && m.StatusNotifyCode != 0
}
// IsTransferAccounts 判断当前的消息是不是微信转账
func (m *Message) IsTransferAccounts() bool {
- return m.IsMedia() && m.FileName == "微信转账"
+ return m.IsMedia() && m.FileName == "微信转账"
}
// IsSendRedPacket 否发出红包判断当前是
func (m *Message) IsSendRedPacket() bool {
- return m.IsSystem() && m.Content == "发出红包，请在手机上查看"
+ return m.IsSystem() && m.Content == "发出红包，请在手机上查看"
}
// IsReceiveRedPacket 判断当前是否收到红包
func (m *Message) IsReceiveRedPacket() bool {
- return m.IsSystem() && m.Content == "收到红包，请在手机上查看"
+ return m.IsSystem() && m.Content == "收到红包，请在手机上查看"
}
func (m *Message) IsSysNotice() bool {
- return m.MsgType == 9999
+ return m.MsgType == 9999
}
// StatusNotify 判断是否为操作通知消息
func (m *Message) StatusNotify() bool {
- return m.MsgType == 51
+ return m.MsgType == 51
}
// HasFile 判断消息是否为文件类型的消息
func (m *Message) HasFile() bool {
- return m.IsPicture() || m.IsVoice() || m.IsVideo() || (m.IsMedia() && m.AppMsgType == AppMsgTypeAttach) || m.IsEmoticon()
+ return m.IsPicture() || m.IsVoice() || m.IsVideo() || (m.IsMedia() && m.AppMsgType == AppMsgTypeAttach) || m.IsEmoticon()
}
// GetFile 获取文件消息的文件
func (m *Message) GetFile() (*http.Response, error) {
- if !m.HasFile() {
- return nil, errors.New("invalid message type")
- }
- if m.IsPicture() || m.IsEmoticon() {
- return m.Bot.Caller.Client.WebWxGetMsgImg(m, m.Bot.Storage.LoginInfo)
- }
- if m.IsVoice() {
- return m.Bot.Caller.Client.WebWxGetVoice(m, m.Bot.Storage.LoginInfo)
- }
- if m.IsVideo() {
- return m.Bot.Caller.Client.WebWxGetVideo(m, m.Bot.Storage.LoginInfo)
- }
- if m.IsMedia() {
- return m.Bot.Caller.Client.WebWxGetMedia(m, m.Bot.Storage.LoginInfo)
- }
- return nil, errors.New("unsupported type")
+ if !m.HasFile() {
+ return nil, errors.New("invalid message type")
+ }
+ if m.IsPicture() || m.IsEmoticon() {
+ return m.Bot.Caller.Client.WebWxGetMsgImg(m, m.Bot.Storage.LoginInfo)
+ }
+ if m.IsVoice() {
+ return m.Bot.Caller.Client.WebWxGetVoice(m, m.Bot.Storage.LoginInfo)
+ }
+ if m.IsVideo() {
+ return m.Bot.Caller.Client.WebWxGetVideo(m, m.Bot.Storage.LoginInfo)
+ }
+ if m.IsMedia() {
+ return m.Bot.Caller.Client.WebWxGetMedia(m, m.Bot.Storage.LoginInfo)
+ }
+ return nil, errors.New("unsupported type")
}
// Card 获取card类型
func (m *Message) Card() (*Card, error) {
- if !m.IsCard() {
- return nil, errors.New("card message required")
- }
- var card Card
- err := xml.Unmarshal(stringToByte(m.Content), &card)
- return &card, err
+ if !m.IsCard() {
+ return nil, errors.New("card message required")
+ }
+ var card Card
+ err := xml.Unmarshal(stringToByte(m.Content), &card)
+ return &card, err
}
// FriendAddMessageContent 获取FriendAddMessageContent内容
func (m *Message) FriendAddMessageContent() (*FriendAddMessage, error) {
- if !m.IsFriendAdd() {
- return nil, errors.New("friend add message required")
- }
- var f FriendAddMessage
- err := xml.Unmarshal(stringToByte(m.Content), &f)
- return &f, err
+ if !m.IsFriendAdd() {
+ return nil, errors.New("friend add message required")
+ }
+ var f FriendAddMessage
+ err := xml.Unmarshal(stringToByte(m.Content), &f)
+ return &f, err
}
// RevokeMsg 获取撤回消息的内容
func (m *Message) RevokeMsg() (*RevokeMsg, error) {
- if !m.IsRecalled() {
- return nil, errors.New("recalled message required")
- }
- var r RevokeMsg
- err := xml.Unmarshal(stringToByte(m.Content), &r)
- return &r, err
+ if !m.IsRecalled() {
+ return nil, errors.New("recalled message required")
+ }
+ var r RevokeMsg
+ err := xml.Unmarshal(stringToByte(m.Content), &r)
+ return &r, err
}
// Agree 同意好友的请求
func (m *Message) Agree(verifyContents ...string) error {
- if !m.IsFriendAdd() {
- return fmt.Errorf("friend add message required")
- }
- var builder strings.Builder
- for _, v := range verifyContents {
- builder.WriteString(v)
- }
- return m.Bot.Caller.WebWxVerifyUser(m.Bot.Storage, m.RecommendInfo, builder.String())
+ if !m.IsFriendAdd() {
+ return fmt.Errorf("friend add message required")
+ }
+ var builder strings.Builder
+ for _, v := range verifyContents {
+ builder.WriteString(v)
+ }
+ return m.Bot.Caller.WebWxVerifyUser(m.Bot.Storage, m.RecommendInfo, builder.String())
}
// AsRead 将消息设置为已读
func (m *Message) AsRead() error {
- return m.Bot.Caller.WebWxStatusAsRead(m.Bot.Storage.Request, m.Bot.Storage.LoginInfo, m)
+ return m.Bot.Caller.WebWxStatusAsRead(m.Bot.Storage.Request, m.Bot.Storage.LoginInfo, m)
}
// IsArticle 判断当前的消息类型是否为文章
func (m *Message) IsArticle() bool {
- return m.AppMsgType == AppMsgTypeUrl
+ return m.AppMsgType == AppMsgTypeUrl
}
// MediaData 获取当前App Message的具体内容
func (m *Message) MediaData() (*AppMessageData, error) {
- if !m.IsMedia() {
- return nil, errors.New("media message required")
- }
- var data AppMessageData
- if err := xml.Unmarshal(stringToByte(m.Content), &data); err != nil {
- return nil, err
- }
- return &data, nil
+ if !m.IsMedia() {
+ return nil, errors.New("media message required")
+ }
+ var data AppMessageData
+ if err := xml.Unmarshal(stringToByte(m.Content), &data); err != nil {
+ return nil, err
+ }
+ return &data, nil
}
// Set 往消息上下文中设置值
// goroutine safe
func (m *Message) Set(key string, value interface{}) {
- m.mu.Lock()
- defer m.mu.Unlock()
- if m.item == nil {
- m.item = make(map[string]interface{})
- }
- m.item[key] = value
+ m.mu.Lock()
+ defer m.mu.Unlock()
+ if m.item == nil {
+ m.item = make(map[string]interface{})
+ }
+ m.item[key] = value
}
// Get 从消息上下文中获取值
// goroutine safe
func (m *Message) Get(key string) (value interface{}, exist bool) {
- m.mu.RLock()
- defer m.mu.RUnlock()
- value, exist = m.item[key]
- return
+ m.mu.RLock()
+ defer m.mu.RUnlock()
+ value, exist = m.item[key]
+ return
}
// 消息初始化,根据不同的消息作出不同的处理
func (m *Message) init(bot *Bot) {
- m.Bot = bot
+ m.Bot = bot
- // 如果是群消息
- if m.IsSendByGroup() {
- // 将Username和正文分开
- data := strings.Split(m.Content, ":
")
- m.Content = strings.Join(data[1:], "")
- m.senderInGroupUserName = data[0]
- receiver, err := m.Receiver()
- if err == nil {
- displayName := receiver.DisplayName
- if displayName == "" {
- displayName = receiver.NickName
- }
- // 判断是不是@消息
- atFlag := "@" + displayName
- index := len(atFlag) + 1 + 1
- if strings.HasPrefix(m.Content, atFlag) && unicode.IsSpace(rune(m.Content[index])) {
- m.IsAt = true
- m.Content = m.Content[index+1:]
- }
- }
- }
- // 处理消息中的换行
- m.Content = strings.Replace(m.Content, `
`, "\n", -1)
- // 处理html转义字符
- m.Content = html.UnescapeString(m.Content)
- // 处理消息中的emoji表情
- m.Content = FormatEmoji(m.Content)
+ // 如果是群消息
+ if m.IsSendByGroup() {
+ // 将Username和正文分开
+ data := strings.Split(m.Content, ":
")
+ m.Content = strings.Join(data[1:], "")
+ m.senderInGroupUserName = data[0]
+ receiver, err := m.Receiver()
+ if err == nil {
+ displayName := receiver.DisplayName
+ if displayName == "" {
+ displayName = receiver.NickName
+ }
+ // 判断是不是@消息
+ atFlag := "@" + displayName
+ index := len(atFlag) + 1 + 1
+ if strings.HasPrefix(m.Content, atFlag) && unicode.IsSpace(rune(m.Content[index])) {
+ m.IsAt = true
+ m.Content = m.Content[index+1:]
+ }
+ }
+ }
+ // 处理消息中的换行
+ m.Content = strings.Replace(m.Content, `
`, "\n", -1)
+ // 处理html转义字符
+ m.Content = html.UnescapeString(m.Content)
+ // 处理消息中的emoji表情
+ m.Content = FormatEmoji(m.Content)
}
// SendMessage 发送消息的结构体
type SendMessage struct {
- Type MessageType
- Content string
- FromUserName string
- ToUserName string
- LocalID string
- ClientMsgId string
- MediaId string `json:"MediaId,omitempty"`
+ Type MessageType
+ Content string
+ FromUserName string
+ ToUserName string
+ LocalID string
+ ClientMsgId string
+ MediaId string `json:"MediaId,omitempty"`
}
// NewSendMessage SendMessage的构造方法
func NewSendMessage(msgType MessageType, content, fromUserName, toUserName, mediaId string) *SendMessage {
- id := strconv.FormatInt(time.Now().UnixNano()/1e2, 10)
- return &SendMessage{
- Type: msgType,
- Content: content,
- FromUserName: fromUserName,
- ToUserName: toUserName,
- LocalID: id,
- ClientMsgId: id,
- MediaId: mediaId,
- }
+ id := strconv.FormatInt(time.Now().UnixNano()/1e2, 10)
+ return &SendMessage{
+ Type: msgType,
+ Content: content,
+ FromUserName: fromUserName,
+ ToUserName: toUserName,
+ LocalID: id,
+ ClientMsgId: id,
+ MediaId: mediaId,
+ }
}
// NewTextSendMessage 文本消息的构造方法
func NewTextSendMessage(content, fromUserName, toUserName string) *SendMessage {
- return NewSendMessage(MsgTypeText, content, fromUserName, toUserName, "")
+ return NewSendMessage(MsgTypeText, content, fromUserName, toUserName, "")
}
// NewMediaSendMessage 媒体消息的构造方法
func NewMediaSendMessage(msgType MessageType, fromUserName, toUserName, mediaId string) *SendMessage {
- return NewSendMessage(msgType, "", fromUserName, toUserName, mediaId)
+ return NewSendMessage(msgType, "", fromUserName, toUserName, mediaId)
}
// RecommendInfo 一些特殊类型的消息会携带该结构体信息
type RecommendInfo struct {
- OpCode int
- Scene int
- Sex int
- VerifyFlag int
- AttrStatus int64
- QQNum int64
- Alias string
- City string
- Content string
- NickName string
- Province string
- Signature string
- Ticket string
- UserName string
+ OpCode int
+ Scene int
+ Sex int
+ VerifyFlag int
+ AttrStatus int64
+ QQNum int64
+ Alias string
+ City string
+ Content string
+ NickName string
+ Province string
+ Signature string
+ Ticket string
+ UserName string
}
// Card 名片消息内容
type Card struct {
- XMLName xml.Name `xml:"msg"`
- ImageStatus int `xml:"imagestatus,attr"`
- Scene int `xml:"scene,attr"`
- Sex int `xml:"sex,attr"`
- Certflag int `xml:"certflag,attr"`
- BigHeadImgUrl string `xml:"bigheadimgurl,attr"`
- SmallHeadImgUrl string `xml:"smallheadimgurl,attr"`
- UserName string `xml:"username,attr"`
- NickName string `xml:"nickname,attr"`
- ShortPy string `xml:"shortpy,attr"`
- Alias string `xml:"alias,attr"` // Note: 这个是名片用户的微信号
- Province string `xml:"province,attr"`
- City string `xml:"city,attr"`
- Sign string `xml:"sign,attr"`
- Certinfo string `xml:"certinfo,attr"`
- BrandIconUrl string `xml:"brandIconUrl,attr"`
- BrandHomeUr string `xml:"brandHomeUr,attr"`
- BrandSubscriptConfigUrl string `xml:"brandSubscriptConfigUrl,attr"`
- BrandFlags string `xml:"brandFlags,attr"`
- RegionCode string `xml:"regionCode,attr"`
+ XMLName xml.Name `xml:"msg"`
+ ImageStatus int `xml:"imagestatus,attr"`
+ Scene int `xml:"scene,attr"`
+ Sex int `xml:"sex,attr"`
+ Certflag int `xml:"certflag,attr"`
+ BigHeadImgUrl string `xml:"bigheadimgurl,attr"`
+ SmallHeadImgUrl string `xml:"smallheadimgurl,attr"`
+ UserName string `xml:"username,attr"`
+ NickName string `xml:"nickname,attr"`
+ ShortPy string `xml:"shortpy,attr"`
+ Alias string `xml:"alias,attr"` // Note: 这个是名片用户的微信号
+ Province string `xml:"province,attr"`
+ City string `xml:"city,attr"`
+ Sign string `xml:"sign,attr"`
+ Certinfo string `xml:"certinfo,attr"`
+ BrandIconUrl string `xml:"brandIconUrl,attr"`
+ BrandHomeUr string `xml:"brandHomeUr,attr"`
+ BrandSubscriptConfigUrl string `xml:"brandSubscriptConfigUrl,attr"`
+ BrandFlags string `xml:"brandFlags,attr"`
+ RegionCode string `xml:"regionCode,attr"`
}
// FriendAddMessage 好友添加消息信息内容
type FriendAddMessage struct {
- XMLName xml.Name `xml:"msg"`
- Shortpy int `xml:"shortpy,attr"`
- ImageStatus int `xml:"imagestatus,attr"`
- Scene int `xml:"scene,attr"`
- PerCard int `xml:"percard,attr"`
- Sex int `xml:"sex,attr"`
- AlbumFlag int `xml:"albumflag,attr"`
- AlbumStyle int `xml:"albumstyle,attr"`
- SnsFlag int `xml:"snsflag,attr"`
- Opcode int `xml:"opcode,attr"`
- FromUserName string `xml:"fromusername,attr"`
- EncryptUserName string `xml:"encryptusername,attr"`
- FromNickName string `xml:"fromnickname,attr"`
- Content string `xml:"content,attr"`
- Country string `xml:"country,attr"`
- Province string `xml:"province,attr"`
- City string `xml:"city,attr"`
- Sign string `xml:"sign,attr"`
- Alias string `xml:"alias,attr"`
- WeiBo string `xml:"weibo,attr"`
- AlbumBgImgId string `xml:"albumbgimgid,attr"`
- SnsBgImgId string `xml:"snsbgimgid,attr"`
- SnsBgObjectId string `xml:"snsbgobjectid,attr"`
- MHash string `xml:"mhash,attr"`
- MFullHash string `xml:"mfullhash,attr"`
- BigHeadImgUrl string `xml:"bigheadimgurl,attr"`
- SmallHeadImgUrl string `xml:"smallheadimgurl,attr"`
- Ticket string `xml:"ticket,attr"`
- GoogleContact string `xml:"googlecontact,attr"`
- QrTicket string `xml:"qrticket,attr"`
- ChatRoomUserName string `xml:"chatroomusername,attr"`
- SourceUserName string `xml:"sourceusername,attr"`
- ShareCardUserName string `xml:"sharecardusername,attr"`
- ShareCardNickName string `xml:"sharecardnickname,attr"`
- CardVersion string `xml:"cardversion,attr"`
- BrandList struct {
- Count int `xml:"count,attr"`
- Ver int64 `xml:"ver,attr"`
- } `xml:"brandlist"`
+ XMLName xml.Name `xml:"msg"`
+ Shortpy int `xml:"shortpy,attr"`
+ ImageStatus int `xml:"imagestatus,attr"`
+ Scene int `xml:"scene,attr"`
+ PerCard int `xml:"percard,attr"`
+ Sex int `xml:"sex,attr"`
+ AlbumFlag int `xml:"albumflag,attr"`
+ AlbumStyle int `xml:"albumstyle,attr"`
+ SnsFlag int `xml:"snsflag,attr"`
+ Opcode int `xml:"opcode,attr"`
+ FromUserName string `xml:"fromusername,attr"`
+ EncryptUserName string `xml:"encryptusername,attr"`
+ FromNickName string `xml:"fromnickname,attr"`
+ Content string `xml:"content,attr"`
+ Country string `xml:"country,attr"`
+ Province string `xml:"province,attr"`
+ City string `xml:"city,attr"`
+ Sign string `xml:"sign,attr"`
+ Alias string `xml:"alias,attr"`
+ WeiBo string `xml:"weibo,attr"`
+ AlbumBgImgId string `xml:"albumbgimgid,attr"`
+ SnsBgImgId string `xml:"snsbgimgid,attr"`
+ SnsBgObjectId string `xml:"snsbgobjectid,attr"`
+ MHash string `xml:"mhash,attr"`
+ MFullHash string `xml:"mfullhash,attr"`
+ BigHeadImgUrl string `xml:"bigheadimgurl,attr"`
+ SmallHeadImgUrl string `xml:"smallheadimgurl,attr"`
+ Ticket string `xml:"ticket,attr"`
+ GoogleContact string `xml:"googlecontact,attr"`
+ QrTicket string `xml:"qrticket,attr"`
+ ChatRoomUserName string `xml:"chatroomusername,attr"`
+ SourceUserName string `xml:"sourceusername,attr"`
+ ShareCardUserName string `xml:"sharecardusername,attr"`
+ ShareCardNickName string `xml:"sharecardnickname,attr"`
+ CardVersion string `xml:"cardversion,attr"`
+ BrandList struct {
+ Count int `xml:"count,attr"`
+ Ver int64 `xml:"ver,attr"`
+ } `xml:"brandlist"`
}
// RevokeMsg 撤回消息Content
type RevokeMsg struct {
- SysMsg xml.Name `xml:"sysmsg"`
- Type string `xml:"type,attr"`
- RevokeMsg struct {
- OldMsgId int64 `xml:"oldmsgid"`
- MsgId int64 `xml:"msgid"`
- Session string `xml:"session"`
- ReplaceMsg string `xml:"replacemsg"`
- } `xml:"revokemsg"`
+ SysMsg xml.Name `xml:"sysmsg"`
+ Type string `xml:"type,attr"`
+ RevokeMsg struct {
+ OldMsgId int64 `xml:"oldmsgid"`
+ MsgId int64 `xml:"msgid"`
+ Session string `xml:"session"`
+ ReplaceMsg string `xml:"replacemsg"`
+ } `xml:"revokemsg"`
}
// SentMessage 已发送的信息
type SentMessage struct {
- *SendMessage
- Self *Self
- MsgId string
+ *SendMessage
+ Self *Self
+ MsgId string
}
// Revoke 撤回该消息
func (s *SentMessage) Revoke() error {
- return s.Self.RevokeMessage(s)
+ return s.Self.RevokeMessage(s)
}
// CanRevoke 是否可以撤回该消息
func (s *SentMessage) CanRevoke() bool {
- i, err := strconv.ParseInt(s.ClientMsgId, 10, 64)
- if err != nil {
- return false
- }
- start := time.Unix(i/10000000, 0)
- return time.Now().Sub(start) < time.Minute*2
+ i, err := strconv.ParseInt(s.ClientMsgId, 10, 64)
+ if err != nil {
+ return false
+ }
+ start := time.Unix(i/10000000, 0)
+ return time.Now().Sub(start) < time.Minute*2
}
// ForwardToFriends 转发该消息给好友
func (s *SentMessage) ForwardToFriends(friends ...*Friend) error {
- return s.Self.ForwardMessageToFriends(s, friends...)
+ return s.Self.ForwardMessageToFriends(s, friends...)
}
// ForwardToGroups 转发该消息给群组
func (s *SentMessage) ForwardToGroups(groups ...*Group) error {
- return s.Self.ForwardMessageToGroups(s, groups...)
+ return s.Self.ForwardMessageToGroups(s, groups...)
}
type appmsg struct {
- Type int `xml:"type"`
- AppId string `xml:"appid,attr"` // wxeb7ec651dd0aefa9
- SdkVer string `xml:"sdkver,attr"`
- Title string `xml:"title"`
- Des string `xml:"des"`
- Action string `xml:"action"`
- Content string `xml:"content"`
- Url string `xml:"url"`
- LowUrl string `xml:"lowurl"`
- ExtInfo string `xml:"extinfo"`
- AppAttach struct {
- TotalLen int64 `xml:"totallen"`
- AttachId string `xml:"attachid"`
- FileExt string `xml:"fileext"`
- } `xml:"appattach"`
+ Type int `xml:"type"`
+ AppId string `xml:"appid,attr"` // wxeb7ec651dd0aefa9
+ SdkVer string `xml:"sdkver,attr"`
+ Title string `xml:"title"`
+ Des string `xml:"des"`
+ Action string `xml:"action"`
+ Content string `xml:"content"`
+ Url string `xml:"url"`
+ LowUrl string `xml:"lowurl"`
+ ExtInfo string `xml:"extinfo"`
+ AppAttach struct {
+ TotalLen int64 `xml:"totallen"`
+ AttachId string `xml:"attachid"`
+ FileExt string `xml:"fileext"`
+ } `xml:"appattach"`
}
func (f appmsg) XmlByte() ([]byte, error) {
- return xml.Marshal(f)
+ return xml.Marshal(f)
}
func NewFileAppMessage(stat os.FileInfo, attachId string) *appmsg {
- m := &appmsg{AppId: appMessageAppId, Title: stat.Name()}
- m.AppAttach.AttachId = attachId
- m.AppAttach.TotalLen = stat.Size()
- m.Type = 6
- m.AppAttach.FileExt = getFileExt(stat.Name())
- return m
+ m := &appmsg{AppId: appMessageAppId, Title: stat.Name()}
+ m.AppAttach.AttachId = attachId
+ m.AppAttach.TotalLen = stat.Size()
+ m.Type = 6
+ m.AppAttach.FileExt = getFileExt(stat.Name())
+ return m
}
// AppMessageData 获取APP消息的正文
// See https://github.com/eatmoreapple/openwechat/issues/62
type AppMessageData struct {
- XMLName xml.Name `xml:"msg"`
- AppMsg struct {
- Appid string `xml:"appid,attr"`
- SdkVer string `xml:"sdkver,attr"`
- Title string `xml:"title"`
- Des string `xml:"des"`
- Action string `xml:"action"`
- Type AppMessageType `xml:"type"`
- ShowType string `xml:"showtype"`
- Content string `xml:"content"`
- URL string `xml:"url"`
- DataUrl string `xml:"dataurl"`
- LowUrl string `xml:"lowurl"`
- LowDataUrl string `xml:"lowdataurl"`
- RecordItem string `xml:"recorditem"`
- ThumbUrl string `xml:"thumburl"`
- MessageAction string `xml:"messageaction"`
- Md5 string `xml:"md5"`
- ExtInfo string `xml:"extinfo"`
- SourceUsername string `xml:"sourceusername"`
- SourceDisplayName string `xml:"sourcedisplayname"`
- CommentUrl string `xml:"commenturl"`
- AppAttach struct {
- TotalLen string `xml:"totallen"`
- AttachId string `xml:"attachid"`
- EmoticonMd5 string `xml:"emoticonmd5"`
- FileExt string `xml:"fileext"`
- FileUploadToken string `xml:"fileuploadtoken"`
- OverwriteNewMsgId string `xml:"overwrite_newmsgid"`
- FileKey string `xml:"filekey"`
- CdnAttachUrl string `xml:"cdnattachurl"`
- AesKey string `xml:"aeskey"`
- EncryVer string `xml:"encryver"`
- } `xml:"appattach"`
- WeAppInfo struct {
- PagePath string `xml:"pagepath"`
- Username string `xml:"username"`
- Appid string `xml:"appid"`
- AppServiceType string `xml:"appservicetype"`
- } `xml:"weappinfo"`
- WebSearch string `xml:"websearch"`
- } `xml:"appmsg"`
- FromUsername string `xml:"fromusername"`
- Scene string `xml:"scene"`
- AppInfo struct {
- Version string `xml:"version"`
- AppName string `xml:"appname"`
- } `xml:"appinfo"`
- CommentUrl string `xml:"commenturl"`
+ XMLName xml.Name `xml:"msg"`
+ AppMsg struct {
+ Appid string `xml:"appid,attr"`
+ SdkVer string `xml:"sdkver,attr"`
+ Title string `xml:"title"`
+ Des string `xml:"des"`
+ Action string `xml:"action"`
+ Type AppMessageType `xml:"type"`
+ ShowType string `xml:"showtype"`
+ Content string `xml:"content"`
+ URL string `xml:"url"`
+ DataUrl string `xml:"dataurl"`
+ LowUrl string `xml:"lowurl"`
+ LowDataUrl string `xml:"lowdataurl"`
+ RecordItem string `xml:"recorditem"`
+ ThumbUrl string `xml:"thumburl"`
+ MessageAction string `xml:"messageaction"`
+ Md5 string `xml:"md5"`
+ ExtInfo string `xml:"extinfo"`
+ SourceUsername string `xml:"sourceusername"`
+ SourceDisplayName string `xml:"sourcedisplayname"`
+ CommentUrl string `xml:"commenturl"`
+ AppAttach struct {
+ TotalLen string `xml:"totallen"`
+ AttachId string `xml:"attachid"`
+ EmoticonMd5 string `xml:"emoticonmd5"`
+ FileExt string `xml:"fileext"`
+ FileUploadToken string `xml:"fileuploadtoken"`
+ OverwriteNewMsgId string `xml:"overwrite_newmsgid"`
+ FileKey string `xml:"filekey"`
+ CdnAttachUrl string `xml:"cdnattachurl"`
+ AesKey string `xml:"aeskey"`
+ EncryVer string `xml:"encryver"`
+ } `xml:"appattach"`
+ WeAppInfo struct {
+ PagePath string `xml:"pagepath"`
+ Username string `xml:"username"`
+ Appid string `xml:"appid"`
+ AppServiceType string `xml:"appservicetype"`
+ } `xml:"weappinfo"`
+ WebSearch string `xml:"websearch"`
+ } `xml:"appmsg"`
+ FromUsername string `xml:"fromusername"`
+ Scene string `xml:"scene"`
+ AppInfo struct {
+ Version string `xml:"version"`
+ AppName string `xml:"appname"`
+ } `xml:"appinfo"`
+ CommentUrl string `xml:"commenturl"`
}
// IsFromApplet 判断当前的消息类型是否来自小程序
func (a *AppMessageData) IsFromApplet() bool {
- return a.AppMsg.Appid != ""
+ return a.AppMsg.Appid != ""
}
// IsArticle 判断当前的消息类型是否为文章
func (a *AppMessageData) IsArticle() bool {
- return a.AppMsg.Type == AppMsgTypeUrl
+ return a.AppMsg.Type == AppMsgTypeUrl
}
// IsFile 判断当前的消息类型是否为文件
func (a AppMessageData) IsFile() bool {
- return a.AppMsg.Type == AppMsgTypeAttach
+ return a.AppMsg.Type == AppMsgTypeAttach
+}
+
+// IsComeFromGroup 判断消息是否来自群组
+// 可能是自己或者别的群员发送
+func (m *Message) IsComeFromGroup() bool {
+ return m.IsSendByGroup() || strings.HasPrefix(m.ToUserName, "@@")
}