Subversion Repositories eFlore/Applications.cel

<?php

// declare(encoding='UTF-8');

/**

 * Script de migration des Mots Clés de la version 1 de la base de données du CEL à la v2.

 *

 * @category	php 5.2

 * @package		Cel/Scripts

 * @author		Aurélien 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.gnu.org/licenses/gpl.html Licence GNU-GPL

 * @version	$Id$

 */

class MigrationMotsCles extends Cel {

	const SEPARATEUR_MOT_CLE_TEXTE = ',';

	const truncate = true; //Doit on vider les tables de destination ?

	const dry_run = false;

	private $nouvellesTables = array('cel_mots_cles_obs', 'cel_mots_cles_images', 'cel_images_mots_cles', 'cel_obs_mots_cles');

	public static $bdd_cel_migration;

	public static $bdd_utilisateurs;

	private $tableau_utilisateurs = 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();

	/**

	 * 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 MOTS CLES --------------------------------------\n";

		if (self::truncate) {

			echo "-------------------------------------------------------------------\n\n";

			echo "  ETAPE 0. Vider les tables ... \n\n";

			echo "-------------------------------------------------------------------\n\n";

			$this->viderTables();

			echo "\n---------------------------------------------------------------- OK\n\n";

		}

		echo "-------------------------------------------------------------------\n\n";

		echo "  ETAPE 1. Paramétrage ... \n\n";

		echo "-------------------------------------------------------------------\n\n";

		$this->getUtilisateurs();

		echo "\n"."\n"."\n";

		echo "-------------------------------------------------------------------\n\n";

		echo "  ETAPE 2. Migration des mots clés ... \n\n";

		echo "-------------------------------------------------------------------\n\n";

		$this->migrerTableMotsClesObs();

		echo "\n---------------------------------------------------------------- OK\n\n";

		$this->migrerTableMotsClesImages();

		echo "\n"."\n"."\n";

		echo "-------------------------------------------------------------------\n\n";

		echo "  ETAPE 3. Migration des liaisons mots clés ... \n\n";

		echo "-------------------------------------------------------------------\n\n";

		$this->migrerLiaisonsMotsClesObs();

		$this->migrerLiaisonsMotsClesImages();

		echo "\n"."\n"."\n";

		echo "-------------------------------------------------------------------\n\n";

		echo "  ETAPE 4. Génération des index des mots clés ... \n\n";

		echo "-------------------------------------------------------------------\n\n";

		$this->genererIndexTexteMotsClesObs();

		$this->genererIndexTexteMotsClesImages();

		echo "\n"."\n"."\n";

	}

	private function viderTables() {

		foreach ($this->nouvellesTables as $nomTable) {

			echo 'Vider la table '.$nomTable.'...';

			$requete = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;

			$resultat = $this->executerRequete($requete);

			echo "ok \n";

		}

	}

	public 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 parent::executerRequeteSimple($requete);

		}

	}

	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 '.

			'FROM '.self::$bdd_utilisateurs.'.annuaire_tela';

		$tableau_utilisateurs = $this->executerRequete($requete);

		foreach( $tableau_utilisateurs as &$utilisateur) {

			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;

		}

		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";

		echo "\n-----------------------------------------------------------------OK\n";

	}

	private function migrerTableMotsClesObs() {

		$this->migrerTableMotsCles('obs');

	}

	private function migrerTableMotsClesImages() {

		$this->migrerTableMotsCles('images');

	}

	private function migrerTableMotsCles($image_ou_obs) {

		echo "--MIGRATION DES MOTS CLES $image_ou_obs ---------------------------------\n";

		$pas = 1;

		//limite des mots clés

		$requeteNbMotsCles = 'SELECT count(*) as nb FROM cel_mots_cles_'.$image_ou_obs;

		$resultatNbMotsCles = $this->executerRequete($requeteNbMotsCles);

		$nbMotsCles = (int) $resultatNbMotsCles[0]['nb'];

		for ($i = 0; $i < $nbMotsCles; $i += $pas) {

			$requete = 'SELECT * '.

				'FROM cel_mots_cles_'.$image_ou_obs.' '.

				'ORDER BY cmc_niveau '.

				"LIMIT $i,$pas ";

			$arbres_mots_cles = $this->executerRequete($requete);

			if (count($arbres_mots_cles) > 0) {

				$champ_parent = ($image_ou_obs == "obs") ? 'ce_mot_cle_obs_parent' : 'ce_mot_cle_image_parent';

				$champ_id = ($image_ou_obs == "obs") ? 'id_mot_cle_obs' : 'id_mot_cle_image';

				$requete = 'INSERT INTO '.self::$bdd_cel_migration.".cel_mots_cles_$image_ou_obs ".

						"($champ_id, id_utilisateur, mot_cle, md5, bg, bd, niveau, $champ_parent) ".

						'VALUES ';

				$sous_requete = array();

				foreach ($arbres_mots_cles as $arbre_mot_cle) {

					$sous_requete[] = $this->construireSousRequeteInsertionArbresMotsCles('cmc_', $arbre_mot_cle);

				}

				$sous_requete = implode(',', $sous_requete);

				$requete .= $sous_requete;

				$migration = $this->executerRequeteSimple($requete);

				if (!$migration) {

					echo  "La migration des mots cles $image_ou_obs a échoué ! "."\n";

				} else {

					$this->afficherAvancement("Migration des mots clés $image_ou_obs (par $pas)");

				}

			}

		}

	}

	/**

	 * 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++;

		} else {

			$actuel =& self::$avancement[$message];

			// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)

			$passage = 0;

			if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {

				$passage = 1;

			}

			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));

			echo $actuel++;

		}

	}

	private function construireSousRequeteInsertionArbresMotsCles($prefixe, $ligne) {

		$id_proprietaire_mot_cle = $ligne[$prefixe.'id_proprietaire'];

		$id_proprietaire_mot_cle = $this->renvoyerIdPourMigration($id_proprietaire_mot_cle);

		$sous_requete = '('.$this->proteger($ligne[$prefixe.'id_mot_cle_utilisateur']).','.

			$this->proteger($id_proprietaire_mot_cle).','.

			$this->proteger($ligne[$prefixe.'mot_cle']).','.

			$this->proteger($ligne[$prefixe.'id_mot_cle_general']).','.

			$this->proteger($ligne[$prefixe.'bg']).','.

			$this->proteger($ligne[$prefixe.'bd']).','.

			$this->proteger($ligne[$prefixe.'niveau']).','.

			$this->proteger($ligne[$prefixe.'id_parent']).

			')';

		return $sous_requete;

	}

	private function renvoyerIdPourMigration($utilisateur) {

		// si tout les test suivant échouent, on garde l'utilisateur tel quel

		// (cas de la chaine de session des utilisateur anonymes)

		$retour = $utilisateur;

		// si le mail correspond a un utilisateur de la bdd

		if (isset($this->tableau_utilisateurs[$utilisateur])) {

			// on renvoie son id

			$retour =  $this->tableau_utilisateurs[$utilisateur]['id'];

		} else {

			// sinon si c'est un mail inconnu, on garde le md5

			if ($this->mailValide($utilisateur)) {

				$retour = md5($utilisateur);

			}

		}

		return $retour;

	}

	public function mailValide($mail) {

		// vérification bidon mais ça suffit pour ici

		return !(strpos('@',$mail) === false);

	}

	private function migrerLiaisonsMotsClesObs() {

		$requete = 'SELECT mots_cles AS mots_cles, id AS id, identifiant AS id_utilisateur '.

				'FROM cel_inventory '.

				'WHERE mots_cles != "" '.

				'	AND mots_cles IS NOT NULL '.

				'ORDER BY identifiant ';

		$mots_cles_obs = $this->executerRequete($requete);

		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_obs_mots_cles '.

				'(id_observation, id_mot_cle_obs, id_utilisateur) '.

				'VALUES '.

				$this->construireSousRequeteInsertionLiaisons($mots_cles_obs, ';');

		$insertion = $this->executerRequeteSimple($requete);

		if (!$insertion) {

			echo 'La migration des mots cles obs a échoué ! '."\n";

		} else {

			echo "Migration des mots cles obs : OK\n\n";

		}

	}

	private function migrerLiaisonsMotsClesImages() {

		$requete = 'SELECT ci_meta_mots_cles AS mots_cles, ci_id_image AS id, ci_ce_utilisateur AS id_utilisateur '.

				'FROM cel_images '.

				'WHERE ci_meta_mots_cles != "" '.

				'	AND ci_meta_mots_cles IS NOT NULL '.

				'ORDER BY ci_ce_utilisateur';

		$mots_cles_images = $this->executerRequete($requete);

		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_images_mots_cles '.

				'(id_image, id_mot_cle_image, id_utilisateur) '.

				'VALUES '.

				$this->construireSousRequeteInsertionLiaisons($mots_cles_images, ',');

		$insertion = $this->executerRequeteSimple($requete);

		if (!$insertion) {

			echo 'La migration des mots cles images a échoué ! '."\n";

		} else {

			echo "Migration des mots cles images : OK\n\n";

		}

	}

	private function construireSousRequeteInsertionLiaisons($tableau_mots_cles, $separateur) {

		$sous_requete = array();

		foreach ($tableau_mots_cles as $element) {

			$mots_cles_ids = $this->parserMotsCles($element['mots_cles'], $separateur);

			foreach ($mots_cles_ids as $mot_cle_id) {

				$id = $this->proteger($element['id']);

				$id_mot_cle = $this->proteger($mot_cle_id);

				$id_utilisateur = $this->proteger($this->renvoyerIdPourMigration($element['id_utilisateur']));

				$sous_requete[] = "($id, $id_mot_cle, $id_utilisateur)";

			}

		}

		$sous_requete_chaine = implode(',', $sous_requete);

		return $sous_requete_chaine;

	}

	private function parserMotsCles($mot_cles, $separateur = ',') {

		$tableau_mots_cles = explode($separateur, $mot_cles);

		$tableau_mots_cles_formates = array();

		foreach ($tableau_mots_cles as $mot_cle) {

			$mot_cle = str_replace($separateur.$separateur, '', $mot_cle);

			$mot_cle = str_replace('null', '', $mot_cle);

			if ($this->estUnIdentifiantMotCle($mot_cle)) {

				// certains mots clés mal formatés contiennent des virgules

				if (strpos($mot_cle, ',') !== false) {

					$tab_mot_cle_mal_formate = explode(',', $mot_cle);

					foreach ( $tab_mot_cle_mal_formate as $mot_cle_mal_formate) {

						if ($this->estUnIdentifiantMotCle($mot_cle_mal_formate)) {

							$tableau_mots_cles_formates[$mot_cle_mal_formate] = $mot_cle_mal_formate;

						}

					}

				} else {

					// on met le mot clé dans sa propre case afin d'éviter

					// facilement les doublons provoqués par de mauvais formatages

					$tableau_mots_cles_formates[$mot_cle] = $mot_cle;

				}

			}

		}

		return $tableau_mots_cles_formates;

	}

	private function estUnIdentifiantMotCle($chaine) {

		return trim($chaine) != '' && preg_match('/^(?:[0-9]+\.[0-9]+|[-_a-z0-9]+(?:[.][-_a-z0-9]+)*)$/i', $chaine);

	}

	private function genererIndexTexteMotsClesObs() {

		$requete_selection_obs = 'SELECT DISTINCT id_observation, ce_utilisateur '.

			'FROM '.self::$bdd_cel_migration.'.cel_obs '.

			'WHERE id_observation IN (SELECT DISTINCT id_observation FROM '.self::$bdd_cel_migration.'.cel_mots_cles_obs) ';

		$obs_a_mots_cles = $this->requeter($requete_selection_obs);

		foreach ($obs_a_mots_cles as $obs) {

			$mots_cles_texte = $this->obtenirMotsClesTexte($obs['id_observation'], $obs['ce_utilisateur'], 'obs');

			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {

				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);

				$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine,$obs['id_observation'], $obs['ce_utilisateur'], 'obs');

				$this->afficherAvancement('Génération des index mots clés obs (par 1)');

			}

		}

		echo "\n-----------------------------------------------------------------OK\n";

	}

	private function genererIndexTexteMotsClesImages() {

		$requete_selection_images = 'SELECT DISTINCT id_image, ce_utilisateur '.

			'FROM '.self::$bdd_cel_migration.'.cel_images '.

			'WHERE id_image IN (SELECT DISTINCT id_image FROM '.self::$bdd_cel_migration.'.cel_mots_cles_images) ';

		$images_a_mots_cles = $this->requeter($requete_selection_images);

		foreach ($images_a_mots_cles as $image) {

			$mots_cles_texte = $this->obtenirMotsClesTexte($image['id_image'], $image['ce_utilisateur'], 'images');

			$mots_cles_texte_chaine = '';

			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {

				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);

				$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine,$image['id_image'], $image['ce_utilisateur'], 'images');

				$this->afficherAvancement('Génération des index mots clés images (par 1)');

			}

		}

		echo "\n-----------------------------------------------------------------OK\n";

	}

	private function executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $id_image_ou_obs, $id_utilisateur, $mode_image_ou_obs) {

		$requete = 	'UPDATE '.self::$bdd_cel_migration.'.'.(($mode_image_ou_obs == 'obs') ? 'cel_obs' : 'cel_images').' '.

			'SET mots_cles_texte = '.$this->proteger($mots_cles_texte_chaine).' '.

			'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).' '.

			'	AND ce_utilisateur = '.$this->proteger($id_utilisateur);

		return $this->executer($requete);

	}

	private function obtenirMotsClesTexte($id_image_ou_obs, $id_utilisateur, $mode_image_ou_obs) {

		$champ_id = ($mode_image_ou_obs == 'obs') ? 'id_mot_cle_obs' : 'id_mot_cle_image';

		$requete = 'SELECT mot_cle '.

			'FROM '.self::$bdd_cel_migration.'.cel_mots_cles_'.$mode_image_ou_obs.' '.

			"WHERE $champ_id IN ".

				'('.

					"SELECT $champ_id ".

					'FROM '.self::$bdd_cel_migration.'.cel_'.$mode_image_ou_obs.'_mots_cles '.

					'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).

				')'.

			' AND id_utilisateur = '.$this->proteger($id_utilisateur);

		$resultats = $this->requeter($requete);

		$mots_cles = array();

		foreach ($resultats as $resultat) {

			$mots_cles[] = $resultat['mot_cle'];

		}

		return $mots_cles;

	}

}