<?php
	require_once('CommentRepositoryInterface.php');
	require_once(dirname(__FILE__).'/../classes/Comment.php');
	require_once(dirname(__FILE__)."/../constants.php");
	require_once(dirname(__FILE__)."/../utilities.php");

	class CommentRepository implements CommentRepositoryInterface {
		protected $db;

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

		public function addComment($comment) {
			$status = array();

			$queryComment = "INSERT INTO commenti(id_locale, id_user, voto, descrizione, data)
    				VALUES ('".$comment->id_locale."',
    						'".$comment->id_user."',
    						'".$comment->voto."',
    						'".$comment->descrizione."',
    						'".$comment->data."')";

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

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

			try {
				$this->db->exec($queryComment);
				$id_commento = $this->db->lastInsertId();

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

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

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

				$status["id"] = $id_commento;
				$status["return"] = 0;

				return $status;

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

				return $status;
			}
		}

		public function countComments($id_local) {
			$countQuery = "SELECT count(*) as count FROM commenti WHERE id_locale=".$id_local;
			try {
				$result = $this->db->query($countQuery);
				return (!$result || $result->rowCount()==0) ? 0 : $result->fetchColumn();
			} catch (PDOException $e) {
				echo $e->getMessage();
				return null;
			}
		}

		public function getComments($id_local, $start_index, $length) {
			/* query SQL da eseguire
				SELECT id_commento, id_locale, id_user, voto, descrizione, data, img
				FROM commenti, immagini_commenti
				WHERE commenti.id=immagini_commenti.id_commento AND id_locale=$id_local
				LIMIT $start_index, $length
			*/

			$comment_id_list = array();
			$comment_list = array();
			$queryComments;

			$sqlComments = "SELECT id
							FROM commenti
							WHERE id_locale=".$id_local."
							LIMIT ".$start_index.",".$length;

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

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

				if (!$query || $query->rowCount()==0) return $comment_list;

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

				foreach ($rows as $row) {
					array_push($comment_id_list, $row["id"]);
				}

				$sqlImgs = "SELECT c.id AS id_commento, id_locale, id_user, voto, descrizione, data, img, username
								FROM commenti as c
								LEFT JOIN immagini_commenti as i ON c.id=i.id_commento
                                JOIN utente as u ON c.id_user=u.id
                                WHERE c.id IN (".implode(",", $comment_id_list).")";

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


				$query = $this->db->query($sqlImgs);

				if (!$query) return null;

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

				foreach ($rows as $row) {
					$comment_id = $row["id_commento"];

					$imgRow = (!is_null($row["img"])) ? IMAGES_PATH.$row["img"] : null;

					if (!array_key_exists($comment_id, $comment_list)) {
						$new_comment = new Comment();
						$new_comment->id 			= $comment_id;
						$new_comment->id_locale 	= $id_local;
						$new_comment->id_user 		= $row["id_user"];
						$new_comment->username 		= $row["username"];
						$new_comment->voto 			= $row["voto"];
						$new_comment->descrizione 	= $row["descrizione"];
						$new_comment->data 			= $row["data"];
						$new_comment->imgs 			= (!is_null($imgRow)) ? array($imgRow) : array();

						$comment_list[$comment_id] = $new_comment;
					} else if (!is_null($imgRow)) {
						array_push($comment_list[$comment_id]->imgs, $imgRow);
					}

				}

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

		}

		public function getImages($id_comment) {
			$comment = new Comment();
			$query;

			$sql = "SELECT img 
						FROM immagini_commenti 
						WHERE id_commento=".$id_comment;

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

				if (!$query) return null;

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

				$comment->imgs = array();

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

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

		/*public function addImage($id_comment, $img) {
			$sql = "INSERT INTO immagini_commenti(id_commento, img)
							VALUES (".$id_comment.",'".$img."')";

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

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

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

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

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

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

	}

?>