Subversion Repositories Applications.annuaire

Rev

Rev 611 | Blame | Compare with Previous | Last modification | View Log | RSS feed

<?php
// Encodage : UTF-8
// +-------------------------------------------------------------------------------------------------------------------+
/**
* Migration des utilisateurs vers wordpress
*
* Description : classe permettant de migrer les profils de l'annuaire vers les profils wordpress
* Utilisation : php cli.php migrationwp -a tous
* vérifier le nom de la base et le préfixe des tables définis dans $basewp
*
//Auteur original :
* @author       Aurélien PERONNET <jpm@tela-botanica.org>
* @copyright    Tela-Botanica 1999-2014
* @licence              GPL v3 & CeCILL v2
* @version              $Id$
*/

class Migrationwp extends Script {
        private $basewp = "wordpress.wp_";
        
        public function executer() {    
                $this->bdd = new Bdd();
                //$this->bdd->setAttribute(MYSQL_ATTR_USE_BUFFERED_QUERY, true);
                // évite les erreurs 2006 "MySQL has gone away"
                $this->bdd->executer("SET wait_timeout=300");
                
                $cmd = $this->getParametre('a');
                $this->mode_verbeux = $this->getParametre('v');
                
                $retour = array();
                
                switch($cmd) {
                        case "tous":
                                $retour = $this->migrerUtilisateur();
                                $retour = $this->migrerUtilisateurMeta();
                                //$retour = $this->migrerUtilisateurProfil();
                                $retour = $this->migrerUtilisateurActivite();
                                break;
                        case "utilisateur": //liste wordpress
                                $retour = $this->migrerUtilisateur();
                                break;
                        case "meta": //role
                                $retour = $this->migrerUtilisateurMeta();
                                break;
                        case "profil":
                                $retour = $this->migrerUtilisateurProfil();
                                break;
                        case "activite": // obligatoire pour affichage
                                $retour = $this->migrerUtilisateurActivite();
                                break;
                        default: break; 
                }
                
                if($this->mode_verbeux) {
                        // echo pour que bash capte la sortie et stocke dans le log
                        //echo 'Identifiants des mails traites : '.implode(',', $retour)."--";
                }
        }
        
        private function migrerUtilisateur() {
                $requete = "INSERT INTO ".$this->basewp.".`users`
                                (`ID`, `user_login`, `user_pass`, `user_nicename`, `user_email`, `user_url`, `user_registered`, `user_status`, `display_name`) 
                                SELECT `U_ID`, `U_MAIL`, `U_PASSWD`,  `U_SURNAME`, `U_MAIL` as mail, `U_WEB`, `U_DATE`, '0', concat(`U_NAME`,' ',`U_SURNAME`)  FROM tela_prod_v4.`annuaire_tela`";
                $retour = $this->bdd->executer($requete);
                echo 'Il y a '.count($retour).' utilisateurs migrés '."--";
                return $retour;
        }
        

        
        private function migrerUtilisateurMeta() {
                $retour = array();
                $requete = "SELECT `U_ID`, `U_NAME`, `U_SURNAME`, amv_valeur FROM `annuaire_tela` left join annu_meta_valeurs on amv_cle_ligne = U_ID WHERE `amv_ce_colonne` =99;";
                $utilisateurs = $this->bdd->recupererTous($requete);
                foreach ($utilisateurs as $utilisateur) {
                        $requete_insert = "INSERT INTO ".$this->basewp.".`usermeta` (`user_id`, `meta_key`, `meta_value`) VALUES
                                        ({$utilisateur['U_ID']}, 'last_activity', '2016-05-18 15:38:18'),
                                        ({$utilisateur['U_ID']}, 'nickname', '{$utilisateur['amv_valeur']}'),
                                        ({$utilisateur['U_ID']}, 'first_name', '{$utilisateur['U_SURNAME']}'),
                                        ({$utilisateur['U_ID']}, 'last_name', '{$utilisateur['U_NAME']}'),
                                        ({$utilisateur['U_ID']}, 'description', ''),
                                        ({$utilisateur['U_ID']}, 'rich_editing', 'true'),
                                        ({$utilisateur['U_ID']}, 'comment_shortcuts', 'false'),
                                        ({$utilisateur['U_ID']}, 'admin_color', 'fresh'),
                                        ({$utilisateur['U_ID']}, 'use_ssl', '0'),
                                        ({$utilisateur['U_ID']}, 'show_admin_bar_front', 'true'),
                                        ({$utilisateur['U_ID']}, 'wp_capabilities', 'a:1:{s:11:\"contributor\";b:1;}'),
                                        ({$utilisateur['U_ID']}, 'wp_user_level', '1'),
                                        ({$utilisateur['U_ID']}, 'dismissed_wp_pointers', ''),
                                        ({$utilisateur['U_ID']}, 'wp_dashboard_quick_press_last_post_id', '63'),
                                        ({$utilisateur['U_ID']}, '_restrict_media', '1'),
                                        ({$utilisateur['U_ID']}, '_access', 'a:1:{i:0;s:2:\"25\";}'),
                                        ({$utilisateur['U_ID']}, 'bp_xprofile_visibility_levels', 'a:12:{i:1;s:6:\'public\';i:60;s:6:\'public\';i:61;s:6:\'public\';i:49;s:6:\'public\';i:55;s:6:\'public\';i:48;s:6:\'public\';i:62;s:6:\'public\';i:63;s:6:\'public\';i:68;s:6:\'public\';i:76;s:6:\'public\';i:120;s:6:\'public\';i:81;s:6:\'public\';}');";
                        $retour[] = $this->bdd->executer($requete_insert);
                }
                // echo pour que bash capte la sortie et stocke dans le log
                //echo 'Il y a '.count($utilisateurs).' utilisateurs '."--";
                //print_r($utilisateurs);
                return $retour;
        }
        
        private function migrerUtilisateurActivite() {
                $retour = array();
                $requete = "SELECT `U_ID`, `U_NAME`, `U_SURNAME` FROM `annuaire_tela`;";
                $utilisateurs = $this->bdd->recupererTous($requete);
                foreach ($utilisateurs as $utilisateur) {
                        $requete_insert = "INSERT INTO `wordpress`.`bp_activity` 
                                        (`id`, `user_id`, `component`, `type`, `action`, `content`, `primary_link`, `item_id`, `secondary_item_id`, `date_recorded`, `hide_sitewide`, `mptt_left`, `mptt_right`, `is_spam`) 
                                        VALUES (NULL, {$utilisateur['U_ID']}, 'members', 'last_activity', '', '', '', '0', NULL, '2016-05-19 15:06:16', '0', '0', '0', '0');";
                        $retour[] = $this->bdd->executer($requete_insert);
                }
                // echo pour que bash capte la sortie et stocke dans le log
                //echo 'Il y a '.count($utilisateurs).' utilisateurs '."--";
                //print_r($utilisateurs);
                return $retour;
        }
        
        private function migrerUtilisateurProfil() {
                $requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ".
                                        "WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
                $maj = $this->bdd->executer($requete);
                // echo pour que bash capte la sortie et stocke dans le log
                echo $maj.' mails ont été mis en traitement '."--";
                return ($maj !== false);
        }
        
}
?>