WebSVN – Applications.projet – /trunk/jrest/services/MigrationWiki.php

<?php

class MigrationWiki extends ProjetService {
        
        const dry_run = false;
        
        public function __construct($config, $demarrer_session= true) {
                parent::__construct($config, $demarrer_session);
                define('NL',"\n"); 
        }
        
        private function executerRequeteManip($requete, $mode_fetch = false) {
                // Fonction de commodité pour afficher les requetes au lieu de les executer
                if (self::dry_run) {
                        echo '<pre>'.str_replace('),','),'.NL, $requete).'</pre>';      
                        return true;
                } else {
                        if($mode_fetch) { 
                                return $this->bdd->query($requete)->fetchAll($mode_fetch);
                        } else {
                                return $this->bdd->query($requete);
                        }
                }
        }
        
        private function executerRequete($requete, $mode_fetch = false) {
                if (self::dry_run) {
                        echo '<pre>'.str_replace('),','),'.NL, $requete).'</pre>'.NL.NL;        
                }
                return $this->bdd->query($requete)->fetchAll($mode_fetch);
        }
        
        public function getElement($uid){
                
                $nom_admin = $this->config['appli']['nom_admin_wiki'];
                $mail_admin = $this->config['appli']['adresse_admin_wiki'];     
                $pass_admin = $this->config['appli']['pass_admin_wiki'];

                $requete_projets_wikinis =      'SELECT * FROM gen_wikini';
                $wikinis_projets = $this->executerRequete($requete_projets_wikinis, PDO::FETCH_ASSOC);
                                
                foreach($wikinis_projets as $wikini) {

                        // test sur un wiki
                        /*if($wikini['gewi_code_alpha_wikini'] != 'bibliobota') {
                                continue;
                        }*/

                        $base = $wikini['gewi_bdd_nom'];
                        $prefixe = $wikini['gewi_table_prefix'];
                        
                        $chemin_wiki_sur_site = $this->config['appli']['chemin_wikis_integres'];
                        //$chemin_wiki = $wikini['gewi_chemin'];
                        $chemin_wiki = '/home/aurelien/web/wikini/'.$wikini['gewi_code_alpha_wikini'];
                        
                        echo NL.'Traitement du wiki '.$chemin_wiki.NL;
                        echo NL.$chemin_wiki.NL;
                        
                        if(!file_exists($chemin_wiki)) {
                                echo 'Impossible de migrer le wikini '.$wikini['gewi_code_alpha_wikini'].' : le dossier n\'existe pas'.NL.NL.NL.NL;
                                continue;
                        }
                        
                        $chemin_base_wiki_defaut = $this->config['appli']['chemin_wiki_defaut'];
                                                
                        $infos_admin = array('name' =>$nom_admin, 'email' => $mail_admin, 'password' => $pass_admin);
                                                                        
                        if(!$this->verifierPresenceTableTriple($base, $prefixe)) {
                                echo 'migration du wiki '.$wikini['gewi_code_alpha_wikini'].NL;
                                $this->creerTableTriple($base, $prefixe);
                                $this->ajouterUtilisateurAdmin($base,$prefixe, $infos_admin);   
                                $this->copierFichiersWikini($chemin_base_wiki_defaut, $chemin_wiki);
                                $this->changerVersionWakkaConfig($chemin_wiki);
                                
                                echo 'migration du wiki '.$wikini['gewi_code_alpha_wikini'].' effectuée '.NL.NL.NL.NL;
                        } else {
                                echo 'wiki dejà à jour '.$wikini['gewi_code_alpha_wikini'].NL.NL.NL.NL;
                        }
                        
                        $this->ajoutPageFormatees($chemin_wiki, $infos_admin);
                }
        }

        private function verifierPresenceTableTriple($base, $prefixe) {
                
                $requete_presence_table = 'SELECT COUNT(*) as table_existe FROM information_schema.tables
                WHERE TABLE_SCHEMA = "'.$base.'" AND TABLE_NAME = "'.$prefixe.'triples"';
                                
                $resultat_presence_table = $this->executerRequete($requete_presence_table);
                
                $presence_table = false;
                
                foreach($resultat_presence_table as $table_est_presente) {
                        if($table_est_presente['table_existe'] >= 1) {
                                $presence_table = true;
                                break;
                        }
                }
                
                return $presence_table;
        }

        private function creerTableTriple($base, $prefixe) {
                
                echo 'Création de la table triple '.NL;
                
                $requete_creation_table = 'CREATE TABLE '.$base.'.'.$prefixe.'triples (' . 
                        ' id int(10) unsigned NOT NULL auto_increment,' . 
                        ' resource varchar(255) NOT NULL default \'\',' . 
                        ' property varchar(255) NOT NULL default \'\',' . 
                        ' value text NOT NULL default \'\',' . 
                        ' PRIMARY KEY  (id),' . 
                        ' KEY resource (resource),' . 
                        ' KEY property (property)' . 
                        ') TYPE=MyISAM';

                return $this->executerRequeteManip($requete_creation_table);
        }
        
        private function verifierPresenceTableUsers($base, $prefixe) {
                
                $requete_presence_table = 'SELECT COUNT(*) as table_existe FROM information_schema.tables
                WHERE TABLE_SCHEMA = "'.$base.'" AND TABLE_NAME = "'.$prefixe.'users"';
                                
                $resultat_presence_table = $this->executerRequete($requete_presence_table);
                
                $presence_table = false;
                
                foreach($resultat_presence_table as $table_est_presente) {
                        if($table_est_presente['table_existe'] >= 1) {
                                $presence_table = true;
                                break;
                        }
                }
                
                return $presence_table;
        }
        
        private function ajouterUtilisateurAdmin($base, $prefixe, $infos_admin) {
                
                if(!$this->verifierPresenceTableUsers($base, $prefixe)) {
                        echo 'Impossible d\'ajouter l\'adminwiki : '.$prefixe.'_users n\'existe_pas'.NL;
                        return; 
                }
                
                echo 'Ajout de l\'utilisateur wikiAdmin '.NL;
                
                $requete_suppression_si_admin_present = 'DELETE FROM '.$base.'.'.$prefixe.'users '.
                                                                                                'WHERE name ="'.$infos_admin['name'].'"';
                
                $this->executerRequeteManip($requete_suppression_si_admin_present);
                
                $requete_creation_admin = "insert into ".$base.'.'.$prefixe."users set ".
                "signuptime = now(), ".
                "name = '".$infos_admin['name']."', ".
                "email = '".$infos_admin['email']."', ".
                "password = md5('".$infos_admin['password']."')";
                                
                return $this->executerRequeteManip($requete_creation_admin);
        }
        
        private function changerVersionWakkaConfig($chemin_wikini) {

                if(file_exists($chemin_wikini.'wakka.config.php')) { 
                        
                        $contenu_wakka_config = file_get_contents($chemin_wikini.'wakka.config.php');
                        $contenu_wakka_config_maj = str_replace('"wikini_version" => "0.4.3"','"wikini_version" => "0.5.0"',$contenu_wakka_config);
                        $contenu_wakka_config_maj = str_replace("'wikini_version' => '0.4.3'","'wikini_version' => '0.5.0'",$contenu_wakka_config_maj);
                        
                        if(self::dry_run) {
                                echo 'Wakka Config mis à jour '.$contenu_wakka_config_maj.NL;
                        } else {
                                //file_put_contents($chemin_wikini.'wakka.config.php', $contenu_wakka_config_maj);
                        }
                        
                        echo 'Changement de la version de wikini '.NL;
                } else {
                        echo 'Attention ! le fichier '.$chemin_wikini.'wakka.config.php n\'existe pas '.NL;
                }
        }
        
        private function copierFichiersWikini($chemin_base_wiki_defaut, $chemin_wiki_dest) {
                        
                if(self::dry_run) {
                        echo 'copie de '.$chemin_base_wiki_defaut.' vers '.$chemin_wiki_dest.NL;
                        $copie_recursive = true;
                } else {
                        if(trim($chemin_base_wiki_defaut) != '/' && trim($chemin_wiki_dest) != '/') { 
                                $copie_recursive = shell_exec( " cp -Rf -a ".$chemin_base_wiki_defaut."* ".$chemin_wiki_dest." 2>&1 " );
                        }
                }
                
                return $copie_recursive;
        }
        
        private function ajoutPageFormatees($chemin_wikini, $utilisateur) {
                
                $chemin_base_wiki_defaut = $this->config['appli']['chemin_wiki_defaut'];
                require_once($chemin_base_wiki_defaut.'wakka_class.php');
                
                $nom_admin = $this->config['appli']['nom_admin_wiki'];
                
                $chemin_wikini = rtrim($chemin_wikini,'/');
                require_once($chemin_wikini.'/wakka.config.php');
                
                // la variable $wakkaConfig est contenu dans le fichier wakka.config.php
                $config = $wakkaConfig;
                
                $wiki = new Wiki($config);
                $wiki->SetGroupACL("admins", $nom_admin);
                
                $wiki->setUser($utilisateur);
                                        
                //insertion des pages de documentation et des pages standards 
                $d = dir($chemin_base_wiki_defaut.'/setup/doc/');
                
                while ($doc = $d->read()){
                        
                        if (is_dir($doc) || substr($doc, -4) != '.txt') {continue;}
                        
                        $pagecontent = implode ('', file($chemin_base_wiki_defaut.'/setup/doc/'.$doc));
                        $pagecontent = mb_convert_encoding($pagecontent,'UTF-8','ISO-8859-15'); 
                        if ($doc=='_root_page.txt'){
                                $pagename = $config["root_page"];
                        }else{
                                $pagename = substr($doc,0,strpos($doc,'.txt'));
                        }
                        
                        $base = $config['mysql_database'];
        
                        $requete_existence_page = "Select tag from ".$base.".".$config['table_prefix']."pages where tag='$pagename'";
                        $existence_page = $this->executerRequete($requete_existence_page);
                        if (is_array($existence_page) && count($existence_page) > 0) {
                                echo 'la page '.$pagename.' existe déjà '.NL;
                        } else {
                                                                
                                echo 'Ajout de la page '.$pagename.NL;
                                
                                $requete_maj_pages_anciennes = "UPDATE ".$base.".".$config['table_prefix']."pages ".
                                        "SET ".
                                        "latest = 'N'".
                                        "WHERE tag = '$pagename'";
        
                                $reussite = $this->executerRequeteManip($requete_maj_pages_anciennes);
                                
                                $requete_insertion_page = "INSERT INTO ".$base.".".$config['table_prefix']."pages ".
                                        "SET tag = '$pagename', ".
                                        "body = ".$this->bdd->quote($pagecontent).", ".
                                        "user = '".$nom_admin."', ".
                                        "owner = '".$nom_admin."', " .
                                        "time = now(), ".
                                        "latest = 'Y'";
        
                                $reussite = $this->executerRequeteManip($requete_insertion_page);
                                
                                if(!$reussite) {
                                        echo 'echec de l\'ajout de la page '.$pagename.NL;      
                                } else {
                                
                                        // mise à jour des liens entre pages
                                        $wiki->SetPage($wiki->LoadPage($pagename,"",0));
                                        $wiki->ClearLinkTable();
                                        $wiki->StartLinkTracking();
                                        $wiki->TrackLinkTo($pagename);
                                        $wiki->StopLinkTracking();
                                        $wiki->WriteLinkTable();
                                        $wiki->ClearLinkTable();
                                }
                        }
                }       
        }
}
?>
Subversion Repositories Applications.projet

(root)/trunk/jrest/services/MigrationWiki.php – Rev 390
