feat(消息通知): ✨ 完善站内信和消息通知功能

Author: huguodong

api/SimpleAdmin/SimpleAdmin.Core/SimpleAdmin.Core.csproj

@@ -1,18 +1,18 @@
 <Project Sdk="Microsoft.NET.Sdk">
-    
+
 
     <ItemGroup>
-        <PackageReference Include="Lazy.Captcha.Core" Version="2.0.7" />
+        <PackageReference Include="Lazy.Captcha.Core" Version="2.0.7"/>
         <PackageReference Include="Minio" Version="5.0.0"/>
-        <PackageReference Include="MoYu.Extras.Authentication.JwtBearer" Version="1.0.6" />
-        <PackageReference Include="MoYu.Extras.ObjectMapper.Mapster" Version="1.0.6" />
-        <PackageReference Include="MoYu.Pure" Version="1.0.6" />
-        <PackageReference Include="NewLife.Core" Version="10.10.2024.601" />
+        <PackageReference Include="MoYu.Extras.Authentication.JwtBearer" Version="1.0.6"/>
+        <PackageReference Include="MoYu.Extras.ObjectMapper.Mapster" Version="1.0.6"/>
+        <PackageReference Include="MoYu.Pure" Version="1.0.6"/>
+        <PackageReference Include="NewLife.Core" Version="10.10.2024.601"/>
         <PackageReference Include="Portable.BouncyCastle" Version="1.9.0"/>
-        <PackageReference Include="SimpleTool" Version="1.0.6"/>
-        <PackageReference Include="System.Drawing.Common" Version="8.0.6" />
+        <PackageReference Include="SimpleTool" Version="1.0.7"/>
+        <PackageReference Include="System.Drawing.Common" Version="8.0.6"/>
         <PackageReference Include="Yitter.IdGenerator" Version="1.0.14"/>
-        <PackageReference Include="Masuit.Tools.Core" Version="2024.3.4" />
+        <PackageReference Include="Masuit.Tools.Core" Version="2024.3.4"/>
         <PackageReference Include="SharpZipLib" Version="1.4.2"/>
 
     </ItemGroup>

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Const/MqttConst.cs

@@ -0,0 +1,32 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+/// mqtt常量
+/// </summary>
+public class MqttConst
+{
+    /// <summary>
+    /// mqtt认证登录信息key
+    /// </summary>
+    public const string CACHE_MQTT_CLIENT_USER = CacheConst.CACHE_PREFIX_WEB + "MqttClientUser:";
+
+    /// <summary>
+    /// mqtt主题前缀
+    /// </summary>
+    public const string MQTT_TOPIC_PREFIX = "SimpleAdmin/";
+
+    /// <summary>
+    /// 登出
+    /// </summary>
+    public const string MQTT_MESSAGE_LOGIN_OUT = "LoginOut";
+
+    /// <summary>
+    /// 新消息
+    /// </summary>
+    public const string MQTT_MESSAGE_NEW = "NewMessage";
+
+    /// <summary>
+    /// 修改密码
+    /// </summary>
+    public const string MQTT_MESSAGE_UPDATE_PASSWORD = "UpdatePassword";
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Controller/MqttController.cs

@@ -0,0 +1,39 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+/// mqtt服务控制器
+/// </summary>
+[ApiDescriptionSettings(Tag = "mqtt服务")]
+[Route("mqtt")]
+public class MqttController : IDynamicApiController
+{
+    private readonly IMqttService _mqttService;
+
+    public MqttController(IMqttService mqttService)
+    {
+        _mqttService = mqttService;
+    }
+
+    /// <summary>
+    /// 获取mqtt登录参数
+    /// </summary>
+    /// <returns></returns>
+    [HttpGet("getParameter")]
+    public async Task<dynamic> GetParameter()
+    {
+        return await _mqttService.GetWebLoginParameter();
+    }
+
+    /// <summary>
+    /// mqtt认证
+    /// </summary>
+    /// <param name="input"></param>
+    /// <returns></returns>
+    [HttpPost("auth")]
+    [AllowAnonymous]
+    [NonUnify]
+    public async Task<dynamic> Auth([FromBody] MqttAuthInput input)
+    {
+        return await _mqttService.Auth(input);
+    }
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/GlobalUsing.cs

@@ -0,0 +1,16 @@
+global using MoYu;
+global using MoYu.DependencyInjection;
+global using Microsoft.AspNetCore.Builder;
+global using Microsoft.AspNetCore.Hosting;
+global using Microsoft.Extensions.DependencyInjection;
+global using SimpleAdmin.Core;
+global using SimpleAdmin.Cache;
+global using SimpleAdmin.SqlSugar;
+global using SimpleMQTT;
+global using Microsoft.AspNetCore.Authorization;
+global using Microsoft.AspNetCore.Mvc;
+global using SimpleAdmin.System;
+global using MoYu.DynamicApiController;
+global using MoYu.DataEncryption;
+global using Microsoft.AspNetCore.Http;
+global using SimpleTool;

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Mqtt.Development.json

@@ -0,0 +1,10 @@
+{
+  //mqtt设置
+  "MqttSettings": {
+    "Host": "127.0.0.1",
+    "Port": 1883,
+    "UserName": "admin",
+    "SecretKey": "admin",
+    "ClientId": "SimpleAdminWeb"
+  }
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Mqtt.Production.json

@@ -0,0 +1,10 @@
+{
+  //mqtt设置
+  "MqttSettings": {
+    "Host": "127.0.0.1",
+    "Port": 1883,
+    "UserName": "admin",
+    "SecretKey": "admin",
+    "ClientId": "SimpleAdminWeb"
+  }
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/MqttComponent.cs

@@ -0,0 +1,32 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+///  mqtt组件
+/// </summary>
+public sealed class MqttComponent : IServiceComponent
+{
+    /// <summary>
+    /// ConfigureServices中不能解析服务，比如App.GetService()，尤其是不能在ConfigureServices中获取诸如缓存等数据进行初始化，应该在Configure中进行
+    /// 服务都还没初始化完成，会导致内存中存在多份 IOC 容器！！
+    /// 正确应该在 Configure 中，这个时候服务（IServiceCollection 已经完成 BuildServiceProvider() 操作了
+    /// </summary>
+    /// <param name="services"></param>
+    /// <param name="componentContext"></param>
+    public void Load(IServiceCollection services, ComponentContext componentContext)
+    {
+        Console.WriteLine("注册Mqtt插件");
+        services.AddMqttClientManager();
+    }
+}
+
+/// <summary>
+/// mqtt组件
+/// 模拟 Configure
+/// </summary>
+public sealed class MqttApplicationComponent : IApplicationComponent
+{
+    public void Load(IApplicationBuilder app, IWebHostEnvironment env, ComponentContext componentContext)
+    {
+        App.GetService<IMqttClientManager>();//获取mqtt服务判断配置是否有问题
+    }
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Service/Mqtt/Dto/MqttInput.cs

@@ -0,0 +1,27 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+/// mqtt认证参数
+/// </summary>
+public class MqttAuthInput
+{
+    /// <summary>
+    /// 用户ID
+    /// </summary>
+    public string UserId { get; set; }
+
+    /// <summary>
+    /// 账号
+    /// </summary>
+    public string Username { get; set; }
+
+    /// <summary>
+    /// 密码
+    /// </summary>
+    public string Password { get; set; }
+
+    /// <summary>
+    /// 客户端ID
+    /// </summary>
+    public string ClientId { get; set; }
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Service/Mqtt/Dto/MqttOutput.cs

@@ -0,0 +1,49 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+/// mqtt登录参数输出
+/// </summary>
+public class MqttParameterOutput
+{
+    /// <summary>
+    /// 地址
+    /// </summary>
+    public string Url { get; set; }
+
+    /// <summary>
+    /// 用户名
+    /// </summary>
+    public string UserName { get; set; }
+
+    /// <summary>
+    /// 密码
+    /// </summary>
+
+    public string Password { get; set; }
+
+    /// <summary>
+    /// 客户端ID
+    /// </summary>
+    public string ClientId { get; set; }
+
+    /// <summary>
+    /// 主题列表
+    /// </summary>
+    public List<string> Topics { get; set; }
+}
+
+/// <summary>
+/// mqtt认证输出
+/// </summary>
+public class MqttAuthOutput
+{
+    /// <summary>
+    /// 结果 "allow" | "deny" | "ignore", // Default `"ignore"`
+    /// </summary>
+    public string Result { get; set; } = "deny";
+
+    /// <summary>
+    /// 是否超级管理员
+    /// </summary>
+    public bool Is_superuser { get; set; } = false;
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Service/Mqtt/IMqttService.cs

@@ -0,0 +1,21 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+///Mqtt服务
+/// </summary>
+public interface IMqttService : ITransient
+{
+    /// <summary>
+    /// mqtt登录http认证
+    /// </summary>
+    /// <param name="input">认证参数</param>
+    /// <param name="userId">用户Id</param>
+    /// <returns>认证结果</returns>
+    Task<MqttAuthOutput> Auth(MqttAuthInput input);
+
+    /// <summary>
+    /// 获取mqtt登录web端参数
+    /// </summary>
+    /// <returns>登录参数</returns>
+    Task<MqttParameterOutput> GetWebLoginParameter();
+}

api/SimpleAdmin/SimpleAdmin.Plugin/SimpleAdmin.Plugin.Mqtt/Service/Mqtt/MqttService.cs

@@ -0,0 +1,76 @@
+namespace SimpleAdmin.Plugin.Mqtt;
+
+/// <summary>
+/// <inheritdoc cref="IMqttService"/>
+/// </summary>
+public class MqttService : IMqttService
+{
+    private readonly ISimpleCacheService _simpleCacheService;
+    private readonly ISysUserService _sysUserService;
+    private readonly IConfigService _configService;
+
+    public MqttService(ISimpleCacheService simpleCacheService, ISysUserService sysUserService, IConfigService configService)
+    {
+        _simpleCacheService = simpleCacheService;
+        _sysUserService = sysUserService;
+        _configService = configService;
+    }
+
+    /// <inheritdoc/>
+    public async Task<MqttParameterOutput> GetWebLoginParameter()
+    {
+        var user = await _sysUserService.GetUserById(UserManager.UserId);//获取用户信息
+        var token = JWTEncryption.GetJwtBearerToken((DefaultHttpContext)App.HttpContext);// 获取当前token
+        //获取mqtt配置
+        var mqttconfig = await _configService.GetConfigsByCategory(CateGoryConst.CONFIG_MQTT_BASE);
+        //地址
+        var url = mqttconfig.Where(it => it.ConfigKey == SysConfigConst.MQTT_PARAM_URL).Select(it => it.ConfigValue).FirstOrDefault();
+        //用户名
+        var userName = mqttconfig.Where(it => it.ConfigKey == SysConfigConst.MQTT_PARAM_USERNAME).Select(it => it.ConfigValue).FirstOrDefault();
+        //密码
+        var password = mqttconfig.Where(it => it.ConfigKey == SysConfigConst.MQTT_PARAM_PASSWORD).Select(it => it.ConfigValue).FirstOrDefault();
+
+        #region 用户名特殊处理
+
+        if (userName.ToLower() == "$username")
+            userName = user.Account;
+        else if (userName.ToLower() == "$userid")
+            userName = user.Id.ToString();
+
+        #endregion 用户名特殊处理
+
+        #region 密码特殊处理
+
+        if (password.ToLower() == "$username")
+            password = token;// 当前token作为mqtt密码
+
+        #endregion 密码特殊处理
+
+        var clientId = $"{user.Id}_{RandomHelper.CreateLetterAndNumber(5)}";//客户端ID
+        _simpleCacheService.Set(MqttConst.CACHE_MQTT_CLIENT_USER + clientId, token,
+            TimeSpan.FromMinutes(1));//将该客户端ID对应的token插入redis后面可以根据这个判断是哪个token登录的
+        return new MqttParameterOutput
+        {
+            ClientId = clientId,
+            Password = password,
+            Url = url,
+            UserName = userName,
+            Topics = new List<string> { MqttConst.MQTT_TOPIC_PREFIX + user.Id }//默认监听自己
+        };
+    }
+
+    /// <inheritdoc/>
+    public async Task<MqttAuthOutput> Auth(MqttAuthInput input)
+    {
+        var user = await _sysUserService.GetUserByAccount(input.Username);
+        var mqttAuthOutput = new MqttAuthOutput { Is_superuser = false, Result = "deny" };
+        //获取用户token
+        var tokens = _simpleCacheService.HashGetOne<List<TokenInfo>>(CacheConst.CACHE_USER_TOKEN, user.Id.ToString());
+        if (tokens != null)
+        {
+            if (tokens.Any(it => it.Token == input.Password))//判断是否有token
+                mqttAuthOutput.Result = "allow";//允许登录
+        }
+        return mqttAuthOutput;
+    }
+}