using System;
|
using Microsoft.AspNetCore.Mvc;
|
using System.Text;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.Caching.AccressToken;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Loging;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.WeChat.Service.HttpClients;
|
using CoreCms.Net.WeChat.Service.Enums;
|
using CoreCms.Net.WeChat.Service.Models;
|
using Microsoft.AspNetCore.Http;
|
using Newtonsoft.Json;
|
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
using SKIT.FlurlHttpClient.Wechat.Api;
|
using LogLevel = NLog.LogLevel;
|
|
namespace CoreCms.Net.Web.Controllers.WeChat
|
{
|
/// <summary>
|
/// 微信公众号用户授权事件
|
/// </summary>
|
public class WeChatOffiaccountOAuth2Controller : ControllerBase
|
{
|
//private readonly string _weChatAppId = AppSettingsConstVars.WeiXinAppId;
|
//private readonly string _weChatSecret = AppSettingsConstVars.WeiXinAppSecret;
|
//private readonly string _weChatOAuth2CallBackUrl = AppSettingsConstVars.AppConfigAppInterFaceUrl + "/WeCharOAuth2/UserInfoCallback";
|
|
private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
private readonly IWeChatUserAccessTokenServices _weChatUserAccessTokenServices;
|
private readonly ICoreCmsUserWeChatInfoServices _weChatUserInfoServices;
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public WeChatOffiaccountOAuth2Controller(IWeChatApiHttpClientFactory weChatApiHttpClientFactory, IWeChatUserAccessTokenServices weChatUserAccessTokenServices, ICoreCmsUserWeChatInfoServices weChatUserInfoServices)
|
{
|
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
_weChatUserAccessTokenServices = weChatUserAccessTokenServices;
|
_weChatUserInfoServices = weChatUserInfoServices;
|
}
|
|
/// <summary>
|
/// OAuthScope.snsapi_userinfo方式回调
|
/// </summary>
|
/// <param name="code"></param>
|
/// <param name="state"></param>
|
/// <param name="bkUrl"></param>
|
/// <returns></returns>
|
[HttpGet]
|
public async Task<ActionResult> UserInfoCallback(string code, string state, string bkUrl)
|
{
|
if (string.IsNullOrEmpty(code))
|
{
|
return Content("您拒绝了授权！");
|
}
|
|
//if (!state.Contains(","))
|
//{
|
// //这里的state其实是会暴露给客户端的，验证能力很弱，这里只是演示一下
|
// //实际上可以存任何想传递的数据，比如用户ID，并且需要结合例如下面的Session["OAuthAccessToken"]进行验证
|
// return Content("验证失败！请从正规途径进入！");
|
//}
|
|
var client = _weChatApiHttpClientFactory.CreateWeXinClient();
|
var accessToken = WeChatCacheAccessTokenHelper.GetWeChatAccessToken();
|
|
var request = new SnsOAuth2AccessTokenRequest()
|
{
|
AccessToken = accessToken,
|
Code = code
|
};
|
|
var response = await client.ExecuteSnsOAuth2AccessTokenAsync(request, HttpContext.RequestAborted);
|
if (response.ErrorCode != (int)WeChatReturnCode.ReturnCode.请求成功)
|
{
|
return Content("错误：" + response.ErrorMessage);
|
}
|
|
NLogUtil.WriteFileLog(LogLevel.Info, LogType.WeChat, "获取用户accessToken", JsonConvert.SerializeObject(response));
|
|
var accessTokenModel = await _weChatUserAccessTokenServices.QueryByClauseAsync(p => p.openid == response.OpenId);
|
if (accessTokenModel == null)
|
{
|
accessTokenModel = new WeChatUserAccessToken();
|
accessTokenModel.access_token = response.AccessToken;
|
accessTokenModel.expires_in = response.ExpiresIn;
|
accessTokenModel.openid = response.OpenId;
|
accessTokenModel.refresh_token = response.RefreshToken;
|
accessTokenModel.scope = response.Scope;
|
accessTokenModel.unionid = response.UnionId;
|
accessTokenModel.refresh_DateTime = DateTime.Now.AddSeconds(response.ExpiresIn);
|
await _weChatUserAccessTokenServices.InsertAsync(accessTokenModel);
|
}
|
else
|
{
|
accessTokenModel.access_token = response.AccessToken;
|
accessTokenModel.expires_in = response.ExpiresIn;
|
//accessTokenModel.openid = response.OpenId;
|
accessTokenModel.refresh_token = response.RefreshToken;
|
accessTokenModel.scope = response.Scope;
|
accessTokenModel.unionid = response.UnionId;
|
accessTokenModel.refresh_DateTime = DateTime.Now.AddSeconds(response.ExpiresIn);
|
await _weChatUserAccessTokenServices.UpdateAsync(accessTokenModel);
|
}
|
|
//因为第一步选择的是OAuthScope.snsapi_userinfo，这里可以进一步获取用户详细信息
|
try
|
{
|
var userInfoRequest = new SnsUserInfoRequest()
|
{
|
AccessToken = response.AccessToken,
|
OpenId = response.OpenId
|
};
|
|
var userInfoResponse = await client.ExecuteSnsUserInfoAsync(userInfoRequest, HttpContext.RequestAborted);
|
if (userInfoResponse.ErrorCode == (int)WeChatReturnCode.ReturnCode.请求成功)
|
{
|
var weChatUserInfo = await _weChatUserInfoServices.QueryByClauseAsync(p => p.openid == response.OpenId);
|
if (weChatUserInfo == null)
|
{
|
weChatUserInfo = new CoreCmsUserWeChatInfo()
|
{
|
createTime = DateTime.Now,
|
type = (int)GlobalEnumVars.UserAccountTypes.微信公众号,
|
//city = userInfoResponse.City,
|
//country = userInfoResponse.Country,
|
//province = userInfoResponse.Province,
|
nickName = userInfoResponse.Nickname,
|
//gender = userInfoResponse.Sex,
|
avatar = userInfoResponse.HeadImageUrl,
|
unionId = userInfoResponse.UnionId,
|
openid = userInfoResponse.OpenId,
|
gender = 1,
|
//isSubscribe = userInfoResponse.PrivilegeList,
|
|
};
|
var id = await _weChatUserInfoServices.InsertAsync(weChatUserInfo);
|
if (id > 0)
|
{
|
await _weChatUserInfoServices.UpdateAsync(
|
p => new CoreCmsUserWeChatInfo()
|
{
|
userId = id
|
}, p => p.id == id);
|
}
|
}
|
else
|
{
|
if (weChatUserInfo.nickName != userInfoResponse.Nickname || weChatUserInfo.avatar != userInfoResponse.HeadImageUrl || weChatUserInfo.unionId != userInfoResponse.UnionId)
|
{
|
weChatUserInfo.nickName = userInfoResponse.Nickname;
|
weChatUserInfo.avatar = userInfoResponse.HeadImageUrl;
|
weChatUserInfo.unionId = userInfoResponse.UnionId;
|
await _weChatUserInfoServices.UpdateAsync(weChatUserInfo);
|
}
|
}
|
}
|
else
|
{
|
return Content("错误：" + response.ErrorMessage);
|
}
|
|
var option = new CookieOptions
|
{
|
Expires = DateTime.Now.AddSeconds(1440)
|
};
|
|
Response.Cookies.Append(GlobalConstVars.CookieOpenId, userInfoResponse.OpenId, option);
|
|
if (!string.IsNullOrEmpty(bkUrl))
|
{
|
var outBase64String = Convert.FromBase64String(bkUrl);
|
var orgStr = Encoding.Default.GetString(outBase64String);
|
|
return Redirect(orgStr);
|
}
|
else
|
{
|
return Redirect(AppSettingsConstVars.AppConfigAppH5Url);
|
}
|
}
|
catch (Exception ex)
|
{
|
return Content(ex.Message);
|
}
|
}
|
|
}
|
}
|
