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();
    }
}