gaoxing/UNIVPLMDataIntegration
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

补缺失文件

Browse Source
This commit is contained in:
yzp 2025-02-22 08:40:10 +08:00
parent e102529c6f
commit e3f9975657
3 changed files with 39 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
Admin.NET/Admin.NET.Core/Service/Mqtt/Dto/SysMqttDto.cs Normal file
View File

@ -0,0 +1,19 @@
// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
//
// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
//
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Admin.NET.Core;
public class PublicMessageInput
{
public string Topic { get; set; }
public string Message { get; set; }
}

34
Admin.NET/Admin.NET.Core/Service/Mqtt/MqttService.cs
View File

@ -1,34 +0,0 @@
// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
//
// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
//
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
using Admin.NET.Core.Service.Mqtt.Dto;
namespace Admin.NET.Core.Service;
/// <summary>
/// 系统职位服务 🧩
/// </summary>
[ApiDescriptionSettings(Order = 460, Description = "MQTT 服务")]
public class MqttService : IDynamicApiController, ITransient
{
MqttHostedService _mqttHostedService;
public MqttService(MqttHostedService mqttProvider)
{
_mqttHostedService = mqttProvider;
}
/// <summary>
/// 发布消息 🔖
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[AllowAnonymous]
[DisplayName("发布消息")]
public async Task PublicMessage(PublicMessageInput input)
{
_mqttHostedService.PublicMessage(input.Topic, input.Message);
}
}

21
Admin.NET/Admin.NET.Core/Service/Mqtt/SysMqttService.cs
View File

@ -13,7 +13,14 @@ namespace Admin.NET.Core.Service;
/// </summary>
[ApiDescriptionSettings(Order = 90, Description = "MQTT 服务")]
public class SysMqttService() : IDynamicApiController, ITransient
{
{
MqttHostedService _mqttHostedService;
public SysMqttService(MqttHostedService mqttProvider)
{
_mqttHostedService = mqttProvider;
}
/// <summary>
/// 获取客户端列表 🔖
/// </summary>
@ -25,5 +32,17 @@ public class SysMqttService() : IDynamicApiController, ITransient
throw Oops.Oh("【MQTT】服务未启动");
return await MqttHostedService.MqttServer.GetClientsAsync();
}
/// <summary>
/// 发布消息 🔖
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[AllowAnonymous]
[DisplayName("发布消息")]
public async Task PublicMessage(PublicMessageInput input)
{
_mqttHostedService.PublicMessage(input.Topic, input.Message);
}
}