package art.servers.colorsserver.controller;
|
|
import art.library.interop.serialization.SerializationException;
|
import art.library.model.devices.Device;
|
import art.servers.colorsserver.Shared;
|
import art.library.model.devices.DeviceStatus;
|
import art.library.model.devices.colors.controller.M.M_Controller;
|
import art.library.model.devices.colors.controller.M.M_ControllerStatus;
|
import art.library.model.devices.colors.controller.M.M_SubcontrollerConfiguration;
|
import art.servers.ColorsServer;
|
import art.servers.ServerException;
|
import art.servers.colorsserver.M.protocol.M_Message;
|
import art.servers.colorsserver.M.protocol.M_ProtocolConstructor;
|
import art.servers.colorsserver.configuration.Configuration;
|
import java.io.BufferedWriter;
|
import java.io.File;
|
import java.io.FileOutputStream;
|
import java.io.OutputStreamWriter;
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
import java.util.List;
|
|
|
|
public class ControllerRtacController extends ControllerController
|
{
|
private SimpleDateFormat sdh = new SimpleDateFormat("HH:mm");
|
private long lastTimestamp = 0;
|
private int status = DeviceStatus.STATUS_ALARM;
|
private BufferedWriter out = null;
|
|
|
|
public ControllerRtacController(M_Controller controller, boolean hasCRC)
|
{
|
super(controller, hasCRC);
|
this.name = Shared.getMessage("Controller junction ") + " " + controller.information.name + " - " + controller.information.number;
|
super.setName(this.name);
|
}
|
|
|
public ControllerRtacController(M_Controller controller, List<M_Controller> lcontroller, boolean hasCRC)
|
{
|
super(controller, lcontroller, hasCRC);
|
this.name = Shared.getMessage("Controller junction ") + " " + controller.information.name + " - " + controller.information.number;
|
super.setName(this.name);
|
}
|
|
|
// <editor-fold defaultstate="collapsed" desc="Update functions">
|
|
public void update() throws ServerException, Exception
|
{
|
if (ColorsServer.REQUEST_RTAC == false) return;
|
|
boolean queryDetectorsRealtime = (((System.currentTimeMillis()-lastQueryDetectorsRealtime) >= (controller.getDeviceInformation().pollingRealtime*1000L)) && (controller.getDeviceStatus().detectorsRealtime == M_ControllerStatus.YES));
|
boolean queryGroupsRealtime = (((System.currentTimeMillis()-lastQueryGroupsRealtime) >= (controller.getDeviceInformation().pollingRealtime*1000L)) && (controller.getDeviceStatus().groupsRealtime == M_ControllerStatus.YES));
|
boolean queryStatus = ((System.currentTimeMillis()-lastQueryStatus) >= (controller.getDeviceInformation().pollingStatus*1000L));
|
boolean queryTrafficData = (((System.currentTimeMillis()-lastQueryTrafficData) >= (controller.getDeviceInformation().pollingTrafficData*1000L))); // && (controller.getDeviceStatus().realTime == true));
|
boolean queryTables = ((System.currentTimeMillis()-lastQueryTables) >= (controller.getDeviceInformation().pollingTables*1000L));
|
|
M_Controller controllerclone = null;
|
if ((queryDetectorsRealtime == true) || (queryGroupsRealtime == true) || (queryStatus == true) || (queryTrafficData == true) || (queryTables == true))
|
{
|
controllerclone = cloneController();
|
}
|
|
try
|
{
|
controllerclone.getDeviceConfiguration().toAluvisa();
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
if ((queryDetectorsRealtime == true) || (queryGroupsRealtime == true) || (queryStatus == true) || (queryTrafficData == true) || (queryTables == true))
|
{
|
if (forceCentralized == 0)
|
{
|
disable(controllerclone);
|
return;
|
}
|
}
|
|
try
|
{
|
if (queryTables == true)
|
{
|
// TODO
|
// View how to query tables for RTAC controllers
|
// In Mataro we have problems when reading tables, that sometimes RTAC controllers lose tables configuration
|
// controllerclone.configuration = readAllTables();
|
// lastQueryTables = System.currentTimeMillis();
|
// recreateStatus(controllerclone);
|
}
|
|
if (queryDetectorsRealtime == true)
|
{
|
// b - 1 seg (Detectores presencia)
|
// getCurrentPresenceDetectors(controllerclone);
|
//
|
// lastQueryDetectorsRealtime = System.currentTimeMillis();
|
// controllerclone.getDeviceRealtime().timestamp = lastQueryDetectorsRealtime;
|
// controllerclone.getDeviceRealtime().lastTimestampUpdate = lastQueryDetectorsRealtime;
|
}
|
|
if (queryGroupsRealtime == true)
|
{
|
// k - 1 seg (Estado grupos)
|
getCurrentStatusGroups(controllerclone);
|
|
lastQueryGroupsRealtime = System.currentTimeMillis();
|
controllerclone.getDeviceRealtime().timestamp = lastQueryGroupsRealtime;
|
controllerclone.getDeviceRealtime().lastTimestampUpdate = lastQueryGroupsRealtime;
|
}
|
|
if (queryStatus == true)
|
{
|
// time - 1 seg
|
try
|
{
|
long[] result = getCurrentTime(controllerclone);
|
long currenttime = result[0];
|
int weekdayController = (int)result[1];
|
|
Calendar c1 = Calendar.getInstance();
|
Calendar c2 = Calendar.getInstance();
|
c1.setTimeInMillis(currenttime);
|
c2.setTimeInMillis(System.currentTimeMillis());
|
// int weekdayController = c1.get(Calendar.DAY_OF_WEEK);
|
int weekdayCurrent = c2.get(Calendar.DAY_OF_WEEK);
|
c1.set(Calendar.DATE, 1);
|
c1.set(Calendar.MONTH, 1);
|
c1.set(Calendar.YEAR, 2008);
|
c1.set(Calendar.MILLISECOND, 0);
|
c2.set(Calendar.DATE, 1);
|
c2.set(Calendar.MONTH, 1);
|
c2.set(Calendar.YEAR, 2008);
|
c2.set(Calendar.MILLISECOND, 0);
|
long dif = c2.getTimeInMillis()-c1.getTimeInMillis();
|
if (dif < 0) dif = -dif;
|
|
int current = 0;
|
if (weekdayCurrent == Calendar.MONDAY) current = 0;
|
if (weekdayCurrent == Calendar.TUESDAY) current = 1;
|
if (weekdayCurrent == Calendar.WEDNESDAY) current = 2;
|
if (weekdayCurrent == Calendar.THURSDAY) current = 3;
|
if (weekdayCurrent == Calendar.FRIDAY) current = 4;
|
if (weekdayCurrent == Calendar.SATURDAY) current = 5;
|
if (weekdayCurrent == Calendar.SUNDAY) current = 6;
|
|
if ((dif > ((Configuration)Shared.configuration).detail.maximumDifferenceTime) || (weekdayController != current))
|
{
|
writeLog("\t" + controllerclone.getIdentifier() + " - 1.DIFTIME: " + dif + " - " + weekdayController + " - " + current + " - Controller: " + Device.getDate(c1.getTimeInMillis()) + " - Server: " + Device.getDate(c2.getTimeInMillis()));
|
|
int currentWeekday = 0;
|
Calendar c3 = Calendar.getInstance();
|
c3.setTimeInMillis(System.currentTimeMillis());
|
int weekday = c3.get(Calendar.DAY_OF_WEEK); // c1.get(Calendar.DAY_OF_WEEK);
|
if (weekday == Calendar.MONDAY) currentWeekday = 0;
|
if (weekday == Calendar.TUESDAY) currentWeekday = 1;
|
if (weekday == Calendar.WEDNESDAY) currentWeekday = 2;
|
if (weekday == Calendar.THURSDAY) currentWeekday = 3;
|
if (weekday == Calendar.FRIDAY) currentWeekday = 4;
|
if (weekday == Calendar.SATURDAY) currentWeekday = 5;
|
if (weekday == Calendar.SUNDAY) currentWeekday = 6;
|
writeLog("\t" + controllerclone.getIdentifier() + " - 3.DIFTIME: " + dif + " - CurrentWeekday: " + currentWeekday);
|
setTime(currentWeekday);
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
|
// estado subregulador - 5 seg
|
getCurrentSubcontrollersState(controllerclone);
|
|
// a - 1 seg (Plan en curso)
|
getCurrentPlan(controllerclone);
|
|
long current = System.currentTimeMillis();
|
controllerclone.getDeviceRealtime().timestamp = current;
|
controllerclone.getDeviceRealtime().lastTimestampUpdate = current;
|
|
// f - 5 seg (Alarmas)
|
int result = getAlarms(controllerclone);
|
|
if ((result & 0x01) != 0)
|
{
|
// g - 5 seg (Lampara fundida si activa en alarmas)
|
getBlownLampAlarms(controllerclone);
|
}
|
else
|
{
|
clearBlownLampsGroupAlarms(controllerclone);
|
}
|
|
if ((result & 0x02) != 0)
|
{
|
// h - 5 seg (Grupo averiado si activa en alarmas)
|
getDamagedGroupAlarms(controllerclone);
|
}
|
else
|
{
|
clearDamagedGroupAlarms(controllerclone);
|
}
|
|
if ((result & 0x04) != 0)
|
{
|
// i - 5 seg (Incompatibilidades si activa en alarmas)
|
getIncompatibilityAlarms(controllerclone);
|
}
|
else
|
{
|
clearIncompatibilityGroupAlarms(controllerclone);
|
}
|
|
for (M_SubcontrollerConfiguration subcontrollerConfiguration : controllerclone.getDeviceConfiguration().lsubcontroller)
|
{
|
try
|
{
|
controllerclone.getDeviceStatus().getStatusSubcontroller(subcontrollerConfiguration.number).recordablePlan = getCurrentRecordablePlan(subcontrollerConfiguration.number);
|
}
|
catch (Exception e)
|
{
|
controllerclone.getDeviceStatus().getStatusSubcontroller(subcontrollerConfiguration.number).recordablePlan = null;
|
}
|
}
|
|
lastQueryStatus = System.currentTimeMillis();
|
}
|
|
if (queryTrafficData == true)
|
{
|
// long query = System.currentTimeMillis();
|
// if (controllerclone.getDeviceConfiguration().lstrategicalDetector.size() > 0)
|
// {
|
// // d - 1 min (Detectores contaje)
|
// getCurrentCountingDetectors(controllerclone);
|
// }
|
|
// lastQueryTrafficData = System.currentTimeMillis();
|
}
|
|
checkNewUpdateCommands(controllerclone);
|
|
if ((queryDetectorsRealtime == true) || (queryGroupsRealtime == true) || (queryStatus == true) || (queryTrafficData == true) || (queryTables == true))
|
{
|
if (forceCentralized == 0)
|
{
|
disable(controllerclone);
|
}
|
else
|
{
|
online(controllerclone);
|
}
|
}
|
|
checkUpdateStatus(controllerclone);
|
}
|
catch (Exception exception)
|
{
|
if ((controllerclone.alarms.alarm_offline <= 0) || (firstTime == true))
|
{
|
Shared.println(name, this.controller.getIdentifier() + " - EXCEPTION RTAC OFFLINE: " + exception.toString());
|
Shared.printstack(name, exception);
|
}
|
|
offline(controllerclone);
|
}
|
}
|
|
|
public void setTime(int weekday) throws SerializationException
|
{
|
try
|
{
|
M_Message request = M_ProtocolConstructor.setDateTimeRTAC(this, 0x00, System.currentTimeMillis()+1000, weekday, hasCRC);
|
getControllerConnection().send(request.toByteArray());
|
|
M_Message requestHTR = M_ProtocolConstructor.HTR();
|
getControllerConnection().send(requestHTR.toByteArray());
|
}
|
catch (Exception exception)
|
{
|
Shared.printstack(name, exception);
|
}
|
}
|
|
// </editor-fold>
|
|
|
private void createLog ()
|
{
|
try
|
{
|
if (ColorsServer.LOG_TIME == true)
|
{
|
File fdir = new File("Logs/" + this.controller.getIdentifier());
|
fdir.mkdirs();
|
out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(fdir.getAbsolutePath() + "/" + System.currentTimeMillis() + ".log")));
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
}
|
|
|
public void writeLog (String message)
|
{
|
try
|
{
|
if (ColorsServer.LOG_TIME == true)
|
{
|
if (out == null)
|
{
|
createLog();
|
}
|
|
String s = Device.getDate(System.currentTimeMillis()) + " - " + message;
|
out.write(s);
|
out.newLine();
|
out.flush();
|
}
|
}
|
catch (Exception e)
|
{
|
|
}
|
}
|
|
}
|
