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

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

}

// Получаем ветви на данном уровне

pParent.GetEnum(tagOPCHDA_BROWSETYPE.OPCHDA_BRANCH, 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.ChangeBrowsePosition(tagOPCHDA_BROWSEDIRECTION.OPC

HDA_BROWSE_DOWN,

strName);

DisplayChildren(tvNode, pParent); //Рекурсивно вызываем метод

//После того как все дочерние узлы показаны постепенно поднимаемся

//вверх

pParent.ChangeBrowsePosition(tagOPCHDA_BROWSEDIRECTION.OPCHDA_BROWSE_UP,

strName);

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

}

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

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

Добавим переменную

private object m_pIfaceObject;

в которой будем хранить интерфейс IOPCHDA_Server и через которую

впоследствие будем получать все остальные интерфейсы OPC.

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

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

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

private void ConnectAndBrowseServer(Guid guid)

{

try

{

Type typeOfServer = Type.GetTypeFromCLSID(guid);

m_pIfaceObj = Activator.CreateInstance(typeOfServer);

IOPCHDA_Server pServer = (IOPCHDA_Server)m_pIfaceObj;

IOPCHDA_Browser pBrowser;

uint dwCount = 0;

uint dwAttrID = 0;

tagOPCHDA_OPERATORCODES opCodes =

tagOPCHDA_OPERATORCODES.OPCHDA_EQUAL;

object vtFilter = null;

IntPtr pErrors = IntPtr.Zero;

pServer.CreateBrowse(dwCount, ref dwAttrID, ref opCodes,

ref vtFilter, out pBrowser, out pErrors);

DisplayChildren(null, pBrowser);

}

catch (ApplicationException ex)

{

string msg="Ошибка подключения и просмотра адресного

пространства";

MessageBox.Show(msg, "Ошибка");

}

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

(SelectedIndexChanged) списка, который будет развертывать адресное

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

private void OPCListClick(object sender, EventArgs e)

{

ListView.SelectedIndexCollection selCol =

m_listOPCServers.SelectedIndices;

if (selCol.Count == 0) return;

OnServerChange();

Guid guid = (Guid)m_listOPCServers.SelectedItems[0].Tag;

m_treeOPCServerBrowse.Nodes.Clear();

ConnectAndBrowseServer(guid);

}

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

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

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

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

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

выборки данных.

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

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

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

временем

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

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

m_fromDate и m_fromTime

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

m_toTime

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

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

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

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

private DateTime GetFromDateTime()

{

DateTime retFromDateTime, tmpFromDate,tmpFromTime;

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

tmpFromDate = m_fromDate.Value;

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

tmpFromTime = m_fromTime.Value;

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

retFromDateTime = new DateTime(tmpFromDate.Year,

tmpFromDate.Month, tmpFromDate.Day,

tmpFromTime.Hour,tmpFromTime.Minute,

tmpFromTime.Second);

return retFromDateTime;//retFromDateTime;

}

private DateTime GetToDateTime()

{

DateTime retToDateTime, tmpToDate, tmpToTime;

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

tmpToDate = m_toDate.Value;

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

tmpToTime = m_toTime.Value;

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

retToDateTime = new DateTime(tmpToDate.Year, tmpToDate.Month,

tmpToDate.Day,tmpToTime.Hour,

tmpToTime.Minute,

tmpToTime.Second);

return retToDateTime;

}

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

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

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

Его реализация имеет вид

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Runtime.InteropServices;

using opchda;

namespace OPCClient

{

class ToStringConverter

{

static public string GetQualityString(ushort usQuality)

{

switch (usQuality)

{

case 0x00: return "Bad";

case 0x04: return "Config Error";

case 0x08: return "Not Connected";

case 0x0C: return "Device Failure";

case 0x10: return "Sensor Failure";

case 0x14: return "Last Known";

case 0x18: return "Comm Failure";

case 0x1C: return "Out of Service";

case 0x20: return "Initializing";

case 0x40: return "Uncertain";

case 0x44: return "Last Usable";

case 0x50: return "Sensor Calibration";

case 0x54: return "EGU Exceeded";

case 0x58: return "Sub Normal";

case 0xC0: return "Good";

case 0xD8: return "Local Override";

default: return "Unknown";

}

static public string GetVTString(ushort vt)

{

return ((VarEnum)vt).ToString();

}

static public string GetFTSting(_FILETIME ft)

{

long lFT = (((long)ft.dwHighDateTime) << 32) + ft.dwLowDateTime;

DateTime dt = DateTime.FromFileTime(lFT);

return dt.ToString();

}

Теперь добавим элемент ListView, который назовем m_valueView,

установим свойство View = Details и добавим пять столбцов с подписями

«Элемент», «Тип», «Значение», «Метка времени» и «Качество», куда мы будем

выводить соответствующие данные. А также кнопку, которую подпишем

«Значение», которую назовем ValueBtn (см. рисунок).

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

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

данных

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

private void valueBtn_Click(object sender, EventArgs e)

{

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

if (null == m_treeOPCServerBrowse.SelectedNode) return;

string itemID = (string)

m_treeOPCServerBrowse.SelectedNode.Tag;

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

//HRESULT *pErrors,hRes;

uint dwCount = 1; // считываем один элемент

uint phClient=0; // идентификатор клиента

IntPtr hItems = IntPtr.Zero; //сюда вернут описатель

IntPtr pErrors = IntPtr.Zero;

IOPCHDA_Server pOPCHDAServer=(IOPCHDA_Server)m_pIfaceObj;

pOPCHDAServer.GetItemHandles(dwCount,ref itemID, ref

phClient,out hItems,out pErrors);

int[] iItems = new int[1];

Marshal.Copy(hItems, iItems, 0, 1);

Marshal.FreeCoTaskMem(pErrors);

uint uiItems = (uint)iItems[0];

IOPCHDA_SyncRead pSyncIO = (IOPCHDA_SyncRead) pOPCHDAServer;

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

DateTime fromTime = GetFromDateTime();

DateTime toTime = GetToDateTime();

tagOPCHDA_TIME opcFromTime = new tagOPCHDA_TIME();

opcFromTime.ftTime.dwLowDateTime = (uint)fromTime.ToFileTime();

opcFromTime.ftTime.dwHighDateTime =(uint)( fromTime.ToFileTime()

>> 32);

tagOPCHDA_TIME opcToTime = new tagOPCHDA_TIME();

opcToTime.ftTime.dwLowDateTime = (uint)toTime.ToFileTime();

opcToTime.ftTime.dwHighDateTime =(uint)(toTime.ToFileTime() >>

32);

IntPtr ipItemValues;

uint dwMaxValuesCount = 500; // Макс количество значений элемента

int bBounds = 0;

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

pSyncIO.ReadRaw(ref opcFromTime,ref opcToTime,

dwMaxValuesCount,bBounds,dwCount,ref uiItems,

out ipItemValues, out pErrors);

//------Теперь начинаем разбираться с типами COM и .NET----------

//-----Получаем структуру tagOPCHDA_ITEM

tagOPCHDA_ITEM pItemValues = (tagOPCHDA_ITEM)

Marshal.PtrToStructure(ipItemValues, typeof(tagOPCHDA_ITEM));

Marshal.FreeCoTaskMem(pErrors);

Marshal.FreeCoTaskMem(ipItemValues);

if (0 == pItemValues.dwCount) return;

// Выделяем массив качеств, считанных значений элемента

int[] iQuality = new int[pItemValues.dwCount];

Marshal.Copy(pItemValues.pdwQualities, iQuality,

0,(int)(pItemValues.dwCount));

//Выделяем тип данных элемента из массива Variant

//pItemValues.pvDataValues, который

//в .NET представлен как IntPtr

//вначале выделяем по два байта (размер dwQuality) из

//pItemValues.pvDataValues

byte[] vt = new byte[2];

Marshal.Copy(pItemValues.pvDataValues, vt, 0, 2);

// потом преобразуем два байта в одну двухбайтовую переменную

ushort usVt = (ushort)(vt[0] + vt[1] * 255);

// теперь выделяем значения, метки времени

object[] objValues = new object[pItemValues.dwCount];

_FILETIME [] ftTimeStamps = new _FILETIME[pItemValues.dwCount];

m_valueView.Items.Clear();

const int szVariant = 16; // размер Variant

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

{

//Выделяем значения в object

objValues[i] = Marshal.GetObjectForNativeVariant(IntPtr.Add(

pItemValues.pvDataValues, i*szVariant));

// Выделяем метки времени в _FILETIME

ftTimeStamps[i] =

(_FILETIME)Marshal.PtrToStructure(IntPtr.Add(

pItemValues.pftTimeStamps, i * Marshal.SizeOf(ftTimeStamps[i])),

typeof(_FILETIME));

ListViewItem lvItem = new ListViewItem();

ListViewItem.ListViewSubItem[] lvSubItem = new

ListViewItem.ListViewSubItem[3];

lvItem.Text = itemID;

lvItem.SubItems.Add(ToStringConverter.GetVTString(usVt));

lvItem.SubItems.Add(objValues[i].ToString());

lvItem.SubItems.Add(ToStringConverter.GetFTSting(

ftTimeStamps[i]));

lvItem.SubItems.Add(ToStringConverter.GetQualityString(

(ushort)iQuality[i]));

m_valueView.Items.Add(lvItem);

}

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

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

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

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

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

минут.

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

за 10 минут».

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

private void MinuteBtn_Click(object sender, EventArgs e)

{

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

if (null == m_treeOPCServerBrowse.SelectedNode) return;

string itemID =

(string)m_treeOPCServerBrowse.SelectedNode.Tag;

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

//HRESULT *pErrors,hRes;

uint dwCount = 1; // считываем один элемент

uint phClient = 0; // идентификатор клиента

IntPtr hItems = IntPtr.Zero; //сюда вернут описатель

IntPtr pErrors = IntPtr.Zero;

IOPCHDA_Server pOPCHDAServer =

(IOPCHDA_Server)this.m_pIfaceObj;