111 lines
4.0 KiB
C#
111 lines
4.0 KiB
C#
using Aop.Api;
|
||
using Aop.Api.Request;
|
||
using Aop.Api.Response;
|
||
using JNPF.Extras.CollectiveOAuth.Cache;
|
||
using JNPF.Extras.CollectiveOAuth.Config;
|
||
using JNPF.Extras.CollectiveOAuth.Models;
|
||
using JNPF.Extras.CollectiveOAuth.Utils;
|
||
using Newtonsoft.Json;
|
||
|
||
namespace JNPF.Extras.CollectiveOAuth.Request;
|
||
|
||
public partial class AlipayMpAuthRequest : DefaultAuthRequest
|
||
{
|
||
private IAopClient aopClient;
|
||
public AlipayMpAuthRequest(ClientConfig config) : base(config, new AlipayMPAuthSource())
|
||
{
|
||
aopClient = new DefaultAopClient(source.accessToken(), config.clientId, config.clientSecret, "json", "1.0", "RSA2", config.alipayPublicKey, "GBK", false);
|
||
}
|
||
|
||
public AlipayMpAuthRequest(ClientConfig config, IAuthStateCache authStateCache) : base(config, new AlipayMPAuthSource(), authStateCache)
|
||
{
|
||
aopClient = new DefaultAopClient(source.accessToken(), config.clientId, config.clientSecret, "json", "1.0", "RSA2", config.alipayPublicKey, "GBK", false);
|
||
}
|
||
|
||
/**
|
||
* 微信的特殊性，此时返回的信息同时包含 openid 和 access_token
|
||
*
|
||
* @param authCallback 回调返回的参数
|
||
* @return 所有信息
|
||
*/
|
||
protected override AuthToken getAccessToken(AuthCallback authCallback)
|
||
{
|
||
AlipaySystemOauthTokenRequest request = new AlipaySystemOauthTokenRequest();
|
||
request.GrantType = "authorization_code";
|
||
request.Code = authCallback.auth_code;
|
||
AlipaySystemOauthTokenResponse response = null;
|
||
try
|
||
{
|
||
response = this.aopClient.Execute(request);
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
throw new Exception(e.Message);
|
||
}
|
||
if (response.IsError)
|
||
{
|
||
throw new Exception(response.SubMsg);
|
||
}
|
||
|
||
var authToken = new AuthToken();
|
||
authToken.accessToken = response.AccessToken;
|
||
authToken.uid = response.UserId;
|
||
authToken.expireIn = Convert.ToInt32(response.ExpiresIn);
|
||
authToken.refreshToken = response.RefreshToken;
|
||
authToken.userId = response.AlipayUserId;
|
||
|
||
return authToken;
|
||
}
|
||
|
||
protected override AuthUser getUserInfo(AuthToken authToken)
|
||
{
|
||
string accessToken = authToken.accessToken;
|
||
AlipayUserInfoShareRequest request = new AlipayUserInfoShareRequest();
|
||
AlipayUserInfoShareResponse response = null;
|
||
try
|
||
{
|
||
response = this.aopClient.Execute(request, accessToken);
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
throw new Exception(e.Message, e);
|
||
}
|
||
if (response.IsError)
|
||
{
|
||
throw new Exception(response.SubMsg);
|
||
}
|
||
|
||
string province = response.Province, city = response.City;
|
||
string location = string.Format("{0} {1}", !province.IsNullOrWhiteSpace() ? "" : province, !city.IsNullOrWhiteSpace() ? "" : city);
|
||
|
||
var authUser = new AuthUser();
|
||
authUser.username = response.UserName.IsNullOrWhiteSpace() ? response.NickName : response.UserName;
|
||
authUser.nickname = response.NickName;
|
||
authUser.avatar = response.Avatar;
|
||
authUser.location = location;
|
||
authUser.uuid = response.UserId;
|
||
authUser.gender = GlobalAuthUtil.getRealGender(response.Gender);
|
||
authUser.token = authToken;
|
||
authUser.source = source.getName();
|
||
authUser.originalUser = response;
|
||
authUser.originalUserStr = JsonConvert.SerializeObject(response);
|
||
return authUser;
|
||
}
|
||
|
||
/**
|
||
* 返回带{@code state}参数的授权url，授权回调时会带上这个{@code state}
|
||
*
|
||
* @param state state 验证授权流程的参数，可以防止csrf
|
||
* @return 返回授权地址
|
||
* @since 1.9.3
|
||
*/
|
||
public override string authorize(string state)
|
||
{
|
||
return UrlBuilder.fromBaseUrl(source.authorize())
|
||
.queryParam("app_id", config.clientId)
|
||
.queryParam("scope", config.scope.IsNullOrWhiteSpace() ? "auth_user" : config.scope)
|
||
.queryParam("redirect_uri", config.redirectUri)
|
||
.queryParam("state", getRealState(state))
|
||
.build();
|
||
}
|
||
} |