|
@@ -12,6 +12,7 @@ import (
|
|
|
"net/http"
|
|
|
"time"
|
|
|
|
|
|
+ "github.com/go-redis/redis/v8"
|
|
|
"github.com/silenceper/wechat/v2"
|
|
|
"github.com/silenceper/wechat/v2/cache"
|
|
|
"github.com/silenceper/wechat/v2/credential"
|
|
@@ -54,7 +55,7 @@ var DefaultKey = "zcmRedis"
|
|
|
func (wechat WechatAccessToken) GetAccessToken() (accessToken string, err error) {
|
|
|
accessToken, err = utils.Redis.Get(context.TODO(), utils.CACHE_WX_ACCESS_TOKEN_HZ).Result()
|
|
|
// wxToken, err := models.GetWxTokenById()
|
|
|
- if err != nil {
|
|
|
+ if err != nil && err != redis.Nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -65,7 +66,6 @@ func (wechat WechatAccessToken) GetAccessToken() (accessToken string, err error)
|
|
|
err = errors.New("获取微信token失败,Err:" + tmpErr.Error())
|
|
|
return
|
|
|
}
|
|
|
- alarm_msg.SendAlarmMsg(fmt.Sprintf("获取微信token成功:%s", tmpAccessToken), 1)
|
|
|
redisTimeExpire := time.Duration(expires-600) * time.Second
|
|
|
err = utils.Redis.SetEX(context.TODO(), utils.CACHE_WX_ACCESS_TOKEN_HZ, tmpAccessToken, redisTimeExpire).Err()
|
|
|
if err != nil {
|