package com.safemobile.dispatch;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Collections;
import java.util.Comparator;
import java.util.Locale;
import java.util.Timer;
import java.util.TimerTask;

import com.safemobile.activities.AbstractEmptyActivity;
import com.safemobile.activities.AbstractLiveActivity;
import com.safemobile.activities.AbstractMessagesActivity;
import com.safemobile.activities.AbstractRadioActivity;
import com.safemobile.activities.AbstractSDParentActivity;
import com.safemobile.interfaces.ITCPListener;
import com.safemobile.interfaces.TCPEvent;
import com.safemobile.lib.Alarm;
import com.safemobile.lib.AlarmMSG;
import com.safemobile.lib.AppParams;
import com.safemobile.lib.GPSmsg;
import com.safemobile.lib.HistCountmsg;
import com.safemobile.lib.HistPos;
import com.safemobile.lib.HistPosmsg;
import com.safemobile.lib.OperationCodes;
import com.safemobile.lib.RadioMSG;
import com.safemobile.lib.LastPos;
import com.safemobile.lib.LastPosmsg;
import com.safemobile.lib.RecordMSG;
import com.safemobile.lib.Recording;
import com.safemobile.lib.SM;
import com.safemobile.lib.SMS;
import com.safemobile.lib.SMSmsg;
import com.safemobile.lib.SerializedObject;
import com.safemobile.lib.SuperVehicle;
import com.safemobile.lib.TCPmsg;
import com.safemobile.lib.VehMSG;
import com.safemobile.lib.Vehicle;
import com.safemobile.lib.radio.RadioGW;
import com.safemobile.services.TCPService;
import com.safemobile.services.TCPhandler;
import com.safemobile.services.TCPService.TCPBinder;

import android.app.Dialog;
import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.BroadcastReceiver;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.ServiceConnection;
import android.content.res.AssetManager;
import android.content.res.Configuration;
import android.content.res.Resources;
import android.net.Uri;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.util.Log;
import android.view.MotionEvent;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.View.OnTouchListener;
import android.view.WindowManager;
import android.view.animation.Animation;
import android.view.animation.AnimationUtils;
import android.widget.ImageButton;
import android.widget.ImageView;
import android.widget.LinearLayout;
import android.widget.RelativeLayout;
import android.widget.TabHost;
import android.widget.TabWidget;
import android.widget.TextView;
import android.widget.Toast;
import android.widget.TabHost.TabSpec;

public class TabLayoutActivity extends AbstractSDParentActivity{
	
	/* Misc */
	private Resources res;
	private Context context;
	
	public RadioGW crtRadio = null;
	public int crtActivity = 0, RADIO = 4; 
	private Boolean isMenuVisible = true, firstGetVehs = true, lastTCPstatus = false;
	private Boolean NOSOUND = false;
	public Boolean inCall = false;
	
	//public boolean DEMO;			// value received through intent.getExtra()
	
	
	/* Activities */
	public AbstractLiveActivity liveActivity = null;
	public RadioActivity radioActivity = null;
	public MessagesActivity messageActivity = null;
	public HistoryActivity historyActivity = null;
	public RecordingsActivity recordingsActivity = null; 
	public AlarmActivity alarmActivity = null;
	
	/* Handler for callbacks to the UI thread */
    public final Handler myHandler = new Handler();

	/* Lists */
	public ArrayList<RadioGW> allRadios;
	public volatile ArrayList<HistPos> HistPosList = new ArrayList<>();
	public volatile Boolean firstHistData = false;
	public volatile Boolean dropAllData = false;
	public volatile ArrayList<Boolean> HistMsgList = new ArrayList<>();
	
	/* DEMO lists */
	public ArrayList<SMS> listSMS;
	public ArrayList<HistPos> demoPositions = new ArrayList<>();
	
	/*  Tab  */
	private TabWidget tabWidget;
	private TabSpec[] tabspecs;
	private TabHost tabHost;
	private Intent[] intent;
	
	/*  Visual Elements  */
	private LinearLayout layoutMenu, layoutSlideMenu; 
	private RelativeLayout layoutNewMessage;
	private TextView textViewNMMessage, textViewNMFrom = null, slideTabsText;
	private ImageView imageViewSlideMenu, imageViewPopUp, imageViewClose;
	private ImageButton buttonLive, buttonHistory, buttonText, buttonRadio, buttonAlarms, buttonRecordings, buttonSetup, buttonLogo;
	
	
	/* Notification */
	private Intent notificationIntent; 
	private final int NOTIFICATION_ACTIVITY_RESULT = 1;
	private NotificationManager mNotificationManager;
	
	/* TCP */
	protected Timer tcpTimer;//timer to check connection!!!
	
	/** TCP Service */
	private TCPService myService;
	private boolean isBound = false;
	
	/* User details */
	//protected int userID = 1;// ID of loged in userr
	//public String userName;
	
	// default app language 
	public String databaseLanguage = "en";			// database language : en, de, tr, ro or empty
	
	
	public enum MsgType { TCP,SMS,POLL,ALARM};
	
	public MsgType activePopupType = MsgType.TCP;
	
	/** Called when the activity is first created. */
    public void onCreate(Bundle savedInstanceState) {
    	
    	if(AppParams.theme == AppParams.Theme.SAFENET)
    		this.setTheme(R.style.Theme_Safenet);
    	else if(AppParams.theme == AppParams.Theme.VISION)
        	this.setTheme(R.style.Theme_Vision);
        else if(AppParams.theme == AppParams.Theme.HYTERA)
        	this.setTheme(R.style.Theme_Hytera);
    	else
    		this.setTheme(R.style.AppTheme);
        super.onCreate(savedInstanceState);
        SM.Debug("######### ON CREATE TAB");
        
        // get settings
        loadSettings();
        // save selected language (may differ from saved one)
        if(AppParams.LANGUAGETMP==null)
        	AppParams.LANGUAGETMP = AppParams.LANGUAGE;
        
        
        // change locale
        Locale locale = new Locale(AppParams.LANGUAGETMP);
        Locale.setDefault(locale);
        Configuration config = new Configuration();
        config.locale = locale;
        getBaseContext().getResources().updateConfiguration(config,
        getBaseContext().getResources().getDisplayMetrics());
        
        setContentView(R.layout.tabpanel);
		context = this;
		res = getResources(); // Resource object to get Drawables
		
		
		// StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder().detectNetwork().build();
		// StrictMode.setThreadPolicy(policy); 
		
		//AppParams.USERID = getIntent().getExtras().getInt("userID");
		//AppParams.userName = getIntent().getExtras().getString("userName");
        //AppParams.DEMO = getIntent().getExtras().getBoolean("demo");
        
        if(AppParams.DEMO)
        {
        	getAllVehicle().add(new Vehicle(101, "101", 101, "101", 101, 101, 101, 0));
        	getAllVehicle().add(new Vehicle(102, "102", 102, "102", 102, 102, 102, 0));
        	getAllVehicle().add(new Vehicle(103, "103", 103, "Ambulance", 78, 103, 103, 0));
        	getAllVehicle().add(new Vehicle(104, "104", 104, "104", 104, 104, 104, 0));
        	getAllVehicle().add(new Vehicle(105, "105", 105, "Police", 105, 105, 105, 0));
        	getAllVehicle().add(new Vehicle(106, "106", 106, "Mike", 106, 106, 106, 0));
        	getAllVehicle().add(new Vehicle(107, "107", 107, "Rob", 107, 107, 107, 0));
        	getAllVehicle().add(new Vehicle(108, "108", 108, "Ben", 108, 108, 108, 0));
        	getAllVehicle().add(new Vehicle(109, "109", 109, "Taxi_3", 109, 109, 109, 0));
        	getAllVehicle().add(new Vehicle(110, "110", 110, "Pam", 110, 110, 110, 0));
        	
        	
        	listSMS = new ArrayList<SMS>();
        	
        	listSMS.add(new SMS(1, 1, 1324016412, "Only one left", 101, 0));
        	listSMS.add(new SMS(2, 1, 1328061660, "Thanks", 0, 105));
        	listSMS.add(new SMS(3, 1, 1328060100, "i'm at the train station", 0, 102));
        	listSMS.add(new SMS(4, 1, 1121016818, "I'll be right there", 0, 103));
        	
        	for(Vehicle veh: getAllVehicle())
        	{        	
        		SuperVehicle tmpSuper = new SuperVehicle(veh.sc_id,veh.imei,veh.lp, veh.name, veh.driver_id, veh.time_route, veh.GPS_reporting_interval, veh.is_stolen);
        		if (veh.sc_id == 101)
        			tmpSuper.SetDataFromLastPos(30.1038811728358, -95.6229997426271, Calendar.getInstance().getTimeInMillis(), 47, "800-804 Sandy Ln, Tomball, TX 77375, USA", true); 
        		else if (veh.sc_id == 102)	
        			tmpSuper.SetDataFromLastPos(30.1035, -95.623, Calendar.getInstance().getTimeInMillis(), 33, "9th St", true); 
        		else if (veh.sc_id == 103)
        		tmpSuper.SetDataFromLastPos(42.320986,-85.183182, Calendar.getInstance().getTimeInMillis(), 61, "Battle Creek, MI,  USA", true); 
        		else if (veh.sc_id == 104)
        		tmpSuper.SetDataFromLastPos(42.337166,-83.049345, Calendar.getInstance().getTimeInMillis(), 47, "Downtown Detroit,  USA", true); 
        		else if (veh.sc_id == 105)
        		tmpSuper.SetDataFromLastPos(42.382514,-83.373184, Calendar.getInstance().getTimeInMillis(), 47, "Livonia, MI, Detroit,  USA", true); 
        		else if (veh.sc_id == 106)
        		tmpSuper.SetDataFromLastPos(41.741667,-87.972336, Calendar.getInstance().getTimeInMillis(), 47, "Darien, IL , USA", true); 
        		else if (veh.sc_id == 107)
        		tmpSuper.SetDataFromLastPos(41.739329,-87.97225, Calendar.getInstance().getTimeInMillis(), 47, "8205 S Cass Ave , USA", true); 
        		else if (veh.sc_id == 108)
        		tmpSuper.SetDataFromLastPos(41.739105,-87.97298, Calendar.getInstance().getTimeInMillis(), 47, "8201-8205 S Cass Ave , USA", true); 
        		else if (veh.sc_id == 109)
        		tmpSuper.SetDataFromLastPos(41.752521,-87.944655, Calendar.getInstance().getTimeInMillis(), 47, "Kingery Hwy, Willowbrook, IL 60527, USA", true); 
        		else if (veh.sc_id == 110)
        		tmpSuper.SetDataFromLastPos(41.748391,-87.933497, Calendar.getInstance().getTimeInMillis(), 47, "Historic U.S. 66, Burr Ridge, IL 60527 , USA", true); 
        		
        		getSuperVehHash().put(Long.valueOf(veh.imei), tmpSuper);
        		getVehHashByScId().put(veh.sc_id, veh);
        	}
        	
        }
        
        
        SM.Debug("Loged user:" + AppParams.USERNAME + " | ID: " + AppParams.USERID);
        // do not dim the display
        getWindow().addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON); 

        // get NewMessage Visual Element
		layoutNewMessage = (RelativeLayout) findViewById(R.id.layoutNewMessage);
		textViewNMMessage = (TextView) findViewById(R.id.textViewNMMessage);
		textViewNMFrom = (TextView) findViewById(R.id.textViewNMFrom);
		slideTabsText = (TextView) findViewById(R.id.slideTabsText);
		imageViewPopUp = (ImageView) findViewById(R.id.imageViewPopUp);
		imageViewClose = (ImageView) findViewById(R.id.imageViewClose);
		if(AppParams.DEMO)
			imageViewClose.setVisibility(View.VISIBLE);
        
		tabHost = getTabHost(); // The activity TabHost
		tabHost.setTag("Tab Panel");
		tabWidget = findViewById(android.R.id.tabs);
		tabWidget.setVisibility(View.GONE);
		
        intent = new Intent[8];
		tabspecs = new TabSpec[8];
		
		// add live tab
		try
		{
			intent[0] = new Intent(context, LiveActivity.class);
			tabspecs[0] = tabHost.newTabSpec("Live")
					.setIndicator("Live", res.getDrawable(R.drawable.ic_tab_live_selected))
					.setContent(intent[0]);
		}
		catch(NoClassDefFoundError e)
		{
			// exception when GoogleApi does not exist
			intent[0] = new Intent(context, AbstractEmptyActivity.class);
			tabspecs[0] = tabHost.newTabSpec("Live")
					.setIndicator("Live", res.getDrawable(R.drawable.ic_tab_live_selected))
					.setContent(intent[0]);
		}
		
		// add text tab
		intent[1] = new Intent(context, MessagesActivity.class);
		tabspecs[1] = tabHost.newTabSpec("Text")
				.setIndicator("Text", res.getDrawable(R.drawable.ic_tab_text_selected))
				.setContent(intent[1]);
		
		// add radio tab
		intent[2] = new Intent(context, RadioActivity.class);
		tabspecs[2] = tabHost.newTabSpec("Radio")
				.setIndicator("Radio", res.getDrawable(R.drawable.ic_tab_radio_selected))
				.setContent(intent[2]);
		
		// add recordings tab
		intent[3] = new Intent(context, RecordingsActivity.class);
		tabspecs[3] = tabHost.newTabSpec("Recordings")
				.setIndicator("Recordings", res.getDrawable(R.drawable.ic_tab_recording_selected))
				.setContent(intent[3]);
		
		// add alarms tab
			intent[4] = new Intent(context, AlarmActivity.class);
		tabspecs[4] = tabHost.newTabSpec("Alarms")
				.setIndicator("Alarms", res.getDrawable(R.drawable.ic_tab_alarms_selected))
				.setContent(intent[4]);
		
		// add setup tab
		intent[5] = new Intent(context, SetupActivity.class);
		tabspecs[5] = tabHost.newTabSpec("Setup")
				.setIndicator("Setup", res.getDrawable(R.drawable.ic_tab_settings_selected))
				.setContent(intent[5]);
		
		// add radio tab
		intent[6] = new Intent(context, AbstractEmptyActivity.class);
		tabspecs[6] = tabHost.newTabSpec("SafeMobile")
				.setIndicator("SafeMobile", res.getDrawable(AppParams.DEMO ? R.drawable.icon_demo : R.mipmap.ic_launcher))
				.setContent(intent[6]);

		// add history tab
		try
		{
			intent[7] = new Intent(context, HistoryActivity.class);
			tabspecs[7] = tabHost.newTabSpec("History")
					.setIndicator("History", res.getDrawable(R.drawable.ic_tab_history_selected))
					.setContent(intent[7]);
		} catch(NoClassDefFoundError e) {
//			 exception when GoogleApi not exists
			intent[7] = new Intent(context, AbstractEmptyActivity.class);
			tabspecs[7] = tabHost.newTabSpec("History")
					.setIndicator("History", res.getDrawable(R.drawable.ic_tab_history_selected))
					.setContent(intent[1]);
		}
		
		// add tab in tabHost
//		for(int i=0;i<7;i++
		for (TabSpec tab: tabspecs) {
			if(tabHost != null)
				tabHost.addTab(tab);
		}
		layoutMenu = (LinearLayout) findViewById(R.id.layoutMenu);
		
		// get slide Menu layout image
		imageViewSlideMenu = (ImageView) findViewById(R.id.imageViewSlideMenu);
		
		// get Live Button
        buttonLive = findViewById(R.id.buttonLive);
        buttonLive.setOnClickListener(v -> {
			if (!buttonLive.isSelected()) {
				// select button
				buttonLive.setSelected(true);
				// deselect other buttons
				buttonAlarms.setSelected(false);
				buttonHistory.setSelected(false);
				buttonRadio.setSelected(false);
				buttonRecordings.setSelected(false);
				buttonSetup.setSelected(false);
				buttonText.setSelected(false);
				// select tab
				tabHost.setCurrentTabByTag("Live");
				AppParams.crtTab = AppParams.Tabs.live;
			}
		});
        
        // get History Button
        buttonHistory = findViewById(R.id.buttonHistory);
        buttonHistory.setOnClickListener(v -> {
			if (!buttonHistory.isSelected()) {
				// select button
				buttonHistory.setSelected(true);
				// deselect other buttons
				buttonAlarms.setSelected(false);
				buttonLive.setSelected(false);
				buttonRadio.setSelected(false);
				buttonRecordings.setSelected(false);
				buttonSetup.setSelected(false);
				buttonText.setSelected(false);
				// select tab
				tabHost.setCurrentTabByTag("History");
				AppParams.crtTab = AppParams.Tabs.history;
			}
		});
        
        // get Text Button
        buttonText= findViewById(R.id.buttonText);
        buttonText.setOnClickListener(v -> {
			if (!buttonText.isSelected()) {
				// select button
				buttonText.setSelected(true);
				// deselect other buttons
				buttonAlarms.setSelected(false);
				buttonLive.setSelected(false);
				buttonRadio.setSelected(false);
				buttonRecordings.setSelected(false);
				buttonSetup.setSelected(false);
				buttonHistory.setSelected(false);
				// select tab
				tabHost.setCurrentTabByTag("Text");
				AppParams.crtTab = AppParams.Tabs.message;

				if (AppParams.DEMO && messageActivity.getAllVehicle().size()== 0) {
					// select button
					buttonText.setSelected(true);
					// deselect other buttons
					buttonAlarms.setSelected(false);
					buttonLive.setSelected(false);
					buttonRadio.setSelected(false);
					buttonRecordings.setSelected(false);
					buttonSetup.setSelected(false);
					buttonHistory.setSelected(false);
					// select tab
					tabHost.setCurrentTabByTag("Text");
					AppParams.crtTab = AppParams.Tabs.message;
					
					if (AppParams.DEMO && messageActivity.getAllVehicle().size()== 0) {
						messageActivity.updateVehicles(getAllVehicle());
						messageActivity.updateSMS(listSMS);
					}
				}
			}
		});
        
        // get Radio Button
        buttonRadio = (ImageButton) findViewById(R.id.buttonRadio);
        if(NOSOUND)
        	buttonRadio.setVisibility(View.GONE);
        buttonRadio.setOnClickListener(new OnClickListener() {
			@Override
			public void onClick(View v) {
				if(!buttonRadio.isSelected())
				{
					// select button
					buttonRadio.setSelected(true);
					// deselect other buttons
					buttonAlarms.setSelected(false);
					buttonLive.setSelected(false);
					buttonRecordings.setSelected(false);
					buttonHistory.setSelected(false);
					buttonSetup.setSelected(false);
					buttonText.setSelected(false);
					// select tab
					tabHost.setCurrentTabByTag("Radio");
					AppParams.crtTab = AppParams.Tabs.radio;
					
					if(radioActivity!= null && radioActivity.allVehicle!= null && radioActivity.allVehicle.size()==0)
					{
						radioActivity.allVehicle = getAllVehicle();
						radioActivity.UpdateVehicle();
					}
				}
			}
		});
        
        // get Recordings Button
        buttonRecordings = (ImageButton) findViewById(R.id.buttonRecording);
        if(NOSOUND)
        	buttonRecordings.setVisibility(View.GONE);
        buttonRecordings.setOnClickListener(new OnClickListener() {
			@Override
			public void onClick(View v) {
				if(!buttonRecordings.isSelected())
				{
					// select button
					buttonRecordings.setSelected(true);
					// deselect other buttons
					buttonRadio.setSelected(false);
					buttonAlarms.setSelected(false);
					buttonLive.setSelected(false);
					buttonHistory.setSelected(false);
					buttonSetup.setSelected(false);
					buttonText.setSelected(false);
					// select tab
					tabHost.setCurrentTabByTag("Recordings");
					AppParams.crtTab = AppParams.Tabs.recordings;
					
					if(AppParams.DEMO && recordingsActivity!= null && recordingsActivity.allRecordings!= null && recordingsActivity.allRecordings.size() ==0 )
					{
						ArrayList<Recording> listRecordings = new ArrayList<Recording>();
			    		Recording rec = new Recording();
			    		rec.NameForDisplay = "Rob";
			    		rec.subID = 101;
			    		rec.endGMT = (int) Calendar.getInstance().getTime().getTime();
			    		rec.startGMT = rec.endGMT - 2;
			    		rec.type = 102;
			    		listRecordings.add(rec);
			    		
			    		rec = new Recording();
			    		rec.NameForDisplay = "Call1 [Rob]";
			    		rec.subID = 102;
			    		rec.endGMT = (int) Calendar.getInstance().getTime().getTime();
			    		rec.startGMT = rec.endGMT - 2;
			    		rec.type = 101;
			    		listRecordings.add(rec);
			    		
			    		rec = new Recording();
			    		rec.NameForDisplay = "Call2 [Rob]";
			    		rec.subID = 101;
			    		rec.endGMT = (int) Calendar.getInstance().getTime().getTime();
			    		rec.startGMT = rec.endGMT - 3;
			    		listRecordings.add(rec);
			    		rec.type = 103;
			    		recordingsActivity.UpdateRecordings(listRecordings);
					}
					
				}
				
			}
		});
        
        // get Alarm Button
        buttonAlarms = (ImageButton) findViewById(R.id.buttonAlarms);
        buttonAlarms.setOnClickListener(new OnClickListener() {
			@Override
			public void onClick(View v) {
				if(!buttonAlarms.isSelected())
				{
					// select button
					buttonAlarms.setSelected(true);
					// deselect other buttons
					buttonHistory.setSelected(false);
					buttonLive.setSelected(false);
					buttonRadio.setSelected(false);
					buttonRecordings.setSelected(false);
					buttonSetup.setSelected(false);
					buttonText.setSelected(false);
					// select tab
					tabHost.setCurrentTabByTag("Alarms");
					AppParams.crtTab = AppParams.Tabs.alarms;
					
					
					if(AppParams.DEMO &&  alarmActivity!=null && alarmActivity.getAllAlarms() != null && alarmActivity.getAllAlarms().size() ==0 )
					{
						ArrayList<Alarm> listAlarms = new ArrayList<Alarm>();
						Alarm alarm = new Alarm();
						alarm.ack = 0;
						alarm.unitName = "Police";
						alarm.timeGMT = (int) Calendar.getInstance().getTime().getTime() - 5210;
						alarm.sc_id = 105;
						alarm.typestr = "Speeding";
						listAlarms.add(alarm);
						
						alarm = new Alarm();
						alarm.ack = 0;
						alarm.unitName = "101";
						alarm.timeGMT = (int) Calendar.getInstance().getTime().getTime() - 3315;
						alarm.sc_id = 101;
						alarm.typestr = "Geofence";
						listAlarms.add(alarm);
						
						alarm = new Alarm();
						alarm.ack = 0;
						alarm.unitName = "101";
						alarm.timeGMT = (int) Calendar.getInstance().getTime().getTime() - 1900;
						alarm.sc_id = 101;
						alarm.typestr = "Telemetry";
						listAlarms.add(alarm);
						
						alarm = new Alarm();
						alarm.ack = 0;
						alarm.unitName = "Taxi_3";
						alarm.timeGMT = (int) Calendar.getInstance().getTime().getTime() - 1521;
						alarm.sc_id = 109;
						alarm.typestr = "Landmark";
						listAlarms.add(alarm);
						
						alarm = new Alarm();
						alarm.ack = 0;
						alarm.unitName = "Ben";
						alarm.timeGMT = (int) Calendar.getInstance().getTime().getTime() - 521;
						alarm.sc_id = 108;
						alarm.typestr = "Emergency";
						listAlarms.add(alarm);
						
						alarmActivity.updateAlarms(listAlarms);
					}
					
				}
			}
		});
        
        //get Setup button
        buttonSetup = (ImageButton) findViewById(R.id.buttonSetup);
        buttonSetup.setOnClickListener(new OnClickListener() {
			@Override
			public void onClick(View v) {
				if(!buttonSetup.isSelected())
				{
					// select button
					buttonSetup.setSelected(true);
					// deselect other buttons
					buttonAlarms.setSelected(false);
					buttonLive.setSelected(false);
					buttonRadio.setSelected(false);
					buttonRecordings.setSelected(false);
					buttonHistory.setSelected(false);
					buttonText.setSelected(false);
					// select tab
					tabHost.setCurrentTabByTag("Setup");
					AppParams.crtTab = AppParams.Tabs.setup;
				}
			}
		});
        
        // get About Button
        buttonLogo = findViewById(R.id.buttonLogo);
        buttonLogo.setOnClickListener(v -> {
			// create dialog
			final Dialog dialog = new Dialog(context);
			dialog.setTitle(AppParams.DEMO ? getString(R.string.app_name_demo) : getString(R.string.app_name));
			dialog.setContentView(R.layout.dialog);
			ImageView image = dialog.findViewById(R.id.image);
			image.setImageResource(AppParams.DEMO ? R.drawable.icon_demo : R.mipmap.ic_launcher);
			TextView text = dialog.findViewById(R.id.text);
			TextView text2 = dialog.findViewById(R.id.text2);
			text.setText(getString(R.string.version) + "1.0.8");
			text2.setText(getString(R.string.email) + ": support@safemobile.com");
			dialog.setCancelable(true);
			dialog.setCanceledOnTouchOutside(true);
			dialog.show();
		});
	    
        imageViewClose.setOnTouchListener(new OnTouchListener() {
			@Override
			public boolean onTouch(View v, MotionEvent event) {
				layoutNewMessage.setVisibility(View.GONE);
				return false;
			}
		});
        
        // set Click event for NewMessageLayout
        layoutNewMessage.setOnClickListener(new OnClickListener() {
			@Override
			public void onClick(View v) {
				if(tcp!=null && tcp.isConnectionUP && inCall == false)
				{
					if(slideTabsText.getText().toString().equals(getString(R.string.newMessage)))
						viewReceived(AppParams.messageNotif);
					else if(slideTabsText.getText().toString().equals(getString(R.string.newAlarm)))
						viewReceived(AppParams.alertNotif);
					else if(slideTabsText.getText().toString().equals(getString(R.string.newPoll)))
						viewReceived(AppParams.pollNotif);
				}
				else if (AppParams.DEMO)
				{
					if(slideTabsText.getText().toString().equals(getString(R.string.newMessage)))
						viewReceived(AppParams.messageNotif);
					else if(slideTabsText.getText().toString().equals(getString(R.string.newPoll)))
						viewReceived(AppParams.pollNotif);
				}
				
				layoutNewMessage.clearAnimation();
				layoutNewMessage.setVisibility(View.INVISIBLE);
				/*
				String currentActivityId = getLocalActivityManager().getCurrentId();
				SM.Debug(" curent activityID: " +currentActivityId);
				while(currentActivityId == null)
				{
					try {
						Thread.sleep(100);
						currentActivityId = getLocalActivityManager().getCurrentId();
						SM.Debug(" curent activityID: " +currentActivityId);
					} catch (InterruptedException e) {
						SM.Debug(e.toString());
					}
				}
				Activity currentActivity = getLocalActivityManager().getActivity(currentActivityId);
				//list for SMS
				if(currentActivity instanceof MessagesActivity)
				{
					// run update showSMS4unit(int scId) form MessageActivity
					((MessagesActivity)currentActivity).showSMS4unit(getVehicle4Imei(imei).scId);
				}
				*/
			}
		});
        
        
	     // if RADIOPAD hide buttons
        
        /*
        // alarm animation
        Animation a = AnimationUtils.loadAnimation(this, R.anim.alpha);
        a.reset();
        textViewAlarm.clearAnimation();
        textViewAlarm.startAnimation(a);
        imageViewAlarm.clearAnimation();
        imageViewAlarm.startAnimation(a);
        */
        
        layoutSlideMenu = (LinearLayout) findViewById(R.id.layoutSlideMenu);
        layoutSlideMenu.setOnClickListener(new OnClickListener() {
			@Override
			public void onClick(View v) {
				if(isMenuVisible)
				{
					// hide Menu
						layoutMenu.setVisibility(View.GONE);
					// change image
						imageViewSlideMenu.setImageResource(R.drawable.arrow_left);
					// set visibile false
						isMenuVisible = false;
				}
				else 
				{
					// hide Menu
						layoutMenu.setVisibility(View.VISIBLE);
					// change image
						imageViewSlideMenu.setImageResource(R.drawable.arrow_right);
					// set visibile true
						isMenuVisible = true;
				}
			}
		});
	        // got to tab
        tabHost.setCurrentTabByTag("Radio");
		tabHost.setCurrentTabByTag("Live");
		buttonLive.setSelected(true);

		AppParams.crtTab = AppParams.Tabs.live;
		
		//start TCP timer
		tcpTimer = new Timer();
		tcpTimer.scheduleAtFixedRate(new TimerTask() {
			
			@Override
			public void run() {
					TimerMethod();
			}
		}, AppParams.DEMO ? 3000 : 1000, 3000);
		
		
		// hide buttons if safenet
		if (AppParams.theme == AppParams.Theme.SAFENET) {
			buttonRadio.setVisibility(View.GONE);
			buttonRecordings.setVisibility(View.GONE);
		}
		
		
    	if (AppParams.DEMO && liveActivity != null) {
    		liveActivity.vehiclesReceived(getAllVehicle());
    		demoPositionsList();
    	}
    	
    	if (!AppParams.DEMO) {
    		Timer t = new Timer();
    		t.schedule(new TimerTask() {
				@Override
				public void run() {
						 // init tcp
						  TCPinit();		
				}
			}, 100);
    	}
    	
    	// Notification Click Filter
    	IntentFilter intentAlertFilter = new IntentFilter(NotificationActivity.NOTIFICATION_ALERT_INTENT);
    	IntentFilter intentMessageFilter = new IntentFilter(NotificationActivity.NOTIFICATION_MESSAGE_INTENT);
    	IntentFilter intentPollFilter = new IntentFilter(NotificationActivity.NOTIFICATION_POLL_INTENT);
		this.registerReceiver(mReceiver, intentAlertFilter);
		this.registerReceiver(mReceiver, intentMessageFilter);
		this.registerReceiver(mReceiver, intentPollFilter);
		
		 /** Create Service and bind to it */
		getApplicationContext().bindService(new Intent(this, TCPService.class), serviceConnection, Context.BIND_AUTO_CREATE);
		
		
		// set tab
		/*
		tabHost.setCurrentTabByTag("Alarms");
		AppParams.crtTab = AppParams.Tabs.setup;
		//*/
	}
    
    
    /** Broadcast Received for notifications */
    private final BroadcastReceiver mReceiver = new BroadcastReceiver() {
        @Override
        public void onReceive(Context context, Intent intent) {
            String action = intent.getAction();
            // get notification click action
            if (action.equals(NotificationActivity.NOTIFICATION_MESSAGE_INTENT) && tabHost.getCurrentTab() != 2)
            	viewReceived(AppParams.messageNotif);
            else if (action.equals(NotificationActivity.NOTIFICATION_ALERT_INTENT) && tabHost.getCurrentTab() != 2)
            	viewReceived(AppParams.alertNotif);
            else if (action.equals(NotificationActivity.NOTIFICATION_POLL_INTENT) && tabHost.getCurrentTab() != 2)
            	viewReceived(AppParams.pollNotif);
        }
    };
    
    private void viewReceived(int icon)
    {
    	switch(icon) 
    	{
    	case AppParams.messageNotif : 
    		// hide NewMessage Layout
			layoutNewMessage.setVisibility(View.GONE);
			// select button
			buttonText.setSelected(true);
			// deselect other buttons
			buttonAlarms.setSelected(false);
			buttonLive.setSelected(false);
			buttonRadio.setSelected(false);
			buttonRecordings.setSelected(false);
			buttonSetup.setSelected(false);
			buttonHistory.setSelected(false);					
			// select text tab
			tabHost.setCurrentTabByTag("Text");
			AppParams.crtTab = AppParams.Tabs.message;
			
			messageActivity.setScId(getVehicle4Imei(getImei()).sc_id);
			messageActivity.LASTMESSAGES = false;
			messageActivity.getLastSMS();
			
			// disable notification
			if(mNotificationManager!=null)
				mNotificationManager.cancel(R.drawable.message);
			break;
    	case AppParams.alertNotif:
    		// hide NewMessage Layout
			layoutNewMessage.setVisibility(View.GONE);
			// select button
			buttonAlarms.setSelected(true);
			// deselect other buttons
			buttonText.setSelected(false);
			buttonLive.setSelected(false);
			buttonRadio.setSelected(false);
			buttonRecordings.setSelected(false);
			buttonSetup.setSelected(false);
			buttonHistory.setSelected(false);					
			// select tab
			tabHost.setCurrentTabByTag("Alarms");
			AppParams.crtTab = AppParams.Tabs.alarms;
			// disable notification
			if(mNotificationManager!=null)
				mNotificationManager.cancel(R.drawable.alert);
			break;
    	case R.drawable.poll:
    		// hide NewMessage Layout
			layoutNewMessage.setVisibility(View.GONE);
			// select button
			buttonLive.setSelected(true);
			// deselect other buttons
			buttonText.setSelected(false);
			buttonAlarms.setSelected(false);
			buttonRadio.setSelected(false);
			buttonRecordings.setSelected(false);
			buttonSetup.setSelected(false);
			buttonHistory.setSelected(false);					
			// select tab
			tabHost.setCurrentTabByTag("live");
			AppParams.crtTab = AppParams.Tabs.live;
			// disable notification
			if(mNotificationManager!=null)
				mNotificationManager.cancel(R.drawable.poll);
			break;
    	}
    }
    
    
    public void demoPositionsList() {
    	AssetManager assetManager = res.getAssets();
		SM.Debug("TRY 2 OPEN demo_positions.txt");
		InputStream input;
		try {
			input = assetManager.open("demo_positions.txt");
			InputStreamReader inputreader = new InputStreamReader(input);
            BufferedReader buffreader = new BufferedReader(inputreader);
            String line;
            while ((line = buffreader.readLine()) != null) {
            	String[] posi = line.split("#");
            	HistPos gps = new HistPos();
            	gps.lat = Double.parseDouble(posi[1]);
            	gps.lng = Double.parseDouble(posi[2]);
            	gps.speed = Integer.parseInt(posi[3]);
            	gps.Address = posi[4];
            	demoPositions.add(gps);
            }
            HistPosmsg msg = new HistPosmsg(new TCPmsg(new char[]{}));
            demoPositions = msg.CalcHeadingForArray(demoPositions);
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		
	}

	@Override
    public void onStart()
    {
    	super.onStart();
    	/*
    	SM.Debug("##### onSTART #####");
    	if(FIRST)
    	{
	    	// start thread to add listener
	    	SM.Debug("##### START initTCPRUN");
	    	new Thread(new Runnable() {
	    	    public void run() {
	    	    	try {
						Thread.sleep(1000);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					myHandler.post(initTCPRUN);
	    	    }
	    	  }).start();
	    	
	    	FIRST = false;
    	}
	*/
    }
	
	 ServiceConnection serviceConnection = new ServiceConnection() {
			
			@Override
			public void onServiceDisconnected(ComponentName name) {
				 //Toast.makeText(context, "Fucking Service is disconnected", 1000).show();
				 SM.Debug("Service is disconnected");
				 isBound = false;
				 myService = null;
			}
			
			@Override
			public void onServiceConnected(ComponentName name, IBinder service) {
				 //Toast.makeText(context, "Fucking Service is connected", 2000).show();
				 SM.Debug("Service is connected");
				 TCPBinder binder = (TCPBinder) service;
			        myService = binder.getService();
			        isBound = true;
			        
			        tcpParser();
			}
		};
    
	
	@Override
	public void whenBackPressed(AppParams.ActivityResult result)
    {
		// close TCP
		/*
		if(tcp!= null) 
		{
			tcp.Stop();
			tcpParser.Stop();
		}*/

		if(tcpTimer!=null)
		{
			tcpTimer.cancel();
			tcpTimer.purge();
			tcpTimer = null;
		}
		

		if(radioActivity.audioThread != null)
		{
			Thread moribund = radioActivity.audioThread;
			radioActivity.audioThread = null;
			moribund.interrupt();
		}
		
		if(mReceiver!=null)
			this.unregisterReceiver(mReceiver);

		// unbound from tcp service
		if (isBound) {
			getApplicationContext().unbindService(serviceConnection);
			isBound = false;
		}

		// cancel new message notification if any
		if(mNotificationManager!=null) {
			mNotificationManager.cancel(R.drawable.message);
			mNotificationManager.cancel(R.drawable.alert);
			mNotificationManager.cancel(R.drawable.poll);
		}
 	    
		
		getIntent().putExtra("result", result);
		setResult(RESULT_OK, getIntent()); //-> used for exit

		finish();
       android.os.Process.killProcess(android.os.Process.myPid());
       System.exit(0);
    }
	
	@Override
    public void changeLanguage()
    {
    	// recreate UI
    	Locale locale = new Locale(AppParams.LANGUAGETMP);
        Locale.setDefault(locale);
        android.content.res.Configuration configuration = new  android.content.res.Configuration();
        configuration.locale = locale;
        getBaseContext().getResources().updateConfiguration(configuration,
        getBaseContext().getResources().getDisplayMetrics());

        // change UI in Live Activity
        // if(liveActivity != null)
        	//liveActivity.onCreate(liveActivity.savedInstanceState);
        if(historyActivity!=null)
        	//historyActivity.onCreate(historyActivity.savedInstanceState);
    	// change UI for RadioActivity and MessageActivity
    	if(radioActivity!=null)
    		radioActivity.onCreate(radioActivity.savedInstanceState);
    	if(messageActivity!=null)
    		messageActivity.onCreate(messageActivity.getSavedInstanceState());
    	if(recordingsActivity!=null)
    		recordingsActivity.onCreate(recordingsActivity.savedInstanceState);
    	if(alarmActivity!=null)
    		alarmActivity.onCreate(alarmActivity.getSavedInstanceState());
    }
    
    
	// Create runnable for posting
    public final Runnable initTCPRUN = new Runnable() {
        public void run() {
        	//SM.Debug("##### GetVehicles()");
        	// get all vehicles
            //getVehs();
        }
    };
    
    //timer stuff
    private void TimerMethod()
	{
    	if(!AppParams.DEMO)
    		this.runOnUiThread(Timer_Tick);
    	else
    		// build TimerMethod for demo
    		this.runOnUiThread(Timer_TickDemo);
	}
    
    private Runnable Timer_TickDemo = new Runnable() {
		public void run() {
			if(AppParams.crtTab == AppParams.Tabs.live)
			{
				if(getSuperVehHash().containsKey((long)101))
				{
					
					HistPos crtPos = demoPositions.get(demoPosition++ % demoPositions.size());
						
					SM.Debug("########### UPDATE");
					int sc_id = demoPosition%3 == 0 ? 101:102;
					getSuperVehHash().get((long)sc_id).SetNewPosition(crtPos.lat, crtPos.lng, Calendar.getInstance().getTime().getTime(), crtPos.speed);
					liveActivity.refreshMap();
				}
			}
		}
    };
    
    @Override
    public void updateDemoPosition()
    {
			HistPos crtPos = demoPositions.get(demoPosition++ % demoPositions.size());
				
			SM.Debug("########### UPDATE");
			int sc_id = Integer.parseInt(getImei());
			getSuperVehHash().get((long)sc_id).SetNewPosition(crtPos.lat + 0.0002, crtPos.lng + 0.0002, Calendar.getInstance().getTime().getTime(), crtPos.speed+2);
			setMess("Lat:" + String.format("%5f", crtPos.lat + 0.0002) + ", Lng:" + String.format("%5f", crtPos.lng + 0.0002));
			liveActivity.refreshMap();
    }
    

	private Runnable Timer_Tick = new Runnable() {
		public void run() {

		//This method runs in the same thread as the UI.    	       

		//Do something to the UI thread here
			if(tcp != null)
			{
				if(!tcp.isConnectionUP)
				{
					//SM.Debug("TCP connection with:"+tcp.serverHostname + " is DOWN!!!");
					// set TextViews
					slideTabsText.setText(getString(R.string.connectionError));
					textViewNMFrom.setText(getString(R.string.tcpConnection));
					textViewNMMessage.setText("");
					imageViewPopUp.setImageResource(R.drawable.error);
					// show layout
					layoutNewMessage.setVisibility(View.VISIBLE);
					// hide close button
					imageViewClose.setVisibility(View.INVISIBLE);
					try
					{
					if(lastTCPstatus)
						radioActivity.UpdateEnableDisableButtons("offline");
					}
					catch(Exception ex)
					{
						SM.Debug(ex.toString());
					}
				}
				else
				{			
					
					//SM.Debug("TCP connection with:"+tcp.serverHostname + " is OKKKKK!!!");
					/*
					if(layoutNewMessage.getVisibility() == View.VISIBLE)
					{
					switch (activePopupType) 
					{
					case SMS:
						imageViewPopUp.setImageResource(R.drawable.message);	
						break;
					case ALARM:
						imageViewPopUp.setImageResource(R.drawable.siren_on);	
						break;
					case POLL:
						imageViewPopUp.setImageResource(R.drawable.poll);	
						break;

					default:
						imageViewPopUp.setImageResource(R.drawable.error);
						break;
					}
					*/
					// reset image to message
					//imageViewPopUp.setImageResource(R.drawable.message);
					// hide layout
					//if(layoutNewMessage.getVisibility() == View.VISIBLE)
					// when connection becomes true after it was false 
					
						
						if(getAllVehicle().size() == 0)
							//connectTask.doIn(OperationCodes.GetVehicles, new Object[] {AppParams.USERID});
							new ConnectTask().execute(new String[] {OperationCodes.GetVehicles + "", AppParams.USERID + ""});
							//getVehicles(AppParams.USERID);
						if(radioActivity != null && AppParams.listRadios.size() == 0)
							new ConnectTask().execute(new String[] {OperationCodes.GetRadiosList + ""});
						//connectTask.execute("3#getRadiosList");
						
						/*
						new Thread(new Runnable() {
				    	    public void run() 
				    	    	{
						    	    	try {
											Thread.sleep(1500);
										} catch (InterruptedException e) {
											e.printStackTrace();
										}
										
										//GetRadioStatus(crtRadio.GW_ID, crtRadio.ID);	// get radio status
						    	    }
						  	  }).start();
					  */	
						
					layoutNewMessage.setVisibility(View.INVISIBLE);
				}
				// remember this tcp connection status
				lastTCPstatus = tcp.isConnectionUP;
			}
		}
	};
	
	
	// hide tabs
	public void hideTabs() 
	{
		//tabWidget.setVisibility( View.GONE );
		layoutMenu.setVisibility(View.GONE);
	}

	// show tabs
	public void showTabs() 
	{
		//tabWidget.setVisibility( View.VISIBLE );
		layoutMenu.setVisibility(View.VISIBLE);
	}

	
	// TCP part
	public void TCPinit()
	{
		SM.Debug("#### TCP INIT ####");
		
		new ConnectTask().execute(new String[] {OperationCodes.TCP_CONNECTION_REQ + ""});
		//connectTask.execute(new Object[] {OperationCodes.GetTCPConnection});
	}
	
	public void tcpParser()
	{
		SM.Debug("TCP PARSER ", "connectParserTask().execute &&  myService is : " + (myService == null ? " null " : " not null"));
		
		if(myService != null) {
			tcpParser = myService.getTCPmsgParser();
			tcp = myService.getTCPConnection();
		}
		
		SM.Debug("connectParserTask","tcpParser is : " + (tcpParser == null ? "null" : "not null"));
		// add TCPParserListener
		if(tcpParser!=null)
		{
			SM.Debug("## tcpParser != null ", "#### call tcpParserListener(") ;
			tcpParserListener();
		}
		
		//new connectParserTask().execute("");
	}
	
	public void tcpParserListener()
	{
		
		SM.Debug("ADDING TCP Listener", "NEW TCP Listener");
        //manager.getActivity(id);
		tcpParser.clearITCPListeners();
        tcpParser.addTCPListener(new ITCPListener() {

			public void onLoginReceived(TCPEvent event) { }

			public void onGPSReceived(TCPEvent event) {
				SM.Debug("Got GPS message");
				TCPmsg msg= event.msg();
				//SM.Debug("Got GPS message :" + msg.allData);
				
				GPSmsg GPSPos= new GPSmsg(msg);
				//SM.Debug("Got new GPS pos data:" + GPSPos.data);

				if (getSuperVehHash().get(GPSPos.gpsValue.imei) != null) {
					getSuperVehHash().get(GPSPos.gpsValue.imei).SetNewPosition(GPSPos.gpsValue.lat, GPSPos.gpsValue.lng, GPSPos.gpsValue.timeGMT, GPSPos.gpsValue.speed);

//					if (getSuperVehHash().get(GPSPos.gpsValue.imei).needUpdate) {
						//list for live
						if (AppParams.crtTab == AppParams.Tabs.live) {
							//SM.Debug("+++++ duda  +++++");
							SM.Debug("currentActivity instanceof LiveActivity");
							try {
								if(liveActivity != null)
									liveActivity.refreshMap();
							} catch (Exception ex) {
								SM.Debug("Error load hash:"+ex.toString());
							}
						}
//					}
				}
			}
			
			@Override
			public void onPollReceived(TCPEvent event) {
				SM.Debug("Got POLL GPS message");
				TCPmsg msg= event.msg();
				GPSmsg GPSPos= new GPSmsg(msg);
				setImei(Long.toString(GPSPos.gpsValue.imei));
		        setMess("LAT:"+Double.toString(GPSPos.gpsValue.lat)+"  LNG:"+Double.toString(GPSPos.gpsValue.lng));
				SM.Debug("Got new Poll pos data:" + GPSPos.data);
											

				if(getSuperVehHash().get(GPSPos.gpsValue.imei) != null) {
					((SuperVehicle) getSuperVehHash().get(GPSPos.gpsValue.imei)).SetNewPosition(GPSPos.gpsValue.lat, GPSPos.gpsValue.lng, GPSPos.gpsValue.timeGMT, GPSPos.gpsValue.speed);
					//if is not check i need to force check to put on the map
					Boolean forceChecked =false;
					if (!getSuperVehHash().get(GPSPos.gpsValue.imei).needUpdate) {
						getSuperVehHash().get(GPSPos.gpsValue.imei).needUpdate =true;
						forceChecked =true;
					}
						
					//back to standard procedures to put on the map
					if(getSuperVehHash().get(GPSPos.gpsValue.imei).needUpdate)
					{
						
						//list for live
						if(AppParams.crtTab == AppParams.Tabs.live)
						{
							//SM.Debug("+++++ duda  +++++");
							//SM.Debug("currentActivity instanceof LiveActivity");
							try
					        {		
								int x = 0;
								if (forceChecked)
								{
									for (Vehicle veh : getAllVehicle())
									{
										if (veh.imei.compareTo(Long.toString(GPSPos.gpsValue.imei))==0) break;
										x++;
									} 									
								}
								else x = -1;
								if(liveActivity!=null)
								{
									if (x!= getAllVehicle().size())
										liveActivity.pollReceived(x ,GPSPos.gpsValue.lat,GPSPos.gpsValue.lng);
									else
										liveActivity.pollReceived(-1 ,GPSPos.gpsValue.lat,GPSPos.gpsValue.lng);
								}
					        }
					        catch (Exception ex) 
					        {
					        	SM.Debug("Error load hash:"+ex.toString());
							}					
						}				
					}
				}
				myHandler.post(UpdateResultsPoll);
			}

			public void onSMSReceived(TCPEvent event) 
			{
				try{
					TCPmsg msg= event.msg();			
					SMSmsg sms= new SMSmsg(msg);
					SM.Debug("am primit lista cu primele SMSuri");

					//list for SMS
					if(AppParams.crtTab == AppParams.Tabs.message)
					{
						//SM.Debug("currentActivity instanceof MessagesActivity - newSMS");
						if(messageActivity != null)
							messageActivity.updateSMS(sms.smsList);
					}
				}
				catch(Exception ex)
				{
					SM.Debug("Error on smsRecived:"+ex.toString());					
				}
			}

			public void onVehiclesReceived(TCPEvent event) {
				//SM.Debug("#########################","###########################");
				TCPmsg msg= event.msg();
				VehMSG vMSG = new VehMSG(msg);
				SM.Debug("### Vehicle Received ###","Received " + vMSG.vehList.size() + " vehicles");
				
				//list for live
				if(AppParams.crtTab == AppParams.Tabs.live)
				{
					//SM.Debug("+++++ duda  +++++");
					SM.Debug("currentActivity instanceof LiveActivity");
					try
			        {			        	
			        	for(Vehicle veh:vMSG.vehList)
			        	{        	
			        		SuperVehicle tmpSuper = new SuperVehicle(veh.sc_id,veh.imei,veh.lp, veh.name, veh.driver_id, veh.time_route, veh.GPS_reporting_interval, veh.is_stolen);
			        		getSuperVehHash().put(Long.valueOf(veh.imei), tmpSuper);
			        		getVehHashByScId().put(veh.sc_id, veh);
			        	}
			        	SM.Debug(" #$############# " + getSuperVehHash().size() + " \nVEH " + vMSG.vehList.size());
			        }
			        catch (Exception ex) 
			        {
			        	SM.Debug("Error load hash:"+ex.toString());
					}
					if(liveActivity!=null)
						liveActivity.vehiclesReceived(vMSG.vehList);
				}
				else if(firstGetVehs)
				{
					// set vehicles to liveActivity
					liveActivity.vehiclesReceived(vMSG.vehList);
					firstGetVehs = false;
				}
				
				//list for SMS
				if(AppParams.crtTab == AppParams.Tabs.message)
				{
					SM.Debug("currentActivity instanceof MessagesActivity");
					if(messageActivity != null)
						messageActivity.updateVehicles(vMSG.vehList);
				}				
				setAllVehicle(vMSG.vehList);
			}

			public void onLastSMSsReceived(TCPEvent event) {
				try
				{
					TCPmsg msg= event.msg();				
					SMSmsg sms= new SMSmsg(msg);
					SM.Debug("am primit lista cu primele SMSuri");

					//list for SMS
					if(AppParams.crtTab == AppParams.Tabs.message)
					{
						//SM.Debug("currentActivity instanceof MessagesActivity");
						if(messageActivity != null)
							messageActivity.updateSMS(sms.smsList);
					}
				}
				catch (Exception ex)
				{
					SM.Debug("Error on lastSMSRecived:"+ex.toString());
				}
			}
			
			@Override
			public void onAlarmsReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				
				AlarmMSG Alarms= new AlarmMSG(msg);
				SM.Debug("am primit lista cu Alarme");
				
				//list for SMS
				if(AppParams.crtTab == AppParams.Tabs.alarms)
				{
					SM.Debug("currentActivity instanceof AlarmActivity");
					if(alarmActivity != null)
						alarmActivity.updateAlarms(Alarms.alarmList);
				}
			}
			
			
			@Override
			public void onAlarmAckReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				
				SM.Debug("Got alarmACK :" + msg.allData);				
				String[] tempArr =msg.data.split("#");
				if (Integer.parseInt(tempArr[0])==1 && AppParams.crtTab == AppParams.Tabs.alarms)
				{
					if(alarmActivity != null)
						alarmActivity.updateACK();
				}
			}

			@Override
			public void onSMSAckReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				SMSmsg sms= new SMSmsg(msg);
				SM.Debug("Got smsComfirm msg.data:" + msg.data);
				
				if (messageActivity != null)
					messageActivity.confirmSMS(sms.data, msg.seqID);
			}

			@Override
			public void onNewSMSReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				SM.Debug("Got smsNew :" + msg.allData);
				String[] tempArr =msg.data.split("#");
				SM.Debug("Unit imei:" + tempArr[0]);
				SM.Debug("Message:" + tempArr[1]);
				
				// change Visual Elements
				setImei(tempArr[0]);
				setMess(tempArr[1]);
				long time = Calendar.getInstance().getTimeInMillis() / 1000;
				try {
					// get time from the last received sms and divide it to 1000 to convert it to seconds
					time = Long.parseLong(msg.seqID.replace('.', '#').split("#")[1]) / 1000 - 100;
				}
				catch(Exception ex) {
				}
				
				// if tab is not TextTab
				if(tabHost.getCurrentTab() != 2) {
					myHandler.post(UpdateResults);
					//mHandler.dispatchMessage(new Message());
				} else
					myHandler.post(() -> {
						// create Notification
						createNotification(AppParams.messageNotif);
					});
				//list for SMS
				if(AppParams.crtTab == AppParams.Tabs.message && messageActivity!= null) {
					SM.Debug("currentActivity instanceof MessagesActivity - newSMS | " + tempArr[0] + " | " + tempArr[1]);
					messageActivity.newSMS(tempArr[0], tempArr[1], time);
				}
			}
			
			@Override
			public void onRecordingPlayReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				SM.Debug("Got PlayRec :" + msg.allData);
				
				if(NOSOUND)
				 {
					//String[] tempArr =msg.data.split("#");
					//SM.Debug("Unit imei:" + tempArr[0]);				
					SM.Debug("Recording Play file ID:" + msg.data);
					
					//list for SMS
					if(AppParams.crtTab == AppParams.Tabs.recordings)
					{
						String tmp = msg.data.replace("#", "");
						
						try {
							long id = Long.parseLong(tmp);
							if(recordingsActivity != null)
								recordingsActivity.PlayRecording(id);
						}
						catch(Exception ex) {
							SM.Exception(ex.toString());
						}
					}
				 }
			}
			
			@Override
			public void onLastPositionsReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				SM.Debug("Got last pos");

				LastPosmsg lastPos= new LastPosmsg(msg);
				for(LastPos posMsg: lastPos.PosList) {
					if(getSuperVehHash().get(posMsg.imei) != null)
						getSuperVehHash().get(posMsg.imei).SetDataFromLastPos(posMsg.lat, posMsg.lng, posMsg.timeGMT, posMsg.speed, posMsg.Address, posMsg.isON);
				}
			}
			
			@Override
			public void onHistoryPositionsCountReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				SM.Debug("Got POS Count");

				HistCountmsg histcount= new HistCountmsg(msg);
				SM.Debug("Message Count:"+histcount.histcountValue.count);
				if (histcount.histcountValue.count>=2000) {
					//list for live
					if(AppParams.crtTab == AppParams.Tabs.history) {
						SM.Debug("currentActivity instanceof HistoryActivity");
						try {
							if(historyActivity != null) {
								historyActivity.UpdateCancel();
								historyActivity.UpdateUnableDisp();
							}
				        } catch (Exception ex) {
				        	SM.Debug("Error load hash:"+ ex);
						}					
					}
				}				
			}		
			
			@Override
			public void onHistoryPositionsReceived(TCPEvent event) {
				TCPmsg msg= event.msg();
				SM.Debug("Got HistoryPos :" + msg.allData);	
				if (!dropAllData) {
					HistPosmsg tmpHist= new HistPosmsg(msg);
					Boolean SendDataToMap =true;
					try {
						for (HistPos obj : tmpHist.PosList) 				
							HistPosList.add(obj);			

						SM.Debug("tmpHist seqID:"+tmpHist.seqID);
						//		
						int pos = Integer.parseInt(tmpHist.seqID.substring(0,tmpHist.seqID.indexOf('.')));
						int all = Integer.parseInt(tmpHist.seqID.substring(tmpHist.seqID.indexOf('.') + 1));
						if (all != 0) {
							if (firstHistData) {
								try {
									for(int i=0;i<all;i++)
										HistMsgList.add(false);
								} catch (Exception e) {
									SM.Debug("Error on init hashTable:"+ e);
								}			
								firstHistData =false;
							}

							HistMsgList.set(pos-1, true);
							for (int i = 0; i < all; i++) {
								if (!HistMsgList.get(i)) {
									SendDataToMap =false;
									break;
								}
							}								
						} else
							SendDataToMap =true;
					} catch (Exception e) {
						SM.Debug("Error on parse: "+ e);
					}
					if (SendDataToMap) {
						Collections.sort(HistPosList, (Comparator<Object>) (o1, o2) -> {
							HistPos p1 = (HistPos) o1;
							HistPos p2 = (HistPos) o2;
							if (p1.timeGMT < p2.timeGMT)
								return -1;
							else if (p1.timeGMT == p2.timeGMT)
								return 0;
							else
								return 1;
						});
						
						//list for live
						if (AppParams.crtTab == AppParams.Tabs.history) {
							try {
								if(historyActivity != null) {
									// cancel last update
									historyActivity.UpdateCancel();
									Thread.sleep(101);
									if (HistPosList.size() < 2000) {
										if (HistPosList.size() == 1 && HistPosList.get(0).timeGMT == 0)
											;// do nothing is not data message
										else
											historyActivity.UpdateNrPos(HistPosList.size());
										Thread.sleep(100);
										
										historyActivity.UpdateMap();
									} else
										historyActivity.UpdateUnableDisp();		// update with more than 200 points
								}
							}
							catch (Exception ex) {
								SM.Debug("Error load hash: "+ ex);
							}					
						}				
						SM.Debug("Got HistPost msg.data: " + msg.data);
					}
				} else
					SM.Debug("Drop history data");
			}

			@Override
			public void onRadioMsgReceived(TCPEvent event) {
				SM.Debug("#### RadioMsgRecv");
				TCPmsg msg= event.msg();
				RadioMSG rmsg = new RadioMSG(msg);
				
				if (!NOSOUND) {
					// update Zone and Channel
					if (radioActivity != null && rmsg.zac != null) {
						// update Zone and Channel in the allRadio List
						for (RadioGW radio: allRadios) {
							if (radio.GW_ID == rmsg.zac.gwID && radio.ID == rmsg.zac.rgwID) {
								radio.lastZoneNr = rmsg.zac.zoneNr;
								radio.lastChannelNr = rmsg.zac.channelNr;
							}
						}

						AppParams.crtZoneAndChannel = rmsg.zac;
						notifyBroadcast(OperationCodes.CHANNEL_BRDCST+"");
						SM.Debug("Received from Apps -> UpdateZoneCH(" + rmsg.zac.rgwID + "," + rmsg.zac.gwID + "," + rmsg.zac.zoneNr + "," + rmsg.zac.channelNr + ")");
					}

					//list for SMS
					if (AppParams.crtTab == AppParams.Tabs.radio) {
						SM.Debug("#### RadioActivity");
						// set crt activity to Radio
						crtActivity = RADIO;

						SM.Debug("## " + (rmsg.RadioGWList!=null? "RadioGWList" + rmsg.RadioGWList.size() : "RadioGWList = null"));
						SM.Debug("## " + (rmsg.zac!=null? "zac" + rmsg.zac : "zac = null"));
						SM.Debug("## " + (rmsg.rStatus!=null? "rStatus" + rmsg.rStatus : "rStatus = null"));

						if (radioActivity != null && rmsg.RadioGWList != null) {
							radioActivity.UpdateRadios(rmsg.RadioGWList);
							SM.Debug("Received from Apps -> UpdateRadios( count:" + rmsg.RadioGWList.size() + ")");
						}

						if (radioActivity != null &&rmsg.rStatus != null) {
							// update status in the crtRadio List
							for (RadioGW radio : allRadios) {
								if (radio.GW_ID == rmsg.rStatus.gwID && radio.ID == rmsg.rStatus.rgwID)
									radio.isOnline = rmsg.rStatus.status == 1;
							}

							SM.Debug("Received from Apps -> UpdateRadioStatus(" + rmsg.rStatus.rgwID + "," + rmsg.rStatus.gwID + "," + rmsg.rStatus.status+ ")");
							if ((crtRadio != null)&&(crtRadio.GW_ID == rmsg.rStatus.gwID)&&(crtRadio.ID == rmsg.rStatus.rgwID))
								radioActivity.UpdateRadioStatus(rmsg.rStatus.status);
						}
						//incCall
						if (radioActivity != null && rmsg.incCall !=null) {
							SM.Debug("Received from Apps -> UpdateBroadcastCall(" + rmsg.incCall.Imei + "," + rmsg.incCall.callType + "," + rmsg.incCall.groupId+ ")");
							// check if radioID and radioGW_ID needs to be changed
							if (crtRadio != null && (crtRadio.GW_ID != rmsg.incCall.gwID || crtRadio.ID != rmsg.incCall.rgwID)) {
								for(RadioGW radio: allRadios) {
									if(radio.GW_ID == rmsg.incCall.gwID && radio.ID == rmsg.incCall.rgwID) {
										crtRadio = radio;
										notifyBroadcast(OperationCodes.RADIOID_CHANGED + "");
										break;
									}
								}
							}

							if(crtRadio != null) {
								if(rmsg.incCall.callStatus == 3)
									inCall = false;
								else
									inCall = true;

								radioActivity.UpdateBroadcastCall(rmsg.incCall.Imei,rmsg.incCall.callType,rmsg.incCall.groupId,rmsg.incCall.callStatus);
							}
						}
					} else {
						if (rmsg.incCall !=null) {
							crtActivity = 0;
							//incCall - update UI in Radio Activity
							SM.Debug("Received from Apps -> UpdateBroadcastCall(" + rmsg.incCall.Imei + "," + rmsg.incCall.callType + "," + rmsg.incCall.groupId+ ")");

							// check if radioID and radioGW_ID needs to be changed
							if(crtRadio != null && (crtRadio.GW_ID != rmsg.incCall.gwID || crtRadio.ID != rmsg.incCall.rgwID)) {
								for(RadioGW radio: allRadios) {
									if(radio.GW_ID == rmsg.incCall.gwID && radio.ID == rmsg.incCall.rgwID) {
										crtRadio = radio;
										notifyBroadcast(OperationCodes.RADIOID_CHANGED + "");
										break;
									}
								}
							}

							if (crtRadio != null) {
								if(rmsg.incCall.callStatus == 3) {
									inCall = false;
									// update recordings list
									if(AppParams.crtTab == AppParams.Tabs.recordings) {
										// no recording is playing
										if(recordingsActivity != null && recordingsActivity.playingPosition < 0)
											getRecordings(crtRadio.GW_ID, crtRadio.ID);
									}
								} else
									inCall = true;
								radioActivity.UpdateBroadcastCall(rmsg.incCall.Imei,rmsg.incCall.callType,rmsg.incCall.groupId,rmsg.incCall.callStatus);
							}
						}

						if(rmsg.RadioGWList!=null && radioActivity!=null)
							radioActivity.UpdateRadios(rmsg.RadioGWList);

						if(rmsg.zac !=null && radioActivity!=null) {
							radioActivity.UpdateZoneCH(rmsg.zac.rgwID, rmsg.zac.gwID, rmsg.zac.zoneNr, rmsg.zac.channelNr);
						}

						if(rmsg.rStatus !=null && radioActivity!=null) {
							// update status in the allRadio List
							for(RadioGW radio: allRadios) {
								if(radio.GW_ID == rmsg.rStatus.gwID && radio.ID == rmsg.rStatus.rgwID)
									radio.isOnline = (rmsg.rStatus.status == 1 ? true : false);
							}

							if ((crtRadio != null)&&(crtRadio.GW_ID == rmsg.rStatus.gwID)&&(crtRadio.ID == rmsg.rStatus.rgwID))
								radioActivity.UpdateRadioStatus(rmsg.rStatus.status);
						}
					}

					// save RadioList
					if (rmsg.RadioGWList!=null) {
						allRadios = rmsg.RadioGWList;
						if (crtRadio == null) {
							crtRadio = allRadios.get(0);
							SM.Debug("rmsg set 0 crtRadio GW_ID:"+crtRadio.GW_ID+" ID:"+crtRadio.ID+")");
							notifyBroadcast(OperationCodes.RADIOID_CHANGED+"");
						}
					}

					// save crt Radio ID and GW
					if (rmsg.zac !=null) {
						for (RadioGW radio: allRadios) {
							if (radio.GW_ID == rmsg.zac.gwID && radio.ID == rmsg.zac.rgwID)
								crtRadio = radio;
						}
					}

					if (AppParams.crtTab == AppParams.Tabs.recordings) {
						if (recordingsActivity != null && rmsg.RadioGWList!=null) {
							SM.Debug("GetRecordings Request + crtRadio:"+ crtRadio.toString());
							getRecordings(crtRadio.GW_ID, crtRadio.ID);
						}
					}
				 }

				// used when a unit is enabled / disabled
				if (rmsg.suStatus !=null) {
					SM.Debug("ENABLED/DISABLED " + rmsg.suStatus);
					notifyBroadcast(OperationCodes.UNIT_STATUS_UPDATE+"", rmsg.suStatus.imei + "#" +rmsg.suStatus.status);
				} else
					SM.Debug("SUStatus is null");
			}

			@Override
			public void alarmLiveRecv(TCPEvent event) {
				TCPmsg msg= event.msg();
				SM.Debug("Got alarmNew :" + msg.allData);
			
				String[] tempArr =msg.data.split("#");
				SM.Debug("Unit imei:" + tempArr[0]);
				String UnitIMEI =tempArr[0];

				//list for SMS
				if (AppParams.crtTab == AppParams.Tabs.alarms) {
					SM.Debug("currentActivity instanceof AlarmActivity - NewSMS | " + tempArr[0] + " | " + tempArr[1]);
					getAlarms(AppParams.USERID);
				}				
				// if tab is not TextTab
				if (tabHost.getCurrentTab() != 5) {
					// change Visual Elements
					setImei(UnitIMEI);
					switch (msg.opCode) {
			            case 135: setMess("speed "+tempArr[1]);
			            break;
			            case 136: setMess("landmark "+tempArr[1]);
			            break;
			            case 137: setMess("zone "+tempArr[1]);
			            break;			           
			            case 138: setMess("emergency");
			            break;
			            case 140: setMess("telemetry "+ tempArr[1]);
			            break;
			            default:
			            	setMess("emergency");
			        }					
					myHandler.post(UpdateResultsAlarm);
					
					if ((msg.opCode==138)&&(AppParams.crtTab == AppParams.Tabs.live)) {
						if(getSuperVehHash().get(Long.parseLong(UnitIMEI)) != null) {
							//if is not check i need to force check to put on the map
							Boolean forceChecked =false;
							if (!getSuperVehHash().get(Long.parseLong(UnitIMEI)).needUpdate) {
								getSuperVehHash().get(Long.parseLong(UnitIMEI)).needUpdate =true;
								forceChecked =true;
							}														
							try {
								int x = 0;
								if (forceChecked) {
									for (Vehicle veh : getAllVehicle()) {
										if (veh.imei.compareTo(UnitIMEI)==0) break;
										x++;
									}									 								
								} else
									x = -1;
								if (liveActivity != null) {
									if (x!= getAllVehicle().size())
										liveActivity.emergencyAlarmReceived(x , getSuperVehHash().get(Long.parseLong(UnitIMEI)).lat, getSuperVehHash().get(Long.parseLong(UnitIMEI)).lng);
									else
										liveActivity.emergencyAlarmReceived(-1, getSuperVehHash().get(Long.parseLong(UnitIMEI)).lat, getSuperVehHash().get(Long.parseLong(UnitIMEI)).lng);
								}
					        } catch (Exception ex) {
					        	SM.Debug("Error load hash: "+ ex);
							}																		
						}
					}
				}
			}

			@Override
			public void onRecordingsListReceived(TCPEvent event) {
				TCPmsg msg= event.msg();				
				RecordMSG Records= new RecordMSG(msg);							
				SM.Debug("am primit lista cu Recording");
				
				//list for SMS
				if (AppParams.crtTab == AppParams.Tabs.recordings) {
					for(Recording rec: Records.recordList) {
						// set the name to be displayed 
						if (rec.typeID == 1)
							rec.NameForDisplay = AppParams.USERNAME;						
						else {			
							if (getSuperVehHash().get((long)rec.subID)!=null)
								rec.NameForDisplay = getSuperVehHash().get((long)rec.subID).name;
						}
					}
					// save recodings to AppParams
					AppParams.recordings = Records.recordList;

					// notify recordings were received
					notifyBroadcast(OperationCodes.RECORDINGS_LIST_REP + "");
				}
			}

			@Override
			public void onConnectionReplyReceived(TCPEvent event) {

			}

			@Override
			public void onContactsListReceived(TCPEvent event) {
				// TODO Auto-generated method stub
			}

			@Override
			public void onTextMessagesListReceived(TCPEvent event) {
				// TODO Auto-generated method stub
			}

			@Override
			public void onTCPConnectionDown(boolean previousConnectionWasUP) {
				// execute logout
				whenBackPressed(AppParams.ActivityResult.tcpDown);
				
				// send a broadcast
				notifyBroadcast(OperationCodes.TCP_CONNECTION_DOWN + "");
			}

			@Override
			public void onTCPConnectionUp(boolean previousConnectionWasUP) {
				
			}

			@Override
			public void onTCPConnectionStatusReceived(boolean isConnectionUp, boolean previuosWasConnectionUp) {
				
			}

			@Override
			public void onPONGReceived() {
				
			}
        });
	}
	
    // Create runnable for posting
    final Runnable UpdateResultsAlarm = () -> updateResultsAlarmInUi("realpha");
    
    public void updateResultsAlarmInUi(String animation) {
        // Back in the UI thread
        // set TextViews
    	if(tcp!=null && !AppParams.DEMO) {
    		try {
	    		activePopupType= MsgType.ALARM;
	    		imageViewPopUp.setImageResource(R.drawable.siren_on);
		    	slideTabsText.setText(getString(R.string.newAlarm));
		    	if (getVehicle4Imei(getImei())!=null)
		    		textViewNMFrom.setText(getString(R.string.from) + ": " + getVehicle4Imei(getImei()).name);
		    	else textViewNMFrom.setText(getString(R.string.from) + ": " + getImei());
				textViewNMMessage.setText("TYPE: " + getMess());
				// show layout
				layoutNewMessage.setVisibility(View.VISIBLE);
				
				Animation anim = AnimationUtils.loadAnimation(this, R.anim.alpha);
				if(animation.equals("realpha"))
					anim = AnimationUtils.loadAnimation(this, R.anim.realpha);
		        anim.reset();
		        layoutNewMessage.clearAnimation();
		        layoutNewMessage.startAnimation(anim);
		        
		        // create Notification
	            createNotification(AppParams.alertNotif);
    		} catch (Exception ex) {
    			SM.Debug("Erorr on update alarm:"+ ex);
    		}
    	}
    }
    
    
    // Create runnable for posting
    final Runnable UpdateResultsPoll = () -> updateResultsPollInUi("realpha");
    
    public void updateResultsPollInUi(String animation) {
        // Back in the UI thread
        // set TextViews
    	String from = "";
    	Vehicle fromVehicle;
    	if ((fromVehicle = getVehicle4Imei(getImei())) != null)
    		from = fromVehicle.name;
    	
    	if (tcp!=null && !AppParams.DEMO) {
    		activePopupType =MsgType.POLL;
    		imageViewPopUp.setImageResource(R.drawable.poll);
	    	slideTabsText.setText("Poll Reply");
			textViewNMFrom.setText("From: " + from);
			textViewNMMessage.setText(getMess());
			// show layout
			layoutNewMessage.setVisibility(View.VISIBLE);
			
			Animation anim = AnimationUtils.loadAnimation(this, R.anim.alpha);
			if(animation.equals("realpha"))
				anim = AnimationUtils.loadAnimation(this, R.anim.realpha);
	        anim.reset();
	        layoutNewMessage.clearAnimation();
	        layoutNewMessage.startAnimation(anim);
    	} else if (AppParams.DEMO) {
    		activePopupType =MsgType.POLL;
    		imageViewPopUp.setImageResource(R.drawable.poll);
	    	slideTabsText.setText("Poll Reply");
			textViewNMFrom.setText("From: " + from);
			textViewNMMessage.setText(getMess());
			// show layout
			layoutNewMessage.setVisibility(View.VISIBLE);
    	}
    	
    	// create Notification
        createNotification(AppParams.pollNotif);
    }
        
	// Create runnable for posting
    final Runnable UpdateResults = () -> updateResultsInUi("realpha");
            
    public void updateResultsInUi(String animation) {
        // Back in the UI thread
        // set TextViews
    	if(tcp!=null && !AppParams.DEMO) {
    		activePopupType = MsgType.SMS;
    		imageViewPopUp.setImageResource(R.drawable.message);
	    	slideTabsText.setText("New Message");
			textViewNMFrom.setText("From: " + getVehicle4Imei(getImei()).name);
			textViewNMMessage.setText("MSG: " + getMess());
			// show layout
			layoutNewMessage.setVisibility(View.VISIBLE);
			
			Animation anim = AnimationUtils.loadAnimation(this, R.anim.alpha);
			if(animation.equals("realpha"))
				anim = AnimationUtils.loadAnimation(this, R.anim.realpha);
	        anim.reset();
	        layoutNewMessage.clearAnimation();
	        layoutNewMessage.startAnimation(anim);
    	} else if(AppParams.DEMO) {
    		setMess("i got your sms");
    		activePopupType = MsgType.SMS;
    		imageViewPopUp.setImageResource(R.drawable.message);
	    	slideTabsText.setText("New Message");
			textViewNMFrom.setText("From: " + getVehicle4Imei(getImei()).name);
			textViewNMMessage.setText("MSG: " + "i got your sms");
			// show layout
			layoutNewMessage.setVisibility(View.VISIBLE);
			
			 // create Notification
            createNotification(AppParams.messageNotif);
    	}
    	
    	// create Notification
        createNotification(AppParams.messageNotif);
    }

    public void createNotification(int icon) {
    	mNotificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
		String tickerText = "SafeMobile Dispatch: New Message  from " + getImei();
		String contentTitle = "New Message from " + getImei();
		String contentText = "\"" + getMess() + "\"";
		
		Vehicle veh = getVehicle4Imei(getImei());
		
		int icon_value = icon;
		switch(icon) {
			case AppParams.messageNotif: 
					contentText = "\"" + getMess() + "\"";
		    		contentTitle = "New Message from " + getImei();
		    		icon = R.drawable.message;
		    		break;
			case AppParams.pollNotif: 
					contentText = "\"" + getMess() + "\"" ;
		    		contentTitle = "Poll Reply from " + (veh !=null ? getVehicle4Imei(getImei()).name : getImei());
					tickerText = "SafeMobile Dispatch: Poll Reply from " + (veh !=null ? getVehicle4Imei(getImei()).name : getImei());
					icon = R.drawable.poll;
					break;
			case AppParams.alertNotif:
					String vehName = getString(R.string.from) + ": " + getImei();
					if(veh!=null)
						vehName = getString(R.string.from) + ": " + (veh !=null ? getVehicle4Imei(getImei()).name : getImei());
					contentText ="\"" + getMess() + "\"";
					contentTitle = getString(R.string.newAlarm) + vehName;
					tickerText = "SafeMobile Dispatch: " + getString(R.string.newAlarm) + vehName;
					icon = R.drawable.alert;
					break;
		}
		
		Notification notification = new Notification(icon, tickerText, System.currentTimeMillis());
		
		// set intent to be opened on NotificationClick
				notificationIntent = new Intent(this, NotificationActivity.class);
				notificationIntent.putExtra("key", icon_value);
		
		// cancel old notification
		mNotificationManager.cancel(icon);
		
		PendingIntent contentIntent = PendingIntent.getActivity(context, NOTIFICATION_ACTIVITY_RESULT, notificationIntent, PendingIntent.FLAG_CANCEL_CURRENT);
		//notification.setLatestEventInfo(context, contentTitle, contentText, contentIntent);
		
		//notification.defaults |= Notification.DEFAULT_SOUND;
		// flag that the notification will be closed when clicked
    	notification.flags |= Notification.FLAG_AUTO_CANCEL;
    	//notification.number = notificationNr++;				// used for multiple notification (different numbers)
    	notification.number = 1;								// the same notification will be shown;
    	notification.tickerText = tickerText;		// notification text when arrives
    	notification.sound = Uri.parse("android.resource://" + getPackageName() + "/" + R.raw.new_sms );
    	// add notification to the manager
    	mNotificationManager.notify(icon, notification);
    }
    
    
    // return vehicle according to imei
    private Vehicle getVehicle4Imei(String imei) {
		Vehicle veh = null;
		for(Vehicle vehicle: getAllVehicle())
			if(vehicle.imei.equals(imei))
				veh = vehicle;
		return veh;
	}
	

    @Override
    public void enableMenuButtons(boolean enable) {
    	if (enable) {
    		buttonAlarms.setEnabled(true);
    		buttonHistory.setEnabled(true);
    		buttonLive.setEnabled(true);
    		buttonRecordings.setEnabled(true);
    		buttonText.setEnabled(true);
    		buttonRadio.setEnabled(true);
    		buttonSetup.setEnabled(true);
    	} else {
    		// disable all buttons
    		buttonAlarms.setEnabled(false);
    		buttonHistory.setEnabled(false);
    		buttonLive.setEnabled(false);
    		buttonRecordings.setEnabled(false);
    		buttonText.setEnabled(false);
    		buttonRadio.setEnabled(false);
    		buttonSetup.setEnabled(false);
    	}
    }
    
    // load settings
    public void loadSettings() {
        try {
        	// get Preferences for SafeDispatch
        	AppParams.prefs = getSharedPreferences(getPackageName(), MODE_PRIVATE);
        	// get default IP
        	AppParams.IP = AppParams.prefs.getString("ip", "n/a");
        	// get default communication port
        	AppParams.PORT = AppParams.prefs.getString("port", "n/a");
        	// get default language
        	AppParams.LANGUAGE =  AppParams.prefs.getString("language", "en");
        	
        	SM.Debug("PORT: " + AppParams.PORT + "  |  IP: " + AppParams.IP);
    	} catch(Exception ex) {
        	Log.e("Exception", "loadSettings exception");
        }
	}
    
    @Override
	public double best_zoom(double latMax, double latMin, double lngMax, double lngMin) {
        double height =400;
        double width =400;
	    double dlat = Math.abs(latMax - latMin);
	    double dlon = Math.abs(lngMax - lngMin);
	    if(dlat == 0 && dlon == 0) {
	    	if ((latMax == latMin)&&(latMax ==0)&&(lngMax == lngMin)&&(lngMax ==0)) return 2;
	    }

	    // Center latitude in radians 
	    double clat = Math.PI*(latMin + latMax)/360.;

	    double C = 0.0000107288; 
	    double z0 = Math.ceil(Math.log(dlat/(C*height))/0.693); 
	    double z1 = Math.ceil(Math.log(dlon/(C*width*Math.cos(clat)))/0.693); 

	    return (z1 > z0) ? (17-z1) : (17-z0); 
	}

	//callType:
	//101 -allcall init
	//111 -allcall stop
	//102 -prvcall init
	//112 -prvcall stop
	//103 -grpcall init
	//113 -grpcall stop
	public void SendPTT(int callType, int id, int gwID, int rgwid, long userID) {
		if(tcp!= null) {
			try {
				Thread.sleep(300);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			boolean res = tcp.Write("0.0", "#30#"+callType+"#"+gwID+"."+rgwid+"." + id+"#"+userID+"#");
			if(res){
				SM.Debug("Message (SendPTT) sent to app server");
			} else {
				SM.Debug("Could not send message(SendPTT)!!");
			}
		}
    }	
	
	
	protected class ConnectTask extends AsyncTask<String, Void, TCPhandler> {
		@Override
		protected TCPhandler doInBackground(String... params) {

			switch(Integer.parseInt(params[0])) {
				case OperationCodes.TCP_CONNECTION_REQ:

					SM.Exception("TCP CONNECTION REQ!!!");
					if(myService!= null) {
						tcp = myService.getTCPConnection();
						SM.Exception("TCP is not null!!!");
					}
					break;

				case OperationCodes.GetVehicles:
					getVehicles(Integer.parseInt(params[1]));
					break;

				case OperationCodes.GetRadiosList:
					getRadiosList();
					break;

				case OperationCodes.GetLastPositions:
					getLastPositions(Integer.parseInt(params[1]));
					break;

				case OperationCodes.GetLastSMS:
					getLastSMSs(Integer.parseInt(params[1]));
					break;

				case OperationCodes.GetRecentSMSs:
					try
					{
						Long.parseLong(params[2]);
					}
					catch (Exception ignored) {

					}
					getRecentSMSs(Integer.parseInt(params[1]), Long.parseLong(params[2]));
					break;

				case OperationCodes.SEND_TM:
					sendSMS(params[1], Integer.parseInt(params[2]), params[3]);

				case OperationCodes.Option4Unit:
					try {
						SM.Debug(params[1] + " | " + params[2] + " | " + params[3] + " | " + params[4]);

						setVehicleStatus(Integer.parseInt(params[1]), Integer.parseInt(params[2]), Integer.parseInt(params[3]), Integer.parseInt(params[4]));
					}
					catch(Exception ex) { SM.Exception("Paramas -> setVehicleStatus","EXCeption ex " + ex.toString()); }
					break;

				case OperationCodes.GetAlarms:
					getAlarms(Integer.parseInt(params[1]));
					break;

				case OperationCodes.SendAlarmAcknoledge:
					sendAlarmAcknowledge(Integer.parseInt(params[1]), Integer.parseInt(params[2]), params[3]);
					break;

				case OperationCodes.GetHistoryPositions:
					getHistoryPositions(Integer.parseInt(params[1]), Long.parseLong(params[2]), Long.parseLong(params[3]));
					break;
			}
			return null;
		}
	}
	
	@Override
	public void executeNetworkStuff(String [] params) {
			new ConnectTask().execute(params);
	}
	
	public class connectParserTask extends AsyncTask<String, Void, TCPhandler>
	{
		@Override
		protected TCPhandler doInBackground(String... params) {
			if(myService!= null)
				tcpParser = myService.getTCPmsgParser();
			
			SM.Debug("connectParserTask","tcpParser is : " + tcpParser == null ? "null" : "not null");
			// add TCPParserListener
			if(tcpParser!=null)
			{
				SM.Debug("## tcpParser != null ", "#### call tcpParserListener(") ;
				tcpParserListener();
			}
			return null;
		}
	}
	
	 /* Display Toast messages*/
    @Override
    public void displayToast(final String msg) {
    	myHandler.post(() -> Toast.makeText(context, msg, Toast.LENGTH_SHORT).show());
    }


	@Override
	public void setRadioActivity(AbstractRadioActivity radioActivity) {
		//this.radioActivity = radioActivity;
	}


	@Override
	public void setLiveActivity(AbstractLiveActivity liveActivity) {
		this.liveActivity = liveActivity;
	}


	@Override
	public void setMessagesActivity(AbstractMessagesActivity messageActivity) {
		//this.messageActivity = messageActivity;
	}


	@Override
	public void unregisterReceivers(BroadcastReceiver receiver) {
		if(mReceiver!=null)
			this.unregisterReceiver(receiver);
	}


	@Override
	public void cancelNotification(int drawable) {
		if(mNotificationManager!=null)
			mNotificationManager.cancel(drawable);
	}


	@Override
	public void stopTCP() {
		if(tcp != null)
			tcp.Stop();
	}


	@Override
	public void stopTCPParser() {
		if(tcpParser != null)
			tcpParser.Stop();
	}

	@Override
	public void recreateTCPConnection() {
		if(!AppParams.DEMO) {
			if(tcpParser!=null)
				tcpParser.clearMsgList();

			myHandler.post(() -> {
				if(myService != null) {
					myService.stopTCPConnection();
					myService.recreateTCPConnection();
					new ConnectTask().execute(new String[] {OperationCodes.TCP_CONNECTION_REQ + ""});

					// add a new ITCPListener
					tcpParser();
				}
				SM.Debug("RECREATE TCP","IP: " + AppParams.IP + "  |   Port: " + AppParams.PORT);
			});
		}
	}
	
	@Override
	public void removeITCPListener() {
		if(tcpParser != null)
			tcpParser.clearITCPListeners();
	}
	
	
	/** send a message to be broadcasted  when a specific event happens
	 *  every listener that is registered to the broadcast will be notified of these event
	 *  @param action The type of action which will be notified
	 *  @param object The object which will be passed through the intent
	 */
	private void notifyBroadcast(String action) {
		Intent intent = new Intent();
		intent.setAction(action);
		getBaseContext().sendBroadcast(intent);
	}
	
	// send a message to be broadcasted  when a specific event happens
	// every listener that is registered to the broadcast will be notified of these event 
	private void notifyBroadcast(String action, Object object) {
		Intent intent = new Intent();
		intent.setAction(action);
		if(action.equals(OperationCodes.UNIT_STATUS_UPDATE + ""))
			intent.putExtra("unitStatus", (String)object);
		else if(action.equals(OperationCodes.BLUETOOTH_TETHER + ""))
			intent.putExtra("tether", Boolean.parseBoolean((String)object));
		else
			intent.putExtra("extra", new SerializedObject(object, action));
		getBaseContext().sendBroadcast(intent);
	}
}