Subversion Repositories eFlore/Applications.cel

Rev

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

Rev 840 Rev 938
1
<?php
1
<?php
2
// declare(encoding='UTF-8');
2
// declare(encoding='UTF-8');
3
/**
3
/**
4
 * Service fournissant une carte dynamique des obsertions publiques du CEL.
4
 * Service fournissant une carte dynamique des obsertions publiques du CEL.
5
 * Encodage en entrée : utf8
5
 * Encodage en entrée : utf8
6
 * Encodage en sortie : utf8
6
 * Encodage en sortie : utf8
7
 *
7
 *
8
 * Cas d'utilisation :
8
 * Cas d'utilisation :
9
 * /CelWidgetMap/Carte/Utilisateur : carte des observations publiques d'un utilisateur.
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.
10
 * /CelWidgetMap/Carte/Utilisateur/Projet : carte des observations publiques d'un utilisateur pour un projet.
11
 * /CelWidgetMap/Carte/Utilisateur/Projet/dept : carte des observations publiques d'un utilisateur pour un projet sur un département.
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.
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.
13
 *
13
 *
14
 * Carte = Type de carte. Valeurs possible : defaut,
14
 * Carte = Type de carte. Valeurs possible : defaut,
15
 * Utilisateur = identifiant (= courriel) de l'utilisateur ou * pour tous les utilisateurs.
15
 * Utilisateur = identifiant (= courriel) de l'utilisateur ou * pour tous les utilisateurs.
16
 * Projet = mot-clé du projet
16
 * Projet = mot-clé du projet
17
 *
17
 *
18
 * @author Jean-Pascal MILCENT <jpm@clapas.org>
18
 * @author Jean-Pascal MILCENT <jpm@clapas.org>
19
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
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>
20
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
21
 * @version $Id$
21
 * @version $Id$
22
 * @copyright © 2010, Jean-Pascal MILCENT
22
 * @copyright © 2010, Jean-Pascal MILCENT
23
 */
23
 */
24
// TODO : supprimer le TRIM quand les obs seront reliées correctements aux localisations (sur le code INSEE par exemple)
24
// TODO : supprimer le TRIM quand les obs seront reliées correctements aux localisations (sur le code INSEE par exemple)
25
class CelWidgetMap extends Cel {
25
class CelWidgetMap extends Cel {
26
	
26
	
27
	/**
27
	/**
28
	 * Méthode appelée avec une requête de type GET.
28
	 * Méthode appelée avec une requête de type GET.
29
	 */
29
	 */
30
	public function getElement($ressources) {
30
	public function getElement($ressources) {
31
		$retour = null;
31
		$retour = null;
32
		extract($this->parametres);
32
		extract($this->parametres);
33
		
33
		
34
		$action = array_shift($ressources);
34
		$action = array_shift($ressources);
35
		if (isset($action)) {
35
		if (isset($action)) {
36
			$methode = $this->traiterNomMethodeGet($action);
36
			$methode = $this->traiterNomMethodeGet($action);
37
			if (method_exists($this, $methode)) {
37
			if (method_exists($this, $methode)) {
38
				$retour = $this->$methode($ressources);
38
				$retour = $this->$methode($ressources);
39
			} else {
39
			} else {
40
				$this->messages[] = "Ce type de ressource '$methode' n'est pas disponible.";
40
				$this->messages[] = "Ce type de ressource '$methode' n'est pas disponible.";
41
			}
41
			}
42
		} else {
42
		} else {
43
			$this->messages[] = "Vous devez indiquer le type de ressource.";
43
			$this->messages[] = "Vous devez indiquer le type de ressource.";
44
		}
44
		}
45
 
45
 
46
		if (is_null($retour)) {
46
		if (is_null($retour)) {
47
			$info = 'Un problème est survenu : '.print_r($this->messages, true);
47
			$info = 'Un problème est survenu : '.print_r($this->messages, true);
48
			$this->envoyer($info);
48
			$this->envoyer($info);
49
		} else if ($retour['type'] == 'json') {
49
		} else if ($retour['type'] == 'jsonVar') {
-
 
50
			
50
			$this->envoyerJsonVar($retour['variable_js'], $retour['donnees']);
51
			$this->envoyerJsonVar($retour['variable_js'], $retour['donnees']);
51
		}  else if ($retour['type'] == 'jsonp') {
52
		}  else if ($retour['type'] == 'jsonP') {
52
			$this->envoyerJsonp($retour['donnees']);
53
			$this->envoyerJsonp($retour['donnees']);
53
		} else {
54
		} else {
54
			$this->envoyer($retour, null, null, true);
55
			$this->envoyerJson($retour);
55
		}
56
		}
56
	}
57
	}
57
 
58
 
58
	/**
59
	/**
59
	 * Données de la carte par défaut
60
	 * Les stations de la carte par défaut
60
	 */
61
	 */
61
	public function getCarteDefautJson($params) {
62
	public function getStations($params) {
62
		$json = null;
63
		$json = null;
-
 
64
		$requete =  'SELECT sector, x_utm, y_utm, wgs84_latitude AS coord_x, wgs84_longitude AS coord_y '.
-
 
65
                    'FROM cel_inventory AS i '.
-
 
66
                    '   LEFT JOIN locations AS l '.
-
 
67
                    '       ON (l.name = i.location AND l.code = i.id_location) '.
-
 
68
                    "WHERE transmission = '1' ".
63
		extract($this->parametres);
69
					$this->construireWhereDept().
-
 
70
                    $this->construireWhereCommune().
-
 
71
                    $this->construireWhereUtilisateur().
-
 
72
					$this->construireWhereNumTaxon().
-
 
73
					$this->construireWhereNomTaxon().
-
 
74
					$this->construireWhereDate().
64
		$dept = $this->traiterValeursMultiples($dept);
75
					$this->construireWhereProjet().
-
 
76
					$this->construireWhereTag();
65
		
-
 
66
		$clause_from = 	'cel_inventory AS i '.
-
 
67
                    	'   LEFT JOIN locations AS l '.
-
 
68
                    	'       ON (l.name = i.location AND l.code = i.id_location)';
-
 
69
		$clause_where = "transmission = '1' ".
-
 
70
                    (!$this->etreNull($utilisateur) ? " AND identifiant = |$utilisateur| " : '' ).
-
 
71
                    (!$this->etreNull($dept) ? " AND l.code IN ($dept) " : '').
-
 
72
                    (!$this->etreNull($num_taxon) ? " AND num_taxon = |$num_taxon| " : '' ).
-
 
73
                    (!$this->etreNull($commune) ? " AND location LIKE |$commune| " : '' ).
-
 
74
                    (!$this->etreNull($projet) ? ' AND ('.$this->getSqlWhereProjet($projet).') ' : '' );
-
 
75
		
-
 
76
		$requete =  'SELECT sector, x_utm, y_utm '.
-
 
77
                    "FROM $clause_from ".
-
 
78
                    "WHERE $clause_where";
77
		
79
		$resultats = $this->requeter($requete);
78
		$resultats = $this->requeter($requete);
80
		
79
		
81
		// Traitement des résultats
80
		// Traitement des résultats
-
 
81
		$obs_nbre = $this->traiterNbreObs($resultats);
-
 
82
		$stations = $this->traiterStations($resultats);
-
 
83
		
-
 
84
		// Création des infos du widget
-
 
85
		$json['donnees']['points'] = $stations;
-
 
86
		$json['donnees']['stats']['communes'] = count($stations);
-
 
87
		$json['donnees']['stats']['observations'] = $obs_nbre;
-
 
88
		
-
 
89
		$json['type'] = (isset($this->formatRetour)) ? $this->formatRetour : 'jsonVar';
-
 
90
		$json['variable_js'] = 'stations';
-
 
91
		
82
		$mm = null;
92
		return $json;
-
 
93
	}
-
 
94
	
-
 
95
	private function traiterNbreObs($resultats) {
-
 
96
		$obs_nbre = 0;
-
 
97
		if ($resultats !== false) {
-
 
98
			$obs_nbre = count($resultats);
-
 
99
		}
-
 
100
		return $obs_nbre;
-
 
101
	}
-
 
102
	
-
 
103
	private function traiterStations($resultats) {
83
		$stations = array();
104
		$stations = array();
84
		if ($resultats !== false) {
105
		if ($resultats !== false) {
85
			foreach ($resultats as $enrg) {
106
			foreach ($resultats as $enrg) {
86
				if ($enrg['x_utm'] != null && $enrg['y_utm'] != null) {
107
				if ($enrg['coord_x'] != null && $enrg['coord_y'] != null) {
87
					$convertisseur = new gPoint();
-
 
88
					$convertisseur->setUTM($enrg['x_utm'], $enrg['y_utm'], $enrg['sector']);
-
 
89
					$convertisseur->convertTMtoLL();
-
 
90
					$enrg['coord_x'] = $convertisseur->Lat();
-
 
91
					$enrg['coord_y'] = $convertisseur->Long();
-
 
92
					$enrg['id'] = 'UTM:'.$enrg['x_utm'].'-'.$enrg['y_utm'].'-'.$enrg['sector'];
-
 
93
					
-
 
94
					$id = $enrg['coord_x'].'-'.$enrg['coord_y'];
108
					$id = $enrg['coord_x'].'-'.$enrg['coord_y'];
95
					if (!isset($stations[$id])) {
109
					if (!isset($stations[$id])) {
-
 
110
						$enrg['id'] = 'UTM:'.$enrg['x_utm'].'-'.$enrg['y_utm'].'-'.$enrg['sector'];
-
 
111
						unset($enrg['x_utm']);
-
 
112
						unset($enrg['y_utm']);
-
 
113
						unset($enrg['sector']);
96
						$stations[$id] = $enrg;
114
						$stations[$id] = $enrg;
97
						$stations[$id]['nbre'] = 1;
115
						$stations[$id]['nbre'] = 1;
98
					} else {
116
					} else {
99
						$stations[$id]['nbre']++;
117
						$stations[$id]['nbre']++;
100
					}
118
					}
101
		
-
 
102
					// Détermination x et y min et max
-
 
103
					if (is_null($mm)) {
-
 
104
						$mm = array('min_x' => $enrg['coord_x'],
-
 
105
							'max_x' => $enrg['coord_x'],
-
 
106
							'min_y' => $enrg['coord_y'],
-
 
107
							'max_y' => $enrg['coord_y']);
-
 
108
					} else {
-
 
109
						$mm['min_x'] = ($mm['min_x'] > $enrg['coord_x']) ? $enrg['coord_x'] : $mm['min_x'];
-
 
110
						$mm['min_y'] = ($mm['min_y'] > $enrg['coord_y']) ? $enrg['coord_y'] : $mm['min_y'];
-
 
111
						$mm['max_x'] = ($mm['max_x'] < $enrg['coord_x']) ? $enrg['coord_x'] : $mm['max_x'];
-
 
112
						$mm['max_y'] = ($mm['max_y'] < $enrg['coord_y']) ? $enrg['coord_y'] : $mm['max_y'];
-
 
113
					}
-
 
114
				}
119
				}
115
			}
120
			}
-
 
121
			$stations = array_values($stations);
116
		}
122
		}
117
		$stations = array_values($stations);
-
 
118
		
-
 
119
		$requete =  'SELECT COUNT(id) AS nbre '.
-
 
120
                    "FROM $clause_from ".
-
 
121
                    "WHERE $clause_where ";
-
 
122
		$obs_nbre = (int) $this->requeter($requete, Cel::SQL_RETOUR_COLONNE);
-
 
123
 
-
 
124
		// Création des infos du widget
-
 
125
		$json['type'] = (isset($this->formatRetour)) ? $this->formatRetour : 'json';
-
 
126
		$json['variable_js'] = 'obs';
-
 
127
		
-
 
128
		$json['donnees']['points'] = $stations;
-
 
129
		$json['donnees']['stats']['communes'] = count($stations);
-
 
130
		$json['donnees']['stats']['observations'] = $obs_nbre;
-
 
131
		$json['donnees']['centre_x'] = $mm['min_x'].'-'.$mm['max_x'];
-
 
132
		$json['donnees']['centre_y'] = $mm['min_y'].'-'.$mm['max_y'];
-
 
133
		return $json;
123
		return $stations;
134
	}
124
	}
135
	
125
	
136
	/**
126
	/**
137
	 * Données pour l'affichage des obs d'une station
127
	 * Données pour l'affichage des obs d'une station
138
	 */
128
	 */
139
	public function getObservations($params) {
129
	public function getObservations($params) {
-
 
130
		$resultats = array();
140
		$json = null;
131
		$total = 0;
141
		extract($this->parametres);
132
		if (!$this->etreNull($this->parametres['station'])) {
-
 
133
			$requete = 	'SELECT SQL_CALC_FOUND_ROWS id, identifiant, nom_sel, nom_ret, num_nom_sel, num_nom_ret, num_taxon, famille, '.
-
 
134
						'	lieudit, location, date_observation, milieu, commentaire, '.
-
 
135
						'	sector, x_utm, y_utm, insee_code, date_transmission '.
-
 
136
						'FROM cel_inventory AS i '.
-
 
137
						'	LEFT JOIN locations AS l '.
-
 
138
						"		ON (l.name = i.location AND l.code = i.id_location) ".
-
 
139
						"WHERE transmission = '1' ".
142
		$dept = $this->traiterValeursMultiples($dept);
140
						$this->construireWhereCoordonnees().
143
		
-
 
144
		// Récupération des coordonnées depuis l'id station
141
						$this->construireWhereUtilisateur().
-
 
142
						$this->construireWhereNumTaxon().
-
 
143
						$this->construireWhereNomTaxon().
145
		$this->debug[] = $station;
144
						$this->construireWhereDate().
146
		list($type, $coord) = explode(':', $station);
145
						$this->construireWhereProjet().
-
 
146
						$this->construireWhereTag().
-
 
147
	                    'ORDER BY nom_sel ASC '.
-
 
148
	                    "LIMIT {$this->start},{$this->limit} ";
147
		if ($type == 'UTM') {
149
			//die($requete);
148
			list($x_utm, $y_utm, $secteur) = explode('-', $coord);
150
			$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
-
 
151
			
149
		} else if ($type == 'LngLat') {
152
			$requete = 'SELECT FOUND_ROWS()';
150
			list($coord_y, $coord_x) = explode('-', $coord);
153
			$total = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
151
		}
154
		}
152
		
-
 
153
		// Récupération du filtre where pour les mots clés "projet"
-
 
154
		if (isset($projet)) {
-
 
155
			$projet_sql = $this->getSqlWhereProjet($projet);
-
 
156
		}
-
 
157
 
-
 
158
		$requete = 	'SELECT id, identifiant, nom_sel, nom_ret, num_nom_sel, num_nom_ret, num_taxon, famille, '.
-
 
159
					'	lieudit, location, date_observation, milieu, commentaire, '.
-
 
160
					'	sector, x_utm, y_utm, insee_code '.
-
 
161
					'FROM cel_inventory AS i '.
-
 
162
					'	LEFT JOIN locations AS l '.
-
 
163
					"		ON (l.name = i.location AND l.code = i.id_location) ".
-
 
164
					"WHERE transmission = '1' ".
-
 
165
					(($type == 'UTM') ? "	AND (sector = |$secteur| AND x_utm = |$x_utm| AND y_utm = |$y_utm| ) " : '').
-
 
166
					(($type == 'LngLat') ? "	AND (coord_x = |$coord_x| AND coord_y = |$coord_y| ) " : '').
-
 
167
					(isset($utilisateur) ? " AND identifiant = |$utilisateur| " : '').
-
 
168
                    (isset($num_taxon) ? " AND num_taxon = |$num_taxon| " : '' ).
-
 
169
                    ((isset($projet) && $projet_sql != '') ? " AND ($projet_sql) " : '' ).
-
 
170
                    'ORDER BY nom_sel ASC '.
-
 
171
                    "LIMIT {$this->start},{$this->limit} ";
-
 
172
		$this->debug[] = $requete;
-
 
173
		$resultats = $this->requeter($requete);
-
 
174
		
155
		
-
 
156
		// Post-traitement
-
 
157
		$observations = $this->traiterObservations($resultats, $total);
-
 
158
		$observations = $this->ajouterImagesAuxObs($observations);
-
 
159
		$observations = $this->ajouterAuteursAuxObs($observations);
-
 
160
		$observations = $this->supprimerIdDesObs($observations);
-
 
161
		return $observations;
-
 
162
	}
-
 
163
	
-
 
164
	private function traiterObservations($donnees, $total) {
-
 
165
		$observations = array('commune' => '', 'observations' => array(), 'observateurs' => array());
-
 
166
		$observations['total'] = (isset($total)) ? $total : 0;
-
 
167
		if (is_array($donnees) && count($donnees) > 0) {
-
 
168
			foreach ($donnees as $donnee) {
-
 
169
				$observation = array();
-
 
170
				$observation['idObs'] = $donnee->id;
-
 
171
				$observation['nn'] = $this->etreNull($donnee->num_nom_sel) ? null : $donnee->num_nom_sel;
-
 
172
				$observation['nomSci'] = $this->nettoyerTexte($donnee->nom_sel);
-
 
173
				$observation['date'] = $this->formaterDate($donnee->date_observation, '%d/%m/%Y');
-
 
174
				$observation['datePubli'] = $this->formaterDate($donnee->date_transmission);
-
 
175
				$observation['lieu'] = $this->traiterLieu($donnee);
-
 
176
				$observation['observateur'] = $donnee->identifiant;
-
 
177
				$observation['urlEflore'] = $this->getUrlEflore($donnee->num_nom_sel);
175
		// Post-traitement
178
				
176
		if (is_array($resultats)) {
179
				if (isset($donnee->location)) {
-
 
180
					$observations['commune'] = $this->nettoyerTexte($donnee->location);
-
 
181
				}
-
 
182
				$observations['observations'][$donnee->id] = $observation;
-
 
183
				
-
 
184
				if (! array_key_exists($donnee->identifiant, $observations['observateurs'])) {
-
 
185
					$observations['observateurs'][$donnee->identifiant] = $donnee->identifiant; 
-
 
186
				}
177
			$resultats = $this->nettoyerTableau($resultats);
187
			}
178
		}
-
 
179
		
188
		}
180
		return $resultats;
189
		return $observations;
181
	}
-
 
182
	
-
 
183
	/**
-
 
184
	 * Nombre d'obs d'une station
190
	}
185
	 */
191
	
186
	public function getObservationsNombre($params) {
192
	private function getUrlEflore($nn) {
187
		$json = null;
-
 
188
		extract($this->parametres);
-
 
189
		$dept = $this->traiterValeursMultiples($dept);
-
 
190
		
-
 
191
		// Récupération des coordonnées depuis l'id station
193
		$urlEflore = null;
192
		$this->debug[] = $station;
-
 
193
		list($type, $coord) = explode(':', $station);
-
 
194
		if ($type == 'UTM') {
-
 
195
			list($x_utm, $y_utm, $secteur) = explode('-', $coord);
-
 
196
		} else if ($type == 'LngLat') {
194
		if (! $this->etreNull($nn)) {
-
 
195
			$urlEflore = sprintf($this->config['settings']['efloreUrlTpl'], $nn, 'illustration');
-
 
196
		}
197
			list($coord_y, $coord_x) = explode('-', $coord);
197
		return $urlEflore;
198
		}
198
	}
-
 
199
	
199
		
200
	private function traiterLieu($donnee) {
200
		// Récupération du filtre where pour les mots clés "projet"
201
		$lieu = array();
201
		if (isset($projet)) {
202
		if (!$this->etreNull($donnee->lieudit)) {
202
			$projet_sql = $this->getSqlWhereProjet($projet);
-
 
203
		}
203
			$lieu[] = $donnee->lieudit;
204
 
204
		}
-
 
205
		if (!$this->etreNull($donnee->milieu)) {
205
		$requete = 	'SELECT COUNT(id) AS nbre '.
206
			$lieu[] = $donnee->milieu;
-
 
207
		}
-
 
208
		return implode(', ', $lieu);
206
					'FROM cel_inventory AS i '.
209
	}
207
					'	LEFT JOIN locations AS l '.
210
	
208
					'		ON (l.name = i.location AND l.code = i.id_location) '.
211
	private function chargerImages(Array $obs_ids) {
209
					"WHERE transmission = '1' ".
212
		// Récupération des données au format Json
210
					(($type == 'UTM') ? "	AND (sector = |$secteur| AND x_utm = |$x_utm| AND y_utm = |$y_utm| ) " : '').
213
		$service = 'CelImage/liste-ids?obsId='.implode(',', $obs_ids);
211
					(($type == 'LngLat') ? "	AND (coord_x = |$coord_x| AND coord_y = |$coord_y| ) " : '').
214
		$url = sprintf($this->config['settings']['baseURLServicesCelTpl'], $service);
212
					(isset($utilisateur) ? " AND identifiant = |$utilisateur| " : '').
-
 
213
                    (isset($num_taxon) ? " AND num_taxon = |$num_taxon| " : '' ).
215
		$json = $this->getRestClient()->consulter($url);
-
 
216
		$donnees = json_decode($json);
214
                    ((isset($projet) && $projet_sql != '') ? " AND ($projet_sql) " : '' );
217
			
215
		
218
		// Post-traitement des données
-
 
219
		$images = $this->traiterImages($donnees);
-
 
220
		
-
 
221
		return $images;
-
 
222
	}
-
 
223
	
-
 
224
	private function traiterImages($donnees) {
-
 
225
		$images = array();
-
 
226
		if (count($donnees) > 0) {
-
 
227
			foreach ($donnees as $id_obs => $id_images) {
-
 
228
				foreach ($id_images as $id_img) {
-
 
229
					$urls['idImg'] = $id_img;
-
 
230
					$urls['guid'] = sprintf($this->config['settings']['guidImgTpl'], $id_img);
-
 
231
					$urls['miniature'] = $this->getUrlImage($id_img, 'CXS');
-
 
232
					$urls['normale'] = $this->getUrlImage($id_img, 'XL');
-
 
233
					$images[$id_obs][] = $urls;
-
 
234
				} 
-
 
235
			}
-
 
236
		}
-
 
237
		return $images;
-
 
238
	}
-
 
239
	
-
 
240
	private function ajouterImagesAuxObs($observations) {
-
 
241
		$images = $this->chargerImages(array_keys($observations['observations']));
-
 
242
		foreach ($observations['observations'] as $id => $infos) {
-
 
243
			$infos['images'] = $images[$id];
-
 
244
			$observations['observations'][$id] = $infos;
-
 
245
		}
-
 
246
		return $observations;
-
 
247
	}
-
 
248
	
-
 
249
	private function ajouterAuteursAuxObs($observations) {
-
 
250
		$observateurs = $this->creerAuteurs(array_keys($observations['observateurs']));
-
 
251
		unset($observations['observateurs']);
-
 
252
		foreach ($observations['observations'] as $id => $infos) {
-
 
253
			$courriel = $infos['observateur'];
-
 
254
			$infos['observateur'] = $observateurs[$courriel];
-
 
255
			$observations['observations'][$id] = $infos;
-
 
256
		}
-
 
257
		return $observations;
-
 
258
	}
-
 
259
	
-
 
260
	private function supprimerIdDesObs($observations) {
-
 
261
		// Le tableau de sortie ne doit pas avoir les id des obs en clé car sinon Jquery Template ne fonctionne pas
-
 
262
		$observationSansId = $observations;
-
 
263
		unset($observationSansId['observations']);
-
 
264
		foreach ($observations['observations'] as $id => $infos) {
216
		$nbre = $this->requeter($requete, Cel::SQL_RETOUR_COLONNE);
265
			$observationSansId['observations'][] = $infos;
217
		
266
		}
218
		return $nbre;
267
		return $observationSansId;
219
	}
268
	}
220
	
269
	
221
	/**
270
	/**
222
	 * Liste des taxons présents sur la carte
271
	 * Liste des taxons présents sur la carte
223
	 */
272
	 */
224
	public function getTaxons($params) {
273
	public function getTaxons($params) {
225
		$json = null;
274
		$json = null;
226
		extract($this->parametres);
-
 
227
		$dept = $this->traiterValeursMultiples($dept);
-
 
228
		// Récupération du filtre where pour les mots clés "projet"
-
 
229
		if (isset($projet)) {
-
 
230
			$projet_sql = $this->getSqlWhereProjet($projet);
-
 
231
		}
-
 
232
 
275
		
233
		$requete = 	'SELECT DISTINCT nom_sel, num_nom_sel, nom_ret, num_nom_ret, num_taxon, famille '.
276
		$requete = 	'SELECT SQL_CALC_FOUND_ROWS DISTINCT nom_ret, num_nom_ret, num_taxon, famille '.
234
					'FROM cel_inventory AS i '.
277
					'FROM cel_inventory AS i '.
235
					'	LEFT JOIN locations AS l '.
278
					'	LEFT JOIN locations AS l '.
236
					"		ON (l.name = i.location AND l.code = i.id_location) ".
279
					'		ON (l.name = i.location AND l.code = i.id_location) '.
237
					"WHERE transmission = '1' ".
280
					"WHERE transmission = '1' ".
-
 
281
					"	AND nom_ret != '' ".
-
 
282
					$this->construireWhereDept().
-
 
283
                    $this->construireWhereCommune().
238
					(!$this->etreNull($utilisateur) ? " AND identifiant = '$utilisateur' " : '').
284
                    $this->construireWhereUtilisateur().
239
					(!$this->etreNull($num_taxon) ? " AND num_taxon = '$num_taxon' " : '' ).
285
					$this->construireWhereNumTaxon().
240
					(!$this->etreNull($dept) ? " AND l.code IN ($dept) " : '').
286
					$this->construireWhereNomTaxon().
241
					(!$this->etreNull($commune) ? " AND location LIKE |$commune| " : '' ).
287
					$this->construireWhereDate().
242
                    ((!$this->etreNull($projet) && $projet_sql != '') ? " AND ($projet_sql) " : '' ).
288
					$this->construireWhereProjet().
-
 
289
					$this->construireWhereTag();
243
                    'ORDER BY nom_ret ASC ';
290
					'ORDER BY nom_ret ASC '.
-
 
291
                    "LIMIT {$this->start},{$this->limit} ";
244
		$this->debug[] = $requete;
292
		//$this->debug[] = $requete;
-
 
293
		$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
245
 
294
		
-
 
295
		$requete = 'SELECT FOUND_ROWS()';
246
		$resultats = $this->executerRequete($requete);
296
		$taxons['total'] = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
247
		
297
		
248
		// Post-traitement
-
 
249
		if (is_array($resultats)) {
298
		// Post-traitement
250
			$resultats = $this->nettoyerTableau($resultats);
-
 
-
 
299
		$taxons['taxons'] = $this->traiterTaxons($resultats);
-
 
300
		
-
 
301
		return $taxons;
-
 
302
	}
-
 
303
	
-
 
304
	private function traiterTaxons($donnees) {
-
 
305
		$taxons = array();
-
 
306
		if (is_array($donnees) && count($donnees) > 0) {
-
 
307
			foreach ($donnees as $donnee) {
-
 
308
				if (!isset($taxons[$donnee->num_taxon]) && ! $this->etreNull($donnee->nom_ret)) {
-
 
309
					$taxon = array();
-
 
310
					$taxon['nn'] = $donnee->num_nom_ret;
-
 
311
					$taxon['nt'] = $donnee->num_taxon;
-
 
312
					$taxon['nom'] = $this->nettoyerTexte($donnee->nom_ret);
-
 
313
					$taxon['famille'] = $this->nettoyerTexte($donnee->famille);
-
 
314
					$taxons[$donnee->num_taxon] = $taxon;
-
 
315
				}
-
 
316
			}
-
 
317
		}
-
 
318
		$taxons = array_values($taxons);
-
 
319
		return $taxons;
-
 
320
	}
-
 
321
	
-
 
322
	private function construireWhereCoordonnees() {
-
 
323
		$sql = '';
-
 
324
		// Récupération des coordonnées depuis l'id station
-
 
325
		extract($this->decomposerStationId());
-
 
326
		if (isset($type)) {
-
 
327
			if ($type == 'UTM') {
-
 
328
				$secteur = $this->proteger($secteur);
-
 
329
				$x_utm = $this->proteger($x_utm);
-
 
330
				$y_utm = $this->proteger($y_utm);
-
 
331
				
-
 
332
				$sql = " AND (sector = $secteur AND x_utm = $x_utm AND y_utm = $y_utm ) ";
-
 
333
			}  else if ($type == 'LngLat') {
-
 
334
				$coord_x = $this->proteger($coord_x);
-
 
335
				$coord_y = $this->proteger($coord_y);
-
 
336
				
-
 
337
				$sql = " AND (coord_x = $coord_x AND coord_y = $coord_y ) ";
-
 
338
			}
-
 
339
		}		
-
 
340
		return $sql;
-
 
341
	}
-
 
342
	
-
 
343
	private function construireWhereNomTaxon() {
-
 
344
		$sql = '';
-
 
345
		// Récupération des coordonnées depuis l'id station
-
 
346
		extract($this->parametres);
-
 
347
		if (!$this->etreNull($taxon)) {
-
 
348
			if (strpos($taxon, ':')) {
-
 
349
				list($type, $nom) = explode(':', $taxon);
-
 
350
			} else {
-
 
351
				$type = 'nr';
-
 
352
				$nom = $taxon;
-
 
353
			}
-
 
354
			
-
 
355
			$nom = $this->proteger($nom.'%');
-
 
356
			switch ($type) {
-
 
357
				case '*' :
-
 
358
					$sql = " AND (nom_ret LIKE $nom OR nom_sel LIKE $nom OR famille LIKE $nom) ";
-
 
359
					break;
-
 
360
				case 'nr' :
-
 
361
					$sql = " AND nom_ret LIKE $nom ";
-
 
362
					break;
-
 
363
				case 'ns' :
-
 
364
					$sql = " AND nom_sel LIKE $nom ";
-
 
365
					break;
-
 
366
				case 'f' :
-
 
367
					$sql = " AND famille LIKE $nom ";
-
 
368
					break;
-
 
369
				default:
-
 
370
					$sql = " AND nom_ret LIKE $nom ";
-
 
371
			}			
-
 
372
		}
-
 
373
		return $sql;
-
 
374
	}
-
 
375
	
-
 
376
	private function construireWhereDate() {
-
 
377
		$sql = '';
-
 
378
		// Récupération des coordonnées depuis l'id station
-
 
379
		extract($this->parametres);
-
 
380
		if (!$this->etreNull($date)) {
-
 
381
			if (strpos($date, ':')) {
-
 
382
				list($type, $date) = explode(':', $date);
-
 
383
			} else {
-
 
384
				$type = 'observation';
-
 
385
			}
-
 
386
			
-
 
387
			$date = $this->proteger($date.'%');
-
 
388
			switch ($type) {
-
 
389
				case '*' :
-
 
390
					$sql = " AND (
-
 
391
						date_observation LIKE $date 
-
 
392
						OR date_creation LIKE $date 
-
 
393
						OR date_modification LIKE $date 
-
 
394
						OR date_transmission LIKE $date) ";
-
 
395
					break;
-
 
396
				case 'observation' :
-
 
397
					$sql = " AND date_observation LIKE $date ";
-
 
398
					break;
-
 
399
				case 'creation' :
-
 
400
					$sql = " AND date_creation LIKE $date ";
-
 
401
					break;
-
 
402
				case 'modification' :
-
 
403
					$sql = " AND date_modification LIKE $date ";
-
 
404
					break;
-
 
405
				case 'transmission' :
-
 
406
					$sql = " AND date_transmission LIKE $date ";
-
 
407
					break;
-
 
408
				case 'liaison' :
-
 
409
					$sql = '';
-
 
410
					break;
-
 
411
				case 'photo' :
-
 
412
					$sql = '';
-
 
413
					break;
-
 
414
				default:
-
 
415
					$sql = " AND date_observation LIKE $date ";
-
 
416
			}
-
 
417
		}
-
 
418
		return $sql;
-
 
419
	}
-
 
420
	
-
 
421
	private function construireWhereDept() {
-
 
422
		$sql = '';
-
 
423
		// Récupération des coordonnées depuis l'id station
-
 
424
		extract($this->parametres);
-
 
425
		if (!$this->etreNull($dept)) {
-
 
426
			$dept = $this->traiterValeursMultiples($dept);
-
 
427
			$sql = " AND code IN ($dept) ";
-
 
428
		}
-
 
429
		return $sql;
-
 
430
	}
-
 
431
	
-
 
432
	private function construireWhereCommune() {
-
 
433
		$sql = '';
-
 
434
		// Récupération des coordonnées depuis l'id station
-
 
435
		extract($this->parametres);
-
 
436
		if (!$this->etreNull($commune)) {
-
 
437
			$commune = $this->proteger($commune);
-
 
438
			$sql = " AND location LIKE $commune ";
-
 
439
		}
-
 
440
		return $sql;
-
 
441
	}
-
 
442
	
-
 
443
	
-
 
444
	private function construireWhereUtilisateur() {
-
 
445
		$sql = '';
-
 
446
		// Récupération des coordonnées depuis l'id station
-
 
447
		extract($this->parametres);
-
 
448
		if (!$this->etreNull($utilisateur)) {
-
 
449
			$utilisateur = $this->proteger($utilisateur);
251
		}
450
			$sql = " AND identifiant = $utilisateur ";
-
 
451
		}
-
 
452
		return $sql;
-
 
453
	}
-
 
454
	
-
 
455
	private function construireWhereNumTaxon() {
-
 
456
		$sql = '';
-
 
457
		// Récupération des coordonnées depuis l'id station
-
 
458
		extract($this->parametres);
-
 
459
		if (!$this->etreNull($num_taxon)) {
-
 
460
			$num_taxon = $this->proteger($num_taxon);
-
 
461
			$sql = " AND num_taxon = $num_taxon ";
-
 
462
		}
-
 
463
		return $sql;
-
 
464
	}
-
 
465
	
-
 
466
	private function construireWhereProjet() {
-
 
467
		$sql = '';
-
 
468
		// Récupération des coordonnées depuis l'id station
-
 
469
		extract($this->parametres);
-
 
470
		$projet_sql = $this->getSqlWhereProjet($projet);
-
 
471
		if (!$this->etreNull($projet_sql)) {
-
 
472
			$sql = " AND ($projet_sql) ";
252
		
473
		}
253
		return $resultats;
474
		return $sql;
254
	}
475
	}
255
	
476
	
256
	/**
477
	/**
257
	 * Traitement de $projet pour construction du filtre dans la requête
478
	 * Traitement de $projet pour construction du filtre dans la requête
258
	 */
479
	 */
259
	private function getSqlWhereProjet($projet) {
480
	private function getSqlWhereProjet($projet) {
-
 
481
		$sql = null;
-
 
482
		if (! $this->etreNull($projet)) {
260
		$mot_cle_encode = $this->bdd->quote($this->encoderMotCle($projet));
483
			$mot_cle_encode = $this->bdd->quote($this->encoderMotCle($projet));
-
 
484
			
-
 
485
			// Construction de la requête
-
 
486
			$requete = 	'SELECT * '.
-
 
487
						'FROM cel_mots_cles_obs '.
-
 
488
						"WHERE cmc_id_mot_cle_general = $mot_cle_encode ";
-
 
489
			$elements_projet = $this->executerRequete($requete);
-
 
490
			
-
 
491
			$requete_projet = array();
-
 
492
			if ($elements_projet != false && count($elements_projet) > 0) {
-
 
493
				// Pré-construction du where de la requête
-
 
494
				$tpl_where = '(mots_cles LIKE "%%%s%%" AND identifiant = %s )';
-
 
495
				
-
 
496
				foreach ($elements_projet as $occurence) {
-
 
497
					$requete_projet[] = sprintf($tpl_where, $occurence['cmc_id_mot_cle_utilisateur'], $this->bdd->quote($occurence['cmc_id_proprietaire']));
-
 
498
				}
-
 
499
			} else {
-
 
500
				$this->messages[] = "Aucune observation ne correspond à ce mot clé.";
-
 
501
			}
-
 
502
			if (count($requete_projet) > 0) {
-
 
503
				$sql = implode(" \nOR ", $requete_projet);
-
 
504
			}
-
 
505
		}
-
 
506
		return $sql;
-
 
507
	}
-
 
508
	
-
 
509
	private function construireWhereTag() {
-
 
510
		$sql = '';
-
 
511
		// Récupération des coordonnées depuis l'id station
-
 
512
		extract($this->parametres);
-
 
513
		$tag_sql = $this->getSqlWhereObsAvecImagesTaguees($tag);
-
 
514
		if (!$this->etreNull($tag_sql)) {
-
 
515
			$sql = " AND ($tag_sql) ";
-
 
516
		}
-
 
517
		return $sql;
-
 
518
	}
-
 
519
	
-
 
520
	/**
-
 
521
	 * Traitement de $tag pour construction du filtre dans la requête
-
 
522
	 */
-
 
523
	private function getSqlWhereObsAvecImagesTaguees($tag) {
-
 
524
		$sql = null;
-
 
525
		if (! $this->etreNull($tag)) {
-
 
526
			$tag_sql = $this->getSqlWhereMotsCles($tag);
-
 
527
			// Construction de la requête
-
 
528
			$requete = 	'SELECT DISTINCT coi_ce_observation AS ordre,  coi_ce_utilisateur AS utilisateur '.
-
 
529
						'FROM cel_images '.
-
 
530
						'	LEFT JOIN cel_obs_images '.
-
 
531
						'		ON (ci_id_image = coi_ce_image) '.
-
 
532
						'	LEFT JOIN cel_inventory AS i '.
-
 
533
						'		ON (coi_ce_utilisateur = i.identifiant AND coi_ce_observation = i.ordre) '.
-
 
534
						'	LEFT JOIN locations AS l '.
-
 
535
						"		ON (l.name = i.location AND l.code = i.id_location) ".
-
 
536
						"WHERE  transmission = '1' ".
-
 
537
						$this->construireWhereCoordonnees().
-
 
538
						$this->construireWhereUtilisateur().
-
 
539
						$this->construireWhereNumTaxon().
-
 
540
						$this->construireWhereNomTaxon().
-
 
541
						$this->construireWhereProjet().
-
 
542
						(!$this->etreNull($tag_sql) ? "AND ($tag_sql) " : '').
-
 
543
						'ORDER BY utilisateur ASC, ordre ASC';
-
 
544
			//$this->debug[] = $requete;
-
 
545
			//die($requete);
-
 
546
			$elements_tag = $this->executerRequete($requete);
-
 
547
			
-
 
548
			$requete_tag = array();
-
 
549
			if ($elements_tag != false && count($elements_tag) > 0) {
-
 
550
				
-
 
551
				$filtres = array();
-
 
552
				foreach ($elements_tag as $occurence) {
-
 
553
					$utilisateur = $occurence['utilisateur'];
-
 
554
					$ordre = $occurence['ordre'];
-
 
555
					if (!array_key_exists($utilisateur, $filtres)) {
-
 
556
						$filtres[$utilisateur] = array();
-
 
557
					}
-
 
558
					if (!array_key_exists($ordre, $filtres[$utilisateur])) {
-
 
559
						$filtres[$utilisateur][$ordre] = $ordre;
-
 
560
					}
-
 
561
				}
-
 
562
				
-
 
563
				// Pré-construction du where de la requête
-
 
564
				$tpl_where = "(identifiant = '%s' AND ordre IN (%s))";
-
 
565
				foreach ($filtres as $utilisateur => $ordres) {
-
 
566
					$requete_tag[] = sprintf($tpl_where, $utilisateur, implode(',', $ordres));
-
 
567
				}
-
 
568
				
-
 
569
			} else {
-
 
570
				$this->messages[] = "Aucune observation ne possède d'images avec ce mot-clé.";
-
 
571
			}
-
 
572
			if (count($requete_tag) > 0) {
-
 
573
				$sql = implode(" \nOR ", $requete_tag);
-
 
574
			}
-
 
575
		}
-
 
576
		return $sql;
-
 
577
	}
-
 
578
	
-
 
579
	/**
-
 
580
	 * Traitement de $tag pour construction du filtre dans la requête
-
 
581
	 */
-
 
582
	private function getSqlWhereMotsCles($tag) {
-
 
583
		$sql = null;
-
 
584
		$mots_cles = $this->decomposerTag($tag);
261
		
585
		
-
 
586
		// Construction de la requête
262
		// Construction de la requête
587
		$requete = 	'SELECT cmc_id_proprietaire AS utilisateur, cmc_id_mot_cle_general AS mot_cle_general, '.
263
		$requete = 	'SELECT * '.
588
					'	cmc_id_mot_cle_utilisateur AS mot_cle_utilisateur '.
264
					'FROM cel_mots_cles_obs '.
589
					'FROM cel_mots_cles_images '.
265
					"WHERE cmc_id_mot_cle_general = $mot_cle_encode ";
590
					'WHERE '.$this->getSqlWhereMotsClesImages($mots_cles['motsClesEncodesProteges']);
-
 
591
		$elements_projet = $this->executerRequete($requete);
266
		$elements_projet = $this->executerRequete($requete);
592
		//$this->debug[] = $requete;
267
		
593
		
268
		$requete_projet = array();
594
		$requete_projet = array();
269
		if ($elements_projet != false && count($elements_projet) > 0) {
595
		if ($elements_projet != false && count($elements_projet) > 0) {
270
			// Pré-construction du where de la requête
596
			// Pré-construction du where de la requête
-
 
597
			if ($mots_cles['type'] == 'OR') {
271
			$tpl_where = '(mots_cles LIKE "%%%s%%" AND identifiant = %s )';
598
				$tpl_where = '(ci_meta_mots_cles LIKE "%%%s,%%" AND ci_ce_utilisateur  = %s )';
-
 
599
				foreach ($elements_projet as $occurence) {
-
 
600
					$requete_projet[] = sprintf($tpl_where, $occurence['mot_cle_utilisateur'], $this->bdd->quote($occurence['utilisateur']));
-
 
601
				}
-
 
602
			} else {
-
 
603
				$tpl_where_mc = "ci_meta_mots_cles LIKE '%%%s,%%'";
-
 
604
				$tpl_where = '((%s) AND ci_ce_utilisateur  = %s)';
-
 
605
				$utilisateur_mc = array();
-
 
606
				foreach ($elements_projet as $occurence) {
-
 
607
					if (!isset($utilisateur_mc[$occurence['utilisateur']][$occurence['mot_cle_general']])) {
-
 
608
						$utilisateur_mc[$occurence['utilisateur']][$occurence['mot_cle_general']] = $occurence['mot_cle_utilisateur'];
-
 
609
					}	
-
 
610
				}
272
			
611
				
-
 
612
				foreach ($utilisateur_mc as $utilisateur => $mots_cles_utilisateur) {
-
 
613
					if (count($mots_cles_utilisateur) == count($mots_cles['motsCles'])) {
-
 
614
						$where_mots_cles_utilisateur = array();
273
			foreach ($elements_projet as $occurence) {
615
						foreach ($mots_cles_utilisateur as $mot_cle) {
-
 
616
							$where_mots_cles_utilisateur[] = sprintf($tpl_where_mc, $mot_cle);
-
 
617
						}
-
 
618
						$where_mots_cles_utilisateur = implode(' AND ', $where_mots_cles_utilisateur);
-
 
619
						$utilisateur = $this->bdd->quote($utilisateur);
274
				$requete_projet[] = sprintf($tpl_where, $occurence['cmc_id_mot_cle_utilisateur'], $this->bdd->quote($occurence['cmc_id_proprietaire']));
620
						$requete_projet[] = sprintf($tpl_where, $where_mots_cles_utilisateur, $utilisateur);
-
 
621
					}
-
 
622
				}
275
			}
623
			}
276
		} else {
624
		} else {
277
			$this->messages[] = "Aucune observation ne correspond à ce mot clé.";
625
			$this->messages[] = "Aucune observation ne correspond à ce mot clé.";
278
		}
626
		}
279
		
627
		
280
		$sql = implode(" \nOR ", $requete_projet);
628
		$sql = implode(" \nOR ", $requete_projet);
-
 
629
		//$this->debug[] = $sql;
281
		return $sql;
630
		return $sql;
282
	}
631
	}
-
 
632
	
-
 
633
	/**
-
 
634
	 * Traitement de $tag pour construction du filtre dans la requête
-
 
635
	 */
-
 
636
	private function getSqlWhereMotsClesImages($mots_cles_encodes) {
-
 
637
		$where_mots_cles_images = array();
-
 
638
		foreach ($mots_cles_encodes as $mot_cle_encode) {
-
 
639
			$where_mots_cles_images[] = "cmc_id_mot_cle_general = $mot_cle_encode";
-
 
640
		}
-
 
641
		$where_mots_cles_images = implode(' OR ', $where_mots_cles_images);
-
 
642
		return $where_mots_cles_images;
-
 
643
	}
-
 
644
	
-
 
645
	private function decomposerTag($tags) {
-
 
646
		$mots_cles = array('type' => null, 'motsCles' => null, 'motsClesEncodesProteges' => null);
-
 
647
		if (preg_match('/.+OU.+/', $tags)) {
-
 
648
			$mots_cles['type'] = 'OR';
-
 
649
			$mots_cles['motsCles'] = explode('OU', $tags);
-
 
650
		} else if (preg_match('/.+ET.+/', $tags)) {
-
 
651
			$mots_cles['type'] = 'AND';
-
 
652
			$mots_cles['motsCles'] = explode('ET', $tags);
-
 
653
		} else {
-
 
654
			$mots_cles['motsCles'][] = $tags;
-
 
655
		}
-
 
656
		
-
 
657
		foreach ($mots_cles['motsCles'] as $mot) {
-
 
658
			$mots_cles['motsClesEncodesProteges'][] = $this->bdd->quote($this->encoderMotCle($mot));
-
 
659
		}
-
 
660
		$this->debug[] = $mots_cles;
-
 
661
		return $mots_cles;
-
 
662
	}
-
 
663
	
-
 
664
	private function decomposerStationId() {
-
 
665
		$station_infos = array();
-
 
666
		if (isset($this->parametres['station'])) {
-
 
667
			$station = $this->parametres['station'];
-
 
668
			$this->debug[] = $station;
-
 
669
			list($type, $coord) = explode(':', $station);
283
 
670
			
-
 
671
			if ($type == 'UTM') {
-
 
672
				list($x_utm, $y_utm, $secteur) = explode('-', $coord);
-
 
673
				$station_infos = array('x_utm' => $x_utm, 'y_utm' => $y_utm, 'secteur' => $secteur);
-
 
674
			} else if ($type == 'LngLat') {
-
 
675
				list($coord_y, $coord_x) = explode('-', $coord);
-
 
676
				$station_infos = array('coord_y' => $coord_y, 'coord_x' => $coord_x);
-
 
677
			}
-
 
678
			$station_infos['type'] = $type;
-
 
679
		}
-
 
680
		return $station_infos;
-
 
681
	}
284
}
682
}
285
683