!1463 新增账号变动事件订阅功能

Merge pull request !1463 from 喵你个汪/jasondom-next

Admin.NET/Admin.NET.Core/Enum/SysUserEventTypeEnum.cs

@@ -0,0 +1,31 @@
+// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+// 
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
+// 
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+
+namespace Admin.NET.Core;
+
+/// <summary>
+/// 系统用户操作事件类型枚举
+/// </summary>
+[Description("系统用户操作事件类型枚举")]
+public enum SysUserEventTypeEnum
+{
+    [Description("增加用户")]
+    Add = 111,
+    [Description("更新用户")]
+    Update = 222,
+    [Description("授权用户角色")]
+    UpdateRole = 333,
+    [Description("删除用户")]
+    Delete = 444,
+    [Description("设置用户状态")]
+    SetStatus = 555,
+    [Description("修改密码")]
+    ChangePwd = 666,
+    [Description("重置密码")]
+    ResetPwd = 777,
+    [Description("解除登录锁定")]
+    UnlockLogin = 888
+}

Admin.NET/Admin.NET.Core/Service/User/Dto/SysUserEventArgs.cs

@@ -0,0 +1,30 @@
+// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+// 
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
+// 
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+
+namespace Admin.NET.Core.Service;
+
+/// <summary>
+/// 系统用户操作事件参数
+/// </summary>
+public class SysUserEventArgs: EventArgs
+{
+    /// <summary>
+    /// 事件类型
+    /// </summary>
+    [Required]
+    public SysUserEventTypeEnum EventType { get; set; }
+    
+    /// <summary>
+    /// 接口输入参数
+    /// </summary>
+    public object Input { get; set; }
+
+    public SysUserEventArgs(SysUserEventTypeEnum eventType, object input)
+    {
+        this.EventType = eventType;
+        this.Input = input;
+    }
+}

Admin.NET/Admin.NET.Core/Service/User/SysUserEventHandler.cs

@@ -0,0 +1,32 @@
+// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+// 
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
+// 
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+
+namespace Admin.NET.Core.Service;
+
+/// <summary>
+/// 系统用户事件处理类
+/// </summary>
+public class SysUserEventHandler : ISingleton
+{
+    private event EventHandler Event;
+
+    /// <summary>
+    /// 订阅
+    /// </summary>
+    /// <param name="eventHandler"></param>
+    public void Subscribe(EventHandler eventHandler) => Event += eventHandler;
+
+    /// <summary>
+    /// 发布事件
+    /// </summary>
+    /// <param name="sender"></param>
+    /// <param name="eventType"></param>
+    /// <param name="input"></param>
+    public void OnEvent(object sender, SysUserEventTypeEnum eventType, object input)
+    {
+        Event?.Invoke(sender, new SysUserEventArgs(eventType, input));
+    }
+}

Admin.NET/Admin.NET.Core/Service/User/SysUserService.cs

@@ -21,6 +21,7 @@ public class SysUserService : IDynamicApiController, ITransient
     private readonly SysCacheService _sysCacheService;
     private readonly SysUserLdapService _sysUserLdapService;
     private readonly SqlSugarRepository<SysUser> _sysUserRep;
+    private readonly SysUserEventHandler _sysUserEventHandler;
 
     public SysUserService(UserManager userManager,
         SysOrgService sysOrgService,
@@ -30,7 +31,8 @@ public class SysUserService : IDynamicApiController, ITransient
         SysOnlineUserService sysOnlineUserService,
         SysCacheService sysCacheService,
         SysUserLdapService sysUserLdapService,
-        SqlSugarRepository<SysUser> sysUserRep)
+        SqlSugarRepository<SysUser> sysUserRep,
+        SysUserEventHandler sysUserEventHandler)
     {
         _userManager = userManager;
         _sysOrgService = sysOrgService;
@@ -41,6 +43,7 @@ public class SysUserService : IDynamicApiController, ITransient
         _sysCacheService = sysCacheService;
         _sysUserLdapService = sysUserLdapService;
         _sysUserRep = sysUserRep;
+        _sysUserEventHandler = sysUserEventHandler;
     }
 
     /// <summary>
@@ -109,7 +112,10 @@ public class SysUserService : IDynamicApiController, ITransient
         // 增加域账号
         if (!string.IsNullOrWhiteSpace(input.DomainAccount))
             await _sysUserLdapService.AddUserLdap(newUser.TenantId.Value, newUser.Id, newUser.Account, input.DomainAccount);
-
+        
+        // 执行订阅事件
+        _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.Add, input);
+        
         return newUser.Id;
     }
 
@@ -141,6 +147,9 @@ public class SysUserService : IDynamicApiController, ITransient
             await _sysOnlineUserService.ForceOffline(input.Id);
         // 更新域账号
         await _sysUserLdapService.AddUserLdap(user.TenantId.Value, user.Id, user.Account, input.DomainAccount);
+        
+        // 执行订阅事件
+        _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.Update, input);
     }
 
     /// <summary>
@@ -192,6 +201,9 @@ public class SysUserService : IDynamicApiController, ITransient
 
         // 删除域账号
         await _sysUserLdapService.DeleteUserLdapByUserId(input.Id);
+        
+        // 执行订阅事件
+        _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.Delete, input);
     }
 
     /// <summary>
@@ -248,7 +260,12 @@ public class SysUserService : IDynamicApiController, ITransient
         }
 
         user.Status = input.Status;
-        return await _sysUserRep.AsUpdateable(user).UpdateColumns(u => new { u.Status }).ExecuteCommandAsync();
+        var rows = await _sysUserRep.AsUpdateable(user).UpdateColumns(u => new { u.Status }).ExecuteCommandAsync();
+        
+        // 执行订阅事件
+        if (rows > 0) _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.SetStatus, input);
+
+        return rows;
     }
 
     /// <summary>
@@ -265,6 +282,9 @@ public class SysUserService : IDynamicApiController, ITransient
         //    throw Oops.Oh(ErrorCodeEnum.D1022);
 
         await _sysUserRoleService.GrantUserRole(input);
+        
+        // 执行订阅事件
+        _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.UpdateRole, input);
     }
 
     /// <summary>
@@ -306,7 +326,12 @@ public class SysUserService : IDynamicApiController, ITransient
             user.Password = CryptogramUtil.Encrypt(input.PasswordNew);
         }
 
-        return await _sysUserRep.AsUpdateable(user).UpdateColumns(u => u.Password).ExecuteCommandAsync();
+        var rows = await _sysUserRep.AsUpdateable(user).UpdateColumns(u => u.Password).ExecuteCommandAsync();
+        
+        // 执行订阅事件
+        if (rows > 0) _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.ChangePwd, input);
+
+        return rows;
     }
 
     /// <summary>
@@ -325,6 +350,9 @@ public class SysUserService : IDynamicApiController, ITransient
         // 清空密码错误次数
         var keyErrorPasswordCount = $"{CacheConst.KeyPasswordErrorTimes}{user.Account}";
         _sysCacheService.Remove(keyErrorPasswordCount);
+        
+        // 执行订阅事件
+        _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.ResetPwd, input);
 
         return password;
     }
@@ -342,6 +370,9 @@ public class SysUserService : IDynamicApiController, ITransient
         // 清空密码错误次数
         var keyPasswordErrorTimes = $"{CacheConst.KeyPasswordErrorTimes}{user.Account}";
         _sysCacheService.Remove(keyPasswordErrorTimes);
+        
+        // 执行订阅事件
+        _sysUserEventHandler.OnEvent(this, SysUserEventTypeEnum.UnlockLogin, input);
     }
 
     /// <summary>