<?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);
	}
}
?>