Subversion Repositories eFlore/Applications.cel

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
416 aurelien 1
<?php
550 jpm 2
// declare(encoding='UTF-8');
416 aurelien 3
/**
4
 * Service fournissant une carte dynamique des obsertions publiques du CEL.
5
 * Encodage en entrée : utf8
6
 * Encodage en sortie : utf8
7
 *
8
 * Cas d'utilisation :
9
 * /CelWidgetMap/Carte/Utilisateur : carte des observations publiques d'un utilisateur.
10
 * /CelWidgetMap/Carte/Utilisateur/Projet : carte des observations publiques d'un utilisateur pour un projet.
485 delphine 11
 * /CelWidgetMap/Carte/Utilisateur/Projet/dept : carte des observations publiques d'un utilisateur pour un projet sur un département.
12
 * /CelWidgetMap/Carte/Utilisateur/Projet/dept/num_taxon : carte des observations publiques d'un utilisateur pour un projet sur un département pour un taxon.
416 aurelien 13
 *
14
 * Carte = Type de carte. Valeurs possible : defaut,
15
 * Utilisateur = identifiant (= courriel) de l'utilisateur ou * pour tous les utilisateurs.
16
 * Projet = mot-clé du projet
17
 *
18
 * @author Jean-Pascal MILCENT <jpm@clapas.org>
19
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
20
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
21
 * @version $Id$
22
 * @copyright © 2010, Jean-Pascal MILCENT
23
 */
519 jpm 24
// TODO : supprimer le TRIM quand les obs seront reliées correctements aux localisations (sur le code INSEE par exemple)
416 aurelien 25
class CelWidgetMap extends Cel {
1095 aurelien 26
 
416 aurelien 27
	/**
28
	 * Méthode appelée avec une requête de type GET.
29
	 */
840 jpm 30
	public function getElement($ressources) {
416 aurelien 31
		$retour = null;
840 jpm 32
		extract($this->parametres);
1095 aurelien 33
 
840 jpm 34
		$action = array_shift($ressources);
35
		if (isset($action)) {
36
			$methode = $this->traiterNomMethodeGet($action);
416 aurelien 37
			if (method_exists($this, $methode)) {
840 jpm 38
				$retour = $this->$methode($ressources);
416 aurelien 39
			} else {
840 jpm 40
				$this->messages[] = "Ce type de ressource '$methode' n'est pas disponible.";
416 aurelien 41
			}
42
		} else {
840 jpm 43
			$this->messages[] = "Vous devez indiquer le type de ressource.";
416 aurelien 44
		}
1003 jpm 45
 
416 aurelien 46
		if (is_null($retour)) {
47
			$info = 'Un problème est survenu : '.print_r($this->messages, true);
48
			$this->envoyer($info);
1333 aurelien 49
		} else if (isset($retour['type']) && $retour['type'] == 'jsonVar') {
1095 aurelien 50
 
694 jpm 51
			$this->envoyerJsonVar($retour['variable_js'], $retour['donnees']);
1333 aurelien 52
		}  else if (isset($retour['type']) && $retour['type'] == 'jsonP') {
584 jpm 53
			$this->envoyerJsonp($retour['donnees']);
474 jpm 54
		} else {
938 jpm 55
			$this->envoyerJson($retour);
416 aurelien 56
		}
57
	}
1003 jpm 58
 
416 aurelien 59
	/**
938 jpm 60
	 * Les stations de la carte par défaut
416 aurelien 61
	 */
938 jpm 62
	public function getStations($params) {
1095 aurelien 63
		$json = null;
1333 aurelien 64
		$requete =  'SELECT utm_secteur, utm_x, utm_y, wgs84_latitude AS latitude, wgs84_longitude AS longitude '.
65
                    'FROM cel_obs AS co '.
66
                    '   LEFT JOIN cel_zones_geo AS l '.
67
                    '       ON (l.nom = co.zone_geo AND l.id_zone_geo = co.ce_zone_geo) '.
938 jpm 68
                    "WHERE transmission = '1' ".
69
					$this->construireWhereDept().
70
                    $this->construireWhereCommune().
71
                    $this->construireWhereUtilisateur().
72
					$this->construireWhereNumTaxon().
73
					$this->construireWhereNomTaxon().
74
					$this->construireWhereDate().
940 jpm 75
					$this->construireWhereCommentaire().
938 jpm 76
					$this->construireWhereProjet().
77
					$this->construireWhereTag();
1095 aurelien 78
		//die($requete);
79
		$resultats = $this->requeter($requete);
80
 
81
		// Traitement des résultats
82
		$obs_nbre = $this->traiterNbreObs($resultats);
83
		$stations = $this->traiterStations($resultats);
84
 
85
		// Création des infos du widget
86
		$json['donnees']['points'] = $stations;
87
		$json['donnees']['stats']['communes'] = count($stations);
88
		$json['donnees']['stats']['observations'] = $obs_nbre;
89
 
90
		$json['type'] = (isset($this->formatRetour)) ? $this->formatRetour : 'jsonVar';
91
		$json['variable_js'] = 'stations';
92
 
93
		return $json;
938 jpm 94
	}
1095 aurelien 95
 
981 jpm 96
	private function traiterNbreObs($resultats) {
97
		$obs_nbre = 0;
98
		if ($resultats !== false) {
99
			$obs_nbre = count($resultats);
100
		}
101
		return $obs_nbre;
102
	}
1095 aurelien 103
 
104
	private function traiterStations($resultats) {
105
		$stations = array();
106
		if ($resultats !== false) {
107
			foreach ($resultats as $enrg) {
1333 aurelien 108
				if ($enrg['latitude'] != null && $enrg['longitude'] != null) {
109
					$id = $enrg['latitude'].'-'.$enrg['longitude'];
1095 aurelien 110
					if (!isset($stations[$id])) {
1333 aurelien 111
						$enrg['id'] = 'UTM:'.$enrg['utm_x'].'-'.$enrg['utm_y'].'-'.$enrg['utm_secteur'];
112
						unset($enrg['utm_x']);
113
						unset($enrg['utm_y']);
114
						unset($enrg['utm_secteur']);
1095 aurelien 115
						$stations[$id] = $enrg;
116
						$stations[$id]['nbre'] = 1;
117
					} else {
118
						$stations[$id]['nbre']++;
119
					}
120
				}
121
			}
122
			$stations = array_values($stations);
981 jpm 123
		}
1095 aurelien 124
		return $stations;
981 jpm 125
	}
1095 aurelien 126
 
474 jpm 127
	/**
128
	 * Données pour l'affichage des obs d'une station
129
	 */
130
	public function getObservations($params) {
938 jpm 131
		$resultats = array();
132
		$total = 0;
133
		if (!$this->etreNull($this->parametres['station'])) {
1333 aurelien 134
			$requete = 	'SELECT SQL_CALC_FOUND_ROWS id_observation, ce_utilisateur, courriel_utilisateur, '.
135
			            '   nom_sel, nom_ret, nom_sel_nn, nom_ret_nn, nt, famille, '.
136
						'	lieudit, zone_geo, date_observation, milieu, commentaire, '.
137
						'	utm_secteur, utm_x, utm_y, id_zone_geo, date_transmission '.
138
						'FROM cel_obs AS co '.
139
						'	LEFT JOIN cel_zones_geo AS l '.
140
						"		ON (l.nom = co.zone_geo AND l.id_zone_geo = co.ce_zone_geo) ".
938 jpm 141
						"WHERE transmission = '1' ".
1095 aurelien 142
						$this->construireWhereCoordonnees().
938 jpm 143
						$this->construireWhereUtilisateur().
144
						$this->construireWhereNumTaxon().
145
						$this->construireWhereNomTaxon().
146
						$this->construireWhereDate().
940 jpm 147
						$this->construireWhereCommentaire().
938 jpm 148
						$this->construireWhereProjet().
149
						$this->construireWhereTag().
150
	                    'ORDER BY nom_sel ASC '.
151
	                    "LIMIT {$this->start},{$this->limit} ";
1095 aurelien 152
			//die($requete);
938 jpm 153
			$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
1095 aurelien 154
 
938 jpm 155
			$requete = 'SELECT FOUND_ROWS()';
156
			$total = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
474 jpm 157
		}
1095 aurelien 158
 
474 jpm 159
		// Post-traitement
938 jpm 160
		$observations = $this->traiterObservations($resultats, $total);
1039 aurelien 161
		$observations = $this->ajouterImagesAuxObs($observations);
938 jpm 162
		$observations = $this->supprimerIdDesObs($observations);
163
		return $observations;
164
	}
1095 aurelien 165
 
938 jpm 166
	private function traiterObservations($donnees, $total) {
1333 aurelien 167
		$observations = array('commune' => '', 'observations' => array());
938 jpm 168
		$observations['total'] = (isset($total)) ? $total : 0;
169
		if (is_array($donnees) && count($donnees) > 0) {
170
			foreach ($donnees as $donnee) {
171
				$observation = array();
1333 aurelien 172
				$observation['idObs'] = $donnee->id_observation;
173
				$observation['nn'] = $this->etreNull($donnee->nom_sel_nn) ? null : $donnee->nom_sel_nn;
938 jpm 174
				$observation['nomSci'] = $this->nettoyerTexte($donnee->nom_sel);
175
				$observation['date'] = $this->formaterDate($donnee->date_observation, '%d/%m/%Y');
176
				$observation['datePubli'] = $this->formaterDate($donnee->date_transmission);
177
				$observation['lieu'] = $this->traiterLieu($donnee);
1333 aurelien 178
				$observation['observateur'] = $donnee->courriel_utilisateur;
179
				$observation['observateurId'] = $donnee->ce_utilisateur;
180
				$observation['urlEflore'] = $this->getUrlEflore($donnee->nom_sel_nn);
1095 aurelien 181
 
1333 aurelien 182
				if (isset($donnee->zone_geo)) {
183
					$observations['commune'] = $this->nettoyerTexte($donnee->zone_geo);
938 jpm 184
				}
1333 aurelien 185
				$observations['observations'][$donnee->id_observation] = $observation;
938 jpm 186
			}
487 jpm 187
		}
938 jpm 188
		return $observations;
189
	}
1095 aurelien 190
 
938 jpm 191
	private function getUrlEflore($nn) {
192
		$urlEflore = null;
193
		if (! $this->etreNull($nn)) {
194
			$urlEflore = sprintf($this->config['settings']['efloreUrlTpl'], $nn, 'illustration');
195
		}
196
		return $urlEflore;
197
	}
1095 aurelien 198
 
938 jpm 199
	private function traiterLieu($donnee) {
200
		$lieu = array();
201
		if (!$this->etreNull($donnee->lieudit)) {
202
			$lieu[] = $donnee->lieudit;
203
		}
204
		if (!$this->etreNull($donnee->milieu)) {
205
			$lieu[] = $donnee->milieu;
206
		}
207
		return implode(', ', $lieu);
208
	}
1095 aurelien 209
 
938 jpm 210
	private function chargerImages(Array $obs_ids) {
211
		// Récupération des données au format Json
212
		$service = 'CelImage/liste-ids?obsId='.implode(',', $obs_ids);
213
		$url = sprintf($this->config['settings']['baseURLServicesCelTpl'], $service);
214
		$json = $this->getRestClient()->consulter($url);
215
		$donnees = json_decode($json);
1095 aurelien 216
 
938 jpm 217
		// Post-traitement des données
218
		$images = $this->traiterImages($donnees);
1095 aurelien 219
 
938 jpm 220
		return $images;
474 jpm 221
	}
1095 aurelien 222
 
938 jpm 223
	private function traiterImages($donnees) {
224
		$images = array();
225
		if (count($donnees) > 0) {
226
			foreach ($donnees as $id_obs => $id_images) {
227
				foreach ($id_images as $id_img) {
228
					$urls['idImg'] = $id_img;
229
					$urls['guid'] = sprintf($this->config['settings']['guidImgTpl'], $id_img);
230
					$urls['miniature'] = $this->getUrlImage($id_img, 'CXS');
231
					$urls['normale'] = $this->getUrlImage($id_img, 'XL');
232
					$images[$id_obs][] = $urls;
1095 aurelien 233
				}
938 jpm 234
			}
235
		}
236
		return $images;
237
	}
1095 aurelien 238
 
938 jpm 239
	private function ajouterImagesAuxObs($observations) {
240
		$images = $this->chargerImages(array_keys($observations['observations']));
241
		foreach ($observations['observations'] as $id => $infos) {
1333 aurelien 242
			if(isset($images[$id])) {
243
				$infos['images'] = $images[$id];
244
			}
1095 aurelien 245
			$observations['observations'][$id] = $infos;
938 jpm 246
		}
247
		return $observations;
248
	}
1095 aurelien 249
 
938 jpm 250
	private function supprimerIdDesObs($observations) {
251
		// Le tableau de sortie ne doit pas avoir les id des obs en clé car sinon Jquery Template ne fonctionne pas
252
		$observationSansId = $observations;
253
		unset($observationSansId['observations']);
254
		foreach ($observations['observations'] as $id => $infos) {
255
			$observationSansId['observations'][] = $infos;
256
		}
257
		return $observationSansId;
258
	}
1095 aurelien 259
 
478 jpm 260
	/**
938 jpm 261
	 * Liste des taxons présents sur la carte
840 jpm 262
	 */
938 jpm 263
	public function getTaxons($params) {
840 jpm 264
		$json = null;
1095 aurelien 265
 
1333 aurelien 266
		$requete = 	'SELECT SQL_CALC_FOUND_ROWS DISTINCT nom_ret, nom_ret_nn, nt, famille '.
267
					'FROM cel_obs AS co '.
268
					'	LEFT JOIN cel_zones_geo AS l '.
269
					'		ON (l.nom = co.zone_geo AND l.id_zone_geo = co.ce_zone_geo) '.
840 jpm 270
					"WHERE transmission = '1' ".
938 jpm 271
					"	AND nom_ret != '' ".
272
					$this->construireWhereDept().
273
                    $this->construireWhereCommune().
274
                    $this->construireWhereUtilisateur().
275
					$this->construireWhereNumTaxon().
276
					$this->construireWhereNomTaxon().
277
					$this->construireWhereDate().
940 jpm 278
					$this->construireWhereCommentaire().
938 jpm 279
					$this->construireWhereProjet().
1095 aurelien 280
					$this->construireWhereTag();
938 jpm 281
					'ORDER BY nom_ret ASC '.
282
                    "LIMIT {$this->start},{$this->limit} ";
283
		//$this->debug[] = $requete;
1333 aurelien 284
		//die($requete);
938 jpm 285
		$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
1095 aurelien 286
 
938 jpm 287
		$requete = 'SELECT FOUND_ROWS()';
288
		$taxons['total'] = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
1095 aurelien 289
 
938 jpm 290
		// Post-traitement
291
		$taxons['taxons'] = $this->traiterTaxons($resultats);
1095 aurelien 292
 
938 jpm 293
		return $taxons;
840 jpm 294
	}
1095 aurelien 295
 
938 jpm 296
	private function traiterTaxons($donnees) {
297
		$taxons = array();
298
		if (is_array($donnees) && count($donnees) > 0) {
299
			foreach ($donnees as $donnee) {
1333 aurelien 300
				if (!isset($taxons[$donnee->nt]) && ! $this->etreNull($donnee->nom_ret)) {
938 jpm 301
					$taxon = array();
1333 aurelien 302
					$taxon['nn'] = $donnee->nom_ret_nn;
303
					$taxon['nt'] = $donnee->nt;
938 jpm 304
					$taxon['nom'] = $this->nettoyerTexte($donnee->nom_ret);
305
					$taxon['famille'] = $this->nettoyerTexte($donnee->famille);
1333 aurelien 306
					$taxons[$donnee->nt] = $taxon;
938 jpm 307
				}
308
			}
309
		}
310
		$taxons = array_values($taxons);
311
		return $taxons;
312
	}
1095 aurelien 313
 
938 jpm 314
	private function construireWhereCoordonnees() {
315
		$sql = '';
316
		// Récupération des coordonnées depuis l'id station
940 jpm 317
		extract($this->decomposerParametreStation());
938 jpm 318
		if (isset($type)) {
1095 aurelien 319
			if ($type == 'UTM') {
320
				$secteur = $this->proteger($secteur);
1333 aurelien 321
				$utm_x = $this->proteger($utm_x);
322
				$utm_y = $this->proteger($utm_y);
1095 aurelien 323
 
1333 aurelien 324
				$sql = " AND (utm_secteur = $secteur AND utm_x = $utm_x AND utm_y = $utm_y ) ";
1095 aurelien 325
			}  else if ($type == 'LngLat') {
1333 aurelien 326
				$latitude = $this->proteger($latitude);
327
				$longitude = $this->proteger($longitude);
1095 aurelien 328
 
1333 aurelien 329
				$sql = " AND (latitude = $latitude AND longitude = $longitude ) ";
938 jpm 330
			}
1095 aurelien 331
		}
938 jpm 332
		return $sql;
333
	}
1095 aurelien 334
 
940 jpm 335
	private function construireWhereCommentaire() {
336
		$sql = '';
337
		list($type, $commentaire) = $this->decomposerParametreCommentaire();
338
		if (!$this->etreNull($commentaire)) {
339
			$commentaire = $this->proteger('%'.$commentaire.'%');
340
			switch ($type) {
341
				case '*' :
342
					$sql = $this->obtenirConditionPourCommentaires($commentaire);
343
					$sql = " AND (commentaire LIKE $commentaire OR ($sql)) ";
344
					break;
345
				case 'observation' :
1333 aurelien 346
					$sql = " AND co.commentaire LIKE $commentaire ";
940 jpm 347
					break;
348
				case 'photo' :
349
					$sql = ' AND '.$this->obtenirConditionPourCommentaires($commentaire).' ';
350
					break;
351
				case 'photo.meta' :
352
					$sql = ' AND '.$this->obtenirConditionPourCommentaireMeta($commentaire).' ';
353
					break;
354
				case 'photo.utilisateur' :
355
					$sql = ' AND '.$this->obtenirConditionPourCommentaireUtilisateur($commentaire).' ';
356
					break;
357
				default:
1333 aurelien 358
					$sql = " AND co.commentaire LIKE $commentaire ";
1095 aurelien 359
			}
940 jpm 360
		}
361
		return $sql;
362
	}
1095 aurelien 363
 
364
 
938 jpm 365
	private function construireWhereNomTaxon() {
366
		$sql = '';
940 jpm 367
		list($type, $nom) = $this->decomposerParametreTaxon();
368
		if (!$this->etreNull($nom)) {
938 jpm 369
			$nom = $this->proteger($nom.'%');
370
			switch ($type) {
371
				case '*' :
372
					$sql = " AND (nom_ret LIKE $nom OR nom_sel LIKE $nom OR famille LIKE $nom) ";
373
					break;
940 jpm 374
				case 'retenu' :
938 jpm 375
					$sql = " AND nom_ret LIKE $nom ";
376
					break;
940 jpm 377
				case 'selectionne' :
938 jpm 378
					$sql = " AND nom_sel LIKE $nom ";
379
					break;
940 jpm 380
				case 'famille' :
938 jpm 381
					$sql = " AND famille LIKE $nom ";
382
					break;
383
				default:
384
					$sql = " AND nom_ret LIKE $nom ";
1095 aurelien 385
			}
938 jpm 386
		}
387
		return $sql;
388
	}
1095 aurelien 389
 
938 jpm 390
	private function construireWhereDate() {
391
		$sql = '';
392
		// Récupération des coordonnées depuis l'id station
940 jpm 393
		list($type, $date) = $this->decomposerParametreDate();
1095 aurelien 394
 
938 jpm 395
		if (!$this->etreNull($date)) {
396
			$date = $this->proteger($date.'%');
397
			switch ($type) {
398
				case '*' :
399
					$sql = " AND (
1095 aurelien 400
						date_observation LIKE $date
401
						OR date_creation LIKE $date
402
						OR date_modification LIKE $date
938 jpm 403
						OR date_transmission LIKE $date) ";
404
					break;
405
				case 'observation' :
406
					$sql = " AND date_observation LIKE $date ";
407
					break;
408
				case 'creation' :
409
					$sql = " AND date_creation LIKE $date ";
410
					break;
411
				case 'modification' :
412
					$sql = " AND date_modification LIKE $date ";
413
					break;
414
				case 'transmission' :
415
					$sql = " AND date_transmission LIKE $date ";
416
					break;
940 jpm 417
				case 'photo' :
418
					$sql = $this->obtenirConditionPourDatePhoto($date);
419
					break;
420
				case 'ajout' :
421
					$sql = $this->obtenirConditionPourDateAjout($date);
422
					break;
938 jpm 423
				case 'liaison' :
940 jpm 424
					$sql = $this->obtenirConditionPourDateLiaison($date);
938 jpm 425
					break;
426
				default:
427
					$sql = " AND date_observation LIKE $date ";
428
			}
429
		}
430
		return $sql;
431
	}
1095 aurelien 432
 
940 jpm 433
	private function obtenirConditionPourDatePhoto($date) {
434
		$observations = $this->obtenirObsLieesImg('date.photo', $date);
435
		if (is_null($observations)) {
436
			$this->debug[] = "Aucune observation n'est liée à une photo prise à la date : $date";
437
		}
438
		$sql = $this->assemblerObsEnConditionSql($observations);
439
		return $sql;
440
	}
1095 aurelien 441
 
940 jpm 442
	private function obtenirConditionPourDateLiaison($date) {
443
		$observations = $this->obtenirObsLieesImg('date.liaison', $date);
444
		if (is_null($observations)) {
445
			$this->debug[] = "Aucune observation n'a été liée à une image à à la date : $date";
446
		}
447
		$sql = $this->assemblerObsEnConditionSql($observations);
448
		return $sql;
449
	}
450
 
451
	private function obtenirConditionPourDateAjout($date) {
452
		$observations = $this->obtenirObsLieesImg('date.ajout', $date);
453
		if (is_null($observations)) {
454
			$this->debug[] = "Aucune observation n'est liée à une image ajoutée à la date : $date";
455
		}
456
		$sql = $this->assemblerObsEnConditionSql($observations);
457
		return $sql;
458
	}
1095 aurelien 459
 
940 jpm 460
	private function obtenirConditionPourCommentaireMeta($commentaire) {
461
		$observations = $this->obtenirObsLieesImg('commentaire.meta', $commentaire);
462
		if (is_null($observations)) {
463
			$this->debug[] = "Aucune observation n'est liée à une image dont le commentaire des méta-données correspond à : $commmentaire";
464
		}
465
		$operateur = '';
466
		$sql = $this->assemblerObsEnConditionSql($observations, $operateur);
467
		return $sql;
468
	}
1095 aurelien 469
 
940 jpm 470
	private function obtenirConditionPourCommentaireUtilisateur($commentaire) {
471
		$observations = $this->obtenirObsLieesImg('commentaire.utilisateur', $commentaire);
472
		if (is_null($observations)) {
473
			$this->debug[] = "Aucune observation n'est liée à une image dont le commentaire des utilisateur correspond à : $commmentaire";
474
		}
475
		$operateur = '';
476
		$sql = $this->assemblerObsEnConditionSql($observations, $operateur);
477
		return $sql;
478
	}
1095 aurelien 479
 
940 jpm 480
	private function obtenirConditionPourCommentaires($commentaire) {
481
		$observations = $this->obtenirObsLieesImg('commentaire.*', $commentaire);
482
		if (is_null($observations)) {
483
			$this->debug[] = "Aucune observation n'est liée à une image dont un des commentaires correspond à : $commmentaire";
484
		}
485
		$operateur = '';
486
		$sql = $this->assemblerObsEnConditionSql($observations, $operateur);
487
		return $sql;
488
	}
1095 aurelien 489
 
940 jpm 490
	/**
491
	 * Récupération des identifiant d'utilisateur et des ordres des observations correspondant à une date.
492
	 * Retour sous forme de tableau : array[identifiant] = array(ordre, ordre...);
493
	 */
494
	private function obtenirObsLieesImg($type, $param) {
495
		// Construction de la requête
1333 aurelien 496
		$requete = 	'SELECT DISTINCT id_observation AS id_obs, ce_utilisateur AS utilisateur '.
497
			'FROM  cel_images ci'.
498
			'	LEFT JOIN cel_obs_images coi '.
499
			'		ON (coi.id_image = ci.id_image) '.
500
			'	LEFT JOIN cel_obs AS co '.
501
			'		ON coi.id_observation = co.id_observation '.
940 jpm 502
			'	LEFT JOIN locations AS l '.
1333 aurelien 503
			'		ON (l.nom = co.zone_geo AND l.id_zone_geo = co.ce_zone_geo) '.
940 jpm 504
			"WHERE  transmission = '1' ".
1333 aurelien 505
			($type == 'date.photo' ? " AND (date_prise_de_vue LIKE ".str_replace('-', ':', $param).") " : '').
506
			($type == 'date.ajout' ? " AND date_creation LIKE $param " : '').
507
			($type == 'date.liaison' ? " AND date_liaison LIKE $param " : '').
508
			// TODO: recherche sur le xml
509
			//($type == 'commentaire.meta' ? " AND ci.commentaire LIKE $param " : '').
510
			($type == 'commentaire.utilisateur' ? "	AND ci.commentaire LIKE $param " : '').
511
			($type == 'commentaire.*' ? " AND (ci.commentaire LIKE $param) " : '').
1095 aurelien 512
			$this->construireWhereCoordonnees().
940 jpm 513
			$this->construireWhereDept().
514
			$this->construireWhereCommune().
515
			$this->construireWhereUtilisateur().
516
			$this->construireWhereNumTaxon().
517
			$this->construireWhereNomTaxon().
518
			$this->construireWhereProjet().
519
			$this->construireWhereTag().
520
			'ORDER BY utilisateur ASC, ordre ASC';
521
		//$this->debug[] = $requete;
522
		//die($requete);
523
		$resultats = $this->executerRequete($requete);
1095 aurelien 524
 
940 jpm 525
		$observations = null;
526
		if ($resultats != false) {
527
			$observations = array();
528
			foreach ($resultats as $occurence) {
529
				$utilisateur = $occurence['utilisateur'];
1333 aurelien 530
				$id_obs = $occurence['id_obs'];
940 jpm 531
				if (!array_key_exists($utilisateur, $observations)) {
532
					$observations[$utilisateur] = array();
533
				}
1333 aurelien 534
				if (!array_key_exists($id_obs, $observations[$utilisateur])) {
535
					$observations[$utilisateur][$id_obs] = $id_obs;
940 jpm 536
				}
537
			}
538
		}
539
		return $observations;
540
	}
1095 aurelien 541
 
940 jpm 542
	private function assemblerObsEnConditionSql($observations, $operateur = 'AND') {
543
		$sql = '';
544
		if ($observations != null) {
545
			// Pré-construction du where de la requête
1333 aurelien 546
			$tpl_where = "(id_observation IN (%s))";
547
			foreach ($observations as $utilisateur => $ids_obs) {
548
				$morceaux_requete[] = sprintf($tpl_where, implode(',', $ids_obs));
940 jpm 549
			}
550
			if (count($morceaux_requete) > 0) {
551
				$sql = implode(" \nOR ", $morceaux_requete);
552
			}
553
		} else {
554
			// Nous voulons que la requête ne retourne rien
1333 aurelien 555
			$sql = "id_observation = ''";
940 jpm 556
		}
557
		$sql = " $operateur ($sql) ";
558
		return $sql;
559
	}
1095 aurelien 560
 
938 jpm 561
	private function construireWhereDept() {
562
		$sql = '';
563
		// Récupération des coordonnées depuis l'id station
564
		extract($this->parametres);
1095 aurelien 565
		if (isset($dept) && !$this->etreNull($dept)) {
1333 aurelien 566
			$valeurs_a_proteger = explode(',',trim($dept));
567
			foreach ($valeurs_a_proteger as $valeur) {
568
				$valeurs_protegees[] = '(ce_zone_geo LIKE '.$this->bdd->quote('INSEE-C:'.$valeur.'%').') ';
569
			}
570
			$valeurs = implode(' OR ', $valeurs_protegees);
571
			$sql = " AND ($valeurs) ";
938 jpm 572
		}
573
		return $sql;
574
	}
1095 aurelien 575
 
938 jpm 576
	private function construireWhereCommune() {
577
		$sql = '';
578
		// Récupération des coordonnées depuis l'id station
579
		extract($this->parametres);
1095 aurelien 580
		if (isset($commune) && !$this->etreNull($commune)) {
938 jpm 581
			$commune = $this->proteger($commune);
1333 aurelien 582
			$sql = " AND zone_geo LIKE $commune ";
938 jpm 583
		}
584
		return $sql;
585
	}
1095 aurelien 586
 
587
 
938 jpm 588
	private function construireWhereUtilisateur() {
589
		$sql = '';
590
		// Récupération des coordonnées depuis l'id station
591
		extract($this->parametres);
1095 aurelien 592
		if (isset($utilisateur) && !$this->etreNull($utilisateur)) {
938 jpm 593
			$utilisateur = $this->proteger($utilisateur);
1333 aurelien 594
			$sql = " AND courriel_utilisateur = $utilisateur ";
938 jpm 595
		}
596
		return $sql;
597
	}
1095 aurelien 598
 
938 jpm 599
	private function construireWhereNumTaxon() {
600
		$sql = '';
601
		// Récupération des coordonnées depuis l'id station
602
		extract($this->parametres);
1095 aurelien 603
		if (isset($num_taxon) && !$this->etreNull($num_taxon)) {
938 jpm 604
			$num_taxon = $this->proteger($num_taxon);
1333 aurelien 605
			$sql = " AND nt = $num_taxon ";
938 jpm 606
		}
607
		return $sql;
608
	}
1095 aurelien 609
 
938 jpm 610
	private function construireWhereProjet() {
611
		$sql = '';
612
		// Récupération des coordonnées depuis l'id station
613
		extract($this->parametres);
1095 aurelien 614
		$projet_sql = isset($projet) ? $this->getSqlWhereProjet($projet) : null;
938 jpm 615
		if (!$this->etreNull($projet_sql)) {
616
			$sql = " AND ($projet_sql) ";
617
		}
618
		return $sql;
619
	}
1095 aurelien 620
 
840 jpm 621
	/**
938 jpm 622
	 * Traitement de $projet pour construction du filtre dans la requête
478 jpm 623
	 */
938 jpm 624
	private function getSqlWhereProjet($projet) {
625
		$sql = null;
1095 aurelien 626
		if (isset($projet) && !$this->etreNull($projet)) {
1333 aurelien 627
			$sql = 'co.mots_cles_texte LIKE '.$this->proteger($projet);
938 jpm 628
		}
629
		return $sql;
630
	}
1095 aurelien 631
 
938 jpm 632
	private function construireWhereTag() {
633
		$sql = '';
840 jpm 634
		extract($this->parametres);
1095 aurelien 635
		$tag_sql = isset($tag) ? $this->getSqlWhereObsAvecImagesTaguees($tag) : null;
938 jpm 636
		if (!$this->etreNull($tag_sql)) {
637
			$sql = " AND ($tag_sql) ";
489 jpm 638
		}
938 jpm 639
		return $sql;
640
	}
1095 aurelien 641
 
938 jpm 642
	/**
643
	 * Traitement de $tag pour construction du filtre dans la requête
644
	 */
645
	private function getSqlWhereObsAvecImagesTaguees($tag) {
646
		$sql = null;
1095 aurelien 647
		if (isset($tag) && !$this->etreNull($tag)) {
938 jpm 648
			$tag_sql = $this->getSqlWhereMotsCles($tag);
649
			// Construction de la requête
1334 aurelien 650
			$requete = 	'SELECT DISTINCT coi.id_observation AS id_obs,  ci.ce_utilisateur AS utilisateur '.
651
						'FROM cel_images ci'.
1333 aurelien 652
						'	LEFT JOIN cel_obs_images coi'.
1334 aurelien 653
						'		ON (ci.id_image = coi.id_image) '.
654
						'	LEFT JOIN cel_obs AS co '.
655
						'		ON (coi.id_observation = co.id_observation) '.
656
						'	LEFT JOIN cel_zones_geo AS l '.
657
						"		ON (l.nom = co.zone_geo AND l.id_zone_geo = co.ce_zone_geo) ".
658
						"WHERE transmission = '1' ".
938 jpm 659
						$this->construireWhereCoordonnees().
660
						$this->construireWhereUtilisateur().
661
						$this->construireWhereNumTaxon().
662
						$this->construireWhereNomTaxon().
663
						$this->construireWhereProjet().
664
						(!$this->etreNull($tag_sql) ? "AND ($tag_sql) " : '').
1334 aurelien 665
						'ORDER BY utilisateur ASC, ci.ordre ASC';
938 jpm 666
			//$this->debug[] = $requete;
1335 aurelien 667
			die($requete);
938 jpm 668
			$elements_tag = $this->executerRequete($requete);
1095 aurelien 669
 
938 jpm 670
			$requete_tag = array();
671
			if ($elements_tag != false && count($elements_tag) > 0) {
1095 aurelien 672
 
938 jpm 673
				$filtres = array();
674
				foreach ($elements_tag as $occurence) {
675
					$utilisateur = $occurence['utilisateur'];
1333 aurelien 676
					$id_obs = $occurence['id_obs'];
938 jpm 677
					if (!array_key_exists($utilisateur, $filtres)) {
678
						$filtres[$utilisateur] = array();
679
					}
1333 aurelien 680
					if (!array_key_exists($id_obs, $filtres[$utilisateur])) {
681
						$filtres[$utilisateur][$id_obs] = $id_obs;
938 jpm 682
					}
683
				}
1095 aurelien 684
 
938 jpm 685
				// Pré-construction du where de la requête
1333 aurelien 686
				$tpl_where = "(id_observation IN (%s))";
687
				foreach ($filtres as $utilisateur => $id_obs) {
688
					$requete_tag[] = sprintf($tpl_where, implode(',', $id_obs));
938 jpm 689
				}
1095 aurelien 690
 
938 jpm 691
			} else {
692
				$this->messages[] = "Aucune observation ne possède d'images avec ce mot-clé.";
693
			}
694
			if (count($requete_tag) > 0) {
695
				$sql = implode(" \nOR ", $requete_tag);
696
			}
489 jpm 697
		}
938 jpm 698
		return $sql;
478 jpm 699
	}
1095 aurelien 700
 
487 jpm 701
	/**
938 jpm 702
	 * Traitement de $tag pour construction du filtre dans la requête
487 jpm 703
	 */
938 jpm 704
	private function getSqlWhereMotsCles($tag) {
705
		$sql = null;
940 jpm 706
		$mots_cles = $this->decomposerParametreTag($tag);
1335 aurelien 707
		$requete_projet = $this->getSqlWhereMotsClesImages($mots_cles);
1334 aurelien 708
		$sql = $requete_projet;
938 jpm 709
		//$this->debug[] = $sql;
487 jpm 710
		return $sql;
840 jpm 711
	}
1095 aurelien 712
 
938 jpm 713
	/**
714
	 * Traitement de $tag pour construction du filtre dans la requête
715
	 */
716
	private function getSqlWhereMotsClesImages($mots_cles_encodes) {
717
		$where_mots_cles_images = array();
1335 aurelien 718
		foreach ($mots_cles_encodes['motsClesEncodesProteges'] as $mot_cle_encode) {
1334 aurelien 719
			$where_mots_cles_images[] = "ci.mots_cles_texte LIKE $mot_cle_encode";
938 jpm 720
		}
1335 aurelien 721
		$where_mots_cles_images = implode(' '.$mots_cles_encodes['type'].' ', $where_mots_cles_images);
938 jpm 722
		return $where_mots_cles_images;
723
	}
1095 aurelien 724
 
940 jpm 725
	private function decomposerParametreTag($tags) {
1334 aurelien 726
 
938 jpm 727
		$mots_cles = array('type' => null, 'motsCles' => null, 'motsClesEncodesProteges' => null);
728
		if (preg_match('/.+OU.+/', $tags)) {
729
			$mots_cles['type'] = 'OR';
730
			$mots_cles['motsCles'] = explode('OU', $tags);
731
		} else if (preg_match('/.+ET.+/', $tags)) {
732
			$mots_cles['type'] = 'AND';
733
			$mots_cles['motsCles'] = explode('ET', $tags);
734
		} else {
735
			$mots_cles['motsCles'][] = $tags;
736
		}
1095 aurelien 737
 
938 jpm 738
		foreach ($mots_cles['motsCles'] as $mot) {
1334 aurelien 739
			$mots_cles['motsClesEncodesProteges'][] = $this->bdd->quote('%'.$mot.'%');
938 jpm 740
		}
741
		$this->debug[] = $mots_cles;
742
		return $mots_cles;
743
	}
1095 aurelien 744
 
940 jpm 745
	private function decomposerParametreStation() {
938 jpm 746
		$station_infos = array();
747
		if (isset($this->parametres['station'])) {
748
			$station = $this->parametres['station'];
749
			$this->debug[] = $station;
1095 aurelien 750
			list($type, $coord) = explode(':', $station);
751
 
752
			if ($type == 'UTM') {
1333 aurelien 753
				list($utm_x, $utm_y, $secteur) = explode('-', $coord);
754
				$station_infos = array('utm_x' => $utm_x, 'utm_y' => $utm_y, 'secteur' => $secteur);
1095 aurelien 755
			} else if ($type == 'LngLat') {
1333 aurelien 756
				list($longitude, $latitude) = explode('-', $coord);
757
				$station_infos = array('longitude' => $longitude, 'latitude' => $latitude);
1095 aurelien 758
			}
759
			$station_infos['type'] = $type;
938 jpm 760
		}
761
		return $station_infos;
762
	}
1095 aurelien 763
 
940 jpm 764
	private function decomposerParametreDate() {
1095 aurelien 765
		$date_infos = array(null,null);
940 jpm 766
		if (isset($this->parametres['date'])) {
767
			$date = $this->parametres['date'];
768
			if (strpos($date, ':')) {
769
				list($type, $date) = explode(':', $date);
770
			} else {
771
				$type = 'observation';
772
			}
1095 aurelien 773
 
940 jpm 774
			$date = str_replace('/', '-', $date);
775
			if (preg_match('/(^[0-9]{2})-([0-9]{2})-([0-9]{4}$)/', $date, $matches)) {
776
				$date = $matches[3].'-'.$matches[2].'-'.$matches[1];
777
			}
1095 aurelien 778
 
940 jpm 779
			$date_infos = array($type, $date);
780
		}
781
		return $date_infos;
782
	}
1095 aurelien 783
 
940 jpm 784
	private function decomposerParametreTaxon() {
1095 aurelien 785
		$nom_infos = array(null, null);
940 jpm 786
		if (isset($this->parametres['taxon'])) {
787
			$taxon = $this->parametres['taxon'];
788
			if (strpos($taxon, ':')) {
789
				$nom_infos = explode(':', $taxon);
790
			} else {
791
				$nom_infos = array('retenu', $taxon);
792
			}
793
		}
794
		return $nom_infos;
795
	}
1095 aurelien 796
 
940 jpm 797
	private function decomposerParametreCommentaire() {
1095 aurelien 798
		$commentaire_infos = array(null, null);
940 jpm 799
		if (isset($this->parametres['commentaire'])) {
800
			$commentaire = $this->parametres['commentaire'];
801
			if (strpos($commentaire, ':')) {
802
				$commentaire_infos = explode(':', $commentaire);
803
			} else {
804
				$commentaire_infos = array('observation', $commentaire);
805
			}
806
		}
807
		return $commentaire_infos;
808
	}
416 aurelien 809
}