0

我正在使用这个用于 WPF 的 ua-client 编写控制软件/HMI，并将 Kepwere 作为 OPC Server。

今天我正在做一些连接测试，断开我的PLC的以太网电缆并更改软件中的一些监控项值。显然这个改变不会因为连接状态而生效，但是，重新连接后为什么不用我之前设置的值刷新PLC标签呢？

或者这是预期的行为，我需要制作一些内部存储变量来复制它？

Kepserver 有一个 System.NoError 标记，指示 PLC 上是否存在错误，因此我知道 PLC 何时离线。但是我正在尝试在重新连接时离线时重新发送最新的更改。

我覆盖了 SetProperty 方法：

protected override bool SetProperty<T>(ref T storage, T value, [CallerMemberName] string propertyName = null)
{

    if(ServerState != CommunicationState.Opened || (!System_NoError && "System_NoError" != propertyName))
    {
        m_eventsPending.Add(new WriteEvent
        {
            PropertyName = propertyName,
            PropertyValue = value
        });
        return false;
    }

    return base.SetProperty(ref storage, value, propertyName);
}

然后用这个监听服务器状态改变事件：

public void OnStateChangeEvent(CommunicationState state)
{
    ServerState = state;
}

在 System_NoError 的每次更改中，我都会：

    private void OnError()
    {
        if(System_NoError)
        {
            while(m_eventsPending.Count > 0)
            {
                WriteEvent e = m_eventsPending.ElementAt(0);
                bool storage = !(bool)e.PropertyValue;
                var p = this.GetType().GetProperty(e.PropertyName);
                p.SetValue(this, storage);
                p.SetValue(this, e.PropertyValue);
                m_eventsPending.RemoveAt(0);
            }
        }
    }

我做了一些初始化并将其保留在 m_eventsPending 列表中，并在连接完成（打开）时开始发送，但 PLC 端没有发生任何事情。有什么问题？

PS：根据我的代码（按钮、滑块等），与软件的任何其他交互都会在 PLC 上进行正确的更改

最好的问候何塞·特鲁约尔

4

1 回答 1

0

考虑直接在属性设置器中编写标签。此示例尝试写入绿灯，每 5 秒重试一次，直到成功。

public class TrafficLightViewModel : ViewModelBase
{        
    private bool green;
    private bool red;
    private bool yellow;
    private CancellationTokenSource greenCts;
    private CancellationTokenSource redCts;
    private CancellationTokenSource yellowCts;
    private UaTcpSessionClient session;

    public TrafficLightViewModel(UaTcpSessionClient session)
    {
        this.session = session;
    }

    public bool Green
    {
        get { return this.green; }

        set
        {
            this.green = value;
            this.greenCts?.Cancel();
            this.greenCts = new CancellationTokenSource();
            var request = new WriteRequest
            {
                NodesToWrite = new[]
                {
                    new WriteValue
                    {
                        NodeId = NodeId.Parse("ns=2;s=GreenLight"),
                        AttributeId = AttributeIds.Value,
                        Value = new DataValue(value)
                    }
                }
            };
            this.WriteOutputAsync(request, this.greenCts.Token);
        }
    }

    // add yellow and red

    private async void WriteOutputAsync(WriteRequest request, CancellationToken token)
    {
        try
        {
            while (!await this.TryWriteAsync(request))
            {
                await Task.Delay(5000, token);
            }
        }
        catch (TaskCanceledException)
        {
            Debug.WriteLine($"Canceled writing output : {request.NodesToWrite[0].NodeId}");
        }
    }

    private async Task<bool> TryWriteAsync(WriteRequest request)
    {
        try
        {
            var response = await this.session.WriteAsync(request);
            for (int i = 0; i < response.Results.Length; i++)
            {
                if (StatusCode.IsBad(response.Results[i]))
                {
                    Debug.WriteLine($"Error writing output '{request.NodesToWrite[i].NodeId}' {request.NodesToWrite[i].Value.GetValue()}: {StatusCodes.GetDefaultMessage(response.Results[i])}");
                    return false;
                }
            }

            return true;
        }
        catch (Exception ex)
        {
            Debug.WriteLine($"Error writing outputs : {ex.Message}");
            return false;
        }
    }
}

希望这可以帮助。安德鲁

于 2016-08-31T02:28:16.770 回答