using HslCommunication.Profinet.Siemens;
|
using System;
|
using System.Threading;
|
using System.Threading.Tasks;
|
|
namespace PLCHelper
|
{
|
public class DataChangedArg<T>
|
{
|
public T oldValue { get; set; }
|
public T newValue { get; set; }
|
}
|
|
public class IntReader
|
{
|
private int lastVallue = 0;
|
|
private string Address = string.Empty;
|
private int Timeout = 1000;
|
|
private SiemensS7Net client;
|
|
private volatile bool isRunning = false;
|
|
public event EventHandler<DataChangedArg<int>> DataChanged;
|
|
public IntReader(SiemensS7Net client, string address, int initValue = 0)
|
{
|
this.client = client;
|
this.Address = address;
|
this.lastVallue = initValue;
|
}
|
|
public void Stop()
|
{
|
isRunning = false;
|
}
|
|
public void Run()
|
{
|
isRunning = true;
|
Task.Run(() =>
|
{
|
while (isRunning)
|
{
|
var res = client.ReadInt16(Address);
|
if (res.IsSuccess)
|
{
|
int val = res.Content;
|
if (val != lastVallue)
|
{
|
DataChanged?.Invoke(this, new DataChangedArg<int>
|
{
|
oldValue = lastVallue,
|
newValue = val
|
});
|
lastVallue = val;
|
}
|
}
|
Thread.Sleep(Timeout);
|
}
|
});
|
}
|
}
|
}
|
