Subversion Repositories eFlore/Applications.del

Rev

Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
2211 arthur 1 
<?php
2 
// declare(encoding='UTF-8');
3 
/**
4 
 * Web service permetant d'ajouter ou de modifier les votes associés aux propositions d'une observation.
5 
 *
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>
16 
 */
17 
 
18 
class VoteObservation {
19 
	private $conteneur;
20 
	private $bdd;
21 
	private $navigation;
22 
	private $mapping;
23 
	private $ressources;
24 
	private $parametres;
25 
 
26 
	public function __construct(Conteneur $conteneur = null) {
27 
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
28 
		$this->bdd = $this->conteneur->getBdd();
29 
		$this->navigation = $conteneur->getNavigation();
30 
 
31 
		$this->mapping = $this->conteneur->getParametreTableau('votes.mapping');
32 
	}
33 
 
34 
	public function consulter($ressources, $parametres) {
35 
		$this->ressources = $ressources;
36 
		$this->parametres = $parametres;
37 
 
38 
		$votes = $this->chargerVotes();
39 
		$this->conteneur->getNavigation()->setTotal(count($votes));
40 
		// Mettre en forme le résultat et l'envoyer pour affichage
41 
		$resultat = new ResultatService();
42 
		$resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => $votes);
43 
		return $resultat;
44 
	}
45 
 
46 
	private function chargerVotes() {
47 
		$idCommentaireP = $this->bdd->proteger($this->ressources[1]);
48 
		$requete = 'SELECT * '.
49 
			'FROM del_commentaire_vote '.
50 
			"WHERE ce_proposition = $idCommentaireP ";
51 
			' -- '.__FILE__.':'.__LINE__;
52 
		$resultats = $this->bdd->recupererTous($requete);
53 
		$votes = array();
54 
		foreach ($resultats as $vote) {
55 
			$votes[$vote['id_vote']] = $this->formaterVotes($vote);
56 
			$utilisateur = $this->chercherUtilisateur($vote['ce_utilisateur']);
57 
			if ($utilisateur && count($utilisateur) > 0) {
58 
				$votes[$vote['id_vote']] = array_merge($votes[$vote['id_vote']], $utilisateur);
59 
			}
60 
		}
61 
		return $votes;
62 
	}
63 
 
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 
 
72 
	/**
73 
	 * Recherche les coordonnées d'un utilisateur en fonction de son ID;
74 
	 * puisqu'il a un ID c'est qu'il est connecté, on suppose donc qu'il
75 
	 * a un tuple dans del_utilisateur_infos
76 
	 *
77 
	 * @TODO vérifier cette hypothèse
78 
	 */
79 
	private function chercherUtilisateur($id) {
80 
		// par défaut, pas d'info
81 
		$utilisateur = array();
82 
		// Si l'id utilisateur est un hash de session, on ne cherche rien
83 
		if (is_numeric($id)) {
84 
			$idUtilisateurP = $this->bdd->proteger($id);
85 
			$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', ".
86 
				'FROM del_utilisateur_infos '.
87 
				"WHERE id_utilisateur = $idUtilisateurP ".
88 
				' -- '.__FILE__.':'.__LINE__;
89 
			$utilisateur = $this->bdd->recuperer($requete);
90 
		}
91 
		return $utilisateur;
92 
	}
93 
 
94 
	public function ajouter($ressources, $parametres) {
95 
		$this->ressources = $ressources;
96 
		$this->parametres = $parametres;
97 
		$this->verifierParametresAjoutModif();
98 
		$idVote = $this->ajouterVote();
99 
		if ($idVote) {
100 
			$resultat = new ResultatService();
101 
			$resultat->corps = array('id_vote' => $idVote);
102 
			return $resultat;
103 
		}
104 
		return false;
105 
	}
106 
 
107 
	private function ajouterVote() {
108 
		$idProposition = $this->creerPropositionDeterminationInitiale();
109 
 
110 
		$idObsP = $this->bdd->proteger($this->ressources[0]);
111 
		$idPropositionP = $this->bdd->proteger($idProposition);
112 
		$idUtilisateurP = $this->bdd->proteger($this->parametres['utilisateur']);
113 
		$valeurP = $this->bdd->proteger($this->parametres['valeur']);
114 
		$requete = 'INSERT INTO del_commentaire_vote (ce_proposition , ce_utilisateur , valeur , date) '.
115 
			"VALUES ($idPropositionP, $idUtilisateurP, $valeurP, NOW()) ".
116 
			' -- '.__FILE__.' : '.__LINE__;
117 
 
118 
		$resultat = $this->bdd->executer($requete);
119 
		if ($resultat === false) {
120 
			$msg = "Un problème est survenu lors de l'ajout d'un vote.";
121 
			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
122 
		} else if ($resultat === 0) {
123 
			$msg = "Aucun vote ne correspond au critères fournis : ".
124 
				"idObs -> $idObsP, idProposition -> $idPropositionP et id_utilisateur -> $idUtilisateurP.";
125 
			throw new Exception($msg, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);
126 
		}
127 
		// ATTENTION : idVote doit être récupéré avant toute nouvelle requete !
128 
		$idVote = $this->bdd->recupererIdDernierAjout();
129 
 
130 
		$requete = "UPDATE tb_new_cel.`occurrence` join
131 
	(SELECT ce_observation, id_commentaire, nom_sel_nn, `proposition_retenue` FROM `del_commentaire` WHERE id_commentaire = ".$idPropositionP.") c
132 
	on id = ce_observation AND user_sci_name_id= `nom_sel_nn`
133 
	SET `identiplante_score`= case
134 
		when ".$this->parametres['valeur']." = 0 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) -3
135 
		when ".$this->parametres['valeur']." = 0 then ifnull(identiplante_score, 0) -1
136 
		when ".$this->parametres['valeur']." = 1 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) + 3
137 
		when ".$this->parametres['valeur']." = 1 then ifnull(identiplante_score, 0) + 1 END;";
138 
 
139 
		$resultat = $this->bdd->executer($requete);
140 
		return $idVote;
141 
	}
142 
 
143 
	/** Si l'identifiant de proposition vaut 0, c'est un vote sur une proposition
144 
	 * fabriquée à partir de l'observation originale, dont on doit obtenir l'id
145 
	 * (cas où l'on vient de voter pour celle et cela a créé la proposition, puis
146 
	 * on revote pour celle ci en changeant d'avis sans recharger la page)
147 
	 */
148 
	private function creerPropositionDeterminationInitiale() {
149 
		$idProposition = $this->ressources[1];
150 
		if ($idProposition == 0) {
151 
			$propositionExiste = $this->verifierExistencePropositionInitiale();
152 
			if ($propositionExiste === false) {
153 
				$idProposition = $this->creerPropositionInitiale();
154 
			} else {
155 
				$idProposition = $this->getIdPropositionInitiale();
156 
			}
157 
		}
158 
		return $idProposition;
159 
	}
160 
 
161 
	private function verifierExistencePropositionInitiale() {
162 
		$idObservationP = $this->bdd->proteger($this->ressources[0]);
163 
		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
164 
			'FROM del_commentaire '.
165 
			"WHERE ce_observation = $idObservationP ".
166 
			'AND proposition_initiale = 1 '.
167 
			' -- '.__FILE__.' : '.__LINE__;
168 
		$resultat = $this->bdd->recuperer($requete);
169 
		return $resultat['existe'] == 1;
170 
	}
171 
 
172 
	private function creerPropositionInitiale() {
173 
		$idObservationP = $this->bdd->proteger($this->ressources[0]);
174 
		$requete = 'INSERT IGNORE INTO del_commentaire '.
175 
			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, '.
176 
			'nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, nt, famille, nom_referentiel, date, proposition_initiale) '.
177 
			'SELECT id_observation, ce_utilisateur, prenom_utilisateur, nom_utilisateur, '.
178 
			'		nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, '.
179 
			"		nt, famille, nom_referentiel, NOW(), '1' ".
180 
			'FROM del_observation do '.
181 
			"WHERE id_observation = $idObservationP ".
182 
			' -- '.__FILE__.' : '.__LINE__;
183 
 
184 
		$this->bdd->executer($requete);
185 
		$id = $this->bdd->recupererIdDernierAjout();
186 
		return $id;
187 
	}
188 
 
189 
	private function getIdPropositionInitiale() {
190 
		$idObservationP = $this->bdd->proteger($this->ressources[0]);
191 
		$requete = 'SELECT id_commentaire '.
192 
			'FROM del_commentaire '.
193 
			"WHERE ce_observation = $idObservationP ".
194 
			'AND proposition_initiale = 1 '.
195 
			' -- '.__FILE__.' : '.__LINE__;
196 
		$resultat = $this->bdd->recuperer($requete);
197 
		return $resultat['id_commentaire'];
198 
	}
199 
 
200 
	public function modifier($ressources, $parametres) {
201 
		$this->ressources = $ressources;
202 
		$this->parametres = $parametres;
203 
		$this->verifierParametresAjoutModif();
204 
		$resultat = $this->modifierVote();
205 
		if ($resultat > 0) {
206 
			return 'ok';
207 
		}
208 
	}
209 
 
210 
	private function modifierVote() {
211 
		// protection anti-usurpateurs @TODO faudrait pt-être la faire !
212 
		$idUtilisateur = $this->parametres['utilisateur'];
213 
		/*$gestionUtilisateurs = $this->conteneur->getUtilisateur();
214 
		$gestionUtilisateurs->controleUtilisateurIdentifie($idUtilisateur);*/
215 
 
216 
		$idObsP = $this->bdd->proteger($this->ressources[0]);
217 
		$idPropositionP = $this->bdd->proteger($this->ressources[1]);
218 
		$idUtilisateurP = $this->bdd->proteger($idUtilisateur);
219 
		$valeurP = $this->bdd->proteger($this->parametres['valeur']);
220 
		$requete = 'UPDATE del_commentaire_vote '.
221 
			"SET valeur = $valeurP, date = NOW() ".
222 
			"WHERE ce_proposition = $idPropositionP AND ce_utilisateur = $idUtilisateurP ".
223 
			' -- '.__FILE__.' : '.__LINE__;
224 
 
225 
		$resultat = $this->bdd->executer($requete);
226 
		if ($resultat === false) {
227 
			$msg = "Une erreur est survenue lors de la tentative de modification du vote.";
228 
			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
229 
		} else if ($resultat === 0) {
230 
			$msg = "Aucun vote ne correspond au critères fournis : ".
231 
				"idObs -> $idObsP, idProposition -> $idPropositionP et id_utilisateur -> $idUtilisateurP.";
232 
			throw new Exception($msg, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);
233 
		}
234 
		$requete = "UPDATE tb_new_cel.`occurrence` join
235 
	(SELECT ce_observation, id_commentaire, nom_sel_nn, `proposition_retenue` FROM `del_commentaire` WHERE id_commentaire = ".$idPropositionP.") c
236 
	on id = ce_observation AND user_sci_name_id= `nom_sel_nn`
237 
	SET `identiplante_score`= case
238 
		when ".$this->parametres['valeur']." = 0 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) -6
239 
		when ".$this->parametres['valeur']." = 0 then ifnull(identiplante_score, 0) -2
240 
		when ".$this->parametres['valeur']." = 1 and ".$idUtilisateurP." REGEXP '^-?[0-9]+$' then ifnull(identiplante_score, 0) + 6
241 
		when ".$this->parametres['valeur']." = 1 then ifnull(identiplante_score, 0) + 2 END;";
242 
 
243 
		$resultat = $this->bdd->executer($requete);
244 
 
245 
		return $resultat;
246 
	}
247 
 
248 
	private function verifierParametresAjoutModif() {
249 
		$erreurs = array();
250 
 
251 
		if (!isset($this->parametres['utilisateur'])) {
252 
			$erreurs[] = 'Paramètre "utilisateur" manquant.';
253 
		}
254 
 
255 
		if (!isset($this->parametres['valeur'])) {
256 
			$erreurs[] = 'Paramètre "valeur" manquant.';
257 
		} else {
258 
			if (!is_numeric($this->parametres['valeur'])) {
259 
				$erreurs[] = 'Le paramètre "valeur" doit être numérique.';
260 
			} elseif($this->parametres['valeur'] != 0 && $this->parametres['valeur'] != 1) {
261 
				$erreurs[] = 'Le paramètre "valeur" ne peut prendre que la valeur 0 ou 1.';
262 
			}
263 
		}
264 
 
265 
		if (!empty($erreurs)) {
266 
			$msg = "Erreur lors de la configuration : \n".implode("\n", $erreurs);
267 
			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
268 
		}
269 
	}
270 
}