WebSVN – eFlore/Applications.coel – Diff – /trunk/scripts/modules/import/Import.php

 	private $bdd = null;
 	private $auteurs = array();
 	protected $parametres_autorises = array(
 			'-n' => array(true, false, 'Nom du fichier à importer.'));
+	protected $colonnes_obligatoires = array();
+	protected $colonnes_acceptees = array();
 	protected $cache_auteur = array();
 	public function __construct($script_nom, $parametres) {
 		parent::__construct($script_nom, $parametres);
-		$this->bdd = new Bdd();
 		$this->bdd = new Bdd();
+	}
 	public function executer() {
 		try {
 	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 'communes.ini' ".
+			$erreur = "Veuillez configurer le projet en créant le fichier 'import.ini' ".
-					"dans le dossier du module de script du projet à partir du fichier 'config.defaut.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');
+	}
+	private function charger($fichier) {
-	private function charger($fichier) {
+		// vérification existence fichier
+		if(!file_exists(Config::get('dossiertmp').$fichier)) {
-		// vérifier si fichier existe
+			$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);
+		}
+		$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]);
+		}
-		// charger fichier
+		$lignes = array();
-		// vérifier séparateur
+		while($ligne = fgetcsv($pointeur, 0, ";")) {
+			$ligne_inseree = array();
+			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
+			$ligne_inseree[] = $this->formaterNomComplet($ligne, $index_colonnes_importees);
+			$lignes[] = "(".implode(",", $ligne_inseree).")";
+		}
-		// vérifier nom colonne
-		// vérifier si colonne "titre" et "auteur" sont bien présent
+		// Ajout de la colonne nom complet aux champs de la requête
-		// modifier champ editeur ajouter AUTRES##
+		$colonnes_importees[] = 'cpu_fmt_nom_complet';
+		$this->insererPublications($colonnes_importees, $lignes);
+	}
-		// vérifier si auteurs sont déjà présents et récupérer le numéro (publi_a_pers)
+	protected function formaterNomComplet($ligne, $roles) {
+		// TODO: écrire la fonction
+		return 'aaaaa';
+	}
+	private function insererPublications(&$colonnes, &$publications) {
+		$requete = "INSERT INTO $table ".
+				   	"(".implode(',', $colonnes).") ".
+				   "VALUES ".implode(","."\n", $publications)."\n";
-		// créer champ nom complet
+		echo $requete;exit;
-		// faire un insert
+	}
+	private function traiterChamp($valeur, $role) {
+		switch($role) {
-		$chemin = Config::get('dossiertmp').$fichier;
+			case 'auteur':
+				$valeur = $this->obtenirInfosAuteur($valeur);
+			break;
+			case 'editeur':
+				$valeur = 'AUTRES##'.$valeur;
+			break;
+		}
-		$table = Config::get('tables.publication');
+		return $this->bdd->proteger($valeur);
+	}
-		$requete = "LOAD DATA INFILE '$chemin' ".
+	private function obtenirInfosAuteur($auteur) {
+		$retour = $auteur;
+		if(isset($cache_auteur[$auteur])) {
+			$retour = $cache_auteur[$auteur];
+		} else {
+			$auteur = $this->fabriquerCombinaisonsAuteur($auteur);
+			$auteur_req = "(".implode(', ', $auteur).")";
+			$requete = "SELECT cp_id_personne FROM coel_personne WHERE cp_fmt_nom_complet IN ".$auteur_req;
+			$infos_auteur = $this->bdd->recupererTous($requete);
-			" INTO TABLE $table ".
+			if(!empty($infos_auteur)) {
+				$retour = $infos_auteur[0]['cp_id_personne'];
-			'CHARACTER SET utf8 '.
+				$cache_auteur[$auteur] = $infos_auteur[0]['cp_id_personne'];
+			} else {
+				$cache_auteur[$auteur] = $auteur;
+			}
+		}
+		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);
-			'FIELDS '.
+		$combinaisons = array();
-			"	TERMINATED BY ';' ".
+		foreach($auteur_tab as &$element_auteur) {
+			$combinaisons[] = array(
-			"	ENCLOSED BY '\"' ".
+								// é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])));
-			"	ESCAPED BY '\\\' ".
+			$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])));
+		}
+		// Elimination d'éventuels doublons
+		array_unique($possibilites_auteurs);
-			'IGNORE 0 LINES (`cpu_ce_truk_editeur`, `cpu_collection`, `cpu_indication_nvt`, `cpu_fascicule`, `cpu_date_parution`, `cpu_truk_pages`, `cpu_titre`, `cpu_fmt_auteur`, cpu_resume_motcle)';
+		$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));
+			}
+		}
-		$this->bdd->requeter($requete);
+		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;
+	}
+}

Subversion Repositories eFlore/Applications.coel

(root)/trunk/scripts/modules/import/Import.php – Rev 1855 → 1856