using Microsoft.AspNetCore.Http;
|
using System.Threading.Tasks;
|
using JiepeiWMS.Common.LogHelper;
|
using JiepeiWMS.Hubs;
|
using Microsoft.AspNetCore.SignalR;
|
using JiepeiWMS.Common;
|
|
namespace JiepeiWMS.Middlewares
|
{
|
/// <summary>
|
/// 中间件
|
/// SignalR发送数据
|
/// </summary>
|
public class SignalRSendMildd
|
{
|
/// <summary>
|
///
|
/// </summary>
|
private readonly RequestDelegate _next;
|
private readonly IHubContext<ChatHub> _hubContext;
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="next"></param>
|
/// <param name="hubContext"></param>
|
public SignalRSendMildd(RequestDelegate next, IHubContext<ChatHub> hubContext)
|
{
|
_next = next;
|
_hubContext = hubContext;
|
}
|
|
|
|
public async Task InvokeAsync(HttpContext context)
|
{
|
if (Appsettings.app("Middleware", "SignalR", "Enabled").ObjToBool())
|
{
|
await _hubContext.Clients.All.SendAsync("ReceiveUpdate", LogLock.GetLogData());
|
}
|
await _next(context);
|
}
|
|
}
|
}
|
