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:46:28 +08:00
parent e3f9975657
commit 102b336a85
2 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -13,14 +13,7 @@ namespace Admin.NET.Core.Service;
/// </summary> /// </summary>
[ApiDescriptionSettings(Order = 90, Description = "MQTT 服务")] [ApiDescriptionSettings(Order = 90, Description = "MQTT 服务")]
public class SysMqttService() : IDynamicApiController, ITransient public class SysMqttService() : IDynamicApiController, ITransient
{ {
MqttHostedService _mqttHostedService;
public SysMqttService(MqttHostedService mqttProvider)
{
_mqttHostedService = mqttProvider;
}
/// <summary> /// <summary>
/// 获取客户端列表 🔖 /// 获取客户端列表 🔖
/// </summary> /// </summary>
@ -35,14 +28,15 @@ public class SysMqttService() : IDynamicApiController, ITransient
} }
/// <summary> /// <summary>
/// 发布消息 🔖 /// 发布主题 🔖
/// </summary> /// </summary>
/// <param name="input"></param> /// <param name="input"></param>
/// <returns></returns> /// <returns></returns>
[AllowAnonymous] [AllowAnonymous]
[DisplayName("发布消息")] [DisplayName("发布主题")]
public async Task PublicMessage(PublicMessageInput input) public async Task PublicMessage(PublicMessageInput input)
{ {
_mqttHostedService.PublicMessage(input.Topic, input.Message); MqttHostedService mqttHostedService = App.GetRequiredService<MqttHostedService>();
mqttHostedService.PublicMessage(input.Topic, input.Message);
} }
} }

1
Admin.NET/Admin.NET.Web.Core/Admin.NET.Web.Core.csproj
View File

@ -11,6 +11,7 @@
<ItemGroup> <ItemGroup>
<PackageReference Include="IGeekFan.AspNetCore.Knife4jUI" Version="0.0.16" /> <PackageReference Include="IGeekFan.AspNetCore.Knife4jUI" Version="0.0.16" />
<PackageReference Include="MQTTnet.AspNetCore" Version="5.0.1.1416" />
<PackageReference Include="System.Security.Cryptography.Pkcs" Version="9.0.2" /> <PackageReference Include="System.Security.Cryptography.Pkcs" Version="9.0.2" />
</ItemGroup> </ItemGroup>