Compare commits
16 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
f14d27129e | ||
![]() |
5b04f02fbe | ||
![]() |
227080e332 | ||
![]() |
1e87482a49 | ||
![]() |
054d31c3ea | ||
![]() |
3a068a7b03 | ||
![]() |
b12e923c99 | ||
![]() |
ab33eed8d3 | ||
![]() |
d930a9a8eb | ||
![]() |
af381fce12 | ||
![]() |
b64ac0539e | ||
![]() |
541c60b363 | ||
![]() |
824e95f7cb | ||
![]() |
38f7850196 | ||
![]() |
bef9de88e2 | ||
![]() |
48cd5e7c7f |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -365,4 +365,5 @@ FodyWeavers.xsd
|
||||
/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_event = false:silent
|
||||
|
||||
|
||||
dotnet_diagnostic.CA2208.severity = none
|
||||
dotnet_diagnostic.CA2008.severity = none
|
||||
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_diagnostic.RCS1146.severity = warning
|
||||
dotnet_diagnostic.RCS1059.severity = none
|
||||
dotnet_diagnostic.RCS1138.severity = suggestion
|
||||
|
||||
dotnet_code_quality.CA1822.api_surface = private, internal
|
@@ -13,14 +13,16 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// <summary>
|
||||
/// 需要角色授权权限
|
||||
/// </summary>
|
||||
[AttributeUsage(AttributeTargets.Class)]
|
||||
[AttributeUsage(AttributeTargets.Class, AllowMultiple = false)]
|
||||
public sealed class RolePermissionAttribute : Attribute
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 忽略角色授权权限
|
||||
/// </summary>
|
||||
[AttributeUsage(AttributeTargets.Class | AttributeTargets.Method, AllowMultiple = false)]
|
||||
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;
|
||||
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class CacheConst
|
||||
public static class CacheConst
|
||||
{
|
||||
/// <summary>
|
||||
/// Token表缓存Key
|
||||
|
@@ -13,7 +13,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// <summary>
|
||||
/// 通讯器常量
|
||||
/// </summary>
|
||||
public class HubConst
|
||||
public static class HubConst
|
||||
{
|
||||
/// <summary>
|
||||
/// 系统HubUrl
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// 资源表常量
|
||||
/// </summary>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class ResourceConst
|
||||
public static class ResourceConst
|
||||
{
|
||||
/// <summary>
|
||||
/// 系统内置编码
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// 角色常量
|
||||
/// </summary>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class RoleConst
|
||||
public static class RoleConst
|
||||
{
|
||||
/// <summary>
|
||||
/// api角色
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// SqlSugar系统常量
|
||||
/// </summary>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class SqlSugarConst
|
||||
public static class SqlSugarConst
|
||||
{
|
||||
/// <summary>
|
||||
/// DB_Admin
|
||||
|
@@ -8,6 +8,7 @@
|
||||
// QQ群:605534569
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
using Microsoft.AspNetCore.Authentication;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
|
||||
@@ -27,14 +28,31 @@ public class AuthController : ControllerBase
|
||||
|
||||
[HttpPost("login")]
|
||||
[AllowAnonymous]
|
||||
[LoginLog]
|
||||
public Task<LoginOutput> LoginAsync([FromBody] LoginInput 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")]
|
||||
[Authorize]
|
||||
[IgnoreRolePermission]
|
||||
[LogoutLog]
|
||||
public Task LogoutAsync()
|
||||
{
|
||||
return _authService.LoginOutAsync();
|
||||
|
@@ -1,14 +1,4 @@
|
||||
// ------------------------------------------------------------------------
|
||||
// 版权信息
|
||||
// 版权归百小僧及百签科技(广东)有限公司所有。
|
||||
// 所有权利保留。
|
||||
// 官方网站:https://baiqian.com
|
||||
//
|
||||
// 许可证信息
|
||||
// 项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。
|
||||
// 许可证的完整文本可以在源代码树根目录中的 LICENSE-APACHE 和 LICENSE-MIT 文件中找到。
|
||||
// ------------------------------------------------------------------------
|
||||
|
||||
|
||||
using ThingsGateway.DependencyInjection;
|
||||
|
||||
namespace System;
|
||||
|
@@ -8,6 +8,8 @@
|
||||
// QQ群:605534569
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
using System.Reflection;
|
||||
|
||||
namespace ThingsGateway.Admin.Application;
|
||||
|
||||
public class RequestAuditData
|
||||
@@ -94,5 +96,6 @@ public class RequestAuditData
|
||||
/// 验证错误信息
|
||||
/// </summary>
|
||||
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];
|
||||
//获取特性
|
||||
|
||||
|
||||
logData.CateGory = desc.Value;//传操作名称
|
||||
logData.Operation = desc.Value;//传操作名称
|
||||
logData.Client = client;
|
||||
logData.Path = httpContext.Request.Path.Value;//请求地址
|
||||
logData.Method = httpContext.Request.Method;//请求方法
|
||||
logData.MethodInfo = actionMethod;//请求方法
|
||||
|
||||
logData.ControllerName = controllerActionDescriptor.ControllerName;
|
||||
logData.ActionName = controllerActionDescriptor.ActionName;
|
||||
|
@@ -1,14 +1,4 @@
|
||||
// ------------------------------------------------------------------------
|
||||
// 版权信息
|
||||
// 版权归百小僧及百签科技(广东)有限公司所有。
|
||||
// 所有权利保留。
|
||||
// 官方网站:https://baiqian.com
|
||||
//
|
||||
// 许可证信息
|
||||
// 项目主要遵循 MIT 许可证和 Apache 许可证(版本 2.0)进行分发和使用。
|
||||
// 许可证的完整文本可以在源代码树根目录中的 LICENSE-APACHE 和 LICENSE-MIT 文件中找到。
|
||||
// ------------------------------------------------------------------------
|
||||
|
||||
|
||||
using ThingsGateway.DependencyInjection;
|
||||
|
||||
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 System.Collections.Concurrent;
|
||||
using System.Reflection;
|
||||
|
||||
using ThingsGateway.Extension;
|
||||
using ThingsGateway.FriendlyException;
|
||||
using ThingsGateway.Logging;
|
||||
using ThingsGateway.NewLife.Json.Extension;
|
||||
using ThingsGateway.Razor;
|
||||
|
||||
namespace ThingsGateway.Admin.Application;
|
||||
|
||||
@@ -51,13 +53,18 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
||||
var client = requestAuditData.Client;//获取客户端信息
|
||||
var path = requestAuditData.Path;//获取操作名称
|
||||
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)
|
||||
{
|
||||
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
|
||||
{
|
||||
@@ -151,17 +158,20 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
||||
/// <param name="path"></param>
|
||||
/// <param name="requestAuditData">requestAuditData</param>
|
||||
/// <param name="userAgent">客户端信息</param>
|
||||
/// <param name="logCateGoryEnum">logCateGory</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
|
||||
var opAccount = "";//用户账号
|
||||
if (path == "/api/auth/login")
|
||||
if (logCateGoryEnum == LogCateGoryEnum.Login)
|
||||
{
|
||||
//如果是登录,用户信息就从返回值里拿
|
||||
dynamic userInfo = requestAuditData.ReturnInformation;
|
||||
opAccount = userInfo.Data.Account;//赋值账号
|
||||
verificatId = userInfo.Data.VerificatId;
|
||||
if (requestAuditData.ReturnInformation is UnifyResult<LoginOutput> userInfo)
|
||||
{
|
||||
opAccount = userInfo.Data.Account;//赋值账号
|
||||
verificatId = userInfo.Data.VerificatId;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
@@ -173,7 +183,7 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
||||
var sysLogVisit = new SysOperateLog
|
||||
{
|
||||
Name = operation,
|
||||
Category = path == "/api/auth/login" ? LogCateGoryEnum.Login : LogCateGoryEnum.Logout,
|
||||
Category = logCateGoryEnum,
|
||||
ExeStatus = true,
|
||||
OpIp = requestAuditData.RemoteIPv4,
|
||||
OpBrowser = userAgent?.Browser,
|
||||
|
@@ -13,7 +13,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// <summary>
|
||||
/// 日志常量
|
||||
/// </summary>
|
||||
public class LoggingConst
|
||||
public static class LoggingConst
|
||||
{
|
||||
/// <summary>
|
||||
/// 分类
|
||||
|
@@ -87,7 +87,7 @@ public class BlazorAuthenticationHandler : AppAuthorizeHandler
|
||||
var roles = await _sysRoleService.GetRoleListByUserIdAsync(userId).ConfigureAwait(false);
|
||||
|
||||
//这里鉴别用户使能状态
|
||||
if (user == null || !user.Status)
|
||||
if (user?.Status != true)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
@@ -137,7 +137,7 @@ public class BlazorAuthenticationHandler : AppAuthorizeHandler
|
||||
else
|
||||
{
|
||||
//这里鉴别用户使能状态
|
||||
if (user == null || !user.Status)
|
||||
if (user?.Status != true)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
@@ -12,8 +12,6 @@ using Microsoft.AspNetCore.Authentication.Cookies;
|
||||
using Microsoft.AspNetCore.Http;
|
||||
using Microsoft.Extensions.Localization;
|
||||
|
||||
using SqlSugar;
|
||||
|
||||
using System.Security.Claims;
|
||||
|
||||
using ThingsGateway.DataEncryption;
|
||||
@@ -64,6 +62,10 @@ public class AuthService : IAuthService
|
||||
{
|
||||
throw Oops.Bah(appConfig.WebsitePolicy.CloseTip);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
string? password = input.Password;
|
||||
if (isCookie) //openApi登录不再需要解密
|
||||
{
|
||||
@@ -237,25 +239,20 @@ public class AuthService : IAuthService
|
||||
var logingEvent = new LoginEvent
|
||||
{
|
||||
Ip = _appService.RemoteIpAddress,
|
||||
Device = App.GetService<IAppService>().UserAgent?.Platform,
|
||||
Device = _appService.UserAgent?.Platform,
|
||||
Expire = expire,
|
||||
SysUser = sysUser,
|
||||
VerificatId = verificatId
|
||||
};
|
||||
await WriteTokenToCache(loginPolicy, logingEvent).ConfigureAwait(false);//写入verificat到cache
|
||||
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
|
||||
{
|
||||
VerificatId = verificatId,
|
||||
Account = sysUser.Account,
|
||||
Id = sysUser.Id,
|
||||
ModuleList = sysUser.ModuleList,
|
||||
AccessToken = accessToken,
|
||||
RefreshToken = refreshToken
|
||||
};
|
||||
|
@@ -334,7 +334,7 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
||||
flatList.Add(node);
|
||||
|
||||
// 如果当前节点有子节点,则递归处理每个子节点
|
||||
if (node.Children != null && node.Children.Count > 0)
|
||||
if (node.Children?.Count > 0)
|
||||
{
|
||||
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);//获取用户信息
|
||||
if (exist != null)
|
||||
{
|
||||
var isSuperAdmin = exist.Account == RoleConst.SuperAdmin;//判断是否有超管
|
||||
var isSuperAdmin = exist.Id == RoleConst.SuperAdminId;//判断是否有超管
|
||||
if (isSuperAdmin && !UserManager.SuperAdmin)
|
||||
throw Oops.Bah(Localizer["CanotEditAdminUser"]);
|
||||
|
||||
@@ -540,7 +540,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
||||
await CheckApiDataScopeAsync(sysUser.OrgId, sysUser.CreateUserId).ConfigureAwait(false);
|
||||
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)
|
||||
throw Oops.Bah(Localizer["CanotGrantAdmin"]);
|
||||
|
||||
@@ -660,7 +660,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
||||
public async Task<bool> DeleteUserAsync(IEnumerable<long> ids)
|
||||
{
|
||||
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)
|
||||
throw Oops.Bah(Localizer["CanotDeleteAdminUser"]);
|
||||
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);
|
||||
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);
|
||||
sysUser.ModuleList = modules.ToList();//模块列表赋值给用户
|
||||
|
@@ -47,7 +47,7 @@
|
||||
|
||||
<ItemGroup>
|
||||
<ProjectReference Include="..\ThingsGateway.Razor\ThingsGateway.Razor.csproj" />
|
||||
<ProjectReference Include="..\ThingsGateway.SqlSugar\ThingsGateway.SqlSugar.csproj" />
|
||||
<ProjectReference Include="..\ThingsGateway.DB\ThingsGateway.DB.csproj" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
|
@@ -13,7 +13,7 @@ using Microsoft.Extensions.DependencyInjection;
|
||||
namespace ThingsGateway.Admin.Application;
|
||||
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class ClearTokenUtil
|
||||
public static class ClearTokenUtil
|
||||
{
|
||||
private static IRelationService RelationService;
|
||||
private static ISysUserService SysUserService;
|
||||
|
@@ -13,7 +13,7 @@ using Microsoft.Extensions.DependencyInjection;
|
||||
namespace ThingsGateway.Admin.Application;
|
||||
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class NoticeUtil
|
||||
public static class NoticeUtil
|
||||
{
|
||||
private static INoticeService NoticeService;
|
||||
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
|
||||
/// <inheritdoc/>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class OpenApiUtil
|
||||
public static class OpenApiUtil
|
||||
{
|
||||
/// <summary>
|
||||
/// 构建树节点,传入的列表已经是树结构
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
|
||||
/// <inheritdoc/>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class OrgUtil
|
||||
public static class OrgUtil
|
||||
{
|
||||
/// <summary>
|
||||
/// 构造选择项,ID/TITLE
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
|
||||
/// <inheritdoc/>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class PositionUtil
|
||||
public static class PositionUtil
|
||||
{
|
||||
|
||||
/// <summary>
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
|
||||
/// <inheritdoc/>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class RoleUtil
|
||||
public static class RoleUtil
|
||||
{
|
||||
|
||||
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
|
||||
/// <inheritdoc/>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class UserUtil
|
||||
public static class UserUtil
|
||||
{
|
||||
|
||||
/// <summary>
|
||||
|
@@ -14,7 +14,7 @@ using ThingsGateway.Extension.Generic;
|
||||
|
||||
namespace ThingsGateway.Admin.Application;
|
||||
|
||||
public class VerificatInfoUtil
|
||||
public static class VerificatInfoUtil
|
||||
{
|
||||
private static IVerificatInfoService VerificatInfoService { get; set; }
|
||||
static VerificatInfoUtil()
|
||||
|
@@ -11,7 +11,7 @@
|
||||
namespace ThingsGateway.Admin.Razor;
|
||||
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class AdminOperConst
|
||||
public static class AdminOperConst
|
||||
{
|
||||
public const string Add = "新增";
|
||||
public const string Delete = "删除";
|
||||
|
@@ -40,6 +40,8 @@ public class BlazorAppContext
|
||||
/// </summary>
|
||||
public SysUser CurrentUser { get; private set; }
|
||||
|
||||
public string? Avatar => UserManager.AvatarUrl.IsNullOrEmpty() ? CurrentUser.Avatar : UserManager.AvatarUrl;
|
||||
|
||||
/// <summary>
|
||||
/// 用户个人菜单
|
||||
/// </summary>
|
||||
|
@@ -48,7 +48,7 @@ public partial class SysUserAvatarEdit : IDisposable
|
||||
|
||||
private async Task OnAvatarUpload(UploadFile file)
|
||||
{
|
||||
if (file != null && file.File != null)
|
||||
if (file?.File != null)
|
||||
{
|
||||
var format = file.File.ContentType;
|
||||
ReadAvatarToken ??= new CancellationTokenSource();
|
||||
|
@@ -38,7 +38,7 @@ public partial class UserCenterPage
|
||||
protected override async Task OnParametersSetAsync()
|
||||
{
|
||||
SysUser = AppContext.CurrentUser.Adapt<SysUser>();
|
||||
SysUser.Avatar = AppContext.CurrentUser.Avatar;
|
||||
SysUser.Avatar = AppContext.Avatar;
|
||||
WorkbenchInfo = (await UserCenterService.GetLoginWorkbenchAsync(SysUser.Id)).Adapt<WorkbenchInfo>();
|
||||
|
||||
await base.OnParametersSetAsync();
|
||||
|
@@ -48,7 +48,7 @@ public partial class UserInfoEditComponent
|
||||
|
||||
private async Task OnAvatarUpload(UploadFile file)
|
||||
{
|
||||
if (file != null && file.File != null)
|
||||
if (file?.File != null)
|
||||
{
|
||||
var format = file.File.ContentType;
|
||||
ReadAvatarToken ??= new CancellationTokenSource();
|
||||
|
@@ -16,7 +16,7 @@ namespace ThingsGateway.Admin.Razor;
|
||||
|
||||
/// <inheritdoc/>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class ResourceUtil
|
||||
public static class ResourceUtil
|
||||
{
|
||||
|
||||
/// <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.Extensions.Localization;
|
||||
|
||||
using ThingsGateway.Admin.Application;
|
||||
using ThingsGateway.Admin.Razor;
|
||||
using ThingsGateway.Extension;
|
||||
|
||||
|
@@ -13,8 +13,6 @@ using Microsoft.Extensions.Localization;
|
||||
|
||||
using System.Diagnostics.CodeAnalysis;
|
||||
|
||||
using ThingsGateway.Admin.Application;
|
||||
|
||||
namespace ThingsGateway.AdminServer;
|
||||
|
||||
public partial class AccessDenied
|
||||
|
@@ -20,11 +20,11 @@ using Microsoft.Extensions.Options;
|
||||
|
||||
using System.Diagnostics.CodeAnalysis;
|
||||
|
||||
using ThingsGateway.Admin.Application;
|
||||
using ThingsGateway.DataEncryption;
|
||||
using ThingsGateway.NewLife.Extension;
|
||||
using ThingsGateway.Razor;
|
||||
|
||||
|
||||
namespace ThingsGateway.AdminServer;
|
||||
|
||||
public partial class Login
|
||||
|
@@ -48,7 +48,7 @@
|
||||
<CultureChooser />
|
||||
</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>
|
||||
<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 ThingsGateway.Admin.Application;
|
||||
using ThingsGateway.Admin.Razor;
|
||||
using ThingsGateway.Razor;
|
||||
|
||||
@@ -27,38 +26,6 @@ public partial class MainLayout : IDisposable
|
||||
{
|
||||
[Inject]
|
||||
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 全局通知
|
||||
|
||||
|
@@ -25,7 +25,6 @@ using System.Text;
|
||||
using System.Text.Encodings.Web;
|
||||
using System.Text.Unicode;
|
||||
|
||||
using ThingsGateway.Admin.Application;
|
||||
using ThingsGateway.Admin.Razor;
|
||||
using ThingsGateway.Extension;
|
||||
using ThingsGateway.NewLife.Caching;
|
||||
@@ -369,12 +368,6 @@ public class Startup : AppStartup
|
||||
app.UseStaticFiles(new StaticFileOptions { ContentTypeProvider = provider });
|
||||
app.UseStaticFiles();
|
||||
|
||||
app.Use(async (context, next) =>
|
||||
{
|
||||
context.Response.Headers.Append("ThingsGateway", "ThingsGateway");
|
||||
await next().ConfigureAwait(false);
|
||||
});
|
||||
|
||||
|
||||
// 特定文件类型(文件后缀)处理
|
||||
var contentTypeProvider = GetFileExtensionContentTypeProvider();
|
||||
|
@@ -14,7 +14,7 @@ namespace ThingsGateway.Admin.Application;
|
||||
/// 授权用户常量
|
||||
/// </summary>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class ClaimConst
|
||||
public static class ClaimConst
|
||||
{
|
||||
/// <summary>
|
||||
/// 账号
|
||||
@@ -31,6 +31,11 @@ public class ClaimConst
|
||||
/// </summary>
|
||||
public const string UserId = "UserId";
|
||||
|
||||
/// <summary>
|
||||
/// AvatarUrl
|
||||
/// </summary>
|
||||
public const string AvatarUrl = "AvatarUrl";
|
||||
|
||||
/// <summary>
|
||||
/// 验证Id
|
||||
/// </summary>
|
@@ -225,7 +225,7 @@ public static class SqlSugarExtensions
|
||||
|
||||
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++)
|
||||
{
|
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>
|
||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||
public class SeedDataUtil
|
||||
public static class SeedDataUtil
|
||||
{
|
||||
/// <summary>
|
||||
/// 获取List列表
|
@@ -27,11 +27,17 @@ public static class UserManager
|
||||
/// </summary>
|
||||
public static bool SuperAdmin => (_claimsPrincipalService.User?.FindFirst(ClaimConst.SuperAdmin)?.Value).ToBoolean(false);
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 当前用户账号
|
||||
/// </summary>
|
||||
public static string UserAccount => _claimsPrincipalService.User?.FindFirst(ClaimConst.Account)?.Value;
|
||||
|
||||
/// <summary>
|
||||
/// AvatarUrl
|
||||
/// </summary>
|
||||
public static string AvatarUrl => (_claimsPrincipalService.User?.FindFirst(ClaimConst.AvatarUrl)?.Value);
|
||||
|
||||
/// <summary>
|
||||
/// 当前用户Id
|
||||
/// </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>();
|
||||
|
||||
// 加载 appsettings.json 配置的外部程序集
|
||||
if (Settings.ExternalAssemblies != null && Settings.ExternalAssemblies.Length > 0)
|
||||
if (Settings.ExternalAssemblies?.Length > 0)
|
||||
{
|
||||
var externalDlls = new List<string>();
|
||||
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));
|
||||
}
|
||||
|
@@ -455,7 +455,7 @@ public static class ObjectExtensions
|
||||
foreach (var property in propertys)
|
||||
{
|
||||
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);
|
||||
}
|
||||
@@ -647,7 +647,7 @@ public static class ObjectExtensions
|
||||
/// <returns><see cref="bool"/> 实例,true 表示空集合,false 表示非空集合</returns>
|
||||
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] 特性
|
||||
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)))
|
||||
{
|
||||
return new FromConvertBinder(_modelBinderConverts);
|
||||
|
@@ -25,7 +25,7 @@ public sealed class AppAuthorizeAttribute : AuthorizeAttribute
|
||||
/// <param name="policies">多个策略</param>
|
||||
public AppAuthorizeAttribute(params string[] policies)
|
||||
{
|
||||
if (policies != null && policies.Length > 0) Policies = policies;
|
||||
if (policies?.Length > 0) Policies = policies;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
|
@@ -47,7 +47,7 @@ public sealed class DependsOnAttribute : Attribute
|
||||
var components = new List<Type>();
|
||||
|
||||
// 遍历所有依赖组件
|
||||
if (dependComponents != null && dependComponents.Length > 0)
|
||||
if (dependComponents?.Length > 0)
|
||||
{
|
||||
foreach (var component in dependComponents)
|
||||
{
|
||||
@@ -102,7 +102,7 @@ public sealed class DependsOnAttribute : Attribute
|
||||
var components = new List<Type>();
|
||||
|
||||
// 遍历所有依赖组件
|
||||
if (value != null && value.Length > 0)
|
||||
if (value?.Length > 0)
|
||||
{
|
||||
foreach (var component in value)
|
||||
{
|
||||
|
@@ -65,7 +65,7 @@ internal static class Penetrates
|
||||
IEnumerable<string> exposedHeaders = corsAccessorSettings.FixedClientToken == true
|
||||
? _defaultExposedHeaders
|
||||
: Array.Empty<string>();
|
||||
if (corsAccessorSettings.WithExposedHeaders != null && corsAccessorSettings.WithExposedHeaders.Length > 0)
|
||||
if (corsAccessorSettings.WithExposedHeaders?.Length > 0)
|
||||
{
|
||||
exposedHeaders = exposedHeaders.Concat(corsAccessorSettings.WithExposedHeaders).Distinct(StringComparer.OrdinalIgnoreCase);
|
||||
}
|
||||
|
@@ -19,7 +19,7 @@ namespace ThingsGateway.DataEncryption;
|
||||
/// AES 加解密
|
||||
/// </summary>
|
||||
[SuppressSniffer]
|
||||
public class AESEncryption
|
||||
public static class AESEncryption
|
||||
{
|
||||
/// <summary>
|
||||
/// 加密
|
||||
|
@@ -20,7 +20,7 @@ namespace ThingsGateway.DataEncryption;
|
||||
/// DES 加解密
|
||||
/// </summary>
|
||||
[SuppressSniffer]
|
||||
public class DESEncryption
|
||||
public static class DESEncryption
|
||||
{
|
||||
/// <summary>
|
||||
/// 加密
|
||||
|
@@ -18,7 +18,7 @@ namespace ThingsGateway.DataEncryption;
|
||||
/// KSort 加密(数据签名)
|
||||
/// </summary>
|
||||
[SuppressSniffer]
|
||||
public class KSortEncryption
|
||||
public static class KSortEncryption
|
||||
{
|
||||
private static DateTime _timeStampStartTime = new(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
|
||||
|
||||
|
@@ -17,7 +17,7 @@ namespace ThingsGateway.DataEncryption;
|
||||
/// PBKDF2 加密
|
||||
/// </summary>
|
||||
[SuppressSniffer]
|
||||
public class PBKDF2Encryption
|
||||
public static class PBKDF2Encryption
|
||||
{
|
||||
private const string SaltHashSeparator = ":";
|
||||
|
||||
|
@@ -18,7 +18,7 @@ namespace ThingsGateway.DataEncryption;
|
||||
/// SHA1 加密
|
||||
/// </summary>
|
||||
[SuppressSniffer]
|
||||
public class SHA1Encryption
|
||||
public static class SHA1Encryption
|
||||
{
|
||||
/// <summary>
|
||||
/// SHA1 加密
|
||||
|
@@ -18,6 +18,7 @@ namespace System.ComponentModel.DataAnnotations;
|
||||
/// 数据类型验证特性
|
||||
/// </summary>
|
||||
[SuppressSniffer]
|
||||
[AttributeUsage(AttributeTargets.All, AllowMultiple = false)]
|
||||
public sealed class DataValidationAttribute : ValidationAttribute
|
||||
{
|
||||
/// <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)
|
||||
{
|
||||
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);
|
||||
|
||||
|
@@ -220,8 +220,7 @@ internal sealed class DynamicApiControllerApplicationModelConvention : IApplicat
|
||||
// 解决 Gitee 该 Issue:https://gitee.com/dotnetchina/Furion/issues/I59B74
|
||||
if (CheckIsForceWithDefaultRoute(controllerApiDescriptionSettings)
|
||||
&& !string.IsNullOrWhiteSpace(_dynamicApiControllerSettings.DefaultRoutePrefix)
|
||||
&& controller.Selectors[0] != null
|
||||
&& controller.Selectors[0].AttributeRouteModel != null
|
||||
&& controller.Selectors[0]?.AttributeRouteModel != null
|
||||
&& !ForceWithDefaultPrefixRouteControllerTypes.Contains(controller.ControllerType))
|
||||
{
|
||||
// 读取模块
|
||||
|
@@ -126,7 +126,7 @@ public static class DynamicApiControllerServiceCollectionExtensions
|
||||
{
|
||||
var partManager = mvcBuilder.PartManager;
|
||||
// 载入程序集部件
|
||||
if (partManager != null && assemblies != null && assemblies.Any())
|
||||
if (partManager != null && assemblies?.Any() == true)
|
||||
{
|
||||
foreach (var assembly in assemblies)
|
||||
{
|
||||
|
@@ -48,7 +48,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
||||
/// <param name="assemblies">程序集</param>
|
||||
public void AddAssemblies(params Assembly[] assemblies)
|
||||
{
|
||||
if (assemblies != null && assemblies.Length > 0)
|
||||
if (assemblies?.Length > 0)
|
||||
{
|
||||
foreach (var assembly in assemblies)
|
||||
{
|
||||
@@ -63,7 +63,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
||||
/// <param name="assemblies">程序集</param>
|
||||
public void AddAssembliesWithNotifyChanges(params Assembly[] assemblies)
|
||||
{
|
||||
if (assemblies != null && assemblies.Length > 0)
|
||||
if (assemblies?.Length > 0)
|
||||
{
|
||||
AddAssemblies(assemblies);
|
||||
NotifyChanges();
|
||||
@@ -76,7 +76,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
||||
/// <param name="assemblyNames">程序集名称</param>
|
||||
public void RemoveAssemblies(params string[] assemblyNames)
|
||||
{
|
||||
if (assemblyNames != null && assemblyNames.Length > 0)
|
||||
if (assemblyNames?.Length > 0)
|
||||
{
|
||||
foreach (var assemblyName in assemblyNames)
|
||||
{
|
||||
@@ -93,7 +93,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
||||
/// <param name="assemblies">程序集</param>
|
||||
public void RemoveAssemblies(params Assembly[] assemblies)
|
||||
{
|
||||
if (assemblies != null && assemblies.Length > 0)
|
||||
if (assemblies?.Length > 0)
|
||||
{
|
||||
RemoveAssemblies(assemblies.Select(ass => ass.GetName().Name).ToArray());
|
||||
}
|
||||
@@ -105,7 +105,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
||||
/// <param name="assemblyNames">程序集名称</param>
|
||||
public void RemoveAssembliesWithNotifyChanges(params string[] assemblyNames)
|
||||
{
|
||||
if (assemblyNames != null && assemblyNames.Length > 0)
|
||||
if (assemblyNames?.Length > 0)
|
||||
{
|
||||
RemoveAssemblies(assemblyNames);
|
||||
NotifyChanges();
|
||||
@@ -118,7 +118,7 @@ internal sealed class DynamicApiRuntimeChangeProvider : IDynamicApiRuntimeChange
|
||||
/// <param name="assemblies">程序集</param>
|
||||
public void RemoveAssembliesWithNotifyChanges(params Assembly[] assemblies)
|
||||
{
|
||||
if (assemblies != null && assemblies.Length > 0)
|
||||
if (assemblies?.Length > 0)
|
||||
{
|
||||
RemoveAssemblies(assemblies);
|
||||
NotifyChanges();
|
||||
|
@@ -49,6 +49,14 @@ public class AppFriendlyException : Exception
|
||||
ErrorCode = OriginErrorCode = errorCode;
|
||||
}
|
||||
|
||||
public AppFriendlyException(string? message) : base(message)
|
||||
{
|
||||
}
|
||||
|
||||
public AppFriendlyException(string? message, Exception? innerException) : base(message, innerException)
|
||||
{
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 错误码
|
||||
/// </summary>
|
||||
|
@@ -102,7 +102,7 @@ public sealed class Retry
|
||||
}
|
||||
|
||||
// 如果填写了 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)
|
||||
{
|
||||
|
@@ -604,7 +604,7 @@ public sealed class LoggingMonitorAttribute : Attribute, IAsyncActionFilter, IAs
|
||||
private string TrySerializeObject(object obj, LoggingMonitorMethod monitorMethod, out bool succeed)
|
||||
{
|
||||
// 排除 IQueryable<> 泛型
|
||||
if (obj != null && obj.GetType().HasImplementedRawGeneric(typeof(IQueryable<>)))
|
||||
if (obj?.GetType().HasImplementedRawGeneric(typeof(IQueryable<>)) == true)
|
||||
{
|
||||
succeed = true;
|
||||
return "{}";
|
||||
@@ -961,8 +961,7 @@ public sealed class LoggingMonitorAttribute : Attribute, IAsyncActionFilter, IAs
|
||||
// token 信息
|
||||
// 判断是否是授权访问
|
||||
var isAuth = actionMethod.GetFoundAttribute<AllowAnonymousAttribute>(true) == null
|
||||
&& resultHttpContext.User != null
|
||||
&& resultHttpContext.User.Identity.IsAuthenticated;
|
||||
&& resultHttpContext.User?.Identity.IsAuthenticated == true;
|
||||
// 获取响应头信息
|
||||
var accessToken = resultHttpContext.Response.Headers["access-token"].ToString();
|
||||
var authorization = string.IsNullOrWhiteSpace(accessToken)
|
||||
|
@@ -47,7 +47,7 @@ public sealed partial class StringLoggingPart
|
||||
/// <param name="args"></param>
|
||||
public StringLoggingPart SetArgs(params object[] args)
|
||||
{
|
||||
if (args != null && args.Length > 0) Args = args;
|
||||
if (args?.Length > 0) Args = args;
|
||||
return this;
|
||||
}
|
||||
|
||||
|
@@ -47,7 +47,7 @@ public static class ObjectMapperServiceCollectionExtensions
|
||||
var config = TypeAdapterConfig.GlobalSettings;
|
||||
|
||||
// 扫描所有继承 IRegister 接口的对象映射配置
|
||||
if (assemblies != null && assemblies.Length > 0) config.Scan(assemblies);
|
||||
if (assemblies?.Length > 0) config.Scan(assemblies);
|
||||
|
||||
// 配置支持依赖注入
|
||||
services.AddSingleton(config);
|
||||
|
@@ -235,7 +235,7 @@ public sealed class SchedulerBuilder
|
||||
var schedulerBuilder = new SchedulerBuilder(jobBuilder);
|
||||
|
||||
// 批量添加触发器
|
||||
if (triggerBuilders != null && triggerBuilders.Length > 0)
|
||||
if (triggerBuilders?.Length > 0)
|
||||
{
|
||||
schedulerBuilder.TriggerBuilders.AddRange(triggerBuilders);
|
||||
}
|
||||
|
@@ -192,7 +192,7 @@ public static class ScheduleExtensions
|
||||
var underScoreCasePropertyName = Penetrates.GetNaming(propertyName, NamingConventions.UnderScoreCase);
|
||||
|
||||
// 处理忽略属性问题
|
||||
if (ignorePropertyNames != null && ignorePropertyNames.Length > 0)
|
||||
if (ignorePropertyNames?.Length > 0)
|
||||
{
|
||||
if (ignorePropertyNames.Contains(propertyName, StringComparer.OrdinalIgnoreCase)
|
||||
|| ignorePropertyNames.Contains(camelCasePropertyName, StringComparer.OrdinalIgnoreCase)
|
||||
|
@@ -327,7 +327,7 @@ internal sealed class ScheduleHostedService : BackgroundService
|
||||
};
|
||||
|
||||
// 是否定义 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
|
||||
, null
|
||||
, 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)
|
||||
{
|
||||
|
@@ -711,7 +711,7 @@ public static class SpecificationDocumentBuilder
|
||||
.Union(
|
||||
actions.SelectMany(u => GetActionGroups(u))
|
||||
)
|
||||
.Where(u => u != null && u.Visible)
|
||||
.Where(u => u?.Visible == true)
|
||||
// 分组后取最大排序
|
||||
.GroupBy(u => u.Group)
|
||||
.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))
|
||||
.DefaultIfEmpty(string.Empty)
|
||||
|
@@ -39,7 +39,7 @@
|
||||
<PackageReference Include="System.Text.RegularExpressions" Version="4.3.1" />
|
||||
<PackageReference Include="Mapster" Version="7.4.0" />
|
||||
<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 Condition=" '$(TargetFramework)' == 'net8.0' ">
|
||||
|
@@ -343,7 +343,7 @@ public partial class Crontab
|
||||
|
||||
// 如果存在且唯一,则进入下一轮判断
|
||||
// 接下来的判断是处理 SUN + L 的情况,如 SUNL == 0L == SUNDAY,它们都是合法的 Cron 值
|
||||
if (replaceVal != null && replaceVal.Count == 1)
|
||||
if (replaceVal?.Count == 1)
|
||||
{
|
||||
var missingParser = "";
|
||||
|
||||
|
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user