Subversion Repositories eFlore/Applications.cel

Rev

Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
1149 gduche 1
<?php
2
 
3
class MigrationObs extends Cel {
4
 
1158 aurelien 5
	public static $bdd_cel_migration;
6
	public static $bdd_utilisateurs;
7
 
1149 gduche 8
	const truncate = true; //Doit on vider les tables de destination ?
9
 
1158 aurelien 10
	const dry_run = false;
1149 gduche 11
 
12
	/** Tableau associatif permettant de stocker l'avancement dans une boucle.
13
	* La clé est un md5 du message à afficher au démarrage de la boucle.
14
	* @var array
15
	*/
16
	private static $avancement = array();
17
 
18
	private $communesOubliees = array();
19
	private $tableau_utilisateurs = array();
20
	private $tableau_mots_cles = array();
21
	private $tableau_zones_geo = array();
22
 
23
	private $tableau_nouveau_ancien = array(
24
		'id_observation' 		=> 'id',
25
		'ordre'					=> 'ordre',
26
		'ce_utilisateur'		=> 'traiterIdentifiantUtilisateur',
27
		'prenom_utilisateur'	=> 'traiterPrenomUtilisateur',
28
		'nom_utilisateur'		=> 'traiterNomUtilisateur',
29
		'courriel_utilisateur'  => 'identifiant',
30
		'nom_sel'				=> 'nom_sel',
31
		'nom_sel_nn'			=> 'num_nom_sel',
32
		'nom_ret'				=> 'nom_ret',
33
		'nom_ret_nn'			=> 'num_nom_ret',
34
		'nt'					=> 'num_taxon',
35
		'famille'				=> 'famille',
36
		'nom_referentiel'		=> 'traiterReferentiel',
37
		'ce_zone_geo'			=> 'traiterIdentifiantZoneGeo',
38
		'zone_geo'				=> 'location',
39
		'lieudit'				=> 'lieudit',
40
		'station'				=> 'station',
41
		'milieu'				=> 'milieu',
42
		'latitude'				=> 'coord_x',
43
		'longitude'				=> 'coord_y',
44
		'geodatum'				=> 'ref_geo',
45
		'date_observation'		=> 'date_observation',
46
		'mots_cles_texte'		=> 'traiterMotsClesTexte',
47
		'commentaire'			=> 'commentaire',
48
		'transmission'			=> 'transmission',
49
		'date_creation'			=> 'date_creation',
50
		'date_modification'		=> 'date_modification',
51
		'date_transmission'		=> 'date_transmission'
52
		);
53
 
54
	private $tableau_ancien_nouveau = array(
55
		'id'					=> 'id_observation',
56
		'identifiant'			=> '',
57
		'prenom_utilisateur'	=> 'prenom_utilisateur',
58
		'nom_utilisateur'		=> 'nom_utilisateur',
59
		'ordre'					=> 'ordre',
60
		'nom_sel'				=> 'nom_sel',
61
		'num_nom_sel'			=> 'nom_sel_nn',
62
		'nom_ret'				=> 'nom_ret',
63
		'num_nom_ret'			=> 'nom_ret_nn',
64
		'num_taxon'				=> 'nt',
65
		'famille'				=> 'famille',
66
		'location'				=> '',
67
		'id_location'			=> '',
68
		'date_observation'		=> 'date_observation',
69
		'lieu_dit'				=> 'lieudit',
70
		'station'				=> 'station',
71
		'milieu'				=> 'milieu',
72
		'commentaire'			=> 'commentaire',
73
		'transmission'			=> 'transmission',
74
		'date_creation' 		=> 'date_creation',
75
		'date_modification' 	=> 'date_modification',
76
		'date_transmission'		=> 'date_transmission',
77
		'mots_cles'				=> '',
78
		'coord_x'				=> 'latitude',
79
		'coord_y'				=> 'longitude',
80
		'ref_geo'				=> 'geodatum'
81
		);
82
 
83
	/**
84
	 * Méthode appelée avec une requête de type GET.
85
	 */
86
	public function getElement($params) {
87
 
1158 aurelien 88
		if(!isset($this->config['database_cel']['database_migration']) || $this->config['database_cel']['database_migration'] == '') {
89
			echo 'Attention la variable de configuration database_migration dans la section database_cel, contenant la base de données d\'arrivée, doit être remplie '."\n";
90
			exit;
91
		}
92
 
93
		if(!isset($this->config['database_ident']['database']) || $this->config['database_ident']['database'] == '') {
94
			echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n";
95
			exit;
96
		}
97
 
98
		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
99
		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
100
 
1149 gduche 101
		echo "--MIGRATION DES OBSERVATIONS --------------------------------------\n";
102
		//1. TEMPORAIRE : vider les tables de destinations
103
		if (self::truncate) {
104
			echo "-------------------------------------------------------------------\n\n";
105
			echo "  ETAPE 0. Vider les tables ... \n\n";
106
			echo "-------------------------------------------------------------------\n\n";
107
			$nouvellesTables = array('`cel_images`', '`cel_images_mots_cles`', '`cel_mots_cles_images`', '`cel_mots_cles_obs`;',
108
								'`cel_obs`', '`cel_obs_images`', '`cel_obs_mots_cles`', '`cel_utilisateurs`', '`cel_utilisateurs`', '`cel_zones_geo`');
109
			foreach ($nouvellesTables as $nomTable) {
110
				echo 'Vider la table '.$nomTable.'...';
1158 aurelien 111
				$requeteTruncate = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
1149 gduche 112
				$resultatTruncate = $this->executerRequete($requeteTruncate);
113
				echo "ok \n";
114
			}
115
 
116
			echo "\n---------------------------------------------------------------- OK\n\n";
117
		}
118
 
119
		echo "-------------------------------------------------------------------\n\n";
120
		echo "  ETAPE 1. Paramétrage ... \n\n";
121
		echo "-------------------------------------------------------------------\n\n";
122
 
123
		$this->getUtilisateurs();
124
		$this->getMotsCles();
125
 
126
		echo "-------------------------------------------------------------------\n\n";
127
		echo "  ETAPE 2. Migration des utilisateurs ... \n\n";
128
		echo "-------------------------------------------------------------------\n\n";
129
 
130
		$this->migrerUtilisateurs();
131
 
132
		echo "-------------------------------------------------------------------\n\n";
133
		echo "  ETAPE 3. Migration des zone géographiques ... \n\n";
134
		echo "-------------------------------------------------------------------\n\n";
135
		$this->migrerZonesGeo();
136
 
137
		echo "-------------------------------------------------------------------\n\n";
138
		echo "  ETAPE 4. Migration des observations ... \n\n";
139
		echo "-------------------------------------------------------------------\n\n";
140
		$this->migrerObs();
141
		echo "\n"."\n"."\n";
142
	}
143
 
144
	public function executerRequeteSimple($requete) {
145
		// Fonction de commodité pour afficher les requetes au lieu de les executer
146
		if (self::dry_run) {
147
			echo str_replace('),','),'."\n", $requete);
148
			return true;
149
		} else {
150
			return parent::executerRequeteSimple($requete);
151
		}
152
	}
153
 
154
	private function getUtilisateurs() {
155
		echo "\n-------------------------------------------------------------------\n";
156
		echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n";
157
 
1158 aurelien 158
		$requete_selection_utilisateurs = 'SELECT U_ID as id, U_MAIL as mail, U_NAME as nom, U_SURNAME as prenom, U_PASSWD as pass FROM '.self::$bdd_utilisateurs.'.annuaire_tela';
1149 gduche 159
		$tableau_utilisateurs = $this->executerRequete($requete_selection_utilisateurs);
160
 
161
		foreach( $tableau_utilisateurs as &$utilisateur) {
162
			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
163
		}
164
 
165
		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";
166
		echo "\n-----------------------------------------------------------------OK\n";
167
	}
168
 
169
	private function getMotsCles() {
170
		echo "\n-------------------------------------------------------------------\n";
171
		echo "--SELECTION DES MOTS-CLES -----------------------------------------\n\n";
172
 
173
		$requete_selection_mots_cles = 'SELECT cmc_id_proprietaire as id_utilisateur, cmc_id_mot_cle_utilisateur as id_mot_cle, cmc_mot_cle as mot_cle FROM cel_mots_cles_obs';
174
		$tableau_mots_cles = $this->executerRequete($requete_selection_mots_cles);
175
 
176
		foreach( $tableau_mots_cles as &$mot_cle) {
177
			$this->tableau_mots_cles[$mot_cle['id_utilisateur']][$mot_cle['id_mot_cle']] = $mot_cle;
178
		}
179
 
180
		echo sizeof($this->tableau_mots_cles)." mots-clés sélectionnés";
181
		echo "\n-----------------------------------------------------------------OK\n";
182
 
183
	}
184
 
185
	/**
186
	 * Utiliser cette méthode dans une boucle pour afficher un message suivi du nombre de tour de boucle effectué.
187
	 * Vous devrez vous même gérer le retour à la ligne à la sortie de la boucle.
188
	 *
189
	 * @param string le message d'information.
190
	 * @param int le nombre de départ à afficher.
191
	 * @return void le message est affiché dans la console.
192
	 */
193
	protected function afficherAvancement($message, $depart = 0) {
194
		if (! isset(self::$avancement[$message])) {
195
			self::$avancement[$message] = $depart;
196
			echo "$message : ";
197
 
198
			$actuel =& self::$avancement[$message];
199
			echo $actuel++;
200
		} else {
201
			$actuel =& self::$avancement[$message];
202
 
203
			// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)
204
			$passage = 0;
205
			if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {
206
				$passage = 1;
207
			}
208
 
209
			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
210
			echo $actuel++;
211
		}
212
	}
213
 
214
	private function migrerUtilisateurs() {
215
 
216
		$pas = 1000;
217
		$nbTotal = 0;
218
		$tabUtilisateurs = $this->tableau_utilisateurs;
219
		while (!empty($tabUtilisateurs)) {
1158 aurelien 220
			$requete_insertion_utilisateurs = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_utilisateurs '.
1149 gduche 221
						'(id_utilisateur, prenom, nom, courriel, mot_de_passe) '.
222
						'VALUES ';
223
			$sous_requete_insertion = '';
224
 
225
			$i = 0;
226
			foreach ($tabUtilisateurs as $id => &$utilisateur) {
227
 
228
				$i++;
229
				if ($i == $pas) {
230
					break;
231
				}
232
				$sous_requete_insertion .= '('.$this->proteger($utilisateur['id']).','.
233
												$this->proteger($utilisateur['prenom']).','.
234
												$this->proteger($utilisateur['nom']).','.
235
												$this->proteger($utilisateur['mail']).','.
236
												$this->proteger($utilisateur['pass']).'),';
237
				unset($tabUtilisateurs[$id]);
238
 
239
			}
240
 
241
			$sous_requete_insertion = rtrim($sous_requete_insertion,',');
242
			$requete_insertion_utilisateurs = $requete_insertion_utilisateurs.$sous_requete_insertion;
243
 
244
			$migration_utilisateurs = $this->executerRequeteSimple($requete_insertion_utilisateurs);
245
 
246
			if ($migration_utilisateurs) {
247
				$nbTotal ++;
248
				$this->afficherAvancement('Migration utilisateurs (par '.$pas.')', $nbTotal);
249
			} else {
250
				exit('Erreur lors de la migration des utilisateurs '."\n");
251
			}
252
		}
253
		echo "\n---------------------------------------------------------------- OK\n\n";
254
 
255
	}
256
 
257
	private function migrerZonesGeo() {
258
 
259
		$pas = 5000;
260
 
261
		//SELECTIONNER LE NOMBRE DE ZONE GEO
262
		$requete_nombreZonesGeo = 'SELECT count(*) as nb FROM locations';
263
		$resultatNbZonesGeo = $this->executerRequete($requete_nombreZonesGeo);
264
		$nbZones = (int) $resultatNbZonesGeo[0]['nb'];
265
 
266
		$nbTotal = 0;
267
		for($i = 0; $i <= $nbZones ; $i += $pas) {
268
 
269
			$requete_selection_zones_geo = 'SELECT * FROM locations LIMIT '.$i.', '.$pas;
270
 
271
			$zones_geo = $this->executerRequete($requete_selection_zones_geo);
272
 
1158 aurelien 273
			$requete_insertion_nouvelles_zones_geo = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_zones_geo '.
1149 gduche 274
					'(id_zone_geo, code, nom, utm_secteur, utm_x, utm_y, wgs84_latitude, wgs84_longitude, date_modification) '.
275
					'VALUES ';
276
 
277
			$sous_requete_insertion_valeurs = '';
278
 
279
			if(count($zones_geo) > 0) {
280
				foreach($zones_geo as $zone_geo) {
281
 
282
					$zone_geo['nouveau_code_geo'] = 'INSEE-C:'.$zone_geo['insee_code'];
283
					$lat_long = $this->convertirUtmVersLatLong($zone_geo['x_utm'],$zone_geo['y_utm'],$zone_geo['sector']);
284
 
285
					$indice_tableau_localites = $this->construireIndiceTableauLocalites($zone_geo['name'], $zone_geo['insee_code']);
286
					$this->tableau_zones_geo[$indice_tableau_localites] = $zone_geo;
287
 
288
					$sous_requete_insertion_valeurs .= '('.$this->proteger($zone_geo['nouveau_code_geo']).','.
289
														$this->proteger($zone_geo['insee_code']).','.
290
														$this->proteger($zone_geo['name']).','.
291
														$this->proteger($zone_geo['sector']).','.
292
														$this->proteger($zone_geo['x_utm']).','.
293
														$this->proteger($zone_geo['y_utm']).','.
294
														$this->proteger($lat_long['lat']).','.
295
														$this->proteger($lat_long['long']).','.
296
														$this->proteger($zone_geo['update_date']).
297
														'),';
298
				}
299
 
300
				$sous_requete_insertion_valeurs = rtrim($sous_requete_insertion_valeurs,',');
301
 
302
				$requete_insertion_nouvelles_zones_geo .= $sous_requete_insertion_valeurs;
303
 
304
				$migration_zones_geo = $this->executerRequeteSimple($requete_insertion_nouvelles_zones_geo);
305
			} else {
306
				echo 'Fin de migration des zones géo '."\n";
307
				return;
308
			}
309
 
310
			if ($migration_zones_geo) {
311
				$nbTotal ++;
312
				$this->afficherAvancement('Migration des zones (par '.$pas.')', $nbTotal);
313
			} else {
314
				exit('Erreur lors de la migration des zones géo '.$i.' à '.($i+$pas)."\n");
315
			}
316
		}
317
		echo "\n---------------------------------------------------------------- OK\n\n";
318
	}
319
 
320
	private function convertirUtmVersLatLong($x, $y, $sector) {
321
 
322
    	$lat_long = array();
323
 
324
    	$convertisseur = new gPoint();
325
		$convertisseur->setUTM($x, $y, $sector);
326
		$convertisseur->convertTMtoLL();
327
		$lat_long['lat'] = str_replace(',','.',$convertisseur->Lat());
328
		$lat_long['long'] = str_replace(',','.',$convertisseur->Long());
329
 
330
		return $lat_long;
331
    }
332
 
333
	private function migrerObs() {
334
 
335
		$debut = 0;
336
		$pas = 1000;
337
		$nbTotal = 0;
338
 
339
		//Selectionner le nombre d'observations
340
		$requeteNbObs = "SELECT COUNT(*) as nb FROM cel_inventory";
341
		$resultatNbObs = $this->executerRequete($requeteNbObs);
342
		$fin = $resultatNbObs[0]['nb'];
343
 
344
		for ($i = $debut; $i < $fin ; $i += $pas) {
345
			$requete_selection_obs = 'SELECT * FROM cel_inventory '.
346
											'ORDER BY identifiant LIMIT '.$i.','.$pas;
347
			$observations = $this->requeter($requete_selection_obs);
348
 
1158 aurelien 349
			$requete_insertion_observations = 'INSERT IGNORE INTO '.self::$bdd_cel_migration.'.cel_obs (';
1149 gduche 350
 
351
			foreach ($this->tableau_nouveau_ancien as $nouveau_champ => $ancien_champ) {
352
				$requete_insertion_observations .= $nouveau_champ.',';
353
			}
354
 
355
			$requete_insertion_observations = rtrim($requete_insertion_observations, ',');
356
			$requete_insertion_observations = $requete_insertion_observations.') VALUES ';
357
 
358
			if (count($observations) > 0) {
359
				foreach($observations as $observation) {
360
					$nouvelle_observation = $this->traiterLigneObservation($observation);
361
 
1158 aurelien 362
					$nouvelle_observation = array_map(array($this,'protegerSiNonNull'),$nouvelle_observation);
1149 gduche 363
					$requete_insertion_observations .= '('.join(',',array_values($nouvelle_observation)).'),';
364
				}
365
 
366
				$requete_insertion_observations = rtrim($requete_insertion_observations, ',');
367
 
368
				$migration_observations = $this->executerRequeteSimple($requete_insertion_observations);
369
			} else {
370
				echo 'Fin de migration des observations '."\n"."\n";
371
				return;
372
			}
373
 
374
			if ($migration_observations) {
375
				$nbTotal ++;
376
				$this->afficherAvancement('Migration des observations (par '.$pas.')', $nbTotal);
377
			} else {
378
				exit('Erreur lors de la migration des observation de '.$i.' à '.($i+$pas)."\n");
379
			}
380
		}
381
		if (sizeof($this->communesOubliees) > 0) {
1158 aurelien 382
			echo "\nxxxxxxxxx communes oubliées : ".sizeof($this->communesOubliees)." xxxxxxxxx \\n";
1149 gduche 383
		}
384
		echo "\n---------------------------------------------------------------- OK\n\n";
385
	}
386
 
387
	private function traiterLigneObservation($obs) {
388
 
389
		$nouvelle_obs = array();
390
 
391
		foreach($this->tableau_nouveau_ancien as $nouveau_champ_obs => $ancien_champ_obs) {
392
 
393
			if ($this->estUnChampATraiter($ancien_champ_obs)) {
394
				if (method_exists($this,$ancien_champ_obs)) {
395
					$nouvelle_obs[$nouveau_champ_obs] = $this->$ancien_champ_obs($obs);
396
				} else {
397
					$nouvelle_obs[$nouveau_champ_obs] = '';
398
				}
399
 
400
			} else {
1158 aurelien 401
				if($obs[$ancien_champ_obs] == '000null' || $obs[$ancien_champ_obs] == 'null' || trim($obs[$ancien_champ_obs]) == '') {
402
					$obs[$ancien_champ_obs] = 'NULL';
403
				}
404
 
405
				if(($ancien_champ_obs == 'coord_x' || $ancien_champ_obs == 'coord_y') && ($obs[$ancien_champ_obs] == '0' || $obs[$ancien_champ_obs] == 0)) {
406
					$obs[$ancien_champ_obs] = 'NULL';
407
				}
408
 
1149 gduche 409
				$nouvelle_obs[$nouveau_champ_obs] = $obs[$ancien_champ_obs];
410
			}
411
		}
412
		return $nouvelle_obs;
413
	}
414
 
1158 aurelien 415
	private function protegerSiNonNull($valeur) {
416
		if($valeur != 'NULL') {
417
			$valeur = $this->proteger($valeur);
418
		}
419
		return $valeur;
420
	}
421
 
1149 gduche 422
	private function estUnChampATraiter($champ) {
423
		return strpos($champ,'traiter') !== false;
424
	}
425
 
426
	private function traiterReferentiel($observation) {
427
		return 'bdtfx_v1';
428
	}
429
 
430
	private function traiterMotsClesTexte($ligne_observation) {
431
 
432
		$mail_observation = $ligne_observation['identifiant'];
433
		$retour = $ligne_observation['mots_cles'];
434
		if (isset($this->tableau_mots_cles[$mail_observation])) {
435
			$mots_cles_tableau = $this->parserMotsCles($mail_observation, $ligne_observation['mots_cles'], ';');
1158 aurelien 436
			$retour =  join(',',$mots_cles_tableau);
437
			$retour = ltrim($retour,',,') ;
1149 gduche 438
		}
439
 
440
		return $retour;
441
	}
442
 
443
	private function parserMotsCles($utilisateur, $mot_cles, $separateur = ',') {
444
 
445
		$tableau_mots_cles = explode($separateur,$mot_cles);
446
		$tableau_mots_cles_formates = array();
447
 
448
		foreach($tableau_mots_cles as $mot_cle) {
449
 
450
			$mot_cle = str_replace($separateur.$separateur,'',$mot_cle);
451
			$mot_cle = str_replace('null','',$mot_cle);
452
 
453
			if ($this->estUnIdentifiantMotCle($mot_cle)) {
454
 
455
				// certains mots clés mal formatés contiennent des virgules
456
				if (strpos($mot_cle,',') !== false) {
457
					$tab_mot_cle_mal_formate = explode(',',$mot_cle);
458
 
459
					foreach ($tab_mot_cle_mal_formate as $mot_cle_mal_formate) {
460
						if ($this->estUnIdentifiantMotCle($mot_cle_mal_formate)) {
461
							$tableau_mots_cles_formates[$mot_cle_mal_formate] = $this->tableau_mots_cles[$utilisateur][$mot_cle_mal_formate]['mot_cle'];
462
						}
463
					}
464
				} else {
465
					// on met le mot clé dans sa propre case afin d'éviter
466
					// facilement les doublons provoqués par de mauvais formatages
467
					if (isset($this->tableau_mots_cles[$utilisateur][$mot_cle]) && trim($this->tableau_mots_cles[$utilisateur][$mot_cle]['mot_cle']) != '') {
468
						$tableau_mots_cles_formates[$mot_cle] = $this->tableau_mots_cles[$utilisateur][$mot_cle]['mot_cle'];
469
					}
470
				}
471
 
472
			}
473
		}
474
 
475
		return $tableau_mots_cles_formates;
476
	}
477
 
478
	private function estUnIdentifiantMotCle($chaine) {
479
		return trim($chaine) != '' && preg_match('/[0-9A-Z]+\.[0-9A-Z]+/i', $chaine) ;
480
	}
481
 
482
	private function traiterIdentifiantUtilisateur($ligne_observation) {
483
		$mail_observation = $ligne_observation['identifiant'];
484
		$retour = $mail_observation;
485
		if (isset($this->tableau_utilisateurs[$mail_observation])) {
486
			$retour =  $this->tableau_utilisateurs[$mail_observation]['id'];
487
		}
488
		return $retour;
489
	}
490
 
491
	private function traiterPrenomUtilisateur($ligne_observation) {
492
 
493
		$mail_observation = $ligne_observation['identifiant'];
494
		$retour = $mail_observation;
495
		if (isset($this->tableau_utilisateurs[$mail_observation])) {
496
			$retour =  $this->tableau_utilisateurs[$mail_observation]['prenom'];
497
		}
498
 
499
		return $retour;
500
	}
501
 
502
	private function traiterNomUtilisateur($ligne_observation) {
503
 
504
		$mail_observation = $ligne_observation['identifiant'];
505
		$retour = $mail_observation;
506
 
507
		if (isset($this->tableau_utilisateurs[$mail_observation])) {
508
			$retour =  $this->tableau_utilisateurs[$mail_observation]['nom'];
509
		}
510
 
511
		return $retour;
512
	}
513
 
514
	private function traiterZoneGeo($ligne_observation) {
515
 
516
		$zone_geo = $ligne_observation['location'];
517
 
518
		if($ligne_observation['id_location'] != null && !is_numeric($ligne_observation['id_location']) && $ligne_observation['id_location'] != '000null') {
519
			$id_zone_geo_ancienne = $ligne_observation['id_location'];
520
			if($zone_geo != '') {
521
				$id_zone_geo_ancienne = '('.$id_zone_geo_ancienne.')';
522
			}
523
 
524
			$zone_geo .= $id_zone_geo_ancienne;
525
		} elseif($ligne_observation['location'] == null || $ligne_observation['location'] == "" || $ligne_observation['location'] == "000null") {
526
 
1158 aurelien 527
			if($ligne_observation['id_location'] != '' && $ligne_observation['id_location'] != '000null') {
528
				$id_zone_geo_ancienne = $ligne_observation['id_location'];
529
				$id_zone_geo_ancienne = $id_zone_geo_ancienne;
530
				$zone_geo = $id_zone_geo_ancienne;
531
			} else {
532
				$zones_geo = 'NULL';
533
			}
1149 gduche 534
		}
535
 
536
		return $zone_geo;
537
	}
538
 
539
	private function traiterIdentifiantZoneGeo($ligne_observation) {
540
		$id_zone_geo = '';
541
 
542
		if($ligne_observation['id_location'] != '' && $ligne_observation['id_location'] != '000null') {
543
			$indice = $this->construireIndiceTableauLocalites($ligne_observation['location'], $ligne_observation['id_location']);
544
			if(isset($this->tableau_zones_geo[$indice])) {
545
				$id_zone_geo = $this->tableau_zones_geo[$indice]['nouveau_code_geo'];
546
			} else {
547
				if($ligne_observation['location'] != "000null") {
548
					$this->communesOubliees[$indice] = false;
549
				}
550
			}
1158 aurelien 551
		} else {
552
			$id_zone_geo = 'NULL';
1149 gduche 553
		}
554
 
555
		return $id_zone_geo;
556
	}
557
 
558
	private function construireIndiceTableauLocalites($nom, $id) {
559
 
560
		$nom = htmlentities($nom, ENT_NOQUOTES, 'UTF-8');
561
 
562
    	$nom = preg_replace('#&([A-za-z])(?:acute|cedil|circ|grave|orn|ring|slash|th|tilde|uml);#', '\1', $nom);
563
    	$nom = preg_replace('#&([A-za-z]{2})(?:lig);#', '\1', $nom); // pour les ligatures e.g. '&oelig;'
564
    	$nom = preg_replace('#&[^;]+;#', '', $nom); // supprime les autres caractères
565
 
566
    	$nom = str_replace("'",'_',$nom);
567
		$nom = str_replace(' ','_',$nom);
568
		$nom = str_replace('-','_',$nom);
569
		$nom = str_replace('  ','_',$nom);
570
		$indice = strtolower($nom).substr($id,0,2);
571
 
572
		return $indice;
573
	}
574
}