GithubStar/ThingsGateway
1
0
Fork 0
mirror of https://github.com/ThingsGateway/ThingsGateway.git synced 2026-10-23 08:48:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复添加订阅时,值死区过滤逻辑

Browse Source
This commit is contained in:
Kimdiego2098
2023-07-18 11:13:21 +08:00
parent a9d3017123
commit 36923d3190
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Plugins/ThingsGateway.Foundation.Adapter.OPCUA/OPCUAClient/OPCUAClient.cs
+8 -2
View File
@@ -283,12 +283,18 @@ public class OPCUAClient : DisposableObject
m_session.AddSubscription(m_subscription);
m_subscription.Create();
foreach (var item in m_subscription.MonitoredItems.Where(a => a.Status.Error?.StatusCode == Opc.Ua.StatusCodes.BadFilterNotAllowed))
foreach (var item in m_subscription.MonitoredItems.Where(a => a.Status.Error!=null&& StatusCode.IsBad( a.Status.Error.StatusCode)))
{
item.Filter = new DataChangeFilter() { DeadbandValue = OPCNode.DeadBand, DeadbandType = (int)DeadbandType.None, Trigger = DataChangeTrigger.StatusValue };
}
m_subscription.ApplyChanges();
var iserror = m_subscription.MonitoredItems.Any(a => a.Status.Error != null && StatusCode.IsBad(a.Status.Error.StatusCode));
if(iserror)
{
UpdateStatus(iserror, DateTime.UtcNow, m_subscription.MonitoredItems.FirstOrDefault(a => a.Status.Error != null && StatusCode.IsBad(a.Status.Error.StatusCode)).Status.Error.ToString());
}
lock (dic_subscriptions)
{
if (dic_subscriptions.ContainsKey(subscriptionName))
@@ -903,7 +909,7 @@ public class OPCUAClient : DisposableObject
m_session = await Opc.Ua.Client.Session.Create(
m_configuration,
endpoint,
true,
false,
false,
(string.IsNullOrEmpty(OPCUAName)) ? m_configuration.ApplicationName : OPCUAName,
60000,