mirror of
https://gitee.com/ThingsGateway/ThingsGateway.git
synced 2025-10-25 12:43:09 +08:00
106 lines
3.9 KiB
C#
106 lines
3.9 KiB
C#
//------------------------------------------------------------------------------
|
||
// 此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
|
||
// 此代码版权（除特别声明外的代码）归作者本人Diego所有
|
||
// 源代码使用协议遵循本仓库的开源协议及附加协议
|
||
// Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
|
||
// Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
|
||
// 使用文档：https://thingsgateway.cn/
|
||
// QQ群：605534569
|
||
//------------------------------------------------------------------------------
|
||
|
||
using Microsoft.AspNetCore.SignalR.Client;
|
||
|
||
using System.Security.Claims;
|
||
|
||
using ThingsGateway.Admin.Application;
|
||
|
||
namespace ThingsGateway.Admin.Razor;
|
||
|
||
public partial class SysSignalRLoginConnectionHub : ComponentBase, IAsyncDisposable
|
||
{
|
||
[Inject]
|
||
private NavigationManager NavigationManager { get; set; }
|
||
|
||
[Inject]
|
||
private ToastService ToastService { get; set; }
|
||
HubConnection _hubConnection;
|
||
|
||
/// <inheritdoc/>
|
||
public async ValueTask DisposeAsync()
|
||
{
|
||
if (_hubConnection != null)
|
||
{
|
||
await _hubConnection.DisposeAsync();
|
||
}
|
||
}
|
||
/// <inheritdoc/>
|
||
protected override async Task OnAfterRenderAsync(bool firstRender)
|
||
{
|
||
if (firstRender)
|
||
{
|
||
try
|
||
{
|
||
//SignalR
|
||
_hubConnection = new HubConnectionBuilder().WithUrl(NavigationManager.ToAbsoluteUri(HubConst.SysHubUrl), (opts) =>
|
||
{
|
||
opts.HttpMessageHandlerFactory = (message) =>
|
||
{
|
||
if (message is HttpClientHandler clientHandler)
|
||
{
|
||
// 绕过SSL证书
|
||
clientHandler.ServerCertificateCustomValidationCallback += (sender, certificate, chain, sslPolicyErrors) => true;
|
||
}
|
||
|
||
return message;
|
||
};
|
||
foreach (var item in App.User?.Claims ?? new List<Claim>())
|
||
{
|
||
if (item.Type == ClaimConst.UserId || item.Type == ClaimConst.VerificatId)
|
||
opts.Headers.Add(item.Type, item.Value);
|
||
}
|
||
}
|
||
).Build();
|
||
|
||
_hubConnection.On<string>(nameof(ISysHub.LoginOut), async (message) =>
|
||
{
|
||
await InvokeAsync(async () => await ToastService.Warning(message));
|
||
await Task.Delay(2000);
|
||
NavigationManager.NavigateTo(NavigationManager.Uri, true);
|
||
});
|
||
_hubConnection.On<AppMessage>(nameof(ISysHub.NewMesage), async (message) =>
|
||
{
|
||
if ((byte)message.LogLevel <= 2)
|
||
await InvokeAsync(async () => await ToastService.Information(message.Data));
|
||
else
|
||
await InvokeAsync(async () => await ToastService.Warning(message.Data));
|
||
});
|
||
|
||
_hubConnection.On<string, string>(nameof(ISysHub.NavigationMesage), async (url, message) => await ShowMessage(new(url, message)));
|
||
|
||
await _hubConnection.StartAsync();
|
||
}
|
||
catch
|
||
{
|
||
}
|
||
await base.OnAfterRenderAsync(firstRender);
|
||
}
|
||
}
|
||
|
||
[Inject]
|
||
private IStringLocalizer<SysSignalRLoginConnectionHub> Localizers { get; set; }
|
||
[Inject]
|
||
private MessageService MessageService { get; set; }
|
||
|
||
private async Task ShowMessage(NavigationUri navigationUri)
|
||
{
|
||
await MessageService.Show(new MessageOption()
|
||
{
|
||
Icon = "fa-solid fa-circle-info",
|
||
ShowDismiss = true,
|
||
IsAutoHide = false,
|
||
ChildContent = RenderItem(navigationUri),
|
||
OnDismiss = () => Task.CompletedTask
|
||
});
|
||
}
|
||
}
|