LegalServiceV1/SourceCode/V2/ContractService/ContractService.Core/CommonManager/Notifications/NotificationManager.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Abp;
using Abp.Dependency;
using Abp.Domain.Entities;
using Abp.Notifications;
using Abp.Runtime.Session;
using ContractService.Configuration;
using ContractService.LegalContract;
using IwbZero.Runtime.Session;

namespace ContractService.CommonManager.Notifications
{
    public class NotificationManager : INotificationManager, ISingletonDependency
    {
        private readonly INotificationPublisher _notificationPublisher;
        private readonly IwbSession _abpSession;
        public NotificationManager(INotificationPublisher notificationPublisher, IwbSession abpSession)
        {
            _notificationPublisher = notificationPublisher;
            _abpSession = abpSession;
        }

        public async Task WelcomeToSystemAsync()
        {
            await _notificationPublisher.PublishAsync(
                IwbNotificationName.WelcomeMsg, new MessageNotificationData("欢迎登陆"), severity: NotificationSeverity.Success,
                userIds: new[] { _abpSession.ToUserIdentifier() });
        }

        /// <summary>
        /// 发送给指定用户消息(info)
        /// </summary>
        /// <param name="user"></param>
        /// <param name="message"></param>
        /// <returns></returns>
        public async Task SendMsgAsync(UserIdentifier user, string message)
        {
            await SendMsgAsync(user, message, NotificationSeverity.Info);
        }

        /// <summary>
        /// 发送给指定用户消息
        /// </summary>
        /// <param name="user"></param>
        /// <param name="message"></param>
        /// <param name="severity"></param>
        /// <returns></returns>
        public async Task SendMsgAsync(UserIdentifier user, string message, NotificationSeverity severity)
        {
            await _notificationPublisher.PublishAsync(
                IwbNotificationName.SendMsg,
                new MessageNotificationData(message), severity: severity, userIds: new[] { user });
        }

        /// <summary>
        /// 发送某种消息给订阅用户(Info)
        /// </summary>
        /// <param name="msgName">消息唯一名称</param>
        /// <param name="message"></param>
        /// <returns></returns>
        public async Task SendMsgAsync(string msgName, string message)
        {
            await SendMsgAsync(msgName, message, NotificationSeverity.Info);
        }

        /// <summary>
        /// 发送某种消息给订阅用户
        /// </summary>
        /// <param name="msgName">消息唯一名称</param>
        /// <param name="message"></param>
        /// <param name="severity"></param>
        /// <returns></returns>
        public async Task SendMsgAsync(string msgName, string message, NotificationSeverity severity)
        {
            await _notificationPublisher.PublishAsync(msgName, new MessageNotificationData(message), severity: severity);
        }

        /// <summary>
        /// 发送某种消息给指定用户(带发送人)
        /// </summary>
        /// <param name="user"></param>
        /// <param name="msgName"></param>
        /// <param name="data"></param>
        /// <param name="severity"></param>
        /// <returns></returns>
        public async Task SendMessageAsync(UserIdentifier user, string msgName, SendMsgNotificationData data, NotificationSeverity severity)
        {
            await _notificationPublisher.PublishAsync(msgName, data, severity: severity, userIds: new[] { user });
        }

        /// <summary>
        /// 发送某种消息给订阅用户(带发送人)
        /// </summary>
        /// <param name="msgName"></param>
        /// <param name="data"></param>
        /// <param name="severity"></param>
        /// <returns></returns>
        public async Task SendMessageAsync(string msgName, SendMsgNotificationData data, NotificationSeverity severity)
        {
            await _notificationPublisher.PublishAsync(msgName, data, severity: severity);
        }

        /// <summary>
        /// 关键点提醒通知
        /// </summary>
        /// <param name="users"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task SendKeyPointAlarmMsg(List<UserIdentifier> users, KeyPointNotificationData data)
        {
            data.IsAlarm = true;
            await _notificationPublisher.PublishAsync(IwbNotificationName.KeyPointAlarm, data,new EntityIdentifier(typeof(LegalContractKeyPointInfo),data.Id),
                 NotificationSeverity.Info,  users.ToArray());
        }
        /// <summary>
        /// 关键点过期通知
        /// </summary>
        /// <param name="users"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task SendKeyPointExpireMsg(List<UserIdentifier> users, KeyPointNotificationData data)
        {
            data.IsAlarm = false;
            await _notificationPublisher.PublishAsync(IwbNotificationName.KeyPointAlarm, data, new EntityIdentifier(typeof(LegalContractKeyPointInfo), data.Id),
                 NotificationSeverity.Warn,  users.ToArray());
        }
    }


    [Serializable]
    public class SendMsgNotificationData : NotificationData
    {
        public string SenderUserName { get; set; }

        public string Message { get; set; }

        public SendMsgNotificationData(string senderUserName, string message)
        {
            SenderUserName = senderUserName;
            Message = message;
        }
    }
}