package art.servers.pvvserver.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.vms.pvv.Pvv;
|
import art.library.model.devices.vms.pvv.PvvCommands;
|
import art.library.model.devices.vms.pvv.PvvConfiguration;
|
import art.library.model.devices.vms.pvv.PvvInformation;
|
import art.library.model.devices.vms.pvv.PvvStatus;
|
import art.library.model.devices.vms.pvv.commands.PvvCommandsConfiguration;
|
import art.library.model.devices.vms.pvv.commands.PvvCommandsMessage;
|
import art.library.model.devices.vms.pvv.commands.PvvCommandsMessageBlinkings;
|
import art.library.model.devices.vms.pvv.commands.PvvCommandsMessageVisibilities;
|
import art.library.model.devices.vms.pvv.information.PvvInformationConfigurationAddressSpeed;
|
import art.library.utils.common.NumberUtils;
|
import art.library.utils.synchro.Mutex;
|
import art.servers.ServerException;
|
import art.servers.Shared;
|
import art.servers.PvvServer;
|
import art.servers.pvvserver.protocols.dgt.PvvDgtConstants;
|
import art.servers.pvvserver.protocols.dgt.PvvDgtProtocolAnalyser;
|
import java.util.Arrays;
|
import java.util.List;
|
import art.servers.pvvserver.protocols.dgt.PvvDgtProtocolConstructor;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
|
public class ControllerPvvVirtual extends ControllerPvv
|
{
|
|
private String name = null;
|
private boolean firstTime = true;
|
private Mutex mutex = new Mutex();
|
|
public ControllerPvvVirtual(Pvv pvv)
|
{
|
super(pvv);
|
this.device = pvv;
|
this.name = Shared.getMessage("Controller pvv virtual") + " " + pvv.toString();
|
|
this.setName(name);
|
if (device.getDeviceStatus() == null)
|
{
|
device.status = new PvvStatus();
|
}
|
}
|
|
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)
|
{
|
//Shared.printstack("run ControllerPvvVirtual", 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)
|
{
|
//Shared.printstack("run ControllerPvvVirtual", e);
|
}
|
} else
|
{
|
try
|
{
|
sleep(50);
|
} catch (Exception e)
|
{
|
//Shared.printstack("run ControllerPvvVirtual", 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();
|
Pvv pvvVirtualClone = (Pvv) Serialization.clone(device);
|
|
try
|
{
|
List<Pvv> lisPvv = getAllValidPvvsOfVirtual(pvvVirtualClone);
|
|
//All pvvs are offline -> Virtual pvv is offline
|
if (lisPvv.isEmpty())
|
{
|
offline(pvvVirtualClone);
|
return;
|
}
|
|
readAlarms(pvvVirtualClone, lisPvv);
|
readConfigurationAndStatus(pvvVirtualClone, lisPvv);
|
online(pvvVirtualClone);
|
} catch (Exception e)
|
{
|
//Shared.printstack("Exception ControllerPvvVirtual update", e);
|
offline(pvvVirtualClone);
|
} finally
|
{
|
mutex.releaseWrite();
|
}
|
}
|
|
//Get all pvvs with status valid from virtual
|
private List<Pvv> getAllValidPvvsOfVirtual(Pvv pvvVirtualClone) throws Exception
|
{
|
List<Pvv> lisPvv = new ArrayList<>();
|
PvvInformation information = pvvVirtualClone.getDeviceInformation();
|
|
if (information.pvvs != null)
|
{
|
for (String identifierVirtualDevice : information.pvvs)
|
{
|
Pvv pvvElem = (Pvv) Shared.model.getDeviceExternal(identifierVirtualDevice);
|
if (pvvElem != null && pvvElem.getDeviceStatus().isValid())
|
{
|
lisPvv.add(pvvElem);
|
}
|
}
|
}
|
|
return lisPvv;
|
}
|
|
//Get all pvvs numbers from virtual joined by character that has enough priority
|
private String getAllPvvsNumbersOfVirtual(List<Pvv> devices, int commandPriority, String joinChars) throws Exception
|
{
|
List<String> lisPvvNumbers = new ArrayList<>();
|
|
for (Pvv pvvElem : devices)
|
{
|
if ((pvvElem.getDeviceInformation().side == false)) // && (commandPriority >= pvvElem.getDeviceStatus().priority)
|
{
|
if ((commandPriority < 0) || (commandPriority >= pvvElem.getDeviceStatus().priority))
|
{
|
pvvElem.getDeviceStatus().priority = commandPriority;
|
pvvElem.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
lisPvvNumbers.add(pvvElem.getDeviceInformation().connectionEru.pvvNumber + "");
|
}
|
}
|
}
|
|
return lisPvvNumbers.isEmpty() ? "" : String.join(joinChars, lisPvvNumbers);
|
}
|
|
private void offline(Pvv pvvVirtualClone) throws Exception
|
{
|
if ((device.alarms.alarm_offline <= 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Pvv offline");
|
art.servers.Shared.println(name, message);
|
}
|
|
pvvVirtualClone.setAlarm("alarm_offline", System.currentTimeMillis());
|
Shared.model.updateDevice(device, pvvVirtualClone);
|
}
|
|
private void online(Pvv pvvVirtualClone) throws Exception
|
{
|
if ((device.alarms.alarm_offline > 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Pvv virtual online");
|
Shared.println(this.name, message);
|
}
|
|
pvvVirtualClone.setAlarm("alarm_offline", false);
|
pvvVirtualClone.setAlarm("alarm_invalid", false);
|
Shared.model.updateDevice(device, pvvVirtualClone);
|
}
|
|
//Add alarms of all contained pvvs to virtual
|
private void readAlarms(Pvv pvvVirtualClone, List<Pvv> lisPvv) throws Exception
|
{
|
try
|
{
|
HashMap<String, String> halarms = new HashMap<String, String>();
|
for (Pvv pvvElem : lisPvv)
|
{
|
for (String alarmName : pvvElem.getDeviceAlarms().getActiveAlarms())
|
{
|
pvvVirtualClone.setAlarm(alarmName, true);
|
halarms.putIfAbsent(alarmName, alarmName);
|
}
|
}
|
|
for (Pvv pvvElem : lisPvv)
|
{
|
for (String alarmName : pvvElem.getDeviceAlarms().getAlarmsFieldsNames())
|
{
|
if (halarms.containsKey(alarmName) == false)
|
{
|
pvvVirtualClone.setAlarm(alarmName, false);
|
}
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
//Shared.printstack("exception pvvVirtual on readAlarms ConnectionEru " + Serialization.toPrettyString(pvvVirtualClone.getDeviceInformation().connectionEru), e);
|
throw e;
|
}
|
}
|
|
private void readConfigurationAndStatus(Pvv pvvVirtualClone, List<Pvv> lisPvv) throws Exception
|
{
|
try
|
{
|
|
PvvStatus minPvvStatus = null;
|
PvvConfiguration minPvvConfiguration = null;
|
int priorityVirtual = pvvVirtualClone.getDeviceStatus().priority;
|
|
for (Pvv pvvElem : lisPvv)
|
{
|
if ((pvvElem.getDeviceStatus().state == PvvStatus.STATE_ON) &&
|
(minPvvStatus == null || pvvElem.getDeviceStatus().speed < minPvvStatus.speed) &&
|
(pvvElem.getDeviceInformation().side == false))
|
{
|
minPvvStatus = pvvElem.getDeviceStatus();
|
minPvvConfiguration = pvvElem.getDeviceConfiguration();
|
}
|
}
|
|
//If all are off -> Virtual is off with speed 0
|
if (minPvvStatus == null)
|
{
|
pvvVirtualClone.getDeviceStatus().state = PvvStatus.STATE_OFF;
|
pvvVirtualClone.getDeviceStatus().speed = 0;
|
//If there are Pvv On -> Virtual has the status of element with min speed
|
} else
|
{
|
pvvVirtualClone.status = Serialization.clone(minPvvStatus);
|
}
|
|
if (minPvvConfiguration == null)
|
{
|
pvvVirtualClone.configuration = new PvvConfiguration();
|
} else
|
{
|
pvvVirtualClone.configuration = Serialization.clone(minPvvConfiguration);
|
}
|
|
pvvVirtualClone.getDeviceStatus().priority = priorityVirtual;
|
|
} catch (Exception e)
|
{
|
if (this.device.getIdentifier().equalsIgnoreCase(PvvServer.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<>();
|
PvvCommands pvvCommands = (PvvCommands) parameters.getBodyContentValue(PvvCommands.class);
|
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, Serialization.toPrettyString(pvvCommands));
|
}
|
|
Pvv clone = (Pvv) Serialization.clone(device);
|
List<Pvv> devicesClone = new ArrayList<>();
|
for (Pvv pvv : getAllValidPvvsOfVirtual(clone))
|
{
|
devicesClone.add((Pvv) Serialization.clone(pvv));
|
}
|
|
//Liberate
|
if (pvvCommands.liberate == DeviceCommands.CONDITION_YES)
|
{
|
PvvCommands command = new PvvCommands();
|
command.liberate = pvvCommands.liberate;
|
result.add(liberate(parameters, command, clone, devicesClone));
|
}
|
|
//Turn off
|
if (pvvCommands.turnOff == DeviceCommands.CONDITION_YES)
|
{
|
PvvCommands command = new PvvCommands();
|
command.priority = pvvCommands.priority;
|
command.turnOff = pvvCommands.turnOff;
|
result.add(turnOff(parameters, command, clone, devicesClone));
|
}
|
|
//Messages
|
if (pvvCommands.message != null)
|
{
|
PvvCommands commandMep = new PvvCommands();
|
commandMep.priority = pvvCommands.priority;
|
commandMep.configuration = new PvvCommandsConfiguration();
|
commandMep.message = new PvvCommandsMessage();
|
|
if (pvvCommands.message.timeout >= 0)
|
{
|
//Timeout
|
commandMep.message.timeout = pvvCommands.message.timeout;
|
}
|
|
commandMep.message.speed = pvvCommands.message.speed;
|
commandMep.message.synchroActivation = pvvCommands.message.synchroActivation;
|
|
//Blinkings
|
if (pvvCommands.message.blinkings == null)
|
{
|
pvvCommands.message.blinkings = new PvvCommandsMessageBlinkings();
|
|
if (this.device.getDeviceStatus() != null)
|
{
|
pvvCommands.message.blinkings.blinkingCircle = this.device.getDeviceStatus().blinkingCircle ? DeviceCommands.CONDITION_YES : DeviceCommands.CONDITION_NO;
|
pvvCommands.message.blinkings.blinkingFlashes = this.device.getDeviceStatus().blinkingFlashes ? DeviceCommands.CONDITION_YES : DeviceCommands.CONDITION_NO;
|
pvvCommands.message.blinkings.blinkingSpeed = this.device.getDeviceStatus().blinkingSpeed ? DeviceCommands.CONDITION_YES : DeviceCommands.CONDITION_NO;
|
}
|
|
}
|
|
commandMep.message.blinkings = new PvvCommandsMessageBlinkings();
|
|
if (pvvCommands.message.blinkings.blinkingCircle > -1)
|
{
|
commandMep.message.blinkings.blinkingCircle = pvvCommands.message.blinkings.blinkingCircle;
|
}
|
if (pvvCommands.message.blinkings.blinkingFlashes > -1)
|
{
|
commandMep.message.blinkings.blinkingFlashes = pvvCommands.message.blinkings.blinkingFlashes;
|
}
|
if (pvvCommands.message.blinkings.blinkingSpeed > -1)
|
{
|
commandMep.message.blinkings.blinkingSpeed = pvvCommands.message.blinkings.blinkingSpeed;
|
}
|
|
//Visibilities
|
if (pvvCommands.message.visibilities == null)
|
{
|
pvvCommands.message.visibilities = new PvvCommandsMessageVisibilities();
|
|
if (this.device.getDeviceStatus() != null)
|
{
|
pvvCommands.message.visibilities.visibilityCircle = this.device.getDeviceStatus().visibilityCircle;
|
pvvCommands.message.visibilities.visibilityFlashes = this.device.getDeviceStatus().visibilityFlashes;
|
pvvCommands.message.visibilities.visibilitySpeed = this.device.getDeviceStatus().visibilitySpeed;
|
}
|
}
|
|
//Visibility
|
commandMep.message.visibilities = new PvvCommandsMessageVisibilities();
|
|
commandMep.message.visibilities.visibilityCircle = pvvCommands.message.visibilities.visibilityCircle;
|
commandMep.message.visibilities.visibilityFlashes = pvvCommands.message.visibilities.visibilityFlashes;
|
commandMep.message.visibilities.visibilitySpeed = pvvCommands.message.visibilities.visibilitySpeed;
|
|
result.add(mep(parameters, commandMep, clone, devicesClone));
|
|
//Side devices
|
PvvCommands commandMepElem = (PvvCommands) Serialization.clone(commandMep);
|
commandMepElem.message.synchroActivation = DeviceCommands.CONDITION_NO;
|
for (Pvv pvvElem : devicesClone)
|
{
|
if (pvvElem.getDeviceInformation().side)
|
{
|
result.add(mep(parameters, commandMepElem, pvvElem, devicesClone));
|
}
|
}
|
}
|
|
if (pvvCommands.configuration != null)
|
{
|
PvvCommands commandMppConfiguration = new PvvCommands();
|
commandMppConfiguration.configuration = pvvCommands.configuration;
|
|
for (Pvv pvvElem : devicesClone)
|
{
|
PvvCommands commandMppConfigurationElem = (PvvCommands) Serialization.clone(commandMppConfiguration);
|
result.add(mpp(parameters, commandMppConfigurationElem, pvvElem));
|
}
|
|
}
|
|
mutex.lockWrite();
|
{
|
Shared.model.updateDevice(device, clone);
|
|
for (Pvv pvvCloneElem : devicesClone)
|
{
|
ControllerPvvDGTEru controller = (ControllerPvvDGTEru) Shared.getDeviceController(pvvCloneElem.getIdentifier());
|
controller.updateExternal(pvvCloneElem);
|
}
|
}
|
mutex.releaseWrite();
|
|
return result.toArray(new DeviceAction[result.size()]);
|
} catch (Exception exception)
|
{
|
//Shared.printstack("PvvVirtual error", exception);
|
return (art.servers.pvvserver.Shared.responseError(device, parameters, exception));
|
}
|
|
}
|
|
private DeviceAction mpp(InteropParameters parameters, PvvCommands command, Pvv deviceclone)
|
{
|
|
String language = (String) parameters.getParameterValue("language");
|
|
DeviceAction action = new DeviceAction(deviceclone, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
Pvv currentPvv = (Pvv) Shared.model.getDevice(deviceclone.getIdentifier());
|
int currentPriority = currentPvv.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
return generateInsufficientPriorityAction(action);
|
} else
|
{
|
|
PvvCommandsConfiguration pvvCommandsConfiguration = new PvvCommandsConfiguration();
|
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setPvvMpp"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("pvv", "" + deviceclone.getDeviceInformation().connectionEru.pvvNumber));
|
|
int brightness = -1; // Auto
|
if (deviceclone.getDeviceConfiguration().brightnessMode != PvvStatus.BRIGHTNESS_MODE_AUTO)
|
{
|
brightness = deviceclone.getDeviceStatus().brightnessLevel;
|
}
|
|
if (command.configuration.brightness != -2)
|
{
|
brightness = command.configuration.brightness;
|
pvvCommandsConfiguration.brightnessControl = command.configuration.brightnessControl;
|
|
}
|
|
int blinkon = (int) Math.round(deviceclone.getDeviceConfiguration().blinkOn * 1000);
|
|
if (command.configuration.blinkOn > -1)
|
{
|
blinkon = (int) Math.round(command.configuration.blinkOn * 1000);
|
}
|
|
int blinkoff = (int) Math.round(deviceclone.getDeviceConfiguration().blinkOff * 1000);
|
|
if (command.configuration.blinkOff > -1)
|
{
|
blinkoff = (int) Math.round(command.configuration.blinkOff * 1000);
|
}
|
|
if (blinkon <= 0)
|
{
|
blinkon = 500;
|
}
|
if (blinkoff <= 0)
|
{
|
blinkoff = 500;
|
}
|
|
if (brightness == -1)
|
{
|
brightness = 'A';
|
} else
|
{
|
brightness = PvvDgtProtocolConstructor.getBrightnessDGTLevel(brightness, deviceclone.getDeviceInformation().maximumBrightnessLevel);
|
}
|
|
pvvCommandsConfiguration.blinkOn = blinkon;
|
pvvCommandsConfiguration.blinkOff = blinkoff;
|
pvvCommandsConfiguration.brightness = brightness;
|
|
pvvCommandsConfiguration.flashPeriod = deviceclone.getDeviceConfiguration().flashPeriod;
|
if (command.configuration.flashPeriod > -1)
|
{
|
pvvCommandsConfiguration.flashPeriod = command.configuration.flashPeriod * 10;
|
}
|
|
pvvCommandsConfiguration.flashStopTime = deviceclone.getDeviceConfiguration().flashStopTime;
|
if (command.configuration.flashStopTime > -1)
|
{
|
pvvCommandsConfiguration.flashStopTime = command.configuration.flashStopTime * 10;
|
}
|
|
pvvCommandsConfiguration.flashesOnPercentage = deviceclone.getDeviceConfiguration().flashesOnPercentage;
|
if (command.configuration.flashesOnPercentage > -1)
|
{
|
pvvCommandsConfiguration.flashesOnPercentage = command.configuration.flashesOnPercentage;
|
}
|
|
pvvCommandsConfiguration.flashesxPeriod = deviceclone.getDeviceConfiguration().flashesxPeriod;
|
if (command.configuration.flashesxPeriod > -1)
|
{
|
pvvCommandsConfiguration.flashesxPeriod = command.configuration.flashesxPeriod;
|
}
|
|
parametersOrder.addBodycontent(pvvCommandsConfiguration);
|
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, currentPvv.getIdentifier() + " - Configuration Body: " + Serialization.toPrettyString(pvvCommandsConfiguration));
|
}
|
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);
|
List<Integer> lbytes = new ArrayList<>();
|
for (Object o : lobject)
|
{
|
lbytes.add((Integer) o);
|
}
|
|
int numberOfPvvs = lbytes.get(0);
|
int pvvNumber = lbytes.get(1);
|
|
if (pvvNumber == deviceclone.getDeviceInformation().connectionEru.pvvNumber)
|
{
|
// Message received corresponds to pvv
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
}
|
|
PvvDgtProtocolAnalyser.analyseResponsePPDgtEru(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 mpp2(InteropParameters parameters, PvvCommands command, Pvv deviceclone)
|
{
|
|
String language = (String) parameters.getParameterValue("language");
|
|
DeviceAction action = new DeviceAction(deviceclone, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
Pvv currentPvv = (Pvv) Shared.model.getDevice(deviceclone.getIdentifier());
|
int currentPriority = currentPvv.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
return generateInsufficientPriorityAction(action);
|
} else
|
{
|
|
PvvCommandsConfiguration pvvCommandsConfiguration = new PvvCommandsConfiguration();
|
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setPvvMpp"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("pvv", "" + deviceclone.getDeviceInformation().connectionEru.pvvNumber));
|
|
int brightness = -1; // Auto
|
if (deviceclone.getDeviceConfiguration().brightnessMode != PvvStatus.BRIGHTNESS_MODE_AUTO)
|
{
|
brightness = deviceclone.getDeviceStatus().brightnessLevel;
|
}
|
|
if (command.configuration.brightness != -2)
|
{
|
brightness = command.configuration.brightness;
|
pvvCommandsConfiguration.brightnessControl = command.configuration.brightnessControl;
|
|
}
|
|
int blinkon = (int) Math.round(deviceclone.getDeviceConfiguration().blinkOn * 1000);
|
|
if (command.configuration.blinkOn > -1)
|
{
|
blinkon = (int) Math.round(command.configuration.blinkOn * 1000);
|
}
|
|
int blinkoff = (int) Math.round(deviceclone.getDeviceConfiguration().blinkOff * 1000);
|
|
if (command.configuration.blinkOff > -1)
|
{
|
blinkoff = (int) Math.round(command.configuration.blinkOff * 1000);
|
}
|
|
if (blinkon == 0)
|
{
|
blinkon = 500;
|
}
|
if (blinkoff == 0)
|
{
|
blinkoff = 500;
|
}
|
|
if (brightness == -1)
|
{
|
brightness = 'A';
|
} else
|
{
|
brightness = PvvDgtProtocolConstructor.getBrightnessDGTLevel(brightness, deviceclone.getDeviceInformation().maximumBrightnessLevel);
|
}
|
|
pvvCommandsConfiguration.blinkOn = blinkon;
|
pvvCommandsConfiguration.blinkOff = blinkoff;
|
pvvCommandsConfiguration.brightness = brightness;
|
|
pvvCommandsConfiguration.flashPeriod = deviceclone.getDeviceConfiguration().flashPeriod;
|
if (command.configuration.flashPeriod > -1)
|
{
|
pvvCommandsConfiguration.flashPeriod = command.configuration.flashPeriod * 10;
|
}
|
|
pvvCommandsConfiguration.flashStopTime = deviceclone.getDeviceConfiguration().flashStopTime;
|
if (command.configuration.flashStopTime > -1)
|
{
|
pvvCommandsConfiguration.flashStopTime = command.configuration.flashStopTime * 10;
|
}
|
|
pvvCommandsConfiguration.flashesOnPercentage = deviceclone.getDeviceConfiguration().flashesOnPercentage;
|
if (command.configuration.flashesOnPercentage > -1)
|
{
|
pvvCommandsConfiguration.flashesOnPercentage = command.configuration.flashesOnPercentage;
|
}
|
|
pvvCommandsConfiguration.flashesxPeriod = deviceclone.getDeviceConfiguration().flashesxPeriod;
|
if (command.configuration.flashesxPeriod > -1)
|
{
|
pvvCommandsConfiguration.flashesxPeriod = command.configuration.flashesxPeriod;
|
}
|
|
parametersOrder.addBodycontent(pvvCommandsConfiguration);
|
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, "Configuration Body: " + Serialization.toPrettyString(pvvCommandsConfiguration));
|
}
|
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);
|
List<Integer> lbytes = new ArrayList<>();
|
for (Object o : lobject)
|
{
|
lbytes.add((Integer) o);
|
}
|
|
int numberOfPvvs = lbytes.get(0);
|
int pvvNumber = lbytes.get(1);
|
|
if (pvvNumber == deviceclone.getDeviceInformation().connectionEru.pvvNumber)
|
{
|
// Message received corresponds to pvv
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
}
|
|
PvvDgtProtocolAnalyser.analyseResponsePPDgtEru(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 liberate(InteropParameters parameters, PvvCommands command, Pvv deviceclone, List<Pvv> devicesClone)
|
{
|
String language = (String) parameters.getParameterValue("language");
|
DeviceAction action = new DeviceAction(device, parameters, command);
|
action.actionName = command.getActionName();
|
|
try
|
{
|
//Liberate device
|
deviceclone.getDeviceStatus().priority = -1;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
|
boolean isVirtual = deviceclone.getDeviceInformation().pvvs != null;
|
|
//If virtual, liberate its physical devices, too
|
if (isVirtual)
|
{
|
for (Pvv pvvElem : devicesClone)
|
{
|
pvvElem.getDeviceStatus().priority = -1;
|
pvvElem.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 turnOff(InteropParameters parameters, PvvCommands command, Pvv deviceclone, List<Pvv> devicesClone)
|
{
|
boolean isVirtual = deviceclone.getDeviceInformation().pvvs != null;
|
String language = (String) parameters.getParameterValue("language");
|
String username = (String) parameters.getParameterValue("username");
|
DeviceAction action = new DeviceAction(deviceclone, parameters, command);
|
|
action.actionName = command.getActionName();
|
|
try
|
{
|
Pvv currentPvv = (Pvv) Shared.model.getDevice(deviceclone.getIdentifier());
|
int currentPriority = currentPvv.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
return generateInsufficientPriorityAction(action);
|
}
|
else
|
{
|
if (isVirtual == true)
|
{
|
for (Pvv pvvElem : devicesClone)
|
{
|
try
|
{
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setPvvMep"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", pvvElem.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("pvv", "" + pvvElem.getDeviceInformation().connectionEru.pvvNumber));
|
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, pvvElem.getIdentifier() + " - " + Serialization.toPrettyString(parametersOrder));
|
}
|
|
byte[] message = getBodyContentMessage(command, pvvElem);
|
String s = "> ";
|
for (int i=0; i<message.length; i++)
|
{
|
s += String.format("%02X ", message[i]);
|
}
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, s);
|
}
|
|
parametersOrder.addBodycontent(message);
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder,
|
pvvElem.getDeviceInformation().connectionEru.address,
|
pvvElem.getDeviceInformation().connectionEru.port,
|
pvvElem.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);
|
}
|
|
s = "< ";
|
for (int i=0; i<lbytes.size(); i++)
|
{
|
s += String.format("%02X ", lbytes.get(i));
|
}
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, s);
|
}
|
|
int pvvNumber = lbytes.get(1);
|
if (pvvNumber == pvvElem.getDeviceInformation().connectionEru.pvvNumber)
|
{
|
// Message received corresponds to pvvs
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
}
|
|
PvvDgtProtocolAnalyser.analyseResponseEP(pvvElem, deviceclone, information);
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, pvvElem.getIdentifier() + " - Analyzed");
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
Shared.printstack(name, e);
|
}
|
}
|
}
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, "TurnOff Ok");
|
}
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
//Shared.printstack("PVVVirtual mep", exception);
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
|
private DeviceAction mep(InteropParameters parameters, PvvCommands command, Pvv deviceclone, List<Pvv> devicesClone)
|
{
|
boolean isVirtual = deviceclone.getDeviceInformation().pvvs != null;
|
String language = (String) parameters.getParameterValue("language");
|
String username = (String) parameters.getParameterValue("username");
|
DeviceAction action = new DeviceAction(deviceclone, parameters, command);
|
|
action.actionName = command.getActionName();
|
|
try
|
{
|
Pvv currentPvv = (Pvv) Shared.model.getDevice(deviceclone.getIdentifier());
|
int currentPriority = currentPvv.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
return generateInsufficientPriorityAction(action);
|
} else
|
{
|
String pvvIdentifier = isVirtual ? getAllPvvsNumbersOfVirtual(devicesClone, command.priority, ",") : "" + currentPvv.getDeviceInformation().connectionEru.pvvNumber;
|
|
if (isVirtual && pvvIdentifier.isEmpty())
|
{
|
return generateInsufficientPriorityAction(action);
|
}
|
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", isVirtual ? "setPvvMepm" : "setPvvMep"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", currentPvv.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("pvv", pvvIdentifier));
|
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, currentPvv.getIdentifier() + " - " + command.message.speed + " - " + Serialization.toPrettyString(parametersOrder));
|
}
|
|
byte[] message = getBodyContentMessage(command, currentPvv);
|
String s = "> ";
|
for (int i=0; i<message.length; i++)
|
{
|
s += String.format("%02X ", message[i]);
|
}
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, s);
|
}
|
|
parametersOrder.addBodycontent(message);
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder, currentPvv.getDeviceInformation().connectionEru.address, currentPvv.getDeviceInformation().connectionEru.port, currentPvv.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);
|
}
|
|
s = "< ";
|
for (int i=0; i<lbytes.size(); i++)
|
{
|
s += String.format("%02X ", lbytes.get(i));
|
}
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, s);
|
}
|
|
if (!isVirtual)
|
{
|
int pvvNumber = lbytes.get(1);
|
if (pvvNumber == currentPvv.getDeviceInformation().connectionEru.pvvNumber)
|
{
|
// Message received corresponds to pvvs
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
}
|
|
PvvDgtProtocolAnalyser.analyseResponseEP(currentPvv, deviceclone, information);
|
}
|
}
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
|
//If has sincro activation, send OPVV_SINCRO
|
if (command.message != null && command.message.synchroActivation == DeviceCommands.CONDITION_YES)
|
{
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, "Send Synchro");
|
}
|
InteropParameters parametersSynchro = new InteropParameters();
|
parametersSynchro.addParameter(new InteropParameter("operation", "setPvvSincro"));
|
parametersSynchro.addParameter(new InteropParameter("language", language));
|
parametersSynchro.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parametersSynchro.addParameter(new InteropParameter("pvv", "" + (isVirtual ? devicesClone.get(0).getDeviceInformation().number : deviceclone.getDeviceInformation().connectionEru.pvvNumber)));
|
parametersSynchro.addParameter(new InteropParameter("sincro", "1"));
|
Serialization.invoke("set", parametersSynchro, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, "Sent Synchro");
|
}
|
}
|
|
if (this.device.getIdentifier().indexOf("08-PVV-ED") == 0)
|
{
|
Shared.println(name, "MEP Ok");
|
}
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
//Shared.printstack("PVVVirtual mep", exception);
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
|
private DeviceAction mep2(InteropParameters parameters, PvvCommands command, Pvv deviceclone, List<Pvv> devicesClone)
|
{
|
boolean isVirtual = deviceclone.getDeviceInformation().pvvs != null;
|
String language = (String) parameters.getParameterValue("language");
|
String username = (String) parameters.getParameterValue("username");
|
DeviceAction action = new DeviceAction(deviceclone, parameters, command);
|
|
action.actionName = command.getActionName();
|
|
try
|
{
|
Pvv currentPvv = (Pvv) Shared.model.getDevice(deviceclone.getIdentifier());
|
int currentPriority = currentPvv.getDeviceStatus().priority;
|
|
if ((command.priority >= 0) && (command.priority < currentPriority))
|
{
|
return generateInsufficientPriorityAction(action);
|
} else
|
{
|
String pvvIdentifier = isVirtual ? getAllPvvsNumbersOfVirtual(devicesClone, command.priority, ",") : "" + currentPvv.getDeviceInformation().connectionEru.pvvNumber;
|
|
if (isVirtual && pvvIdentifier.isEmpty())
|
{
|
return generateInsufficientPriorityAction(action);
|
}
|
|
if (isVirtual == true)
|
{
|
for (Pvv pvvElem : devicesClone)
|
{
|
try
|
{
|
if (pvvElem.getDeviceInformation().side == true)
|
{
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", "setPvvMep"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", pvvElem.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("pvv", "" + pvvElem.getDeviceInformation().connectionEru.pvvNumber));
|
|
Shared.println(name, pvvElem.getIdentifier() + " - " + command.message.speed + " - " + Serialization.toPrettyString(parametersOrder));
|
|
byte[] message = getBodyContentMessage(command, pvvElem);
|
String s = "> ";
|
for (int i=0; i<message.length; i++)
|
{
|
s += String.format("%02X ", message[i]);
|
}
|
Shared.println(name, s);
|
|
parametersOrder.addBodycontent(message);
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder,
|
pvvElem.getDeviceInformation().connectionEru.address,
|
pvvElem.getDeviceInformation().connectionEru.port,
|
pvvElem.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);
|
}
|
|
s = "< ";
|
for (int i=0; i<lbytes.size(); i++)
|
{
|
s += String.format("%02X ", lbytes.get(i));
|
}
|
Shared.println(name, s);
|
|
int pvvNumber = lbytes.get(1);
|
if (pvvNumber == pvvElem.getDeviceInformation().connectionEru.pvvNumber)
|
{
|
// Message received corresponds to pvvs
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
}
|
|
PvvDgtProtocolAnalyser.analyseResponseEP(pvvElem, deviceclone, information);
|
Shared.println(name, pvvElem.getIdentifier() + " - " + command.message.speed + " - Analyzed");
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
Shared.printstack(name, e);
|
}
|
}
|
}
|
|
InteropParameters parametersOrder = new InteropParameters();
|
parametersOrder.addParameter(new InteropParameter("operation", isVirtual ? "setPvvMepm" : "setPvvMep"));
|
parametersOrder.addParameter(new InteropParameter("language", language));
|
parametersOrder.addParameter(new InteropParameter("device", currentPvv.getDeviceInformation().connectionEru.eru));
|
parametersOrder.addParameter(new InteropParameter("pvv", pvvIdentifier));
|
|
Shared.println(name, currentPvv.getIdentifier() + " - " + Serialization.toPrettyString(parametersOrder));
|
|
byte[] message = getBodyContentMessage(command, currentPvv);
|
parametersOrder.addBodycontent(message);
|
|
InteropResponse response = (InteropResponse) Serialization.invoke("set", parametersOrder, currentPvv.getDeviceInformation().connectionEru.address, currentPvv.getDeviceInformation().connectionEru.port, currentPvv.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);
|
}
|
|
if (!isVirtual)
|
{
|
int pvvNumber = lbytes.get(1);
|
if (pvvNumber == currentPvv.getDeviceInformation().connectionEru.pvvNumber)
|
{
|
// Message received corresponds to pvvs
|
int[] information = new int[lbytes.size() - 2];
|
for (int i = 2; i < lbytes.size(); i++)
|
{
|
information[i - 2] = lbytes.get(i);
|
}
|
|
PvvDgtProtocolAnalyser.analyseResponseEP(currentPvv, deviceclone, information);
|
}
|
}
|
|
deviceclone.getDeviceStatus().priority = command.priority;
|
deviceclone.getDeviceStatus().timestampOrder = System.currentTimeMillis();
|
|
//If has sincro activation, send OPVV_SINCRO
|
if (command.message != null && command.message.synchroActivation == DeviceCommands.CONDITION_YES)
|
{
|
Shared.println(name, "Send Synchro");
|
InteropParameters parametersSynchro = new InteropParameters();
|
parametersSynchro.addParameter(new InteropParameter("operation", "setPvvSincro"));
|
parametersSynchro.addParameter(new InteropParameter("language", language));
|
parametersSynchro.addParameter(new InteropParameter("device", deviceclone.getDeviceInformation().connectionEru.eru));
|
parametersSynchro.addParameter(new InteropParameter("pvv", "" + (isVirtual ? devicesClone.get(0).getDeviceInformation().number : deviceclone.getDeviceInformation().connectionEru.pvvNumber)));
|
parametersSynchro.addParameter(new InteropParameter("sincro", "1"));
|
Serialization.invoke("set", parametersSynchro, deviceclone.getDeviceInformation().connectionEru.address, deviceclone.getDeviceInformation().connectionEru.port, deviceclone.getDeviceInformation().connectionEru.timeout);
|
Shared.println(name, "Sent Synchro");
|
}
|
|
Shared.println(name, "MEP2 OK");
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
} catch (Exception exception)
|
{
|
//Shared.printstack("PVVVirtual mep", exception);
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
}
|
|
|
private byte[] getBodyContentMessage(PvvCommands command, Pvv currentPvv) throws Exception
|
{
|
try
|
{
|
if (command.turnOff == PvvCommands.CONDITION_YES || command.message.speed == 0)
|
{
|
return new byte[]
|
{
|
PvvDgtConstants.PVV_OFF
|
};
|
}
|
List<Byte> lresult = new ArrayList<>();
|
lresult.add((byte) PvvDgtConstants.PVV_FIX);
|
lresult.add((byte) PvvDgtConstants.PVV_TOPOLOGY_5);
|
lresult.add((byte) NumberUtils.IntToAscii(1));
|
|
List<Byte> lgraphicA = new ArrayList<>();
|
PvvInformationConfigurationAddressSpeed addressSpeed = currentPvv.getDeviceInformation().configuration.getBySpeed(command.message.speed);
|
if (addressSpeed == null)
|
{
|
throw new Exception(String.format("Error: Speed '%s' not found", command.message.speed));
|
}
|
|
// Subpanel 1
|
/*
|
|
Parámetros para el tipo de contenido = Memoria (31h)
|
Número de Memoria 1 Byte hexadecimal
|
Intermitencia 1 Byte ‘S’ o ‘N’.
|
(los tiempos de intermitencia son los definidos en la trama de configuración 11h)
|
|
Parámetros para el tipo de contenido = Memoria Extendido (34h)
|
Número de Memoria 1 Byte hexadecimal
|
Activar al recibir sincro 1 Byte ‘S’ o ‘N’.
|
Intermitencia Velocidad 1 Byte ‘S’ o ‘N’.
|
Intermitencia Orla 1 Byte ‘S’ o ‘N’.
|
Intermitencia Flashes 1 Byte ‘S’ o ‘N’.
|
Visibilidad Velocidad 1 Byte ‘S’ o ‘N’.
|
Visibilidad Orla 1 Byte ‘S’ o ‘N’.
|
Visibilidad Flashes 1 Byte ‘S’ o ‘N’.
|
*/
|
|
lgraphicA.add((byte) 0x31);
|
lgraphicA.add((byte) 0x34);
|
lgraphicA.add((byte) addressSpeed.address);
|
|
if (command.message.synchroActivation == DeviceCommands.CONDITION_YES)
|
{
|
lgraphicA.add((byte)'S');
|
}
|
else
|
{
|
lgraphicA.add((byte)'N');
|
}
|
lgraphicA.add((byte) (command.message.blinkings.blinkingSpeed == DeviceCommands.CONDITION_YES ? 'S' : 'N'));
|
lgraphicA.add((byte) (command.message.blinkings.blinkingCircle == DeviceCommands.CONDITION_YES ? 'S' : 'N'));
|
lgraphicA.add((byte) (command.message.blinkings.blinkingFlashes == DeviceCommands.CONDITION_YES ? 'S' : 'N'));
|
lgraphicA.add((byte) (command.message.visibilities.visibilitySpeed ? 'S' : 'N'));
|
lgraphicA.add((byte) (command.message.visibilities.visibilityCircle ? 'S' : 'N'));
|
lgraphicA.add((byte) (command.message.visibilities.visibilityFlashes ? 'S' : 'N'));
|
|
lresult.addAll(lgraphicA);
|
|
byte[] aux = new byte[lresult.size()];
|
for (int i = 0; i < aux.length; i++)
|
{
|
aux[i] = lresult.get(i);
|
}
|
|
return (aux);
|
} catch (Exception exception)
|
{
|
exception.printStackTrace();
|
throw exception;
|
}
|
}
|
|
private DeviceAction generateInsufficientPriorityAction(DeviceAction action)
|
{
|
DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, Shared.getMessage("Insufficient priority"));
|
action.setResult(actionResult);
|
Shared.model.addAction(action);
|
return action;
|
}
|
|
// </editor-fold>
|
}
|
