27 lines
1.2 KiB
C#
27 lines
1.2 KiB
C#
using F9WebAiTest.Application.Dtos.Notice;
|
|
|
|
namespace F9WebAiTest.Application.Services.Notice;
|
|
|
|
/// <summary>
|
|
/// 消息实时推送器（抽象）。
|
|
/// 定义在应用层、实现在 Api 层（依赖 SignalR 的 IHubContext 与在线登记表），
|
|
/// 避免应用层反向依赖表示层，同时让"创建消息即推送"这一动作可以写在命令处理器里。
|
|
/// </summary>
|
|
public interface INotificationPusher
|
|
{
|
|
/// <summary>
|
|
/// 判断用户当前是否在线。
|
|
/// 判定依据：该用户在 SignalR Hub 上是否有活动连接（由 Hub 连接/断开时登记的内存表得出）。
|
|
/// </summary>
|
|
bool IsOnline(long userId);
|
|
|
|
/// <summary>
|
|
/// 推送新消息给指定用户。
|
|
/// 返回 true 表示已推送给其在线连接；返回 false 表示用户离线（未推送，消息已落库，上线后从"我的消息"拉取）。
|
|
/// </summary>
|
|
Task<bool> PushNewMessageAsync(long userId, NotificationMessageDto message, CancellationToken ct = default);
|
|
|
|
/// <summary>推送未读统计，用于消息角标实时同步（用户离线时无需推送）。</summary>
|
|
Task PushUnreadCountAsync(long userId, int unreadCount, int todoCount, CancellationToken ct = default);
|
|
}
|