package art.servers.etdserver.controller;
|
|
|
import art.library.interop.InteropParameter;
|
import art.library.interop.InteropParameters;
|
import art.library.interop.InteropResponse;
|
import art.library.model.devices.DeviceStatus;
|
import art.library.model.devices.etd.Etd;
|
import art.library.interop.serialization.Serialization;
|
import art.library.model.devices.Device;
|
import art.library.model.transactions.traces.Trace;
|
import art.servers.etdserver.Shared;
|
import art.servers.etdserver.protocols.dgt.EtdDgtProtocolAnalyser;
|
import static java.lang.Thread.sleep;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
|
|
public class ControllerEtdDgtEru extends ControllerEtd
|
{
|
private int status = DeviceStatus.STATUS_ALARM;
|
private boolean firstTime = true;
|
private final EtdDgtProtocolAnalyser protocolAnalyser = new EtdDgtProtocolAnalyser();
|
|
|
public ControllerEtdDgtEru(Etd etd)
|
{
|
super(etd);
|
this.device = etd;
|
this.name = Shared.getMessage("Controller etd") + " " + etd.information.name;
|
}
|
|
|
|
|
public void run()
|
{
|
String message = Shared.getMessage("Running");
|
// <editor-fold defaultstate="collapsed" desc="Trace">
|
art.servers.Shared.println(Trace.getTraceInformation(art.servers.Shared.getApplicationName(), name, art.servers.Shared.getMessage("Starting"), art.servers.Shared.getMessage("Success")), true);
|
// </editor-fold>
|
status = DeviceStatus.STATUS_ONLINE;
|
|
while ((isInterrupted() == false) && (exit == false))
|
{
|
long startTimestamp = System.currentTimeMillis();
|
|
try
|
{
|
if (art.servers.Shared.isServerEnabled() == true)
|
{
|
update();
|
}
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
|
if (startTimestamp > System.currentTimeMillis())
|
{
|
startTimestamp = System.currentTimeMillis();
|
}
|
|
long stopTimestamp = startTimestamp + (device.getDeviceInformation().polling * 1000);
|
|
while ((System.currentTimeMillis() < stopTimestamp) && (exit == false))
|
{
|
try
|
{
|
sleep(50);
|
}
|
catch (Exception e)
|
{
|
}
|
}
|
|
if (art.servers.Shared.model.existsDevice(device.getIdentifier()) == false)
|
{
|
art.servers.Shared.println(name, art.servers.Shared.getMessage("Device no longer exists"));
|
exit = true;
|
}
|
}
|
|
// <editor-fold defaultstate="collapsed" desc="Trace">
|
art.servers.Shared.println(Trace.getTraceInformation(art.servers.Shared.getApplicationName(), name, art.servers.Shared.getMessage("Finishing"), art.servers.Shared.getMessage("Success")), true);
|
// </editor-fold>
|
}
|
|
|
|
|
/*
|
Private controller functions
|
*/
|
|
private void update() throws Exception
|
{
|
Etd deviceclone = (Etd)Serialization.clone(device);
|
|
try
|
{
|
|
readAlarms(deviceclone);
|
|
if (deviceclone.getAlarm("alarm_offline") > 0)
|
{
|
offline(deviceclone);
|
return;
|
}
|
|
readCurrentTrafficData(deviceclone);
|
online(deviceclone);
|
}
|
catch (Exception exception)
|
{
|
exception.printStackTrace();
|
offline(deviceclone);
|
}
|
}
|
|
|
private void readAlarms(Etd deviceclone) throws Exception
|
{
|
try
|
{
|
System.out.println(Device.getDate(System.currentTimeMillis()) + " - 1. " + deviceclone.getIdentifier() + " - EYA >> ");
|
|
InteropParameters parameters = new InteropParameters();
|
parameters.addParameter(new InteropParameter("operation", "getEtdEya"));
|
parameters.addParameter(new InteropParameter("language", "en-GB"));
|
parameters.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parameters.addParameter(new InteropParameter("etd", "" + deviceclone.getDeviceInformation().connectionEru.etdNumber));
|
InteropResponse response = (InteropResponse) Serialization.invoke("get", parameters, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
System.out.println(Device.getDate(System.currentTimeMillis()) + " - 2. " + deviceclone.getIdentifier() + " - EYA >> ");
|
|
Object[] lobject = Arrays.copyOf(response.getValue(), response.getValue().length, Object[].class);
|
List<Integer> lbytes = new ArrayList<Integer>(); for (Object o : lobject){lbytes.add((Integer)o);}
|
|
String s = deviceclone.getIdentifier() + " - EYA << ";
|
for (Integer value : lbytes)
|
{
|
s += " " + String.format("%02X", value.intValue());
|
}
|
System.out.println(s);
|
|
int numberOfEtds = lbytes.get(0).intValue();
|
int etdNumber = lbytes.get(1).intValue();
|
if (etdNumber == deviceclone.getDeviceInformation().connectionEru.etdNumber)
|
{
|
// Message received corresponds to vms
|
int[] information = new int[lbytes.size() - 2];
|
for (int i=2; i<lbytes.size(); i++)
|
{
|
information[i-2] = lbytes.get(i);
|
}
|
|
protocolAnalyser.analyseResponseEyA(deviceclone, information);
|
}
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
throw e;
|
}
|
}
|
|
|
private void readCurrentTrafficData(Etd deviceclone) throws Exception
|
{
|
try
|
{
|
InteropParameters parameters = new InteropParameters();
|
parameters.addParameter(new InteropParameter("operation", "getEtdDup"));
|
parameters.addParameter(new InteropParameter("language", "en-GB"));
|
parameters.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parameters.addParameter(new InteropParameter("etd", "" + deviceclone.getDeviceInformation().connectionEru.etdNumber));
|
InteropResponse response = (InteropResponse) Serialization.invoke("get", parameters, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
|
Object[] lobject = Arrays.copyOf(response.getValue(), response.getValue().length, Object[].class);
|
List<Integer> lbytes = new ArrayList<Integer>(); for (Object o : lobject){lbytes.add((Integer)o);}
|
|
String s = deviceclone.getIdentifier() + " - DUP << ";
|
for (Integer value : lbytes)
|
{
|
s += " " + String.format("%02X", value.intValue());
|
}
|
System.out.println(s);
|
|
int numberOfEtds = lbytes.get(0).intValue();
|
int etdNumber = lbytes.get(1).intValue();
|
System.out.println(deviceclone.getIdentifier() + " 1.DUP: " + numberOfEtds + "." + etdNumber + " - " + deviceclone.getDeviceInformation().connectionEru.etdNumber);
|
if (etdNumber == deviceclone.getDeviceInformation().connectionEru.etdNumber)
|
{
|
// Message received corresponds to vms
|
int[] information = new int[lbytes.size() - 2];
|
for (int i=2; i<lbytes.size(); i++)
|
{
|
information[i-2] = lbytes.get(i);
|
}
|
|
protocolAnalyser.analyseResponseDUP(deviceclone, information);
|
}
|
}
|
catch (Exception e)
|
{
|
throw e;
|
}
|
}
|
|
|
|
|
private void offline(Etd etdclone)throws Exception
|
{
|
if ((device.alarms.alarm_offline <= 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Etd offline");
|
art.servers.Shared.println(name, message);
|
}
|
|
if (etdclone.getAlarm("alarm_offline") <= 0)
|
{
|
etdclone.getDeviceAlarms().clear();
|
}
|
etdclone.setAlarm("alarm_offline", true);
|
Shared.model.updateDevice(device, etdclone);
|
}
|
|
|
private void online(Etd etdclone) throws Exception
|
{
|
if ((device.alarms.alarm_offline > 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Etd online");
|
art.servers.Shared.println(name, message);
|
}
|
|
etdclone.setAlarm("alarm_offline", false);
|
etdclone.setAlarm("alarm_invalid", false);
|
Shared.model.updateDevice(device, etdclone);
|
}
|
|
}
|
