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

 <?php
 class MigrationObs extends Cel {
-	const bdd_cel_migration = 'cel';
+	public static $bdd_cel_migration;
-	const bdd_utilisateurs = 'cel_old';
+	public static $bdd_utilisateurs;
 	const truncate = true; //Doit on vider les tables de destination ?
-	const dry_run = true;
+	const dry_run = false;
 	/**
 	 * Méthode appelée avec une requête de type GET.
 	 */
 	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'];
 		echo "--MIGRATION DES OBSERVATIONS --------------------------------------\n";
 		//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`;',
 								'`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;
+				$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_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';
+		$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';
 		$tableau_utilisateurs = $this->executerRequete($requete_selection_utilisateurs);
 		$pas = 1000;
 		$nbTotal = 0;
 		$tabUtilisateurs = $this->tableau_utilisateurs;
 		while (!empty($tabUtilisateurs)) {
-			$requete_insertion_utilisateurs = 'INSERT INTO '.self::bdd_cel_migration.'.cel_utilisateurs '.
+			$requete_insertion_utilisateurs = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_utilisateurs '.
 						'(id_utilisateur, prenom, nom, courriel, mot_de_passe) '.
 						'VALUES ';
 			$sous_requete_insertion = '';
 			if ($migration_utilisateurs) {
 				$nbTotal ++;
 				$this->afficherAvancement('Migration utilisateurs (par '.$pas.')', $nbTotal);
-			} else {
-				exit($requete_insertion_utilisateurs);
+			} else {
 				exit('Erreur lors de la migration des utilisateurs '."\n");
+			}
+		}
 			$requete_selection_zones_geo = 'SELECT * FROM locations LIMIT '.$i.', '.$pas;
 			$zones_geo = $this->executerRequete($requete_selection_zones_geo);
-			$requete_insertion_nouvelles_zones_geo = 'INSERT INTO '.self::bdd_cel_migration.'.cel_zones_geo '.
+			$requete_insertion_nouvelles_zones_geo = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_zones_geo '.
 		for ($i = $debut; $i < $fin ; $i += $pas) {
 			$requete_selection_obs = 'SELECT * FROM cel_inventory '.
 											'ORDER BY identifiant LIMIT '.$i.','.$pas;
 			$observations = $this->requeter($requete_selection_obs);
-			$requete_insertion_observations = 'INSERT IGNORE INTO '.self::bdd_cel_migration.'.cel_obs (';
+			$requete_insertion_observations = 'INSERT IGNORE INTO '.self::$bdd_cel_migration.'.cel_obs (';
 			foreach ($this->tableau_nouveau_ancien as $nouveau_champ => $ancien_champ) {
 			if (count($observations) > 0) {
 				foreach($observations as $observation) {
 					$nouvelle_observation = $this->traiterLigneObservation($observation);
-					$nouvelle_observation = array_map(array($this,'proteger'),$nouvelle_observation);
+					$nouvelle_observation = array_map(array($this,'protegerSiNonNull'),$nouvelle_observation);
 					$requete_insertion_observations .= '('.join(',',array_values($nouvelle_observation)).'),';
+				}
 				$requete_insertion_observations = rtrim($requete_insertion_observations, ',');
 				$requete_insertion_observations = rtrim($requete_insertion_observations, ',');
 				$migration_observations = $this->executerRequeteSimple($requete_insertion_observations);
-				//exit($requete_insertion_observations);
+				$migration_observations = $this->executerRequeteSimple($requete_insertion_observations);
 			} else {
 				exit('Erreur lors de la migration des observation de '.$i.' à '.($i+$pas)."\n");
+			}
+		}
 		if (sizeof($this->communesOubliees) > 0) {
-			echo "\nxxxxxxxxx communes oubliées : ".sizeof($this->communnesOubliees)." xxxxxxxxx \\n";
+			echo "\nxxxxxxxxx communes oubliées : ".sizeof($this->communesOubliees)." xxxxxxxxx \\n";
-			echo var_dump(array_keys($this->communesOubliees));
+		}
 		echo "\n---------------------------------------------------------------- OK\n\n";
+	}
 				} else {
 					$nouvelle_obs[$nouveau_champ_obs] = '';
+				}
+			} else {
+				if($obs[$ancien_champ_obs] == '000null' || $obs[$ancien_champ_obs] == 'null' || trim($obs[$ancien_champ_obs]) == '') {
+					$obs[$ancien_champ_obs] = 'NULL';
+				}
+				if(($ancien_champ_obs == 'coord_x' || $ancien_champ_obs == 'coord_y') && ($obs[$ancien_champ_obs] == '0' || $obs[$ancien_champ_obs] == 0)) {
+					$obs[$ancien_champ_obs] = 'NULL';
+				}
 			} else {
 				$nouvelle_obs[$nouveau_champ_obs] = $obs[$ancien_champ_obs];
+			}
+		}
 		return $nouvelle_obs;
+	}
+	private function protegerSiNonNull($valeur) {
+		if($valeur != 'NULL') {
+			$valeur = $this->proteger($valeur);
+		}
+		return $valeur;
+	}
 	private function estUnChampATraiter($champ) {
 		return strpos($champ,'traiter') !== false;
 		$mail_observation = $ligne_observation['identifiant'];
 		$retour = $ligne_observation['mots_cles'];
 		if (isset($this->tableau_mots_cles[$mail_observation])) {
 			$mots_cles_tableau = $this->parserMotsCles($mail_observation, $ligne_observation['mots_cles'], ';');
-			$retour =  join(';',$mots_cles_tableau);
+			$retour =  join(',',$mots_cles_tableau);
-			$retour = ltrim($retour,';;') ;
+			$retour = ltrim($retour,',,') ;
+		}
 		$mail_observation = $ligne_observation['identifiant'];
 		$retour = $mail_observation;
 		if (isset($this->tableau_utilisateurs[$mail_observation])) {
-			$retour =  $this->tableau_utilisateurs[$mail_observation]['prenom'];
-		} else {
+			$retour =  $this->tableau_utilisateurs[$mail_observation]['prenom'];
+		}
+			}
 			$zone_geo .= $id_zone_geo_ancienne;
+		} elseif($ligne_observation['location'] == null || $ligne_observation['location'] == "" || $ligne_observation['location'] == "000null") {
-		} elseif($ligne_observation['location'] == null || $ligne_observation['location'] == "" || $ligne_observation['location'] == "000null") {
+			if($ligne_observation['id_location'] != '' && $ligne_observation['id_location'] != '000null') {
-			$id_zone_geo_ancienne = $ligne_observation['id_location'];
+				$id_zone_geo_ancienne = $ligne_observation['id_location'];
+				$id_zone_geo_ancienne = $id_zone_geo_ancienne;
+				$zone_geo = $id_zone_geo_ancienne;
+			} else {
-			$id_zone_geo_ancienne = $id_zone_geo_ancienne;
+				$zones_geo = 'NULL';
 			$zone_geo = $id_zone_geo_ancienne;
+		}
 			} else {
 				if($ligne_observation['location'] != "000null") {
 					$this->communesOubliees[$indice] = false;
+				}
+			}
+		} else {
+			$id_zone_geo = 'NULL';
+		}
 		return $id_zone_geo;

Subversion Repositories eFlore/Applications.cel

(root)/trunk/jrest/services/MigrationObs.php @ 1180 – Rev 1149 → 1158