mirror of
http://git.coreshop.cn/jianweie/coreshoppro.git
synced 2025-12-06 14:53:26 +08:00
258 lines
14 KiB
C#
258 lines
14 KiB
C#
/***********************************************************************
|
||
* Project: CoreCms.Net *
|
||
* Web: https://CoreCms.Net *
|
||
* ProjectName: 核心内容管理系统 *
|
||
* Author: 大灰灰 *
|
||
* Email: JianWeie@163.com *
|
||
* CreateTime: 2020-08-25 1:25:29
|
||
* Description: 暂无
|
||
***********************************************************************/
|
||
|
||
|
||
using System;
|
||
using CoreCms.Net.Caching.AccressToken;
|
||
using CoreCms.Net.Caching.AutoMate.RedisCache;
|
||
using CoreCms.Net.Configuration;
|
||
using CoreCms.Net.IServices;
|
||
using CoreCms.Net.Model.Entities;
|
||
using CoreCms.Net.WeChat.Service.HttpClients;
|
||
using CoreCms.Net.WeChat.Service.Options;
|
||
using Microsoft.Extensions.Options;
|
||
using Newtonsoft.Json;
|
||
using SKIT.FlurlHttpClient;
|
||
using SKIT.FlurlHttpClient.Wechat;
|
||
using SKIT.FlurlHttpClient.Wechat.Api;
|
||
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
||
|
||
|
||
namespace CoreCms.Net.Task
|
||
{
|
||
/// <summary>
|
||
/// 定时刷新获取微信AccessToken
|
||
/// </summary>
|
||
public class RefreshWeChatAccessTokenJob
|
||
{
|
||
private readonly ISysTaskLogServices _taskLogServices;
|
||
|
||
private readonly IRedisOperationRepository _redisOperationRepository;
|
||
|
||
private readonly WeChatOptions _weChatOptions;
|
||
private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
||
private readonly IWeChatAccessTokenServices _weChatAccessTokenServices;
|
||
|
||
|
||
public RefreshWeChatAccessTokenJob(IRedisOperationRepository redisOperationRepository, ISysTaskLogServices taskLogServices, IOptions<WeChatOptions> weChatOptions, IWeChatApiHttpClientFactory weChatApiHttpClientFactory, IWeChatAccessTokenServices weChatAccessTokenServices)
|
||
{
|
||
_redisOperationRepository = redisOperationRepository;
|
||
_taskLogServices = taskLogServices;
|
||
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
||
_weChatAccessTokenServices = weChatAccessTokenServices;
|
||
_weChatOptions = weChatOptions.Value;
|
||
}
|
||
|
||
public async System.Threading.Tasks.Task Execute()
|
||
{
|
||
try
|
||
{
|
||
//微信公众号刷新
|
||
if (!string.IsNullOrEmpty(_weChatOptions.WeiXinAppId) && !string.IsNullOrEmpty(_weChatOptions.WeiXinAppSecret))
|
||
{
|
||
var entity = await _weChatAccessTokenServices.QueryByClauseAsync(p => p.appId == _weChatOptions.WeiXinAppId && p.appType == (int)GlobalEnumVars.AccessTokenEnum.WeiXinAccessToken);
|
||
if (entity == null || entity.expireTimestamp <= DateTimeOffset.Now.ToUnixTimeSeconds())
|
||
{
|
||
var client = _weChatApiHttpClientFactory.CreateWeXinClient();
|
||
|
||
var request = new CgibinTokenRequest();
|
||
var response = await client.ExecuteCgibinTokenAsync(request);
|
||
if (!response.IsSuccessful())
|
||
{
|
||
//插入日志
|
||
var log = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = false,
|
||
name = "定时刷新获取微信AccessToken",
|
||
parameters = $"刷新 AppId 为 {_weChatOptions.WeiXinAppId} 微信 AccessToken 失败（错误代码：{response.ErrorCode}，错误描述：{response.ErrorMessage}）。"
|
||
};
|
||
await _taskLogServices.InsertAsync(log);
|
||
}
|
||
else
|
||
{
|
||
// 提前十分钟过期，以便于系统能及时刷新，防止因在过期临界点时出现问题
|
||
long nextExpireTimestamp = DateTimeOffset.Now.AddSeconds(response.ExpiresIn).AddMinutes(-10).ToUnixTimeSeconds();
|
||
|
||
if (entity == null)
|
||
{
|
||
entity = new WeChatAccessToken();
|
||
|
||
entity.appId = _weChatOptions.WeiXinAppId;
|
||
entity.accessToken = response.AccessToken;
|
||
entity.appType = (int)GlobalEnumVars.AccessTokenEnum.WeiXinAccessToken;
|
||
entity.expireTimestamp = nextExpireTimestamp;
|
||
entity.createTimestamp = DateTimeOffset.Now.ToUnixTimeSeconds();
|
||
entity.updateTimestamp = entity.createTimestamp;
|
||
|
||
entity.id = await _weChatAccessTokenServices.InsertAsync(entity);
|
||
}
|
||
else
|
||
{
|
||
entity.accessToken = response.AccessToken;
|
||
entity.expireTimestamp = nextExpireTimestamp;
|
||
entity.updateTimestamp = DateTimeOffset.Now.ToUnixTimeSeconds();
|
||
await _weChatAccessTokenServices.UpdateAsync(entity);
|
||
}
|
||
await _redisOperationRepository.SetAsync(GlobalEnumVars.AccessTokenEnum.WeiXinAccessToken.ToString(), entity, TimeSpan.FromMinutes(120));
|
||
|
||
//获取js-token并且全局缓存
|
||
var requestJsTicket = new CgibinTicketGetTicketRequest();
|
||
requestJsTicket.AccessToken = response.AccessToken;
|
||
|
||
var responseJsTicket = await client.ExecuteCgibinTicketGetTicketAsync(requestJsTicket);
|
||
if (responseJsTicket.IsSuccessful())
|
||
{
|
||
//插入缓存
|
||
await _redisOperationRepository.SetAsync(GlobalEnumVars.JsApiTicketEnum.WeiXinJsApiTicket.ToString(), responseJsTicket, TimeSpan.FromMinutes(120));
|
||
}
|
||
|
||
|
||
//插入日志
|
||
var model = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = true,
|
||
name = "定时刷新获取微信AccessToken",
|
||
parameters = JsonConvert.SerializeObject(entity)
|
||
};
|
||
await _taskLogServices.InsertAsync(model);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
var accessToken = WeChatCacheAccessTokenHelper.GetWeChatAccessToken();
|
||
if (string.IsNullOrEmpty(accessToken) && entity.expireTimestamp > DateTimeOffset.Now.ToUnixTimeSeconds())
|
||
{
|
||
// 将时间戳转换为DateTime，使用LocalDateTime时间，防止出现 utc 偏移。导致转化的时间不对。
|
||
var expireTime = DateTimeOffset.FromUnixTimeSeconds(entity.expireTimestamp).LocalDateTime;
|
||
// 计算两个时间的时间差
|
||
var timeDifference = expireTime - DateTime.Now;
|
||
|
||
await _redisOperationRepository.SetAsync(GlobalEnumVars.AccessTokenEnum.WeiXinAccessToken.ToString(), entity, TimeSpan.FromMinutes(timeDifference.TotalMinutes));
|
||
|
||
//插入日志
|
||
var model = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = true,
|
||
name = "Redis无缓存",
|
||
parameters = "重新根据数据库有效数据更新缓存"
|
||
};
|
||
await _taskLogServices.InsertAsync(model);
|
||
|
||
}
|
||
|
||
}
|
||
}
|
||
//微信小程序也刷新
|
||
if (!string.IsNullOrEmpty(_weChatOptions.WxOpenAppId) && !string.IsNullOrEmpty(_weChatOptions.WxOpenAppSecret))
|
||
{
|
||
var entity = await _weChatAccessTokenServices.QueryByClauseAsync(p => p.appId == _weChatOptions.WxOpenAppId && p.appType == (int)GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken);
|
||
if (entity == null || entity.expireTimestamp <= DateTimeOffset.Now.ToUnixTimeSeconds())
|
||
{
|
||
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
||
|
||
var request = new CgibinTokenRequest();
|
||
var response = await client.ExecuteCgibinTokenAsync(request);
|
||
if (response.IsSuccessful())
|
||
{
|
||
// 提前十分钟过期，以便于系统能及时刷新，防止因在过期临界点时出现问题
|
||
long nextExpireTimestamp = DateTimeOffset.Now.AddSeconds(response.ExpiresIn).AddMinutes(-10).ToUnixTimeSeconds();
|
||
|
||
if (entity == null)
|
||
{
|
||
entity = new WeChatAccessToken();
|
||
|
||
entity.appId = _weChatOptions.WxOpenAppId;
|
||
entity.accessToken = response.AccessToken;
|
||
entity.appType = (int)GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken;
|
||
entity.expireTimestamp = nextExpireTimestamp;
|
||
entity.createTimestamp = DateTimeOffset.Now.ToUnixTimeSeconds();
|
||
entity.updateTimestamp = entity.createTimestamp;
|
||
|
||
await _weChatAccessTokenServices.InsertAsync(entity);
|
||
}
|
||
else
|
||
{
|
||
entity.accessToken = response.AccessToken;
|
||
entity.expireTimestamp = nextExpireTimestamp;
|
||
entity.updateTimestamp = DateTimeOffset.Now.ToUnixTimeSeconds();
|
||
await _weChatAccessTokenServices.UpdateAsync(entity);
|
||
}
|
||
|
||
await _redisOperationRepository.SetAsync(GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken.ToString(), entity, TimeSpan.FromMinutes(120));
|
||
|
||
//插入日志
|
||
var model = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = true,
|
||
name = "定时刷新获取微信AccessToken",
|
||
parameters = JsonConvert.SerializeObject(entity)
|
||
};
|
||
await _taskLogServices.InsertAsync(model);
|
||
}
|
||
else
|
||
{
|
||
//插入日志
|
||
var log = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = false,
|
||
name = "定时刷新获取微信AccessToken",
|
||
parameters = $"刷新 AppId 为 {_weChatOptions.WeiXinAppId} 微信 AccessToken 失败（错误代码：{response.ErrorCode}，错误描述：{response.ErrorMessage}）。"
|
||
};
|
||
await _taskLogServices.InsertAsync(log);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
||
if (string.IsNullOrEmpty(accessToken) && entity.expireTimestamp > DateTimeOffset.Now.ToUnixTimeSeconds())
|
||
{
|
||
// 将时间戳转换为DateTime，使用LocalDateTime时间，防止出现 utc 偏移。导致转化的时间不对。
|
||
var expireTime = DateTimeOffset.FromUnixTimeSeconds(entity.expireTimestamp).LocalDateTime;
|
||
// 计算两个时间的时间差
|
||
var timeDifference = expireTime - DateTime.Now;
|
||
|
||
await _redisOperationRepository.SetAsync(GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken.ToString(), entity, TimeSpan.FromMinutes(timeDifference.TotalMinutes));
|
||
|
||
|
||
//插入日志
|
||
var model = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = true,
|
||
name = "Redis无缓存",
|
||
parameters = "重新根据数据库有效数据更新缓存"
|
||
};
|
||
await _taskLogServices.InsertAsync(model);
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
//插入日志
|
||
var model = new SysTaskLog
|
||
{
|
||
createTime = DateTime.Now,
|
||
isSuccess = false,
|
||
name = "定时刷新获取微信AccessToken",
|
||
parameters = JsonConvert.SerializeObject(ex)
|
||
};
|
||
await _taskLogServices.InsertAsync(model);
|
||
}
|
||
}
|
||
}
|
||
}
|