update service wechat

service/ip/app_test.go

@@ -0,0 +1,16 @@
+package ip
+
+import (
+	"net"
+	"testing"
+)
+
+var app App
+
+func TestIp(t *testing.T) {
+	t.Log(net.ParseIP("61.241.55.180").To4())
+	t.Log(net.ParseIP("240e:3b4:38e4:3295:7093:af6c:e545:f2e9").To16())
+	t.Log(app.V4db.Find("61.241.55.180"))
+	t.Log(app.V6db.Find("240e:3b4:38e4:3295:7093:af6c:e545:f2e9"))
+	t.Log(app.V4Region.MemorySearch("61.241.55.180"))
+}

service/wechatminiprogram/cgi-bin.token.db.go

@@ -0,0 +1,47 @@
+package wechatminiprogram
+
+import (
+	"gopkg.in/dtapps/go-library.v3/utils/gotime"
+	"time"
+)
+
+type WechatAccessTokenDbModel struct {
+	ID          int64     `json:"id"`
+	AppID       string    `json:"app_id"`
+	AppSecret   string    `json:"app_secret"`
+	AccessToken string    `json:"access_token"`
+	ExpiresIn   int       `json:"expires_in"`
+	ExpiresTime string    `json:"expires_time"`
+	CreateTime  time.Time `gorm:"autoCreateTime" json:"-"`
+}
+
+func (m *WechatAccessTokenDbModel) TableName() string {
+	return "wechat_access_token"
+}
+
+func (app *App) wechatAccessTokenModelTake() (result WechatAccessTokenDbModel) {
+	app.Db.Where("app_id = ?", app.AppId).Where("expires_time > ?", gotime.Current().Format()).Take(&result)
+	return result
+}
+
+func (app *App) GetAccessTokenDb() string {
+	wat := app.wechatAccessTokenModelTake()
+	if wat.AccessToken != "" {
+		return wat.AccessToken
+	} else {
+		token, _ := app.AuthGetAccessToken()
+		if token.AccessToken == "" {
+			return ""
+		} else {
+			// 创建
+			app.Db.Create(&WechatAccessTokenDbModel{
+				AppID:       app.AppId,
+				AppSecret:   app.AppSecret,
+				AccessToken: token.AccessToken,
+				ExpiresIn:   token.ExpiresIn,
+				ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
+			})
+			return token.AccessToken
+		}
+	}
+}

service/wechatminiprogram/cgi-bin.token.rdb.go

@@ -0,0 +1,19 @@
+package wechatminiprogram
+
+import (
+	"fmt"
+	"gopkg.in/dtapps/go-library.v3/utils/goredis"
+)
+
+func (app *App) GetAccessTokenRDb() string {
+	cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
+	redis := goredis.App{
+		Rdb: app.RDb,
+	}
+	newCache := redis.NewSimpleStringCache(redis.NewStringOperation(), 7000)
+	newCache.DBGetter = func() string {
+		token, _ := app.AuthGetAccessToken()
+		return token.AccessToken
+	}
+	return newCache.GetCache(cacheName)
+}

service/wechatmp/cgi-bin.token.db.go

@@ -0,0 +1,47 @@
+package wechatmp
+
+import (
+	"gopkg.in/dtapps/go-library.v3/utils/gotime"
+	"time"
+)
+
+type WechatAccessTokenDbModel struct {
+	ID          int64     `json:"id"`
+	AppID       string    `json:"app_id"`
+	AppSecret   string    `json:"app_secret"`
+	AccessToken string    `json:"access_token"`
+	ExpiresIn   int       `json:"expires_in"`
+	ExpiresTime string    `json:"expires_time"`
+	CreateTime  time.Time `gorm:"autoCreateTime" json:"-"`
+}
+
+func (m *WechatAccessTokenDbModel) TableName() string {
+	return "wechat_access_token"
+}
+
+func (app *App) wechatAccessTokenModelTake() (result WechatAccessTokenDbModel) {
+	app.Db.Where("app_id = ?", app.AppId).Where("expires_time > ?", gotime.Current().Format()).Take(&result)
+	return result
+}
+
+func (app *App) GetAccessTokenDb() string {
+	wat := app.wechatAccessTokenModelTake()
+	if wat.AccessToken != "" {
+		return wat.AccessToken
+	} else {
+		token, _ := app.AuthGetAccessToken()
+		if token.AccessToken == "" {
+			return ""
+		} else {
+			// 创建
+			app.Db.Create(&WechatAccessTokenDbModel{
+				AppID:       app.AppId,
+				AppSecret:   app.AppSecret,
+				AccessToken: token.AccessToken,
+				ExpiresIn:   token.ExpiresIn,
+				ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
+			})
+			return token.AccessToken
+		}
+	}
+}

service/wechatmp/cgi-bin.token.rdb.go

@@ -0,0 +1,19 @@
+package wechatmp
+
+import (
+	"fmt"
+	"gopkg.in/dtapps/go-library.v3/utils/goredis"
+)
+
+func (app *App) GetAccessTokenRDb() string {
+	cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
+	redis := goredis.App{
+		Rdb: app.RDb,
+	}
+	newCache := redis.NewSimpleStringCache(redis.NewStringOperation(), 7000)
+	newCache.DBGetter = func() string {
+		token, _ := app.AuthGetAccessToken()
+		return token.AccessToken
+	}
+	return newCache.GetCache(cacheName)
+}

service/wechatoffice/cgi-bin.token.db.go

@@ -0,0 +1,47 @@
+package wechatoffice
+
+import (
+	"gopkg.in/dtapps/go-library.v3/utils/gotime"
+	"time"
+)
+
+type WechatAccessTokenDbModel struct {
+	ID          int64     `json:"id"`
+	AppID       string    `json:"app_id"`
+	AppSecret   string    `json:"app_secret"`
+	AccessToken string    `json:"access_token"`
+	ExpiresIn   int       `json:"expires_in"`
+	ExpiresTime string    `json:"expires_time"`
+	CreateTime  time.Time `gorm:"autoCreateTime" json:"-"`
+}
+
+func (m *WechatAccessTokenDbModel) TableName() string {
+	return "wechat_access_token"
+}
+
+func (app *App) wechatAccessTokenModelTake() (result WechatAccessTokenDbModel) {
+	app.Db.Where("app_id = ?", app.AppId).Where("expires_time > ?", gotime.Current().Format()).Take(&result)
+	return result
+}
+
+func (app *App) GetAccessTokenDb() string {
+	wat := app.wechatAccessTokenModelTake()
+	if wat.AccessToken != "" {
+		return wat.AccessToken
+	} else {
+		token, _ := app.AuthGetAccessToken()
+		if token.AccessToken == "" {
+			return ""
+		} else {
+			// 创建
+			app.Db.Create(&WechatAccessTokenDbModel{
+				AppID:       app.AppId,
+				AppSecret:   app.AppSecret,
+				AccessToken: token.AccessToken,
+				ExpiresIn:   token.ExpiresIn,
+				ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
+			})
+			return token.AccessToken
+		}
+	}
+}

service/wechatoffice/cgi-bin.token.rdb.go

@@ -0,0 +1,19 @@
+package wechatoffice
+
+import (
+	"fmt"
+	"gopkg.in/dtapps/go-library.v3/utils/goredis"
+)
+
+func (app *App) GetAccessTokenRDb() string {
+	cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
+	redis := goredis.App{
+		Rdb: app.RDb,
+	}
+	newCache := redis.NewSimpleStringCache(redis.NewStringOperation(), 7000)
+	newCache.DBGetter = func() string {
+		token, _ := app.AuthGetAccessToken()
+		return token.AccessToken
+	}
+	return newCache.GetCache(cacheName)
+}

service/wechatunion/cgi-bin.token.db.go

@@ -0,0 +1,47 @@
+package wechatunion
+
+import (
+	"gopkg.in/dtapps/go-library.v3/utils/gotime"
+	"time"
+)
+
+type WechatAccessTokenDbModel struct {
+	ID          int64     `json:"id"`
+	AppID       string    `json:"app_id"`
+	AppSecret   string    `json:"app_secret"`
+	AccessToken string    `json:"access_token"`
+	ExpiresIn   int       `json:"expires_in"`
+	ExpiresTime string    `json:"expires_time"`
+	CreateTime  time.Time `gorm:"autoCreateTime" json:"-"`
+}
+
+func (m *WechatAccessTokenDbModel) TableName() string {
+	return "wechat_access_token"
+}
+
+func (app *App) wechatAccessTokenModelTake() (result WechatAccessTokenDbModel) {
+	app.Db.Where("app_id = ?", app.AppId).Where("expires_time > ?", gotime.Current().Format()).Take(&result)
+	return result
+}
+
+func (app *App) GetAccessTokenDb() string {
+	wat := app.wechatAccessTokenModelTake()
+	if wat.AccessToken != "" {
+		return wat.AccessToken
+	} else {
+		token := app.AuthGetAccessToken()
+		if token.Result.AccessToken == "" {
+			return ""
+		} 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 token.Result.AccessToken
+		}
+	}
+}

service/wechatunion/cgi-bin.token.rdb.go

@@ -0,0 +1,19 @@
+package wechatunion
+
+import (
+	"fmt"
+	"gopkg.in/dtapps/go-library.v3/utils/goredis"
+)
+
+func (app *App) GetAccessTokenRDb() string {
+	cacheName := fmt.Sprintf("wechat_access_token:%v", app.AppId)
+	redis := goredis.App{
+		Rdb: app.RDb,
+	}
+	newCache := redis.NewSimpleStringCache(redis.NewStringOperation(), 7000)
+	newCache.DBGetter = func() string {
+		token := app.AuthGetAccessToken()
+		return token.Result.AccessToken
+	}
+	return newCache.GetCache(cacheName)
+}

service/wechatunion/cgi_bin.token.go

@@ -6,22 +6,37 @@ import (
 	"net/http"
 )
 
-// 返回参数
 type authGetAccessTokenResult struct {
-	AccessToken string `json:"access_token"` // 获取到的凭证
-	ExpiresIn   int    `json:"expires_in"`   // 凭证有效时间，单位：秒。目前是7200秒之内的值
-	Errcode     int    `json:"errcode"`      // 错误码
-	Errmsg      string `json:"errmsg"`       // 错误信息
+	Byte   []byte                     // 内容
+	Result authGetAccessTokenResponse // 结果
+	Err    error                      // 错误
+}
+
+// NewAuthGetAccessTokenResult 实例化
+func NewAuthGetAccessTokenResult(byte []byte, result authGetAccessTokenResponse, err error) *authGetAccessTokenResult {
+	return &authGetAccessTokenResult{
+		Byte:   byte,
+		Result: result,
+		Err:    err,
+	}
 }
 
 // AuthGetAccessToken
 // 接口调用凭证
 // https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/access-token/auth.getAccessToken.html
-func (app *App) AuthGetAccessToken() (accessToken string, err error) {
+func (app *App) AuthGetAccessToken() *authGetAccessTokenResult {
 	// 请求
 	body, err := app.request(fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s", app.AppId, app.AppSecret), map[string]interface{}{}, http.MethodGet)
 	// 定义
-	var result authGetAccessTokenResult
-	err = json.Unmarshal(body, &result)
-	return result.AccessToken, err
+	var response authGetAccessTokenResponse
+	err = json.Unmarshal(body, &response)
+	return NewAuthGetAccessTokenResult(body, response, err)
+}
+
+// 返回参数
+type authGetAccessTokenResponse struct {
+	AccessToken string `json:"access_token"` // 获取到的凭证
+	ExpiresIn   int    `json:"expires_in"`   // 凭证有效时间，单位：秒。目前是7200秒之内的值
+	Errcode     int    `json:"errcode"`      // 错误码
+	Errmsg      string `json:"errmsg"`       // 错误信息
 }