Compare commits
	
		
			19 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 
						 | 
					1e87482a49 | ||
| 
						 | 
					054d31c3ea | ||
| 
						 | 
					3a068a7b03 | ||
| 
						 | 
					b12e923c99 | ||
| 
						 | 
					ab33eed8d3 | ||
| 
						 | 
					d930a9a8eb | ||
| 
						 | 
					af381fce12 | ||
| 
						 | 
					b64ac0539e | ||
| 
						 | 
					541c60b363 | ||
| 
						 | 
					824e95f7cb | ||
| 
						 | 
					38f7850196 | ||
| 
						 | 
					bef9de88e2 | ||
| 
						 | 
					48cd5e7c7f | ||
| 
						 | 
					3b44fda51c | ||
| 
						 | 
					dbfc9a5bb4 | ||
| 
						 | 
					1b758aa41a | ||
| 
						 | 
					43bdc70899 | ||
| 
						 | 
					fadda000a6 | ||
| 
						 | 
					45a8c91a5a | 
							
								
								
									
										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;
 | 
			
		||||
            }
 | 
			
		||||
 
 | 
			
		||||
@@ -20,9 +20,11 @@ namespace ThingsGateway.Admin.Application;
 | 
			
		||||
public class AppService : IAppService
 | 
			
		||||
{
 | 
			
		||||
    private readonly IUserAgentService UserAgentService;
 | 
			
		||||
    public AppService(IUserAgentService userAgentService)
 | 
			
		||||
    private readonly IClaimsPrincipalService ClaimsPrincipalService;
 | 
			
		||||
    public AppService(IUserAgentService userAgentService, IClaimsPrincipalService claimsPrincipalService)
 | 
			
		||||
    {
 | 
			
		||||
        UserAgentService = userAgentService;
 | 
			
		||||
        ClaimsPrincipalService = claimsPrincipalService;
 | 
			
		||||
    }
 | 
			
		||||
    public string GetReturnUrl(string returnUrl)
 | 
			
		||||
    {
 | 
			
		||||
@@ -70,7 +72,7 @@ public class AppService : IAppService
 | 
			
		||||
            ExpiresUtc = diffTime,
 | 
			
		||||
        }).ConfigureAwait(false);
 | 
			
		||||
    }
 | 
			
		||||
    public ClaimsPrincipal? User => App.User;
 | 
			
		||||
    public ClaimsPrincipal? User => ClaimsPrincipalService.User;
 | 
			
		||||
 | 
			
		||||
    public string? RemoteIpAddress => App.HttpContext?.GetRemoteIpAddressToIPv4();
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -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.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
 | 
			
		||||
        };
 | 
			
		||||
 
 | 
			
		||||
@@ -11,8 +11,6 @@
 | 
			
		||||
using Microsoft.AspNetCore.Http.Connections.Features;
 | 
			
		||||
using Microsoft.AspNetCore.SignalR;
 | 
			
		||||
 | 
			
		||||
using Yitter.IdGenerator;
 | 
			
		||||
 | 
			
		||||
namespace ThingsGateway.Admin.Application;
 | 
			
		||||
 | 
			
		||||
/// <summary>
 | 
			
		||||
 
 | 
			
		||||
@@ -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();//模块列表赋值给用户
 | 
			
		||||
 
 | 
			
		||||
@@ -13,8 +13,6 @@ using BootstrapBlazor.Components;
 | 
			
		||||
using Microsoft.AspNetCore.Builder;
 | 
			
		||||
using Microsoft.Extensions.DependencyInjection;
 | 
			
		||||
 | 
			
		||||
using SqlSugar;
 | 
			
		||||
 | 
			
		||||
using System.Reflection;
 | 
			
		||||
 | 
			
		||||
using ThingsGateway.UnifyResult;
 | 
			
		||||
@@ -28,19 +26,12 @@ public class Startup : AppStartup
 | 
			
		||||
    {
 | 
			
		||||
        Directory.CreateDirectory("DB");
 | 
			
		||||
 | 
			
		||||
        services.AddConfigurableOptions<SqlSugarOptions>();
 | 
			
		||||
        services.AddConfigurableOptions<AdminLogOptions>();
 | 
			
		||||
        services.AddConfigurableOptions<TenantOptions>();
 | 
			
		||||
 | 
			
		||||
        services.AddSingleton(typeof(IDataService<>), typeof(BaseService<>));
 | 
			
		||||
        services.AddSingleton<ISugarAopService, SugarAopService>();
 | 
			
		||||
        services.AddSingleton<ISugarConfigAopService, SugarConfigAopService>();
 | 
			
		||||
 | 
			
		||||
        services.AddSingleton<IUserAgentService, UserAgentService>();
 | 
			
		||||
        services.AddSingleton<IAppService, AppService>();
 | 
			
		||||
 | 
			
		||||
        StaticConfig.EnableAllWhereIF = true;
 | 
			
		||||
 | 
			
		||||
        services.AddConfigurableOptions<EmailOptions>();
 | 
			
		||||
        services.AddConfigurableOptions<HardwareInfoOptions>();
 | 
			
		||||
 | 
			
		||||
@@ -57,7 +48,6 @@ public class Startup : AppStartup
 | 
			
		||||
 | 
			
		||||
        services.AddSingleton<IVerificatInfoService, VerificatInfoService>();
 | 
			
		||||
        services.AddSingleton<IUserCenterService, UserCenterService>();
 | 
			
		||||
        services.AddSingleton<ISugarAopService, SugarAopService>();
 | 
			
		||||
        services.AddSingleton<ISysDictService, SysDictService>();
 | 
			
		||||
        services.AddSingleton<ISysOperateLogService, SysOperateLogService>();
 | 
			
		||||
        services.AddSingleton<IRelationService, RelationService>();
 | 
			
		||||
 
 | 
			
		||||
@@ -18,9 +18,7 @@
 | 
			
		||||
	</ItemGroup>
 | 
			
		||||
	
 | 
			
		||||
	<ItemGroup>
 | 
			
		||||
		<PackageReference Include="BootstrapBlazor.TableExport" Version="9.2.5" />
 | 
			
		||||
		<PackageReference Include="Rougamo.Fody" Version="5.0.0" />
 | 
			
		||||
		<PackageReference Include="SqlSugarCore" Version="5.1.4.193" />
 | 
			
		||||
	</ItemGroup>
 | 
			
		||||
	<ItemGroup Condition=" '$(TargetFramework)' == 'net8.0' ">
 | 
			
		||||
		<PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" />
 | 
			
		||||
@@ -49,6 +47,7 @@
 | 
			
		||||
 | 
			
		||||
	<ItemGroup>
 | 
			
		||||
		<ProjectReference Include="..\ThingsGateway.Razor\ThingsGateway.Razor.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>
 | 
			
		||||
 
 | 
			
		||||
@@ -11,6 +11,7 @@
 | 
			
		||||
 | 
			
		||||
    // nuget动态加载的程序集
 | 
			
		||||
    "SupportPackageNamePrefixs": [
 | 
			
		||||
      "ThingsGateway.SqlSugar",
 | 
			
		||||
      "ThingsGateway.Admin.Application",
 | 
			
		||||
      "ThingsGateway.Admin.Razor",
 | 
			
		||||
      "ThingsGateway.Razor"
 | 
			
		||||
 
 | 
			
		||||
@@ -11,6 +11,7 @@
 | 
			
		||||
 | 
			
		||||
    // nuget动态加载的程序集
 | 
			
		||||
    "SupportPackageNamePrefixs": [
 | 
			
		||||
      "ThingsGateway.SqlSugar",
 | 
			
		||||
      "ThingsGateway.Admin.Application",
 | 
			
		||||
      "ThingsGateway.Admin.Razor",
 | 
			
		||||
      "ThingsGateway.Razor"
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										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 全局通知
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -40,7 +40,8 @@ public class SingleFilePublish : ISingleFilePublish
 | 
			
		||||
            "ThingsGateway.NewLife.X",
 | 
			
		||||
            "ThingsGateway.Razor",
 | 
			
		||||
            "ThingsGateway.Admin.Razor"   ,
 | 
			
		||||
            "ThingsGateway.Admin.Application"
 | 
			
		||||
            "ThingsGateway.Admin.Application",
 | 
			
		||||
            "ThingsGateway.SqlSugar",
 | 
			
		||||
        ];
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -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;
 | 
			
		||||
@@ -0,0 +1,20 @@
 | 
			
		||||
//------------------------------------------------------------------------------
 | 
			
		||||
//  此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
 | 
			
		||||
//  此代码版权(除特别声明外的代码)归作者本人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 ClaimsPrincipalService : IClaimsPrincipalService
 | 
			
		||||
{
 | 
			
		||||
 | 
			
		||||
    public ClaimsPrincipal? User => App.User;
 | 
			
		||||
 | 
			
		||||
}
 | 
			
		||||
@@ -0,0 +1,18 @@
 | 
			
		||||
//------------------------------------------------------------------------------
 | 
			
		||||
//  此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
 | 
			
		||||
//  此代码版权(除特别声明外的代码)归作者本人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 interface IClaimsPrincipalService
 | 
			
		||||
{
 | 
			
		||||
    public ClaimsPrincipal? User { get; }
 | 
			
		||||
}
 | 
			
		||||
@@ -17,10 +17,10 @@ namespace ThingsGateway.Admin.Application;
 | 
			
		||||
 | 
			
		||||
public class SugarAopService : ISugarAopService
 | 
			
		||||
{
 | 
			
		||||
    private IAppService _appService;
 | 
			
		||||
    public SugarAopService(IAppService appService)
 | 
			
		||||
    private IClaimsPrincipalService _claimsPrincipalService;
 | 
			
		||||
    public SugarAopService(IClaimsPrincipalService appService)
 | 
			
		||||
    {
 | 
			
		||||
        _appService = appService;
 | 
			
		||||
        _claimsPrincipalService = appService;
 | 
			
		||||
    }
 | 
			
		||||
    /// <summary>
 | 
			
		||||
    /// Aop设置
 | 
			
		||||
@@ -85,7 +85,7 @@ public class SugarAopService : ISugarAopService
 | 
			
		||||
                if (entityInfo.PropertyName == nameof(BaseEntity.CreateTime))
 | 
			
		||||
                    entityInfo.SetValue(DateTime.Now);
 | 
			
		||||
 | 
			
		||||
                if (_appService.User != null)
 | 
			
		||||
                if (_claimsPrincipalService.User != null)
 | 
			
		||||
                {
 | 
			
		||||
                    //创建人
 | 
			
		||||
                    if (entityInfo.PropertyName == nameof(BaseEntity.CreateUserId))
 | 
			
		||||
@@ -103,7 +103,7 @@ public class SugarAopService : ISugarAopService
 | 
			
		||||
                if (entityInfo.PropertyName == nameof(BaseEntity.UpdateTime))
 | 
			
		||||
                    entityInfo.SetValue(DateTime.Now);
 | 
			
		||||
                //更新人
 | 
			
		||||
                if (_appService.User != null)
 | 
			
		||||
                if (_claimsPrincipalService.User != null)
 | 
			
		||||
                {
 | 
			
		||||
                    if (entityInfo.PropertyName == nameof(BaseEntity.UpdateUserId))
 | 
			
		||||
                        entityInfo.SetValue(UserManager.UserId);
 | 
			
		||||
@@ -25,7 +25,7 @@ namespace ThingsGateway.Admin.Application;
 | 
			
		||||
/// 种子数据工具类
 | 
			
		||||
/// </summary>
 | 
			
		||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
 | 
			
		||||
public class SeedDataUtil
 | 
			
		||||
public static class SeedDataUtil
 | 
			
		||||
{
 | 
			
		||||
    /// <summary>
 | 
			
		||||
    /// 获取List列表
 | 
			
		||||
							
								
								
									
										44
									
								
								src/Admin/ThingsGateway.DB/Startup.cs
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										44
									
								
								src/Admin/ThingsGateway.DB/Startup.cs
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,44 @@
 | 
			
		||||
//------------------------------------------------------------------------------
 | 
			
		||||
//  此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
 | 
			
		||||
//  此代码版权(除特别声明外的代码)归作者本人Diego所有
 | 
			
		||||
//  源代码使用协议遵循本仓库的开源协议及附加协议
 | 
			
		||||
//  Gitee源代码仓库:https://gitee.com/diego2098/ThingsGateway
 | 
			
		||||
//  Github源代码仓库:https://github.com/kimdiego2098/ThingsGateway
 | 
			
		||||
//  使用文档:https://thingsgateway.cn/
 | 
			
		||||
//  QQ群:605534569
 | 
			
		||||
//------------------------------------------------------------------------------
 | 
			
		||||
 | 
			
		||||
using BootstrapBlazor.Components;
 | 
			
		||||
 | 
			
		||||
using Microsoft.AspNetCore.Builder;
 | 
			
		||||
using Microsoft.Extensions.DependencyInjection;
 | 
			
		||||
 | 
			
		||||
using SqlSugar;
 | 
			
		||||
 | 
			
		||||
namespace ThingsGateway.Admin.Application;
 | 
			
		||||
 | 
			
		||||
[AppStartup(1000000000)]
 | 
			
		||||
public class Startup : AppStartup
 | 
			
		||||
{
 | 
			
		||||
    public void Configure(IServiceCollection services)
 | 
			
		||||
    {
 | 
			
		||||
        services.AddConfigurableOptions<SqlSugarOptions>();
 | 
			
		||||
 | 
			
		||||
        services.AddSingleton(typeof(IDataService<>), typeof(BaseService<>));
 | 
			
		||||
        services.AddSingleton<ISugarAopService, SugarAopService>();
 | 
			
		||||
        services.AddSingleton<ISugarConfigAopService, SugarConfigAopService>();
 | 
			
		||||
 | 
			
		||||
        services.AddSingleton<IClaimsPrincipalService, ClaimsPrincipalService>();
 | 
			
		||||
 | 
			
		||||
        StaticConfig.EnableAllWhereIF = true;
 | 
			
		||||
 | 
			
		||||
        services.AddSingleton<ISugarAopService, SugarAopService>();
 | 
			
		||||
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    public void Use(IApplicationBuilder applicationBuilder)
 | 
			
		||||
    {
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
@@ -17,33 +17,39 @@ namespace ThingsGateway.Admin.Application;
 | 
			
		||||
/// </summary>
 | 
			
		||||
public static class UserManager
 | 
			
		||||
{
 | 
			
		||||
    private static readonly IAppService _appService;
 | 
			
		||||
    private static readonly IClaimsPrincipalService _claimsPrincipalService;
 | 
			
		||||
    static UserManager()
 | 
			
		||||
    {
 | 
			
		||||
        _appService = App.RootServices.GetService<IAppService>();
 | 
			
		||||
        _claimsPrincipalService = App.RootServices.GetService<IClaimsPrincipalService>();
 | 
			
		||||
    }
 | 
			
		||||
    /// <summary>
 | 
			
		||||
    /// 是否超级管理员
 | 
			
		||||
    /// </summary>
 | 
			
		||||
    public static bool SuperAdmin => (_appService.User?.FindFirst(ClaimConst.SuperAdmin)?.Value).ToBoolean(false);
 | 
			
		||||
    public static bool SuperAdmin => (_claimsPrincipalService.User?.FindFirst(ClaimConst.SuperAdmin)?.Value).ToBoolean(false);
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
    /// <summary>
 | 
			
		||||
    /// 当前用户账号
 | 
			
		||||
    /// </summary>
 | 
			
		||||
    public static string UserAccount => _appService.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>
 | 
			
		||||
    /// 当前用户Id
 | 
			
		||||
    /// </summary>
 | 
			
		||||
    public static long UserId => (_appService.User?.FindFirst(ClaimConst.UserId)?.Value).ToLong();
 | 
			
		||||
    public static long UserId => (_claimsPrincipalService.User?.FindFirst(ClaimConst.UserId)?.Value).ToLong();
 | 
			
		||||
 | 
			
		||||
    /// <summary>
 | 
			
		||||
    /// 当前验证Id
 | 
			
		||||
    /// </summary>
 | 
			
		||||
    public static long VerificatId => (_appService.User?.FindFirst(ClaimConst.VerificatId)?.Value).ToLong();
 | 
			
		||||
    public static long VerificatId => (_claimsPrincipalService.User?.FindFirst(ClaimConst.VerificatId)?.Value).ToLong();
 | 
			
		||||
 | 
			
		||||
    public static long OrgId => (_appService.User?.FindFirst(ClaimConst.OrgId)?.Value).ToLong();
 | 
			
		||||
    public static long OrgId => (_claimsPrincipalService.User?.FindFirst(ClaimConst.OrgId)?.Value).ToLong();
 | 
			
		||||
 | 
			
		||||
    public static long TenantId => (_appService.User?.FindFirst(ClaimConst.TenantId)?.Value)?.ToLong() ?? 0;
 | 
			
		||||
    public static long TenantId => (_claimsPrincipalService.User?.FindFirst(ClaimConst.TenantId)?.Value)?.ToLong() ?? 0;
 | 
			
		||||
 | 
			
		||||
}
 | 
			
		||||
							
								
								
									
										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);
 | 
			
		||||
        }
 | 
			
		||||
 
 | 
			
		||||
Some files were not shown because too many files have changed in this diff Show More
		Reference in New Issue
	
	Block a user