abp-next-admin/aspnet-core/services/LY.MicroService.Applications.Single/EventBus/Local/UserCreateSendWelcomeEventHandler.cs

using LINGYUN.Abp.Notifications;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Domain.Entities.Events;
using Volo.Abp.EventBus;
using Volo.Abp.Users;

namespace LY.MicroService.Applications.Single.EventBus
{
    public class UserCreateSendWelcomeEventHandler : ILocalEventHandler<EntityCreatedEventData<UserEto>>, ITransientDependency
    {
        private readonly INotificationSender _notificationSender;
        private readonly INotificationSubscriptionManager _notificationSubscriptionManager;
        public UserCreateSendWelcomeEventHandler(
            INotificationSender notificationSender,
            INotificationSubscriptionManager notificationSubscriptionManager
            )
        {
            _notificationSender = notificationSender;
            _notificationSubscriptionManager = notificationSubscriptionManager;
        }

        public async Task HandleEventAsync(EntityCreatedEventData<UserEto> eventData)
        {
            var userIdentifer = new UserIdentifier(eventData.Entity.Id, eventData.Entity.UserName);
            // 订阅用户欢迎消息
            await SubscribeInternalNotifers(userIdentifer, eventData.Entity.TenantId);

            await _notificationSender.SendNofiterAsync(
                    UserNotificationNames.WelcomeToApplication,
                    new NotificationTemplate(
                        UserNotificationNames.WelcomeToApplication,
                        formUser: eventData.Entity.UserName,
                        data: new Dictionary<string, object>
                        {
                            { "name", eventData.Entity.UserName },
                        }),
                    userIdentifer,
                    eventData.Entity.TenantId,
                    NotificationSeverity.Info);
        }

        private async Task SubscribeInternalNotifers(UserIdentifier userIdentifer, Guid? tenantId = null)
        {
            // 订阅内置通知
            await _notificationSubscriptionManager
                .SubscribeAsync(
                    tenantId,
                    userIdentifer,
                    DefaultNotifications.SystemNotice);
            await _notificationSubscriptionManager
                .SubscribeAsync(
                    tenantId,
                    userIdentifer,
                    DefaultNotifications.OnsideNotice);
            await _notificationSubscriptionManager
                .SubscribeAsync(
                    tenantId,
                    userIdentifer,
                    DefaultNotifications.ActivityNotice);

            // 订阅用户欢迎消息
            await _notificationSubscriptionManager
                .SubscribeAsync(
                    tenantId,
                    userIdentifer,
                    UserNotificationNames.WelcomeToApplication);
        }
    }
}