Compare commits

...

163 Commits

Author SHA1 Message Date
2248356998 qq.com
c0337e2b19 build: 10.11.105
feat: json添加AllowNamedFloatingPointLiterals
2025-10-15 11:16:18 +08:00
2248356998 qq.com
8a95f48f5a 适配 net10 rc2 2025-10-15 10:02:11 +08:00
2248356998 qq.com
14f3c31265 build: 10.11.102 2025-10-14 22:22:06 +08:00
2248356998 qq.com
1bad65378f build: 10.11.101 2025-10-14 11:46:26 +08:00
2248356998 qq.com
db3affc67e build: 10.11.100
feat(VariablePage): 优化UI性能
2025-10-14 10:18:09 +08:00
2248356998 qq.com
5ee8b50a92 build: 10.11.99 2025-10-13 22:11:05 +08:00
2248356998 qq.com
301beda2a2 build: 10.11.98 2025-10-13 21:10:39 +08:00
2248356998 qq.com
628b51a353 build: 10.11.97 2025-10-12 15:15:42 +08:00
2248356998 qq.com
f03445bc83 更新依赖 2025-10-12 00:25:57 +08:00
2248356998 qq.com
55a2ff5487 build: 10.11.96 2025-10-11 13:38:28 +08:00
2248356998 qq.com
0fef7dcf3b 更新依赖 2025-10-10 21:41:24 +08:00
2248356998 qq.com
19d9702606 fix: sqlite 批量更新 2025-10-10 14:19:43 +08:00
2248356998 qq.com
a8a9774932 fix: orm 序列化 2025-10-10 12:26:35 +08:00
2248356998 qq.com
aad0f0e8c3 fix: orm批量插入 2025-10-10 11:19:14 +08:00
2248356998 qq.com
e74eae50a7 build: 10.11.87 2025-10-09 20:58:16 +08:00
2248356998 qq.com
3b16d7019f feat: 优化orm 批量插入 2025-10-09 20:57:18 +08:00
2248356998 qq.com
3e038028c2 feat: 优化orm 批量插入 2025-10-09 19:19:18 +08:00
2248356998 qq.com
b1d8041f7e feat: 优化orm BulkCopy 2025-10-09 19:05:33 +08:00
2248356998 qq.com
53a98b26cd fix: 数据库插件保留天数逻辑错误 2025-10-09 08:52:02 +08:00
2248356998 qq.com
42c740fa1b 更新依赖 2025-10-07 22:25:38 +08:00
2248356998 qq.com
556819c90c 10.11.83 2025-09-30 15:25:15 +08:00
2248356998 qq.com
2522333a9c 更新依赖 2025-09-29 23:16:34 +08:00
2248356998 qq.com
bd4ce7c09b 适配net10 2025-09-29 17:47:24 +08:00
2248356998 qq.com
156ed88bd6 10.11.80 2025-09-29 17:09:12 +08:00
2248356998 qq.com
2416226eb0 10.11.78 2025-09-28 17:01:19 +08:00
2248356998 qq.com
976323a716 适配net10 2025-09-28 13:06:39 +08:00
2248356998 qq.com
3c9e397403 10.11.76 2025-09-28 00:33:56 +08:00
2248356998 qq.com
79406ad4a0 更新依赖 2025-09-27 23:59:38 +08:00
2248356998 qq.com
20c44f10ca 10.11.73 2025-09-27 20:18:56 +08:00
2248356998 qq.com
31d6b2a9e6 添加FastMapper 2025-09-26 15:24:37 +08:00
2248356998 qq.com
68e5a9c546 build: 10.11.71 2025-09-26 11:51:05 +08:00
2248356998 qq.com
b2ea9f99b9 适配net10 2025-09-26 10:58:57 +08:00
2248356998 qq.com
6d7d0e468a fix: opcua连接状态 2025-09-24 11:03:23 +08:00
2248356998 qq.com
ff1f632de2 build: 10.11.67 sqldb插件 2025-09-23 22:38:05 +08:00
2248356998 qq.com
fc3d7015ee sqldb插件 清理数据cron表达式错误 2025-09-23 22:36:45 +08:00
2248356998 qq.com
40c5acb522 调整UI 2025-09-23 13:41:20 +08:00
2248356998 qq.com
f9cc1cbb05 10.11.65 2025-09-23 12:02:17 +08:00
2248356998 qq.com
cf6e8b58f0 更新内存变量 2025-09-23 01:22:02 +08:00
2248356998 qq.com
615e3bb24c 修改 脚本调试项目 依赖项 2025-09-22 14:58:03 +08:00
2248356998 qq.com
4a7534b210 添加 脚本调试项目 2025-09-22 10:36:28 +08:00
2248356998 qq.com
58e099cb93 10.11.58 2025-09-21 20:53:50 +08:00
2248356998 qq.com
a94a9c953c 10.11.57 2025-09-19 14:32:34 +08:00
Diego
35e1ffa3e9 添加文件 2025-09-18 17:54:29 +08:00
Diego
4921642151 10.11.56 2025-09-18 17:15:57 +08:00
2248356998 qq.com
d71ee29da8 10.11.54 2025-09-17 20:50:41 +08:00
2248356998 qq.com
901aa2d59f 10.11.52 2025-09-17 11:07:45 +08:00
2248356998 qq.com
764957c014 10.11.51 2025-09-16 22:19:01 +08:00
Diego
0e3898218b 10.11.44 2025-09-16 19:13:19 +08:00
Diego
61f13cef3c 10.11.43 2025-09-15 17:35:49 +08:00
2248356998 qq.com
0b663d9e01 fix: modbusRtu 0x10 2025-09-14 11:18:41 +08:00
2248356998 qq.com
6c95c6209f 10.11.41 2025-09-13 14:22:13 +08:00
2248356998 qq.com
4d223d2622 10.11.40 2025-09-13 13:00:52 +08:00
yunqi
e8d7e91b64 !74 modify dlt645_2007 buildcmd
* modify dlt645_2007 buildcmd
2025-09-13 04:59:10 +00:00
2248356998 qq.com
8175f541ec 更新基准测试 2025-09-12 23:53:36 +08:00
2248356998 qq.com
0adbdb926b 更新基准测试 2025-09-12 23:49:18 +08:00
Diego
42adee9980 更新依赖 2025-09-11 22:22:39 +08:00
2248356998 qq.com
427a7404bc 更新UI 2025-09-11 19:05:14 +08:00
2248356998 qq.com
3658199e0a 10.11.37 2025-09-11 18:30:49 +08:00
Diego
82eedee50a 更新依赖 2025-09-11 18:12:40 +08:00
2248356998 qq.com
6a18fc3e06 10.11.36 2025-09-10 12:59:54 +08:00
2248356998 qq.com
c37e314ed6 更新依赖 2025-09-09 21:53:39 +08:00
2248356998 qq.com
a937a85d90 添加项目 2025-09-08 21:51:37 +08:00
2248356998 qq.com
35dd4ae9d3 更新依赖 2025-09-08 21:27:49 +08:00
2248356998 qq.com
0b829ac85c 10.11.33 2025-09-08 21:16:37 +08:00
2248356998 qq.com
aa247422d2 10.11.31 2025-09-08 17:56:19 +08:00
2248356998 qq.com
2e00e8c135 更新依赖 2025-09-08 08:46:52 +08:00
2248356998 qq.com
34dd2cf0a7 更新依赖 2025-09-07 21:52:41 +08:00
2248356998 qq.com
8404e20c5e build: 10.11.27
refactor: 更新依赖
2025-09-06 23:34:32 +08:00
2248356998 qq.com
662aa162e9 fix: sugar无实体curd 2025-09-05 13:16:18 +08:00
2248356998 qq.com
5927738c32 10.11.25 2025-09-05 11:30:33 +08:00
2248356998 qq.com
3c9f97a5c3 10.11.24 2025-09-04 22:39:21 +08:00
2248356998 qq.com
179ca0aa0e build: 10.11.23
feat: 增加部分demo
feat: 增加管理软件桌面端
2025-09-03 17:40:19 +08:00
Diego
fc09a52da1 build: 10.11.22
refactor:性能优化
2025-09-02 11:13:54 +08:00
Diego
5436b91c89 10.11.21 2025-09-01 18:40:12 +08:00
Diego
d1c46f51a6 添加api接口 2025-09-01 16:00:53 +08:00
Diego
4539d8d198 fix: 字符串反转功能失效 2025-09-01 11:52:03 +08:00
2248356998 qq.com
9ea9529a5f 10.11.19 2025-08-29 15:43:02 +08:00
2248356998 qq.com
4e6be23aac 10.11.17 2025-08-28 17:15:08 +08:00
2248356998 qq.com
2fabbd236b 10.11.16 2025-08-28 17:05:00 +08:00
2248356998 qq.com
163a66530e fix: dlt645校验和 2025-08-28 17:04:27 +08:00
2248356998 qq.com
29073a00c4 fix: dtu连接注册包解析错误 2025-08-28 15:35:43 +08:00
2248356998 qq.com
c6d4d1ecfa fix: dtu连接注册包解析错误 2025-08-28 15:20:00 +08:00
2248356998 qq.com
ba16889cad 10.11.14 2025-08-28 14:21:58 +08:00
2248356998 qq.com
5aaed35b0f 10.11.12 2025-08-28 01:42:59 +08:00
Diego
df067c91eb 10.11.12 2025-08-28 01:39:39 +08:00
2248356998 qq.com
2078b4a60b 补充忽略的文件 2025-08-26 08:54:09 +08:00
2248356998 qq.com
20a2e3ff8e 示例 2025-08-25 20:39:26 +08:00
Diego
61a973b1b5 !73 10.11.10 2025-08-25 12:21:12 +00:00
2248356998 qq.com
cbd72e2081 添加文本日志配置json文件 2025-08-22 16:17:25 +08:00
2248356998 qq.com
4e0377b20c 添加文本日志配置json文件 2025-08-22 16:15:54 +08:00
2248356998 qq.com
fd318d3cdc 移除警告项 2025-08-22 16:12:14 +08:00
2248356998 qq.com
515bdb9700 10.11.7 2025-08-21 23:35:12 +08:00
2248356998 qq.com
46c1780017 10.11.6 2025-08-21 22:40:53 +08:00
2248356998 qq.com
fe78a4c3ca 更新依赖库 2025-08-21 22:05:30 +08:00
2248356998 qq.com
2d7effadf9 10.11.4 2025-08-21 21:13:18 +08:00
Diego
346c560f8b !72 更新依赖项 2025-08-21 11:46:58 +00:00
Diego
8e3bd89f61 修改编译项 2025-08-18 17:30:34 +08:00
Diego
6da142d080 10.10.23 2025-08-18 17:03:40 +08:00
2248356998 qq.com
ff7d029e6f 更新依赖 2025-08-14 20:25:00 +08:00
2248356998 qq.com
21b4695683 10.10.19 2025-08-14 05:47:54 +08:00
Diego
02ad494a26 !71 适配远程客户端 2025-08-12 16:00:53 +00:00
2248356998 qq.com
280366e1b2 添加写优先选项,默认false 2025-08-09 13:07:08 +08:00
2248356998 qq.com
6660ce3e34 适配远程管理客户端 2025-08-08 18:01:24 +08:00
2248356998 qq.com
7499162c1a 适配远程管理客户端 2025-08-08 02:51:42 +08:00
2248356998 qq.com
40208a5cd6 适配远程网关管理客户端 2025-08-08 02:16:05 +08:00
2248356998 qq.com
fa347f4f68 修改报警事件时间字段,增加变量表报警类 2025-08-07 19:19:36 +08:00
Diego
d7df6fc605 10.10.12 2025-08-07 11:24:57 +08:00
2248356998 qq.com
eb4bb2fd48 10.10.11 2025-08-07 10:19:28 +08:00
2248356998 qq.com
faa9858974 10.10.11 2025-08-07 10:18:22 +08:00
2248356998 qq.com
1b3d2dda49 QuestDbRestAPI 2025-08-07 10:11:37 +08:00
Diego
a8a9453611 !70 fix: questdb restapi多实例 2025-08-07 01:58:32 +00:00
2248356998 qq.com
e84f42ce14 10.10.10 2025-08-06 21:42:46 +08:00
2248356998 qq.com
6f814cf6b8 更新questdb restapi启用字段 2025-08-06 21:42:23 +08:00
2248356998 qq.com
e36432e4e9 10.10.9 2025-08-06 19:33:30 +08:00
Diego
ebd71e807b !69 更新依赖 2025-08-06 11:25:31 +00:00
Diego
34000d8d7d !68 10.10.7 2025-08-05 09:22:11 +00:00
2248356998 qq.com
e785f6660c 10.10.5 2025-08-01 21:53:47 +08:00
Diego
831c611797 10.10.4 2025-08-01 17:30:37 +08:00
Diego
453817ef86 添加IAsyncDisposable 2025-08-01 16:36:27 +08:00
2248356998 qq.com
8ce0b981c1 no message 2025-08-01 12:55:01 +08:00
2248356998 qq.com
4e5c51b54c 2025-08-01 12:47:21 +08:00
2248356998 qq.com
3cc9d31f28 修改可用内存策略 2025-08-01 12:43:39 +08:00
2248356998 qq.com
10391f869b 支持相对路径创建sqlite 2025-07-31 23:41:58 +08:00
Diego
fba0723a6d 更新依赖 2025-07-31 18:39:46 +08:00
Diego
2db3f78f0c 添加 控制写操作与读操作的比率 的插件配置属性 2025-07-31 18:18:41 +08:00
Diego
badf61fe01 10.9.99 2025-07-31 16:25:47 +08:00
Diego
d74e0952dc 10.9.98 2025-07-31 15:57:33 +08:00
Diego
fb1699ce80 10.9.97 2025-07-31 14:06:47 +08:00
Diego
44adddbcd4 10.9.97 2025-07-31 13:56:49 +08:00
Diego
0eab889452 10.9.97 2025-07-31 13:56:34 +08:00
Diego
e14d39a459 添加 rpc写入 多写日志 2025-07-31 12:52:40 +08:00
2248356998 qq.com
7575264ede 添加变量初始化标记 2025-07-31 00:40:03 +08:00
2248356998 qq.com
3e1a077b96 添加变量初始化标记 2025-07-31 00:30:53 +08:00
2248356998 qq.com
a921cb8400 refactor: 连接时判断setup 2025-07-30 23:27:35 +08:00
2248356998 qq.com
4de7c31ed7 10.9.92 2025-07-30 22:00:23 +08:00
2248356998 qq.com
08326a2cfd fix: 单属性验证异常 2025-07-30 21:11:35 +08:00
Diego
e045de5acb !67 更新依赖 2025-07-30 10:01:20 +00:00
2248356998 qq.com
d3bef31aa6 10.9.70 2025-07-30 04:32:14 +08:00
2248356998 qq.com
347d4d6e5d 10.9.69 2025-07-25 22:21:34 +08:00
2248356998 qq.com
b006a066e1 10.9.69 2025-07-25 22:14:06 +08:00
Diego
e331bc5d3c 10.9.68 2025-07-25 20:30:48 +08:00
Diego
2e81806231 优化 2025-07-25 20:20:35 +08:00
Diego
37b48cf221 BindField 2025-07-24 20:03:53 +08:00
Diego
5997487434 修改参数 2025-07-24 19:46:30 +08:00
Diego
4ce843182f build: 10.9.67
feat: 报警恢复增加延时功能
refactor: 移除通讯任务时,设置设备、变量离线状态

fix: 罗克韦尔PLC通讯超时错误
2025-07-24 13:25:55 +08:00
2248356998 qq.com
a4aa000cf0 10.9.66 2025-07-23 19:11:39 +08:00
Diego
01aa6ca066 10.9.65 2025-07-23 16:34:02 +08:00
Diego
10a0280c4a 10.9.64 2025-07-22 15:55:49 +08:00
Diego
3b8b00c783 变量类验证提示 2025-07-22 11:03:48 +08:00
Diego
232ee5d5d4 10.9.63 2025-07-22 01:17:12 +08:00
2248356998 qq.com
605830edce 10.9.62 2025-07-20 21:52:59 +08:00
2248356998 qq.com
ca86441e05 orm性能优化 2025-07-20 19:04:25 +08:00
2248356998 qq.com
b30b876c5f 更新依赖 2025-07-20 10:44:20 +08:00
2248356998 qq.com
f95590b4cb 修正拼写错误 2025-07-19 22:36:13 +08:00
2248356998 qq.com
9921130406 更新依赖 2025-07-19 21:38:19 +08:00
2248356998 qq.com
5c47589ca1 更新依赖 2025-07-19 21:31:46 +08:00
2248356998 qq.com
048abfae2e 添加可空标识 2025-07-19 13:35:55 +08:00
Diego
8e35c16edf 恢复restart标记 2025-07-18 17:46:56 +08:00
Diego
143b751213 Revert "build: 10.9.42"
This reverts commit 2cafe745b9.
2025-07-18 14:41:19 +08:00
Diego
2cafe745b9 build: 10.9.42
feat: 优化读写调度
feat: rpc日志添加执行时间字段
2025-07-18 09:48:41 +08:00
Diego
210ac2c122 更新解决方案 2025-07-18 00:02:38 +08:00
Diego
4707ce6d58 新增RemoteWebApp项目 2025-07-17 23:41:11 +08:00
2248356998 qq.com
788a8b670d 10.9.40 2025-07-16 21:18:14 +08:00
1738 changed files with 38880 additions and 25727 deletions

3
.gitignore vendored
View File

@@ -364,6 +364,5 @@ FodyWeavers.xsd
/src/*Pro*/ /src/*Pro*/
/src/*Pro* /src/*Pro*
/src/*pro*
/src/*pro*/
/src/ThingsGateway.Server/Configuration/GiteeOAuthSettings.json /src/ThingsGateway.Server/Configuration/GiteeOAuthSettings.json
/src/.idea/

View File

@@ -11,6 +11,7 @@
<IncludeBuildOutput>false</IncludeBuildOutput> <IncludeBuildOutput>false</IncludeBuildOutput>
<!-- 避免 DLL 被打包到 lib/ --> <!-- 避免 DLL 被打包到 lib/ -->
<EnableSourceGenerator>true</EnableSourceGenerator> <EnableSourceGenerator>true</EnableSourceGenerator>
<!-- 可选 --> <!-- 可选 -->
@@ -26,6 +27,6 @@
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="Microsoft.CodeAnalysis.CSharp" Version="4.13.0" PrivateAssets="all" Private="false" /> <PackageReference Include="Microsoft.CodeAnalysis.CSharp" Version="4.12.0" PrivateAssets="all" Private="false" />
</ItemGroup> </ItemGroup>
</Project> </Project>

View File

@@ -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);
} }
} }

View File

@@ -1,5 +1,5 @@
<div align="center"><h1 align="center">ThingsBlazor</a></h1></div> <div align="center"><h1 align="center">ThingsBlazor</h1></div>
<div align="center"><h3 align="center">权限管理框架</h3></div> <div align="center"><h3 align="center">权限管理框架</h3></div>

View File

@@ -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)

View File

@@ -18,7 +18,6 @@ public sealed class RolePermissionAttribute : Attribute
{ {
} }
/// <summary> /// <summary>
/// 忽略角色授权权限 /// 忽略角色授权权限
/// </summary> /// </summary>

View File

@@ -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
{ {

View File

@@ -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]

View File

@@ -34,17 +34,20 @@ 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 ((!(fileName.StartsWith(@"../Logs") || fileName.StartsWith(@"..\Logs")) && filePath.Contains("..")) || !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);
Response.Headers.Append("Access-Control-Expose-Headers", "Content-Disposition"); Response.Headers.Append("Access-Control-Expose-Headers", "Content-Disposition");
return File(fileStream, "application/octet-stream", (fileName.Replace('/', '_'))); return File(fileStream, "application/octet-stream", (Path.GetFileName(filePath).Replace('/', '_')));
} }
} }

View File

@@ -15,7 +15,6 @@ using System.ComponentModel;
namespace ThingsGateway.Admin.Application; namespace ThingsGateway.Admin.Application;
/// <summary> /// <summary>
/// 登录 /// 登录
/// </summary> /// </summary>

View File

@@ -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;
} }

View File

@@ -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; }
} }

View File

@@ -71,8 +71,6 @@ public class SysRole : BaseEntity
} }
} }
/// <summary> /// <summary>
/// 默认数据范围 /// 默认数据范围
/// </summary> /// </summary>

View File

@@ -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>

View File

@@ -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
@@ -39,12 +38,14 @@ public class VerificatInfo : PrimaryIdEntity
[AutoGenerateColumn(Filterable = true, Sortable = true)] [AutoGenerateColumn(Filterable = true, Sortable = true)]
[SugarColumn(ColumnDescription = "Id", IsPrimaryKey = true)] [SugarColumn(ColumnDescription = "Id", IsPrimaryKey = true)]
[IgnoreExcel] [IgnoreExcel]
[System.ComponentModel.DataAnnotations.Key]
public override long Id { get; set; } public override long Id { get; set; }
/// <summary> /// <summary>
/// 登录IP /// 登录IP
/// </summary> /// </summary>
[AutoGenerateColumn(Filterable = true, Sortable = true, Width = 200)] [AutoGenerateColumn(Filterable = true, Sortable = true, Width = 200)]
[SugarColumn(IsNullable = true)]
public string LoginIp { get; set; } public string LoginIp { get; set; }
/// <summary> /// <summary>
@@ -78,7 +79,6 @@ public class VerificatInfo : PrimaryIdEntity
/// 登录设备 /// 登录设备
/// </summary> /// </summary>
[AutoGenerateColumn(Filterable = true, Sortable = true, Width = 100)] [AutoGenerateColumn(Filterable = true, Sortable = true, Width = 100)]
[SugarColumn(IsNullable = true)]
public string Device { get; set; } public string Device { get; set; }
} }

View File

@@ -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,
} }

View File

@@ -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;
} }
} }
} }

View File

@@ -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
{ {
} }

View File

@@ -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; }
} }

View File

@@ -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>>();
@@ -263,11 +251,13 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
if (exception == null) if (exception == null)
{ {
logger.Log(LogLevel.Information, $"{logData.Method}:{logData.Path}-{logData.Operation}"); if (logger.IsEnabled(LogLevel.Information))
logger.Log(LogLevel.Information, $"{logData.Method}:{logData.Path}-{logData.Operation}");
} }
else else
{ {
logger.Log(LogLevel.Warning, $"{logData.Method}:{logData.Path}-{logData.Operation}{Environment.NewLine}{logData.Exception?.ToSystemTextJsonString()}{Environment.NewLine}{logData.Validation?.ToSystemTextJsonString()}"); if (logger.IsEnabled(LogLevel.Warning))
logger.Log(LogLevel.Warning, $"{logData.Method}:{logData.Path}-{logData.Operation}{Environment.NewLine}{logData.Exception?.ToSystemTextJsonString()}{Environment.NewLine}{logData.Validation?.ToSystemTextJsonString()}");
} }
} }
@@ -296,6 +286,4 @@ public class RequestAuditFilter : IAsyncActionFilter, IOrderedFilter
} }
} }

View File

@@ -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
{ {
} }

View File

@@ -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
} }
} }
} }
} }

View File

@@ -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>

View File

@@ -21,16 +21,7 @@
"UserNoModule": "This account has not been assigned a module. Please contact the administrator", "UserNoModule": "This account has not been assigned a module. Please contact the administrator",
"UserNull": "User {0} does not exist" "UserNull": "User {0} does not exist"
}, },
"ThingsGateway.Admin.Application.BaseDataEntity": {
"CreateOrgId": "CreateOrgId"
},
"ThingsGateway.Admin.Application.BaseEntity": {
"CreateTime": "CreateTime",
"CreateUser": "CreateUser",
"SortCode": "SortCode",
"UpdateTime": "UpdateTime",
"UpdateUser": "UpdateUser"
},
"ThingsGateway.Admin.Application.BlazorAuthenticationHandler": { "ThingsGateway.Admin.Application.BlazorAuthenticationHandler": {
"UserExpire": "User expired, please login again" "UserExpire": "User expired, please login again"
}, },

View File

@@ -21,16 +21,7 @@
"UserNoModule": "该账号未分配模块,请联系管理员", "UserNoModule": "该账号未分配模块,请联系管理员",
"UserNull": "用户 {0} 不存在" "UserNull": "用户 {0} 不存在"
}, },
"ThingsGateway.Admin.Application.BaseDataEntity": {
"CreateOrgId": "创建机构Id"
},
"ThingsGateway.Admin.Application.BaseEntity": {
"CreateTime": "创建时间",
"CreateUser": "创建人",
"SortCode": "排序",
"UpdateTime": "更新时间",
"UpdateUser": "更新人"
},
"ThingsGateway.Admin.Application.BlazorAuthenticationHandler": { "ThingsGateway.Admin.Application.BlazorAuthenticationHandler": {
"UserExpire": "用户登录已过期,请重新登录" "UserExpire": "用户登录已过期,请重新登录"
}, },

View File

@@ -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
{ {

View File

@@ -11,6 +11,7 @@
using Riok.Mapperly.Abstractions; using Riok.Mapperly.Abstractions;
namespace ThingsGateway.Admin.Application; namespace ThingsGateway.Admin.Application;
[Mapper(UseDeepCloning = true, EnumMappingStrategy = EnumMappingStrategy.ByName, RequiredMappingStrategy = RequiredMappingStrategy.None)] [Mapper(UseDeepCloning = true, EnumMappingStrategy = EnumMappingStrategy.ByName, RequiredMappingStrategy = RequiredMappingStrategy.None)]
public static partial class AdminMapper public static partial class AdminMapper
{ {
@@ -25,7 +26,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);
} }

View File

@@ -8,7 +8,7 @@
// QQ群605534569 // QQ群605534569
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------
namespace ThingsGateway.Gateway.Application; namespace ThingsGateway.Admin.Application;
public class USheetDatas public class USheetDatas
{ {

View File

@@ -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);//获取用户信息
@@ -154,7 +145,7 @@ public class AdminOAuthHandler<TOptions>(
var loginEvent = new LoginEvent var loginEvent = new LoginEvent
{ {
Ip = appService.RemoteIpAddress, Ip = appService.RemoteIpAddress,
Device = appService.UserAgent?.Platform, Device = appService.UserAgent?.Platform ?? "Unknown",
Expire = expire, Expire = expire,
SysUser = sysUser, SysUser = sysUser,
VerificatId = CommonUtils.GetSingleId() VerificatId = CommonUtils.GetSingleId()
@@ -165,7 +156,7 @@ public class AdminOAuthHandler<TOptions>(
//生成verificat信息 //生成verificat信息
var verificatInfo = new VerificatInfo var verificatInfo = new VerificatInfo
{ {
Device = loginEvent.Device, Device = loginEvent.Device ?? "Unknown",
Expire = loginEvent.Expire, Expire = loginEvent.Expire,
VerificatTimeout = tokenTimeout, VerificatTimeout = tokenTimeout,
Id = loginEvent.VerificatId, Id = loginEvent.VerificatId,
@@ -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,

View File

@@ -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)
{ {

View File

@@ -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()
{ {

View File

@@ -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"));

View File

@@ -2,5 +2,4 @@
public class GithubOAuthSettings : GiteeOAuthSettings public class GithubOAuthSettings : GiteeOAuthSettings
{ {
} }

View File

@@ -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; }
} }

View File

@@ -12,7 +12,6 @@ using ThingsGateway.ConfigurableOptions;
namespace ThingsGateway.Admin.Application; namespace ThingsGateway.Admin.Application;
/// <summary> /// <summary>
/// 邮件配置选项 /// 邮件配置选项
/// </summary> /// </summary>

View File

@@ -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; }
} }

View File

@@ -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

View File

@@ -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)
{ {
} }
} }

View File

@@ -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));
} }
} }

View File

@@ -26,7 +26,7 @@
"Module": 2, "Module": 2,
"Title": "权限管理", "Title": "权限管理",
"Code": "System", "Code": "System",
"NavLinkMatch": "All", "NavLinkMatch": "Prefix",
"Category": "MENU", "Category": "MENU",
"Target": "_self", "Target": "_self",
"Href": null, "Href": null,
@@ -47,7 +47,7 @@
"ParentId": 0, "ParentId": 0,
"Module": 2, "Module": 2,
"Title": "系统运维", "Title": "系统运维",
"NavLinkMatch": "All", "NavLinkMatch": "Prefix",
"Code": "System", "Code": "System",
"Category": "MENU", "Category": "MENU",
"Target": "_self", "Target": "_self",

View File

@@ -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);
} }
} }

View File

@@ -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));
} }
} }

View File

@@ -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));
} }
} }

View File

@@ -31,6 +31,5 @@ public class SysResourceSeedData : ISqlSugarEntitySeedData<SysResource>
.Concat(data2) .Concat(data2)
.Concat(data3) .Concat(data3)
; ;
} }
} }

View File

@@ -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);
} }
} }

View File

@@ -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>

View File

@@ -8,7 +8,6 @@
// QQ群605534569 // QQ群605534569
// ------------------------------------------------------------------------------ // ------------------------------------------------------------------------------
using ThingsGateway.Admin.Application; using ThingsGateway.Admin.Application;
public interface IApiPermissionService public interface IApiPermissionService

View File

@@ -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);

View File

@@ -71,5 +71,4 @@ public class HybridAppService : IAppService
User = new ClaimsPrincipal(claimsIdentity); User = new ClaimsPrincipal(claimsIdentity);
return Task.CompletedTask; return Task.CompletedTask;
} }
} }

View File

@@ -20,5 +20,4 @@ public class HybridClaimsPrincipalService : IClaimsPrincipalService
_hybridAppService = hybridAppService; _hybridAppService = hybridAppService;
} }
public ClaimsPrincipal? User => _hybridAppService.User; public ClaimsPrincipal? User => _hybridAppService.User;
} }

View File

@@ -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);
} }

View File

@@ -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登录不再需要解密
{ {
@@ -238,7 +235,7 @@ public class AuthService : IAuthService
var logingEvent = new LoginEvent var logingEvent = new LoginEvent
{ {
Ip = _appService.RemoteIpAddress, Ip = _appService.RemoteIpAddress,
Device = _appService.UserAgent?.Platform, Device = _appService.UserAgent?.Platform ?? "Unknown",
Expire = expire, Expire = expire,
SysUser = sysUser, SysUser = sysUser,
VerificatId = verificatId VerificatId = verificatId
@@ -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,
@@ -347,7 +344,7 @@ public class AuthService : IAuthService
//生成verificat信息 //生成verificat信息
var verificatInfo = new VerificatInfo var verificatInfo = new VerificatInfo
{ {
Device = loginEvent.Device, Device = loginEvent.Device ?? "Unknown",
Expire = loginEvent.Expire, Expire = loginEvent.Expire,
VerificatTimeout = tokenTimeout, VerificatTimeout = tokenTimeout,
Id = loginEvent.VerificatId, Id = loginEvent.VerificatId,

View File

@@ -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;
} }

View File

@@ -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

View File

@@ -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; }
} }

View File

@@ -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();
} }

View File

@@ -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>

View File

@@ -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
} }

View File

@@ -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
} }

View File

@@ -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
} }

View File

@@ -9,6 +9,7 @@
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------
namespace ThingsGateway.Admin.Application; namespace ThingsGateway.Admin.Application;
internal sealed class NoticeService : INoticeService internal sealed class NoticeService : INoticeService
{ {
private IEventService<AppMessage>? MessageDispatchService { get; set; } private IEventService<AppMessage>? MessageDispatchService { get; set; }
@@ -24,7 +25,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 +51,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)
{ {

View File

@@ -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);
} }

View File

@@ -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);
} }
} }

View File

@@ -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
} }

View File

@@ -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>

View File

@@ -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)
{ {

View File

@@ -10,9 +10,6 @@
namespace ThingsGateway.Admin.Application; namespace ThingsGateway.Admin.Application;
public class PositionSelectorInput : UserSelectorInput public class PositionSelectorInput : UserSelectorInput
{ {
} }

View File

@@ -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>

View File

@@ -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
} }

View File

@@ -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
} }
} }

View File

@@ -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)//如果成功了
{ {

View File

@@ -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>
/// 从缓存/数据库读取全部资源列表 /// 从缓存/数据库读取全部资源列表

View File

@@ -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)));
} }
} }

View File

@@ -10,7 +10,6 @@
namespace ThingsGateway.Admin.Application; namespace ThingsGateway.Admin.Application;
/// <summary> /// <summary>
/// 角色树输出参数 /// 角色树输出参数
/// </summary> /// </summary>

View File

@@ -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获取角色列表

View File

@@ -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>
@@ -282,7 +282,7 @@ internal sealed class SysRoleService : BaseService<SysRole>, ISysRoleService
if (sysRole != null) if (sysRole != null)
{ {
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 && menuIds.Contains(a.Id));
#region #region
@@ -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
} }

View File

@@ -18,6 +18,7 @@ public class SessionOutput : PrimaryIdEntity
/// <summary> /// <summary>
/// 主键Id /// 主键Id
/// </summary> /// </summary>
[System.ComponentModel.DataAnnotations.Key]
public override long Id { get; set; } public override long Id { get; set; }
/// <summary> /// <summary>

View File

@@ -28,5 +28,4 @@ public class UserSelectorInput
/// 角色ID /// 角色ID
/// </summary> /// </summary>
public long RoleId { get; set; } public long RoleId { get; set; }
} }

View File

@@ -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>
/// 从缓存中删除用户信息。 /// 从缓存中删除用户信息。

View File

@@ -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>
@@ -386,9 +377,9 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
/// 获取用户拥有的资源 /// 获取用户拥有的资源
/// </summary> /// </summary>
/// <param name="id">用户id</param> /// <param name="id">用户id</param>
public async Task<GrantResourceData> OwnResourceAsync(long id) public Task<GrantResourceData> OwnResourceAsync(long id)
{ {
return await _roleService.OwnResourceAsync(id, RelationCategoryEnum.UserHasResource).ConfigureAwait(false); return _roleService.OwnResourceAsync(id, RelationCategoryEnum.UserHasResource);
} }
/// <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
{ {
//忽略更新字段 //忽略更新字段
@@ -514,10 +505,10 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
var password = await GetDefaultPassWord(true).ConfigureAwait(false);//获取默认密码,这里不走Aop所以需要加密一下 var password = await GetDefaultPassWord(true).ConfigureAwait(false);//获取默认密码,这里不走Aop所以需要加密一下
using var db = GetDB(); using var db = GetDB();
//重置密码 //重置密码
if (await db.UpdateSetColumnsTrueAsync<SysUser>(it => new SysUser if ((await db.UpdateSetColumnsTrueAsync<SysUser>(it => new SysUser
{ {
Password = password Password = password
}, it => it.Id == id).ConfigureAwait(false)) }, it => it.Id == id).ConfigureAwait(false)) > 0)
{ {
DeleteUserFromCache(id);//从cache删除用户信息 DeleteUserFromCache(id);//从cache删除用户信息
var verificatInfoIds = _verificatInfoService.GetListByUserId(id); var verificatInfoIds = _verificatInfoService.GetListByUserId(id);
@@ -559,8 +550,7 @@ internal sealed class SysUserService : BaseService<SysUser>, ISysUserService
if (sysUser != null) if (sysUser != null)
{ {
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 && menuIds.Contains(a.Id));
#region #region
@@ -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列表

View File

@@ -42,5 +42,4 @@ public class UpdatePasswordInput
/// </summary> /// </summary>
[Required] [Required]
public string ConfirmPassword { get; set; } public string ConfirmPassword { get; set; }
} }

View File

@@ -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;

View File

@@ -185,12 +185,12 @@ internal sealed class UserCenterService : BaseService<SysUser>, IUserCenterServi
using var db = GetDB(); using var db = GetDB();
//更新指定字段 //更新指定字段
var result = await db.UpdateSetColumnsTrueAsync<SysUser>(it => new SysUser var result = (await db.UpdateSetColumnsTrueAsync<SysUser>(it => new SysUser
{ {
Email = input.Email, Email = input.Email,
Phone = input.Phone, Phone = input.Phone,
Avatar = input.Avatar, Avatar = input.Avatar,
}, it => it.Id == UserManager.UserId).ConfigureAwait(false); }, it => it.Id == UserManager.UserId).ConfigureAwait(false)) > 0;
if (result) if (result)
_userService.DeleteUserFromCache(UserManager.UserId);//cache删除用户数据 _userService.DeleteUserFromCache(UserManager.UserId);//cache删除用户数据
} }

View File

@@ -119,7 +119,7 @@ internal sealed class VerificatInfoService : BaseService<VerificatInfo>, IVerifi
public void Add(VerificatInfo verificatInfo) public void Add(VerificatInfo verificatInfo)
{ {
using var db = GetDB(); using var db = GetDB();
db.Insertable<VerificatInfo>(verificatInfo).ExecuteCommand(); db.InsertableT<VerificatInfo>(verificatInfo).ExecuteCommand();
VerificatInfoService.RemoveCache(verificatInfo.Id); VerificatInfoService.RemoveCache(verificatInfo.Id);
if (verificatInfo != null) if (verificatInfo != null)
VerificatInfoService.SetCahce(verificatInfo); VerificatInfoService.SetCahce(verificatInfo);
@@ -132,7 +132,7 @@ internal sealed class VerificatInfoService : BaseService<VerificatInfo>, IVerifi
public void Update(VerificatInfo verificatInfo) public void Update(VerificatInfo verificatInfo)
{ {
using var db = GetDB(); using var db = GetDB();
db.Updateable<VerificatInfo>(verificatInfo).ExecuteCommand(); db.UpdateableT<VerificatInfo>(verificatInfo).ExecuteCommand();
VerificatInfoService.RemoveCache(verificatInfo.Id); VerificatInfoService.RemoveCache(verificatInfo.Id);
if (verificatInfo != null) if (verificatInfo != null)
VerificatInfoService.SetCahce(verificatInfo); VerificatInfoService.SetCahce(verificatInfo);
@@ -145,7 +145,7 @@ internal sealed class VerificatInfoService : BaseService<VerificatInfo>, IVerifi
public void Delete(long id) public void Delete(long id)
{ {
using var db = GetDB(); using var db = GetDB();
db.Deleteable<VerificatInfo>(id).ExecuteCommand(); db.Deleteable<VerificatInfo>(a => a.Id == id).ExecuteCommand();
VerificatInfoService.RemoveCache(id); VerificatInfoService.RemoveCache(id);
} }

View File

@@ -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();
} }
} }

View File

@@ -5,9 +5,10 @@
<PropertyGroup> <PropertyGroup>
<GenerateDocumentationFile>True</GenerateDocumentationFile> <GenerateDocumentationFile>True</GenerateDocumentationFile>
</PropertyGroup> </PropertyGroup>
<PropertyGroup> <PropertyGroup>
<TargetFrameworks>net8.0;net9.0;</TargetFrameworks> <TargetFrameworks>net8.0;$(OtherTargetFrameworks);</TargetFrameworks>
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
@@ -19,7 +20,7 @@
<ItemGroup> <ItemGroup>
<PackageReference Include="Riok.Mapperly" Version="4.2.1" ExcludeAssets="runtime" PrivateAssets="all" /> <PackageReference Include="Riok.Mapperly" Version="4.2.1" ExcludeAssets="runtime" PrivateAssets="all" />
<PackageReference Include="Rougamo.Fody" Version="5.0.1" /> <PackageReference Include="Rougamo.Fody" Version="5.0.2" />
</ItemGroup> </ItemGroup>
<ItemGroup Condition=" '$(TargetFramework)' == 'net8.0' "> <ItemGroup Condition=" '$(TargetFramework)' == 'net8.0' ">
<PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" /> <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" />
@@ -27,10 +28,10 @@
<PackageReference Include="System.Threading.RateLimiting" Version="8.0.0" /> <PackageReference Include="System.Threading.RateLimiting" Version="8.0.0" />
</ItemGroup> </ItemGroup>
<ItemGroup Condition=" '$(TargetFramework)' == 'net9.0' "> <ItemGroup Condition=" '$(TargetFramework)' == 'net10.0' ">
<PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="$(NET9Version)" /> <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="$(NET10Version)" />
<PackageReference Include="System.Formats.Asn1" Version="$(NET9Version)" /> <PackageReference Include="System.Formats.Asn1" Version="$(NET10Version)" />
<PackageReference Include="System.Threading.RateLimiting" Version="$(NET9Version)" /> <PackageReference Include="System.Threading.RateLimiting" Version="$(NET10Version)" />
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<Content Remove="SeedData\Admin\*.json" /> <Content Remove="SeedData\Admin\*.json" />

View File

@@ -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);
});
} }
} }
} }

View File

@@ -36,5 +36,4 @@ public static class ImportExportUtil
return path; return path;
} }
} }

View File

@@ -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>

View File

@@ -37,6 +37,4 @@ public static class OpenApiUtil
} }
return trees; return trees;
} }
} }

View File

@@ -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;
} }
} }

View File

@@ -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;
} }
} }

View File

@@ -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
} }
} }

View File

@@ -0,0 +1,57 @@
//------------------------------------------------------------------------------
// 此代码版权声明为全文件覆盖,如有原作者特别声明,会在下方手动补充
// 此代码版权除特别声明外的代码归作者本人Diego所有
// 源代码使用协议遵循本仓库的开源协议及附加协议
// Gitee源代码仓库https://gitee.com/diego2098/ThingsGateway
// Github源代码仓库https://github.com/kimdiego2098/ThingsGateway
// 使用文档https://thingsgateway.cn/
// QQ群605534569
//------------------------------------------------------------------------------
namespace ThingsGateway.Admin.Application;
public static class USheetDataHelpers
{
public static USheetDatas GetUSheetDatas(Dictionary<string, object> data)
{
var uSheetDatas = new USheetDatas();
foreach (var a in data)
{
var value = (a.Value as IEnumerable<Dictionary<string, object>>).ToList();
var uSheetData = new USheetData();
uSheetData.id = a.Key;
uSheetData.name = a.Key;
for (int row1 = 0; row1 < value.Count; row1++)
{
if (row1 == 0)
{
Dictionary<int, USheetCelldata> usheetColldata = new();
int col = 0;
foreach (var colData in value[row1])
{
usheetColldata.Add(col, new USheetCelldata() { v = colData.Key });
col++;
}
uSheetData.cellData.Add(row1, usheetColldata);
}
{
Dictionary<int, USheetCelldata> usheetColldata = new();
int col = 0;
foreach (var colData in value[row1])
{
usheetColldata.Add(col, new USheetCelldata() { v = colData.Value });
col++;
}
uSheetData.cellData.Add(row1 + 1, usheetColldata);
}
}
uSheetData.rowCount = uSheetData.cellData.Count + 100;
uSheetData.columnCount = uSheetData.cellData.FirstOrDefault().Value?.Count ?? 0;
uSheetDatas.sheets.Add(a.Key, uSheetData);
}
return uSheetDatas;
}
}

View File

@@ -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;
} }
} }

View File

@@ -58,5 +58,4 @@ public static class VerificatInfoUtil
#endregion #endregion
} }

View File

@@ -4,9 +4,9 @@
<div class="tg-table h-100"> <div class="tg-table h-100">
<Table TItem="TItem" IsBordered="true" IsStriped="true" TableSize="TableSize.Compact" IsMultipleSelect="IsMultipleSelect" @ref="Instance" SearchTemplate="SearchTemplate" <Table TItem="TItem" IsBordered="true" IsStriped="true" TableSize="TableSize.Compact" SelectedRows=SelectedRows SelectedRowsChanged=privateSelectedRowsChanged IsMultipleSelect="IsMultipleSelect" @ref="Instance" SearchTemplate="SearchTemplate"
DataService="DataService" CreateItemCallback="CreateItemCallback!" DataService="DataService" CreateItemCallback="CreateItemCallback!" RenderMode=RenderMode
IsPagination="IsPagination" PageItemsSource="PageItemsSource" IsFixedHeader="IsFixedHeader" IndentSize=24 RowHeight=RowHeight ShowSearchText="ShowSearchText" ShowSearchButton="ShowSearchButton" BeforeShowEditDialogCallback="BeforeShowEditDialogCallback!" IsPagination="IsPagination" PageItemsSource="PageItemsSource" IsFixedHeader="IsFixedHeader" IndentSize=24 RowHeight=RowHeight ShowSearchText="ShowSearchText" ShowSearchButton="ShowSearchButton" DisableEditButtonCallback="DisableEditButtonCallback" DisableDeleteButtonCallback="DisableDeleteButtonCallback" BeforeShowEditDialogCallback=" BeforeShowEditDialogCallback!"
IsTree="IsTree" OnTreeExpand="OnTreeExpand!" TreeNodeConverter="TreeNodeConverter!" TreeIcon="fa-solid fa-circle-chevron-right" TreeExpandIcon="fa-solid fa-circle-chevron-right fa-rotate-90" IsAutoQueryFirstRender=IsAutoQueryFirstRender IsTree="IsTree" OnTreeExpand="OnTreeExpand!" TreeNodeConverter="TreeNodeConverter!" TreeIcon="fa-solid fa-circle-chevron-right" TreeExpandIcon="fa-solid fa-circle-chevron-right fa-rotate-90" IsAutoQueryFirstRender=IsAutoQueryFirstRender
ShowDefaultButtons="ShowDefaultButtons" ShowAdvancedSearch="ShowAdvancedSearch" ShowResetButton=ShowResetButton ShowDefaultButtons="ShowDefaultButtons" ShowAdvancedSearch="ShowAdvancedSearch" ShowResetButton=ShowResetButton
ShowEmpty="ShowEmpty" EmptyText="@EmptyText" EmptyImage="@($"{WebsiteConst.DefaultResourceUrl}images/empty.svg")" SortString="@SortString" EditDialogSize="EditDialogSize" ShowEmpty="ShowEmpty" EmptyText="@EmptyText" EmptyImage="@($"{WebsiteConst.DefaultResourceUrl}images/empty.svg")" SortString="@SortString" EditDialogSize="EditDialogSize"
@@ -14,7 +14,7 @@
ShowSkeleton="true" ShowLoading="ShowLoading" ShowSearch="ShowSearch" SearchModel=@SearchModel ShowLineNo ShowSkeleton="true" ShowLoading="ShowLoading" ShowSearch="ShowSearch" SearchModel=@SearchModel ShowLineNo
SearchMode=SearchMode ShowExportPdfButton=ShowExportPdfButton ExportButtonText=@ExportButtonText SearchMode=SearchMode ShowExportPdfButton=ShowExportPdfButton ExportButtonText=@ExportButtonText
ShowExportButton=@ShowExportButton Items=Items ClickToSelect=ClickToSelect ScrollMode=ScrollMode ShowExportButton=@ShowExportButton Items=Items ClickToSelect=ClickToSelect ScrollMode=ScrollMode
ShowExportCsvButton=@ShowExportCsvButton SelectedRowsChanged=SelectedRowsChanged ShowCardView=ShowCardView ShowExportCsvButton=@ShowExportCsvButton ShowCardView=ShowCardView
FixedExtendButtonsColumn=FixedExtendButtonsColumn FixedMultipleColumn=FixedMultipleColumn FixedDetailRowHeaderColumn=FixedDetailRowHeaderColumn FixedLineNoColumn=FixedLineNoColumn FixedExtendButtonsColumn=FixedExtendButtonsColumn FixedMultipleColumn=FixedMultipleColumn FixedDetailRowHeaderColumn=FixedDetailRowHeaderColumn FixedLineNoColumn=FixedLineNoColumn
IsAutoRefresh=IsAutoRefresh AutoRefreshInterval=AutoRefreshInterval IsAutoRefresh=IsAutoRefresh AutoRefreshInterval=AutoRefreshInterval
AllowDragColumn=@AllowDragColumn Height=@Height ShowRefresh=ShowRefresh AllowDragColumn=@AllowDragColumn Height=@Height ShowRefresh=ShowRefresh
@@ -29,7 +29,7 @@
ShowMultiFilterHeader=ShowMultiFilterHeader ShowMultiFilterHeader=ShowMultiFilterHeader
ShowFilterHeader=ShowFilterHeader ShowFilterHeader=ShowFilterHeader
ShowColumnList=ShowColumnList ExtendButtonColumnWidth="@ExtendButtonColumnWidth" ShowColumnList=ShowColumnList ExtendButtonColumnWidth="@ExtendButtonColumnWidth"
CustomerSearchModel="CustomerSearchModel" SelectedRows="SelectedRows" ModelEqualityComparer="ModelEqualityComparer!" CustomerSearchModel="CustomerSearchModel" ModelEqualityComparer="ModelEqualityComparer!"
ShowExtendEditButtonCallback="ShowExtendEditButtonCallback!" ShowExtendDeleteButtonCallback="ShowExtendDeleteButtonCallback!" ShowExtendEditButtonCallback="ShowExtendEditButtonCallback!" ShowExtendDeleteButtonCallback="ShowExtendDeleteButtonCallback!"
DisableExtendEditButton="DisableExtendEditButton!" DisableExtendDeleteButton="DisableExtendDeleteButton!" DisableExtendEditButton="DisableExtendEditButton!" DisableExtendDeleteButton="DisableExtendDeleteButton!"
DisableExtendEditButtonCallback="DisableExtendEditButtonCallback!" DisableExtendDeleteButtonCallback="DisableExtendDeleteButtonCallback!" DisableExtendEditButtonCallback="DisableExtendEditButtonCallback!" DisableExtendDeleteButtonCallback="DisableExtendDeleteButtonCallback!"
@@ -41,6 +41,7 @@
DoubleClickToEdit="DoubleClickToEdit" DoubleClickToEdit="DoubleClickToEdit"
OnDoubleClickCellCallback="OnDoubleClickCellCallback" OnDoubleClickCellCallback="OnDoubleClickCellCallback"
OnDoubleClickRowCallback="OnDoubleClickRowCallback" OnDoubleClickRowCallback="OnDoubleClickRowCallback"
RowContentTemplate="RowContentTemplate"
OnClickRowCallback="OnClickRowCallback"> OnClickRowCallback="OnClickRowCallback">
</Table> </Table>
</div> </div>

View File

@@ -14,6 +14,31 @@ namespace ThingsGateway.Admin.Razor;
public partial class AdminTable<TItem> where TItem : class, new() public partial class AdminTable<TItem> where TItem : class, new()
{ {
/// <inheritdoc cref="Table{TItem}.RenderMode"/>
[Parameter]
public TableRenderMode RenderMode { get; set; }
public List<ITableColumn> Columns => Instance?.Columns;
/// <inheritdoc cref="Table{TItem}.SelectedRowsChanged"/>
[Parameter]
public EventCallback<List<TItem>> SelectedRowsChanged { get; set; }
/// <inheritdoc cref="Table{TItem}.SelectedRows"/>
[Parameter]
public List<TItem> SelectedRows { get; set; } = new();
private async Task privateSelectedRowsChanged(List<TItem> items)
{
SelectedRows = items;
if (SelectedRowsChanged.HasDelegate)
await SelectedRowsChanged.InvokeAsync(items);
}
/// <inheritdoc cref="Table{TItem}.DoubleClickToEdit"/> /// <inheritdoc cref="Table{TItem}.DoubleClickToEdit"/>
[Parameter] [Parameter]
public bool DoubleClickToEdit { get; set; } = false; public bool DoubleClickToEdit { get; set; } = false;
@@ -23,11 +48,14 @@ public partial class AdminTable<TItem> where TItem : class, new()
/// <inheritdoc cref="Table{TItem}.OnDoubleClickRowCallback"/> /// <inheritdoc cref="Table{TItem}.OnDoubleClickRowCallback"/>
[Parameter] [Parameter]
public Func<TItem, Task>? OnDoubleClickRowCallback { get; set; } public Func<TItem, Task>? OnDoubleClickRowCallback { get; set; }
/// <inheritdoc cref="Table{TItem}.RowContentTemplate"/>
[Parameter]
public RenderFragment<TableRowContext<TItem>>? RowContentTemplate { get; set; }
/// <inheritdoc cref="Table{TItem}.OnClickRowCallback"/> /// <inheritdoc cref="Table{TItem}.OnClickRowCallback"/>
[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 +162,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; }
@@ -213,14 +240,6 @@ public partial class AdminTable<TItem> where TItem : class, new()
[Parameter] [Parameter]
public RenderFragment<TItem>? SearchTemplate { get; set; } public RenderFragment<TItem>? SearchTemplate { get; set; }
/// <inheritdoc cref="Table{TItem}.SelectedRows"/>
[Parameter]
public List<TItem>? SelectedRows { get; set; } = new List<TItem>();
/// <inheritdoc cref="Table{TItem}.SelectedRowsChanged"/>
[Parameter]
public EventCallback<List<TItem>> SelectedRowsChanged { get; set; }
/// <inheritdoc cref="Table{TItem}.SetRowClassFormatter"/> /// <inheritdoc cref="Table{TItem}.SetRowClassFormatter"/>
[Parameter] [Parameter]
public Func<TItem, string?>? SetRowClassFormatter { get; set; } public Func<TItem, string?>? SetRowClassFormatter { get; set; }
@@ -269,6 +288,15 @@ public partial class AdminTable<TItem> where TItem : class, new()
[Parameter] [Parameter]
public bool ShowExportButton { get; set; } = false; public bool ShowExportButton { get; set; } = false;
/// <inheritdoc cref="Table{TItem}.DisableEditButtonCallback"/>
public Func<List<TItem>, bool> DisableEditButtonCallback { get; set; } = (list) =>
list.Count != 1;
/// <inheritdoc cref="Table{TItem}.DisableDeleteButtonCallback"/>
[Parameter]
public Func<List<TItem>, bool> DisableDeleteButtonCallback { get; set; } = (list) =>
list.Count <= 0;
/// <inheritdoc cref="Table{TItem}.ShowExportCsvButton"/> /// <inheritdoc cref="Table{TItem}.ShowExportCsvButton"/>
[Parameter] [Parameter]
public bool ShowExportCsvButton { get; set; } = false; public bool ShowExportCsvButton { get; set; } = false;
@@ -337,7 +365,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 +453,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);
} }
} }

View File

@@ -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;
} }
} }

View File

@@ -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()
} }
} }

Some files were not shown because too many files have changed in this diff Show More