update service wechat

service/wechatoffice/getticket.db.go

@@ -0,0 +1,48 @@
+package wechatoffice
+
+import (
+	"gopkg.in/dtapps/go-library.v3/utils/gotime"
+	"time"
+)
+
+type WechatJsapiTicketDbModel struct {
+	ID          int64     `json:"id"`
+	AppID       string    `json:"app_id"`
+	AppSecret   string    `json:"app_secret"`
+	Ticket      string    `json:"ticket"`
+	ExpiresIn   int       `json:"expires_in"`
+	ExpiresTime string    `json:"expires_time"`
+	CreateTime  time.Time `gorm:"autoCreateTime" json:"-"`
+}
+
+func (m *WechatJsapiTicketDbModel) TableName() string {
+	return "wechat_jsapi_ticket"
+}
+
+func (app *App) wechatJsapiTicketModelTake() (result WechatJsapiTicketDbModel) {
+	app.Db.Where("app_id = ?", app.AppId).Where("expires_time > ?", gotime.Current().Format()).Take(&result)
+	return result
+}
+
+// GetJsapiTicketDb 获取api_ticket
+func (app *App) GetJsapiTicketDb() string {
+	wat := app.wechatJsapiTicketModelTake()
+	if wat.Ticket != "" {
+		return wat.Ticket
+	} else {
+		token := app.GetTicket(app.GetAccessTokenDb(), "jsapi")
+		if token.Result.Ticket == "" {
+			return ""
+		} else {
+			// 创建
+			app.Db.Create(&WechatJsapiTicketDbModel{
+				AppID:       app.AppId,
+				AppSecret:   app.AppSecret,
+				Ticket:      token.Result.Ticket,
+				ExpiresIn:   token.Result.ExpiresIn,
+				ExpiresTime: gotime.Current().AfterSeconds(7000).Format(),
+			})
+			return token.Result.Ticket
+		}
+	}
+}

service/wechatoffice/getticket.go

@@ -5,24 +5,30 @@ import (
 	"fmt"
 )
 
-// GetTicketResult 返回参数
-type GetTicketResult struct {
+type GetTicketRespons struct {
 	Errcode   int    `json:"errcode"` // 错误码
 	Errmsg    string `json:"errmsg"`  // 错误信息
 	Ticket    string `json:"ticket"`
 	ExpiresIn int    `json:"expires_in"`
 }
 
+type GetTicketResult struct {
+	Result GetTicketRespons // 结果
+	Byte   []byte           // 内容
+	Err    error            // 错误
+}
+
+func NewGetTicketResult(result GetTicketRespons, byte []byte, err error) *GetTicketResult {
+	return &GetTicketResult{Result: result, Byte: byte, Err: err}
+}
+
 // GetTicket 获取api_ticket
 // https://developers.weixin.qq.com/doc/offiaccount/OA_Web_Apps/JS-SDK.html
-func (app *App) GetTicket(accessToken, Type string) (result GetTicketResult, err error) {
+func (app *App) GetTicket(accessToken, Type string) *GetTicketResult {
 	// request
 	body, err := app.request(fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=%s&type=%s", accessToken, Type), map[string]interface{}{}, "GET")
-	if err != nil {
-		return
-	}
-	if err = json.Unmarshal(body, &result); err != nil {
-		return
-	}
-	return
+	// 定义
+	var response GetTicketRespons
+	err = json.Unmarshal(body, &response)
+	return NewGetTicketResult(response, body, err)
 }

service/wechatoffice/getticket.monitor.go

@@ -0,0 +1,23 @@
+package wechatoffice
+
+import (
+	"errors"
+)
+
+// AuthGetJsapiTicketMonitor 监控api_ticket
+func (app *App) AuthGetJsapiTicketMonitor(qdType string) error {
+	result := app.GetCallBackIp()
+	if len(result.Result.IpList) <= 0 {
+		switch qdType {
+		case qdTypeDb:
+			app.GetJsapiTicketDb()
+			return nil
+		case qdTypeRdb:
+			app.GetJsapiTicketRDb()
+			return nil
+		default:
+			return errors.New("驱动类型不在范围内")
+		}
+	}
+	return nil
+}

service/wechatoffice/getticket.rdb.go

@@ -0,0 +1,20 @@
+package wechatoffice
+
+import (
+	"fmt"
+	"gopkg.in/dtapps/go-library.v3/utils/goredis"
+)
+
+// GetJsapiTicketRDb 获取api_ticket
+func (app *App) GetJsapiTicketRDb() string {
+	cacheName := fmt.Sprintf("wechat_jsapi_ticket:%v", app.AppId)
+	redis := goredis.App{
+		Rdb: app.RDb,
+	}
+	newCache := redis.NewSimpleStringCache(redis.NewStringOperation(), 7000)
+	newCache.DBGetter = func() string {
+		token := app.GetTicket(app.GetAccessTokenRDb(), "jsapi")
+		return token.Result.Ticket
+	}
+	return newCache.GetCache(cacheName)
+}