159 lines
4.8 KiB
C#
159 lines
4.8 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Threading;
|
|
|
|
using IEC61850.Client;
|
|
using IEC61850.Common;
|
|
using System.Runtime.Remoting.Metadata.W3cXsd2001;
|
|
|
|
namespace reporting
|
|
{
|
|
class ReportingExample
|
|
{
|
|
|
|
private static void reportHandler (Report report, object parameter)
|
|
{
|
|
Console.WriteLine ("Received report:\n----------------");
|
|
|
|
Console.WriteLine (" for RCB: " + report.GetRcbReference());
|
|
|
|
if (report.HasTimestamp ())
|
|
Console.WriteLine (" timestamp: " + MmsValue.MsTimeToDateTimeOffset (report.GetTimestamp ()).ToString ());
|
|
|
|
MmsValue values = report.GetDataSetValues ();
|
|
|
|
byte[] entryId = report.GetEntryId ();
|
|
|
|
if (entryId != null) {
|
|
SoapHexBinary shb = new SoapHexBinary(entryId);
|
|
|
|
Console.WriteLine (" entryID: " + shb.ToString ());
|
|
}
|
|
|
|
if (report.HasDataSetName ()) {
|
|
Console.WriteLine (" report data set: " + report.GetDataSetName ());
|
|
}
|
|
|
|
Console.WriteLine (" report dataset contains " + values.Size () + " elements");
|
|
|
|
for (int i = 0; i < values.Size(); i++) {
|
|
if (report.GetReasonForInclusion(i) != ReasonForInclusion.REASON_NOT_INCLUDED) {
|
|
Console.WriteLine(" element " + i + " included for reason " + report.GetReasonForInclusion(i).ToString() + " " + values.GetElement(i));
|
|
}
|
|
|
|
if (report.HasDataReference()) {
|
|
Console.WriteLine(" data-ref: " + report.GetDataReference(i));
|
|
}
|
|
|
|
}
|
|
|
|
ReportControlBlock rcb = (ReportControlBlock) parameter;
|
|
|
|
Console.WriteLine(" For RCB: " + rcb.GetObjectReference() + " Buffered: " + rcb.IsBuffered() +
|
|
" data-set: " + rcb.GetDataSetReference ());
|
|
|
|
}
|
|
|
|
|
|
private static bool running = true;
|
|
|
|
public static void Main (string[] args)
|
|
{
|
|
IedConnection con = new IedConnection ();
|
|
|
|
string hostname;
|
|
|
|
if (args.Length > 0)
|
|
hostname = args [0];
|
|
else
|
|
hostname = "localhost";
|
|
|
|
Console.WriteLine ("Connect to " + hostname);
|
|
|
|
try {
|
|
con.Connect (hostname, 102);
|
|
|
|
string rcbReference1 = "simpleIOGenericIO/LLN0.RP.EventsRCB01";
|
|
string rcbReference2 = "simpleIOGenericIO/LLN0.RP.EventsIndexed01";
|
|
string rcbReference3 = "simpleIOGenericIO/LLN0.BR.Measurements01";
|
|
|
|
ReportControlBlock rcb1 = con.GetReportControlBlock(rcbReference1);
|
|
ReportControlBlock rcb2 = con.GetReportControlBlock(rcbReference2);
|
|
ReportControlBlock rcb3 = con.GetReportControlBlock(rcbReference3);
|
|
|
|
rcb1.GetRCBValues();
|
|
|
|
// note: the second parameter is not required!
|
|
rcb1.InstallReportHandler(reportHandler, rcb1);
|
|
|
|
if (rcb1.IsBuffered())
|
|
Console.WriteLine("RCB: " + rcbReference1 + " is buffered");
|
|
|
|
rcb1.SetTrgOps(TriggerOptions.DATA_CHANGED | TriggerOptions.INTEGRITY);
|
|
rcb1.SetIntgPd(5000);
|
|
rcb1.SetRptEna(true);
|
|
|
|
rcb2.GetRCBValues();
|
|
|
|
if (rcb2.IsBuffered())
|
|
Console.WriteLine("RCB: " + rcbReference2 + " is buffered");
|
|
|
|
rcb2.InstallReportHandler(reportHandler, rcb2);
|
|
|
|
rcb2.SetOptFlds(ReportOptions.REASON_FOR_INCLUSION | ReportOptions.SEQ_NUM | ReportOptions.TIME_STAMP |
|
|
ReportOptions.CONF_REV | ReportOptions.ENTRY_ID | ReportOptions.DATA_REFERENCE | ReportOptions.DATA_SET);
|
|
rcb2.SetTrgOps(TriggerOptions.DATA_CHANGED | TriggerOptions.INTEGRITY);
|
|
rcb2.SetIntgPd(2000);
|
|
rcb2.SetRptEna(true);
|
|
|
|
rcb2.SetRCBValues();
|
|
|
|
rcb3.GetRCBValues();
|
|
|
|
if (rcb3.IsBuffered())
|
|
Console.WriteLine ("RCB: " + rcbReference3 + " is buffered");
|
|
|
|
rcb3.InstallReportHandler(reportHandler, rcb2);
|
|
|
|
rcb3.SetOptFlds(ReportOptions.REASON_FOR_INCLUSION | ReportOptions.SEQ_NUM | ReportOptions.TIME_STAMP |
|
|
ReportOptions.CONF_REV | ReportOptions.ENTRY_ID | ReportOptions.DATA_REFERENCE | ReportOptions.DATA_SET);
|
|
rcb3.SetTrgOps(TriggerOptions.DATA_CHANGED | TriggerOptions.INTEGRITY);
|
|
rcb3.SetIntgPd(2000);
|
|
rcb3.SetRptEna(true);
|
|
|
|
rcb3.SetRCBValues();
|
|
|
|
|
|
/* run until Ctrl-C is pressed */
|
|
Console.CancelKeyPress += delegate(object sender, ConsoleCancelEventArgs e) {
|
|
e.Cancel = true;
|
|
ReportingExample.running = false;
|
|
};
|
|
|
|
/* stop main loop when connection is lost */
|
|
con.InstallConnectionClosedHandler(delegate(IedConnection connection) {
|
|
Console.WriteLine("Connection closed");
|
|
ReportingExample.running = false;
|
|
});
|
|
|
|
while (running) {
|
|
Thread.Sleep(10);
|
|
}
|
|
|
|
/* Dispose the RCBs when you no longer need them */
|
|
rcb1.Dispose();
|
|
rcb2.Dispose();
|
|
rcb3.Dispose();
|
|
|
|
con.Abort ();
|
|
|
|
con.Dispose();
|
|
} catch (IedConnectionException e) {
|
|
Console.WriteLine ("Error: " + e.Message);
|
|
|
|
con.Dispose ();
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|