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

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

Версия C++/MFC

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

Первое, что сделаем - создадим диалоговый проект (MFC Dialog based) и

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

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

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

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

Т.к. нам часто придется обращаться к созданным элементам управления,

то необходимо создать соответствующие им переменные.

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

private:

CListCtrl m_listOPCServers;

CTreeCtrl m_treeOPCServerBrowse;

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

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

серверов будет использовать утилита OPCEnum, которая кратко описана в [1].

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

библиотеки OpcEnum. Для этого необходимо найти директорию, где

расположена утилита и в свой проект вставить директиву препроцессора import

с указанием абсолютного пути к файлу OPCEnum.exe. Т.е. необходимо

добавить экспорт типов в файл stdafx.h

#import "с:\\Windows\system32\opcenum.exe" \

rename_namespace OPCENUM

using namespace OPCENUM;

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

Теперь добавим в класс COPCClientDlg объявление функции

private:

int ShowRegisteredServers();

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

возвращать их общее количество.

int COPCHDAClientDlg::ShowRegisteredServers()

{

CLSID clsid; // индентификатор ОРСEnum

CLSID clsidcat; //идентифификатор категории ОРС DA серверов

HRESULT hRes;

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

hRes=CLSIDFromString(L"{58E13251-AC87-11D1-84D5-

00608CB8A7E9}",&clsidcat);

// Идентификатор компонента просмотра списка серверов

hRes=CLSIDFromProgID(L"OPC.ServerList",&clsid);

//Идентификатор интерфейса IOPCServerList

IID IID_IOPCServerList=__uuidof(IOPCServerList);

IOPCServerList *pServerList;

// запрос интерфейса у компонента должен вернуть S_OK

hRes=CoCreateInstance(clsid,NULL,CLSCTX_LOCAL_SERVER,

IID_IOPCServerList,(void**)&pServerList);

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

IEnumGUID * pIOPCEnumGuid;

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

pServerList->EnumClassesOfCategories(1, &clsidcat,0,

NULL,&pIOPCEnumGuid);

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

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

LVITEM lvItem; // подготовка элемента списка для вставки

ZeroMemory(&lvItem,sizeof(lvItem));

lvItem.cchTextMax=100;

lvItem.mask=LVIF_TEXT;

GUID guid; // Сюда будет записывать идентификатор текущего сервера

int nServerCnt=0; // общее количество доступных серверов

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

запросом

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

pIOPCEnumGuid->Next(1,&guid,&iRetSvr);

while (iRetSvr!=0)

{

nServerCnt++;

pServerList->GetClassDetails(&guid,&pszProgID,&pszUserType);

lvItem.pszText=pszProgID;

int iItem=m_listOPCServers.InsertItem(&lvItem);

GUID *pGuid = new GUID;

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

привязке к строке списка

memcpy(pGuid,&guid,sizeof(guid));

//связываем элемент списка и указатель на идентификатор

m_listOPCServers.SetItemData(iItem,(DWORD_PTR)pGuid);

pIOPCEnumGuid->Next(1,&guid,&iRetSvr);

}

return nServerCnt;

}

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

инициализацию COM. Код, отвечающий за все это выделен курсивом

BOOL COPCHDAClientDlg::OnInitDialog()

{

CDialogEx::OnInitDialog();

ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);

ASSERT(IDM_ABOUTBOX < 0xF000);

CMenu* pSysMenu = GetSystemMenu(FALSE);

if (pSysMenu != NULL)

{

BOOL bNameValid;

CString strAboutMenu;

bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);

ASSERT(bNameValid);

if (!strAboutMenu.IsEmpty())

{

pSysMenu->AppendMenu(MF_SEPARATOR);

pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);

}

SetIcon(m_hIcon, TRUE); // Set big icon

SetIcon(m_hIcon, FALSE); // Set small icon

CoInitialize(NULL);

if (0 == ShowRegisteredServers())

MessageBox(L"Нет установленных OPCHDA серверов",

L"Сообщение",MB_OK);

return TRUE;

}

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

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

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

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

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

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

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

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

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

библиотеки типов, для чего включим в stdafx.h следующий код

#import "c:\\Windows\system32\opchda_ps.dll" \

rename_namespace("OPCHDA")

using namespace OPCHDA;

Добавим переменную, в которой будет хранить текущее подключение к

серверу, интерфейс IOPCHDA_Server

private:

IOPCHDA_Server* m_pOPCHDAServer;

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

private:

void DisplayChildren(HTREEITEM hParent,IOPCHDA_Browser* pParent);

Реализация, которой имеет вид

void COPCHDAClientDlg::DisplayChildren(HTREEITEM hParent,

IOPCHDA_Browser* pParent)

{

IEnumString *pEnum;

HTREEITEM hItem;

wchar_t * strName,*strTst;

unsigned long cnt;

TVINSERTSTRUCT tvInsert;

ZeroMemory(&tvInsert,sizeof(tvInsert));

pParent->GetEnum(OPCHDA_LEAF,&pEnum);

tvInsert.item.cchTextMax=100;

tvInsert.item.mask=TVIF_TEXT;

tvInsert.hParent=hParent;

pEnum->Next(1,&strName,&cnt);

LPWSTR lpItemID;

while (cnt!=0)

{

tvInsert.item.pszText=strName;

hItem=m_treeOPCServerBrowse.InsertItem(&tvInsert);

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

pParent->GetItemID(strName,&lpItemID);

m_treeOPCServerBrowse.SetItemData(hItem,(DWORD_PTR)lpItemID);

pEnum->Next(1,&strName,&cnt);

}

pParent->GetEnum(OPCHDA_BRANCH,&pEnum);

tvInsert.hParent=hParent;

pEnum->Next(1,&strName,&cnt);

HRESULT hRes;

tvInsert.item.iImage=0;

tvInsert.item.iSelectedImage=0;

while (cnt!=0)

{

tvInsert.item.pszText=strName;

hItem=this->m_treeOPCServerBrowse.InsertItem(&tvInsert);

hRes=pParent->ChangeBrowsePosition(OPCHDA_BROWSE_DOWN,strName);

if (S_OK==hRes)

DisplayChildren(hItem,pParent);

pParent->ChangeBrowsePosition(OPCHDA_BROWSE_UP,strName);

pEnum->Next(1,&strName,&cnt);

}

Как можно заметить, она практически идентична просмотру адресного

пространства с помощью интерфейса IOPCBrowseServerAddressSpace.

И, наконец, реализуем функцию ConnectAndBrowseServer(GUID *guid),

которая, как и в случае OPC DA, будет подключаться к серверу и вызывать

экспорт адресного пространства.

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_IOPCHDASERVER,(void**)&m_pOPCHDAServer);

if (hRes!=S_OK)

{

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

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

return;

}

//создаем объект браузера

IOPCHDA_Browser *pBrowser;

HRESULT *pErrors;

/*Эти параметры используются для задания фильтров

на этапе создания браузера, у нас фильтров не будет -

по-этому они игнорируются */

unsigned long dwCount = 0;

unsigned long dwAttrID = 0;

tagOPCHDA_OPERATORCODES Operator = OPCHDA_EQUAL;

VARIANT vFilter;

//Вызываем метод создания браузер

hRes = m_pOPCHDAServer->CreateBrowse(dwCount,&dwAttrID,

&Operator,&vFilter,&pBrowser,&pErrors);

if (hRes!=S_OK)

{

MessageBox(L"Не удалось создать объект браузера",L"Ошибка",MB_OK);

return;

}

DisplayChildren(TVI_ROOT,pBrowser);

CoTaskMemFree(pErrors);

pBrowser->Release();

}

Вызов этой функции необходимо вставить в обработчик изменения

текущего выделения списка серверов

void COPCHDAClientDlg::OnLvnItemchangingOPCList(NMHDR *pNMHDR,

LRESULT *pResult)

{

LPNMLISTVIEW pNMLV = reinterpret_cast<LPNMLISTVIEW>(pNMHDR);

BOOL bSelectedNow = ( pNMLV->uNewState & LVIS_SELECTED);

BOOL bSelectedBefore = (pNMLV ->uOldState & LVIS_SELECTED);

HRESULT hRes = S_OK;

if ( bSelectedNow && !bSelectedBefore )

{

int nItem = pNMLV->iItem;

m_treeOPCServerBrowse.DeleteAllItems();

GUID * pGuid=(GUID*)m_listOPCServers.GetItemData(nItem);

ConnectAndBrowseServer(pGuid);

}

*pResult = 0;

}

И, наконец, в конструкторе класса диалога необходимо обнулить

указатель на интерфейс сервера

COPCHDAClientDlg::COPCHDAClientDlg(CWnd* pParent /*=NULL*/)

: CDialogEx(COPCHDAClientDlg::IDD, pParent)

{

m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);

m_pOPCHDAServer = NULL;

}

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

Шаг 3.1. Синхронное чтение данных из сервера

Теперь займемся реализацией синхронного чтения. Т.к. OPCHDA

предоставляет доступ к архивным данным, то логчным будет вынести элементы

управления, которые бы позволяли задавать временные рамки для выборки

данных.

Для этого вынесем 4 элемента DateTimePicker и сгрупиируем их как

показано на рисунке.

Рисунок 7. – Добавление элементов управления для работы со временем

Логично предположить, что в группе «Начиная с» будет задаваться

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

переменные

public:

CDateTimeCtrl m_fromDate;

CDateTimeCtrl m_fromTime;

, а в группе «Оканчивая» конечное и соответственно переменные

public:

CDateTimeCtrl m_toDate;

CDateTimeCtrl m_toTime;

Кроме того, реализуем две функции, которые будут считывать выбранные

пользователем временные рамки и возвращать их в формате COleDateTime для

последующего исползования.

public:

COleDateTime GetFromDateTime(); // Время и дата начала выборки

COleDateTime GetToDateTime(); // Время и дата конца выборки

Реализация этих функций имеет следующий вид

COleDateTime COPCHDAClientDlg::GetFromDateTime()

{

COleDateTime retFromDateTime, tmpFromDate,tmpFromTime;

//считываем дату начала выборки

m_fromDate.GetTime(tmpFromDate);

//считываем время начала выборки

m_fromTime.GetTime(tmpFromTime);

//совмещаем дату и время начала выборки

retFromDateTime.SetDateTime(tmpFromDate.GetYear(),

tmpFromDate.GetMonth(),tmpFromDate.GetDay()

tmpFromTime.GetHour(),tmpFromTime.GetMinute(),

tmpFromTime.GetSecond());

return retFromDateTime;

}

COleDateTime COPCHDAClientDlg::GetToDateTime()

{

COleDateTime retToDateTime, tmpToDate,tmpToTime;

//считываем дату конца выборки

m_toDate.GetTime(tmpToDate);

//считываем время конца выборки

m_toTime.GetTime(tmpToTime);

//совмещаем дату и время начала выборки

retToDateTime.SetDateTime(tmpToDate.GetYear(),

tmpToDate.GetMonth(),tmpToDate.GetDay(),

tmpToTime.GetHour(),tmpToTime.GetMinute(),

tmpToTime.GetSecond());

return retToDateTime;

}

Также необходимо реализовать все тот же класс CToStringConvertor,

который как и вслучае с OPC DA будем преобразовывать значения типа

данных, метки времени и качества данных в текст.

Объявление класса имеет вид

#pragma once

class CToStringConverter

{

public:

static CString GetVTypeString(unsigned short usType);

static CString GetQualityString(unsigned short usQuality);

static CString GetFTString(_FILETIME ft);

};

А реализация имеет вид

// Преобразование типа в текст