Subversion Repositories eFlore/Applications.cel

Rev

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

Rev 1149 Rev 1160
Line 1... Line 1...
1 
<?php
 1 
<?php
Line 2... Line 2...
2 
 
 2 
 
3 
class MigrationImages extends Cel {
 3 
class MigrationImages extends Cel {
4 
 
 4
5 
	const bdd_cel_migration = 'cel';
 5 
	public static $bdd_cel_migration;
- 
 
 6 
	public static $bdd_utilisateurs;
- 
 
 7
Line 6... Line 8...
6 
	const bdd_utilisateurs = 'cel_old';
 8 
	const truncate = true; //Doit on vider les tables de destination ?
7
9
Line 8... Line 10...
8 
	const separateur_champs_metadonnees = ';';
 10 
	const separateur_champs_metadonnees = ';';
Line 14... Line 16...
14 
	* La clé est un md5 du message à afficher au démarrage de la boucle.
 16 
	* La clé est un md5 du message à afficher au démarrage de la boucle.
15 
	* @var array
 17 
	* @var array
16 
	*/
 18 
	*/
17 
	private static $avancement = array();
 19 
	private static $avancement = array();
Line 18... Line 20...
18
20
Line 19... Line 21...
19 
	const dry_run = true;
 21 
	const dry_run = false;
20
22
21 
	private $tableau_utilisateurs = array();
 23 
	private $tableau_utilisateurs = array();
Line 111... Line 113...
111 
	* @param string le message d'information.
 113 
	* @param string le message d'information.
112 
	* @param int le nombre de départ à afficher.
 114 
	* @param int le nombre de départ à afficher.
113 
	* @return void le message est affiché dans la console.
 115 
	* @return void le message est affiché dans la console.
114 
	*/
 116 
	*/
115 
	protected function afficherAvancement($message, $depart = 0) {
 117 
	protected function afficherAvancement($message, $depart = 0) {
116 
	if (! isset(self::$avancement[$message])) {
 118 
		if (! isset(self::$avancement[$message])) {
117 
	self::$avancement[$message] = $depart;
 119 
			self::$avancement[$message] = $depart;
118 
	echo "$message : ";
 120 
			echo "$message : ";
119
121
120 
	$actuel =& self::$avancement[$message];
 122 
			$actuel =& self::$avancement[$message];
121 
	echo $actuel++;
 123 
			echo $actuel++;
122 
	} else {
 124 
		} else {
123 
	$actuel =& self::$avancement[$message];
 125 
			$actuel =& self::$avancement[$message];
124
126
125 
		// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)
 127 
			// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères)
126 
		$passage = 0;
 128 
			$passage = 0;
127 
		if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {
 129 
			if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) {
128 
		$passage = 1;
 130 
			$passage = 1;
129 
	}
 131 
		}
130
132
131 
		echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
 133 
			echo str_repeat(chr(8), (strlen((string) $actuel) - $passage));
132 
		echo $actuel++;
 134 
			echo $actuel++;
133 
	}
 135 
		}
134 
	}
 136 
	}
Line 135... Line 137...
135
137
136 
	/**
 138 
	/**
137 
	 * Méthode appelée avec une requête de type GET.
 139 
	 * Méthode appelée avec une requête de type GET.
138 
	 */
 140 
	 */
Line -... Line 141...
- 
 
 141 
	public function getElement($params) {
- 
 
 142
- 
 
 143 
		if(!isset($this->config['database_cel']['database_migration']) || $this->config['database_cel']['database_migration'] == '') {
- 
 
 144 
			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";
- 
 
 145 
			exit;
- 
 
 146 
		}
- 
 
 147
- 
 
 148 
		if(!isset($this->config['database_ident']['database']) || $this->config['database_ident']['database'] == '') {
- 
 
 149 
			echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n";
- 
 
 150 
			exit;
- 
 
 151 
		}
- 
 
 152
- 
 
 153 
		self::$bdd_cel_migration = $this->config['database_cel']['database_migration'];
139 
	public function getElement($params) {
 154 
		self::$bdd_utilisateurs = $this->config['database_ident']['database'];
140
155
- 
 
 156 
		$this->id_cle_metadonnees = array_merge($this->tableau_ids_tags_exif, $this->tableau_ids_tags_iptc);
- 
 
 157 
 
- 
 
 158 
		echo "--MIGRATION DES IMAGES --------------------------------------\n";
- 
 
 159 
		//1. TEMPORAIRE : vider les tables de destinations
- 
 
 160 
		if (self::truncate) {
- 
 
 161 
			echo "-------------------------------------------------------------------\n\n";
- 
 
 162 
			echo "  ETAPE 0. Vider les tables ... \n\n";
- 
 
 163 
			echo "-------------------------------------------------------------------\n\n";
- 
 
 164 
			$nouvellesTables = array('`cel_images`', '`cel_obs_images`');
- 
 
 165 
			foreach ($nouvellesTables as $nomTable) {
- 
 
 166 
				echo 'Vider la table '.$nomTable.'...';
- 
 
 167 
				$requeteTruncate = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable;
- 
 
 168 
				$resultatTruncate = $this->executerRequete($requeteTruncate);
- 
 
 169 
				echo "ok \n";
- 
 
 170 
			}
- 
 
 171
- 
 
 172 
			echo "\n---------------------------------------------------------------- OK\n\n";
- 
 
 173 
		}
- 
 
 174
- 
 
 175 
		echo "-------------------------------------------------------------------\n\n";
141 
		$this->id_cle_metadonnees = array_merge($this->tableau_ids_tags_exif, $this->tableau_ids_tags_iptc);
 176 
		echo "  ETAPE 1. Paramétrage ... \n\n";
142
177 
		echo "-------------------------------------------------------------------\n\n";
143 
		$this->getUtilisateurs();
 178 
		$this->getUtilisateurs();
Line -... Line 179...
- 
 
 179 
		$this->getMotsCles();
144 
		$this->getMotsCles();
 180 
		$this->getObservations();
- 
 
 181
145 
		$this->getObservations();
 182 
		echo "-------------------------------------------------------------------\n\n";
146
183 
		echo "  ETAPE 2. Migration des images ... \n\n";
Line -... Line 184...
- 
 
 184 
		echo "-------------------------------------------------------------------\n\n";
147 
		echo '|| Migration des images ||'."\n";
 185 
		$this->migrerImages();
- 
 
 186 
		echo "\n"."\n"."\n";
148 
		//$this->migrerImages();
 187
149 
		echo "\n"."\n"."\n";
 188 
		echo "-------------------------------------------------------------------\n\n";
150
189 
		echo "  ETAPE 3. migration des liaisons obs images ... \n\n";
Line 151... Line 190...
151 
		echo '|| Migration des liaisons obs images ||'."\n";
 190 
		echo "-------------------------------------------------------------------\n\n";
- 
 
 191 
		//$this->migrerLiaisonsObsImages();
- 
 
 192 
		echo "\n"."\n"."\n";
Line 152... Line 193...
152 
		$this->migrerLiaisonsObsImages();
 193 
	}
153 
		echo "\n"."\n"."\n";
 194
Line 154... Line 195...
154 
	}
 195 
	private function getUtilisateurs() {
155
196 
		echo "\n-------------------------------------------------------------------\n";
156 
	private function getUtilisateurs() {
 197 
		echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n";
Line -... Line 198...
- 
 
 198
- 
 
 199 
		$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';
157
200 
		$tableau_utilisateurs = $this->executerRequete($requete_selection_utilisateurs);
Line 158... Line 201...
158 
		$requete_selection_utilisateurs = 'SELECT U_ID as id, U_MAIL as mail, U_NAME as nom, U_SURNAME as prenom FROM '.self::bdd_utilisateurs.'.annuaire_tela';
 201
- 
 
 202 
		foreach( $tableau_utilisateurs as &$utilisateur) {
- 
 
 203 
			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
Line 159... Line 204...
159 
		$tableau_utilisateurs = $this->executerRequete($requete_selection_utilisateurs);
 204 
		}
160
205
Line 161... Line 206...
161 
		foreach( $tableau_utilisateurs as &$utilisateur) {
 206 
		echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés";
162 
			$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur;
 207 
		echo "\n-----------------------------------------------------------------OK\n";
163 
		}
 208 
	}
- 
 
 209
- 
 
 210 
	private function getMotsCles() {
- 
 
 211 
		echo "\n-------------------------------------------------------------------\n";
- 
 
 212 
		echo "--SELECTION DES MOTS-CLES -----------------------------------------\n\n";
164
213
Line 165... Line 214...
165 
	}
 214 
		$requete_selection_mots_cles = 'SELECT cmc_id_proprietaire as id_utilisateur, cmc_id_mot_cle_utilisateur as id_mot_cle, cmc_mot_cle as mot_cle FROM cel_mots_cles_obs';
- 
 
 215 
		$tableau_mots_cles = $this->executerRequete($requete_selection_mots_cles);
166
216 
 
Line 167... Line 217...
167 
	private function getMotsCles() {
 217 
		foreach( $tableau_mots_cles as &$mot_cle) {
168
218 
			$this->tableau_mots_cles[$mot_cle['id_utilisateur']][$mot_cle['id_mot_cle']] = $mot_cle;
169 
		$requete_selection_mots_cles = 'SELECT cmc_id_proprietaire as id_utilisateur, cmc_id_mot_cle_utilisateur as id_mot_cle, cmc_mot_cle as mot_cle FROM cel_mots_cles_images';
 219 
		}
Line 186... Line 236...
186 
			$tableau_observations = $this->executerRequete($requete_selection_observations);
 236 
			$tableau_observations = $this->executerRequete($requete_selection_observations);
187 
			foreach($tableau_observations as &$obs) {
 237 
			foreach($tableau_observations as &$obs) {
188 
				$this->tableau_observations[$obs['identifiant']][$obs['ordre']] = $obs['id'];
 238 
				$this->tableau_observations[$obs['identifiant']][$obs['ordre']] = $obs['id'];
189 
			}
 239 
			}
Line 190... Line 240...
190
240
191 
			//$this->afficherAvancement('Selection des observations (par '.$pas.' )', $i);
 - 
 
192 
			echo "\n obs : ".$i;
 241 
			$this->afficherAvancement('Selection des observations (par '.$pas.' )', $nbObs);
Line 193... Line -...
193 
		}
 - 
 
194
242 
		}
195
243
Line 196... Line 244...
196
244 
		echo "\n\n";
197 
	}
 245 
	}
198
246
Line 210... Line 258...
210
258
211 
		$debut = 0;
 259 
		$debut = 0;
212 
		$pas = 200;
260 
		$pas = 200;
Line -... Line 261...
- 
 
 261 
		$fin = 150000;
- 
 
 262
- 
 
 263 
		//Selectionner le nombre d'images
- 
 
 264 
		$requeteNbImg = "SELECT COUNT(*) as nb FROM cel_images";
- 
 
 265 
		$resultatNbImg = $this->executerRequete($requeteNbImg);
213 
		$fin = 150000;
266 
		$fin = $resultatNbImg[0]['nb'];
214
267
215 
		for ($i = $debut; $i <= $fin ; $i += $pas) {
 268 
		for ($i = $debut; $i <= $fin ; $i += $pas) {
Line 216... Line 269...
216 
			$requete_selection_images = 'SELECT * FROM cel_images '.
 269 
			$requete_selection_images = 'SELECT * FROM cel_images '.
Line 217... Line 270...
217 
											'ORDER BY ci_id_image ASC LIMIT '.$i.','.$pas;
 270 
											'ORDER BY ci_id_image ASC LIMIT '.$i.','.$pas;
218
271
219 
			$images = $this->requeter($requete_selection_images);
272 
			$images = @$this->requeter($requete_selection_images);
220
273
221 
			$requete_insertion_images = 'INSERT INTO '.self::bdd_cel_migration.'.cel_images (';
 274 
			$requete_insertion_images = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_images (';
Line 242... Line 295...
242 
				$migration_images = $this->executer($requete_insertion_images);
 295 
				$migration_images = $this->executer($requete_insertion_images);
Line 243... Line 296...
243
296
244 
				if (!$migration_images) {
 297 
				if (!$migration_images) {
245 
					echo 'la migration des images '.$i.' à '.($i+$nb_images_a_traiter).' a échoué '."\n";
 298 
					echo 'la migration des images '.$i.' à '.($i+$nb_images_a_traiter).' a échoué '."\n";
246 
				} else {
 299 
				} else {
247 
					echo 'migration des images '.$i.' à '.($i+$nb_images_a_traiter).' effectuée '."\n";
 300 
					$this->afficherAvancement('Migration des images (par '.$pas.' )', $fin);
248 
				}
301 
				}
Line 249... Line 302...
249 
			}
 302 
			}
250
303
251 
			if(count($images) < $pas) {
 304 
			if(count($images) < $pas) {
252 
				echo 'Fin de la migration des images '."\n";
 305 
				echo "\n---------------------------------------------------------------- OK\n\n";
253 
				return;
 306 
				return;
254 
			}
 307 
			}
Line 255... Line 308...
255 
		}
 308 
		}
256 
	}
 309 
	}
257
310
258 
	private function migrerLiaisonsObsImages() {
 311 
	private function migrerLiaisonsObsImages() {
Line -... Line 312...
- 
 
 312 
		$debut = 0;
- 
 
 313 
		$pas = 500;
- 
 
 314 
		$fin = 50000;
- 
 
 315
- 
 
 316 
		$liaisons_obs_inexistantes = 0;
- 
 
 317
- 
 
 318 
		//Selectionner le nombre de liaisons
259 
		$debut = 0;
 319 
		$requeteNbImgObs = "SELECT COUNT(*) as nb FROM cel_obs_images";
- 
 
 320 
		$resultatNbImgObs = $this->executerRequete($requeteNbImgObs);
- 
 
 321 
		$fin = $resultatNbImgObs[0]['nb'];
- 
 
 322
- 
 
 323 
		for ($i = $debut; $i <= $fin ; $i += $pas) {
- 
 
 324
260 
		$pas = 200;
325 
			if($i > $fin) {
261 
		$fin = 50000;
326 
				$i = $fin;
Line 262... Line 327...
262
327 
			}
263 
		for ($i = $debut; $i <= $fin ; $i += $pas) {
 328
264 
			$requete_selection_liaisons = 'SELECT * FROM cel_obs_images LIMIT '.$i.','.$pas;
 329 
			$requete_selection_liaisons = 'SELECT * FROM cel_obs_images LIMIT '.$i.','.$pas;
Line 265... Line 330...
265 
			$tableau_liaisons = $this->executerRequete($requete_selection_liaisons);
 330 
			$tableau_liaisons = $this->executerRequete($requete_selection_liaisons);
Line -... Line 331...
- 
 
 331
266
332 
			$requete_migration_liaison = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_obs_images '.
- 
 
 333 
											'(id_image, id_utilisateur, id_observation, date_liaison) '.
- 
 
 334 
											'VALUES ';
- 
 
 335
Line 267... Line 336...
267 
			$requete_migration_liaison = 'INSERT INTO '.self::bdd_cel_migration.'.cel_obs_images '.
 336 
			$sous_requete_insertion = '';
268 
											'(ce_image, ce_utilisateur, ce_observation, date_liaison) '.
 337
- 
 
 338 
			if(is_array($tableau_liaisons)) {
- 
 
 339 
				foreach($tableau_liaisons as &$liaison) {
- 
 
 340
269 
											'VALUES ';
 341 
					$mail_utilisateur = $liaison['coi_ce_utilisateur'];
270
342 
					$utilisateur = $mail_utilisateur;
271 
			$sous_requete_insertion = '';
 343
- 
 
 344 
					if (isset($this->tableau_utilisateurs[$mail_utilisateur])) {
- 
 
 345 
						$utilisateur =  $this->tableau_utilisateurs[$mail_utilisateur]['id'];
- 
 
 346 
					}
- 
 
 347
- 
 
 348 
					$id_obs = $liaison['coi_ce_observation'];
- 
 
 349
- 
 
 350 
					if (isset($this->tableau_observations[$mail_utilisateur][$id_obs])) {
- 
 
 351 
						$id_obs =  $this->tableau_observations[$mail_utilisateur][$id_obs];
- 
 
 352
- 
 
 353 
						$sous_requete_insertion .= '('.$this->proteger($liaison['coi_ce_image']).','.
272
354 
							$this->proteger($utilisateur).','.
Line 273... Line 355...
273 
			foreach($tableau_liaisons as &$liaison) {
 355 
							$this->proteger($id_obs).','.
- 
 
 356 
							$this->proteger($liaison['coi_date_liaison']).
274
357 
						'),';
275 
				$mail_utilisateur = $liaison['coi_ce_utilisateur'];
 - 
 
276 
				$utilisateur = $mail_utilisateur;
 358 
					} else {
277
359 
						// cas d'une observation inexistante, la liaison est ignorée
278 
				if (isset($this->tableau_utilisateurs[$mail_utilisateur])) {
 - 
 
279 
					$utilisateur =  $this->tableau_utilisateurs[$mail_utilisateur]['id'];
 - 
 
280 
				}
 360 
						$liaisons_obs_inexistantes++;
281
361 
					}
282 
				$id_obs = $liaison['coi_ce_observation'];
 - 
 
283
362 
				}
284 
				if (isset($this->tableau_observations[$mail_utilisateur][$id_obs])) {
 363
285 
					$id_obs =  $this->tableau_observations[$mail_utilisateur][$id_obs];
 364 
				$sous_requete_insertion = rtrim($sous_requete_insertion,',');
286
365 
				$requete_migration_liaison = $requete_migration_liaison.$sous_requete_insertion;
287 
					$sous_requete_insertion .= '('.$this->proteger($liaison['coi_ce_image']).','.
 - 
 
288 
						$this->proteger($utilisateur).','.
 - 
 
289 
						$this->proteger($id_obs).','.
 - 
 
290 
						$this->proteger($liaison['coi_date_liaison']).
 - 
 
291 
					'),';
 - 
 
292 
				} else {
 - 
 
293 
					echo 'l\'obs '.$id_obs.' n\'existe pas pour l\'utilisateur '.$mail_utilisateur."\n";
 - 
 
294 
				}
 - 
 
295 
			}
 - 
 
296
- 
 
297 
			$sous_requete_insertion = rtrim($sous_requete_insertion,',');
 - 
 
298 
			$requete_migration_liaison = $requete_migration_liaison.$sous_requete_insertion;
 366
- 
 
 367 
				$migration_liaison = $this->executerRequeteSimple($requete_migration_liaison);
- 
 
 368
- 
 
 369 
				if (!$migration_liaison) {
- 
 
 370 
					echo 'la migration des liaisons obs images de '.$i.' à '.($i+$pas).' a échoué ! '."\n<br />";
299
371 
				} else {
Line 300... Line 372...
300 
			$migration_liaison = $this->executerRequeteSimple($requete_migration_liaison);
 372 
					$this->afficherAvancement('Migration des liaisons obs images (par '.$pas.' )', $fin);
Line 301... Line 373...
301
373 
				}
Line 371... Line 443...
371 
						}
 443 
						}
372 
					}
444 
					}
373 
				} else {
 445 
				} else {
374 
					// on met le mot clé dans sa propre case afin d'éviter
 446 
					// on met le mot clé dans sa propre case afin d'éviter
375 
					// facilement les doublons provoqués par de mauvais formatages
447 
					// facilement les doublons provoqués par de mauvais formatages
- 
 
 448 
					if(isset($this->tableau_mots_cles[$utilisateur][$mot_cle])) {
376 
					$tableau_mots_cles_formates[$mot_cle] = $this->tableau_mots_cles[$utilisateur][$mot_cle]['mot_cle'];
 449 
						$tableau_mots_cles_formates[$mot_cle] = $this->tableau_mots_cles[$utilisateur][$mot_cle]['mot_cle'];
- 
 
 450 
					}
377 
				}
 451 
				}
Line 378... Line 452...
378 
 
 452 
 
379 
			}
 453 
			}
Line 443... Line 517...
443
517
Line 444... Line 518...
444 
	private function convertirTableauMetadonneesEnXml($tableau) {
 518 
	private function convertirTableauMetadonneesEnXml($tableau) {
Line 445... Line 519...
445
519
Line 446... Line 520...
446 
		$xml = '';
 520 
		$xml = '';
447
521
448 
		/*foreach($tableau as $cle => $valeur) {
 522 
		foreach($tableau as $cle => $valeur) {
449 
 
 523 
 
450 
			$cle = str_replace('ci_meta_exif_','',$cle);
 524 
			$cle = str_replace('ci_meta_exif_','',$cle);
451 
			$cle = str_replace('ci_meta_iptc_','',$cle);
 525 
			$cle = str_replace('ci_meta_iptc_','',$cle);
- 
 
 526 
			$cle = str_replace('ci_meta_','',$cle);
452 
			$cle = str_replace('ci_meta_','',$cle);
 527 
			$cle = str_replace('_',' ',$cle);
453 
			$cle = str_replace('_',' ',$cle);
 528 
			$cle = str_replace(' ','',ucwords($cle));
Line 454... Line 529...
454 
			$cle = str_replace(' ','',ucwords($cle));
 529 
			$valeur = str_replace("\0",'',$valeur);
455 
			$valeur = str_replace("\0",'',$valeur);
 530 
			$id = isset($this->id_cle_metadonnees[$cle]) ? $this->id_cle_metadonnees[$cle] : $cle;
Line 456... Line 531...
456 
			$xml .= '<'.$cle.' id="'.$this->id_cle_metadonnees[$cle].'">'.$valeur.'</'.$cle.'>'."\n";
 531 
			$xml .= '<'.$cle.' id="'.$id.'">'.$valeur.'</'.$cle.'>'."\n";
Line 564... Line 639...
564 
	}
 639 
	}
Line 565... Line 640...
565
640
Line 566... Line 641...
566 
	private function traiterXmp($ligne_image) {
 641 
	private function traiterXmp($ligne_image) {
- 
 
 642
567
643 
		$chemin = $this->obtenirCheminImageOriginale($ligne_image['ci_id_image']);
568 
		$chemin = $this->obtenirCheminImageOriginale($ligne_image['ci_id_image']);
 644 
		// TODO décommenté car pour le moment ça n'est pas necessaire, à éxécuter à part
569 
		//$res = $this->decoderMetadonneesExifTool($chemin);
 645 
		//$res = $this->decoderMetadonneesExifTool($chemin);
570 
		$xml = '<?xml version="1.0" encoding="UTF-8" ?>';
 646 
		$xml = '<?xml version="1.0" encoding="UTF-8" ?>';
571 
		$xml .= '<xmp>';
 647 
		$xml .= '<xmp>';