dtapps
/
go-library
1
0
Fork 0
Code Issues Pull Requests Projects Releases 40 Wiki Activity

优化微信服务

Browse Source
master
李光春 2 years ago
parent 47d9cefb40
commit f18d18d7a2
3 changed files with 6 additions and 78 deletions
Show Stats Download Patch File Download Diff File

28
service/wechatminiprogram/cgi-bin.token.monitor.go
Unescape View File

@ -2,10 +2,6 @@ package wechatminiprogram
import (
"errors"
"fmt"
"gopkg.in/dtapps/go-library.v3/utils/goredis"
"gopkg.in/dtapps/go-library.v3/utils/gotime"
"time"
)
var (
@ -21,32 +17,12 @@ func (app *App) AuthGetAccessTokenMonitor(qdType string) error {
if app.Db == nil {
return errors.New("驱动没有初始化")
}
token := app.AuthGetAccessToken()
if token.Result.AccessToken == "" {
return errors.New("获取AccessToken失败")
} else {
app.Db.Create(&WechatAccessTokenDbModel{
AppID: app.AppId,
AppSecret: app.AppSecret,
AccessToken: token.Result.AccessToken,
ExpiresIn: token.Result.ExpiresIn,
ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
})
return nil
}
app.GetAccessTokenDb()
case QdTypeRdb:
if app.RDb == nil {
return errors.New("驱动没有初始化")
}
cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
redis := goredis.App{
Rdb: app.RDb,
}
token := app.AuthGetAccessToken()
if token.Result.AccessToken == "" {
return errors.New("获取AccessToken失败")
}
redis.NewStringOperation().Set(cacheName, token.Result.AccessToken, goredis.WithExpire(time.Second*7000))
app.GetAccessTokenRDb()
return nil
default:
return errors.New("驱动类型不在范围内")

28
service/wechatoffice/cgi-bin.token.monitor.go
Unescape View File

@ -2,10 +2,6 @@ package wechatoffice
import (
"errors"
"fmt"
"gopkg.in/dtapps/go-library.v3/utils/goredis"
"gopkg.in/dtapps/go-library.v3/utils/gotime"
"time"
)
var (
@ -21,32 +17,12 @@ func (app *App) AuthGetAccessTokenMonitor(qdType string) error {
if app.Db == nil {
return errors.New("驱动没有初始化")
}
token := app.AuthGetAccessToken()
if token.Result.AccessToken == "" {
return errors.New("获取AccessToken失败")
} else {
app.Db.Create(&WechatAccessTokenDbModel{
AppID: app.AppId,
AppSecret: app.AppSecret,
AccessToken: token.Result.AccessToken,
ExpiresIn: token.Result.ExpiresIn,
ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
})
return nil
}
app.GetAccessTokenDb()
case QdTypeRdb:
if app.RDb == nil {
return errors.New("驱动没有初始化")
}
cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
redis := goredis.App{
Rdb: app.RDb,
}
token := app.AuthGetAccessToken()
if token.Result.AccessToken == "" {
return errors.New("获取AccessToken失败")
}
redis.NewStringOperation().Set(cacheName, token.Result.AccessToken, goredis.WithExpire(time.Second*7000))
app.GetAccessTokenRDb()
return nil
default:
return errors.New("驱动类型不在范围内")

28
service/wechatunion/cgi-bin.token.monitor.go
Unescape View File

@ -2,10 +2,6 @@ package wechatunion
import (
"errors"
"fmt"
"gopkg.in/dtapps/go-library.v3/utils/goredis"
"gopkg.in/dtapps/go-library.v3/utils/gotime"
"time"
)
var (
@ -21,32 +17,12 @@ func (app *App) AuthGetAccessTokenMonitor(qdType string) error {
if app.Db == nil {
return errors.New("驱动没有初始化")
}
token := app.AuthGetAccessToken()
if token.Result.AccessToken == "" {
return errors.New("获取AccessToken失败")
} else {
app.Db.Create(&WechatAccessTokenDbModel{
AppID: app.AppId,
AppSecret: app.AppSecret,
AccessToken: token.Result.AccessToken,
ExpiresIn: token.Result.ExpiresIn,
ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
})
return nil
}
app.GetAccessTokenDb()
case QdTypeRdb:
if app.RDb == nil {
return errors.New("驱动没有初始化")
}
cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
redis := goredis.App{
Rdb: app.RDb,
}
token := app.AuthGetAccessToken()
if token.Result.AccessToken == "" {
return errors.New("获取AccessToken失败")
}
redis.NewStringOperation().Set(cacheName, token.Result.AccessToken, goredis.WithExpire(time.Second*7000))
app.GetAccessTokenRDb()
return nil
default:
return errors.New("驱动类型不在范围内")

Write Preview
Loading…
Cancel
Save