You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
83 lines
2.8 KiB
83 lines
2.8 KiB
using Microsoft.AspNetCore.SignalR;
|
|
|
|
namespace Admin.NET.Core.Service;
|
|
|
|
/// <summary>
|
|
/// 系统在线用户服务
|
|
/// </summary>
|
|
[ApiDescriptionSettings(Order = 300)]
|
|
public class SysOnlineUserService : IDynamicApiController, ITransient
|
|
{
|
|
private readonly SqlSugarRepository<SysOnlineUser> _sysOnlineUerRep;
|
|
private readonly SysConfigService _sysConfigService;
|
|
private readonly IHubContext<OnlineUserHub, IOnlineUserHub> _onlineUserHubContext;
|
|
|
|
public SysOnlineUserService(SqlSugarRepository<SysOnlineUser> sysOnlineUerRep,
|
|
SysConfigService sysConfigService,
|
|
IHubContext<OnlineUserHub, IOnlineUserHub> onlineUserHubContext)
|
|
{
|
|
_sysOnlineUerRep = sysOnlineUerRep;
|
|
_sysConfigService = sysConfigService;
|
|
_onlineUserHubContext = onlineUserHubContext;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取在线用户分页列表
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[DisplayName("获取在线用户分页列表")]
|
|
public async Task<SqlSugarPagedList<SysOnlineUser>> Page(PageOnlineUserInput input)
|
|
{
|
|
return await _sysOnlineUerRep.AsQueryable()
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.UserName), u => u.UserName.Contains(input.UserName))
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.RealName), u => u.RealName.Contains(input.RealName))
|
|
.ToPagedListAsync(input.Page, input.PageSize);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 强制下线
|
|
/// </summary>
|
|
/// <param name="user"></param>
|
|
/// <returns></returns>
|
|
[NonValidation]
|
|
[DisplayName("强制下线")]
|
|
public async Task ForceOffline(SysOnlineUser user)
|
|
{
|
|
await _onlineUserHubContext.Clients.Client(user.ConnectionId).ForceOffline("强制下线");
|
|
await _sysOnlineUerRep.DeleteAsync(user);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 发布站内消息
|
|
/// </summary>
|
|
/// <param name="notice"></param>
|
|
/// <param name="userIds"></param>
|
|
/// <returns></returns>
|
|
[ApiDescriptionSettings(false)]
|
|
public async Task PublicNotice(SysNotice notice, List<long> userIds)
|
|
{
|
|
var userList = await _sysOnlineUerRep.GetListAsync(m => userIds.Contains(m.UserId));
|
|
if (!userList.Any()) return;
|
|
|
|
foreach (var item in userList)
|
|
{
|
|
await _onlineUserHubContext.Clients.Client(item.ConnectionId).PublicNotice(notice);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 单用户登录
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[ApiDescriptionSettings(false)]
|
|
public async Task SignleLogin(long userId)
|
|
{
|
|
if (await _sysConfigService.GetConfigValue<bool>(CommonConst.SysSingleLogin))
|
|
{
|
|
var user = await _sysOnlineUerRep.GetFirstAsync(u => u.UserId == userId);
|
|
if (user == null) return;
|
|
|
|
await ForceOffline(user);
|
|
}
|
|
}
|
|
}
|