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

 <?php
 // declare(encoding='UTF-8');
 /**
  * Script de migration des Observations de la version 1 de la base de données du CEL à la v2.
+ * Utilisation : /opt/lampp/bin/php cli.php MigrationObs
+ *
  * @category	php 5.2
  * @package		Cel/Scripts
- * @author		Aurélien PERONNET <aurelien@tela-botanica.org>
+ * @author		Aurelien PERONNET <aurelien@tela-botanica.org>
  * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
  * @copyright	Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
- * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
+ * @license		http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
- * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
+ * @license		http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
- * @version	$Id$
+ * @version		$Id$
  */
-class MigrationObs extends Cel {
+class MigrationObs {
 	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]+|)$/';
+	private $bdd = null;
 	private $script = null;
 	public static $bdd_cel_migration;
 	public static $bdd_utilisateurs;
 	private $communesOubliees = array();
 	private $tableau_utilisateurs = array();
 		'id_observation' 		=> 'id',
 		'ordre'					=> 'ordre',
 		'ce_utilisateur'		=> 'traiterIdentifiantUtilisateur',
 		'prenom_utilisateur'	=> 'traiterPrenomUtilisateur',
 		'nom_utilisateur'		=> 'traiterNomUtilisateur',
-		'courriel_utilisateur'  => 'identifiant',
+		'courriel_utilisateur'  => 'traiterCourrielUtilisateur',
 		'nom_sel'				=> 'nom_sel',
 		'nom_sel_nn'			=> 'num_nom_sel',
 		'nom_ret'				=> 'nom_ret',
 		'nom_ret_nn'			=> 'num_nom_ret',
 		'nt'					=> 'num_taxon',
 		'mots_cles'				=> '',
 		'coord_x'				=> 'latitude',
 		'coord_y'				=> 'longitude',
 		'ref_geo'				=> 'geodatum'
 		);
+	public function __construct(Conteneur $conteneur) {
+		$bddMigration = $conteneur->getParametre('database_cel.database_migration');
+		if ($bddMigration == null || $bddMigration == '') {
+			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";
+			exit;
+		}
+		$bddIdentification = $conteneur->getParametre('database_ident.database');
+		if ($bddIdentification == null || $bddIdentification == '') {
+			echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n";
+			exit;
+		}
+		self::$bdd_cel_migration = $conteneur->getParametre('database_cel.database_migration');
+		self::$bdd_utilisateurs = $conteneur->getParametre('database_ident.database');
+		$this->bdd = $conteneur->getBdd();
+		$this->script = $conteneur->getScript();
+	}
 	/**
-	 * Méthode appelée avec une requête de type GET.
+	 * Méthode appelée pour executer le script.
 	 */
-	public function getElement($params) {
-		if(!isset($this->config['database_cel']['database_migration']) || $this->config['database_cel']['database_migration'] == '') {
-			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";
-			exit;
-		}
-		if(!isset($this->config['database_ident']['database']) || $this->config['database_ident']['database'] == '') {
-			echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n";
-			exit;
-		}
-		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
-		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
 	public function executer($params) {
 		echo "--MIGRATION DES OBSERVATIONS --------------------------------------\n";
 		//1. TEMPORAIRE : vider les tables de destinations
 		if (self::truncate) {
-			echo "-------------------------------------------------------------------\n\n";
+			echo "-------------------------------------------------------------------\n";
-			echo "  ETAPE 0. Vider les tables ... \n\n";
+			echo "  ETAPE 0. Vider les tables ... \n";
-			echo "-------------------------------------------------------------------\n\n";
+			echo "-------------------------------------------------------------------\n";
 			$nouvellesTables = array('cel_obs', 'cel_utilisateurs_infos', 'cel_zones_geo');
 			foreach ($nouvellesTables as $nomTable) {
 				echo 'Vider la table '.$nomTable.'...';
 				$requeteTruncate = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
-				$resultatTruncate = $this->executerRequete($requeteTruncate);
+				$resultatTruncate = $this->bdd->executer($requeteTruncate);
 				echo "ok \n";
-			}
 			echo "\n---------------------------------------------------------------- OK\n\n";
 		}
-		echo "-------------------------------------------------------------------\n\n";
+		echo "-------------------------------------------------------------------\n";
-		echo "  ETAPE 1. Paramétrage ... \n\n";
+		echo "  ETAPE 1. Paramétrage ... \n";
-		echo "-------------------------------------------------------------------\n\n";
+		echo "-------------------------------------------------------------------\n";
 		$this->getUtilisateurs();
 		$this->getMotsCles();
-		echo "-------------------------------------------------------------------\n\n";
+		echo "-------------------------------------------------------------------\n";
-		echo "  ETAPE 2. Migration des utilisateurs ... \n\n";
-		echo "-------------------------------------------------------------------\n\n";
+		echo "  ETAPE 2. Migration des utilisateurs ... \n";
-		$this->migrerUtilisateurs();
+		echo "-------------------------------------------------------------------\n";
+		$this->migrerUtilisateurs();
-		echo "-------------------------------------------------------------------\n\n";
+		echo "-------------------------------------------------------------------\n";
-		echo "  ETAPE 3. Migration des zone géographiques ... \n\n";
+		echo "  ETAPE 3. Migration des zone géographiques ... \n";
-		echo "-------------------------------------------------------------------\n\n";
+		echo "-------------------------------------------------------------------\n";
 		$this->migrerZonesGeo();
-		echo "-------------------------------------------------------------------\n\n";
+		echo "-------------------------------------------------------------------\n";
-		echo "  ETAPE 4. Migration des observations ... \n\n";
-		echo "-------------------------------------------------------------------\n\n";
+		echo "  ETAPE 4. Migration des observations ... \n";
-		$this->migrerObs();
+		echo "-------------------------------------------------------------------\n";
-		$this->mettreANullPrenomNomVide();
+		$this->migrerObs();
-		$this->ordonnerObs();
+		$this->mettreANullPrenomNomVide();
-		echo "\n"."\n"."\n";
+		$this->ordonnerObs();
+	}
-	public function executerRequeteSimple($requete) {
+	private function executerRequeteSimple($requete) {
 		// Fonction de commodité pour afficher les requetes au lieu de les executer
 		if (self::dry_run) {
 			echo str_replace('),','),'."\n", $requete);
-			return true;
-		} else {
+			return true;
-			return parent::executerRequeteSimple($requete);
+		} else {
 			return $this->bdd->executer($requete);
-	}
+		}
+	}
 	private function getUtilisateurs() {
-		echo "\n-------------------------------------------------------------------\n";
+	private function getUtilisateurs() {
-		echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n";
+		echo "SELECTION DES UTILISATEURS\n";
 		$requete = 'SELECT DISTINCT u_id AS id, u_mail AS mail, u_name AS nom, u_surname AS prenom, u_passwd AS pass '.
-			'FROM cel_inventory INNER JOIN '.self::$bdd_utilisateurs.'.annuaire_tela ON (u_mail = identifiant) ';
+		$requete = 'SELECT DISTINCT u_id AS id, u_mail AS mail, u_name AS nom, u_surname AS prenom, u_passwd AS pass '.
-		$tableau_utilisateurs = $this->executerRequete($requete);
+			'FROM cel_inventory INNER JOIN '.self::$bdd_utilisateurs.'.annuaire_tela ON (u_mail = identifiant) ';
-		foreach( $tableau_utilisateurs as &$utilisateur) {
+		$tableau_utilisateurs = $this->bdd->requeter($requete);
 			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
 		foreach( $tableau_utilisateurs as &$utilisateur) {
+			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
 		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";
 		echo "\n-----------------------------------------------------------------OK\n";
 		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés\n";
+	}
-	private function getMotsCles() {
-		echo "\n-------------------------------------------------------------------\n";
-		echo "--SELECTION DES MOTS-CLES -----------------------------------------\n\n";
-		$requete = '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 ';
-		$tableau_mots_cles = $this->executerRequete($requete);
-		foreach( $tableau_mots_cles as &$mot_cle) {
-			$this->tableau_mots_cles[$mot_cle['id_utilisateur']][$mot_cle['id_mot_cle']] = $mot_cle;
-		}
-		echo sizeof($this->tableau_mots_cles)." mots-clés sélectionnés";
-		echo "\n-----------------------------------------------------------------OK\n";
-	}
-	/**
-	 * Utiliser cette méthode dans une boucle pour afficher un message suivi du nombre de tour de boucle effectué.
-	 * Vous devrez vous même gérer le retour à la ligne à la sortie de la boucle.
-	 *
-	 * @param string le message d'information.
-	 * @param int le nombre de départ à afficher.
-	 * @return void le message est affiché dans la console.
-	 */
-	protected function afficherAvancement($message, $depart = 0) {
-		if (! isset(self::$avancement[$message])) {
-			self::$avancement[$message] = $depart;
-			echo "$message : ";
 			$actuel =& self::$avancement[$message];
-			echo $actuel++;
+	private function getMotsCles() {
-		} else {
+		echo "SELECTION DES MOTS-CLES \n";
 			$actuel =& self::$avancement[$message];
 		$requete = 'SELECT cmc_id_proprietaire as id_utilisateur, cmc_id_mot_cle_utilisateur as id_mot_cle, '.
-			// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)
+			'cmc_mot_cle as mot_cle '.
-			$passage = 0;
+			'FROM cel_mots_cles_obs ';
-			if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {
+		$tableau_mots_cles = $this->bdd->requeter($requete);
 				$passage = 1;
 		foreach( $tableau_mots_cles as &$mot_cle) {
 			$this->tableau_mots_cles[$mot_cle['id_utilisateur']][$mot_cle['id_mot_cle']] = $mot_cle;
 			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
 			echo $actuel++;
 		echo sizeof($this->tableau_mots_cles)." mots-clés sélectionnés\n";
+	}
 	private function migrerUtilisateurs() {
-		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_utilisateurs_infos '.
-					'(id_utilisateur) '.
+		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_utilisateurs_infos '.
-					'VALUES ';
+					'(id_utilisateur) '.
-		$sous_requete = array();
+					'VALUES ';
 		foreach ($this->tableau_utilisateurs as $id => &$utilisateur) {
-			$sous_requete[] = '('.$this->proteger($utilisateur['id']).')';
+		$sous_requete = array();
-		}
+		foreach ($this->tableau_utilisateurs as $id => &$utilisateur) {
-		$requete .= implode(',', $sous_requete);
+			$sous_requete[] = '('.$this->bdd->proteger($utilisateur['id']).')';
+		}
-		$migration_utilisateurs = $this->executerRequeteSimple($requete);
+		$requete .= implode(',', $sous_requete);
-		if ($migration_utilisateurs) {
+		$migration_utilisateurs = $this->executerRequeteSimple($requete);
 			echo "Migration utilisateurs : ".count($sous_requete);
-		} else {
+		if ($migration_utilisateurs) {
-			exit('Erreur lors de la migration des utilisateurs '."\n");
+			echo "Migration utilisateurs : ".count($sous_requete);
 					$lat_long = $this->convertirUtmVersLatLong($zone_geo['x_utm'],$zone_geo['y_utm'],$zone_geo['sector']);
 					$indice_tableau_localites = $this->construireIndiceTableauLocalites($zone_geo['name'], $zone_geo['insee_code']);
 					$this->tableau_zones_geo[$indice_tableau_localites] = $zone_geo;
-					$sous_requete_insertion_valeurs .= '('.$this->proteger($zone_geo['nouveau_code_geo']).','.
+					$sous_requete_insertion_valeurs .= '('.$this->bdd->proteger($zone_geo['nouveau_code_geo']).','.
-														$this->proteger($zone_geo['insee_code']).','.
+						$this->bdd->proteger($zone_geo['insee_code']).','.
-														$this->proteger($zone_geo['name']).','.
+						$this->bdd->proteger($zone_geo['name']).','.
-														$this->proteger($zone_geo['sector']).','.
+						$this->bdd->proteger($zone_geo['sector']).','.
-														$this->proteger($zone_geo['x_utm']).','.
+						$this->bdd->proteger($zone_geo['x_utm']).','.
-														$this->proteger($zone_geo['y_utm']).','.
+						$this->bdd->proteger($zone_geo['y_utm']).','.
-														$this->proteger($lat_long['lat']).','.
+						$this->bdd->proteger($lat_long['lat']).','.
-														$this->proteger($lat_long['long']).','.
+						$this->bdd->proteger($lat_long['long']).','.
-														$this->proteger($zone_geo['update_date']).
+						$this->bdd->proteger($zone_geo['update_date']).
-														'),';
+						'),';
+				}
 				return;
+			}
 			if ($migration_zones_geo) {
 				$nbTotal ++;
-				$this->afficherAvancement('Migration des zones (par '.$pas.')', $nbTotal);
+				$this->script->afficherAvancement('Migration des zones (par '.$pas.')', $nbTotal);
 			} else {
 				exit('Erreur lors de la migration des zones géo '.$i.' à '.($i+$pas)."\n");
+			}
 		}
-		echo "\n---------------------------------------------------------------- OK\n\n";
+		echo "\n";
+	}
 		$pas = 1000;
 		$nbTotal = 0;
 		//Selectionner le nombre d'observations
 		$requeteNbObs = "SELECT COUNT(*) as nb FROM cel_inventory";
-		$resultatNbObs = $this->executerRequete($requeteNbObs);
-		$fin = $resultatNbObs[0]['nb'];
+		$fin = $this->bdd->requeter($requeteNbObs, Bdd::SQL_RETOUR_COLONNE);
+		for ($i = $debut; $i < $fin ; $i += $pas) {
-		for ($i = $debut; $i < $fin ; $i += $pas) {
+			$requete_selection_obs = 'SELECT * '.
+				'FROM cel_inventory '.
-			$requete_selection_obs = 'SELECT * FROM cel_inventory '.
+				'ORDER BY identifiant '.
-											'ORDER BY identifiant LIMIT '.$i.','.$pas;
+				'LIMIT '.$i.','.$pas;
-			$observations = $this->requeter($requete_selection_obs);
+			$observations = $this->bdd->requeter($requete_selection_obs);
 				$requete_insertion_observations = rtrim($requete_insertion_observations, ',');
 				$migration_observations = $this->executerRequeteSimple($requete_insertion_observations);
 			} else {
-				echo 'Fin de migration des observations '."\n"."\n";
+				echo "Fin de migration des observations\n";
 				return;
+			}
 			if ($migration_observations) {
 				$nbTotal ++;
-				$this->afficherAvancement('Migration des observations (par '.$pas.')', $nbTotal);
+				$this->script->afficherAvancement('Migration des observations (par '.$pas.')', $nbTotal);
 			} else {
+				exit('Erreur lors de la migration des observation de '.$i.' à '.($i+$pas)."\n");
 				exit('Erreur lors de la migration des observation de '.$i.' à '.($i+$pas)."\n");
-			}
+		}
 		echo "\n";
-		if (sizeof($this->communesOubliees) > 0) {
-			echo "\nxxxxxxxxx communes oubliées : ".sizeof($this->communesOubliees)." xxxxxxxxx \\n";
+		if (sizeof($this->communesOubliees) > 0) {
 			echo "xxxxxxxxx Communes ignorées : ".sizeof($this->communesOubliees)." xxxxxxxxx \n";
 		echo "\n---------------------------------------------------------------- OK\n\n";
+	}
 		return $nouvelle_obs;
+	}
 	private function protegerSiNonNull($valeur) {
 		if ($valeur != 'NULL') {
-			$valeur = $this->proteger($valeur);
+			$valeur = $this->bdd->proteger($valeur);
+		}
 		return $valeur;
+	}
+		}
 		return $retour;
+	}
 	private function traiterLat(&$observation) {
-		if ($this->etreNull($observation['coord_x'])) {
+		if ($this->bdd->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'])) {
+			if ($this->bdd->etreNull($observation['commentaire'])) {
 				$observation['commentaire'] = $latNote;
 			} else {
 				$observation['commentaire'] .= "\n".$latNote;
+			}
 		$retour = $observation['coord_x'];
 		return $retour;
+	}
 	private function traiterLng(&$observation) {
-		if ($this->etreNull($observation['coord_y'])) {
+		if ($this->bdd->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'])) {
+			if ($this->bdd->etreNull($observation['commentaire'])) {
 				$observation['commentaire'] = $lngNote;
 			} else {
 				$observation['commentaire'] .= "\n".$lngNote;
+			}
+	}
 	private function traiterNomUtilisateur($ligne_observation) {
 		$mail_observation = $ligne_observation['identifiant'];
-		$retour = '';
+		$retour = 'NULL';
 		if (isset($this->tableau_utilisateurs[$mail_observation])) {
 			$nom =  $this->tableau_utilisateurs[$mail_observation]['nom'];
 			$retour = self::formaterMotEnMajuscule($nom);
+		}
+		return $retour;
+	}
+	private function traiterCourrielUtilisateur($observation) {
+		$courriel = $observation['identifiant'];
+		$retour = 'NULL';
+		if ($this->mailValide($courriel)) {
+			$retour = $courriel;
+		}
+		return $retour;
 		return $retour;
 	public static function formaterMotPremiereLettreChaqueMotEnMajuscule($chaine, $encodage= 'UTF-8') {
     	$nom = str_replace("'",'_',$nom);
 		$nom = str_replace(' ','_',$nom);
 		$nom = str_replace('-','_',$nom);
 		$nom = str_replace('  ','_',$nom);
-		$indice = strtolower($nom).substr($id,0,2);
+		$indice = strtolower($nom).substr($id, 0, 2);
 		return $indice;
 		} else if ($utilisateur != '') {
 			// sinon si c'est un mail inconnu, on garde le md5
 			if ($this->mailValide($utilisateur)) {
 				$retour = md5($utilisateur);
+			}
+		} else if ($utilisateur == '') {
+			$retour = 'NULL';
+		}
 		return $retour;
+	}
-	public function mailValide($mail) {
+	private function mailValide($mail) {
 		// vérification bidon mais ça suffit pour ici
-		return !(strpos('@', $mail) === false);
+		return !(strpos($mail, '@') === false);
+	}
 	private function mettreANullPrenomNomVide() {
 		$bdd = self::$bdd_cel_migration;
 		$requete = 	"UPDATE $bdd.cel_obs ".
 				'SET prenom_utilisateur = NULL '.
 				"WHERE prenom_utilisateur = '' ";
-		$this->executer($requete);
+		$this->bdd->executer($requete);
 		$requete = 	"UPDATE $bdd.cel_obs ".
 				'SET nom_utilisateur = NULL '.
 				"WHERE nom_utilisateur = '' ";
-		$this->executer($requete);
+		$this->bdd->executer($requete);

Subversion Repositories eFlore/Applications.cel

(root)/trunk/jrest/scripts/MigrationObs.php @ 1497 – Rev 1200 → 1224