实例化Redis新增dialOpts参数以支持redis更多拨号设置 (#475)

* 实例化Redis新dialOpts参数以支持redis更多拨号设置

* debug

* gofmt file

* remove go.mod empty line

Co-authored-by: Jerry <prc.tzy@gmail.com>

.github/workflows/go.yml

@@ -2,9 +2,9 @@ name: Go
 
 on:
   push:
-    branches: [ master,release-* ]
+    branches: [ master,release-*,v2 ]
   pull_request:
-    branches: [ master,release-* ]
+    branches: [ master,release-*,v2 ]
 
 jobs:
   golangci:

cache/redis.go

@@ -7,7 +7,7 @@ import (
 	"github.com/gomodule/redigo/redis"
 )
 
-//Redis redis cache
+// Redis .redis cache
 type Redis struct {
 	conn *redis.Pool
 }
@@ -23,16 +23,17 @@ type RedisOpts struct {
 }
 
 // NewRedis 实例化
-func NewRedis(opts *RedisOpts) *Redis {
+func NewRedis(opts *RedisOpts, dialOpts ...redis.DialOption) *Redis {
 	pool := &redis.Pool{
 		MaxActive:   opts.MaxActive,
 		MaxIdle:     opts.MaxIdle,
 		IdleTimeout: time.Second * time.Duration(opts.IdleTimeout),
 		Dial: func() (redis.Conn, error) {
-			return redis.Dial("tcp", opts.Host,
+			dialOpts = append(dialOpts, []redis.DialOption{
 				redis.DialDatabase(opts.Database),
 				redis.DialPassword(opts.Password),
-			)
+			}...)
+			return redis.Dial("tcp", opts.Host, dialOpts...)
 		},
 		TestOnBorrow: func(conn redis.Conn, t time.Time) error {
 			if time.Since(t) < time.Minute {

credential/default_access_token.go

@@ -56,15 +56,19 @@ type ResAccessToken struct {
 
 // GetAccessToken 获取access_token,先从cache中获取，没有则从服务端获取
 func (ak *DefaultAccessToken) GetAccessToken() (accessToken string, err error) {
+	// 先从cache中取
+	accessTokenCacheKey := fmt.Sprintf("%s_access_token_%s", ak.cacheKeyPrefix, ak.appID)
+	if val := ak.cache.Get(accessTokenCacheKey); val != nil {
+		return val.(string), nil
+	}
+
 	// 加上lock，是为了防止在并发获取token时，cache刚好失效，导致从微信服务器上获取到不同token
 	ak.accessTokenLock.Lock()
 	defer ak.accessTokenLock.Unlock()
 
-	accessTokenCacheKey := fmt.Sprintf("%s_access_token_%s", ak.cacheKeyPrefix, ak.appID)
+	// 双检，防止重复从微信服务器获取
-	val := ak.cache.Get(accessTokenCacheKey)
+	if val := ak.cache.Get(accessTokenCacheKey); val != nil {
-	if val != nil {
+		return val.(string), nil
-		accessToken = val.(string)
-		return
 	}
 
 	// cache失效，从微信服务器获取

credential/default_access_token_test.go

@@ -7,6 +7,7 @@ import (
 	"gopkg.in/h2non/gock.v1"
 )
 
+// TestGetTicketFromServer .
 func TestGetTicketFromServer(t *testing.T) {
 	defer gock.Off()
 	gock.New(getTicketURL).Reply(200).JSON(&ResTicket{Ticket: "mock-ticket", ExpiresIn: 10})

credential/default_js_ticket.go

@@ -10,7 +10,7 @@ import (
 	"github.com/silenceper/wechat/v2/util"
 )
 
-//获取ticket的url
+// getTicketURL 获取ticket的url
 const getTicketURL = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=%s&type=jsapi"
 
 // DefaultJsTicket 默认获取js ticket方法
@@ -42,16 +42,20 @@ type ResTicket struct {
 
 // GetTicket 获取jsapi_ticket
 func (js *DefaultJsTicket) GetTicket(accessToken string) (ticketStr string, err error) {
+	// 先从cache中取
+	jsAPITicketCacheKey := fmt.Sprintf("%s_jsapi_ticket_%s", js.cacheKeyPrefix, js.appID)
+	if val := js.cache.Get(jsAPITicketCacheKey); val != nil {
+		return val.(string), nil
+	}
+
 	js.jsAPITicketLock.Lock()
 	defer js.jsAPITicketLock.Unlock()
 
-	//先从cache中取
+	// 双检，防止重复从微信服务器获取
-	jsAPITicketCacheKey := fmt.Sprintf("%s_jsapi_ticket_%s", js.cacheKeyPrefix, js.appID)
+	if val := js.cache.Get(jsAPITicketCacheKey); val != nil {
-	val := js.cache.Get(jsAPITicketCacheKey)
+		return val.(string), nil
-	if val != nil {
-		ticketStr = val.(string)
-		return
 	}
+
 	var ticket ResTicket
 	ticket, err = GetTicketFromServer(accessToken)
 	if err != nil {

go.mod

@@ -5,7 +5,7 @@ go 1.14
 require (
 	github.com/bradfitz/gomemcache v0.0.0-20190913173617-a41fca850d0b
 	github.com/fatih/structs v1.1.0
-	github.com/gomodule/redigo v1.8.4
+	github.com/gomodule/redigo v1.8.5
 	github.com/kr/text v0.2.0 // indirect
 	github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e // indirect
 	github.com/sirupsen/logrus v1.8.1

go.sum

@@ -6,8 +6,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/fatih/structs v1.1.0 h1:Q7juDM0QtcnhCpeyLGQKyg4TOIghuNXrkL32pHAUMxo=
 github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M=
-github.com/gomodule/redigo v1.8.4 h1:Z5JUg94HMTR1XpwBaSH4vq3+PNSIykBLxMdglbw10gg=
+github.com/gomodule/redigo v1.8.5 h1:nRAxCa+SVsyjSBrtZmG/cqb6VbTmuRzpg/PoTFlpumc=
-github.com/gomodule/redigo v1.8.4/go.mod h1:P9dn9mFrCBvWhGE1wpxx6fgq7BAeLBk+UUUzlpkBYO0=
+github.com/gomodule/redigo v1.8.5/go.mod h1:P9dn9mFrCBvWhGE1wpxx6fgq7BAeLBk+UUUzlpkBYO0=
 github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542 h1:2VTzZjLZBgl62/EtslCrtky5vbi9dd7HrQPQIx6wqiw=
 github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542/go.mod h1:Ow0tF8D4Kplbc8s8sSb3V2oUCygFHVp8gC3Dn6U4MNI=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=

miniprogram/auth/auth.go

@@ -10,6 +10,8 @@ import (
 
 const (
 	code2SessionURL = "https://api.weixin.qq.com/sns/jscode2session?appid=%s&secret=%s&js_code=%s&grant_type=authorization_code"
+
+	checkEncryptedDataURL = "https://api.weixin.qq.com/wxa/business/checkencryptedmsg?access_token=%s"
 )
 
 // Auth 登录/用户信息
@@ -31,16 +33,21 @@ type ResCode2Session struct {
 	UnionID    string `json:"unionid"`     // 用户在开放平台的唯一标识符，在满足UnionID下发条件的情况下会返回
 }
 
+// RspCheckEncryptedData .
+type RspCheckEncryptedData struct {
+	util.CommonError
+
+	Vaild      bool `json:"vaild"`       // 是否是合法的数据
+	CreateTime uint `json:"create_time"` // 加密数据生成的时间戳
+}
+
 // Code2Session 登录凭证校验。
 func (auth *Auth) Code2Session(jsCode string) (result ResCode2Session, err error) {
-	urlStr := fmt.Sprintf(code2SessionURL, auth.AppID, auth.AppSecret, jsCode)
 	var response []byte
-	response, err = util.HTTPGet(urlStr)
+	if response, err = util.HTTPGet(fmt.Sprintf(code2SessionURL, auth.AppID, auth.AppSecret, jsCode)); err != nil {
-	if err != nil {
 		return
 	}
-	err = json.Unmarshal(response, &result)
+	if err = json.Unmarshal(response, &result); err != nil {
-	if err != nil {
 		return
 	}
 	if result.ErrCode != 0 {
@@ -54,3 +61,21 @@ func (auth *Auth) Code2Session(jsCode string) (result ResCode2Session, err error
 func (auth *Auth) GetPaidUnionID() {
 	// TODO
 }
+
+// CheckEncryptedData .检查加密信息是否由微信生成（当前只支持手机号加密数据），只能检测最近3天生成的加密数据
+func (auth *Auth) CheckEncryptedData(encryptedMsgHash string) (result RspCheckEncryptedData, err error) {
+	var response []byte
+	var (
+		at string
+	)
+	if at, err = auth.GetAccessToken(); err != nil {
+		return
+	}
+	if response, err = util.HTTPPost(fmt.Sprintf(checkEncryptedDataURL, at), "encrypted_msg_hash="+encryptedMsgHash); err != nil {
+		return
+	}
+	if err = util.DecodeWithError(response, &result, "CheckEncryptedDataAuth"); err != nil {
+		return
+	}
+	return
+}

miniprogram/config/config.go

@@ -5,7 +5,7 @@ import (
 	"github.com/silenceper/wechat/v2/cache"
 )
 
-// Config config for 小程序
+// Config .config for 小程序
 type Config struct {
 	AppID     string `json:"app_id"`     // appid
 	AppSecret string `json:"app_secret"` // appsecret

miniprogram/miniprogram.go

@@ -10,8 +10,10 @@ import (
 	"github.com/silenceper/wechat/v2/miniprogram/encryptor"
 	"github.com/silenceper/wechat/v2/miniprogram/message"
 	"github.com/silenceper/wechat/v2/miniprogram/qrcode"
+	"github.com/silenceper/wechat/v2/miniprogram/shortlink"
 	"github.com/silenceper/wechat/v2/miniprogram/subscribe"
 	"github.com/silenceper/wechat/v2/miniprogram/tcb"
+	"github.com/silenceper/wechat/v2/miniprogram/urllink"
 	"github.com/silenceper/wechat/v2/miniprogram/werun"
 )
 
@@ -84,3 +86,13 @@ func (miniProgram *MiniProgram) GetWeRun() *werun.WeRun {
 func (miniProgram *MiniProgram) GetContentSecurity() *content.Content {
 	return content.NewContent(miniProgram.ctx)
 }
+
+// GetURLLink 小程序URL Link接口
+func (miniProgram *MiniProgram) GetURLLink() *urllink.URLLink {
+	return urllink.NewURLLink(miniProgram.ctx)
+}
+
+// GetShortLink 小程序短链接口
+func (miniProgram *MiniProgram) GetShortLink() *shortlink.ShortLink {
+	return shortlink.NewShortLink(miniProgram.ctx)
+}

miniprogram/shortlink/shortlink.go

@@ -0,0 +1,86 @@
+package shortlink
+
+import (
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/miniprogram/context"
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	generateShortLinkURL = "https://api.weixin.qq.com/wxa/genwxashortlink?access_token=%s"
+)
+
+// ShortLink 短链接
+type ShortLink struct {
+	*context.Context
+}
+
+// NewShortLink 实例
+func NewShortLink(ctx *context.Context) *ShortLink {
+	return &ShortLink{ctx}
+}
+
+// ShortLinker 请求结构体
+type ShortLinker struct {
+
+	// pageUrl 通过 Short Link 进入的小程序页面路径，必须是已经发布的小程序存在的页面，可携带 query，最大1024个字符
+	PageURL string `json:"page_url"`
+
+	// pageTitle 页面标题，不能包含违法信息，超过20字符会用... 截断代替
+	PageTitle string `json:"page_title"`
+
+	// isPermanent 生成的 Short Link 类型，短期有效：false，永久有效：true
+	IsPermanent bool `json:"is_permanent,omitempty"`
+}
+
+// resShortLinker 返回结构体
+type resShortLinker struct {
+	// 通用错误
+	*util.CommonError
+
+	// 返回的 shortLink
+	Link string `json:"link"`
+}
+
+// Generate 生成 shortLink
+func (shortLink *ShortLink) generate(shortLinkParams ShortLinker) (string, error) {
+	var accessToken string
+	accessToken, err := shortLink.GetAccessToken()
+	if err != nil {
+		return "", err
+	}
+
+	urlStr := fmt.Sprintf(generateShortLinkURL, accessToken)
+	response, err := util.PostJSON(urlStr, shortLinkParams)
+	if err != nil {
+		return "", err
+	}
+
+	// 使用通用方法返回错误
+	var res resShortLinker
+	err = util.DecodeWithError(response, &res, "GenerateShortLink")
+	if err != nil {
+		return "", err
+	}
+
+	return res.Link, nil
+}
+
+// GenerateShortLinkPermanent 生成永久shortLink
+func (shortLink *ShortLink) GenerateShortLinkPermanent(PageURL, pageTitle string) (string, error) {
+	return shortLink.generate(ShortLinker{
+		PageURL:     PageURL,
+		PageTitle:   pageTitle,
+		IsPermanent: true,
+	})
+}
+
+// GenerateShortLinkTemp 生成临时shortLink
+func (shortLink *ShortLink) GenerateShortLinkTemp(PageURL, pageTitle string) (string, error) {
+	return shortLink.generate(ShortLinker{
+		PageURL:     PageURL,
+		PageTitle:   pageTitle,
+		IsPermanent: false,
+	})
+}

miniprogram/subscribe/subscribe.go

@@ -16,6 +16,14 @@ const (
 	// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subscribeMessage.getTemplateList.html
 	getTemplateURL = "https://api.weixin.qq.com/wxaapi/newtmpl/gettemplate"
 
+	// 添加订阅模板
+	// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subscribeMessage.addTemplate.html
+	addTemplateURL = "https://api.weixin.qq.com/wxaapi/newtmpl/addtemplate"
+
+	// 删除私有模板
+	// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subscribeMessage.deleteTemplate.html
+	delTemplateURL = "https://api.weixin.qq.com/wxaapi/newtmpl/deltemplate"
+
 	// 统一服务消息
 	// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/uniform-message/uniformMessage.send.html
 	uniformMessageSend = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/uniform_send"
@@ -133,3 +141,55 @@ func (s *Subscribe) UniformSend(msg *UniformMessage) (err error) {
 	}
 	return util.DecodeWithCommonError(response, "UniformSend")
 }
+
+type resSubscribeAdd struct {
+	util.CommonError
+
+	TemplateID string `json:"priTmplId"`
+}
+
+// Add 添加订阅消息模板
+func (s *Subscribe) Add(ShortID string, kidList []int, sceneDesc string) (templateID string, err error) {
+	var accessToken string
+	accessToken, err = s.GetAccessToken()
+	if err != nil {
+		return
+	}
+	var msg = struct {
+		TemplateIDShort string `json:"tid"`
+		SceneDesc       string `json:"sceneDesc"`
+		KidList         []int  `json:"kidList"`
+	}{TemplateIDShort: ShortID, SceneDesc: sceneDesc, KidList: kidList}
+	uri := fmt.Sprintf("%s?access_token=%s", addTemplateURL, accessToken)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
+	if err != nil {
+		return
+	}
+	var result resSubscribeAdd
+	err = util.DecodeWithError(response, &result, "AddSubscribe")
+	if err != nil {
+		return
+	}
+	templateID = result.TemplateID
+	return
+}
+
+// Delete 删除私有模板
+func (s *Subscribe) Delete(templateID string) (err error) {
+	var accessToken string
+	accessToken, err = s.GetAccessToken()
+	if err != nil {
+		return
+	}
+	var msg = struct {
+		TemplateID string `json:"priTmplId"`
+	}{TemplateID: templateID}
+	uri := fmt.Sprintf("%s?access_token=%s", delTemplateURL, accessToken)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
+	if err != nil {
+		return
+	}
+	return util.DecodeWithCommonError(response, "DeleteSubscribe")
+}

miniprogram/urllink/urllink.go

@@ -0,0 +1,70 @@
+package urllink
+
+import (
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/miniprogram/context"
+	"github.com/silenceper/wechat/v2/util"
+)
+
+// URLLink 小程序 URL Link
+type URLLink struct {
+	*context.Context
+}
+
+// NewURLLink 实例化
+func NewURLLink(ctx *context.Context) *URLLink {
+	return &URLLink{Context: ctx}
+}
+
+const generateURL = "https://api.weixin.qq.com/wxa/generate_urllink"
+
+// TExpireType 失效类型 (指定时间戳/指定间隔)
+type TExpireType int
+
+const (
+	// ExpireTypeTime 指定时间戳后失效
+	ExpireTypeTime TExpireType = 0
+
+	// ExpireTypeInterval 间隔指定天数后失效
+	ExpireTypeInterval TExpireType = 1
+)
+
+// ULParams 请求参数
+// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/url-link/urllink.generate.html#请求参数
+type ULParams struct {
+	Path           string      `json:"path"`
+	Query          string      `json:"query"`
+	IsExpire       bool        `json:"is_expire"`
+	ExpireType     TExpireType `json:"expire_type"`
+	ExpireTime     int64       `json:"expire_time"`
+	ExpireInterval int         `json:"expire_interval"`
+}
+
+// ULResult 返回的结果
+// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/url-link/urllink.generate.html#返回值
+type ULResult struct {
+	util.CommonError
+
+	URLLink string `json:"url_link"`
+}
+
+// Generate 生成url link
+func (u *URLLink) Generate(params *ULParams) (string, error) {
+	accessToken, err := u.GetAccessToken()
+	if err != nil {
+		return "", err
+	}
+
+	uri := fmt.Sprintf("%s?access_token=%s", generateURL, accessToken)
+	response, err := util.PostJSON(uri, params)
+	if err != nil {
+		return "", err
+	}
+	var resp ULResult
+	err = util.DecodeWithError(response, &resp, "URLLink.Generate")
+	if err != nil {
+		return "", err
+	}
+	return resp.URLLink, nil
+}

officialaccount/config/config.go

@@ -4,7 +4,7 @@ import (
 	"github.com/silenceper/wechat/v2/cache"
 )
 
-// Config config for 微信公众号
+// Config .config for 微信公众号
 type Config struct {
 	AppID          string `json:"app_id"`           // appid
 	AppSecret      string `json:"app_secret"`       // appsecret

officialaccount/message/subscribe.go

@@ -10,16 +10,18 @@ import (
 const (
 	subscribeSendURL         = "https://api.weixin.qq.com/cgi-bin/message/subscribe/bizsend"
 	subscribeTemplateListURL = "https://api.weixin.qq.com/wxaapi/newtmpl/gettemplate"
+	subscribeTemplateAddURL  = "https://api.weixin.qq.com/wxaapi/newtmpl/addtemplate"
+	subscribeTemplateDelURL  = "https://api.weixin.qq.com/wxaapi/newtmpl/deltemplate"
 )
 
-//Subscrib 订阅消息
+// Subscribe 订阅消息
-type Subscrib struct {
+type Subscribe struct {
 	*context.Context
 }
 
-//NewSubscrib 实例化
+// NewSubscribe 实例化
-func NewSubscrib(context *context.Context) *Subscrib {
+func NewSubscribe(context *context.Context) *Subscribe {
-	tpl := new(Subscrib)
+	tpl := new(Subscribe)
 	tpl.Context = context
 	return tpl
 }
@@ -42,7 +44,7 @@ type SubscribeDataItem struct {
 }
 
 // Send 发送订阅消息
-func (tpl *Subscrib) Send(msg *SubscribeMessage) (err error) {
+func (tpl *Subscribe) Send(msg *SubscribeMessage) (err error) {
 	var accessToken string
 	accessToken, err = tpl.GetAccessToken()
 	if err != nil {
@@ -53,11 +55,11 @@ func (tpl *Subscrib) Send(msg *SubscribeMessage) (err error) {
 	if err != nil {
 		return
 	}
-	return util.DecodeWithCommonError(response, "SendSubscribMessage")
+	return util.DecodeWithCommonError(response, "SendSubscribeMessage")
 }
 
-// PrivateSubscribItem 私有订阅消息模板
+// PrivateSubscribeItem 私有订阅消息模板
-type PrivateSubscribItem struct {
+type PrivateSubscribeItem struct {
 	PriTmplID string `json:"priTmplId"` //	添加至帐号下的模板 id，发送订阅通知时所需
 	Title     string `json:"title"`     // 模版标题
 	Content   string `json:"content"`   // 模版内容
@@ -65,13 +67,13 @@ type PrivateSubscribItem struct {
 	SubType   int    `json:"type"`      // 模版类型，2 为一次性订阅，3 为长期订阅
 }
 
-type resPrivateSubscribList struct {
+type resPrivateSubscribeList struct {
 	util.CommonError
-	SubscriptionList []*PrivateSubscribItem `json:"data"`
+	SubscriptionList []*PrivateSubscribeItem `json:"data"`
 }
 
 // List 获取私有订阅消息模板列表
-func (tpl *Subscrib) List() (templateList []*PrivateSubscribItem, err error) {
+func (tpl *Subscribe) List() (templateList []*PrivateSubscribeItem, err error) {
 	var accessToken string
 	accessToken, err = tpl.GetAccessToken()
 	if err != nil {
@@ -83,11 +85,63 @@ func (tpl *Subscrib) List() (templateList []*PrivateSubscribItem, err error) {
 	if err != nil {
 		return
 	}
-	var res resPrivateSubscribList
+	var res resPrivateSubscribeList
-	err = util.DecodeWithError(response, &res, "ListSubscription")
+	err = util.DecodeWithError(response, &res, "ListSubscribe")
 	if err != nil {
 		return
 	}
 	templateList = res.SubscriptionList
 	return
 }
+
+type resSubscribeAdd struct {
+	util.CommonError
+
+	TemplateID string `json:"priTmplId"`
+}
+
+// Add 添加订阅消息模板
+func (tpl *Subscribe) Add(ShortID string, kidList []int, sceneDesc string) (templateID string, err error) {
+	var accessToken string
+	accessToken, err = tpl.GetAccessToken()
+	if err != nil {
+		return
+	}
+	var msg = struct {
+		TemplateIDShort string `json:"tid"`
+		SceneDesc       string `json:"sceneDesc"`
+		KidList         []int  `json:"kidList"`
+	}{TemplateIDShort: ShortID, SceneDesc: sceneDesc, KidList: kidList}
+	uri := fmt.Sprintf("%s?access_token=%s", subscribeTemplateAddURL, accessToken)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
+	if err != nil {
+		return
+	}
+	var result resSubscribeAdd
+	err = util.DecodeWithError(response, &result, "AddSubscribe")
+	if err != nil {
+		return
+	}
+	templateID = result.TemplateID
+	return
+}
+
+// Delete 删除私有模板
+func (tpl *Subscribe) Delete(templateID string) (err error) {
+	var accessToken string
+	accessToken, err = tpl.GetAccessToken()
+	if err != nil {
+		return
+	}
+	var msg = struct {
+		TemplateID string `json:"priTmplId"`
+	}{TemplateID: templateID}
+	uri := fmt.Sprintf("%s?access_token=%s", subscribeTemplateDelURL, accessToken)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
+	if err != nil {
+		return
+	}
+	return util.DecodeWithCommonError(response, "DeleteSubscribe")
+}

officialaccount/message/template.go

@@ -11,6 +11,8 @@ import (
 const (
 	templateSendURL = "https://api.weixin.qq.com/cgi-bin/message/template/send"
 	templateListURL = "https://api.weixin.qq.com/cgi-bin/template/get_all_private_template"
+	templateAddURL  = "https://api.weixin.qq.com/cgi-bin/template/api_add_template"
+	templateDelURL  = "https://api.weixin.qq.com/cgi-bin/template/del_private_template"
 )
 
 // Template 模板消息
@@ -59,7 +61,8 @@ func (tpl *Template) Send(msg *TemplateMessage) (msgID int64, err error) {
 		return
 	}
 	uri := fmt.Sprintf("%s?access_token=%s", templateSendURL, accessToken)
-	response, err := util.PostJSON(uri, msg)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
 	if err != nil {
 		return
 	}
@@ -113,3 +116,55 @@ func (tpl *Template) List() (templateList []*TemplateItem, err error) {
 	templateList = res.TemplateList
 	return
 }
+
+type resTemplateAdd struct {
+	util.CommonError
+
+	TemplateID string `json:"template_id"`
+}
+
+// Add 添加模板.
+func (tpl *Template) Add(shortID string) (templateID string, err error) {
+	var accessToken string
+	accessToken, err = tpl.GetAccessToken()
+	if err != nil {
+		return
+	}
+	var msg = struct {
+		ShortID string `json:"template_id_short"`
+	}{ShortID: shortID}
+	uri := fmt.Sprintf("%s?access_token=%s", templateAddURL, accessToken)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
+	if err != nil {
+		return
+	}
+
+	var result resTemplateAdd
+	err = util.DecodeWithError(response, &result, "AddTemplate")
+	if err != nil {
+		return
+	}
+	templateID = result.TemplateID
+	return
+}
+
+// Delete 删除私有模板.
+func (tpl *Template) Delete(templateID string) (err error) {
+	var accessToken string
+	accessToken, err = tpl.GetAccessToken()
+	if err != nil {
+		return
+	}
+	var msg = struct {
+		TemplateID string `json:"template_id"`
+	}{TemplateID: templateID}
+
+	uri := fmt.Sprintf("%s?access_token=%s", templateDelURL, accessToken)
+	var response []byte
+	response, err = util.PostJSON(uri, msg)
+	if err != nil {
+		return
+	}
+	return util.DecodeWithCommonError(response, "DeleteTemplate")
+}

officialaccount/officialaccount.go

@@ -120,3 +120,8 @@ func (officialAccount *OfficialAccount) GetDataCube() *datacube.DataCube {
 func (officialAccount *OfficialAccount) GetOCR() *ocr.OCR {
 	return ocr.NewOCR(officialAccount.ctx)
 }
+
+// GetSubscribe 公众号订阅消息
+func (officialAccount *OfficialAccount) GetSubscribe() *message.Subscribe {
+	return message.NewSubscribe(officialAccount.ctx)
+}

openplatform/config/config.go

@@ -4,7 +4,7 @@ import (
 	"github.com/silenceper/wechat/v2/cache"
 )
 
-//Config config for 微信开放平台
+// Config .config for 微信开放平台
 type Config struct {
 	AppID          string `json:"app_id"`           // appid
 	AppSecret      string `json:"app_secret"`       // appsecret

pay/config/config.go

@@ -1,6 +1,6 @@
 package config
 
-// Config config for pay
+// Config .config for pay
 type Config struct {
 	AppID     string `json:"app_id"`
 	MchID     string `json:"mch_id"`

pay/notify/paid.go

@@ -30,6 +30,7 @@ type PaidResult struct {
 	OpenID             *string `xml:"openid"`
 	IsSubscribe        *string `xml:"is_subscribe"`
 	TradeType          *string `xml:"trade_type"`
+	TradeState         *string `xml:"trade_state"`
 	BankType           *string `xml:"bank_type"`
 	TotalFee           *int    `xml:"total_fee"`
 	SettlementTotalFee *int    `xml:"settlement_total_fee"`

pay/notify/refund.go

@@ -35,7 +35,7 @@ type RefundedReqInfo struct {
 	SettlementRefundFee *int    `xml:"settlement_refund_fee"`
 	RefundStatus        *string `xml:"refund_status"`
 	SuccessTime         *string `xml:"success_time"`
-	RefundRecvAccount   *string `xml:"refund_recv_account"`
+	RefundRecvAccount   *string `xml:"refund_recv_accout"`
 	RefundAccount       *string `xml:"refund_account"`
 	RefundRequestSource *string `xml:"refund_request_source"`
 }

pay/order/close.go

@@ -0,0 +1,98 @@
+package order
+
+import (
+	"encoding/xml"
+	"errors"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+// https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=9_3
+var closeGateway = "https://api.mch.weixin.qq.com/pay/closeorder"
+
+// CloseParams 传入的参数
+type CloseParams struct {
+	OutTradeNo string // 商户订单号
+	SignType   string // 签名类型
+}
+
+// closeRequest 接口请求参数
+type closeRequest struct {
+	AppID      string `xml:"appid"`               // 公众账号ID
+	MchID      string `xml:"mch_id"`              // 商户号
+	NonceStr   string `xml:"nonce_str"`           // 随机字符串
+	Sign       string `xml:"sign"`                // 签名
+	SignType   string `xml:"sign_type,omitempty"` // 签名类型
+	OutTradeNo string `xml:"out_trade_no"`        // 商户订单号
+}
+
+// CloseResult 关闭订单返回结果
+type CloseResult struct {
+	ReturnCode *string `xml:"return_code"`
+	ReturnMsg  *string `xml:"return_msg"`
+
+	AppID      *string `xml:"appid" json:"appid"`
+	MchID      *string `xml:"mch_id"`
+	NonceStr   *string `xml:"nonce_str"`
+	Sign       *string `xml:"sign"`
+	ResultCode *string `xml:"result_code"`
+	ResultMsg  *string `xml:"result_msg"`
+	ErrCode    *string `xml:"err_code"`
+	ErrCodeDes *string `xml:"err_code_des"`
+}
+
+// CloseOrder 关闭订单
+func (o *Order) CloseOrder(p *CloseParams) (closeResult CloseResult, err error) {
+	nonceStr := util.RandomStr(32)
+	// 签名类型
+	if p.SignType == "" {
+		p.SignType = "MD5"
+	}
+
+	params := make(map[string]string)
+	params["appid"] = o.AppID
+	params["mch_id"] = o.MchID
+	params["nonce_str"] = nonceStr
+	params["out_trade_no"] = p.OutTradeNo
+	params["sign_type"] = p.SignType
+
+	var (
+		sign   string
+		rawRet []byte
+	)
+
+	sign, err = util.ParamSign(params, o.Key)
+	if err != nil {
+		return
+	}
+	request := closeRequest{
+		AppID:      o.AppID,
+		MchID:      o.MchID,
+		NonceStr:   nonceStr,
+		Sign:       sign,
+		OutTradeNo: p.OutTradeNo,
+		SignType:   p.SignType,
+	}
+
+	rawRet, err = util.PostXML(closeGateway, request)
+	if err != nil {
+		return
+	}
+
+	err = xml.Unmarshal(rawRet, &closeResult)
+	if err != nil {
+		return
+	}
+
+	if *closeResult.ReturnCode == SUCCESS {
+		// close success
+		if *closeResult.ResultCode == SUCCESS {
+			err = nil
+			return
+		}
+		err = errors.New(*closeResult.ErrCode + *closeResult.ErrCodeDes)
+		return
+	}
+	err = errors.New("[msg : xmlUnmarshalError] [rawReturn : " + string(rawRet) + "] [sign : " + sign + "]")
+	return
+}

pay/order/pay.go

@@ -35,6 +35,7 @@ type Params struct {
 	CreateIP   string
 	Body       string
 	OutTradeNo string
+	TimeExpire string // 订单失效时间，格式为yyyyMMddHHmmss，如2009年12月27日9点10分10秒表示为20091227091010。
 	OpenID     string
 	TradeType  string
 	SignType   string
@@ -54,6 +55,17 @@ type Config struct {
 	PaySign   string `json:"paySign"`
 }
 
+// ConfigForApp 是传出用于 app sdk 用的参数
+type ConfigForApp struct {
+	AppID     string `json:"appid"`
+	MchID     string `json:"partnerid"` // 微信支付分配的商户号
+	PrePayID  string `json:"prepayid"`
+	Package   string `json:"package"`
+	NonceStr  string `json:"nonceStr"`
+	Timestamp string `json:"timestamp"`
+	Sign      string `json:"sign"`
+}
+
 // PreOrder 是 Unified order 接口的返回
 type PreOrder struct {
 	ReturnCode string `xml:"return_code"`
@@ -99,6 +111,27 @@ type payRequest struct {
 	XMLName struct{} `xml:"xml"`
 }
 
+func (req *payRequest) BridgePayRequest(p *Params, AppID, MchID, nonceStr, sign string) *payRequest {
+	request := payRequest{
+		AppID:          AppID,
+		MchID:          MchID,
+		NonceStr:       nonceStr,
+		Sign:           sign,
+		Body:           p.Body,
+		OutTradeNo:     p.OutTradeNo,
+		TotalFee:       p.TotalFee,
+		SpbillCreateIP: p.CreateIP,
+		NotifyURL:      p.NotifyURL,
+		TradeType:      p.TradeType,
+		OpenID:         p.OpenID,
+		SignType:       p.SignType,
+		Detail:         p.Detail,
+		Attach:         p.Attach,
+		GoodsTag:       p.GoodsTag,
+	}
+	return &request
+}
+
 // BridgeConfig get js bridge config
 func (o *Order) BridgeConfig(p *Params) (cfg Config, err error) {
 	var (
@@ -136,54 +169,87 @@ func (o *Order) BridgeConfig(p *Params) (cfg Config, err error) {
 	return
 }
 
+// BridgeAppConfig get app bridge config
+func (o *Order) BridgeAppConfig(p *Params) (cfg ConfigForApp, err error) {
+	var (
+		timestamp = strconv.FormatInt(time.Now().Unix(), 10)
+		noncestr  = util.RandomStr(32)
+		_package  = "Sign=WXPay"
+	)
+	order, err := o.PrePayOrder(p)
+	if err != nil {
+		return
+	}
+
+	result := map[string]string{
+		"appid":     order.AppID,
+		"partnerid": order.MchID,
+		"prepayid":  order.PrePayID,
+		"package":   _package,
+		"noncestr":  noncestr,
+		"timestamp": timestamp,
+	}
+	// 签名
+	sign, err := util.ParamSign(result, o.Key)
+	if err != nil {
+		return
+	}
+	result["sign"] = sign
+	cfg = ConfigForApp{
+		AppID:     result["appid"],
+		MchID:     result["partnerid"],
+		PrePayID:  result["prepayid"],
+		Package:   result["package"],
+		NonceStr:  result["noncestr"],
+		Timestamp: result["timestamp"],
+		Sign:      result["sign"],
+	}
+	return
+}
+
 // PrePayOrder return data for invoke wechat payment
 func (o *Order) PrePayOrder(p *Params) (payOrder PreOrder, err error) {
 	nonceStr := util.RandomStr(32)
-	notifyURL := o.NotifyURL
+
-	// 签名类型
-	if p.SignType == "" {
-		p.SignType = util.SignTypeMD5
-	}
 	// 通知地址
-	if p.NotifyURL != "" {
+	if len(p.NotifyURL) == 0 {
-		notifyURL = p.NotifyURL
+		p.NotifyURL = o.NotifyURL // 默认使用order.NotifyURL
+	}
+
+	param := map[string]string{
+		"appid":            o.AppID,
+		"body":             p.Body,
+		"mch_id":           o.MchID,
+		"nonce_str":        nonceStr,
+		"out_trade_no":     p.OutTradeNo,
+		"spbill_create_ip": p.CreateIP,
+		"total_fee":        p.TotalFee,
+		"trade_type":       p.TradeType,
+		"openid":           p.OpenID,
+		"sign_type":        p.SignType,
+		"detail":           p.Detail,
+		"attach":           p.Attach,
+		"goods_tag":        p.GoodsTag,
+		"notify_url":       p.NotifyURL,
+	}
+	// 签名类型
+	if param["sign_type"] == "" {
+		param["sign_type"] = util.SignTypeMD5
+	}
+
+	if p.TimeExpire != "" {
+		// 如果有传入交易结束时间
+		param["time_expire"] = p.TimeExpire
 	}
-	param := make(map[string]string)
-	param["appid"] = o.AppID
-	param["body"] = p.Body
-	param["mch_id"] = o.MchID
-	param["nonce_str"] = nonceStr
-	param["out_trade_no"] = p.OutTradeNo
-	param["spbill_create_ip"] = p.CreateIP
-	param["total_fee"] = p.TotalFee
-	param["trade_type"] = p.TradeType
-	param["openid"] = p.OpenID
-	param["sign_type"] = p.SignType
-	param["detail"] = p.Detail
-	param["attach"] = p.Attach
-	param["goods_tag"] = p.GoodsTag
-	param["notify_url"] = notifyURL
 
 	sign, err := util.ParamSign(param, o.Key)
 	if err != nil {
 		return
 	}
-	request := payRequest{
+	request := new(payRequest).BridgePayRequest(p, o.AppID, o.MchID, nonceStr, sign)
-		AppID:          o.AppID,
+	if len(p.TimeExpire) > 0 {
-		MchID:          o.MchID,
+		// 如果有传入交易结束时间
-		NonceStr:       nonceStr,
+		request.TimeExpire = p.TimeExpire
-		Sign:           sign,
-		Body:           p.Body,
-		OutTradeNo:     p.OutTradeNo,
-		TotalFee:       p.TotalFee,
-		SpbillCreateIP: p.CreateIP,
-		NotifyURL:      notifyURL,
-		TradeType:      p.TradeType,
-		OpenID:         p.OpenID,
-		SignType:       p.SignType,
-		Detail:         p.Detail,
-		Attach:         p.Attach,
-		GoodsTag:       p.GoodsTag,
 	}
 	rawRet, err := util.PostXML(payGateway, request)
 	if err != nil {

work/config/config.go

@@ -5,11 +5,14 @@ import (
 	"github.com/silenceper/wechat/v2/cache"
 )
 
-// Config config for 企业微信
+// Config for 企业微信
 type Config struct {
 	CorpID        string `json:"corp_id"`     // corp_id
 	CorpSecret    string `json:"corp_secret"` // corp_secret,如果需要获取会话存档实例，当前参数请填写聊天内容存档的Secret，可以在企业微信管理端--管理工具--聊天内容存档查看
 	AgentID       string `json:"agent_id"`    // agent_id
 	Cache         cache.Cache
 	RasPrivateKey string // 消息加密私钥，可以在企业微信管理端--管理工具--消息加密公钥查看对用公钥，私钥一般由自己保存
+
+	Token          string `json:"token"`            // 微信客服回调配置，用于生成签名校验回调请求的合法性
+	EncodingAESKey string `json:"encoding_aes_key"` // 微信客服回调p配置，用于解密回调消息内容对应的密文
 }

work/kf/README.md

@@ -0,0 +1,3 @@
+### 微信客服SDK
+
+相关文档正在梳理中...

work/kf/account.go

@@ -0,0 +1,189 @@
+package kf
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	//添加客服账号
+	accountAddAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/account/add?access_token=%s"
+	// 删除客服账号
+	accountDelAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/account/del?access_token=%s"
+	// 修改客服账号
+	accountUpdateAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/account/update?access_token=%s"
+	// 获取客服账号列表
+	accountListAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/account/list?access_token=%s"
+	//获取客服账号链接
+	addContactWayAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/add_contact_way?access_token=%s"
+)
+
+// AccountAddOptions 添加客服账号请求参数
+type AccountAddOptions struct {
+	Name    string `json:"name"`     // 客服帐号名称, 不多于16个字符
+	MediaID string `json:"media_id"` // 客服头像临时素材。可以调用上传临时素材接口获取, 不多于128个字节
+}
+
+// AccountAddSchema 添加客服账号响应内容
+type AccountAddSchema struct {
+	util.CommonError
+	OpenKFID string `json:"open_kfid"` // 新创建的客服张号ID
+}
+
+// AccountAdd 添加客服账号
+func (r *Client) AccountAdd(options AccountAddOptions) (info AccountAddSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(accountAddAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// AccountDelOptions 删除客服账号请求参数
+type AccountDelOptions struct {
+	OpenKFID string `json:"open_kfid"` // 客服帐号ID, 不多于64字节
+}
+
+// AccountDel 删除客服账号
+func (r *Client) AccountDel(options AccountDelOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(accountDelAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// AccountUpdateOptions 修改客服账号请求参数
+type AccountUpdateOptions struct {
+	OpenKFID string `json:"open_kfid"` // 客服帐号ID, 不多于64字节
+	Name     string `json:"name"`      // 客服帐号名称, 不多于16个字符
+	MediaID  string `json:"media_id"`  // 客服头像临时素材。可以调用上传临时素材接口获取, 不多于128个字节
+}
+
+// AccountUpdate 修复客服账号
+func (r *Client) AccountUpdate(options AccountUpdateOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(accountUpdateAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// AccountInfoSchema 客服详情
+type AccountInfoSchema struct {
+	OpenKFID string `json:"open_kfid"` // 客服帐号ID
+	Name     string `json:"name"`      // 客服帐号名称
+	Avatar   string `json:"avatar"`    // 客服头像URL
+}
+
+// AccountListSchema 获取客服账号列表响应内容
+type AccountListSchema struct {
+	util.CommonError
+	AccountList []AccountInfoSchema `json:"account_list"` // 客服账号列表
+}
+
+// AccountList 获取客服账号列表
+func (r *Client) AccountList() (info AccountListSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.HTTPGet(fmt.Sprintf(accountListAddr, accessToken))
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// AddContactWayOptions 获取客服账号链接
+// 1.若scene非空，返回的客服链接开发者可拼接scene_param=SCENE_PARAM参数使用，用户进入会话事件会将SCENE_PARAM原样返回。其中SCENE_PARAM需要urlencode，且长度不能超过128字节。
+// 如 https://work.weixin.qq.com/kf/kfcbf8f8d07ac7215f?enc_scene=ENCGFSDF567DF&scene_param=a%3D1%26b%3D2
+// 2.历史调用接口返回的客服链接（包含encScene=XXX参数），不支持scene_param参数。
+// 3.返回的客服链接，不能修改或复制参数到其他链接使用。否则进入会话事件参数校验不通过，导致无法回调。
+type AddContactWayOptions struct {
+	OpenKFID string `json:"open_kfid"` // 客服帐号ID, 不多于64字节
+	Scene    string `json:"scene"`     // 场景值，字符串类型，由开发者自定义, 不多于32字节, 字符串取值范围(正则表达式)：[0-9a-zA-Z_-]*
+}
+
+// AddContactWaySchema 获取客服账号链接响应内容
+type AddContactWaySchema struct {
+	util.CommonError
+	URL string `json:"url"` // 客服链接，开发者可将该链接嵌入到H5页面中，用户点击链接即可向对应的微信客服帐号发起咨询。开发者也可根据该url自行生成需要的二维码图片
+}
+
+// AddContactWay 获取客服账号链接
+func (r *Client) AddContactWay(options AddContactWayOptions) (info AddContactWaySchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(addContactWayAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}

work/kf/callback.go

@@ -0,0 +1,96 @@
+package kf
+
+import (
+	"encoding/xml"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+// SignatureOptions 微信服务器验证参数
+type SignatureOptions struct {
+	Signature string `form:"msg_signature"`
+	TimeStamp string `form:"timestamp"`
+	Nonce     string `form:"nonce"`
+	EchoStr   string `form:"echostr"`
+}
+
+// VerifyURL 验证请求参数是否合法并返回解密后的消息内容
+//  //Gin框架的使用示例
+//	r.GET("/v1/event/callback", func(c *gin.Context) {
+//		options := kf.SignatureOptions{}
+//		//获取回调的的校验参数
+//		if = c.ShouldBindQuery(&options); err != nil {
+//			c.String(http.StatusUnauthorized, "参数解析失败")
+//		}
+//		// 调用VerifyURL方法校验当前请求，如果合法则把解密后的内容作为响应返回给微信服务器
+//		echo, err := kfClient.VerifyURL(options)
+//		if err == nil {
+//			c.String(http.StatusOK, echo)
+//		} else {
+//			c.String(http.StatusUnauthorized, "非法请求来源")
+//		}
+//	})
+func (r *Client) VerifyURL(options SignatureOptions) (string, error) {
+	if options.Signature != util.Signature(r.ctx.Token, options.TimeStamp, options.Nonce, options.EchoStr) {
+		return "", NewSDKErr(40015)
+	}
+	_, bData, err := util.DecryptMsg(r.corpID, options.EchoStr, r.encodingAESKey)
+	if err != nil {
+		return "", NewSDKErr(40016)
+	}
+
+	return string(bData), nil
+}
+
+// 原始回调消息内容
+type callbackOriginMessage struct {
+	ToUserName string // 企业微信的CorpID，当为第三方套件回调事件时，CorpID的内容为suiteid
+	AgentID    string // 接收的应用id，可在应用的设置页面获取
+	Encrypt    string // 消息结构体加密后的字符串
+}
+
+// CallbackMessage 微信客服回调消息
+type CallbackMessage struct {
+	ToUserName string `json:"to_user_name"` // 微信客服组件ID
+	CreateTime int    `json:"create_time"`  // 消息创建时间，unix时间戳
+	MsgType    string `json:"msgtype"`      // 消息的类型，此时固定为 event
+	Event      string `json:"event"`        // 事件的类型，此时固定为 kf_msg_or_event
+	Token      string `json:"token"`        // 调用拉取消息接口时，需要传此token，用于校验请求的合法性
+}
+
+// GetCallbackMessage 获取回调事件中的消息内容
+//  //Gin框架的使用示例
+//	r.POST("/v1/event/callback", func(c *gin.Context) {
+//		var (
+//			message kf.CallbackMessage
+//			body []byte
+//		)
+//		// 读取原始消息内容
+//		body, err = c.GetRawData()
+//		if err != nil {
+//			c.String(http.StatusInternalServerError, err.Error())
+//			return
+//		}
+//		// 解析原始数据
+//		message, err = kfClient.GetCallbackMessage(body)
+//		if err != nil {
+//			c.String(http.StatusInternalServerError, "消息获取失败")
+//			return
+//		}
+//		fmt.Println(message)
+//		c.String(200, "ok")
+//	})
+func (r *Client) GetCallbackMessage(encryptedMsg []byte) (msg CallbackMessage, err error) {
+	var origin callbackOriginMessage
+	if err = xml.Unmarshal(encryptedMsg, &origin); err != nil {
+		return msg, err
+	}
+	_, bData, err := util.DecryptMsg(r.corpID, origin.Encrypt, r.encodingAESKey)
+	if err != nil {
+		return msg, NewSDKErr(40016)
+	}
+	if err = xml.Unmarshal(bData, &msg); err != nil {
+		return msg, err
+	}
+	return msg, err
+}

work/kf/client.go

@@ -0,0 +1,43 @@
+package kf
+
+import (
+	"github.com/silenceper/wechat/v2/cache"
+	"github.com/silenceper/wechat/v2/credential"
+	"github.com/silenceper/wechat/v2/work/config"
+	"github.com/silenceper/wechat/v2/work/context"
+)
+
+// Client 微信客服实例
+type Client struct {
+	corpID         string // 企业ID：企业开通的每个微信客服，都对应唯一的企业ID，企业可在微信客服管理后台的企业信息处查看
+	secret         string // Secret是微信客服用于校验开发者身份的访问密钥，企业成功注册微信客服后，可在「微信客服管理后台-开发配置」处获取
+	token          string // 用于生成签名校验回调请求的合法性
+	encodingAESKey string // 回调消息加解密参数是AES密钥的Base64编码，用于解密回调消息内容对应的密文
+	cache          cache.Cache
+	ctx            *context.Context
+}
+
+// NewClient 初始化微信客服实例
+func NewClient(cfg *config.Config) (client *Client, err error) {
+	if cfg.Cache == nil {
+		return nil, NewSDKErr(50001)
+	}
+
+	//初始化 AccessToken Handle
+	defaultAkHandle := credential.NewWorkAccessToken(cfg.CorpID, cfg.CorpSecret, credential.CacheKeyWorkPrefix, cfg.Cache)
+	ctx := &context.Context{
+		Config:            cfg,
+		AccessTokenHandle: defaultAkHandle,
+	}
+
+	client = &Client{
+		corpID:         cfg.CorpID,
+		secret:         cfg.CorpSecret,
+		token:          cfg.Token,
+		encodingAESKey: cfg.EncodingAESKey,
+		cache:          cfg.Cache,
+		ctx:            ctx,
+	}
+
+	return client, nil
+}

work/kf/customer.go

@@ -0,0 +1,56 @@
+package kf
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	customerBatchGetAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/customer/batchget?access_token=%s"
+)
+
+// CustomerBatchGetOptions 客户基本信息获取请求参数
+type CustomerBatchGetOptions struct {
+	ExternalUserIDList []string `json:"external_userid_list"` // external_userid列表
+}
+
+// CustomerSchema 微信客户基本资料
+type CustomerSchema struct {
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+	NickName       string `json:"nickname"`        // 微信昵称
+	Avatar         string `json:"avatar"`          // 微信头像。第三方不可获取
+	Gender         int    `json:"gender"`          // 性别
+	UnionID        string `json:"unionid"`         // unionid，需要绑定微信开发者帐号才能获取到，查看绑定方法: https://open.work.weixin.qq.com/kf/doc/92512/93143/94769#%E5%A6%82%E4%BD%95%E8%8E%B7%E5%8F%96%E5%BE%AE%E4%BF%A1%E5%AE%A2%E6%88%B7%E7%9A%84unionid
+}
+
+// CustomerBatchGetSchema 获取客户基本信息响应内容
+type CustomerBatchGetSchema struct {
+	util.CommonError
+	CustomerList          []CustomerSchema `json:"customer_list"`           // 微信客户信息列表
+	InvalidExternalUserID []string         `json:"invalid_external_userid"` // 无效的微信客户ID
+}
+
+// CustomerBatchGet 客户基本信息获取
+func (r *Client) CustomerBatchGet(options CustomerBatchGetOptions) (info CustomerBatchGetSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(customerBatchGetAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}

work/kf/error.go

@@ -0,0 +1,95 @@
+package kf
+
+import (
+	"reflect"
+	"strings"
+)
+
+// Error 错误
+type Error string
+
+const (
+	// SDKInitFailed 错误码：50001
+	SDKInitFailed Error = "SDK初始化失败"
+	// SDKCacheUnavailable 错误码：50002
+	SDKCacheUnavailable Error = "缓存无效"
+	// SDKUnknownError 错误码：50003
+	SDKUnknownError Error = "未知错误"
+	// SDKInvalidCredential 错误码：40001
+	SDKInvalidCredential Error = "不合法的secret参数"
+	// SDKInvalidCorpID 错误码：40013
+	SDKInvalidCorpID Error = "无效的 CorpID"
+	// SDKAccessTokenInvalid 错误码：40014
+	SDKAccessTokenInvalid Error = "AccessToken 无效"
+	// SDKValidateSignatureFailed 错误码：40015
+	SDKValidateSignatureFailed Error = "校验签名错误"
+	// SDKDecryptMSGFailed 错误码：40016
+	SDKDecryptMSGFailed Error = "消息解密失败"
+	// SDKAccessTokenMissing 错误码：41001
+	SDKAccessTokenMissing Error = "缺少AccessToken参数"
+	// SDKAccessTokenExpired 错误码：42001
+	SDKAccessTokenExpired Error = "AccessToken 已过期"
+	// SDKApiFreqOutOfLimit 错误码：45009
+	SDKApiFreqOutOfLimit Error = "接口请求次数超频"
+	// SDKApiForbidden 错误码：48002
+	SDKApiForbidden Error = "API 禁止调用"
+	// SDKInvalidOpenKFID 错误码：95000
+	SDKInvalidOpenKFID Error = "无效的 open_kfid"
+	// SDKOpenKFIDNotExist 错误码：95004
+	SDKOpenKFIDNotExist Error = "open_kfid 不存在"
+	// SDKWeWorkAlready 错误码：95011
+	SDKWeWorkAlready Error = "已在企业微信使用微信客服"
+	// SDKNotUseInWeCom 错误码：95012
+	SDKNotUseInWeCom Error = "未在企业微信使用微信客服"
+	// SDKApiNotOpen 错误码：95017
+	SDKApiNotOpen Error = "API 功能没有被开启"
+)
+
+//Error 输出错误信息
+func (r Error) Error() string {
+	return reflect.ValueOf(r).String()
+}
+
+// NewSDKErr 初始化SDK实例错误信息
+func NewSDKErr(code int64, msgList ...string) Error {
+	switch code {
+	case 50001:
+		return SDKInitFailed
+	case 50002:
+		return SDKCacheUnavailable
+	case 40001:
+		return SDKInvalidCredential
+	case 41001:
+		return SDKAccessTokenMissing
+	case 42001:
+		return SDKAccessTokenExpired
+	case 40013:
+		return SDKInvalidCorpID
+	case 40014:
+		return SDKAccessTokenInvalid
+	case 40015:
+		return SDKValidateSignatureFailed
+	case 40016:
+		return SDKDecryptMSGFailed
+	case 45009:
+		return SDKApiFreqOutOfLimit
+	case 48002:
+		return SDKApiForbidden
+	case 95000:
+		return SDKInvalidOpenKFID
+	case 95004:
+		return SDKOpenKFIDNotExist
+	case 95011:
+		return SDKWeWorkAlready
+	case 95012:
+		return SDKNotUseInWeCom
+	case 95017:
+		return SDKApiNotOpen
+	default:
+		//返回未知的自定义错误
+		if len(msgList) > 0 {
+			return Error(strings.Join(msgList, ","))
+		}
+		return SDKUnknownError
+	}
+}

work/kf/sendmsg.go

@@ -0,0 +1,42 @@
+package kf
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	//发送消息
+	sendMsgAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/send_msg?access_token=%s"
+)
+
+// SendMsgSchema 发送消息响应内容
+type SendMsgSchema struct {
+	util.CommonError
+	MsgID string `json:"msgid"` // 消息ID。如果请求参数指定了msgid，则原样返回，否则系统自动生成并返回。不多于32字节, 字符串取值范围(正则表达式)：[0-9a-zA-Z_-]*
+}
+
+// SendMsg 获取消息
+func (r *Client) SendMsg(options interface{}) (info SendMsgSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(sendMsgAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}

work/kf/sendmsg/message.go

@@ -0,0 +1,127 @@
+package sendmsg
+
+// Message 发送消息
+type Message struct {
+	ToUser   string `json:"touser"`    // 指定接收消息的客户UserID
+	OpenKFID string `json:"open_kfid"` // 指定发送消息的客服帐号ID
+	MsgID    string `json:"msgid"`     // 指定消息ID
+}
+
+// Text 发送文本消息
+type Text struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：text
+	Text    struct {
+		Content string `json:"content"` // 消息内容，最长不超过2048个字节
+	} `json:"text"` // 文本消息
+}
+
+// Image 发送图片消息
+type Image struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：image
+	Image   struct {
+		MediaID string `json:"media_id"` // 图片文件id，可以调用上传临时素材接口获取
+	} `json:"image"` // 图片消息
+}
+
+// Voice 发送语音消息
+type Voice struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：voice
+	Voice   struct {
+		MediaID string `json:"media_id"` // 语音文件id，可以调用上传临时素材接口获取
+	} `json:"voice"` // 语音消息
+}
+
+// Video 发送视频消息
+type Video struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：video
+	Video   struct {
+		MediaID string `json:"media_id"` // 视频文件id，可以调用上传临时素材接口获取
+	} `json:"video"` // 视频消息
+}
+
+// File 发送文件消息
+type File struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：file
+	File    struct {
+		MediaID string `json:"media_id"` // 文件id，可以调用上传临时素材接口获取
+	} `json:"file"` // 文件消息
+}
+
+// Link 图文链接消息
+type Link struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：link
+	Link    struct {
+		Title        string `json:"title"`          // 标题，不超过128个字节，超过会自动截断
+		Desc         string `json:"desc"`           // 描述，不超过512个字节，超过会自动截断
+		URL          string `json:"url"`            // 点击后跳转的链接。 最长2048字节，请确保包含了协议头(http/https)
+		ThumbMediaID string `json:"thumb_media_id"` // 缩略图的media_id, 可以通过素材管理接口获得。此处thumb_media_id即上传接口返回的media_id
+	} `json:"link"` // 链接消息
+}
+
+// MiniProgram 小程序消息
+type MiniProgram struct {
+	Message
+	MsgType     string `json:"msgtype"` // 消息类型，此时固定为：miniprogram
+	MiniProgram struct {
+		AppID        string `json:"appid"`          // 小程序appid，必须是关联到企业的小程序应用
+		Title        string `json:"title"`          // 小程序消息标题，最多64个字节，超过会自动截断
+		ThumbMediaID string `json:"thumb_media_id"` // 小程序消息封面的mediaid，封面图建议尺寸为520*416
+		PagePath     string `json:"pagepath"`       // 点击消息卡片后进入的小程序页面路径
+	} `json:"miniprogram"` // 小程序消息
+}
+
+// Menu 发送菜单消息
+type Menu struct {
+	Message
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：msgmenu
+	MsgMenu struct {
+		HeadContent string        `json:"head_content"` // 消息内容，不多于1024字节
+		List        []interface{} `json:"list"`         // 菜单项配置
+	} `json:"msgmenu"`
+}
+
+// MenuClick 回复菜单
+type MenuClick struct {
+	Type  string `json:"type"` // 菜单类型: click 回复菜单
+	Click struct {
+		ID      string `json:"id"`      // 菜单ID, 不少于1字节, 不多于64字节
+		Content string `json:"content"` // 菜单显示内容, 不少于1字节, 不多于128字节
+	} `json:"click"`
+}
+
+// MenuView 超链接菜单
+type MenuView struct {
+	Type string `json:"type"` // 菜单类型: view 超链接菜单
+	View struct {
+		URL     string `json:"url"`     // 点击后跳转的链接, 不少于1字节, 不多于2048字节
+		Content string `json:"content"` // 菜单显示内容, 不少于1字节, 不多于1024字节
+	} `json:"view"`
+}
+
+// MenuMiniProgram 小程序菜单
+type MenuMiniProgram struct {
+	Type        string `json:"type"` // 菜单类型: miniprogram 小程序菜单
+	MiniProgram struct {
+		AppID    string `json:"appid"`    // 小程序appid, 不少于1字节, 不多于32字节
+		PagePath string `json:"pagepath"` // 点击后进入的小程序页面, 不少于1字节, 不多于1024字节
+		Content  string `json:"content"`  // 菜单显示内容, 不少于1字节, 不多于1024字节
+	} `json:"miniprogram"`
+}
+
+// Location 地理位置消息
+type Location struct {
+	Message
+	MsgType  string `json:"msgtype"` // 消息类型，此时固定为：location
+	Location struct {
+		Latitude  float32 `json:"latitude"`  // 纬度, 浮点数，范围为90 ~ -90
+		Longitude float32 `json:"longitude"` // 经度, 浮点数，范围为180 ~ -180
+		Name      string  `json:"name"`      // 位置名
+		Address   string  `json:"address"`   // 地址详情说明
+	} `json:"location"`
+}

work/kf/sendmsg/sendmsg.go

@@ -0,0 +1 @@
+package sendmsg

work/kf/servicer.go

@@ -0,0 +1,110 @@
+package kf
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	//添加接待人员
+	receptionistAddAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/servicer/add?access_token=%s"
+	//删除接待人员
+	receptionistDelAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/servicer/del?access_token=%s"
+	//获取接待人员列表
+	receptionistListAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/servicer/list?access_token=%s&open_kfid=%s"
+)
+
+// ReceptionistOptions 添加接待人员请求参数
+type ReceptionistOptions struct {
+	OpenKFID   string   `json:"open_kfid"`   // 客服帐号ID
+	UserIDList []string `json:"userid_list"` // 接待人员userid列表。第三方应用填密文userid，即open_userid 可填充个数：1 ~ 100。超过100个需分批调用。
+}
+
+// ReceptionistSchema 添加接待人员响应内容
+type ReceptionistSchema struct {
+	util.CommonError
+	ResultList []struct {
+		UserID string `json:"userid"`
+		util.CommonError
+	} `json:"result_list"`
+}
+
+// ReceptionistAdd 添加接待人员
+func (r *Client) ReceptionistAdd(options ReceptionistOptions) (info ReceptionistSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(receptionistAddAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// ReceptionistDel 删除接待人员
+func (r *Client) ReceptionistDel(options ReceptionistOptions) (info ReceptionistSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(receptionistDelAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// ReceptionistListSchema 获取接待人员列表响应内容
+type ReceptionistListSchema struct {
+	util.CommonError
+	ReceptionistList []struct {
+		UserID string `json:"userid"` // 接待人员的userid。第三方应用获取到的为密文userid，即open_userid
+		Status int    `json:"status"` // 接待人员的接待状态。0:接待中,1:停止接待。第三方应用需具有“管理帐号、分配会话和收发消息”权限才可获取
+	} `json:"servicer_list"`
+}
+
+// ReceptionistList 获取接待人员列表
+func (r *Client) ReceptionistList(kfID string) (info ReceptionistListSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.HTTPGet(fmt.Sprintf(receptionistListAddr, accessToken, kfID))
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}

work/kf/servicestate.go

@@ -0,0 +1,88 @@
+package kf
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	// 获取会话状态
+	serviceStateGetAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/service_state/get?access_token=%s"
+	// 变更会话状态
+	serviceStateTransAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/service_state/trans?access_token=%s"
+)
+
+// ServiceStateGetOptions 获取会话状态请求参数
+type ServiceStateGetOptions struct {
+	OpenKFID       string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+}
+
+// ServiceStateGetSchema 获取会话状态响应内容
+type ServiceStateGetSchema struct {
+	util.CommonError
+	ServiceState  int    `json:"service_state"`  // 当前的会话状态，状态定义参考概述中的表格
+	ServiceUserID string `json:"service_userid"` // 接待人员的userid，仅当state=3时有效
+}
+
+// ServiceStateGet 获取会话状态
+// 0	未处理	新会话接入。可选择：1.直接用API自动回复消息。2.放进待接入池等待接待人员接待。3.指定接待人员进行接待
+// 1	由智能助手接待	可使用API回复消息。可选择转入待接入池或者指定接待人员处理。
+// 2	待接入池排队中	在待接入池中排队等待接待人员接入。可选择转为指定人员接待
+// 3	由人工接待	人工接待中。可选择结束会话
+// 4	已结束	会话已经结束或未开始。不允许变更会话状态，等待用户发起咨询
+// 注：一个微信用户向一个客服帐号发起咨询后，在48h内，或主动结束会话前（包括接待人员手动结束，或企业通过API结束会话），都算是一次会话
+func (r *Client) ServiceStateGet(options ServiceStateGetOptions) (info ServiceStateGetSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(serviceStateGetAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// ServiceStateTransOptions 变更会话状态请求参数
+type ServiceStateTransOptions struct {
+	OpenKFID       string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+	ServiceState   int    `json:"service_state"`   // 变更的目标状态，状态定义和所允许的变更可参考概述中的流程图和表格
+	ServicerUserID string `json:"servicer_userid"` // 接待人员的userid，当state=3时要求必填，接待人员须处于“正在接待”中
+}
+
+// ServiceStateTrans 变更会话状态
+func (r *Client) ServiceStateTrans(options ServiceStateTransOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(serviceStateTransAddr, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}

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"` // 下次调用带上该值，则从当前的位置继续往后拉，以实现增量拉取。强烈建议对改该字段入库保存，每次请求读取带上，请求结束后更新。避免因意外丢，导致必须从头开始拉取，引起消息延迟。
+	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
+}

work/kf/syncmsg/message.go

@@ -0,0 +1,162 @@
+package syncmsg
+
+// BaseMessage 接收消息
+type BaseMessage struct {
+	MsgID              string `json:"msgid"`           // 消息ID
+	OpenKFID           string `json:"open_kfid"`       // 客服帐号ID（msgtype为event，该字段不返回）
+	ExternalUserID     string `json:"external_userid"` // 客户UserID（msgtype为event，该字段不返回）
+	ReceptionistUserID string `json:"servicer_userid"` // 接待客服userID
+	SendTime           uint64 `json:"send_time"`       // 消息发送时间
+	Origin             uint32 `json:"origin"`          // 消息来源。3-微信客户发送的消息 4-系统推送的事件消息 5-接待人员在企业微信客户端发送的消息
+}
+
+// Text 文本消息
+type Text struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：text
+	Text    struct {
+		Content string `json:"content"` // 文本内容
+		MenuID  string `json:"menu_id"` // 客户点击菜单消息，触发的回复消息中附带的菜单ID
+	} `json:"text"` // 文本消息
+}
+
+// Image 图片消息
+type Image struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：image
+	Image   struct {
+		MediaID string `json:"media_id"` // 图片文件ID
+	} `json:"image"` // 图片消息
+}
+
+// Voice 语音消息
+type Voice struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：voice
+	Voice   struct {
+		MediaID string `json:"media_id"` // 语音文件ID
+	} `json:"voice"` // 语音消息
+}
+
+// Video 视频消息
+type Video struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：video
+	Video   struct {
+		MediaID string `json:"media_id"` // 文件ID
+	} `json:"video"` // 视频消息
+}
+
+// File 文件消息
+type File struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：file
+	File    struct {
+		MediaID string `json:"media_id"` // 文件ID
+	} `json:"file"` // 文件消息
+}
+
+// Location 地理位置消息
+type Location struct {
+	BaseMessage
+	MsgType  string `json:"msgtype"` // 消息类型，此时固定为：location
+	Location struct {
+		Latitude  float32 `json:"latitude"`  // 纬度
+		Longitude float32 `json:"longitude"` // 经度
+		Name      string  `json:"name"`      // 位置名
+		Address   string  `json:"address"`   // 地址详情说明
+	} `json:"location"` // 地理位置消息
+}
+
+// Link 链接消息
+type Link struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：link
+	Link    struct {
+		Title  string `json:"title"`   // 标题
+		Desc   string `json:"desc"`    // 描述
+		URL    string `json:"url"`     // 点击后跳转的链接
+		PicURL string `json:"pic_url"` // 缩略图链接
+	} `json:"link"` // 链接消息
+}
+
+// BusinessCard 名片消息
+type BusinessCard struct {
+	BaseMessage
+	MsgType      string `json:"msgtype"` // 消息类型，此时固定为：business_card
+	BusinessCard struct {
+		UserID string `json:"userid"` // 名片 userid
+	} `json:"business_card"` // 名片消息
+}
+
+// MiniProgram 小程序消息
+type MiniProgram struct {
+	BaseMessage
+	MsgType     string `json:"msgtype"` // 消息类型，此时固定为：miniprogram
+	MiniProgram struct {
+		AppID        string `json:"appid"`          // 小程序appid，必须是关联到企业的小程序应用
+		Title        string `json:"title"`          // 小程序消息标题，最多64个字节，超过会自动截断
+		ThumbMediaID string `json:"thumb_media_id"` // 小程序消息封面的mediaid，封面图建议尺寸为520*416
+		PagePath     string `json:"pagepath"`       // 点击消息卡片后进入的小程序页面路径
+	} `json:"miniprogram"` // 小程序消息
+}
+
+// EventMessage 事件消息
+type EventMessage struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：event
+	Event   struct {
+		EventType string `json:"event_type"` // 事件类型
+	} `json:"event"` // 事件消息
+}
+
+// EnterSessionEvent 用户进入会话事件
+type EnterSessionEvent struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：event
+	Event   struct {
+		EventType      string `json:"event_type"`      // 事件类型。此处固定为：enter_session
+		OpenKFID       string `json:"open_kfid"`       // 客服账号ID
+		ExternalUserID string `json:"external_userid"` // 客户UserID
+		Scene          string `json:"scene"`           // 进入会话的场景值，获取客服帐号链接开发者自定义的场景值
+		SceneParam     string `json:"scene_param"`     // 进入会话的自定义参数，获取客服帐号链接返回的url，开发者按规范拼接的scene_param参数
+	} `json:"event"` // 事件消息
+}
+
+// MsgSendFailEvent 消息发送失败事件
+type MsgSendFailEvent struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：event
+	Event   struct {
+		EventType      string `json:"event_type"`      // 事件类型。此处固定为：msg_send_fail
+		OpenKFID       string `json:"open_kfid"`       // 客服账号ID
+		ExternalUserID string `json:"external_userid"` // 客户UserID
+		FailMsgID      string `json:"fail_msgid"`      // 发送失败的消息msgid
+		FailType       uint32 `json:"fail_type"`       // 失败类型。0-未知原因 1-客服账号已删除 2-应用已关闭 4-会话已过期，超过48小时 5-会话已关闭 6-超过5条限制 7-未绑定视频号 8-主体未验证 9-未绑定视频号且主体未验证 10-用户拒收
+	} `json:"event"` // 事件消息
+}
+
+// ReceptionistStatusChangeEvent 客服人员接待状态变更事件
+type ReceptionistStatusChangeEvent struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：event
+	Event   struct {
+		EventType          string `json:"event_type"`      // 事件类型。此处固定为：servicer_status_change
+		ReceptionistUserID string `json:"servicer_userid"` // 客服人员userid
+		Status             uint32 `json:"status"`          // 状态类型。1-接待中 2-停止接待
+	} `json:"event"`
+}
+
+// SessionStatusChangeEvent 会话状态变更事件
+type SessionStatusChangeEvent struct {
+	BaseMessage
+	MsgType string `json:"msgtype"` // 消息类型，此时固定为：event
+	Event   struct {
+		EventType             string `json:"event_type"`          // 事件类型。此处固定为：session_status_change
+		OpenKFID              string `json:"open_kfid"`           // 客服账号ID
+		ExternalUserID        string `json:"external_userid"`     // 客户UserID
+		ChangeType            uint32 `json:"change_type"`         // 变更类型。1-从接待池接入会话 2-转接会话 3-结束会话
+		OldReceptionistUserID string `json:"old_servicer_userid"` // 老的客服人员userid。仅change_type为2和3有值
+		NewReceptionistUserID string `json:"new_servicer_userid"` // 新的客服人员userid。仅change_type为1和2有值
+	} `json:"event"` // 事件消息
+}

work/kf/syncmsg/syncmsg.go

@@ -0,0 +1,103 @@
+package syncmsg
+
+import "encoding/json"
+
+// Message 同步的消息内容
+type Message struct {
+	MsgID              string `json:"msgid"`           // 消息ID
+	OpenKFID           string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID     string `json:"external_userid"` // 客户UserID
+	ReceptionistUserID string `json:"servicer_userid"` // 接待客服userID
+	SendTime           uint64 `json:"send_time"`       // 消息发送时间
+	Origin             uint32 `json:"origin"`          // 消息来源。3-客户回复的消息 4-系统推送的消 息
+	MsgType            string `json:"msgtype"`         // 消息类型
+	EventType          string `json:"event_type"`      // 事件类型
+	OriginData         []byte `json:"origin_data"`     // 原始数据内容
+}
+
+// GetOriginMessage 获取原始消息
+func (r Message) GetOriginMessage() (info []byte) {
+	return r.OriginData
+}
+
+// GetTextMessage 获取文本消息
+func (r Message) GetTextMessage() (info Text, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetImageMessage 获取图片消息
+func (r Message) GetImageMessage() (info Image, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetVoiceMessage 获取语音消息
+func (r Message) GetVoiceMessage() (info Voice, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetVideoMessage 获取视频消息
+func (r Message) GetVideoMessage() (info Video, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetFileMessage 获取文件消息
+func (r Message) GetFileMessage() (info File, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetLocationMessage 获取文件消息
+func (r Message) GetLocationMessage() (info Location, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetLinkMessage 获取链接消息
+func (r Message) GetLinkMessage() (info Link, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetBusinessCardMessage 获取名片消息
+func (r Message) GetBusinessCardMessage() (info BusinessCard, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetMiniProgramMessage 获取小程序消息
+func (r Message) GetMiniProgramMessage() (info MiniProgram, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetEnterSessionEvent 用户进入会话事件
+func (r Message) GetEnterSessionEvent() (info EnterSessionEvent, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	info.OpenKFID = info.Event.OpenKFID
+	info.ExternalUserID = info.Event.ExternalUserID
+	return info, err
+}
+
+// GetMsgSendFailEvent 消息发送失败事件
+func (r Message) GetMsgSendFailEvent() (info MsgSendFailEvent, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetReceptionistStatusChangeEvent 客服人员接待状态变更事件
+func (r Message) GetReceptionistStatusChangeEvent() (info ReceptionistStatusChangeEvent, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	return info, err
+}
+
+// GetSessionStatusChangeEvent 会话状态变更事件
+func (r Message) GetSessionStatusChangeEvent() (info SessionStatusChangeEvent, err error) {
+	err = json.Unmarshal(r.OriginData, &info)
+	info.OpenKFID = info.Event.OpenKFID
+	info.ExternalUserID = info.Event.ExternalUserID
+	return info, err
+}

work/kf/upgrade.go

@@ -0,0 +1,187 @@
+package kf
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	//获取配置的专员与客户群
+	upgradeServiceConfigAddr = "https://qyapi.weixin.qq.com/cgi-bin/kf/customer/get_upgrade_service_config?access_token=%s"
+	// 为客户升级为专员或客户群服务
+	upgradeService = "https://qyapi.weixin.qq.com/cgi-bin/kf/customer/upgrade_service?access_token=%s"
+	//为客户取消推荐
+	upgradeServiceCancel = "https://qyapi.weixin.qq.com/cgi-bin/kf/customer/cancel_upgrade_service?access_token=%s"
+)
+
+// UpgradeServiceConfigSchema 获取配置的专员与客户群
+type UpgradeServiceConfigSchema struct {
+	util.CommonError
+	MemberRange struct {
+		UserIDList       []string `json:"userid_list"`        // 专员userid列表
+		DepartmentIDList []string `json:"department_id_list"` // 专员部门列表
+	} `json:"member_range"` // 专员服务配置范围
+	GroupChatRange struct {
+		ChatIDList []string `json:"chat_id_list"` // 客户群列表
+	} `json:"groupchat_range"` // 客户群配置范围
+}
+
+// UpgradeServiceConfig 获取配置的专员与客户群
+func (r *Client) UpgradeServiceConfig() (info UpgradeServiceConfigSchema, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.HTTPGet(fmt.Sprintf(upgradeServiceConfigAddr, accessToken))
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// UpgradeServiceOptions 为客户升级为专员或客户群服务请求参数
+type UpgradeServiceOptions struct {
+	OpenKFID       string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+	Type           int    `json:"type"`            // 表示是升级到专员服务还是客户群服务。1:专员服务。2:客户群服务
+	Member         struct {
+		UserID  string `json:"userid"`  // 服务专员的userid
+		Wording string `json:"wording"` // 推荐语
+	} `json:"member"` // 推荐的服务专员，type等于1时有效
+	GroupChat struct {
+		ChatID  string `json:"chat_id"` // 客户群id
+		Wording string `json:"wording"` // 推荐语
+	} `json:"groupchat"` // 推荐的客户群，type等于2时有效
+}
+
+// UpgradeService 为客户升级为专员或客户群服务
+func (r *Client) UpgradeService(options UpgradeServiceOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(upgradeService, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// UpgradeMemberServiceOptions 为客户升级为专员服务请求参数
+type UpgradeMemberServiceOptions struct {
+	OpenKFID       string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+	Type           int    `json:"type"`            // 表示是升级到专员服务还是客户群服务。1:专员服务
+	Member         struct {
+		UserID  string `json:"userid"`  // 服务专员的userid
+		Wording string `json:"wording"` // 推荐语
+	} `json:"member"` // 推荐的服务专员，type等于1时有效
+}
+
+// UpgradeMemberService 为客户升级为专员服务
+func (r *Client) UpgradeMemberService(options UpgradeMemberServiceOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(upgradeService, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// UpgradeServiceGroupChatOptions 为客户升级为客户群服务请求参数
+type UpgradeServiceGroupChatOptions struct {
+	OpenKFID       string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+	Type           int    `json:"type"`            // 表示是升级到专员服务还是客户群服务。2:客户群服务
+	GroupChat      struct {
+		ChatID  string `json:"chat_id"` // 客户群id
+		Wording string `json:"wording"` // 推荐语
+	} `json:"groupchat"` // 推荐的客户群，type等于2时有效
+}
+
+// UpgradeGroupChatService 为客户升级为客户群服务
+func (r *Client) UpgradeGroupChatService(options UpgradeServiceGroupChatOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(upgradeService, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}
+
+// UpgradeServiceCancelOptions 为客户取消推荐
+type UpgradeServiceCancelOptions struct {
+	OpenKFID       string `json:"open_kfid"`       // 客服帐号ID
+	ExternalUserID string `json:"external_userid"` // 微信客户的external_userid
+}
+
+// UpgradeServiceCancel 为客户取消推荐
+func (r *Client) UpgradeServiceCancel(options UpgradeServiceCancelOptions) (info util.CommonError, err error) {
+	var (
+		accessToken string
+		data        []byte
+	)
+	accessToken, err = r.ctx.GetAccessToken()
+	if err != nil {
+		return
+	}
+	data, err = util.PostJSON(fmt.Sprintf(upgradeServiceCancel, accessToken), options)
+	if err != nil {
+		return
+	}
+	if err = json.Unmarshal(data, &info); err != nil {
+		return
+	}
+	if info.ErrCode != 0 {
+		return info, NewSDKErr(info.ErrCode, info.ErrMsg)
+	}
+	return info, nil
+}

work/msgaudit/README.md

@@ -1,5 +1,6 @@
 企业微信会话存档SDK（基于企业微信C版官方SDK封装），暂时只支持在`linux`环境下使用当前SDK。
 
+
 ### 官方文档地址
 https://open.work.weixin.qq.com/api/doc/90000/90135/91774
 
@@ -10,6 +11,10 @@ https://open.work.weixin.qq.com/api/doc/90000/90135/91774
 
 2、从 `github.com/silenceper/wechat/v2/work/msgaudit/lib` 文件夹下复制 `libWeWorkFinanceSdk_C.so` 动态库文件到系统动态链接库默认文件夹下，或者复制到任意文件夹并在当前文件夹下执行 `export LD_LIBRARY_PATH=$(pwd)`命令设置动态链接库检索地址后即可正常使用
 
+3、编译要求
+- 开启CGO: `CGO_ENABLED=1`
+- 增加tags参数`msgaudit`： `go build -tags msgaudit`或者`go run -tags msgaudit main.go`
+
 ### Example
 
 ```go
@@ -30,7 +35,7 @@ func main() {
 	//初始化客户端
 	wechatClient := wechat.NewWechat()
 	
-	workClient := wechatClient.NewWork(&config.Config{
+	workClient := wechatClient.GetWork(&config.Config{
 		CorpID:        "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
 		CorpSecret:    "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
 		RasPrivateKey: "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",

work/msgaudit/client_linux.go

@@ -1,3 +1,7 @@
+//go:build linux && cgo && msgaudit
+// +build linux,cgo,msgaudit
+
+// Package msgaudit only for linux
 package msgaudit
 
 // #cgo LDFLAGS: -L${SRCDIR}/lib -lWeWorkFinanceSdk_C
@@ -7,9 +11,10 @@ package msgaudit
 import "C"
 import (
 	"encoding/json"
+	"unsafe"
+
 	"github.com/silenceper/wechat/v2/util"
 	"github.com/silenceper/wechat/v2/work/config"
-	"unsafe"
 )
 
 // Client 会话存档

work/msgaudit/client_unsupport.go

@@ -0,0 +1,20 @@
+//go:build !linux || !cgo || !msgaudit
+// +build !linux !cgo !msgaudit
+
+// Package msgaudit for unsupport platform
+package msgaudit
+
+import (
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/work/config"
+)
+
+// Client 会话存档
+type Client struct {
+}
+
+// NewClient new
+func NewClient(cfg *config.Config) (*Client, error) {
+	return nil, fmt.Errorf("会话存档功能目前只支持Linux平台运行，并且打开设置CGO_ENABLED=1")
+}

work/work.go

@@ -4,6 +4,7 @@ import (
 	"github.com/silenceper/wechat/v2/credential"
 	"github.com/silenceper/wechat/v2/work/config"
 	"github.com/silenceper/wechat/v2/work/context"
+	"github.com/silenceper/wechat/v2/work/kf"
 	"github.com/silenceper/wechat/v2/work/msgaudit"
 	"github.com/silenceper/wechat/v2/work/oauth"
 )
@@ -37,3 +38,8 @@ func (wk *Work) GetOauth() *oauth.Oauth {
 func (wk *Work) GetMsgAudit() (*msgaudit.Client, error) {
 	return msgaudit.NewClient(wk.ctx.Config)
 }
+
+// GetKF get kf
+func (wk *Work) GetKF() (*kf.Client, error) {
+	return kf.NewClient(wk.ctx.Config)
+}