Go-获取小程序访问ACCESS_TOKEN

阳光穿透心脏的1/2处 2022-08-31 06:54 205阅读 0赞

// GetAccessToken 获取访问TOKEN
    func GetAccessToken(waID, appID, appSecret string) string {
    	if len(waID) == 0 || len(appID) == 0 || len(appSecret) == 0 {
    		log.WithFields(log.Fields{
    			"error":     "参数错误",
    			"waID":      waID,
    			"appID":     appID,
    			"appSecret": appSecret,
    		}).Warn("公众号标识获取-GetAccessToken")
    
    		return ""
    	}
    
    	redis1 := NewRedis("REDIS_ALL_HOST1")
    	if accessToken, accessTokenErr := redis1.Get("wechat_access_token_" + waID); accessTokenErr == nil && !common.Empty(accessToken) {
    		return accessToken.(string)
    	}
    
    	url := fmt.Sprintf(ACCESS_TOKEN_URL, appID, appSecret)
    	tokenBody, tokenErr := http.Get(url)
    	if tokenErr != nil {
    		log.WithFields(log.Fields{"error": tokenErr}).Warn("token请求-GetAccessToken")
    		return ""
    	}
    
    	defer tokenBody.Body.Close()
    	tokenResp := AccessTokenRule{}
    	decoder := json.NewDecoder(tokenBody.Body)
    	if decodeErr := decoder.Decode(&tokenResp); decodeErr != nil {
    		log.WithFields(log.Fields{"error": decodeErr}).Warn("json解密-GetAccessToken")
    		return ""
    	}
    
    	if tokenResp.ErrCode != 0 {
    		log.WithFields(log.Fields{"error": tokenResp}).Warn("官方提示-GetAccessToken")
    		return ""
    	}
    
    	setResult, setErr := redis1.Set("wechat_access_token_"+waID, tokenResp.AccessToken, 7000)
    	if setErr != nil || !setResult {
    		log.WithFields(log.Fields{"error": setErr, "setResult": setResult}).Warn("TOKEN缓存")
    		return ""
    	}
    
    	return tokenResp.AccessToken
    }

小程序token过期时间7200秒，且没有刷新token的接口，所以我这边是定义的缓存时间7000秒，可以在有效期内刷新缓存内的token。