mirror of
https://gitee.com/ThingsGateway/ThingsGateway.git
synced 2025-10-25 12:43:09 +08:00
Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ab33eed8d3 | ||
|
|
d930a9a8eb | ||
|
|
af381fce12 | ||
|
|
b64ac0539e | ||
|
|
541c60b363 | ||
|
|
824e95f7cb | ||
|
|
38f7850196 | ||
|
|
bef9de88e2 | ||
|
|
48cd5e7c7f | ||
|
|
3b44fda51c |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -365,4 +365,5 @@ FodyWeavers.xsd
|
|||||||
/src/*Pro*/
|
/src/*Pro*/
|
||||||
/src/*Pro*
|
/src/*Pro*
|
||||||
/src/*pro*
|
/src/*pro*
|
||||||
/src/*pro*/
|
/src/*pro*/
|
||||||
|
/src/ThingsGateway.Server/Configuration/GiteeOAuthSettings.json
|
||||||
|
|||||||
@@ -126,35 +126,8 @@ dotnet_style_qualification_for_property = false:silent
|
|||||||
dotnet_style_qualification_for_method = false:silent
|
dotnet_style_qualification_for_method = false:silent
|
||||||
dotnet_style_qualification_for_event = false:silent
|
dotnet_style_qualification_for_event = false:silent
|
||||||
|
|
||||||
|
dotnet_diagnostic.RCS1146.severity = warning
|
||||||
dotnet_diagnostic.CA2208.severity = none
|
dotnet_diagnostic.RCS1059.severity = none
|
||||||
dotnet_diagnostic.CA2008.severity = none
|
dotnet_diagnostic.RCS1138.severity = suggestion
|
||||||
dotnet_diagnostic.CA1812.severity = none
|
|
||||||
dotnet_diagnostic.CA1508.severity = none
|
|
||||||
dotnet_diagnostic.CA1512.severity = none
|
|
||||||
dotnet_diagnostic.CA1513.severity = none
|
|
||||||
dotnet_diagnostic.CA1810.severity = none
|
|
||||||
dotnet_diagnostic.CA1814.severity = none
|
|
||||||
dotnet_diagnostic.CA1815.severity = none
|
|
||||||
dotnet_diagnostic.CA1835.severity = none
|
|
||||||
dotnet_diagnostic.CA1819.severity = none
|
|
||||||
dotnet_diagnostic.CA1823.severity = none
|
|
||||||
dotnet_diagnostic.CA2002.severity = none
|
|
||||||
dotnet_diagnostic.CA5350.severity = none
|
|
||||||
dotnet_diagnostic.CA5351.severity = none
|
|
||||||
dotnet_diagnostic.CA5358.severity = none
|
|
||||||
dotnet_diagnostic.CA5384.severity = none
|
|
||||||
dotnet_diagnostic.CA5392.severity = none
|
|
||||||
dotnet_diagnostic.CA1805.severity = none
|
|
||||||
dotnet_diagnostic.CA1851.severity = none
|
|
||||||
dotnet_diagnostic.CA1510.severity = none
|
|
||||||
dotnet_diagnostic.CA5401.severity = none
|
|
||||||
dotnet_diagnostic.CA2022.severity = none
|
|
||||||
dotnet_diagnostic.CA1848.severity = none
|
|
||||||
dotnet_diagnostic.CA2000.severity = none
|
|
||||||
dotnet_diagnostic.CA5394.severity = none
|
|
||||||
dotnet_diagnostic.CA3003.severity = none
|
|
||||||
dotnet_diagnostic.CA1515.severity = none
|
|
||||||
dotnet_diagnostic.CA1849.severity = none
|
|
||||||
|
|
||||||
dotnet_code_quality.CA1822.api_surface = private, internal
|
dotnet_code_quality.CA1822.api_surface = private, internal
|
||||||
@@ -13,14 +13,16 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 需要角色授权权限
|
/// 需要角色授权权限
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[AttributeUsage(AttributeTargets.Class)]
|
[AttributeUsage(AttributeTargets.Class, AllowMultiple = false)]
|
||||||
public sealed class RolePermissionAttribute : Attribute
|
public sealed class RolePermissionAttribute : Attribute
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 忽略角色授权权限
|
/// 忽略角色授权权限
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
[AttributeUsage(AttributeTargets.Class | AttributeTargets.Method, AllowMultiple = false)]
|
||||||
public sealed class IgnoreRolePermissionAttribute : Attribute
|
public sealed class IgnoreRolePermissionAttribute : Attribute
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,21 @@
|
|||||||
|
//------------------------------------------------------------------------------
|
||||||
|
// 此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
|
||||||
|
// 此代码版权(除特别声明外的代码)归作者本人Diego所有
|
||||||
|
// 源代码使用协议遵循本仓库的开源协议及附加协议
|
||||||
|
// Gitee源代码仓库:https://gitee.com/diego2098/ThingsGateway
|
||||||
|
// Github源代码仓库:https://github.com/kimdiego2098/ThingsGateway
|
||||||
|
// 使用文档:https://thingsgateway.cn/
|
||||||
|
// QQ群:605534569
|
||||||
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
|
[AttributeUsage(AttributeTargets.Method)]
|
||||||
|
public sealed class LoginLogAttribute : Attribute
|
||||||
|
{
|
||||||
|
}
|
||||||
|
[AttributeUsage(AttributeTargets.Method)]
|
||||||
|
public sealed class LogoutLogAttribute : Attribute
|
||||||
|
{
|
||||||
|
}
|
||||||
@@ -11,7 +11,7 @@
|
|||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class CacheConst
|
public static class CacheConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Token表缓存Key
|
/// Token表缓存Key
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 通讯器常量
|
/// 通讯器常量
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class HubConst
|
public static class HubConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 系统HubUrl
|
/// 系统HubUrl
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// 资源表常量
|
/// 资源表常量
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class ResourceConst
|
public static class ResourceConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 系统内置编码
|
/// 系统内置编码
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// 角色常量
|
/// 角色常量
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class RoleConst
|
public static class RoleConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// api角色
|
/// api角色
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// SqlSugar系统常量
|
/// SqlSugar系统常量
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class SqlSugarConst
|
public static class SqlSugarConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// DB_Admin
|
/// DB_Admin
|
||||||
|
|||||||
@@ -8,6 +8,7 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
using Microsoft.AspNetCore.Authentication;
|
||||||
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Authorization;
|
||||||
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.AspNetCore.Mvc;
|
||||||
|
|
||||||
@@ -27,14 +28,31 @@ public class AuthController : ControllerBase
|
|||||||
|
|
||||||
[HttpPost("login")]
|
[HttpPost("login")]
|
||||||
[AllowAnonymous]
|
[AllowAnonymous]
|
||||||
|
[LoginLog]
|
||||||
public Task<LoginOutput> LoginAsync([FromBody] LoginInput input)
|
public Task<LoginOutput> LoginAsync([FromBody] LoginInput input)
|
||||||
{
|
{
|
||||||
|
|
||||||
return _authService.LoginAsync(input);
|
return _authService.LoginAsync(input);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
[HttpGet("oauth-login")]
|
||||||
|
[AllowAnonymous]
|
||||||
|
[SuppressRequestAudit]
|
||||||
|
public IActionResult OAuthLogin(string scheme = "Gitee", string returnUrl = "/")
|
||||||
|
{
|
||||||
|
var props = new AuthenticationProperties
|
||||||
|
{
|
||||||
|
RedirectUri = returnUrl
|
||||||
|
};
|
||||||
|
return Challenge(props, scheme);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
[HttpPost("logout")]
|
[HttpPost("logout")]
|
||||||
[Authorize]
|
[Authorize]
|
||||||
[IgnoreRolePermission]
|
[IgnoreRolePermission]
|
||||||
|
[LogoutLog]
|
||||||
public Task LogoutAsync()
|
public Task LogoutAsync()
|
||||||
{
|
{
|
||||||
return _authService.LoginOutAsync();
|
return _authService.LoginOutAsync();
|
||||||
|
|||||||
@@ -1,14 +1,4 @@
|
|||||||
// ------------------------------------------------------------------------
|
|
||||||
// 版权信息
|
|
||||||
// 版权归百小僧及百签科技(广东)有限公司所有。
|
|
||||||
// 所有权利保留。
|
|
||||||
// 官方网站:https://baiqian.com
|
|
||||||
//
|
|
||||||
// 许可证信息
|
|
||||||
// 项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。
|
|
||||||
// 许可证的完整文本可以在源代码树根目录中的 LICENSE-APACHE 和 LICENSE-MIT 文件中找到。
|
|
||||||
// ------------------------------------------------------------------------
|
|
||||||
|
|
||||||
using ThingsGateway.DependencyInjection;
|
using ThingsGateway.DependencyInjection;
|
||||||
|
|
||||||
namespace System;
|
namespace System;
|
||||||
|
|||||||
@@ -8,6 +8,8 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
using System.Reflection;
|
||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
public class RequestAuditData
|
public class RequestAuditData
|
||||||
@@ -94,5 +96,6 @@ public class RequestAuditData
|
|||||||
/// 验证错误信息
|
/// 验证错误信息
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public Validation Validation { get; set; }
|
public Validation Validation { get; set; }
|
||||||
|
public MethodInfo MethodInfo { get; set; }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -123,12 +123,12 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
var desc = App.CreateLocalizerByType(controllerActionDescriptor.ControllerTypeInfo.AsType())[actionMethod.Name];
|
var desc = App.CreateLocalizerByType(controllerActionDescriptor.ControllerTypeInfo.AsType())[actionMethod.Name];
|
||||||
//获取特性
|
//获取特性
|
||||||
|
|
||||||
|
|
||||||
logData.CateGory = desc.Value;//传操作名称
|
logData.CateGory = desc.Value;//传操作名称
|
||||||
logData.Operation = desc.Value;//传操作名称
|
logData.Operation = desc.Value;//传操作名称
|
||||||
logData.Client = client;
|
logData.Client = client;
|
||||||
logData.Path = httpContext.Request.Path.Value;//请求地址
|
logData.Path = httpContext.Request.Path.Value;//请求地址
|
||||||
logData.Method = httpContext.Request.Method;//请求方法
|
logData.Method = httpContext.Request.Method;//请求方法
|
||||||
|
logData.MethodInfo = actionMethod;//请求方法
|
||||||
|
|
||||||
logData.ControllerName = controllerActionDescriptor.ControllerName;
|
logData.ControllerName = controllerActionDescriptor.ControllerName;
|
||||||
logData.ActionName = controllerActionDescriptor.ActionName;
|
logData.ActionName = controllerActionDescriptor.ActionName;
|
||||||
|
|||||||
@@ -1,14 +1,4 @@
|
|||||||
// ------------------------------------------------------------------------
|
|
||||||
// 版权信息
|
|
||||||
// 版权归百小僧及百签科技(广东)有限公司所有。
|
|
||||||
// 所有权利保留。
|
|
||||||
// 官方网站:https://baiqian.com
|
|
||||||
//
|
|
||||||
// 许可证信息
|
|
||||||
// 项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。
|
|
||||||
// 许可证的完整文本可以在源代码树根目录中的 LICENSE-APACHE 和 LICENSE-MIT 文件中找到。
|
|
||||||
// ------------------------------------------------------------------------
|
|
||||||
|
|
||||||
using ThingsGateway.DependencyInjection;
|
using ThingsGateway.DependencyInjection;
|
||||||
|
|
||||||
namespace System;
|
namespace System;
|
||||||
|
|||||||
@@ -0,0 +1,277 @@
|
|||||||
|
using Microsoft.AspNetCore.Authentication;
|
||||||
|
using Microsoft.AspNetCore.Authentication.OAuth;
|
||||||
|
using Microsoft.AspNetCore.Http;
|
||||||
|
using Microsoft.AspNetCore.WebUtilities;
|
||||||
|
using Microsoft.Extensions.DependencyInjection;
|
||||||
|
using Microsoft.Extensions.Hosting;
|
||||||
|
using Microsoft.Extensions.Logging;
|
||||||
|
using Microsoft.Extensions.Options;
|
||||||
|
|
||||||
|
using System.Collections.Concurrent;
|
||||||
|
using System.Net.Http.Headers;
|
||||||
|
using System.Security.Claims;
|
||||||
|
using System.Text;
|
||||||
|
using System.Text.Encodings.Web;
|
||||||
|
using System.Text.Json;
|
||||||
|
|
||||||
|
using ThingsGateway.Extension;
|
||||||
|
|
||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 只适合 Demo 登录,会直接授权超管的权限
|
||||||
|
/// </summary>
|
||||||
|
public class AdminOAuthHandler<TOptions>(
|
||||||
|
IVerificatInfoService verificatInfoService,
|
||||||
|
IAppService appService,
|
||||||
|
ISysUserService sysUserService,
|
||||||
|
ISysDictService configService,
|
||||||
|
IOptionsMonitor<TOptions> options,
|
||||||
|
ILoggerFactory logger,
|
||||||
|
IUserAgentService userAgentService,
|
||||||
|
UrlEncoder encoder
|
||||||
|
) : OAuthHandler<TOptions>(options, logger, encoder)
|
||||||
|
where TOptions : AdminOAuthOptions, new()
|
||||||
|
{
|
||||||
|
|
||||||
|
|
||||||
|
static AdminOAuthHandler()
|
||||||
|
{
|
||||||
|
Task.Factory.StartNew(Insertable, TaskCreationOptions.LongRunning);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 日志消息队列(线程安全)
|
||||||
|
/// </summary>
|
||||||
|
protected static readonly ConcurrentQueue<SysOperateLog> _operateLogMessageQueue = new();
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 创建访问日志
|
||||||
|
/// </summary>
|
||||||
|
private static async Task Insertable()
|
||||||
|
{
|
||||||
|
var db = DbContext.Db.GetConnectionScopeWithAttr<SysOperateLog>().CopyNew();
|
||||||
|
var appLifetime = App.RootServices!.GetService<IHostApplicationLifetime>()!;
|
||||||
|
while (!appLifetime.ApplicationStopping.IsCancellationRequested)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var data = _operateLogMessageQueue.ToListWithDequeue(); // 从日志队列中获取数据
|
||||||
|
if (data.Count > 0)
|
||||||
|
{
|
||||||
|
await db.InsertableWithAttr(data).ExecuteCommandAsync(appLifetime.ApplicationStopping).ConfigureAwait(false);//入库
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
NewLife.Log.XTrace.WriteException(ex);
|
||||||
|
}
|
||||||
|
finally
|
||||||
|
{
|
||||||
|
await Task.Delay(3000, appLifetime.ApplicationStopping).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
protected override async Task<AuthenticationTicket> CreateTicketAsync(
|
||||||
|
ClaimsIdentity identity,
|
||||||
|
AuthenticationProperties properties,
|
||||||
|
OAuthTokenResponse tokens)
|
||||||
|
{
|
||||||
|
properties.RedirectUri = Options.HomePath;
|
||||||
|
properties.IsPersistent = true;
|
||||||
|
var appConfig = await configService.GetAppConfigAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
|
int expire = appConfig.LoginPolicy.VerificatExpireTime;
|
||||||
|
if (!string.IsNullOrEmpty(tokens.ExpiresIn) && int.TryParse(tokens.ExpiresIn, out var result))
|
||||||
|
{
|
||||||
|
properties.ExpiresUtc = TimeProvider.System.GetUtcNow().AddSeconds(result);
|
||||||
|
expire = (int)(result / 60.0);
|
||||||
|
}
|
||||||
|
var user = await HandleUserInfoAsync(tokens).ConfigureAwait(false);
|
||||||
|
|
||||||
|
var loginEvent = await GetLogin(expire).ConfigureAwait(false);
|
||||||
|
await UpdateUser(loginEvent).ConfigureAwait(false);
|
||||||
|
identity.AddClaim(new Claim(ClaimConst.VerificatId, loginEvent.VerificatId.ToString()));
|
||||||
|
identity.AddClaim(new Claim(ClaimConst.UserId, RoleConst.SuperAdminId.ToString()));
|
||||||
|
|
||||||
|
identity.AddClaim(new Claim(ClaimConst.SuperAdmin, "true"));
|
||||||
|
identity.AddClaim(new Claim(ClaimConst.OrgId, RoleConst.DefaultTenantId.ToString()));
|
||||||
|
identity.AddClaim(new Claim(ClaimConst.TenantId, RoleConst.DefaultTenantId.ToString()));
|
||||||
|
|
||||||
|
|
||||||
|
var context = new OAuthCreatingTicketContext(
|
||||||
|
new ClaimsPrincipal(identity),
|
||||||
|
properties,
|
||||||
|
Context,
|
||||||
|
Scheme,
|
||||||
|
Options,
|
||||||
|
Backchannel,
|
||||||
|
tokens,
|
||||||
|
user
|
||||||
|
);
|
||||||
|
|
||||||
|
context.RunClaimActions();
|
||||||
|
await Events.CreatingTicket(context).ConfigureAwait(false);
|
||||||
|
|
||||||
|
var httpContext = context.HttpContext;
|
||||||
|
UserAgent? userAgent = null;
|
||||||
|
var str = httpContext?.Request?.Headers?.UserAgent;
|
||||||
|
if (!string.IsNullOrEmpty(str))
|
||||||
|
{
|
||||||
|
userAgent = userAgentService.Parse(str);
|
||||||
|
}
|
||||||
|
|
||||||
|
var sysOperateLog = new SysOperateLog()
|
||||||
|
{
|
||||||
|
Name = this.Scheme.Name,
|
||||||
|
Category = LogCateGoryEnum.Login,
|
||||||
|
ExeStatus = true,
|
||||||
|
OpIp = httpContext.GetRemoteIpAddressToIPv4(),
|
||||||
|
OpBrowser = userAgent?.Browser,
|
||||||
|
OpOs = userAgent?.Platform,
|
||||||
|
OpTime = DateTime.Now,
|
||||||
|
VerificatId = loginEvent.VerificatId,
|
||||||
|
OpAccount = Options.GetName(user),
|
||||||
|
|
||||||
|
ReqMethod = "OAuth",
|
||||||
|
ReqUrl = string.Empty,
|
||||||
|
ResultJson = string.Empty,
|
||||||
|
ClassName = nameof(AdminOAuthHandler<TOptions>),
|
||||||
|
MethodName = string.Empty,
|
||||||
|
ParamJson = string.Empty,
|
||||||
|
};
|
||||||
|
_operateLogMessageQueue.Enqueue(sysOperateLog);
|
||||||
|
return new AuthenticationTicket(context.Principal, context.Properties, Scheme.Name);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/// <summary>处理用户信息方法</summary>
|
||||||
|
protected virtual async Task<JsonElement> HandleUserInfoAsync(OAuthTokenResponse tokens)
|
||||||
|
{
|
||||||
|
var request = new HttpRequestMessage(HttpMethod.Get, BuildUserInfoUrl(tokens));
|
||||||
|
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
|
||||||
|
|
||||||
|
var response = await Backchannel.SendAsync(request, Context.RequestAborted).ConfigureAwait(false);
|
||||||
|
|
||||||
|
var content = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (response.IsSuccessStatusCode)
|
||||||
|
{
|
||||||
|
return JsonDocument.Parse(content).RootElement;
|
||||||
|
}
|
||||||
|
|
||||||
|
throw new OAuthTokenException($"OAuth user info endpoint failure: {await Display(response).ConfigureAwait(false)}");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>生成用户信息请求地址方法</summary>
|
||||||
|
protected virtual string BuildUserInfoUrl(OAuthTokenResponse tokens)
|
||||||
|
{
|
||||||
|
return QueryHelpers.AddQueryString(Options.UserInformationEndpoint, new Dictionary<string, string>
|
||||||
|
{
|
||||||
|
{ "access_token", tokens.AccessToken }
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>生成错误信息方法</summary>
|
||||||
|
protected static async Task<string> Display(HttpResponseMessage response)
|
||||||
|
{
|
||||||
|
var output = new StringBuilder();
|
||||||
|
output.Append($"Status: {response.StatusCode}; ");
|
||||||
|
output.Append($"Headers: {response.Headers}; ");
|
||||||
|
output.Append($"Body: {await response.Content.ReadAsStringAsync().ConfigureAwait(false)};");
|
||||||
|
|
||||||
|
return output.ToString();
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task<LoginEvent> GetLogin(int expire)
|
||||||
|
{
|
||||||
|
var sysUser = await sysUserService.GetUserByIdAsync(RoleConst.SuperAdminId).ConfigureAwait(false);//获取用户信息
|
||||||
|
|
||||||
|
var loginEvent = new LoginEvent
|
||||||
|
{
|
||||||
|
Ip = appService.RemoteIpAddress,
|
||||||
|
Device = appService.UserAgent?.Platform,
|
||||||
|
Expire = expire,
|
||||||
|
SysUser = sysUser,
|
||||||
|
VerificatId = CommonUtils.GetSingleId()
|
||||||
|
};
|
||||||
|
|
||||||
|
//获取verificat列表
|
||||||
|
var tokenTimeout = loginEvent.DateTime.AddMinutes(loginEvent.Expire);
|
||||||
|
//生成verificat信息
|
||||||
|
var verificatInfo = new VerificatInfo
|
||||||
|
{
|
||||||
|
Device = loginEvent.Device,
|
||||||
|
Expire = loginEvent.Expire,
|
||||||
|
VerificatTimeout = tokenTimeout,
|
||||||
|
Id = loginEvent.VerificatId,
|
||||||
|
UserId = loginEvent.SysUser.Id,
|
||||||
|
LoginIp = loginEvent.Ip,
|
||||||
|
LoginTime = loginEvent.DateTime
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
//添加到verificat列表
|
||||||
|
verificatInfoService.Add(verificatInfo);
|
||||||
|
return loginEvent;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 登录事件
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="loginEvent"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
private async Task UpdateUser(LoginEvent loginEvent)
|
||||||
|
{
|
||||||
|
var sysUser = loginEvent.SysUser;
|
||||||
|
|
||||||
|
#region 登录/密码策略
|
||||||
|
|
||||||
|
var key = CacheConst.Cache_LoginErrorCount + sysUser.Account;//获取登录错误次数Key值
|
||||||
|
App.CacheService.Remove(key);//移除登录错误次数
|
||||||
|
|
||||||
|
//获取用户verificat列表
|
||||||
|
var userToken = verificatInfoService.GetOne(loginEvent.VerificatId);
|
||||||
|
|
||||||
|
#endregion 登录/密码策略
|
||||||
|
|
||||||
|
#region 重新赋值属性,设置本次登录信息为最新的信息
|
||||||
|
|
||||||
|
sysUser.LastLoginIp = sysUser.LatestLoginIp;
|
||||||
|
sysUser.LastLoginTime = sysUser.LatestLoginTime;
|
||||||
|
sysUser.LatestLoginIp = loginEvent.Ip;
|
||||||
|
sysUser.LatestLoginTime = loginEvent.DateTime;
|
||||||
|
|
||||||
|
#endregion 重新赋值属性,设置本次登录信息为最新的信息
|
||||||
|
|
||||||
|
using var db = DbContext.Db.GetConnectionScopeWithAttr<SysUser>().CopyNew();
|
||||||
|
//更新用户登录信息
|
||||||
|
if (await db.Updateable(sysUser).UpdateColumns(it => new
|
||||||
|
{
|
||||||
|
it.LastLoginIp,
|
||||||
|
it.LastLoginTime,
|
||||||
|
it.LatestLoginIp,
|
||||||
|
it.LatestLoginTime,
|
||||||
|
}).ExecuteCommandAsync().ConfigureAwait(false) > 0)
|
||||||
|
App.CacheService.HashAdd(CacheConst.Cache_SysUser, sysUser.Id.ToString(), sysUser);//更新Cache信息
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>自定义 Token 异常</summary>
|
||||||
|
public class OAuthTokenException : Exception
|
||||||
|
{
|
||||||
|
public OAuthTokenException() : base()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
public OAuthTokenException(string? message, Exception? innerException) : base(message, innerException)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
public OAuthTokenException(string? message) : base(message)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,40 @@
|
|||||||
|
using Microsoft.AspNetCore.Authentication.OAuth;
|
||||||
|
|
||||||
|
using System.Text.Json;
|
||||||
|
|
||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
/// <summary>OAuthOptions 配置类</summary>
|
||||||
|
public abstract class AdminOAuthOptions : OAuthOptions
|
||||||
|
{
|
||||||
|
/// <summary>默认构造函数</summary>
|
||||||
|
protected AdminOAuthOptions()
|
||||||
|
{
|
||||||
|
ConfigureClaims();
|
||||||
|
this.Events.OnRemoteFailure = context =>
|
||||||
|
{
|
||||||
|
var redirectUri = string.IsNullOrEmpty(HomePath) ? "/" : HomePath;
|
||||||
|
context.Response.Redirect(redirectUri);
|
||||||
|
context.HandleResponse();
|
||||||
|
return Task.CompletedTask;
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>配置 Claims 映射</summary>
|
||||||
|
protected virtual void ConfigureClaims()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public virtual string GetName(JsonElement element)
|
||||||
|
{
|
||||||
|
JsonElement.ObjectEnumerator target = element.EnumerateObject();
|
||||||
|
return target.TryGetValue("name");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>获得/设置 登陆后首页</summary>
|
||||||
|
public string HomePath { get; set; } = "/";
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,114 @@
|
|||||||
|
using Microsoft.AspNetCore.Authentication;
|
||||||
|
using Microsoft.AspNetCore.Authentication.OAuth;
|
||||||
|
using Microsoft.AspNetCore.WebUtilities;
|
||||||
|
|
||||||
|
using System.Net.Http.Headers;
|
||||||
|
using System.Text;
|
||||||
|
using System.Text.Json;
|
||||||
|
|
||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
public class GiteeOAuthOptions : AdminOAuthOptions
|
||||||
|
{
|
||||||
|
|
||||||
|
public GiteeOAuthOptions() : base()
|
||||||
|
{
|
||||||
|
this.SignInScheme = ClaimConst.Scheme;
|
||||||
|
this.AuthorizationEndpoint = "https://gitee.com/oauth/authorize";
|
||||||
|
this.TokenEndpoint = "https://gitee.com/oauth/token";
|
||||||
|
this.UserInformationEndpoint = "https://gitee.com/api/v5/user";
|
||||||
|
this.HomePath = "/";
|
||||||
|
this.CallbackPath = "/signin-gitee";
|
||||||
|
Scope.Add("user_info");
|
||||||
|
Scope.Add("projects");
|
||||||
|
|
||||||
|
Events.OnCreatingTicket = async context =>
|
||||||
|
{
|
||||||
|
await HandlerGiteeStarredUrl(context).ConfigureAwait(false);
|
||||||
|
};
|
||||||
|
|
||||||
|
Events.OnRedirectToAuthorizationEndpoint = context =>
|
||||||
|
{
|
||||||
|
//context.RedirectUri = context.RedirectUri.Replace("http%3A%2F%2F", "https%3A%2F%2F"); // 强制替换
|
||||||
|
context.Response.Redirect(context.RedirectUri);
|
||||||
|
return Task.CompletedTask;
|
||||||
|
};
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>刷新 Token 方法</summary>
|
||||||
|
protected virtual async Task<OAuthTokenResponse> RefreshTokenAsync(TicketReceivedContext ticketReceivedContext, string refreshToken)
|
||||||
|
{
|
||||||
|
var query = new Dictionary<string, string>
|
||||||
|
{
|
||||||
|
{ "refresh_token", refreshToken },
|
||||||
|
{ "grant_type", "refresh_token" }
|
||||||
|
};
|
||||||
|
|
||||||
|
var request = new HttpRequestMessage(HttpMethod.Post, QueryHelpers.AddQueryString(TokenEndpoint, query));
|
||||||
|
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
|
||||||
|
|
||||||
|
var response = await Backchannel.SendAsync(request, ticketReceivedContext.HttpContext.RequestAborted).ConfigureAwait(false);
|
||||||
|
|
||||||
|
var content = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (response.IsSuccessStatusCode)
|
||||||
|
{
|
||||||
|
return OAuthTokenResponse.Success(JsonDocument.Parse(content));
|
||||||
|
}
|
||||||
|
|
||||||
|
return OAuthTokenResponse.Failed(new OAuthTokenException($"OAuth token endpoint failure: {await Display(response).ConfigureAwait(false)}"));
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>生成错误信息方法</summary>
|
||||||
|
protected static async Task<string> Display(HttpResponseMessage response)
|
||||||
|
{
|
||||||
|
var output = new StringBuilder();
|
||||||
|
output.Append($"Status: {response.StatusCode}; ");
|
||||||
|
output.Append($"Headers: {response.Headers}; ");
|
||||||
|
output.Append($"Body: {await response.Content.ReadAsStringAsync().ConfigureAwait(false)};");
|
||||||
|
|
||||||
|
return output.ToString();
|
||||||
|
}
|
||||||
|
|
||||||
|
public override string GetName(JsonElement element)
|
||||||
|
{
|
||||||
|
JsonElement.ObjectEnumerator target = element.EnumerateObject();
|
||||||
|
return target.TryGetValue("name");
|
||||||
|
}
|
||||||
|
|
||||||
|
private static async Task HandlerGiteeStarredUrl(OAuthCreatingTicketContext context, string repoFullName = "ThingsGateway/ThingsGateway")
|
||||||
|
{
|
||||||
|
if (string.IsNullOrWhiteSpace(context.AccessToken))
|
||||||
|
throw new InvalidOperationException("Access token is missing.");
|
||||||
|
|
||||||
|
var uri = $"https://gitee.com/api/v5/user/starred/{repoFullName}";
|
||||||
|
|
||||||
|
var queryString = new Dictionary<string, string>
|
||||||
|
{
|
||||||
|
{ "access_token", context.AccessToken }
|
||||||
|
};
|
||||||
|
|
||||||
|
var request = new HttpRequestMessage(HttpMethod.Put, QueryHelpers.AddQueryString(uri, queryString))
|
||||||
|
{
|
||||||
|
Headers = { Accept = { new MediaTypeWithQualityHeaderValue("application/json") } }
|
||||||
|
};
|
||||||
|
|
||||||
|
var response = await context.Backchannel.SendAsync(request, context.HttpContext.RequestAborted).ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (!response.IsSuccessStatusCode)
|
||||||
|
{
|
||||||
|
var content = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
|
||||||
|
throw new Exception($"Failed to star repository: {response.StatusCode}, {content}");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
protected override void ConfigureClaims()
|
||||||
|
{
|
||||||
|
ClaimActions.MapJsonKey(ClaimConst.AvatarUrl, "avatar_url");
|
||||||
|
ClaimActions.MapJsonKey(ClaimConst.Account, "name");
|
||||||
|
|
||||||
|
base.ConfigureClaims();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,7 @@
|
|||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
public class GiteeOAuthSettings
|
||||||
|
{
|
||||||
|
public string ClientId { get; set; }
|
||||||
|
public string ClientSecret { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,12 @@
|
|||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
public class GiteeOAuthUser
|
||||||
|
{
|
||||||
|
public string Id { get; set; }
|
||||||
|
|
||||||
|
public string Login { get; set; }
|
||||||
|
|
||||||
|
public string Name { get; set; }
|
||||||
|
|
||||||
|
public string Avatar_Url { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,22 @@
|
|||||||
|
using System.Text.Json;
|
||||||
|
|
||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
public static class OAuthUserExtensions
|
||||||
|
{
|
||||||
|
public static GiteeOAuthUser ToAuthUser(this JsonElement element)
|
||||||
|
{
|
||||||
|
GiteeOAuthUser authUser = new GiteeOAuthUser();
|
||||||
|
JsonElement.ObjectEnumerator target = element.EnumerateObject();
|
||||||
|
authUser.Id = target.TryGetValue("id");
|
||||||
|
authUser.Login = target.TryGetValue("login");
|
||||||
|
authUser.Name = target.TryGetValue("name");
|
||||||
|
authUser.Avatar_Url = target.TryGetValue("avatar_url");
|
||||||
|
return authUser;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static string TryGetValue(this JsonElement.ObjectEnumerator target, string propertyName)
|
||||||
|
{
|
||||||
|
return target.FirstOrDefault<JsonProperty>((Func<JsonProperty, bool>)(t => t.Name.Equals(propertyName, StringComparison.OrdinalIgnoreCase))).Value.ToString() ?? string.Empty;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -11,11 +11,13 @@
|
|||||||
using SqlSugar;
|
using SqlSugar;
|
||||||
|
|
||||||
using System.Collections.Concurrent;
|
using System.Collections.Concurrent;
|
||||||
|
using System.Reflection;
|
||||||
|
|
||||||
using ThingsGateway.Extension;
|
using ThingsGateway.Extension;
|
||||||
using ThingsGateway.FriendlyException;
|
using ThingsGateway.FriendlyException;
|
||||||
using ThingsGateway.Logging;
|
using ThingsGateway.Logging;
|
||||||
using ThingsGateway.NewLife.Json.Extension;
|
using ThingsGateway.NewLife.Json.Extension;
|
||||||
|
using ThingsGateway.Razor;
|
||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
@@ -51,13 +53,18 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
|||||||
var client = requestAuditData.Client;//获取客户端信息
|
var client = requestAuditData.Client;//获取客户端信息
|
||||||
var path = requestAuditData.Path;//获取操作名称
|
var path = requestAuditData.Path;//获取操作名称
|
||||||
var method = requestAuditData.Method;//获取方法
|
var method = requestAuditData.Method;//获取方法
|
||||||
|
var methodInfo = requestAuditData.MethodInfo;
|
||||||
|
var login = methodInfo.GetCustomAttribute(typeof(LoginLogAttribute));
|
||||||
|
var logout = methodInfo.GetCustomAttribute(typeof(LogoutLogAttribute));
|
||||||
|
|
||||||
//表示访问日志
|
//表示访问日志
|
||||||
if (path == "/api/auth/login" || path == "/api/auth/logout")
|
if (login != null || logout != null)
|
||||||
{
|
{
|
||||||
//如果没有异常信息
|
//如果没有异常信息
|
||||||
if (requestAuditData.Exception == null)
|
if (requestAuditData.Exception == null)
|
||||||
{
|
{
|
||||||
save = await CreateVisitLog(operation, path, requestAuditData, client, flush).ConfigureAwait(false);//添加到访问日志
|
LogCateGoryEnum logCateGoryEnum = login != null ? LogCateGoryEnum.Login : LogCateGoryEnum.Logout;
|
||||||
|
save = await CreateVisitLog(operation, path, requestAuditData, client, logCateGoryEnum, flush).ConfigureAwait(false);//添加到访问日志
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -151,17 +158,20 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
|||||||
/// <param name="path"></param>
|
/// <param name="path"></param>
|
||||||
/// <param name="requestAuditData">requestAuditData</param>
|
/// <param name="requestAuditData">requestAuditData</param>
|
||||||
/// <param name="userAgent">客户端信息</param>
|
/// <param name="userAgent">客户端信息</param>
|
||||||
|
/// <param name="logCateGoryEnum">logCateGory</param>
|
||||||
/// <param name="flush"></param>
|
/// <param name="flush"></param>
|
||||||
private async Task<bool> CreateVisitLog(string operation, string path, RequestAuditData requestAuditData, UserAgent userAgent, bool flush)
|
private async Task<bool> CreateVisitLog(string operation, string path, RequestAuditData requestAuditData, UserAgent userAgent, LogCateGoryEnum logCateGoryEnum, bool flush)
|
||||||
{
|
{
|
||||||
long verificatId = 0;//验证Id
|
long verificatId = 0;//验证Id
|
||||||
var opAccount = "";//用户账号
|
var opAccount = "";//用户账号
|
||||||
if (path == "/api/auth/login")
|
if (logCateGoryEnum == LogCateGoryEnum.Login)
|
||||||
{
|
{
|
||||||
//如果是登录,用户信息就从返回值里拿
|
//如果是登录,用户信息就从返回值里拿
|
||||||
dynamic userInfo = requestAuditData.ReturnInformation;
|
if (requestAuditData.ReturnInformation is UnifyResult<LoginOutput> userInfo)
|
||||||
opAccount = userInfo.Data.Account;//赋值账号
|
{
|
||||||
verificatId = userInfo.Data.VerificatId;
|
opAccount = userInfo.Data.Account;//赋值账号
|
||||||
|
verificatId = userInfo.Data.VerificatId;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -173,7 +183,7 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
|||||||
var sysLogVisit = new SysOperateLog
|
var sysLogVisit = new SysOperateLog
|
||||||
{
|
{
|
||||||
Name = operation,
|
Name = operation,
|
||||||
Category = path == "/api/auth/login" ? LogCateGoryEnum.Login : LogCateGoryEnum.Logout,
|
Category = logCateGoryEnum,
|
||||||
ExeStatus = true,
|
ExeStatus = true,
|
||||||
OpIp = requestAuditData.RemoteIPv4,
|
OpIp = requestAuditData.RemoteIPv4,
|
||||||
OpBrowser = userAgent?.Browser,
|
OpBrowser = userAgent?.Browser,
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 日志常量
|
/// 日志常量
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class LoggingConst
|
public static class LoggingConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 分类
|
/// 分类
|
||||||
|
|||||||
@@ -87,7 +87,7 @@ public class BlazorAuthenticationHandler : AppAuthorizeHandler
|
|||||||
var roles = await _sysRoleService.GetRoleListByUserIdAsync(userId).ConfigureAwait(false);
|
var roles = await _sysRoleService.GetRoleListByUserIdAsync(userId).ConfigureAwait(false);
|
||||||
|
|
||||||
//这里鉴别用户使能状态
|
//这里鉴别用户使能状态
|
||||||
if (user == null || !user.Status)
|
if (user?.Status != true)
|
||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
@@ -137,7 +137,7 @@ public class BlazorAuthenticationHandler : AppAuthorizeHandler
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
//这里鉴别用户使能状态
|
//这里鉴别用户使能状态
|
||||||
if (user == null || !user.Status)
|
if (user?.Status != true)
|
||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,24 @@
|
|||||||
|
//------------------------------------------------------------------------------
|
||||||
|
// 此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
|
||||||
|
// 此代码版权(除特别声明外的代码)归作者本人Diego所有
|
||||||
|
// 源代码使用协议遵循本仓库的开源协议及附加协议
|
||||||
|
// Gitee源代码仓库:https://gitee.com/diego2098/ThingsGateway
|
||||||
|
// Github源代码仓库:https://github.com/kimdiego2098/ThingsGateway
|
||||||
|
// 使用文档:https://thingsgateway.cn/
|
||||||
|
// QQ群:605534569
|
||||||
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
using System.Security.Claims;
|
||||||
|
|
||||||
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
public class HybridClaimsPrincipalService : IClaimsPrincipalService
|
||||||
|
{
|
||||||
|
HybridAppService _hybridAppService;
|
||||||
|
public HybridClaimsPrincipalService(HybridAppService hybridAppService)
|
||||||
|
{
|
||||||
|
_hybridAppService = hybridAppService;
|
||||||
|
}
|
||||||
|
public ClaimsPrincipal? User => _hybridAppService.User;
|
||||||
|
|
||||||
|
}
|
||||||
@@ -12,8 +12,6 @@ using Microsoft.AspNetCore.Authentication.Cookies;
|
|||||||
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Http;
|
||||||
using Microsoft.Extensions.Localization;
|
using Microsoft.Extensions.Localization;
|
||||||
|
|
||||||
using SqlSugar;
|
|
||||||
|
|
||||||
using System.Security.Claims;
|
using System.Security.Claims;
|
||||||
|
|
||||||
using ThingsGateway.DataEncryption;
|
using ThingsGateway.DataEncryption;
|
||||||
@@ -64,6 +62,10 @@ public class AuthService : IAuthService
|
|||||||
{
|
{
|
||||||
throw Oops.Bah(appConfig.WebsitePolicy.CloseTip);
|
throw Oops.Bah(appConfig.WebsitePolicy.CloseTip);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
string? password = input.Password;
|
string? password = input.Password;
|
||||||
if (isCookie) //openApi登录不再需要解密
|
if (isCookie) //openApi登录不再需要解密
|
||||||
{
|
{
|
||||||
@@ -237,25 +239,20 @@ public class AuthService : IAuthService
|
|||||||
var logingEvent = new LoginEvent
|
var logingEvent = new LoginEvent
|
||||||
{
|
{
|
||||||
Ip = _appService.RemoteIpAddress,
|
Ip = _appService.RemoteIpAddress,
|
||||||
Device = App.GetService<IAppService>().UserAgent?.Platform,
|
Device = _appService.UserAgent?.Platform,
|
||||||
Expire = expire,
|
Expire = expire,
|
||||||
SysUser = sysUser,
|
SysUser = sysUser,
|
||||||
VerificatId = verificatId
|
VerificatId = verificatId
|
||||||
};
|
};
|
||||||
await WriteTokenToCache(loginPolicy, logingEvent).ConfigureAwait(false);//写入verificat到cache
|
await WriteTokenToCache(loginPolicy, logingEvent).ConfigureAwait(false);//写入verificat到cache
|
||||||
await UpdateUser(logingEvent).ConfigureAwait(false);
|
await UpdateUser(logingEvent).ConfigureAwait(false);
|
||||||
if (sysUser.Account == RoleConst.SuperAdmin)
|
|
||||||
{
|
|
||||||
var modules = (await _sysResourceService.GetAllAsync().ConfigureAwait(false)).Where(a => a.Category == ResourceCategoryEnum.Module).OrderBy(a => a.SortCode);//获取模块列表
|
|
||||||
sysUser.ModuleList = modules.ToList();//模块列表赋值给用户
|
|
||||||
}
|
|
||||||
//返回结果
|
//返回结果
|
||||||
return new LoginOutput
|
return new LoginOutput
|
||||||
{
|
{
|
||||||
VerificatId = verificatId,
|
VerificatId = verificatId,
|
||||||
Account = sysUser.Account,
|
Account = sysUser.Account,
|
||||||
Id = sysUser.Id,
|
Id = sysUser.Id,
|
||||||
ModuleList = sysUser.ModuleList,
|
|
||||||
AccessToken = accessToken,
|
AccessToken = accessToken,
|
||||||
RefreshToken = refreshToken
|
RefreshToken = refreshToken
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -334,7 +334,7 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
flatList.Add(node);
|
flatList.Add(node);
|
||||||
|
|
||||||
// 如果当前节点有子节点,则递归处理每个子节点
|
// 如果当前节点有子节点,则递归处理每个子节点
|
||||||
if (node.Children != null && node.Children.Count > 0)
|
if (node.Children?.Count > 0)
|
||||||
{
|
{
|
||||||
foreach (var child in node.Children)
|
foreach (var child in node.Children)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -466,7 +466,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
var exist = await GetUserByIdAsync(input.Id).ConfigureAwait(false);//获取用户信息
|
var exist = await GetUserByIdAsync(input.Id).ConfigureAwait(false);//获取用户信息
|
||||||
if (exist != null)
|
if (exist != null)
|
||||||
{
|
{
|
||||||
var isSuperAdmin = exist.Account == RoleConst.SuperAdmin;//判断是否有超管
|
var isSuperAdmin = exist.Id == RoleConst.SuperAdminId;//判断是否有超管
|
||||||
if (isSuperAdmin && !UserManager.SuperAdmin)
|
if (isSuperAdmin && !UserManager.SuperAdmin)
|
||||||
throw Oops.Bah(Localizer["CanotEditAdminUser"]);
|
throw Oops.Bah(Localizer["CanotEditAdminUser"]);
|
||||||
|
|
||||||
@@ -540,7 +540,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
await CheckApiDataScopeAsync(sysUser.OrgId, sysUser.CreateUserId).ConfigureAwait(false);
|
await CheckApiDataScopeAsync(sysUser.OrgId, sysUser.CreateUserId).ConfigureAwait(false);
|
||||||
if (sysUser != null)
|
if (sysUser != null)
|
||||||
{
|
{
|
||||||
var isSuperAdmin = (sysUser.Account == RoleConst.SuperAdmin || input.GrantInfoList.Any(a => a == RoleConst.SuperAdminRoleId)) && !UserManager.SuperAdmin;//判断是否有超管
|
var isSuperAdmin = (sysUser.Id == RoleConst.SuperAdminId || input.GrantInfoList.Any(a => a == RoleConst.SuperAdminRoleId)) && !UserManager.SuperAdmin;//判断是否有超管
|
||||||
if (isSuperAdmin)
|
if (isSuperAdmin)
|
||||||
throw Oops.Bah(Localizer["CanotGrantAdmin"]);
|
throw Oops.Bah(Localizer["CanotGrantAdmin"]);
|
||||||
|
|
||||||
@@ -660,7 +660,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
public async Task<bool> DeleteUserAsync(IEnumerable<long> ids)
|
public async Task<bool> DeleteUserAsync(IEnumerable<long> ids)
|
||||||
{
|
{
|
||||||
using var db = GetDB();
|
using var db = GetDB();
|
||||||
var containsSuperAdmin = await db.Queryable<SysUser>().Where(it => it.Account == RoleConst.SuperAdmin && ids.Contains(it.Id)).AnyAsync().ConfigureAwait(false);//判断是否有超管
|
var containsSuperAdmin = await db.Queryable<SysUser>().Where(it => it.Id == RoleConst.SuperAdminId && ids.Contains(it.Id)).AnyAsync().ConfigureAwait(false);//判断是否有超管
|
||||||
if (containsSuperAdmin)
|
if (containsSuperAdmin)
|
||||||
throw Oops.Bah(Localizer["CanotDeleteAdminUser"]);
|
throw Oops.Bah(Localizer["CanotDeleteAdminUser"]);
|
||||||
if (ids.Contains(UserManager.UserId))
|
if (ids.Contains(UserManager.UserId))
|
||||||
@@ -899,7 +899,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
var tenantId = await _sysOrgService.GetTenantIdByOrgIdAsync(sysUser.OrgId, sysOrgList).ConfigureAwait(false);
|
var tenantId = await _sysOrgService.GetTenantIdByOrgIdAsync(sysUser.OrgId, sysOrgList).ConfigureAwait(false);
|
||||||
sysUser.TenantId = tenantId;
|
sysUser.TenantId = tenantId;
|
||||||
|
|
||||||
if (sysUser.Account == RoleConst.SuperAdmin)
|
if (sysUser.Id == RoleConst.SuperAdminId)
|
||||||
{
|
{
|
||||||
var modules = (await _sysResourceService.GetAllAsync().ConfigureAwait(false)).Where(a => a.Category == ResourceCategoryEnum.Module).OrderBy(a => a.SortCode);
|
var modules = (await _sysResourceService.GetAllAsync().ConfigureAwait(false)).Where(a => a.Category == ResourceCategoryEnum.Module).OrderBy(a => a.SortCode);
|
||||||
sysUser.ModuleList = modules.ToList();//模块列表赋值给用户
|
sysUser.ModuleList = modules.ToList();//模块列表赋值给用户
|
||||||
|
|||||||
@@ -47,7 +47,7 @@
|
|||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<ProjectReference Include="..\ThingsGateway.Razor\ThingsGateway.Razor.csproj" />
|
<ProjectReference Include="..\ThingsGateway.Razor\ThingsGateway.Razor.csproj" />
|
||||||
<ProjectReference Include="..\ThingsGateway.SqlSugar\ThingsGateway.SqlSugar.csproj" />
|
<ProjectReference Include="..\ThingsGateway.DB\ThingsGateway.DB.csproj" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ using Microsoft.Extensions.DependencyInjection;
|
|||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class ClearTokenUtil
|
public static class ClearTokenUtil
|
||||||
{
|
{
|
||||||
private static IRelationService RelationService;
|
private static IRelationService RelationService;
|
||||||
private static ISysUserService SysUserService;
|
private static ISysUserService SysUserService;
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ using Microsoft.Extensions.DependencyInjection;
|
|||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class NoticeUtil
|
public static class NoticeUtil
|
||||||
{
|
{
|
||||||
private static INoticeService NoticeService;
|
private static INoticeService NoticeService;
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class OpenApiUtil
|
public static class OpenApiUtil
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 构建树节点,传入的列表已经是树结构
|
/// 构建树节点,传入的列表已经是树结构
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class OrgUtil
|
public static class OrgUtil
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 构造选择项,ID/TITLE
|
/// 构造选择项,ID/TITLE
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class PositionUtil
|
public static class PositionUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class RoleUtil
|
public static class RoleUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class UserUtil
|
public static class UserUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ using ThingsGateway.Extension.Generic;
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
public class VerificatInfoUtil
|
public static class VerificatInfoUtil
|
||||||
{
|
{
|
||||||
private static IVerificatInfoService VerificatInfoService { get; set; }
|
private static IVerificatInfoService VerificatInfoService { get; set; }
|
||||||
static VerificatInfoUtil()
|
static VerificatInfoUtil()
|
||||||
|
|||||||
@@ -11,7 +11,7 @@
|
|||||||
namespace ThingsGateway.Admin.Razor;
|
namespace ThingsGateway.Admin.Razor;
|
||||||
|
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class AdminOperConst
|
public static class AdminOperConst
|
||||||
{
|
{
|
||||||
public const string Add = "新增";
|
public const string Add = "新增";
|
||||||
public const string Delete = "删除";
|
public const string Delete = "删除";
|
||||||
|
|||||||
@@ -40,6 +40,8 @@ public class BlazorAppContext
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public SysUser CurrentUser { get; private set; }
|
public SysUser CurrentUser { get; private set; }
|
||||||
|
|
||||||
|
public string? Avatar => UserManager.AvatarUrl.IsNullOrEmpty() ? CurrentUser.Avatar : UserManager.AvatarUrl;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 用户个人菜单
|
/// 用户个人菜单
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|||||||
@@ -48,7 +48,7 @@ public partial class SysUserAvatarEdit : IDisposable
|
|||||||
|
|
||||||
private async Task OnAvatarUpload(UploadFile file)
|
private async Task OnAvatarUpload(UploadFile file)
|
||||||
{
|
{
|
||||||
if (file != null && file.File != null)
|
if (file?.File != null)
|
||||||
{
|
{
|
||||||
var format = file.File.ContentType;
|
var format = file.File.ContentType;
|
||||||
ReadAvatarToken ??= new CancellationTokenSource();
|
ReadAvatarToken ??= new CancellationTokenSource();
|
||||||
|
|||||||
@@ -38,7 +38,7 @@ public partial class UserCenterPage
|
|||||||
protected override async Task OnParametersSetAsync()
|
protected override async Task OnParametersSetAsync()
|
||||||
{
|
{
|
||||||
SysUser = AppContext.CurrentUser.Adapt<SysUser>();
|
SysUser = AppContext.CurrentUser.Adapt<SysUser>();
|
||||||
SysUser.Avatar = AppContext.CurrentUser.Avatar;
|
SysUser.Avatar = AppContext.Avatar;
|
||||||
WorkbenchInfo = (await UserCenterService.GetLoginWorkbenchAsync(SysUser.Id)).Adapt<WorkbenchInfo>();
|
WorkbenchInfo = (await UserCenterService.GetLoginWorkbenchAsync(SysUser.Id)).Adapt<WorkbenchInfo>();
|
||||||
|
|
||||||
await base.OnParametersSetAsync();
|
await base.OnParametersSetAsync();
|
||||||
|
|||||||
@@ -48,7 +48,7 @@ public partial class UserInfoEditComponent
|
|||||||
|
|
||||||
private async Task OnAvatarUpload(UploadFile file)
|
private async Task OnAvatarUpload(UploadFile file)
|
||||||
{
|
{
|
||||||
if (file != null && file.File != null)
|
if (file?.File != null)
|
||||||
{
|
{
|
||||||
var format = file.File.ContentType;
|
var format = file.File.ContentType;
|
||||||
ReadAvatarToken ??= new CancellationTokenSource();
|
ReadAvatarToken ??= new CancellationTokenSource();
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ namespace ThingsGateway.Admin.Razor;
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class ResourceUtil
|
public static class ResourceUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
1
src/Admin/ThingsGateway.AdminServer/GlobalUsings.cs
Normal file
1
src/Admin/ThingsGateway.AdminServer/GlobalUsings.cs
Normal file
@@ -0,0 +1 @@
|
|||||||
|
global using ThingsGateway.Admin.Application;
|
||||||
@@ -18,7 +18,6 @@ using Microsoft.AspNetCore.Authorization;
|
|||||||
using Microsoft.AspNetCore.Components;
|
using Microsoft.AspNetCore.Components;
|
||||||
using Microsoft.Extensions.Localization;
|
using Microsoft.Extensions.Localization;
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
|
||||||
using ThingsGateway.Admin.Razor;
|
using ThingsGateway.Admin.Razor;
|
||||||
using ThingsGateway.Extension;
|
using ThingsGateway.Extension;
|
||||||
|
|
||||||
|
|||||||
@@ -13,8 +13,6 @@ using Microsoft.Extensions.Localization;
|
|||||||
|
|
||||||
using System.Diagnostics.CodeAnalysis;
|
using System.Diagnostics.CodeAnalysis;
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
|
||||||
|
|
||||||
namespace ThingsGateway.AdminServer;
|
namespace ThingsGateway.AdminServer;
|
||||||
|
|
||||||
public partial class AccessDenied
|
public partial class AccessDenied
|
||||||
|
|||||||
@@ -20,11 +20,11 @@ using Microsoft.Extensions.Options;
|
|||||||
|
|
||||||
using System.Diagnostics.CodeAnalysis;
|
using System.Diagnostics.CodeAnalysis;
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
|
||||||
using ThingsGateway.DataEncryption;
|
using ThingsGateway.DataEncryption;
|
||||||
using ThingsGateway.NewLife.Extension;
|
using ThingsGateway.NewLife.Extension;
|
||||||
using ThingsGateway.Razor;
|
using ThingsGateway.Razor;
|
||||||
|
|
||||||
|
|
||||||
namespace ThingsGateway.AdminServer;
|
namespace ThingsGateway.AdminServer;
|
||||||
|
|
||||||
public partial class Login
|
public partial class Login
|
||||||
|
|||||||
@@ -48,7 +48,7 @@
|
|||||||
<CultureChooser />
|
<CultureChooser />
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<Logout ImageUrl="@(AppContext.CurrentUser.Avatar??$"{WebsiteConst.DefaultResourceUrl}images/defaultUser.svg")" ShowUserName=false DisplayName="@UserManager.UserAccount" UserName="@UserManager.VerificatId.ToString()" PrefixUserNameText=@AdminLocalizer["CurrentVerificat"]>
|
<Logout ImageUrl="@(AppContext.Avatar??$"{WebsiteConst.DefaultResourceUrl}images/defaultUser.svg")" ShowUserName=false DisplayName="@UserManager.UserAccount" UserName="@UserManager.VerificatId.ToString()" PrefixUserNameText=@AdminLocalizer["CurrentVerificat"]>
|
||||||
<LinkTemplate>
|
<LinkTemplate>
|
||||||
<a href=@("/") class="h6"><i class="fa-solid fa-suitcase me-2"></i>@Localizer["系统首页"]</a>
|
<a href=@("/") class="h6"><i class="fa-solid fa-suitcase me-2"></i>@Localizer["系统首页"]</a>
|
||||||
|
|
||||||
|
|||||||
@@ -17,7 +17,6 @@ using Microsoft.Extensions.Options;
|
|||||||
|
|
||||||
using System.Diagnostics.CodeAnalysis;
|
using System.Diagnostics.CodeAnalysis;
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
|
||||||
using ThingsGateway.Admin.Razor;
|
using ThingsGateway.Admin.Razor;
|
||||||
using ThingsGateway.Razor;
|
using ThingsGateway.Razor;
|
||||||
|
|
||||||
@@ -27,38 +26,6 @@ public partial class MainLayout : IDisposable
|
|||||||
{
|
{
|
||||||
[Inject]
|
[Inject]
|
||||||
IStringLocalizer<ThingsGateway.Razor._Imports> RazorLocalizer { get; set; }
|
IStringLocalizer<ThingsGateway.Razor._Imports> RazorLocalizer { get; set; }
|
||||||
private Task OnRefresh(ContextMenuItem item, object? context)
|
|
||||||
{
|
|
||||||
if (context is TabItem tabItem)
|
|
||||||
{
|
|
||||||
_tab.Refresh(tabItem);
|
|
||||||
}
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
private async Task OnClose(ContextMenuItem item, object? context)
|
|
||||||
{
|
|
||||||
if (context is TabItem tabItem)
|
|
||||||
{
|
|
||||||
await _tab.RemoveTab(tabItem);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private Task OnCloseOther(ContextMenuItem item, object? context)
|
|
||||||
{
|
|
||||||
if (context is TabItem tabItem)
|
|
||||||
{
|
|
||||||
_tab.ActiveTab(tabItem);
|
|
||||||
}
|
|
||||||
_tab.CloseOtherTabs();
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
private Task OnCloseAll(ContextMenuItem item, object? context)
|
|
||||||
{
|
|
||||||
_tab.CloseAllTabs();
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
#region 全局通知
|
#region 全局通知
|
||||||
|
|
||||||
|
|||||||
@@ -25,7 +25,6 @@ using System.Text;
|
|||||||
using System.Text.Encodings.Web;
|
using System.Text.Encodings.Web;
|
||||||
using System.Text.Unicode;
|
using System.Text.Unicode;
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
|
||||||
using ThingsGateway.Admin.Razor;
|
using ThingsGateway.Admin.Razor;
|
||||||
using ThingsGateway.Extension;
|
using ThingsGateway.Extension;
|
||||||
using ThingsGateway.NewLife.Caching;
|
using ThingsGateway.NewLife.Caching;
|
||||||
@@ -369,12 +368,6 @@ public class Startup : AppStartup
|
|||||||
app.UseStaticFiles(new StaticFileOptions { ContentTypeProvider = provider });
|
app.UseStaticFiles(new StaticFileOptions { ContentTypeProvider = provider });
|
||||||
app.UseStaticFiles();
|
app.UseStaticFiles();
|
||||||
|
|
||||||
app.Use(async (context, next) =>
|
|
||||||
{
|
|
||||||
context.Response.Headers.Append("ThingsGateway", "ThingsGateway");
|
|
||||||
await next().ConfigureAwait(false);
|
|
||||||
});
|
|
||||||
|
|
||||||
|
|
||||||
// 特定文件类型(文件后缀)处理
|
// 特定文件类型(文件后缀)处理
|
||||||
var contentTypeProvider = GetFileExtensionContentTypeProvider();
|
var contentTypeProvider = GetFileExtensionContentTypeProvider();
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// 授权用户常量
|
/// 授权用户常量
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class ClaimConst
|
public static class ClaimConst
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 账号
|
/// 账号
|
||||||
@@ -31,6 +31,11 @@ public class ClaimConst
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public const string UserId = "UserId";
|
public const string UserId = "UserId";
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// AvatarUrl
|
||||||
|
/// </summary>
|
||||||
|
public const string AvatarUrl = "AvatarUrl";
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 验证Id
|
/// 验证Id
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -225,7 +225,7 @@ public static class SqlSugarExtensions
|
|||||||
|
|
||||||
private static IEnumerable<T> Sort<T>(this IEnumerable<T> list, BasePageInput basePageInput)
|
private static IEnumerable<T> Sort<T>(this IEnumerable<T> list, BasePageInput basePageInput)
|
||||||
{
|
{
|
||||||
if (basePageInput != null && basePageInput.SortField != null)
|
if (basePageInput?.SortField != null)
|
||||||
{
|
{
|
||||||
for (int i = 0; i < basePageInput.SortField.Count; i++)
|
for (int i = 0; i < basePageInput.SortField.Count; i++)
|
||||||
{
|
{
|
||||||
11
src/Admin/ThingsGateway.DB/GlobalUsings.cs
Normal file
11
src/Admin/ThingsGateway.DB/GlobalUsings.cs
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
//------------------------------------------------------------------------------
|
||||||
|
// 此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
|
||||||
|
// 此代码版权(除特别声明外的代码)归作者本人Diego所有
|
||||||
|
// 源代码使用协议遵循本仓库的开源协议及附加协议
|
||||||
|
// Gitee源代码仓库:https://gitee.com/diego2098/ThingsGateway
|
||||||
|
// Github源代码仓库:https://github.com/kimdiego2098/ThingsGateway
|
||||||
|
// 使用文档:https://thingsgateway.cn/
|
||||||
|
// QQ群:605534569
|
||||||
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
global using ThingsGateway.NewLife.Extension;
|
||||||
@@ -25,7 +25,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// 种子数据工具类
|
/// 种子数据工具类
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public class SeedDataUtil
|
public static class SeedDataUtil
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 获取List列表
|
/// 获取List列表
|
||||||
@@ -27,11 +27,17 @@ public static class UserManager
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public static bool SuperAdmin => (_claimsPrincipalService.User?.FindFirst(ClaimConst.SuperAdmin)?.Value).ToBoolean(false);
|
public static bool SuperAdmin => (_claimsPrincipalService.User?.FindFirst(ClaimConst.SuperAdmin)?.Value).ToBoolean(false);
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 当前用户账号
|
/// 当前用户账号
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public static string UserAccount => _claimsPrincipalService.User?.FindFirst(ClaimConst.Account)?.Value;
|
public static string UserAccount => _claimsPrincipalService.User?.FindFirst(ClaimConst.Account)?.Value;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// AvatarUrl
|
||||||
|
/// </summary>
|
||||||
|
public static string AvatarUrl => (_claimsPrincipalService.User?.FindFirst(ClaimConst.AvatarUrl)?.Value);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 当前用户Id
|
/// 当前用户Id
|
||||||
/// </summary>
|
/// </summary>
|
||||||
33
src/Admin/ThingsGateway.DB/ThingsGateway.DB.csproj
Normal file
33
src/Admin/ThingsGateway.DB/ThingsGateway.DB.csproj
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
|
||||||
|
<Import Project="$(SolutionDir)Version.props" />
|
||||||
|
<Import Project="$(SolutionDir)PackNuget.props" />
|
||||||
|
|
||||||
|
<PropertyGroup>
|
||||||
|
<GenerateDocumentationFile>True</GenerateDocumentationFile>
|
||||||
|
</PropertyGroup>
|
||||||
|
<PropertyGroup>
|
||||||
|
<TargetFrameworks>net8.0;net9.0;</TargetFrameworks>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="BootstrapBlazor.TableExport" Version="9.2.5" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<None Include="..\README.md" Pack="true" PackagePath="\" />
|
||||||
|
<None Include="..\README.zh-CN.md" Pack="true" PackagePath="\" />
|
||||||
|
<None Remove="$(SolutionDir)..\README.md" Pack="false" PackagePath="\" />
|
||||||
|
<None Remove="$(SolutionDir)..\README.zh-CN.md" Pack="false" PackagePath="\" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<ProjectReference Include="..\ThingsGateway.Razor\ThingsGateway.Razor.csproj" />
|
||||||
|
<ProjectReference Include="..\ThingsGateway.SqlSugar\ThingsGateway.SqlSugar.csproj" />
|
||||||
|
<!--<PackageReference Include="SqlSugarCore" Version="5.1.4.195" />-->
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
</Project>
|
||||||
@@ -471,7 +471,7 @@ public static class App
|
|||||||
IEnumerable<string> pathOfExternalAssemblies = Array.Empty<string>();
|
IEnumerable<string> pathOfExternalAssemblies = Array.Empty<string>();
|
||||||
|
|
||||||
// 加载 appsettings.json 配置的外部程序集
|
// 加载 appsettings.json 配置的外部程序集
|
||||||
if (Settings.ExternalAssemblies != null && Settings.ExternalAssemblies.Length > 0)
|
if (Settings.ExternalAssemblies?.Length > 0)
|
||||||
{
|
{
|
||||||
var externalDlls = new List<string>();
|
var externalDlls = new List<string>();
|
||||||
foreach (var item in Settings.ExternalAssemblies)
|
foreach (var item in Settings.ExternalAssemblies)
|
||||||
@@ -552,7 +552,7 @@ public static class App
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 处理排除的程序集
|
// 处理排除的程序集
|
||||||
if (Settings.ExcludeAssemblies != null && Settings.ExcludeAssemblies.Length > 0)
|
if (Settings.ExcludeAssemblies?.Length > 0)
|
||||||
{
|
{
|
||||||
scanAssemblies = scanAssemblies.Where(ass => !Settings.ExcludeAssemblies.Contains(ass.GetName().Name, StringComparer.OrdinalIgnoreCase));
|
scanAssemblies = scanAssemblies.Where(ass => !Settings.ExcludeAssemblies.Contains(ass.GetName().Name, StringComparer.OrdinalIgnoreCase));
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -455,7 +455,7 @@ public static class ObjectExtensions
|
|||||||
foreach (var property in propertys)
|
foreach (var property in propertys)
|
||||||
{
|
{
|
||||||
var p = oldType.GetProperty(property.Name);
|
var p = oldType.GetProperty(property.Name);
|
||||||
if (property.CanWrite && p != null && p.CanRead)
|
if (property.CanWrite && p?.CanRead == true)
|
||||||
{
|
{
|
||||||
property.SetValue(o, ChangeType(p.GetValue(obj, null), property.PropertyType), null);
|
property.SetValue(o, ChangeType(p.GetValue(obj, null), property.PropertyType), null);
|
||||||
}
|
}
|
||||||
@@ -647,7 +647,7 @@ public static class ObjectExtensions
|
|||||||
/// <returns><see cref="bool"/> 实例,true 表示空集合,false 表示非空集合</returns>
|
/// <returns><see cref="bool"/> 实例,true 表示空集合,false 表示非空集合</returns>
|
||||||
internal static bool IsEmpty<T>(this IEnumerable<T> collection)
|
internal static bool IsEmpty<T>(this IEnumerable<T> collection)
|
||||||
{
|
{
|
||||||
return collection == null || !collection.Any();
|
return collection?.Any() != true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -54,8 +54,7 @@ public class FromConvertBinderProvider : IModelBinderProvider
|
|||||||
|
|
||||||
// 判断是否定义 [FromConvert] 特性
|
// 判断是否定义 [FromConvert] 特性
|
||||||
if (context.Metadata is DefaultModelMetadata actMetadata
|
if (context.Metadata is DefaultModelMetadata actMetadata
|
||||||
&& actMetadata.Attributes.ParameterAttributes != null
|
&& actMetadata.Attributes.ParameterAttributes?.Count > 0
|
||||||
&& actMetadata.Attributes.ParameterAttributes.Count > 0
|
|
||||||
&& actMetadata.Attributes.ParameterAttributes.Any(u => u.GetType() == typeof(FromConvertAttribute)))
|
&& actMetadata.Attributes.ParameterAttributes.Any(u => u.GetType() == typeof(FromConvertAttribute)))
|
||||||
{
|
{
|
||||||
return new FromConvertBinder(_modelBinderConverts);
|
return new FromConvertBinder(_modelBinderConverts);
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ public sealed class AppAuthorizeAttribute : AuthorizeAttribute
|
|||||||
/// <param name="policies">多个策略</param>
|
/// <param name="policies">多个策略</param>
|
||||||
public AppAuthorizeAttribute(params string[] policies)
|
public AppAuthorizeAttribute(params string[] policies)
|
||||||
{
|
{
|
||||||
if (policies != null && policies.Length > 0) Policies = policies;
|
if (policies?.Length > 0) Policies = policies;
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ public sealed class DependsOnAttribute : Attribute
|
|||||||
var components = new List<Type>();
|
var components = new List<Type>();
|
||||||
|
|
||||||
// 遍历所有依赖组件
|
// 遍历所有依赖组件
|
||||||
if (dependComponents != null && dependComponents.Length > 0)
|
if (dependComponents?.Length > 0)
|
||||||
{
|
{
|
||||||
foreach (var component in dependComponents)
|
foreach (var component in dependComponents)
|
||||||
{
|
{
|
||||||
@@ -102,7 +102,7 @@ public sealed class DependsOnAttribute : Attribute
|
|||||||
var components = new List<Type>();
|
var components = new List<Type>();
|
||||||
|
|
||||||
// 遍历所有依赖组件
|
// 遍历所有依赖组件
|
||||||
if (value != null && value.Length > 0)
|
if (value?.Length > 0)
|
||||||
{
|
{
|
||||||
foreach (var component in value)
|
foreach (var component in value)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -65,7 +65,7 @@ internal static class Penetrates
|
|||||||
IEnumerable<string> exposedHeaders = corsAccessorSettings.FixedClientToken == true
|
IEnumerable<string> exposedHeaders = corsAccessorSettings.FixedClientToken == true
|
||||||
? _defaultExposedHeaders
|
? _defaultExposedHeaders
|
||||||
: Array.Empty<string>();
|
: Array.Empty<string>();
|
||||||
if (corsAccessorSettings.WithExposedHeaders != null && corsAccessorSettings.WithExposedHeaders.Length > 0)
|
if (corsAccessorSettings.WithExposedHeaders?.Length > 0)
|
||||||
{
|
{
|
||||||
exposedHeaders = exposedHeaders.Concat(corsAccessorSettings.WithExposedHeaders).Distinct(StringComparer.OrdinalIgnoreCase);
|
exposedHeaders = exposedHeaders.Concat(corsAccessorSettings.WithExposedHeaders).Distinct(StringComparer.OrdinalIgnoreCase);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ namespace ThingsGateway.DataEncryption;
|
|||||||
/// AES 加解密
|
/// AES 加解密
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SuppressSniffer]
|
[SuppressSniffer]
|
||||||
public class AESEncryption
|
public static class AESEncryption
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 加密
|
/// 加密
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ namespace ThingsGateway.DataEncryption;
|
|||||||
/// DES 加解密
|
/// DES 加解密
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SuppressSniffer]
|
[SuppressSniffer]
|
||||||
public class DESEncryption
|
public static class DESEncryption
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 加密
|
/// 加密
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ namespace ThingsGateway.DataEncryption;
|
|||||||
/// KSort 加密(数据签名)
|
/// KSort 加密(数据签名)
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SuppressSniffer]
|
[SuppressSniffer]
|
||||||
public class KSortEncryption
|
public static class KSortEncryption
|
||||||
{
|
{
|
||||||
private static DateTime _timeStampStartTime = new(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
|
private static DateTime _timeStampStartTime = new(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
|
||||||
|
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ namespace ThingsGateway.DataEncryption;
|
|||||||
/// PBKDF2 加密
|
/// PBKDF2 加密
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SuppressSniffer]
|
[SuppressSniffer]
|
||||||
public class PBKDF2Encryption
|
public static class PBKDF2Encryption
|
||||||
{
|
{
|
||||||
private const string SaltHashSeparator = ":";
|
private const string SaltHashSeparator = ":";
|
||||||
|
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ namespace ThingsGateway.DataEncryption;
|
|||||||
/// SHA1 加密
|
/// SHA1 加密
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SuppressSniffer]
|
[SuppressSniffer]
|
||||||
public class SHA1Encryption
|
public static class SHA1Encryption
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// SHA1 加密
|
/// SHA1 加密
|
||||||
|
|||||||
@@ -18,6 +18,7 @@ namespace System.ComponentModel.DataAnnotations;
|
|||||||
/// 数据类型验证特性
|
/// 数据类型验证特性
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SuppressSniffer]
|
[SuppressSniffer]
|
||||||
|
[AttributeUsage(AttributeTargets.All, AllowMultiple = false)]
|
||||||
public sealed class DataValidationAttribute : ValidationAttribute
|
public sealed class DataValidationAttribute : ValidationAttribute
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
@@ -215,7 +215,7 @@ public static class DependencyInjectionServiceCollectionExtensions
|
|||||||
private static void AddDispatchProxy(IServiceCollection services, Type dependencyType, Type type, Type proxyType, Type inter, bool hasTarget = true)
|
private static void AddDispatchProxy(IServiceCollection services, Type dependencyType, Type type, Type proxyType, Type inter, bool hasTarget = true)
|
||||||
{
|
{
|
||||||
proxyType ??= GlobalServiceProxyType;
|
proxyType ??= GlobalServiceProxyType;
|
||||||
if (proxyType == null || (type != null && type.IsDefined(typeof(SuppressProxyAttribute), true))) return;
|
if (proxyType == null || (type?.IsDefined(typeof(SuppressProxyAttribute), true) == true)) return;
|
||||||
|
|
||||||
var lifetime = TryGetServiceLifetime(dependencyType);
|
var lifetime = TryGetServiceLifetime(dependencyType);
|
||||||
|
|
||||||
|
|||||||
@@ -220,8 +220,7 @@ internal sealed class DynamicApiControllerApplicationModelConvention : IApplicat
|
|||||||
// 解决 Gitee 该 Issue:https://gitee.com/dotnetchina/Furion/issues/I59B74
|
// 解决 Gitee 该 Issue:https://gitee.com/dotnetchina/Furion/issues/I59B74
|
||||||
if (CheckIsForceWithDefaultRoute(controllerApiDescriptionSettings)
|
if (CheckIsForceWithDefaultRoute(controllerApiDescriptionSettings)
|
||||||
&& !string.IsNullOrWhiteSpace(_dynamicApiControllerSettings.DefaultRoutePrefix)
|
&& !string.IsNullOrWhiteSpace(_dynamicApiControllerSettings.DefaultRoutePrefix)
|
||||||
&& controller.Selectors[0] != null
|
&& controller.Selectors[0]?.AttributeRouteModel != null
|
||||||
&& controller.Selectors[0].AttributeRouteModel != null
|
|
||||||
&& !ForceWithDefaultPrefixRouteControllerTypes.Contains(controller.ControllerType))
|
&& !ForceWithDefaultPrefixRouteControllerTypes.Contains(controller.ControllerType))
|
||||||
{
|
{
|
||||||
// 读取模块
|
// 读取模块
|
||||||
|
|||||||
@@ -126,7 +126,7 @@ public static class DynamicApiControllerServiceCollectionExtensions
|
|||||||
{
|
{
|
||||||
var partManager = mvcBuilder.PartManager;
|
var partManager = mvcBuilder.PartManager;
|
||||||
// 载入程序集部件
|
// 载入程序集部件
|
||||||
if (partManager != null && assemblies != null && assemblies.Any())
|
if (partManager != null && assemblies?.Any() == true)
|
||||||
{
|
{
|
||||||
foreach (var assembly in assemblies)
|
foreach (var assembly in assemblies)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -48,7 +48,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
|||||||
/// <param name="assemblies">程序集</param>
|
/// <param name="assemblies">程序集</param>
|
||||||
public void AddAssemblies(params Assembly[] assemblies)
|
public void AddAssemblies(params Assembly[] assemblies)
|
||||||
{
|
{
|
||||||
if (assemblies != null && assemblies.Length > 0)
|
if (assemblies?.Length > 0)
|
||||||
{
|
{
|
||||||
foreach (var assembly in assemblies)
|
foreach (var assembly in assemblies)
|
||||||
{
|
{
|
||||||
@@ -63,7 +63,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
|||||||
/// <param name="assemblies">程序集</param>
|
/// <param name="assemblies">程序集</param>
|
||||||
public void AddAssembliesWithNotifyChanges(params Assembly[] assemblies)
|
public void AddAssembliesWithNotifyChanges(params Assembly[] assemblies)
|
||||||
{
|
{
|
||||||
if (assemblies != null && assemblies.Length > 0)
|
if (assemblies?.Length > 0)
|
||||||
{
|
{
|
||||||
AddAssemblies(assemblies);
|
AddAssemblies(assemblies);
|
||||||
NotifyChanges();
|
NotifyChanges();
|
||||||
@@ -76,7 +76,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
|||||||
/// <param name="assemblyNames">程序集名称</param>
|
/// <param name="assemblyNames">程序集名称</param>
|
||||||
public void RemoveAssemblies(params string[] assemblyNames)
|
public void RemoveAssemblies(params string[] assemblyNames)
|
||||||
{
|
{
|
||||||
if (assemblyNames != null && assemblyNames.Length > 0)
|
if (assemblyNames?.Length > 0)
|
||||||
{
|
{
|
||||||
foreach (var assemblyName in assemblyNames)
|
foreach (var assemblyName in assemblyNames)
|
||||||
{
|
{
|
||||||
@@ -93,7 +93,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
|||||||
/// <param name="assemblies">程序集</param>
|
/// <param name="assemblies">程序集</param>
|
||||||
public void RemoveAssemblies(params Assembly[] assemblies)
|
public void RemoveAssemblies(params Assembly[] assemblies)
|
||||||
{
|
{
|
||||||
if (assemblies != null && assemblies.Length > 0)
|
if (assemblies?.Length > 0)
|
||||||
{
|
{
|
||||||
RemoveAssemblies(assemblies.Select(ass => ass.GetName().Name).ToArray());
|
RemoveAssemblies(assemblies.Select(ass => ass.GetName().Name).ToArray());
|
||||||
}
|
}
|
||||||
@@ -105,7 +105,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
|||||||
/// <param name="assemblyNames">程序集名称</param>
|
/// <param name="assemblyNames">程序集名称</param>
|
||||||
public void RemoveAssembliesWithNotifyChanges(params string[] assemblyNames)
|
public void RemoveAssembliesWithNotifyChanges(params string[] assemblyNames)
|
||||||
{
|
{
|
||||||
if (assemblyNames != null && assemblyNames.Length > 0)
|
if (assemblyNames?.Length > 0)
|
||||||
{
|
{
|
||||||
RemoveAssemblies(assemblyNames);
|
RemoveAssemblies(assemblyNames);
|
||||||
NotifyChanges();
|
NotifyChanges();
|
||||||
@@ -118,7 +118,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
|||||||
/// <param name="assemblies">程序集</param>
|
/// <param name="assemblies">程序集</param>
|
||||||
public void RemoveAssembliesWithNotifyChanges(params Assembly[] assemblies)
|
public void RemoveAssembliesWithNotifyChanges(params Assembly[] assemblies)
|
||||||
{
|
{
|
||||||
if (assemblies != null && assemblies.Length > 0)
|
if (assemblies?.Length > 0)
|
||||||
{
|
{
|
||||||
RemoveAssemblies(assemblies);
|
RemoveAssemblies(assemblies);
|
||||||
NotifyChanges();
|
NotifyChanges();
|
||||||
|
|||||||
@@ -49,6 +49,14 @@ public class AppFriendlyException : Exception
|
|||||||
ErrorCode = OriginErrorCode = errorCode;
|
ErrorCode = OriginErrorCode = errorCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public AppFriendlyException(string? message) : base(message)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
public AppFriendlyException(string? message, Exception? innerException) : base(message, innerException)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 错误码
|
/// 错误码
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|||||||
@@ -102,7 +102,7 @@ public sealed class Retry
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 如果填写了 exceptionTypes 且异常类型不在 exceptionTypes 之内,则终止重试
|
// 如果填写了 exceptionTypes 且异常类型不在 exceptionTypes 之内,则终止重试
|
||||||
if (exceptionTypes != null && exceptionTypes.Length > 0 && !exceptionTypes.Any(u => u.IsAssignableFrom(ex.GetType())))
|
if (exceptionTypes?.Length > 0 && !exceptionTypes.Any(u => u.IsAssignableFrom(ex.GetType())))
|
||||||
{
|
{
|
||||||
if (finalThrow)
|
if (finalThrow)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -604,7 +604,7 @@ public sealed class LoggingMonitorAttribute : Attribute, IAsyncActionFilter, IAs
|
|||||||
private string TrySerializeObject(object obj, LoggingMonitorMethod monitorMethod, out bool succeed)
|
private string TrySerializeObject(object obj, LoggingMonitorMethod monitorMethod, out bool succeed)
|
||||||
{
|
{
|
||||||
// 排除 IQueryable<> 泛型
|
// 排除 IQueryable<> 泛型
|
||||||
if (obj != null && obj.GetType().HasImplementedRawGeneric(typeof(IQueryable<>)))
|
if (obj?.GetType().HasImplementedRawGeneric(typeof(IQueryable<>)) == true)
|
||||||
{
|
{
|
||||||
succeed = true;
|
succeed = true;
|
||||||
return "{}";
|
return "{}";
|
||||||
@@ -961,8 +961,7 @@ public sealed class LoggingMonitorAttribute : Attribute, IAsyncActionFilter, IAs
|
|||||||
// token 信息
|
// token 信息
|
||||||
// 判断是否是授权访问
|
// 判断是否是授权访问
|
||||||
var isAuth = actionMethod.GetFoundAttribute<AllowAnonymousAttribute>(true) == null
|
var isAuth = actionMethod.GetFoundAttribute<AllowAnonymousAttribute>(true) == null
|
||||||
&& resultHttpContext.User != null
|
&& resultHttpContext.User?.Identity.IsAuthenticated == true;
|
||||||
&& resultHttpContext.User.Identity.IsAuthenticated;
|
|
||||||
// 获取响应头信息
|
// 获取响应头信息
|
||||||
var accessToken = resultHttpContext.Response.Headers["access-token"].ToString();
|
var accessToken = resultHttpContext.Response.Headers["access-token"].ToString();
|
||||||
var authorization = string.IsNullOrWhiteSpace(accessToken)
|
var authorization = string.IsNullOrWhiteSpace(accessToken)
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ public sealed partial class StringLoggingPart
|
|||||||
/// <param name="args"></param>
|
/// <param name="args"></param>
|
||||||
public StringLoggingPart SetArgs(params object[] args)
|
public StringLoggingPart SetArgs(params object[] args)
|
||||||
{
|
{
|
||||||
if (args != null && args.Length > 0) Args = args;
|
if (args?.Length > 0) Args = args;
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ public static class ObjectMapperServiceCollectionExtensions
|
|||||||
var config = TypeAdapterConfig.GlobalSettings;
|
var config = TypeAdapterConfig.GlobalSettings;
|
||||||
|
|
||||||
// 扫描所有继承 IRegister 接口的对象映射配置
|
// 扫描所有继承 IRegister 接口的对象映射配置
|
||||||
if (assemblies != null && assemblies.Length > 0) config.Scan(assemblies);
|
if (assemblies?.Length > 0) config.Scan(assemblies);
|
||||||
|
|
||||||
// 配置支持依赖注入
|
// 配置支持依赖注入
|
||||||
services.AddSingleton(config);
|
services.AddSingleton(config);
|
||||||
|
|||||||
@@ -235,7 +235,7 @@ public sealed class SchedulerBuilder
|
|||||||
var schedulerBuilder = new SchedulerBuilder(jobBuilder);
|
var schedulerBuilder = new SchedulerBuilder(jobBuilder);
|
||||||
|
|
||||||
// 批量添加触发器
|
// 批量添加触发器
|
||||||
if (triggerBuilders != null && triggerBuilders.Length > 0)
|
if (triggerBuilders?.Length > 0)
|
||||||
{
|
{
|
||||||
schedulerBuilder.TriggerBuilders.AddRange(triggerBuilders);
|
schedulerBuilder.TriggerBuilders.AddRange(triggerBuilders);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -192,7 +192,7 @@ public static class ScheduleExtensions
|
|||||||
var underScoreCasePropertyName = Penetrates.GetNaming(propertyName, NamingConventions.UnderScoreCase);
|
var underScoreCasePropertyName = Penetrates.GetNaming(propertyName, NamingConventions.UnderScoreCase);
|
||||||
|
|
||||||
// 处理忽略属性问题
|
// 处理忽略属性问题
|
||||||
if (ignorePropertyNames != null && ignorePropertyNames.Length > 0)
|
if (ignorePropertyNames?.Length > 0)
|
||||||
{
|
{
|
||||||
if (ignorePropertyNames.Contains(propertyName, StringComparer.OrdinalIgnoreCase)
|
if (ignorePropertyNames.Contains(propertyName, StringComparer.OrdinalIgnoreCase)
|
||||||
|| ignorePropertyNames.Contains(camelCasePropertyName, StringComparer.OrdinalIgnoreCase)
|
|| ignorePropertyNames.Contains(camelCasePropertyName, StringComparer.OrdinalIgnoreCase)
|
||||||
|
|||||||
@@ -327,7 +327,7 @@ internal sealed class ScheduleHostedService : BackgroundService
|
|||||||
};
|
};
|
||||||
|
|
||||||
// 是否定义 FallbackAsync 方法
|
// 是否定义 FallbackAsync 方法
|
||||||
var isDefinedFallbackAsyncMethod = jobHandler != null && jobHandler.GetType().GetMethod(nameof(IJob.FallbackAsync)
|
var isDefinedFallbackAsyncMethod = jobHandler?.GetType().GetMethod(nameof(IJob.FallbackAsync)
|
||||||
, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance | BindingFlags.DeclaredOnly
|
, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance | BindingFlags.DeclaredOnly
|
||||||
, null
|
, null
|
||||||
, new[] { typeof(JobExecutedContext), typeof(CancellationToken) }
|
, new[] { typeof(JobExecutedContext), typeof(CancellationToken) }
|
||||||
|
|||||||
@@ -101,7 +101,7 @@ public class HttpJob : IJob
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 添加请求头
|
// 添加请求头
|
||||||
if (httpJobMessage.Headers != null && httpJobMessage.Headers.Count > 0)
|
if (httpJobMessage.Headers?.Count > 0)
|
||||||
{
|
{
|
||||||
foreach (var (name, value) in httpJobMessage.Headers)
|
foreach (var (name, value) in httpJobMessage.Headers)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -711,7 +711,7 @@ public static class SpecificationDocumentBuilder
|
|||||||
.Union(
|
.Union(
|
||||||
actions.SelectMany(u => GetActionGroups(u))
|
actions.SelectMany(u => GetActionGroups(u))
|
||||||
)
|
)
|
||||||
.Where(u => u != null && u.Visible)
|
.Where(u => u?.Visible == true)
|
||||||
// 分组后取最大排序
|
// 分组后取最大排序
|
||||||
.GroupBy(u => u.Group)
|
.GroupBy(u => u.Group)
|
||||||
.Select(u => new GroupExtraInfo
|
.Select(u => new GroupExtraInfo
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ public static class TP
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 添加项
|
// 添加项
|
||||||
if (items != null && items.Length > 0)
|
if (items?.Length > 0)
|
||||||
{
|
{
|
||||||
var propMaxLength = items.Where(u => _lazyRegex.Value.IsMatch(u))
|
var propMaxLength = items.Where(u => _lazyRegex.Value.IsMatch(u))
|
||||||
.DefaultIfEmpty(string.Empty)
|
.DefaultIfEmpty(string.Empty)
|
||||||
|
|||||||
@@ -39,7 +39,7 @@
|
|||||||
<PackageReference Include="System.Text.RegularExpressions" Version="4.3.1" />
|
<PackageReference Include="System.Text.RegularExpressions" Version="4.3.1" />
|
||||||
<PackageReference Include="Mapster" Version="7.4.0" />
|
<PackageReference Include="Mapster" Version="7.4.0" />
|
||||||
<PackageReference Include="MiniProfiler.AspNetCore.Mvc" Version="4.5.4" />
|
<PackageReference Include="MiniProfiler.AspNetCore.Mvc" Version="4.5.4" />
|
||||||
<PackageReference Include="Swashbuckle.AspNetCore" Version="8.1.2" />
|
<PackageReference Include="Swashbuckle.AspNetCore" Version="8.1.4" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
<ItemGroup Condition=" '$(TargetFramework)' == 'net8.0' ">
|
<ItemGroup Condition=" '$(TargetFramework)' == 'net8.0' ">
|
||||||
|
|||||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user