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

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

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;

tagOPCHDA_TIME opcFromTime = new tagOPCHDA_TIME();

opcFromTime.bString = 1;

opcFromTime.szTime = "NOW-10M";

tagOPCHDA_TIME opcToTime = new tagOPCHDA_TIME();

opcToTime.bString = 1;

opcToTime.szTime = "NOW";

IntPtr ipItemValues;

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

элемента

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.pvDataVal

ues, i * szVariant));

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

ftTimeStamps[i] =

(_FILETIME)Marshal.PtrToStructure(IntPtr.Add(pItemValues.pftTimeSt

amps, 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)iQu

ality[i]));

m_valueView.Items.Add(lvItem);

}

Marshal.FreeCoTaskMem(pItemValues.pvDataValues);

Marshal.FreeCoTaskMem(pItemValues.pftTimeStamps);

Marshal.FreeCoTaskMem(pItemValues.pdwQualities);

}

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

времени

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

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

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

m_listServerAggregates.

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

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

агрегаций

Также добавим функцию, которая будет запрашивать у сервера доступные

агрегации и заносить их в список.

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

private void GetSupportedAggregates()

{

uint dwAggregatesCount;

IntPtr iptrAggregatesIDs = IntPtr.Zero;

IntPtr iptrAggregatesNames = IntPtr.Zero;

IntPtr iptrAggregatesDesc = IntPtr.Zero;

try

{

IOPCHDA_Server pOPCHDAServer = (IOPCHDA_Server)m_pIfaceObj;

pOPCHDAServer.GetAggregates(out dwAggregatesCount, out

iptrAggregatesIDs, out iptrAggregatesNames, out

iptrAggregatesDesc);

int[] dwAggregatesIDs = new int[dwAggregatesCount];

string[] szAggregatesNames = new string[dwAggregatesCount];

string[] szAggregatesDesc = new string[dwAggregatesCount];

IntPtr[] iptrAggregatesNamesArray = new

IntPtr[dwAggregatesCount];

Marshal.Copy(iptrAggregatesNames, iptrAggregatesNamesArray,

0, (int)dwAggregatesCount);

Marshal.Copy(iptrAggregatesIDs, dwAggregatesIDs, 0,

(int)dwAggregatesCount);

m_listServerAggregates.Clear();

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

{

szAggregatesNames[i] =

Marshal.PtrToStringAuto(IntPtr.Add(iptrAggregatesNamesArray[i],

offset));

szAggregatesDesc[i] =

Marshal.PtrToStringUni(iptrAggregatesDesc);

ListViewItem lvItem = new ListViewItem();

lvItem.Text = szAggregatesNames[i];

lvItem.Tag = (uint)dwAggregatesIDs[i];

m_listServerAggregates.Items.Add(lvItem);

Marshal.FreeCoTaskMem(iptrAggregatesNamesArray[i]);

}

Marshal.FreeCoTaskMem(iptrAggregatesIDs);

Marshal.FreeCoTaskMem(iptrAggregatesNames);

Marshal.FreeCoTaskMem(iptrAggregatesDesc);

}

catch (ApplicationException ex)

{

MessageBox.Show("Ошибка получения агрегаций", "Ошибка");

}

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

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

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

private void ConnectAndBrowseServer(Guid guid)

{

try

{

Type typeOfServer = Type.GetTypeFromCLSID(guid);

m_pIfaceObj = Activator.CreateInstance(typeOfServer);

GetSupportedAggregates();

---------------------------------

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

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

Рисунок 23. – Списки агрегаций, поддерживаемые различными серверами

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

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

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

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

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

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

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

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

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

выбранную агрегация за выбранные временные рамки с заданным интервалом.

private void aggregateValueBtn_Click(object sender, EventArgs e)

{

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

if (null == m_treeOPCServerBrowse.SelectedNode) return;

//Получаем AggregateID выбранной агрегации

if (0 == m_listServerAggregates.SelectedItems.Count) return;

string itemID =

(string)m_treeOPCServerBrowse.SelectedNode.Tag;

uint haAggregate =

(uint)m_listServerAggregates.SelectedItems[0].Tag;

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

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

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

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

IntPtr pErrors = IntPtr.Zero;

IOPCHDA_Server pOPCHDAServer =

(IOPCHDA_Server)this.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;

long iResInt =

Convert.ToInt64(intervalValueEdit.Text)*60*10000000;

_FILETIME ftResInterval;

ftResInterval.dwLowDateTime = (uint)iResInt;

ftResInterval.dwHighDateTime = (uint)(iResInt >> 32);

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

pSyncIO.ReadProcessed(ref opcFromTime, ref opcToTime,

ftResInterval, 1, ref uiItems, ref haAggregate, 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.pvDataV

alues, i * szVariant));

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

ftTimeStamps[i] =

(_FILETIME)Marshal.PtrToStructure(IntPtr.Add(pItemValues.pftTime

Stamps, 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)i

Quality[i]));

m_valueView.Items.Add(lvItem);

}

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

суток.

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