Subversion Repositories eFlore/Applications.cel

Rev

Rev 1181 | Go to most recent revision | Show entire file | Regard 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 {
Line 4... Line -...
4
	
-
 
5
	public static $bdd_cel_migration;
-
 
6
	public static $bdd_utilisateurs;
16
 
7
	const SEPARATEUR_MOT_CLE_TEXTE = ',';
-
 
8
	
17
	const SEPARATEUR_MOT_CLE_TEXTE = ',';
9
	const truncate = true; //Doit on vider les tables de destination ?
-
 
10
	
18
	const truncate = true; //Doit on vider les tables de destination ?
Line -... Line 19...
-
 
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');
11
	const dry_run = false;
22
	public static $bdd_cel_migration;
Line 12... Line 23...
12
	
23
	public static $bdd_utilisateurs;
13
	private $tableau_utilisateurs = array();
24
	private $tableau_utilisateurs = array();
14
 
25
 
Line 20... Line 31...
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;
Line 35... Line 45...
35
		
45
 
36
		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
46
		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
Line 37... Line 47...
37
		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
47
		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
38
		
-
 
39
		echo "--MIGRATION DES MOTS CLES --------------------------------------\n";
48
 
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";
-
 
44
			echo "-------------------------------------------------------------------\n\n";
-
 
45
			$nouvellesTables = array('`cel_mots_cles_obs`','`cel_mots_cles_images`', '`cel_images_mots_cles`', '`cel_obs_mots_cles`');
52
			echo "  ETAPE 0. Vider les tables ... \n\n";
46
			foreach ($nouvellesTables as $nomTable) {
-
 
47
				echo 'Vider la table '.$nomTable.'...';
-
 
48
				$requeteTruncate = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
-
 
49
				$resultatTruncate = $this->executerRequete($requeteTruncate);
-
 
50
				echo "ok \n";
53
			echo "-------------------------------------------------------------------\n\n";
51
			}
54
			$this->viderTables();
Line 52... Line 55...
52
			echo "\n---------------------------------------------------------------- OK\n\n";
55
			echo "\n---------------------------------------------------------------- OK\n\n";
53
		}
56
		}
Line 77... Line 80...
77
		$this->genererIndexTexteMotsClesObs();
80
		$this->genererIndexTexteMotsClesObs();
78
		$this->genererIndexTexteMotsClesImages();
81
		$this->genererIndexTexteMotsClesImages();
79
		echo "\n"."\n"."\n";
82
		echo "\n"."\n"."\n";
80
	}
83
	}
Line -... Line 84...
-
 
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);
Line 93... Line 105...
93
	
105
 
94
	private function getUtilisateurs() {
106
	private function getUtilisateurs() {
95
		echo "\n-------------------------------------------------------------------\n";
107
		echo "\n-------------------------------------------------------------------\n";
Line 96... Line 108...
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 '.
Line 98... Line 111...
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
 
Line 101... Line 114...
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
		}
Line 104... Line 117...
104
	
117
 
105
		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 '.
118
		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";
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
		
119
		echo "\n-----------------------------------------------------------------OK\n";
Line -... Line 120...
-
 
120
	}
127
		if(!$insertion) {
121
 
128
			echo 'la migration des mots cles obs a échoué ! '."\n";
122
	private function migrerTableMotsClesObs() {
Line 129... Line 123...
129
		} else {
123
		$this->migrerTableMotsCles('obs');
130
			echo "\n---------------------------------------------------------------- OK\n\n";
-
 
131
		}
124
	}
132
		
-
 
133
		echo "\n";
125
 
134
	}
-
 
135
	
-
 
Line -... Line 126...
-
 
126
	private function migrerTableMotsClesImages() {
-
 
127
		$this->migrerTableMotsCles('images');
-
 
128
	}
-
 
129
 
-
 
130
	private function migrerTableMotsCles($image_ou_obs) {
-
 
131
		echo "--MIGRATION DES MOTS CLES $image_ou_obs ---------------------------------\n";
136
	private function migrerLiaisonsMotsClesImages() {
132
		$pas = 1;
-
 
133
 
-
 
134
		//limite des mots clés
-
 
135
		$requeteNbMotsCles = 'SELECT count(*) as nb FROM cel_mots_cles_'.$image_ou_obs;
Line -... Line 136...
-
 
136
		$resultatNbMotsCles = $this->executerRequete($requeteNbMotsCles);
-
 
137
		$nbMotsCles = (int) $resultatNbMotsCles[0]['nb'];
-
 
138
		for ($i = 0; $i < $nbMotsCles; $i += $pas) {
137
		
139
			$requete = 'SELECT * '.
138
		$requete_selection_mots_cles = 'SELECT ci_meta_mots_cles, ci_id_image FROM cel_images '.
140
				'FROM cel_mots_cles_'.$image_ou_obs.' '.
139
										'WHERE ci_meta_mots_cles != "" AND ci_meta_mots_cles IS NOT NULL '.
141
				'ORDER BY cmc_niveau '.
140
										'ORDER BY ci_ce_utilisateur';
-
 
141
										
-
 
142
		$mots_cles_images = $this->executerRequete($requete_selection_mots_cles);
-
 
Line -... Line 142...
-
 
142
				"LIMIT $i,$pas ";
-
 
143
			$arbres_mots_cles = $this->executerRequete($requete);
143
		
144
 
-
 
145
			if (count($arbres_mots_cles) > 0) {
-
 
146
				$champ_parent = ($image_ou_obs == "obs") ? 'ce_mot_cle_obs_parent' : 'ce_mot_cle_image_parent';
-
 
147
				$champ_id = ($image_ou_obs == "obs") ? 'id_mot_cle_obs' : 'id_mot_cle_image';
Line -... Line 148...
-
 
148
				$requete = 'INSERT INTO '.self::$bdd_cel_migration.".cel_mots_cles_$image_ou_obs ".
144
		$mots_cles_tableau = array();
149
						"($champ_id, id_utilisateur, mot_cle, md5, bg, bd, niveau, $champ_parent) ".
145
		
150
						'VALUES ';
146
		$requete_insertion_mots_cles = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_images_mots_cles '.
151
 
147
										'(id_image, id_mot_cle_image) '.
152
				$sous_requete = array();
148
										'VALUES ';
153
				foreach ($arbres_mots_cles as $arbre_mot_cle) {
149
		$sous_requete_insertion_mots_cles = $this->construireSousRequeteInsertionLiaisons($mots_cles_images, 'ci_meta_mots_cles','ci_id_image',',');
154
					$sous_requete[] = $this->construireSousRequeteInsertionArbresMotsCles('cmc_', $arbre_mot_cle);
150
		
-
 
151
		$requete_insertion_mots_cles = $requete_insertion_mots_cles.$sous_requete_insertion_mots_cles;
-
 
152
		
-
 
153
		$insertion = $this->executerRequeteSimple($requete_insertion_mots_cles);
155
				}
154
		
-
 
155
		if(!$insertion) {
-
 
156
			echo 'la migration des mots cles images a échoué ! '."\n";
-
 
157
		} else {
156
				$sous_requete = implode(',', $sous_requete);
Line 158... Line -...
158
			echo "\n---------------------------------------------------------------- OK\n\n";
-
 
159
		}
157
				$requete .= $sous_requete;
160
	}
158
 
161
	
159
				$migration = $this->executerRequeteSimple($requete);
162
	private function migrerTableMotsClesObs() {
160
				if (!$migration) {
163
		$this->migrerTableMotsCles('obs');
161
					echo  "La migration des mots cles $image_ou_obs a échoué ! "."\n";
Line 195... Line 193...
195
			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
193
			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
196
			echo $actuel++;
194
			echo $actuel++;
197
		}
195
		}
198
	}
196
	}
Line 199... Line -...
199
	
-
 
200
	private function migrerTableMotsCles($image_ou_obs) {
-
 
201
		echo "--MIGRATION DES MOTS CLES $image_ou_obs ---------------------------------\n";
-
 
202
		$pas = 1;
-
 
203
		
-
 
204
		//limite des mots clés
-
 
205
		$requeteNbMotsCles = 'SELECT count(*) as nb FROM cel_mots_cles_'.$image_ou_obs;
-
 
206
		$resultatNbMotsCles = $this->executerRequete($requeteNbMotsCles);
-
 
207
		$nbMotsCles = (int) $resultatNbMotsCles[0]['nb'];
-
 
208
		
-
 
209
		$nbTotal = 0;
-
 
210
		for($i = 0; $i < $nbMotsCles; $i += $pas) {
-
 
211
			$requete_selection_arbres_mots_cles = 'SELECT * FROM cel_mots_cles_'.$image_ou_obs.' ORDER BY cmc_niveau '.
-
 
212
													'LIMIT '.$i.','.$pas;
-
 
213
			$arbres_mots_cles = $this->executerRequete($requete_selection_arbres_mots_cles);
-
 
214
			
-
 
215
			$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';
-
 
217
			$requete_insertion_nouvel_arbre = '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 '; 
-
 
220
			$sous_requete_insertion_nouvel_arbre = '';
-
 
221
			
-
 
222
			if(count($arbres_mots_cles) > 0) {
-
 
223
				foreach($arbres_mots_cles as $arbre_mot_cle) {
-
 
224
					$sous_requete_insertion_nouvel_arbre .= $this->construireSousRequeteInsertionArbresMotsCles('cmc_', $arbre_mot_cle);
-
 
225
				}
-
 
226
				
-
 
227
				$sous_requete_insertion_nouvel_arbre = rtrim($sous_requete_insertion_nouvel_arbre,',');
-
 
228
				
-
 
229
				$requete_insertion_nouvel_arbre = $requete_insertion_nouvel_arbre.$sous_requete_insertion_nouvel_arbre;
-
 
230
				$migration = $this->executerRequeteSimple($requete_insertion_nouvel_arbre);
-
 
231
				if(!$migration) {
-
 
232
					echo  'la migration des mots cles '.$image_ou_obs.' a échoué ! '."\n";
-
 
233
				} else {
-
 
234
					$nbTotal ++;
-
 
235
					$this->afficherAvancement('Migration des mots clés (par '.$pas.') :', $nbTotal);
-
 
236
				}
-
 
237
			} else {
-
 
238
				echo "\n---------------------------------------------------------------- OK\n\n";
-
 
239
				return;
-
 
240
			}
-
 
241
			
-
 
242
		}
-
 
243
	}
-
 
244
	
197
 
245
	private function construireSousRequeteInsertionArbresMotsCles($prefixe, $ligne) {
-
 
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'];
Line 248... Line 200...
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) {
-
 
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 '.
-
 
241
				'ORDER BY identifiant ';
-
 
242
		$mots_cles_obs = $this->executerRequete($requete);
-
 
243
 
-
 
244
		$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_obs_mots_cles '.
-
 
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";
258
													'),';
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 '.
-
 
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) '.
Line 259... Line -...
259
		return $sous_requete_insertion_valeurs;
-
 
260
	}
267
				'VALUES '.
Line 261... Line 268...
261
	
268
				$this->construireSousRequeteInsertionLiaisons($mots_cles_images, ',');
262
	private function construireSousRequeteInsertionLiaisons($tableau_mots_cles, $champ_mot_cle, $champ_id, $separateur) {
269
 
-
 
270
		$insertion = $this->executerRequeteSimple($requete);
263
		$sous_requete_insertion_valeurs = '';
271
 
264
		
-
 
265
		foreach($tableau_mots_cles as $mot_cle_element) {
272
		if (!$insertion) {
266
			$mots_cles_tableau = $this->parserMotsCles($mot_cle_element[$champ_mot_cle],$separateur);
273
			echo 'La migration des mots cles images a échoué ! '."\n";
Line -... Line 274...
-
 
274
		} else {
-
 
275
			echo "Migration des mots cles images : OK\n\n";
-
 
276
		}
-
 
277
	}
-
 
278
 
-
 
279
	private function construireSousRequeteInsertionLiaisons($tableau_mots_cles, $separateur) {
-
 
280
		$sous_requete = array();
-
 
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) {
-
 
284
				$id = $this->proteger($element['id']);
267
			foreach($mots_cles_tableau as $mot_cle_en_cours) {
285
				$id_mot_cle = $this->proteger($mot_cle_id);
268
				$sous_requete_insertion_valeurs .= '('.$mot_cle_element[$champ_id].','.$this->proteger($mot_cle_en_cours).'),';
286
				$id_utilisateur = $this->proteger($this->renvoyerIdPourMigration($element['id_utilisateur']));
269
			}
287
				$sous_requete[] = "($id, $id_mot_cle, $id_utilisateur)";
Line 270... Line 288...
270
		}
288
			}
271
		
-
 
272
		$sous_requete_insertion_valeurs = rtrim($sous_requete_insertion_valeurs,',');
289
		}
273
		return $sous_requete_insertion_valeurs;
-
 
Line -... Line 290...
-
 
290
		$sous_requete_chaine = implode(',', $sous_requete);
274
	}
291
		return $sous_requete_chaine;
275
	
-
 
276
	private function parserMotsCles($mot_cles, $separateur = ',') {
292
	}
277
		
293
 
Line 278... Line 294...
278
		$tableau_mots_cles = explode($separateur,$mot_cles);
294
	private function parserMotsCles($mot_cles, $separateur = ',') {
279
		$tableau_mots_cles_formates = array();
295
		$tableau_mots_cles = explode($separateur, $mot_cles);
Line 298... Line 314...
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
			}
317
			}
302
		}
318
		}
303
		
-
 
304
		return $tableau_mots_cles_formates;
319
		return $tableau_mots_cles_formates;
305
	}
320
	}
Line 306... Line 321...
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);
Line 309... Line 324...
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) ';
-
 
Line 314... Line 329...
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) {
-
 
320
				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);
334
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
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
			}
Line 325... Line 339...
325
		}
339
		}
326
		echo "\n-----------------------------------------------------------------OK\n";
340
		echo "\n-----------------------------------------------------------------OK\n";
-
 
341
	}
327
	}
342
 
328
	
343
	private function genererIndexTexteMotsClesImages() {
329
	private function genererIndexTexteMotsClesImages() {
-
 
Line 330... Line 344...
330
		$requete_selection_images = 'SELECT DISTINCT id_image, ce_utilisateur FROM '.self::$bdd_cel_migration.'.cel_images '.
344
		$requete_selection_images = 'SELECT DISTINCT id_image, ce_utilisateur '.
331
		                              'WHERE id_image IN (SELECT DISTINCT id_image FROM '.self::$bdd_cel_migration.'.cel_mots_cles_images) ';
345
			'FROM '.self::$bdd_cel_migration.'.cel_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');
-
 
337
			$mots_cles_texte_chaine = '';
350
			$mots_cles_texte = $this->obtenirMotsClesTexte($image['id_image'], $image['ce_utilisateur'], 'images');
338
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
351
			$mots_cles_texte_chaine = '';
339
				$mots_cles_texte_chaine = implode(',', $mots_cles_texte);
352
			if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) {
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');
Line 342... Line 355...
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
	}
Line 347... Line 360...
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) {
Line 349... Line 362...
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).' '.
-
 
351
						'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).
363
			'SET mots_cles_texte = '.$this->proteger($mots_cles_texte_chaine).' '.
Line 352... Line 364...
352
						' AND ce_utilisateur = '.$this->proteger($identifiant_utilisateur);
364
			'WHERE '.(($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image').' = '.$this->proteger($id_image_ou_obs).' '.
353
	
365
			'	AND ce_utilisateur = '.$this->proteger($id_utilisateur);
354
		return $this->executer($requete);
366
 
355
	}
367
		return $this->executer($requete);
356
	
368
	}
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 '.
-
 
362
						'FROM '.self::$bdd_cel_migration.'.cel_mots_cles_'.$mode_image_ou_obs.' '.
373
		$requete = 'SELECT mot_cle '.
-
 
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 '.
Line 367... Line 379...
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
							')'.
380
				')'.
369
						' AND ce_utilisateur = '.$this->proteger($identifiant_utilisateur);
-
 
370
	
-
 
371
		$resultats = $this->requeter($requete);	
-
 
372
		$mots_cles = array();
-
 
373
		foreach($resultats as $resultat) {
-
 
374
			$mots_cles[] = $resultat['mot_cle'];
-
 
375
		}
-
 
376
		
-
 
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
			}
381
			' AND id_utilisateur = '.$this->proteger($id_utilisateur);
393
		}
382
		$resultats = $this->requeter($requete);