Subversion Repositories eFlore/Applications.cel

Rev

Rev 1106 | Rev 1142 | Go to most recent revision | Details | Compare with Previous | 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)
1092 aurelien 25
class CelWidgetMapPoint extends Cel {
981 jpm 26
	const MARQUEUR_GROUPE = 'GROUPE';
27
	const MARQUEUR_COMMUNE = 'COMMUNE';
28
	const MARQUEUR_STATION = 'STATION';
416 aurelien 29
	/**
30
	 * Méthode appelée avec une requête de type GET.
31
	 */
840 jpm 32
	public function getElement($ressources) {
416 aurelien 33
		$retour = null;
1132 aurelien 34
		if($this->parametres == null) {
35
			$this->parametres = array();
36
		}
840 jpm 37
		extract($this->parametres);
981 jpm 38
		//Chronometre::chrono("Avant groupage");
1003 jpm 39
 
840 jpm 40
		$action = array_shift($ressources);
41
		if (isset($action)) {
42
			$methode = $this->traiterNomMethodeGet($action);
416 aurelien 43
			if (method_exists($this, $methode)) {
840 jpm 44
				$retour = $this->$methode($ressources);
416 aurelien 45
			} else {
840 jpm 46
				$this->messages[] = "Ce type de ressource '$methode' n'est pas disponible.";
416 aurelien 47
			}
48
		} else {
840 jpm 49
			$this->messages[] = "Vous devez indiquer le type de ressource.";
416 aurelien 50
		}
1003 jpm 51
 
981 jpm 52
		//Chronometre::chrono("Apres traitement");
53
		//echo Chronometre::afficherChrono();
416 aurelien 54
		if (is_null($retour)) {
55
			$info = 'Un problème est survenu : '.print_r($this->messages, true);
56
			$this->envoyer($info);
1003 jpm 57
		} else if (isset($retour['type']) && $retour['type'] == 'jsonVar') {
694 jpm 58
			$this->envoyerJsonVar($retour['variable_js'], $retour['donnees']);
1003 jpm 59
		} else if (isset($retour['type']) && $retour['type'] == 'jsonP') {
584 jpm 60
			$this->envoyerJsonp($retour['donnees']);
1003 jpm 61
		} else if (isset($retour['type']) && $retour['type'] == 'png') {
981 jpm 62
			header("Content-type: image/png");
63
			imagepng($retour['img']);
64
			imagedestroy($retour['img']);
474 jpm 65
		} else {
938 jpm 66
			$this->envoyerJson($retour);
416 aurelien 67
		}
68
	}
1003 jpm 69
 
416 aurelien 70
	/**
981 jpm 71
	 * Les icones des groupes de stations
72
	 */
73
	public function getIconeGroupe($params) {
74
		extract($this->parametres);
1003 jpm 75
 
1033 aurelien 76
		$chemin_marqueur = sprintf($this->config['settings']['cheminCelMarkerObsTpl'], $type);
77
		$img = imagecreatefrompng($chemin_marqueur);
1003 jpm 78
 
981 jpm 79
		$noir = imagecolorallocate($img, 0, 0, 0);
80
		$texte = (String) $nbre;
81
		$x = (imagesx($img) - 6.0 * strlen($texte)) / 2;
82
		$y = (imagesy($img) - 16) / 2;
1003 jpm 83
 
981 jpm 84
		imagestring($img, 3, $x, $y, $texte, $noir);
1003 jpm 85
 
981 jpm 86
		imagealphablending($img, false);
87
		imagesavealpha($img, true);
1003 jpm 88
 
981 jpm 89
		return array('type' => 'png', 'img' => $img);
90
	}
1003 jpm 91
 
981 jpm 92
	/**
938 jpm 93
	 * Les stations de la carte par défaut
416 aurelien 94
	 */
938 jpm 95
	public function getStations($params) {
981 jpm 96
		$stations = null;
97
		$requete =  'SELECT wgs84_latitude AS lat, wgs84_longitude AS lng, location AS nom '.
938 jpm 98
                    'FROM cel_inventory AS i '.
99
                    '   LEFT JOIN locations AS l '.
100
                    '       ON (l.name = i.location AND l.code = i.id_location) '.
101
                    "WHERE transmission = '1' ".
981 jpm 102
					" AND (( ".
103
					"		(coord_x = '' OR coord_x IS NULL OR coord_x = '000null') ".
104
					" 		AND (coord_y = '' OR coord_y IS NULL OR coord_y = '000null') ".
105
					"	) OR mots_cles_texte LIKE '%sensible%') ".
106
					$this->construireWhereRectangleCommune().
938 jpm 107
					$this->construireWhereDept().
108
                    $this->construireWhereCommune().
109
                    $this->construireWhereUtilisateur().
110
					$this->construireWhereNumTaxon().
111
					$this->construireWhereNomTaxon().
112
					$this->construireWhereDate().
940 jpm 113
					$this->construireWhereCommentaire().
938 jpm 114
					$this->construireWhereProjet().
115
					$this->construireWhereTag();
1003 jpm 116
 
981 jpm 117
		$resultats_communes = $this->requeter($requete);
1003 jpm 118
 
981 jpm 119
		$requete =  'SELECT coord_x AS lat, coord_y  AS lng, location AS nom '.
120
					'FROM cel_inventory AS i '.
121
                    '   LEFT JOIN locations AS l '.
122
                    '       ON (l.name = i.location AND l.code = i.id_location) '.
123
                    "WHERE transmission = '1' ".
124
					" AND coord_x != '' AND coord_x IS NOT NULL AND coord_x != '000null' ".
125
					" AND coord_y != '' AND coord_y IS NOT NULL AND coord_y != '000null' ".
126
					" AND (mots_cles_texte IS NULL OR mots_cles_texte NOT LIKE '%sensible%') ".
127
					$this->construireWhereRectangleStation().
128
					$this->construireWhereDept().
129
                    $this->construireWhereCommune().
130
                    $this->construireWhereUtilisateur().
131
					$this->construireWhereNumTaxon().
132
					$this->construireWhereNomTaxon().
133
					$this->construireWhereDate().
134
					$this->construireWhereCommentaire().
135
					$this->construireWhereProjet().
136
					$this->construireWhereTag();
1003 jpm 137
 
981 jpm 138
		$resultats_stations = $this->requeter($requete);
139
		$stations = $this->traiterStations($resultats_communes, $resultats_stations);
1003 jpm 140
 
981 jpm 141
		return $stations;
938 jpm 142
	}
1003 jpm 143
 
981 jpm 144
	public function getTout($params) {
1003 jpm 145
 
146
		$emplacements = null;
1092 aurelien 147
		$coordonnees_nulles = "coord_x = '000null' OR coord_x = '' ".
148
								" OR coord_y = '000null' OR coord_y = ''";
149
		$coordonnees_non_nulles = "coord_x != '000null' AND coord_x != '' ".
150
								" AND coord_y != '000null' AND coord_y != ''";
151
		$coordonnees_non_nulles_pas_sensible = "(".$coordonnees_non_nulles." AND mots_cles_texte NOT LIKE '%sensible%')";
152
 
153
		$requete =  'SELECT DISTINCT *, location AS nom, '.
154
							"IF (".$coordonnees_non_nulles_pas_sensible.", ".
981 jpm 155
								"'stations', ".
156
							"'communes' ".
157
							") as type_emplacement, ".
1092 aurelien 158
							"IF (".$coordonnees_non_nulles_pas_sensible.", ".
1033 aurelien 159
								"coord_x, ".
160
								"wgs84_latitude ".
981 jpm 161
							") as lat, ".
1092 aurelien 162
							"IF (".$coordonnees_non_nulles_pas_sensible.", ".
1033 aurelien 163
								"coord_y, ".
164
								"wgs84_longitude ".
981 jpm 165
							") as lng, ".
1092 aurelien 166
							"IF (".$coordonnees_non_nulles_pas_sensible.", ".
1033 aurelien 167
								'CONCAT("'.self::MARQUEUR_STATION.':",coord_x,"|",coord_y), '.
168
								'CONCAT("'.self::MARQUEUR_COMMUNE.':",wgs84_latitude,"|",wgs84_longitude) '.
981 jpm 169
							") as id ".
170
					'FROM cel_inventory AS i '.
171
                    '   LEFT JOIN locations AS l '.
172
                    '       ON (l.name = i.location AND l.code = i.id_location) '.
173
                    "WHERE transmission = '1' ".
1003 jpm 174
					" AND (".
1033 aurelien 175
						"(".($this->construireWhereRectangleStationOR() != null ? $this->construireWhereRectangleStationOR().' AND ' : '').
176
							" (mots_cles_texte IS NULL OR mots_cles_texte NOT LIKE '%sensible%') ".
981 jpm 177
						")".
178
						" OR ".
179
						" ( ".
1092 aurelien 180
							"(".($this->construireWhereRectangleCommuneOR() != null ? $this->construireWhereRectangleCommuneOR().' AND ' : '').
181
								"(".$coordonnees_nulles.")".
1033 aurelien 182
							")".
981 jpm 183
						" ) ".
1003 jpm 184
					") ".
981 jpm 185
					$this->construireWhereDept().
186
                    $this->construireWhereCommune().
187
                    $this->construireWhereUtilisateur().
188
					$this->construireWhereNumTaxon().
189
					$this->construireWhereNomTaxon().
190
					$this->construireWhereDate().
191
					$this->construireWhereCommentaire().
192
					$this->construireWhereProjet().
1106 aurelien 193
					$this->construireWhereTag().' LIMIT 0,20000';
1092 aurelien 194
 
1106 aurelien 195
		$resultats_emplacements = $this->executerRequete($requete);
196
		$emplacements = $this->traiterEmplacements($resultats_emplacements, $this->compterObservations($params));
197
		return $emplacements;
981 jpm 198
	}
1092 aurelien 199
 
200
	private function afficherRequeteFormatee($requete) {
201
		$requete = str_replace(')',')<br />',$requete);
202
		$requete = str_replace('(','	<br />	(',$requete);
203
		echo '<pre>'.$requete.'</pre>';
204
		exit;
205
	}
1003 jpm 206
 
1039 aurelien 207
	private $nb_obs = 0;
208
 
209
	private function compterObservations($params) {
210
		$requete =  'SELECT COUNT(*) AS nb '.
211
					'FROM cel_inventory AS i '.
212
                    '   LEFT JOIN locations AS l '.
213
                    '       ON (l.name = i.location AND l.code = i.id_location) '.
214
                    "WHERE transmission = '1' ".
215
					" AND (".
216
						"(".($this->construireWhereRectangleStationOR() != null ? $this->construireWhereRectangleStationOR().' AND ' : '').
217
							" (mots_cles_texte IS NULL OR mots_cles_texte NOT LIKE '%sensible%') ".
218
						")".
219
						" OR ".
220
						" ( ".
221
							"(".($this->construireWhereRectangleCommuneOR() != null ? $this->construireWhereRectangleCommuneOR().' Or ' : '').
222
							" mots_cles_texte LIKE '%sensible%' ".
223
							")".
224
						" ) ".
225
					") ".
226
					$this->construireWhereDept().
227
                    $this->construireWhereCommune().
228
                    $this->construireWhereUtilisateur().
229
					$this->construireWhereNumTaxon().
230
					$this->construireWhereNomTaxon().
231
					$this->construireWhereDate().
232
					$this->construireWhereCommentaire().
233
					$this->construireWhereProjet().
234
					$this->construireWhereTag();
235
 
236
		$resultats_nb_obs = $this->executerRequete($requete);
237
		return $resultats_nb_obs[0]['nb'];
238
	}
239
 
240
	private function traiterEmplacements(&$emplacements, $nb_total_observation) {
981 jpm 241
		$zoom = (int) array_key_exists('zoom', $this->parametres) ? $this->parametres['zoom'] : 11;
242
		$distance = (int) array_key_exists('distance', $this->parametres) ? $this->parametres['distance'] : 20;
1003 jpm 243
 
981 jpm 244
		$marqueurs = array(
245
			'stats' => array('stations' => 0, 'communes' => 0, 'observations' => 0),
246
			'points' => null
247
		);
1003 jpm 248
 
1132 aurelien 249
		if (isset($this->parametres['ne']) && $this->parametres['sw'] && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) {
981 jpm 250
			$ne = $this->decomposerLatLng($this->parametres['ne']);
251
			$sw = $this->decomposerLatLng($this->parametres['sw']);
252
			$marqueurs['points'] = CartoGroupage::creerGroupesQuadtree($emplacements, $ne['lat'], $ne['lng'], $sw['lat'], $sw['lng'], $zoom);
1003 jpm 253
 
254
			// laisser la classe cartoGroupage compter les élements simplifie le comptage
982 jpm 255
			// et permet de ne pas reparser le tableau pour compter les différents éléments
981 jpm 256
			$nb_elements = CartoGroupage::getNbElements();
1106 aurelien 257
 
258
			$marqueurs['stats']['coordmax'] = CartoGroupage::getBornes();
981 jpm 259
			$marqueurs['stats']['stations'] = $nb_elements['stations'];
260
			$marqueurs['stats']['communes'] = $nb_elements['communes'];
1039 aurelien 261
			$marqueurs['stats']['observations'] = (int)$nb_total_observation;
981 jpm 262
		} else {
263
			$marqueurs['points'] = $emplacements;
938 jpm 264
		}
981 jpm 265
 
266
		return $marqueurs;
938 jpm 267
	}
1003 jpm 268
 
981 jpm 269
	private function traiterStations($communes, $stations) {
270
		$zoom = (int) array_key_exists('zoom', $this->parametres) ? $this->parametres['zoom'] : 11;
271
		$distance = (int) array_key_exists('distance', $this->parametres) ? $this->parametres['distance'] : 20;
1003 jpm 272
 
981 jpm 273
		$marqueurs = array(
954 jpm 274
			'stats' => array('stations' => 0, 'communes' => 0, 'observations' => 0),
275
			'points' => null
276
		);
981 jpm 277
		$marqueurs['stats']['observations'] = $this->traiterNbreObs($communes) + $this->traiterNbreObs($stations);
1003 jpm 278
 
954 jpm 279
		$points = array();
981 jpm 280
		if ($communes !== false) {
281
			foreach ($communes as $commune) {
282
				if (is_numeric($commune['lat']) && is_numeric($commune['lng'])) {
283
					extract($commune);
284
					$id = self::MARQUEUR_COMMUNE.':'.$lat.'|'.$lng;
1004 jpm 285
					//$this->definirLatLngMaxMin($marqueurs, $lat, $lng);
981 jpm 286
					$lata = round($lat, 5);
287
					$lnga = round($lng, 5);
1003 jpm 288
 
954 jpm 289
					if (!isset($points[$id])) {
981 jpm 290
						$points[$id]['id'] = $id;
291
						$points[$id]['nom'] = $nom;
292
						$points[$id]['lat'] = $lata;
293
						$points[$id]['lng'] = $lnga;
954 jpm 294
						$points[$id]['nbre'] = 1;
981 jpm 295
						$marqueurs['stats']['communes']++;
840 jpm 296
					} else {
954 jpm 297
						$points[$id]['nbre']++;
840 jpm 298
					}
981 jpm 299
				}
300
			}
301
		}
302
		if ($stations !== false) {
303
			foreach ($stations as $station) {
304
				if (is_numeric($station['lat']) && is_numeric($station['lng'])) {
305
					extract($station);
306
					$id = self::MARQUEUR_STATION.':'.$lat.'|'.$lng;
1004 jpm 307
					//$this->definirLatLngMaxMin($marqueurs, $lat, $lng);
981 jpm 308
					$lata = round($lat, 5);
309
					$lnga = round($lng, 5);
310
					$nom = $this->etreNull($nom) ? $lata.','.$lnga : $nom;
1003 jpm 311
 
954 jpm 312
					if (!isset($points[$id])) {
981 jpm 313
						$points[$id]['id'] = $id;
314
						$points[$id]['nom'] = $nom;
315
						$points[$id]['lat'] = $lata;
316
						$points[$id]['lng'] = $lnga;
954 jpm 317
						$points[$id]['nbre'] = 1;
981 jpm 318
						$marqueurs['stats']['stations']++;
954 jpm 319
					} else {
320
						$points[$id]['nbre']++;
321
					}
981 jpm 322
				}
416 aurelien 323
			}
324
		}
1003 jpm 325
 
1132 aurelien 326
		if (isset($this->parametres['ne']) && $this->parametres['sw'] && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) {
981 jpm 327
			$ne = $this->decomposerLatLng($this->parametres['ne']);
328
			$sw = $this->decomposerLatLng($this->parametres['sw']);
329
			$marqueurs['points'] = CartoGroupage::creerGroupesQuadtree(&$points, $ne['lat'], $ne['lng'], $sw['lat'], $sw['lng'], $zoom);
330
		} else {
331
			$marqueurs['points'] = $points;
332
		}
1004 jpm 333
		//$marqueurs['stats']['latDiff'] = abs($marqueurs['stats']['latMin'] - $marqueurs['stats']['latMax']);
334
		//$marqueurs['stats']['lngDiff'] = abs($marqueurs['stats']['lngMin'] - $marqueurs['stats']['lngMax']);
1003 jpm 335
 
981 jpm 336
		return $marqueurs;
416 aurelien 337
	}
1003 jpm 338
 
981 jpm 339
	private function definirLatLngMaxMin(&$marqueurs, $lat, $lng) {
340
		if ($lat != null && $lng != null) {
341
			$marqueurs['stats']['latMin'] = $marqueurs['stats']['latMin'] > $lat ? $lat : $marqueurs['stats']['latMin'];
342
			$marqueurs['stats']['lngMin'] = $marqueurs['stats']['lngMin'] > $lng ? $lng : $marqueurs['stats']['lngMin'];
343
			$marqueurs['stats']['latMax'] = $marqueurs['stats']['latMax'] < $lat ? $lat : $marqueurs['stats']['latMax'];
344
			$marqueurs['stats']['lngMax'] = $marqueurs['stats']['lngMax'] < $lng ? $lng : $marqueurs['stats']['lngMax'];
345
		}
346
	}
1003 jpm 347
 
981 jpm 348
	private function traiterNbreObs($resultats) {
349
		$obs_nbre = 0;
350
		if ($resultats !== false) {
351
			$obs_nbre = count($resultats);
352
		}
353
		return $obs_nbre;
354
	}
1003 jpm 355
 
981 jpm 356
	private function verifierLatLng($lat, $lng) {
357
		$ok_lat = $this->etreLatitude($lat) ? true : false;
358
		$ok_lng = $this->etreLongitude($lng) ? true : false;
359
		$ok = $ok_lat && $ok_lng;
1003 jpm 360
		return $ok;
981 jpm 361
	}
1003 jpm 362
 
981 jpm 363
	private function etreLatitude($lat) {
364
		$ok = false;
365
		//$format =  preg_match('/^[-]?[0-9]+(?:[.][0-9]+|)$/', $lat) ? true : false;
366
		$ok = ($lat >= -90 && $lat <= 90) ? true : false;
367
		return $ok;
368
	}
1003 jpm 369
 
981 jpm 370
	private function etreLongitude($lng) {
371
		$ok = false;
372
		//$format =  preg_match('/^[-]?[0-9]+(?:[.][0-9]+|)$/', $lng) ? true : false;
373
		$ok = ($lng >= -180 && $lng <= 180) ? true : false;
374
		return $ok;
375
	}
1003 jpm 376
 
981 jpm 377
	private function etreObsSensible($tags) {
378
		$sensible = true;
379
		if (stristr($tags, 'sensible') === FALSE) {
380
			$sensible = false;
381
		}
382
		return $sensible;
383
	}
1003 jpm 384
 
474 jpm 385
	/**
386
	 * Données pour l'affichage des obs d'une station
387
	 */
388
	public function getObservations($params) {
938 jpm 389
		$resultats = array();
390
		$total = 0;
1132 aurelien 391
		if (isset($this->parametres['station']) && !$this->etreNull($this->parametres['station'])) {
938 jpm 392
			$requete = 	'SELECT SQL_CALC_FOUND_ROWS id, identifiant, nom_sel, nom_ret, num_nom_sel, num_nom_ret, num_taxon, famille, '.
393
						'	lieudit, location, date_observation, milieu, commentaire, '.
394
						'	sector, x_utm, y_utm, insee_code, date_transmission '.
395
						'FROM cel_inventory AS i '.
396
						'	LEFT JOIN locations AS l '.
397
						"		ON (l.name = i.location AND l.code = i.id_location) ".
398
						"WHERE transmission = '1' ".
1092 aurelien 399
						((!$this->etreNull($this->parametres['commune'])) ? $this->construireWhereCommuneSansCoordonneesAvecSensibles() : $this->construireWhereCoordonneesSansSensibles()).
938 jpm 400
						$this->construireWhereUtilisateur().
401
						$this->construireWhereNumTaxon().
402
						$this->construireWhereNomTaxon().
403
						$this->construireWhereDate().
940 jpm 404
						$this->construireWhereCommentaire().
938 jpm 405
						$this->construireWhereProjet().
406
						$this->construireWhereTag().
407
	                    'ORDER BY nom_sel ASC '.
408
	                    "LIMIT {$this->start},{$this->limit} ";
1033 aurelien 409
 
938 jpm 410
			$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
411
			$requete = 'SELECT FOUND_ROWS()';
412
			$total = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
474 jpm 413
		}
1003 jpm 414
 
474 jpm 415
		// Post-traitement
938 jpm 416
		$observations = $this->traiterObservations($resultats, $total);
1039 aurelien 417
		$observations = $this->ajouterImagesAuxObs($observations);
418
		$observations = $this->ajouterAuteursAuxObs($observations);
938 jpm 419
		$observations = $this->supprimerIdDesObs($observations);
1003 jpm 420
 
938 jpm 421
		return $observations;
422
	}
1003 jpm 423
 
938 jpm 424
	private function traiterObservations($donnees, $total) {
425
		$observations = array('commune' => '', 'observations' => array(), 'observateurs' => array());
426
		$observations['total'] = (isset($total)) ? $total : 0;
427
		if (is_array($donnees) && count($donnees) > 0) {
428
			foreach ($donnees as $donnee) {
429
				$observation = array();
430
				$observation['idObs'] = $donnee->id;
431
				$observation['nn'] = $this->etreNull($donnee->num_nom_sel) ? null : $donnee->num_nom_sel;
432
				$observation['nomSci'] = $this->nettoyerTexte($donnee->nom_sel);
433
				$observation['date'] = $this->formaterDate($donnee->date_observation, '%d/%m/%Y');
434
				$observation['datePubli'] = $this->formaterDate($donnee->date_transmission);
435
				$observation['lieu'] = $this->traiterLieu($donnee);
436
				$observation['observateur'] = $donnee->identifiant;
437
				$observation['urlEflore'] = $this->getUrlEflore($donnee->num_nom_sel);
1003 jpm 438
 
938 jpm 439
				if (isset($donnee->location)) {
440
					$observations['commune'] = $this->nettoyerTexte($donnee->location);
441
				}
442
				$observations['observations'][$donnee->id] = $observation;
1003 jpm 443
 
938 jpm 444
				if (! array_key_exists($donnee->identifiant, $observations['observateurs'])) {
1003 jpm 445
					$observations['observateurs'][$donnee->identifiant] = $donnee->identifiant;
938 jpm 446
				}
447
			}
487 jpm 448
		}
938 jpm 449
		return $observations;
450
	}
1003 jpm 451
 
938 jpm 452
	private function getUrlEflore($nn) {
453
		$urlEflore = null;
454
		if (! $this->etreNull($nn)) {
455
			$urlEflore = sprintf($this->config['settings']['efloreUrlTpl'], $nn, 'illustration');
456
		}
457
		return $urlEflore;
458
	}
1003 jpm 459
 
938 jpm 460
	private function traiterLieu($donnee) {
461
		$lieu = array();
462
		if (!$this->etreNull($donnee->lieudit)) {
463
			$lieu[] = $donnee->lieudit;
464
		}
465
		if (!$this->etreNull($donnee->milieu)) {
466
			$lieu[] = $donnee->milieu;
467
		}
468
		return implode(', ', $lieu);
469
	}
1003 jpm 470
 
938 jpm 471
	private function chargerImages(Array $obs_ids) {
472
		// Récupération des données au format Json
473
		$service = 'CelImage/liste-ids?obsId='.implode(',', $obs_ids);
474
		$url = sprintf($this->config['settings']['baseURLServicesCelTpl'], $service);
475
		$json = $this->getRestClient()->consulter($url);
476
		$donnees = json_decode($json);
1003 jpm 477
 
938 jpm 478
		// Post-traitement des données
479
		$images = $this->traiterImages($donnees);
1003 jpm 480
 
938 jpm 481
		return $images;
474 jpm 482
	}
1003 jpm 483
 
938 jpm 484
	private function traiterImages($donnees) {
485
		$images = array();
486
		if (count($donnees) > 0) {
487
			foreach ($donnees as $id_obs => $id_images) {
488
				foreach ($id_images as $id_img) {
489
					$urls['idImg'] = $id_img;
490
					$urls['guid'] = sprintf($this->config['settings']['guidImgTpl'], $id_img);
491
					$urls['miniature'] = $this->getUrlImage($id_img, 'CXS');
492
					$urls['normale'] = $this->getUrlImage($id_img, 'XL');
493
					$images[$id_obs][] = $urls;
1003 jpm 494
				}
938 jpm 495
			}
496
		}
497
		return $images;
498
	}
1003 jpm 499
 
938 jpm 500
	private function ajouterImagesAuxObs($observations) {
501
		$images = $this->chargerImages(array_keys($observations['observations']));
502
		foreach ($observations['observations'] as $id => $infos) {
1043 aurelien 503
			if(isset($images[$id])) {
504
				$infos['images'] = $images[$id];
505
				$observations['observations'][$id] = $infos;
506
			}
938 jpm 507
		}
508
		return $observations;
509
	}
1003 jpm 510
 
938 jpm 511
	private function ajouterAuteursAuxObs($observations) {
944 jpm 512
		$observateurs = $this->recupererUtilisateursIdentite(array_keys($observations['observateurs']));
938 jpm 513
		unset($observations['observateurs']);
514
		foreach ($observations['observations'] as $id => $infos) {
515
			$courriel = $infos['observateur'];
944 jpm 516
			$infos['observateur'] = $observateurs[$courriel]['intitule'];
517
			$infos['observateurId'] = $observateurs[$courriel]['id'];
938 jpm 518
			$observations['observations'][$id] = $infos;
519
		}
520
		return $observations;
521
	}
1003 jpm 522
 
938 jpm 523
	private function supprimerIdDesObs($observations) {
524
		// Le tableau de sortie ne doit pas avoir les id des obs en clé car sinon Jquery Template ne fonctionne pas
525
		$observationSansId = $observations;
526
		unset($observationSansId['observations']);
527
		foreach ($observations['observations'] as $id => $infos) {
528
			$observationSansId['observations'][] = $infos;
529
		}
530
		return $observationSansId;
531
	}
1003 jpm 532
 
478 jpm 533
	/**
938 jpm 534
	 * Liste des taxons présents sur la carte
840 jpm 535
	 */
938 jpm 536
	public function getTaxons($params) {
840 jpm 537
		$json = null;
1003 jpm 538
 
938 jpm 539
		$requete = 	'SELECT SQL_CALC_FOUND_ROWS DISTINCT nom_ret, num_nom_ret, num_taxon, famille '.
840 jpm 540
					'FROM cel_inventory AS i '.
541
					'	LEFT JOIN locations AS l '.
542
					'		ON (l.name = i.location AND l.code = i.id_location) '.
543
					"WHERE transmission = '1' ".
938 jpm 544
					"	AND nom_ret != '' ".
545
					$this->construireWhereDept().
546
                    $this->construireWhereCommune().
547
                    $this->construireWhereUtilisateur().
548
					$this->construireWhereNumTaxon().
549
					$this->construireWhereNomTaxon().
550
					$this->construireWhereDate().
940 jpm 551
					$this->construireWhereCommentaire().
938 jpm 552
					$this->construireWhereProjet().
981 jpm 553
					$this->construireWhereTag().
938 jpm 554
					'ORDER BY nom_ret ASC '.
555
                    "LIMIT {$this->start},{$this->limit} ";
556
		//$this->debug[] = $requete;
557
		$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
1003 jpm 558
 
938 jpm 559
		$requete = 'SELECT FOUND_ROWS()';
560
		$taxons['total'] = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
1003 jpm 561
 
938 jpm 562
		// Post-traitement
563
		$taxons['taxons'] = $this->traiterTaxons($resultats);
1003 jpm 564
 
938 jpm 565
		return $taxons;
840 jpm 566
	}
1003 jpm 567
 
938 jpm 568
	private function traiterTaxons($donnees) {
569
		$taxons = array();
570
		if (is_array($donnees) && count($donnees) > 0) {
571
			foreach ($donnees as $donnee) {
572
				if (!isset($taxons[$donnee->num_taxon]) && ! $this->etreNull($donnee->nom_ret)) {
573
					$taxon = array();
574
					$taxon['nn'] = $donnee->num_nom_ret;
575
					$taxon['nt'] = $donnee->num_taxon;
576
					$taxon['nom'] = $this->nettoyerTexte($donnee->nom_ret);
577
					$taxon['famille'] = $this->nettoyerTexte($donnee->famille);
578
					$taxons[$donnee->num_taxon] = $taxon;
579
				}
580
			}
581
		}
582
		$taxons = array_values($taxons);
583
		return $taxons;
584
	}
1003 jpm 585
 
938 jpm 586
	private function construireWhereCoordonnees() {
587
		$sql = '';
588
		// Récupération des coordonnées depuis l'id station
940 jpm 589
		extract($this->decomposerParametreStation());
938 jpm 590
		if (isset($type)) {
981 jpm 591
			if ($type == self::MARQUEUR_COMMUNE) {
954 jpm 592
				$lat = $this->proteger($lat);
593
				$lng = $this->proteger($lng);
1033 aurelien 594
				$sql = " AND (ROUND(wgs84_latitude,5) = ROUND($lat,5) AND ROUND(wgs84_longitude,5) = ROUND($lng,5)) ";
981 jpm 595
			}  else if ($type == self::MARQUEUR_STATION) {
954 jpm 596
				$lat = $this->proteger($lat);
597
				$lng = $this->proteger($lng);
598
				$sql = " AND (coord_x = $lat AND coord_y = $lng) ";
938 jpm 599
			}
1003 jpm 600
		}
938 jpm 601
		return $sql;
602
	}
1092 aurelien 603
 
604
	private function construireWhereCoordonneesSansSensibles() {
605
		$sql = '(';
606
		// Récupération des coordonnées depuis l'id station
607
		extract($this->decomposerParametreStation());
608
		if (isset($type)) {
609
			if ($type == self::MARQUEUR_COMMUNE) {
610
				$lat = $this->proteger($lat);
611
				$lng = $this->proteger($lng);
612
				$sql = " AND (ROUND(wgs84_latitude,5) = ROUND($lat,5) AND ROUND(wgs84_longitude,5) = ROUND($lng,5)) ";
613
			}  else if ($type == self::MARQUEUR_STATION) {
614
				$lat = $this->proteger($lat);
615
				$lng = $this->proteger($lng);
616
				$sql = " AND (coord_x = $lat AND coord_y = $lng) ";
617
			}
618
		}
619
		$sql .= ' AND mots_cles_texte NOT LIKE %sensible%';
620
		return $sql;
621
	}
1003 jpm 622
 
940 jpm 623
	private function construireWhereCommentaire() {
624
		$sql = '';
625
		list($type, $commentaire) = $this->decomposerParametreCommentaire();
626
		if (!$this->etreNull($commentaire)) {
627
			$commentaire = $this->proteger('%'.$commentaire.'%');
628
			switch ($type) {
629
				case '*' :
630
					$sql = $this->obtenirConditionPourCommentaires($commentaire);
631
					$sql = " AND (commentaire LIKE $commentaire OR ($sql)) ";
632
					break;
633
				case 'observation' :
634
					$sql = " AND commentaire LIKE $commentaire ";
635
					break;
636
				case 'photo' :
637
					$sql = ' AND '.$this->obtenirConditionPourCommentaires($commentaire).' ';
638
					break;
639
				case 'photo.meta' :
640
					$sql = ' AND '.$this->obtenirConditionPourCommentaireMeta($commentaire).' ';
641
					break;
642
				case 'photo.utilisateur' :
643
					$sql = ' AND '.$this->obtenirConditionPourCommentaireUtilisateur($commentaire).' ';
644
					break;
645
				default:
646
					$sql = " AND commentaire LIKE $commentaire ";
1003 jpm 647
			}
940 jpm 648
		}
649
		return $sql;
650
	}
1003 jpm 651
 
652
 
938 jpm 653
	private function construireWhereNomTaxon() {
654
		$sql = '';
940 jpm 655
		list($type, $nom) = $this->decomposerParametreTaxon();
656
		if (!$this->etreNull($nom)) {
938 jpm 657
			$nom = $this->proteger($nom.'%');
658
			switch ($type) {
659
				case '*' :
660
					$sql = " AND (nom_ret LIKE $nom OR nom_sel LIKE $nom OR famille LIKE $nom) ";
661
					break;
940 jpm 662
				case 'retenu' :
938 jpm 663
					$sql = " AND nom_ret LIKE $nom ";
664
					break;
940 jpm 665
				case 'selectionne' :
938 jpm 666
					$sql = " AND nom_sel LIKE $nom ";
667
					break;
940 jpm 668
				case 'famille' :
938 jpm 669
					$sql = " AND famille LIKE $nom ";
670
					break;
671
				default:
672
					$sql = " AND nom_ret LIKE $nom ";
1003 jpm 673
			}
938 jpm 674
		}
675
		return $sql;
676
	}
1003 jpm 677
 
938 jpm 678
	private function construireWhereDate() {
679
		$sql = '';
680
		// Récupération des coordonnées depuis l'id station
940 jpm 681
		list($type, $date) = $this->decomposerParametreDate();
1003 jpm 682
 
938 jpm 683
		if (!$this->etreNull($date)) {
684
			$date = $this->proteger($date.'%');
685
			switch ($type) {
686
				case '*' :
687
					$sql = " AND (
1003 jpm 688
						date_observation LIKE $date
689
						OR date_creation LIKE $date
690
						OR date_modification LIKE $date
938 jpm 691
						OR date_transmission LIKE $date) ";
692
					break;
693
				case 'observation' :
694
					$sql = " AND date_observation LIKE $date ";
695
					break;
696
				case 'creation' :
697
					$sql = " AND date_creation LIKE $date ";
698
					break;
699
				case 'modification' :
700
					$sql = " AND date_modification LIKE $date ";
701
					break;
702
				case 'transmission' :
703
					$sql = " AND date_transmission LIKE $date ";
704
					break;
940 jpm 705
				case 'photo' :
706
					$sql = $this->obtenirConditionPourDatePhoto($date);
707
					break;
708
				case 'ajout' :
709
					$sql = $this->obtenirConditionPourDateAjout($date);
710
					break;
938 jpm 711
				case 'liaison' :
940 jpm 712
					$sql = $this->obtenirConditionPourDateLiaison($date);
938 jpm 713
					break;
714
				default:
715
					$sql = " AND date_observation LIKE $date ";
716
			}
717
		}
718
		return $sql;
719
	}
1003 jpm 720
 
940 jpm 721
	private function obtenirConditionPourDatePhoto($date) {
722
		$observations = $this->obtenirObsLieesImg('date.photo', $date);
723
		if (is_null($observations)) {
724
			$this->debug[] = "Aucune observation n'est liée à une photo prise à la date : $date";
725
		}
726
		$sql = $this->assemblerObsEnConditionSql($observations);
727
		return $sql;
728
	}
1003 jpm 729
 
940 jpm 730
	private function obtenirConditionPourDateLiaison($date) {
731
		$observations = $this->obtenirObsLieesImg('date.liaison', $date);
732
		if (is_null($observations)) {
733
			$this->debug[] = "Aucune observation n'a été liée à une image à à la date : $date";
734
		}
735
		$sql = $this->assemblerObsEnConditionSql($observations);
736
		return $sql;
737
	}
738
 
739
	private function obtenirConditionPourDateAjout($date) {
740
		$observations = $this->obtenirObsLieesImg('date.ajout', $date);
741
		if (is_null($observations)) {
742
			$this->debug[] = "Aucune observation n'est liée à une image ajoutée à la date : $date";
743
		}
744
		$sql = $this->assemblerObsEnConditionSql($observations);
745
		return $sql;
746
	}
1003 jpm 747
 
940 jpm 748
	private function obtenirConditionPourCommentaireMeta($commentaire) {
749
		$observations = $this->obtenirObsLieesImg('commentaire.meta', $commentaire);
750
		if (is_null($observations)) {
751
			$this->debug[] = "Aucune observation n'est liée à une image dont le commentaire des méta-données correspond à : $commmentaire";
752
		}
753
		$operateur = '';
754
		$sql = $this->assemblerObsEnConditionSql($observations, $operateur);
755
		return $sql;
756
	}
1003 jpm 757
 
940 jpm 758
	private function obtenirConditionPourCommentaireUtilisateur($commentaire) {
759
		$observations = $this->obtenirObsLieesImg('commentaire.utilisateur', $commentaire);
760
		if (is_null($observations)) {
761
			$this->debug[] = "Aucune observation n'est liée à une image dont le commentaire des utilisateur correspond à : $commmentaire";
762
		}
763
		$operateur = '';
764
		$sql = $this->assemblerObsEnConditionSql($observations, $operateur);
765
		return $sql;
766
	}
1003 jpm 767
 
940 jpm 768
	private function obtenirConditionPourCommentaires($commentaire) {
769
		$observations = $this->obtenirObsLieesImg('commentaire.*', $commentaire);
770
		if (is_null($observations)) {
771
			$this->debug[] = "Aucune observation n'est liée à une image dont un des commentaires correspond à : $commmentaire";
772
		}
773
		$operateur = '';
774
		$sql = $this->assemblerObsEnConditionSql($observations, $operateur);
775
		return $sql;
776
	}
1003 jpm 777
 
940 jpm 778
	/**
779
	 * Récupération des identifiant d'utilisateur et des ordres des observations correspondant à une date.
780
	 * Retour sous forme de tableau : array[identifiant] = array(ordre, ordre...);
781
	 */
782
	private function obtenirObsLieesImg($type, $param) {
783
		// Construction de la requête
784
		$requete = 	'SELECT DISTINCT coi_ce_observation AS ordre,  coi_ce_utilisateur AS utilisateur '.
785
			'FROM  cel_images '.
786
			'	LEFT JOIN cel_obs_images '.
787
			'		ON (ci_id_image = coi_ce_image) '.
788
			'	LEFT JOIN cel_inventory AS i '.
789
			'		ON (coi_ce_utilisateur = i.identifiant AND coi_ce_observation = i.ordre) '.
790
			'	LEFT JOIN locations AS l '.
791
			'		ON (l.name = i.location AND l.code = i.id_location) '.
792
			"WHERE  transmission = '1' ".
793
			($type == 'date.photo' ? " AND (ci_meta_date_time LIKE ".str_replace('-', ':', $param)." OR ci_meta_date LIKE $param) " : '').
794
			($type == 'date.ajout' ? " AND ci_meta_date_ajout LIKE $param " : '').
795
			($type == 'date.liaison' ? " AND coi_date_liaison LIKE $param " : '').
796
			($type == 'commentaire.meta' ? " AND ci_meta_comment LIKE $param " : '').
797
			($type == 'commentaire.utilisateur' ? "	AND ci_meta_user_comment LIKE $param " : '').
798
			($type == 'commentaire.*' ? " AND (ci_meta_comment LIKE $param OR ci_meta_user_comment LIKE $param) " : '').
1003 jpm 799
			$this->construireWhereCoordonnees().
940 jpm 800
			$this->construireWhereDept().
801
			$this->construireWhereCommune().
802
			$this->construireWhereUtilisateur().
803
			$this->construireWhereNumTaxon().
804
			$this->construireWhereNomTaxon().
805
			$this->construireWhereProjet().
806
			$this->construireWhereTag().
807
			'ORDER BY utilisateur ASC, ordre ASC';
808
		//$this->debug[] = $requete;
809
		//die($requete);
810
		$resultats = $this->executerRequete($requete);
1003 jpm 811
 
940 jpm 812
		$observations = null;
813
		if ($resultats != false) {
814
			$observations = array();
815
			foreach ($resultats as $occurence) {
816
				$utilisateur = $occurence['utilisateur'];
817
				$ordre = $occurence['ordre'];
818
				if (!array_key_exists($utilisateur, $observations)) {
819
					$observations[$utilisateur] = array();
820
				}
821
				if (!array_key_exists($ordre, $observations[$utilisateur])) {
822
					$observations[$utilisateur][$ordre] = $ordre;
823
				}
824
			}
825
		}
826
		return $observations;
827
	}
1003 jpm 828
 
940 jpm 829
	private function assemblerObsEnConditionSql($observations, $operateur = 'AND') {
830
		$sql = '';
831
		if ($observations != null) {
832
			// Pré-construction du where de la requête
833
			$tpl_where = "(identifiant = '%s' AND ordre IN (%s))";
834
			foreach ($observations as $utilisateur => $ordres) {
835
				$morceaux_requete[] = sprintf($tpl_where, $utilisateur, implode(',', $ordres));
836
			}
837
			if (count($morceaux_requete) > 0) {
838
				$sql = implode(" \nOR ", $morceaux_requete);
839
			}
840
		} else {
841
			// Nous voulons que la requête ne retourne rien
842
			$sql = "identifiant = '' AND ordre = ''";
843
		}
844
		$sql = " $operateur ($sql) ";
845
		return $sql;
846
	}
1003 jpm 847
 
981 jpm 848
	private function construireWhereRectangleStation() {
849
		$sql = '';
1132 aurelien 850
		if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) {
981 jpm 851
			$ne = $this->decomposerLatLng($this->parametres['ne']);
852
			$sw = $this->decomposerLatLng($this->parametres['sw']);
1003 jpm 853
 
981 jpm 854
			$latMin = $sw['lat'];
855
			$lngMin = $sw['lng'];
1003 jpm 856
 
981 jpm 857
			$latMax = $ne['lat'];
858
			$lngMax = $ne['lng'];
1003 jpm 859
 
981 jpm 860
			// ATTENTION : coord_x correspond bien à la LATITUDE!
1003 jpm 861
			$sql = " AND (coord_x != 0 AND coord_y != 0) ".
981 jpm 862
				" AND coord_x > $latMin ".
863
				" AND coord_x < $latMax ".
864
				" AND coord_y > $lngMin ".
865
				" AND coord_y < $lngMax ";
866
		}
867
		return $sql;
868
	}
1003 jpm 869
 
981 jpm 870
	private function construireWhereRectangleStationOR() {
871
		$sql = '';
1132 aurelien 872
		if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) {
981 jpm 873
			$ne = $this->decomposerLatLng($this->parametres['ne']);
874
			$sw = $this->decomposerLatLng($this->parametres['sw']);
1003 jpm 875
 
981 jpm 876
			$latMin = $sw['lat'];
877
			$lngMin = $sw['lng'];
1003 jpm 878
 
981 jpm 879
			$latMax = $ne['lat'];
880
			$lngMax = $ne['lng'];
1003 jpm 881
 
981 jpm 882
			// ATTENTION : coord_x correspond bien à la LATITUDE!
1003 jpm 883
			$sql = "( (coord_x != 0 AND coord_y != 0) ".
981 jpm 884
				" AND coord_x > $latMin ".
885
				" AND coord_x < $latMax ".
886
				" AND coord_y > $lngMin ".
887
				" AND coord_y < $lngMax )";
888
		}
889
		return $sql;
890
	}
1003 jpm 891
 
981 jpm 892
	private function construireWhereRectangleCommune() {
893
		$sql = '';
1132 aurelien 894
		if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) {
981 jpm 895
			$ne = $this->decomposerLatLng($this->parametres['ne']);
896
			$sw = $this->decomposerLatLng($this->parametres['sw']);
1003 jpm 897
 
981 jpm 898
			$latMin = $sw['lat'];
899
			$lngMin = $sw['lng'];
1003 jpm 900
 
981 jpm 901
			$latMax = $ne['lat'];
902
			$lngMax = $ne['lng'];
1003 jpm 903
 
904
			$sql = "AND wgs84_longitude != 0 AND wgs84_latitude != 0 ".
981 jpm 905
				" AND wgs84_latitude > $latMin ".
906
				" AND wgs84_latitude < $latMax ".
907
				" AND wgs84_longitude > $lngMin ".
908
				" AND wgs84_longitude < $lngMax ";
909
		}
910
		return $sql;
911
	}
1003 jpm 912
 
981 jpm 913
	private function construireWhereRectangleCommuneOR() {
914
		$sql = '';
1132 aurelien 915
		if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) {
981 jpm 916
			$ne = $this->decomposerLatLng($this->parametres['ne']);
917
			$sw = $this->decomposerLatLng($this->parametres['sw']);
1003 jpm 918
 
981 jpm 919
			$latMin = $sw['lat'];
920
			$lngMin = $sw['lng'];
1003 jpm 921
 
981 jpm 922
			$latMax = $ne['lat'];
923
			$lngMax = $ne['lng'];
1003 jpm 924
 
925
			$sql = "( wgs84_longitude != 0 AND wgs84_latitude != 0 ".
981 jpm 926
				" AND wgs84_latitude > $latMin ".
927
				" AND wgs84_latitude < $latMax ".
928
				" AND wgs84_longitude > $lngMin ".
929
				" AND wgs84_longitude < $lngMax )";
930
		}
931
		return $sql;
932
	}
1003 jpm 933
 
938 jpm 934
	private function construireWhereDept() {
935
		$sql = '';
936
		// Récupération des coordonnées depuis l'id station
937
		extract($this->parametres);
1132 aurelien 938
		if (isset($this->parametres['dept']) && !$this->etreNull($dept)) {
938 jpm 939
			$dept = $this->traiterValeursMultiples($dept);
940
			$sql = " AND code IN ($dept) ";
941
		}
942
		return $sql;
943
	}
1003 jpm 944
 
938 jpm 945
	private function construireWhereCommune() {
946
		$sql = '';
947
		// Récupération des coordonnées depuis l'id station
948
		extract($this->parametres);
1132 aurelien 949
		if (isset($this->parametres['commune']) && !$this->etreNull($commune)) {
938 jpm 950
			$commune = $this->proteger($commune);
951
			$sql = " AND location LIKE $commune ";
952
		}
953
		return $sql;
954
	}
1003 jpm 955
 
1092 aurelien 956
	private function construireWhereCommuneSansCoordonneesAvecSensibles() {
1043 aurelien 957
		$sql = '';
958
		// Récupération des coordonnées depuis l'id station
959
		extract($this->parametres);
1132 aurelien 960
		if (isset($this->parametres['commune']) && !$this->etreNull($commune)) {
1043 aurelien 961
			$commune = $this->proteger($commune);
962
			$sql = " AND location LIKE $commune ";
1092 aurelien 963
			$sql .= " AND (
964
			           		(
965
			           			(coord_x = '000null' OR coord_x = '') ".
966
								" AND (coord_y = '000null' OR coord_y = '')".
967
							')'.
968
							' OR mots_cles_texte LIKE "%sensible%"'.
969
						') ';
970
 
1043 aurelien 971
		}
972
		return $sql;
973
	}
1003 jpm 974
 
938 jpm 975
	private function construireWhereUtilisateur() {
976
		$sql = '';
977
		// Récupération des coordonnées depuis l'id station
978
		extract($this->parametres);
1132 aurelien 979
		if (isset($this->parametres['utilisateur']) && !$this->etreNull($utilisateur)) {
938 jpm 980
			$utilisateur = $this->proteger($utilisateur);
981
			$sql = " AND identifiant = $utilisateur ";
982
		}
983
		return $sql;
984
	}
1003 jpm 985
 
938 jpm 986
	private function construireWhereNumTaxon() {
987
		$sql = '';
988
		// Récupération des coordonnées depuis l'id station
989
		extract($this->parametres);
1132 aurelien 990
		if (isset($this->parametres['num_taxon']) && !$this->etreNull($num_taxon)) {
938 jpm 991
			$num_taxon = $this->proteger($num_taxon);
992
			$sql = " AND num_taxon = $num_taxon ";
993
		}
994
		return $sql;
995
	}
1003 jpm 996
 
938 jpm 997
	private function construireWhereProjet() {
998
		$sql = '';
999
		// Récupération des coordonnées depuis l'id station
1000
		extract($this->parametres);
1132 aurelien 1001
		if(isset($this->parametres['projet']) ) {
1002
			$projet_sql = $this->getSqlWhereProjet($projet);
1003
			if (!$this->etreNull($projet_sql)) {
1004
				$sql = " AND ($projet_sql) ";
1005
			}
938 jpm 1006
		}
1007
		return $sql;
1008
	}
1003 jpm 1009
 
840 jpm 1010
	/**
938 jpm 1011
	 * Traitement de $projet pour construction du filtre dans la requête
478 jpm 1012
	 */
938 jpm 1013
	private function getSqlWhereProjet($projet) {
1014
		$sql = null;
1015
		if (! $this->etreNull($projet)) {
1016
			$mot_cle_encode = $this->bdd->quote($this->encoderMotCle($projet));
1003 jpm 1017
 
938 jpm 1018
			// Construction de la requête
1019
			$requete = 	'SELECT * '.
1020
						'FROM cel_mots_cles_obs '.
1021
						"WHERE cmc_id_mot_cle_general = $mot_cle_encode ";
1022
			$elements_projet = $this->executerRequete($requete);
1003 jpm 1023
 
938 jpm 1024
			$requete_projet = array();
1025
			if ($elements_projet != false && count($elements_projet) > 0) {
1026
				// Pré-construction du where de la requête
1027
				$tpl_where = '(mots_cles LIKE "%%%s%%" AND identifiant = %s )';
1003 jpm 1028
 
938 jpm 1029
				foreach ($elements_projet as $occurence) {
1030
					$requete_projet[] = sprintf($tpl_where, $occurence['cmc_id_mot_cle_utilisateur'], $this->bdd->quote($occurence['cmc_id_proprietaire']));
1031
				}
1032
			} else {
1033
				$this->messages[] = "Aucune observation ne correspond à ce mot clé.";
1034
			}
1035
			if (count($requete_projet) > 0) {
1036
				$sql = implode(" \nOR ", $requete_projet);
1037
			}
1038
		}
1039
		return $sql;
1040
	}
1003 jpm 1041
 
938 jpm 1042
	private function construireWhereTag() {
1043
		$sql = '';
1044
		// Récupération des coordonnées depuis l'id station
840 jpm 1045
		extract($this->parametres);
1132 aurelien 1046
		if(isset($this->parametres['tag']) ) {
1047
			$tag_sql = $this->getSqlWhereObsAvecImagesTaguees($tag);
1048
			if (!$this->etreNull($tag_sql)) {
1049
				$sql = " AND ($tag_sql) ";
1050
			}
489 jpm 1051
		}
938 jpm 1052
		return $sql;
1053
	}
1003 jpm 1054
 
938 jpm 1055
	/**
1056
	 * Traitement de $tag pour construction du filtre dans la requête
1057
	 */
1058
	private function getSqlWhereObsAvecImagesTaguees($tag) {
1059
		$sql = null;
1060
		if (! $this->etreNull($tag)) {
1061
			$tag_sql = $this->getSqlWhereMotsCles($tag);
1062
			// Construction de la requête
1063
			$requete = 	'SELECT DISTINCT coi_ce_observation AS ordre,  coi_ce_utilisateur AS utilisateur '.
1064
						'FROM cel_images '.
1065
						'	LEFT JOIN cel_obs_images '.
1066
						'		ON (ci_id_image = coi_ce_image) '.
1067
						'	LEFT JOIN cel_inventory AS i '.
1068
						'		ON (coi_ce_utilisateur = i.identifiant AND coi_ce_observation = i.ordre) '.
1069
						'	LEFT JOIN locations AS l '.
1070
						"		ON (l.name = i.location AND l.code = i.id_location) ".
1071
						"WHERE  transmission = '1' ".
1072
						$this->construireWhereCoordonnees().
1073
						$this->construireWhereUtilisateur().
1074
						$this->construireWhereNumTaxon().
1075
						$this->construireWhereNomTaxon().
1076
						$this->construireWhereProjet().
1077
						(!$this->etreNull($tag_sql) ? "AND ($tag_sql) " : '').
1078
						'ORDER BY utilisateur ASC, ordre ASC';
1079
			//$this->debug[] = $requete;
1080
			//die($requete);
1081
			$elements_tag = $this->executerRequete($requete);
1003 jpm 1082
 
938 jpm 1083
			$requete_tag = array();
1084
			if ($elements_tag != false && count($elements_tag) > 0) {
1003 jpm 1085
 
938 jpm 1086
				$filtres = array();
1087
				foreach ($elements_tag as $occurence) {
1088
					$utilisateur = $occurence['utilisateur'];
1089
					$ordre = $occurence['ordre'];
1090
					if (!array_key_exists($utilisateur, $filtres)) {
1091
						$filtres[$utilisateur] = array();
1092
					}
1093
					if (!array_key_exists($ordre, $filtres[$utilisateur])) {
1094
						$filtres[$utilisateur][$ordre] = $ordre;
1095
					}
1096
				}
1003 jpm 1097
 
938 jpm 1098
				// Pré-construction du where de la requête
1099
				$tpl_where = "(identifiant = '%s' AND ordre IN (%s))";
1100
				foreach ($filtres as $utilisateur => $ordres) {
1101
					$requete_tag[] = sprintf($tpl_where, $utilisateur, implode(',', $ordres));
1102
				}
1003 jpm 1103
 
938 jpm 1104
			} else {
1105
				$this->messages[] = "Aucune observation ne possède d'images avec ce mot-clé.";
1106
			}
1107
			if (count($requete_tag) > 0) {
1108
				$sql = implode(" \nOR ", $requete_tag);
1109
			}
489 jpm 1110
		}
938 jpm 1111
		return $sql;
478 jpm 1112
	}
1003 jpm 1113
 
487 jpm 1114
	/**
938 jpm 1115
	 * Traitement de $tag pour construction du filtre dans la requête
487 jpm 1116
	 */
938 jpm 1117
	private function getSqlWhereMotsCles($tag) {
1118
		$sql = null;
940 jpm 1119
		$mots_cles = $this->decomposerParametreTag($tag);
1003 jpm 1120
 
487 jpm 1121
		// Construction de la requête
938 jpm 1122
		$requete = 	'SELECT cmc_id_proprietaire AS utilisateur, cmc_id_mot_cle_general AS mot_cle_general, '.
1123
					'	cmc_id_mot_cle_utilisateur AS mot_cle_utilisateur '.
1124
					'FROM cel_mots_cles_images '.
1125
					'WHERE '.$this->getSqlWhereMotsClesImages($mots_cles['motsClesEncodesProteges']);
487 jpm 1126
		$elements_projet = $this->executerRequete($requete);
938 jpm 1127
		//$this->debug[] = $requete;
1003 jpm 1128
 
487 jpm 1129
		$requete_projet = array();
1130
		if ($elements_projet != false && count($elements_projet) > 0) {
1131
			// Pré-construction du where de la requête
938 jpm 1132
			if ($mots_cles['type'] == 'OR') {
1133
				$tpl_where = '(ci_meta_mots_cles LIKE "%%%s,%%" AND ci_ce_utilisateur  = %s )';
1134
				foreach ($elements_projet as $occurence) {
1135
					$requete_projet[] = sprintf($tpl_where, $occurence['mot_cle_utilisateur'], $this->bdd->quote($occurence['utilisateur']));
1136
				}
1137
			} else {
1138
				$tpl_where_mc = "ci_meta_mots_cles LIKE '%%%s,%%'";
1139
				$tpl_where = '((%s) AND ci_ce_utilisateur  = %s)';
1140
				$utilisateur_mc = array();
1141
				foreach ($elements_projet as $occurence) {
1142
					if (!isset($utilisateur_mc[$occurence['utilisateur']][$occurence['mot_cle_general']])) {
1143
						$utilisateur_mc[$occurence['utilisateur']][$occurence['mot_cle_general']] = $occurence['mot_cle_utilisateur'];
1003 jpm 1144
					}
938 jpm 1145
				}
1003 jpm 1146
 
938 jpm 1147
				foreach ($utilisateur_mc as $utilisateur => $mots_cles_utilisateur) {
1148
					if (count($mots_cles_utilisateur) == count($mots_cles['motsCles'])) {
1149
						$where_mots_cles_utilisateur = array();
1150
						foreach ($mots_cles_utilisateur as $mot_cle) {
1151
							$where_mots_cles_utilisateur[] = sprintf($tpl_where_mc, $mot_cle);
1152
						}
1153
						$where_mots_cles_utilisateur = implode(' AND ', $where_mots_cles_utilisateur);
1154
						$utilisateur = $this->bdd->quote($utilisateur);
1155
						$requete_projet[] = sprintf($tpl_where, $where_mots_cles_utilisateur, $utilisateur);
1156
					}
1157
				}
487 jpm 1158
			}
1159
		} else {
1160
			$this->messages[] = "Aucune observation ne correspond à ce mot clé.";
1161
		}
1003 jpm 1162
 
487 jpm 1163
		$sql = implode(" \nOR ", $requete_projet);
938 jpm 1164
		//$this->debug[] = $sql;
487 jpm 1165
		return $sql;
840 jpm 1166
	}
1003 jpm 1167
 
938 jpm 1168
	/**
1169
	 * Traitement de $tag pour construction du filtre dans la requête
1170
	 */
1171
	private function getSqlWhereMotsClesImages($mots_cles_encodes) {
1172
		$where_mots_cles_images = array();
1173
		foreach ($mots_cles_encodes as $mot_cle_encode) {
1174
			$where_mots_cles_images[] = "cmc_id_mot_cle_general = $mot_cle_encode";
1175
		}
1176
		$where_mots_cles_images = implode(' OR ', $where_mots_cles_images);
1177
		return $where_mots_cles_images;
1178
	}
1003 jpm 1179
 
940 jpm 1180
	private function decomposerParametreTag($tags) {
938 jpm 1181
		$mots_cles = array('type' => null, 'motsCles' => null, 'motsClesEncodesProteges' => null);
1182
		if (preg_match('/.+OU.+/', $tags)) {
1183
			$mots_cles['type'] = 'OR';
1184
			$mots_cles['motsCles'] = explode('OU', $tags);
1185
		} else if (preg_match('/.+ET.+/', $tags)) {
1186
			$mots_cles['type'] = 'AND';
1187
			$mots_cles['motsCles'] = explode('ET', $tags);
1188
		} else {
1189
			$mots_cles['motsCles'][] = $tags;
1190
		}
1003 jpm 1191
 
938 jpm 1192
		foreach ($mots_cles['motsCles'] as $mot) {
1193
			$mots_cles['motsClesEncodesProteges'][] = $this->bdd->quote($this->encoderMotCle($mot));
1194
		}
1195
		$this->debug[] = $mots_cles;
1196
		return $mots_cles;
1197
	}
1003 jpm 1198
 
981 jpm 1199
	private function decomposerLatLng($coord) {
1200
		$lat_lng = array();
1201
		if (isset($coord)) {
1202
			list($lat, $lng) = explode('|', $coord);
1203
			$lat_lng = array('lat' => $lat, 'lng' => $lng);
1204
		}
1205
		return $lat_lng;
1206
	}
1003 jpm 1207
 
940 jpm 1208
	private function decomposerParametreStation() {
938 jpm 1209
		$station_infos = array();
1210
		if (isset($this->parametres['station'])) {
1211
			$station = $this->parametres['station'];
1212
			$this->debug[] = $station;
1033 aurelien 1213
			@list($type, $coord) = explode(':', $station);
1214
			@list($lat, $lng) = explode('|', $coord);
1003 jpm 1215
 
954 jpm 1216
			$station_infos = array('type' => $type, 'lat' => $lat, 'lng' => $lng);
938 jpm 1217
		}
1218
		return $station_infos;
1219
	}
1003 jpm 1220
 
940 jpm 1221
	private function decomposerParametreDate() {
1132 aurelien 1222
		$date_infos = array(null,null);
940 jpm 1223
		if (isset($this->parametres['date'])) {
1224
			$date = $this->parametres['date'];
1225
			if (strpos($date, ':')) {
1226
				list($type, $date) = explode(':', $date);
1227
			} else {
1228
				$type = 'observation';
1229
			}
1003 jpm 1230
 
940 jpm 1231
			$date = str_replace('/', '-', $date);
1232
			if (preg_match('/(^[0-9]{2})-([0-9]{2})-([0-9]{4}$)/', $date, $matches)) {
1233
				$date = $matches[3].'-'.$matches[2].'-'.$matches[1];
1234
			}
1003 jpm 1235
 
940 jpm 1236
			$date_infos = array($type, $date);
1237
		}
1238
		return $date_infos;
1239
	}
1003 jpm 1240
 
940 jpm 1241
	private function decomposerParametreTaxon() {
1132 aurelien 1242
		$nom_infos = array(null,null);
940 jpm 1243
		if (isset($this->parametres['taxon'])) {
1244
			$taxon = $this->parametres['taxon'];
1245
			if (strpos($taxon, ':')) {
1246
				$nom_infos = explode(':', $taxon);
1247
			} else {
1248
				$nom_infos = array('retenu', $taxon);
1249
			}
1250
		}
1251
		return $nom_infos;
1252
	}
1003 jpm 1253
 
940 jpm 1254
	private function decomposerParametreCommentaire() {
1132 aurelien 1255
		$commentaire_infos = array(null,null);
940 jpm 1256
		if (isset($this->parametres['commentaire'])) {
1257
			$commentaire = $this->parametres['commentaire'];
1258
			if (strpos($commentaire, ':')) {
1259
				$commentaire_infos = explode(':', $commentaire);
1260
			} else {
1261
				$commentaire_infos = array('observation', $commentaire);
1262
			}
1263
		}
1264
		return $commentaire_infos;
1265
	}
416 aurelien 1266
}