Subversion Repositories Sites.obs-saisons.fr

Rev

Rev 263 | Rev 270 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
207 aurelien 1
<?php
2
 
3
class OdsExport extends OdsTriple {
4
 
5
	const PREFIXE = 'get';
6
	const ABBR_LISTE_EVENEMENTS = 'evenement';
7
	const ABBR_LISTE_ESPECES = 'espece';
249 aurelien 8
	const ABBR_LISTE_MILIEUX = 'environnement';
9
 
246 aurelien 10
	private $type_mime = 'text/html';
11
 
207 aurelien 12
	/**
13
 	* Méthodes d'extractions d'informations
14
 	*/
15
 
16
	/**
17
     * Méthode appelée avec une requête de type GET.
18
     *
19
     */
20
    function getElement($param = array()) {
21
 
22
    	$type = $param[0];
23
 
24
        if ($type == '*' || is_numeric($type)) {
25
            $info = $this->getElementParDefaut($param);
26
        } else {
27
            $methode = self::PREFIXE.$type;
28
            if (method_exists($this, $methode)) {
29
                array_shift($param);
30
                $info = $this->$methode($param);
31
            } else {
32
                $this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
33
            }
34
        }
249 aurelien 35
 
36
	$this->envoyer($info,$this->type_mime);
207 aurelien 37
    }
249 aurelien 38
 
207 aurelien 39
	public function getExportObservation($start = null,$limit = null, $order_by = 'oo_date') {
227 aurelien 40
 
207 aurelien 41
		$requete_selection_observations = 'SELECT * FROM ods_observations '.
42
									' LEFT JOIN ods_individus '.
43
									' ON oi_id_individu = oo_ce_individu'.
44
									' LEFT JOIN ods_stations '.
263 gduche 45
									' ON oi_ce_station = os_id_station '.
46
									' LEFT JOIN ods_communes '.
47
									'ON os_ce_commune = oc_code_insee ';
207 aurelien 48
 
49
		$requete_selection_observations .= $this->construireConditionRequete();
50
		$requete_selection_observations .= ' ORDER BY oo_date DESC';
51
 
52
		$res_selection_observations = $this->executerRequete($requete_selection_observations);
53
 
54
		return $res_selection_observations;
55
	}
56
 
263 gduche 57
	private function creerFiltreIdZoneGeo($valeurMasque) {
58
		$masque = '';
59
		$dept = $valeurMasque;
60
		$dept = sprintf('%02s', $dept);
61
		$dept = sprintf("%-'_5s", $dept);
62
		$masque = " oc_code_insee LIKE ".$this->proteger($dept);
63
		return $masque;
64
	}
65
 
207 aurelien 66
	public function construireConditionRequete() {
67
 
235 aurelien 68
		$condition = ' WHERE oo_date != "0000-00-00" AND DAY(oo_date) != "00" AND ';
207 aurelien 69
 
70
		foreach($_GET as $cle => $valeur) {
71
 
72
			switch($cle) {
73
 
74
				case 'type_espece':
75
					$condition .= 'oi_ce_espece IN (SELECT oe_id_espece FROM ods_especes WHERE oe_ce_type = '.$this->proteger($valeur).')';
76
				break;
77
 
78
				case 'annee':
235 aurelien 79
					if($this->anneesMultiplesDemandees($valeur)) {
80
						$valeur = rtrim($valeur,',');
81
						$condition .= 'YEAR(oo_date) IN ('.$valeur.')';
82
					} else {
83
						$condition .= 'YEAR(oo_date) ';
84
						$condition .= ' = '.$this->proteger($valeur);
85
					}
207 aurelien 86
				break;
87
 
88
				case 'mois':
89
					$condition .= 'MONTH(oo_date) <= '.$this->proteger($valeur);
90
				break;
91
 
92
				case 'espece':
235 aurelien 93
					$condition .= 'oi_ce_espece IN ('.$valeur.') ';
207 aurelien 94
				break;
95
 
96
				case 'evenement':
97
					$condition .= 'oo_ce_evenement = '.$this->proteger($valeur);
98
				break;
99
 
100
				case 'utilisateur':
101
					$condition .= 'oo_ce_participant = '.$this->proteger($valeur);
102
				break;
103
 
264 gduche 104
				case 'departement' :
263 gduche 105
					$condition .= $this->creerFiltreIdZoneGeo($valeur);
106
				break;
264 gduche 107
 
108
				case 'region' :
109
					$requete_association_region .= 'SELECT * FROM ods_triples WHERE ot_ce_parent = 36 AND ot_valeur = '.$valeur;
110
					$listeAssociationRegions = $this->executerRequete($requete_association_region);
111
					$departements = array();
112
					foreach ($listeAssociationRegions as $associationRegion) {
113
						$departements[] = $this->creerFiltreIdZoneGeo($associationRegion['ot_cle']);
114
					}
115
					$condition .= ' ('. implode(' OR ', $departements).')';
116
				break;
207 aurelien 117
				default:
118
			}
119
 
120
			$condition .= ' AND ';
121
		}
122
 
123
		$condition = rtrim($condition,'AND ');
124
 
227 aurelien 125
		$id_demo = $this->config['appli']['id_participant_demo'];
126
		$id_admin = $this->config['appli']['id_participant_admin'];
127
 
128
		$condition .= ' AND oo_ce_participant != '.$id_demo;
129
		$condition .= ' AND oo_ce_participant != '.$id_admin;
130
 
207 aurelien 131
		return $condition;
132
	}
133
 
235 aurelien 134
	private function anneesMultiplesDemandees($annee) {
135
		// un ensemble d'identifiants est une suite d'identifiants séparés par des virgules
136
		// sans virgule terminale
137
		$reg_exp = "/^(([0-9])+,)*([0-9])+$/";
138
		return preg_match($reg_exp, $annee);
139
	}
140
 
210 aurelien 141
	public function getExportObservationPlat() {
142
 
143
		$donnees = $this->getExportObservation();
249 aurelien 144
		$donnees_formatees = $this->formaterPourExportCSV($donnees);
210 aurelien 145
 
146
		return $donnees_formatees ;
147
	}
148
 
207 aurelien 149
	public function getExportObservationJson() {
150
 
151
		$donnees = $this->getExportObservation();
249 aurelien 152
		$donnees_formatees = $this->formaterPourExportJson($donnees);
153
 
246 aurelien 154
		$this->type_mime = 'application/json';
155
 
207 aurelien 156
		return $donnees_formatees;
157
	}
158
 
249 aurelien 159
	public function formaterPourExportJson($tableau_observations_infos) {
207 aurelien 160
 
161
		$gestionnaire_especes = new OdsEspece($this->config);
162
		$gestionnaire_communes = new OdsCommune($this->config);
163
 
164
		$especes = $gestionnaire_especes->getToutesEspeces();
165
		$evenements = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_EVENEMENTS);
249 aurelien 166
		$milieux = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_MILIEUX);
207 aurelien 167
 
168
		$resultats_formates = array();
169
 
170
		foreach($tableau_observations_infos as $observations_infos) {
171
 
172
			$id_espece = $observations_infos['oi_ce_espece'];
173
			$nom_espece =  $especes[$id_espece]['nom_scientifique'];
174
 
175
			$id_evenement = $observations_infos['oo_ce_evenement'];
176
			$chaine_evenement = $evenements[$id_evenement]['ot_cle'];
177
 
178
			$infos_evenement = $this->renvoyerInformationStadeAPartirChaineTriple($chaine_evenement);
179
 
180
			$date_observation_formatee = date($this->config['appli']['format_date'], strtotime($observations_infos['oo_date']));
181
 
182
			$id_observation = $observations_infos['oo_id_observation'];
183
			$infos_formatees = array(
184
				'date' => $date_observation_formatee,
185
				'evenenement' => $infos_evenement['nom'],
186
				'code_bbch' => $infos_evenement['numero'],
187
				'nom_scientifique' => $nom_espece,
235 aurelien 188
				'id_espece' => $id_espece,
189
				'participant' => $observations_infos['os_ce_participant']
207 aurelien 190
			);
191
 
192
			$id_station = $observations_infos['oi_ce_station'];
193
 
194
			if(!isset($resultats_formates[$id_station])) {
195
				$resultats_formates[$id_station]['station'] = $observations_infos['os_nom'];
196
				$resultats_formates[$id_station]['code_commune'] = $observations_infos['os_ce_commune'];
197
				//$resultats_formates[$id_station]['nom_commune'] = $gestionnaire_communes->obtenirNomCommuneParCodeInsee($observations_infos['os_ce_commune']);
198
				$resultats_formates[$id_station]['latitude'] = $observations_infos['os_latitude'];
199
				$resultats_formates[$id_station]['longitude'] = $observations_infos['os_longitude'];
200
				$resultats_formates[$id_station]['altitude'] = $observations_infos['os_altitude'];
249 aurelien 201
				$resultats_formates[$id_station]['milieu'] = $milieux[$observations_infos['os_ce_environnement']]['ot_valeur'];
207 aurelien 202
				$resultats_formates[$id_station]['participant'] = $observations_infos['os_ce_participant'];
203
			}
204
 
205
			$resultats_formates[$id_station]['obs'][$id_observation] = $infos_formatees;
206
		}
207
 
208
		return $resultats_formates;
209
	}
210
 
210 aurelien 211
	public function getFichierExportObservationCsv() {
212
 
213
		$donnees = $this->getExportObservation();
249 aurelien 214
		$donnees_formatees = $this->formaterPourExportCSV($donnees);
210 aurelien 215
		$chaine_csv = $this->convertirTableauAssocVersCSV($donnees_formatees);
207 aurelien 216
 
210 aurelien 217
		$this->envoyerFichier($chaine_csv);
207 aurelien 218
	}
219
 
249 aurelien 220
	public function formaterPourExportCSV($tableau_observations_infos) {
207 aurelien 221
 
222
		$gestionnaire_especes = new OdsEspece($this->config);
223
		$gestionnaire_communes = new OdsCommune($this->config);
227 aurelien 224
		$gestionnaire_utilisateurs = new OdsUtilisateur($this->config);
207 aurelien 225
 
226
		$especes = $gestionnaire_especes->getToutesEspeces();
227
		$evenements = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_EVENEMENTS);
249 aurelien 228
		$milieux = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_MILIEUX);
207 aurelien 229
 
210 aurelien 230
		$codes_insee_communes = array();
231
 
207 aurelien 232
		$resultats_formates = array();
233
 
234
		foreach($tableau_observations_infos as $observations_infos) {
235
 
236
			$id_espece = $observations_infos['oi_ce_espece'];
237
			$nom_espece =  $especes[$id_espece]['nom_scientifique'];
238
 
239
			$id_evenement = $observations_infos['oo_ce_evenement'];
240
			$chaine_evenement = $evenements[$id_evenement]['ot_cle'];
241
 
242
			$infos_evenement = $this->renvoyerInformationStadeAPartirChaineTriple($chaine_evenement);
243
 
244
			$date_observation_formatee = date($this->config['appli']['format_date'], strtotime($observations_infos['oo_date']));
245
 
246
			$id_observation = $observations_infos['oo_id_observation'];
247
 
248
			$infos_formatees = array(
249
				'id_observation' => $id_observation,
250
				'date' => $date_observation_formatee,
251
				'evenenement' => $infos_evenement['nom'],
252
				'code_bbch' => $infos_evenement['numero'],
253
				'nom_scientifique' => $nom_espece,
254
				'station' => $observations_infos['os_nom'],
255
				'code_commune' => $observations_infos['os_ce_commune'],
210 aurelien 256
				'nom_commune' => '',
207 aurelien 257
				'latitude' => $observations_infos['os_latitude'],
258
				'longitude' => $observations_infos['os_longitude'],
259
				'altitude' => $observations_infos['os_altitude'],
249 aurelien 260
				'milieu' => $milieux[$observations_infos['os_ce_environnement']]['ot_valeur'],
227 aurelien 261
				'id_participant' => $observations_infos['os_ce_participant'],
262
				'pseudo_participant' => '',
263
				'mail_participant' => ''
207 aurelien 264
			);
265
 
266
			$resultats_formates[] = $infos_formatees;
210 aurelien 267
 
268
			if(is_numeric($observations_infos['os_ce_commune'])) {
269
				$codes_insee_communes[] = $observations_infos['os_ce_commune'];
270
			}
207 aurelien 271
		}
272
 
210 aurelien 273
		$correspondance_codes_insee_noms = $gestionnaire_communes->obtenirTableauNomsCommunesParTableauCodesInsee($codes_insee_communes);
227 aurelien 274
		$correspondance_id_utilisateur = $gestionnaire_utilisateurs->getListeUtilisateurFormateeId();
210 aurelien 275
 
276
		foreach($resultats_formates as &$resultat) {
277
 
227 aurelien 278
			if(isset($correspondance_codes_insee_noms[$resultat['code_commune']]) && trim($correspondance_codes_insee_noms[$resultat['code_commune']]) != '') {
210 aurelien 279
				$resultat['nom_commune'] = $correspondance_codes_insee_noms[$resultat['code_commune']];
280
			}
227 aurelien 281
 
282
			$resultat['pseudo_participant'] = $correspondance_id_utilisateur[$resultat['id_participant']]['name'];
283
			$resultat['mail_participant'] = $correspondance_id_utilisateur[$resultat['id_participant']]['mail'];
210 aurelien 284
		}
285
 
207 aurelien 286
		return $resultats_formates;
287
	}
288
 
289
	public function convertirTableauAssocVersCSV($tableau) {
290
 
291
		$csv = '';
292
		$colonnes = array_keys($tableau[0]);
293
		$csv .= implode(';',$colonnes).";\n";
294
 
295
		foreach($tableau as $elements) {
296
			$csv .= implode(';',$elements).";\n";
297
		}
298
 
299
		return $csv;
300
	}
301
 
302
	public function envoyerFichier($contenu) {
303
 
304
		$nom_fichier = "observations_export.csv";
305
		$chemin_fichier = $this->config['appli']['chemin_fichiers_temp'].'/'.$nom_fichier;
306
 
307
		file_put_contents($chemin_fichier, $contenu);
308
 
309
		$contenu = file_get_contents($chemin_fichier);
310
		$taille_fichier = filesize($chemin_fichier);
311
 
312
		unlink($chemin_fichier);
313
 
314
		ini_set('zlib.output_compression','Off');
315
 
316
		header('Pragma: public');
317
		header('Last-Modified: '.gmdate('D, d M Y H:i:s').' GMT');
318
		header('Cache-Control: must-revalidate, pre-check=0, post-check=0, max-age=0');
319
 
320
		header('Content-Tranfer-Encoding: none');
321
 
322
		header('Content-Type: application/octetstream; name="'.$nom_fichier.'"');
323
		header('Content-Disposition: attachement; filename="'.$nom_fichier.'"');
324
 
325
		header('Content-Length: '.$taille_fichier);
326
 
327
		echo $contenu;
328
		exit();
329
	}
330
 
331
	private function formaterInformationPourEnvoi($tableauinfos) {
332
 
333
	}
334
}
335
?>