package art.servers.etdserver.controller;
|
|
|
import art.library.model.devices.DeviceStatus;
|
import art.library.model.devices.etd.Etd;
|
import art.library.interop.serialization.Serialization;
|
import art.library.model.transactions.traces.Trace;
|
import art.servers.etdserver.Shared;
|
import art.servers.etdserver.protocols.diamond.configuration.DIAMOND_SpeedBinnedData;
|
import static java.lang.Thread.sleep;
|
|
|
public class ControllerVirtualEtd extends ControllerEtd
|
{
|
private int status = DeviceStatus.STATUS_ALARM;
|
private boolean firstTime = true;
|
|
|
public ControllerVirtualEtd(Etd etd)
|
{
|
super(etd);
|
this.device = etd;
|
this.name = Shared.getMessage("Controller etd") + " " + etd.information.name;
|
}
|
|
|
|
|
public void run()
|
{
|
// <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 etdclone = (Etd)Serialization.clone(device);
|
|
try
|
{
|
String externalIdentifier = device.getDeviceInformation().associatedDevice;
|
|
Etd etdExternal = (Etd)Shared.model.getDeviceExternal(externalIdentifier);
|
|
etdclone = (Etd)Serialization.clone(etdExternal);
|
etdclone.information = device.information;
|
etdclone.getDeviceInformation().lSpeedClassification = etdExternal.getDeviceInformation().lSpeedClassification;
|
etdclone.configuration = device.configuration;
|
|
online(etdclone);
|
return;
|
}
|
catch (Exception exception)
|
{
|
if ((etdclone.alarms.alarm_offline <= 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Etd offline");
|
art.servers.Shared.println(name, exception);
|
}
|
|
offline(etdclone);
|
}
|
}
|
|
|
|
|
private boolean isError()
|
{
|
errorsNumber = errorsNumber + 1;
|
if (errorsNumber >= maxErrorsNumber)
|
{
|
return(true);
|
}
|
return(false);
|
}
|
|
|
|
|
private void offline(Etd etdclone)throws Exception
|
{
|
if (isError() == true)
|
{
|
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
|
{
|
errorsNumber = 0;
|
if ((etdclone.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);
|
}
|
|
|
private DIAMOND_SpeedBinnedData createSpeedBinTable() throws Exception
|
{
|
if ((this.device.getIdentifier().equalsIgnoreCase("etd-wisznice-1") == false) &&
|
(this.device.getIdentifier().equalsIgnoreCase("etd-sławatycze-1") == false))
|
{
|
DIAMOND_SpeedBinnedData speedBinnedData = new DIAMOND_SpeedBinnedData();
|
speedBinnedData.numberOfBins = 17; // 16;
|
speedBinnedData.fileName = "POLONIA.SPD"; // "DEFAULTX.SPD";
|
speedBinnedData.createBins();
|
return speedBinnedData;
|
}
|
|
DIAMOND_SpeedBinnedData speedBinnedData = new DIAMOND_SpeedBinnedData();
|
speedBinnedData.numberOfBins = 16;
|
speedBinnedData.fileName = "DEFAULTX.SPD";
|
speedBinnedData.createBinsOld();
|
return speedBinnedData;
|
}
|
|
}
|
