Subversion Repositories eFlore/Applications.coel

<?php

/**

 * Exemple lancement:

 * /opt/lampp/bin/php -d memory_limit=3500M cli.php import -n

 */

class Import extends Script {

	private $bdd = null;

	private $auteurs = array();

	protected $parametres_autorises = array(

			'-n' => array(true, false, 'Nom du fichier à importer.'),

			'-u' => array(false, false, 'Infos utilisateur sous forme de JSON contenant : id, session et ip'));

	protected $table_publication = null;

	protected $table_auteur = null;

	protected $table_publication_a_auteur = null;

	protected $table_meta = null;

	protected $id_table_publication = null;

	protected $id_table_publication_personne = null;

	protected $id_role_auteur = null;

	protected $colonnes_obligatoires = array();

	protected $colonnes_acceptees = array();

	protected $cache_auteur = array();

	protected $auteurs_a_publis = array();

	protected $publis_a_auteurs = array();

	protected $id_utilisateur = 0;

	protected $id_session = 0;

	protected $ip_utilisateur = "127.0.01";

	const ETAT_AJOUTER = 1;

	public function __construct($script_nom, $parametres) {

		parent::__construct($script_nom, $parametres);

		$this->bdd = new Bdd();

	}

	public function executer() {

		try {

			$this->initialiserScript();

			$cmd = $this->getParametre('a');

			$fichier = $this->getParametre('n');

			$utilisateur = $this->getParametre('u');

			$this->traiterInfosUtilisateur($utilisateur);

			switch ($cmd) {

				case "import" :

					$resultat = $this->charger($fichier); break;

				default :

					$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));

			}

		} catch (Exception $erreur) {

			$this->traiterErreur($erreur->getMessage());

		}

		// renvoi du résultat vers la sortie php

		// car le script est surtout destiné à être appelé par un web service

		echo $resultat;

		exit;

	}

	private function traiterInfosUtilisateur($utilisateur) {

		$utilisateur_infos = json_decode($utilisateur, true);

		if(!empty($utilisateur_infos)) {

			$this->id_utilisateur = !empty($utilisateur_infos['id']) ? $utilisateur_infos['id'] : $this->id_utilisateur;

			$this->id_session = !empty($utilisateur_infos['session']) ? $utilisateur_infos['session'] : $this->id_session;

			$this->ip_utilisateur = !empty($utilisateur_infos['ip']) ? $utilisateur_infos['ip'] : $this->ip_utilisateur;

		}

	}

	private function initialiserScript() {

		$fichierIni = $this->getScriptChemin().'import.ini';

		if (file_exists($fichierIni)) {

			Config::charger($fichierIni);

		} else {

			$erreur = "Veuillez configurer le projet en créant le fichier 'import.ini' ".

					"dans le dossier du module de script du projet à partir du fichier 'import.defaut.ini'.";

			throw new Exception($erreur);

		}

		$this->colonnes_obligatoires= Config::get('champs_obligatoires');

		$this->colonnes_acceptees = Config::get('champs');

		$tables = Config::get('tables');

		$this->table_publication = $tables['publication'];

		$this->table_auteur = $tables['auteur'];

		$this->table_publication_a_auteur = $tables['publication_a_auteur'];

		$this->table_meta = $tables['meta'];

		$this->id_table_publication = $tables['id_table_publication'];

		$this->id_table_publication_personne = $tables['id_table_publication_personne'];

		$this->id_role_auteur = $tables['id_role_auteur'];

	}

	private function charger($fichier) {

		// vérification existence fichier

		if(!file_exists(Config::get('dossiertmp').$fichier)) {

			$erreur = "Le fichier ".Config::get('dossiertmp').$fichier." n'existe pas.";

			throw new Exception($erreur);

		}

		$pointeur = fopen(Config::get('dossiertmp').$fichier, "r");

		// Chargement de la première colonne (qui contient les noms de colonnes à importer

		$colonnes = fgetcsv($pointeur, 0, ";");

		// Vérification des colonnes obligatoires et en même temps du séparateur

		if(count($colonnes) < 2 || !array_intersect(array_keys($this->colonnes_obligatoires), $colonnes)) {

			$erreur = "Le fichier ne contient pas les colonnes obligatoires : ".implode(',', array_keys($this->colonnes_obligatoires))."\n";

			$erreur .= "ou bien n'est pas séparé par le caractère ';' ";

			throw new Exception($erreur);

		}

		//TODO: vérifier si les deux index ci dessous ne font pas double emploi

		// Création d'un index des colonnes qui seront importées dans la fiche en les associant

		// au numéro de colonne dans la feuille csv

		$index_colonnes_importees = array_intersect(array_keys($this->colonnes_acceptees), $colonnes);

		$colonnes_importees = array();

		foreach($index_colonnes_importees as $index_colonne_importee) {

			$colonnes_importees[] = $this->colonnes_acceptees[$index_colonne_importee];

		}

		$index_colonnes_refusees = array_keys(array_diff($colonnes, array_keys($this->colonnes_acceptees)));

		// Création d'un index associant chaque numéro de colonne importée à son rôle

		// pour y apporter des traitement spécifiques

		$index_colonnes_importees = $colonnes;

		foreach($index_colonnes_refusees as $colonne_refusee) {

			unset($index_colonnes_importees[$colonne_refusee]);

		}

		$roles_a_num_colonnes = array_flip($index_colonnes_importees);

		// Ajout de la colonne nom complet aux champs de la requête

		$colonnes_importees[] = 'cpu_fmt_nom_complet';

		$nb_publis_inserees = 0;

		$lignes = array();

		while($ligne = fgetcsv($pointeur, 0, ";")) {

			$ligne_inseree = array();

			// Traitement des champs suivant leur role

			foreach($ligne as $index => &$valeur) {

				if(!in_array($index, $index_colonnes_refusees)) {

					$ligne_inseree[] = $this->traiterChamp($valeur, $index_colonnes_importees[$index]);

				}

			}

			// Ajout du nom complet formaté de la publication

			$nom_complet = $this->bdd->proteger($this->formaterNomComplet($ligne, $index_colonnes_importees));

			$ligne_inseree[] = $nom_complet;

			$id_publication = $this->insererPublication($colonnes_importees, $ligne_inseree);

			// TODO: quoi faire en cas d'échec pour une publication ?

			if(!empty($id_publication)) {

				$nb_publis_inserees++;

				// Pour aller plus vite on pourrait éventuellement faire une grosse requete d'ajout des publications

				// à personne à la fin, mais ça nous priverait de faire une transaction (TODO: faire une transaction)

				$nb_auteurs_lies = $this->insererLiensPublicationAuteurs($id_publication, $ligne[$roles_a_num_colonnes['auteur']]);

			}

		}

		return $nb_publis_inserees;

	}

	private function insererPublication(&$colonnes, &$publication) {

		$requete = "INSERT INTO ".$this->table_publication." ".

				"(".implode(',', $colonnes).") ".

				"VALUES (".implode(",", $publication).")";

		$insertion = $this->bdd->executer($requete);

		$id_publi = $this->bdd->recupererIdDernierAjout();

		// Historisation de l'ajout

		$histo = $this->creerXmlHisto(array_combine($colonnes, $publication));

		$id_meta = $this->historiser($this->id_table_publication, $id_publi, $histo);

		// Affectation des méta données concernat l'ajout à la publication

		$requete_affectation_meta = "UPDATE  ".$this->table_publication." ".

				"SET cpu_ce_meta = ".$id_meta." ".

				"WHERE cpu_id_publication = ".$id_publi;

		$this->bdd->executer($requete_affectation_meta);

		return $id_publi;

	}

	protected function insererLiensPublicationAuteurs($id_publication, &$auteurs) {

		$colonnes = array('cpuap_id_publication', 'cpuap_id_personne', 'cpuap_id_role', 'cpuap_ce_truk_type', 'cpuap_ordre', 'cpuap_ce_meta');

		$requete = "INSERT IGNORE INTO ".$this->table_publication_a_auteur." ".

				"(".implode(",", $colonnes).") VALUES ";

		// L'ordre des auteurs commence à 1

		$ordre_auteur = 1;

		// Découpage des différents auteurs

		$auteurs_tab = explode(',', $auteurs);

		$auteurs_tab = array_filter($auteurs_tab);

		// Les auteurs sont normalement cités dans l'ordre dans l'import

		foreach($auteurs_tab as $auteur) {

			// si les infos auteurs sont un tableau dans le cache alors l'id existe bien en base de données

			if(is_array($this->cache_auteur[$auteur])) {

				$id_auteur = $this->cache_auteur[$auteur]['cp_id_personne'];

				$valeurs = array($id_publication, $id_auteur, $this->id_role_auteur, "NULL", $ordre_auteur, "0");

				$requete_insertion = $requete." (".implode(',', $valeurs).") ";

				$liaison = $this->bdd->executer($requete_insertion);

				// Historisation de l'ajout

				$histo = $this->creerXmlHisto(array_combine($colonnes, $liaison));

				$cle_liaison = $id_publication.'-'.$this->id_role_auteur.'-'.$id_auteur;

				$id_meta = $this->historiser($this->id_table_publication_personne, $cle_liaison, $histo);

				// Affectation des méta données concernant l'ajout à la publication à auteur

				$requete_affectation_meta = "UPDATE  ".$this->table_publication_a_auteur." ".

						"SET cpuap_ce_meta = ".$id_meta;

				$this->bdd->executer($requete_affectation_meta);

			}

			// L'ordre des auteurs est conservé même pour ceux qui n'existe pas dans la bdd

			$ordre_auteur++;

		}

	}

	protected function creerXmlHisto($donnees) {

		// Création du xml de l'enregistrement à historiser

		$info = null;

		$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";

		$xml = null;

		foreach ($donnees as $cle => $valeur) {

			// Pour éviter un éventuel double échappement des valeurs

			$valeur = stripslashes($valeur);

			$valeur = trim($valeur, "'");

			if (!is_null($valeur) && $valeur != '') {

				$xml .= "<$cle>$valeur</$cle>\n";

			}

		}

		if ($xml !== null) {

			$info = sprintf($xml_tpl, $xml);

			$info = $this->bdd->proteger($info);

		}

		return $info;

	}

	protected function historiser($table_id, $ligne_cle, $info) {

		date_default_timezone_set('Europe/Paris');

		// Pré-traitement des variables

		$info = (is_null($info)) ? 'NULL' : $info;

		// Historisation (Ajout des méta-données)

		$requete = 	'INSERT INTO coel_meta_historique_ligne '.

				'	(cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.

				'VALUES ('.

				"		$table_id, ".

				'		"'.$ligne_cle.'", '.

				"		$info, ".

				'		"'.date('Y-m-d H:i:s', time()).'", '.

				"		$this->id_utilisateur, ".

				"		".self::ETAT_AJOUTER.", ".

				'		"'.$this->ip_utilisateur.'", '.

				'		"'.$this->id_session.'") ';

		$resultat = $this->bdd->executer($requete);

		return $this->bdd->recupererIdDernierAjout();

	}

	protected function formaterNomComplet($ligne, $roles) {

		$roles = array_flip($roles);

		// Intitulé de la publication complet : fmt_auteur, date_parution(année). titre. Editeur (nom), collection, fascicule, indication_nvt. pages.

		// indication_nvt = serie_tome

		$champs_nom_complet = array('auteur', 'annee', 'titre', 'editeur', 'intitule_revue', 'fascicule', 'serie_tome', 'pages');

		$champs_fmt = array();

		$fmt_nom_complet = "";

		foreach($champs_nom_complet as $champ) {

			$index = $roles[$champ];

			if(!isset($ligne[$index])) {

				$champs_fmt[$champ] = "";

			} else {

				$champs_fmt[$champ] = $ligne[$index];

			}

		}

		$indication_nvt_pages = array($champs_fmt['serie_tome'], $champs_fmt['pages']);

		$indication_nvt_pages = array_filter($indication_nvt_pages, 'strlen');

		$indication_nvt_pages = trim(implode(". ", $indication_nvt_pages));

		$indication_nvt_pages .= !empty($indication_nvt_pages) ? "." : "";

		$annee_titre_editeur = array($champs_fmt['annee'], $champs_fmt['titre'], $champs_fmt['editeur']);

		$annee_titre_editeur = array_filter($annee_titre_editeur, 'strlen');

		$annee_titre_editeur = trim(implode(". ", $annee_titre_editeur));

		$fmt_nom_complet =  array($champs_fmt['auteur'],

							$annee_titre_editeur,

							$champs_fmt['intitule_revue'],

							$champs_fmt['fascicule'],

							$indication_nvt_pages);

		$fmt_nom_complet = array_filter($fmt_nom_complet, 'strlen');

		$fmt_nom_complet = implode(", ", $fmt_nom_complet);

		return $fmt_nom_complet;

	}

	private function traiterChamp($valeur, $role) {

		switch($role) {

			case 'auteur':

				$valeur = $this->traiterChampAuteur($valeur);

			break;

			case 'editeur':

				$valeur = 'AUTRE##'.$valeur;

			break;

		}

		return $this->bdd->proteger($valeur);

	}

	private function traiterChampAuteur($auteur_intitule) {

		$auteurs_fmt = array();

		$auteurs_tab = explode(',', $auteur_intitule);

		foreach($auteurs_tab as $auteur) {

			if(!empty(trim($auteur))) {

				$auteurs_fmt[] = $this->obtenirInfosAuteur($auteur);

			}

		}

		return implode(', ', $auteurs_fmt);

	}

	private function obtenirInfosAuteur($auteur_intitule) {

		$retour = $auteur_intitule;

		// Si on déjà recherché et trouvé (ou non l'auteur)

		if(isset($this->cache_auteur[$auteur_intitule])) {

			// On renvoie son nom complet formaté s'il existe en bdd ou sinon

			// le nom qui a été donné dans la feuille csv

			$retour = !empty($this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet']) ?

				$this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet'] :

				$auteur_intitule;

		} else {

			// Recherche de l'auteur sur un maximum du combinaisons possible des variations

			// de son nom et prénom

			$auteur = $this->fabriquerCombinaisonsAuteur($auteur_intitule);

			$auteur_req = "(".implode(', ', $auteur).")";

			$requete = "SELECT cp_id_personne, cp_fmt_nom_complet FROM ".$this->table_auteur." WHERE cp_fmt_nom_complet IN ".$auteur_req;

			$infos_auteur = $this->bdd->recupererTous($requete);

			// Stockage en cache de la ligne de bdd si trouvé,

			// de la valeur brute sinon

			if(!empty($infos_auteur)) {

				$retour = $infos_auteur[0]['cp_fmt_nom_complet'];

				$this->cache_auteur[$auteur_intitule] = $infos_auteur[0];

				// Stocker le nom d'auteur sous les deux formes (fmt nom complet et tel que saisi), facilite la recherche

				// plus tard lors de la liaison des publications aux auteurs

				$this->cache_auteur[$infos_auteur[0]['cp_fmt_nom_complet']] = $infos_auteur[0];

			} else {

				$retour = $auteur_intitule;

				$this->cache_auteur[$auteur_intitule] = $auteur_intitule;

			}

		}

		return $retour;

	}

	private function fabriquerCombinaisonsAuteur($auteur) {

		$auteur = trim($auteur);

		$auteurs_formates = array($this->bdd->proteger($auteur));

		// Séparation des élements de l'auteur des espaces pour obtenir

		// les noms et prénoms (Ex. "Carl Von Linné" => "Carl", "Von", "Linné")

		$auteur_tab = explode(' ', $auteur);

		$auteur_tab = array_filter($auteur_tab);

		$combinaisons = array();

		foreach($auteur_tab as &$element_auteur) {

			$combinaisons[] = array(

								// élement tel quel (Ex: "Linné")

								$element_auteur,

								// possibilité de l'initiale seule (Ex: "L")

								substr($element_auteur, 0, 1),

								// possibilité de l'initiale avec un point du genre (Ex: "L.")

								substr($element_auteur, 0, 1)."."

							);

		}

		// Fabrication de toutes les combinaisons possibles des parties de noms ci-dessus

		// pour deux et trois élements en faisant plusieurs produits cartésiens

		// car le nom peut être combiné différement de celui en base de données

		// (Ex. : "Carl Von Linné" VS "C. Von Linné" ou "C. V. Linné" ou encore "Von Linné C." etc...)

		// C'est moche et pas très élégant mais bon ça marche dans 90% des cas

		// On ne teste pas plus que 3 combinaisons, car ça serait très très couteux

		// TODO: faire mieux et factoriser les appels ci dessous

		if(count($auteur_tab) > 2) {

			// Cas du nom à trois parties (genre "Carl Von Linné")

			$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1], $combinaisons[2]));

			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[0], $combinaisons[2], $combinaisons[1])));

			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[2], $combinaisons[0])));

			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0], $combinaisons[2])));

			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[1], $combinaisons[0])));

			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[0], $combinaisons[1])));

		} else {

			// Cas du nom à trois parties (genre "Carl Linné")

			$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1]));

			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0])));

		}

		$auteurs_formates = array();

		foreach($possibilites_auteurs as &$possibilite) {

			$initiales = true;

			// Suppression des possibilités ne contenant que des initiales avec ou sans point

			foreach($possibilite as &$chars) {

				$initiales = $initiales && mb_strlen($chars) <= 2;

			}

			if(!$initiales) {

				$auteurs_formates[] = $this->bdd->proteger(implode(" ", $possibilite));

			}

		}

		return $auteurs_formates;

	}

	// http://stackoverflow.com/questions/6311779/finding-cartesian-product-with-php-associative-arrays

	function cartesian($input) {

		// filter out empty values

		$input = array_filter($input);

		$result = array(array());

		foreach ($input as $key => $values) {

			$append = array();

			foreach($result as $product) {

				foreach($values as $item) {

					$product[$key] = $item;

					$append[] = $product;

				}

			}

			$result = $append;

		}

		return $result;

	}

}

?>