调整结构体中CreateTime (#691)

* fix: 修改FollowInfo结构体中的tag标签为createtime

* fix: 统一CreateTime为int64

* chore: format

* chore: format

.github/workflows/go.yml

@@ -10,17 +10,21 @@ jobs:
   golangci:
     strategy:
       matrix:
-        go-version: [1.16.x,1.17.x,1.18.x]
+        go-version: [ '1.16','1.17','1.18','1.19','1.20' ]
     name: golangci-lint
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/setup-go@v3
-      - uses: actions/checkout@v3
+      - name: Setup Golang ${{ matrix.go-version }}
+        uses: actions/setup-go@v4
+        with:
+          go-version: ${{ matrix.go-version }}
+      - name: Checkout
+        uses: actions/checkout@v3
       - name: golangci-lint
-        uses: golangci/golangci-lint-action@v3.2.0
+        uses: golangci/golangci-lint-action@v3
         with:
           # Required: the version of golangci-lint is required and must be specified without patch version: we always use the latest patch version.
-          version: latest
+          version: v1.52.2
   build:
     name: Test
     runs-on: ubuntu-latest
@@ -28,7 +32,7 @@ jobs:
       redis:
         image: redis
         ports:
-        - 6379:6379
+          - 6379:6379
         options: --entrypoint redis-server
       memcached:
         image: memcached
@@ -38,14 +42,14 @@ jobs:
     # strategy set
     strategy:
       matrix:
-        go: ["1.16", "1.17", "1.18"]
+        go: [ '1.16','1.17','1.18','1.19','1.20' ]
 
     steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v3
       - name: Set up Go 1.x
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
           go-version: ${{ matrix.go }}
         id: go
       - name: Test
-        run: go test -v -race ./...
+        run: go test -v -race ./...

.github/workflows/release.yml

@@ -11,17 +11,17 @@ jobs:
     steps:
       -
         name: Checkout
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
         with:
           fetch-depth: 0
       -
         name: Set up Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.15
+          go-version: 1.16
       -
         name: Run GoReleaser
-        uses: goreleaser/goreleaser-action@v2
+        uses: goreleaser/goreleaser-action@v4
         with:
           version: latest
           args: release --rm-dist

credential/default_access_token.go

@@ -12,9 +12,11 @@ import (
 )
 
 const (
-	// AccessTokenURL 获取access_token的接口
+	// accessTokenURL 获取access_token的接口
 	accessTokenURL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"
-	// AccessTokenURL 企业微信获取access_token的接口
+	// stableAccessTokenURL 获取稳定版access_token的接口
+	stableAccessTokenURL = "https://api.weixin.qq.com/cgi-bin/stable_token"
+	// workAccessTokenURL 企业微信获取access_token的接口
 	workAccessTokenURL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=%s&corpsecret=%s"
 	// CacheKeyOfficialAccountPrefix 微信公众号cache key前缀
 	CacheKeyOfficialAccountPrefix = "gowechat_officialaccount_"
@@ -79,17 +81,87 @@ func (ak *DefaultAccessToken) GetAccessTokenContext(ctx context.Context) (access
 
 	// cache失效，从微信服务器获取
 	var resAccessToken ResAccessToken
-	resAccessToken, err = GetTokenFromServerContext(ctx, fmt.Sprintf(accessTokenURL, ak.appID, ak.appSecret))
+	if resAccessToken, err = GetTokenFromServerContext(ctx, fmt.Sprintf(accessTokenURL, ak.appID, ak.appSecret)); err != nil {
+		return
+	}
+
+	if err = ak.cache.Set(accessTokenCacheKey, resAccessToken.AccessToken, time.Duration(resAccessToken.ExpiresIn-1500)*time.Second); err != nil {
+		return
+	}
+	accessToken = resAccessToken.AccessToken
+	return
+}
+
+// StableAccessToken 获取稳定版接口调用凭据(与getAccessToken获取的调用凭证完全隔离，互不影响)
+// 不强制更新access_token,可用于不同环境不同服务而不需要分布式锁以及公用缓存，避免access_token争抢
+// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/mp-access-token/getStableAccessToken.html
+type StableAccessToken struct {
+	appID          string
+	appSecret      string
+	cacheKeyPrefix string
+	cache          cache.Cache
+}
+
+// NewStableAccessToken new StableAccessToken
+func NewStableAccessToken(appID, appSecret, cacheKeyPrefix string, cache cache.Cache) AccessTokenContextHandle {
+	if cache == nil {
+		panic("cache is need")
+	}
+	return &StableAccessToken{
+		appID:          appID,
+		appSecret:      appSecret,
+		cache:          cache,
+		cacheKeyPrefix: cacheKeyPrefix,
+	}
+}
+
+// GetAccessToken 获取access_token,先从cache中获取，没有则从服务端获取
+func (ak *StableAccessToken) GetAccessToken() (accessToken string, err error) {
+	return ak.GetAccessTokenContext(context.Background())
+}
+
+// GetAccessTokenContext 获取access_token,先从cache中获取，没有则从服务端获取
+func (ak *StableAccessToken) GetAccessTokenContext(ctx context.Context) (accessToken string, err error) {
+	// 先从cache中取
+	accessTokenCacheKey := fmt.Sprintf("%s_stable_access_token_%s", ak.cacheKeyPrefix, ak.appID)
+	if val := ak.cache.Get(accessTokenCacheKey); val != nil {
+		return val.(string), nil
+	}
+
+	// cache失效，从微信服务器获取
+	var resAccessToken ResAccessToken
+	resAccessToken, err = ak.GetAccessTokenDirectly(ctx, false)
 	if err != nil {
 		return
 	}
 
-	expires := resAccessToken.ExpiresIn - 1500
-	err = ak.cache.Set(accessTokenCacheKey, resAccessToken.AccessToken, time.Duration(expires)*time.Second)
+	expires := resAccessToken.ExpiresIn - 300
+	_ = ak.cache.Set(accessTokenCacheKey, resAccessToken.AccessToken, time.Duration(expires)*time.Second)
+
+	accessToken = resAccessToken.AccessToken
+	return
+}
+
+// GetAccessTokenDirectly 从微信获取access_token
+func (ak *StableAccessToken) GetAccessTokenDirectly(ctx context.Context, forceRefresh bool) (resAccessToken ResAccessToken, err error) {
+	b, err := util.PostJSONContext(ctx, stableAccessTokenURL, map[string]interface{}{
+		"grant_type":    "client_credential",
+		"appid":         ak.appID,
+		"secret":        ak.appSecret,
+		"force_refresh": forceRefresh,
+	})
 	if err != nil {
 		return
 	}
-	accessToken = resAccessToken.AccessToken
+
+	if err = json.Unmarshal(b, &resAccessToken); err != nil {
+		return
+	}
+
+	if resAccessToken.ErrCode != 0 {
+		err = fmt.Errorf("get stable access_token error : errcode=%v , errormsg=%v", resAccessToken.ErrCode, resAccessToken.ErrMsg)
+		return
+	}
 	return
 }
 

domain/openapi/mgnt.go

@@ -0,0 +1,36 @@
+package openapi
+
+import "github.com/silenceper/wechat/v2/util"
+
+// GetAPIQuotaParams 查询API调用额度参数
+type GetAPIQuotaParams struct {
+	CgiPath string `json:"cgi_path"` // api的请求地址，例如"/cgi-bin/message/custom/send";不要前缀“https://api.weixin.qq.com” ，也不要漏了"/",否则都会76003的报错
+}
+
+// APIQuota API调用额度
+type APIQuota struct {
+	util.CommonError
+	Quota struct {
+		DailyLimit int64 `json:"daily_limit"` // 当天该账号可调用该接口的次数
+		Used       int64 `json:"used"`        // 当天已经调用的次数
+		Remain     int64 `json:"remain"`      // 当天剩余调用次数
+	} `json:"quota"` // 详情
+}
+
+// GetRidInfoParams 查询rid信息参数
+type GetRidInfoParams struct {
+	Rid string `json:"rid"` // 调用接口报错返回的rid
+}
+
+// RidInfo rid信息
+type RidInfo struct {
+	util.CommonError
+	Request struct {
+		InvokeTime   int64  `json:"invoke_time"`   // 发起请求的时间戳
+		CostInMs     int64  `json:"cost_in_ms"`    // 请求毫秒级耗时
+		RequestURL   string `json:"request_url"`   // 请求的URL参数
+		RequestBody  string `json:"request_body"`  // post请求的请求参数
+		ResponseBody string `json:"response_body"` // 接口请求返回参数
+		ClientIP     string `json:"client_ip"`     // 接口请求的客户端ip
+	} `json:"request"` // 该rid对应的请求详情
+}

internal/openapi/mgnt.go

@@ -0,0 +1,127 @@
+package openapi
+
+import (
+	"errors"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/domain/openapi"
+	mpContext "github.com/silenceper/wechat/v2/miniprogram/context"
+	ocContext "github.com/silenceper/wechat/v2/officialaccount/context"
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	clearQuotaURL            = "https://api.weixin.qq.com/cgi-bin/clear_quota"       // 重置API调用次数
+	getAPIQuotaURL           = "https://api.weixin.qq.com/cgi-bin/openapi/quota/get" // 查询API调用额度
+	getRidInfoURL            = "https://api.weixin.qq.com/cgi-bin/openapi/rid/get"   // 查询rid信息
+	clearQuotaByAppSecretURL = "https://api.weixin.qq.com/cgi-bin/clear_quota/v2"    // 使用AppSecret重置 API 调用次数
+)
+
+// OpenAPI openApi管理
+type OpenAPI struct {
+	ctx interface{}
+}
+
+// NewOpenAPI 实例化
+func NewOpenAPI(ctx interface{}) *OpenAPI {
+	return &OpenAPI{ctx: ctx}
+}
+
+// ClearQuota 重置API调用次数
+// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/clearQuota.html
+func (o *OpenAPI) ClearQuota() error {
+	appID, _, err := o.getAppIDAndSecret()
+	if err != nil {
+		return err
+	}
+
+	var payload = struct {
+		AppID string `json:"appid"`
+	}{
+		AppID: appID,
+	}
+	res, err := o.doPostRequest(clearQuotaURL, payload)
+	if err != nil {
+		return err
+	}
+
+	return util.DecodeWithCommonError(res, "ClearQuota")
+}
+
+// GetAPIQuota 查询API调用额度
+// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/getApiQuota.html
+func (o *OpenAPI) GetAPIQuota(params openapi.GetAPIQuotaParams) (quota openapi.APIQuota, err error) {
+	res, err := o.doPostRequest(getAPIQuotaURL, params)
+	if err != nil {
+		return
+	}
+
+	err = util.DecodeWithError(res, &quota, "GetAPIQuota")
+	return
+}
+
+// GetRidInfo 查询rid信息
+// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/getRidInfo.html
+func (o *OpenAPI) GetRidInfo(params openapi.GetRidInfoParams) (r openapi.RidInfo, err error) {
+	res, err := o.doPostRequest(getRidInfoURL, params)
+	if err != nil {
+		return
+	}
+
+	err = util.DecodeWithError(res, &r, "GetRidInfo")
+	return
+}
+
+// ClearQuotaByAppSecret 使用AppSecret重置 API 调用次数
+// https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/openApi-mgnt/clearQuotaByAppSecret.html
+func (o *OpenAPI) ClearQuotaByAppSecret() error {
+	id, secret, err := o.getAppIDAndSecret()
+	if err != nil {
+		return err
+	}
+
+	uri := fmt.Sprintf("%s?appid=%s&appsecret=%s", clearQuotaByAppSecretURL, id, secret)
+	res, err := util.HTTPPost(uri, "")
+	if err != nil {
+		return err
+	}
+
+	return util.DecodeWithCommonError(res, "ClearQuotaByAppSecret")
+}
+
+// 获取 AppID 和 AppSecret
+func (o *OpenAPI) getAppIDAndSecret() (string, string, error) {
+	switch o.ctx.(type) {
+	case *mpContext.Context:
+		c := o.ctx.(*mpContext.Context)
+		return c.AppID, c.AppSecret, nil
+	case *ocContext.Context:
+		c := o.ctx.(*ocContext.Context)
+		return c.AppID, c.AppSecret, nil
+	default:
+		return "", "", errors.New("invalid context type")
+	}
+}
+
+// 获取 AccessToken
+func (o *OpenAPI) getAccessToken() (string, error) {
+	switch o.ctx.(type) {
+	case *mpContext.Context:
+		return o.ctx.(*mpContext.Context).GetAccessToken()
+	case *ocContext.Context:
+		return o.ctx.(*ocContext.Context).GetAccessToken()
+	default:
+		return "", errors.New("invalid context type")
+	}
+}
+
+// 创建 POST 请求
+func (o *OpenAPI) doPostRequest(uri string, payload interface{}) ([]byte, error) {
+	ak, err := o.getAccessToken()
+	if err != nil {
+		return nil, err
+	}
+
+	uri = fmt.Sprintf("%s?access_token=%s", uri, ak)
+	return util.PostJSON(uri, payload)
+}

miniprogram/auth/auth.go

@@ -40,8 +40,8 @@ type ResCode2Session struct {
 type RspCheckEncryptedData struct {
 	util.CommonError
 
-	Vaild      bool `json:"vaild"`       // 是否是合法的数据
-	CreateTime uint `json:"create_time"` // 加密数据生成的时间戳
+	Vaild      bool   `json:"vaild"`       // 是否是合法的数据
+	CreateTime uint64 `json:"create_time"` // 加密数据生成的时间戳
 }
 
 // Code2Session 登录凭证校验。

miniprogram/miniprogram.go

@@ -2,6 +2,7 @@ package miniprogram
 
 import (
 	"github.com/silenceper/wechat/v2/credential"
+	"github.com/silenceper/wechat/v2/internal/openapi"
 	"github.com/silenceper/wechat/v2/miniprogram/analysis"
 	"github.com/silenceper/wechat/v2/miniprogram/auth"
 	"github.com/silenceper/wechat/v2/miniprogram/business"
@@ -126,3 +127,8 @@ func (miniProgram *MiniProgram) GetShortLink() *shortlink.ShortLink {
 func (miniProgram *MiniProgram) GetSURLScheme() *urlscheme.URLScheme {
 	return urlscheme.NewURLScheme(miniProgram.ctx)
 }
+
+// GetOpenAPI openApi管理接口
+func (miniProgram *MiniProgram) GetOpenAPI() *openapi.OpenAPI {
+	return openapi.NewOpenAPI(miniProgram.ctx)
+}

officialaccount/message/message.go

@@ -123,6 +123,7 @@ type MixMessage struct {
 	Title         string  `xml:"Title"`
 	Description   string  `xml:"Description"`
 	URL           string  `xml:"Url"`
+	BizMsgMenuID  int64   `xml:"bizmsgmenuid"`
 
 	// 事件相关
 	Event       EventType `xml:"Event" json:"Event"`
@@ -195,6 +196,14 @@ type MixMessage struct {
 		LegalPersonaName   string `xml:"legal_persona_name"`
 		ComponentPhone     string `xml:"component_phone"`
 	} `xml:"info"`
+	ResultInfo struct {
+		APIName   string `xml:"api_name"`
+		ApplyTime string `xml:"apply_time"`
+		AuditID   string `xml:"audit_id"`
+		AuditTime string `xml:"audit_time"`
+		Reason    string `xml:"reason"`
+		Status    string `xml:"status"`
+	} `xml:"result_info"`
 
 	// 卡券相关
 	CardID              string `xml:"CardId"`
@@ -213,6 +222,10 @@ type MixMessage struct {
 	TraceID       string `xml:"trace_id"`
 	StatusCode    int    `xml:"status_code"`
 
+	//小程序名称审核结果事件推送
+	Ret      int32  `xml:"ret"`      //审核结果 2：失败，3：成功
+	NickName string `xml:"nickname"` //小程序昵称
+
 	// 设备相关
 	device.MsgDevice
 

officialaccount/officialaccount.go

@@ -4,6 +4,7 @@ import (
 	stdcontext "context"
 	"net/http"
 
+	"github.com/silenceper/wechat/v2/internal/openapi"
 	"github.com/silenceper/wechat/v2/officialaccount/draft"
 	"github.com/silenceper/wechat/v2/officialaccount/freepublish"
 	"github.com/silenceper/wechat/v2/officialaccount/ocr"
@@ -212,3 +213,8 @@ func (officialAccount *OfficialAccount) GetSubscribe() *message.Subscribe {
 func (officialAccount *OfficialAccount) GetCustomerServiceManager() *customerservice.Manager {
 	return customerservice.NewCustomerServiceManager(officialAccount.ctx)
 }
+
+// GetOpenAPI openApi管理接口
+func (officialAccount *OfficialAccount) GetOpenAPI() *openapi.OpenAPI {
+	return openapi.NewOpenAPI(officialAccount.ctx)
+}

officialaccount/user/user.go

@@ -2,6 +2,7 @@ package user
 
 import (
 	"encoding/json"
+	"errors"
 	"fmt"
 	"net/url"
 
@@ -10,9 +11,10 @@ import (
 )
 
 const (
-	userInfoURL     = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=%s&openid=%s&lang=zh_CN"
-	updateRemarkURL = "https://api.weixin.qq.com/cgi-bin/user/info/updateremark?access_token=%s"
-	userListURL     = "https://api.weixin.qq.com/cgi-bin/user/get"
+	userInfoURL      = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=%s&openid=%s&lang=zh_CN"
+	userInfoBatchURL = "https://api.weixin.qq.com/cgi-bin/user/info/batchget"
+	updateRemarkURL  = "https://api.weixin.qq.com/cgi-bin/user/info/updateremark?access_token=%s"
+	userListURL      = "https://api.weixin.qq.com/cgi-bin/user/get"
 )
 
 // User 用户管理
@@ -30,7 +32,11 @@ func NewUser(context *context.Context) *User {
 // Info 用户基本信息
 type Info struct {
 	util.CommonError
+	userInfo
+}
 
+// 用户基本信息
+type userInfo struct {
 	Subscribe      int32   `json:"subscribe"`
 	OpenID         string  `json:"openid"`
 	Nickname       string  `json:"nickname"`
@@ -88,6 +94,48 @@ func (user *User) GetUserInfo(openID string) (userInfo *Info, err error) {
 	return
 }
 
+// BatchGetUserInfoParams 批量获取用户基本信息参数
+type BatchGetUserInfoParams struct {
+	UserList []BatchGetUserListItem `json:"user_list"` // 需要批量获取基本信息的用户列表
+}
+
+// BatchGetUserListItem 需要获取基本信息的用户
+type BatchGetUserListItem struct {
+	OpenID string `json:"openid"` // 用户的标识，对当前公众号唯一
+	Lang   string `json:"lang"`   // 国家地区语言版本，zh_CN 简体，zh_TW 繁体，en 英语，默认为zh-CN
+}
+
+// InfoList 用户基本信息列表
+type InfoList struct {
+	util.CommonError
+	UserInfoList []userInfo `json:"user_info_list"`
+}
+
+// BatchGetUserInfo 批量获取用户基本信息
+func (user *User) BatchGetUserInfo(params BatchGetUserInfoParams) (*InfoList, error) {
+	if len(params.UserList) > 100 {
+		return nil, errors.New("params length must be less than or equal to 100")
+	}
+
+	ak, err := user.GetAccessToken()
+	if err != nil {
+		return nil, err
+	}
+
+	uri := fmt.Sprintf("%s?access_token=%s", userInfoBatchURL, ak)
+	res, err := util.PostJSON(uri, params)
+	if err != nil {
+		return nil, err
+	}
+
+	var data InfoList
+	err = util.DecodeWithError(res, &data, "BatchGetUserInfo")
+	if err != nil {
+		return nil, err
+	}
+	return &data, nil
+}
+
 // UpdateRemark 设置用户备注名
 func (user *User) UpdateRemark(openID, remark string) (err error) {
 	var accessToken string

openplatform/miniprogram/component/component.go

@@ -36,7 +36,7 @@ type RegisterMiniProgramParam struct {
 func (component *Component) RegisterMiniProgram(param *RegisterMiniProgramParam) error {
 	componentAK, err := component.GetComponentAccessToken()
 	if err != nil {
-		return nil
+		return err
 	}
 	url := fmt.Sprintf(fastregisterweappURL+"?action=create&component_access_token=%s", componentAK)
 	data, err := util.PostJSON(url, param)
@@ -58,7 +58,7 @@ type GetRegistrationStatusParam struct {
 func (component *Component) GetRegistrationStatus(param *GetRegistrationStatusParam) error {
 	componentAK, err := component.GetComponentAccessToken()
 	if err != nil {
-		return nil
+		return err
 	}
 	url := fmt.Sprintf(fastregisterweappURL+"?action=search&component_access_token=%s", componentAK)
 	data, err := util.PostJSON(url, param)

util/query.go

@@ -0,0 +1,24 @@
+package util
+
+import (
+	"fmt"
+	"strings"
+)
+
+// Query 将Map序列化为Query参数
+func Query(params map[string]interface{}) string {
+	finalString := make([]string, 0)
+	for key, value := range params {
+		valueString := ""
+		switch v := value.(type) {
+		case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
+			valueString = fmt.Sprintf("%d", v)
+		case bool:
+			valueString = fmt.Sprintf("%v", v)
+		default:
+			valueString = fmt.Sprintf("%s", v)
+		}
+		finalString = append(finalString, strings.Join([]string{key, valueString}, "="))
+	}
+	return strings.Join(finalString, "&")
+}

util/query_test.go

@@ -0,0 +1,19 @@
+package util
+
+import (
+	"testing"
+)
+
+// TestQuery query method test case
+func TestQuery(t *testing.T) {
+	result := Query(map[string]interface{}{
+		"age":  12,
+		"name": "Alan",
+		"cat":  "Peter",
+	})
+	if result == "" {
+		// 由于hash是乱序 所以没法很好的预测输出的字符串
+		// 将会输出符合Query规则的字符串 "age=12&name=Alan&cat=Peter"
+		t.Error("NOT PASS")
+	}
+}

util/template.go

@@ -0,0 +1,24 @@
+package util
+
+import (
+	"fmt"
+	"strings"
+)
+
+// Template 对字符串中的和map的key相同的字符串进行模板替换 仅支持 形如: {name}
+func Template(source string, data map[string]interface{}) string {
+	sourceCopy := &source
+	for k, val := range data {
+		valStr := ""
+		switch v := val.(type) {
+		case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
+			valStr = fmt.Sprintf("%d", v)
+		case bool:
+			valStr = fmt.Sprintf("%v", v)
+		default:
+			valStr = fmt.Sprintf("%s", v)
+		}
+		*sourceCopy = strings.Replace(*sourceCopy, strings.Join([]string{"{", k, "}"}, ""), valStr, 1)
+	}
+	return *sourceCopy
+}

util/template_test.go

@@ -0,0 +1,20 @@
+package util
+
+import (
+	"testing"
+)
+
+// TestTemplate testing case about Template method
+func TestTemplate(t *testing.T) {
+	result := Template("{name}={age};{with}={another};any={any};boolean={boolean}", map[string]interface{}{
+		"name":    "Helan",
+		"age":     "33",
+		"with":    "Pep",
+		"another": "C",
+		"any":     33,
+		"boolean": false,
+	})
+	if result != "Helan=33;Pep=C;any=33;boolean=false" {
+		t.Error("NOT PSS testing")
+	}
+}

work/addresslist/linkedcorp.go

@@ -0,0 +1,230 @@
+package addresslist
+
+import (
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	// getPermListURL 获取应用的可见范围
+	getPermListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/agent/get_perm_list?access_token=%s"
+	// getLinkedCorpUserURL 获取互联企业成员详细信息
+	getLinkedCorpUserURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/user/get?access_token=%s"
+	// linkedCorpSimpleListURL 获取互联企业部门成员
+	linkedCorpSimpleListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/user/simplelist?access_token=%s"
+	// linkedCorpUserListURL 获取互联企业部门成员详情
+	linkedCorpUserListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/user/list?access_token=%s"
+	// linkedCorpDepartmentListURL 获取互联企业部门列表
+	linkedCorpDepartmentListURL = "https://qyapi.weixin.qq.com/cgi-bin/linkedcorp/department/list?access_token=%s"
+)
+
+// GetPermListResponse 获取应用的可见范围响应
+type GetPermListResponse struct {
+	util.CommonError
+	UserIDs       []string `json:"userids"`
+	DepartmentIDs []string `json:"department_ids"`
+}
+
+// GetPermList 获取应用的可见范围
+// see https://developer.work.weixin.qq.com/document/path/93172
+func (r *Client) GetPermList() (*GetPermListResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.HTTPPost(fmt.Sprintf(getPermListURL, accessToken), ""); err != nil {
+		return nil, err
+	}
+	result := &GetPermListResponse{}
+	if err = util.DecodeWithError(response, result, "GetPermList"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// GetLinkedCorpUserRequest 获取互联企业成员详细信息请求
+type GetLinkedCorpUserRequest struct {
+	UserID string `json:"userid"`
+}
+
+// GetLinkedCorpUserResponse 获取互联企业成员详细信息响应
+type GetLinkedCorpUserResponse struct {
+	util.CommonError
+	UserInfo LinkedCorpUserInfo `json:"user_info"`
+}
+
+// LinkedCorpUserInfo 互联企业成员详细信息
+type LinkedCorpUserInfo struct {
+	UserID     string   `json:"userid"`
+	Name       string   `json:"name"`
+	Department []string `json:"department"`
+	Mobile     string   `json:"mobile"`
+	Telephone  string   `json:"telephone"`
+	Email      string   `json:"email"`
+	Position   string   `json:"position"`
+	CorpID     string   `json:"corpid"`
+	Extattr    Extattr  `json:"extattr"`
+}
+
+// Extattr 互联企业成员详细信息扩展属性
+type Extattr struct {
+	Attrs []ExtattrItem `json:"attrs"`
+}
+
+// ExtattrItem 互联企业成员详细信息扩展属性条目
+type ExtattrItem struct {
+	Name  string          `json:"name"`
+	Value string          `json:"value,omitempty"`
+	Type  int             `json:"type"`
+	Text  ExtattrItemText `json:"text,omitempty"`
+	Web   ExtattrItemWeb  `json:"web,omitempty"`
+}
+
+// ExtattrItemText 互联企业成员详细信息自定义属性(文本)
+type ExtattrItemText struct {
+	Value string `json:"value"`
+}
+
+// ExtattrItemWeb 互联企业成员详细信息自定义属性(网页)
+type ExtattrItemWeb struct {
+	URL   string `json:"url"`
+	Title string `json:"title"`
+}
+
+// GetLinkedCorpUser 获取互联企业成员详细信息
+// see https://developer.work.weixin.qq.com/document/path/93171
+func (r *Client) GetLinkedCorpUser(req *GetLinkedCorpUserRequest) (*GetLinkedCorpUserResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getLinkedCorpUserURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetLinkedCorpUserResponse{}
+	if err = util.DecodeWithError(response, result, "GetLinkedCorpUser"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// LinkedCorpSimpleListRequest 获取互联企业部门成员请求
+type LinkedCorpSimpleListRequest struct {
+	DepartmentID string `json:"department_id"`
+}
+
+// LinkedCorpSimpleListResponse 获取互联企业部门成员响应
+type LinkedCorpSimpleListResponse struct {
+	util.CommonError
+	Userlist []LinkedCorpUser `json:"userlist"`
+}
+
+// LinkedCorpUser 企业部门成员
+type LinkedCorpUser struct {
+	UserID     string   `json:"userid"`
+	Name       string   `json:"name"`
+	Department []string `json:"department"`
+	CorpID     string   `json:"corpid"`
+}
+
+// LinkedCorpSimpleList 获取互联企业部门成员
+// see https://developer.work.weixin.qq.com/document/path/93168
+func (r *Client) LinkedCorpSimpleList(req *LinkedCorpSimpleListRequest) (*LinkedCorpSimpleListResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(linkedCorpSimpleListURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &LinkedCorpSimpleListResponse{}
+	if err = util.DecodeWithError(response, result, "LinkedCorpSimpleList"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// LinkedCorpUserListRequest 获取互联企业部门成员详情请求
+type LinkedCorpUserListRequest struct {
+	DepartmentID string `json:"department_id"`
+}
+
+// LinkedCorpUserListResponse 获取互联企业部门成员详情响应
+type LinkedCorpUserListResponse struct {
+	util.CommonError
+	UserList []LinkedCorpUserInfo `json:"userlist"`
+}
+
+// LinkedCorpUserList 获取互联企业部门成员详情
+// see https://developer.work.weixin.qq.com/document/path/93169
+func (r *Client) LinkedCorpUserList(req *LinkedCorpUserListRequest) (*LinkedCorpUserListResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(linkedCorpUserListURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &LinkedCorpUserListResponse{}
+	if err = util.DecodeWithError(response, result, "LinkedCorpUserList"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// LinkedCorpDepartmentListRequest 获取互联企业部门列表请求
+type LinkedCorpDepartmentListRequest struct {
+	DepartmentID string `json:"department_id"`
+}
+
+// LinkedCorpDepartmentListResponse 获取互联企业部门列表响应
+type LinkedCorpDepartmentListResponse struct {
+	util.CommonError
+	DepartmentList []LinkedCorpDepartment `json:"department_list"`
+}
+
+// LinkedCorpDepartment 互联企业部门
+type LinkedCorpDepartment struct {
+	DepartmentID   string `json:"department_id"`
+	DepartmentName string `json:"department_name"`
+	ParentID       string `json:"parentid"`
+	Order          int    `json:"order"`
+}
+
+// LinkedCorpDepartmentList 获取互联企业部门列表
+// see https://developer.work.weixin.qq.com/document/path/93170
+func (r *Client) LinkedCorpDepartmentList(req *LinkedCorpDepartmentListRequest) (*LinkedCorpDepartmentListResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(linkedCorpDepartmentListURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &LinkedCorpDepartmentListResponse{}
+	if err = util.DecodeWithError(response, result, "LinkedCorpDepartmentList"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}

work/addresslist/tag.go

@@ -13,6 +13,14 @@ const (
 	updateTagURL = "https://qyapi.weixin.qq.com/cgi-bin/tag/update?access_token=%s"
 	// deleteTagURL 删除标签
 	deleteTagURL = "https://qyapi.weixin.qq.com/cgi-bin/tag/delete?access_token=%s&tagid=%d"
+	// getTagURL 获取标签成员
+	getTagURL = "https://qyapi.weixin.qq.com/cgi-bin/tag/get?access_token=%s&tagid=%d"
+	// addTagUsersURL 增加标签成员
+	addTagUsersURL = "https://qyapi.weixin.qq.com/cgi-bin/tag/addtagusers?access_token=%s"
+	// delTagUsersURL 删除标签成员
+	delTagUsersURL = "https://qyapi.weixin.qq.com/cgi-bin/tag/deltagusers?access_token=%s"
+	// listTagURL 获取标签列表
+	listTagURL = "https://qyapi.weixin.qq.com/cgi-bin/tag/list?access_token=%s"
 )
 
 type (
@@ -90,3 +98,145 @@ func (r *Client) DeleteTag(tagID int) error {
 	}
 	return util.DecodeWithCommonError(response, "DeleteTag")
 }
+
+type (
+	// GetTagResponse 获取标签成员响应
+	GetTagResponse struct {
+		util.CommonError
+		TagName   string           `json:"tagname"`
+		UserList  []GetTagUserList `json:"userlist"`
+		PartyList []int            `json:"partylist"`
+	}
+	// GetTagUserList 标签中包含的成员列表
+	GetTagUserList struct {
+		UserID string `json:"userid"`
+		Name   string `json:"name"`
+	}
+)
+
+// GetTag 获取标签成员
+// @see https://developer.work.weixin.qq.com/document/path/90213
+func (r *Client) GetTag(tagID int) (*GetTagResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.HTTPGet(fmt.Sprintf(getTagURL, accessToken, tagID)); err != nil {
+		return nil, err
+	}
+	result := &GetTagResponse{}
+	if err = util.DecodeWithError(response, result, "GetTag"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+type (
+	// AddTagUsersRequest 增加标签成员请求
+	AddTagUsersRequest struct {
+		TagID     int      `json:"tagid"`
+		UserList  []string `json:"userlist"`
+		PartyList []int    `json:"partylist"`
+	}
+	// AddTagUsersResponse 增加标签成员响应
+	AddTagUsersResponse struct {
+		util.CommonError
+		InvalidList  string `json:"invalidlist"`
+		InvalidParty []int  `json:"invalidparty"`
+	}
+)
+
+// AddTagUsers 增加标签成员
+// see https://developer.work.weixin.qq.com/document/path/90214
+func (r *Client) AddTagUsers(req *AddTagUsersRequest) (*AddTagUsersResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(addTagUsersURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &AddTagUsersResponse{}
+	if err = util.DecodeWithError(response, result, "AddTagUsers"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+type (
+	// DelTagUsersRequest 删除标签成员请求
+	DelTagUsersRequest struct {
+		TagID     int      `json:"tagid"`
+		UserList  []string `json:"userlist"`
+		PartyList []int    `json:"partylist"`
+	}
+	// DelTagUsersResponse 删除标签成员响应
+	DelTagUsersResponse struct {
+		util.CommonError
+		InvalidList  string `json:"invalidlist"`
+		InvalidParty []int  `json:"invalidparty"`
+	}
+)
+
+// DelTagUsers 删除标签成员
+// see https://developer.work.weixin.qq.com/document/path/90215
+func (r *Client) DelTagUsers(req *DelTagUsersRequest) (*DelTagUsersResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(delTagUsersURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &DelTagUsersResponse{}
+	if err = util.DecodeWithError(response, result, "DelTagUsers"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+type (
+	// ListTagResponse 获取标签列表响应
+	ListTagResponse struct {
+		util.CommonError
+		TagList []Tag `json:"taglist"`
+	}
+	// Tag 标签
+	Tag struct {
+		TagID   int    `json:"tagid"`
+		TagName string `json:"tagname"`
+	}
+)
+
+// ListTag 获取标签列表
+// @see https://developer.work.weixin.qq.com/document/path/90216
+func (r *Client) ListTag() (*ListTagResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.HTTPGet(fmt.Sprintf(listTagURL, accessToken)); err != nil {
+		return nil, err
+	}
+	result := &ListTagResponse{}
+	if err = util.DecodeWithError(response, result, "ListTag"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}

work/addresslist/user.go

@@ -1,18 +1,22 @@
 package addresslist
 
 import (
-	"fmt"
+	"strings"
 
 	"github.com/silenceper/wechat/v2/util"
 )
 
 const (
 	// userSimpleListURL 获取部门成员
-	userSimpleListURL = "https://qyapi.weixin.qq.com/cgi-bin/user/simplelist?access_token=%s&department_id=%d"
+	userSimpleListURL = "https://qyapi.weixin.qq.com/cgi-bin/user/simplelist"
 	// userGetURL 读取成员
-	userGetURL = "https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token=%s&userid=%s"
+	userGetURL = "https://qyapi.weixin.qq.com/cgi-bin/user/get"
 	// userListIDURL 获取成员ID列表
-	userListIDURL = "https://qyapi.weixin.qq.com/cgi-bin/user/list_id?access_token=%s"
+	userListIDURL = "https://qyapi.weixin.qq.com/cgi-bin/user/list_id"
+	// convertToOpenIDURL userID转openID
+	convertToOpenIDURL = "https://qyapi.weixin.qq.com/cgi-bin/user/convert_to_openid"
+	// convertToUserIDURL openID转userID
+	convertToUserIDURL = "https://qyapi.weixin.qq.com/cgi-bin/user/convert_to_userid"
 )
 
 type (
@@ -41,7 +45,13 @@ func (r *Client) UserSimpleList(departmentID int) ([]*UserList, error) {
 		return nil, err
 	}
 	var response []byte
-	if response, err = util.HTTPGet(fmt.Sprintf(userSimpleListURL, accessToken, departmentID)); err != nil {
+	if response, err = util.HTTPGet(strings.Join([]string{
+		userSimpleListURL,
+		util.Query(map[string]interface{}{
+			"access_token":  accessToken,
+			"department_id": departmentID,
+		}),
+	}, "?")); err != nil {
 		return nil, err
 	}
 	result := &UserSimpleListResponse{}
@@ -125,7 +135,15 @@ func (r *Client) UserGet(UserID string) (*UserGetResponse, error) {
 		return nil, err
 	}
 	var response []byte
-	if response, err = util.HTTPGet(fmt.Sprintf(userGetURL, accessToken, UserID)); err != nil {
+
+	if response, err = util.HTTPGet(
+		strings.Join([]string{
+			userGetURL,
+			util.Query(map[string]interface{}{
+				"access_token":  accessToken,
+				"department_id": UserID,
+			}),
+		}, "?")); err != nil {
 		return nil, err
 	}
 	result := &UserGetResponse{}
@@ -166,7 +184,12 @@ func (r *Client) UserListID(req *UserListIDRequest) (*UserListIDResponse, error)
 		return nil, err
 	}
 	var response []byte
-	if response, err = util.PostJSON(fmt.Sprintf(userListIDURL, accessToken), req); err != nil {
+	if response, err = util.PostJSON(strings.Join([]string{
+		userListIDURL,
+		util.Query(map[string]interface{}{
+			"access_token": accessToken,
+		}),
+	}, "?"), req); err != nil {
 		return nil, err
 	}
 	result := &UserListIDResponse{}
@@ -175,3 +198,87 @@ func (r *Client) UserListID(req *UserListIDRequest) (*UserListIDResponse, error)
 	}
 	return result, nil
 }
+
+type (
+	// convertToOpenIDRequest userID转openID请求
+	convertToOpenIDRequest struct {
+		UserID string `json:"userid"`
+	}
+
+	// convertToOpenIDResponse userID转openID响应
+	convertToOpenIDResponse struct {
+		util.CommonError
+		OpenID string `json:"openid"`
+	}
+)
+
+// ConvertToOpenID userID转openID
+// see https://developer.work.weixin.qq.com/document/path/90202
+func (r *Client) ConvertToOpenID(userID string) (string, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return "", err
+	}
+	var response []byte
+
+	if response, err = util.PostJSON(strings.Join([]string{
+		convertToOpenIDURL,
+		util.Query(map[string]interface{}{
+			"access_token": accessToken,
+		}),
+	}, "?"), &convertToOpenIDRequest{
+		UserID: userID,
+	}); err != nil {
+		return "", err
+	}
+	result := &convertToOpenIDResponse{}
+	if err = util.DecodeWithError(response, result, "ConvertToOpenID"); err != nil {
+		return "", err
+	}
+	return result.OpenID, nil
+}
+
+type (
+	// convertToUserIDRequest openID转userID请求
+	convertToUserIDRequest struct {
+		OpenID string `json:"openid"`
+	}
+
+	// convertToUserIDResponse openID转userID响应
+	convertToUserIDResponse struct {
+		util.CommonError
+		UserID string `json:"userid"`
+	}
+)
+
+// ConvertToUserID openID转userID
+// see https://developer.work.weixin.qq.com/document/path/90202
+func (r *Client) ConvertToUserID(openID string) (string, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return "", err
+	}
+	var response []byte
+
+	if response, err = util.PostJSON(strings.Join([]string{
+		convertToUserIDURL,
+		util.Query(map[string]interface{}{
+			"access_token": accessToken,
+		}),
+	}, "?"), &convertToUserIDRequest{
+		OpenID: openID,
+	}); err != nil {
+		return "", err
+	}
+	result := &convertToUserIDResponse{}
+	if err = util.DecodeWithError(response, result, "ConvertToUserID"); err != nil {
+		return "", err
+	}
+	return result.UserID, nil
+}

work/appchat/appchat.go

@@ -0,0 +1,115 @@
+package appchat
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	// 应用推送消息接口地址
+	sendURL = "https://qyapi.weixin.qq.com/cgi-bin/appchat/send?access_token=%s"
+)
+
+type (
+	// SendRequestCommon 发送应用推送消息请求公共参数
+	SendRequestCommon struct {
+		// 群聊id
+		ChatID string `json:"chatid"`
+		// 消息类型
+		MsgType string `json:"msgtype"`
+		// 表示是否是保密消息，0表示否，1表示是，默认0
+		Safe int `json:"safe"`
+	}
+
+	// SendResponse 发送应用消息响应参数
+	SendResponse struct {
+		util.CommonError
+	}
+
+	// SendTextRequest 发送文本消息的请求
+	SendTextRequest struct {
+		*SendRequestCommon
+		Text TextField `json:"text"`
+	}
+	// TextField 文本消息参数
+	TextField struct {
+		// 消息内容，最长不超过2048个字节
+		Content string `json:"content"`
+	}
+
+	// SendImageRequest 发送图片消息的请求
+	SendImageRequest struct {
+		*SendRequestCommon
+		Image ImageField `json:"image"`
+	}
+	// ImageField 图片消息参数
+	ImageField struct {
+		// 图片媒体文件id，可以调用上传临时素材接口获取
+		MediaID string `json:"media_id"`
+	}
+
+	// SendVoiceRequest 发送语音消息的请求
+	SendVoiceRequest struct {
+		*SendRequestCommon
+		Voice VoiceField `json:"voice"`
+	}
+	// VoiceField 语音消息参数
+	VoiceField struct {
+		// 语音文件id，可以调用上传临时素材接口获取
+		MediaID string `json:"media_id"`
+	}
+)
+
+// Send 发送应用消息
+// @desc 实现企业微信发送应用消息接口：https://developer.work.weixin.qq.com/document/path/90248
+func (r *Client) Send(apiName string, request interface{}) (*SendResponse, error) {
+	// 获取accessToken
+	accessToken, err := r.GetAccessToken()
+	if err != nil {
+		return nil, err
+	}
+	// 请求参数转 JSON 格式
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		return nil, err
+	}
+	// 发起http请求
+	response, err := util.HTTPPost(fmt.Sprintf(sendURL, accessToken), string(jsonData))
+	if err != nil {
+		return nil, err
+	}
+	// 按照结构体解析返回值
+	result := &SendResponse{}
+	if err = util.DecodeWithError(response, result, apiName); err != nil {
+		return nil, err
+	}
+	// 返回数据
+	return result, nil
+}
+
+// SendText 发送文本消息
+func (r *Client) SendText(request SendTextRequest) (*SendResponse, error) {
+	// 发送文本消息MsgType参数固定为：text
+	request.MsgType = "text"
+	return r.Send("MessageSendText", request)
+}
+
+// SendImage 发送图片消息
+func (r *Client) SendImage(request SendImageRequest) (*SendResponse, error) {
+	// 发送图片消息MsgType参数固定为：image
+	request.MsgType = "image"
+	return r.Send("MessageSendImage", request)
+}
+
+// SendVoice 发送语音消息
+func (r *Client) SendVoice(request SendVoiceRequest) (*SendResponse, error) {
+	// 发送语音消息MsgType参数固定为：voice
+	request.MsgType = "voice"
+	return r.Send("MessageSendVoice", request)
+}
+
+// 以上实现了部分常用消息推送：SendText 发送文本消息、SendImage 发送图片消息、SendVoice 发送语音消息，
+// 如需扩展其他消息类型，建议按照以上格式，扩展对应消息类型的参数即可
+// 也可以直接使用Send方法，按照企业微信消息推送的接口文档传对应消息类型的参数来使用

work/appchat/client.go

@@ -0,0 +1,16 @@
+// Package appchat 应用发送消息到群聊会话,企业微信接口：https://developer.work.weixin.qq.com/document/path/90248
+package appchat
+
+import (
+	"github.com/silenceper/wechat/v2/work/context"
+)
+
+// Client 接口实例
+type Client struct {
+	*context.Context
+}
+
+// NewClient 初始化实例
+func NewClient(ctx *context.Context) *Client {
+	return &Client{ctx}
+}

work/externalcontact/external_user.go

@@ -16,6 +16,18 @@ const (
 	fetchBatchExternalContactUserDetailURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/batch/get_by_user"
 	// updateUserRemarkURL 更新客户备注信息
 	updateUserRemarkURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/remark"
+	// listCustomerStrategyURL 获取规则组列表
+	listCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/list?access_token=%s"
+	// getCustomerStrategyURL 获取规则组详情
+	getCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/get?access_token=%s"
+	// getRangeCustomerStrategyURL 获取规则组管理范围
+	getRangeCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/get_range?access_token=%s"
+	// createCustomerStrategyURL 创建新的规则组
+	createCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/create?access_token=%s"
+	// editCustomerStrategyURL 编辑规则组及其管理范围
+	editCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/edit?access_token=%s"
+	// delCustomerStrategyURL 删除规则组
+	delCustomerStrategyURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/customer_strategy/del?access_token=%s"
 )
 
 // ExternalUserListResponse 外部联系人列表响应
@@ -71,7 +83,7 @@ type FollowUser struct {
 	UserID         string        `json:"userid"`
 	Remark         string        `json:"remark"`
 	Description    string        `json:"description"`
-	CreateTime     string        `json:"create_time"`
+	CreateTime     int64         `json:"createtime"`
 	Tags           []Tag         `json:"tags"`
 	RemarkCorpName string        `json:"remark_corp_name"`
 	RemarkMobiles  []string      `json:"remark_mobiles"`
@@ -157,7 +169,7 @@ type FollowInfo struct {
 	UserID         string        `json:"userid"`
 	Remark         string        `json:"remark"`
 	Description    string        `json:"description"`
-	CreateTime     int           `json:"create_time"`
+	CreateTime     int64         `json:"createtime"`
 	TagID          []string      `json:"tag_id"`
 	RemarkCorpName string        `json:"remark_corp_name"`
 	RemarkMobiles  []string      `json:"remark_mobiles"`
@@ -219,3 +231,236 @@ func (r *Client) UpdateUserRemark(request UpdateUserRemarkRequest) error {
 	}
 	return util.DecodeWithCommonError(response, "UpdateUserRemark")
 }
+
+// ListCustomerStrategyRequest 获取规则组列表请求
+type ListCustomerStrategyRequest struct {
+	Cursor string `json:"cursor"`
+	Limit  int    `json:"limit"`
+}
+
+// ListCustomerStrategyResponse 获取规则组列表响应
+type ListCustomerStrategyResponse struct {
+	util.CommonError
+	Strategy   []StrategyID `json:"strategy"`
+	NextCursor string       `json:"next_cursor"`
+}
+
+// StrategyID 规则组ID
+type StrategyID struct {
+	StrategyID int `json:"strategy_id"`
+}
+
+// ListCustomerStrategy 获取规则组列表
+// @see https://developer.work.weixin.qq.com/document/path/94883#%E8%8E%B7%E5%8F%96%E8%A7%84%E5%88%99%E7%BB%84%E5%88%97%E8%A1%A8
+func (r *Client) ListCustomerStrategy(req *ListCustomerStrategyRequest) (*ListCustomerStrategyResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(listCustomerStrategyURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &ListCustomerStrategyResponse{}
+	if err = util.DecodeWithError(response, result, "ListCustomerStrategy"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// GetCustomerStrategyRequest 获取规则组详情请求
+type GetCustomerStrategyRequest struct {
+	StrategyID int `json:"strategy_id"`
+}
+
+// GetCustomerStrategyResponse 获取规则组详情响应
+type GetCustomerStrategyResponse struct {
+	util.CommonError
+	Strategy Strategy `json:"strategy"`
+}
+
+// Strategy 规则组
+type Strategy struct {
+	StrategyID   int       `json:"strategy_id"`
+	ParentID     int       `json:"parent_id"`
+	StrategyName string    `json:"strategy_name"`
+	CreateTime   int64     `json:"create_time"`
+	AdminList    []string  `json:"admin_list"`
+	Privilege    Privilege `json:"privilege"`
+}
+
+// Privilege 权限
+type Privilege struct {
+	ViewCustomerList        bool `json:"view_customer_list"`
+	ViewCustomerData        bool `json:"view_customer_data"`
+	ViewRoomList            bool `json:"view_room_list"`
+	ContactMe               bool `json:"contact_me"`
+	JoinRoom                bool `json:"join_room"`
+	ShareCustomer           bool `json:"share_customer"`
+	OperResignCustomer      bool `json:"oper_resign_customer"`
+	OperResignGroup         bool `json:"oper_resign_group"`
+	SendCustomerMsg         bool `json:"send_customer_msg"`
+	EditWelcomeMsg          bool `json:"edit_welcome_msg"`
+	ViewBehaviorData        bool `json:"view_behavior_data"`
+	ViewRoomData            bool `json:"view_room_data"`
+	SendGroupMsg            bool `json:"send_group_msg"`
+	RoomDeduplication       bool `json:"room_deduplication"`
+	RapidReply              bool `json:"rapid_reply"`
+	OnjobCustomerTransfer   bool `json:"onjob_customer_transfer"`
+	EditAntiSpamRule        bool `json:"edit_anti_spam_rule"`
+	ExportCustomerList      bool `json:"export_customer_list"`
+	ExportCustomerData      bool `json:"export_customer_data"`
+	ExportCustomerGroupList bool `json:"export_customer_group_list"`
+	ManageCustomerTag       bool `json:"manage_customer_tag"`
+}
+
+// GetCustomerStrategy 获取规则组详情
+// @see https://developer.work.weixin.qq.com/document/path/94883#%E8%8E%B7%E5%8F%96%E8%A7%84%E5%88%99%E7%BB%84%E8%AF%A6%E6%83%85
+func (r *Client) GetCustomerStrategy(req *GetCustomerStrategyRequest) (*GetCustomerStrategyResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getCustomerStrategyURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetCustomerStrategyResponse{}
+	if err = util.DecodeWithError(response, result, "GetCustomerStrategy"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// GetRangeCustomerStrategyRequest 获取规则组管理范围请求
+type GetRangeCustomerStrategyRequest struct {
+	StrategyID int    `json:"strategy_id"`
+	Cursor     string `json:"cursor"`
+	Limit      int    `json:"limit"`
+}
+
+// GetRangeCustomerStrategyResponse 获取规则组管理范围响应
+type GetRangeCustomerStrategyResponse struct {
+	util.CommonError
+	Range      []Range `json:"range"`
+	NextCursor string  `json:"next_cursor"`
+}
+
+// Range 管理范围节点
+type Range struct {
+	Type    int    `json:"type"`
+	UserID  string `json:"userid,omitempty"`
+	PartyID int    `json:"partyid,omitempty"`
+}
+
+// GetRangeCustomerStrategy 获取规则组管理范围
+// @see https://developer.work.weixin.qq.com/document/path/94883#%E8%8E%B7%E5%8F%96%E8%A7%84%E5%88%99%E7%BB%84%E7%AE%A1%E7%90%86%E8%8C%83%E5%9B%B4
+func (r *Client) GetRangeCustomerStrategy(req *GetRangeCustomerStrategyRequest) (*GetRangeCustomerStrategyResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getRangeCustomerStrategyURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetRangeCustomerStrategyResponse{}
+	if err = util.DecodeWithError(response, result, "GetRangeCustomerStrategy"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// CreateCustomerStrategyRequest 创建新的规则组请求
+type CreateCustomerStrategyRequest struct {
+	ParentID     int       `json:"parent_id"`
+	StrategyName string    `json:"strategy_name"`
+	AdminList    []string  `json:"admin_list"`
+	Privilege    Privilege `json:"privilege"`
+	Range        []Range   `json:"range"`
+}
+
+// CreateCustomerStrategyResponse 创建新的规则组响应
+type CreateCustomerStrategyResponse struct {
+	util.CommonError
+	StrategyID int `json:"strategy_id"`
+}
+
+// CreateCustomerStrategy 创建新的规则组
+// @see https://developer.work.weixin.qq.com/document/path/94883#%E5%88%9B%E5%BB%BA%E6%96%B0%E7%9A%84%E8%A7%84%E5%88%99%E7%BB%84
+func (r *Client) CreateCustomerStrategy(req *CreateCustomerStrategyRequest) (*CreateCustomerStrategyResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(createCustomerStrategyURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &CreateCustomerStrategyResponse{}
+	if err = util.DecodeWithError(response, result, "CreateCustomerStrategy"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// EditCustomerStrategyRequest 编辑规则组及其管理范围请求
+type EditCustomerStrategyRequest struct {
+	StrategyID   int       `json:"strategy_id"`
+	StrategyName string    `json:"strategy_name"`
+	AdminList    []string  `json:"admin_list"`
+	Privilege    Privilege `json:"privilege"`
+	RangeAdd     []Range   `json:"range_add"`
+	RangeDel     []Range   `json:"range_del"`
+}
+
+// EditCustomerStrategy 编辑规则组及其管理范围
+// see https://developer.work.weixin.qq.com/document/path/94883#%E7%BC%96%E8%BE%91%E8%A7%84%E5%88%99%E7%BB%84%E5%8F%8A%E5%85%B6%E7%AE%A1%E7%90%86%E8%8C%83%E5%9B%B4
+func (r *Client) EditCustomerStrategy(req *EditCustomerStrategyRequest) error {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(editCustomerStrategyURL, accessToken), req); err != nil {
+		return err
+	}
+	return util.DecodeWithCommonError(response, "EditCustomerStrategy")
+}
+
+// DelCustomerStrategyRequest 删除规则组请求
+type DelCustomerStrategyRequest struct {
+	StrategyID int `json:"strategy_id"`
+}
+
+// DelCustomerStrategy 删除规则组
+// see https://developer.work.weixin.qq.com/document/path/94883#%E5%88%A0%E9%99%A4%E8%A7%84%E5%88%99%E7%BB%84
+func (r *Client) DelCustomerStrategy(req *DelCustomerStrategyRequest) error {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(delCustomerStrategyURL, accessToken), req); err != nil {
+		return err
+	}
+	return util.DecodeWithCommonError(response, "DelCustomerStrategy")
+}

work/externalcontact/groupchat.go

@@ -80,7 +80,7 @@ type (
 		ChatID     string            `json:"chat_id"`     //客户群ID
 		Name       string            `json:"name"`        //群名
 		Owner      string            `json:"owner"`       //群主ID
-		CreateTime int               `json:"create_time"` //群的创建时间
+		CreateTime int64             `json:"create_time"` //群的创建时间
 		Notice     string            `json:"notice"`      //群公告
 		MemberList []GroupChatMember `json:"member_list"` //群成员列表
 		AdminList  []GroupChatAdmin  `json:"admin_list"`  //群管理员列表

work/externalcontact/msg.go

@@ -111,8 +111,8 @@ func (r *Client) AddMsgTemplate(req *AddMsgTemplateRequest) (*AddMsgTemplateResp
 // GetGroupMsgListV2Request 获取群发记录列表请求
 type GetGroupMsgListV2Request struct {
 	ChatType   string `json:"chat_type"`
-	StartTime  int    `json:"start_time"`
-	EndTime    int    `json:"end_time"`
+	StartTime  int64  `json:"start_time"`
+	EndTime    int64  `json:"end_time"`
 	Creator    string `json:"creator,omitempty"`
 	FilterType int    `json:"filter_type"`
 	Limit      int    `json:"limit"`
@@ -130,7 +130,7 @@ type GetGroupMsgListV2Response struct {
 type GroupMsg struct {
 	MsgID       string        `json:"msgid"`
 	Creator     string        `json:"creator"`
-	CreateTime  int           `json:"create_time"`
+	CreateTime  int64         `json:"create_time"`
 	CreateType  int           `json:"create_type"`
 	Text        MsgText       `json:"text"`
 	Attachments []*Attachment `json:"attachments"`

work/externalcontact/tag.go

@@ -18,6 +18,14 @@ const (
 	delCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_corp_tag"
 	// markCropTagURL 为客户打上、删除标签
 	markCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag"
+	// getStrategyTagListURL 获取指定规则组下的企业客户标签
+	getStrategyTagListURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_strategy_tag_list?access_token=%s"
+	// addStrategyTagURL 为指定规则组创建企业客户标签
+	addStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_strategy_tag?access_token=%s"
+	// editStrategyTagURL 编辑指定规则组下的企业客户标签
+	editStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/edit_strategy_tag?access_token=%s"
+	// delStrategyTagURL 删除指定规则组下的企业客户标签
+	delStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_strategy_tag?access_token=%s"
 )
 
 // GetCropTagRequest 获取企业标签请求
@@ -36,7 +44,7 @@ type GetCropTagListResponse struct {
 type TagGroup struct {
 	GroupID    string            `json:"group_id"`
 	GroupName  string            `json:"group_name"`
-	CreateTime int               `json:"create_time"`
+	CreateTime int64             `json:"create_time"`
 	GroupOrder int               `json:"group_order"`
 	Deleted    bool              `json:"deleted"`
 	Tag        []TagGroupTagItem `json:"tag"`
@@ -46,7 +54,7 @@ type TagGroup struct {
 type TagGroupTagItem struct {
 	ID         string `json:"id"`
 	Name       string `json:"name"`
-	CreateTime int    `json:"create_time"`
+	CreateTime int64  `json:"create_time"`
 	Order      int    `json:"order"`
 	Deleted    bool   `json:"deleted"`
 }
@@ -201,3 +209,161 @@ func (r *Client) MarkTag(request MarkTagRequest) error {
 	}
 	return util.DecodeWithCommonError(response, "MarkTag")
 }
+
+// GetStrategyTagListRequest 获取指定规则组下的企业客户标签请求
+type GetStrategyTagListRequest struct {
+	StrategyID int      `json:"strategy_id"`
+	TagID      []string `json:"tag_id"`
+	GroupID    []string `json:"group_id"`
+}
+
+// GetStrategyTagListResponse 获取指定规则组下的企业客户标签响应
+type GetStrategyTagListResponse struct {
+	util.CommonError
+	TagGroup []StrategyTagGroup `json:"tag_group"`
+}
+
+// StrategyTagGroup 规则组下的企业标签组
+type StrategyTagGroup struct {
+	GroupID    string        `json:"group_id"`
+	GroupName  string        `json:"group_name"`
+	CreateTime int64         `json:"create_time"`
+	Order      int           `json:"order"`
+	StrategyID int           `json:"strategy_id"`
+	Tag        []StrategyTag `json:"tag"`
+}
+
+// StrategyTag 规则组下的企业标签
+type StrategyTag struct {
+	ID         string `json:"id"`
+	Name       string `json:"name"`
+	CreateTime int64  `json:"create_time"`
+	Order      int    `json:"order"`
+}
+
+// GetStrategyTagList 获取指定规则组下的企业客户标签
+// @see https://developer.work.weixin.qq.com/document/path/94882#%E8%8E%B7%E5%8F%96%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
+func (r *Client) GetStrategyTagList(req *GetStrategyTagListRequest) (*GetStrategyTagListResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getStrategyTagListURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetStrategyTagListResponse{}
+	if err = util.DecodeWithError(response, result, "GetStrategyTagList"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// AddStrategyTagRequest 为指定规则组创建企业客户标签请求
+type AddStrategyTagRequest struct {
+	StrategyID int                         `json:"strategy_id"`
+	GroupID    string                      `json:"group_id"`
+	GroupName  string                      `json:"group_name"`
+	Order      int                         `json:"order"`
+	Tag        []AddStrategyTagRequestItem `json:"tag"`
+}
+
+// AddStrategyTagRequestItem 为指定规则组创建企业客户标签请求条目
+type AddStrategyTagRequestItem struct {
+	Name  string `json:"name"`
+	Order int    `json:"order"`
+}
+
+// AddStrategyTagResponse 为指定规则组创建企业客户标签响应
+type AddStrategyTagResponse struct {
+	util.CommonError
+	TagGroup AddStrategyTagResponseTagGroup `json:"tag_group"`
+}
+
+// AddStrategyTagResponseTagGroup 为指定规则组创建企业客户标签响应标签组
+type AddStrategyTagResponseTagGroup struct {
+	GroupID    string                       `json:"group_id"`
+	GroupName  string                       `json:"group_name"`
+	CreateTime int64                        `json:"create_time"`
+	Order      int                          `json:"order"`
+	Tag        []AddStrategyTagResponseItem `json:"tag"`
+}
+
+// AddStrategyTagResponseItem 标签组内的标签列表
+type AddStrategyTagResponseItem struct {
+	ID         string `json:"id"`
+	Name       string `json:"name"`
+	CreateTime int64  `json:"create_time"`
+	Order      int    `json:"order"`
+}
+
+// AddStrategyTag 为指定规则组创建企业客户标签
+// @see https://developer.work.weixin.qq.com/document/path/94882#%E4%B8%BA%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E5%88%9B%E5%BB%BA%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
+func (r *Client) AddStrategyTag(req *AddStrategyTagRequest) (*AddStrategyTagResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(addStrategyTagURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &AddStrategyTagResponse{}
+	if err = util.DecodeWithError(response, result, "AddStrategyTag"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// EditStrategyTagRequest 编辑指定规则组下的企业客户标签请求
+type EditStrategyTagRequest struct {
+	ID    string `json:"id"`
+	Name  string `json:"name"`
+	Order int    `json:"order"`
+}
+
+// EditStrategyTag 编辑指定规则组下的企业客户标签
+// see https://developer.work.weixin.qq.com/document/path/94882#%E7%BC%96%E8%BE%91%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
+func (r *Client) EditStrategyTag(req *EditStrategyTagRequest) error {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(editStrategyTagURL, accessToken), req); err != nil {
+		return err
+	}
+	return util.DecodeWithCommonError(response, "EditStrategyTag")
+}
+
+// DelStrategyTagRequest 删除指定规则组下的企业客户标签请求
+type DelStrategyTagRequest struct {
+	TagID   []string `json:"tag_id"`
+	GroupID []string `json:"group_id"`
+}
+
+// DelStrategyTag 删除指定规则组下的企业客户标签
+// see https://developer.work.weixin.qq.com/document/path/94882#%E5%88%A0%E9%99%A4%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
+func (r *Client) DelStrategyTag(req *DelStrategyTagRequest) error {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(delStrategyTagURL, accessToken), req); err != nil {
+		return err
+	}
+	return util.DecodeWithCommonError(response, "DelStrategyTag")
+}

work/invoice/client.go

@@ -0,0 +1,17 @@
+package invoice
+
+import (
+	"github.com/silenceper/wechat/v2/work/context"
+)
+
+// Client 电子发票接口实例
+type Client struct {
+	*context.Context
+}
+
+// NewClient 初始化实例
+func NewClient(ctx *context.Context) *Client {
+	return &Client{
+		ctx,
+	}
+}

work/invoice/invoice.go

@@ -0,0 +1,191 @@
+package invoice
+
+import (
+	"fmt"
+
+	"github.com/silenceper/wechat/v2/util"
+)
+
+const (
+	// getInvoiceInfoURL 查询电子发票
+	getInvoiceInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/getinvoiceinfo?access_token=%s"
+	// updateInvoiceStatusURL 更新发票状态
+	updateInvoiceStatusURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/updateinvoicestatus?access_token=%s"
+	// updateStatusBatchURL 批量更新发票状态
+	updateStatusBatchURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/updatestatusbatch?access_token=%s"
+	// getInvoiceInfoBatchURL 批量查询电子发票
+	getInvoiceInfoBatchURL = "https://qyapi.weixin.qq.com/cgi-bin/card/invoice/reimburse/getinvoiceinfobatch?access_token=%s"
+)
+
+// GetInvoiceInfoRequest 查询电子发票请求
+type GetInvoiceInfoRequest struct {
+	CardID      string `json:"card_id"`
+	EncryptCode string `json:"encrypt_code"`
+}
+
+// GetInvoiceInfoResponse 查询电子发票响应
+type GetInvoiceInfoResponse struct {
+	util.CommonError
+	CardID    string   `json:"card_id"`
+	BeginTime int64    `json:"begin_time"`
+	EndTime   int64    `json:"end_time"`
+	OpenID    string   `json:"openid"`
+	Type      string   `json:"type"`
+	Payee     string   `json:"payee"`
+	Detail    string   `json:"detail"`
+	UserInfo  UserInfo `json:"user_info"`
+}
+
+// UserInfo 发票的用户信息
+type UserInfo struct {
+	Fee                   int64  `json:"fee"`
+	Title                 string `json:"title"`
+	BillingTime           int64  `json:"billing_time"`
+	BillingNo             string `json:"billing_no"`
+	BillingCode           string `json:"billing_code"`
+	Info                  []Info `json:"info"`
+	FeeWithoutTax         int64  `json:"fee_without_tax"`
+	Tax                   int64  `json:"tax"`
+	Detail                string `json:"detail"`
+	PdfURL                string `json:"pdf_url"`
+	TripPdfURL            string `json:"trip_pdf_url"`
+	ReimburseStatus       string `json:"reimburse_status"`
+	CheckCode             string `json:"check_code"`
+	BuyerNumber           string `json:"buyer_number"`
+	BuyerAddressAndPhone  string `json:"buyer_address_and_phone"`
+	BuyerBankAccount      string `json:"buyer_bank_account"`
+	SellerNumber          string `json:"seller_number"`
+	SellerAddressAndPhone string `json:"seller_address_and_phone"`
+	SellerBankAccount     string `json:"seller_bank_account"`
+	Remarks               string `json:"remarks"`
+	Cashier               string `json:"cashier"`
+	Maker                 string `json:"maker"`
+}
+
+// Info 商品信息结构
+type Info struct {
+	Name  string `json:"name"`
+	Num   int64  `json:"num"`
+	Unit  string `json:"unit"`
+	Fee   int64  `json:"fee"`
+	Price int64  `json:"price"`
+}
+
+// GetInvoiceInfo 查询电子发票
+// see https://developer.work.weixin.qq.com/document/path/90284
+func (r *Client) GetInvoiceInfo(req *GetInvoiceInfoRequest) (*GetInvoiceInfoResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getInvoiceInfoURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetInvoiceInfoResponse{}
+	if err = util.DecodeWithError(response, result, "GetInvoiceInfo"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// UpdateInvoiceStatusRequest 更新发票状态请求
+type UpdateInvoiceStatusRequest struct {
+	CardID          string `json:"card_id"`
+	EncryptCode     string `json:"encrypt_code"`
+	ReimburseStatus string `json:"reimburse_status"`
+}
+
+// UpdateInvoiceStatus 更新发票状态
+// see https://developer.work.weixin.qq.com/document/path/90285
+func (r *Client) UpdateInvoiceStatus(req *UpdateInvoiceStatusRequest) error {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(updateInvoiceStatusURL, accessToken), req); err != nil {
+		return err
+	}
+	return util.DecodeWithCommonError(response, "UpdateInvoiceStatus")
+}
+
+// UpdateStatusBatchRequest 批量更新发票状态
+type UpdateStatusBatchRequest struct {
+	OpenID          string    `json:"openid"`
+	ReimburseStatus string    `json:"reimburse_status"`
+	InvoiceList     []Invoice `json:"invoice_list"`
+}
+
+// Invoice 发票卡券
+type Invoice struct {
+	CardID      string `json:"card_id"`
+	EncryptCode string `json:"encrypt_code"`
+}
+
+// UpdateStatusBatch 批量更新发票状态
+// see https://developer.work.weixin.qq.com/document/path/90286
+func (r *Client) UpdateStatusBatch(req *UpdateStatusBatchRequest) error {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(updateStatusBatchURL, accessToken), req); err != nil {
+		return err
+	}
+	return util.DecodeWithCommonError(response, "UpdateStatusBatch")
+}
+
+// GetInvoiceInfoBatchRequest 批量查询电子发票请求
+type GetInvoiceInfoBatchRequest struct {
+	ItemList []Invoice `json:"item_list"`
+}
+
+// GetInvoiceInfoBatchResponse 批量查询电子发票响应
+type GetInvoiceInfoBatchResponse struct {
+	util.CommonError
+	ItemList []Item `json:"item_list"`
+}
+
+// Item 电子发票的结构化信息
+type Item struct {
+	CardID    string   `json:"card_id"`
+	BeginTime int64    `json:"begin_time"`
+	EndTime   int64    `json:"end_time"`
+	OpenID    string   `json:"openid"`
+	Type      string   `json:"type"`
+	Payee     string   `json:"payee"`
+	Detail    string   `json:"detail"`
+	UserInfo  UserInfo `json:"user_info"`
+}
+
+// GetInvoiceInfoBatch 批量查询电子发票
+// see https://developer.work.weixin.qq.com/document/path/90287
+func (r *Client) GetInvoiceInfoBatch(req *GetInvoiceInfoBatchRequest) (*GetInvoiceInfoBatchResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = r.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getInvoiceInfoBatchURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetInvoiceInfoBatchResponse{}
+	if err = util.DecodeWithError(response, result, "GetInvoiceInfoBatch"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}

work/kf/callback.go

@@ -52,12 +52,12 @@ type callbackOriginMessage struct {
 
 // 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，用于校验请求的合法性
-	OpenKfID   string `json:"open_kfid"`    // 有新消息的客服帐号。可通过sync_msg接口指定open_kfid获取此客服帐号的消息
+	ToUserName string `json:"to_user_name" xml:"ToUserName"` // 微信客服组件ID
+	CreateTime int64  `json:"create_time" xml:"CreateTime"`  // 消息创建时间，unix时间戳
+	MsgType    string `json:"msgtype" xml:"MsgType"`         // 消息的类型，此时固定为 event
+	Event      string `json:"event" xml:"Event"`             // 事件的类型，此时固定为 kf_msg_or_event
+	Token      string `json:"token" xml:"Token"`             // 调用拉取消息接口时，需要传此token，用于校验请求的合法性
+	OpenKfID   string `json:"open_kfid" xml:"OpenKfId"`      // 有新消息的客服帐号。可通过sync_msg接口指定open_kfid获取此客服帐号的消息
 }
 
 // GetCallbackMessage 获取回调事件中的消息内容

work/kf/syncmsg.go

@@ -16,11 +16,11 @@ const (
 
 // 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字段判断是否继续请求。
-	VoiceFormat uint   `json:"voice_format"` // 语音消息类型，0-Amr 1-Silk，默认0。可通过该参数控制返回的语音格式，开发者可按需选择自己程序支持的一种格式
-	OpenKfID    string `json:"open_kfid"`    // 指定拉取某个客服帐号的消息，否则默认返回有权限的客服帐号的消息。当客服帐号较多，建议按open_kfid来拉取以获取更好的性能。
+	Cursor      string `json:"cursor"`                 // 上一次调用时返回的next_cursor，第一次拉取可以不填, 不多于64字节
+	Token       string `json:"token"`                  // 回调事件返回的token字段，10分钟内有效；可不填，如果不填接口有严格的频率限制, 不多于128字节
+	Limit       uint   `json:"limit"`                  // 期望请求的数据量，默认值和最大值都为1000, 注意：可能会出现返回条数少于limit的情况，需结合返回的has_more字段判断是否继续请求。
+	VoiceFormat uint   `json:"voice_format,omitempty"` // 语音消息类型，0-Amr 1-Silk，默认0。可通过该参数控制返回的语音格式，开发者可按需选择自己程序支持的一种格式
+	OpenKfID    string `json:"open_kfid,omitempty"`    // 指定拉取某个客服帐号的消息，否则默认返回有权限的客服帐号的消息。当客服帐号较多，建议按open_kfid来拉取以获取更好的性能。
 }
 
 // SyncMsgSchema 获取消息查询响应内容

work/msgaudit/message.go

@@ -169,7 +169,7 @@ type CollectMessage struct {
 	Collect struct {
 		RoomName   string           `json:"room_name,omitempty"`   // 填表消息所在的群名称。
 		Creator    string           `json:"creator,omitempty"`     // 创建者在群中的名字
-		CreateTime string           `json:"create_time,omitempty"` // 创建的时间
+		CreateTime int64            `json:"create_time,omitempty"` // 创建的时间
 		Details    []CollectDetails `json:"details,omitempty"`     // 表内容
 	} `json:"collect,omitempty"`
 }

work/oauth/oauth.go

@@ -23,6 +23,10 @@ var (
 	oauthUserInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo?access_token=%s&code=%s"
 	// oauthQrContentTargetURL 构造独立窗口登录二维码
 	oauthQrContentTargetURL = "https://open.work.weixin.qq.com/wwopen/sso/qrConnect?appid=%s&agentid=%s&redirect_uri=%s&state=%s"
+	// getUserInfoURL 获取访问用户身份&获取用户登录身份
+	getUserInfoURL = "https://qyapi.weixin.qq.com/cgi-bin/auth/getuserinfo?access_token=%s&code=%s"
+	// getUserDetailURL 获取访问用户敏感信息
+	getUserDetailURL = "https://qyapi.weixin.qq.com/cgi-bin/auth/getuserdetail?access_token=%s"
 )
 
 // NewOauth new init oauth
@@ -93,3 +97,73 @@ func (ctr *Oauth) UserFromCode(code string) (result ResUserInfo, err error) {
 	}
 	return
 }
+
+// GetUserInfoResponse 获取访问用户身份&获取用户登录身份响应
+type GetUserInfoResponse struct {
+	util.CommonError
+	UserID         string `json:"userid"`
+	UserTicket     string `json:"user_ticket"`
+	OpenID         string `json:"openid"`
+	ExternalUserID string `json:"external_userid"`
+}
+
+// GetUserInfo 获取访问用户身份&获取用户登录身份
+// @see https://developer.work.weixin.qq.com/document/path/90213 获取访问用户身份
+// @see https://developer.work.weixin.qq.com/document/path/98176 获取用户登录身份
+func (ctr *Oauth) GetUserInfo(code string) (*GetUserInfoResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = ctr.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.HTTPGet(fmt.Sprintf(getUserInfoURL, accessToken, code)); err != nil {
+		return nil, err
+	}
+	result := &GetUserInfoResponse{}
+	if err = util.DecodeWithError(response, result, "GetUserInfo"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}
+
+// GetUserDetailRequest 获取访问用户敏感信息请求
+type GetUserDetailRequest struct {
+	UserTicket string `json:"user_ticket"`
+}
+
+// GetUserDetailResponse 获取访问用户敏感信息响应
+type GetUserDetailResponse struct {
+	util.CommonError
+	UserID  string `json:"userid"`
+	Gender  string `json:"gender"`
+	Avatar  string `json:"avatar"`
+	QrCode  string `json:"qr_code"`
+	Mobile  string `json:"mobile"`
+	Email   string `json:"email"`
+	BizMail string `json:"biz_mail"`
+	Address string `json:"address"`
+}
+
+// GetUserDetail 获取访问用户敏感信息
+// @see https://developer.work.weixin.qq.com/document/path/95833
+func (ctr *Oauth) GetUserDetail(req *GetUserDetailRequest) (*GetUserDetailResponse, error) {
+	var (
+		accessToken string
+		err         error
+	)
+	if accessToken, err = ctr.GetAccessToken(); err != nil {
+		return nil, err
+	}
+	var response []byte
+	if response, err = util.PostJSON(fmt.Sprintf(getUserDetailURL, accessToken), req); err != nil {
+		return nil, err
+	}
+	result := &GetUserDetailResponse{}
+	if err = util.DecodeWithError(response, result, "GetUserDetail"); err != nil {
+		return nil, err
+	}
+	return result, nil
+}

work/work.go

@@ -3,9 +3,11 @@ package work
 import (
 	"github.com/silenceper/wechat/v2/credential"
 	"github.com/silenceper/wechat/v2/work/addresslist"
+	"github.com/silenceper/wechat/v2/work/appchat"
 	"github.com/silenceper/wechat/v2/work/config"
 	"github.com/silenceper/wechat/v2/work/context"
 	"github.com/silenceper/wechat/v2/work/externalcontact"
+	"github.com/silenceper/wechat/v2/work/invoice"
 	"github.com/silenceper/wechat/v2/work/kf"
 	"github.com/silenceper/wechat/v2/work/material"
 	"github.com/silenceper/wechat/v2/work/message"
@@ -69,7 +71,17 @@ func (wk *Work) GetRobot() *robot.Client {
 	return robot.NewClient(wk.ctx)
 }
 
-// GetMessage get robot
+// GetMessage 获取发送应用消息接口实例
 func (wk *Work) GetMessage() *message.Client {
 	return message.NewClient(wk.ctx)
 }
+
+// GetAppChat 获取应用发送消息到群聊会话接口实例
+func (wk *Work) GetAppChat() *appchat.Client {
+	return appchat.NewClient(wk.ctx)
+}
+
+// GetInvoice get invoice
+func (wk *Work) GetInvoice() *invoice.Client {
+	return invoice.NewClient(wk.ctx)
+}