xiaowei/DMS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

初步完成Mqtt后台服务的改造

Browse Source
This commit is contained in:
David P.G
2025-09-06 15:19:04 +08:00
parent 56130cd92a
commit e4cb38cd1d
18 changed files with 1047 additions and 315 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
DMS.Application/Services/DataCenterService.cs
View File

@@ -63,7 +63,7 @@ public class DataCenterService : IDataCenterService
/// <summary>
/// 当数据加载完成时触发
/// </summary>
public event EventHandler<DataLoadCompletedEventArgs> DataLoadCompleted;
public event EventHandler<DataLoadCompletedEventArgs> OnLoadDataCompleted;
/// <summary>
/// 当设备数据发生变化时触发
@@ -747,7 +747,7 @@ public class DataCenterService : IDataCenterService
/// </summary>
protected virtual void OnDataLoadCompleted(DataLoadCompletedEventArgs e)
{
DataLoadCompleted?.Invoke(this, e);
OnLoadDataCompleted?.Invoke(this, e);
}
/// <summary>

25
DMS.Application/Services/Processors/MqttPublishProcessor.cs
View File

@@ -10,11 +10,11 @@ namespace DMS.Application.Services.Processors;
/// </summary>
public class MqttPublishProcessor : IVariableProcessor
{
// private readonly MqttBackgroundService _mqttBackgroundService;
//
// public MqttPublishProcessor(MqttBackgroundService mqttBackgroundService)
// private readonly IMqttServiceManager _mqttServiceManager;
// public MqttPublishProcessor(IMqttServiceManager mqttServiceManager)
// {
// _mqttBackgroundService = mqttBackgroundService;
// // _mqttServiceManager = mqttServiceManager;
// }
/// <summary>
@@ -24,17 +24,24 @@ public class MqttPublishProcessor : IVariableProcessor
public async Task ProcessAsync(VariableContext context)
{
// var variable = context.Data;
// if (variable?.VariableMqtts == null || variable.VariableMqtts.Count == 0)
// if (variable?.MqttAliases == null || variable.MqttAliases.Count == 0)
// {
// return; // 没有关联的MQTT配置，直接返回
// }
//
// // 遍历所有关联的MQTT配置，并将其推入发送队列
// foreach (var variableMqtt in variable.VariableMqtts)
// foreach (var variableMqttAlias in variable.MqttAliases)
// {
// // 确保VariableMqtt对象中包含了最新的Variable数据
// variableMqtt.Variable = variable;
// await _mqttBackgroundService.SendVariableAsync(variableMqtt);
// // 创建VariableMqtt对象
// var variableMqtt = new VariableMqtt
// {
// Variable = variable,
// Mqtt = variableMqttAlias.MqttServer,
// MqttId = variableMqttAlias.MqttServerId
// };
//
// // 发布变量数据到MQTT服务器
// await _mqttServiceManager.PublishVariableDataAsync(variableMqtt);
// }
}
}