Subversion Repositories eFlore/Applications.cel

Rev

Rev 840 | Rev 940 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 840 Rev 938
Line 44... Line 44...
44 
		}
 44 
		}
Line 45... Line 45...
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'] == 'jsonVar') {
49 
		} else if ($retour['type'] == 'json') {
 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 
		}
Line 56... Line 57...
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 
	 */
- 
 
 62 
	public function getStations($params) {
- 
 
 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 '.
61 
	public function getCarteDefautJson($params) {
 67 
                    '       ON (l.name = i.location AND l.code = i.id_location) '.
- 
 
 68 
                    "WHERE transmission = '1' ".
- 
 
 69 
					$this->construireWhereDept().
- 
 
 70 
                    $this->construireWhereCommune().
- 
 
 71 
                    $this->construireWhereUtilisateur().
- 
 
 72 
					$this->construireWhereNumTaxon().
62 
		$json = null;
 73 
					$this->construireWhereNomTaxon().
- 
 
 74 
					$this->construireWhereDate().
Line 63... Line -...
63 
		extract($this->parametres);
 - 
 
64 
		$dept = $this->traiterValeursMultiples($dept);
 - 
 
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 '.
 75 
					$this->construireWhereProjet().
Line 77... Line 76...
77 
                    "FROM $clause_from ".
 76 
					$this->construireWhereTag();
- 
 
 77
- 
 
 78 
		$resultats = $this->requeter($requete);
- 
 
 79
- 
 
 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;
78 
                    "WHERE $clause_where";
 88
- 
 
 89 
		$json['type'] = (isset($this->formatRetour)) ? $this->formatRetour : 'jsonVar';
- 
 
 90 
		$json['variable_js'] = 'stations';
- 
 
 91
- 
 
 92 
		return $json;
- 
 
 93 
	}
- 
 
 94
- 
 
 95 
	private function traiterNbreObs($resultats) {
- 
 
 96 
		$obs_nbre = 0;
- 
 
 97 
		if ($resultats !== false) {
- 
 
 98 
			$obs_nbre = count($resultats);
- 
 
 99 
		}
79 
		$resultats = $this->requeter($requete);
 100 
		return $obs_nbre;
80
101 
	}
81 
		// Traitement des résultats
 102
82 
		$mm = null;
 103 
	private function traiterStations($resultats) {
83 
		$stations = array();
 - 
 
84 
		if ($resultats !== false) {
 - 
 
85 
			foreach ($resultats as $enrg) {
 - 
 
86 
				if ($enrg['x_utm'] != null && $enrg['y_utm'] != 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();
 104 
		$stations = array();
91 
					$enrg['coord_y'] = $convertisseur->Long();
 105 
		if ($resultats !== false) {
- 
 
 106 
			foreach ($resultats as $enrg) {
- 
 
 107 
				if ($enrg['coord_x'] != null && $enrg['coord_y'] != null) {
- 
 
 108 
					$id = $enrg['coord_x'].'-'.$enrg['coord_y'];
- 
 
 109 
					if (!isset($stations[$id])) {
92 
					$enrg['id'] = 'UTM:'.$enrg['x_utm'].'-'.$enrg['y_utm'].'-'.$enrg['sector'];
 110 
						$enrg['id'] = 'UTM:'.$enrg['x_utm'].'-'.$enrg['y_utm'].'-'.$enrg['sector'];
93
111 
						unset($enrg['x_utm']);
94 
					$id = $enrg['coord_x'].'-'.$enrg['coord_y'];
 112 
						unset($enrg['y_utm']);
95 
					if (!isset($stations[$id])) {
 113 
						unset($enrg['sector']);
96 
						$stations[$id] = $enrg;
 114 
						$stations[$id] = $enrg;
97 
						$stations[$id]['nbre'] = 1;
 - 
 
98 
					} else {
 - 
 
99 
						$stations[$id]['nbre']++;
 - 
 
100 
					}
 - 
 
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'];
 115 
						$stations[$id]['nbre'] = 1;
111 
						$mm['max_x'] = ($mm['max_x'] < $enrg['coord_x']) ? $enrg['coord_x'] : $mm['max_x'];
 116 
					} else {
- 
 
 117 
						$stations[$id]['nbre']++;
112 
						$mm['max_y'] = ($mm['max_y'] < $enrg['coord_y']) ? $enrg['coord_y'] : $mm['max_y'];
 118 
					}
113 
					}
 - 
 
114 
				}
 - 
 
115 
			}
 - 
 
116 
		}
 - 
 
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);
 119 
				}
130 
		$json['donnees']['stats']['observations'] = $obs_nbre;
 120 
			}
Line 131... Line 121...
131 
		$json['donnees']['centre_x'] = $mm['min_x'].'-'.$mm['max_x'];
 121 
			$stations = array_values($stations);
132 
		$json['donnees']['centre_y'] = $mm['min_y'].'-'.$mm['max_y'];
 122 
		}
133 
		return $json;
 123 
		return $stations;
134 
	}
 124 
	}
- 
 
 125
135
126 
	/**
136 
	/**
 127 
	 * Données pour l'affichage des obs d'une station
- 
 
 128 
	 */
- 
 
 129 
	public function getObservations($params) {
- 
 
 130 
		$resultats = array();
- 
 
 131 
		$total = 0;
- 
 
 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, '.
137 
	 * Données pour l'affichage des obs d'une station
 135 
						'	sector, x_utm, y_utm, insee_code, date_transmission '.
138 
	 */
 - 
 
139 
	public function getObservations($params) {
 136 
						'FROM cel_inventory AS i '.
- 
 
 137 
						'	LEFT JOIN locations AS l '.
- 
 
 138 
						"		ON (l.name = i.location AND l.code = i.id_location) ".
140 
		$json = null;
 139 
						"WHERE transmission = '1' ".
141 
		extract($this->parametres);
 140 
						$this->construireWhereCoordonnees().
- 
 
 141 
						$this->construireWhereUtilisateur().
- 
 
 142 
						$this->construireWhereNumTaxon().
- 
 
 143 
						$this->construireWhereNomTaxon().
142 
		$dept = $this->traiterValeursMultiples($dept);
 144 
						$this->construireWhereDate().
143
145 
						$this->construireWhereProjet().
- 
 
 146 
						$this->construireWhereTag().
144 
		// Récupération des coordonnées depuis l'id station
 147 
	                    'ORDER BY nom_sel ASC '.
145 
		$this->debug[] = $station;
 148 
	                    "LIMIT {$this->start},{$this->limit} ";
146 
		list($type, $coord) = explode(':', $station);
 149 
			//die($requete);
Line 147... Line -...
147 
		if ($type == 'UTM') {
 - 
 
148 
			list($x_utm, $y_utm, $secteur) = explode('-', $coord);
 - 
 
149 
		} else if ($type == 'LngLat') {
 - 
 
150 
			list($coord_y, $coord_x) = explode('-', $coord);
 - 
 
151 
		}
 - 
 
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) " : '' ).
 150 
			$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
- 
 
 151
- 
 
 152 
			$requete = 'SELECT FOUND_ROWS()';
- 
 
 153 
			$total = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
- 
 
 154 
		}
- 
 
 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);
170 
                    'ORDER BY nom_sel ASC '.
 173 
				$observation['date'] = $this->formaterDate($donnee->date_observation, '%d/%m/%Y');
171 
                    "LIMIT {$this->start},{$this->limit} ";
 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);
- 
 
 178
- 
 
 179 
				if (isset($donnee->location)) {
- 
 
 180 
					$observations['commune'] = $this->nettoyerTexte($donnee->location);
- 
 
 181 
				}
172 
		$this->debug[] = $requete;
 182 
				$observations['observations'][$donnee->id] = $observation;
173 
		$resultats = $this->requeter($requete);
 - 
 
174
183
175 
		// Post-traitement
 184 
				if (! array_key_exists($donnee->identifiant, $observations['observateurs'])) {
Line 176... Line -...
176 
		if (is_array($resultats)) {
 - 
 
177 
			$resultats = $this->nettoyerTableau($resultats);
 - 
 
178 
		}
 - 
 
179
185 
					$observations['observateurs'][$donnee->identifiant] = $donnee->identifiant;
180 
		return $resultats;
 186 
				}
181 
	}
 187 
			}
182
- 
 
183 
	/**
 - 
 
184 
	 * Nombre d'obs d'une station
 - 
 
185 
	 */
 - 
 
186 
	public function getObservationsNombre($params) {
 188 
		}
187 
		$json = null;
 - 
 
188 
		extract($this->parametres);
 - 
 
189 
		$dept = $this->traiterValeursMultiples($dept);
 - 
 
190
- 
 
191 
		// Récupération des coordonnées depuis l'id station
 189 
		return $observations;
- 
 
 190 
	}
- 
 
 191
192 
		$this->debug[] = $station;
 192 
	private function getUrlEflore($nn) {
193 
		list($type, $coord) = explode(':', $station);
 193 
		$urlEflore = null;
- 
 
 194 
		if (! $this->etreNull($nn)) {
194 
		if ($type == 'UTM') {
 195 
			$urlEflore = sprintf($this->config['settings']['efloreUrlTpl'], $nn, 'illustration');
195 
			list($x_utm, $y_utm, $secteur) = explode('-', $coord);
 196 
		}
196 
		} else if ($type == 'LngLat') {
 197 
		return $urlEflore;
197 
			list($coord_y, $coord_x) = explode('-', $coord);
 - 
 
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();
- 
 
 202 
		if (!$this->etreNull($donnee->lieudit)) {
- 
 
 203 
			$lieu[] = $donnee->lieudit;
201 
		if (isset($projet)) {
 204 
		}
202 
			$projet_sql = $this->getSqlWhereProjet($projet);
 205 
		if (!$this->etreNull($donnee->milieu)) {
203 
		}
 206 
			$lieu[] = $donnee->milieu;
204 
 
 207 
		}
205 
		$requete = 	'SELECT COUNT(id) AS nbre '.
 208 
		return implode(', ', $lieu);
206 
					'FROM cel_inventory AS i '.
 209 
	}
207 
					'	LEFT JOIN locations AS l '.
 - 
 
208 
					'		ON (l.name = i.location AND l.code = i.id_location) '.
 210
- 
 
 211 
	private function chargerImages(Array $obs_ids) {
209 
					"WHERE transmission = '1' ".
 212 
		// Récupération des données au format Json
Line 210... Line 213...
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);
- 
 
 214 
		$url = sprintf($this->config['settings']['baseURLServicesCelTpl'], $service);
- 
 
 215 
		$json = $this->getRestClient()->consulter($url);
- 
 
 216 
		$donnees = json_decode($json);
- 
 
 217
- 
 
 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
211 
					(($type == 'LngLat') ? "	AND (coord_x = |$coord_x| AND coord_y = |$coord_y| ) " : '').
 260 
	private function supprimerIdDesObs($observations) {
Line 212... Line 261...
212 
					(isset($utilisateur) ? " AND identifiant = |$utilisateur| " : '').
 261 
		// Le tableau de sortie ne doit pas avoir les id des obs en clé car sinon Jquery Template ne fonctionne pas
213 
                    (isset($num_taxon) ? " AND num_taxon = |$num_taxon| " : '' ).
 262 
		$observationSansId = $observations;
214 
                    ((isset($projet) && $projet_sql != '') ? " AND ($projet_sql) " : '' );
 263 
		unset($observationSansId['observations']);
215
264 
		foreach ($observations['observations'] as $id => $infos) {
216 
		$nbre = $this->requeter($requete, Cel::SQL_RETOUR_COLONNE);
 265 
			$observationSansId['observations'][] = $infos;
217
- 
 
218 
		return $nbre;
 - 
 
219 
	}
 - 
 
220
- 
 
221 
	/**
 - 
 
222 
	 * Liste des taxons présents sur la carte
 - 
 
223 
	 */
 266 
		}
224 
	public function getTaxons($params) {
 267 
		return $observationSansId;
225 
		$json = null;
 268 
	}
226 
		extract($this->parametres);
 269
227 
		$dept = $this->traiterValeursMultiples($dept);
 270 
	/**
228 
		// Récupération du filtre where pour les mots clés "projet"
 271 
	 * Liste des taxons présents sur la carte
- 
 
 272 
	 */
- 
 
 273 
	public function getTaxons($params) {
- 
 
 274 
		$json = null;
229 
		if (isset($projet)) {
 275
230 
			$projet_sql = $this->getSqlWhereProjet($projet);
 276 
		$requete = 	'SELECT SQL_CALC_FOUND_ROWS DISTINCT nom_ret, num_nom_ret, num_taxon, famille '.
231 
		}
 277 
					'FROM cel_inventory AS i '.
232 
 
 278 
					'	LEFT JOIN locations AS l '.
233 
		$requete = 	'SELECT DISTINCT nom_sel, num_nom_sel, nom_ret, num_nom_ret, num_taxon, famille '.
 279 
					'		ON (l.name = i.location AND l.code = i.id_location) '.
- 
 
 280 
					"WHERE transmission = '1' ".
234 
					'FROM cel_inventory AS i '.
 281 
					"	AND nom_ret != '' ".
- 
 
 282 
					$this->construireWhereDept().
235 
					'	LEFT JOIN locations AS l '.
 283 
                    $this->construireWhereCommune().
- 
 
 284 
                    $this->construireWhereUtilisateur().
236 
					"		ON (l.name = i.location AND l.code = i.id_location) ".
 285 
					$this->construireWhereNumTaxon().
- 
 
 286 
					$this->construireWhereNomTaxon().
237 
					"WHERE transmission = '1' ".
 287 
					$this->construireWhereDate().
Line 238... Line 288...
238 
					(!$this->etreNull($utilisateur) ? " AND identifiant = '$utilisateur' " : '').
 288 
					$this->construireWhereProjet().
239 
					(!$this->etreNull($num_taxon) ? " AND num_taxon = '$num_taxon' " : '' ).
 - 
 
240 
					(!$this->etreNull($dept) ? " AND l.code IN ($dept) " : '').
 289 
					$this->construireWhereTag();
241 
					(!$this->etreNull($commune) ? " AND location LIKE |$commune| " : '' ).
 - 
 
Line -... Line 290...
- 
 
 290 
					'ORDER BY nom_ret ASC '.
- 
 
 291 
                    "LIMIT {$this->start},{$this->limit} ";
- 
 
 292 
		//$this->debug[] = $requete;
- 
 
 293 
		$resultats = $this->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET);
- 
 
 294
- 
 
 295 
		$requete = 'SELECT FOUND_ROWS()';
- 
 
 296 
		$taxons['total'] = (int) $this->requeter($requete, self::SQL_RETOUR_COLONNE);
- 
 
 297
- 
 
 298 
		// Post-traitement
- 
 
 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;
242 
                    ((!$this->etreNull($projet) && $projet_sql != '') ? " AND ($projet_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);
- 
 
 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;
243 
                    'ORDER BY nom_ret ASC ';
 464 
	}
Line 244... Line 465...
244 
		$this->debug[] = $requete;
 465
245 
 
 466 
	private function construireWhereProjet() {
246 
		$resultats = $this->executerRequete($requete);
 467 
		$sql = '';
247
468 
		// Récupération des coordonnées depuis l'id station
- 
 
 469 
		extract($this->parametres);
- 
 
 470 
		$projet_sql = $this->getSqlWhereProjet($projet);
248 
		// Post-traitement
 471 
		if (!$this->etreNull($projet_sql)) {
- 
 
 472 
			$sql = " AND ($projet_sql) ";
- 
 
 473 
		}
- 
 
 474 
		return $sql;
- 
 
 475 
	}
- 
 
 476
- 
 
 477 
	/**
- 
 
 478 
	 * Traitement de $projet pour construction du filtre dans la requête
- 
 
 479 
	 */
- 
 
 480 
	private function getSqlWhereProjet($projet) {
- 
 
 481 
		$sql = null;
- 
 
 482 
		if (! $this->etreNull($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) {
Line 249... Line 573...
249 
		if (is_array($resultats)) {
 573 
				$sql = implode(" \nOR ", $requete_tag);
- 
 
 574 
			}
250 
			$resultats = $this->nettoyerTableau($resultats);
 575 
		}
251 
		}
 576 
		return $sql;
252
577 
	}
253 
		return $resultats;
 578
- 
 
 579 
	/**
Line 254... Line 580...
254 
	}
 580 
	 * Traitement de $tag pour construction du filtre dans la requête
255
581 
	 */
256 
	/**
 582 
	private function getSqlWhereMotsCles($tag) {
- 
 
 583 
		$sql = null;
257 
	 * Traitement de $projet pour construction du filtre dans la requête
 584 
		$mots_cles = $this->decomposerTag($tag);
- 
 
 585
- 
 
 586 
		// Construction de la requête
- 
 
 587 
		$requete = 	'SELECT cmc_id_proprietaire AS utilisateur, cmc_id_mot_cle_general AS mot_cle_general, '.
- 
 
 588 
					'	cmc_id_mot_cle_utilisateur AS mot_cle_utilisateur '.
- 
 
 589 
					'FROM cel_mots_cles_images '.
- 
 
 590 
					'WHERE '.$this->getSqlWhereMotsClesImages($mots_cles['motsClesEncodesProteges']);
- 
 
 591 
		$elements_projet = $this->executerRequete($requete);
- 
 
 592 
		//$this->debug[] = $requete;
- 
 
 593
- 
 
 594 
		$requete_projet = array();
- 
 
 595 
		if ($elements_projet != false && count($elements_projet) > 0) {
- 
 
 596 
			// Pré-construction du where de la requête
258 
	 */
 597 
			if ($mots_cles['type'] == 'OR') {
- 
 
 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']));
259 
	private function getSqlWhereProjet($projet) {
 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();
260 
		$mot_cle_encode = $this->bdd->quote($this->encoderMotCle($projet));
 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'];
261
609 
					}
262 
		// Construction de la requête
 610 
				}
263 
		$requete = 	'SELECT * '.
 611
264 
					'FROM cel_mots_cles_obs '.
 612 
				foreach ($utilisateur_mc as $utilisateur => $mots_cles_utilisateur) {
Line 265... Line 613...
265 
					"WHERE cmc_id_mot_cle_general = $mot_cle_encode ";
 613 
					if (count($mots_cles_utilisateur) == count($mots_cles['motsCles'])) {
- 
 
 614 
						$where_mots_cles_utilisateur = array();
266 
		$elements_projet = $this->executerRequete($requete);
 615 
						foreach ($mots_cles_utilisateur as $mot_cle) {
267
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);
- 
 
 620 
						$requete_projet[] = sprintf($tpl_where, $where_mots_cles_utilisateur, $utilisateur);
- 
 
 621 
					}
- 
 
 622 
				}
- 
 
 623 
			}
- 
 
 624 
		} else {
- 
 
 625 
			$this->messages[] = "Aucune observation ne correspond à ce mot clé.";
- 
 
 626 
		}
- 
 
 627
- 
 
 628 
		$sql = implode(" \nOR ", $requete_projet);
- 
 
 629 
		//$this->debug[] = $sql;
- 
 
 630 
		return $sql;
- 
 
 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;
268 
		$requete_projet = array();
 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'])) {
269 
		if ($elements_projet != false && count($elements_projet) > 0) {
 667 
			$station = $this->parametres['station'];
270 
			// Pré-construction du where de la requête
 668 
			$this->debug[] = $station;