Subversion Repositories eFlore/Applications.del

Rev

Rev 2106 | Rev 2164 | Go to most recent revision | Details | Compare with Previous | 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
 
1850 jpm 18
class VoteObservation {
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
 
2157 mathias 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
	 */
895 aurelien 79
	private function chercherUtilisateur($id) {
1763 mathias 80
		// par défaut, pas d'info
81
		$utilisateur = array();
1759 mathias 82
		// Si l'id utilisateur est un hash de session, on ne cherche rien
83
		if (is_numeric($id)) {
1848 jpm 84
			$idUtilisateurP = $this->bdd->proteger($id);
1759 mathias 85
			$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', ".
86
				"courriel AS 'auteur.courriel' ".
2157 mathias 87
				'FROM del_utilisateur_infos '.
1848 jpm 88
				"WHERE id_utilisateur = $idUtilisateurP ".
89
				' -- '.__FILE__.':'.__LINE__;
1759 mathias 90
			$utilisateur = $this->bdd->recuperer($requete);
91
		}
895 aurelien 92
		return $utilisateur;
93
	}
1305 jpm 94
 
787 delphine 95
	public function ajouter($ressources, $parametres) {
1848 jpm 96
		$this->ressources = $ressources;
97
		$this->parametres = $parametres;
98
		$this->verifierParametresAjoutModif();
1849 jpm 99
		$idVote = $this->ajouterVote();
100
		if ($idVote) {
101
			$resultat = new ResultatService();
102
			$resultat->corps = array('id_vote' => $idVote);
103
			return $resultat;
104
		}
105
		return false;
106
	}
107
 
108
	private function ajouterVote() {
1850 jpm 109
		$idProposition = $this->creerPropositionDeterminationInitiale();
110
 
1849 jpm 111
		$idObsP = $this->bdd->proteger($this->ressources[0]);
1850 jpm 112
		$idPropositionP = $this->bdd->proteger($idProposition);
1849 jpm 113
		$idUtilisateurP = $this->bdd->proteger($this->parametres['utilisateur']);
114
		$valeurP = $this->bdd->proteger($this->parametres['valeur']);
1848 jpm 115
		$requete = 'INSERT INTO del_commentaire_vote (ce_proposition , ce_utilisateur , valeur , date) '.
116
			"VALUES ($idPropositionP, $idUtilisateurP, $valeurP, NOW()) ".
117
			' -- '.__FILE__.' : '.__LINE__;
1305 jpm 118
 
1849 jpm 119
		$resultat = $this->bdd->executer($requete);
120
		if ($resultat === false) {
121
			$msg = "Un problème est survenu lors de l'ajout d'un vote.";
122
			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
123
		} else if ($resultat === 0) {
124
			$msg = "Aucun vote ne correspond au critères fournis : ".
125
				"idObs -> $idObsP, idProposition -> $idPropositionP et id_utilisateur -> $idUtilisateurP.";
126
			throw new Exception($msg, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);
787 delphine 127
		}
1849 jpm 128
		// ATTENTION : idVote doit être récupéré avant toute nouvelle requete !
129
		$idVote = $this->bdd->recupererIdDernierAjout();
130
		return $idVote;
787 delphine 131
	}
1305 jpm 132
 
1850 jpm 133
	/** Si l'identifiant de proposition vaut 0, c'est un vote sur une proposition
134
	 * fabriquée à partir de l'observation originale, dont on doit obtenir l'id
135
	 * (cas où l'on vient de voter pour celle et cela a créé la proposition, puis
136
	 * on revote pour celle ci en changeant d'avis sans recharger la page)
137
	 */
138
	private function creerPropositionDeterminationInitiale() {
139
		$idProposition = $this->ressources[1];
1943 mathias 140
		if ($idProposition == 0) {
1850 jpm 141
			$propositionExiste = $this->verifierExistencePropositionInitiale();
142
			if ($propositionExiste === false) {
143
				$idProposition = $this->creerPropositionInitiale();
144
			} else {
145
				$idProposition = $this->getIdPropositionInitiale();
146
			}
1252 aurelien 147
		}
1850 jpm 148
		return $idProposition;
1252 aurelien 149
	}
1305 jpm 150
 
1850 jpm 151
	private function verifierExistencePropositionInitiale() {
152
		$idObservationP = $this->bdd->proteger($this->ressources[0]);
1612 jpm 153
		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
154
			'FROM del_commentaire '.
1850 jpm 155
			"WHERE ce_observation = $idObservationP ".
1848 jpm 156
			'AND proposition_initiale = 1 '.
157
			' -- '.__FILE__.' : '.__LINE__;
1252 aurelien 158
		$resultat = $this->bdd->recuperer($requete);
159
		return $resultat['existe'] == 1;
160
	}
1305 jpm 161
 
1850 jpm 162
	private function creerPropositionInitiale() {
163
		$idObservationP = $this->bdd->proteger($this->ressources[0]);
1848 jpm 164
		$requete = 'INSERT IGNORE INTO del_commentaire '.
871 aurelien 165
			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, utilisateur_courriel, '.
1305 jpm 166
			'nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, nt, famille, nom_referentiel, date, proposition_initiale) '.
2157 mathias 167
			'SELECT id_observation, ce_utilisateur, prenom_utilisateur, nom_utilisateur, '.
168
			'		courriel_utilisateur, nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, '.
1977 aurelien 169
			"		nt, famille, nom_referentiel, NOW(), '1' ".
871 aurelien 170
			'FROM del_observation do '.
1848 jpm 171
			"WHERE id_observation = $idObservationP ".
172
			' -- '.__FILE__.' : '.__LINE__;
1305 jpm 173
 
1848 jpm 174
		$this->bdd->executer($requete);
871 aurelien 175
		$id = $this->bdd->recupererIdDernierAjout();
176
		return $id;
177
	}
1305 jpm 178
 
1850 jpm 179
	private function getIdPropositionInitiale() {
180
		$idObservationP = $this->bdd->proteger($this->ressources[0]);
181
		$requete = 'SELECT id_commentaire '.
182
			'FROM del_commentaire '.
183
			"WHERE ce_observation = $idObservationP ".
184
			'AND proposition_initiale = 1 '.
185
			' -- '.__FILE__.' : '.__LINE__;
186
		$resultat = $this->bdd->recuperer($requete);
187
		return $resultat['id_commentaire'];
188
	}
189
 
841 aurelien 190
	public function modifier($ressources, $parametres) {
1848 jpm 191
		$this->ressources = $ressources;
192
		$this->parametres = $parametres;
193
		$this->verifierParametresAjoutModif();
1850 jpm 194
		$resultat = $this->modifierVote();
195
		if ($resultat > 0) {
196
			return 'ok';
197
		}
198
	}
1305 jpm 199
 
1850 jpm 200
	private function modifierVote() {
2106 mathias 201
		// protection anti-usurpateurs @TODO faudrait pt-être la faire !
2105 delphine 202
		$idUtilisateur = $this->parametres['utilisateur'];
203
		/*$gestionUtilisateurs = $this->conteneur->getUtilisateur();
2077 mathias 204
		$gestionUtilisateurs->controleUtilisateurIdentifie($idUtilisateur);*/
1850 jpm 205
 
206
		$idObsP = $this->bdd->proteger($this->ressources[0]);
2105 delphine 207
		$idPropositionP = $this->bdd->proteger($this->ressources[1]);
2077 mathias 208
		$idUtilisateurP = $this->bdd->proteger($idUtilisateur);
1850 jpm 209
		$valeurP = $this->bdd->proteger($this->parametres['valeur']);
1848 jpm 210
		$requete = 'UPDATE del_commentaire_vote '.
211
			"SET valeur = $valeurP, date = NOW() ".
212
			"WHERE ce_proposition = $idPropositionP AND ce_utilisateur = $idUtilisateurP ".
213
			' -- '.__FILE__.' : '.__LINE__;
1305 jpm 214
 
1850 jpm 215
		$resultat = $this->bdd->executer($requete);
216
		if ($resultat === false) {
2077 mathias 217
			$msg = "Une erreur est survenue lors de la tentative de modification du vote.";
1850 jpm 218
			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
219
		} else if ($resultat === 0) {
220
			$msg = "Aucun vote ne correspond au critères fournis : ".
221
				"idObs -> $idObsP, idProposition -> $idPropositionP et id_utilisateur -> $idUtilisateurP.";
222
			throw new Exception($msg, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);
841 aurelien 223
		}
1850 jpm 224
		return $resultat;
841 aurelien 225
	}
1305 jpm 226
 
1848 jpm 227
	private function verifierParametresAjoutModif() {
855 aurelien 228
		$erreurs = array();
1305 jpm 229
 
1848 jpm 230
		if (!isset($this->parametres['utilisateur'])) {
231
			$erreurs[] = 'Paramètre "utilisateur" manquant.';
855 aurelien 232
		}
1305 jpm 233
 
1848 jpm 234
		if (!isset($this->parametres['valeur'])) {
235
			$erreurs[] = 'Paramètre "valeur" manquant.';
855 aurelien 236
		} else {
1848 jpm 237
			if (!is_numeric($this->parametres['valeur'])) {
238
				$erreurs[] = 'Le paramètre "valeur" doit être numérique.';
239
			} elseif($this->parametres['valeur'] != 0 && $this->parametres['valeur'] != 1) {
240
				$erreurs[] = 'Le paramètre "valeur" ne peut prendre que la valeur 0 ou 1.';
855 aurelien 241
			}
242
		}
1305 jpm 243
 
855 aurelien 244
		if (!empty($erreurs)) {
1848 jpm 245
			$msg = "Erreur lors de la configuration : \n".implode("\n", $erreurs);
246
			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
855 aurelien 247
		}
248
	}
1845 jpm 249
}