66 lines
2.2 KiB
C#
66 lines
2.2 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Microsoft.AspNetCore.SignalR;
|
|
using Microsoft.Extensions.Logging;
|
|
using Yi.Framework.Infrastructure.Ddd.Dtos;
|
|
using Yi.Furion.Application.Rbac.SignalRHub;
|
|
using Yi.Furion.Application.Rbac.SignalRHub.Model;
|
|
|
|
namespace Yi.Furion.Application.Rbac.Services.Impl
|
|
{
|
|
public class OnlineService:IOnlineService,IDynamicApiController,ITransient
|
|
{
|
|
private ILogger<OnlineService> _logger;
|
|
private IHubContext<OnlineUserHub> _hub;
|
|
public OnlineService(ILogger<OnlineService> logger, IHubContext<OnlineUserHub> hub)
|
|
{
|
|
_logger = logger;
|
|
_hub = hub;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 动态条件获取当前在线用户
|
|
/// </summary>
|
|
/// <param name="online"></param>
|
|
/// <returns></returns>
|
|
[HttpGet("")]
|
|
public PagedResultDto<OnlineUserModel> GetListAsync([FromQuery] OnlineUserModel online)
|
|
{
|
|
var data = OnlineUserHub.clientUsers;
|
|
IEnumerable<OnlineUserModel> dataWhere = data.AsEnumerable();
|
|
|
|
if (!string.IsNullOrEmpty(online.Ipaddr))
|
|
{
|
|
dataWhere = dataWhere.Where((u) => u.Ipaddr!.Contains(online.Ipaddr));
|
|
}
|
|
if (!string.IsNullOrEmpty(online.UserName))
|
|
{
|
|
dataWhere = dataWhere.Where((u) => u.UserName!.Contains(online.UserName));
|
|
}
|
|
return new PagedResultDto<OnlineUserModel>() { Total = data.Count, Items = dataWhere.ToList() };
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 强制退出用户
|
|
/// </summary>
|
|
/// <param name="connnectionId"></param>
|
|
/// <returns></returns>
|
|
[HttpDelete]
|
|
[Route("{connnectionId}")]
|
|
public async Task<bool> ForceOut(string connnectionId)
|
|
{
|
|
if (OnlineUserHub.clientUsers.Exists(u => u.ConnnectionId == connnectionId))
|
|
{
|
|
//前端接受到这个事件后，触发前端自动退出
|
|
await _hub.Clients.Client(connnectionId).SendAsync("forceOut", "你已被强制退出！");
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
}
|
|
}
|