Subversion Repositories eFlore/Applications.del

<?php

// declare(encoding='UTF-8');

/**

 * Web service permetant d'ajouter ou de modifier les votes associés aux propositions d'une observation.

 *

 * @category   DEL

 * @package    Services

 * @subpackage Observations

 * @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 VoteObservation {

	private $conteneur;

	private $bdd;

	private $navigation;

	private $mapping;

	private $ressources;

	private $parametres;

	public function __construct(Conteneur $conteneur = null) {

		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;

		$this->bdd = $this->conteneur->getBdd();

		$this->navigation = $conteneur->getNavigation();

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

	}

	public function consulter($ressources, $parametres) {

		$this->ressources = $ressources;

		$this->parametres = $parametres;

		$votes = $this->chargerVotes();

		$this->conteneur->getNavigation()->setTotal(count($votes));

		// Mettre en forme le résultat et l'envoyer pour affichage

		$resultat = new ResultatService();

		$resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => $votes);

		return $resultat;

	}

	private function chargerVotes() {

		$idCommentaireP = $this->bdd->proteger($this->ressources[1]);

		$requete = 'SELECT * '.

			'FROM del_commentaire_vote '.

			"WHERE ce_proposition = $idCommentaireP ";

			' -- '.__FILE__.':'.__LINE__;

		$resultats = $this->bdd->recupererTous($requete);

		$votes = array();

		foreach ($resultats as $vote) {

			$votes[$vote['id_vote']] = $this->formaterVotes($vote);

			$utilisateur = $this->chercherUtilisateur($vote['ce_utilisateur']);

			if ($utilisateur && count($utilisateur) > 0) {

				$votes[$vote['id_vote']] = array_merge($votes[$vote['id_vote']], $utilisateur);

			}

		}

		return $votes;

	}

	private function formaterVotes($vote) {

		$retour = array();

		foreach ($vote as $param => $valeur) {

			$retour[$this->mapping[$param]] = $valeur;

		}

		return $retour;

	}

	/**

	 * Recherche les coordonnées d'un utilisateur en fonction de son ID;

	 * puisqu'il a un ID c'est qu'il est connecté, on suppose donc qu'il

	 * a un tuple dans del_utilisateur_infos

	 *

	 * @TODO vérifier cette hypothèse

	 */

	private function chercherUtilisateur($id) {

		// par défaut, pas d'info

		$utilisateur = array();

		// Si l'id utilisateur est un hash de session, on ne cherche rien

		if (is_numeric($id)) {

			$idUtilisateurP = $this->bdd->proteger($id);

			$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', ".

				'FROM del_utilisateur_infos '.

				"WHERE id_utilisateur = $idUtilisateurP ".

				' -- '.__FILE__.':'.__LINE__;

			$utilisateur = $this->bdd->recuperer($requete);

		}

		return $utilisateur;

	}

	public function ajouter($ressources, $parametres) {

		$this->ressources = $ressources;

		$this->parametres = $parametres;

		$this->verifierParametresAjoutModif();

		$idVote = $this->ajouterVote();

		if ($idVote) {

			$resultat = new ResultatService();

			$resultat->corps = array('id_vote' => $idVote);

			return $resultat;

		}

		return false;

	}

	private function ajouterVote() {

		$idProposition = $this->creerPropositionDeterminationInitiale();

		$idObsP = $this->bdd->proteger($this->ressources[0]);

		$idPropositionP = $this->bdd->proteger($idProposition);

		$idUtilisateurP = $this->bdd->proteger($this->parametres['utilisateur']);

		$valeurP = $this->bdd->proteger($this->parametres['valeur']);

		$requete = 'INSERT INTO del_commentaire_vote (ce_proposition , ce_utilisateur , valeur , date) '.

			"VALUES ($idPropositionP, $idUtilisateurP, $valeurP, NOW()) ".

			' -- '.__FILE__.' : '.__LINE__;

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

		if ($resultat === false) {

			$msg = "Un problème est survenu lors de l'ajout d'un vote.";

			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);

		} else if ($resultat === 0) {

			$msg = "Aucun vote ne correspond au critères fournis : ".

				"idObs -> $idObsP, idProposition -> $idPropositionP et id_utilisateur -> $idUtilisateurP.";

			throw new Exception($msg, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);

		}

		// ATTENTION : idVote doit être récupéré avant toute nouvelle requete !

		$idVote = $this->bdd->recupererIdDernierAjout();

		$requete = "UPDATE tb_new_cel.`occurrence` join

	(SELECT ce_observation, id_commentaire, nom_sel_nn, `proposition_retenue` FROM `del_commentaire` WHERE id_commentaire = ".$idPropositionP.") c

	on id = ce_observation AND user_sci_name_id= `nom_sel_nn`

	SET `identiplante_score`= case

		when ".$this->parametres['valeur']." = 0 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) -3

		when ".$this->parametres['valeur']." = 0 then ifnull(identiplante_score, 0) -1

		when ".$this->parametres['valeur']." = 1 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) + 3

		when ".$this->parametres['valeur']." = 1 then ifnull(identiplante_score, 0) + 1 END;";

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

		return $idVote;

	}

	/** Si l'identifiant de proposition vaut 0, c'est un vote sur une proposition

	 * fabriquée à partir de l'observation originale, dont on doit obtenir l'id

	 * (cas où l'on vient de voter pour celle et cela a créé la proposition, puis

	 * on revote pour celle ci en changeant d'avis sans recharger la page)

	 */

	private function creerPropositionDeterminationInitiale() {

		$idProposition = $this->ressources[1];

		if ($idProposition == 0) {

			$propositionExiste = $this->verifierExistencePropositionInitiale();

			if ($propositionExiste === false) {

				$idProposition = $this->creerPropositionInitiale();

			} else {

				$idProposition = $this->getIdPropositionInitiale();

			}

		}

		return $idProposition;

	}

	private function verifierExistencePropositionInitiale() {

		$idObservationP = $this->bdd->proteger($this->ressources[0]);

		$requete = 'SELECT COUNT(*) >= 1 AS existe '.

			'FROM del_commentaire '.

			"WHERE ce_observation = $idObservationP ".

			'AND proposition_initiale = 1 '.

			' -- '.__FILE__.' : '.__LINE__;

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

		return $resultat['existe'] == 1;

	}

	private function creerPropositionInitiale() {

		$idObservationP = $this->bdd->proteger($this->ressources[0]);

		$requete = 'INSERT IGNORE INTO del_commentaire '.

			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, '.

			'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, '.

			'		nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, '.

			"		nt, famille, nom_referentiel, NOW(), '1' ".

			'FROM del_observation do '.

			"WHERE id_observation = $idObservationP ".

			' -- '.__FILE__.' : '.__LINE__;

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

		$id = $this->bdd->recupererIdDernierAjout();

		return $id;

	}

	private function getIdPropositionInitiale() {

		$idObservationP = $this->bdd->proteger($this->ressources[0]);

		$requete = 'SELECT id_commentaire '.

			'FROM del_commentaire '.

			"WHERE ce_observation = $idObservationP ".

			'AND proposition_initiale = 1 '.

			' -- '.__FILE__.' : '.__LINE__;

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

		return $resultat['id_commentaire'];

	}

	public function modifier($ressources, $parametres) {

		$this->ressources = $ressources;

		$this->parametres = $parametres;

		$this->verifierParametresAjoutModif();

		$resultat = $this->modifierVote();

		if ($resultat > 0) {

			return 'ok';

		}

	}

	private function modifierVote() {

		// protection anti-usurpateurs @TODO faudrait pt-être la faire !

		$idUtilisateur = $this->parametres['utilisateur'];

		/*$gestionUtilisateurs = $this->conteneur->getUtilisateur();

		$gestionUtilisateurs->controleUtilisateurIdentifie($idUtilisateur);*/

		$idObsP = $this->bdd->proteger($this->ressources[0]);

		$idPropositionP = $this->bdd->proteger($this->ressources[1]);

		$idUtilisateurP = $this->bdd->proteger($idUtilisateur);

		$valeurP = $this->bdd->proteger($this->parametres['valeur']);

		$requete = 'UPDATE del_commentaire_vote '.

			"SET valeur = $valeurP, date = NOW() ".

			"WHERE ce_proposition = $idPropositionP AND ce_utilisateur = $idUtilisateurP ".

			' -- '.__FILE__.' : '.__LINE__;

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

		if ($resultat === false) {

			$msg = "Une erreur est survenue lors de la tentative de modification du vote.";

			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);

		} else if ($resultat === 0) {

			$msg = "Aucun vote ne correspond au critères fournis : ".

				"idObs -> $idObsP, idProposition -> $idPropositionP et id_utilisateur -> $idUtilisateurP.";

			throw new Exception($msg, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);

		}

		$requete = "UPDATE tb_new_cel.`occurrence` join

	(SELECT ce_observation, id_commentaire, nom_sel_nn, `proposition_retenue` FROM `del_commentaire` WHERE id_commentaire = ".$idPropositionP.") c

	on id = ce_observation AND user_sci_name_id= `nom_sel_nn`

	SET `identiplante_score`= case

		when ".$this->parametres['valeur']." = 0 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) -6

		when ".$this->parametres['valeur']." = 0 then ifnull(identiplante_score, 0) -2

		when ".$this->parametres['valeur']." = 1 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) + 6

		when ".$this->parametres['valeur']." = 1 then ifnull(identiplante_score, 0) + 2 END;";

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

		return $resultat;

	}

	private function verifierParametresAjoutModif() {

		$erreurs = array();

		if (!isset($this->parametres['utilisateur'])) {

			$erreurs[] = 'Paramètre "utilisateur" manquant.';

		}

		if (!isset($this->parametres['valeur'])) {

			$erreurs[] = 'Paramètre "valeur" manquant.';

		} else {

			if (!is_numeric($this->parametres['valeur'])) {

				$erreurs[] = 'Le paramètre "valeur" doit être numérique.';

			} elseif($this->parametres['valeur'] != 0 && $this->parametres['valeur'] != 1) {

				$erreurs[] = 'Le paramètre "valeur" ne peut prendre que la valeur 0 ou 1.';

			}

		}

		if (!empty($erreurs)) {

			$msg = "Erreur lors de la configuration : \n".implode("\n", $erreurs);

			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);

		}

	}

}