package art.servers.asfserver.controller;
|
|
import art.library.interop.InteropParameter;
|
import art.library.interop.InteropParameters;
|
import art.library.interop.InteropResponse;
|
import art.library.interop.serialization.Serialization;
|
import art.library.interop.serialization.SerializationException;
|
import art.library.model.devices.DeviceAction;
|
import art.library.model.devices.DeviceActionResult;
|
import art.library.model.devices.DeviceCommands;
|
import art.library.model.devices.DeviceStatus;
|
import art.library.model.devices.vms.asf.Asf;
|
import art.library.model.devices.vms.asf.AsfCommands;
|
import art.library.model.devices.vms.asf.AsfStatus;
|
import art.library.utils.synchro.Mutex;
|
import art.servers.ServerException;
|
import art.servers.Shared;
|
import art.servers.AsfServer;
|
import art.servers.asfserver.protocols.dgt.AsfDgtConstants;
|
import art.servers.asfserver.protocols.dgt.AsfDgtProtocolAnalyser;
|
import java.util.Arrays;
|
import java.util.List;
|
import art.servers.asfserver.protocols.dgt.AsfDgtProtocolConstructor;
|
import java.util.ArrayList;
|
|
public class ControllerAsfDGTEru extends ControllerAsf
|
{
|
|
private String name = null;
|
private boolean firstTime = true;
|
private final Mutex mutex = new Mutex();
|
|
public ControllerAsfDGTEru(Asf asf)
|
{
|
super(asf);
|
this.device = asf;
|
this.name = Shared.getMessage("Controller asf") + " " + asf.toString();
|
|
this.setName(name);
|
if (device.getDeviceStatus() == null)
|
{
|
device.status = new AsfStatus();
|
}
|
}
|
|
public void run()
|
{
|
Shared.traceInformation(name, "Starting");
|
|
while ((isInterrupted() == false) && (exit == false))
|
{
|
long startTimestamp = System.currentTimeMillis();
|
|
try
|
{
|
if (art.servers.Shared.isServerEnabled() == true)
|
{
|
update();
|
}
|
} catch (Exception e)
|
{
|
}
|
|
long timetowait = (device.getDeviceInformation().polling * 1000) - (System.currentTimeMillis() - startTimestamp);
|
timetowait = Math.min(timetowait, (device.getDeviceInformation().polling * 1000));
|
|
if (timetowait > 0)
|
{
|
try
|
{
|
sleep(timetowait);
|
} catch (Exception e)
|
{
|
}
|
} else
|
{
|
try
|
{
|
sleep(50);
|
} catch (Exception e)
|
{
|
};
|
}
|
|
if (Shared.model.existsDevice(device.getIdentifier()) == false)
|
{
|
exit = true;
|
}
|
}
|
|
Shared.traceInformation(name, "Finishing");
|
}
|
|
// <editor-fold defaultstate="collapsed" desc="Update">
|
private void update() throws Exception
|
{
|
mutex.lockWrite();
|
|
Asf deviceclone = (Asf) Serialization.clone(device);
|
deviceclone.getDeviceAlarms().clear();
|
|
try
|
{
|
readAlarms(deviceclone);
|
|
if (deviceclone.getAlarm("alarm_offline") > 0)
|
{
|
offline(deviceclone);
|
return;
|
}
|
|
readConfiguration(deviceclone);
|
readStatus(deviceclone);
|
online(deviceclone);
|
} catch (Exception e)
|
{
|
offline(deviceclone);
|
} finally
|
{
|
mutex.releaseWrite();
|
}
|
}
|
|
private void offline(Asf deviceclone) throws Exception
|
{
|
deviceclone.setAlarm("alarm_offline", System.currentTimeMillis());
|
Shared.model.updateDevice(device, deviceclone);
|
}
|
|
private void online(Asf deviceclone) throws Exception
|
{
|
if ((device.alarms.alarm_offline > 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Asf online");
|
Shared.println(this.name, message);
|
}
|
|
deviceclone.setAlarm("alarm_offline", false);
|
deviceclone.setAlarm("alarm_invalid", false);
|
Shared.model.updateDevice(device, deviceclone);
|
}
|
|
private void readAlarms(Asf deviceclone) throws Exception
|
{
|
try
|
{
|
InteropParameters parameters = new InteropParameters();
|
parameters.addParameter(new InteropParameter("operation", "getVmsEya"));
|
parameters.addParameter(new InteropParameter("language", "en-GB"));
|
parameters.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parameters.addParameter(new InteropParameter("vms", "" + deviceclone.getDeviceInformation().connectionEru.vmsNumber));
|
|
Shared.println(name, "1.ReadAlarms: " + deviceclone.getDeviceInformation().connectionEru.eru + " " + deviceclone.getDeviceInformation().connectionEru.vmsNumber);
|
InteropResponse response = (InteropResponse) Serialization.invoke("get", parameters, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
Shared.println(name, "2.ReadAlarms: " + deviceclone.getDeviceInformation().connectionEru.eru + " " + deviceclone.getDeviceInformation().connectionEru.vmsNumber);
|
|
Object[] lobject = Arrays.copyOf(response.getValue(), response.getValue().length, Object[].class);
|
Shared.println(name, "3.ReadAlarms: " + deviceclone.getDeviceInformation().connectionEru.eru + " " + deviceclone.getDeviceInformation().connectionEru.vmsNumber + " - " + lobject.length);
|
List<Integer> lbytes = new ArrayList<Integer>();
|
for (Object o : lobject)
|
{
|
lbytes.add((Integer) o);
|
}
|
|
int numberOfVmss = lbytes.get(0).intValue();
|
Shared.println(name, "4.ReadAlarms: " + deviceclone.getDeviceInformation().connectionEru.eru + " " + deviceclone.getDeviceInformation().connectionEru.vmsNumber + " - " + numberOfVmss);
|
int vmsNumber = lbytes.get(1).intValue();
|
Shared.println(name, "5.ReadAlarms: " + deviceclone.getDeviceInformation().connectionEru.eru + " " + deviceclone.getDeviceInformation().connectionEru.vmsNumber + " - " + vmsNumber);
|
if (vmsNumber == deviceclone.getDeviceInformation().connectionEru.vmsNumber)
|
{
|
// Message received corresponds to vms
|
String s = " EYA << ";
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
s += " " + information[i-2];
|
}
|
|
Shared.println(name, s);
|
AsfDgtProtocolAnalyser.analyseResponseEyA(deviceclone, information);
|
}
|
} catch (Exception e)
|
{
|
Shared.printstack(name, e);
|
throw e;
|
}
|
}
|
|
private void readConfiguration(Asf deviceclone) throws Exception
|
{
|
try
|
{
|
InteropParameters parameters = new InteropParameters();
|
parameters.addParameter(new InteropParameter("operation", "getVmsPp"));
|
parameters.addParameter(new InteropParameter("language", "en-GB"));
|
parameters.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parameters.addParameter(new InteropParameter("vms", "" + deviceclone.getDeviceInformation().connectionEru.vmsNumber));
|
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<>();
|
for (Object o : lobject)
|
{
|
lbytes.add((Integer) o);
|
}
|
|
int numberOfVmss = lbytes.get(0).intValue();
|
int vmsNumber = lbytes.get(1).intValue();
|
if (vmsNumber == deviceclone.getDeviceInformation().connectionEru.vmsNumber)
|
{
|
// 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);
|
}
|
|
AsfDgtProtocolAnalyser.analyseResponsePP(deviceclone, information);
|
}
|
} catch (Exception e)
|
{
|
throw e;
|
}
|
}
|
|
private void readStatus(Asf deviceclone) throws Exception
|
{
|
try
|
{
|
InteropParameters parameters = new InteropParameters();
|
parameters.addParameter(new InteropParameter("operation", "getVmsEp"));
|
parameters.addParameter(new InteropParameter("language", "en-GB"));
|
parameters.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parameters.addParameter(new InteropParameter("vms", "" + deviceclone.getDeviceInformation().connectionEru.vmsNumber));
|
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<>();
|
for (Object o : lobject)
|
{
|
lbytes.add((Integer) o);
|
}
|
|
int numberOfVmss = lbytes.get(0).intValue();
|
int vmsNumber = lbytes.get(1).intValue();
|
if (vmsNumber == deviceclone.getDeviceInformation().connectionEru.vmsNumber)
|
{
|
// 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);
|
}
|
|
AsfDgtProtocolAnalyser.analyseResponseEP(deviceclone, information);
|
}
|
} catch (Exception e)
|
{
|
if (this.device.getIdentifier().equalsIgnoreCase(AsfServer.devicelog) == true)
|
{
|
e.printStackTrace();
|
}
|
throw e;
|
}
|
}
|
|
// </editor-fold>
|
// <editor-fold defaultstate="collapsed" desc="Actions">
|
public DeviceAction[] sendCommands(InteropParameters parameters) throws ServerException, SerializationException, Exception
|
{
|
try
|
{
|
List<DeviceAction> result = new ArrayList<>();
|
|
AsfCommands asfCommands = (AsfCommands) parameters.getBodyContentValue(AsfCommands.class);
|
Shared.println("AsfCommand", Serialization.toPrettyString(asfCommands));
|
|
Asf clone = (Asf) Serialization.clone(device);
|
|
if (asfCommands.liberate == DeviceCommands.CONDITION_YES)
|
{
|
AsfCommands command = new AsfCommands();
|
command.liberate = asfCommands.liberate;
|
result.add(liberate(parameters, command, clone));
|
}
|
|
if (asfCommands.state != AsfCommands.STATE_NOTHING)
|
{
|
AsfCommands command = new AsfCommands();
|
command.state = asfCommands.state;
|
command.priority = asfCommands.priority;
|
result.add(mep(parameters, command, clone));
|
}
|
|
if ((asfCommands.brightness != -2) || (asfCommands.blinkOn > -1) || (asfCommands.blinkOff > -1))
|
{
|
AsfCommands command = new AsfCommands();
|
if (asfCommands.brightness != -2)
|
{
|
command.brightness = asfCommands.brightness;
|
}
|
if (asfCommands.blinkOn > -1)
|
{
|
command.blinkOn = asfCommands.blinkOn;
|
}
|
if (asfCommands.blinkOff > -1)
|
{
|
command.blinkOff = asfCommands.blinkOff;
|
}
|
result.add(mpp(parameters, command, clone));
|
}
|
|
if (asfCommands.reset == AsfCommands.CONDITION_YES)
|
{
|
AsfCommands command = new AsfCommands();
|
command.reset = asfCommands.reset;
|
result.add(reset(parameters, command, clone));
|
}
|
|
if (asfCommands.timeout >= 0)
|
{
|
AsfCommands command = new AsfCommands();
|
command.timeout = asfCommands.timeout;
|
result.add(timeout(parameters, command, clone));
|
}
|
|
mutex.lockWrite();
|
{
|
Shared.model.updateDevice(device, clone);
|
}
|
mutex.releaseWrite();
|
|
return result.toArray(new DeviceAction[result.size()]);
|
} catch (Exception exception)
|
{
|
//Shared.printstack("update exception", exception);
|
return (art.servers.asfserver.Shared.responseError(device, parameters, exception));
|
}
|
}
|
|
private DeviceAction mpp(InteropParameters parameters, AsfCommands command, Asf deviceclone)
|
{
|
String language = (String) parameters.getParameterValue("language");
|
DeviceAction action = new DeviceAction(device, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
int currentPriority = this.device.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, Shared.getMessage("Insufficient priority"));
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
} else
|
{
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setVmsPp"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("vms", "" + deviceclone.getDeviceInformation().connectionEru.vmsNumber));
|
|
int brightness = -1; // Auto
|
if (deviceclone.getDeviceStatus().brightnessMode != AsfStatus.BRIGHTNESS_MODE_AUTO)
|
{
|
brightness = deviceclone.getDeviceStatus().brightnessLevel;
|
}
|
if (command.brightness != -2)
|
{
|
brightness = command.brightness;
|
}
|
int blinkon = (int) Math.round(deviceclone.getDeviceStatus().blinkOn * 1000);
|
if (command.blinkOn > -1)
|
{
|
blinkon = (int) Math.round(command.blinkOn * 10);
|
}
|
int blinkoff = (int) Math.round(deviceclone.getDeviceStatus().blinkOff * 1000);
|
if (command.blinkOff > -1)
|
{
|
blinkoff = (int) Math.round(command.blinkOff * 10);
|
}
|
|
if (blinkon == 0)
|
{
|
blinkon = 500;
|
}
|
if (blinkoff == 0)
|
{
|
blinkoff = 500;
|
}
|
|
int messagetime = 2;
|
if (brightness == -1)
|
{
|
brightness = 'A';
|
} else
|
{
|
brightness = AsfDgtProtocolConstructor.getBrightnessDGTLevel(brightness, deviceclone.getDeviceInformation().maximumBrightnessLevel);
|
}
|
|
parametersOrder.addParameter(new InteropParameter("brightness", "" + brightness));
|
parametersOrder.addParameter(new InteropParameter("blinkon", "" + blinkon));
|
parametersOrder.addParameter(new InteropParameter("blinkoff", "" + blinkoff));
|
parametersOrder.addParameter(new InteropParameter("messagetime", "" + messagetime));
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
Object[] lobject = Arrays.copyOf(response.getValue(), response.getValue().length, Object[].class);
|
|
int asfNumber = (Integer) lobject[1];
|
if (asfNumber == deviceclone.getDeviceInformation().connectionEru.vmsNumber)
|
{
|
int[] information = new int[lobject.length - 2];
|
for (int i = 0; i < information.length; i++)
|
{
|
information[i] = (Integer) lobject[i + 2];
|
}
|
|
AsfDgtProtocolAnalyser.analyseResponsePP(deviceclone, information);
|
}
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
private DeviceAction reset(InteropParameters parameters, AsfCommands command, Asf deviceclone)
|
{
|
String language = (String) parameters.getParameterValue("language");
|
DeviceAction action = new DeviceAction(device, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
int currentPriority = this.device.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, Shared.getMessage("Insufficient priority"));
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
} else
|
{
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setVmsReset"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", device.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("vms", "" + device.getDeviceInformation().connectionEru.vmsNumber));
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder, device.getDeviceInformation().connectionEru.address, device.getDeviceInformation().connectionEru.port, device.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);
|
}
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
private DeviceAction timeout(InteropParameters parameters, AsfCommands command, Asf deviceclone)
|
{
|
String language = (String) parameters.getParameterValue("language");
|
DeviceAction action = new DeviceAction(device, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
int currentPriority = this.device.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, Shared.getMessage("Insufficient priority"));
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
} else
|
{
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setVmsTimeout"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", device.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("vms", "" + device.getDeviceInformation().connectionEru.vmsNumber));
|
parametersOrder.addParameter(new InteropParameter("timeout", "" + command.timeout));
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder, device.getDeviceInformation().connectionEru.address, device.getDeviceInformation().connectionEru.port, device.getDeviceInformation().connectionEru.timeout);
|
Object[] lobject = Arrays.copyOf(response.getValue(), response.getValue().length, Object[].class);
|
List<Integer> lbytes = new ArrayList<>();
|
for (Object o : lobject)
|
{
|
lbytes.add((Integer) o);
|
}
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
private DeviceAction liberate(InteropParameters parameters, AsfCommands command, Asf deviceclone)
|
{
|
String language = (String) parameters.getParameterValue("language");
|
DeviceAction action = new DeviceAction(device, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
deviceclone.getDeviceStatus().priority = -1;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
} catch (Exception exception)
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
private DeviceAction mep(InteropParameters parameters, AsfCommands command, Asf deviceclone)
|
{
|
String language = (String) parameters.getParameterValue("language");
|
String username = (String) parameters.getParameterValue("username");
|
DeviceAction action = new DeviceAction(device, parameters, command);
|
|
action.actionName = command.getActionName();
|
|
try
|
{
|
int currentPriority = this.device.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, Shared.getMessage("Insufficient priority"));
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
} else
|
{
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setVmsMep"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", device.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("vms", "" + device.getDeviceInformation().connectionEru.vmsNumber));
|
|
byte[] message = AsfDgtProtocolConstructor.getBodyContentMessage(command.state, deviceclone);
|
parametersOrder.addBodycontent(message);
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
|
Object[] lobject = Arrays.copyOf(response.getValue(), response.getValue().length, Object[].class);
|
int asfNumber = (Integer) lobject[1];
|
if (asfNumber == deviceclone.getDeviceInformation().connectionEru.vmsNumber)
|
{
|
int[] information = new int[lobject.length - 2];
|
for (int i = 0; i < information.length; i++)
|
{
|
information[i] = (Integer) lobject[i + 2];
|
}
|
|
AsfDgtProtocolAnalyser.analyseResponseEP(deviceclone, information);
|
}
|
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
//Shared.printstack("Exception", exception);
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
// </editor-fold>
|
}
|
