refactor: 增加 OpcWriteItem 类

Author: ArgoZhang

src/extensions/BootstrapBlazor.OpcDa/IOpcItem.cs

@@ -0,0 +1,16 @@
+// Copyright (c) Argo Zhang (argo@163.com). All rights reserved.
+// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Website: https://www.blazor.zone or https://argozhang.github.io/
+
+namespace BootstrapBlazor.OpcDa;
+
+/// <summary>
+/// 
+/// </summary>
+public interface IOpcItem
+{
+    /// <summary>
+    /// 
+    /// </summary>
+    string Name { get; }
+}

src/extensions/BootstrapBlazor.OpcDa/IOpcServer.cs

@@ -51,5 +51,12 @@ public interface IOpcServer : IDisposable
     /// </summary>
     /// <param name="items"></param>
     /// <returns></returns>
-    HashSet<OpcItem> Read(params List<string> items);
+    HashSet<OpcReadItem> Read(params HashSet<string> items);
+
+    /// <summary>
+    /// 读取 Item 值方法
+    /// </summary>
+    /// <param name="items"></param>
+    /// <returns></returns>
+    HashSet<OpcWriteItem> Write(params HashSet<OpcWriteItem> items);
 }

src/extensions/BootstrapBlazor.OpcDa/ISubscription.cs

@@ -12,7 +12,7 @@ public interface ISubscription
     /// <summary>
     /// 数据变更回调
     /// </summary>
-    Func<List<OpcItem>>? DataChanged { get; set; }
+    Func<List<OpcReadItem>>? DataChanged { get; set; }
 
     /// <summary>
     /// 获得 <see cref="Opc.Da.ISubscription"/> 实例

src/extensions/BootstrapBlazor.OpcDa/OpcItemEqualityComparer.cs

@@ -5,27 +5,27 @@
 namespace BootstrapBlazor.OpcDa;
 
 /// <summary>
-/// <see cref="OpcItem"/> 比较器
+/// <see cref="IOpcItem"/> 比较器
 /// </summary>
-public class OpcItemEqualityComparer : IEqualityComparer<OpcItem>
+public class OpcItemEqualityComparer<TItem> : IEqualityComparer<TItem> where TItem : IOpcItem
 {
     /// <summary>
-    /// 获得 <see cref="OpcItemEqualityComparer"/> 实例
+    /// 获得 <see cref="OpcItemEqualityComparer{TItem}"/> 实例
     /// </summary>
-    public static OpcItemEqualityComparer Default { get; } = new();
+    public static OpcItemEqualityComparer<TItem> Default { get; } = new();
 
     /// <summary>
     /// <inheritdoc/>
     /// </summary>
     /// <param name="x"></param>
     /// <param name="y"></param>
     /// <returns></returns>
-    public bool Equals(OpcItem x, OpcItem y) => x.Name == y.Name;
+    public bool Equals(TItem? x, TItem? y) => x?.Name == y?.Name;
 
     /// <summary>
     /// <inheritdoc/>
     /// </summary>
     /// <param name="item"></param>
     /// <returns></returns>
-    public int GetHashCode([DisallowNull] OpcItem item) => item.Name.GetHashCode();
+    public int GetHashCode([DisallowNull] TItem item) => item.Name.GetHashCode();
 }

…ensions/BootstrapBlazor.OpcDa/OpcItem.cs …ons/BootstrapBlazor.OpcDa/OpcReadItem.cssrc/extensions/BootstrapBlazor.OpcDa/OpcItem.cs renamed to src/extensions/BootstrapBlazor.OpcDa/OpcReadItem.cs src/extensions/BootstrapBlazor.OpcDa/OpcItem.cs renamed to src/extensions/BootstrapBlazor.OpcDa/OpcReadItem.cs

@@ -5,9 +5,9 @@
 namespace BootstrapBlazor.OpcDa;
 
 /// <summary>
-/// OPC Item 配置实体类
+/// OPC Item 读取实体类
 /// </summary>
-public record struct OpcItem(string Name, Quality Quality, DateTime Timestamp, object? Value)
+public record struct OpcReadItem(string Name, Quality Quality, DateTime Timestamp, object? Value) : IOpcItem
 {
     /// <summary>
     /// 获得 Opc Item 上次值

src/extensions/BootstrapBlazor.OpcDa/OpcServer.cs

@@ -16,7 +16,7 @@ namespace BootstrapBlazor.OpcDa;
 class OpcServer : IOpcServer
 {
     private Opc.Da.Server? _server = null;
-    private readonly ConcurrentDictionary<string, HashSet<OpcItem>> _valuesCache = [];
+    private readonly ConcurrentDictionary<string, HashSet<OpcReadItem>> _valuesCache = [];
 
     /// <summary>
     /// 获得 OPC Server 名称
@@ -101,12 +101,28 @@ public void CancelSubscription(ISubscription subscription)
     /// </summary>
     /// <param name="items"></param>
     /// <returns></returns>
-    /// <exception cref="InvalidOperationException"></exception>
-    public HashSet<OpcItem> Read(params List<string> items)
+    public HashSet<OpcReadItem> Read(params HashSet<string> items)
     {
         var server = GetOpcServer();
         var results = server.Read([.. items.Select(i => new Item() { ItemName = i })]);
-        return results.Select(i => new OpcItem(i.ItemName, i.Quality.ToQuality(), i.Timestamp, i.Value)).ToHashSet(OpcItemEqualityComparer.Default);
+        return results.Select(i => new OpcReadItem(i.ItemName, i.Quality.ToQuality(), i.Timestamp, i.Value)).ToHashSet(OpcItemEqualityComparer<OpcReadItem>.Default);
+    }
+
+    /// <summary>
+    /// 读取指定 Item 值方法
+    /// </summary>
+    /// <param name="items"></param>
+    /// <returns></returns>
+    public HashSet<OpcWriteItem> Write(params HashSet<OpcWriteItem> items)
+    {
+        var server = GetOpcServer();
+        var results = server.Write([.. items.Select(i => new ItemValue() { ItemName = i.Name, Value = i.Value })]);
+
+        return items.Select(i =>
+        {
+            var item = results.FirstOrDefault(v => v.ItemName == i.Name);
+            return new OpcWriteItem(i.Name, i.Value) { Result = item != null && item.ResultID == ResultID.S_OK };
+        }).ToHashSet(OpcItemEqualityComparer<OpcWriteItem>.Default);
     }
 
     private Opc.Da.Server GetOpcServer()

src/extensions/BootstrapBlazor.OpcDa/OpcSubscription.cs

@@ -6,7 +6,7 @@ namespace BootstrapBlazor.OpcDa;
 
 class OpcSubscription(Opc.Da.ISubscription subscription) : ISubscription
 {
-    public Func<List<OpcItem>>? DataChanged { get; set; }
+    public Func<List<OpcReadItem>>? DataChanged { get; set; }
 
     public Opc.Da.ISubscription GetSubscription() => subscription;
 }

src/extensions/BootstrapBlazor.OpcDa/OpcWriteItem.cs

@@ -0,0 +1,16 @@
+// Copyright (c) Argo Zhang (argo@163.com). All rights reserved.
+// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Website: https://www.blazor.zone or https://argozhang.github.io/
+
+namespace BootstrapBlazor.OpcDa;
+
+/// <summary>
+/// OPC Item 写入实体类
+/// </summary>
+public record struct OpcWriteItem(string Name, object? Value) : IOpcItem
+{
+    /// <summary>
+    /// 获得/设置 写入结果
+    /// </summary>
+    public bool Result { get; set; }
+}