<?php
// declare(encoding='UTF-8');
/**
 * Permet d'ajouter un commentaire.
 *
 * @category   DEL
 * @package    Services
 * @subpackage Commentaires
 * @version    0.1
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
 * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
 */

class AjouterCommentaire {

	private $conteneur;
	private $navigation;
	private $bdd;
	private $parametres = array();

	private $mapping = array();
	private $erreurs = array();

	public function __construct(Conteneur $conteneur) {
		$this->conteneur = $conteneur;
		$this->navigation =  $this->conteneur->getNavigation();
		$this->bdd = $this->conteneur->getBdd();

		$this->mapping = $this->conteneur->getParametreTableau('commentaires.mapping');
	}

	public function ajouter($parametres) {
		$this->parametres = $parametres;
		$this->verifierParametres();

		$this->completerParametresUtilisateur();
		$this->gererPropositionInitiale();
		// Dernière chance de rattachement au référentiel d'un nom 
		// sans nn (cas du copier-coller ou bien de l'appli tierce
		// qui envoie des infos incomplètes)
		$this->tenterEnrichissementTaxonomique();
		$idCommentaireAjoute = $this->insererCommentaire();

		// Mettre en forme le résultat et l'envoyer pour affichage
		$resultat = new ResultatService();
		$resultat->corps = array('id_commentaire' => $idCommentaireAjoute);

		return $resultat;
	}

	/**
	 * Vérifie notamment que l'auteur du vote est désigné soit par un ID, soit
	 * par un triplet (nom, prénom, adresse courriel)
	 */
	private function verifierParametres() {
		if (!isset($this->parametres['observation'])) {
			$this->erreurs[] = "Impossible d'ajouter un commentaire sans identifiant d'observation (paramètre 'observation').";
		}

		if (!isset($this->parametres['auteur.id'])) {
			$this->verifierParamsAuteurAnonyme();
		}

		$this->verifierParamsNonVide();

		if (isset($this->parametres['nom_sel_nn']) && !isset($this->parametres['nom_referentiel'])) {
			$this->erreurs[] = "Si le paramètre «nom_sel_nn» est présent, le paramètre «nom_referentiel» doit l'être aussi.";
		}

		if (!empty($this->erreurs)) {
			$msg = "Erreur de configuration :\n".implode("\n\n", $this->erreurs);
			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
		}
	}

	private function verifierParamsAuteurAnonyme() {
		$paramsAuteur = array('auteur.nom', 'auteur.prenom', 'auteur.courriel');
		$paramsAuteurManquant = array();
		foreach ($paramsAuteur as $param) {
			if (!isset($this->parametres[$param])) {
				$paramsAuteurManquant[] = $param;
			}
		}

		if (!empty($paramsAuteurManquant)) {
			$msgAuteurTpl = "Si le parametre 'auteur.id' n'est pas utilisé, il est nécessaire d'indiquer les ".
			"nom (paramètre 'auteur.nom'), prénom (paramètre 'auteur.prenom') et courriel ".
			"(paramètre 'auteur.courriel') de l'auteur.\nLes paramètres suivant sont abscents : %s\n";
			$this->erreurs[] = sprintf($msgAuteurTpl, implode(', ', $paramsAuteurManquant));
		}
	}

	private function verifierParamsNonVide() {
		$paramsNonVide = array('nom_sel', 'nom_referentiel', 'nom_sel_nn');
		foreach ($paramsNonVide as $param) {
			if (isset($this->parametres[$param]) && trim($this->parametres[$param]) == '' ) {
				$this->erreurs[] = "S'il est présent le paramètre «$param» ne peut pas être vide.";
			}
		}
	}

	/**
	 * Si l'auteur du vote est désigné par un ID, va chercher ses nom, prénom, courriel;
	 * s'il est désigné par un triplet (nom, prénom, adresse courriel), va chercher son ID
	 */
	private function completerParametresUtilisateur() {
		$utilisateur =  (isset($this->parametres['auteur.id'])) ? $this->obtenirUtilisateurAvecId() : $this->obtenirUtilisateurSansId();
		if ($utilisateur != false) {
			foreach ($utilisateur as $param => $valeur) {
				$this->parametres[$param] = $valeur;
			}
		}
	}

	/**
	 * On suppose que si l'utilisateur envoie sa proposition avec un ID, c'est
	 * qu'il est connu d'IP, donc qu'on trouvera ses coordonnées dans
	 * del_utilisateur_infos
	 * 
	 * @TODO valider cette hypothèse
	 */
	private function obtenirUtilisateurAvecId() {
		$auteurIdP = $this->bdd->proteger($this->parametres['auteur.id']);
		$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', courriel AS 'auteur.courriel' ".
			'FROM del_utilisateur_infos '.
			"WHERE id_utilisateur = $auteurIdP ".
			' -- '.__FILE__.' : '.__LINE__;
		$utilisateur = $this->bdd->recuperer($requete);
		return $utilisateur;
	}

	/**
	 * Pour un utilisateur désigné par un triplet (nom, prenom, adresse courriel), demande
	 * son ID à l'annuaire - vue la base de données (2017-03-24), aucun tuple ne contient
	 * une adresse courriel sans contenir d'ID, mais beaucoup ne contiennent ni l'un ni
	 * l'autre (code stupide, tentative de correction ajd)
	 */
	private function obtenirUtilisateurSansId() {
		$nomP = $this->bdd->proteger($this->parametres['auteur.nom']);
		$prenomP = $this->bdd->proteger($this->parametres['auteur.prenom']);
		$courrielP = $this->bdd->proteger($this->parametres['auteur.courriel']);

		// Si l'utilisateur s'est déjà connecté à DeL au moins une fois, on récupère ses
		// nom et prénom connus dans la base; on lui interdit d'usurper sa propre identité
		$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', ".
			"courriel AS 'auteur.courriel' ".
			'FROM del_utilisateur_infos '.
			"WHERE courriel = $courrielP ".
			' -- '.__FILE__.' : '.__LINE__;
		$utilisateur = $this->bdd->recuperer($requete);

		// si l'utilisateur n'a pas été trouvé, on devrait aller le chercher dans
		// l'annuaire, au cas où il soit inscrit à TB mais ne se soit pas connecté
		// @TODO faire un appel au service annuaire/identite-par-courriel

		return $utilisateur;
	}

	private function gererPropositionInitiale() {
		if ($this->verifierExistencePropositionInitiale() === false) {
			$this->creerPropositionInitiale();
			// TODO : en cas d'échec de la création de la proposition ajouter un log...
		}
	}

	private function verifierExistencePropositionInitiale() {
		$idObsP =  $this->bdd->proteger($this->parametres['observation']);
		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
			'FROM del_commentaire '.
			"WHERE ce_observation = $idObsP ".
			'	AND proposition_initiale = 1 '.
			' -- '.__FILE__.' : '.__LINE__;
		$resultat = $this->bdd->recuperer($requete);
		return $resultat['existe'] == 1;
	}

	private function creerPropositionInitiale() {
		$idObsP =  $this->bdd->proteger($this->parametres['observation']);

		$requete = 'INSERT IGNORE INTO del_commentaire '.
			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, utilisateur_courriel, '.
			'nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, nt, famille, nom_referentiel, date, proposition_initiale) '.
			'SELECT id_observation, ce_utilisateur, prenom_utilisateur, nom_utilisateur, courriel_utilisateur, nom_sel, '.
			"IF(nom_sel_nn = 0, NULL, nom_sel_nn), IF(nom_ret = '', NULL, nom_ret), IF(nom_ret_nn = 0, NULL, nom_ret_nn), ".
			"IF(nt = 0, NULL, nt), IF(famille = '', NULL, famille), IF(nom_sel_nn = 0, NULL, nom_referentiel), NOW(), '1' ".
			'FROM del_observation AS do '.
			"WHERE id_observation = $idObsP ".
			' -- '.__FILE__.' : '.__LINE__;

		$resultat = $this->bdd->executer($requete);

		return $resultat;
	}

	private function insererCommentaire() {
		$champs = $this->creerEnteteChamps();
		$values = $this->creerClauseValues();
		$requete = "INSERT INTO del_commentaire (date, $champs) VALUES (NOW(), $values) ".
			' -- '.__FILE__.' : '.__LINE__;

		$retour = $this->bdd->executer($requete);
		if ($retour == null) {
			$msgTpl = "Erreur inopinée lors de l'insertion du commentaire lié à l'observation «%s».";
			$msg = sprintf($msgTpl, $this->parametres['observation']);
			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
		}

		$idCommentaire = $this->bdd->recupererIdDernierAjout();
		return $idCommentaire;
	}

	private function creerEnteteChamps() {
		return $this->creerSuiteChampsOuValeurs('champs');
	}

	private function creerClauseValues() {
		return $this->creerSuiteChampsOuValeurs('valeurs');
	}

	private function creerSuiteChampsOuValeurs($mode) {
		$suite = array();
		foreach ($this->mapping as $nomChampBdd => $nomAttributSortie) {
			if (isset($this->parametres[$nomAttributSortie]) && $this->parametres[$nomAttributSortie] != null) {
				if ($mode == 'valeurs') {
					$suite[] = $this->bdd->proteger($this->parametres[$nomAttributSortie]);
				} else if ($mode == 'champs') {
					$suite[] = $nomChampBdd;
				} else {
					$msg = "Erreur interne : mauvais paramètre passé à la méthode 'creerSuiteChampsOuValeurs'";
					throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
				}
			}
		}
		return implode(', ', $suite);
	}
	
	private function tenterEnrichissementTaxonomique() {
		if($this->commentaireEstPropositionSansNn()) {
			// TODO: utiliser le référentiel de l'obs si celui-ci 
			// n'est pas fourni dans le commentaire et prendre le résultat
			// si celui-ci est unique
			$referentiel = $this->parametres['nom_referentiel'];
			$requete = urlencode($this->parametres['nom_sel']);
			
			$url = sprintf($this->conteneur->getParametre('nomstaxons.url_autocompletion_tpl'), $referentiel, $requete);
			$restClient = $this->conteneur->getRestClient();
			// Un retour vide est possible (un cas normal où il n'y a pas de résultat)
			// mais il fait planter le retour du service si on active l'affichage des erreurs
			// donc on passe sciemment les erreurs sous silence (car cette erreur n'en est pas une)
			$resultatJson = @$restClient->consulter($url);
			$resultats = json_decode($resultatJson, true);

			// On ne fait l'affectation que si l'on est sur (donc si un seul résultat)
			if (isset($resultats['resultat']) && count($resultats['resultat']) == 1) {
				$info = array_pop($resultats['resultat']);
				$this->parametres['nom_sel_nn'] = $info['num_nom'];
			}
		}
	}
	
	private function commentaireEstPropositionSansNn() {
		// Pas besoin de tester si c'est vide, normalement verifierParametres 
		// l'a déjà fait au-dessus
		return isset($this->parametres['nom_sel']) 
				&& isset($this->parametres['nom_referentiel']) 
						&& !isset($this->parametres['nom_sel_nn']);
	}
}