Subversion Repositories eFlore/Applications.cel

Rev

Rev 1181 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1181 Rev 1198
Line 1... Line 1...
1 
<?php
 1 
<?php
- 
 
 2 
// declare(encoding='UTF-8');
- 
 
 3 
/**
- 
 
 4 
 * Script de migration des Mots Clés de la version 1 de la base de données du CEL à la v2.
2 
 
 5 
 *
- 
 
 6 
 * @category	php 5.2
- 
 
 7 
 * @package		Cel/Scripts
- 
 
 8 
 * @author		Aurélien PERONNET <aurelien@tela-botanica.org>
- 
 
 9 
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
- 
 
 10 
 * @copyright	Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
- 
 
 11 
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
- 
 
 12 
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
- 
 
 13 
 * @version	$Id$
- 
 
 14 
 */
3 
class MigrationMotsCles extends Cel {
 15 
class MigrationMotsCles extends Cel {
4
16 
 
- 
 
 17 
	const SEPARATEUR_MOT_CLE_TEXTE = ',';
- 
 
 18 
	const truncate = true; //Doit on vider les tables de destination ?
- 
 
 19 
	const dry_run = false;
- 
 
 20 
 
- 
 
 21 
	private $nouvellesTables = array('cel_mots_cles_obs', 'cel_mots_cles_images', 'cel_images_mots_cles', 'cel_obs_mots_cles');
5 
	public static $bdd_cel_migration;
 22 
	public static $bdd_cel_migration;
6 
	public static $bdd_utilisateurs;
 23 
	public static $bdd_utilisateurs;
7 
	const SEPARATEUR_MOT_CLE_TEXTE = ',';
 - 
 
8
- 
 
9 
	const truncate = true; //Doit on vider les tables de destination ?
 - 
 
10
- 
 
11 
	const dry_run = false;
 - 
 
12
- 
 
13 
	private $tableau_utilisateurs = array();
 24 
	private $tableau_utilisateurs = array();
Line 14... Line 25...
14 
 
 25 
 
15 
	/** Tableau associatif permettant de stocker l'avancement dans une boucle.
 26 
	/** Tableau associatif permettant de stocker l'avancement dans une boucle.
16 
	* La clé est un md5 du message à afficher au démarrage de la boucle.
 27 
	* La clé est un md5 du message à afficher au démarrage de la boucle.
17 
	* @var array
 28 
	* @var array
18 
	*/
 29 
	*/
19 
	private static $avancement = array();
 30 
	private static $avancement = array();
20
31 
 
21 
	/**
 32 
	/**
22 
	 * Méthode appelée avec une requête de type GET.
 33 
	 * Méthode appelée avec une requête de type GET.
23 
	 */
 34 
	 */
24 
	public function getElement($params) {
 - 
 
25
35 
	public function getElement($params) {
26 
		if(!isset($this->config['database_cel']['database_migration']) || $this->config['database_cel']['database_migration'] == '') {
 36 
		if (!isset($this->config['database_cel']['database_migration']) || $this->config['database_cel']['database_migration'] == '') {
27 
			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";
 37 
			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";
28 
			exit;
 38 
			exit;
29 
		}
 39 
		}
30
40 
 
31 
		if(!isset($this->config['database_ident']['database']) || $this->config['database_ident']['database'] == '') {
 41 
		if (!isset($this->config['database_ident']['database']) || $this->config['database_ident']['database'] == '') {
32 
			echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n";
 42 
			echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n";
33 
			exit;
 43 
			exit;
34 
		}
 44 
		}
35
45 
 
36 
		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
 46 
		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
37 
		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
 47 
		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
38
48 
 
39 
		echo "--MIGRATION DES MOTS CLES --------------------------------------\n";
 - 
 
40 
		//1. TEMPORAIRE : vider les tables de destinations
 49 
		echo "--MIGRATION DES MOTS CLES --------------------------------------\n";
41 
		if (self::truncate) {
 50 
		if (self::truncate) {
42 
			echo "-------------------------------------------------------------------\n\n";
 51 
			echo "-------------------------------------------------------------------\n\n";
43 
			echo "  ETAPE 0. Vider les tables ... \n\n";
 52 
			echo "  ETAPE 0. Vider les tables ... \n\n";
44 
			echo "-------------------------------------------------------------------\n\n";
 - 
 
45 
			$nouvellesTables = array('`cel_mots_cles_obs`','`cel_mots_cles_images`', '`cel_images_mots_cles`', '`cel_obs_mots_cles`');
 - 
 
46 
			foreach ($nouvellesTables as $nomTable) {
 53 
			echo "-------------------------------------------------------------------\n\n";
47 
				echo 'Vider la table '.$nomTable.'...';
 - 
 
48 
				$requeteTruncate = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
 - 
 
49 
				$resultatTruncate = $this->executerRequete($requeteTruncate);
 - 
 
50 
				echo "ok \n";
 - 
 
51 
			}
 54 
			$this->viderTables();
52 
			echo "\n---------------------------------------------------------------- OK\n\n";
 55 
			echo "\n---------------------------------------------------------------- OK\n\n";
53 
		}
 56 
		}
54
57 
 
55 
		echo "-------------------------------------------------------------------\n\n";
 58 
		echo "-------------------------------------------------------------------\n\n";
56 
		echo "  ETAPE 1. Paramétrage ... \n\n";
 59 
		echo "  ETAPE 1. Paramétrage ... \n\n";
57 
		echo "-------------------------------------------------------------------\n\n";
 60 
		echo "-------------------------------------------------------------------\n\n";
58 
		$this->getUtilisateurs();
 61 
		$this->getUtilisateurs();
59 
		echo "\n"."\n"."\n";
 62 
		echo "\n"."\n"."\n";
60 
		echo "-------------------------------------------------------------------\n\n";
 63 
		echo "-------------------------------------------------------------------\n\n";
61 
		echo "  ETAPE 2. Migration des mots clés ... \n\n";
 64 
		echo "  ETAPE 2. Migration des mots clés ... \n\n";
62 
		echo "-------------------------------------------------------------------\n\n";
65 
		echo "-------------------------------------------------------------------\n\n";
63 
		$this->migrerTableMotsClesObs();
 66 
		$this->migrerTableMotsClesObs();
64 
		echo "\n---------------------------------------------------------------- OK\n\n";
 67 
		echo "\n---------------------------------------------------------------- OK\n\n";
65 
		$this->migrerTableMotsClesImages();
 68 
		$this->migrerTableMotsClesImages();
66 
		echo "\n"."\n"."\n";
 69 
		echo "\n"."\n"."\n";
67 
		echo "-------------------------------------------------------------------\n\n";
 70 
		echo "-------------------------------------------------------------------\n\n";
68 
		echo "  ETAPE 3. Migration des liaisons mots clés ... \n\n";
 71 
		echo "  ETAPE 3. Migration des liaisons mots clés ... \n\n";
69 
		echo "-------------------------------------------------------------------\n\n";
 72 
		echo "-------------------------------------------------------------------\n\n";
70 
		$this->migrerLiaisonsMotsClesObs();
 73 
		$this->migrerLiaisonsMotsClesObs();
71 
		$this->migrerLiaisonsMotsClesImages();
 74 
		$this->migrerLiaisonsMotsClesImages();
72 
		echo "\n"."\n"."\n";
 75 
		echo "\n"."\n"."\n";
73
76 
 
74 
		echo "-------------------------------------------------------------------\n\n";
 77 
		echo "-------------------------------------------------------------------\n\n";
75 
		echo "  ETAPE 4. Génération des index des mots clés ... \n\n";
 78 
		echo "  ETAPE 4. Génération des index des mots clés ... \n\n";
76 
		echo "-------------------------------------------------------------------\n\n";
 79 
		echo "-------------------------------------------------------------------\n\n";
77 
		$this->genererIndexTexteMotsClesObs();
 80 
		$this->genererIndexTexteMotsClesObs();
78 
		$this->genererIndexTexteMotsClesImages();
 81 
		$this->genererIndexTexteMotsClesImages();
79 
		echo "\n"."\n"."\n";
 82 
		echo "\n"."\n"."\n";
80 
	}
 83 
	}
- 
 
 84 
 
- 
 
 85 
	private function viderTables() {
- 
 
 86 
		foreach ($this->nouvellesTables as $nomTable) {
- 
 
 87 
			echo 'Vider la table '.$nomTable.'...';
- 
 
 88 
			$requete = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
- 
 
 89 
			$resultat = $this->executerRequete($requete);
- 
 
 90 
			echo "ok \n";
- 
 
 91 
		}
- 
 
 92 
	}
81
93 
 
82 
	public function executerRequeteSimple($requete) {
 94 
	public function executerRequeteSimple($requete) {
83 
		// Fonction de commodité pour afficher les requetes au lieu de les executer
 95 
		// Fonction de commodité pour afficher les requetes au lieu de les executer
84 
		if(self::dry_run) {
 96 
		if (self::dry_run) {
85 
			echo str_replace('),','),'."\n", $requete);
97 
			echo str_replace('),','),'."\n", $requete);
86 
			return true;
 98 
			return true;
87 
		} else {
 99 
		} else {
88 
			return parent::executerRequeteSimple($requete);
 100 
			return parent::executerRequeteSimple($requete);
Line 89... Line 101...
89 
		}
 101 
		}
90 
 
 102 
 
91 
	}
 103 
	}
92
104 
 
93
105 
 
94 
	private function getUtilisateurs() {
 106 
	private function getUtilisateurs() {
95 
		echo "\n-------------------------------------------------------------------\n";
 107 
		echo "\n-------------------------------------------------------------------\n";
96 
		echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n";
 108 
		echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n";
- 
 
 109 
 
97
110 
		$requete = 'SELECT U_ID as id, U_MAIL as mail, U_NAME as nom, U_SURNAME as prenom, U_PASSWD as pass '.
98 
		$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';
 111 
			'FROM '.self::$bdd_utilisateurs.'.annuaire_tela';
99 
		$tableau_utilisateurs = $this->executerRequete($requete_selection_utilisateurs);
 112 
		$tableau_utilisateurs = $this->executerRequete($requete);
100
113 
 
101 
		foreach( $tableau_utilisateurs as &$utilisateur) {
 114 
		foreach( $tableau_utilisateurs as &$utilisateur) {
102 
			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
 115 
			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
103 
		}
 116 
		}
104
117 
 
105 
		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";
 118 
		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";
106 
		echo "\n-----------------------------------------------------------------OK\n";
 - 
 
107 
	}
 - 
 
108
- 
 
109 
	private function migrerLiaisonsMotsClesObs() {
 - 
 
110 
		$requete_selection_mots_cles = 'SELECT mots_cles, id FROM cel_inventory '.
 - 
 
111 
										'WHERE mots_cles != "" AND mots_cles IS NOT NULL '.
 - 
 
112 
										'ORDER BY identifiant';
 - 
 
113
- 
 
114 
		$mots_cles_obs = $this->executerRequete($requete_selection_mots_cles);
 - 
 
115
- 
 
116 
		$mots_cles_tableau = array();
 - 
 
117
- 
 
118 
		$requete_insertion_mots_cles = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_obs_mots_cles '.
 - 
 
119 
										'(id_observation, id_mot_cle_obs) '.
 - 
 
120 
										'VALUES ';
 - 
 
121
- 
 
122 
		$sous_requete_insertion_valeurs = $sous_requete_insertion_mots_cles = $this->construireSousRequeteInsertionLiaisons($mots_cles_obs, 'mots_cles','id',';');
 - 
 
123 
		$requete_insertion_mots_cles = $requete_insertion_mots_cles.$sous_requete_insertion_valeurs;
 - 
 
124
- 
 
125 
		$insertion = $this->executerRequeteSimple($requete_insertion_mots_cles);
 - 
 
126
- 
 
127 
		if(!$insertion) {
 - 
 
128 
			echo 'la migration des mots cles obs a échoué ! '."\n";
 - 
 
129 
		} else {
 - 
 
130 
			echo "\n---------------------------------------------------------------- OK\n\n";
 - 
 
131 
		}
 - 
 
132
- 
 
133 
		echo "\n";
 - 
 
134 
	}
 - 
 
135
- 
 
136 
	private function migrerLiaisonsMotsClesImages() {
 - 
 
137
- 
 
138 
		$requete_selection_mots_cles = 'SELECT ci_meta_mots_cles, ci_id_image FROM cel_images '.
 - 
 
139 
										'WHERE ci_meta_mots_cles != "" AND ci_meta_mots_cles IS NOT NULL '.
 - 
 
140 
										'ORDER BY ci_ce_utilisateur';
 - 
 
141
- 
 
142 
		$mots_cles_images = $this->executerRequete($requete_selection_mots_cles);
 - 
 
143
- 
 
144 
		$mots_cles_tableau = array();
 - 
 
145
- 
 
146 
		$requete_insertion_mots_cles = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_images_mots_cles '.
 - 
 
147 
										'(id_image, id_mot_cle_image) '.
 - 
 
148 
										'VALUES ';
 - 
 
149 
		$sous_requete_insertion_mots_cles = $this->construireSousRequeteInsertionLiaisons($mots_cles_images, 'ci_meta_mots_cles','ci_id_image',',');
 - 
 
150
- 
 
151 
		$requete_insertion_mots_cles = $requete_insertion_mots_cles.$sous_requete_insertion_mots_cles;
 - 
 
152
- 
 
153 
		$insertion = $this->executerRequeteSimple($requete_insertion_mots_cles);
 - 
 
154
- 
 
155 
		if(!$insertion) {
 - 
 
156 
			echo 'la migration des mots cles images a échoué ! '."\n";
 - 
 
157 
		} else {
 - 
 
158 
			echo "\n---------------------------------------------------------------- OK\n\n";
 - 
 
159 
		}
 119 
		echo "\n-----------------------------------------------------------------OK\n";
160 
	}
 120 
	}
161
121 
 
162 
	private function migrerTableMotsClesObs() {
 122 
	private function migrerTableMotsClesObs() {
163 
		$this->migrerTableMotsCles('obs');
 123 
		$this->migrerTableMotsCles('obs');
164 
	}
 124 
	}
165
125 
 
166 
	private function migrerTableMotsClesImages() {
 126 
	private function migrerTableMotsClesImages() {
167 
		$this->migrerTableMotsCles('images');
 - 
 
168 
	}
 127 
		$this->migrerTableMotsCles('images');
169
- 
 
170
- 
 
171 
	/**
- 
 
172 
	 * Utiliser cette méthode dans une boucle pour afficher un message suivi du nombre de tour de boucle effectué.
 - 
 
173 
	 * Vous devrez vous même gérer le retour à la ligne à la sortie de la boucle.
- 
 
174 
	 *
- 
 
175 
	 * @param string le message d'information.
 - 
 
176 
	 * @param int le nombre de départ à afficher.
 - 
 
177 
	 * @return void le message est affiché dans la console.
 - 
 
178 
	 */
 - 
 
179 
	protected function afficherAvancement($message, $depart = 0) {
 - 
 
180 
		if (! isset(self::$avancement[$message])) {
 - 
 
181 
			self::$avancement[$message] = $depart;
 - 
 
182 
			echo "$message : ";
 - 
 
183
- 
 
184 
			$actuel =& self::$avancement[$message];
 - 
 
185 
			echo $actuel++;
 - 
 
186 
		} else {
 - 
 
187 
			$actuel =& self::$avancement[$message];
 - 
 
188
- 
 
189 
			// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)
 - 
 
190 
			$passage = 0;
 - 
 
191 
			if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {
 - 
 
192 
				$passage = 1;
- 
 
193 
			}
 - 
 
194
- 
 
195 
			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
 - 
 
196 
			echo $actuel++;
 - 
 
197 
		}
 - 
 
198 
	}
 128 
	}
199
129 
 
200 
	private function migrerTableMotsCles($image_ou_obs) {
 130 
	private function migrerTableMotsCles($image_ou_obs) {
201 
		echo "--MIGRATION DES MOTS CLES $image_ou_obs ---------------------------------\n";
 131 
		echo "--MIGRATION DES MOTS CLES $image_ou_obs ---------------------------------\n";
202 
		$pas = 1;
 132 
		$pas = 1;
203
133 
 
204 
		//limite des mots clés
 134 
		//limite des mots clés
205 
		$requeteNbMotsCles = 'SELECT count(*) as nb FROM cel_mots_cles_'.$image_ou_obs;
 135 
		$requeteNbMotsCles = 'SELECT count(*) as nb FROM cel_mots_cles_'.$image_ou_obs;
206 
		$resultatNbMotsCles = $this->executerRequete($requeteNbMotsCles);
 - 
 
207 
		$nbMotsCles = (int) $resultatNbMotsCles[0]['nb'];
 - 
 
208
136 
		$resultatNbMotsCles = $this->executerRequete($requeteNbMotsCles);
- 
 
 137 
		$nbMotsCles = (int) $resultatNbMotsCles[0]['nb'];
209 
		$nbTotal = 0;
 138 
		for ($i = 0; $i < $nbMotsCles; $i += $pas) {
- 
 
 139 
			$requete = 'SELECT * '.
210 
		for($i = 0; $i < $nbMotsCles; $i += $pas) {
 140 
				'FROM cel_mots_cles_'.$image_ou_obs.' '.
211 
			$requete_selection_arbres_mots_cles = 'SELECT * FROM cel_mots_cles_'.$image_ou_obs.' ORDER BY cmc_niveau '.
 141 
				'ORDER BY cmc_niveau '.
212 
													'LIMIT '.$i.','.$pas;
 142 
				"LIMIT $i,$pas ";
- 
 
 143 
			$arbres_mots_cles = $this->executerRequete($requete);
213 
			$arbres_mots_cles = $this->executerRequete($requete_selection_arbres_mots_cles);
 144 
 
214
145 
			if (count($arbres_mots_cles) > 0) {
215 
			$champ_parent = ($image_ou_obs == "obs") ? 'ce_mot_cle_obs_parent' : 'ce_mot_cle_image_parent';
 146 
				$champ_parent = ($image_ou_obs == "obs") ? 'ce_mot_cle_obs_parent' : 'ce_mot_cle_image_parent';
216 
			$champ_id = ($image_ou_obs == "obs") ? 'id_mot_cle_obs' : 'id_mot_cle_image';
 147 
				$champ_id = ($image_ou_obs == "obs") ? 'id_mot_cle_obs' : 'id_mot_cle_image';
217 
			$requete_insertion_nouvel_arbre = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_mots_cles_'.$image_ou_obs.' '.
 148 
				$requete = 'INSERT INTO '.self::$bdd_cel_migration.".cel_mots_cles_$image_ou_obs ".
218 
												'('.$champ_id.', ce_utilisateur, mot_cle, md5, bg, bd, niveau, '.$champ_parent.') '.
 - 
 
219 
												'VALUES ';
149 
						"($champ_id, id_utilisateur, mot_cle, md5, bg, bd, niveau, $champ_parent) ".
220 
			$sous_requete_insertion_nouvel_arbre = '';
 150 
						'VALUES ';
221
151 
 
222 
			if(count($arbres_mots_cles) > 0) {
 152 
				$sous_requete = array();
223 
				foreach($arbres_mots_cles as $arbre_mot_cle) {
 153 
				foreach ($arbres_mots_cles as $arbre_mot_cle) {
224 
					$sous_requete_insertion_nouvel_arbre .= $this->construireSousRequeteInsertionArbresMotsCles('cmc_', $arbre_mot_cle);
 - 
 
225 
				}
 154 
					$sous_requete[] = $this->construireSousRequeteInsertionArbresMotsCles('cmc_', $arbre_mot_cle);
- 
 
 155 
				}
226
156 
				$sous_requete = implode(',', $sous_requete);
227 
				$sous_requete_insertion_nouvel_arbre = rtrim($sous_requete_insertion_nouvel_arbre,',');
 - 
 
228
157 
				$requete .= $sous_requete;
229 
				$requete_insertion_nouvel_arbre = $requete_insertion_nouvel_arbre.$sous_requete_insertion_nouvel_arbre;
 158 
 
230 
				$migration = $this->executerRequeteSimple($requete_insertion_nouvel_arbre);
 159 
				$migration = $this->executerRequeteSimple($requete);
231 
				if(!$migration) {
 160 
				if (!$migration) {
232 
					echo  'la migration des mots cles '.$image_ou_obs.' a échoué ! '."\n";
 - 
 
233 
				} else {
 161 
					echo  "La migration des mots cles $image_ou_obs a échoué ! "."\n";
234 
					$nbTotal ++;
 162 
				} else {
235 
					$this->afficherAvancement('Migration des mots clés (par '.$pas.') :', $nbTotal);
 - 
 
236 
				}
 - 
 
237 
			} else {
 - 
 
238 
				echo "\n---------------------------------------------------------------- OK\n\n";
 163 
					$this->afficherAvancement("Migration des mots clés $image_ou_obs (par $pas)");
239 
				return;
 - 
 
240 
			}
 164 
				}
241
165 
			}
242 
		}
 166 
		}
- 
 
 167 
	}
- 
 
 168 
 
- 
 
 169 
	/**
- 
 
 170 
	 * Utiliser cette méthode dans une boucle pour afficher un message suivi du nombre de tour de boucle effectué.
- 
 
 171 
	 * Vous devrez vous même gérer le retour à la ligne à la sortie de la boucle.
- 
 
 172 
	 *
- 
 
 173 
	 * @param string le message d'information.
- 
 
 174 
	 * @param int le nombre de départ à afficher.
- 
 
 175 
	 * @return void le message est affiché dans la console.
- 
 
 176 
	 */
- 
 
 177 
	protected function afficherAvancement($message, $depart = 0) {
- 
 
 178 
		if (! isset(self::$avancement[$message])) {
- 
 
 179 
			self::$avancement[$message] = $depart;
- 
 
 180 
			echo "$message : ";
- 
 
 181 
 
- 
 
 182 
			$actuel =& self::$avancement[$message];
- 
 
 183 
			echo $actuel++;
- 
 
 184 
		} else {
- 
 
 185 
			$actuel =& self::$avancement[$message];
- 
 
 186 
 
- 
 
 187 
			// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)
- 
 
 188 
			$passage = 0;
- 
 
 189 
			if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {
- 
 
 190 
				$passage = 1;
- 
 
 191 
			}
- 
 
 192 
 
- 
 
 193 
			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
- 
 
 194 
			echo $actuel++;
- 
 
 195 
		}
243 
	}
 196 
	}
244
- 
 
245 
	private function construireSousRequeteInsertionArbresMotsCles($prefixe, $ligne) {
 197 
 
246
198 
	private function construireSousRequeteInsertionArbresMotsCles($prefixe, $ligne) {
247 
		$id_proprietaire_mot_cle = $ligne[$prefixe.'id_proprietaire'];
 199 
		$id_proprietaire_mot_cle = $ligne[$prefixe.'id_proprietaire'];
248 
		$id_proprietaire_mot_cle = $this->renvoyerIdPourMigration($id_proprietaire_mot_cle);
 200 
		$id_proprietaire_mot_cle = $this->renvoyerIdPourMigration($id_proprietaire_mot_cle);
249
201 
 
250 
		$sous_requete_insertion_valeurs = '('.$this->proteger($ligne[$prefixe.'id_mot_cle_utilisateur']).','.
 202 
		$sous_requete = '('.$this->proteger($ligne[$prefixe.'id_mot_cle_utilisateur']).','.
251 
													$this->proteger($id_proprietaire_mot_cle).','.
 203 
			$this->proteger($id_proprietaire_mot_cle).','.
252 
													$this->proteger($ligne[$prefixe.'mot_cle']).','.
 204 
			$this->proteger($ligne[$prefixe.'mot_cle']).','.
253 
													$this->proteger($ligne[$prefixe.'id_mot_cle_general']).','.
 205 
			$this->proteger($ligne[$prefixe.'id_mot_cle_general']).','.
254 
													$this->proteger($ligne[$prefixe.'bg']).','.
 206 
			$this->proteger($ligne[$prefixe.'bg']).','.
255 
													$this->proteger($ligne[$prefixe.'bd']).','.
 207 
			$this->proteger($ligne[$prefixe.'bd']).','.
256 
													$this->proteger($ligne[$prefixe.'niveau']).','.
 208 
			$this->proteger($ligne[$prefixe.'niveau']).','.
257 
													$this->proteger($ligne[$prefixe.'id_parent']).
 209 
			$this->proteger($ligne[$prefixe.'id_parent']).
- 
 
 210 
			')';
- 
 
 211 
		return $sous_requete;
- 
 
 212 
	}
- 
 
 213 
 
- 
 
 214 
	private function renvoyerIdPourMigration($utilisateur) {
- 
 
 215 
		// si tout les test suivant échouent, on garde l'utilisateur tel quel
- 
 
 216 
		// (cas de la chaine de session des utilisateur anonymes)
- 
 
 217 
		$retour = $utilisateur;
- 
 
 218 
		// si le mail correspond a un utilisateur de la bdd
- 
 
 219 
		if (isset($this->tableau_utilisateurs[$utilisateur])) {
- 
 
 220 
			// on renvoie son id
- 
 
 221 
			$retour =  $this->tableau_utilisateurs[$utilisateur]['id'];
- 
 
 222 
		} else {
- 
 
 223 
			// sinon si c'est un mail inconnu, on garde le md5
- 
 
 224 
			if ($this->mailValide($utilisateur)) {
- 
 
 225 
				$retour = md5($utilisateur);
- 
 
 226 
			}
- 
 
 227 
		}
- 
 
 228 
		return $retour;
- 
 
 229 
	}
- 
 
 230 
 
- 
 
 231 
	public function mailValide($mail) {
258 
													'),';
 232 
		// vérification bidon mais ça suffit pour ici
- 
 
 233 
		return !(strpos('@',$mail) === false);
- 
 
 234 
	}
- 
 
 235 
 
- 
 
 236 
	private function migrerLiaisonsMotsClesObs() {
- 
 
 237 
		$requete = 'SELECT mots_cles AS mots_cles, id AS id, identifiant AS id_utilisateur '.
- 
 
 238 
				'FROM cel_inventory '.
- 
 
 239 
				'WHERE mots_cles != "" '.
- 
 
 240 
				'	AND mots_cles IS NOT NULL '.
259 
		return $sous_requete_insertion_valeurs;
 241 
				'ORDER BY identifiant ';
- 
 
 242 
		$mots_cles_obs = $this->executerRequete($requete);
- 
 
 243 
 
- 
 
 244 
		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_obs_mots_cles '.
260 
	}
 245 
				'(id_observation, id_mot_cle_obs, id_utilisateur) '.
- 
 
 246 
				'VALUES '.
- 
 
 247 
				$this->construireSousRequeteInsertionLiaisons($mots_cles_obs, ';');
- 
 
 248 
 
- 
 
 249 
		$insertion = $this->executerRequeteSimple($requete);
- 
 
 250 
		if (!$insertion) {
- 
 
 251 
			echo 'La migration des mots cles obs a échoué ! '."\n";
- 
 
 252 
		} else {
- 
 
 253 
			echo "Migration des mots cles obs : OK\n\n";
- 
 
 254 
		}
- 
 
 255 
	}
- 
 
 256 
 
- 
 
 257 
	private function migrerLiaisonsMotsClesImages() {
- 
 
 258 
		$requete = 'SELECT ci_meta_mots_cles AS mots_cles, ci_id_image AS id, ci_ce_utilisateur AS id_utilisateur '.
- 
 
 259 
				'FROM cel_images '.
261
260 
				'WHERE ci_meta_mots_cles != "" '.
- 
 
 261 
				'	AND ci_meta_mots_cles IS NOT NULL '.
- 
 
 262 
				'ORDER BY ci_ce_utilisateur';
- 
 
 263 
		$mots_cles_images = $this->executerRequete($requete);
- 
 
 264 
 
- 
 
 265 
		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_images_mots_cles '.
- 
 
 266 
				'(id_image, id_mot_cle_image, id_utilisateur) '.
- 
 
 267 
				'VALUES '.
- 
 
 268 
				$this->construireSousRequeteInsertionLiaisons($mots_cles_images, ',');
- 
 
 269 
 
- 
 
 270 
		$insertion = $this->executerRequeteSimple($requete);
- 
 
 271 
 
- 
 
 272 
		if (!$insertion) {
- 
 
 273 
			echo 'La migration des mots cles images a échoué ! '."\n";
- 
 
 274 
		} else {
- 
 
 275 
			echo "Migration des mots cles images : OK\n\n";
262 
	private function construireSousRequeteInsertionLiaisons($tableau_mots_cles, $champ_mot_cle, $champ_id, $separateur) {
 276 
		}
- 
 
 277 
	}
- 
 
 278 
 
263 
		$sous_requete_insertion_valeurs = '';
 279 
	private function construireSousRequeteInsertionLiaisons($tableau_mots_cles, $separateur) {
264
280 
		$sous_requete = array();
265 
		foreach($tableau_mots_cles as $mot_cle_element) {
 281 
		foreach ($tableau_mots_cles as $element) {
- 
 
 282 
			$mots_cles_ids = $this->parserMotsCles($element['mots_cles'], $separateur);
- 
 
 283 
			foreach ($mots_cles_ids as $mot_cle_id) {
266 
			$mots_cles_tableau = $this->parserMotsCles($mot_cle_element[$champ_mot_cle],$separateur);
 284 
				$id = $this->proteger($element['id']);
- 
 
 285 
				$id_mot_cle = $this->proteger($mot_cle_id);
267 
			foreach($mots_cles_tableau as $mot_cle_en_cours) {
 286 
				$id_utilisateur = $this->proteger($this->renvoyerIdPourMigration($element['id_utilisateur']));
268 
				$sous_requete_insertion_valeurs .= '('.$mot_cle_element[$champ_id].','.$this->proteger($mot_cle_en_cours).'),';
 287 
				$sous_requete[] = "($id, $id_mot_cle, $id_utilisateur)";
269 
			}
 - 
 
270 
		}
 288 
			}
271
289 
		}
272 
		$sous_requete_insertion_valeurs = rtrim($sous_requete_insertion_valeurs,',');
 290 
		$sous_requete_chaine = implode(',', $sous_requete);
273 
		return $sous_requete_insertion_valeurs;
 291 
		return $sous_requete_chaine;
274 
	}
 292 
	}
- 
 
 293 
 
275
294 
	private function parserMotsCles($mot_cles, $separateur = ',') {
276 
	private function parserMotsCles($mot_cles, $separateur = ',') {
 - 
 
277
295 
		$tableau_mots_cles = explode($separateur, $mot_cles);
278 
		$tableau_mots_cles = explode($separateur,$mot_cles);
 - 
 
279 
		$tableau_mots_cles_formates = array();
 296 
 
280
- 
 
281 
		foreach($tableau_mots_cles as $mot_cle) {
 297 
		$tableau_mots_cles_formates = array();
282
298 
		foreach ($tableau_mots_cles as $mot_cle) {
283 
			$mot_cle = str_replace($separateur.$separateur,'',$mot_cle);
 299 
			$mot_cle = str_replace($separateur.$separateur, '', $mot_cle);
284 
			$mot_cle = str_replace('null','',$mot_cle);
 300 
			$mot_cle = str_replace('null', '', $mot_cle);
285
301 
 
286 
			if($this->estUnIdentifiantMotCle($mot_cle)) {
302 
			if ($this->estUnIdentifiantMotCle($mot_cle)) {
287 
				// certains mots clés mal formatés contiennent des virgules
 303 
				// certains mots clés mal formatés contiennent des virgules
288 
				if(strpos($mot_cle,',') !== false) {
 304 
				if (strpos($mot_cle, ',') !== false) {
289 
					$tab_mot_cle_mal_formate = explode(',',$mot_cle);
 305 
					$tab_mot_cle_mal_formate = explode(',', $mot_cle);
290
306 
 
291 
					foreach ( $tab_mot_cle_mal_formate as $mot_cle_mal_formate) {
 307 
					foreach ( $tab_mot_cle_mal_formate as $mot_cle_mal_formate) {
292 
						if($this->estUnIdentifiantMotCle($mot_cle_mal_formate)) {
 308 
						if ($this->estUnIdentifiantMotCle($mot_cle_mal_formate)) {
293 
							$tableau_mots_cles_formates[$mot_cle_mal_formate] = $mot_cle_mal_formate;
 309 
							$tableau_mots_cles_formates[$mot_cle_mal_formate] = $mot_cle_mal_formate;
294 
						}
 310 
						}
295 
					}
311 
					}
296 
				} else {
 312 
				} else {
297 
					// on met le mot clé dans sa propre case afin d'éviter
 313 
					// on met le mot clé dans sa propre case afin d'éviter
298 
					// facilement les doublons provoqués par de mauvais formatages
314 
					// facilement les doublons provoqués par de mauvais formatages
299 
					$tableau_mots_cles_formates[$mot_cle] = $mot_cle;
 315 
					$tableau_mots_cles_formates[$mot_cle] = $mot_cle;
300 
				}
 316 
				}
301 
			}
 - 
 
302 
		}
 317 
			}
303
318 
		}
304 
		return $tableau_mots_cles_formates;
 319 
		return $tableau_mots_cles_formates;
305 
	}
 320 
	}
306
321 
 
307 
	private function estUnIdentifiantMotCle($chaine) {
 322 
	private function estUnIdentifiantMotCle($chaine) {
308 
		return trim($chaine) != '' && preg_match('/[0-9A-Z]+\.[0-9A-Z]+/i', $chaine) ;
 323 
		return trim($chaine) != '' && preg_match('/^(?:[0-9]+\.[0-9]+|[-_a-z0-9]+(?:[.][-_a-z0-9]+)*)$/i', $chaine);
309 
	}
 324 
	}
310
325 
 
- 
 
 326 
	private function genererIndexTexteMotsClesObs() {
311 
	private function genererIndexTexteMotsClesObs() {
 327 
		$requete_selection_obs = 'SELECT DISTINCT id_observation, ce_utilisateur '.
312 
		$requete_selection_obs = 'SELECT DISTINCT id_observation, ce_utilisateur FROM '.self::$bdd_cel_migration.'.cel_obs '.
 328 
			'FROM '.self::$bdd_cel_migration.'.cel_obs '.
313 
			                              'WHERE id_observation IN (SELECT DISTINCT id_observation FROM '.self::$bdd_cel_migration.'.cel_mots_cles_obs) ';
 - 
 
314 
		$obs_a_mots_cles = $this->requeter($requete_selection_obs);
 329 
			'WHERE id_observation IN (SELECT DISTINCT id_observation FROM '.self::$bdd_cel_migration.'.cel_mots_cles_obs) ';
315 
		$nbTotal = 0;
 330 
		$obs_a_mots_cles = $this->requeter($requete_selection_obs);
316
331 
 
317 
		foreach($obs_a_mots_cles as $obs) {
 332 
		foreach ($obs_a_mots_cles as $obs) {
318 
			$mots_cles_texte = $this->obtenirMotsClesTexte($obs['id_observation'], $obs['ce_utilisateur'], 'obs');
 333 
			$mots_cles_texte = $this->obtenirMotsClesTexte($obs['id_observation'], $obs['ce_utilisateur'], 'obs');
319 
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
 334 
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
320 
				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);
 - 
 
321 
				$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine,$obs['id_observation'], $obs['ce_utilisateur'], 'obs');
 335 
				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);
322 
				$nbTotal ++;
 336 
				$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine,$obs['id_observation'], $obs['ce_utilisateur'], 'obs');
323 
				$this->afficherAvancement('Génération des index mots clés obs (par 1) :', $nbTotal);
 337 
				$this->afficherAvancement('Génération des index mots clés obs (par 1)');
324 
			}
 338 
			}
325 
		}
 339 
		}
326 
		echo "\n-----------------------------------------------------------------OK\n";
 340 
		echo "\n-----------------------------------------------------------------OK\n";
327 
	}
 341 
	}
328
342 
 
- 
 
 343 
	private function genererIndexTexteMotsClesImages() {
329 
	private function genererIndexTexteMotsClesImages() {
 344 
		$requete_selection_images = 'SELECT DISTINCT id_image, ce_utilisateur '.
330 
		$requete_selection_images = 'SELECT DISTINCT id_image, ce_utilisateur FROM '.self::$bdd_cel_migration.'.cel_images '.
 345 
			'FROM '.self::$bdd_cel_migration.'.cel_images '.
331 
		                              'WHERE id_image IN (SELECT DISTINCT id_image FROM '.self::$bdd_cel_migration.'.cel_mots_cles_images) ';
 - 
 
332 
		$images_a_mots_cles = $this->requeter($requete_selection_images);
 346 
			'WHERE id_image IN (SELECT DISTINCT id_image FROM '.self::$bdd_cel_migration.'.cel_mots_cles_images) ';
333 
		$nbTotal = 0;
 347 
		$images_a_mots_cles = $this->requeter($requete_selection_images);
334
348 
 
335 
		foreach($images_a_mots_cles as $image) {
 349 
		foreach ($images_a_mots_cles as $image) {
336 
			$mots_cles_texte = $this->obtenirMotsClesTexte($image['id_image'], $image['ce_utilisateur'], 'images');
 350 
			$mots_cles_texte = $this->obtenirMotsClesTexte($image['id_image'], $image['ce_utilisateur'], 'images');
337 
			$mots_cles_texte_chaine = '';
 351 
			$mots_cles_texte_chaine = '';
338 
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
 352 
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
339 
				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);
 - 
 
340 
				$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine,$image['id_image'], $image['ce_utilisateur'], 'images');
 353 
				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);
341 
				$nbTotal ++;
 354 
				$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine,$image['id_image'], $image['ce_utilisateur'], 'images');
342 
				$this->afficherAvancement('Génération des index  mots clés images (par 1) :', $nbTotal);
 355 
				$this->afficherAvancement('Génération des index mots clés images (par 1)');
343 
			}
 356 
			}
344 
		}
 357 
		}
345 
		echo "\n-----------------------------------------------------------------OK\n";
 358 
		echo "\n-----------------------------------------------------------------OK\n";
346 
	}
 359 
	}
347
360 
 
348 
	private function executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $id_image_ou_obs, $identifiant_utilisateur, $mode_image_ou_obs) {
 361 
	private function executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $id_image_ou_obs, $id_utilisateur, $mode_image_ou_obs) {
349 
		$requete = 	'UPDATE '.self::$bdd_cel_migration.'.'.(($mode_image_ou_obs == 'obs') ? 'cel_obs' : 'cel_images').' '.
 362 
		$requete = 	'UPDATE '.self::$bdd_cel_migration.'.'.(($mode_image_ou_obs == 'obs') ? 'cel_obs' : 'cel_images').' '.
350 
						'SET mots_cles_texte = '.$this->proteger($mots_cles_texte_chaine).' '.
 363 
			'SET mots_cles_texte = '.$this->proteger($mots_cles_texte_chaine).' '.
351 
						'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).
 364 
			'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).' '.
352 
						' AND ce_utilisateur = '.$this->proteger($identifiant_utilisateur);
 365 
			'	AND ce_utilisateur = '.$this->proteger($id_utilisateur);
353
366 
 
354 
		return $this->executer($requete);
 367 
		return $this->executer($requete);
355 
	}
 368 
	}
356
- 
 
357 
	private function obtenirMotsClesTexte($id_image_ou_obs, $identifiant_utilisateur, $mode_image_ou_obs) {
 369 
 
358
370 
	private function obtenirMotsClesTexte($id_image_ou_obs, $id_utilisateur, $mode_image_ou_obs) {
359 
		$champ_id = ($mode_image_ou_obs == 'obs') ? 'id_mot_cle_obs' : 'id_mot_cle_image';
 371 
		$champ_id = ($mode_image_ou_obs == 'obs') ? 'id_mot_cle_obs' : 'id_mot_cle_image';
360
372 
 
361 
		$requete = 	'SELECT mot_cle '.
 373 
		$requete = 'SELECT mot_cle '.
362 
						'FROM '.self::$bdd_cel_migration.'.cel_mots_cles_'.$mode_image_ou_obs.' '.
 374 
			'FROM '.self::$bdd_cel_migration.'.cel_mots_cles_'.$mode_image_ou_obs.' '.
363 
						'WHERE '.$champ_id.' IN '.
 375 
			"WHERE $champ_id IN ".
364 
							'('.
 376 
				'('.
365 
								'SELECT '.$champ_id.' '.
 377 
					"SELECT $champ_id ".
366 
								'FROM '.self::$bdd_cel_migration.'.cel_'.$mode_image_ou_obs.'_mots_cles '.
 378 
					'FROM '.self::$bdd_cel_migration.'.cel_'.$mode_image_ou_obs.'_mots_cles '.
367 
								'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).
 379 
					'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).
368 
							')'.
 - 
 
369 
						' AND ce_utilisateur = '.$this->proteger($identifiant_utilisateur);
 380 
				')'.
- 
 
 381 
			' AND id_utilisateur = '.$this->proteger($id_utilisateur);
370
382 
		$resultats = $this->requeter($requete);
371 
		$resultats = $this->requeter($requete);
383 
 
372 
		$mots_cles = array();
 384 
		$mots_cles = array();
373 
		foreach($resultats as $resultat) {
 385 
		foreach ($resultats as $resultat) {
374 
			$mots_cles[] = $resultat['mot_cle'];
 386 
			$mots_cles[] = $resultat['mot_cle'];
375 
		}
 387 
		}
376
388 
 
377 
		return $mots_cles;
 - 
 
378 
	}
 - 
 
379
- 
 
380 
	private function renvoyerIdPourMigration($utilisateur) {
 - 
 
381 
		// si tout les test suivant échouent, on garde l'utilisateur tel quel
 - 
 
382 
		// (cas de la chaine de session des utilisateur anonymes)
 - 
 
383 
		$retour = $utilisateur;
 - 
 
384 
		// si le mail correspond a un utilisateur de la bdd
 - 
 
385 
		if (isset($this->tableau_utilisateurs[$utilisateur])) {
 - 
 
386 
			// on renvoie son id
 - 
 
387 
			$retour =  $this->tableau_utilisateurs[$utilisateur]['id'];
 - 
 
388 
		} else {
 - 
 
389 
			// sinon si c'est un mail inconnu, on garde le md5
 - 
 
390 
			if($this->mailValide($utilisateur)) {
 - 
 
391 
				$retour = md5($utilisateur);
 - 
 
392 
			}
 - 
 
393 
		}
 - 
 
394
- 
 
395 
		return $retour;
 - 
 
396 
	}
 - 
 
397
- 
 
398 
	public function mailValide($mail) {
 - 
 
399 
		// vérification bidon mais ça suffit pour ici
 - 
 
400 
		return !(strpos('@',$mail) === false);
389 
		return $mots_cles;
401 
	}
 390 
	}