<?php
	require_once('LocalRepositoryInterface.php');
	require_once(dirname(__FILE__).'/../classes/Local.php');
	require_once(dirname(__FILE__)."/../utilities.php");

	class LocalRepository implements LocalRepositoryInterface {
		protected $db;

		public function __construct($db) {
			$this->db = $db;
		}

		public function registerLocal($local) {
			$status = array();

			$queryLocal = "INSERT INTO locale(id_utente_owner, nomelocale, descrizione, tipologia, lat, lon, indirizzo, email, telefono, sito, n_punti_ricarica)
    				VALUES ('".$local->id_utente_owner."',
    						'".$local->nomelocale."',
    						'".$local->descrizione."',
    						'".$local->tipologia."',
    						'".$local->lat."',
    						'".$local->lon."',
    						'".$local->indirizzo."',
    						'".$local->email."',
    						'".$local->telefono."',
    						'".$local->sito."',
    						'".$local->n_punti_ricarica."')";
			
			//echo "<br/>".$query."<br/>";

			$imgs = $local->imgs;
			$imgsToInsert = array();

			try {
				$this->db->exec($queryLocal);
				$id_locale = $this->db->lastInsertId();

				$queryUser = "UPDATE utente SET is_owner=1 WHERE id=".$local->id_utente_owner;				

				/*foreach($imgs as $img) {
					$imgsToInsert[] = '("'.$id_locale.'", "'.$img.'")';
				}

				$queryImgs = "INSERT INTO immagini_locali(id_locale, img) VALUES" . implode(',', $imgsToInsert);

				$this->db->exec($queryImgs);*/

				$this->db->exec($queryUser);

				$status["local_id"] = $id_locale;
				$status["return"] = 0;

				return $status;

			} catch (PDOException $e) {
				echo $e->getMessage();
				$status = createErrorMessage(3, "Errore DB");
				$status["local_id"] = -1;
				//$status["return"] = 3;

				return $status;
			}
		}

		public function setLocalPosition($id_local, $lat, $lon, $indirizzo) { //deprecata
			$query = "UPDATE locale
						SET lat=".$lat.",lon=".$lon.",indirizzo='".$indirizzo."'".
						"WHERE id=".$id_local;

			//echo "<br/>".$query."<br/>";

			try {
				return $this->db->exec($query);
			} catch (PDOException $e) {
				echo $e->getMessage();
				return -1;
			}		
		}

		public function setLocalName($id_local, $name) { //deprecata
			$query = "UPDATE locale
						SET nomelocale='".$name."'".
						"WHERE id=".$id_local;

			//echo "<br/>".$query."<br/>";

			try {
				return $this->db->exec($query);
			} catch (PDOException $e) {
				echo $e->getMessage();
				return -1;
			}		
		}

		public function setLocalDescription($id_local, $description) { //deprecata
			$query = "UPDATE locale
						SET descrizione='".$description."'".
						"WHERE id=".$id_local;

			try {
				return $this->db->exec($query);
			} catch (PDOException $e) {
				echo $e->getMessage();
				return -1;
			}		
		}

		public function editLocal($local) { //$local è l'oggetto Locale
			$status = array();

			try {

				$setString = "";

				if (isset($local->nomelocale) && !is_null($local->nomelocale)) {
					$setString = ($setString == "") ? "nomelocale='".$local->nomelocale."'" : $setString.",nomelocale='".$local->nomelocale."'";
				}

				if (isset($local->descrizione) && !is_null($local->descrizione)) {
					$setString = ($setString == "") ? "descrizione='".$local->descrizione."'" : $setString.",descrizione='".$local->descrizione."'";
				}

				if (isset($local->tipologia) && !is_null($local->tipologia)) {
					$setString = ($setString == "") ? "tipologia='".$local->tipologia."'" : $setString.",tipologia='".$local->tipologia."'";
				}

				if (isset($local->lat) && !is_null($local->lat)) {
					$setString = ($setString == "") ? "lat='".$local->lat."'" : $setString.",lat='".$local->lat."'";
				}

				if (isset($local->lon) && !is_null($local->lon)) {
					$setString = ($setString == "") ? "lon='".$local->lon."'" : $setString.",lon='".$local->lon."'";
				}

				if (isset($local->indirizzo) && !is_null($local->indirizzo)) {
					$setString = ($setString == "") ? "indirizzo='".$local->indirizzo."'" : $setString.",indirizzo='".$local->indirizzo."'";
				}

				if (isset($local->email) && !is_null($local->email)) {
					$setString = ($setString == "") ? "email='".$local->email."'" : $setString.",email='".$local->email."'";
				}

				if (isset($local->telefono) && !is_null($local->telefono)) {
					$setString = ($setString == "") ? "telefono='".$local->telefono."'" : $setString.",telefono='".$local->telefono."'";
				}

				if (isset($local->sito) && !is_null($local->sito)) {
					$setString = ($setString == "") ? "sito='".$local->sito."'" : $setString.",sito='".$local->sito."'";
				}

				if (isset($local->n_punti_ricarica) && !is_null($local->n_punti_ricarica)) {
					$setString = ($setString == "") ? "n_punti_ricarica='".$local->n_punti_ricarica."'" : $setString.",n_punti_ricarica='".$local->n_punti_ricarica."'";
				}

				$query = "UPDATE locale
							SET ".$setString."
	    					WHERE id=".$local->id;

	    		//echo "<br/>".$query."<br/>";	

				$this->db->exec($query);
				$status["return"] = 0;

			} catch (PDOException $e) {
				echo $e->getMessage();
				$risposta = createErrorMessage(1, "Errore DB");
				//$status["return"] = 1;
				return $status;
			}

			return $status;

		}

		public function getImages($id_local) {
			$local = new Local();
			$query;

			$sql = "SELECT img 
						FROM immagini_locali 
						WHERE id_locale=".$id_local;

			try {
				$query = $this->db->query($sql);

				if (!$query) return null;

				$rows = $query->fetchAll(PDO::FETCH_ASSOC);

				$local->imgs = array();

				foreach ($rows as $row) {
					array_push($local->imgs, IMAGE_SERVER.IMAGES_PATH.$row["img"]);
				}

				return $local;
			} catch (PDOException $e) {
				echo $e->getMessage();
				return null;
			}	
		}

		/*public function addImage($id_local, $imgs) {
			$sql = "INSERT INTO immagini_locali(id_locale, img)
							VALUES (".$id_local.",'".$img."')";

			try {
				$this->db->exec($sql);
				return 0;
			} catch (PDOException $e) {
				echo $e->getMessage();
				return 1;
			}
		}*/

		public function addImages($id_local, $imgs) {
			try {
				foreach($imgs as $img) {
					$imgsToInsert[] = '("'.$id_local.'", "'.$img.'")';
				}

				$queryImgs = "INSERT INTO immagini_locali(id_locale, img) VALUES" . implode(',', $imgsToInsert);
				//echo "<br/>".$queryImgs."<br/>";

				$this->db->exec($queryImgs);
				return 0;

			} catch (PDOException $e) {
				echo $e->getMessage();
				return 1;
			}
		}

		public function getMinimalLocalInfo($id_local) {
			$local = new Local();
			$queryLocal;

			$sqlLocal = "SELECT id, tipologia, descrizione, indirizzo
					FROM locale
					WHERE id=".$id_local;

			//echo "<br/>".$sql."<br/>";

			try {
				$queryLocal = $this->db->query($sqlLocal);

				if (!$queryLocal) return null;

				$rowLocal = $queryLocal->fetch(PDO::FETCH_ASSOC);

				$local->tipologia 	= $rowLocal["tipologia"];
				$local->descrizione = $rowLocal["descrizione"];
				//$local->stelle 		= $row["stelle"];
				$local->indirizzo	= (!is_null($rowLocal["indirizzo"])) ? $rowLocal["indirizzo"] : "";

				$sqlStelle = "SELECT avg(commenti.voto) as stelle
								FROM commenti
								WHERE commenti.id_locale=".$id_local."
								GROUP BY commenti.id_locale";

				$resultStelle = $this->db->query($sqlStelle);

				$local->stelle 	= ($resultStelle->rowCount()>0) ? $resultStelle->fetchColumn() : 0;

				return $local;

			} catch (PDOException $e) {
				echo $e->getMessage();
				return null;
			}
		}

		public function getFullLocalInfo($id_local) {
			$local = new Local();
			$queryLocal;

			$sqlLocal = "SELECT l.id as id, l.id_utente_owner as id_utente_owner, u.username as username_owner,
							l.nomelocale as nomelocale, l.descrizione as descrizione, l.tipologia as tipologia,
							l.lat as lat, l.lon as lon, l.indirizzo as indirizzo, l.email as email,
							l.telefono as telefono, l.sito as sito, l.n_punti_ricarica as n_punti_ricarica
					FROM locale l ,utente u
					WHERE l.id=".$id_local." AND u.id=l.id_utente_owner";

			//echo "<br/>".$sql."<br/>";

			try {
				$queryLocal = $this->db->query($sqlLocal);

				if (!$queryLocal) return null;

				$rowLocal = $queryLocal->fetch(PDO::FETCH_ASSOC);

				$local->id 						= $rowLocal["id"];
				$local->id_utente_owner			= $rowLocal["id_utente_owner"];
				$local->username_owner			= $rowLocal["username_owner"];
				$local->nomelocale 				= $rowLocal["nomelocale"];
				$local->descrizione 			= $rowLocal["descrizione"];
				$local->tipologia 				= $rowLocal["tipologia"];
				$local->lat 					= $rowLocal["lat"];
				$local->lon 					= $rowLocal["lon"];
				$local->indirizzo				= (!is_null($rowLocal["indirizzo"])) ? $rowLocal["indirizzo"] : "";
				$local->email 					= $rowLocal["email"];
				$local->telefono 				= $rowLocal["telefono"];
				$local->sito 					= $rowLocal["sito"];
				$local->n_punti_ricarica		= $rowLocal["n_punti_ricarica"];

				$sqlStelle = "SELECT avg(commenti.voto) as stelle
								FROM commenti
								WHERE commenti.id_locale=".$id_local."
								GROUP BY commenti.id_locale";

				//echo "<br/>".$sqlStelle."<br/>";

				$resultStelle = $this->db->query($sqlStelle);

				$local->stelle 	= ($resultStelle->rowCount()>0) ? $resultStelle->fetchColumn() : 0;

				return $local;

			} catch (PDOException $e) {
				echo $e->getMessage();
				return null;
			}
		}

		public function deleteImage($id_local, $img) {
			$sql = "DELETE FROM immagini_locali WHERE id_locale=".$id_local." AND img='".$img."'";
			try {
				$this->db->exec($sql);
				return 0;
			} catch (PDOException $e) {
				echo $e->getMessage();
				return 1;
			}
		}

		public function getCloseLocals($tipologia, $lat, $lon, $distance) {
			$local_list = array();

			$harvesinFormulaSQL;

			$whereClause = ($tipologia>=0) ? "WHERE tipologia='".$tipologia."' AND hidden=0" : "WHERE hidden=0";

			if ($lat==="" || $lon==="") {
				$harvesinFormulaSQL = "SELECT * FROM locale WHERE hidden=0";
			} else {
				$harvesinFormulaSQL = "SELECT id, id_utente_owner, lat, lon, indirizzo, tipologia, nomelocale, telefono, email, sito, n_punti_ricarica,
									( 6371 * acos( cos( radians(".$lat.") ) * cos( radians( lat ) ) * cos( radians( lon ) - radians(".$lon.") ) + sin( radians(".$lat.") ) * sin( radians( lat ) ) ) ) AS distance
									FROM locale
									".$whereClause."
									HAVING distance < ".$distance/1000.0."
									ORDER BY distance";
									//ORDER BY distance LIMIT 0 , 20"; //nel caso in cui si voglia introdurre il limite di locali vicini
			}

			//echo "<br/>".$harvesinFormulaSQL."<br/>";

			try {
				$query = $this->db->query($harvesinFormulaSQL);

				if (!$query) return null;

				$rows = $query->fetchAll(PDO::FETCH_ASSOC);

				foreach ($rows as $row) {
					$local = array();
					$local["id"]					= $row["id"];
					$local["id_utente_owner"]		= $row["id_utente_owner"];
					$local["lat"] 					= $row["lat"];
					$local["lon"] 					= $row["lon"];
					$local["indirizzo"]				= $row["indirizzo"];
					$local["tipologia"]				= $row["tipologia"];
					$local["nomelocale"] 			= $row["nomelocale"];
					$local["telefono"] 				= $row["telefono"];
					$local["email"] 				= $row["email"];
					$local["sito"] 					= $row["sito"];
					$local["n_punti_ricarica"]		= $row["n_punti_ricarica"];

					array_push($local_list, $local);
				}

				return $local_list;

			} catch (PDOException $e) {
				echo $e->getMessage();
				return null;
			}
		}

		public function getLocalsByUser($user_id) {
			$local_list = array();

			$sql = "SELECT id, lat, lon, indirizzo, tipologia, nomelocale, telefono, email, sito, descrizione, n_punti_ricarica
					FROM locale
					WHERE id_utente_owner=".$user_id;

			//echo "<br/>".$sql."<br/>";

			try {
				$query = $this->db->query($sql);

				if (!$query) return null;

				$rows = $query->fetchAll(PDO::FETCH_ASSOC);

				foreach ($rows as $row) {
					$local = array();
					$local["id"]				= $row["id"];
					$local["lat"] 				= $row["lat"];
					$local["lon"] 				= $row["lon"];
					$local["indirizzo"]			= $row["indirizzo"];
					$local["tipologia"]			= $row["tipologia"];
					$local["nomelocale"] 		= $row["nomelocale"];
					$local["telefono"] 			= $row["telefono"];
					$local["email"] 			= $row["email"];
					$local["sito"] 				= $row["sito"];
					$local["descrizione"] 		= $row["descrizione"];
					$local["n_punti_ricarica"] 	= $row["n_punti_ricarica"];

					array_push($local_list, $local);
				}

				return $local_list;

			} catch (PDOException $e) {
				echo $e->getMessage();
				return null;
			}
		}
	}

?>