Blame | Last modification | View Log | RSS feed
<?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) ;
}
}