| New file |
|---|
| 0,0 → 1,190 |
|---|
| <?php |
| // declare(encoding='UTF-8'); |
| /** |
| * Réalise la migration des obs du référentiel bdnff vers le référentie bdtfx |
| * |
| * @category php 5.2 |
| * @package Cel/Scripts |
| * @author Aurelien PERONNET <aurelien@tela-botanica.org> |
| * @author Jean-Pascal MILCENT <jpm@tela-botanica.org> |
| * @copyright Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org) |
| * @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL |
| * @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL |
| * @version $Id$ |
| */ |
| class MigrationReferentiel { |
| |
| private $bdd = null; |
| private $script = null; |
| |
| private $table_eflore = 'tb_eflore.bdtfx_v1_01'; |
| private $table_cel = 'tb_cel.cel_obs'; |
| private $correspondance_nn_sel_nn_ret = null; |
| private $infos_noms = array(); |
| |
| private $obs_sans_nn = array(); |
| private $obs_a_modifier = array(); |
| private $modif_douteuses = array(); |
| private $modif_familles = 0; |
| |
| private $chemin_log = '/home/telabotap/www/tmp/migration_noms_log.csv'; |
| private $fp = null; |
| |
| public function __construct(Conteneur $conteneur) { |
| $this->bdd = $conteneur->getBdd(); |
| $this->script = $conteneur->getScript(); |
| $this->initialiserLog(); |
| } |
| |
| public function executer($arguments) { |
| if (isset($arguments[0]) == false) { |
| throw new Exception("Veuillez indiquer l'action à réaliser en paramètre.", E_USER_ERROR); |
| } |
| $action = $arguments[0]; |
| switch ($action) { |
| case 'migration_referentiel' : |
| $this->migrerReferentiel(); |
| break; |
| } |
| fclose($this->fp); |
| } |
| |
| private function migrerReferentiel() { |
| |
| echo "-------------------------------------------------------------------\n"; |
| echo " ETAPE 1. Paramétrage ... \n"; |
| echo "-------------------------------------------------------------------\n"; |
| $this->chargerInfosNoms(); |
| |
| echo "-------------------------------------------------------------------\n"; |
| echo " ETAPE 2. Chargement des observations ... \n"; |
| echo "-------------------------------------------------------------------\n"; |
| |
| $requete_selection_obs = 'SELECT id_observation, nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, nt, '. |
| 'famille, nom_referentiel FROM '.$this->table_cel; |
| $liste_obs = $this->bdd->requeter($requete_selection_obs); |
| echo sizeof($liste_obs)." observations sélectionnées \n"; |
| |
| foreach ($liste_obs as $obs) { |
| if($this->doitChangerNomRetenu($obs)) { |
| $nouveau_nom = $this->getInfosNouveauNumNomRetenu($obs); |
| $this->obs_a_modifier[] = array( |
| 'id' => $obs['id_observation'], |
| 'nouveau_nom_sci_retenu' => $nouveau_nom['nom_complet'], |
| 'nouveau_nn_retenu' => $nouveau_nom['num_nom'], |
| 'nouveau_num_tax' => $nouveau_nom['num_taxonomique'], |
| 'nouvelle_famille' => $nouveau_nom['famille'] |
| ); |
| $this->logger($obs, $nouveau_nom); |
| } |
| } |
| |
| echo "-------------------------------------------------------------------\n"; |
| echo " ETAPE 3. modification des observations ... \n"; |
| echo "-------------------------------------------------------------------\n"; |
| echo sizeof($this->obs_a_modifier)." obs doivent voir changer leur nom retenu \n"; |
| echo $this->modif_familles." obs doivent voir changer leur famille \n"; |
| echo sizeof($this->obs_sans_nn)." observations n'ont pas de num nom \n"; |
| echo sizeof($this->modif_douteuses)." modifications sont douteuses et ne seront pas effectuées \n"; |
| echo "\n"; |
| $this->executerRequeteMiseAJour(); |
| echo "\n"; |
| echo "-------------------------------------------------------------------\n"; |
| echo " Migration des noms terminée ... \n"; |
| echo "-------------------------------------------------------------------\n"; |
| |
| } |
| |
| private function chargerInfosNoms() { |
| |
| $requete = 'SELECT num_nom, num_nom_retenu, nom_complet, num_taxonomique, famille FROM '.$this->table_eflore; |
| $nums = $this->bdd->requeter($requete); |
| |
| foreach ($nums as $num) { |
| $this->correspondance_nn_sel_nn_ret[$num['num_nom']] = $num['num_nom_retenu']; |
| $this->infos_noms[$num['num_nom']] = $num; |
| } |
| |
| echo sizeof($this->correspondance_nn_sel_nn_ret)." noms sélectionnés\n"; |
| } |
| |
| private function doitChangerNomRetenu($obs) { |
| $changement = false; |
| $nn_retenu_obs = $obs['nom_ret_nn']; |
| $nn_saisi_obs = $obs['nom_sel_nn']; |
| $famille_saisie_obs = $obs['famille']; |
| $sans_nn_retenu = false; |
| |
| if($nn_saisi_obs != '') { |
| if(!isset($this->correspondance_nn_sel_nn_ret[$nn_saisi_obs]) || $this->correspondance_nn_sel_nn_ret[$nn_saisi_obs] == 0) { |
| $this->obs_sans_nn[] = $obs['id_observation']; |
| $sans_nn_retenu = true; |
| } else { |
| if($nn_retenu_obs != $this->correspondance_nn_sel_nn_ret[$nn_saisi_obs] && str_word_count($obs['nom_ret']) >= 1) { |
| $changement = true; |
| } |
| } |
| |
| if(!$sans_nn_retenu && $famille_saisie_obs != $this->infos_noms[$nn_saisi_obs]['famille']) { |
| $changement = true; |
| $this->modif_familles++; |
| } |
| } |
| |
| if($changement && str_word_count($obs['nom_ret']) == 1) { |
| $this->modif_douteuses[] = $obs; |
| $changement = false; |
| } |
| |
| return $changement; |
| } |
| |
| private function getInfosNouveauNumNomRetenu($obs) { |
| $nouveau_nn_ret = $this->correspondance_nn_sel_nn_ret[$obs['nom_sel_nn']]; |
| return $this->infos_noms[$nouveau_nn_ret]; |
| } |
| |
| private function executerRequeteMiseAJour() { |
| $total = 0; |
| foreach($this->obs_a_modifier as $valeurs) { |
| $requete = $this->assemblerRequeteMiseAJour($valeurs); |
| $migration_noms = $this->bdd->executer($requete); |
| if ($migration_noms) { |
| $total++; |
| $this->script->afficherAvancement('Migration des noms (par 1)', $total); |
| } else { |
| echo $requete."\n"; |
| exit('Erreur lors de la migration des noms de l\'observation '.$valeurs['id']."\n"); |
| } |
| } |
| } |
| private function proteger($valeur) { |
| return $this->bdd->proteger($valeur); |
| } |
| |
| private function assemblerRequeteMiseAJour($tableau) { |
| $requete = 'UPDATE '.$this->table_cel.' '. |
| 'SET nom_ret = '.$this->proteger($tableau['nouveau_nom_sci_retenu']).', '. |
| 'nom_ret_nn = '.$this->proteger($tableau['nouveau_nn_retenu']).', '. |
| 'nt = '.$this->proteger($tableau['nouveau_num_tax']).', '. |
| 'famille = '.$this->proteger($tableau['nouvelle_famille']).', '. |
| 'nom_referentiel = "bdtfx:v1.01" '. |
| 'WHERE id_observation = '.$this->proteger($tableau['id']); |
| return $requete; |
| } |
| |
| private function initialiserLog() { |
| $this->fp = fopen($this->chemin_log, 'w'); |
| $colonnes = 'nom sélectionné, nn nom sélectionné, ancien nom retenu, nn ancien nom retenu, '. |
| 'nouveau nom sélectionné, nn nouveau nom sélectionné'."\n"; |
| fwrite($this->fp, $colonnes); |
| } |
| |
| private function logger($obs, $nouveau_nom) { |
| $chaine = '"'.$obs['nom_sel'].'"'.','.'"'.$obs['nom_sel_nn'].'"'.','.'"'.$obs['nom_ret'].'"'.','. |
| '"'.$obs['nom_ret_nn'].'"'.','.'"'.$nouveau_nom['nom_complet'].'"'.','. |
| '"'.$nouveau_nom['num_nom'].'"'."\n"; |
| fwrite($this->fp, $chaine); |
| } |
| } |
| ?> |