Galosys.Foundation.Notification 26.5.20.1

Galosys.Foundation.Notification

通知统一抽象模块，提供 INotificationProvider 接口 + INotificationDispatcher 调度器，支持单通道路由和多通道广播两种模式。

最小配置

// Program.cs / Startup.cs
services.AddNotification(); // 注册 INotificationDispatcher

无需额外配置项。Notification 模块本身不依赖 IConfiguration。

通道注册

Notification 模块只定义接口和调度器。各通道适配器由对应的模块自行注册，引用通道模块后自动生效：

// 注册邮件通道（需配置 MailKit 节）
services.AddMailkit(configuration);

// 注册钉钉通道（需配置 DingTalk 节）
// DingTalk 模块通过 IModule 自动注册

// 注册短信通道（需配置 Aliyun 节）
services.AddAliyun(configuration);

// 注册微信通道
// Wechat 模块通过 IModule 自动注册

// 注册 WxPusher 通道
// WxPusher 模块通过 IModule 自动注册

使用示例

单通道发送 (SendAsync)

public class MyService
{
    private readonly INotificationDispatcher _dispatcher;

    public MyService(INotificationDispatcher dispatcher)
    {
        _dispatcher = dispatcher;
    }

    // 发送邮件
    public async Task SendEmailAsync()
    {
        var result = await _dispatcher.SendAsync(new NotificationRequest(
            Channel: "email",
            Recipient: "user@example.com",
            Subject: "系统通知",
            Content: "这是一封测试邮件"
        ));

        if (!result.Success)
        {
            // 处理发送失败: result.ErrorMessage
        }
    }

    // 发送短信
    public async Task SendSmsAsync()
    {
        var result = await _dispatcher.SendAsync(new NotificationRequest(
            Channel: "sms",
            Recipient: "13800138000",
            Subject: "SMS_001",  // 阿里云短信模板 Code
            Content: "您的验证码是 123456"
        ));
    }

    // 发送钉钉消息
    public async Task SendDingTalkAsync()
    {
        var result = await _dispatcher.SendAsync(new NotificationRequest(
            Channel: "dingtalk",
            Content: "钉钉群通知内容"
        ));
    }
}

多通道广播 (BroadcastAsync)

// 向所有已注册通道并行发送通知
var results = await _dispatcher.BroadcastAsync(new NotificationRequest(
    Recipient: "user",
    Subject: "系统公告",
    Content: "系统将于今晚维护"
));

// results 包含每个通道的独立结果
foreach (var result in results)
{
    Console.WriteLine($"{result.Channel}: {(result.Success ? "成功" : result.ErrorMessage)}");
}

请求模型

Extra 参数说明

微信通道 (wechat)

new NotificationRequest(
    Channel: "wechat",
    Recipient: "openId",
    Content: "模板内容",
    Extra: new Dictionary<string, object?>
    {
        ["AccessToken"] = "access_token",     // 直接传入 token
        // 或通过 AppId/AppSecret 自动获取:
        ["AppId"] = "wx...",
        ["AppSecret"] = "secret...",
        ["TemplateId"] = "template_id",
        ["Page"] = "pages/index"
    }
)

WxPusher 通道 (wxpusher)

new NotificationRequest(
    Channel: "wxpusher",
    Recipient: "uid1,uid2",     // 多个 UID 逗号分隔
    Subject: "摘要",
    Content: "内容",
    Extra: new Dictionary<string, object?>
    {
        ["ContentType"] = 1,     // 1=文字 2=HTML 3=Markdown
        ["Url"] = "https://..."
    }
)

阿里云短信通道 (sms)

new NotificationRequest(
    Channel: "sms",
    Recipient: "13800138000,13900139000",  // 多个手机号逗号分隔
    Subject: "SMS_TEMPLATE_CODE",          // 短信模板 Code
    Content: "内容",
    Extra: new Dictionary<string, object?>
    {
        ["TemplateCode"] = "SMS_001",  // 优先于 Subject
        ["key1"] = "value1"            // 模板参数
    }
)

自定义通道

实现 INotificationProvider 接口并注册到 DI：

using Galosys.Foundation.Notification;
using Microsoft.Extensions.Plugining;

public class MyChannelProvider : INotificationProvider
{
    public string ChannelName => "my-channel";

    public bool Supports(NotificationRequest request)
    {
        return string.IsNullOrEmpty(request.Channel) ||
               string.Equals(request.Channel, ChannelName, StringComparison.OrdinalIgnoreCase);
    }

    public async Task<NotificationResult> SendAsync(NotificationRequest request, CancellationToken cancellationToken = default)
    {
        try
        {
            // 发送逻辑...
            return new NotificationResult(true, Channel: ChannelName);
        }
        catch (Exception ex)
        {
            return new NotificationResult(false, ex.Message, ChannelName);
        }
    }
}

// DI 注册
services.TryAddSingleton<INotificationProvider, MyChannelProvider>();

接口一览

适配器