package org.openmuc.openiec61850.app;
|
|
import java.io.IOException;
|
import java.net.InetAddress;
|
import java.net.UnknownHostException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import javax.swing.JCheckBox;
|
import org.openmuc.openiec61850.BdaFloat32;
|
import org.openmuc.openiec61850.BdaBoolean;
|
import org.openmuc.openiec61850.ClientAssociation;
|
import org.openmuc.openiec61850.ClientSap;
|
import org.openmuc.openiec61850.DataSet;
|
import org.openmuc.openiec61850.Fc;
|
import org.openmuc.openiec61850.FcModelNode;
|
import org.openmuc.openiec61850.ServerModel;
|
import org.openmuc.openiec61850.ServiceError;
|
import org.openmuc.openiec61850.clientgui.BasicDataBind;
|
import org.openmuc.openiec61850.internal.cli.CliParameter;
|
import org.openmuc.openiec61850.internal.cli.CliParameterBuilder;
|
import org.openmuc.openiec61850.internal.cli.CliParseException;
|
import org.openmuc.openiec61850.internal.cli.CliParser;
|
import org.openmuc.openiec61850.internal.cli.IntCliParameter;
|
import org.openmuc.openiec61850.internal.cli.StringCliParameter;
|
import org.openmuc.openiec61850.clientgui.databind.BooleanDataBind;
|
|
|
/**
|
*
|
* @author Stefan Feuerhahn
|
*
|
*/
|
public class ConsoleClient_1 {
|
|
private static final StringCliParameter hostParam = new CliParameterBuilder("-h")
|
.setDescription("The IP/domain address of the server you want to access.")
|
.setMandatory()
|
.buildStringParameter("host");
|
private static final IntCliParameter portParam = new CliParameterBuilder("-p")
|
.setDescription("The port to connect to.")
|
.buildIntParameter("port", 102);
|
private static final StringCliParameter modelFileParam = new CliParameterBuilder("-m").setDescription(
|
"The file name of the SCL file to read the model from. If this parameter is omitted the model will be read from the server device after connection.")
|
.buildStringParameter("model-file");
|
|
private static volatile ClientAssociation association;
|
private static ServerModel serverModel;
|
|
public static void writeNodeData(String reference, String fc_str) {
|
FcModelNode fcModelNode = (FcModelNode)serverModel.findModelNode(reference, Fc.fromString(fc_str));
|
if(null == fcModelNode) {
|
System.err.println("error, no modenode was found.....");
|
return;
|
}
|
|
System.out.println("Sending SetDataValues request...");
|
try {
|
/*
|
BasicDataBind<?> data = new Float32DataBind((BdaFloat32)fcModelNode);
|
JTextField tf_t = (JTextField)data.getValueField();
|
tf_t.setText("12.0");
|
*/
|
BasicDataBind<?> data = new BooleanDataBind((BdaBoolean)fcModelNode.getChild("ctlVal"));
|
JCheckBox ckb_t = (JCheckBox)data.getValueField();
|
ckb_t.setSelected(false);
|
data.write();
|
association.setDataValues(fcModelNode);
|
} catch (ServiceError e) {
|
System.out.println("Service error: " + e.getMessage());
|
return;
|
} catch (IOException e) {
|
System.out.println("Fatal error: " + e.getMessage());
|
return;
|
}
|
System.out.println("Successfully write data.");
|
}
|
|
public static void readNodeData(String reference, String fc_str) {
|
FcModelNode fcModelNode = (FcModelNode)serverModel.findModelNode(reference, Fc.fromString(fc_str));
|
if(null == fcModelNode) {
|
System.err.println("error, no modenode was found.....");
|
return;
|
}
|
|
System.out.println("Sending GetDataValues request...");
|
try {
|
association.getDataValues(fcModelNode);
|
} catch (ServiceError e) {
|
System.out.println("Service error: " + e.getMessage());
|
return;
|
} catch (IOException e) {
|
System.out.println("Fatal error: " + e.getMessage());
|
return;
|
}
|
|
System.out.println("Successfully read data.");
|
/*
|
BasicDataBind<?> data = new Float32DataBind((BdaFloat32)fcModelNode);
|
JTextField tf_t = (JTextField)data.getValueField();
|
System.out.println("The modelnode is:" + fcModelNode.getReference() + ", the value is: " + tf_t.getText());
|
*/
|
BasicDataBind<?> data = new BooleanDataBind((BdaBoolean)fcModelNode.getChild("ctlVal"));
|
JCheckBox ckb_t = (JCheckBox)data.getValueField();
|
System.out.println("The modelnode is:" + fcModelNode.getChild("ctlVal").getReference() + ", the value is: " + ckb_t.isSelected());
|
}
|
|
public static void main(String[] args) {
|
|
List<CliParameter> cliParameters = new ArrayList<>();
|
cliParameters.add(hostParam);
|
cliParameters.add(portParam);
|
cliParameters.add(modelFileParam);
|
|
CliParser cliParser = new CliParser("openiec61850-console-client",
|
"A client application to access IEC 61850 MMS servers.");
|
cliParser.addParameters(cliParameters);
|
|
try {
|
cliParser.parseArguments(args);
|
} catch (CliParseException e1) {
|
System.err.println("Error parsing command line parameters: " + e1.getMessage());
|
System.out.println(cliParser.getUsageString());
|
System.exit(1);
|
}
|
|
InetAddress address;
|
try {
|
address = InetAddress.getByName(hostParam.getValue());
|
} catch (UnknownHostException e) {
|
System.out.println("Unknown host: " + hostParam.getValue());
|
return;
|
}
|
|
ClientSap clientSap = new ClientSap();
|
|
while(true) {
|
|
try {
|
Thread.sleep(2000);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
try {
|
association = clientSap.associate(address, portParam.getValue(), null, null);
|
} catch (IOException e) {
|
System.out.println("Unable to connect to remote host.");
|
continue;
|
}
|
|
System.out.println("successfully connected");
|
System.out.println("retrieving model...");
|
|
try {
|
serverModel = association.retrieveModel();
|
} catch (ServiceError e) {
|
System.out.println("Service error: " + e.getMessage());
|
continue;
|
} catch (IOException e) {
|
System.out.println("Fatal error: " + e.getMessage());
|
continue;
|
}
|
|
System.out.println("successfully read model");
|
|
/*
|
writeNodeData("ZJDYBTSE/ncdGGIO1.Para6.setMag.f", "SP");
|
readNodeData("ZJDYBTSE/ncdGGIO1.Para6.setMag.f", "SP");
|
*/
|
//DataSet ds_pm = serverModel.getDataSet("ZJDYBTSE/LLN0.dsParameter");
|
//int size_cnt = ds_pm.getMembers().size();
|
//m_Association.getDataSetValues(ds_pm);
|
/*
|
for(int n=0; n<size_cnt; n++) {
|
FcModelNode fc_mode = (FcModelNode) ds_pm.getMembers().get(n).getChild("setMag").getChild("f");
|
BasicDataBind<?> data = new Float32DataBind((BdaFloat32)fc_mode);
|
JTextField tf_t = (JTextField)data.getValueField();
|
tf_t.setText(String.valueOf(n+1));
|
data.write();
|
}
|
try {
|
association.setDataSetValues(ds_pm);
|
} catch (ServiceError e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
System.out.println("done");
|
*/
|
writeNodeData("ZJDYBTSE/ncdGGIO1.SPCSO1.Oper", "CO");
|
readNodeData("ZJDYBTSE/ncdGGIO1.SPCSO1.Oper", "CO");
|
|
while(true) {
|
DataSet ds = serverModel.getDataSet("ZJDYBTSE/LLN0.dsMeasure");
|
int size_cnt1 = ds.getMembers().size();
|
try {
|
association.getDataSetValues(ds);
|
|
String str_out = "";
|
for(int n=0; n<size_cnt1; n++) {
|
FcModelNode fc_mode = (FcModelNode) ds.getMembers().get(n).getChild("mag").getChild("f");
|
//BasicDataBind<?> data = new Float32DataBind((BdaFloat32)fc_mode);
|
//((BdaFloat32)fc_mode).getFloat();
|
//JTextField tf_t = (JTextField)data.getValueField();
|
str_out += String.format("#%02d: %1.3f ", n+1, ((BdaFloat32)fc_mode).getFloat());
|
//System.out.println(fc_mode.getReference() + ", the value is: " + tf_t.getText());
|
//System.out.println(fc_mode.getChild("setMag").getChild("f").getReference());
|
}
|
System.out.println(str_out);
|
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
break;
|
} finally {
|
try {
|
Thread.sleep(500);
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
|
}
|
}
|
