Subversion Repositories eFlore/Applications.del

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
787 delphine 1 
<?php
2 
// declare(encoding='UTF-8');
3 
/**
1845 jpm 4 
 * Web service permetant d'ajouter ou de modifier les votes associés aux propositions d'une observation.
787 delphine 5 
 *
1845 jpm 6 
 * @category   DEL
7 
 * @package    Services
8 
 * @subpackage Observations
9 
 * @version    0.1
10 
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
11 
 * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
12 
 * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
13 
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
14 
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
15 
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
787 delphine 16 
 */
17 
 
841 aurelien 18 
class VoteObservation extends RestService {
1848 jpm 19 
	private $conteneur;
20 
	private $bdd;
21 
	private $navigation;
22 
	private $mapping;
23 
	private $ressources;
24 
	private $parametres;
1305 jpm 25 
 
787 delphine 26 
	public function __construct(Conteneur $conteneur = null) {
27 
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
1793 jpm 28 
		$this->bdd = $this->conteneur->getBdd();
895 aurelien 29 
		$this->navigation = $conteneur->getNavigation();
1305 jpm 30 
 
1848 jpm 31 
		$this->mapping = $this->conteneur->getParametreTableau('votes.mapping');
895 aurelien 32 
	}
1305 jpm 33 
 
34 
	public function consulter($ressources, $parametres) {
1848 jpm 35 
		$this->ressources = $ressources;
36 
		$this->parametres = $parametres;
1305 jpm 37 
 
1848 jpm 38 
		$votes = $this->chargerVotes();
910 aurelien 39 
		$this->conteneur->getNavigation()->setTotal(count($votes));
895 aurelien 40 
		// Mettre en forme le résultat et l'envoyer pour affichage
41 
		$resultat = new ResultatService();
1794 jpm 42 
		$resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => $votes);
895 aurelien 43 
		return $resultat;
787 delphine 44 
	}
1305 jpm 45 
 
1848 jpm 46 
	private function chargerVotes() {
47 
		$idCommentaireP = $this->bdd->proteger($this->ressources[1]);
48 
		$requete = 'SELECT * '.
1612 jpm 49 
			'FROM del_commentaire_vote '.
1848 jpm 50 
			"WHERE ce_proposition = $idCommentaireP ";
51 
			' -- '.__FILE__.':'.__LINE__;
52 
		$resultats = $this->bdd->recupererTous($requete);
895 aurelien 53 
		$votes = array();
1848 jpm 54 
		foreach ($resultats as $vote) {
895 aurelien 55 
			$votes[$vote['id_vote']] = $this->formaterVotes($vote);
56 
			$utilisateur = $this->chercherUtilisateur($vote['ce_utilisateur']);
1848 jpm 57 
			if (count($utilisateur) > 0) {
895 aurelien 58 
				$votes[$vote['id_vote']] = array_merge($votes[$vote['id_vote']], $utilisateur);
59 
			}
60 
		}
61 
		return $votes;
62 
	}
1305 jpm 63 
 
1848 jpm 64 
	private function formaterVotes($vote) {
65 
		$retour = array();
66 
		foreach ($vote as $param => $valeur) {
67 
			$retour[$this->mapping[$param]] = $valeur;
68 
		}
69 
		return $retour;
70 
	}
71 
 
895 aurelien 72 
	private function chercherUtilisateur($id) {
1763 mathias 73 
		// par défaut, pas d'info
74 
		$utilisateur = array();
1759 mathias 75 
		// Si l'id utilisateur est un hash de session, on ne cherche rien
76 
		if (is_numeric($id)) {
1848 jpm 77 
			$idUtilisateurP = $this->bdd->proteger($id);
1759 mathias 78 
			$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', ".
79 
				"courriel AS 'auteur.courriel' ".
80 
				'FROM del_utilisateur '.
1848 jpm 81 
				"WHERE id_utilisateur = $idUtilisateurP ".
82 
				' -- '.__FILE__.':'.__LINE__;
1759 mathias 83 
			$utilisateur = $this->bdd->recuperer($requete);
84 
		}
895 aurelien 85 
		return $utilisateur;
86 
	}
1305 jpm 87 
 
787 delphine 88 
	public function ajouter($ressources, $parametres) {
1848 jpm 89 
		$this->ressources = $ressources;
90 
		$this->parametres = $parametres;
91 
		$this->verifierParametresAjoutModif();
871 aurelien 92 
 
93 
		// Vérifie si la proposition existe, et la crée sinon
855 aurelien 94 
		// (cas du vote sur la proposition fabriquée à partir de l'observation originale)
1848 jpm 95 
		$idProposition = $this->ressources[1];
96 
		if ($idProposition == 0) {
97 
			$idProposition = $this->renvoyerIdOuCreerPropositionDeterminationInitiale($idProposition);
871 aurelien 98 
		}
1848 jpm 99 
		$idPropositionP = $this->bdd->proteger($idProposition);
100 
		$idUtilisateurP = $this->bdd->proteger($parametres['utilisateur']);
101 
		$valeurP = $this->bdd->proteger($parametres['valeur']);
102 
		$requete = 'INSERT INTO del_commentaire_vote (ce_proposition , ce_utilisateur , valeur , date) '.
103 
			"VALUES ($idPropositionP, $idUtilisateurP, $valeurP, NOW()) ".
104 
			' -- '.__FILE__.' : '.__LINE__;
1305 jpm 105 
 
1848 jpm 106 
		$resultats = $this->bdd->requeter($requete);
107 
		if ($resultats == false) {
787 delphine 108 
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
109 
		} else {
110 
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_CREATION_OK);
111 
		}
112 
	}
1305 jpm 113 
 
1252 aurelien 114 
	private function renvoyerIdOuCreerPropositionDeterminationInitiale($id_observation) {
115 
		$proposition_existe = $this->propositionInitialeExiste($id_observation);
116 
		if(!$proposition_existe) {
117 
			$id_proposition = $this->creerPropositionAPartirObservation($id_observation);
118 
		} else {
1612 jpm 119 
			$requete = 'SELECT id_commentaire '.
120 
				'FROM del_commentaire '.
121 
				"WHERE ce_observation = $id_observation ".
1848 jpm 122 
				'AND proposition_initiale = 1 '.
123 
				' -- '.__FILE__.' : '.__LINE__;
1252 aurelien 124 
			$resultat = $this->bdd->recuperer($requete);
125 
			$id_proposition = $resultat['id_commentaire'];
126 
		}
127 
		return $id_proposition;
128 
	}
1305 jpm 129 
 
1252 aurelien 130 
	private function propositionInitialeExiste($id_observation) {
1612 jpm 131 
		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
132 
			'FROM del_commentaire '.
133 
			"WHERE ce_observation = $id_observation ".
1848 jpm 134 
			'AND proposition_initiale = 1 '.
135 
			' -- '.__FILE__.' : '.__LINE__;
1252 aurelien 136 
		$resultat = $this->bdd->recuperer($requete);
137 
		return $resultat['existe'] == 1;
138 
	}
1305 jpm 139 
 
871 aurelien 140 
	private function creerPropositionAPartirObservation($id_observation) {
1848 jpm 141 
		$idObservationP = $this->bdd->proteger($id_observation);
142 
		$requete = 'INSERT IGNORE INTO del_commentaire '.
871 aurelien 143 
			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, utilisateur_courriel, '.
1305 jpm 144 
			'nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, nt, famille, nom_referentiel, date, proposition_initiale) '.
871 aurelien 145 
			'SELECT id_observation, ce_utilisateur, prenom, nom, '.
146 
			'		courriel, nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, '.
1305 jpm 147 
			"		nt, famille, 'bdtfx_v1', NOW(), '1' ".
871 aurelien 148 
			'FROM del_observation do '.
1612 jpm 149 
			'	LEFT JOIN del_utilisateur du ON (do.ce_utilisateur = du.id_utilisateur) '.
1848 jpm 150 
			"WHERE id_observation = $idObservationP ".
151 
			' -- '.__FILE__.' : '.__LINE__;
1305 jpm 152 
 
1848 jpm 153 
		$this->bdd->executer($requete);
1612 jpm 154 
 
871 aurelien 155 
		// Attention à l'abstraction utilisée, récupérer le dernier id en mysql ou msqli ça marche bien, mais pour d'autres moins
156 
		$id = $this->bdd->recupererIdDernierAjout();
157 
		return $id;
158 
	}
1305 jpm 159 
 
841 aurelien 160 
	public function modifier($ressources, $parametres) {
1848 jpm 161 
		$this->ressources = $ressources;
162 
		$this->parametres = $parametres;
163 
		$this->verifierParametresAjoutModif();
1305 jpm 164 
 
871 aurelien 165 
		// Si l'identifiant de proposition vaut 0, c'est un vote sur une proposition
166 
		// fabriquée à partir de l'observation originale, dont on doit obtenir l'id
1305 jpm 167 
		// (cas où l'on vient de voter pour celle et cela a créé la proposition, puis
871 aurelien 168 
		// on revote pour celle ci en changeant d'avis sans recharger la page)
1848 jpm 169 
		$idProposition = $this->ressources[1];
170 
		if ($idProposition == 0) {
171 
			$idProposition = $this->renvoyerIdOuCreerPropositionDeterminationInitiale($idProposition);
172 
			if ($idProposition == null) {
173 
				$msg = "Aucun identifiant de proposition n'est lié à cette observation.";
174 
				throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
871 aurelien 175 
			}
176 
		}
1848 jpm 177 
		$idPropositionP = $this->bdd->proteger($idProposition);
178 
		$idUtilisateurP = $this->bdd->proteger($parametres['utilisateur']);
179 
		$valeurP = $this->bdd->proteger($parametres['valeur']);
180 
		$requete = 'UPDATE del_commentaire_vote '.
181 
			"SET valeur = $valeurP, date = NOW() ".
182 
			"WHERE ce_proposition = $idPropositionP AND ce_utilisateur = $idUtilisateurP ".
183 
			' -- '.__FILE__.' : '.__LINE__;
1305 jpm 184 
 
1848 jpm 185 
		$resultats = $this->bdd->requeter($requete);
186 
		if ($resultats == false) {
841 aurelien 187 
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
188 
		} else {
189 
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_OK);
190 
		}
191 
	}
1305 jpm 192 
 
1848 jpm 193 
	private function verifierParametresAjoutModif() {
855 aurelien 194 
		$erreurs = array();
1305 jpm 195 
 
1848 jpm 196 
		if (!isset($this->parametres['utilisateur'])) {
197 
			$erreurs[] = 'Paramètre "utilisateur" manquant.';
855 aurelien 198 
		}
1305 jpm 199 
 
1848 jpm 200 
		if (!isset($this->parametres['valeur'])) {
201 
			$erreurs[] = 'Paramètre "valeur" manquant.';
855 aurelien 202 
		} else {
1848 jpm 203 
			if (!is_numeric($this->parametres['valeur'])) {
204 
				$erreurs[] = 'Le paramètre "valeur" doit être numérique.';
205 
			} elseif($this->parametres['valeur'] != 0 && $this->parametres['valeur'] != 1) {
206 
				$erreurs[] = 'Le paramètre "valeur" ne peut prendre que la valeur 0 ou 1.';
855 aurelien 207 
			}
208 
		}
1305 jpm 209 
 
855 aurelien 210 
		if (!empty($erreurs)) {
1848 jpm 211 
			$msg = "Erreur lors de la configuration : \n".implode("\n", $erreurs);
212 
			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
855 aurelien 213 
		}
214 
	}
1845 jpm 215 
}