Subversion Repositories Sites.obs-saisons.fr

Rev

Rev 281 | Rev 284 | 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
 
270 aurelien 36
		$this->envoyer($info,$this->type_mime);
207 aurelien 37
    }
281 aurelien 38
 
270 aurelien 39
    public function getExportStationJson() {
281 aurelien 40
 
270 aurelien 41
    	$donnees = $this->getExportStation();
42
    	$donnees_formatees = $this->formaterListeStationPourExportJson($donnees);
43
 
44
    	$this->type_mime = 'application/json';
45
 
46
    	return $donnees_formatees;
47
    }
48
 
49
    public function getExportStation($start = null,$limit = null, $order_by = 'oo_date') {
50
 
279 aurelien 51
    	$id_demo = $this->config['appli']['id_participant_demo'];
52
    	$requete_selection_stations = 'SELECT * FROM ods_stations WHERE os_ce_participant != '.$this->proteger($id_demo);
270 aurelien 53
    	$res_selection_stations = $this->executerRequete($requete_selection_stations);
54
 
55
    	return $res_selection_stations;
56
    }
57
 
281 aurelien 58
    public function getExportUtilisateurCsv() {
59
 
60
    	$controle = new ControleUtilisateur($this->config);
61
    	$controle->authentifierAdmin();
62
 
63
    	$gestionnaire_utilisateurs = new OdsUtilisateur($this->config);
64
    	$utilisateurs = $gestionnaire_utilisateurs->getListeUtilisateurAvecInfosComplementairesFormateeId();
65
 
66
    	$utilisateurs_formates = array();
67
    	$premiere_annee = 2006;
68
 
69
    	$nb_obs = $this->compterObservationsParUtilisateur();
282 aurelien 70
    	$annees = array();
281 aurelien 71
 
72
    	foreach ($utilisateurs as $id => $utilisateur) {
73
    		$utilisateur_formate = array(
74
	    		'id' => isset($utilisateur['uid']) ? $utilisateur['uid'] : '',
75
	    		'pseudo' => isset($utilisateur['name']) ? $utilisateur['name'] : '',
76
	    		'mail' => isset($utilisateur['mail']) ? $utilisateur['mail'] : '',
77
	    		'nom' => isset($utilisateur['profile_nom']) ? $utilisateur['profile_nom'] : '',
78
	    		'prenom' => isset($utilisateur['profile_prenom']) ? $utilisateur['profile_prenom'] : '',
79
	    		'code postal' => isset($utilisateur['profile_code_postal']) ? $utilisateur['profile_code_postal'] : '',
80
	    		'ville' => isset($utilisateur['profile_ville']) ? $utilisateur['profile_ville'] : '',
282 aurelien 81
	    		'type' => isset($utilisateur['profile_type']) ? $utilisateur['profile_type'] : '',
82
	    		'date inscription' => isset($utilisateur['created']) ? date('d/m/Y', $utilisateur['created']) : '',
281 aurelien 83
    		);
84
 
85
    		for($i = $premiere_annee; $i <= date('Y'); $i++) {
282 aurelien 86
    			$annees['annee '.$i] += isset($nb_obs[$utilisateur['uid']]) && isset($nb_obs[$utilisateur['uid']][$i]) ? $nb_obs[$utilisateur['uid']][$i] : '0';
281 aurelien 87
    			$utilisateur_formate['annee '.$i] = isset($nb_obs[$utilisateur['uid']]) && isset($nb_obs[$utilisateur['uid']][$i]) ? $nb_obs[$utilisateur['uid']][$i] : '0';
88
    		}
89
 
90
    		$utilisateurs_formates[] = $utilisateur_formate;
91
    	}
92
 
282 aurelien 93
    	$ligne_total_obs = array(
94
    		'id' => '',
95
    		'pseudo' => '',
96
    		'mail' => '',
97
    		'nom' => '',
98
    		'prenom' => '',
99
    		'code postal' => '',
100
    		'ville' => '',
101
    		'type' => '',
102
    		'date inscription' => ''
103
    	);
104
    	$ligne_total_obs = array_merge($ligne_total_obs, $annees);
105
    	$utilisateurs_formates[] = $ligne_total_obs;
281 aurelien 106
    	$csv = $this->convertirTableauAssocVersCSV($utilisateurs_formates);
107
    	$this->envoyerFichier($csv, 'utilisateurs');
108
    }
109
 
110
    private function compterObservationsParUtilisateur() {
111
    	$requete = 'SELECT COUNT(*) as nb_obs, oo_ce_participant as participant, YEAR(oo_date) as annee '.
112
    			   'FROM `ods_observations` WHERE oo_date != "0000-00-00" GROUP BY oo_ce_participant, YEAR(oo_date)';
113
 
114
    	$res_selection_obs = $this->executerRequete($requete);
115
    	$stats = array();
116
    	foreach ($res_selection_obs as $obs_nb) {
117
    		$stats[$obs_nb['participant']][$obs_nb['annee']] = $obs_nb['nb_obs'];
118
    	}
119
 
120
    	return $stats;
121
    }
122
 
270 aurelien 123
    public function formaterListeStationPourExportJson($tableau_stations_infos) {
124
 
125
    	$gestionnaire_especes = new OdsEspece($this->config);
126
    	$gestionnaire_communes = new OdsCommune($this->config);
127
    	$gestionnaire_utilisateurs = new OdsUtilisateur($this->config);
128
 
129
    	$especes = $gestionnaire_especes->getToutesEspeces();
130
    	$evenements = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_EVENEMENTS);
131
    	$milieux = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_MILIEUX);
132
    	$utilisateurs = $gestionnaire_utilisateurs->getListeUtilisateurAvecInfosComplementairesFormateeId();
133
    	$communes = $gestionnaire_communes->obtenirCommunesLieesAStationIndexeesCodeInsee();
134
 
135
    	$resultats_formates = array();
136
    	$stats = array('total' => count($tableau_stations_infos));
137
 
138
    	foreach($tableau_stations_infos as $stations_infos) {
139
    		$commune = isset($communes[$stations_infos['os_ce_commune']]['oc_nom']) ? $communes[$stations_infos['os_ce_commune']]['oc_nom'] : '';
140
 
141
    		$id_station = $stations_infos['os_id_station'];
142
    		$resultats_formates[$id_station]['nom'] = $stations_infos['os_nom'];
143
    		$resultats_formates[$id_station]['code_commune'] = is_numeric($stations_infos['os_ce_commune']) ? substr($stations_infos['os_ce_commune'], 0, 2) : '';
144
    		$resultats_formates[$id_station]['nom_commune'] = $commune;
145
    		$resultats_formates[$id_station]['latitude'] = $stations_infos['os_latitude'];
146
    		$resultats_formates[$id_station]['longitude'] = $stations_infos['os_longitude'];
147
    		$resultats_formates[$id_station]['altitude'] = $stations_infos['os_altitude'];
148
    		$resultats_formates[$id_station]['type_participant'] = 'Particulier';
149
 
150
    		if(isset($utilisateurs[$stations_infos['os_ce_participant']])) {
151
    			$participant = $utilisateurs[$stations_infos['os_ce_participant']];
152
    			$resultats_formates[$id_station]['participant']['id'] = $participant['uid'];
153
    			$resultats_formates[$id_station]['participant']['nom'] = $participant['name'];
154
    			$resultats_formates[$id_station]['type_participant'] = isset($participant['profile_type']) ? $participant['profile_type'] : 'Particulier';
155
    		} else {
156
    			$resultats_formates[$id_station]['participant']['id'] = null;
157
    			$resultats_formates[$id_station]['participant']['nom'] = 'Anonyme';
158
    			$resultats_formates[$id_station]['type_participant'] = 'Particulier';
159
    		}
160
    		if(isset($stats[$resultats_formates[$id_station]['type_participant']])) {
161
    			$stats[$resultats_formates[$id_station]['type_participant']]++;
162
    		} else {
163
    			$stats[$resultats_formates[$id_station]['type_participant']] = 1;
164
    		}
165
    	}
271 aurelien 166
    	$resultat = array('stats' => $stats, 'stations' => $resultats_formates);
270 aurelien 167
    	return $resultat;
168
    }
249 aurelien 169
 
207 aurelien 170
	public function getExportObservation($start = null,$limit = null, $order_by = 'oo_date') {
227 aurelien 171
 
207 aurelien 172
		$requete_selection_observations = 'SELECT * FROM ods_observations '.
173
									' LEFT JOIN ods_individus '.
174
									' ON oi_id_individu = oo_ce_individu'.
175
									' LEFT JOIN ods_stations '.
263 gduche 176
									' ON oi_ce_station = os_id_station '.
177
									' LEFT JOIN ods_communes '.
178
									'ON os_ce_commune = oc_code_insee ';
207 aurelien 179
 
180
		$requete_selection_observations .= $this->construireConditionRequete();
181
		$requete_selection_observations .= ' ORDER BY oo_date DESC';
182
 
183
		$res_selection_observations = $this->executerRequete($requete_selection_observations);
184
 
185
		return $res_selection_observations;
186
	}
187
 
270 aurelien 188
	private function creerFiltreIdZoneGeo($valeurMasque) {
189
		$masque = '';
190
		$dept = $valeurMasque;
191
		$dept = sprintf('%02s', $dept);
192
		$dept = sprintf("%-'_5s", $dept);
193
		$masque = " oc_code_insee LIKE ".$this->proteger($dept);
194
		return $masque;
263 gduche 195
	}
196
 
207 aurelien 197
	public function construireConditionRequete() {
198
 
235 aurelien 199
		$condition = ' WHERE oo_date != "0000-00-00" AND DAY(oo_date) != "00" AND ';
207 aurelien 200
 
201
		foreach($_GET as $cle => $valeur) {
202
 
203
			switch($cle) {
204
 
205
				case 'type_espece':
206
					$condition .= 'oi_ce_espece IN (SELECT oe_id_espece FROM ods_especes WHERE oe_ce_type = '.$this->proteger($valeur).')';
207
				break;
208
 
209
				case 'annee':
235 aurelien 210
					if($this->anneesMultiplesDemandees($valeur)) {
211
						$valeur = rtrim($valeur,',');
212
						$condition .= 'YEAR(oo_date) IN ('.$valeur.')';
213
					} else {
214
						$condition .= 'YEAR(oo_date) ';
215
						$condition .= ' = '.$this->proteger($valeur);
216
					}
207 aurelien 217
				break;
218
 
219
				case 'mois':
220
					$condition .= 'MONTH(oo_date) <= '.$this->proteger($valeur);
221
				break;
222
 
223
				case 'espece':
235 aurelien 224
					$condition .= 'oi_ce_espece IN ('.$valeur.') ';
207 aurelien 225
				break;
226
 
227
				case 'evenement':
228
					$condition .= 'oo_ce_evenement = '.$this->proteger($valeur);
229
				break;
230
 
231
				case 'utilisateur':
232
					$condition .= 'oo_ce_participant = '.$this->proteger($valeur);
233
				break;
234
 
264 gduche 235
				case 'departement' :
263 gduche 236
					$condition .= $this->creerFiltreIdZoneGeo($valeur);
237
				break;
264 gduche 238
 
239
				case 'region' :
240
					$requete_association_region .= 'SELECT * FROM ods_triples WHERE ot_ce_parent = 36 AND ot_valeur = '.$valeur;
241
					$listeAssociationRegions = $this->executerRequete($requete_association_region);
242
					$departements = array();
243
					foreach ($listeAssociationRegions as $associationRegion) {
244
						$departements[] = $this->creerFiltreIdZoneGeo($associationRegion['ot_cle']);
245
					}
246
					$condition .= ' ('. implode(' OR ', $departements).')';
247
				break;
207 aurelien 248
				default:
249
			}
250
 
251
			$condition .= ' AND ';
252
		}
253
 
254
		$condition = rtrim($condition,'AND ');
255
 
227 aurelien 256
		$id_demo = $this->config['appli']['id_participant_demo'];
257
		$id_admin = $this->config['appli']['id_participant_admin'];
258
 
259
		$condition .= ' AND oo_ce_participant != '.$id_demo;
260
		$condition .= ' AND oo_ce_participant != '.$id_admin;
261
 
207 aurelien 262
		return $condition;
263
	}
264
 
235 aurelien 265
	private function anneesMultiplesDemandees($annee) {
266
		// un ensemble d'identifiants est une suite d'identifiants séparés par des virgules
267
		// sans virgule terminale
268
		$reg_exp = "/^(([0-9])+,)*([0-9])+$/";
269
		return preg_match($reg_exp, $annee);
270
	}
271
 
210 aurelien 272
	public function getExportObservationPlat() {
273
 
274
		$donnees = $this->getExportObservation();
270 aurelien 275
		$donnees_formatees = $this->formaterListeObservationPourExportCSV($donnees);
210 aurelien 276
 
277
		return $donnees_formatees ;
278
	}
279
 
207 aurelien 280
	public function getExportObservationJson() {
281
 
282
		$donnees = $this->getExportObservation();
270 aurelien 283
		$donnees_formatees = $this->formaterListeObservationPourExportJson($donnees);
249 aurelien 284
 
246 aurelien 285
		$this->type_mime = 'application/json';
286
 
207 aurelien 287
		return $donnees_formatees;
288
	}
289
 
270 aurelien 290
	public function formaterListeObservationPourExportJson($tableau_observations_infos) {
207 aurelien 291
 
292
		$gestionnaire_especes = new OdsEspece($this->config);
293
		$gestionnaire_communes = new OdsCommune($this->config);
294
 
295
		$especes = $gestionnaire_especes->getToutesEspeces();
296
		$evenements = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_EVENEMENTS);
249 aurelien 297
		$milieux = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_MILIEUX);
207 aurelien 298
 
299
		$resultats_formates = array();
300
 
301
		foreach($tableau_observations_infos as $observations_infos) {
302
 
303
			$id_espece = $observations_infos['oi_ce_espece'];
278 aurelien 304
			if($id_espece == 0) {
305
				continue;
306
			}
207 aurelien 307
			$nom_espece =  $especes[$id_espece]['nom_scientifique'];
308
 
309
			$id_evenement = $observations_infos['oo_ce_evenement'];
310
			$chaine_evenement = $evenements[$id_evenement]['ot_cle'];
311
 
312
			$infos_evenement = $this->renvoyerInformationStadeAPartirChaineTriple($chaine_evenement);
313
 
314
			$date_observation_formatee = date($this->config['appli']['format_date'], strtotime($observations_infos['oo_date']));
315
 
316
			$id_observation = $observations_infos['oo_id_observation'];
317
			$infos_formatees = array(
318
				'date' => $date_observation_formatee,
319
				'evenenement' => $infos_evenement['nom'],
320
				'code_bbch' => $infos_evenement['numero'],
321
				'nom_scientifique' => $nom_espece,
235 aurelien 322
				'id_espece' => $id_espece,
323
				'participant' => $observations_infos['os_ce_participant']
207 aurelien 324
			);
325
 
326
			$id_station = $observations_infos['oi_ce_station'];
327
 
328
			if(!isset($resultats_formates[$id_station])) {
329
				$resultats_formates[$id_station]['station'] = $observations_infos['os_nom'];
330
				$resultats_formates[$id_station]['code_commune'] = $observations_infos['os_ce_commune'];
331
				//$resultats_formates[$id_station]['nom_commune'] = $gestionnaire_communes->obtenirNomCommuneParCodeInsee($observations_infos['os_ce_commune']);
332
				$resultats_formates[$id_station]['latitude'] = $observations_infos['os_latitude'];
333
				$resultats_formates[$id_station]['longitude'] = $observations_infos['os_longitude'];
334
				$resultats_formates[$id_station]['altitude'] = $observations_infos['os_altitude'];
278 aurelien 335
				if(isset($milieux[$observations_infos['os_ce_environnement']]['ot_valeur'])) {
336
					$resultats_formates[$id_station]['milieu'] = $milieux[$observations_infos['os_ce_environnement']]['ot_valeur'];
337
				} else {
338
					$resultats_formates[$id_station]['milieu'] = '';
339
				}
207 aurelien 340
				$resultats_formates[$id_station]['participant'] = $observations_infos['os_ce_participant'];
341
			}
342
 
343
			$resultats_formates[$id_station]['obs'][$id_observation] = $infos_formatees;
344
		}
345
 
346
		return $resultats_formates;
347
	}
348
 
210 aurelien 349
	public function getFichierExportObservationCsv() {
350
 
351
		$donnees = $this->getExportObservation();
270 aurelien 352
		$donnees_formatees = $this->formaterListeObservationPourExportCSV($donnees);
210 aurelien 353
		$chaine_csv = $this->convertirTableauAssocVersCSV($donnees_formatees);
207 aurelien 354
 
210 aurelien 355
		$this->envoyerFichier($chaine_csv);
207 aurelien 356
	}
357
 
270 aurelien 358
	public function formaterListeObservationPourExportCSV($tableau_observations_infos) {
207 aurelien 359
 
360
		$gestionnaire_especes = new OdsEspece($this->config);
361
		$gestionnaire_communes = new OdsCommune($this->config);
227 aurelien 362
		$gestionnaire_utilisateurs = new OdsUtilisateur($this->config);
207 aurelien 363
 
364
		$especes = $gestionnaire_especes->getToutesEspeces();
365
		$evenements = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_EVENEMENTS);
249 aurelien 366
		$milieux = $this->obtenirValeursListeParAbreviation(self::ABBR_LISTE_MILIEUX);
207 aurelien 367
 
210 aurelien 368
		$codes_insee_communes = array();
369
 
207 aurelien 370
		$resultats_formates = array();
371
 
372
		foreach($tableau_observations_infos as $observations_infos) {
373
 
374
			$id_espece = $observations_infos['oi_ce_espece'];
375
			$nom_espece =  $especes[$id_espece]['nom_scientifique'];
376
 
377
			$id_evenement = $observations_infos['oo_ce_evenement'];
378
			$chaine_evenement = $evenements[$id_evenement]['ot_cle'];
379
 
380
			$infos_evenement = $this->renvoyerInformationStadeAPartirChaineTriple($chaine_evenement);
381
 
382
			$date_observation_formatee = date($this->config['appli']['format_date'], strtotime($observations_infos['oo_date']));
383
 
384
			$id_observation = $observations_infos['oo_id_observation'];
281 aurelien 385
			$milieu = isset($milieux[$observations_infos['os_ce_environnement']]['ot_valeur']) ? $milieux[$observations_infos['os_ce_environnement']]['ot_valeur'] : '';
207 aurelien 386
 
387
			$infos_formatees = array(
388
				'id_observation' => $id_observation,
389
				'date' => $date_observation_formatee,
390
				'evenenement' => $infos_evenement['nom'],
391
				'code_bbch' => $infos_evenement['numero'],
392
				'nom_scientifique' => $nom_espece,
393
				'station' => $observations_infos['os_nom'],
394
				'code_commune' => $observations_infos['os_ce_commune'],
210 aurelien 395
				'nom_commune' => '',
207 aurelien 396
				'latitude' => $observations_infos['os_latitude'],
397
				'longitude' => $observations_infos['os_longitude'],
398
				'altitude' => $observations_infos['os_altitude'],
281 aurelien 399
				'milieu' => $milieu,
227 aurelien 400
				'id_participant' => $observations_infos['os_ce_participant'],
401
				'pseudo_participant' => '',
402
				'mail_participant' => ''
207 aurelien 403
			);
404
 
405
			$resultats_formates[] = $infos_formatees;
210 aurelien 406
 
407
			if(is_numeric($observations_infos['os_ce_commune'])) {
408
				$codes_insee_communes[] = $observations_infos['os_ce_commune'];
409
			}
207 aurelien 410
		}
281 aurelien 411
 
210 aurelien 412
		$correspondance_codes_insee_noms = $gestionnaire_communes->obtenirTableauNomsCommunesParTableauCodesInsee($codes_insee_communes);
227 aurelien 413
		$correspondance_id_utilisateur = $gestionnaire_utilisateurs->getListeUtilisateurFormateeId();
210 aurelien 414
 
415
		foreach($resultats_formates as &$resultat) {
416
 
227 aurelien 417
			if(isset($correspondance_codes_insee_noms[$resultat['code_commune']]) && trim($correspondance_codes_insee_noms[$resultat['code_commune']]) != '') {
210 aurelien 418
				$resultat['nom_commune'] = $correspondance_codes_insee_noms[$resultat['code_commune']];
419
			}
227 aurelien 420
 
421
			$resultat['pseudo_participant'] = $correspondance_id_utilisateur[$resultat['id_participant']]['name'];
422
			$resultat['mail_participant'] = $correspondance_id_utilisateur[$resultat['id_participant']]['mail'];
210 aurelien 423
		}
424
 
207 aurelien 425
		return $resultats_formates;
426
	}
427
 
428
	public function convertirTableauAssocVersCSV($tableau) {
429
 
430
		$csv = '';
431
		$colonnes = array_keys($tableau[0]);
432
		$csv .= implode(';',$colonnes).";\n";
433
 
434
		foreach($tableau as $elements) {
281 aurelien 435
			$ligne = "";
436
			// parcours des cases de chaque ligne nécessaire car si on utilise implode
437
			// les valeurs vides ne sont pas prises et ça décale les colonnes
438
			foreach ($elements as $element) {
439
				$ligne .= '"'.$element.'";';
440
			}
441
			$csv .= $ligne."\n";
207 aurelien 442
		}
443
 
444
		return $csv;
445
	}
446
 
281 aurelien 447
	public function envoyerFichier($contenu, $nom = 'observations_export') {
207 aurelien 448
 
281 aurelien 449
		$nom_fichier = $nom.".csv";
207 aurelien 450
		$chemin_fichier = $this->config['appli']['chemin_fichiers_temp'].'/'.$nom_fichier;
451
 
452
		file_put_contents($chemin_fichier, $contenu);
453
 
454
		$contenu = file_get_contents($chemin_fichier);
455
		$taille_fichier = filesize($chemin_fichier);
456
 
457
		unlink($chemin_fichier);
458
 
459
		ini_set('zlib.output_compression','Off');
460
 
461
		header('Pragma: public');
462
		header('Last-Modified: '.gmdate('D, d M Y H:i:s').' GMT');
463
		header('Cache-Control: must-revalidate, pre-check=0, post-check=0, max-age=0');
464
 
465
		header('Content-Tranfer-Encoding: none');
466
 
467
		header('Content-Type: application/octetstream; name="'.$nom_fichier.'"');
468
		header('Content-Disposition: attachement; filename="'.$nom_fichier.'"');
469
 
470
		header('Content-Length: '.$taille_fichier);
471
 
472
		echo $contenu;
473
		exit();
474
	}
475
 
476
	private function formaterInformationPourEnvoi($tableauinfos) {
477
 
478
	}
479
}
480
?>