-
Notifications
You must be signed in to change notification settings - Fork 7
/
syncmsg.go
100 lines (93 loc) · 3.87 KB
/
syncmsg.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
package WeChatCustomerServiceSDK
import (
"encoding/json"
"errors"
"fmt"
"github.com/NICEXAI/WeChatCustomerServiceSDK/syncmsg"
"github.com/NICEXAI/WeChatCustomerServiceSDK/util"
)
const (
//获取消息
syncMsgAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/sync_msg?access_token=%s"
)
// SyncMsgOptions 获取消息查询参数
type SyncMsgOptions struct {
Cursor string `json:"cursor"` // 上一次调用时返回的next_cursor,第一次拉取可以不填, 不多于64字节
Token string `json:"token"` // 回调事件返回的token字段,10分钟内有效;可不填,如果不填接口有严格的频率限制, 不多于128字节
Limit uint `json:"limit"` // 期望请求的数据量,默认值和最大值都为1000, 注意:可能会出现返回条数少于limit的情况,需结合返回的has_more字段判断是否继续请求。
}
// SyncMsgSchema 获取消息查询响应内容
type syncMsgSchema struct {
ErrCode int32 `json:"errcode"` // 返回码
ErrMsg string `json:"errmsg"` // 错误码描述
NextCursor string `json:"next_cursor"` // 下次调用带上该值,则从当前的位置继续往后拉,以实现增量拉取。强烈建议对改该字段入库保存,每次请求读取带上,请求结束后更新。避免因意外丢,导致必须从头开始拉取,引起消息延迟。
HasMore uint32 `json:"has_more"` // 是否还有更多数据。0-否;1-是。不能通过判断msg_list是否空来停止拉取,可能会出现has_more为1,而msg_list为空的情况
MsgList []map[string]interface{} `json:"msg_list"` // 消息列表
}
// SyncMsgSchema 获取消息查询响应内容
type SyncMsgSchema struct {
ErrCode int32 `json:"errcode"` // 返回码
ErrMsg string `json:"errmsg"` // 错误码描述
NextCursor string `json:"next_cursor"` // 下次调用带上该值则从该key值往后拉,用于增量拉取
HasMore uint32 `json:"has_more"` // 是否还有更多数据。0-否;1-是。不能通过判断msg_list是否空来停止拉取,可能会出现has_more为1,而msg_list为空的情况
MsgList []syncmsg.Message `json:"msg_list"` // 消息列表
}
// SyncMsg 获取消息
func (r *Client) SyncMsg(options SyncMsgOptions) (info SyncMsgSchema, err error) {
data, err := util.HttpPost(fmt.Sprintf(syncMsgAddr, r.accessToken), options)
if err != nil {
return info, err
}
fmt.Println(string(data))
originInfo := syncMsgSchema{}
if err = json.Unmarshal(data, &originInfo); err != nil {
return info, err
}
if originInfo.ErrCode != 0 {
return info, errors.New(originInfo.ErrMsg)
}
msgList := make([]syncmsg.Message, 0)
if len(originInfo.MsgList) > 0 {
for _, msg := range originInfo.MsgList {
newMsg := syncmsg.Message{}
if val, ok := msg["msgid"].(string); ok {
newMsg.MsgID = val
}
if val, ok := msg["open_kfid"].(string); ok {
newMsg.OpenKFID = val
}
if val, ok := msg["external_userid"].(string); ok {
newMsg.ExternalUserID = val
}
if val, ok := msg["send_time"].(float64); ok {
newMsg.SendTime = uint64(val)
}
if val, ok := msg["origin"].(float64); ok {
newMsg.Origin = uint32(val)
}
if val, ok := msg["msgtype"].(string); ok {
newMsg.MsgType = val
}
if newMsg.MsgType == "event" {
if event, ok := msg["event"].(map[string]interface{}); ok {
if eType, ok := event["event_type"].(string); ok {
newMsg.EventType = eType
}
}
}
originData, err := json.Marshal(msg)
if err != nil {
return info, err
}
newMsg.OriginData = originData
msgList = append(msgList, newMsg)
}
}
return SyncMsgSchema{
ErrCode: originInfo.ErrCode,
ErrMsg: originInfo.ErrMsg,
NextCursor: originInfo.NextCursor,
HasMore: originInfo.HasMore,
MsgList: msgList,
}, nil
}