Федоренко Д.Ю. Программирование OPC клиентов на C++ и C# Часть 2. OPC HDA

Подождите немного. Документ загружается.

lvItem.mask = LVIF_TEXT;

m_listServerAggregates.DeleteAllItems();

int iIndex;

for (int i=0;i<dwAggregatesCount;i++)

{

lvItem.pszText = szAggregatesNames[i];

iIndex = m_listServerAggregates.InsertItem(&lvItem);

m_listServerAggregates.SetItemData(iIndex,

(DWORD_PTR)pdwAggregatesIDs[i]);

}

CoTaskMemFree(pdwAggregatesIDs);

CoTaskMemFree(szAggregatesNames);

CoTaskMemFree(szAggregatesDesc);

}

Теперь вызов этой функции необходимо вставить в ConnectAndBrowse()

сразу после того, как удачно получен интерфейс IOPCHDA_Server, т.е. должно

выглядеть следующим образом (вызов выделем курсивом и подчеркиванием)

void COPCHDAClientDlg::ConnectAndBrowseServer(GUID * pGuid)

{

if (m_pOPCHDAServer!=NULL)

m_pOPCHDAServer->Release();

IID IID_IOPCHDASERVER = __uuidof(IOPCHDA_Server);

HRESULT

hRes=CoCreateInstance(*pGuid,NULL,CLSCTX_LOCAL_SERVER,IID_IO

PCHDASERVER,(void**)&m_pOPCHDAServer);

if (hRes!=S_OK)

{

MessageBox(L"Не удалось подключиться к

серверу",L"Ошибка",MB_OK);

return;

}

GetSupportedAggregates();

………………………………………………………………..

………………………………………………………………….

В результате при выборе серверов у нас будет выводится список агрегации

каждого из них.

Рисунок 12. – Результат зпроса списка агрегаций, поддерживаемого

различными серверами

Теперь займемся чтением агрегаций.

Добавим функцию

unsigned long GetSelectedAggregateID();

Которая будет возвращать текущую выбранную из спика агрегацию

unsigned long COPCHDAClientDlg::GetSelectedAggregateID()

{

int iSelItem = m_listServerAggregates.GetSelectionMark();

if (-1 == iSelItem)

return 0;

unsigned long dwAggregateID = (unsigned long)

m_listServerAggregates.GetItemData(iSelItem);

return dwAggregateID;

}

Добавим на диалог поле ввода с подписью «Промежуток» и кнопку с

надписью считать агрегацию.

В поле «Промежуток» будем вводить временной промежуток, по

которому нужно рассчитывать агрегации в выбранных временных рамках.

Необходимо создать связанную с полем ввода переменную типа unsigned long.

В результате диалог примет вид как на рисунке

Рисунок 13. – Добавление поля ввода Промежутка агрегации и кнопки

синхронного чтения агрегаций.

Теперь, добавим обработчик нажатия на кнопку, который будет

считывать выбранную агрегация за выбранные временные рамки с заданным

интервалом.

void COPCHDAClientDlg::OnBnClickedAggregatevaluebtn()

{

LPWSTR szItemID = GetCurrentItemID();

if (NULL == szItemID) return;

unsigned long haAggregate = GetSelectedAggregateID();

if (0 == haAggregate)

return;

COleDateTime fromTime = GetFromDateTime();

COleDateTime toTime = GetToDateTime();

HRESULT *pErrors,hRes;

DWORD dwCount = 1;

unsigned long phClient=0;

unsigned long *hItems = NULL;

hRes=m_pOPCHDAServer->GetItemHandles(dwCount,&szItemID,

&phClient,&(hItems),&pErrors);

CoTaskMemFree(pErrors);

if (S_OK!=hRes)

{

MessageBox(L"Ошибка получения описателя элементов",

L"Ошибка",MB_OK);

return;

}

IOPCHDA_SyncRead *pSyncIO;

IID IID_IOPCHDASYNCREAD = __uuidof(IOPCHDA_SyncRead);

hRes = m_pOPCHDAServer->QueryInterface(IID_IOPCHDASYNCREAD,

(void**)&pSyncIO);

if (S_OK!=hRes)

{

MessageBox(L"Ошибка получения IOPCSyncRead",L"Ошибка",MB_OK);

return;

}

tagOPCHDA_TIME opcFromTime;

ZeroMemory(&opcFromTime,sizeof(opcFromTime));

SYSTEMTIME st;

fromTime.GetAsSystemTime(st);

SystemTimeToFileTime(&st,&(opcFromTime.ftTime));

tagOPCHDA_TIME opcToTime;

ZeroMemory(&opcToTime,sizeof(opcToTime));

toTime.GetAsSystemTime(st);

SystemTimeToFileTime(&st,&(opcToTime.ftTime));

tagOPCHDA_ITEM *pItemValues;

unsigned long dwMaxValuesCount = 1000;

long bBounds = false;

//переводим интервал в FILETIME

const __int64 iResInt = (__int64)m_dwInterval*60*10000000;

FILETIME ftResInterval;

ftResInterval.dwLowDateTime = iResInt;

ftResInterval.dwHighDateTime = (iResInt >> 32);

//Запрашиваем агрегацию

hRes = pSyncIO->ReadProcessed(&opcFromTime,&opcToTime,

ftResInterval,dwCount,hItems,

&haAggregate,&pItemValues,&pErrors);

if (S_OK!=hRes)

{

MessageBox(L"Ошибка синхронного чтения данных",L"Ошибка",MB_OK);

}

else

{

m_valueView.DeleteAllItems();

LVITEM lvItem;

ZeroMemory(&lvItem,sizeof(lvItem));

lvItem.cchTextMax = 25;

lvItem.mask = LVIF_TEXT;

lvItem.pszText = szItemID;

for (int i = 0;i<pItemValues->dwCount;i++)

{

lvItem.iItem = i;

m_valueView.InsertItem(&lvItem);

m_valueView.SetItem(i,1,LVIF_TEXT,

CToStringConverter::GetVTypeString(

pItemValues[0].pvDataValues[i].vt),0,0,0,0,0);

m_valueView.SetItem(i,2,LVIF_TEXT,

CString(pItemValues[0].pvDataValues[i]),0,0,0,0,0);

m_valueView.SetItem(i,3,LVIF_TEXT,

CToStringConverter::GetFTString(

pItemValues[0].pftTimeStamps[i]),0,0,0,0,0);

m_valueView.SetItem(i,4,LVIF_TEXT,

CToStringConverter::GetQualityString(

pItemValues[0].pdwQualities[i]),0,0,0,0,0);

}

CoTaskMemFree(pItemValues[0].pdwQualities);

CoTaskMemFree(pItemValues[0].pftTimeStamps);

CoTaskMemFree(pItemValues[0].pvDataValues);

CoTaskMemFree(pItemValues);

}

pSyncIO->Release();

}

На рисунке приведен пример чтения среднего значения за каждый час в течение

суток.

Рисунок 14. – Чтение агрегации TIMEAVERAGE из OPC DA сервера

Версия C#/.NET

Шаг 0. Подготовка диалога

Первое, что сделаем - создадим новое приложение Windows Forms и

назовем его OPCHDAClient.

Разместим два элемента управления ListView и TreeView. В первом мы

будем отображать список доступных OPC HDA серверов, а в дереве будем

показывать его структуру адресного пространства. Назовем их соответственно

m_listOPCServers и m_treeOPCServerBrowse

Рисунок 15. – Внешний вид диалога

Шаг 1. Просмотр установленных на локальной машине OPC HDA серверов

Как и вслучае OPC DA серверов для просмотра списка доступных OPC

HDA серверов будет использовать утилита OPCEnum.

Первое что необходимо – это импортировать объявления классов из

библиотеки OpcEnum.

Первое что необходимо – это импортировать объявления классов из

библиотеки OpcEnum. Т.к. этот файл уже является зарегистрированной

библиотекой типов, то его сразу можно включить в проект. Для этого

необходимо добавить ссылку на него, Project->Add Reference->COM-

>OPCEnum 1.1 Type Library.

Если все выполнено верно, то появится возможность использования

адресного пространства OPCEnumLib, которое мы можем включить в свой

проект обычным образом (выделено курсивом).

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Runtime.InteropServices;

using OpcEnumLib;

Путь к OPCEnum может отличаться для различных рабочих станций.

Теперь доступна работа с OPCEnum. Добавим функцию

ShowRegisteredServers, которая будет выводить список зарегистрированных на

локальном узле серверов, каждый раз при загрузке формы. Функция будет

добавлять в список установленные ОРС сервера и возвращать их общее

количество.

private int ShowRegisteredServers()

{

//Создаем объект списка OPC серверов

OpcServerList pServerList = new OpcServerList();

// Идентификатор категории ОРС HDA 1.2

Guid clsidcat = new Guid("{7DE5B060-E089-11D2-A5E6-

000086339399}");

//перечислитель, в котором будут храниться GUID серверов

IOPCEnumGUID pIOPCEnumGuid;

//запрос по группе серверов спецификации OPC HDA 1.2

pServerList.EnumClassesOfCategories(1, ref clsidcat, 0,

ref clsidcat, out pIOPCEnumGuid);

string pszProgID; // буфер для записи ProgID серверов

string pszUserType; // буфер для записи описания серверов

string pszVerIndProgID;

Guid guid = new Guid();

int nServerCnt = 0;

uint iRetSvr; // количество серверов, предоставленных запросом

// получение идентификаторов серверов

pIOPCEnumGuid.Next(1, out guid, out iRetSvr);

while (iRetSvr != 0)

{

nServerCnt++;

pServerList.GetClassDetails(ref guid, out pszProgID,

out pszUserType, out pszVerIndProgID);

ListViewItem lvItem = new ListViewItem();

lvItem.Tag = (object)guid;

lvItem.Text = pszProgID;

m_listOPCServers.Items.Add(lvItem);

pIOPCEnumGuid.Next(1, out guid, out iRetSvr);

}

return nServerCnt;

}

Теперь добавим обработчик события загрузки текущей формы(Load) и

поместим туда вызов функции ShowRegisteredServers.

protected void OnLoadForm(object sended, EventArgs e)

{

if (0 == ShowRegisteredServers())

{

MessageBox.Show("Нет установленных серверов");

}

Результат работы программы приведен на рисунке

Рисунок 16. – Результат просмотра списка доступных OPC HDA серверов

Шаг 2. Просмотр содержимого OPC сервера

По непонятным причинам в спецификации OPC HDA предусмотрен

отличный от DA с точки зрения объектной модели, но практически полностью

идентичный по идеологии способ просмотра адресного пространства. Идея его

состоит в том, что клиент не запрашивает интерфейс просмотра через

QueryInterface, а исползует функцию CreateBrowse для создания объекта

браузера и получения его единственного интерфейса IOPCHDA_Browser.

Как всегда при работе с COM экспортируем типы OPC HDA данных из

библиотеки типов и преобразуем их в типы .NET. Для этого необходимо найти

применить утилиту tlbImp к билбиотеке opchda_ps.dll, т.е. выполнить конманду

tlbImp.exe с:\Windows\system32\opchda_ps.dll /out:c:\opchda.dll

Тогда в корневом каталоге диска C появится библиотека opchda.dll,

ссылку на которую необходимо включить в проект (Solution Explorer-

>References->Add Reference->Browse).

После этого, станет доступным адресное пространство opchda, которое

необходимо подключить

using opchda;

Теперь мы можем обращаться к интерфейсам и методам OPC HDA.

Реализуем функцию, которая будет рекурсивно розвертывать адресное

пространство сервера

private void DisplayChildren(TreeNode ParentNode,IOPCHDA_Browser pParent)

{

uint cnt;

string strName;

string szItemID;

IEnumString pEnum;

// Вначале выводим все листья на данном уровне

pParent.GetEnum(tagOPCHDA_BROWSETYPE.OPCHDA_LEAF,out pEnum);

pEnum.RemoteNext(1, out strName, out cnt);

while (cnt != 0)

{

TreeNode tvNode;

if (ParentNode == null)

tvNode = m_treeOPCServerBrowse.Nodes.Add(strName);

else

tvNode = ParentNode.Nodes.Add(strName);

//получает полный идентификатор тега

pParent.GetItemID(strName, out szItemID);

tvNode.Tag = (object)szItemID;

pEnum.RemoteNext(1, out strName, out cnt);