Subversion Repositories eFlore/Applications.del

Rev

Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
720 gduche 1
<?php
2
// declare(encoding='UTF-8');
3
/**
737 gduche 4
	* Le web service observations récupère toutes les observations et, pour chacune d'elle, les
5
	* images qui lui sont associées.
720 gduche 6
 *
7
 * @category	php 5.2
8
 * @package	del
9
 * @subpackage images
10
 * @author		Jean-Pascal MILCENT <jpm@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
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 $
737 gduche 15
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Observations
720 gduche 16
 */
17
 
755 gduche 18
class ListeObservations {
1297 gduche 19
 
720 gduche 20
	private $conteneur;
726 gduche 21
	private $navigation;
22
	private $masque;
737 gduche 23
	private $gestionBdd;
24
	private $bdd;
797 aurelien 25
	private $parametres = array();
26
	private $ressources = array();
800 aurelien 27
	private $tri = 'date_transmission';
28
	private $directionTri = 'desc';
1298 jpm 29
 
720 gduche 30
	public function __construct(Conteneur $conteneur = null) {
31
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
790 aurelien 32
		$this->conteneur->chargerConfiguration('config_departements_bruts.ini');
776 aurelien 33
		$this->conteneur->chargerConfiguration('config_observations.ini');
797 aurelien 34
		$this->conteneur->chargerConfiguration('config_mapping_votes.ini');
950 aurelien 35
		$this->conteneur->chargerConfiguration('config_mapping_commentaires.ini');
726 gduche 36
		$this->navigation = $conteneur->getNavigation();
37
		$this->masque = $conteneur->getMasque();
737 gduche 38
		$this->gestionBdd = $conteneur->getGestionBdd();
39
		$this->bdd = $this->gestionBdd->getBdd();
720 gduche 40
	}
1298 jpm 41
 
720 gduche 42
	/**
1297 gduche 43
	 * RequeteSansParametres
1298 jpm 44
	 *
1297 gduche 45
	 * permet de vérifier qu'il n'y a aucun paramètre dans la requete, excepté les informations de start et limite,
46
	 * pour ajuster la requête pour un gain de temps
47
	 * @param array $ressources les ressources telles qu'elles sont passées au script
48
	 * @param array $parametres les paramètres tels qu'il sont passés au script
49
	 * */
50
	public function requeteSansParametres($ressources, $parametres) {
51
		$estSansParametres = true;
1298 jpm 52
 
1297 gduche 53
		if (sizeof($ressources) > 0) {
54
			$estSansParametres = false;
55
		}
1298 jpm 56
 
1297 gduche 57
		if (sizeof($parametres) > 2) {
58
			// s'il y a plus de 2 paramètres, on est forcément dans le cas où on a demandé des paramètres autre que la navigation
59
			$estSansParametres = false;
60
		} else {
61
			if (sizeof($parametres) == 1) {
62
				if (!(isset($parametres['navigation.depart']) || isset($parametres['navigation.limite']))) {
63
					// s'il y a des paramètres, seul les paramètres de navigation n'interfère pas sur la requête
64
					$estSansParametres = false;
65
				}
66
			} elseif (sizeof($parametres) == 2) {
67
				// s'il y a des paramètres, seul les paramètres de navigation n'interfère pas sur la requête
68
				if (!(isset($parametres['navigation.depart']) && isset($parametres['navigation.limite']))) {
69
					$estSansParametres = false;
70
				}
71
			}
72
		}
1298 jpm 73
 
1297 gduche 74
		return $estSansParametres;
75
	}
1298 jpm 76
 
1297 gduche 77
	/**
720 gduche 78
	 * Méthode principale de la classe.
1298 jpm 79
	 * Lance la récupération des images dans la base et les place dans un objet ResultatService
720 gduche 80
	 * pour l'afficher.
81
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
82
	 * @param array $parametres les paramètres situés après le ? dans l'url
83
	 * */
84
	public function consulter($ressources, $parametres) {
797 aurelien 85
		$this->initialiserRessourcesEtParametres($ressources, $parametres);
720 gduche 86
		$this->configurer();
87
		$this->verifierConfiguration();
800 aurelien 88
		$this->verifierParametresTri();
89
		$this->initialiserTri();
1297 gduche 90
 
1298 jpm 91
		$resultat = new ResultatService();
1297 gduche 92
		if ($this->requeteSansParametres($ressources, $parametres)) {
93
			$liaisons = $this->chargerLiaisonsSimple();
94
			$observations = $this->chargerObservations($liaisons);
95
			$total = $this->compterObservations();
96
			$this->navigation->setTotal($total);
97
			$observations = $this->chargerImages($observations);
98
			$observations = $this->chargerDeterminations($observations);
1298 jpm 99
 
1297 gduche 100
			//Compute
101
			$resultats = array();
102
			foreach ($observations as $id => $observation) {
103
				$idObs = $observation['id_observation'];
104
				$resultats['"'.$idObs.'"'] = $observation;
105
			}
1298 jpm 106
 
1297 gduche 107
			// Mettre en forme le résultat et l'envoyer pour affichage
108
			$resultat->corps = array('entete' => $this->conteneur->getEntete(), 'resultats' => $resultats);
109
		} else {
110
			$liaisons = $this->chargerLiaisons();
111
			$total = $this->compterObservations();
112
			$this->navigation->setTotal($total);
113
			$observations = $this->chargerObservations($liaisons);
114
			$observations = $this->chargerImages($observations);
115
			$observations = $this->chargerDeterminations($observations);
1298 jpm 116
 
1297 gduche 117
			// Mettre en forme le résultat et l'envoyer pour affichage
118
			$resultat->corps = array('entete' => $this->conteneur->getEntete(), 'resultats' => $observations);
119
		}
1298 jpm 120
		return $resultat;
720 gduche 121
	}
1298 jpm 122
 
797 aurelien 123
	private function initialiserRessourcesEtParametres($ressources, $parametres) {
124
		$this->ressources = $ressources;
125
		$this->parametres = $parametres;
126
	}
1298 jpm 127
 
800 aurelien 128
	private function verifierParametresTri() {
129
		$erreurs = array();
130
		$tris_possibles = $this->conteneur->getParametre('tris_possibles');
131
		$tris_possibles_tableau = explode(',', $tris_possibles);
132
		if(isset($this->parametres['tri']) && !in_array($this->parametres['tri'], $tris_possibles_tableau)) {
133
			$erreurs[] = '- le type de tri demandé est incorrect, les valeurs possibles sont '.$tris_possibles.' ;';
134
		}
1298 jpm 135
 
800 aurelien 136
		$directions_tri = array('asc', 'desc');
137
		if(isset($this->parametres['ordre']) && !in_array($this->parametres['ordre'], $directions_tri)) {
138
			$erreurs[] = '- la direction du tri demandé est incorrecte, les valeurs supportées sont asc ou desc ;';
139
		}
1298 jpm 140
 
800 aurelien 141
		if (!empty($erreurs)) {
142
			$e = 'Erreur lors de l\'analyse des parametres du tri : '."\n";
143
			$e .= implode("\n", $erreurs);
144
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
145
		}
146
	}
1298 jpm 147
 
800 aurelien 148
	private function initialiserTri() {
149
		$this->tri = isset($this->parametres['tri']) ? $this->parametres['tri'] : $this->tri;
150
		$this->directionTri = isset($this->parametres['ordre']) ? $this->parametres['ordre'] : $this->directionTri;
151
	}
720 gduche 152
	/*-------------------------------------------------------------------------------
153
	 							CONFIGURATION DU SERVICE
154
	 --------------------------------------------------------------------------------*/
155
	/**
156
	 * Configuration du service en fonction du fichier de config config_del.ini
157
	 * */
755 gduche 158
	private function configurer() {
720 gduche 159
		$this->mappingFiltre = $this->conteneur->getParametre('mapping_masque');
160
		$this->mappingObservation = $this->conteneur->getParametre('mapping_observation');
787 delphine 161
		$this->mappingVotes = $this->conteneur->getParametre('mapping_votes');
950 aurelien 162
		$this->mappingCommentaire = $this->conteneur->getParametre('mapping_commentaire');
720 gduche 163
	}
1298 jpm 164
 
720 gduche 165
	/**
1298 jpm 166
	 * Vérifier que le service est bien configuré
720 gduche 167
	 * */
755 gduche 168
	private function verifierConfiguration() {
720 gduche 169
		$erreurs = array();
755 gduche 170
		$tableauObservations = $this->conteneur->getParametre('observations');
171
		if (empty($tableauObservations)) {
1298 jpm 172
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [images] ou celui-ci est vide ;';
720 gduche 173
		} else {
737 gduche 174
			if ($this->conteneur->getParametre('url_service') == null) {
720 gduche 175
				$erreurs[] = '- paramètre "url_service" manquant ;';
176
			}
1298 jpm 177
 
737 gduche 178
			if ($this->conteneur->getParametre('url_images') == null) {
720 gduche 179
				$erreurs[] = '- paramètre "url_images" manquant ;';
180
			}
181
		}
182
 
183
		if (empty($this->mappingObservation)) {
184
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_observation] ou celui-ci est vide ;';
185
		} else {
1298 jpm 186
			$champsMappingObs = array('id_observation', 'date_observation', 'date_transmission', 'famille',
187
				'nom_sel', 'nom_sel_nn', 'nt', 'ce_zone_geo', 'zone_geo', 'lieudit', 'station', 'courriel',
188
				'ce_utilisateur', 'nom', 'prenom');
189
 
720 gduche 190
			foreach ($champsMappingObs as $champ) {
191
				if (!isset($this->mappingObservation[$champ])) {
192
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour l\'observation est manquant ;';
1298 jpm 193
				}
720 gduche 194
			}
195
		}
1298 jpm 196
 
950 aurelien 197
		if (empty($this->mappingCommentaire)) {
198
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_commentaire] ou celui-ci est vide ;';
199
		} else {
1298 jpm 200
			$champsMappingCom = array('id_commentaire', 'texte', 'ce_utilisateur', 'utilisateur_nom',
201
				'utilisateur_prenom', 'utilisateur_courriel', 'date');
950 aurelien 202
			foreach ($champsMappingCom as $champ) {
203
				if (!isset($this->mappingCommentaire[$champ])) {
204
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour le commentaire est manquant ;';
205
				}
206
			}
207
		}
1298 jpm 208
 
720 gduche 209
		if (empty($this->mappingFiltre)) {
210
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_masque] ou celui-ci est vide ;';
211
		} else {
212
			$champsMappingFiltre = array('famille', 'ns', 'nn', 'date', 'tag', 'commune');
213
			foreach ($champsMappingFiltre as $champ) {
214
				if (!isset($this->mappingFiltre[$champ])) {
215
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour l\'observation est manquant ;';
1298 jpm 216
				}
720 gduche 217
			}
218
		}
1298 jpm 219
 
720 gduche 220
		if (!empty($erreurs)) {
221
			$e = 'Erreur lors de la configuration : '."\n";
222
			$e .= implode("\n", $erreurs);
223
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
737 gduche 224
		}
720 gduche 225
	}
1298 jpm 226
 
720 gduche 227
	/**
228
	 * Obtenir une chaine de caractère concaténant nom et prénom séparé par une virgule
229
	 * @param String $auteurId l'identifiant de l'auteur
230
	 * @return String la chaine de concaténation
231
	 * */
232
	private function getChaineNomPrenom($auteurId) {
233
		$nomPrenom = explode(' ', $auteurId);
234
		$nomPrenom = $this->proteger($nomPrenom);
235
		$chaineNomPrenom = implode(', ', $nomPrenom);
236
		return $chaineNomPrenom;
237
	}
1298 jpm 238
 
720 gduche 239
	/**
240
	* Charger la clause WHERE en fonction des paramètres de masque
241
	* */
242
	private function chargerClauseWhere() {
243
		$where = array();
737 gduche 244
		$tableauMasque = $this->masque->getMasque();
245
		if (!empty($tableauMasque)) {
1298 jpm 246
			foreach ($tableauMasque as $idMasque => $valeurMasque) {
737 gduche 247
				$idMasque = str_replace('masque.', '', $idMasque);
248
				switch ($idMasque) {
249
					// nom du masque => nom BDD
250
					case 'auteur' :
797 aurelien 251
						$whereAuteur = ' '.$this->creerFiltreAuteur($this->masque->getMasque('auteur'));
1298 jpm 252
						if ($whereAuteur != '') {
797 aurelien 253
							$where[] = $whereAuteur;
254
						}
737 gduche 255
						break;
790 aurelien 256
					case 'date' :
797 aurelien 257
						$whereDate = ' '.$this->creerFiltreDate($valeurMasque);
1298 jpm 258
						if ($whereDate != '') {
797 aurelien 259
							$where[] = $whereDate;
260
						}
790 aurelien 261
						break;
737 gduche 262
					case 'departement' :
797 aurelien 263
						$where[] = ' '.$this->creerFiltreIdZoneGeo($valeurMasque);
737 gduche 264
						break;
265
					case 'genre' :
744 gduche 266
						$where[] = ' '.$this->mappingFiltre['ns'].' LIKE '.$this->proteger('%'.$valeurMasque.'% %');
737 gduche 267
						break;
268
					case 'tag' :
797 aurelien 269
						$where[] = ' '.$this->creerFiltreMotsCles($valeurMasque);
737 gduche 270
						break;
776 aurelien 271
					case 'ns' :
797 aurelien 272
						$where[] = ' nom_sel LIKE '.$this->proteger($valeurMasque.'%');
1298 jpm 273
						break;
790 aurelien 274
					case 'commune' :
797 aurelien 275
						$where[] = ' '.$this->mappingFiltre[$idMasque].' LIKE '.$this->proteger(str_replace(array('-',' '), '_', $valeurMasque).'%');
1298 jpm 276
						break;
790 aurelien 277
					case 'masque' :
797 aurelien 278
						$where[] = ' '.$this->creerFiltreMasqueGeneral($valeurMasque);
1298 jpm 279
						break;
1097 gduche 280
					case 'type' :
1104 gduche 281
						//TODO : en discussion doit faire ressortir les observations qui ont plusieurs propositions de nom OU celle qui ont plus de N commentaires
1102 gduche 282
						$tableauTypes = explode(';', $valeurMasque);
1138 aurelien 283
						$requeteType = array();
1298 jpm 284
 
1102 gduche 285
						if (in_array('adeterminer', $tableauTypes)) {
1097 gduche 286
							//On récupère toutes les observations qui on le tag "aDeterminer" ou qui n'ont pas de nom d'espèce
1240 gduche 287
							$requeteType[] = '(dob.mots_cles_texte = '.$this->proteger($this->conteneur->getParametre('tag_adeterminer')).' OR nom_sel_nn IS NULL) ';
1138 aurelien 288
						}
289
 
290
						if (in_array('aconfirmer', $tableauTypes)) {
1097 gduche 291
							//On récupère toutes les observations qui ne sont pas "aDeterminer" et qui ont un nom d'espèce
1138 aurelien 292
							$requeteType[] = '(nom_sel is not null AND dob.mots_cles_texte NOT LIKE '.$this->proteger($this->conteneur->getParametre('tag_adeterminer')).') ';
1102 gduche 293
						}
1298 jpm 294
 
1102 gduche 295
						if (in_array('endiscussion', $tableauTypes)) {
1097 gduche 296
							//Si on veut les observations en discussion, on va récupérer les ids des observations dont le nombre de commentaire est supérieur à N
297
							$idsObservations = $this->chargerIdsObservationsParNbCommentaires();
1138 aurelien 298
							if(!empty($idsObservations)) {
299
								$requeteType[] = 'dob.id_observation IN ('.$idsObservations.') ';
300
							} else {
301
								$requeteType[] = 'dob.id_observation IN (NULL) ';
302
							}
1097 gduche 303
						}
1298 jpm 304
						if ($valeurMasque != '') {
1138 aurelien 305
						  $where[] = implode(' OR ', $requeteType);
306
						}
1298 jpm 307
						break;
737 gduche 308
					default:
797 aurelien 309
						$where[] = ' '.$this->mappingFiltre[$idMasque].' = '.$this->proteger($valeurMasque);
1298 jpm 310
						break;
737 gduche 311
				}
1298 jpm 312
			}
720 gduche 313
		}
1298 jpm 314
 
720 gduche 315
		if (!empty($where)) {
316
			return ' WHERE '.implode('AND', $where);
317
		} else {
318
			return;
319
		}
320
	}
1298 jpm 321
 
1097 gduche 322
	public function chargerIdsObservationsParNbCommentaires() {
1298 jpm 323
		$requeteIdsObservations = 'SELECT ce_observation '.
324
			'FROM del_commentaire '.
325
			'GROUP BY ce_observation '.
326
			'HAVING count(id_commentaire) > '.$this->conteneur->getParametre('nb_commentaires_discussion');
1097 gduche 327
		$listeIdsObservations = $this->bdd->recupererTous($requeteIdsObservations);
328
		$idsObservations = '';
329
		foreach ($listeIdsObservations as $idObservation) {
330
			$idsObservations .= $idObservation['ce_observation'].',';
1298 jpm 331
 
1097 gduche 332
		}
333
		$idsObservations = rtrim($idsObservations, ',');
334
		return $idsObservations;
335
	}
1298 jpm 336
 
790 aurelien 337
	private function creerFiltreMasqueGeneral($valeurMasque) {
797 aurelien 338
		//TODO: affecter d'aborder les variables, puis les tester pour les
339
		// ajouter à la chaine
790 aurelien 340
		$whereAuteur = $this->creerFiltreAuteur($valeurMasque);
797 aurelien 341
		$whereIdZoneGeo = $this->creerFiltreIdZoneGeo($valeurMasque);
1298 jpm 342
 
790 aurelien 343
		$masqueGeneral = '( '.
1298 jpm 344
			(($whereAuteur != '') ? $whereAuteur.' OR ' : '' ).
345
			(($whereIdZoneGeo != '') ? $whereIdZoneGeo.' OR ' : '' ).
346
			'zone_geo LIKE '.$this->proteger($this->remplacerParJokerCaractere($valeurMasque).'%').' OR '.
347
			$this->creerFiltreMotsCles($valeurMasque).' OR '.
348
			'nom_sel LIKE '.$this->proteger($valeurMasque.'%').' OR '.
349
			'famille LIKE '.$this->proteger($valeurMasque.'%').' OR '.
350
			'milieu LIKE '.$this->proteger($valeurMasque).' OR '.
351
			$this->mappingFiltre['ns'].' LIKE '.$this->proteger('%'.$valeurMasque.'% %').' OR '.
352
			$this->creerFiltreDate($valeurMasque).
353
			') ';
354
 
790 aurelien 355
		return $masqueGeneral;
356
	}
1298 jpm 357
 
790 aurelien 358
	private function creerFiltreAuteur($valeurMasque) {
359
		$masque = '';
360
		$auteurId = $valeurMasque;
361
		if (is_numeric($auteurId)) {
362
			$masque = ' ce_utilisateur = '.$auteurId;
363
		} else {
1278 aurelien 364
		if (strpos($auteurId, '@') === false) {
790 aurelien 365
				$tableauNomPrenom = explode(' ',$auteurId, 2);
366
				if(count($tableauNomPrenom) == 2) {
367
					// on teste potentiellement un nom prenom ou bien un prénom nom
368
					$masque = '('.
1298 jpm 369
						'(nom LIKE '.$this->proteger($tableauNomPrenom[0].'%').' AND '.
370
						'prenom LIKE '.$this->proteger($tableauNomPrenom[1].'%').') OR '.
371
						'(nom LIKE '.$this->proteger($tableauNomPrenom[1].'%').' AND '.
372
						'prenom LIKE '.$this->proteger($tableauNomPrenom[0].'%').') OR '.
373
						'(dob.nom_utilisateur LIKE '.$this->proteger($tableauNomPrenom[0].'%').' AND '.
374
						'dob.prenom_utilisateur LIKE '.$this->proteger($tableauNomPrenom[1].'%').') OR '.
375
						'(dob.nom_utilisateur LIKE '.$this->proteger($tableauNomPrenom[1].'%').' AND '.
376
						'dob.prenom_utilisateur LIKE '.$this->proteger($tableauNomPrenom[0].'%').') '.
377
						')';
790 aurelien 378
				} else {
379
					$masque = '(
1298 jpm 380
						(nom LIKE '.$this->proteger($auteurId.'%').' OR '.
381
						'prenom LIKE '.$this->proteger($auteurId.'%').' OR '.
382
						'dob.nom_utilisateur LIKE '.$this->proteger($auteurId.'%').' OR '.
383
						'dob.prenom_utilisateur LIKE '.$this->proteger($auteurId.'%').')'.
384
						')';
790 aurelien 385
				}
386
			} else {
1298 jpm 387
				$masque = ' courriel LIKE '.$this->proteger($valeurMasque.'%').
388
					' OR dob.courriel_utilisateur LIKE '.$this->proteger($valeurMasque.'%').' ';
790 aurelien 389
			}
390
		}
391
		return $masque;
392
	}
1298 jpm 393
 
790 aurelien 394
	private function remplacerParJokerCaractere($valeurMasque) {
395
		return str_replace(array('-',' '), '_', $valeurMasque);
396
	}
1298 jpm 397
 
797 aurelien 398
	//TODO: déplacer les fonctions ci dessus et dessous dans une classe
790 aurelien 399
	// utilitaire
1298 jpm 400
	function supprimerAccents($str, $charset='utf-8') {
790 aurelien 401
		$str = htmlentities($str, ENT_NOQUOTES, $charset);
1298 jpm 402
 
790 aurelien 403
		$str = preg_replace('#&([A-za-z])(?:acute|cedil|circ|grave|orn|ring|slash|th|tilde|uml);#', '\1', $str);
404
		$str = preg_replace('#&([A-za-z]{2})(?:lig);#', '\1', $str); // pour les ligatures e.g. '&oelig;'
405
		$str = preg_replace('#&[^;]+;#', '', $str); // supprime les autres caractères
1298 jpm 406
 
790 aurelien 407
		return $str;
408
	}
1298 jpm 409
 
790 aurelien 410
	private function obtenirIdDepartement($nomDpt) {
411
		$nomDpt = $this->supprimerAccents($nomDpt);
412
		$nomDpt = strtolower(str_replace(' ','-',$nomDpt));
1298 jpm 413
 
790 aurelien 414
		$idDpt = $this->conteneur->getParametre($nomDpt);
1298 jpm 415
		if ($idDpt == null || $idDpt == ' ') {
790 aurelien 416
			$idDpt = ' ';
417
		}
418
		return $idDpt;
419
	}
1298 jpm 420
 
790 aurelien 421
	private function creerFiltreIdZoneGeo($valeurMasque) {
422
		$masque = '';
423
		$dept = $valeurMasque;
424
		if (is_numeric($dept)) {
425
			$dept = sprintf('%02s', $dept);
426
			$dept = sprintf("%-'_5s", $dept);
427
			$masque = " ce_zone_geo LIKE ".$this->proteger('INSEE-C:'.$dept);
428
		} else {
429
			$deptId = $this->conteneur->getParametre($dept);
430
			if ($deptId != null) {
431
				$masque = " ce_zone_geo LIKE ".$this->proteger('INSEE-C:'.$deptId.'%');
432
			} else {
433
				$id = $this->obtenirIdDepartement($valeurMasque);
434
				$masque = " ce_zone_geo LIKE ".$this->proteger('INSEE-C:'.$id.'%');
435
			}
436
		}
437
		return $masque;
438
	}
1298 jpm 439
 
790 aurelien 440
	private function creerFiltreDate($valeurMasque) {
441
		//TODO: définir dans le fichier de config un tableau contenant plusieurs format de date
442
		// autorisés pour la recherche, qui seraient ajoutés au OR
443
		$masque = '(';
444
		$masque .= (is_numeric($valeurMasque)) ? ' YEAR(date_observation) = '.$this->proteger($valeurMasque).' OR ' : '';
1298 jpm 445
		$masque .= " DATE_FORMAT(date_observation, '%d/%m/%Y') = ".$this->proteger($valeurMasque).' )';
790 aurelien 446
		return $masque;
447
	}
1298 jpm 448
 
790 aurelien 449
	private function creerFiltreMotsCles($valeurMasque) {
800 aurelien 450
		$mots_cles = explode(' ', $valeurMasque);
451
		$requeteMotsClesImg = '';
452
		$requeteMotsClesObs = '';
453
		//TODO voir s'il existe un moyen plus simple que le foreach + rtrim
806 aurelien 454
		// comme avec implode (attention au fait que l'on concatène des % au début et à la fin)
800 aurelien 455
		foreach($mots_cles as $mot_cle) {
456
			$requeteMotsCles = $this->proteger('%'.$mot_cle.'%');
1298 jpm 457
			$requeteMotsClesImg .= "di.mots_cles_texte LIKE $requeteMotsCles AND ";
458
			$requeteMotsClesObs .= "dob.mots_cles_texte LIKE $requeteMotsCles AND ";
800 aurelien 459
		}
460
		$requeteMotsClesImg = rtrim($requeteMotsClesImg, ' AND ');
461
		$requeteMotsClesObs = rtrim($requeteMotsClesObs, ' AND ');
1298 jpm 462
 
463
		$masque = "( ($requeteMotsClesImg) OR ($requeteMotsClesObs) ) ";
464
		return $masque;
790 aurelien 465
	}
1298 jpm 466
 
720 gduche 467
	/*-------------------------------------------------------------------------------
1298 jpm 468
								CHARGEMENT DES OBSERVATIONS
720 gduche 469
	--------------------------------------------------------------------------------*/
470
	/**
471
	* Chargement depuis la bdd de toutes les liaisons entre images et observations
472
	* */
473
	private function chargerLiaisons() {
1298 jpm 474
		$requeteLiaisons = 'SELECT SQL_CALC_FOUND_ROWS '.
475
			'	dob.id_observation, nom_sel, famille, ce_zone_geo, zone_geo, lieudit, '.
476
			'	station, milieu, date_observation, dob.mots_cles_texte, date_transmission, di.id_image, '.
477
			'	dob.ce_utilisateur, prenom, nom, courriel, '.
478
			'	dob.prenom_utilisateur, dob.nom_utilisateur, dob.courriel_utilisateur, '.
479
			'	nom_original, dob.commentaire AS dob_commentaire, '.
480
			'	dob.nt, dob.nom_sel_nn '.
481
			'FROM del_observation AS dob '.
482
			'	LEFT JOIN del_utilisateur AS du '.
483
			'		ON du.id_utilisateur = dob.ce_utilisateur '.
484
			'	LEFT JOIN del_obs_image AS doi '.
485
			'		ON doi.id_observation = dob.id_observation '.
486
			'	LEFT JOIN del_image AS di '.
487
			'		ON di.id_image = doi.id_image '.
488
			$this->chargerClauseWhere().
489
			' GROUP BY doi.id_observation'.
490
			' ORDER BY '.$this->tri.' '.$this->directionTri.' '.
491
			$this->gestionBdd->getLimitSql();
492
 
720 gduche 493
		return $this->bdd->recupererTous($requeteLiaisons);
494
	}
1298 jpm 495
 
1297 gduche 496
	private function chargerLiaisonsSimple() {
1298 jpm 497
		$requeteObs = 'SELECT SQL_CALC_FOUND_ROWS '.
498
			'	dob.id_observation, nom_sel, famille, ce_zone_geo, zone_geo, lieudit, '.
499
			'	station, milieu, date_observation, dob.mots_cles_texte, date_transmission, '.
500
			'	dob.ce_utilisateur, prenom, nom, courriel, '.
501
			'	dob.prenom_utilisateur, dob.nom_utilisateur, dob.courriel_utilisateur, '.
502
			'	dob.commentaire as dob_commentaire, '.
503
			'	dob.nt, dob.nom_sel_nn '.
504
			'FROM del_observation AS dob '.
505
			'	LEFT JOIN del_utilisateur AS du
506
					ON dob.ce_utilisateur = du.id_utilisateur '.
507
			'ORDER BY id_observation DESC '.
508
			$this->gestionBdd->getLimitSql();
1297 gduche 509
		$liaisons = $this->bdd->recupererTous($requeteObs);
510
 
511
		return $liaisons;
512
	}
1298 jpm 513
 
720 gduche 514
	/**
515
	* Compter le nombre total d'images dans la base pour affichage dans entete.
516
	* */
737 gduche 517
	private function compterObservations() {
720 gduche 518
		$requete = 'SELECT FOUND_ROWS() AS nbre ';
519
		$resultats = $this->bdd->recuperer($requete);
766 aurelien 520
		return (int) $resultats['nbre'];
720 gduche 521
	}
1298 jpm 522
 
720 gduche 523
	/**
524
	* Retourner un tableau d'images formaté en fonction des liaisons trouvées
525
	* @param $liaisons les liaisons de la table del_obs_images
526
	* */
737 gduche 527
	private function chargerObservations($liaisons) {
528
		$observations = array();
720 gduche 529
		foreach ($liaisons as $liaison) {
737 gduche 530
			$idObs = $liaison[$this->mappingObservation['id_observation']];
1298 jpm 531
 
1278 aurelien 532
			if($liaison['ce_utilisateur'] == 0) {
533
				$liaison['prenom'] = $liaison['prenom_utilisateur'];
534
				$liaison['nom'] = $liaison['nom_utilisateur'];
535
			}
1298 jpm 536
 
1297 gduche 537
			$observation = $this->formaterObservation($liaison);
1298 jpm 538
 
539
			// attention, il est important que les index du tableau soient des chaines
1140 aurelien 540
			// de caractères pour que l'ordre d'insertion soit respecté lors de la lecture
541
			// du json par les navigateur (voir bug du moteur javascript v8 #164)
542
			$observations['"'.$idObs.'"'] = $observation;
720 gduche 543
		}
737 gduche 544
		return $observations;
720 gduche 545
	}
1298 jpm 546
 
720 gduche 547
	/**
737 gduche 548
	 * Sélectionner toutes les images de chaque observation
1298 jpm 549
	 * @param array $observations la liste des observations
737 gduche 550
	 * */
755 gduche 551
	private function chargerImages($observations) {
737 gduche 552
		foreach ($observations as $id => $observation) {
1303 gduche 553
			$idObs = $observation['id_observation'];
1298 jpm 554
			$requeteImages = 'SELECT * '.
555
				'FROM del_obs_image AS doi '.
556
				'	INNER JOIN del_image AS di '.
557
				'		ON doi.id_image = di.id_image '.
558
				"WHERE doi.id_observation = $idObs ";
559
 
737 gduche 560
			$images = $this->bdd->recupererTous($requeteImages);
561
			$images = $this->formaterImages($images);
562
			$observations[$id]['images'] = $images;
720 gduche 563
		}
1298 jpm 564
 
737 gduche 565
		return $observations;
720 gduche 566
	}
1298 jpm 567
 
755 gduche 568
	/**
569
	* Récupérer toutes les déterminations et le nombre de commentaire au total
570
	* @param array $observations la liste des observations à mettre à jour
571
	* */
572
	private function chargerDeterminations($observations) {
573
		foreach ($observations as $id => $observation) {
1298 jpm 574
			$idObs = $observation['id_observation'];
575
			$requetePropositions = 'SELECT * '.
576
				'FROM del_commentaire AS dc '.
577
				'WHERE dc.nom_sel IS NOT NULL '.
578
				"	AND ce_observation = $idObs ";
755 gduche 579
			$propositions = $this->bdd->recupererTous($requetePropositions);
841 aurelien 580
			$observations[$id]['commentaires'] = $this->formaterDeterminations($propositions);
755 gduche 581
		}
582
		return $observations;
583
	}
1298 jpm 584
 
755 gduche 585
	/**
781 delphine 586
	 * Charger les votes sur les déterminations
797 aurelien 587
	 * @param Array $observations le tableau des observations à mettre à jour
781 delphine 588
	* */
589
	private function chargerVotes($ids_proposition, $propositions) {
1298 jpm 590
		$listePropositions = implode(', ', $ids_proposition);
591
		$requeteVotes = 'SELECT * '.
592
			'FROM del_commentaire_vote '.
593
			"WHERE ce_proposition IN ($listePropositions)";
594
 
781 delphine 595
		$resultatsVotes = $this->bdd->recupererTous($requeteVotes);
596
		foreach ($resultatsVotes as $vote) {
950 aurelien 597
			$propositions[$vote['ce_proposition']]['votes'][$vote['id_vote']] = $this->formaterVote($vote);
781 delphine 598
		}
599
		return $propositions;
600
	}
1298 jpm 601
 
781 delphine 602
	/**
755 gduche 603
	 * Charger le nombre de commentaires (sans détermination) associé à l'observation
604
	 * @param Array $observations le tableau des observatins à mettre à jour
605
	 * */
781 delphine 606
	private function chargerNombreCommentaire($ids_proposition, $propositions) {
1298 jpm 607
		$listePropositions = implode(', ', $ids_proposition);
608
		$requeteNbCommentaires = 'SELECT ce_commentaire_parent, ce_proposition, COUNT( id_commentaire ) AS nb '.
609
			'FROM del_commentaire '.
610
			"WHERE ce_proposition IN ($listePropositions) ".
611
			'GROUP BY ce_proposition ';
1063 gduche 612
 
613
		$listeCommentaires = $this->bdd->recupererTous($requeteNbCommentaires);
1298 jpm 614
 
1063 gduche 615
		foreach ($listeCommentaires as $ligneProposition) {
616
			// ce test sert à exclure les proposition de 1er niveau qui sont elles aussi des commentaires
617
			if($ligneProposition['ce_commentaire_parent'] != null && $ligneProposition['ce_commentaire_parent'] != 0) {
618
				$propositions[$ligneProposition['ce_commentaire_parent']]['nb_commentaires'] = $ligneProposition['nb'];
619
			} else {
620
				$propositions[$ligneProposition['ce_proposition']]['observation']['nb_commentaires'] = $ligneProposition['nb'];
621
			}
755 gduche 622
		}
781 delphine 623
		return $propositions;
755 gduche 624
	}
1298 jpm 625
 
720 gduche 626
	/*-------------------------------------------------------------------------------
627
								FORMATER ET METTRE EN FORME
628
	--------------------------------------------------------------------------------*/
1298 jpm 629
 
720 gduche 630
	/**
737 gduche 631
	 * Formater les images d'une observation
632
	 * @param array $images les images de l'observation
633
	 * */
634
	private function formaterImages($images) {
635
		$imagesRetour = array();
636
		foreach ($images as $image) {
637
			$imageCourante = array();
638
			$imageCourante['id_image'] = $image['id_image'];
639
			$imageCourante['date'] = $image['date_prise_de_vue'];
640
			$imageCourante['binaire.href'] = $this->formaterLienImage($image['id_image']);
641
			$imageCourante['hauteur'] = $image['hauteur'];
642
			$imageRetour['largeur'] = $image['largeur'];
1298 jpm 643
 
737 gduche 644
			$imagesRetour[] = $imageCourante;
645
		}
646
		return $imagesRetour;
1298 jpm 647
	}
648
 
737 gduche 649
	/**
720 gduche 650
	*  Formater une observation depuis une ligne liaison
651
	*  @param $liaison liaison issue de la recherche
652
	*  @return $observation l'observation mise en forme
653
	* */
654
	private function formaterObservation($liaison) {
655
		$observation = array();
656
		foreach ($this->mappingObservation as $nomOriginal => $nomFinal) {
657
			$observation[$nomFinal] = $liaison[$nomOriginal];
658
		}
745 gduche 659
		$observation['images'] = array();
720 gduche 660
		return $observation;
661
	}
1298 jpm 662
 
720 gduche 663
	/**
664
	 * Formater le lien de l'image en fonction du fichier de config et de l'identifiant de l'image
665
	 * */
666
	private function formaterLienImage($idImage) {
667
		$idImage = sprintf('%09s', $idImage);
668
		$url = $this->conteneur->getParametre('url_images');
669
		$urlImage = str_replace('%s', $idImage, $url);
670
		return $urlImage;
671
	}
1298 jpm 672
 
787 delphine 673
	/**
1298 jpm 674
	 *
950 aurelien 675
	 * Formate une liste de proposition en fonction du fichier de configuration
676
	 */
677
	private function formaterDeterminations($listePropositions) {
678
		$propositions_format = array();
679
		if ($listePropositions != array()) {
680
			foreach ($listePropositions as $id => $proposition) {
681
				$ids_proposition[] = $proposition['id_commentaire'];
1298 jpm 682
 
683
				$proposition_formatee = array('nb_commentaires' => '0');
950 aurelien 684
				foreach ($this->mappingCommentaire as $nomOriginal => $nomFinal) {
1000 delphine 685
					if (isset($proposition[$nomOriginal])) {
686
						$proposition_formatee[$nomFinal] = $proposition[$nomOriginal];
687
					}
950 aurelien 688
				}
689
				$propositions_format[$proposition['id_commentaire']] = $proposition_formatee;
690
			}
691
			$propositions_format = $this->chargerVotes($ids_proposition, $propositions_format);
692
			$propositions_format = $this->chargerNombreCommentaire($ids_proposition, $propositions_format);
693
		}
694
		return $propositions_format;
695
	}
1298 jpm 696
 
950 aurelien 697
	/**
787 delphine 698
	*  Formater un vote en fonction du fichier de configuration config_votes.ini
699
	*  @param $votes array()
700
	* */
950 aurelien 701
	private function formaterVote($vote) {
787 delphine 702
		$retour = array();
703
		foreach ($vote as $param=>$valeur) {
841 aurelien 704
			$retour[$this->mappingVotes[$param]] = $valeur;
787 delphine 705
		}
706
		return $retour;
707
	}
1298 jpm 708
 
720 gduche 709
	private function proteger($valeur) {
710
		if (is_array($valeur)) {
711
			return $this->bdd->protegerTableau($valeur);
712
		} else {
713
			return $this->bdd->proteger($valeur);
714
		}
715
	}
716
}
717
?>