package art.servers.sosserver.controller.musatel;

import art.library.interop.serialization.Serialization;
import art.library.model.devices.sos.Sos;
import art.library.model.devices.sos.musatel.status.SosStatusMusatel;
import art.library.model.devices.sos.musatel.status.SosStatusMusatelAudio;
import art.library.utils.synchro.Mutex;
import art.servers.Shared;
import java.io.InputStream;




public class ControllerSos_MusatelReceiver
{
    private ControllerSos_Musatel controller = null;
    private String name = null;
    private Mutex mutex = new Mutex();

    
    public ControllerSos_MusatelReceiver(ControllerSos_Musatel controller)
    {
        this.controller = controller;
        this.name = controller.getName();
    }
    
    

    /**
     * Una vez reciba el poste ACK_DEM_USE, actuará el sintetizador con el mensaje de espera en cuatro idiomas<br>
     * Acabado el mensaje, actuará el tono de llamada durante un máximo de 2 minutos<br>
     * Si el poste no recibe en 5 segundos el ACK_DEM_USE enviará la demanda 3 veces, en tiempos de 5
     * segundos. Si ninguno de los intentos fuera positivo pasará a estar en estado de "Fuera de Servicio" y
     * activará el sintetizador de voz con el mensaje oportuno durante 1 minuto<br>
     * El poste pasa a fonía y el sintetizador se desactiva. Para mantener la fonía activa el centro de control
     * debe enviar ORD_FON_ON periódicamente al poste en un intervalo inferior a dos minutos
     * En caso contrario el poste pasará automáticamente a reposo<br>
     * Se corta la fonía en el poste.El poste pasa a reposo.
     * 
     * Poste                Central
     * ------------------------------------
     * DEM_USE      ---->      
     *              <----   ACK_DEM_USE
     *              <----   ORD_FON_ON 
     * ACK_FON_ON   ---->
     *              <----   ORD_FON_ON 
     * ACK_FON_ON   ---->
     *              <----   ORD_FON_ON 
     * ACK_FON_ON   ---->
     *              <----   ORD_FON_OFF
     * ACK_FON_OFF  ---->
     */

    protected void DEM_USE(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            String message = "< DEM_USE, type = " + String.format("%02X", type);
            Shared.println(name, message);

            controller.sender.ACK_DEM_USE();
            clone.getDeviceStatus().musatel.state = SosStatusMusatel.STATE_PENDING_USER_CALL;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }




    /**
     * Una vez reciba el poste ACK_DEM_SER, actuará el sintetizador con el mensaje de espera en cuatro  idiomas<br> 
     * Acabado el mensaje, actuará el tono de llamada durante un máximo de 2 minutos<br>
     * Si el poste no recibe en 5 segundos el ACK_DEM_SER enviará la demanda 3 veces, en tiempos de 5
     * segundos. Si ninguno de los intentos fuera positivo pasará a estar en estado de "Fuera de Servicio" y
     * activará el sintetizador de voz con el mensaje oportuno durante 1 minuto<br>
     * El poste pasa a fonía y el sintetizador se desactiva.Para mantener la fonía activa el centro de control
     * debe enviar ORD_FON_ON periódicamente al poste en un intervalo inferior a dos minutos<br> 
     * En caso contrario el poste pasará automáticamente a reposo<br>
     * Se corta la fonía en el poste.El poste pasa a reposo
     * 
     * Poste                Central
     * ------------------------------------
     * DEM_SER      ---->      
     *              <----   ACK_DEM_SER
     *              <----   ORD_FON_ON 
     * ACK_FON_ON   ---->
     *              <----   ORD_FON_ON 
     * ACK_FON_ON   ---->
     *              <----   ORD_FON_ON 
     * ACK_FON_ON   ---->
     *              <----   ORD_FON_OFF
     * ACK_FON_OFF  ---->
     */

    protected void DEM_SER(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            String message = "< DEM_SER, type = " + String.format("%02X", type);
            Shared.println(name, message);

            controller.sender.ACK_DEM_SER();
            clone.getDeviceStatus().musatel.state = SosStatusMusatel.STATE_PENDING_SERVICE_CALL;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }



    /**
     *El poste envía solamente una vez cada alarma para evitar el envío repetitivo de alarmas<br> 
     * El test demantenimiento al poste refresca el estado de las alarmas. El proceso es el siguiente:<br>
     * El poste enviará SOLAMENTE UNA VEZ la alarma (Puerta abierta, batería baja)<br>
     * - Cuando el operador haga un test de mantenimiento al poste emisor de la alarma, se
     * refrescará (reseteará) indicando en la respuesta el estado de la alarma en dicho momento<br>
     * - Suponiendo que una alarma, en el momento del test, se hubiera corregido
     * momentáneamente, en el resultado del test se reflejará como alarma OK, anulándose
     * automáticamente de la ventana de alarmas pendientes<br>
     * - Si después del test se volviese a producir de nuevo la misma alarma anterior, el poste volverá
     * a enviar de nuevo SOLAMENTE UNA VEZ dicha alarma reflejándose otra vez en la ventana
     * de alarmas pendientes<br> 
     */
    protected void ENV_ALA(int stateMaster, int stateSlave) throws Exception
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            String message = "< ENV_ALA, primary state = " + String.format("%02X", stateMaster) + ", secondary state = " + String.format("%02X", stateSlave);
            Shared.println(name, message);
            controller.sender.ACK_ENV_ALA();
            alarms(clone, stateMaster);
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }



    protected void ACK_FON_ON(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            Shared.println(name, "< ACK_FON_ON");
            clone.getDeviceStatus().musatel.state = SosStatusMusatel.STATE_ACTIVE_CALL;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }            

    

    protected void ACK_FON_OFF(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            Shared.println(name, "< ACK_FON_OFF");
            clone.getDeviceStatus().musatel.currentConnection = null;
            clone.getDeviceStatus().musatel.state = SosStatusMusatel.STATE_IDLE;
            controller.setSosPriority(-1);
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }            


    
    protected void ACK_TON_ON(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            Shared.println(name, "< ACK_TON_ON");

            if (clone.getDeviceStatus().musatel.audio == null) clone.getDeviceStatus().musatel.audio = new SosStatusMusatelAudio();
            clone.getDeviceStatus().musatel.audio.tone = SosStatusMusatelAudio.STATE_ON;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }



    
    
    protected void ACK_TON_OFF(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            Shared.println(name, "< ACK_TON_OFF");

            if (clone.getDeviceStatus().musatel.audio == null) clone.getDeviceStatus().musatel.audio = new SosStatusMusatelAudio();
            clone.getDeviceStatus().musatel.audio.tone = SosStatusMusatelAudio.STATE_OFF;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }
    

    

    protected void RES_TST_FON(int type, int result) 
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            Shared.println(name, "< RES_TST_FON");
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }



    protected void RES_TST_MAN(InputStream input) throws Exception
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            Shared.println(name, "< RES_TST_MAN");

            if (clone.getDeviceStatus().musatel.audio == null) clone.getDeviceStatus().musatel.audio = new SosStatusMusatelAudio();

            /**
             * Bit 7 Batería baja
             * Bit 6 Puerta Abierta
             * Bit 5 No usado
             * Bit 4 No usado
             * Bit 3 Fonía ON
             * Bit 2 Tono ON
             * Bit 1 Pulsador bloqueado
             * Bit 0 -
             */
            int stateMaster = input.read();
            int stateSlave = input.read();
            int attenuatorMaters = input.read(); // Not used
            int attenuatorSlave = input.read(); // Not used
            int volumeMaster = input.read();
            int volumeSlave = input.read();

            alarms(clone, stateMaster);
            clone.getDeviceStatus().musatel.audio.volume = (int)(((double)volumeMaster/7.0) * 100);

            // Update
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }            




    

    protected void ACK_VOZ_ON(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            if (clone.getDeviceStatus().musatel.audio == null) clone.getDeviceStatus().musatel.audio = new SosStatusMusatelAudio();
            Shared.println(name, "< ACK_VOZ_ON");
            clone.getDeviceStatus().musatel.audio.audio = SosStatusMusatelAudio.STATE_ON;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }




    protected void ACK_VOZ_OFF(int type)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            if (clone.getDeviceStatus().musatel.audio == null) clone.getDeviceStatus().musatel.audio = new SosStatusMusatelAudio();
            Shared.println(name, "< ACK_VOZ_OFF");
            clone.getDeviceStatus().musatel.audio.audio = SosStatusMusatelAudio.STATE_OFF;
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }


    
    protected void ACK_ADJ_VOL(int type, int volume)
    {
        mutex.lockWrite();
        
        try
        {
            Sos clone = (Sos)Serialization.clone(controller.getDevice());
            if (clone.getDeviceStatus().musatel.audio == null) clone.getDeviceStatus().musatel.audio = new SosStatusMusatelAudio();
            Shared.println(name, "< ACK_ADJ_VOL");
            clone.getDeviceStatus().musatel.audio.volume = (int)(((double)volume/7.0) * 100.0);
            controller.online(clone);
        }
        catch (Exception e)
        {
            Shared.printstack(name, e);
        }
        finally
        {
            mutex.releaseWrite();
        }
    }            



    protected void NACK(int reason)
    {
        // Causa: indica la razón por la cual se rechaza la orden. 
        // En este caso tiene el valor OTRO_CC_ASIGNADO (bit 4 a 1, siendo el bit 0 el de menor peso).
        
        Shared.println(name, "< NACK");
    }            

    

    protected void UNKNOWN(int code)
    {
        Shared.println(name, "< UNKNOWN FUNCTION CODE (0x" + String.format("%02X", code) + ")");
    }            




    
    
    private void alarms(Sos sos, int state)
    {

        /**
         * Bit 7 Batería baja
         * Bit 6 Puerta Abierta
         * Bit 5 No usado
         * Bit 4 No usado
         * Bit 3 Fonía ON
         * Bit 2 Tono ON
         * Bit 1 Pulsador bloqueado
         * Bit 0 -
         */

        sos.setAlarm("alarm_call_button_locked", (state & 0x02) > 0);

        if ((state & 0x04) > 0)
        {
            sos.getDeviceStatus().musatel.audio.tone = SosStatusMusatelAudio.STATE_ON;
        }
        else
        {
            sos.getDeviceStatus().musatel.audio.tone = SosStatusMusatelAudio.STATE_OFF;
        }


        if ((state & 0x08) > 0)
        {
            sos.getDeviceStatus().musatel.audio.audio = SosStatusMusatelAudio.STATE_ON;
        }
        else
        {
            sos.getDeviceStatus().musatel.audio.audio = SosStatusMusatelAudio.STATE_OFF;
        }

        sos.setAlarm("alarm_open_door", (state & 0x40) > 0);
        sos.setAlarm("alarm_batteries_low", (state & 0x80) > 0);
    }

    
}