package art.servers.colorsserver.controller;

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.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.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.List;


public class ControllerDynamicController extends ControllerController
{
    private SimpleDateFormat sdh = new SimpleDateFormat("HH:mm");
    private long lastTimestamp = 0;
    private int status = DeviceStatus.STATUS_ALARM;


    public ControllerDynamicController(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 ControllerDynamicController(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
    {
        long time = ((Configuration)Shared.configuration).detail.statusTime;
        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 queryStatusSlow = ((System.currentTimeMillis()-lastQueryStatus) >= (controller.getDeviceInformation().pollingStatus*time*1000L));
        boolean queryStatusFast = ((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) || (queryStatusSlow == true) || (queryTrafficData == true) || (queryTables == true) || (queryStatusFast == true))
        {
            controllerclone = cloneController();
        }

        try
        {
            controllerclone.getDeviceConfiguration().toAluvisa();
        }
        catch (Exception e)
        {
            
        }

        if ((queryDetectorsRealtime == true) || (queryGroupsRealtime == true) || (queryStatusSlow == true) || (queryTrafficData == true) || (queryTables == true) || (queryStatusFast == true))
        {
            if (forceCentralized == 0)
            {
                disable(controllerclone);
                return;
            }
        }

        try
        {
            if (commandsConfiguration != null)
            {
                // Save SPTP tables to controller
                sendSPTPConfigurationToController(controllerclone.getDeviceInformation().subcontroller, commandsConfiguration);
            }

            if (commandsDemands != null)
            {
                getBusDemandsControllerReal(controllerclone.getDeviceInformation().subcontroller);
            }

            if (queryTables == true)
            {
                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 (queryStatusSlow == true)
            {
                // time - 1 seg
                try
                {
                    long[] result = getCurrentTime(controllerclone);
                    if (getControllerConnection().address.equalsIgnoreCase("127.0.0.1") == false)
                    {
                        long currenttime = result[0];
                        int weekdayController = (int)result[1];

                        Calendar c1 = Calendar.getInstance();
                        Calendar c2 = Calendar.getInstance();
                        c1.setTimeInMillis(currenttime);
                        c2.setTimeInMillis(System.currentTimeMillis());
                        long dif = c2.getTimeInMillis()-c1.getTimeInMillis();
                        if (dif < 0) dif = -dif;

                        if (dif > ((Configuration)Shared.configuration).detail.maximumDifferenceTime)
                        {
                            M_Message request = M_ProtocolConstructor.setDateTime(0x00, System.currentTimeMillis()+1000, hasCRC);
                            getControllerConnection().send(request.toByteArray());

                            M_Message requestHTR = M_ProtocolConstructor.HTR();
                            getControllerConnection().send(requestHTR.toByteArray());
                        }
                    }
                }
                catch (Exception exception)
                {
                    Shared.printstack(this.name, exception);
                }

                // estado subregulador - 5 seg
                getCurrentSubcontrollersState(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 (queryStatusFast == true)
            {
                // 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);
                }

                lastQueryStatus = System.currentTimeMillis();
            }

            if (queryTrafficData == true)
            {
                if ((controllerclone.getDeviceConfiguration().lstrategicalDetector.size() > 0) &&
                    (controllerclone.getDeviceInformation().address.equalsIgnoreCase("127.0.0.1") == false))
                {
                    if (controllerclone.getIdentifier().indexOf("286") > -1)
                    {
                        Shared.println(name, "1.TrafficData");
                    }
                    // d - 1 min (Detectores contaje)
                    getCurrentCountingDetectors(controllerclone);
                }

                lastQueryTrafficData = System.currentTimeMillis();
            }

            checkNewUpdateCommands(controllerclone);

            if ((queryDetectorsRealtime == true) || (queryGroupsRealtime == true) || (queryStatusSlow == true) || (queryTrafficData == true) || (queryTables == true) || (queryStatusFast == true))
            {
                if (forceCentralized == 0)
                {
                    disable(controllerclone);
                }
                else
                {
                    online(controllerclone);
                }
            }

            checkUpdateStatus(controllerclone);
        }
        catch (Exception exception)
        {
            Shared.printstack(name, exception); 
            Shared.println(name, Device.getDate(System.currentTimeMillis()) + " - " + this.controller.getIdentifier() + " - EXCEPTION DYNAMIC: " + exception.toString());
            offline(controllerclone);
        }
    }

    // </editor-fold>  

}