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.devices.Device;
|
import art.library.model.devices.dps.DPS;
|
import art.library.model.devices.dps.types.DPSVehicle;
|
import art.library.model.devices.etd.EtdStatus;
|
import art.library.model.devices.etd.information.EtdClassification;
|
import art.library.model.devices.etd.information.EtdInformationLane;
|
import art.library.model.devices.etd.information.EtdInformationSection;
|
import art.library.model.devices.etd.status.EtdStatusLane;
|
import art.library.model.transactions.traces.Trace;
|
import art.library.utils.common.TimeUtils;
|
import art.servers.etdserver.Shared;
|
import art.servers.etdserver.configuration.Configuration;
|
import art.servers.etdserver.configuration.ConfigurationEtd;
|
import art.servers.etdserver.configuration.EtdConfigurationLaneDPS;
|
import static java.lang.Thread.sleep;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
|
public class ControllerEtdDPS extends ControllerEtd
|
{
|
private SimpleDateFormat sdh = new SimpleDateFormat("HH:mm");
|
private long lastTimestamp = 0;
|
private int status = DeviceStatus.STATUS_ALARM;
|
private boolean firstTime = true;
|
|
|
public ControllerEtdDPS(Etd etd)
|
{
|
super(etd);
|
this.device = etd;
|
this.name = Shared.getMessage("Controller etd") + " " + etd.information.name;
|
this.setName(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
|
{
|
Configuration configuration = (Configuration)Shared.configuration;
|
ConfigurationEtd configurationEtd = configuration.getConfigurationEtd(deviceclone.getIdentifier());
|
ControllerDPS controllerDPS = Shared.getControllerDPS(configurationEtd.dpsIdentifier);
|
DPS dps = controllerDPS.getDPS();
|
|
if (dps.getAlarm("alarm_offline") > 0)
|
{
|
if (allDpsLanesOffline(deviceclone) == true)
|
{
|
deviceclone.getDeviceAlarms().clear();
|
deviceclone.setAlarm("alarm_offline", true);
|
return;
|
}
|
}
|
|
deviceclone.setAlarm("alarm_offline", false);
|
deviceclone.setAlarm("alarm_batteries_disconnected", dps.getAlarm("alarm_battery"));
|
deviceclone.setAlarm("alarm_power_stopped", dps.getAlarm("alarm_magnetometer"));
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
throw e;
|
}
|
}
|
|
|
private boolean allDpsLanesOffline(Etd deviceclone) throws Exception
|
{
|
try
|
{
|
Configuration configuration = (Configuration)Shared.configuration;
|
ConfigurationEtd configurationEtd = configuration.getConfigurationEtd(deviceclone.getIdentifier());
|
for (EtdConfigurationLaneDPS laneDPS : configurationEtd.llanesDPS)
|
{
|
ControllerDPS controllerDPS = Shared.getControllerDPS(laneDPS.dps);
|
if (controllerDPS == null)
|
{
|
System.out.println(Device.getDate(System.currentTimeMillis()) + " DPS LANES NULL: " + deviceclone.getIdentifier() + " - DPS: " + laneDPS.dps + " - Lane: " + laneDPS.lane);
|
}
|
DPS dps = controllerDPS.getDPS();
|
if (dps.getAlarm("alarm_offline") <= 0)
|
{
|
return(false);
|
}
|
}
|
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
|
return(true);
|
}
|
|
|
private void readCurrentTrafficData(Etd deviceclone) throws Exception
|
{
|
try
|
{
|
long tsPeriod = TimeUtils.thisperiod(deviceclone.getDeviceInformation().period);
|
long tsPeriodFrom = tsPeriod - (deviceclone.getDeviceInformation().period*1000L);
|
Configuration configuration = (Configuration)Shared.configuration;
|
ConfigurationEtd configurationEtd = configuration.getConfigurationEtd(deviceclone.getIdentifier());
|
List<DPSVehicle> lvehicles = new ArrayList<DPSVehicle>();
|
for (EtdConfigurationLaneDPS laneDPS : configurationEtd.llanesDPS)
|
{
|
ControllerDPS controllerDPS = Shared.getControllerDPS(laneDPS.dps);
|
try
|
{
|
if (controllerDPS == null)
|
{
|
System.out.println(Device.getDate(System.currentTimeMillis()) + " DPS NULL: " + deviceclone.getIdentifier() + " - DPS: " + laneDPS.dps + " - Lane: " + laneDPS.lane);
|
}
|
lvehicles.addAll(controllerDPS.getVehicles(tsPeriodFrom, tsPeriod, laneDPS.dpsLane));
|
}
|
catch (Exception e)
|
{
|
|
}
|
}
|
|
// lvehicles contains all vehicles of etd lanes
|
initialiseStatus(deviceclone, tsPeriod);
|
|
for (DPSVehicle vehicle : lvehicles)
|
{
|
try
|
{
|
addVehicleLane(vehicle, deviceclone, configurationEtd);
|
addVehicleLaneTotal(vehicle, deviceclone, configurationEtd);
|
addVehicleLaneSection(vehicle, deviceclone, configurationEtd);
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
}
|
|
for (EtdStatusLane laneStatus : deviceclone.getDeviceStatus().llane)
|
{
|
int classified = laneStatus.counting - laneStatus.unclassified;
|
|
if (classified > 0)
|
{
|
laneStatus.length = (laneStatus.length / classified);
|
int length = (int)(laneStatus.length*10);
|
laneStatus.length = (double)((double)length / 10d);
|
laneStatus.speed = (int)(laneStatus.speed / classified);
|
}
|
|
if (deviceclone.getDeviceInformation().period > 0)
|
{
|
if (deviceclone.getIdentifier().indexOf("21022") > -1)
|
{
|
System.out.println(deviceclone.getIdentifier() + " 1.Lane: " + laneStatus.number + " - Occ: " + laneStatus.occupancy + " - Period: " + deviceclone.getDeviceInformation().period);
|
}
|
laneStatus.occupancy = (float)((laneStatus.occupancy * 100f) / (float)(deviceclone.getDeviceInformation().period*1000));
|
if (deviceclone.getIdentifier().indexOf("21022") > -1)
|
{
|
System.out.println(deviceclone.getIdentifier() + " 2.Lane: " + laneStatus.number + " - Occ: " + laneStatus.occupancy + " - Period: " + deviceclone.getDeviceInformation().period);
|
}
|
int occupancy = (int)(laneStatus.occupancy*10);
|
laneStatus.occupancy = (float)((float)occupancy / 10f);
|
if (deviceclone.getIdentifier().indexOf("21022") > -1)
|
{
|
System.out.println(deviceclone.getIdentifier() + " 3.Lane: " + laneStatus.number + " - Occ: " + laneStatus.occupancy + " - Period: " + deviceclone.getDeviceInformation().period);
|
}
|
if (laneStatus.occupancy > 100f) laneStatus.occupancy = 100f;
|
}
|
}
|
|
for (EtdStatusLane sectionStatus : deviceclone.getDeviceStatus().lsection)
|
{
|
int classified = sectionStatus.counting - sectionStatus.unclassified;
|
|
if (classified > 0)
|
{
|
sectionStatus.length = (sectionStatus.length / classified);
|
int length = (int)(sectionStatus.length*10);
|
sectionStatus.length = (double)((double)length / 10d);
|
sectionStatus.speed = (int)(sectionStatus.speed / classified);
|
}
|
|
if (deviceclone.getDeviceInformation().period > 0)
|
{
|
if (deviceclone.getIdentifier().indexOf("21022") > -1)
|
{
|
System.out.println(deviceclone.getIdentifier() + " 1.Section: " + sectionStatus.number + " - Occ: " + sectionStatus.occupancy + " - Period: " + deviceclone.getDeviceInformation().period);
|
}
|
sectionStatus.occupancy = (float)((sectionStatus.occupancy * 100f) / (float)(deviceclone.getDeviceInformation().period*1000));
|
if (deviceclone.getIdentifier().indexOf("21022") > -1)
|
{
|
System.out.println(deviceclone.getIdentifier() + " 2.Section: " + sectionStatus.number + " - Occ: " + sectionStatus.occupancy + " - Period: " + deviceclone.getDeviceInformation().period);
|
}
|
EtdInformationSection sectionInformation = deviceclone.getDeviceInformation().getSection(sectionStatus.number);
|
sectionStatus.occupancy = (float)((sectionStatus.occupancy) / (float)(sectionInformation.llane.size()));
|
int occupancy = (int)(sectionStatus.occupancy*10);
|
sectionStatus.occupancy = (float)((float)occupancy / 10f);
|
if (deviceclone.getIdentifier().indexOf("21022") > -1)
|
{
|
System.out.println(deviceclone.getIdentifier() + " 3.Section: " + sectionStatus.number + " - Occ: " + sectionStatus.occupancy + " - Period: " + deviceclone.getDeviceInformation().period);
|
}
|
if (sectionStatus.occupancy > 100f) sectionStatus.occupancy = 100f;
|
}
|
}
|
|
int classified = deviceclone.getDeviceStatus().total.counting - deviceclone.getDeviceStatus().total.unclassified;
|
|
if (classified > 0)
|
{
|
deviceclone.getDeviceStatus().total.length = deviceclone.getDeviceStatus().total.length / classified;
|
int length = (int)(deviceclone.getDeviceStatus().total.length*10);
|
deviceclone.getDeviceStatus().total.length = (double)((double)length / 10d);
|
deviceclone.getDeviceStatus().total.speed = (int)(deviceclone.getDeviceStatus().total.speed / classified);
|
}
|
|
if (deviceclone.getDeviceInformation().period > 0)
|
{
|
deviceclone.getDeviceStatus().total.occupancy = (float)((deviceclone.getDeviceStatus().total.occupancy * 100f) / (float)(deviceclone.getDeviceInformation().period*1000));
|
deviceclone.getDeviceStatus().total.occupancy = (float)((deviceclone.getDeviceStatus().total.occupancy) / (float)(deviceclone.getDeviceInformation().lLane.size()));
|
int occupancy = (int)(deviceclone.getDeviceStatus().total.occupancy*10);
|
deviceclone.getDeviceStatus().total.occupancy = (float)((float)occupancy / 10f);
|
if (deviceclone.getDeviceStatus().total.occupancy > 100f) deviceclone.getDeviceStatus().total.occupancy = 100f;
|
}
|
|
deviceclone.setLastTimestampStatusUpdate(deviceclone.getDeviceStatus().measurementTimestamp);
|
}
|
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);
|
}
|
|
|
private void initialiseStatus (Etd deviceclone, long tsperiod)
|
{
|
if (deviceclone.getDeviceStatus() == null)
|
{
|
deviceclone.status = new EtdStatus();
|
for (EtdInformationLane laneInformation : deviceclone.getDeviceInformation().lLane)
|
{
|
EtdStatusLane laneStatus = new EtdStatusLane();
|
laneStatus.number = laneInformation.number;
|
laneStatus.correctMeasurements = 1;
|
laneStatus.totalMeasurements = 1;
|
laneStatus.status = DeviceStatus.STATUS_ONLINE;
|
deviceclone.getDeviceStatus().llane.add(laneStatus);
|
}
|
|
for (EtdInformationSection sectionInformation : deviceclone.getDeviceInformation().lSection)
|
{
|
EtdStatusLane sectionStatus = new EtdStatusLane();
|
sectionStatus.number = sectionInformation.number;
|
sectionStatus.correctMeasurements = 1;
|
sectionStatus.totalMeasurements = 1;
|
sectionStatus.status = DeviceStatus.STATUS_ONLINE;
|
deviceclone.getDeviceStatus().lsection.add(sectionStatus);
|
}
|
|
deviceclone.getDeviceStatus().total = new EtdStatusLane();
|
}
|
|
if (deviceclone.getDeviceStatus().total == null)
|
{
|
deviceclone.getDeviceStatus().total = new EtdStatusLane();
|
}
|
|
deviceclone.getDeviceStatus().total.status = DeviceStatus.STATUS_ONLINE;
|
|
deviceclone.getDeviceStatus().llane.clear();
|
deviceclone.getDeviceStatus().lsection.clear();
|
for (EtdInformationLane laneInformation : deviceclone.getDeviceInformation().lLane)
|
{
|
EtdStatusLane laneStatus = new EtdStatusLane();
|
laneStatus.number = laneInformation.number;
|
laneStatus.totalMeasurements = 1;
|
laneStatus.correctMeasurements = 1;
|
laneStatus.status = DeviceStatus.STATUS_ONLINE;
|
laneStatus.lengths = new int[deviceclone.getDeviceInformation().lLengthClassification.size()];
|
for (int l=0; l<laneStatus.lengths.length; l++)
|
laneStatus.lengths[l] = 0;
|
laneStatus.speeds = new int[deviceclone.getDeviceInformation().lSpeedClassification.size()];
|
for (int s=0; s<laneStatus.speeds.length; s++)
|
laneStatus.speeds[s] = 0;
|
laneStatus.speedxlength = new int[deviceclone.getDeviceInformation().lSpeedClassification.size()][deviceclone.getDeviceInformation().lLengthClassification.size()];
|
for (int s=0; s<laneStatus.speeds.length; s++)
|
{
|
for (int l=0; l<laneStatus.lengths.length; l++)
|
{
|
laneStatus.speedxlength[s][l] = 0;
|
}
|
}
|
deviceclone.getDeviceStatus().llane.add(laneStatus);
|
}
|
|
for (EtdInformationSection sectionInformation : deviceclone.getDeviceInformation().lSection)
|
{
|
EtdStatusLane sectionStatus = new EtdStatusLane();
|
sectionStatus.number = sectionInformation.number;
|
sectionStatus.totalMeasurements = 1;
|
sectionStatus.correctMeasurements = 1;
|
sectionStatus.status = DeviceStatus.STATUS_ONLINE;
|
sectionStatus.lengths = new int[deviceclone.getDeviceInformation().lLengthClassification.size()];
|
for (int l=0; l<sectionStatus.lengths.length; l++)
|
sectionStatus.lengths[l] = 0;
|
sectionStatus.speeds = new int[deviceclone.getDeviceInformation().lSpeedClassification.size()];
|
for (int s=0; s<sectionStatus.speeds.length; s++)
|
sectionStatus.speeds[s] = 0;
|
sectionStatus.speedxlength = new int[deviceclone.getDeviceInformation().lSpeedClassification.size()][deviceclone.getDeviceInformation().lLengthClassification.size()];
|
for (int s=0; s<sectionStatus.speeds.length; s++)
|
{
|
for (int l=0; l<sectionStatus.lengths.length; l++)
|
{
|
sectionStatus.speedxlength[s][l] = 0;
|
}
|
}
|
deviceclone.getDeviceStatus().lsection.add(sectionStatus);
|
}
|
|
deviceclone.getDeviceStatus().total.correctMeasurements = 1;
|
deviceclone.getDeviceStatus().total.totalMeasurements = 1;
|
deviceclone.getDeviceStatus().total.counting = 0;
|
deviceclone.getDeviceStatus().total.distance = 0;
|
deviceclone.getDeviceStatus().total.length = 0;
|
deviceclone.getDeviceStatus().total.occupancy = 0;
|
deviceclone.getDeviceStatus().total.speed = 0;
|
deviceclone.getDeviceStatus().total.unclassified = 0;
|
deviceclone.getDeviceStatus().total.wrongWayVehicleDetection = false;
|
deviceclone.getDeviceStatus().total.congestionDetection = false;
|
deviceclone.getDeviceStatus().total.lengths = new int[deviceclone.getDeviceInformation().lLengthClassification.size()];
|
for (int l=0; l<deviceclone.getDeviceStatus().total.lengths.length; l++)
|
deviceclone.getDeviceStatus().total.lengths[l] = 0;
|
deviceclone.getDeviceStatus().total.speeds = new int[deviceclone.getDeviceInformation().lSpeedClassification.size()];
|
for (int s=0; s<deviceclone.getDeviceStatus().total.speeds.length; s++)
|
deviceclone.getDeviceStatus().total.speeds[s] = 0;
|
deviceclone.getDeviceStatus().total.speedxlength = new int[deviceclone.getDeviceInformation().lSpeedClassification.size()][deviceclone.getDeviceInformation().lLengthClassification.size()];
|
for (int s=0; s<deviceclone.getDeviceStatus().total.speeds.length; s++)
|
{
|
for (int l=0; l<deviceclone.getDeviceStatus().total.lengths.length; l++)
|
{
|
deviceclone.getDeviceStatus().total.speedxlength[s][l] = 0;
|
}
|
}
|
|
deviceclone.getDeviceStatus().period = deviceclone.getDeviceInformation().period;
|
deviceclone.getDeviceStatus().setMeasurementTimestamp(Device.getDate(tsperiod));
|
}
|
|
|
private void addVehicleLane(DPSVehicle vehicle, Etd deviceclone, ConfigurationEtd configurationEtd)
|
{
|
try
|
{
|
List<EtdStatusLane> llaneStatus = getEtdStatusLane(deviceclone, vehicle, configurationEtd);
|
if ((llaneStatus == null) || (llaneStatus.size() == 0)) return;
|
|
for (EtdStatusLane laneStatus : llaneStatus)
|
{
|
laneStatus.counting = laneStatus.counting + 1;
|
if (vehicle.speed > -1) laneStatus.speed = laneStatus.speed + vehicle.speed;
|
if (vehicle.length > -1) laneStatus.length = laneStatus.length + ((double)vehicle.length);
|
laneStatus.occupancy = laneStatus.occupancy + vehicle.occupancy;
|
if (vehicle.length <= 0) laneStatus.unclassified = laneStatus.unclassified + 1;
|
laneStatus.totalMeasurements = 1;
|
laneStatus.correctMeasurements = 1;
|
}
|
|
// int lengthPosition = getClassificationPosition(((double)vehicle.length/100d), deviceclone.getDeviceInformation().lLengthClassification);
|
// laneStatus.lengths[lengthPosition] = laneStatus.lengths[lengthPosition] + 1;
|
// int speedPosition = getClassificationPosition(vehicle.speed, deviceclone.getDeviceInformation().lSpeedClassification);
|
// laneStatus.speeds[speedPosition] = laneStatus.speeds[speedPosition] + 1;
|
// laneStatus.speedxlength[speedPosition][lengthPosition] = laneStatus.speedxlength[speedPosition][lengthPosition] + 1;
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
}
|
|
|
private int getClassificationPosition(double value, List<EtdClassification> lclassification)
|
{
|
int position = 0;
|
|
try
|
{
|
for (int i=0; i<lclassification.size(); i++)
|
{
|
EtdClassification classification = lclassification.get(i);
|
if ((classification.lowerLimit <= value) && (value <= classification.upperLimit))
|
return(i);
|
}
|
|
if (lclassification.size() > 0)
|
return(lclassification.size()-1);
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
return(position);
|
}
|
|
|
private void addVehicleLaneTotal(DPSVehicle vehicle, Etd deviceclone, ConfigurationEtd configurationEtd)
|
{
|
try
|
{
|
List<EtdStatusLane> llaneStatus = getEtdStatusLane(deviceclone, vehicle, configurationEtd);
|
int number = 1;
|
if ((llaneStatus == null) || (llaneStatus.size() == 0)) number = 1;
|
else
|
number = llaneStatus.size();
|
|
deviceclone.getDeviceStatus().total.counting = deviceclone.getDeviceStatus().total.counting + number;
|
if (vehicle.speed > -1)
|
{
|
for (int i=0; i<number; i++)
|
deviceclone.getDeviceStatus().total.speed = deviceclone.getDeviceStatus().total.speed + vehicle.speed;
|
}
|
if (vehicle.length > -1)
|
{
|
for (int i=0; i<number; i++)
|
deviceclone.getDeviceStatus().total.length = deviceclone.getDeviceStatus().total.length + ((double)vehicle.length);
|
}
|
for (int i=0; i<number; i++)
|
deviceclone.getDeviceStatus().total.occupancy = deviceclone.getDeviceStatus().total.occupancy + vehicle.occupancy;
|
|
if (vehicle.length <= 0) deviceclone.getDeviceStatus().total.unclassified = deviceclone.getDeviceStatus().total.unclassified + number;
|
deviceclone.getDeviceStatus().total.totalMeasurements = number;
|
deviceclone.getDeviceStatus().total.correctMeasurements = number;
|
|
// int lengthPosition = getClassificationPosition(((double)vehicle.length/100d), deviceclone.getDeviceInformation().lLengthClassification);
|
// deviceclone.getDeviceStatus().total.lengths[lengthPosition] = deviceclone.getDeviceStatus().total.lengths[lengthPosition] + 1;
|
// int speedPosition = getClassificationPosition(vehicle.speed, deviceclone.getDeviceInformation().lSpeedClassification);
|
// deviceclone.getDeviceStatus().total.speeds[speedPosition] = deviceclone.getDeviceStatus().total.speeds[speedPosition] + 1;
|
// deviceclone.getDeviceStatus().total.speedxlength[speedPosition][lengthPosition] = deviceclone.getDeviceStatus().total.speedxlength[speedPosition][lengthPosition] + 1;
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
}
|
|
|
private void addVehicleLaneSection(DPSVehicle vehicle, Etd deviceclone, ConfigurationEtd configurationEtd)
|
{
|
try
|
{
|
List<EtdStatusLane> lsectionStatus = getEtdStatusSection(vehicle, deviceclone, configurationEtd);
|
|
if ((lsectionStatus == null) || (lsectionStatus.size() == 0)) return;
|
|
for (EtdStatusLane sectionStatus : lsectionStatus)
|
{
|
sectionStatus.counting = sectionStatus.counting + 1;
|
if (vehicle.speed > -1) sectionStatus.speed = sectionStatus.speed + vehicle.speed;
|
if (vehicle.length > -1) sectionStatus.length = sectionStatus.length + ((double)vehicle.length);
|
sectionStatus.occupancy = sectionStatus.occupancy + vehicle.occupancy;
|
if (vehicle.length <= 0) sectionStatus.unclassified = sectionStatus.unclassified + 1;
|
sectionStatus.totalMeasurements = 1;
|
sectionStatus.correctMeasurements = 1;
|
}
|
|
// int lengthPosition = getClassificationPosition(((double)vehicle.length/100d), deviceclone.getDeviceInformation().lLengthClassification);
|
// sectionStatus.lengths[lengthPosition] = sectionStatus.lengths[lengthPosition] + 1;
|
// int speedPosition = getClassificationPosition(vehicle.speed, deviceclone.getDeviceInformation().lSpeedClassification);
|
// sectionStatus.speeds[speedPosition] = sectionStatus.speeds[speedPosition] + 1;
|
// sectionStatus.speedxlength[speedPosition][lengthPosition] = sectionStatus.speedxlength[speedPosition][lengthPosition] + 1;
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
}
|
|
|
private List<EtdStatusLane> getEtdStatusLane(Etd deviceclone, DPSVehicle vehicle, ConfigurationEtd configurationEtd)
|
{
|
List<EtdStatusLane> llanes = new ArrayList<EtdStatusLane>();
|
|
try
|
{
|
List<EtdConfigurationLaneDPS> list = configurationEtd.getLaneEtd(vehicle.device, vehicle.lane);
|
if ((list == null) || (list.size() == 0)) System.out.println(deviceclone.getIdentifier() + " - LANE NULL: " + vehicle.device + " - " + vehicle.lane);
|
for (EtdConfigurationLaneDPS lane : list)
|
{
|
for (EtdStatusLane laneStatus : deviceclone.getDeviceStatus().llane)
|
{
|
if (laneStatus.number == lane.lane) llanes.add(laneStatus);
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
return(llanes);
|
}
|
|
|
private List<EtdStatusLane> getEtdStatusSection(DPSVehicle vehicle, Etd deviceclone, ConfigurationEtd configurationEtd)
|
{
|
List<EtdStatusLane> lsections = new ArrayList<EtdStatusLane>();
|
|
try
|
{
|
List<EtdInformationSection> lsection = getEtdInformationSection(deviceclone, vehicle, configurationEtd);
|
for (EtdInformationSection section : lsection)
|
{
|
for (EtdStatusLane sectionStatus : deviceclone.getDeviceStatus().lsection)
|
{
|
if (section.number == sectionStatus.number) lsections.add(sectionStatus);
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
if ((lsections == null) || (lsections.size() == 0)) System.out.println(deviceclone.getIdentifier() + " - LANE_SECTION_STATUS NULL: " + vehicle.device + " - " + vehicle.lane);
|
return(lsections);
|
}
|
|
|
private List<EtdInformationSection> getEtdInformationSection(Etd deviceclone, DPSVehicle vehicle, ConfigurationEtd configurationEtd)
|
{
|
List<EtdInformationSection> lsections = new ArrayList<EtdInformationSection>();
|
|
try
|
{
|
List<EtdConfigurationLaneDPS> list = configurationEtd.getLaneEtd(vehicle.device, vehicle.lane);
|
if ((list == null) || (list.size() == 0)) System.out.println(deviceclone.getIdentifier() + " - LANE_SECTION NULL: " + vehicle.device + " - " + vehicle.lane);
|
for (EtdConfigurationLaneDPS lane : list)
|
{
|
for (EtdInformationSection sectionInformation : deviceclone.getDeviceInformation().lSection)
|
{
|
for (Integer number : sectionInformation.llane)
|
{
|
if (number == lane.lane) lsections.add(sectionInformation);
|
}
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
return(lsections);
|
}
|
|
}
|
