WebSVN – eFlore/Applications.cel – Diff – /trunk/jrest/services/MigrationObs.php

 <?php
-class MigrationObs extends Cel {
-	public static $bdd_cel_migration;
-	public static $bdd_utilisateurs;
+class MigrationObs extends Cel {
 	const truncate = true; //Doit on vider les tables de destination ?
+	const truncate = true; //Doit on vider les tables de destination ?
+	const dry_run = false;
+	const PATTERN_LAT = '/^[+-]?(?:[1-9][0-9]|[0-9])(?:[.][0-9]+|)$/';
+	const PATTERN_LNG = '/^[+-]?(?:1[0-8][0-9]|[1-9][0-9]|[0-9])(?:[.][0-9]+|)$/';
+	public static $bdd_cel_migration;
+	public static $bdd_utilisateurs;
+	private $communesOubliees = array();
+	private $tableau_utilisateurs = array();
 	private $tableau_mots_cles = array();
-	const dry_run = false;
+	private $tableau_zones_geo = array();
 	/** Tableau associatif permettant de stocker l'avancement dans une boucle.
 	* La clé est un md5 du message à afficher au démarrage de la boucle.
-	* @var array
-	*/
-	private static $avancement = array();
-	private $communesOubliees = array();
-	private $tableau_utilisateurs = array();
+	* @var array
-	private $tableau_mots_cles = array();
+	*/
-	private $tableau_zones_geo = array();
+	private static $avancement = array();
 	private $tableau_nouveau_ancien = array(
 		'ce_zone_geo'			=> 'traiterIdentifiantZoneGeo',
 		'zone_geo'				=> 'location',
 		'lieudit'				=> 'lieudit',
 		'station'				=> 'station',
 		'milieu'				=> 'milieu',
-		'latitude'				=> 'coord_x',
+		'latitude'				=> 'traiterLat',
-		'longitude'				=> 'coord_y',
+		'longitude'				=> 'traiterLng',
 		'geodatum'				=> 'traiterGeodatum',
 		'date_observation'		=> 'date_observation',
 		'mots_cles_texte'		=> 'traiterMotsClesTexte',
 		'commentaire'			=> 'commentaire',
 		'transmission'			=> 'transmission',
 		//1. TEMPORAIRE : vider les tables de destinations
 		if (self::truncate) {
 			echo "-------------------------------------------------------------------\n\n";
 			echo "  ETAPE 0. Vider les tables ... \n\n";
 			echo "-------------------------------------------------------------------\n\n";
-			$nouvellesTables = array('`cel_images`', '`cel_images_mots_cles`', '`cel_mots_cles_images`', '`cel_mots_cles_obs`;',
+			$nouvellesTables = array('cel_obs', 'cel_utilisateurs_infos', 'cel_zones_geo');
-								'`cel_obs`', '`cel_obs_images`', '`cel_obs_mots_cles`', '`cel_utilisateurs`', '`cel_utilisateurs`', '`cel_zones_geo`');
 			foreach ($nouvellesTables as $nomTable) {
 				echo 'Vider la table '.$nomTable.'...';
 				$requeteTruncate = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
 				$resultatTruncate = $this->executerRequete($requeteTruncate);
 				echo "ok \n";
 	private function getUtilisateurs() {
 		echo "\n-------------------------------------------------------------------\n";
 		echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n";
-		$requete = 'SELECT U_ID as id, U_MAIL as mail, U_NAME as nom, U_SURNAME as prenom, U_PASSWD as pass '.
+		$requete = 'SELECT DISTINCT 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 ';
+			'FROM cel_inventory INNER JOIN '.self::$bdd_utilisateurs.'.annuaire_tela ON (u_mail = identifiant) ';
 		$tableau_utilisateurs = $this->executerRequete($requete);
 			echo $actuel++;
+		}
+	}
-	private function migrerUtilisateurs() {
-		$pas = 1000;
-		$nbTotal = 0;
-		$tabUtilisateurs = $this->tableau_utilisateurs;
-		while (!empty($tabUtilisateurs)) {
+	private function migrerUtilisateurs() {
-			$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_utilisateurs '.
+		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_utilisateurs_infos '.
-						'(id_utilisateur, prenom, nom, courriel, mot_de_passe) '.
+					'(id_utilisateur) '.
-						'VALUES ';
-			$sous_requete = array();
-			$i = 0;
-			foreach ($tabUtilisateurs as $id => &$utilisateur) {
-				$i++;
-				if ($i == $pas) {
-					break;
-				}
-				$prenom = self::formaterMotPremiereLettreChaqueMotEnMajuscule($utilisateur['prenom']);
-				$nom = self::formaterMotEnMajuscule($utilisateur['nom']);
-				$sous_requete[] = '('.$this->proteger($utilisateur['id']).','.
-					$this->proteger($prenom).','.
-					$this->proteger($nom).','.
-					$this->proteger($utilisateur['mail']).','.
-					$this->proteger($utilisateur['pass']).')';
-				unset($tabUtilisateurs[$id]);
-			}
-			$requete = $requete.implode(',', $sous_requete);
+					'VALUES ';
+		$sous_requete = array();
+		foreach ($this->tableau_utilisateurs as $id => &$utilisateur) {
+			$sous_requete[] = '('.$this->proteger($utilisateur['id']).')';
+		}
+		$requete .= implode(',', $sous_requete);
-			$migration_utilisateurs = $this->executerRequeteSimple($requete);
+		$migration_utilisateurs = $this->executerRequeteSimple($requete);
-			if ($migration_utilisateurs) {
-				$nbTotal ++;
+		if ($migration_utilisateurs) {
-				$this->afficherAvancement('Migration utilisateurs (par '.$pas.')', $nbTotal);
+			echo "Migration utilisateurs : ".count($sous_requete);
-			} else {
-				exit('Erreur lors de la migration des utilisateurs '."\n");
+		} else {
 			exit('Erreur lors de la migration des utilisateurs '."\n");
+		}
 			if (count($observations) > 0) {
 				foreach($observations as $observation) {
 					$nouvelle_observation = $this->traiterLigneObservation($observation);
-					$nouvelle_observation = array_map(array($this,'protegerSiNonNull'),$nouvelle_observation);
+					$nouvelle_observation = array_map(array($this, 'protegerSiNonNull'), $nouvelle_observation);
-					$requete_insertion_observations .= '('.join(',',array_values($nouvelle_observation)).'),';
+					$requete_insertion_observations .= '('.join(',', array_values($nouvelle_observation)).'),';
+				}
 			$retour = 'bdnff:4.02';
+		}
 		return $retour;
+	}
+	private function traiterLat(&$observation) {
+		if ($this->etreNull($observation['coord_x'])) {
+			$observation['coord_x'] = 'NULL';
+		} else if (preg_match(self::PATTERN_LAT, $observation['coord_x']) == false) {
+			$latNote = 'Latitude éronnée : '.$observation['coord_x'];
+			if ($this->etreNull($observation['commentaire'])) {
+				$observation['commentaire'] = $latNote;
+			} else {
+				$observation['commentaire'] .= "\n".$latNote;
+			}
+			$observation['coord_x'] = 'NULL';
+		}
+		$retour = $observation['coord_x'];
+		return $retour;
+	}
+	private function traiterLng(&$observation) {
+		if ($this->etreNull($observation['coord_y'])) {
+			$observation['coord_y'] = 'NULL';
+		} else if (preg_match(self::PATTERN_LNG, $observation['coord_y']) == false) {
+			$lngNote = 'Longitude éronnée : '.$observation['coord_y'];
+			if ($this->etreNull($observation['commentaire'])) {
+				$observation['commentaire'] = $lngNote;
+			} else {
+				$observation['commentaire'] .= "\n".$lngNote;
+			}
+			$observation['coord_y'] = 'NULL';
+		}
+		$retour = $observation['coord_y'];
+		return $retour;
+	}
 	private function traiterGeodatum($observation) {
 		$retour = 'NULL';
 		if ($observation['coord_x'] != 'NULL' && $observation['coord_y'] != 'NULL') {
 			$retour = 'WGS84';

Subversion Repositories eFlore/Applications.cel

(root)/trunk/jrest/services/MigrationObs.php – Rev 1186 → 1189