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

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

CString CToStringConverter::GetVTypeString(unsigned short usType)

{

switch (usType)

{

case VARENUM::VT_R4 : return CString("VT_R4");

case VARENUM::VT_R8 : return CString("VT_R8");

case VARENUM::VT_ARRAY : return CString("VT_ARRAY");

case VARENUM::VT_BOOL : return CString("VT_BOOL");

case VARENUM::VT_BSTR : return CString("VT_BSTR");

case VARENUM::VT_DECIMAL : return CString("VT_DECIMAL");

case VARENUM::VT_I1 : return CString("VT_I1");

case VARENUM::VT_I2 : return CString("VT_I2");

case VARENUM::VT_I4 : return CString("VT_I4");

case VARENUM::VT_I8 : return CString("VT_I8");

case VARENUM::VT_FILETIME : return CString("FILETIME");

default : return CString("Unknown Type");

}

CString CToStringConverter::GetQualityString(unsigned short

usQuality)

{

switch (usQuality)

{

case 0x00: return L"Bad";

case 0x04: return L"Config Error";

case 0x08: return L"Not Connected";

case 0x0C: return L"Device Failure";

case 0x10: return L"Sensor Failure";

case 0x14: return L"Last Known";

case 0x18: return L"Comm Failure";

case 0x1C: return L"Out of Service";

case 0x20: return L"Initializing";

case 0x40: return L"Uncertain";

case 0x44: return L"Last Usable";

case 0x50: return L"Sensor Calibration";

case 0x54: return L"EGU Exceeded";

case 0x58: return L"Sub Normal";

case 0xC0: return L"Good";

case 0xD8: return L"Local Override";

default: return L"Unknown";

}

CString CToStringConverter::GetFTString(_FILETIME ft)

{

COleDateTime dt = COleDateTime(ft);

return dt.Format(L"%Y-%m-%d %H:%M:%S");

}

Теперь добавим элемент CListCtrl, который отформатируем в стиле

таблицы, аналогично примеру вывода данных полученный по OPC DA.

Напомним, у элемента необходимо поставить параметр View = Report и

создать соответствующую элементу переменную m_valueView.

public:

CListCtrl m_valueView;

Функция, которая форматирует элемент необходимым нам образом

void FormatValueView();

Имеет следующую реализацию

void COPCHDAClientDlg::FormatValueView()

{

m_valueView.SetExtendedStyle(LVS_EX_GRIDLINES| LVS_EX_FLATSB |

LVS_EX_FULLROWSELECT);

LVCOLUMNW lvColumn;

lvColumn.cchTextMax=25;

lvColumn.cx=150;

lvColumn.mask=LVCF_TEXT|LVCF_WIDTH;

lvColumn.pszText=L"Элемент";

m_valueView.InsertColumn(0,&lvColumn);

lvColumn.cx=100;

lvColumn.pszText=L"Тип";

m_valueView.InsertColumn(1,&lvColumn);

lvColumn.cx=100;

lvColumn.pszText=L"Значение";

m_valueView.InsertColumn(2,&lvColumn);

lvColumn.cx=150;

lvColumn.pszText=L"Метка времени";

m_valueView.InsertColumn(3,&lvColumn);

lvColumn.cx=100;

lvColumn.pszText=L"Качество";

m_valueView.InsertColumn(4,&lvColumn);

}

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

кнопку, которую подпишем «Значение».

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

Рисунок 8. – Добавления полей вывода данных и кнопки синхронного чтения

Теперь добавим обработчи нажатия на кнопку «Значение».

void COPCHDAClientDlg::OnBnClickedValuebtn()

{

//Получаем ItemID текущего выбранного элемента в дереве

LPWSTR szItemID = GetCurrentItemID();

if (NULL == szItemID) return;

//Запрашиваем у сервера описатель интересующих элементов

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);

HRESULT hRes = m_pOPCHDAServer->QueryInterface(

IID_IOPCHDASYNCREAD,(void**)&pSyncIO);

if (S_OK!=hRes)

{

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

return;

}

//Подготовка параметров синхронного чтения

//Считываем выбранные временные диапазоны

COleDateTime fromTime = GetFromDateTime();

COleDateTime toTime = GetToDateTime();

SYSTEMTIME st;

tagOPCHDA_TIME opcFromTime;

ZeroMemory(&opcFromTime,sizeof(opcFromTime));

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 = 500; // Макс количество значений

элемента

long bBounds = false;

//Синхронное чтение данных

hRes = pSyncIO->ReadRaw(&opcFromTime,&opcToTime,dwMaxValuesCount,

bBounds,dwCount,hItems,&pItemValues,&pErrors);

CoTaskMemFree(pErrors);

if (S_OK!=hRes)

{

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

}

else

{

//Вывод полученных данных

//Т.к. был считан один элемент,то pItemValues всегда с индексом 0

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();

}

Как можно заметить преобразование формата времени от COleDateTime к

FILETIME ведется по схеме

COleDateTime->SYSTEMITME->FILETIME.

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

Рисунок 9. – Результат синхронного чтения данных из OPCHDA сервера в

абсолютном времени.

Теперь реализуем пример чтения значений элементов с относительным

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

минут.

Для этого вынесем еще одну кнопку на диалог и подпишем ее «Значение

за 10 минут».

Обработчик нажатия на кнопку будет иметь вид

void COPCHDAClientDlg::OnBnClickedHourvaluebtn()

{

LPWSTR szItemID = GetCurrentItemID();

if (NULL == szItemID) 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;

}

//Задаем начальное время как текущий момент минус 10 минут

tagOPCHDA_TIME opcFromTime;

ZeroMemory(&opcFromTime,sizeof(opcFromTime));

opcFromTime.bString = true;

opcFromTime.szTime = (LPWSTR)CoTaskMemAlloc(

2*(lstrlen(L"NOW-10M")+1));

lstrcpy(opcFromTime.szTime,L"NOW-10M");

//Задаем начальное время как текущий момент

tagOPCHDA_TIME opcToTime;

ZeroMemory(&opcToTime,sizeof(opcToTime));

opcToTime.bString = true;

opcToTime.szTime = (LPWSTR)CoTaskMemAlloc(2*(lstrlen(L"NOW")+1));

lstrcpy(opcToTime.szTime,L"NOW");

tagOPCHDA_ITEM *pItemValues;

unsigned long dwMaxValuesCount = 1000;

long bBounds = false;

hRes = pSyncIO->ReadRaw(&opcFromTime,&opcToTime,dwMaxValuesCount,

bBounds,dwCount,hItems,&pItemValues,&pErrors);

CoTaskMemFree(pErrors);

CoTaskMemFree(opcFromTime.szTime);

CoTaskMemFree(opcToTime.szTime);

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();

}

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

времени.

Шаг 3.2. Синхронное чтение агрегаций OPC HDA сервера

Для начала необходимо определить какие агрегации поддерживает данный

сервер. Для этого вынесем еще один элемент CListCtrl на диалог и создадим

соответствующую ему переменную m_listServerAggregates.

public:

CListCtrl m_listServerAggregates;

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

Рисунок 11. – Добавление списка для вывода поддерживаемых агрегаций

Также добавим функцию

public:

void GetSupportedAggregates();

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

список.

Реализация функции имеет вид

void COPCHDAClientDlg::GetSupportedAggregates()

{

DWORD dwAggregatesCount;

DWORD * pdwAggregatesIDs;

LPWSTR * szAggregatesNames;

LPWSTR * szAggregatesDesc;

HRESULT hRes = m_pOPCHDAServer->GetAggregates(&dwAggregatesCount,

&pdwAggregatesIDs,&szAggregatesNames,&szAggregatesDesc);

if (hRes!=S_OK)

{

MessageBox(L"Ошибка запроса доступных агрегаций",L"Ошибка",

MB_OK);

return;

}

LVITEM lvItem;

ZeroMemory(&lvItem,sizeof(lvItem));

lvItem.cchTextMax = 25;