Subversion Repositories eFlore/Applications.del

Rev

Rev 1960 | Rev 1975 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

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