Subversion Repositories eFlore/Applications.del

Rev

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

Rev 829 Rev 1428
1
<?php
1
<?php
2
// declare(encoding='UTF-8');
2
// declare(encoding='UTF-8');
3
/**
3
/**
4
	* Le web service image récupère toutes les données de la table del_obs_images
4
	* Le web service image récupère toutes les données de la table del_obs_images
5
 * pour retourner une liste d'images associée à une observation
5
 * pour retourner une liste d'images associée à une observation
6
 *
6
 *
7
 * @category	php 5.2
7
 * @category	php 5.2
8
 * @package	del
8
 * @package	del
9
 * @subpackage images
9
 * @subpackage images
10
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
10
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
11
 * @copyright	Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
11
 * @copyright	Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
12
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
12
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
13
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
13
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
14
 * @version	$Id: Bdd.php 403 2012-02-22 14:35:20Z gduche $
14
 * @version	$Id: Bdd.php 403 2012-02-22 14:35:20Z gduche $
15
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Images
15
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Images
16
 */
16
 */
17
 
17
 
18
class VotesImage extends RestService {
18
class VotesImage extends RestService {
19
	
19
	
20
	private $imageIds = array();
20
	private $imageIds = array();
21
	private $conteneur;
21
	private $conteneur;
22
	private $navigation;
22
	private $navigation;
23
	private $masque;
23
	private $masque;
24
	protected $gestionBdd;
24
	protected $gestionBdd;
25
	protected $bdd;
25
	protected $bdd;
26
	private $ressources;
26
	private $ressources;
27
	private $parametres;
27
	private $parametres;
28
	
28
	
29
	public function __construct(Conteneur $conteneur = null) {
29
	public function __construct(Conteneur $conteneur = null) {
30
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
30
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
31
		$this->conteneur->chargerConfiguration('config_votes.ini');
31
		$this->conteneur->chargerConfiguration('config_votes.ini');
32
		$this->conteneur->chargerConfiguration('config_mapping_votes.ini');
32
		$this->conteneur->chargerConfiguration('config_mapping_votes.ini');
33
		$this->navigation = $conteneur->getNavigation();
33
		$this->navigation = $conteneur->getNavigation();
34
		$this->masque = $conteneur->getMasque();
34
		$this->masque = $conteneur->getMasque();
35
		$this->gestionBdd = $conteneur->getGestionBdd();
35
		$this->gestionBdd = $conteneur->getGestionBdd();
36
		$this->bdd = $this->gestionBdd->getBdd();
36
		$this->bdd = $this->gestionBdd->getBdd();
37
	}
37
	}
38
	
38
	
39
	/**
39
	/**
40
	 * Méthode principale de la classe.
40
	 * Méthode principale de la classe.
41
	 * Lance la récupération des images dans la base et les place dans un objet ResultatService 
41
	 * Lance la récupération des images dans la base et les place dans un objet ResultatService 
42
	 * pour l'afficher.
42
	 * pour l'afficher.
43
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
43
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
44
	 * @param array $parametres les paramètres situés après le ? dans l'url
44
	 * @param array $parametres les paramètres situés après le ? dans l'url
45
	 * */
45
	 * */
46
	public function consulter($ressources, $parametres) {
46
	public function consulter($ressources, $parametres) {
47
		// Gestion des configuration du script
47
		// Gestion des configuration du script
48
		$this->ressources = $ressources;
48
		$this->ressources = $ressources;
49
		$this->parametres = $parametres;
49
		$this->parametres = $parametres;
50
		$this->configurer();
50
		$this->configurer();
51
		$this->verifierConfiguration();
51
		$this->verifierConfiguration();
52
		
52
		
53
		// Lancement du service
53
		// Lancement du service
54
		$votes = $this->chargerVotes();
54
		$votes = $this->chargerVotes();
55
		$total = $this->compterVotes();
55
		$total = $this->compterVotes();
56
		$this->navigation->setTotal($total);
56
		$this->navigation->setTotal($total);
57
		
57
		
58
		// Mettre en forme le résultat et l'envoyer pour affichage
58
		// Mettre en forme le résultat et l'envoyer pour affichage
59
		$resultat = new ResultatService();
59
		$resultat = new ResultatService();
60
		$resultat->corps = array('entete' => $this->conteneur->getEntete(), 'resultats' => $votes);
60
		$resultat->corps = array('entete' => $this->conteneur->getEntete(), 'resultats' => $votes);
61
		return $resultat;
61
		return $resultat;
62
	}
62
	}
63
	
63
	
64
	public function ajouter($ressources, $parametres) {
64
	public function ajouter($ressources, $parametres) {
65
		
65
		
66
		$this->verifierParametresAjoutModif($ressources, $parametres);
66
		$this->verifierParametresAjoutModif($ressources, $parametres);
67
		
67
		
68
		$insertion = 'INSERT INTO del_image_vote '.
68
		$insertion = 'INSERT INTO del_image_vote '.
69
						'(ce_image, ce_protocole, ce_utilisateur, valeur, date) '.
69
						'(ce_image, ce_protocole, ce_utilisateur, valeur, date) '.
70
						'VALUES ('.
70
						'VALUES ('.
71
							$this->proteger($ressources[0]).','.
71
							$this->proteger($ressources[0]).','.
72
							$this->proteger($parametres['protocole']).','.
72
							$this->proteger($parametres['protocole']).','.
73
							$this->proteger($parametres['utilisateur']).','.
73
							$this->proteger($parametres['utilisateur']).','.
74
							$this->proteger($parametres['valeur']).', '.
74
							$this->proteger($parametres['valeur']).', '.
75
						'NOW()'.
75
						'NOW()'.
76
						');';
76
						');';
77
		
77
		
78
		$resultat = $this->bdd->requeter($insertion);
78
		$resultat = $this->bdd->requeter($insertion);
79
		if ($resultat == false) {
79
		if ($resultat == false) {
80
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
80
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
81
		} else {
81
		} else {
-
 
82
			self::updateStats($this->bdd, $ressources[0],$parametres['protocole']);
82
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_CREATION_OK);
83
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_CREATION_OK);
83
		}
84
		}
84
	}
85
	}
85
	
86
	
86
	public function modifier($ressources, $parametres) {
87
	public function modifier($ressources, $parametres) {
87
	
88
	
88
		$this->verifierParametresAjoutModif($ressources, $parametres);
89
		$this->verifierParametresAjoutModif($ressources, $parametres);
89
		
90
		
90
		//TODO: est il nécessaire de tester si ça existe et renoyer une erreur 404
91
		//TODO: est il nécessaire de tester si ça existe et renoyer une erreur 404
91
		// si l'on vote ? Cela peut ralentir considérablement les choses
92
		// si l'on vote ? Cela peut ralentir considérablement les choses
92
		// une contrainte d'unicité sur le triplet image, protocole, vote existe,
93
		// une contrainte d'unicité sur le triplet image, protocole, vote existe,
93
		// ça suffira pour provoquer une erreur 500
94
		// ça suffira pour provoquer une erreur 500
94
		$modification = 'UPDATE del_image_vote '.
95
		$modification = 'UPDATE del_image_vote '.
95
							'SET valeur = '.$this->proteger($parametres['valeur']).', '.
96
							'SET valeur = '.$this->proteger($parametres['valeur']).', '.
96
							'    date = NOW() '.
97
							'    date = NOW() '.
97
						'WHERE '.
98
						'WHERE '.
98
							'ce_image = '.$this->proteger($ressources[0]).' AND '.
99
							'ce_image = '.$this->proteger($ressources[0]).' AND '.
99
							'ce_protocole = '.$this->proteger($parametres['protocole']).' AND '.
100
							'ce_protocole = '.$this->proteger($parametres['protocole']).' AND '.
100
							'ce_utilisateur = '.$this->proteger($parametres['utilisateur']).' ';		
101
							'ce_utilisateur = '.$this->proteger($parametres['utilisateur']).' ';		
101
		$resultat = $this->bdd->requeter($modification);
102
		$resultat = $this->bdd->requeter($modification);
102
		if ($resultat == false) {
103
		if ($resultat == false) {
103
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
104
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
104
		} else {
105
		} else {
-
 
106
			self::updateStats($this->bdd, $ressources[0],$parametres['protocole']);
105
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_OK);
107
			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_OK);
106
		}
108
		}
107
	}
109
	}
-
 
110
	
-
 
111
	static function updateStats($db, $id_image, $id_proto) {
-
 
112
		$id_image = intval($id_image);
-
 
113
		$id_proto = intval($id_proto);
-
 
114
		if(!$id_image || !$id_proto) throw new Exception("Ne peut mettre à jour les statistiques de vote",
-
 
115
														 RestServeur::HTTP_CODE_ERREUR);
-
 
116
		/* REPLACE ... SELECT: réinitalise les champs non-défini (MySQL 5.1)
-
 
117
		   REPLACE ... SET a=b, c=d: idem ou plusieurs requête
-
 
118
		   Du coup il faut récupérer les données actuelles mais REPLACE ne le permet pas
-
 
119
		   (http://dev.mysql.com/doc/refman/5.5/en/replace.html :
-
 
120
		   You cannot refer to values from the current row and use them in the new row.)
-
 
121
		   D'où INSERT ... ON DUPLICATE KEY UPDATE. Notons que VALUES() récupère la valeur
-
 
122
		   *associée* au champ passé en paramètre, c'est à dire VALUES(moyenne) == divo.moyenne */
-
 
123
		$db->requeter(sprintf('INSERT INTO del_image_stat (ce_image, ce_protocole, moyenne, nb_votes)'.
-
 
124
							  ' SELECT ce_image, ce_protocole, AVG(valeur) AS moyenne, COUNT(valeur) AS nb_votes'.
-
 
125
							  ' FROM del_image_vote divo'.
-
 
126
							  ' WHERE ce_image = %d AND ce_protocole = %d GROUP BY ce_image, ce_protocole'.
-
 
127
							  ' ON DUPLICATE KEY UPDATE moyenne = VALUES(moyenne), nb_votes = VALUES(nb_votes)',
-
 
128
							  $id_image, $id_proto));
-
 
129
		
-
 
130
 
-
 
131
	}
108
	
132
 
109
	/*-------------------------------------------------------------------------------
133
	/*-------------------------------------------------------------------------------
110
	 							CONFIGURATION DU SERVICE
134
	 							CONFIGURATION DU SERVICE
111
	 --------------------------------------------------------------------------------*/
135
	 --------------------------------------------------------------------------------*/
112
	/**
136
	/**
113
	 * Configuration du service en fonction du fichier de config config_del.ini
137
	 * Configuration du service en fonction du fichier de config config_del.ini
114
	 * */
138
	 * */
115
	public function configurer() {
139
	public function configurer() {
116
		$this->mappingFiltre = $this->conteneur->getParametre('mapping_masque');
140
		$this->mappingFiltre = $this->conteneur->getParametre('mapping_masque');
117
		$this->mappingVotes = $this->conteneur->getParametre('mapping_votes');
141
		$this->mappingVotes = $this->conteneur->getParametre('mapping_votes');
118
	}
142
	}
119
	
143
	
120
	/**
144
	/**
121
	 * Vérifier que le service est bien configuré 
145
	 * Vérifier que le service est bien configuré 
122
	 * */
146
	 * */
123
	public function verifierConfiguration() {
147
	public function verifierConfiguration() {
124
	
148
	
125
		$erreurs = array();
149
		$erreurs = array();
126
		$tableauImages = $this->conteneur->getParametre('images');
150
		$tableauImages = $this->conteneur->getParametre('images');
127
		if (empty($tableauImages)) {
151
		if (empty($tableauImages)) {
128
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [images] ou celui-ci est vide ;'; 
152
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [images] ou celui-ci est vide ;'; 
129
		} else {
153
		} else {
130
			if ($this->conteneur->getParametre('url_service') == null) {
154
			if ($this->conteneur->getParametre('url_service') == null) {
131
				$erreurs[] = '- paramètre "url_service" manquant ;';
155
				$erreurs[] = '- paramètre "url_service" manquant ;';
132
			}
156
			}
133
		}
157
		}
134
 
158
 
135
		if (empty($this->mappingVotes)) {
159
		if (empty($this->mappingVotes)) {
136
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_votes] ou celui-ci est vide ;';
160
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_votes] ou celui-ci est vide ;';
137
		} else {
161
		} else {
138
			$champsMappingObs = array('ce_protocole','id_vote','valeur','ce_image', 'ce_utilisateur', 'nom', 'prenom');
162
			$champsMappingObs = array('ce_protocole','id_vote','valeur','ce_image', 'ce_utilisateur', 'nom', 'prenom');
139
			foreach ($champsMappingObs as $champ) {
163
			foreach ($champsMappingObs as $champ) {
140
				if (!isset($this->mappingVotes[$champ])) {
164
				if (!isset($this->mappingVotes[$champ])) {
141
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour le vote est manquant ;';
165
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour le vote est manquant ;';
142
				}				
166
				}				
143
			}
167
			}
144
		}
168
		}
145
		
169
		
146
		
170
		
147
		if (!empty($erreurs)) {
171
		if (!empty($erreurs)) {
148
			$e = 'Erreur lors de la configuration : '."\n";
172
			$e = 'Erreur lors de la configuration : '."\n";
149
			$e .= implode("\n", $erreurs);
173
			$e .= implode("\n", $erreurs);
150
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
174
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
151
		}
175
		}
152
	}
176
	}
153
	
177
	
154
	
178
	
155
	public function verifierParametresAjoutModif($ressources, $parametres) {
179
	public function verifierParametresAjoutModif($ressources, $parametres) {
156
		$erreurs = array();
180
		$erreurs = array();
157
		if (!is_numeric($ressources[0])) {
181
		if (!is_numeric($ressources[0])) {
158
			$erreurs[] = '- le paramètre indiquant l\'identifiant de l\'image doit être numérique ;';
182
			$erreurs[] = '- le paramètre indiquant l\'identifiant de l\'image doit être numérique ;';
159
		}
183
		}
160
			
184
			
161
		if (!isset($parametres['utilisateur'])) {
185
		if (!isset($parametres['utilisateur'])) {
162
			$erreurs[] = '- paramètre "utilisateur" manquant ;';
186
			$erreurs[] = '- paramètre "utilisateur" manquant ;';
163
		}
187
		}
164
	
188
	
165
		if (!isset($parametres['protocole'])) {
189
		if (!isset($parametres['protocole'])) {
166
			$erreurs[] = '- paramètre "id_protocole" manquant ;';
190
			$erreurs[] = '- paramètre "id_protocole" manquant ;';
167
		} else {
191
		} else {
168
			if (!is_numeric($parametres['protocole'])) {
192
			if (!is_numeric($parametres['protocole'])) {
169
				$erreurs[] = '- le paramètre "protocole" doit être numérique ;';
193
				$erreurs[] = '- le paramètre "protocole" doit être numérique ;';
170
			}
194
			}
171
		}
195
		}
172
			
196
			
173
		if (!isset($parametres['valeur'])) {
197
		if (!isset($parametres['valeur'])) {
174
			$erreurs[] = '- paramètre "valeur" manquant ;';
198
			$erreurs[] = '- paramètre "valeur" manquant ;';
175
		} else {
199
		} else {
176
			if (!is_numeric($parametres['valeur'])) {
200
			if (!is_numeric($parametres['valeur'])) {
177
				$erreurs[] = '- le paramètre "valeur" doit être numérique ;';
201
				$erreurs[] = '- le paramètre "valeur" doit être numérique ;';
178
			}
202
			}
179
		}
203
		}
180
			
204
			
181
		if (!empty($erreurs)) {
205
		if (!empty($erreurs)) {
182
			$e = 'Erreur lors de la configuration : '."\n";
206
			$e = 'Erreur lors de la configuration : '."\n";
183
			$e .= implode("\n", $erreurs);
207
			$e .= implode("\n", $erreurs);
184
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
208
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
185
		}
209
		}
186
	}
210
	}
187
 
211
 
188
	
212
	
189
	/**
213
	/**
190
	* Charger la clause WHERE en fonction des paramètres de masque
214
	* Charger la clause WHERE en fonction des paramètres de masque
191
	* */
215
	* */
192
	private function chargerClauseWhere() {
216
	private function chargerClauseWhere() {
193
		$where[] = 'WHERE ce_image = '.$this->proteger($this->ressources[0]);
217
		$where[] = 'WHERE ce_image = '.$this->proteger($this->ressources[0]);
194
		if (isset($this->parametres['protocole'])) {
218
		if (isset($this->parametres['protocole'])) {
195
			$where[] = 'ce_protocole = '.$this->proteger($this->parametres['protocole']);
219
			$where[] = 'ce_protocole = '.$this->proteger($this->parametres['protocole']);
196
		}
220
		}
197
		return implode(' AND ', $where);
221
		return implode(' AND ', $where);
198
	}	
222
	}	
199
	/*-------------------------------------------------------------------------------
223
	/*-------------------------------------------------------------------------------
200
								CHARGEMENT DES IMAGES 
224
								CHARGEMENT DES IMAGES 
201
	--------------------------------------------------------------------------------*/
225
	--------------------------------------------------------------------------------*/
202
	/**
226
	/**
203
	* Charger les votes pour chaque image
227
	* Charger les votes pour chaque image
204
	* */
228
	* */
205
	private function chargerVotes() {
229
	private function chargerVotes() {
206
		$requeteVotes = 'SELECT * FROM '.
230
		$requeteVotes = 'SELECT * FROM '.
207
						$this->gestionBdd->formaterTable('del_image_vote').
231
						$this->gestionBdd->formaterTable('del_image_vote').
208
						$this->chargerClauseWhere();
232
						$this->chargerClauseWhere();
209
		$resultatsVotes = $this->bdd->recupererTous($requeteVotes);
233
		$resultatsVotes = $this->bdd->recupererTous($requeteVotes);
210
		$votes = $this->formaterVotes($resultatsVotes);
234
		$votes = $this->formaterVotes($resultatsVotes);
211
		return $votes;
235
		return $votes;
212
	}
236
	}
213
	
237
	
214
	/**
238
	/**
215
	* Compter le nombre total d'images dans la base pour affichage dans entete.
239
	* Compter le nombre total d'images dans la base pour affichage dans entete.
216
	* */
240
	* */
217
	private function compterVotes() {
241
	private function compterVotes() {
218
		$requete = 'SELECT FOUND_ROWS() AS nbre ';
242
		$requete = 'SELECT FOUND_ROWS() AS nbre ';
219
		$resultats = $this->bdd->recuperer($requete);
243
		$resultats = $this->bdd->recuperer($requete);
220
		return (int) $resultats['nbre'];
244
		return (int) $resultats['nbre'];
221
	}	
245
	}	
222
 
246
 
223
	
247
	
224
	/*-------------------------------------------------------------------------------
248
	/*-------------------------------------------------------------------------------
225
								FORMATER ET METTRE EN FORME
249
								FORMATER ET METTRE EN FORME
226
	--------------------------------------------------------------------------------*/
250
	--------------------------------------------------------------------------------*/
227
	
251
	
228
	/**
252
	/**
229
	*  Formater une observation depuis une ligne liaison
253
	*  Formater une observation depuis une ligne liaison
230
	*  @param $liaison liaison issue de la recherche
254
	*  @param $liaison liaison issue de la recherche
231
	*  @return $observation l'observation mise en forme
255
	*  @return $observation l'observation mise en forme
232
	* */
256
	* */
233
	private function formaterVotes($votes) {
257
	private function formaterVotes($votes) {
234
		$retour = array();
258
		$retour = array();
235
		foreach ($votes as $vote) {
259
		foreach ($votes as $vote) {
236
			foreach ($vote as $p=>$valeur) {
260
			foreach ($vote as $p=>$valeur) {
237
				$retour[$vote['id_vote']][$this->mappingVotes[$p]] = $valeur;
261
				$retour[$vote['id_vote']][$this->mappingVotes[$p]] = $valeur;
238
			}
262
			}
239
		}
263
		}
240
		
264
		
241
		return $retour;
265
		return $retour;
242
	}
266
	}
243
	
267
	
244
	private function proteger($valeur) {
268
	private function proteger($valeur) {
245
		if (is_array($valeur)) {
269
		if (is_array($valeur)) {
246
			return $this->bdd->protegerTableau($valeur);
270
			return $this->bdd->protegerTableau($valeur);
247
		} else {
271
		} else {
248
			return $this->bdd->proteger($valeur);
272
			return $this->bdd->proteger($valeur);
249
		}
273
		}
250
	}
274
	}
251
}
275
}
252
?>
276
?>