添加了Mqtt服务器的连接，并添加了中文注释
This commit is contained in:
@@ -72,6 +72,7 @@ public partial class App : Application
|
||||
services.AddSingleton<IDialogService, DialogService>();
|
||||
services.AddSingleton<GrowlNotificationService>();
|
||||
services.AddHostedService<S7BackgroundService>(); // Register as HostedService
|
||||
services.AddHostedService<MqttBackgroundService>();
|
||||
services.AddSingleton<MainViewModel>();
|
||||
services.AddSingleton<HomeViewModel>();
|
||||
services.AddSingleton<DevicesViewModel>();
|
||||
@@ -193,6 +194,7 @@ public partial class App : Application
|
||||
_db.CodeFirst.InitTables<DbVariableS7Data>();
|
||||
_db.CodeFirst.InitTables<DbUser>();
|
||||
_db.CodeFirst.InitTables<DbMqtt>();
|
||||
_db.CodeFirst.InitTables<DbVariableDataMqtt>();
|
||||
_db.CodeFirst.InitTables<DbMenu>();
|
||||
}
|
||||
}
|
||||
@@ -19,6 +19,7 @@
|
||||
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="9.0.5" />
|
||||
<PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.5" />
|
||||
<PackageReference Include="Microsoft.Xaml.Behaviors.Wpf" Version="1.1.135" />
|
||||
<PackageReference Include="MQTTnet" Version="3.0.16" />
|
||||
<PackageReference Include="MySql.Data" Version="9.3.0" />
|
||||
<PackageReference Include="NLog" Version="6.0.0" />
|
||||
<PackageReference Include="NLog.Database" Version="6.0.0" />
|
||||
|
||||
@@ -12,100 +12,182 @@ using SqlSugar;
|
||||
|
||||
namespace PMSWPF.Services;
|
||||
|
||||
/// <summary>
|
||||
/// 数据服务类，负责从数据库加载和管理各种数据，并提供数据变更通知。
|
||||
/// 继承自ObservableRecipient，可以接收消息；实现IRecipient<LoadMessage>，处理加载消息。
|
||||
/// </summary>
|
||||
public partial class DataServices : ObservableRecipient, IRecipient<LoadMessage>
|
||||
{
|
||||
// 日志记录器，用于记录数据服务中的操作和错误。
|
||||
private readonly ILogger<DataServices> _logger;
|
||||
// 设备列表，使用ObservableProperty特性，当值改变时会自动触发属性变更通知。
|
||||
[ObservableProperty] private List<Device> _devices;
|
||||
// 变量表列表。
|
||||
[ObservableProperty] private List<VariableTable> _variableTables;
|
||||
// 变量数据列表。
|
||||
[ObservableProperty] private List<VariableData> _variableDatas;
|
||||
// 菜单树列表。
|
||||
[ObservableProperty] private List<MenuBean> menuTrees;
|
||||
// MQTT配置列表。
|
||||
[ObservableProperty] private List<Mqtt> _mqtts;
|
||||
|
||||
// 设备数据仓库，用于设备数据的CRUD操作。
|
||||
private readonly DeviceRepository _deviceRepository;
|
||||
// 菜单数据仓库，用于菜单数据的CRUD操作。
|
||||
private readonly MenuRepository _menuRepository;
|
||||
// MQTT数据仓库，用于MQTT配置数据的CRUD操作。
|
||||
private readonly MqttRepository _mqttRepository;
|
||||
// 变量数据仓库，用于变量数据的CRUD操作。
|
||||
private readonly VarDataRepository _varDataRepository;
|
||||
|
||||
// 设备列表变更事件，当设备列表数据更新时触发。
|
||||
public event EventHandler<List<Device>> OnDeviceListChanged;
|
||||
// 菜单树列表变更事件，当菜单树数据更新时触发。
|
||||
public event EventHandler<List<MenuBean>> OnMenuTreeListChanged;
|
||||
// MQTT列表变更事件，当MQTT配置数据更新时触发。
|
||||
public event EventHandler<List<Mqtt>> OnMqttListChanged;
|
||||
// 变量数据变更事件，当变量数据更新时触发。
|
||||
public event EventHandler<List<VariableData>> OnVariableDataChanged;
|
||||
|
||||
public event Action<List<Device>> OnDeviceListChanged;
|
||||
public event Action<List<MenuBean>> OnMenuTreeListChanged;
|
||||
public event Action<List<Mqtt>> OnMqttListChanged;
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 当_devices属性值改变时触发的局部方法，用于调用OnDeviceListChanged事件。
|
||||
/// </summary>
|
||||
/// <param name="devices">新的设备列表。</param>
|
||||
partial void OnDevicesChanged(List<Device> devices)
|
||||
{
|
||||
OnDeviceListChanged?.Invoke(devices);
|
||||
OnDeviceListChanged?.Invoke(this, devices);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 当menuTrees属性值改变时触发的局部方法，用于调用OnMenuTreeListChanged事件。
|
||||
/// </summary>
|
||||
/// <param name="MenuTrees">新的菜单树列表。</param>
|
||||
partial void OnMenuTreesChanged(List<MenuBean> MenuTrees)
|
||||
{
|
||||
OnMenuTreeListChanged?.Invoke(MenuTrees);
|
||||
OnMenuTreeListChanged?.Invoke(this, MenuTrees);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 当_mqtts属性值改变时触发的局部方法，用于调用OnMqttListChanged事件。
|
||||
/// </summary>
|
||||
/// <param name="mqtts">新的MQTT配置列表。</param>
|
||||
partial void OnMqttsChanged(List<Mqtt> mqtts)
|
||||
{
|
||||
OnMqttListChanged?.Invoke(mqtts);
|
||||
OnMqttListChanged?.Invoke(this, mqtts);
|
||||
}
|
||||
|
||||
// 注释掉的代码块，可能用于变量数据变更事件的触发，但目前未启用。
|
||||
// {
|
||||
// OnVariableDataChanged?.Invoke(this, value);
|
||||
// }
|
||||
|
||||
/// <summary>
|
||||
/// DataServices类的构造函数。
|
||||
/// 注入ILogger<DataServices>，并初始化各个数据仓库。
|
||||
/// </summary>
|
||||
/// <param name="logger">日志记录器实例。</param>
|
||||
public DataServices(ILogger<DataServices> logger)
|
||||
{
|
||||
_logger = logger;
|
||||
IsActive = true;
|
||||
IsActive = true; // 激活消息接收器
|
||||
_deviceRepository = new DeviceRepository();
|
||||
_menuRepository = new MenuRepository();
|
||||
_mqttRepository = new MqttRepository();
|
||||
_varDataRepository = new VarDataRepository();
|
||||
}
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 接受加载消息，收到消息后从数据库加载对应的数据
|
||||
/// 接收加载消息，根据消息类型从数据库加载对应的数据。
|
||||
/// </summary>
|
||||
/// <param name="message">消息的类型，如加载菜单LoadMessage.Menu</param>
|
||||
/// <exception cref="ArgumentException"></exception>
|
||||
/// <param name="message">加载消息，包含要加载的数据类型。</param>
|
||||
/// <exception cref="ArgumentException">如果加载类型未知，可能会抛出此异常（尽管当前实现中未显式抛出）。</exception>
|
||||
public async void Receive(LoadMessage message)
|
||||
{
|
||||
try
|
||||
{
|
||||
switch (message.LoadType)
|
||||
{
|
||||
case LoadTypes.All:
|
||||
case LoadTypes.All: // 加载所有数据
|
||||
await LoadDevices();
|
||||
await LoadMenus();
|
||||
await LoadMqtts();
|
||||
await LoadVariableDatas();
|
||||
break;
|
||||
case LoadTypes.Devices:
|
||||
case LoadTypes.Devices: // 仅加载设备数据
|
||||
await LoadDevices();
|
||||
break;
|
||||
case LoadTypes.Menu:
|
||||
case LoadTypes.Menu: // 仅加载菜单数据
|
||||
await LoadMenus();
|
||||
break;
|
||||
case LoadTypes.Mqtts:
|
||||
case LoadTypes.Mqtts: // 仅加载MQTT配置数据
|
||||
await LoadMqtts();
|
||||
break;
|
||||
}
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
// 捕获加载数据时发生的异常，并通过通知和日志记录错误信息。
|
||||
NotificationHelper.ShowMessage($"加载数据出现了错误：{e.Message}");
|
||||
_logger.LogError($"加载数据出现了错误：{e}");
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 异步加载设备数据。
|
||||
/// </summary>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task LoadDevices()
|
||||
{
|
||||
Devices = await _deviceRepository.GetAll();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 异步加载菜单数据，并进行父级关联和排序。
|
||||
/// </summary>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task LoadMenus()
|
||||
{
|
||||
MenuTrees = await _menuRepository.GetMenuTrees();
|
||||
foreach (MenuBean menu in MenuTrees)
|
||||
{
|
||||
MenuHelper.MenuAddParent(menu);
|
||||
DataServicesHelper.SortMenus(menu);
|
||||
MenuHelper.MenuAddParent(menu); // 为菜单添加父级引用
|
||||
DataServicesHelper.SortMenus(menu); // 排序菜单
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 异步获取所有MQTT配置。
|
||||
/// </summary>
|
||||
/// <returns>包含所有MQTT配置的列表。</returns>
|
||||
public async Task<List<Mqtt>> GetMqttsAsync()
|
||||
{
|
||||
return await _mqttRepository.GetAll();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 异步加载MQTT配置数据。
|
||||
/// </summary>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task LoadMqtts()
|
||||
{
|
||||
Mqtts = await _mqttRepository.GetAll();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 异步获取所有变量数据。
|
||||
/// </summary>
|
||||
/// <returns>包含所有变量数据的列表。</returns>
|
||||
public async Task<List<VariableData>> GetAllVariableDataAsync()
|
||||
{
|
||||
return await _varDataRepository.GetAllAsync();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 异步加载变量数据。
|
||||
/// </summary>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task LoadVariableDatas()
|
||||
{
|
||||
VariableDatas = await _varDataRepository.GetAllAsync();
|
||||
}
|
||||
}
|
||||
292
Services/MqttBackgroundService.cs
Normal file
292
Services/MqttBackgroundService.cs
Normal file
@@ -0,0 +1,292 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Threading;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Extensions.Hosting;
|
||||
using NLog;
|
||||
using MQTTnet;
|
||||
using MQTTnet.Client;
|
||||
using MQTTnet.Client.Options;
|
||||
using PMSWPF.Models;
|
||||
using PMSWPF.Services;
|
||||
using PMSWPF.Helper;
|
||||
using PMSWPF.Enums;
|
||||
|
||||
namespace PMSWPF.Services
|
||||
{
|
||||
/// <summary>
|
||||
/// MQTT后台服务，继承自BackgroundService，用于在后台管理MQTT连接和数据发布。
|
||||
/// </summary>
|
||||
public class MqttBackgroundService : BackgroundService
|
||||
{
|
||||
// NLog日志记录器，用于记录服务运行时的信息、警告和错误。
|
||||
private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
|
||||
// 数据服务实例，用于访问和操作应用程序数据，如MQTT配置和变量数据。
|
||||
private readonly DataServices _dataServices;
|
||||
// 存储MQTT客户端实例的字典，键为MQTT配置ID，值为IMqttClient对象。
|
||||
private readonly Dictionary<int, IMqttClient> _mqttClients;
|
||||
// 存储MQTT配置的字典，键为MQTT配置ID，值为Mqtt模型对象。
|
||||
private readonly Dictionary<int, Mqtt> _mqttConfigurations;
|
||||
// 存储与MQTT配置关联的变量数据的字典，键为MQTT配置ID，值为VariableData列表。
|
||||
private readonly Dictionary<int, List<VariableData>> _mqttVariableData;
|
||||
// 定时器，用于周期性地执行数据发布任务。
|
||||
private Timer _timer;
|
||||
|
||||
/// <summary>
|
||||
/// 构造函数，注入DataServices。
|
||||
/// </summary>
|
||||
/// <param name="dataServices">数据服务实例。</param>
|
||||
public MqttBackgroundService(DataServices dataServices)
|
||||
{
|
||||
_dataServices = dataServices;
|
||||
_mqttClients = new Dictionary<int, IMqttClient>();
|
||||
_mqttConfigurations = new Dictionary<int, Mqtt>();
|
||||
_mqttVariableData = new Dictionary<int, List<VariableData>>();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 后台服务的执行方法，当服务启动时调用。
|
||||
/// </summary>
|
||||
/// <param name="stoppingToken">用于取消操作的CancellationToken。</param>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
Logger.Info("MqttBackgroundService started."); // 记录服务启动信息
|
||||
|
||||
// 订阅MQTT列表和变量数据变化的事件，以便在数据更新时重新加载配置和数据。
|
||||
_dataServices.OnMqttListChanged += HandleMqttListChanged;
|
||||
_dataServices.OnVariableDataChanged += HandleVariableDataChanged;
|
||||
|
||||
// 初始加载MQTT配置和变量数据。
|
||||
await LoadMqttConfigurations();
|
||||
await LoadVariableData();
|
||||
|
||||
// 初始化定时器，每5秒执行一次DoWork方法，用于周期性地发布数据。
|
||||
_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromSeconds(5)); // 每5秒轮询一次
|
||||
|
||||
// 使服务保持运行，直到收到停止请求。
|
||||
await Task.Delay(Timeout.Infinite, stoppingToken);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 后台服务的停止方法，当服务停止时调用。
|
||||
/// </summary>
|
||||
/// <param name="stoppingToken">用于取消操作的CancellationToken。</param>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
public override async Task StopAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
Logger.Info("MqttBackgroundService stopping."); // 记录服务停止信息
|
||||
|
||||
// 停止定时器。
|
||||
_timer?.Change(Timeout.Infinite, 0);
|
||||
|
||||
// 取消订阅事件。
|
||||
_dataServices.OnMqttListChanged -= HandleMqttListChanged;
|
||||
_dataServices.OnVariableDataChanged -= HandleVariableDataChanged;
|
||||
|
||||
// 断开所有已连接的MQTT客户端。
|
||||
foreach (var client in _mqttClients.Values)
|
||||
{
|
||||
if (client.IsConnected)
|
||||
{
|
||||
await client.DisconnectAsync();
|
||||
}
|
||||
}
|
||||
// 清空所有字典。
|
||||
_mqttClients.Clear();
|
||||
_mqttConfigurations.Clear();
|
||||
_mqttVariableData.Clear();
|
||||
|
||||
await base.StopAsync(stoppingToken);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 定时器回调方法，用于周期性地检查并发布已修改的变量数据。
|
||||
/// </summary>
|
||||
/// <param name="state">定时器状态对象（此处未使用）。</param>
|
||||
private async void DoWork(object state)
|
||||
{
|
||||
// 遍历所有MQTT配置关联的变量数据。
|
||||
foreach (var mqttConfigId in _mqttVariableData.Keys)
|
||||
{
|
||||
// 检查MQTT客户端是否连接。
|
||||
if (_mqttClients.TryGetValue(mqttConfigId, out var client) && client.IsConnected)
|
||||
{
|
||||
var variables = _mqttVariableData[mqttConfigId];
|
||||
// 遍历与当前MQTT配置关联的变量。
|
||||
foreach (var variable in variables)
|
||||
{
|
||||
// 如果变量已被修改（IsModified标志为true）。
|
||||
if (variable.IsModified)
|
||||
{
|
||||
// 获取发布主题。
|
||||
var topic = _mqttConfigurations[mqttConfigId].PublishTopic;
|
||||
if (!string.IsNullOrEmpty(topic))
|
||||
{
|
||||
// 构建MQTT消息。
|
||||
var message = new MqttApplicationMessageBuilder()
|
||||
.WithTopic($"{topic}/{variable.Name}") // 主题格式：PublishTopic/VariableName
|
||||
.WithPayload(variable.DataValue) // 消息载荷为变量的值
|
||||
.Build();
|
||||
|
||||
// 发布MQTT消息。
|
||||
await client.PublishAsync(message);
|
||||
Logger.Info($"Published {variable.Name} = {variable.DataValue} to {topic}/{variable.Name}"); // 记录发布信息
|
||||
variable.IsModified = false; // 发布后重置修改标志。
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 加载并连接MQTT配置。
|
||||
/// </summary>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task LoadMqttConfigurations()
|
||||
{
|
||||
// 从数据服务获取所有MQTT配置。
|
||||
var mqtts = await _dataServices.GetMqttsAsync();
|
||||
foreach (var mqtt in mqtts)
|
||||
{
|
||||
// 如果客户端字典中不包含当前MQTT配置的客户端，则尝试连接。
|
||||
if (!_mqttClients.ContainsKey(mqtt.Id))
|
||||
{
|
||||
await ConnectMqttClient(mqtt);
|
||||
}
|
||||
// 更新或添加MQTT配置到字典。
|
||||
_mqttConfigurations[mqtt.Id] = mqtt;
|
||||
}
|
||||
|
||||
// 断开并移除不再配置中的MQTT客户端。
|
||||
var removedMqttIds = _mqttClients.Keys.Except(mqtts.Select(m => m.Id)).ToList();
|
||||
foreach (var id in removedMqttIds)
|
||||
{
|
||||
if (_mqttClients.ContainsKey(id))
|
||||
{
|
||||
var client = _mqttClients[id];
|
||||
if (client.IsConnected)
|
||||
{
|
||||
await client.DisconnectAsync();
|
||||
}
|
||||
_mqttClients.Remove(id);
|
||||
Logger.Info($"Disconnected and removed MQTT client for ID: {id}");
|
||||
}
|
||||
_mqttConfigurations.Remove(id);
|
||||
_mqttVariableData.Remove(id);
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 连接到指定的MQTT代理。
|
||||
/// </summary>
|
||||
/// <param name="mqtt">MQTT配置对象。</param>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task ConnectMqttClient(Mqtt mqtt)
|
||||
{
|
||||
try
|
||||
{
|
||||
// 创建MQTT客户端工厂和客户端实例。
|
||||
var factory = new MqttFactory();
|
||||
var client = factory.CreateMqttClient();
|
||||
// 构建MQTT客户端连接选项。
|
||||
var options = new MqttClientOptionsBuilder()
|
||||
.WithClientId(mqtt.ClientID)
|
||||
.WithTcpServer(mqtt.Host, mqtt.Port)
|
||||
.WithCredentials(mqtt.UserName, mqtt.PassWord)
|
||||
.WithCleanSession() // 清理会话，每次连接都是新会话
|
||||
.Build();
|
||||
|
||||
// 设置连接成功事件处理程序。
|
||||
client.UseConnectedHandler(e =>
|
||||
{
|
||||
Logger.Info($"Connected to MQTT broker: {mqtt.Name}");
|
||||
NotificationHelper.ShowMessage($"已连接到MQTT服务器: {mqtt.Name}", NotificationType.Success);
|
||||
});
|
||||
|
||||
// 设置断开连接事件处理程序。
|
||||
client.UseDisconnectedHandler(async e =>
|
||||
{
|
||||
Logger.Warn($"Disconnected from MQTT broker: {mqtt.Name}. Reason: {e.Reason}");
|
||||
NotificationHelper.ShowMessage($"与MQTT服务器断开连接: {mqtt.Name}", NotificationType.Warning);
|
||||
// 尝试重新连接。
|
||||
await Task.Delay(TimeSpan.FromSeconds(5)); // 等待5秒后重连
|
||||
try
|
||||
{
|
||||
await client.ConnectAsync(options, CancellationToken.None);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logger.Error(ex, $"Failed to reconnect to MQTT broker: {mqtt.Name}");
|
||||
}
|
||||
});
|
||||
|
||||
// 尝试连接到MQTT代理。
|
||||
await client.ConnectAsync(options, CancellationToken.None);
|
||||
// 将连接成功的客户端添加到字典。
|
||||
_mqttClients[mqtt.Id] = client;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logger.Error(ex, $"Failed to connect to MQTT broker: {mqtt.Name}");
|
||||
NotificationHelper.ShowMessage($"连接MQTT服务器失败: {mqtt.Name} - {ex.Message}", NotificationType.Error);
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 加载所有变量数据并按MQTT配置ID进行分组。
|
||||
/// </summary>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
private async Task LoadVariableData()
|
||||
{
|
||||
// 从数据服务获取所有变量数据。
|
||||
var allVariables = await _dataServices.GetAllVariableDataAsync();
|
||||
_mqttVariableData.Clear(); // 清空现有数据
|
||||
|
||||
// 遍历所有变量，并根据其关联的MQTT配置进行分组。
|
||||
foreach (var variable in allVariables)
|
||||
{
|
||||
if (variable.Mqtts != null)
|
||||
{
|
||||
foreach (var mqtt in variable.Mqtts)
|
||||
{
|
||||
// 如果字典中没有该MQTT配置的条目，则创建一个新的列表。
|
||||
if (!_mqttVariableData.ContainsKey(mqtt.Id))
|
||||
{
|
||||
_mqttVariableData[mqtt.Id] = new List<VariableData>();
|
||||
}
|
||||
// 将变量添加到对应MQTT配置的列表中。
|
||||
_mqttVariableData[mqtt.Id].Add(variable);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 处理MQTT列表变化事件的回调方法。
|
||||
/// </summary>
|
||||
/// <param name="sender">事件发送者。</param>
|
||||
/// <param name="mqtts">更新后的MQTT配置列表。</param>
|
||||
private async void HandleMqttListChanged(object sender, List<Mqtt> mqtts)
|
||||
{
|
||||
Logger.Info("MQTT list changed. Reloading configurations."); // 记录MQTT列表变化信息
|
||||
// 重新加载MQTT配置和变量数据。
|
||||
await LoadMqttConfigurations();
|
||||
await LoadVariableData(); // 重新加载变量数据，以防关联发生变化
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 处理变量数据变化事件的回调方法。
|
||||
/// </summary>
|
||||
/// <param name="sender">事件发送者。</param>
|
||||
/// <param name="variableDatas">更新后的变量数据列表。</param>
|
||||
private async void HandleVariableDataChanged(object sender, List<VariableData> variableDatas)
|
||||
{
|
||||
Logger.Info("Variable data changed. Reloading variable associations."); // 记录变量数据变化信息
|
||||
// 重新加载变量数据。
|
||||
await LoadVariableData();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -13,17 +13,28 @@ using PMSWPF.Helper;
|
||||
|
||||
namespace PMSWPF.Services
|
||||
{
|
||||
/// <summary>
|
||||
/// S7后台服务，继承自BackgroundService，用于在后台周期性地轮询S7 PLC设备数据。
|
||||
/// </summary>
|
||||
public class S7BackgroundService : BackgroundService
|
||||
{
|
||||
// 日志记录器，用于记录服务运行时的信息、警告和错误。
|
||||
private readonly ILogger<S7BackgroundService> _logger;
|
||||
// 数据服务实例，用于访问和操作应用程序数据，如设备配置。
|
||||
private readonly DataServices _dataServices;
|
||||
// 存储S7 PLC客户端实例的字典，键为设备ID，值为Plc对象。
|
||||
private readonly Dictionary<int, Plc> _s7PlcClients = new Dictionary<int, Plc>();
|
||||
// 轮询数据的线程。
|
||||
private Thread _pollingThread;
|
||||
// 用于取消轮询操作的CancellationTokenSource。
|
||||
private CancellationTokenSource _cancellationTokenSource;
|
||||
|
||||
// 读取变量计数器。
|
||||
private int readCount = 0;
|
||||
// 跳过变量计数器（未到轮询时间）。
|
||||
private int TGCount = 0;
|
||||
|
||||
// 定义不同轮询级别的间隔时间。
|
||||
private readonly Dictionary<PollLevelType, TimeSpan> _pollingIntervals = new Dictionary<PollLevelType, TimeSpan>
|
||||
{
|
||||
{ PollLevelType.TenMilliseconds, TimeSpan.FromMilliseconds((int)PollLevelType.TenMilliseconds) },
|
||||
@@ -46,17 +57,30 @@ namespace PMSWPF.Services
|
||||
{ PollLevelType.ThirtyMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.ThirtyMinutes) }
|
||||
};
|
||||
|
||||
// 存储S7设备列表。
|
||||
private List<Device>? _s7Devices;
|
||||
|
||||
/// <summary>
|
||||
/// 构造函数，注入ILogger和DataServices。
|
||||
/// </summary>
|
||||
/// <param name="logger">日志记录器实例。</param>
|
||||
/// <param name="dataServices">数据服务实例。</param>
|
||||
public S7BackgroundService(ILogger<S7BackgroundService> logger, DataServices dataServices)
|
||||
{
|
||||
_logger = logger;
|
||||
_dataServices = dataServices;
|
||||
// 订阅设备列表变更事件，以便在设备配置更新时重新加载。
|
||||
_dataServices.OnDeviceListChanged += HandleDeviceListChanged;
|
||||
}
|
||||
|
||||
private void HandleDeviceListChanged(List<Device> devices)
|
||||
/// <summary>
|
||||
/// 处理设备列表变更事件的回调方法。
|
||||
/// </summary>
|
||||
/// <param name="sender">事件发送者。</param>
|
||||
/// <param name="devices">更新后的设备列表。</param>
|
||||
private void HandleDeviceListChanged(object sender, List<Device> devices)
|
||||
{
|
||||
// 过滤出S7协议且激活的设备。
|
||||
_s7Devices = devices.Where(d => d.ProtocolType == ProtocolType.S7 && d.IsActive)
|
||||
.ToList();
|
||||
// 当设备列表变化时，更新PLC客户端
|
||||
@@ -65,28 +89,42 @@ namespace PMSWPF.Services
|
||||
_logger.LogInformation("设备列表已更改。S7客户端可能需要重新初始化。");
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 后台服务的执行方法，当服务启动时调用。
|
||||
/// </summary>
|
||||
/// <param name="stoppingToken">用于取消操作的CancellationToken。</param>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
protected override Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
_logger.LogInformation("S7后台服务正在启动。");
|
||||
// 创建一个CancellationTokenSource，用于控制轮询线程的取消。
|
||||
_cancellationTokenSource = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken);
|
||||
|
||||
// 创建并启动轮询线程。
|
||||
_pollingThread = new Thread(() => PollingLoop(_cancellationTokenSource.Token))
|
||||
{
|
||||
IsBackground = true
|
||||
IsBackground = true // 设置为后台线程，随主程序退出而退出
|
||||
};
|
||||
_pollingThread.Start();
|
||||
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 轮询循环方法，在新线程中执行，周期性地读取S7设备数据。
|
||||
/// </summary>
|
||||
/// <param name="stoppingToken">用于取消轮询的CancellationToken。</param>
|
||||
private void PollingLoop(CancellationToken stoppingToken)
|
||||
{
|
||||
_logger.LogInformation("S7轮询线程已启动。");
|
||||
// 注册取消回调，当服务停止时记录日志。
|
||||
stoppingToken.Register(() => _logger.LogInformation("S7后台服务正在停止。"));
|
||||
|
||||
// 初始加载S7设备列表。
|
||||
_s7Devices = _dataServices.Devices?.Where(d => d.ProtocolType == ProtocolType.S7 && d.IsActive)
|
||||
.ToList();
|
||||
|
||||
// 轮询循环，直到收到取消请求。
|
||||
while (!stoppingToken.IsCancellationRequested)
|
||||
{
|
||||
// _logger.LogDebug("S7后台服务正在执行后台工作。");
|
||||
@@ -94,13 +132,13 @@ namespace PMSWPF.Services
|
||||
readCount = 0;
|
||||
TGCount = 0;
|
||||
|
||||
Stopwatch stopwatch = Stopwatch.StartNew();
|
||||
PollS7Devices(stoppingToken);
|
||||
stopwatch.Stop();
|
||||
Stopwatch stopwatch = Stopwatch.StartNew(); // 启动计时器，测量轮询耗时
|
||||
PollS7Devices(stoppingToken); // 执行S7设备轮询
|
||||
stopwatch.Stop(); // 停止计时器
|
||||
// _logger.LogDebug($"结束轮询变量,当前时间：{DateTime.Now}");
|
||||
_logger.LogDebug($"读取变量数：{readCount}个，跳过变量数：{TGCount}总耗时：{stopwatch.ElapsedMilliseconds}ms");
|
||||
|
||||
// 短暂休眠以防止CPU占用过高
|
||||
// 短暂休眠以防止CPU占用过高，并控制轮询频率。
|
||||
Thread.Sleep(1000);
|
||||
}
|
||||
|
||||
@@ -109,84 +147,86 @@ namespace PMSWPF.Services
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 初始化或重新连接PLC客户端
|
||||
/// 初始化或重新连接PLC客户端。
|
||||
/// </summary>
|
||||
/// <param name="device">S7设备</param>
|
||||
/// <returns>连接成功的Plc客户端实例，如果连接失败则返回null</returns>
|
||||
/// <param name="device">S7设备。</param>
|
||||
/// <returns>连接成功的Plc客户端实例，如果连接失败则返回null。</returns>
|
||||
private Plc? InitializePlcClient(Device device)
|
||||
{
|
||||
// 检查字典中是否已存在该设备的PLC客户端
|
||||
// 检查字典中是否已存在该设备的PLC客户端。
|
||||
if (!_s7PlcClients.TryGetValue(device.Id, out var plcClient))
|
||||
{
|
||||
// 如果不存在，则创建新的Plc客户端
|
||||
// 如果不存在，则创建新的Plc客户端。
|
||||
try
|
||||
{
|
||||
plcClient = new Plc(device.CpuType, device.Ip, (short)device.Prot, device.Rack, device.Slot);
|
||||
plcClient.Open(); // 尝试打开连接
|
||||
_s7PlcClients[device.Id] = plcClient; // 将新创建的客户端添加到字典
|
||||
plcClient.Open(); // 尝试打开连接。
|
||||
_s7PlcClients[device.Id] = plcClient; // 将新创建的客户端添加到字典。
|
||||
_logger.LogInformation($"已连接到S7 PLC: {device.Name} ({device.Ip})");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, $"连接S7 PLC失败: {device.Name} ({device.Ip})");
|
||||
return null; // 连接失败，返回null
|
||||
return null; // 连接失败，返回null。
|
||||
}
|
||||
}
|
||||
else if (!plcClient.IsConnected)
|
||||
{
|
||||
// 如果存在但未连接，则尝试重新连接
|
||||
// 如果存在但未连接，则尝试重新连接。
|
||||
try
|
||||
{
|
||||
plcClient.Open(); // 尝试重新打开连接
|
||||
plcClient.Open(); // 尝试重新打开连接。
|
||||
_logger.LogInformation($"已重新连接到S7 PLC: {device.Name} ({device.Ip})");
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, $"重新连接S7 PLC失败: {device.Name} ({device.Ip})");
|
||||
return null; // 重新连接失败，返回null
|
||||
return null; // 重新连接失败，返回null。
|
||||
}
|
||||
}
|
||||
|
||||
return plcClient; // 返回连接成功的Plc客户端
|
||||
return plcClient; // 返回连接成功的Plc客户端。
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 轮询S7设备数据
|
||||
/// 轮询S7设备数据。
|
||||
/// </summary>
|
||||
/// <param name="stoppingToken">取消令牌</param>
|
||||
/// <param name="stoppingToken">取消令牌。</param>
|
||||
private void PollS7Devices(CancellationToken stoppingToken)
|
||||
{
|
||||
// 如果没有活跃的S7设备，则等待一段时间后重试。
|
||||
if (_s7Devices == null || !_s7Devices.Any())
|
||||
{
|
||||
_logger.LogDebug("未找到活跃的S7设备进行轮询。等待5秒后重试。");
|
||||
try
|
||||
{
|
||||
// 使用CancellationToken来使等待可取消
|
||||
// 使用CancellationToken来使等待可取消。
|
||||
Task.Delay(TimeSpan.FromSeconds(5), stoppingToken)
|
||||
.Wait(stoppingToken);
|
||||
}
|
||||
catch (OperationCanceledException)
|
||||
{
|
||||
// 如果在等待期间取消，则退出
|
||||
// 如果在等待期间取消，则退出。
|
||||
return;
|
||||
}
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
// 遍历所有S7设备。
|
||||
foreach (var device in _s7Devices)
|
||||
{
|
||||
if (stoppingToken.IsCancellationRequested) return;
|
||||
if (stoppingToken.IsCancellationRequested) return; // 如果收到取消请求，则停止。
|
||||
|
||||
// 尝试获取或初始化PLC客户端连接
|
||||
// 尝试获取或初始化PLC客户端连接。
|
||||
var plcClient = InitializePlcClient(device);
|
||||
if (plcClient == null)
|
||||
{
|
||||
continue; // 如果连接失败，则跳过当前设备
|
||||
continue; // 如果连接失败，则跳过当前设备。
|
||||
}
|
||||
|
||||
|
||||
// 读取设备变量
|
||||
// 读取设备变量。
|
||||
ReadDeviceVariables(plcClient, device, stoppingToken);
|
||||
}
|
||||
}
|
||||
@@ -199,7 +239,7 @@ namespace PMSWPF.Services
|
||||
/// <param name="stoppingToken">取消令牌。</param>
|
||||
private void ReadDeviceVariables(Plc plcClient, Device device, CancellationToken stoppingToken)
|
||||
{
|
||||
// 过滤出当前设备和S7协议相关的变量
|
||||
// 过滤出当前设备和S7协议相关的变量。
|
||||
var s7Variables = device.VariableTables
|
||||
.Where(vt => vt.ProtocolType == ProtocolType.S7 && vt.IsActive)
|
||||
.SelectMany(vt => vt.DataVariables)
|
||||
@@ -213,40 +253,40 @@ namespace PMSWPF.Services
|
||||
|
||||
try
|
||||
{
|
||||
// 遍历并读取每个S7变量
|
||||
// 遍历并读取每个S7变量。
|
||||
foreach (var variable in s7Variables)
|
||||
{
|
||||
// Stopwatch stopwatch = Stopwatch.StartNew();
|
||||
if (stoppingToken.IsCancellationRequested) return; // 如果取消令牌被请求，则停止读取
|
||||
if (stoppingToken.IsCancellationRequested) return; // 如果取消令牌被请求，则停止读取。
|
||||
|
||||
// 获取变量的轮询间隔
|
||||
// 获取变量的轮询间隔。
|
||||
if (!_pollingIntervals.TryGetValue(variable.PollLevelType, out var interval))
|
||||
{
|
||||
_logger.LogWarning($"未知轮询级别 {variable.PollLevelType}，跳过变量 {variable.Name}。");
|
||||
continue;
|
||||
}
|
||||
|
||||
// 检查是否达到轮询时间
|
||||
// 检查是否达到轮询时间。
|
||||
if ((DateTime.Now - variable.LastPollTime) < interval)
|
||||
{
|
||||
TGCount++;
|
||||
continue; // 未到轮询时间，跳过
|
||||
continue; // 未到轮询时间，跳过。
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
|
||||
// 从PLC读取变量值
|
||||
// 从PLC读取变量值。
|
||||
var value = plcClient.Read(variable.S7Address);
|
||||
if (value != null)
|
||||
{
|
||||
// 更新变量的原始数据值和显示值
|
||||
// 更新变量的原始数据值和显示值。
|
||||
variable.DataValue = value.ToString();
|
||||
variable.DisplayValue
|
||||
= SiemensHelper.ConvertS7Value(value, variable.DataType, variable.Converstion);
|
||||
variable.UpdateTime = DateTime.Now;
|
||||
|
||||
variable.LastPollTime = DateTime.Now; // 更新最后轮询时间
|
||||
variable.LastPollTime = DateTime.Now; // 更新最后轮询时间。
|
||||
readCount++;
|
||||
// _logger.LogDebug($"线程ID：{Environment.CurrentManagedThreadId},已读取变量 {variable.Name}: {variable.DataValue}");
|
||||
}
|
||||
@@ -266,16 +306,21 @@ namespace PMSWPF.Services
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 后台服务的停止方法，当服务停止时调用。
|
||||
/// </summary>
|
||||
/// <param name="stoppingToken">用于取消操作的CancellationToken。</param>
|
||||
/// <returns>表示异步操作的任务。</returns>
|
||||
public override async Task StopAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
_logger.LogInformation("S7 Background Service is stopping.");
|
||||
|
||||
// Signal the polling thread to stop
|
||||
// 发出信号，请求轮询线程停止。
|
||||
_cancellationTokenSource?.Cancel();
|
||||
// Wait for the polling thread to finish
|
||||
// 等待轮询线程完成。
|
||||
_pollingThread?.Join();
|
||||
|
||||
// Close all active PLC connections
|
||||
// 关闭所有活跃的PLC连接。
|
||||
foreach (var plcClient in _s7PlcClients.Values)
|
||||
{
|
||||
if (plcClient.IsConnected)
|
||||
@@ -285,7 +330,7 @@ namespace PMSWPF.Services
|
||||
}
|
||||
}
|
||||
|
||||
_s7PlcClients.Clear();
|
||||
_s7PlcClients.Clear(); // 清空PLC客户端字典。
|
||||
|
||||
await base.StopAsync(stoppingToken);
|
||||
}
|
||||
|
||||
@@ -53,7 +53,7 @@ public partial class DevicesViewModel : ViewModelBase
|
||||
_dataServices = dataServices;
|
||||
|
||||
MessageHelper.SendLoadMessage(LoadTypes.Devices);
|
||||
_dataServices.OnDeviceListChanged += (devices) => { Devices = new ObservableCollection<Device>(devices); };
|
||||
_dataServices.OnDeviceListChanged += (sender, devices) => { Devices = new ObservableCollection<Device>(devices); };
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
|
||||
@@ -61,7 +61,7 @@ public partial class MainViewModel : ViewModelBase
|
||||
// 发送消息加载数据
|
||||
MessageHelper.SendLoadMessage(LoadTypes.All);
|
||||
// 当菜单加载成功后，在前台显示菜单
|
||||
dataServices.OnMenuTreeListChanged += (menus) => { Menus = new ObservableCollection<MenuBean>(menus); };
|
||||
dataServices.OnMenuTreeListChanged += (sender, menus) => { Menus = new ObservableCollection<MenuBean>(menus); };
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
|
||||
@@ -43,7 +43,7 @@ public partial class MqttsViewModel : ViewModelBase
|
||||
}
|
||||
|
||||
|
||||
_dataServices.OnMqttListChanged += (mqtts) =>
|
||||
_dataServices.OnMqttListChanged += (sender, mqtts) =>
|
||||
{
|
||||
Mqtts = new ObservableCollection<Mqtt>(mqtts);
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user