Subversion Repositories eFlore/Applications.cel

<?php

class MigrationMotsCles extends Cel {

	const bdd_cel_migration = 'cel';

	const bdd_utilisateurs = 'cel_old';

	const dry_run = true;

	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) {

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

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

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

		$this->getUtilisateurs();

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

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

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

		$this->migrerTableMotsClesObs();

		$this->migrerTableMotsClesImages();

		echo "\n"."\n".'|| Migration des tables de liaison des mots clés ||'."\n";

		$this->migrerLiaisonsMotsClesObs();

		$this->migrerLiaisonsMotsClesImages();

		echo "\n"."\n"."\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_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);

		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 migrerLiaisonsMotsClesObs() {

		$requete_selection_mots_cles = 'SELECT mots_cles, id FROM cel_inventory '.

										'WHERE mots_cles != "" AND mots_cles IS NOT NULL '.

										'ORDER BY identifiant';

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

		$mots_cles_tableau = array();

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

										'(id_observation, id_mot_cle_utilisateur) '.

										'VALUES ';

		$sous_requete_insertion_valeurs = $sous_requete_insertion_mots_cles = $this->construireSousRequeteInsertionLiaisons($mots_cles_obs, 'mots_cles','id',';');

		$requete_insertion_mots_cles = $requete_insertion_mots_cles.$sous_requete_insertion_valeurs;

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

		if(!$insertion) {

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

		} else {

			echo 'migration des mots cles obs réussie '."\n";

		}

		echo "\n";

	}

	private function migrerLiaisonsMotsClesImages() {

		$requete_selection_mots_cles = 'SELECT ci_meta_mots_cles, ci_id_image 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_selection_mots_cles);

		$mots_cles_tableau = array();

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

										'(id_image, id_mot_cle_utilisateur) '.

										'VALUES ';

		$sous_requete_insertion_mots_cles = $this->construireSousRequeteInsertionLiaisons($mots_cles_images, 'ci_meta_mots_cles','ci_id_image',',');

		$requete_insertion_mots_cles = $requete_insertion_mots_cles.$sous_requete_insertion_mots_cles;

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

		if(!$insertion) {

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

		} else {

			echo 'migration des mots cles images réussie '."\n";

		}

	}

	private function migrerTableMotsClesObs() {

		$this->migrerTableMotsCles('obs');

	}

	private function migrerTableMotsClesImages() {

		$this->migrerTableMotsCles('images');

	}

	/**

	 * 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 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'];

		$nbTotal = 0;

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

			$requete_selection_arbres_mots_cles = 'SELECT * FROM cel_mots_cles_'.$image_ou_obs.' ORDER BY cmc_niveau '.

													'LIMIT '.$i.','.$pas;

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

			$requete_insertion_nouvel_arbre = 'INSERT INTO '.self::bdd_cel_migration.'.cel_mots_cles_'.$image_ou_obs.' '.

												'(id_mot_cle_utilisateur, ce_utilisateur, mot_cle, md5, bg, bd, niveau, ce_mot_cle_utilisateur_parent) '.

												'VALUES ';

			$sous_requete_insertion_nouvel_arbre = '';

			if(count($arbres_mots_cles) > 0) {

				foreach($arbres_mots_cles as $arbre_mot_cle) {

					$sous_requete_insertion_nouvel_arbre .= $this->construireSousRequeteInsertionArbresMotsCles('cmc_', $arbre_mot_cle);

				}

				$sous_requete_insertion_nouvel_arbre = rtrim($sous_requete_insertion_nouvel_arbre,',');

				$requete_insertion_nouvel_arbre = $requete_insertion_nouvel_arbre.$sous_requete_insertion_nouvel_arbre;

				//echo var_dump($requete_insertion_nouvel_arbre);

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

				if(!$migration) {

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

				} else {

					$nbTotal ++;

					$this->afficherAvancement('Migration des mots clés (par '.$pas.') :', $nbTotal);

				}

			} else {

				return;

			}

		}

	}

	private function construireSousRequeteInsertionArbresMotsCles($prefixe, $ligne) {

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

		if(isset($this->tableau_utilisateurs[$ligne[$prefixe.'id_proprietaire']])) {

			$id_proprietaire_mot_cle = $this->tableau_utilisateurs[$ligne[$prefixe.'id_proprietaire']]['id'];

		}

		$sous_requete_insertion_valeurs = '('.$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_insertion_valeurs;

	}

	private function construireSousRequeteInsertionLiaisons($tableau_mots_cles, $champ_mot_cle, $champ_id, $separateur) {

		$sous_requete_insertion_valeurs = '';

		foreach($tableau_mots_cles as $mot_cle_element) {

			$mots_cles_tableau = $this->parserMotsCles($mot_cle_element[$champ_mot_cle],$separateur);

			foreach($mots_cles_tableau as $mot_cle_en_cours) {

				$sous_requete_insertion_valeurs .= '('.$mot_cle_element[$champ_id].','.$this->proteger($mot_cle_en_cours).'),';

			}

		}

		$sous_requete_insertion_valeurs = rtrim($sous_requete_insertion_valeurs,',');

		return $sous_requete_insertion_valeurs;

	}

	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-9A-Z]+\.[0-9A-Z]+/i', $chaine) ;

	}

}