租户会话在 IRealTimeNotifier 中丢失

Question

我们正在尝试实现用户可以通过频道订阅通知的场景。

例如，用户可以通过电子邮件、短信、实时通知等订阅通知

目前，为了实现电子邮件通知，我正在以这种方式实现IRealTimeNotifier：

public class EmailNotifier : IRealTimeNotifier, ITransientDependency
{
    private readonly IEmailSender _emailSender;
    private readonly ISettingManager _settingManager;

    public IAbpSession AbpSession { get; set; }

    public EmailNotifier(IEmailSender emailSender, ISettingManager settingManager, IAbpSession abpSession)
    {
        this._emailSender = emailSender;
        this._settingManager = settingManager;
        this.AbpSession = NullAbpSession.Instance;
    }

    public async Task SendNotificationsAsync(UserNotification[] userNotifications)
    {
        List<Task> sendEmails = new List<Task>();
        string fromAddress = this._settingManager.GetSettingValueForTenant(EmailSettingNames.Smtp.UserName, Convert.ToInt32(this.AbpSession.TenantId));

        foreach (UserNotification notification in userNotifications)
        {
            notification.Notification.Data.Properties.TryGetValue("toAddresses", out object toAddresses);
            notification.Notification.Data.Properties.TryGetValue("subject", out object sub);
            notification.Notification.Data.Properties.TryGetValue("body", out object content);
            notification.Notification.Data.Properties.TryGetValue("toAddresses", out object toAddresses);

            List<string> toEmails = toAddresses as List<string>                    ;
            string subject = Convert.ToString(sub);
            string body = Convert.ToString(content);
            toEmails.ForEach(to =>
            {
                sendEmails.Add(this._emailSender.SendAsync(fromAddress, to, subject, body));
            });
        }

        await Task.Run(() =>
        {
            sendEmails.ForEach(async task =>
            {
                try
                {
                    await task.ConfigureAwait(false);
                }
                catch (Exception)
                {
                    // TODO #1: Add email to background job to be sent later.
                    // TODO #2: Add circuit breaker to email sending mechanism
                    /*
                        Email sending is failing because of two possible reasons.
                        1. Email addresses are wrong.
                        2. SMTP server is down.
                        3. Break the circuit while the SMTP server is down.
                     */

                    // TODO #3 (Optional): Notify tenant admin about failure.
                    // TODO #4: Remove throw statement for graceful degradation.
                    throw;
                }
            });
        });
    }
}

问题出在IAbpSession，无论我是通过属性还是构造函数注入它，在执行此通知程序时，响应已经返回并且TenantId 在这个会话中是 null，所以电子邮件是用主机配置而不是租户配置发送的。

同样，我需要为 SMS 实现 IRealTimeNotifier。我想我可以重用 ABP 中的 SignalRRealTimeNotifier，但是会话中的 tenantId 被设置为 null.

这是调用发布者的地方：

public class EventUserEmailer : IEventHandler<EntityCreatedEventData<Event>>
{
    public ILogger Logger { get; set; }

    private readonly IEventManager _eventManager;
    private readonly UserManager _userManager;
    private readonly IAbpSession _abpSession;
    private readonly INotificationPublisher _notiticationPublisher;

    public EventUserEmailer(
        UserManager userManager,
        IEventManager eventManager,
        IAbpSession abpSession,
        INotificationPublisher notiticationPublisher)
    {
        _userManager = userManager;
        _eventManager = eventManager;
        _notiticationPublisher = notiticationPublisher;
        _abpSession = abpSession;
        Logger = NullLogger.Instance;
    }

    [UnitOfWork]
    public virtual void HandleEvent(EntityCreatedEventData<Event> eventData)
    {
        // TODO: Send email to all tenant users as a notification

        var users = _userManager
            .Users
            .Where(u => u.TenantId == eventData.Entity.TenantId)
            .ToList();

        // Send notification to all subscribed uses of tenant
        _notiticationPublisher.Publish(AppNotificationNames.EventCreated);
    }
}

有人可以推荐更好的方法吗？或者指出我们在这里做错的任何事情。

我还没有想过如何处理这些特定通知程序的 DI。出于测试目的，我在我的模块中给出了一个命名注入，如下所示：

IocManager.IocContainer.Register(
    Component.For<IRealTimeNotifier>()
        .ImplementedBy<EmailNotifier>()
        .Named("Email")
        .LifestyleTransient()
);

当前ABP版本：3.7.1

这是我目前掌握的信息。有什么需要的可以在评论里问。

Answer 1

// Send notification to all subscribed uses of tenant
_notificationPublisher.Publish(AppNotificationNames.EventCreated);

如果你像这样发布通知，ABP 的默认实现 enqueues a background job。

后台作业中没有会话。

你可以这样得到tenantId：

var tenantId = userNotifications[0].Notification.TenantId;

using (AbpSession.Use(tenantId, null))
{
    // ...
}

租户会话在 IRealTimeNotifier 中丢失

Tenant session is lost in IRealTimeNotifier

c#

session

notifications

aspnetboilerplate