代码拉取完成,页面将自动刷新
package weixin
import (
"gitee.com/h79/gothird/token"
"gitee.com/h79/gothird/weixin/errors"
"gitee.com/h79/gothird/weixin/media"
"gitee.com/h79/gothird/weixin/oauth2"
"gitee.com/h79/gothird/weixin/offia/ticket"
"gitee.com/h79/gothird/weixin/session"
"gitee.com/h79/goutils/common/data"
"mime/multipart"
"net/http"
"reflect"
)
var firstService *acsReq
var webService *acsReq
func init() {
firstService = &acsReq{
name: token.WxType,
get: GetAccessToken,
ref: token.GetEmpty,
auth: oauth2.GetAccessToken,
}
webService = &acsReq{
name: token.WxWebType,
get: token.GetEmpty,
ref: oauth2.RefreshToken,
auth: token.GetEmpty,
}
}
func GetService() token.Service {
return firstService
}
func GetWebService() token.Service {
return webService
}
func NewToken(app token.App) token.Token {
return token.New(&app, firstService)
}
func NewWebToken(app token.App) token.Token {
return token.New(&app, webService)
}
type acsReq struct {
name string
check token.CheckErrorFunc
get token.GenFunc
ref token.GenFunc
auth token.GenFunc
}
func (req *acsReq) GetName() string {
return req.name
}
// Execute token.Service interface
func (req *acsReq) Execute(tk token.Token, cmd string, d data.D) (interface{}, error) {
if cmd == token.NTicket {
return ticket.GetTicket(tk, d)
}
if cmd == token.NAccessToken {
return req.get(tk, d)
}
if cmd == token.NRefreshToken {
return req.ref(tk, d)
}
if cmd == token.NOauth2 { // 网页,个人授权,返回一个 openid
acs, err := req.auth(tk, d)
if err != nil {
return nil, err
}
if se, ok := acs.(*session.Session); ok {
ch := &token.Child{
App: token.App{
ParentId: tk.GetId(),
IsCache: tk.IsCache(),
Type: token.WxWebType,
Id: token.GenId(tk.GetAppId(), se.Openid),
AppId: se.Openid,
Name: "web",
},
VMap: token.VMap{},
}
token.SyncCreateChild(tk, webService, ch, acs, []string{se.Openid}, func() {
}) // 需要把个人openid 与 appid 对应
}
return acs, err
}
return nil, token.ErrNotSupported
}
func (req *acsReq) BuildUrl(uri string, acsKey string, d data.D) string {
return token.DefaultUrl(acsKey, uri)
}
func (req *acsReq) SetHead(h *http.Header, acsKey string) {
}
func (req *acsReq) CreateForm(w *multipart.Writer, field string, form interface{}) error {
img, ok := form.(*media.Image)
if !ok {
return token.Result{Code: -1, Msg: "file object not is Image"}
}
val := reflect.ValueOf(img)
if val.CanInterface() && val.Type().Implements(token.FormType) {
fm := val.Interface().(token.Form)
return fm.CreateForm(w, field)
}
return token.DefaultForm(w, field, img.FileName)
}
func (req *acsReq) SetCheckError(check token.CheckErrorFunc) {
req.check = check
}
func (req *acsReq) CheckError(err error) error {
if res, ok := err.(token.Result); ok {
if req.check != nil {
return req.check(&res)
}
if errors.IsExpired(res.Code) {
return token.ErrExpired
}
}
return err
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。