package art.servers.fleetserver.controller;

import art.library.model.devices.DeviceStatus;
import art.library.model.devices.vehicle.Vehicle;
import art.library.model.devices.vehicle.VehiclePosition;
import art.library.model.devices.vehicle.VehicleRealtime;
import art.servers.fleetserver.Shared;
import art.servers.fleetserver.configuration.ConfigurationRadio;
import art.servers.fleetserver.radio.sepura.CTSDSR;
import art.servers.fleetserver.radio.sepura.MOD_10_1147;
import art.servers.fleetserver.radio.sepura.MOD_10_1243;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;


public class ControllerRadioSepura extends art.servers.controller.Controller
{
    private ConfigurationRadio configurationRadio = null; 
    private Socket socket = null;
    private BufferedReader reader = null;
    private int status = DeviceStatus.STATUS_ALARM;
    private String name = "";
    

    public ControllerRadioSepura(ConfigurationRadio configurationRadio)
    {
        this.configurationRadio = configurationRadio;
        this.setName(this.getClass().getName() + " : " + configurationRadio.name);
        this.name = this.getName();
    }
    
    
    
    public void run()
    {
        Shared.traceInformation(configurationRadio.name, "Starting");

        while ((isInterrupted() == false) && (exit == false))
        {
            try
            {
                connect();
            }
            catch (Exception e)
            {
                disconnect();
            }
            
            
            try
            {
                String command = readLine();
                
                if (command.indexOf("+CTSDSR: ") == 0)
                {
                    analyseCTSDSR(command);
                }
            }
            catch (Exception e)
            {
                disconnect();
            }
        }
        
        Shared.traceInformation(configurationRadio.name, "Finishing");

        disconnect();
    }
    
    
    
    
    private void connect() 
    {
        try
        {
            if (socket != null)
            {
                if (socket.isConnected() == true)
                {
                    return;
                }
            }
            
            socket = new Socket(configurationRadio.address, configurationRadio.port);
            socket.setSoTimeout(configurationRadio.timeout);
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            if (status != DeviceStatus.STATUS_ONLINE)
            {
                String message = Shared.configuration.getMessage("Connected, address = %1, port = %2, timeout = %3");
                message = message.replace("%1", configurationRadio.address);
                message = message.replace("%2", "" +configurationRadio.port);
                message = message.replace("%3", "" + configurationRadio.timeout);
                Shared.println(configurationRadio.name, message);
                status = DeviceStatus.STATUS_ONLINE;
            }
            
        }
        catch (Exception e)
        {
            disconnect();
        }
    }
    
    
    

    private void disconnect() 
    {
        if (status == DeviceStatus.STATUS_ONLINE)
        {
            Shared.println(configurationRadio.name, Shared.configuration.getMessage("Disconnected"));
        }
        
        status = DeviceStatus.STATUS_ALARM;

        try
        {
            sleep(5000);
        }
        catch (Exception e)
        {
        }

        try { reader.close(); }catch (Exception e) {}
        try { socket.close(); }catch (Exception e) {}
        reader = null;
        socket = null;
    }
        

    
    
        
    private void analyseCTSDSR(String command)
    {
        try
        {
            CTSDSR ctsdsr = MOD_10_1243.CTSDSR(this, command.replace("+CTSDSR: ", ""), readLine());

            if ((ctsdsr.service == 108) || (ctsdsr.service == 12))
            {
                // 12  : SDS type 4
                // 108 : SDS type 4 (incoming message to MT copied to TE)
                
                if (ctsdsr.calledPartyIdentity.replace("21400080", "").equals(configurationRadio.SSI))
                {
                    int protocoloIdentifier = Integer.parseInt(ctsdsr.userData.substring(0, 2), 16);
                    
                    if (protocoloIdentifier == 0x03)
                    {
                        VehiclePosition vehiclePosition = MOD_10_1147.proprietaryFormatMinimalCompactFullLocationReport(ctsdsr.userData);
                        vehiclePosition.ISSI = ctsdsr.callingPartyIdentity.replace("21400080", "");
                        Vehicle vehicle = (Vehicle)Shared.model.getDevice(vehiclePosition.ISSI);
                        vehicle.realtime = new VehicleRealtime();
                        vehicle.realtime.identifier = vehicle.getIdentifier();
                        vehicle.getDeviceRealtime().position = vehiclePosition;
                        Shared.getModel().updateDevice(vehicle, vehiclePosition, null);
                    }
                    else
                    {
                        String message = Shared.configuration.getMessage("Protocol identifier %1 not valid");
                        message = message.replace("%1", String.format("%02X", protocoloIdentifier)) + ", " + ctsdsr.toString();
                        Shared.println(configurationRadio.name, message);
                        throw new Exception(message);
                    }
                }
                else
                {
                    String message = Shared.configuration.getMessage("ISSI not valid");
                    message = message + ", " + ctsdsr.toString();
                    Shared.println(configurationRadio.name, message);
                    throw new Exception(message);
                }

            }
            else
            {
                String message = Shared.configuration.getMessage("Service not implemented yet");
                message = message + ", " + ctsdsr.toString();
                Shared.println(configurationRadio.name, message);
                throw new Exception(message);
            }
        }
        catch (Exception e)
        {
            Shared.println(configurationRadio.name, e.getMessage());
        }
    }
    
    
    
    
    
    private String readLine() throws Exception
    {
        try
        {
            return reader.readLine().trim();
        }
        catch (Exception e)
        {
        }
        
        throw new Exception(Shared.configuration.getMessage("Timeout"));
    }    

    
    
    
    
    
/*
    +CTSDSR: 12,214000806013507,1,214000806010005,1,81
    038042A3B145701BD2840

    +CTSDSR: 12,214000806013504,1,214000806010005,1,81
    038042B3B186D01BD4B50

    +CTSDSR: 12,214000806013907,1,214000806010005,1,81
    038042B3B14BE01BB7D40

    +CTSDSR: 12,214000806013413,1,214000806010005,1,81
    03804373B11F401BD2440

    +CTSDSR: 12,214000806013510,1,214000806010005,1,81
    038043C3B187A01BD7750


    +CTSDSR: 12,214000806013508,1,214000806010006,1,81
    03804523B13A401BAE040

    +CDTXC: 658,0

    +CTXG: 658,3,0,0,1,214000806010002

    +CDTXC: 658,0

    +CTSDSR: 12,214000806014801,1,214000806010006,1,81
    038045B3B15D401BCCF30

    +CTSDSR: 12,214000806013343,1,214000806010006,1,81
    03804283B143701BD00D0

    +CTSDSR: 12,214000806013314,1,214000806010006,1,81
    038045C3B14C001BB7D40

    +CTXG: 658,3,0,0,1,214000806013414

    +CTSDSR: 12,214000806013312,1,214000806010006,1,81
    038045F3B14C901BB7D40

    +CTSDSR: 12,214000806013509,1,214000806010006,1,81
    03804613B13A001BAE350

    +CDTXC: 658,0

    +CTSDSR: 12,214000806013411,1,214000806010006,1,81
    03804643B121501BD3640

    +CTSDSR: 12,214000806013503,1,214000806010006,1,81
    03804633B13BC01BD5D50

    +CTXG: 658,3,0,0,1,214000806010002

    +CTSDSR: 12,214000806013801,1,214000806010006,1,81
    03804653B11B101BC4F40

    +CTSDSR: 12,214000806011105,1,214000806010006,1,81
    03804663B14B601BB9040    
    
    
*/    
    
}