opc UA .net 源码 2016年的1.33版本

/* ======================================================================== * Copyright (c) 2005-2011 The OPC Foundation, Inc. All rights reserved. * * OPC Foundation MIT License 1.00 * * Permission is hereby granted, free of charge, to any person * obtaining a copy of this software and associated documentation * files (the "Software"), to deal in the Software without * restriction, including without limitation the rights to use, * copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the * Software is furnished to do so, subject to the following * conditions: * * The above copyright notice and this permission notice shall be * included in all copies or substantial portions of the Software. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR * OTHER DEALINGS IN THE SOFTWARE. * * The complete license agreement can be found here: * http://opcfoundation.org/License/MIT/1.00/ * ======================================================================*/ #include "StdAfx.h" #include "OpcUaComProxyServer.h" #include "COpcUaHdaProxyServer.h" #include "COpcUaProxyUtils.h" #include "COpcUaHdaProxyBrowser.h" #include "COpcUaHdaProxyDataCallback.h" using namespace System; using namespace System::Text; using namespace System::Runtime::InteropServices; using namespace System::Reflection; using namespace System::Collections::Generic; using namespace System::Security::Cryptography::X509Certificates; using namespace Opc::Ua; using namespace Opc::Ua::Com; using namespace Opc::Ua::Com::Server; //============================================================================== // Static Functions /// <summary> /// Writes a trace message. /// </summary> static void TraceState(String^ context, ... array<Object^>^ args) { #ifdef TRACESTATE COpcUaProxyUtils::TraceState("COpcUaHdaProxyServer", context, args); #endif } struct OpcHdaAttributeDesc { DWORD dwID; VARTYPE vtDataType; LPCWSTR szName; LPCWSTR szDescription; }; OpcHdaAttributeDesc g_AttributeTable[] = { { OPCHDA_DATA_TYPE, VT_I2, OPCHDA_ATTRNAME_DATA_TYPE, L"Specifies the data type for the item." }, { OPCHDA_DESCRIPTION, VT_BSTR, OPCHDA_ATTRNAME_DESCRIPTION, L"Describes the item." }, { OPCHDA_ENG_UNITS, VT_BSTR, OPCHDA_ATTRNAME_ENG_UNITS, L"The label to use in displays to define the units for the item (e.g., kg/sec)." }, { OPCHDA_STEPPED, VT_BOOL, OPCHDA_ATTRNAME_STEPPED, L"Whether data from the history repository should be displayed as interpolated or stepped." }, { OPCHDA_ARCHIVING, VT_BOOL, OPCHDA_ATTRNAME_ARCHIVING, L"Indicates whether historian is recording data for this item." }, { OPCHDA_DERIVE_EQUATION, VT_BSTR, OPCHDA_ATTRNAME_DERIVE_EQUATION, L"Specifies the equation to be used by a derived item to calculate its value." }, { OPCHDA_NORMAL_MAXIMUM, VT_R8, OPCHDA_ATTRNAME_NORMAL_MAXIMUM, L"Specifies the upper limit for the normal value range for the item." }, { OPCHDA_NORMAL_MINIMUM, VT_R8, OPCHDA_ATTRNAME_NORMAL_MINIMUM, L"Specifies the lower limit for the normal value range for the item." }, { OPCHDA_ITEMID, VT_BSTR, OPCHDA_ATTRNAME_ITEMID, L"Specifies the leaf name portion the item id." }, { OPCHDA_MAX_TIME_INT, VT_CY, OPCHDA_ATTRNAME_MAX_TIME_INT, L"Specifies the maximum interval between data points in the history repository." }, { OPCHDA_MIN_TIME_INT, VT_CY, OPCHDA_ATTRNAME_MIN_TIME_INT, L"Specifies the minimum interval between data points in the history repository." }, { OPCHDA_EXCEPTION_DEV, VT_R8, OPCHDA_ATTRNAME_EXCEPTION_DEV, L"Specifies the minimum amount that the data for the item must change in order for the change to be reported to the history database." }, { OPCHDA_EXCEPTION_DEV_TYPE, VT_I2, OPCHDA_ATTRNAME_EXCEPTION_DEV_TYPE, L"Specifies whether the exception deviation is given as an absolute value, percent of span, or percent of value." }, { OPCHDA_HIGH_ENTRY_LIMIT, VT_R8, OPCHDA_ATTRNAME_HIGH_ENTRY_LIMIT, L"Specifies the highest valid value for the item." }, { OPCHDA_LOW_ENTRY_LIMIT, VT_R8, OPCHDA_ATTRNAME_LOW_ENTRY_LIMIT, L"Specifies the lowest valid value for the item." }, { 0, VT_EMPTY, NULL, NULL } }; static void* AllocArray(int size, int count) { // allocate return array. void* pValues = CoTaskMemAlloc(size*count); // check allocations. if (pValues == NULL) { throw gcnew System::OutOfMemoryException(); } // initialize results. memset(pValues, 0, size*count); return pValues; } #define ALLOC_ARRAY(xType, xCount) (xType*)AllocArray(sizeof(xType),xCount) // Copy(HRESULT) HRESULT Copy( array<int>^ results, DWORD dwNumItems, HRESULT* pErrors) { HRESULT hResult = S_OK; for (DWORD ii = 0; ii < dwNumItems; ii++) { pErrors[ii] = results[ii]; if (pErrors[ii] != S_OK) { hResult = S_FALSE; } } return hResult; } // Copy(HdaUpdateRequest) HRESULT Copy( List<HdaUpdateRequest^>^ results, DWORD dwNumItems, OPCHANDLE* phClient, HRESULT* pErrors) { HRESULT hResult = S_OK; for (DWORD ii = 0; ii < dwNumItems; ii++) { phClient[ii] = results[ii]->ClientHandle; pErrors[ii] = results[ii]->Error; if (pErrors[ii] != S_OK) { hResult = S_FALSE; } } return hResult; } // MarshalRequests static HRESULT MarshalRequests( array<DaValue^>^ values, VARIANT* pvValues, DWORD* pdwQualities, ::FILETIME* pftTimeStamps) { // check arguments. if (pvValues == NULL || pdwQualities == NULL || pftTimeStamps == NULL) { return E_INVALIDARG; } DWORD dwCount = values->Length; try { // fix any marshalling issues. COpcUaProxyUtils::FixupInputVariants(dwCount, pvValues); // copy data. for (int ii = 0; ii < values->Length; ii++) { values[ii] = gcnew DaValue(); values[ii]->Value = Marshal::GetObjectForNativeVariant((IntPtr)&(pvValues[ii])); values[ii]->Timestamp = COpcUaProxyUtils::ResolveTime(&(pftTimeStamps[ii])); values[ii]->HdaQuality = pdwQualities[ii]; } return S_OK; } catch (Exception^ e) { // extract unexpected error. return Marshal::GetHRForException(e); } } // MarshalRequests static HRESULT MarshalRequests( array<int>^ serverHandles, array<DateTime>^ timestamps, array<array<Annotation^>^>^ annotations, OPCHANDLE* phServer, ::FILETIME* ftTimeStamps, OPCHDA_ANNOTATION* pAnnotationValues) { // check arguments. if (pAnnotationValues == NULL || ftTimeStamps == NULL) { return E_INVALIDARG; } DWORD dwCount = serverHandles->Length; try { for (int ii = 0; ii < serverHandles->Length; ii++) { // marshal handle/timestamps. serverHandles[ii] = phServer[ii]; timestamps[ii] = COpcUaProxyUtils::ResolveTime(&(ftTimeStamps[ii])); if (pAnnotationValues[ii].dwNumValues == 0) { continue; } // marhsal annotations. List<Annotation^>^ list = gcnew List<Annotation