package art.servers.etdserver.controller;
|
|
|
import art.library.interop.serialization.Serialization;
|
import art.library.model.devices.Device;
|
import art.library.model.devices.DeviceStatus;
|
import art.library.model.devices.etd.Etd;
|
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.devices.etd.status.EtdStatusVehicle;
|
import art.library.model.transactions.traces.Trace;
|
import art.library.utils.common.TimeUtils;
|
import art.servers.etdserver.Shared;
|
import static java.lang.Thread.sleep;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
|
public class ControllerDataIntegration extends art.servers.controller.Controller
|
{
|
private int status = DeviceStatus.STATUS_ALARM;
|
private boolean firstTime = true;
|
protected ControllerEtd controller = null;
|
protected String name = null;
|
private long lastPeriodQuery = 0;
|
|
|
public ControllerDataIntegration(ControllerEtd controller)
|
{
|
this.controller = controller;
|
this.name = "Controller Data integration: " + controller.device.getIdentifier();
|
this.setName(this.name);
|
}
|
|
|
public void run ()
|
{
|
boolean firstTime = true;
|
// <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))
|
{
|
try
|
{
|
if (art.servers.Shared.isServerEnabled() == true)
|
{
|
if (firstTime == false)
|
{
|
integratePeriod();
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTimeInMillis(System.currentTimeMillis());
|
while ((calendar.get(Calendar.SECOND) != 0) && (exit == false))
|
{
|
try
|
{
|
sleep(50);
|
}
|
catch (Exception e)
|
{
|
}
|
}
|
|
firstTime = false;
|
if (art.servers.Shared.model.existsDevice(controller.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 void integratePeriod ()
|
{
|
Etd deviceclone = Serialization.clone(controller.device);
|
|
try
|
{
|
sleep(15000);
|
|
if (controller instanceof ControllerDiamondRaw)
|
{
|
if (((ControllerDiamondRaw)controller).isConnected() == false)
|
{
|
offline(deviceclone);
|
return;
|
}
|
}
|
|
int period = controller.device.getDeviceInformation().period;
|
long tsPeriod = TimeUtils.thisperiod(controller.device.getDeviceInformation().period) - (controller.device.getDeviceInformation().period*1000L);
|
long tsPeriodEnd = tsPeriod + (controller.device.getDeviceInformation().period*1000L);
|
List<EtdStatusVehicle> lvehicle = controller.getVehiclesPeriod(tsPeriod, tsPeriodEnd);
|
|
System.out.println(deviceclone.getIdentifier() + " - 1.DataIntegration: " + Device.getDate(tsPeriod) + " to " + Device.getDate(tsPeriodEnd) + " - Vehicles: " + lvehicle.size());
|
System.out.println(deviceclone.getIdentifier() + " - 2.DataIntegration: " + Device.getDate(deviceclone.getDeviceStatus().measurementTimestamp));
|
|
initialiseStatus(deviceclone, tsPeriod);
|
System.out.println(deviceclone.getIdentifier() + " - 3.DataIntegration: " + Device.getDate(deviceclone.getDeviceStatus().measurementTimestamp));
|
|
for (EtdStatusVehicle vehicle : lvehicle)
|
{
|
try
|
{
|
addVehicleLane(vehicle, deviceclone);
|
addVehicleLaneTotal(vehicle, deviceclone);
|
addVehicleLaneSection(vehicle, deviceclone);
|
}
|
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 (controller.device.getDeviceInformation().period > 0)
|
{
|
laneStatus.occupancy = (float)((laneStatus.occupancy * 100f) / (float)(controller.device.getDeviceInformation().period*1000));
|
int occupancy = (int)(laneStatus.occupancy*10);
|
laneStatus.occupancy = (float)((float)occupancy / 10f);
|
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 (controller.device.getDeviceInformation().period > 0)
|
{
|
sectionStatus.occupancy = (float)((sectionStatus.occupancy * 100f) / (float)(controller.device.getDeviceInformation().period*1000));
|
int occupancy = (int)(sectionStatus.occupancy*10);
|
sectionStatus.occupancy = (float)((float)occupancy / 10f);
|
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 (controller.device.getDeviceInformation().period > 0)
|
{
|
deviceclone.getDeviceStatus().total.occupancy = (float)((deviceclone.getDeviceStatus().total.occupancy * 100f) / (float)(controller.device.getDeviceInformation().period*1000));
|
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);
|
System.out.println(deviceclone.getIdentifier() + " - 4.DataIntegration: " + Device.getDate(deviceclone.getDeviceStatus().measurementTimestamp) + " - " + deviceclone.getDeviceStatus().llane.size() + " - " + deviceclone.getDeviceStatus().lsection.size() + " - " + deviceclone.getDeviceStatus().period + " - " + deviceclone.getDeviceStatus().total);
|
online(deviceclone);
|
}
|
catch (Exception exception)
|
{
|
try{offline(deviceclone);} catch (Exception e){};
|
exception.printStackTrace();
|
}
|
}
|
|
|
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;
|
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;
|
deviceclone.getDeviceStatus().lsection.add(sectionStatus);
|
}
|
|
deviceclone.getDeviceStatus().total = new EtdStatusLane();
|
}
|
|
if (deviceclone.getDeviceStatus().total == null)
|
{
|
deviceclone.getDeviceStatus().total = new EtdStatusLane();
|
}
|
|
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.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.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 EtdStatusLane getEtdStatusLane(Etd deviceclone, int lane)
|
{
|
try
|
{
|
for (EtdStatusLane laneStatus : deviceclone.getDeviceStatus().llane)
|
{
|
if (laneStatus.number == lane) return(laneStatus);
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
return(null);
|
}
|
|
|
private EtdStatusLane getEtdStatusSection(EtdStatusVehicle vehicle, Etd deviceclone)
|
{
|
try
|
{
|
EtdInformationSection section = getEtdInformationSection(deviceclone, vehicle.lane);
|
for (EtdStatusLane sectionStatus : deviceclone.getDeviceStatus().lsection)
|
{
|
if (section.number == sectionStatus.number) return(sectionStatus);
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
return(null);
|
}
|
|
|
private EtdInformationSection getEtdInformationSection(Etd deviceclone, int lane)
|
{
|
try
|
{
|
for (EtdInformationSection sectionInformation : deviceclone.getDeviceInformation().lSection)
|
{
|
for (Integer number : sectionInformation.llane)
|
{
|
if (number == lane) return(sectionInformation);
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
return(null);
|
}
|
|
|
private void addVehicleLane(EtdStatusVehicle vehicle, Etd deviceclone)
|
{
|
try
|
{
|
EtdStatusLane laneStatus = getEtdStatusLane(deviceclone, vehicle.lane);
|
|
if (laneStatus == null) return;
|
|
if (vehicle.speed > 0) laneStatus.occupancy += ((((double)vehicle.length/10.0)/((double)vehicle.speed/3.6)) * 1000.0);
|
|
laneStatus.counting = laneStatus.counting + 1;
|
laneStatus.speed = laneStatus.speed + vehicle.speed;
|
laneStatus.length = laneStatus.length + ((double)vehicle.length/100d);
|
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)
|
{
|
if (controller.device.getIdentifier().equalsIgnoreCase("etdtc-rzeszów-2") == true)
|
{
|
e.printStackTrace();
|
Shared.println("Data Integration", e);
|
}
|
}
|
}
|
|
|
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(EtdStatusVehicle vehicle, Etd deviceclone)
|
{
|
try
|
{
|
if (vehicle.speed > 0) deviceclone.getDeviceStatus().total.occupancy += ((((double)vehicle.length/10.0)/((double)vehicle.speed/3.6)) * 1000.0);
|
|
deviceclone.getDeviceStatus().total.counting = deviceclone.getDeviceStatus().total.counting + 1;
|
deviceclone.getDeviceStatus().total.speed = deviceclone.getDeviceStatus().total.speed + vehicle.speed;
|
deviceclone.getDeviceStatus().total.length = deviceclone.getDeviceStatus().total.length + ((double)vehicle.length/100d);
|
if (vehicle.length <= 0) deviceclone.getDeviceStatus().total.unclassified = deviceclone.getDeviceStatus().total.unclassified + 1;
|
deviceclone.getDeviceStatus().total.totalMeasurements = 1;
|
deviceclone.getDeviceStatus().total.correctMeasurements = 1;
|
|
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)
|
{
|
if (controller.device.getIdentifier().equalsIgnoreCase("etdtc-rzeszów-2") == true)
|
{
|
e.printStackTrace();
|
Shared.println("Data Integration", e);
|
}
|
}
|
}
|
|
|
private void addVehicleLaneSection(EtdStatusVehicle vehicle, Etd deviceclone)
|
{
|
try
|
{
|
EtdStatusLane sectionStatus = getEtdStatusSection(vehicle, deviceclone);
|
|
if (sectionStatus == null) return;
|
|
if (vehicle.speed > 0) sectionStatus.occupancy += ((((double)vehicle.length/10.0)/((double)vehicle.speed/3.6)) * 1000.0);
|
|
sectionStatus.counting = sectionStatus.counting + 1;
|
sectionStatus.speed = sectionStatus.speed + vehicle.speed;
|
sectionStatus.length = sectionStatus.length + ((double)vehicle.length/100d);
|
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)
|
{
|
if (controller.device.getIdentifier().equalsIgnoreCase("etdtc-rzeszów-2") == true)
|
{
|
e.printStackTrace();
|
Shared.println("Data Integration", e);
|
}
|
|
}
|
}
|
|
|
|
|
private void offline(Etd deviceclone)throws Exception
|
{
|
if (deviceclone.getAlarm("alarm_offline") <= 0)
|
{
|
deviceclone.getDeviceAlarms().clear();
|
}
|
deviceclone.setAlarm("alarm_offline", true);
|
boolean modified = Shared.model.updateDevice(controller.device, deviceclone);
|
System.out.println(deviceclone.getIdentifier() + " - OFFLINE.DataIntegration: DIF: " + modified);
|
}
|
|
|
private void online(Etd deviceclone) throws Exception
|
{
|
if ((deviceclone.alarms.alarm_offline > 0) || (firstTime == true))
|
{
|
firstTime = false;
|
String message = art.servers.Shared.getMessage("Etd online");
|
art.servers.Shared.println(name, message);
|
}
|
|
deviceclone.setAlarm("alarm_offline", false);
|
deviceclone.setAlarm("alarm_invalid", false);
|
boolean modified = Shared.model.updateDevice(controller.device, deviceclone);
|
System.out.println(deviceclone.getIdentifier() + " - ONLINE.DataIntegration: " + Device.getDate(controller.device.getDeviceStatus().measurementTimestamp) + " - " + controller.device.getDeviceStatus().llane.size() + " - " + controller.device.getDeviceStatus().lsection.size() + " - " + controller.device.getDeviceStatus().period + " - " + controller.device.getDeviceStatus().total + " - DIF: " + modified);
|
}
|
|
}
|
/*
|
|
|
|
|
private void integratePeriod ()
|
{
|
Etd deviceclone = Serialization.clone(controller.device);
|
|
try
|
{
|
sleep(1000);
|
List<EtdStatusVehicle> lvehicle = controller.getVehiclesPeriod(lastPeriodQuery, System.currentTimeMillis());
|
|
if (lvehicle.size() > 0)
|
{
|
EtdStatusVehicle vehicle0 = lvehicle.get(0);
|
int period = controller.device.getDeviceInformation().period;
|
long tsperiod = TimeUtils.thisperiod(period, vehicle0.timestamp);
|
long tsPeriodEnd = tsperiod + (period*1000L);
|
|
initialiseStatus(deviceclone, tsperiod);
|
|
boolean end = false;
|
long maxTimestamp = vehicle0.timestamp;
|
for (int i=0; (end==false) && (i<lvehicle.size()); i++)
|
{
|
try
|
{
|
EtdStatusVehicle vehicle = lvehicle.get(i);
|
|
if (vehicle.timestamp < tsPeriodEnd)
|
{
|
addVehicleLane(vehicle, deviceclone);
|
addVehicleLaneTotal(vehicle, deviceclone);
|
addVehicleLaneSection(vehicle, deviceclone);
|
}
|
else
|
{
|
maxTimestamp = vehicle.timestamp;
|
end = true;
|
}
|
}
|
catch (Exception e)
|
{
|
if (controller.device.getIdentifier().equalsIgnoreCase("etdtc-rzeszów-2") == true)
|
{
|
e.printStackTrace();
|
String message = "EX1.";
|
Shared.println("Data Integration", message, e);
|
}
|
}
|
}
|
|
if (maxTimestamp == vehicle0.timestamp)
|
{
|
// Wait until period will be really closed
|
return;
|
}
|
|
lastPeriodQuery = maxTimestamp;
|
|
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 (controller.device.getDeviceInformation().period > 0)
|
{
|
laneStatus.occupancy = (float)((laneStatus.occupancy * 100f) / (float)(controller.device.getDeviceInformation().period*1000));
|
int occupancy = (int)(laneStatus.occupancy*10);
|
laneStatus.occupancy = (float)((float)occupancy / 10f);
|
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 (controller.device.getDeviceInformation().period > 0)
|
{
|
sectionStatus.occupancy = (float)((sectionStatus.occupancy * 100f) / (float)(controller.device.getDeviceInformation().period*1000));
|
int occupancy = (int)(sectionStatus.occupancy*10);
|
sectionStatus.occupancy = (float)((float)occupancy / 10f);
|
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 (controller.device.getDeviceInformation().period > 0)
|
{
|
deviceclone.getDeviceStatus().total.occupancy = (float)((deviceclone.getDeviceStatus().total.occupancy * 100f) / (float)(controller.device.getDeviceInformation().period*1000));
|
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);
|
online(deviceclone);
|
|
long nextTsPeriod = TimeUtils.thisperiod(period, maxTimestamp);
|
long tsperiodEmpty = tsperiod + (period * 1000L);
|
|
while (tsperiodEmpty < nextTsPeriod)
|
{
|
try
|
{
|
Etd deviceclone2 = Serialization.clone(controller.device);
|
initialiseStatus(deviceclone2, tsperiodEmpty);
|
deviceclone2.setLastTimestampStatusUpdate(deviceclone2.getDeviceStatus().measurementTimestamp);
|
online(deviceclone2);
|
}
|
catch (Exception e)
|
{
|
if (controller.device.getIdentifier().equalsIgnoreCase("etdtc-rzeszów-2") == true)
|
{
|
String message = controller.device.getIdentifier() + " - EX.5.IntegratePeriod: " + period + " - " + Device.getDate(nextTsPeriod) + " - " + Device.getDate(tsperiodEmpty);
|
Shared.println("Data Integration", message, e);
|
}
|
}
|
|
tsperiodEmpty = tsperiodEmpty + (period * 1000L);
|
}
|
}
|
}
|
catch (Exception exception)
|
{
|
try{offline(deviceclone);} catch (Exception e){};
|
exception.printStackTrace();
|
}
|
}
|
|
*/
|
