g82tt/ThingsGateway
1
0
Fork 0
mirror of https://gitee.com/ThingsGateway/ThingsGateway.git synced 2025-10-21 11:08:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

OPCUACClient订阅初始化添加trycatch

Browse Source
This commit is contained in:
Kimdiego2098
2023-08-13 16:29:59 +08:00
parent 96d98e8f39
commit 9b42fa78e7
1 changed files with 19 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
framework/ThingsGateway.Plugin/Foundataion/ThingsGateway.Foundation.Adapter.OPCUA/OPCUAClient/OPCUAClient.cs
View File

@@ -205,7 +205,7 @@ public class OPCUAClient : DisposableObject
#region 订阅
/// <summary>
/// 新增订阅，需要指定订阅的关键字，订阅的tag名数组，以及回调方法
/// 新增订阅，需要指定订阅组名称，订阅的tag名数组
/// </summary>
public async Task AddSubscriptionAsync(string subscriptionName, string[] items)
{
@@ -222,19 +222,26 @@ public class OPCUAClient : DisposableObject
List<MonitoredItem> monitoredItems = new();
for (int i = 0; i < items.Length; i++)
{
var variableNode = (VariableNode)ReadNode(items[i], false);
var item = new MonitoredItem
try
{
StartNodeId = variableNode.NodeId,
AttributeId = Attributes.Value,
DisplayName = items[i],
Filter = new DataChangeFilter() { DeadbandValue = OPCNode.DeadBand, DeadbandType = (int)DeadbandType.Absolute, Trigger = DataChangeTrigger.StatusValue },
SamplingInterval = OPCNode?.UpdateRate ?? 1000,
};
await typeSystem.LoadType(variableNode.DataType, true, true);
var variableNode = (VariableNode)ReadNode(items[i], false);
var item = new MonitoredItem
{
StartNodeId = variableNode.NodeId,
AttributeId = Attributes.Value,
DisplayName = items[i],
Filter = new DataChangeFilter() { DeadbandValue = OPCNode.DeadBand, DeadbandType = (int)DeadbandType.Absolute, Trigger = DataChangeTrigger.StatusValue },
SamplingInterval = OPCNode?.UpdateRate ?? 1000,
};
await typeSystem.LoadType(variableNode.DataType, true, true);
item.Notification += Callback;
monitoredItems.Add(item);
item.Notification += Callback;
monitoredItems.Add(item);
}
catch (Exception ex)
{
Log.Error($"初始化{items[i]}变量订阅失败" + ex.Message);
}
}
m_subscription.AddItems(monitoredItems);