添加微信客服SDK (#436)

* 添加微信客服SDK

* polish:优化签名函数

* polish：优化注释内容

* polish:复用已有的Token以及CommonError,移除无用的输出

* polish:复用已有的消息加解密

* fix:修复错误信息被覆盖的问题

* polish:go fmt 文件

work/kf/syncmsg.go

@@ -0,0 +1,108 @@
+package kf
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+	"github.com/silenceper/wechat/v2/work/kf/syncmsg"
+)
+
+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"` // 下次调用带上该值则从该key值往后拉，用于增量拉取
+	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) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(syncMsgAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	originInfo := syncMsgSchema{}
+	if err = json.Unmarshal(data, &originInfo); err != nil {
+		return
+	}
+	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
+}