mirror of
https://github.com/silenceper/wechat.git
synced 2026-02-04 21:02:25 +08:00
a571bf3546
* Update default_access_token.go 微信获取稳定版token，只有不等于空字符串的情况下才会返回access_token信息，未空的情况，继续调去微信服务 * 微信稳定性获取 access_token 接口，添加防止并发性获取 access_token 和多次微信服务获取代码 --------- Co-authored-by: w_yangyili <w_yangyili@xiwang.com>
264 lines
8.6 KiB
Go
264 lines
8.6 KiB
Go
package credential
|
||
|
||
import (
|
||
"context"
|
||
"encoding/json"
|
||
"fmt"
|
||
"sync"
|
||
"time"
|
||
|
||
"github.com/silenceper/wechat/v2/cache"
|
||
"github.com/silenceper/wechat/v2/util"
|
||
)
|
||
|
||
const (
|
||
// accessTokenURL 获取access_token的接口
|
||
accessTokenURL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"
|
||
// 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_"
|
||
// CacheKeyMiniProgramPrefix 小程序cache key前缀
|
||
CacheKeyMiniProgramPrefix = "gowechat_miniprogram_"
|
||
// CacheKeyWorkPrefix 企业微信cache key前缀
|
||
CacheKeyWorkPrefix = "gowechat_work_"
|
||
)
|
||
|
||
// DefaultAccessToken 默认AccessToken 获取
|
||
type DefaultAccessToken struct {
|
||
appID string
|
||
appSecret string
|
||
cacheKeyPrefix string
|
||
cache cache.Cache
|
||
accessTokenLock *sync.Mutex
|
||
}
|
||
|
||
// NewDefaultAccessToken new DefaultAccessToken
|
||
func NewDefaultAccessToken(appID, appSecret, cacheKeyPrefix string, cache cache.Cache) AccessTokenContextHandle {
|
||
if cache == nil {
|
||
panic("cache is ineed")
|
||
}
|
||
return &DefaultAccessToken{
|
||
appID: appID,
|
||
appSecret: appSecret,
|
||
cache: cache,
|
||
cacheKeyPrefix: cacheKeyPrefix,
|
||
accessTokenLock: new(sync.Mutex),
|
||
}
|
||
}
|
||
|
||
// ResAccessToken struct
|
||
type ResAccessToken struct {
|
||
util.CommonError
|
||
|
||
AccessToken string `json:"access_token"`
|
||
ExpiresIn int64 `json:"expires_in"`
|
||
}
|
||
|
||
// GetAccessToken 获取access_token,先从cache中获取，没有则从服务端获取
|
||
func (ak *DefaultAccessToken) GetAccessToken() (accessToken string, err error) {
|
||
return ak.GetAccessTokenContext(context.Background())
|
||
}
|
||
|
||
// GetAccessTokenContext 获取access_token,先从cache中获取，没有则从服务端获取
|
||
func (ak *DefaultAccessToken) GetAccessTokenContext(ctx context.Context) (accessToken string, err error) {
|
||
// 先从cache中取
|
||
accessTokenCacheKey := fmt.Sprintf("%s_access_token_%s", ak.cacheKeyPrefix, ak.appID)
|
||
|
||
if val := ak.cache.Get(accessTokenCacheKey); val != nil {
|
||
if accessToken = val.(string); accessToken != "" {
|
||
return
|
||
}
|
||
}
|
||
|
||
// 加上lock，是为了防止在并发获取token时，cache刚好失效，导致从微信服务器上获取到不同token
|
||
ak.accessTokenLock.Lock()
|
||
defer ak.accessTokenLock.Unlock()
|
||
|
||
// 双检，防止重复从微信服务器获取
|
||
if val := ak.cache.Get(accessTokenCacheKey); val != nil {
|
||
if accessToken = val.(string); accessToken != "" {
|
||
return
|
||
}
|
||
}
|
||
|
||
// cache失效，从微信服务器获取
|
||
var resAccessToken ResAccessToken
|
||
if resAccessToken, err = GetTokenFromServerContext(ctx, fmt.Sprintf(accessTokenURL, ak.appID, ak.appSecret)); err != nil {
|
||
return
|
||
}
|
||
|
||
expires := resAccessToken.ExpiresIn - 1500
|
||
err = ak.cache.Set(accessTokenCacheKey, resAccessToken.AccessToken, time.Duration(expires)*time.Second)
|
||
|
||
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
|
||
accessTokenLock *sync.Mutex
|
||
}
|
||
|
||
// 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,
|
||
accessTokenLock: new(sync.Mutex),
|
||
}
|
||
}
|
||
|
||
// 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 {
|
||
if accessToken = val.(string); accessToken != "" {
|
||
return
|
||
}
|
||
}
|
||
|
||
// 加上lock，是为了防止在并发获取token时，cache刚好失效，导致从微信服务器上获取到不同token
|
||
ak.accessTokenLock.Lock()
|
||
defer ak.accessTokenLock.Unlock()
|
||
|
||
// 双检，防止重复从微信服务器获取
|
||
if val := ak.cache.Get(accessTokenCacheKey); val != nil {
|
||
if accessToken = val.(string); accessToken != "" {
|
||
return
|
||
}
|
||
}
|
||
|
||
// cache失效，从微信服务器获取
|
||
var resAccessToken ResAccessToken
|
||
resAccessToken, err = ak.GetAccessTokenDirectly(ctx, false)
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
expires := resAccessToken.ExpiresIn - 300
|
||
err = 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
|
||
}
|
||
|
||
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
|
||
}
|
||
|
||
// WorkAccessToken 企业微信AccessToken 获取
|
||
type WorkAccessToken struct {
|
||
CorpID string
|
||
CorpSecret string
|
||
cacheKeyPrefix string
|
||
cache cache.Cache
|
||
accessTokenLock *sync.Mutex
|
||
}
|
||
|
||
// NewWorkAccessToken new WorkAccessToken
|
||
func NewWorkAccessToken(corpID, corpSecret, cacheKeyPrefix string, cache cache.Cache) AccessTokenContextHandle {
|
||
if cache == nil {
|
||
panic("cache the not exist")
|
||
}
|
||
return &WorkAccessToken{
|
||
CorpID: corpID,
|
||
CorpSecret: corpSecret,
|
||
cache: cache,
|
||
cacheKeyPrefix: cacheKeyPrefix,
|
||
accessTokenLock: new(sync.Mutex),
|
||
}
|
||
}
|
||
|
||
// GetAccessToken 企业微信获取access_token,先从cache中获取，没有则从服务端获取
|
||
func (ak *WorkAccessToken) GetAccessToken() (accessToken string, err error) {
|
||
return ak.GetAccessTokenContext(context.Background())
|
||
}
|
||
|
||
// GetAccessTokenContext 企业微信获取access_token,先从cache中获取，没有则从服务端获取
|
||
func (ak *WorkAccessToken) GetAccessTokenContext(ctx context.Context) (accessToken string, err error) {
|
||
// 加上lock，是为了防止在并发获取token时，cache刚好失效，导致从微信服务器上获取到不同token
|
||
ak.accessTokenLock.Lock()
|
||
defer ak.accessTokenLock.Unlock()
|
||
accessTokenCacheKey := fmt.Sprintf("%s_access_token_%s", ak.cacheKeyPrefix, ak.CorpID)
|
||
val := ak.cache.Get(accessTokenCacheKey)
|
||
if val != nil {
|
||
accessToken = val.(string)
|
||
return
|
||
}
|
||
|
||
// cache失效，从微信服务器获取
|
||
var resAccessToken ResAccessToken
|
||
resAccessToken, err = GetTokenFromServerContext(ctx, fmt.Sprintf(workAccessTokenURL, ak.CorpID, ak.CorpSecret))
|
||
if err != nil {
|
||
return
|
||
}
|
||
|
||
expires := resAccessToken.ExpiresIn - 1500
|
||
err = ak.cache.Set(accessTokenCacheKey, resAccessToken.AccessToken, time.Duration(expires)*time.Second)
|
||
|
||
accessToken = resAccessToken.AccessToken
|
||
return
|
||
}
|
||
|
||
// GetTokenFromServer 强制从微信服务器获取token
|
||
func GetTokenFromServer(url string) (resAccessToken ResAccessToken, err error) {
|
||
return GetTokenFromServerContext(context.Background(), url)
|
||
}
|
||
|
||
// GetTokenFromServerContext 强制从微信服务器获取token
|
||
func GetTokenFromServerContext(ctx context.Context, url string) (resAccessToken ResAccessToken, err error) {
|
||
var body []byte
|
||
body, err = util.HTTPGetContext(ctx, url)
|
||
if err != nil {
|
||
return
|
||
}
|
||
err = json.Unmarshal(body, &resAccessToken)
|
||
if err != nil {
|
||
return
|
||
}
|
||
if resAccessToken.ErrCode != 0 {
|
||
err = fmt.Errorf("get access_token error : errcode=%v , errormsg=%v", resAccessToken.ErrCode, resAccessToken.ErrMsg)
|
||
return
|
||
}
|
||
return
|
||
}
|