OPC UA：如何打开服务器文件以在 OPC UA 中写入原始数据？

Question

我正在创建一个 C# 应用程序，它使用 OPC UA 将文件发送到西门子数控系统。

我正在使用 CopyFileToServer 方法。文件已创建，但我看到要传递文件中的原始数据，必须使用 filetype 中包含的 Open 方法，传递原始数据并调用 Close 方法关闭文件。我尝试了几次使用 Open 方法都没有成功。有人可以帮助我吗？

我在 Windows 10 64 位计算机上用 Visual Studio 2017 试过了。

public void SendFile(Opc.Ua.Client.Session session)
    {
        try
        {
            if (session != null)
            {

                NodeId node0 = new NodeId("ns=2;s=/Methods");
                NodeId node1 = new NodeId("ns=2;s=/Methods/GiveUserAccess");
                object[] argument0 = new object[2];

                argument0[0] = "USER";
                argument0[1] = "SinuWriteAll";

                session.Call(node0, node1, argument0);

                NodeId node = new NodeId("ns=2;s=/Methods");
                NodeId method = new NodeId("ns=2;s=/Methods/CopyFileToServer");
                object[] argument = new object[3];
                byte[] data = new byte[1];

                argument[0] = "Sinumerik/FileSystem/Part Program/sendFile.mpf";
                argument[1] = data;
                argument[2] = true;

                var a = session.Call(node, method, argument);

                NodeId nodeFile = new NodeId("file to open"); // The problem is this (i don't find the method for the file server nodeid)
                NodeId methodOpen = new NodeId("ns=0;i=11580");
                object[] argument1 = new object[1];
                argument1[0] = OpenFileMode.Write;

                var hndl = session.Call(nodeFile, methodOpen, argument1); // Exception 
            }
        }
        catch (Exception ex)
        {

        }
    }

上面的代码returns下面的异常：

"Bad invalid argument".

Answer 1

找到解决方案。

    NodeId open = new NodeId("ns=2;s=Sinumerik/FileSystem/Part Program/SENDFILE.MPF.Open");
    var parent = GetMethodParent(session, open);
    object[] argument1 = new object[1];
    argument1[0] = Convert.ToByte(OpenFileMode.Write);
    var hndl = session.Call(parent, open, argument1);

这样我就有了句柄来和write函数一起使用。在 NodeId "Open" 中表示要打开的文件。

函数"GetMethodParent":

private NodeId GetMethodParent(Session session, NodeId methodNodeId)
    {
        session.Browse(
          null,
          null,
          methodNodeId,
          0u,
          BrowseDirection.Inverse, //browse in inverse direction
          ReferenceTypeIds.HierarchicalReferences,
          true,
          (uint)NodeClass.Object, //only return nodes of type Object
          out _,
          out var references); //get all parent references

        var parentReference = references[0]; //a MethodNode can only have one parent reference
        return ExpandedNodeId.ToNodeId(parentReference.NodeId, session.NamespaceUris); //return the NodeId converted from an ExpandedNodeId
    }

Answer 2

一个重要的事情，就是在创建一个新的NodeId之后使用Browse方法。 Browse 方法，允许使用刚创建的新 NodeID 重新加载服务器树。

     private ReferenceDescriptionCollection Browse(Session session, BrowseDescription nodeToBrowse, bool throwOnError)
    {
        try
        {
            var descriptionCollection = new ReferenceDescriptionCollection();
            var nodesToBrowse = new BrowseDescriptionCollection { nodeToBrowse };
            BrowseResultCollection results;
            DiagnosticInfoCollection diagnosticInfos;
            session.Browse(null, null, 0U, nodesToBrowse, out results, out diagnosticInfos);
            ClientBase.ValidateResponse(results, nodesToBrowse);
            ClientBase.ValidateDiagnosticInfos(diagnosticInfos, nodesToBrowse);
            while (!StatusCode.IsBad(results[0].StatusCode))
            {
                for (var index = 0; index < results[0].References.Count; ++index)
                    descriptionCollection.Add(results[0].References[index]);
                if (results[0].References.Count == 0 || results[0].ContinuationPoint == null)
                    return descriptionCollection;
                var continuationPoints = new ByteStringCollection();
                continuationPoints.Add(results[0].ContinuationPoint);
                session.BrowseNext(null, false, continuationPoints, out results, out diagnosticInfos);
                ClientBase.ValidateResponse(results, continuationPoints);
                ClientBase.ValidateDiagnosticInfos(diagnosticInfos, continuationPoints);
            }
            throw new ServiceResultException(results[0].StatusCode);
        }
        catch (Exception ex)
        {
            if (throwOnError)
                throw new ServiceResultException(ex, 2147549184U);
            return null;
        }
    }
}

OPC UA：如何打开服务器文件以在 OPC UA 中写入原始数据？

OPC UA: How open a server file for write raw data in OPC UA?

c#

opc-ua