80 lines
3.2 KiB
C#
80 lines
3.2 KiB
C#
using Microsoft.Extensions.Logging;
|
|
using Volo.Abp.Caching;
|
|
using Volo.Abp.DependencyInjection;
|
|
using Volo.Abp.Domain.Services;
|
|
using Volo.Abp.EventBus;
|
|
using Yi.Framework.DigitalCollectibles.Domain.Shared.Caches;
|
|
using Yi.Framework.DigitalCollectibles.Domain.Shared.Consts;
|
|
using Yi.Framework.DigitalCollectibles.Domain.Shared.Etos;
|
|
using Yi.Framework.Rbac.Application.Contracts.IServices;
|
|
using Yi.Framework.WeChat.MiniProgram;
|
|
using Yi.Framework.WeChat.MiniProgram.HttpModels;
|
|
|
|
namespace Yi.Framework.DigitalCollectibles.Domain.Managers;
|
|
|
|
public class WeChatMiniProgramNoticeEventHandler : ILocalEventHandler<WeChatMiniProgramNoticeEto>, ITransientDependency
|
|
{
|
|
private readonly IWeChatMiniProgramManager _weChatMiniProgramManager;
|
|
private readonly IAuthService _authService;
|
|
private readonly ILogger<WeChatMiniProgramNoticeEventHandler> _logger;
|
|
private readonly IDistributedCache<WeChatNoticeCacheItem> _noticeCache;
|
|
public WeChatMiniProgramNoticeEventHandler(IWeChatMiniProgramManager weChatMiniProgramManager,
|
|
IAuthService authService, ILogger<WeChatMiniProgramNoticeEventHandler> logger, IDistributedCache<WeChatNoticeCacheItem> noticeCache)
|
|
{
|
|
_weChatMiniProgramManager = weChatMiniProgramManager;
|
|
_authService = authService;
|
|
_logger = logger;
|
|
_noticeCache = noticeCache;
|
|
}
|
|
|
|
public async Task HandleEventAsync(WeChatMiniProgramNoticeEto eventData)
|
|
{
|
|
//需要判断该用户是否已经订阅
|
|
var noticeCache= await _noticeCache.GetAsync($"MiniProgram:notice:{eventData.UserId}");
|
|
//判断用户是否点击了一次性消息订阅
|
|
if (noticeCache is not null)
|
|
{
|
|
var authInfo = await _authService.TryGetAuthInfoAsync(null, AuthTypeConst.WeChatMiniProgram, eventData.UserId);
|
|
await SendAsync(authInfo.OpenId, eventData.Title);
|
|
//发送完成之后，删除缓存
|
|
await _noticeCache.RemoveAsync($"MiniProgram:notice:{eventData.UserId}");
|
|
}
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 像用户发送微信消息
|
|
/// </summary>
|
|
/// <param name="userId"></param>
|
|
public async Task SendAsync(string openId, string title)
|
|
{
|
|
try
|
|
{
|
|
//成功挖到矿，可以发消息给用户了
|
|
await _weChatMiniProgramManager.SendSubscribeNoticeAsync(new SubscribeNoticeInput
|
|
{
|
|
touser = openId,
|
|
page = "pages/digitalCollectibles/digitalCollectibles",
|
|
data = new Dictionary<string, keyValueItem>()
|
|
{
|
|
//活动名称
|
|
{ "thing9", new keyValueItem("恭喜挖到新的数字藏品") },
|
|
|
|
//奖品名称
|
|
{ "thing1", new keyValueItem(title) },
|
|
|
|
//中奖时间
|
|
{ "date5", new keyValueItem(DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss")) },
|
|
|
|
//温馨提醒
|
|
{ "thing4", new keyValueItem("点击前往小程序，可在仓库或者记录中查看") },
|
|
}
|
|
});
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_logger.LogError($"微信通知提醒失败,错误信息:{e.Message},堆栈:{e.InnerException}");
|
|
}
|
|
|
|
}
|
|
} |