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

修复了一些错误

Browse Source
This commit is contained in:
David P.G
2025-07-05 17:15:03 +08:00
parent 57b28bf9bc
commit 33bdc5e131
3 changed files with 63 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
Services/S7BackgroundService.cs
View File

@@ -21,22 +21,31 @@ namespace PMSWPF.Services
private Thread _pollingThread; private Thread _pollingThread;
private CancellationTokenSource _cancellationTokenSource; private CancellationTokenSource _cancellationTokenSource;
private int readCount = 0;
private int TGCount = 0;
private readonly Dictionary<PollLevelType, TimeSpan> _pollingIntervals = new Dictionary<PollLevelType, TimeSpan> private readonly Dictionary<PollLevelType, TimeSpan> _pollingIntervals = new Dictionary<PollLevelType, TimeSpan>
{ {
{ PollLevelType.TenMilliseconds, TimeSpan.FromMilliseconds((int)PollLevelType.TenMilliseconds) }, { PollLevelType.TenMilliseconds, TimeSpan.FromMilliseconds((int)PollLevelType.TenMilliseconds) },
{ PollLevelType.HundredMilliseconds, TimeSpan.FromMilliseconds((int)PollLevelType.HundredMilliseconds) }, {
{ PollLevelType.FiveHundredMilliseconds, TimeSpan.FromMilliseconds((int)PollLevelType.FiveHundredMilliseconds) }, PollLevelType.HundredMilliseconds, TimeSpan.FromMilliseconds((int)PollLevelType.HundredMilliseconds)
{ PollLevelType.OneSecond, TimeSpan.FromMilliseconds((int)PollLevelType.OneSecond) }, },
{ PollLevelType.FiveSeconds, TimeSpan.FromMilliseconds((int)PollLevelType.FiveSeconds) }, {
{ PollLevelType.TenSeconds, TimeSpan.FromMilliseconds((int)PollLevelType.TenSeconds) }, PollLevelType.FiveHundredMilliseconds,
{ PollLevelType.TwentySeconds, TimeSpan.FromMilliseconds((int)PollLevelType.TwentySeconds) }, TimeSpan.FromMilliseconds((int)PollLevelType.FiveHundredMilliseconds)
{ PollLevelType.ThirtySeconds, TimeSpan.FromMilliseconds((int)PollLevelType.ThirtySeconds) }, },
{ PollLevelType.OneMinute, TimeSpan.FromMilliseconds((int)PollLevelType.OneMinute) }, { PollLevelType.OneSecond, TimeSpan.FromMilliseconds((int)PollLevelType.OneSecond) },
{ PollLevelType.ThreeMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.ThreeMinutes) }, { PollLevelType.FiveSeconds, TimeSpan.FromMilliseconds((int)PollLevelType.FiveSeconds) },
{ PollLevelType.FiveMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.FiveMinutes) }, { PollLevelType.TenSeconds, TimeSpan.FromMilliseconds((int)PollLevelType.TenSeconds) },
{ PollLevelType.TenMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.TenMinutes) }, { PollLevelType.TwentySeconds, TimeSpan.FromMilliseconds((int)PollLevelType.TwentySeconds) },
{ PollLevelType.ThirtyMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.ThirtyMinutes) } { PollLevelType.ThirtySeconds, TimeSpan.FromMilliseconds((int)PollLevelType.ThirtySeconds) },
}; { PollLevelType.OneMinute, TimeSpan.FromMilliseconds((int)PollLevelType.OneMinute) },
{ PollLevelType.ThreeMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.ThreeMinutes) },
{ PollLevelType.FiveMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.FiveMinutes) },
{ PollLevelType.TenMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.TenMinutes) },
{ PollLevelType.ThirtyMinutes, TimeSpan.FromMilliseconds((int)PollLevelType.ThirtyMinutes) }
};
private List<Device>? _s7Devices; private List<Device>? _s7Devices;
public S7BackgroundService(ILogger<S7BackgroundService> logger, DataServices dataServices) public S7BackgroundService(ILogger<S7BackgroundService> logger, DataServices dataServices)
@@ -62,9 +71,9 @@ namespace PMSWPF.Services
_cancellationTokenSource = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken); _cancellationTokenSource = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken);
_pollingThread = new Thread(() => PollingLoop(_cancellationTokenSource.Token)) _pollingThread = new Thread(() => PollingLoop(_cancellationTokenSource.Token))
{ {
IsBackground = true IsBackground = true
}; };
_pollingThread.Start(); _pollingThread.Start();
return Task.CompletedTask; return Task.CompletedTask;
@@ -81,9 +90,18 @@ namespace PMSWPF.Services
while (!stoppingToken.IsCancellationRequested) while (!stoppingToken.IsCancellationRequested)
{ {
// _logger.LogDebug("S7后台服务正在执行后台工作。"); // _logger.LogDebug("S7后台服务正在执行后台工作。");
// _logger.LogDebug($"开始轮询变量,当前时间：{DateTime.Now}");
readCount = 0;
TGCount = 0;
Stopwatch stopwatch = Stopwatch.StartNew();
PollS7Devices(stoppingToken); PollS7Devices(stoppingToken);
stopwatch.Stop();
// _logger.LogDebug($"结束轮询变量,当前时间：{DateTime.Now}");
_logger.LogDebug($"读取变量数：{readCount}个，跳过变量数：{TGCount}总耗时：{stopwatch.ElapsedMilliseconds}ms");
// 短暂休眠以防止CPU占用过高 // 短暂休眠以防止CPU占用过高
Thread.Sleep(100); Thread.Sleep(1000);
} }
_logger.LogInformation("S7轮询线程已停止。"); _logger.LogInformation("S7轮询线程已停止。");
@@ -128,6 +146,7 @@ namespace PMSWPF.Services
return null; // 重新连接失败，返回null return null; // 重新连接失败，返回null
} }
} }
return plcClient; // 返回连接成功的Plc客户端 return plcClient; // 返回连接成功的Plc客户端
} }
@@ -143,13 +162,15 @@ namespace PMSWPF.Services
try try
{ {
// 使用CancellationToken来使等待可取消 // 使用CancellationToken来使等待可取消
Task.Delay(TimeSpan.FromSeconds(5), stoppingToken).Wait(stoppingToken); Task.Delay(TimeSpan.FromSeconds(5), stoppingToken)
.Wait(stoppingToken);
} }
catch (OperationCanceledException) catch (OperationCanceledException)
{ {
// 如果在等待期间取消，则退出 // 如果在等待期间取消，则退出
return; return;
} }
return; return;
} }
@@ -164,10 +185,9 @@ namespace PMSWPF.Services
continue; // 如果连接失败，则跳过当前设备 continue; // 如果连接失败，则跳过当前设备
} }
// 读取设备变量 // 读取设备变量
ReadDeviceVariables(plcClient, device, stoppingToken); ReadDeviceVariables(plcClient, device, stoppingToken);
} }
} }
@@ -196,6 +216,7 @@ namespace PMSWPF.Services
// 遍历并读取每个S7变量 // 遍历并读取每个S7变量
foreach (var variable in s7Variables) foreach (var variable in s7Variables)
{ {
// Stopwatch stopwatch = Stopwatch.StartNew();
if (stoppingToken.IsCancellationRequested) return; // 如果取消令牌被请求，则停止读取 if (stoppingToken.IsCancellationRequested) return; // 如果取消令牌被请求，则停止读取
// 获取变量的轮询间隔 // 获取变量的轮询间隔
@@ -204,33 +225,40 @@ namespace PMSWPF.Services
_logger.LogWarning($"未知轮询级别 {variable.PollLevelType}，跳过变量 {variable.Name}。"); _logger.LogWarning($"未知轮询级别 {variable.PollLevelType}，跳过变量 {variable.Name}。");
continue; continue;
} }
Thread.Sleep(100);
// 检查是否达到轮询时间 // 检查是否达到轮询时间
if ((DateTime.Now - variable.LastPollTime) < interval) if ((DateTime.Now - variable.LastPollTime) < interval)
{ {
TGCount++;
continue; // 未到轮询时间，跳过 continue; // 未到轮询时间，跳过
} }
try try
{ {
// 从PLC读取变量值 // 从PLC读取变量值
var value = plcClient.Read(variable.S7Address); var value = plcClient.Read(variable.S7Address);
if (value != null) if (value != null)
{ {
// 更新变量的原始数据值和显示值 // 更新变量的原始数据值和显示值
variable.DataValue = value.ToString(); variable.DataValue = value.ToString();
variable.DisplayValue = SiemensHelper.ConvertS7Value(value, variable.DataType, variable.Converstion); 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}"); // _logger.LogDebug($"线程ID：{Environment.CurrentManagedThreadId},已读取变量 {variable.Name}: {variable.DataValue}");
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, $"从设备 {device.Name} 读取变量 {variable.Name} 失败。"); _logger.LogError(ex, $"从设备 {device.Name} 读取变量 {variable.Name} 失败。");
} }
// stopwatch.Stop();
// _logger.LogInformation($"读取变量耗时:{stopwatch.ElapsedMilliseconds}ms ");
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -262,4 +290,4 @@ namespace PMSWPF.Services
await base.StopAsync(stoppingToken); await base.StopAsync(stoppingToken);
} }
} }
} }

6
ViewModels/VariableTableViewModel.cs
View File

@@ -59,6 +59,12 @@ partial class VariableTableViewModel : ViewModelBase
// 推荐使用 JSON 序列化/反序列化进行深度拷贝 // 推荐使用 JSON 序列化/反序列化进行深度拷贝
var serialized = JsonConvert.SerializeObject(DataVariables); var serialized = JsonConvert.SerializeObject(DataVariables);
_originalDataVariables = JsonConvert.DeserializeObject<ObservableCollection<VariableData>>(serialized); _originalDataVariables = JsonConvert.DeserializeObject<ObservableCollection<VariableData>>(serialized);
// 在数据加载完成后，将所有变量的 IsModified 状态重置为 false
foreach (var variableData in DataVariables)
{
variableData.IsModified = false;
}
} }

4
Views/VariableTableView.xaml
View File

@@ -289,10 +289,10 @@
<DataGridTextColumn IsReadOnly="True" <DataGridTextColumn IsReadOnly="True"
Header="创建时间" Header="创建时间"
Binding="{Binding CreateTime}" /> Binding="{Binding CreateTime, StringFormat='{}{0:yyyy-MM-dd HH:mm:ss}'}" />
<DataGridTextColumn IsReadOnly="True" <DataGridTextColumn IsReadOnly="True"
Header="更新时间" Header="更新时间"
Binding="{Binding UpdateTime}" /> Binding="{Binding UpdateTime, StringFormat='{}{0:yyyy-MM-dd HH:mm:ss}'}" />
<DataGridTextColumn Header="转换规则" <DataGridTextColumn Header="转换规则"
Binding="{Binding Converstion}" /> Binding="{Binding Converstion}" />
<DataGridCheckBoxColumn Header="启用" <DataGridCheckBoxColumn Header="启用"