mirror of
https://gitee.com/ThingsGateway/ThingsGateway.git
synced 2025-10-20 18:51:28 +08:00
Compare commits
25 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
347d4d6e5d | ||
![]() |
b006a066e1 | ||
![]() |
e331bc5d3c | ||
![]() |
2e81806231 | ||
![]() |
37b48cf221 | ||
![]() |
5997487434 | ||
![]() |
4ce843182f | ||
![]() |
a4aa000cf0 | ||
![]() |
01aa6ca066 | ||
![]() |
10a0280c4a | ||
![]() |
3b8b00c783 | ||
![]() |
232ee5d5d4 | ||
![]() |
605830edce | ||
![]() |
ca86441e05 | ||
![]() |
b30b876c5f | ||
![]() |
f95590b4cb | ||
![]() |
9921130406 | ||
![]() |
5c47589ca1 | ||
![]() |
048abfae2e | ||
![]() |
8e35c16edf | ||
![]() |
143b751213 | ||
![]() |
2cafe745b9 | ||
![]() |
210ac2c122 | ||
![]() |
4707ce6d58 | ||
![]() |
788a8b670d |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -367,3 +367,4 @@ FodyWeavers.xsd
|
|||||||
/src/*pro*
|
/src/*pro*
|
||||||
/src/*pro*/
|
/src/*pro*/
|
||||||
/src/ThingsGateway.Server/Configuration/GiteeOAuthSettings.json
|
/src/ThingsGateway.Server/Configuration/GiteeOAuthSettings.json
|
||||||
|
/src/.idea/
|
||||||
|
@@ -122,6 +122,7 @@ using Microsoft.AspNetCore.Components;
|
|||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.Threading.Tasks;
|
using System.Threading.Tasks;
|
||||||
|
|
||||||
|
#pragma warning disable CA1849
|
||||||
#pragma warning disable CA2007
|
#pragma warning disable CA2007
|
||||||
#pragma warning disable CS0162
|
#pragma warning disable CS0162
|
||||||
#pragma warning disable CS8632
|
#pragma warning disable CS8632
|
||||||
@@ -276,6 +277,7 @@ namespace {namespaceName}
|
|||||||
#pragma warning restore CS8632
|
#pragma warning restore CS8632
|
||||||
#pragma warning restore CS0162
|
#pragma warning restore CS0162
|
||||||
#pragma warning restore CA2007
|
#pragma warning restore CA2007
|
||||||
|
#pragma warning restore CA1849
|
||||||
");
|
");
|
||||||
var bases = class_symbol.GetTypeHierarchy().Where(t => !SymbolEqualityComparer.Default.Equals(t, class_symbol));
|
var bases = class_symbol.GetTypeHierarchy().Where(t => !SymbolEqualityComparer.Default.Equals(t, class_symbol));
|
||||||
var members = class_symbol.GetMembers() // members of the type itself
|
var members = class_symbol.GetMembers() // members of the type itself
|
||||||
@@ -435,5 +437,4 @@ namespace {namespaceName}
|
|||||||
m.DeclaredAccessibility == Accessibility.Public &&
|
m.DeclaredAccessibility == Accessibility.Public &&
|
||||||
!m.IsStatic);
|
!m.IsStatic);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
@@ -38,9 +38,9 @@ public sealed class OperDescAttribute : MoAttribute
|
|||||||
|
|
||||||
static OperDescAttribute()
|
static OperDescAttribute()
|
||||||
{
|
{
|
||||||
// 创建长时间运行的后台任务,并将日志消息队列中数据写入存储中
|
|
||||||
Task.Factory.StartNew(ProcessQueue, TaskCreationOptions.LongRunning);
|
|
||||||
AppService = App.RootServices.GetService<IAppService>();
|
AppService = App.RootServices.GetService<IAppService>();
|
||||||
|
// 创建长时间运行的后台任务,并将日志消息队列中数据写入存储中
|
||||||
|
Task.Factory.StartNew(ProcessQueueAsync, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default);
|
||||||
}
|
}
|
||||||
|
|
||||||
public OperDescAttribute(string description, bool isRecordPar = true, object localizerType = null)
|
public OperDescAttribute(string description, bool isRecordPar = true, object localizerType = null)
|
||||||
@@ -84,7 +84,6 @@ public sealed class OperDescAttribute : MoAttribute
|
|||||||
{
|
{
|
||||||
if (App.HttpContext?.Request.Path.StartsWithSegments("/_blazor") == true)
|
if (App.HttpContext?.Request.Path.StartsWithSegments("/_blazor") == true)
|
||||||
{
|
{
|
||||||
|
|
||||||
//插入操作日志
|
//插入操作日志
|
||||||
SysOperateLog log = GetOperLog(LocalizerType, context);
|
SysOperateLog log = GetOperLog(LocalizerType, context);
|
||||||
OperDescAttribute.WriteToQueue(log);
|
OperDescAttribute.WriteToQueue(log);
|
||||||
@@ -94,7 +93,7 @@ public sealed class OperDescAttribute : MoAttribute
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 将日志消息写入数据库中
|
/// 将日志消息写入数据库中
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private static async Task ProcessQueue()
|
private static async Task ProcessQueueAsync()
|
||||||
{
|
{
|
||||||
var appLifetime = App.RootServices!.GetService<IHostApplicationLifetime>()!;
|
var appLifetime = App.RootServices!.GetService<IHostApplicationLifetime>()!;
|
||||||
while (!appLifetime.ApplicationStopping.IsCancellationRequested)
|
while (!appLifetime.ApplicationStopping.IsCancellationRequested)
|
||||||
|
@@ -18,7 +18,6 @@ public sealed class RolePermissionAttribute : Attribute
|
|||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 忽略角色授权权限
|
/// 忽略角色授权权限
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -10,7 +10,6 @@
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
[AttributeUsage(AttributeTargets.Method)]
|
[AttributeUsage(AttributeTargets.Method)]
|
||||||
public sealed class LoginLogAttribute : Attribute
|
public sealed class LoginLogAttribute : Attribute
|
||||||
{
|
{
|
||||||
|
@@ -31,9 +31,7 @@ public class AuthController : ControllerBase
|
|||||||
[LoginLog]
|
[LoginLog]
|
||||||
public Task<LoginOutput> LoginAsync([FromBody] LoginInput input)
|
public Task<LoginOutput> LoginAsync([FromBody] LoginInput input)
|
||||||
{
|
{
|
||||||
|
|
||||||
return _authService.LoginAsync(input);
|
return _authService.LoginAsync(input);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
[HttpGet("oauth-login")]
|
[HttpGet("oauth-login")]
|
||||||
@@ -48,7 +46,6 @@ public class AuthController : ControllerBase
|
|||||||
return Challenge(props, scheme);
|
return Challenge(props, scheme);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
[HttpPost("logout")]
|
[HttpPost("logout")]
|
||||||
[Authorize]
|
[Authorize]
|
||||||
[IgnoreRolePermission]
|
[IgnoreRolePermission]
|
||||||
|
@@ -34,12 +34,16 @@ public class FileController : ControllerBase
|
|||||||
return BadRequest("Invalid file name.");
|
return BadRequest("Invalid file name.");
|
||||||
}
|
}
|
||||||
|
|
||||||
var filePath = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", fileName);
|
var root = Directory.GetCurrentDirectory();
|
||||||
|
var wwwroot = Path.Combine(root, "wwwroot");
|
||||||
if (!System.IO.File.Exists(filePath))
|
var filePath = Path.Combine(wwwroot, fileName);
|
||||||
|
// 防止路径穿越攻击
|
||||||
|
#pragma warning disable CA3003
|
||||||
|
if (!filePath.StartsWith(wwwroot, StringComparison.OrdinalIgnoreCase) || !System.IO.File.Exists(filePath))
|
||||||
{
|
{
|
||||||
return NotFound();
|
return NotFound();
|
||||||
}
|
}
|
||||||
|
#pragma warning restore CA3003
|
||||||
|
|
||||||
var fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
|
var fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
|
||||||
|
|
||||||
|
@@ -15,7 +15,6 @@ using System.ComponentModel;
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 登录
|
/// 登录
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -66,12 +66,9 @@ public class SysOrg : BaseEntity
|
|||||||
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
||||||
public OrgEnum Category { get; set; }
|
public OrgEnum Category { get; set; }
|
||||||
|
|
||||||
|
|
||||||
[SugarColumn(ColumnName = "Status", ColumnDescription = "启用")]
|
[SugarColumn(ColumnName = "Status", ColumnDescription = "启用")]
|
||||||
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
||||||
public bool Status { get; set; } = true;
|
public bool Status { get; set; } = true;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -10,8 +10,6 @@
|
|||||||
|
|
||||||
using System.ComponentModel.DataAnnotations;
|
using System.ComponentModel.DataAnnotations;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -44,7 +42,6 @@ public class SysPosition : BaseEntity
|
|||||||
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
||||||
public string Code { get; set; }
|
public string Code { get; set; }
|
||||||
|
|
||||||
|
|
||||||
[SugarColumn(ColumnName = "Status", ColumnDescription = "启用")]
|
[SugarColumn(ColumnName = "Status", ColumnDescription = "启用")]
|
||||||
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
||||||
public bool Status { get; set; } = true;
|
public bool Status { get; set; } = true;
|
||||||
@@ -55,5 +52,4 @@ public class SysPosition : BaseEntity
|
|||||||
[SugarColumn(ColumnName = "Category", ColumnDescription = "分类")]
|
[SugarColumn(ColumnName = "Category", ColumnDescription = "分类")]
|
||||||
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
[AutoGenerateColumn(Visible = true, Sortable = true, Filterable = true)]
|
||||||
public virtual PositionCategoryEnum Category { get; set; }
|
public virtual PositionCategoryEnum Category { get; set; }
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -71,8 +71,6 @@ public class SysRole : BaseEntity
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 默认数据范围
|
/// 默认数据范围
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -170,14 +170,14 @@ public class SysUser : BaseEntity
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true, IsJson = true)]
|
[SugarColumn(IsIgnore = true, IsJson = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public List<long> OrgAndPosIdList { get; set; } = new List<long>();
|
public List<long>? OrgAndPosIdList { get; set; } = new List<long>();
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 主管信息
|
/// 主管信息
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true)]
|
[SugarColumn(IsIgnore = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public UserSelectorOutput DirectorInfo { get; set; }
|
public UserSelectorOutput? DirectorInfo { get; set; }
|
||||||
|
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
@@ -188,35 +188,35 @@ public class SysUser : BaseEntity
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true)]
|
[SugarColumn(IsIgnore = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public Dictionary<string, List<string>> ButtonCodeList { get; set; } = new();
|
public Dictionary<string, List<string>>? ButtonCodeList { get; set; } = new();
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 权限码集合
|
/// 权限码集合
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true)]
|
[SugarColumn(IsIgnore = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public HashSet<string> PermissionCodeList { get; set; } = new();
|
public HashSet<string>? PermissionCodeList { get; set; } = new();
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 角色ID集合
|
/// 角色ID集合
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true)]
|
[SugarColumn(IsIgnore = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public HashSet<long> RoleIdList { get; set; } = new();
|
public HashSet<long>? RoleIdList { get; set; } = new();
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 机构及以下机构ID集合
|
/// 机构及以下机构ID集合
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true)]
|
[SugarColumn(IsIgnore = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public HashSet<long> ScopeOrgChildList { get; set; }
|
public HashSet<long>? ScopeOrgChildList { get; set; }
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 模块集合
|
/// 模块集合
|
||||||
/// </summary>
|
/// </summary>
|
||||||
[SugarColumn(IsIgnore = true)]
|
[SugarColumn(IsIgnore = true)]
|
||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public List<SysResource> ModuleList { get; set; } = new();
|
public List<SysResource>? ModuleList { get; set; } = new();
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 租户Id
|
/// 租户Id
|
||||||
@@ -225,7 +225,6 @@ public class SysUser : BaseEntity
|
|||||||
[AutoGenerateColumn(Ignore = true)]
|
[AutoGenerateColumn(Ignore = true)]
|
||||||
public long? TenantId { get; set; }
|
public long? TenantId { get; set; }
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 全局用戶
|
/// 全局用戶
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -15,7 +15,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 会话信息
|
/// 会话信息
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|
||||||
[SugarTable("verificatinfo", TableDescription = "验证缓存表")]
|
[SugarTable("verificatinfo", TableDescription = "验证缓存表")]
|
||||||
[Tenant(SqlSugarConst.DB_TokenCache)]
|
[Tenant(SqlSugarConst.DB_TokenCache)]
|
||||||
public class VerificatInfo : PrimaryIdEntity
|
public class VerificatInfo : PrimaryIdEntity
|
||||||
@@ -79,6 +78,4 @@ public class VerificatInfo : PrimaryIdEntity
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
[AutoGenerateColumn(Filterable = true, Sortable = true, Width = 100)]
|
[AutoGenerateColumn(Filterable = true, Sortable = true, Width = 100)]
|
||||||
public string Device { get; set; }
|
public string Device { get; set; }
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -12,7 +12,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
public enum DataScopeEnum
|
public enum DataScopeEnum
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 仅自己
|
/// 仅自己
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -37,5 +36,4 @@ public enum DataScopeEnum
|
|||||||
/// 自定义
|
/// 自定义
|
||||||
/// </summary>
|
/// </summary>
|
||||||
SCOPE_ORG_DEFINE,
|
SCOPE_ORG_DEFINE,
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -16,7 +16,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public static class SchemeHelper
|
public static class SchemeHelper
|
||||||
{
|
{
|
||||||
|
|
||||||
public static string GetOrCreate()
|
public static string GetOrCreate()
|
||||||
{
|
{
|
||||||
var path = "Keys/SchemeKey.txt";
|
var path = "Keys/SchemeKey.txt";
|
||||||
@@ -33,5 +32,4 @@ public static class SchemeHelper
|
|||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -6,5 +6,4 @@ namespace System;
|
|||||||
[SuppressSniffer, AttributeUsage(AttributeTargets.Method | AttributeTargets.Class, Inherited = true, AllowMultiple = false)]
|
[SuppressSniffer, AttributeUsage(AttributeTargets.Method | AttributeTargets.Class, Inherited = true, AllowMultiple = false)]
|
||||||
public sealed class RequestAuditAttribute : Attribute
|
public sealed class RequestAuditAttribute : Attribute
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
@@ -61,7 +61,6 @@ public class RequestAuditData
|
|||||||
|
|
||||||
public long TimeOperationElapsedMilliseconds { get; set; }
|
public long TimeOperationElapsedMilliseconds { get; set; }
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 服务端
|
/// 服务端
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -98,4 +97,3 @@ public class RequestAuditData
|
|||||||
public Validation Validation { get; set; }
|
public Validation Validation { get; set; }
|
||||||
public MethodInfo MethodInfo { get; set; }
|
public MethodInfo MethodInfo { get; set; }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -41,7 +41,6 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
// 获取动作方法描述器
|
// 获取动作方法描述器
|
||||||
var actionMethod = controllerActionDescriptor?.MethodInfo;
|
var actionMethod = controllerActionDescriptor?.MethodInfo;
|
||||||
|
|
||||||
|
|
||||||
// 处理 Blazor Server
|
// 处理 Blazor Server
|
||||||
if (actionMethod == null)
|
if (actionMethod == null)
|
||||||
{
|
{
|
||||||
@@ -61,7 +60,6 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// 只有方法贴有特性才进行审计
|
// 只有方法贴有特性才进行审计
|
||||||
if (
|
if (
|
||||||
!actionMethod.DeclaringType.IsDefined(typeof(RequestAuditAttribute), true)
|
!actionMethod.DeclaringType.IsDefined(typeof(RequestAuditAttribute), true)
|
||||||
@@ -71,12 +69,8 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
var logData = new RequestAuditData();
|
var logData = new RequestAuditData();
|
||||||
|
|
||||||
|
|
||||||
logData.TimeOperationElapsedMilliseconds = timeOperation.ElapsedMilliseconds;
|
logData.TimeOperationElapsedMilliseconds = timeOperation.ElapsedMilliseconds;
|
||||||
|
|
||||||
var resultHttpContext = (resultContext as Microsoft.AspNetCore.Mvc.Filters.FilterContext).HttpContext;
|
var resultHttpContext = (resultContext as Microsoft.AspNetCore.Mvc.Filters.FilterContext).HttpContext;
|
||||||
@@ -145,8 +139,6 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
logData.LocalIPv4 = httpContext.GetLocalIpAddressToIPv4();
|
logData.LocalIPv4 = httpContext.GetLocalIpAddressToIPv4();
|
||||||
logData.LogDateTime = DateTimeOffset.Now;
|
logData.LogDateTime = DateTimeOffset.Now;
|
||||||
var parameterValues = context.ActionArguments;
|
var parameterValues = context.ActionArguments;
|
||||||
@@ -167,7 +159,6 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
|
|
||||||
_ = parameterValues.TryGetValue(name, out var value);
|
_ = parameterValues.TryGetValue(name, out var value);
|
||||||
|
|
||||||
|
|
||||||
var par = new Parameters()
|
var par = new Parameters()
|
||||||
{
|
{
|
||||||
Name = name,
|
Name = name,
|
||||||
@@ -233,7 +224,6 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
par.Value = rawValue;
|
par.Value = rawValue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// 获取异常对象情况
|
// 获取异常对象情况
|
||||||
Exception exception = resultContext.Exception;
|
Exception exception = resultContext.Exception;
|
||||||
if (exception is AppFriendlyException friendlyException)
|
if (exception is AppFriendlyException friendlyException)
|
||||||
@@ -249,8 +239,6 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
logData.Exception.Type = HandleGenericType(exception.GetType());
|
logData.Exception.Type = HandleGenericType(exception.GetType());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// 创建日志记录器
|
// 创建日志记录器
|
||||||
var logger = httpContext.RequestServices.GetRequiredService<ILogger<RequestAudit>>();
|
var logger = httpContext.RequestServices.GetRequiredService<ILogger<RequestAudit>>();
|
||||||
|
|
||||||
@@ -296,6 +284,4 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
@@ -6,5 +6,4 @@ namespace System;
|
|||||||
[SuppressSniffer, AttributeUsage(AttributeTargets.Method | AttributeTargets.Class, Inherited = true, AllowMultiple = false)]
|
[SuppressSniffer, AttributeUsage(AttributeTargets.Method | AttributeTargets.Class, Inherited = true, AllowMultiple = false)]
|
||||||
public sealed class SuppressRequestAuditAttribute : Attribute
|
public sealed class SuppressRequestAuditAttribute : Attribute
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
@@ -58,7 +58,7 @@ public class HardwareJob : IJob, IHardwareJob
|
|||||||
var historyHardwareInfos = MemoryCache.Get<List<HistoryHardwareInfo>>(CacheKey);
|
var historyHardwareInfos = MemoryCache.Get<List<HistoryHardwareInfo>>(CacheKey);
|
||||||
if (historyHardwareInfos == null)
|
if (historyHardwareInfos == null)
|
||||||
{
|
{
|
||||||
using var db = DbContext.GetDB<HistoryHardwareInfo>(); ;
|
using var db = DbContext.GetDB<HistoryHardwareInfo>();
|
||||||
historyHardwareInfos = await db.Queryable<HistoryHardwareInfo>().Where(a => a.Date > DateTime.Now.AddDays(-3)).Take(1000).ToListAsync().ConfigureAwait(false);
|
historyHardwareInfos = await db.Queryable<HistoryHardwareInfo>().Where(a => a.Date > DateTime.Now.AddDays(-3)).Take(1000).ToListAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
MemoryCache.Set(CacheKey, historyHardwareInfos);
|
MemoryCache.Set(CacheKey, historyHardwareInfos);
|
||||||
@@ -92,7 +92,6 @@ public class HardwareJob : IJob, IHardwareJob
|
|||||||
HardwareInfo.UUID = HardwareInfo.MachineInfo.UUID;
|
HardwareInfo.UUID = HardwareInfo.MachineInfo.UUID;
|
||||||
|
|
||||||
HardwareInfo.UpdateTime = TimerX.Now.ToDefaultDateTimeFormat();
|
HardwareInfo.UpdateTime = TimerX.Now.ToDefaultDateTimeFormat();
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch
|
catch
|
||||||
@@ -129,7 +128,7 @@ public class HardwareJob : IJob, IHardwareJob
|
|||||||
CpuUsage = (HardwareInfo.MachineInfo.CpuRate * 100).ToInt(),
|
CpuUsage = (HardwareInfo.MachineInfo.CpuRate * 100).ToInt(),
|
||||||
Temperature = (HardwareInfo.MachineInfo.Temperature).ToInt(),
|
Temperature = (HardwareInfo.MachineInfo.Temperature).ToInt(),
|
||||||
};
|
};
|
||||||
await _db.Insertable(his).ExecuteCommandAsync(stoppingToken).ConfigureAwait(false);
|
await _db.InsertableT(his).ExecuteCommandAsync(stoppingToken).ConfigureAwait(false);
|
||||||
MemoryCache.Remove(CacheKey);
|
MemoryCache.Remove(CacheKey);
|
||||||
}
|
}
|
||||||
var sevenDaysAgo = TimerX.Now.AddDays(-HardwareInfoOptions.DaysAgo);
|
var sevenDaysAgo = TimerX.Now.AddDays(-HardwareInfoOptions.DaysAgo);
|
||||||
@@ -154,5 +153,4 @@ public class HardwareJob : IJob, IHardwareJob
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -17,7 +17,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public class JobPersistence : IJobPersistence
|
public class JobPersistence : IJobPersistence
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 作业调度服务启动时
|
/// 作业调度服务启动时
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -61,7 +60,6 @@ public class JobPersistence : IJobPersistence
|
|||||||
public async Task OnTriggerChangedAsync(PersistenceTriggerContext context)
|
public async Task OnTriggerChangedAsync(PersistenceTriggerContext context)
|
||||||
{
|
{
|
||||||
await Task.CompletedTask.ConfigureAwait(false);
|
await Task.CompletedTask.ConfigureAwait(false);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@@ -105,7 +105,6 @@ public class DatabaseLoggingWriter : IDatabaseLoggingWriter
|
|||||||
//获取结果json字符串
|
//获取结果json字符串
|
||||||
var resultJson = requestAuditData.ReturnInformation?.ToSystemTextJsonString();
|
var resultJson = requestAuditData.ReturnInformation?.ToSystemTextJsonString();
|
||||||
|
|
||||||
|
|
||||||
//操作日志表实体
|
//操作日志表实体
|
||||||
var sysLogOperate = new SysOperateLog
|
var sysLogOperate = new SysOperateLog
|
||||||
{
|
{
|
||||||
|
@@ -25,7 +25,3 @@ public static partial class AdminMapper
|
|||||||
public static partial QueryData<UserSelectorOutput> AdaptQueryDataUserSelectorOutput(this QueryData<SysUser> src);
|
public static partial QueryData<UserSelectorOutput> AdaptQueryDataUserSelectorOutput(this QueryData<SysUser> src);
|
||||||
public static partial LoginInput AdaptLoginInput(this LoginInput src);
|
public static partial LoginInput AdaptLoginInput(this LoginInput src);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
@@ -28,11 +28,9 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
) : OAuthHandler<TOptions>(options, logger, encoder)
|
) : OAuthHandler<TOptions>(options, logger, encoder)
|
||||||
where TOptions : AdminOAuthOptions, new()
|
where TOptions : AdminOAuthOptions, new()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
|
||||||
static AdminOAuthHandler()
|
static AdminOAuthHandler()
|
||||||
{
|
{
|
||||||
Task.Factory.StartNew(Insertable, TaskCreationOptions.LongRunning);
|
Task.Factory.StartNew(InsertableAsync, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -43,7 +41,7 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 创建访问日志
|
/// 创建访问日志
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private static async Task Insertable()
|
private static async Task InsertableAsync()
|
||||||
{
|
{
|
||||||
var db = DbContext.GetDB<SysOperateLog>();
|
var db = DbContext.GetDB<SysOperateLog>();
|
||||||
var appLifetime = App.RootServices!.GetService<IHostApplicationLifetime>()!;
|
var appLifetime = App.RootServices!.GetService<IHostApplicationLifetime>()!;
|
||||||
@@ -66,8 +64,6 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
await Task.Delay(3000, appLifetime.ApplicationStopping).ConfigureAwait(false);
|
await Task.Delay(3000, appLifetime.ApplicationStopping).ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
protected override async Task<AuthenticationTicket> CreateTicketAsync(
|
protected override async Task<AuthenticationTicket> CreateTicketAsync(
|
||||||
@@ -97,7 +93,6 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
identity.AddClaim(new Claim(ClaimConst.OrgId, RoleConst.DefaultTenantId.ToString()));
|
identity.AddClaim(new Claim(ClaimConst.OrgId, RoleConst.DefaultTenantId.ToString()));
|
||||||
identity.AddClaim(new Claim(ClaimConst.TenantId, RoleConst.DefaultTenantId.ToString()));
|
identity.AddClaim(new Claim(ClaimConst.TenantId, RoleConst.DefaultTenantId.ToString()));
|
||||||
|
|
||||||
|
|
||||||
var context = new OAuthCreatingTicketContext(
|
var context = new OAuthCreatingTicketContext(
|
||||||
new ClaimsPrincipal(identity),
|
new ClaimsPrincipal(identity),
|
||||||
properties,
|
properties,
|
||||||
@@ -143,10 +138,6 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
return new AuthenticationTicket(context.Principal, context.Properties, Scheme.Name);
|
return new AuthenticationTicket(context.Principal, context.Properties, Scheme.Name);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
private async Task<LoginEvent> GetLogin(int expire)
|
private async Task<LoginEvent> GetLogin(int expire)
|
||||||
{
|
{
|
||||||
var sysUser = await sysUserService.GetUserByIdAsync(RoleConst.SuperAdminId).ConfigureAwait(false);//获取用户信息
|
var sysUser = await sysUserService.GetUserByIdAsync(RoleConst.SuperAdminId).ConfigureAwait(false);//获取用户信息
|
||||||
@@ -174,7 +165,6 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
LoginTime = loginEvent.DateTime
|
LoginTime = loginEvent.DateTime
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
//添加到verificat列表
|
//添加到verificat列表
|
||||||
verificatInfoService.Add(verificatInfo);
|
verificatInfoService.Add(verificatInfo);
|
||||||
return loginEvent;
|
return loginEvent;
|
||||||
@@ -210,7 +200,7 @@ public class AdminOAuthHandler<TOptions>(
|
|||||||
|
|
||||||
using var db = DbContext.GetDB<SysUser>();
|
using var db = DbContext.GetDB<SysUser>();
|
||||||
//更新用户登录信息
|
//更新用户登录信息
|
||||||
if (await db.Updateable(sysUser).UpdateColumns(it => new
|
if (await db.UpdateableT(sysUser).UpdateColumns(it => new
|
||||||
{
|
{
|
||||||
it.LastLoginIp,
|
it.LastLoginIp,
|
||||||
it.LastLoginTime,
|
it.LastLoginTime,
|
||||||
|
@@ -34,7 +34,6 @@ public abstract class AdminOAuthOptions : OAuthOptions
|
|||||||
/// <summary>配置 Claims 映射</summary>
|
/// <summary>配置 Claims 映射</summary>
|
||||||
protected virtual void ConfigureClaims()
|
protected virtual void ConfigureClaims()
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public virtual string GetName(JsonElement element)
|
public virtual string GetName(JsonElement element)
|
||||||
@@ -46,8 +45,6 @@ public abstract class AdminOAuthOptions : OAuthOptions
|
|||||||
/// <summary>获得/设置 登陆后首页</summary>
|
/// <summary>获得/设置 登陆后首页</summary>
|
||||||
public string HomePath { get; set; } = "/";
|
public string HomePath { get; set; } = "/";
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>处理用户信息方法</summary>
|
/// <summary>处理用户信息方法</summary>
|
||||||
public virtual async Task<JsonElement> HandleUserInfoAsync(HttpContext context, OAuthTokenResponse tokens)
|
public virtual async Task<JsonElement> HandleUserInfoAsync(HttpContext context, OAuthTokenResponse tokens)
|
||||||
{
|
{
|
||||||
|
@@ -26,10 +26,7 @@ public class GiteeOAuthOptions : AdminOAuthOptions
|
|||||||
Scope.Add("user_info");
|
Scope.Add("user_info");
|
||||||
Scope.Add("projects");
|
Scope.Add("projects");
|
||||||
|
|
||||||
Events.OnCreatingTicket = async context =>
|
Events.OnCreatingTicket = async context => await HandlerGiteeStarredUrl(context).ConfigureAwait(false);
|
||||||
{
|
|
||||||
await HandlerGiteeStarredUrl(context).ConfigureAwait(false);
|
|
||||||
};
|
|
||||||
|
|
||||||
Events.OnRedirectToAuthorizationEndpoint = context =>
|
Events.OnRedirectToAuthorizationEndpoint = context =>
|
||||||
{
|
{
|
||||||
@@ -67,8 +64,6 @@ public class GiteeOAuthOptions : AdminOAuthOptions
|
|||||||
return OAuthTokenResponse.Failed(new OAuthTokenException($"OAuth token endpoint failure: {await Display(response).ConfigureAwait(false)}"));
|
return OAuthTokenResponse.Failed(new OAuthTokenException($"OAuth token endpoint failure: {await Display(response).ConfigureAwait(false)}"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public override string GetName(JsonElement element)
|
public override string GetName(JsonElement element)
|
||||||
{
|
{
|
||||||
JsonElement.ObjectEnumerator target = element.EnumerateObject();
|
JsonElement.ObjectEnumerator target = element.EnumerateObject();
|
||||||
@@ -109,8 +104,6 @@ public class GiteeOAuthOptions : AdminOAuthOptions
|
|||||||
});
|
});
|
||||||
//throw new Exception($"Failed to star repository: {response.StatusCode}, {content}");
|
//throw new Exception($"Failed to star repository: {response.StatusCode}, {content}");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
protected override void ConfigureClaims()
|
protected override void ConfigureClaims()
|
||||||
{
|
{
|
||||||
|
@@ -27,10 +27,7 @@ public class GitHubOAuthOptions : AdminOAuthOptions
|
|||||||
Scope.Add("read:user");
|
Scope.Add("read:user");
|
||||||
Scope.Add("public_repo"); // 需要用于 Star 仓库
|
Scope.Add("public_repo"); // 需要用于 Star 仓库
|
||||||
|
|
||||||
Events.OnCreatingTicket = async context =>
|
Events.OnCreatingTicket = async context => await HandleGitHubStarAsync(context).ConfigureAwait(false);
|
||||||
{
|
|
||||||
await HandleGitHubStarAsync(context).ConfigureAwait(false);
|
|
||||||
};
|
|
||||||
|
|
||||||
Events.OnRedirectToAuthorizationEndpoint = context =>
|
Events.OnRedirectToAuthorizationEndpoint = context =>
|
||||||
{
|
{
|
||||||
@@ -66,8 +63,6 @@ public class GitHubOAuthOptions : AdminOAuthOptions
|
|||||||
if (string.IsNullOrWhiteSpace(context.AccessToken))
|
if (string.IsNullOrWhiteSpace(context.AccessToken))
|
||||||
throw new InvalidOperationException("Access token is missing.");
|
throw new InvalidOperationException("Access token is missing.");
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
var request = new HttpRequestMessage(HttpMethod.Put, $"https://api.github.com/user/starred/{repoFullName}")
|
var request = new HttpRequestMessage(HttpMethod.Put, $"https://api.github.com/user/starred/{repoFullName}")
|
||||||
{
|
{
|
||||||
Headers =
|
Headers =
|
||||||
@@ -93,17 +88,12 @@ public class GitHubOAuthOptions : AdminOAuthOptions
|
|||||||
await Task.Delay(5000).ConfigureAwait(false);
|
await Task.Delay(5000).ConfigureAwait(false);
|
||||||
await _noticeService.NavigationMesage(verificatInfoIds.ClientIds, "https://github.com/ThingsGateway/ThingsGateway", "创作不易,如有帮助请star仓库").ConfigureAwait(false);
|
await _noticeService.NavigationMesage(verificatInfoIds.ClientIds, "https://github.com/ThingsGateway/ThingsGateway", "创作不易,如有帮助请star仓库").ConfigureAwait(false);
|
||||||
});
|
});
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>处理用户信息方法</summary>
|
/// <summary>处理用户信息方法</summary>
|
||||||
public override async Task<JsonElement> HandleUserInfoAsync(HttpContext context, OAuthTokenResponse tokens)
|
public override async Task<JsonElement> HandleUserInfoAsync(HttpContext context, OAuthTokenResponse tokens)
|
||||||
{
|
{
|
||||||
|
|
||||||
var request = new HttpRequestMessage(HttpMethod.Get, UserInformationEndpoint);
|
var request = new HttpRequestMessage(HttpMethod.Get, UserInformationEndpoint);
|
||||||
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", tokens.AccessToken);
|
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", tokens.AccessToken);
|
||||||
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/vnd.github+json"));
|
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/vnd.github+json"));
|
||||||
|
@@ -2,5 +2,4 @@
|
|||||||
|
|
||||||
public class GithubOAuthSettings : GiteeOAuthSettings
|
public class GithubOAuthSettings : GiteeOAuthSettings
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -12,10 +12,7 @@ using ThingsGateway.ConfigurableOptions;
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
public sealed class AdminLogOptions : IConfigurableOptions
|
public sealed class AdminLogOptions : IConfigurableOptions
|
||||||
{
|
{
|
||||||
|
|
||||||
public int OperateLogDaysAgo { get; set; }
|
public int OperateLogDaysAgo { get; set; }
|
||||||
|
|
||||||
}
|
}
|
@@ -12,7 +12,6 @@ using ThingsGateway.ConfigurableOptions;
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 邮件配置选项
|
/// 邮件配置选项
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -12,12 +12,10 @@ using ThingsGateway.ConfigurableOptions;
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
public sealed class TenantOptions : IConfigurableOptions
|
public sealed class TenantOptions : IConfigurableOptions
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 启用
|
/// 启用
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public bool Enable { get; set; }
|
public bool Enable { get; set; }
|
||||||
|
|
||||||
}
|
}
|
@@ -52,7 +52,6 @@ public class BlazorAuthenticationHandler : AppAuthorizeHandler
|
|||||||
{
|
{
|
||||||
await Fail(context).ConfigureAwait(false);// 授权失败
|
await Fail(context).ConfigureAwait(false);// 授权失败
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
static async Task Fail(AuthorizationHandlerContext context)
|
static async Task Fail(AuthorizationHandlerContext context)
|
||||||
{
|
{
|
||||||
@@ -263,15 +262,12 @@ public class BlazorAuthenticationHandler : AppAuthorizeHandler
|
|||||||
{
|
{
|
||||||
verificatInfo.VerificatTimeout = verificatInfo.VerificatTimeout.AddMinutes(verificatInfo.Expire); //新的过期时间
|
verificatInfo.VerificatTimeout = verificatInfo.VerificatTimeout.AddMinutes(verificatInfo.Expire); //新的过期时间
|
||||||
VerificatInfoService.Update(verificatInfo); //更新tokne信息到cache
|
VerificatInfoService.Update(verificatInfo); //更新tokne信息到cache
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
//无法在server中刷新cookies,单页面应用会一直保持登录状态,所以这里不需要刷新cookies,但是F5刷新后会重新登录
|
//无法在server中刷新cookies,单页面应用会一直保持登录状态,所以这里不需要刷新cookies,但是F5刷新后会重新登录
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
@@ -13,9 +13,7 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public class BlazorHybridAuthorizationHandler : BlazorAuthenticationHandler
|
public class BlazorHybridAuthorizationHandler : BlazorAuthenticationHandler
|
||||||
{
|
{
|
||||||
|
|
||||||
public BlazorHybridAuthorizationHandler(ISysUserService sysUserService, ISysRoleService sysRoleService, ISysDictService sysDictService) : base(sysUserService, sysRoleService, sysDictService)
|
public BlazorHybridAuthorizationHandler(ISysUserService sysUserService, ISysRoleService sysRoleService, ISysDictService sysDictService) : base(sysUserService, sysRoleService, sysDictService)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -57,8 +57,6 @@ public class UnifyResultProvider : IUnifyResultProvider
|
|||||||
return new JsonResult(RESTfulResult(StatusCodes.Status200OK, true, data));
|
return new JsonResult(RESTfulResult(StatusCodes.Status200OK, true, data));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 返回 RESTful 风格结果集
|
/// 返回 RESTful 风格结果集
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -95,6 +93,4 @@ public class UnifyResultProvider : IUnifyResultProvider
|
|||||||
return new JsonResult(RESTfulResult(metadata.StatusCode ?? StatusCodes.Status400BadRequest, data: metadata.Data, errors: metadata.ValidationResult) // 如果需要只显示第一条错误,修改为:errors: metadata.FirstErrorMessage
|
return new JsonResult(RESTfulResult(metadata.StatusCode ?? StatusCodes.Status400BadRequest, data: metadata.Data, errors: metadata.ValidationResult) // 如果需要只显示第一条错误,修改为:errors: metadata.FirstErrorMessage
|
||||||
, UnifyContext.GetSerializerSettings(context));
|
, UnifyContext.GetSerializerSettings(context));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -23,6 +23,4 @@ public class SysDictSeedData : ISqlSugarEntitySeedData<SysDict>
|
|||||||
var assembly = GetType().Assembly;
|
var assembly = GetType().Assembly;
|
||||||
return SeedDataUtil.GetSeedDataByJson<SysDict>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_dict.json")).Concat(data);
|
return SeedDataUtil.GetSeedDataByJson<SysDict>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_dict.json")).Concat(data);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -37,6 +37,5 @@ public class SysOrgSeedData : ISqlSugarEntitySeedData<SysOrg>
|
|||||||
SortCode=0
|
SortCode=0
|
||||||
}
|
}
|
||||||
}.Concat(SeedDataUtil.GetSeedDataByJson<SysOrg>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_org.json")).Concat(data));
|
}.Concat(SeedDataUtil.GetSeedDataByJson<SysOrg>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_org.json")).Concat(data));
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -36,6 +36,5 @@ public class SysPositionSeedData : ISqlSugarEntitySeedData<SysPosition>
|
|||||||
SortCode=0
|
SortCode=0
|
||||||
}
|
}
|
||||||
}.Concat(SeedDataUtil.GetSeedDataByJson<SysPosition>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_position.json")).Concat(data));
|
}.Concat(SeedDataUtil.GetSeedDataByJson<SysPosition>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_position.json")).Concat(data));
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -31,6 +31,5 @@ public class SysResourceSeedData : ISqlSugarEntitySeedData<SysResource>
|
|||||||
.Concat(data2)
|
.Concat(data2)
|
||||||
.Concat(data3)
|
.Concat(data3)
|
||||||
;
|
;
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -35,6 +35,4 @@ public class SysUserSeedData : ISqlSugarEntitySeedData<SysUser>
|
|||||||
}
|
}
|
||||||
}.Concat(SeedDataUtil.GetSeedDataByJson<SysUser>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_user.json"))).Concat(data);
|
}.Concat(SeedDataUtil.GetSeedDataByJson<SysUser>(SeedDataUtil.GetManifestResourceStream(assembly, "SeedData.Admin.seed_sys_user.json"))).Concat(data);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -8,7 +8,6 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
// ------------------------------------------------------------------------------
|
// ------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
|
||||||
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Authorization;
|
||||||
using Microsoft.AspNetCore.Mvc.ApiExplorer;
|
using Microsoft.AspNetCore.Mvc.ApiExplorer;
|
||||||
using Microsoft.AspNetCore.Mvc.Controllers;
|
using Microsoft.AspNetCore.Mvc.Controllers;
|
||||||
@@ -63,10 +62,8 @@ internal sealed class ApiPermissionService : IApiPermissionService
|
|||||||
|
|
||||||
//foreach (var groupOpenApi in groupOpenApis)
|
//foreach (var groupOpenApi in groupOpenApis)
|
||||||
{
|
{
|
||||||
|
|
||||||
foreach (var apiDescriptionGroup in apiDescriptions)
|
foreach (var apiDescriptionGroup in apiDescriptions)
|
||||||
{
|
{
|
||||||
|
|
||||||
var routes = apiDescriptionGroup.Items.Where(api => api.ActionDescriptor is ControllerActionDescriptor);
|
var routes = apiDescriptionGroup.Items.Where(api => api.ActionDescriptor is ControllerActionDescriptor);
|
||||||
|
|
||||||
Dictionary<string, OpenApiPermissionTreeSelector> openApiPermissionTreeSelectorDict = new();
|
Dictionary<string, OpenApiPermissionTreeSelector> openApiPermissionTreeSelectorDict = new();
|
||||||
@@ -80,7 +77,6 @@ internal sealed class ApiPermissionService : IApiPermissionService
|
|||||||
|
|
||||||
if (openApiPermissionTreeSelectorDict.TryGetValue(actionDesc.ControllerName, out var openApiControllerGroup))
|
if (openApiPermissionTreeSelectorDict.TryGetValue(actionDesc.ControllerName, out var openApiControllerGroup))
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -104,12 +100,9 @@ internal sealed class ApiPermissionService : IApiPermissionService
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
if (openApiPermissionTreeSelectorDict.Values.Any(a => a.Children.Count > 0))
|
if (openApiPermissionTreeSelectorDict.Values.Any(a => a.Children.Count > 0))
|
||||||
permissions.AddRange(openApiPermissionTreeSelectorDict.Values);
|
permissions.AddRange(openApiPermissionTreeSelectorDict.Values);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
App.CacheService.Set(cacheKey, permissions);
|
App.CacheService.Set(cacheKey, permissions);
|
||||||
@@ -117,7 +110,6 @@ internal sealed class ApiPermissionService : IApiPermissionService
|
|||||||
return permissions;
|
return permissions;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 获取路由地址名称
|
/// 获取路由地址名称
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -8,7 +8,6 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
// ------------------------------------------------------------------------------
|
// ------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
using ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
public interface IApiPermissionService
|
public interface IApiPermissionService
|
||||||
|
@@ -59,8 +59,6 @@ public class AppService : IAppService
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public async Task LoginAsync(ClaimsIdentity identity, int expire)
|
public async Task LoginAsync(ClaimsIdentity identity, int expire)
|
||||||
{
|
{
|
||||||
var diffTime = DateTime.Now + TimeSpan.FromMinutes(expire);
|
var diffTime = DateTime.Now + TimeSpan.FromMinutes(expire);
|
||||||
|
@@ -71,5 +71,4 @@ public class HybridAppService : IAppService
|
|||||||
User = new ClaimsPrincipal(claimsIdentity);
|
User = new ClaimsPrincipal(claimsIdentity);
|
||||||
return Task.CompletedTask;
|
return Task.CompletedTask;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -20,5 +20,4 @@ public class HybridClaimsPrincipalService : IClaimsPrincipalService
|
|||||||
_hybridAppService = hybridAppService;
|
_hybridAppService = hybridAppService;
|
||||||
}
|
}
|
||||||
public ClaimsPrincipal? User => _hybridAppService.User;
|
public ClaimsPrincipal? User => _hybridAppService.User;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -8,7 +8,6 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
|
||||||
using System.Security.Claims;
|
using System.Security.Claims;
|
||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
@@ -47,7 +46,4 @@ public interface IAppService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public Task LoginAsync(ClaimsIdentity claimsIdentity, int expire);
|
public Task LoginAsync(ClaimsIdentity claimsIdentity, int expire);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@@ -62,9 +62,6 @@ public class AuthService : IAuthService
|
|||||||
throw Oops.Bah(appConfig.WebsitePolicy.CloseTip);
|
throw Oops.Bah(appConfig.WebsitePolicy.CloseTip);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
string? password = input.Password;
|
string? password = input.Password;
|
||||||
if (isCookie) //openApi登录不再需要解密
|
if (isCookie) //openApi登录不再需要解密
|
||||||
{
|
{
|
||||||
@@ -325,7 +322,7 @@ public class AuthService : IAuthService
|
|||||||
|
|
||||||
using var db = DbContext.GetDB<SysUser>();
|
using var db = DbContext.GetDB<SysUser>();
|
||||||
//更新用户登录信息
|
//更新用户登录信息
|
||||||
if (await db.Updateable(sysUser).UpdateColumns(it => new
|
if (await db.UpdateableT(sysUser).UpdateColumns(it => new
|
||||||
{
|
{
|
||||||
it.LastLoginIp,
|
it.LastLoginIp,
|
||||||
it.LastLoginTime,
|
it.LastLoginTime,
|
||||||
|
@@ -31,7 +31,6 @@ public class OpenApiLoginInput
|
|||||||
[Required]
|
[Required]
|
||||||
public string Password { get; set; }
|
public string Password { get; set; }
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 租户Id
|
/// 租户Id
|
||||||
///</summary>
|
///</summary>
|
||||||
@@ -63,5 +62,4 @@ public class LoginInput
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
///<example>252885263003720</example>
|
///<example>252885263003720</example>
|
||||||
public long? TenantId { get; set; } = RoleConst.DefaultTenantId;
|
public long? TenantId { get; set; } = RoleConst.DefaultTenantId;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -58,7 +58,7 @@ public class LoginOutput
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 模块列表
|
/// 模块列表
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public IEnumerable<SysResource> ModuleList { get; set; } = Enumerable.Empty<SysResource>();
|
public IEnumerable<SysResource>? ModuleList { get; set; } = Enumerable.Empty<SysResource>();
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 刷新Token
|
/// 刷新Token
|
||||||
|
@@ -15,17 +15,17 @@ public class AppConfig
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 登录策略
|
/// 登录策略
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public LoginPolicy LoginPolicy { get; set; }
|
public LoginPolicy? LoginPolicy { get; set; }
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 页面策略
|
/// 页面策略
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public PagePolicy PagePolicy { get; set; }
|
public PagePolicy? PagePolicy { get; set; }
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 密码策略
|
/// 密码策略
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public PasswordPolicy PasswordPolicy { get; set; }
|
public PasswordPolicy? PasswordPolicy { get; set; }
|
||||||
|
|
||||||
public WebsitePolicy WebsitePolicy { get; set; }
|
public WebsitePolicy? WebsitePolicy { get; set; }
|
||||||
}
|
}
|
||||||
|
@@ -15,5 +15,5 @@ public class PagePolicy
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// 系统默认快捷方式菜单ID列表
|
/// 系统默认快捷方式菜单ID列表
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public List<long> Shortcuts { get; set; } = new();
|
public List<long>? Shortcuts { get; set; } = new();
|
||||||
}
|
}
|
||||||
|
@@ -60,7 +60,6 @@ public interface ISysDictService
|
|||||||
/// <returns>系统字典项</returns>
|
/// <returns>系统字典项</returns>
|
||||||
Task<SysDict> GetByKeyAsync(string category, string name);
|
Task<SysDict> GetByKeyAsync(string category, string name);
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 从缓存/数据库获取自定义配置列表
|
/// 从缓存/数据库获取自定义配置列表
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -245,7 +245,6 @@ internal sealed class SysDictService : BaseService<SysDict>, ISysDictService
|
|||||||
return sysDicts;
|
return sysDicts;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 从缓存/数据库获取系统配置列表
|
/// 从缓存/数据库获取系统配置列表
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -264,7 +263,6 @@ internal sealed class SysDictService : BaseService<SysDict>, ISysDictService
|
|||||||
return sysDicts;
|
return sysDicts;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 表格查询
|
/// 表格查询
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -301,7 +299,6 @@ internal sealed class SysDictService : BaseService<SysDict>, ISysDictService
|
|||||||
/// <param name="input">配置项</param>
|
/// <param name="input">配置项</param>
|
||||||
private async Task CheckInput(SysDict input)
|
private async Task CheckInput(SysDict input)
|
||||||
{
|
{
|
||||||
|
|
||||||
//设置类型为业务
|
//设置类型为业务
|
||||||
input.DictType = DictTypeEnum.Define;
|
input.DictType = DictTypeEnum.Define;
|
||||||
|
|
||||||
@@ -313,7 +310,6 @@ internal sealed class SysDictService : BaseService<SysDict>, ISysDictService
|
|||||||
{
|
{
|
||||||
throw Oops.Bah(Localizer["DictDup", input.Category, input.Name]);
|
throw Oops.Bah(Localizer["DictDup", input.Category, input.Name]);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -328,6 +324,5 @@ internal sealed class SysDictService : BaseService<SysDict>, ISysDictService
|
|||||||
App.CacheService.Remove($"{CacheConst.Cache_SysDict}{define}{nameof(AppConfig)}");
|
App.CacheService.Remove($"{CacheConst.Cache_SysDict}{define}{nameof(AppConfig)}");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
#endregion 方法
|
#endregion 方法
|
||||||
}
|
}
|
||||||
|
@@ -25,7 +25,6 @@ internal sealed class FileService : IFileService
|
|||||||
IStringLocalizer<FileService> localizer)
|
IStringLocalizer<FileService> localizer)
|
||||||
{
|
{
|
||||||
_localizer = localizer;
|
_localizer = localizer;
|
||||||
|
|
||||||
}
|
}
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 获取本地存储文件流
|
/// 获取本地存储文件流
|
||||||
@@ -88,8 +87,4 @@ internal sealed class FileService : IFileService
|
|||||||
string[] allowTypeS = allowTypes == null ? ["xlsx"] : allowTypes;//允许上传的文件类型
|
string[] allowTypeS = allowTypes == null ? ["xlsx"] : allowTypes;//允许上传的文件类型
|
||||||
if (!allowTypeS.Contains(fileSuffix)) throw Oops.Bah(_localizer["FileTypeError", fileSuffix]);
|
if (!allowTypeS.Contains(fileSuffix)) throw Oops.Bah(_localizer["FileTypeError", fileSuffix]);
|
||||||
}
|
}
|
||||||
|
|
||||||
#region 方法
|
|
||||||
|
|
||||||
#endregion 方法
|
|
||||||
}
|
}
|
||||||
|
@@ -37,7 +37,6 @@ internal sealed class ImportExportService : IImportExportService
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public async Task<FileStreamResult> ExportAsync<T>(object input, string fileName, bool isDynamicExcelColumn = true) where T : class
|
public async Task<FileStreamResult> ExportAsync<T>(object input, string fileName, bool isDynamicExcelColumn = true) where T : class
|
||||||
{
|
{
|
||||||
|
|
||||||
var path = ImportExportUtil.GetFileDir(ref fileName);
|
var path = ImportExportUtil.GetFileDir(ref fileName);
|
||||||
|
|
||||||
fileName = CommonUtils.GetSingleId() + fileName;
|
fileName = CommonUtils.GetSingleId() + fileName;
|
||||||
@@ -95,7 +94,5 @@ internal sealed class ImportExportService : IImportExportService
|
|||||||
return fileName;
|
return fileName;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#endregion 方法
|
#endregion 方法
|
||||||
}
|
}
|
||||||
|
@@ -24,7 +24,6 @@ internal sealed class NoticeService : INoticeService
|
|||||||
NavigationMesageDispatchService = navigationMesageDispatchService;
|
NavigationMesageDispatchService = navigationMesageDispatchService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public async Task NewMesage(IEnumerable<string>? clientIds, AppMessage message)
|
public async Task NewMesage(IEnumerable<string>? clientIds, AppMessage message)
|
||||||
{
|
{
|
||||||
@@ -51,8 +50,6 @@ internal sealed class NoticeService : INoticeService
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public async Task NavigationMesage(IEnumerable<string>? clientIds, string uri, string message)
|
public async Task NavigationMesage(IEnumerable<string>? clientIds, string uri, string message)
|
||||||
{
|
{
|
||||||
|
@@ -32,5 +32,4 @@ public interface ISysHub
|
|||||||
/// <param name="message">消息内容</param>
|
/// <param name="message">消息内容</param>
|
||||||
/// <returns>异步操作结果</returns>
|
/// <returns>异步操作结果</returns>
|
||||||
Task NewMesage(AppMessage message);
|
Task NewMesage(AppMessage message);
|
||||||
|
|
||||||
}
|
}
|
@@ -63,5 +63,4 @@ public class SysHub : Hub<ISysHub>
|
|||||||
VerificatInfoUtil.UpdateVerificat(userIdentifier, VerificatId, false);//更新cache
|
VerificatInfoUtil.UpdateVerificat(userIdentifier, VerificatId, false);//更新cache
|
||||||
return base.OnDisconnectedAsync(exception);
|
return base.OnDisconnectedAsync(exception);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
@@ -14,7 +14,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
|
|
||||||
internal sealed class SysOperateLogService : BaseService<SysOperateLog>, ISysOperateLogService
|
internal sealed class SysOperateLogService : BaseService<SysOperateLog>, ISysOperateLogService
|
||||||
{
|
{
|
||||||
|
|
||||||
#region 查询
|
#region 查询
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -86,6 +85,4 @@ internal sealed class SysOperateLogService : BaseService<SysOperateLog>, ISysOpe
|
|||||||
|
|
||||||
#endregion 删除
|
#endregion 删除
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -55,7 +55,6 @@ public interface ISysOrgService
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
Task<HashSet<long>> GetOrgChildIdsAsync(long orgId, bool isContainOneself = true, List<SysOrg> sysOrgList = null);
|
Task<HashSet<long>> GetOrgChildIdsAsync(long orgId, bool isContainOneself = true, List<SysOrg> sysOrgList = null);
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 根据组织ID获取租户ID
|
/// 根据组织ID获取租户ID
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -122,26 +122,25 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
{
|
{
|
||||||
throw new(result.ErrorMessage, result.ErrorException);
|
throw new(result.ErrorMessage, result.ErrorException);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
[OperDesc("DeleteOrg")]
|
[OperDesc("DeleteOrg")]
|
||||||
public async Task<bool> DeleteOrgAsync(IEnumerable<long> ids)
|
public async Task<bool> DeleteOrgAsync(IEnumerable<long> ids)
|
||||||
{
|
{
|
||||||
|
var sysDeleteOrgList = new List<long>();//需要删除的组织ID集合
|
||||||
|
var sysOrgList = await GetAllAsync().ConfigureAwait(false);//获取所有组织
|
||||||
|
foreach (var it in ids)
|
||||||
|
{
|
||||||
|
var children = SysOrgService.GetSysOrgChildren(sysOrgList, it);//查找下级组织
|
||||||
|
sysDeleteOrgList.AddRange(children.Select(it => it.Id).ToList());
|
||||||
|
sysDeleteOrgList.Add(it);
|
||||||
|
}
|
||||||
//获取所有ID
|
//获取所有ID
|
||||||
if (ids.Any())
|
if (sysDeleteOrgList.Count != 0)
|
||||||
{
|
{
|
||||||
using var db = GetDB();
|
using var db = GetDB();
|
||||||
var sysOrgList = await GetAllAsync().ConfigureAwait(false);//获取所有组织
|
|
||||||
var sysDeleteOrgList = new List<long>();//需要删除的组织ID集合
|
|
||||||
foreach (var it in ids)
|
|
||||||
{
|
|
||||||
var children = SysOrgService.GetSysOrgChildren(sysOrgList, it);//查找下级组织
|
|
||||||
sysDeleteOrgList.AddRange(children.Select(it => it.Id).ToList());
|
|
||||||
sysDeleteOrgList.Add(it);
|
|
||||||
}
|
|
||||||
//如果组织下有用户则不能删除
|
//如果组织下有用户则不能删除
|
||||||
if (await db.Queryable<SysUser>().AnyAsync(it => sysDeleteOrgList.Contains(it.OrgId)).ConfigureAwait(false))
|
if (await db.Queryable<SysUser>().AnyAsync(it => sysDeleteOrgList.Contains(it.OrgId)).ConfigureAwait(false))
|
||||||
{
|
{
|
||||||
@@ -165,10 +164,8 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 从缓存/数据库获取系统配置列表
|
/// 从缓存/数据库获取系统配置列表
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -243,7 +240,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
return reuslt;
|
return reuslt;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public async Task<HashSet<long>> GetOrgChildIdsAsync(long orgId, bool isContainOneself = true, List<SysOrg> sysOrgList = null)
|
public async Task<HashSet<long>> GetOrgChildIdsAsync(long orgId, bool isContainOneself = true, List<SysOrg> sysOrgList = null)
|
||||||
{
|
{
|
||||||
@@ -273,8 +269,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
return childList;
|
return childList;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public async Task<List<SysOrg>> GetTenantListAsync()
|
public async Task<List<SysOrg>> GetTenantListAsync()
|
||||||
{
|
{
|
||||||
@@ -380,7 +374,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 获取组织所有下级
|
/// 获取组织所有下级
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -405,7 +398,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
return new List<SysOrg>();
|
return new List<SysOrg>();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 重新生成组织实体
|
/// 重新生成组织实体
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -425,7 +417,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
private async Task CheckInput(SysOrg input)
|
private async Task CheckInput(SysOrg input)
|
||||||
{
|
{
|
||||||
|
|
||||||
if (!(await SysUserService.GetUserByIdAsync(UserManager.UserId).ConfigureAwait(false)).IsGlobal)
|
if (!(await SysUserService.GetUserByIdAsync(UserManager.UserId).ConfigureAwait(false)).IsGlobal)
|
||||||
{
|
{
|
||||||
if (input.ParentId == 0)
|
if (input.ParentId == 0)
|
||||||
@@ -467,8 +458,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 刷新缓存
|
/// 刷新缓存
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -483,7 +472,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
_dispatchService.Dispatch(null);
|
_dispatchService.Dispatch(null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 获取全称
|
/// 获取全称
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -506,7 +494,6 @@ internal sealed class SysOrgService : BaseService<SysOrg>, ISysOrgService
|
|||||||
return parentIdList;
|
return parentIdList;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
private static List<SysOrg> GetOrgParents(List<SysOrg> allOrgList, long orgId, bool includeSelf = true)
|
private static List<SysOrg> GetOrgParents(List<SysOrg> allOrgList, long orgId, bool includeSelf = true)
|
||||||
{
|
{
|
||||||
|
@@ -10,9 +10,6 @@
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public class PositionSelectorInput : UserSelectorInput
|
public class PositionSelectorInput : UserSelectorInput
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
@@ -10,7 +10,6 @@
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
public class PositionTreeOutput
|
public class PositionTreeOutput
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -34,7 +33,6 @@ public class PositionTreeOutput
|
|||||||
public List<PositionTreeOutput> Children { get; set; } = new List<PositionTreeOutput>();
|
public List<PositionTreeOutput> Children { get; set; } = new List<PositionTreeOutput>();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public class PositionSelectorOutput
|
public class PositionSelectorOutput
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@@ -62,8 +62,6 @@ public interface ISysPositionService
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
Task<List<PositionSelectorOutput>> SelectorAsync(PositionSelectorInput input);
|
Task<List<PositionSelectorOutput>> SelectorAsync(PositionSelectorInput input);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -75,7 +75,7 @@ public class SysPositionService : BaseService<SysPosition>, ISysPositionService
|
|||||||
}
|
}
|
||||||
|
|
||||||
var dels = (await GetAllAsync().ConfigureAwait(false)).Where(a => ids.Contains(a.Id));
|
var dels = (await GetAllAsync().ConfigureAwait(false)).Where(a => ids.Contains(a.Id));
|
||||||
await SysUserService.CheckApiDataScopeAsync(dels.Select(a => a.OrgId).ToList(), dels.Select(a => a.CreateUserId).ToList()).ConfigureAwait(false);
|
await SysUserService.CheckApiDataScopeAsync(dels.Select(a => a.OrgId), dels.Select(a => a.CreateUserId)).ConfigureAwait(false);
|
||||||
//删除职位
|
//删除职位
|
||||||
var result = await base.DeleteAsync(ids).ConfigureAwait(false);
|
var result = await base.DeleteAsync(ids).ConfigureAwait(false);
|
||||||
if (result)
|
if (result)
|
||||||
@@ -86,7 +86,6 @@ public class SysPositionService : BaseService<SysPosition>, ISysPositionService
|
|||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -280,6 +279,4 @@ public class SysPositionService : BaseService<SysPosition>, ISysPositionService
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -137,7 +137,7 @@ internal sealed class RelationService : BaseService<SysRelation>, IRelationServi
|
|||||||
{
|
{
|
||||||
if (clear)
|
if (clear)
|
||||||
await db.Deleteable<SysRelation>().Where(it => it.ObjectId == objectId && it.Category == category).ExecuteCommandAsync().ConfigureAwait(false);//删除老的
|
await db.Deleteable<SysRelation>().Where(it => it.ObjectId == objectId && it.Category == category).ExecuteCommandAsync().ConfigureAwait(false);//删除老的
|
||||||
await db.Insertable(sysRelation).ExecuteCommandAsync().ConfigureAwait(false);//添加新的
|
await db.InsertableT(sysRelation).ExecuteCommandAsync().ConfigureAwait(false);//添加新的
|
||||||
}).ConfigureAwait(false);
|
}).ConfigureAwait(false);
|
||||||
if (result.IsSuccess)//如果成功了
|
if (result.IsSuccess)//如果成功了
|
||||||
{
|
{
|
||||||
|
@@ -29,8 +29,7 @@ public interface ISysResourceService
|
|||||||
/// <param name="resourceList">资源列表</param>
|
/// <param name="resourceList">资源列表</param>
|
||||||
/// <param name="parentId">父ID</param>
|
/// <param name="parentId">父ID</param>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
IEnumerable<SysResource> ConstructMenuTrees(IEnumerable<SysResource> resourceList, long parentId = 0);
|
IEnumerable<SysResource> ConstructMenuTrees(List<SysResource> resourceList, long parentId = 0);
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 复制资源到其他模块
|
/// 复制资源到其他模块
|
||||||
@@ -45,7 +44,7 @@ public interface ISysResourceService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="ids">id列表</param>
|
/// <param name="ids">id列表</param>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
Task<bool> DeleteResourceAsync(IEnumerable<long> ids);
|
Task<bool> DeleteResourceAsync(HashSet<long> ids);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 从缓存/数据库读取全部资源列表
|
/// 从缓存/数据库读取全部资源列表
|
||||||
|
@@ -63,7 +63,7 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
var resource = resourceList.First(a => a.Id == id);
|
var resource = resourceList.First(a => a.Id == id);
|
||||||
resource.ParentId = parentMenuId;
|
resource.ParentId = parentMenuId;
|
||||||
using var db = GetDB();
|
using var db = GetDB();
|
||||||
var result = await db.Updateable(resource).ExecuteCommandAsync().ConfigureAwait(false);
|
var result = await db.UpdateableT(resource).ExecuteCommandAsync().ConfigureAwait(false);
|
||||||
RefreshCache();//刷新缓存
|
RefreshCache();//刷新缓存
|
||||||
_relationService.RefreshCache(RelationCategoryEnum.RoleHasResource);//关系表刷新缓存
|
_relationService.RefreshCache(RelationCategoryEnum.RoleHasResource);//关系表刷新缓存
|
||||||
_relationService.RefreshCache(RelationCategoryEnum.UserHasResource);//关系表刷新缓存
|
_relationService.RefreshCache(RelationCategoryEnum.UserHasResource);//关系表刷新缓存
|
||||||
@@ -75,10 +75,10 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
/// <param name="ids">id列表</param>
|
/// <param name="ids">id列表</param>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
[OperDesc("DeleteResource")]
|
[OperDesc("DeleteResource")]
|
||||||
public async Task<bool> DeleteResourceAsync(IEnumerable<long> ids)
|
public async Task<bool> DeleteResourceAsync(HashSet<long> ids)
|
||||||
{
|
{
|
||||||
//删除
|
//删除
|
||||||
if (ids.Any())
|
if (ids.Count != 0)
|
||||||
{
|
{
|
||||||
//获取所有菜单和按钮
|
//获取所有菜单和按钮
|
||||||
var resourceList = await GetAllAsync().ConfigureAwait(false);
|
var resourceList = await GetAllAsync().ConfigureAwait(false);
|
||||||
@@ -86,10 +86,11 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
var delSysResources = resourceList.Where(it => ids.Contains(it.Id));
|
var delSysResources = resourceList.Where(it => ids.Contains(it.Id));
|
||||||
//找到要删除的模块
|
//找到要删除的模块
|
||||||
var delModules = resourceList.Where(a => a.Category == ResourceCategoryEnum.Module).Where(it => ids.Contains(it.Id));
|
var delModules = resourceList.Where(a => a.Category == ResourceCategoryEnum.Module).Where(it => ids.Contains(it.Id));
|
||||||
if (delModules.Any())
|
|
||||||
|
//获取模块下的所有列表
|
||||||
|
var delHashSet = delModules.Select(a => a.Id).ToHashSet();
|
||||||
|
if (delHashSet.Count != 0)
|
||||||
{
|
{
|
||||||
//获取模块下的所有列表
|
|
||||||
var delHashSet = delModules.Select(a => a.Id).ToHashSet();
|
|
||||||
var delModuleResources = resourceList.Where(it => delHashSet.Contains(it.Module));
|
var delModuleResources = resourceList.Where(it => delHashSet.Contains(it.Module));
|
||||||
delSysResources = delSysResources.Concat(delModuleResources).ToHashSet();
|
delSysResources = delSysResources.Concat(delModuleResources).ToHashSet();
|
||||||
}
|
}
|
||||||
@@ -195,7 +196,7 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
|
|
||||||
if (type == ItemChangedType.Add)
|
if (type == ItemChangedType.Add)
|
||||||
{
|
{
|
||||||
var result = await db.Insertable(input).ExecuteCommandAsync().ConfigureAwait(false);
|
var result = await db.InsertableT(input).ExecuteCommandAsync().ConfigureAwait(false);
|
||||||
RefreshCache();//刷新缓存
|
RefreshCache();//刷新缓存
|
||||||
return result > 0;
|
return result > 0;
|
||||||
}
|
}
|
||||||
@@ -220,7 +221,7 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
//事务
|
//事务
|
||||||
var result = await db.UseTranAsync(async () =>
|
var result = await db.UseTranAsync(async () =>
|
||||||
{
|
{
|
||||||
await db.Updateable(input).ExecuteCommandAsync().ConfigureAwait(false);//更新数据
|
await db.UpdateableT(input).ExecuteCommandAsync().ConfigureAwait(false);//更新数据
|
||||||
if (permissions.Count > 0)//如果权限列表大于0就更新
|
if (permissions.Count > 0)//如果权限列表大于0就更新
|
||||||
{
|
{
|
||||||
await db.Updateable(permissions).ExecuteCommandAsync().ConfigureAwait(false);//更新关系表
|
await db.Updateable(permissions).ExecuteCommandAsync().ConfigureAwait(false);//更新关系表
|
||||||
@@ -315,7 +316,6 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
|
|
||||||
#endregion 方法
|
#endregion 方法
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
private static List<SysResource> MenuTreesToSaveLevel(IEnumerable<SysResource> resourceList)
|
private static List<SysResource> MenuTreesToSaveLevel(IEnumerable<SysResource> resourceList)
|
||||||
{
|
{
|
||||||
@@ -345,24 +345,19 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
return flatList;
|
return flatList;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public IEnumerable<SysResource> ConstructMenuTrees(IEnumerable<SysResource> resourceList, long parentId = 0)
|
public IEnumerable<SysResource> ConstructMenuTrees(List<SysResource> resourceList, long parentId = 0)
|
||||||
{
|
{
|
||||||
//找下级资源ID列表
|
//找下级资源ID列表
|
||||||
var resources = resourceList.Where(it => it.ParentId == parentId).OrderBy(it => it.SortCode);
|
var resources = resourceList.Where(it => it.ParentId == parentId).OrderBy(it => it.SortCode);
|
||||||
if (resources.Any())//如果数量大于0
|
foreach (var item in resources)//遍历资源
|
||||||
{
|
{
|
||||||
foreach (var item in resources)//遍历资源
|
var children = ConstructMenuTrees(resourceList, item.Id).ToList();//添加子节点
|
||||||
{
|
item.Children = children.Count > 0 ? children : null;
|
||||||
var children = ConstructMenuTrees(resourceList, item.Id).ToList();//添加子节点
|
|
||||||
item.Children = children.Count > 0 ? children : null;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return resources;
|
return resources;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public IEnumerable<SysResource> GetMyParentResources(IEnumerable<SysResource> allMenuList, IEnumerable<SysResource> myMenus)
|
public IEnumerable<SysResource> GetMyParentResources(IEnumerable<SysResource> allMenuList, IEnumerable<SysResource> myMenus)
|
||||||
{
|
{
|
||||||
@@ -375,7 +370,6 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
return parentList;
|
return parentList;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public IEnumerable<SysResource> GetResourceChilden(IEnumerable<SysResource> resourceList, long parentId)
|
public IEnumerable<SysResource> GetResourceChilden(IEnumerable<SysResource> resourceList, long parentId)
|
||||||
{
|
{
|
||||||
@@ -392,6 +386,4 @@ internal sealed class SysResourceService : BaseService<SysResource>, ISysResourc
|
|||||||
.SelectMany(item => new List<SysResource> { item }.Concat(GetResourceParent(resourceList, item.ParentId)));
|
.SelectMany(item => new List<SysResource> { item }.Concat(GetResourceParent(resourceList, item.ParentId)));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -10,7 +10,6 @@
|
|||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
namespace ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 角色树输出参数
|
/// 角色树输出参数
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
@@ -30,7 +30,7 @@ public interface ISysRoleService
|
|||||||
/// 删除角色
|
/// 删除角色
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="ids">id列表</param>
|
/// <param name="ids">id列表</param>
|
||||||
Task<bool> DeleteRoleAsync(IEnumerable<long> ids);
|
Task<bool> DeleteRoleAsync(HashSet<long> ids);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 从缓存/数据库获取全部角色信息
|
/// 从缓存/数据库获取全部角色信息
|
||||||
@@ -43,7 +43,7 @@ public interface ISysRoleService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="input">角色id列表</param>
|
/// <param name="input">角色id列表</param>
|
||||||
/// <returns>角色列表</returns>
|
/// <returns>角色列表</returns>
|
||||||
Task<IEnumerable<SysRole>> GetRoleListByIdListAsync(IEnumerable<long> input);
|
Task<IEnumerable<SysRole>> GetRoleListByIdListAsync(HashSet<long> input);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 根据用户id获取角色列表
|
/// 根据用户id获取角色列表
|
||||||
|
@@ -61,42 +61,46 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
|
|
||||||
var topOrgList = sysOrgList.Where(it => it.ParentId == 0);//获取顶级机构
|
var topOrgList = sysOrgList.Where(it => it.ParentId == 0);//获取顶级机构
|
||||||
var globalRole = sysRoles.Where(it => it.Category == RoleCategoryEnum.Global);//获取全局角色
|
var globalRole = sysRoles.Where(it => it.Category == RoleCategoryEnum.Global);//获取全局角色
|
||||||
if (globalRole.Any())
|
var children = globalRole.Select(it => new RoleTreeOutput
|
||||||
{
|
{
|
||||||
result.Add(new RoleTreeOutput()
|
Id = it.Id,
|
||||||
{
|
Name = it.Name,
|
||||||
Id = CommonUtils.GetSingleId(),
|
IsRole = true
|
||||||
Name = Localizer["Global"],
|
}).ToList();
|
||||||
Children = globalRole.Select(it => new RoleTreeOutput
|
|
||||||
{
|
result.Add(new RoleTreeOutput()
|
||||||
Id = it.Id,
|
{
|
||||||
Name = it.Name,
|
Id = CommonUtils.GetSingleId(),
|
||||||
IsRole = true
|
Name = Localizer["Global"],
|
||||||
}).ToList()
|
Children = children
|
||||||
});//添加全局角色
|
});//添加全局角色
|
||||||
}
|
|
||||||
//遍历顶级机构
|
//遍历顶级机构
|
||||||
foreach (var org in topOrgList)
|
foreach (var org in topOrgList)
|
||||||
{
|
{
|
||||||
var childIds = await _sysOrgService.GetOrgChildIdsAsync(org.Id, true, sysOrgList).ConfigureAwait(false);//获取机构下的所有子级ID
|
var childIds = await _sysOrgService.GetOrgChildIdsAsync(org.Id, true, sysOrgList).ConfigureAwait(false);//获取机构下的所有子级ID
|
||||||
var childRoles = sysRoles.Where(it => it.OrgId != 0 && childIds.Contains(it.OrgId));//获取机构下的所有角色
|
var childRoles = sysRoles.Where(it => it.OrgId != 0 && childIds.Contains(it.OrgId));//获取机构下的所有角色
|
||||||
if (childRoles.Any())
|
|
||||||
|
List<RoleTreeOutput> childrenRoleTreeOutputs = new();
|
||||||
|
|
||||||
|
foreach (var it in childRoles)
|
||||||
|
{
|
||||||
|
childrenRoleTreeOutputs.Add(new RoleTreeOutput()
|
||||||
|
{
|
||||||
|
Id = it.Id,
|
||||||
|
Name = it.Name,
|
||||||
|
IsRole = true
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (childrenRoleTreeOutputs.Count > 0)
|
||||||
|
|
||||||
{
|
{
|
||||||
var roleTreeOutput = new RoleTreeOutput
|
var roleTreeOutput = new RoleTreeOutput
|
||||||
{
|
{
|
||||||
Id = org.Id,
|
Id = org.Id,
|
||||||
Name = org.Name,
|
Name = org.Name,
|
||||||
IsRole = false
|
IsRole = false,
|
||||||
|
Children = childrenRoleTreeOutputs
|
||||||
};//实例化角色树
|
};//实例化角色树
|
||||||
foreach (var it in childRoles)
|
|
||||||
{
|
|
||||||
roleTreeOutput.Children.Add(new RoleTreeOutput()
|
|
||||||
{
|
|
||||||
Id = it.Id,
|
|
||||||
Name = it.Name,
|
|
||||||
IsRole = true
|
|
||||||
});
|
|
||||||
}
|
|
||||||
result.Add(roleTreeOutput);
|
result.Add(roleTreeOutput);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -147,7 +151,7 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="input">角色id列表</param>
|
/// <param name="input">角色id列表</param>
|
||||||
/// <returns>角色列表</returns>
|
/// <returns>角色列表</returns>
|
||||||
public async Task<IEnumerable<SysRole>> GetRoleListByIdListAsync(IEnumerable<long> input)
|
public async Task<IEnumerable<SysRole>> GetRoleListByIdListAsync(HashSet<long> input)
|
||||||
{
|
{
|
||||||
var roles = await GetAllAsync().ConfigureAwait(false);
|
var roles = await GetAllAsync().ConfigureAwait(false);
|
||||||
var roleList = roles.Where(it => input.Contains(it.Id));
|
var roleList = roles.Where(it => input.Contains(it.Id));
|
||||||
@@ -162,19 +166,18 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="ids">id列表</param>
|
/// <param name="ids">id列表</param>
|
||||||
[OperDesc("DeleteRole")]
|
[OperDesc("DeleteRole")]
|
||||||
public async Task<bool> DeleteRoleAsync(IEnumerable<long> ids)
|
public async Task<bool> DeleteRoleAsync(HashSet<long> ids)
|
||||||
{
|
{
|
||||||
var sysRoles = await GetAllAsync().ConfigureAwait(false);//获取所有角色
|
var sysRoles = await GetAllAsync().ConfigureAwait(false);//获取所有角色
|
||||||
var hasSuperAdmin = sysRoles.Any(it => it.Id == RoleConst.SuperAdminRoleId && ids.Contains(it.Id));//判断是否有超级管理员
|
var hasSuperAdmin = sysRoles.Any(it => it.Id == RoleConst.SuperAdminRoleId && ids.Contains(it.Id));//判断是否有超级管理员
|
||||||
if (hasSuperAdmin)
|
if (hasSuperAdmin)
|
||||||
throw Oops.Bah(Localizer["CanotDeleteAdmin"]);
|
throw Oops.Bah(Localizer["CanotDeleteAdmin"]);
|
||||||
|
|
||||||
|
|
||||||
var dels = (await GetAllAsync().ConfigureAwait(false)).Where(a => ids.Contains(a.Id));
|
var dels = (await GetAllAsync().ConfigureAwait(false)).Where(a => ids.Contains(a.Id));
|
||||||
await SysUserService.CheckApiDataScopeAsync(dels.Select(a => a.OrgId).ToList(), dels.Select(a => a.CreateUserId).ToList()).ConfigureAwait(false);
|
await SysUserService.CheckApiDataScopeAsync(dels.Select(a => a.OrgId), dels.Select(a => a.CreateUserId)).ConfigureAwait(false);
|
||||||
|
|
||||||
//数据库是string所以这里转下
|
//数据库是string所以这里转下
|
||||||
var targetIds = ids.Select(it => it.ToString());
|
var targetIds = ids.Select(it => it.ToString()).ToList();
|
||||||
//定义删除的关系
|
//定义删除的关系
|
||||||
var delRelations = new List<RelationCategoryEnum> {
|
var delRelations = new List<RelationCategoryEnum> {
|
||||||
RelationCategoryEnum.RoleHasResource,
|
RelationCategoryEnum.RoleHasResource,
|
||||||
@@ -185,7 +188,7 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
//事务
|
//事务
|
||||||
var result = await db.UseTranAsync(async () =>
|
var result = await db.UseTranAsync(async () =>
|
||||||
{
|
{
|
||||||
await db.Deleteable<SysRole>().In(ids.ToList()).ExecuteCommandHasChangeAsync().ConfigureAwait(false);//删除
|
await db.Deleteable<SysRole>().In(ids).ExecuteCommandHasChangeAsync().ConfigureAwait(false);//删除
|
||||||
//删除关系表角色与资源关系,角色与权限关系
|
//删除关系表角色与资源关系,角色与权限关系
|
||||||
await db.Deleteable<SysRelation>(it => ids.Contains(it.ObjectId) && delRelations.Contains(it.Category)).ExecuteCommandAsync().ConfigureAwait(false);
|
await db.Deleteable<SysRelation>(it => ids.Contains(it.ObjectId) && delRelations.Contains(it.Category)).ExecuteCommandAsync().ConfigureAwait(false);
|
||||||
//删除关系表角色与用户关系
|
//删除关系表角色与用户关系
|
||||||
@@ -216,7 +219,6 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
[OperDesc("SaveRole")]
|
[OperDesc("SaveRole")]
|
||||||
public async Task<bool> SaveRoleAsync(SysRole input, ItemChangedType type)
|
public async Task<bool> SaveRoleAsync(SysRole input, ItemChangedType type)
|
||||||
{
|
{
|
||||||
|
|
||||||
await CheckInput(input).ConfigureAwait(false);//检查参数
|
await CheckInput(input).ConfigureAwait(false);//检查参数
|
||||||
|
|
||||||
if (type == ItemChangedType.Add)
|
if (type == ItemChangedType.Add)
|
||||||
@@ -244,8 +246,6 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
|
|
||||||
#region 授权
|
#region 授权
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#region 资源
|
#region 资源
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -321,7 +321,7 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
#region 角色权限处理.
|
#region 角色权限处理.
|
||||||
var defaultDataScope = sysRole.DefaultDataScope;//获取默认数据范围
|
var defaultDataScope = sysRole.DefaultDataScope;//获取默认数据范围
|
||||||
|
|
||||||
if (menusList.Any())
|
if (relationRoles.Count != 0)
|
||||||
{
|
{
|
||||||
//获取权限授权树
|
//获取权限授权树
|
||||||
var permissions = App.GetService<IApiPermissionService>().PermissionTreeSelector(menusList.Select(it => it.Href));
|
var permissions = App.GetService<IApiPermissionService>().PermissionTreeSelector(menusList.Select(it => it.Href));
|
||||||
@@ -424,7 +424,6 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
return relations.Select(it => it.ObjectId);
|
return relations.Select(it => it.ObjectId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 授权用户
|
/// 授权用户
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -467,7 +466,6 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
@@ -476,7 +474,6 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
App.CacheService.Remove(CacheConst.Cache_SysRole);//删除KEY
|
App.CacheService.Remove(CacheConst.Cache_SysRole);//删除KEY
|
||||||
|
|
||||||
_dispatchService.Dispatch(null);
|
_dispatchService.Dispatch(null);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#endregion 授权
|
#endregion 授权
|
||||||
@@ -517,10 +514,7 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
|
|||||||
//判断是否有相同的Code
|
//判断是否有相同的Code
|
||||||
if (sysRoles.Any(it => it.Code == sysRole.Code && it.Id != sysRole.Id))
|
if (sysRoles.Any(it => it.Code == sysRole.Code && it.Id != sysRole.Id))
|
||||||
throw Oops.Bah(Localizer["CodeDup", sysRole.Code]);
|
throw Oops.Bah(Localizer["CodeDup", sysRole.Code]);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
#endregion 方法
|
#endregion 方法
|
||||||
}
|
}
|
||||||
|
@@ -28,5 +28,4 @@ public class UserSelectorInput
|
|||||||
/// 角色ID
|
/// 角色ID
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public long RoleId { get; set; }
|
public long RoleId { get; set; }
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -58,7 +58,7 @@ public interface ISysUserService
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="ids">用户ID列表。</param>
|
/// <param name="ids">用户ID列表。</param>
|
||||||
/// <returns>是否删除成功。</returns>
|
/// <returns>是否删除成功。</returns>
|
||||||
Task<bool> DeleteUserAsync(IEnumerable<long> ids);
|
Task<bool> DeleteUserAsync(HashSet<long> ids);
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 从缓存中删除用户信息。
|
/// 从缓存中删除用户信息。
|
||||||
|
@@ -45,7 +45,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
_verificatInfoService = verificatInfoService;
|
_verificatInfoService = verificatInfoService;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
#region 数据范围相关
|
#region 数据范围相关
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
@@ -100,7 +99,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
return hasPermission;
|
return hasPermission;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public async Task<bool> CheckApiDataScopeAsync(IEnumerable<long> orgIds, IEnumerable<long> createUerIds, bool throwEnable = true)
|
public async Task<bool> CheckApiDataScopeAsync(IEnumerable<long> orgIds, IEnumerable<long> createUerIds, bool throwEnable = true)
|
||||||
{
|
{
|
||||||
var hasPermission = true;
|
var hasPermission = true;
|
||||||
@@ -127,7 +125,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
|
|
||||||
#region 查询
|
#region 查询
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
public async Task<SysUser?> GetUserByAccountAsync(string account, long? tenantId)
|
public async Task<SysUser?> GetUserByAccountAsync(string account, long? tenantId)
|
||||||
{
|
{
|
||||||
@@ -178,7 +175,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
var userId = App.CacheService.HashGetOne<long>(key, account);
|
var userId = App.CacheService.HashGetOne<long>(key, account);
|
||||||
if (userId == 0)
|
if (userId == 0)
|
||||||
{
|
{
|
||||||
|
|
||||||
//单查获取用户账号对应ID
|
//单查获取用户账号对应ID
|
||||||
using var db = GetDB();
|
using var db = GetDB();
|
||||||
userId = await db.Queryable<SysUser>()
|
userId = await db.Queryable<SysUser>()
|
||||||
@@ -272,7 +268,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
ApiUrl = it.Key,
|
ApiUrl = it.Key,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#endregion Razor页面权限
|
#endregion Razor页面权限
|
||||||
@@ -303,7 +298,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
ApiUrl = it.Key,
|
ApiUrl = it.Key,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#endregion API权限
|
#endregion API权限
|
||||||
@@ -352,7 +346,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
u.Phone = DESEncryption.Decrypt(u.Phone);//解密手机号
|
u.Phone = DESEncryption.Decrypt(u.Phone);//解密手机号
|
||||||
#pragma warning restore CS8625 // 无法将 null 字面量转换为非 null 的引用类型。
|
#pragma warning restore CS8625 // 无法将 null 字面量转换为非 null 的引用类型。
|
||||||
})).ConfigureAwait(false);
|
})).ConfigureAwait(false);
|
||||||
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -367,8 +360,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -470,7 +461,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
|
|
||||||
var sysUser = input;//实体转换
|
var sysUser = input;//实体转换
|
||||||
using var db = GetDB();
|
using var db = GetDB();
|
||||||
var result = await db.Updateable(sysUser).IgnoreColumns(it =>
|
var result = await db.UpdateableT(sysUser).IgnoreColumns(it =>
|
||||||
new
|
new
|
||||||
{
|
{
|
||||||
//忽略更新字段
|
//忽略更新字段
|
||||||
@@ -561,7 +552,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
var resources = await _sysResourceService.GetAllAsync().ConfigureAwait(false);
|
var resources = await _sysResourceService.GetAllAsync().ConfigureAwait(false);
|
||||||
var menusList = resources.Where(a => a.Category == ResourceCategoryEnum.Menu).Where(a => menuIds.Contains(a.Id));
|
var menusList = resources.Where(a => a.Category == ResourceCategoryEnum.Menu).Where(a => menuIds.Contains(a.Id));
|
||||||
|
|
||||||
|
|
||||||
#region 用户模块处理
|
#region 用户模块处理
|
||||||
|
|
||||||
//获取我的模块信息Id列表
|
//获取我的模块信息Id列表
|
||||||
@@ -597,7 +587,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
#region 用户权限处理.
|
#region 用户权限处理.
|
||||||
|
|
||||||
//获取菜单信息
|
//获取菜单信息
|
||||||
if (menusList.Any())
|
if (relationUsers.Count != 0)
|
||||||
{
|
{
|
||||||
//获取权限授权树
|
//获取权限授权树
|
||||||
var permissions = App.GetService<IApiPermissionService>().PermissionTreeSelector(menusList.Select(it => it.Href));
|
var permissions = App.GetService<IApiPermissionService>().PermissionTreeSelector(menusList.Select(it => it.Href));
|
||||||
@@ -652,7 +642,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
|
|
||||||
/// <inheritdoc/>
|
/// <inheritdoc/>
|
||||||
[OperDesc("DeleteUser")]
|
[OperDesc("DeleteUser")]
|
||||||
public async Task<bool> DeleteUserAsync(IEnumerable<long> ids)
|
public async Task<bool> DeleteUserAsync(HashSet<long> ids)
|
||||||
{
|
{
|
||||||
using var db = GetDB();
|
using var db = GetDB();
|
||||||
var containsSuperAdmin = await db.Queryable<SysUser>().Where(it => it.Id == RoleConst.SuperAdminId && 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);//判断是否有超管
|
||||||
@@ -682,14 +672,13 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
.ExecuteCommandAsync().ConfigureAwait(false);
|
.ExecuteCommandAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
//删除用户
|
//删除用户
|
||||||
await db.Deleteable<SysUser>().In(ids.ToList()).ExecuteCommandHasChangeAsync().ConfigureAwait(false);//删除
|
await db.Deleteable<SysUser>().In(ids).ExecuteCommandHasChangeAsync().ConfigureAwait(false);//删除
|
||||||
|
|
||||||
//删除关系表用户与资源关系,用户与权限关系,用户与角色关系
|
//删除关系表用户与资源关系,用户与权限关系,用户与角色关系
|
||||||
await db.Deleteable<SysRelation>(it => ids.Contains(it.ObjectId) && delRelations.Contains(it.Category)).ExecuteCommandAsync().ConfigureAwait(false);
|
await db.Deleteable<SysRelation>(it => ids.Contains(it.ObjectId) && delRelations.Contains(it.Category)).ExecuteCommandAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
//删除组织表主管信息
|
//删除组织表主管信息
|
||||||
await db.Deleteable<SysOrg>(it => ids.Contains(it.DirectorId.Value)).ExecuteCommandAsync().ConfigureAwait(false);
|
await db.Deleteable<SysOrg>(it => ids.Contains(it.DirectorId.Value)).ExecuteCommandAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
}).ConfigureAwait(false);
|
}).ConfigureAwait(false);
|
||||||
|
|
||||||
if (result.IsSuccess)//如果成功了
|
if (result.IsSuccess)//如果成功了
|
||||||
@@ -729,16 +718,16 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
public void DeleteUserFromCache(IEnumerable<long> ids)
|
public void DeleteUserFromCache(IEnumerable<long> ids)
|
||||||
{
|
{
|
||||||
var userIds = ids.Select(it => it.ToString()).ToArray();//id转string列表
|
var userIds = ids.Select(it => it.ToString()).ToArray();//id转string列表
|
||||||
var sysUsers = App.CacheService.HashGet<SysUser>(CacheConst.Cache_SysUser, userIds).Where(it => it != null);//获取用户列表
|
var sysUsers = App.CacheService.HashGet<SysUser>(CacheConst.Cache_SysUser, userIds);//获取用户列表
|
||||||
if (sysUsers.Any() == true)
|
if (sysUsers.Count != 0)
|
||||||
{
|
{
|
||||||
var accounts = sysUsers.Where(it => it != null).Select(it => it.Account).ToArray();//账号集合
|
var accounts = sysUsers.Where(it => it != null).Select(it => it.Account).ToArray();//账号集合
|
||||||
var phones = sysUsers.Select(it => it.Phone);//手机号集合
|
var phones = sysUsers.Select(it => it?.Phone);//手机号集合
|
||||||
|
|
||||||
if (sysUsers.Any(it => it.TenantId != null))//如果有租户id不是空的表示是多租户模式
|
if (sysUsers.Any(it => it?.TenantId != null))//如果有租户id不是空的表示是多租户模式
|
||||||
{
|
{
|
||||||
var userAccountKey = CacheConst.Cache_SysUserAccount;
|
var userAccountKey = CacheConst.Cache_SysUserAccount;
|
||||||
var tenantIds = sysUsers.Where(it => it.TenantId != null).Select(it => it.TenantId.Value).Distinct().ToArray();//租户id列表
|
var tenantIds = sysUsers.Where(it => it?.TenantId != null).Select(it => it.TenantId.Value).Distinct().ToArray();//租户id列表
|
||||||
foreach (var tenantId in tenantIds)
|
foreach (var tenantId in tenantIds)
|
||||||
{
|
{
|
||||||
userAccountKey = $"{userAccountKey}:{tenantId}";
|
userAccountKey = $"{userAccountKey}:{tenantId}";
|
||||||
@@ -752,8 +741,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
App.CacheService.HashDel<long>(CacheConst.Cache_SysUserAccount, accounts);
|
App.CacheService.HashDel<long>(CacheConst.Cache_SysUserAccount, accounts);
|
||||||
|
|
||||||
App.CacheService.HashDel<VerificatInfo>(CacheConst.Cache_Token, userIds.Select(it => it.ToString()).ToArray());
|
App.CacheService.HashDel<VerificatInfo>(CacheConst.Cache_Token, userIds.Select(it => it.ToString()).ToArray());
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -792,7 +779,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
/// <param name="sysUser"></param>
|
/// <param name="sysUser"></param>
|
||||||
private async Task CheckInput(SysUser sysUser)
|
private async Task CheckInput(SysUser sysUser)
|
||||||
{
|
{
|
||||||
|
|
||||||
var sysOrgList = await _sysOrgService.GetAllAsync().ConfigureAwait(false);//获取组织列表
|
var sysOrgList = await _sysOrgService.GetAllAsync().ConfigureAwait(false);//获取组织列表
|
||||||
var userOrg = sysOrgList.FirstOrDefault(it => it.Id == sysUser.OrgId);
|
var userOrg = sysOrgList.FirstOrDefault(it => it.Id == sysUser.OrgId);
|
||||||
if (userOrg == null)
|
if (userOrg == null)
|
||||||
@@ -885,8 +871,6 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
|
|||||||
sysUser.PermissionCodeList = permissionCodeList;
|
sysUser.PermissionCodeList = permissionCodeList;
|
||||||
sysUser.IsGlobal = roleCodeList.Any(a => a.Category == RoleCategoryEnum.Global);
|
sysUser.IsGlobal = roleCodeList.Any(a => a.Category == RoleCategoryEnum.Global);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
var sysOrgList = await _sysOrgService.GetAllAsync().ConfigureAwait(false);
|
var sysOrgList = await _sysOrgService.GetAllAsync().ConfigureAwait(false);
|
||||||
var scopeOrgChildList =
|
var scopeOrgChildList =
|
||||||
(await _sysOrgService.GetChildListByIdAsync(sysUser.OrgId, true, sysOrgList).ConfigureAwait(false)).Select(it => it.Id).ToHashSet();//获取所属机构的下级机构Id列表
|
(await _sysOrgService.GetChildListByIdAsync(sysUser.OrgId, true, sysOrgList).ConfigureAwait(false)).Select(it => it.Id).ToHashSet();//获取所属机构的下级机构Id列表
|
||||||
|
@@ -42,5 +42,4 @@ public class UpdatePasswordInput
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
[Required]
|
[Required]
|
||||||
public string ConfirmPassword { get; set; }
|
public string ConfirmPassword { get; set; }
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -6,6 +6,4 @@
|
|||||||
// Github源代码仓库:https://github.com/kimdiego2098/ThingsGateway
|
// Github源代码仓库:https://github.com/kimdiego2098/ThingsGateway
|
||||||
// 使用文档:https://thingsgateway.cn/
|
// 使用文档:https://thingsgateway.cn/
|
||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
namespace ThingsGateway.Admin.Application;
|
|
@@ -64,7 +64,6 @@ public class Startup : AppStartup
|
|||||||
|
|
||||||
services.AddSingleton(typeof(IEventService<>), typeof(EventService<>));
|
services.AddSingleton(typeof(IEventService<>), typeof(EventService<>));
|
||||||
|
|
||||||
|
|
||||||
#region 控制台美化
|
#region 控制台美化
|
||||||
|
|
||||||
services.AddConsoleFormatter(options =>
|
services.AddConsoleFormatter(options =>
|
||||||
@@ -153,7 +152,6 @@ public class Startup : AppStartup
|
|||||||
var fullName = Assembly.GetExecutingAssembly().FullName;//获取程序集全名
|
var fullName = Assembly.GetExecutingAssembly().FullName;//获取程序集全名
|
||||||
CodeFirstUtils.CodeFirst(fullName!);//CodeFirst
|
CodeFirstUtils.CodeFirst(fullName!);//CodeFirst
|
||||||
|
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
using var db = DbContext.GetDB<SysOperateLog>();
|
using var db = DbContext.GetDB<SysOperateLog>();
|
||||||
@@ -168,11 +166,8 @@ public class Startup : AppStartup
|
|||||||
}
|
}
|
||||||
catch { }
|
catch { }
|
||||||
|
|
||||||
|
|
||||||
//删除在线用户统计
|
//删除在线用户统计
|
||||||
var verificatInfoService = App.RootServices.GetService<IVerificatInfoService>();
|
var verificatInfoService = App.RootServices.GetService<IVerificatInfoService>();
|
||||||
verificatInfoService.RemoveAllClientId();
|
verificatInfoService.RemoveAllClientId();
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -33,11 +33,7 @@ namespace ThingsGateway.Admin.Application
|
|||||||
public UserAgent? Parse(string? userAgentString)
|
public UserAgent? Parse(string? userAgentString)
|
||||||
{
|
{
|
||||||
userAgentString = ((userAgentString?.Length > Settings.UaStringSizeLimit) ? userAgentString?.Trim().Substring(0, Settings.UaStringSizeLimit) : userAgentString?.Trim()) ?? "";
|
userAgentString = ((userAgentString?.Length > Settings.UaStringSizeLimit) ? userAgentString?.Trim().Substring(0, Settings.UaStringSizeLimit) : userAgentString?.Trim()) ?? "";
|
||||||
return MemoryCache.GetOrAdd(userAgentString, entry =>
|
return MemoryCache.GetOrAdd(userAgentString, entry => new UserAgent(Settings, userAgentString));
|
||||||
{
|
|
||||||
return new UserAgent(Settings, userAgentString);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -36,5 +36,4 @@ public static class ImportExportUtil
|
|||||||
|
|
||||||
return path;
|
return path;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -38,7 +38,6 @@ public class UserLoginOutEvent
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// verificat信息
|
/// verificat信息
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|
||||||
public List<string>? ClientIds { get; set; }
|
public List<string>? ClientIds { get; set; }
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@@ -37,6 +37,4 @@ public static class OpenApiUtil
|
|||||||
}
|
}
|
||||||
return trees;
|
return trees;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -24,8 +24,6 @@ public static class OrgUtil
|
|||||||
var data = items
|
var data = items
|
||||||
.Select((item, index) =>
|
.Select((item, index) =>
|
||||||
new SelectedItem(item.Id.ToString(), item.Name)
|
new SelectedItem(item.Id.ToString(), item.Name)
|
||||||
{
|
|
||||||
}
|
|
||||||
).ToList();
|
).ToList();
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
@@ -98,5 +96,4 @@ public static class OrgUtil
|
|||||||
}
|
}
|
||||||
return trees;
|
return trees;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -14,7 +14,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public static class PositionUtil
|
public static class PositionUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 构建树节点
|
/// 构建树节点
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -39,7 +38,6 @@ public static class PositionUtil
|
|||||||
return trees;
|
return trees;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public static List<CascaderItem> BuildCascaderItemList(IEnumerable<PositionSelectorOutput> sysresources)
|
public static List<CascaderItem> BuildCascaderItemList(IEnumerable<PositionSelectorOutput> sysresources)
|
||||||
{
|
{
|
||||||
if (sysresources == null) return null;
|
if (sysresources == null) return null;
|
||||||
@@ -60,6 +58,4 @@ public static class PositionUtil
|
|||||||
}
|
}
|
||||||
return trees;
|
return trees;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -14,8 +14,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public static class RoleUtil
|
public static class RoleUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 构建树节点
|
/// 构建树节点
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -41,6 +39,4 @@ public static class RoleUtil
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -14,7 +14,6 @@ namespace ThingsGateway.Admin.Application;
|
|||||||
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
[ThingsGateway.DependencyInjection.SuppressSniffer]
|
||||||
public static class UserUtil
|
public static class UserUtil
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 构造选择项,ID/TITLE
|
/// 构造选择项,ID/TITLE
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -25,11 +24,7 @@ public static class UserUtil
|
|||||||
var data = items
|
var data = items
|
||||||
.Select((item, index) =>
|
.Select((item, index) =>
|
||||||
new SelectedItem(item.Id.ToString(), item.Account)
|
new SelectedItem(item.Id.ToString(), item.Account)
|
||||||
{
|
|
||||||
}
|
|
||||||
).ToList();
|
).ToList();
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -58,5 +58,4 @@ public static class VerificatInfoUtil
|
|||||||
|
|
||||||
#endregion 更新
|
#endregion 更新
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -13,7 +13,6 @@ namespace ThingsGateway.Admin.Razor;
|
|||||||
[CascadingTypeParameter(nameof(TItem))]
|
[CascadingTypeParameter(nameof(TItem))]
|
||||||
public partial class AdminTable<TItem> where TItem : class, new()
|
public partial class AdminTable<TItem> where TItem : class, new()
|
||||||
{
|
{
|
||||||
|
|
||||||
/// <inheritdoc cref="Table{TItem}.DoubleClickToEdit"/>
|
/// <inheritdoc cref="Table{TItem}.DoubleClickToEdit"/>
|
||||||
[Parameter]
|
[Parameter]
|
||||||
public bool DoubleClickToEdit { get; set; } = false;
|
public bool DoubleClickToEdit { get; set; } = false;
|
||||||
@@ -27,7 +26,6 @@ public partial class AdminTable<TItem> where TItem : class, new()
|
|||||||
[Parameter]
|
[Parameter]
|
||||||
public Func<TItem, Task>? OnClickRowCallback { get; set; }
|
public Func<TItem, Task>? OnClickRowCallback { get; set; }
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc cref="Table{TItem}.AllowDragColumn"/>
|
/// <inheritdoc cref="Table{TItem}.AllowDragColumn"/>
|
||||||
[Parameter]
|
[Parameter]
|
||||||
public bool AllowDragColumn { get; set; } = false;
|
public bool AllowDragColumn { get; set; } = false;
|
||||||
@@ -134,7 +132,6 @@ public partial class AdminTable<TItem> where TItem : class, new()
|
|||||||
[Parameter]
|
[Parameter]
|
||||||
public Func<TItem> CreateItemCallback { get; set; }
|
public Func<TItem> CreateItemCallback { get; set; }
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc cref="Table{TItem}.IsPagination"/>
|
/// <inheritdoc cref="Table{TItem}.IsPagination"/>
|
||||||
[Parameter]
|
[Parameter]
|
||||||
public bool IsPagination { get; set; }
|
public bool IsPagination { get; set; }
|
||||||
@@ -337,7 +334,6 @@ public partial class AdminTable<TItem> where TItem : class, new()
|
|||||||
[Parameter]
|
[Parameter]
|
||||||
public bool ShowSearch { get; set; } = true;
|
public bool ShowSearch { get; set; } = true;
|
||||||
|
|
||||||
|
|
||||||
/// <inheritdoc cref="Table{TItem}.BeforeShowEditDialogCallback"/>
|
/// <inheritdoc cref="Table{TItem}.BeforeShowEditDialogCallback"/>
|
||||||
[Parameter]
|
[Parameter]
|
||||||
public Action<ITableEditDialogOption<TItem>>? BeforeShowEditDialogCallback { get; set; }
|
public Action<ITableEditDialogOption<TItem>>? BeforeShowEditDialogCallback { get; set; }
|
||||||
@@ -426,5 +422,4 @@ public partial class AdminTable<TItem> where TItem : class, new()
|
|||||||
var url = NavigationManager.ToBaseRelativePath(NavigationManager.Uri);
|
var url = NavigationManager.ToBaseRelativePath(NavigationManager.Uri);
|
||||||
return AppContext.IsHasButtonWithRole(url, operate);
|
return AppContext.IsHasButtonWithRole(url, operate);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -42,7 +42,6 @@ public partial class ChoiceModuleComponent
|
|||||||
await OnClick.Invoke(tabItem.Url.ToLong());
|
await OnClick.Invoke(tabItem.Url.ToLong());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private List<RibbonTabItem> GenerateRibbonTabs()
|
private List<RibbonTabItem> GenerateRibbonTabs()
|
||||||
{
|
{
|
||||||
var tabs = new List<RibbonTabItem>(ModuleList?.Count ?? 1);
|
var tabs = new List<RibbonTabItem>(ModuleList?.Count ?? 1);
|
||||||
@@ -53,6 +52,4 @@ public partial class ChoiceModuleComponent
|
|||||||
}
|
}
|
||||||
return tabs;
|
return tabs;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -31,12 +31,13 @@ public partial class ChoiceTable<TItem> where TItem : class, new()
|
|||||||
|
|
||||||
public async Task OnAddAsync(IEnumerable<TItem> selectorOutputs)
|
public async Task OnAddAsync(IEnumerable<TItem> selectorOutputs)
|
||||||
{
|
{
|
||||||
if (MaxCount > 0 && selectorOutputs.Count() + SelectedRows.Count > MaxCount)
|
var data = selectorOutputs is IReadOnlyCollection<TItem> list ? list : selectorOutputs.ToList();
|
||||||
|
if (MaxCount > 0 && data.Count + SelectedRows.Count > MaxCount)
|
||||||
{
|
{
|
||||||
await ToastService.Warning(AdminLocalizer["MaxCount"]);
|
await ToastService.Warning(AdminLocalizer["MaxCount"]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
foreach (var item in selectorOutputs)
|
foreach (var item in data)
|
||||||
{
|
{
|
||||||
SelectedRows.Add(item);
|
SelectedRows.Add(item);
|
||||||
await table2.QueryAsync();
|
await table2.QueryAsync();
|
||||||
@@ -60,6 +61,4 @@ public partial class ChoiceTable<TItem> where TItem : class, new()
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -8,7 +8,6 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
|
||||||
using ThingsGateway.Admin.Application;
|
using ThingsGateway.Admin.Application;
|
||||||
|
|
||||||
namespace ThingsGateway.Admin.Razor;
|
namespace ThingsGateway.Admin.Razor;
|
||||||
@@ -59,10 +58,7 @@ public partial class LoginConnectionHub : ComponentBase, IDisposable
|
|||||||
else
|
else
|
||||||
await InvokeAsync(async () => await ToastService.Warning(message.Data));
|
await InvokeAsync(async () => await ToastService.Warning(message.Data));
|
||||||
});
|
});
|
||||||
NavigationUri.Subscribe(ClientId, async (message) =>
|
NavigationUri.Subscribe(ClientId, async (message) => await ShowMessage(message));
|
||||||
{
|
|
||||||
await ShowMessage(message);
|
|
||||||
});
|
|
||||||
VerificatInfoUtil.UpdateVerificat(ClientId, VerificatId, isConnect: true);
|
VerificatInfoUtil.UpdateVerificat(ClientId, VerificatId, isConnect: true);
|
||||||
}
|
}
|
||||||
catch (OperationCanceledException)
|
catch (OperationCanceledException)
|
||||||
@@ -88,12 +84,7 @@ public partial class LoginConnectionHub : ComponentBase, IDisposable
|
|||||||
ShowDismiss = true,
|
ShowDismiss = true,
|
||||||
IsAutoHide = false,
|
IsAutoHide = false,
|
||||||
ChildContent = RenderItem(navigationUri),
|
ChildContent = RenderItem(navigationUri),
|
||||||
OnDismiss = () =>
|
OnDismiss = () => Task.CompletedTask
|
||||||
{
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -8,8 +8,6 @@
|
|||||||
// QQ群:605534569
|
// QQ群:605534569
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
using Microsoft.AspNetCore.SignalR.Client;
|
using Microsoft.AspNetCore.SignalR.Client;
|
||||||
|
|
||||||
using System.Security.Claims;
|
using System.Security.Claims;
|
||||||
@@ -50,12 +48,9 @@ public partial class SysSignalRLoginConnectionHub : ComponentBase, IAsyncDisposa
|
|||||||
if (message is HttpClientHandler clientHandler)
|
if (message is HttpClientHandler clientHandler)
|
||||||
{
|
{
|
||||||
// 绕过SSL证书
|
// 绕过SSL证书
|
||||||
clientHandler.ServerCertificateCustomValidationCallback += (sender, certificate, chain, sslPolicyErrors) =>
|
clientHandler.ServerCertificateCustomValidationCallback += (sender, certificate, chain, sslPolicyErrors) => true;
|
||||||
{
|
|
||||||
return true;
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
;
|
|
||||||
return message;
|
return message;
|
||||||
};
|
};
|
||||||
foreach (var item in App.User?.Claims ?? new List<Claim>())
|
foreach (var item in App.User?.Claims ?? new List<Claim>())
|
||||||
@@ -80,16 +75,12 @@ public partial class SysSignalRLoginConnectionHub : ComponentBase, IAsyncDisposa
|
|||||||
await InvokeAsync(async () => await ToastService.Warning(message.Data));
|
await InvokeAsync(async () => await ToastService.Warning(message.Data));
|
||||||
});
|
});
|
||||||
|
|
||||||
_hubConnection.On<string, string>(nameof(ISysHub.NavigationMesage), async (url, message) =>
|
_hubConnection.On<string, string>(nameof(ISysHub.NavigationMesage), async (url, message) => await ShowMessage(new(url, message)));
|
||||||
{
|
|
||||||
await ShowMessage(new(url, message));
|
|
||||||
});
|
|
||||||
|
|
||||||
await _hubConnection.StartAsync();
|
await _hubConnection.StartAsync();
|
||||||
}
|
}
|
||||||
catch
|
catch
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
||||||
await base.OnAfterRenderAsync(firstRender);
|
await base.OnAfterRenderAsync(firstRender);
|
||||||
}
|
}
|
||||||
@@ -100,7 +91,6 @@ public partial class SysSignalRLoginConnectionHub : ComponentBase, IAsyncDisposa
|
|||||||
[Inject]
|
[Inject]
|
||||||
private MessageService MessageService { get; set; }
|
private MessageService MessageService { get; set; }
|
||||||
|
|
||||||
|
|
||||||
private async Task ShowMessage(NavigationUri navigationUri)
|
private async Task ShowMessage(NavigationUri navigationUri)
|
||||||
{
|
{
|
||||||
await MessageService.Show(new MessageOption()
|
await MessageService.Show(new MessageOption()
|
||||||
@@ -109,11 +99,7 @@ public partial class SysSignalRLoginConnectionHub : ComponentBase, IAsyncDisposa
|
|||||||
ShowDismiss = true,
|
ShowDismiss = true,
|
||||||
IsAutoHide = false,
|
IsAutoHide = false,
|
||||||
ChildContent = RenderItem(navigationUri),
|
ChildContent = RenderItem(navigationUri),
|
||||||
OnDismiss = () =>
|
OnDismiss = () => Task.CompletedTask
|
||||||
{
|
|
||||||
return Task.CompletedTask;
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -88,10 +88,7 @@ public class BlazorAppContext
|
|||||||
var sysResources = (await ResourceService.GetAllAsync()).AdaptListSysResource();
|
var sysResources = (await ResourceService.GetAllAsync()).AdaptListSysResource();
|
||||||
if (TitleLocalizer != null)
|
if (TitleLocalizer != null)
|
||||||
{
|
{
|
||||||
sysResources.ForEach(a =>
|
sysResources.ForEach(a => a.Title = TitleLocalizer[a.Title]);
|
||||||
{
|
|
||||||
a.Title = TitleLocalizer[a.Title];
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
AllResource = sysResources;
|
AllResource = sysResources;
|
||||||
var ids = CurrentUser.ModuleList.Select(a => a.Id).ToHashSet();
|
var ids = CurrentUser.ModuleList.Select(a => a.Id).ToHashSet();
|
||||||
@@ -109,9 +106,7 @@ public class BlazorAppContext
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
CurrentModuleId = CurrentUser.ModuleList.Select(a => a.Id).FirstOrDefault();
|
CurrentModuleId = CurrentUser.ModuleList.Select(a => a.Id).FirstOrDefault();
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
@@ -49,7 +49,5 @@ public partial class EditPagePolicy
|
|||||||
await Task.CompletedTask;
|
await Task.CompletedTask;
|
||||||
ShortcutsSearchText = searchText;
|
ShortcutsSearchText = searchText;
|
||||||
return ResourceUtil.BuildTreeItemList(AppContext.OwnMenus.WhereIf(!ShortcutsSearchText.IsNullOrEmpty(), a => a.Title.Contains(ShortcutsSearchText)), Model.Shortcuts, null);
|
return ResourceUtil.BuildTreeItemList(AppContext.OwnMenus.WhereIf(!ShortcutsSearchText.IsNullOrEmpty(), a => a.Title.Contains(ShortcutsSearchText)), Model.Shortcuts, null);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -22,7 +22,6 @@ public partial class SysDictPage
|
|||||||
|
|
||||||
#region 查询
|
#region 查询
|
||||||
|
|
||||||
|
|
||||||
private async Task<QueryData<SysDict>> OnQueryAsync(QueryPageOptions options)
|
private async Task<QueryData<SysDict>> OnQueryAsync(QueryPageOptions options)
|
||||||
{
|
{
|
||||||
var data = await SysDictService.PageAsync(options);
|
var data = await SysDictService.PageAsync(options);
|
||||||
|
@@ -24,7 +24,6 @@ public partial class OrgTree : IDisposable
|
|||||||
[NotNull]
|
[NotNull]
|
||||||
private List<TreeViewItem<SysOrg>> Items { get; set; }
|
private List<TreeViewItem<SysOrg>> Items { get; set; }
|
||||||
|
|
||||||
|
|
||||||
[Inject]
|
[Inject]
|
||||||
private IStringLocalizer<ThingsGateway.Admin.Razor._Imports> AdminLocalizer { get; set; }
|
private IStringLocalizer<ThingsGateway.Admin.Razor._Imports> AdminLocalizer { get; set; }
|
||||||
[Inject]
|
[Inject]
|
||||||
@@ -43,11 +42,10 @@ public partial class OrgTree : IDisposable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private List<TreeViewItem<SysOrg>> ZItem;
|
private List<TreeViewItem<SysOrg>> ZItem;
|
||||||
protected override async Task OnInitializedAsync()
|
protected override async Task OnInitializedAsync()
|
||||||
{
|
{
|
||||||
ZItem = new List<TreeViewItem<SysOrg>>() {new TreeViewItem<SysOrg>(new SysOrg(){ })
|
ZItem = new List<TreeViewItem<SysOrg>>() {new TreeViewItem<SysOrg>(new SysOrg())
|
||||||
{
|
{
|
||||||
Text = AdminLocalizer["All"],
|
Text = AdminLocalizer["All"],
|
||||||
IsActive = Value == 0,
|
IsActive = Value == 0,
|
||||||
@@ -67,10 +65,7 @@ public partial class OrgTree : IDisposable
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
ExecutionContext.Restore(context);
|
ExecutionContext.Restore(context);
|
||||||
await InvokeAsync(async () =>
|
await InvokeAsync(async () => await OnClickSearch(SearchText));
|
||||||
{
|
|
||||||
await OnClickSearch(SearchText);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
|
@@ -73,11 +73,9 @@ public partial class SysOrgPage
|
|||||||
{
|
{
|
||||||
[nameof(SysOrgCopy.SysOrgCopyInput)] = SysOrgCopyInput,
|
[nameof(SysOrgCopy.SysOrgCopyInput)] = SysOrgCopyInput,
|
||||||
}).Render(),
|
}).Render(),
|
||||||
|
|
||||||
};
|
};
|
||||||
SysOrgCopyInput.Ids = SelectedRows.Select(a => a.Id).ToList();
|
SysOrgCopyInput.Ids = SelectedRows.Select(a => a.Id).ToList();
|
||||||
await DialogService.Show(option);
|
await DialogService.Show(option);
|
||||||
|
|
||||||
}
|
}
|
||||||
private async Task<bool> Delete(IEnumerable<SysOrg> sysOrgs)
|
private async Task<bool> Delete(IEnumerable<SysOrg> sysOrgs)
|
||||||
{
|
{
|
||||||
|
@@ -66,10 +66,7 @@ public partial class PositionTree : IDisposable
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
ExecutionContext.Restore(context);
|
ExecutionContext.Restore(context);
|
||||||
await InvokeAsync(async () =>
|
await InvokeAsync(async () => await OnClickSearch(SearchText));
|
||||||
{
|
|
||||||
await OnClickSearch(SearchText);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
@@ -91,7 +88,6 @@ public partial class PositionTree : IDisposable
|
|||||||
var items = (await SysPositionService.TreeAsync());
|
var items = (await SysPositionService.TreeAsync());
|
||||||
items = items.WhereIF(!searchText.IsNullOrEmpty(), a => a.Name.Contains(searchText)).ToList();
|
items = items.WhereIF(!searchText.IsNullOrEmpty(), a => a.Name.Contains(searchText)).ToList();
|
||||||
return ZItem.Concat(PositionUtil.BuildTreeItemList(items, new List<long> { Value })).ToList();
|
return ZItem.Concat(PositionUtil.BuildTreeItemList(items, new List<long> { Value })).ToList();
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void Dispose()
|
public void Dispose()
|
||||||
|
@@ -79,7 +79,6 @@ public partial class MenuChoice
|
|||||||
|
|
||||||
[nameof(MenuChoiceDialog.ValueChanged)] = EventCallback.Factory.Create<long>(this, v => OnValueChanged(v))
|
[nameof(MenuChoiceDialog.ValueChanged)] = EventCallback.Factory.Create<long>(this, v => OnValueChanged(v))
|
||||||
}).Render(),
|
}).Render(),
|
||||||
|
|
||||||
};
|
};
|
||||||
await DialogService.Show(option);
|
await DialogService.Show(option);
|
||||||
}
|
}
|
||||||
|
@@ -74,7 +74,6 @@ public partial class SysResourcePage
|
|||||||
{
|
{
|
||||||
await ToastService.Warn(ex);
|
await ToastService.Warn(ex);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
private async Task OnChangeParent()
|
private async Task OnChangeParent()
|
||||||
{
|
{
|
||||||
@@ -88,14 +87,13 @@ public partial class SysResourcePage
|
|||||||
{
|
{
|
||||||
await ToastService.Warn(ex);
|
await ToastService.Warn(ex);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task<bool> Delete(IEnumerable<SysResource> sysResources)
|
private async Task<bool> Delete(IEnumerable<SysResource> sysResources)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var result = await SysResourceService.DeleteResourceAsync(sysResources.Select(a => a.Id));
|
var result = await SysResourceService.DeleteResourceAsync(sysResources.Select(a => a.Id).ToHashSet());
|
||||||
if (ReloadUser != null)
|
if (ReloadUser != null)
|
||||||
{
|
{
|
||||||
await ReloadUser();
|
await ReloadUser();
|
||||||
|
@@ -42,7 +42,6 @@ public partial class RoleTree : IDisposable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private List<TreeViewItem<RoleTreeOutput>> ZItem;
|
private List<TreeViewItem<RoleTreeOutput>> ZItem;
|
||||||
protected override async Task OnInitializedAsync()
|
protected override async Task OnInitializedAsync()
|
||||||
{
|
{
|
||||||
@@ -67,10 +66,7 @@ public partial class RoleTree : IDisposable
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
ExecutionContext.Restore(context);
|
ExecutionContext.Restore(context);
|
||||||
await InvokeAsync(async () =>
|
await InvokeAsync(async () => await OnClickSearch(SearchText));
|
||||||
{
|
|
||||||
await OnClickSearch(SearchText);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
|
@@ -15,11 +15,9 @@ namespace ThingsGateway.Admin.Razor;
|
|||||||
|
|
||||||
public partial class SysRoleEdit
|
public partial class SysRoleEdit
|
||||||
{
|
{
|
||||||
|
|
||||||
[Inject]
|
[Inject]
|
||||||
private IStringLocalizer<ThingsGateway.Admin.Razor._Imports>? AdminLocalizer { get; set; }
|
private IStringLocalizer<ThingsGateway.Admin.Razor._Imports>? AdminLocalizer { get; set; }
|
||||||
|
|
||||||
|
|
||||||
[Parameter]
|
[Parameter]
|
||||||
[NotNull]
|
[NotNull]
|
||||||
public SysRole? Model { get; set; }
|
public SysRole? Model { get; set; }
|
||||||
@@ -64,6 +62,4 @@ public partial class SysRoleEdit
|
|||||||
}
|
}
|
||||||
[NotNull]
|
[NotNull]
|
||||||
private List<TreeViewItem<long>> OrgItems { get; set; }
|
private List<TreeViewItem<long>> OrgItems { get; set; }
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user