授权码
This commit is contained in:
@@ -133,22 +133,22 @@ func (a *API) AccessAPI(baseUrl, actionApi, method string, bizParams map[string]
|
|||||||
// 获取access_token
|
// 获取access_token
|
||||||
func (a *API) GetAccessToken() (tokenInfo *TokenInfo, err error) {
|
func (a *API) GetAccessToken() (tokenInfo *TokenInfo, err error) {
|
||||||
parameter := make(map[string]interface{}, 6)
|
parameter := make(map[string]interface{}, 6)
|
||||||
parameter["grant_type"] = a.grantType
|
parameter["grant_type"] = "refresh_token"
|
||||||
parameter["app_id"] = a.appID
|
parameter["app_id"] = a.appID
|
||||||
parameter["merchant_id"] = a.merchantId
|
parameter["merchant_id"] = a.merchantId
|
||||||
|
|
||||||
// 先去刷新token,没有的话再去获取token(code只能使用一次,生成的token管一年)
|
// 先去刷新token,没有的话再去获取token(code只能使用一次,生成的token管一年)
|
||||||
var result map[string]interface{}
|
var result map[string]interface{}
|
||||||
parameter["refresh_token"] = a.refreshToken
|
if a.accessToken != "" && a.refreshToken != "" {
|
||||||
if a.refreshToken == "" {
|
result, err = a.AccessAPI(RefreshTokenUrl, "", RequestPost, parameter)
|
||||||
|
} else {
|
||||||
|
parameter["grant_type"] = "authorization_code"
|
||||||
parameter["code"] = a.code
|
parameter["code"] = a.code
|
||||||
result, err = a.AccessAPI(TokenURL, "", RequestPost, parameter)
|
result, err = a.AccessAPI(TokenURL, "", RequestPost, parameter)
|
||||||
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
result, err = a.AccessAPI(RefreshTokenUrl, "", RequestPost, parameter)
|
|
||||||
}
|
|
||||||
|
|
||||||
if err := utils.Map2StructByJson(result, &tokenInfo, false); err != nil {
|
if err := utils.Map2StructByJson(result, &tokenInfo, false); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -25,6 +25,7 @@ type API struct {
|
|||||||
signature string `json:"signature"`
|
signature string `json:"signature"`
|
||||||
timestamp int64 `json:"timestamp"`
|
timestamp int64 `json:"timestamp"`
|
||||||
accessToken string `json:"access_token"`
|
accessToken string `json:"access_token"`
|
||||||
|
refreshToken string `json:"refresh_token"`
|
||||||
appSecret string `json:"app_secret"`
|
appSecret string `json:"app_secret"`
|
||||||
version string `json:"version"`
|
version string `json:"version"`
|
||||||
locker sync.RWMutex
|
locker sync.RWMutex
|
||||||
|
|||||||
@@ -74,19 +74,19 @@ func (a *API) GetAccessToken() (tokenInfo *TokenInfo, err error) {
|
|||||||
parameter["grant_type"] = "refresh_token"
|
parameter["grant_type"] = "refresh_token"
|
||||||
parameter["app_id"] = a.appID
|
parameter["app_id"] = a.appID
|
||||||
parameter["merchant_id"] = a.merchantId
|
parameter["merchant_id"] = a.merchantId
|
||||||
parameter["refresh_token"] = "1"
|
|
||||||
|
|
||||||
// 先去刷新token,没有的话再去获取token(code只能使用一次,生成的token管一年)
|
// 先去刷新token,没有的话再去获取token(code只能使用一次,生成的token管一年)
|
||||||
var result map[string]interface{}
|
var result map[string]interface{}
|
||||||
|
if a.accessToken != "" && a.refreshToken != "" {
|
||||||
result, err = a.AccessAPI(RefreshTokenUrl, "", RequestPost, parameter)
|
result, err = a.AccessAPI(RefreshTokenUrl, "", RequestPost, parameter)
|
||||||
if err != nil {
|
} else {
|
||||||
parameter["grant_type"] = "authorization_code"
|
parameter["grant_type"] = "authorization_code"
|
||||||
parameter["code"] = a.code
|
parameter["code"] = a.code
|
||||||
result, err = a.AccessAPI(TokenURL, "", RequestPost, parameter)
|
result, err = a.AccessAPI(TokenURL, "", RequestPost, parameter)
|
||||||
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
if err := utils.Map2StructByJson(result, &tokenInfo, false); err != nil {
|
if err := utils.Map2StructByJson(result, &tokenInfo, false); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
Reference in New Issue
Block a user