Subversion Repositories eFlore/Applications.coel

Rev

Rev 1928 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1855 delphine 1
<?php
2
/**
3
 * Exemple lancement:
4
 * /opt/lampp/bin/php -d memory_limit=3500M cli.php import -n
5
 */
6
class Import extends Script {
7
	private $bdd = null;
8
	private $auteurs = array();
9
	protected $parametres_autorises = array(
1882 aurelien 10
			'-n' => array(true, false, 'Nom du fichier à importer.'),
11
			'-u' => array(false, false, 'Infos utilisateur sous forme de JSON contenant : id, session et ip'));
1855 delphine 12
 
1857 aurelien 13
	protected $table_publication = null;
14
	protected $table_auteur = null;
1862 aurelien 15
	protected $table_publication_a_auteur = null;
1882 aurelien 16
	protected $table_meta = null;
1929 mathias 17
	protected $table_structure = 'coel_structure'; // @TODO configurer
18
	protected $table_collection = 'coel_collection'; // @TODO configurer
19
	protected $table_collection_bota = 'coel_collection_botanique'; // @TODO configurer
1857 aurelien 20
 
1882 aurelien 21
	protected $id_table_publication = null;
22
	protected $id_table_publication_personne = null;
23
 
1862 aurelien 24
	protected $id_role_auteur = null;
25
 
1856 aurelien 26
	protected $colonnes_obligatoires = array();
27
	protected $colonnes_acceptees = array();
1855 delphine 28
 
1856 aurelien 29
	protected $cache_auteur = array();
1862 aurelien 30
	protected $auteurs_a_publis = array();
31
	protected $publis_a_auteurs = array();
1856 aurelien 32
 
1882 aurelien 33
	protected $id_utilisateur = 0;
34
	protected $id_session = 0;
35
	protected $ip_utilisateur = "127.0.01";
36
 
37
	const ETAT_AJOUTER = 1;
38
 
1855 delphine 39
	public function __construct($script_nom, $parametres) {
40
		parent::__construct($script_nom, $parametres);
41
		$this->bdd = new Bdd();
42
	}
43
 
44
	public function executer() {
45
		try {
46
			$this->initialiserScript();
47
			$cmd = $this->getParametre('a');
48
			$fichier = $this->getParametre('n');
1882 aurelien 49
			$utilisateur = $this->getParametre('u');
50
 
51
			$this->traiterInfosUtilisateur($utilisateur);
52
 
1855 delphine 53
			switch ($cmd) {
1928 delphine 54
				case "collections" :
55
					$resultat = $this->chargerCollections($fichier); break;
56
				case "publi" :
57
					$resultat = $this->chargerPubli($fichier); break;
1855 delphine 58
				default :
59
					$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
60
			}
61
		} catch (Exception $erreur) {
62
			$this->traiterErreur($erreur->getMessage());
63
		}
1857 aurelien 64
 
65
		// renvoi du résultat vers la sortie php
1862 aurelien 66
		// car le script est surtout destiné à être appelé par un web service
1857 aurelien 67
		echo $resultat;
1875 aurelien 68
		exit;
1855 delphine 69
	}
70
 
1882 aurelien 71
	private function traiterInfosUtilisateur($utilisateur) {
72
		$utilisateur_infos = json_decode($utilisateur, true);
73
		if(!empty($utilisateur_infos)) {
74
			$this->id_utilisateur = !empty($utilisateur_infos['id']) ? $utilisateur_infos['id'] : $this->id_utilisateur;
75
			$this->id_session = !empty($utilisateur_infos['session']) ? $utilisateur_infos['session'] : $this->id_session;
76
			$this->ip_utilisateur = !empty($utilisateur_infos['ip']) ? $utilisateur_infos['ip'] : $this->ip_utilisateur;
77
		}
78
	}
79
 
1855 delphine 80
	private function initialiserScript() {
81
		$fichierIni = $this->getScriptChemin().'import.ini';
82
		if (file_exists($fichierIni)) {
83
			Config::charger($fichierIni);
84
		} else {
1856 aurelien 85
			$erreur = "Veuillez configurer le projet en créant le fichier 'import.ini' ".
86
					"dans le dossier du module de script du projet à partir du fichier 'import.defaut.ini'.";
1855 delphine 87
			throw new Exception($erreur);
88
		}
1856 aurelien 89
 
90
		$this->colonnes_obligatoires= Config::get('champs_obligatoires');
91
		$this->colonnes_acceptees = Config::get('champs');
1857 aurelien 92
 
93
		$tables = Config::get('tables');
94
		$this->table_publication = $tables['publication'];
95
		$this->table_auteur = $tables['auteur'];
1862 aurelien 96
		$this->table_publication_a_auteur = $tables['publication_a_auteur'];
1882 aurelien 97
		$this->table_meta = $tables['meta'];
1862 aurelien 98
 
1882 aurelien 99
		$this->id_table_publication = $tables['id_table_publication'];
100
		$this->id_table_publication_personne = $tables['id_table_publication_personne'];
101
 
1862 aurelien 102
		$this->id_role_auteur = $tables['id_role_auteur'];
1855 delphine 103
	}
1929 mathias 104
 
105
	/**
106
	 * Importe des collections botaniques à partir de deux fichiers : $fichier-collections.csv et
107
	 * $fichier-collections-bota.csv
108
	 * Il faut donc fournir en paramètre seulement le début du nom de fichier. Ex :
109
	 * fichiers:
110
	 *  - rhone-alpes-collections.csv
111
	 *  - rhone-alpes-collections-bota.csv
112
	 * commande :
113
	 *  - php cli.php import -a collections -n rhone-alpes
114
	 */
1928 delphine 115
	private function chargerCollections($fichier) {
1929 mathias 116
 
117
		$separateur = "\t"; // @TODO configurer
118
		$fichierCollections = Config::get('dossiertmp').$fichier . '-collections.csv';
119
		$fichierCollectionsBota = Config::get('dossiertmp').$fichier . '-collections-bota.csv';
120
 
121
		// vérification existence fichiers
122
		if(!file_exists($fichierCollections)) {
123
			throw new Exception("Le fichier ".Config::get('dossiertmp').$fichierCollections." n'existe pas.");
124
		}
125
		if(!file_exists($fichierCollectionsBota)) {
126
			throw new Exception("Le fichier ".Config::get('dossiertmp').$fichierCollectionsBota." n'existe pas.");
127
		}
128
 
1928 delphine 129
		//ouvrir le fichier - collection
1929 mathias 130
		$pointeurCollections = fopen($fichierCollections, "r");
131
		// Chargement de la première colonne (qui contient les noms de colonnes à importer)
132
		$colonnes = fgetcsv($pointeurCollections, 0, $separateur);
133
		$colonnesParNom = array_flip($colonnes);
134
		//var_dump($colonnes);
135
		//var_dump($colonnesParNom);
136
 
1928 delphine 137
		// vérifier le nom des colonnes
1929 mathias 138
		// @TODO on verra plus tard
139
		/*if(count($colonnes) < 2 || !array_intersect(array_keys($this->colonnes_obligatoires), $colonnes)) {
140
		// Vérification des colonnes obligatoires et en même temps du séparateur
141
			$erreur = "Le fichier ne contient pas les colonnes obligatoires : ".implode(',', array_keys($this->colonnes_obligatoires))."\n";
142
			$erreur .= "ou bien n'est pas séparé par le caractère ';' ";
143
			throw new Exception($erreur);
144
		}*/
145
 
146
		$idCollectionsParIdTemp = array();
147
		// parcours du fichier "-collections.csv"
148
		while($ligne = fgetcsv($pointeurCollections, 0, $separateur)) {
149
			//var_dump($ligne);
150
			$nomStructure = $ligne[$colonnesParNom['cc_ce_structure']];
151
			if (empty($nomStructure) || is_numeric($nomStructure)) {
152
				echo "- omission de la structure pour cause de nom chelou [$nomStructure]\n";
153
				continue;
154
			}
155
			// tester l'existence de la structure
156
			$idStructure = $this->verifierExistenceStructureParNom($nomStructure);
157
			// si oui récupérer l'id
158
			//sinon créer la structure et récupérer son id
159
			if ($idStructure === false) {
160
				$idStructure = $this->creerStructure($nomStructure);
161
			}
162
			// remplacer le nom de la structure par son id
163
			// créer les collections et récupérer leur id
164
			// @TODO vérifier qu'elles existent pour ne pas insérer de doublons en relançant le script !!
165
			$idCollection = $this->creerCollection($idStructure, $ligne, $colonnesParNom);
166
			$idCollectionsParIdTemp[$ligne[$colonnesParNom['id']]] = $idCollection;
167
		}
168
 
1928 delphine 169
		//ouvrir le fichier collection botanique
1929 mathias 170
		$pointeurCollectionsBota = fopen($fichierCollectionsBota, "r");
171
		// Chargement de la première colonne (qui contient les noms de colonnes à importer)
172
		$colonnesBota = fgetcsv($pointeurCollectionsBota, 0, $separateur);
173
		$colonnesBotaParNom = array_flip($colonnesBota);
174
		//var_dump($colonnesBota);
175
		//var_dump($colonnesBotaParNom);
176
 
1928 delphine 177
		// vérifier les colonnes
1929 mathias 178
		// @TODO on verra plus tard
179
 
180
		// parcours du fichier "-collections-bota.csv"
181
		while($ligne = fgetcsv($pointeurCollectionsBota, 0, $separateur)) {
182
			// remplacer les noms des collections par leur id (créé précédemment)
183
			$ligne[$colonnesBotaParNom['ccb_id_collection']] = $idCollectionsParIdTemp[$ligne[$colonnesBotaParNom['ccb_id_collection']]];
184
			// créer/importer
185
			// @TODO vérifier qu'elles existent pour ne pas insérer de doublons en relançant le script !!
186
			$this->creerCollectionBota($ligne, $colonnesBotaParNom);
187
		}
1928 delphine 188
 
189
	}
1855 delphine 190
 
1929 mathias 191
	/**
192
	 * Si une structure ayant pour nom $nomStructure existe, retourne son
193
	 * identifiant numérique, sinon retourne false
194
	 */
195
	protected function verifierExistenceStructureParNom($nomStructure) {
196
		$idStructure = false;
197
		$nsp = $this->bdd->proteger($nomStructure);
198
		$requete = "SELECT cs_id_structure FROM " . $this->table_structure
199
			. " WHERE cs_nom = $nsp";
200
 
201
		$resultat = $this->bdd->recupererTous($requete);
202
		// var_dump($resultat);
203
		if (count($resultat) > 0) {
204
			$idStructure = $resultat[0]['cs_id_structure'];
205
		}
206
		return $idStructure;
207
	}
208
 
209
	/**
210
	 * Crée une structure portant le nom $nomStructure, sans rien fournir d'autre, et
211
	 * retourne l'identifiant numérique du novueau tuple
212
	 */
213
	protected function creerStructure($nomStructure) {
214
		$nsp = $this->bdd->proteger($nomStructure);
215
		$requete = "INSERT INTO " . $this->table_structure . " (cs_nom)"
216
			. " VALUES ($nsp)";
217
		//echo "REQ INS: $requete\n";
218
		$resultat = $this->bdd->executer($requete);
219
		$idStructure = $this->bdd->recupererIdDernierAjout();
220
 
221
		return $idStructure;
222
	}
223
 
224
	/**
225
	 * Crée une collection en la rattachant à la structure d'id $idStrucutre; la remplit
226
	 * avec les données issues de $ligne en se servant de $colonnesParNom pour accéder
227
	 * aux valeurs par clés textuelles; retourne l'identifiant numérique du novueau tuple
228
	 */
229
	protected function creerCollection($idStructure, $ligne, $colonnesParNom) {
230
		//echo "Insertion ! : "; var_dump($ligne); echo "<br/>";
231
		$nom = $this->bdd->proteger($ligne[$colonnesParNom['cc_nom']]);
232
		$desc = $this->bdd->proteger($ligne[$colonnesParNom['cc_description']]);
233
		$pcd = $this->bdd->proteger($ligne[$colonnesParNom['cc_periode_constitution_debut']]);
234
		$pcf = $this->bdd->proteger($ligne[$colonnesParNom['cc_periode_constitution_fin']]);
235
		$tcl = $this->bdd->proteger($ligne[$colonnesParNom['cc_truk_couverture_lieu']]);
236
		$cst = $this->bdd->proteger($ligne[$colonnesParNom['cc_ce_specimen_type']]);
237
 
238
		$requete = "INSERT INTO " . $this->table_collection
239
			. " (cc_ce_structure, cc_nom, cc_description, cc_periode_constitution_debut, cc_periode_constitution_fin, cc_truk_couverture_lieu, cc_ce_specimen_type)"
240
			. " VALUES ($idStructure, $nom, $desc, $pcd, $pcf, $tcl, $cst)";
241
		//echo "REQ INS: $requete\n";
242
		$resultat = $this->bdd->executer($requete);
243
		$idCollection = $this->bdd->recupererIdDernierAjout();
244
 
245
		return $idCollection;
246
	}
247
 
248
	/**
249
	 * Crée une collection botanique; la remplit avec les données issues de $ligne en se
250
	 * servant de $colonnesParNom pour accéder aux valeurs par clés textuelles
251
	 */
252
	protected function creerCollectionBota($ligne, $colonnesBotaParNom) {
253
		//echo "Insertion ! : "; var_dump($ligne); echo "<br/>";
254
		$id = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_id_collection']]);
255
		$ceg = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_ce_etat_general']]);
256
		$ne = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_nbre_echantillon']]);
257
		$spec = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_specialite']]);
258
		$ac = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_annotation_classement']]);
259
		$ct = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_ce_traitement']]);
260
		$ci = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_ce_inventaire']]);
261
		$ii = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_inventaire_info']]);
262
		$aur = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_autres_unite_rangement']]);
263
		$tcpt = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_truk_conservation_papier_type']]);
264
 
265
		// @TODO comment gérer la colonne "Nombre de parts" ? Faut la mettre dans quoi ?
266
		$requete = "INSERT INTO " . $this->table_collection_bota
267
			. " (ccb_id_collection, ccb_ce_etat_general, ccb_nbre_echantillon, ccb_specialite, ccb_annotation_classement, ccb_ce_traitement, ccb_ce_inventaire,"
268
			. " ccb_inventaire_info, ccb_autres_unites_rangement, ccb_truk_conservation_papier_type)"
269
			. " VALUES ($id, $ceg, $ne, $spec, $ac, $ct, $ci, $ii, $aur, $tcpt)";
270
		//echo "REQ INS: $requete\n";
271
		$resultat = $this->bdd->executer($requete);
272
	}
273
 
1928 delphine 274
	private function chargerPubli($fichier) {
1855 delphine 275
 
1856 aurelien 276
		// vérification existence fichier
277
		if(!file_exists(Config::get('dossiertmp').$fichier)) {
278
			$erreur = "Le fichier ".Config::get('dossiertmp').$fichier." n'existe pas.";
279
			throw new Exception($erreur);
280
		}
281
 
282
		$pointeur = fopen(Config::get('dossiertmp').$fichier, "r");
283
		// Chargement de la première colonne (qui contient les noms de colonnes à importer
284
		$colonnes = fgetcsv($pointeur, 0, ";");
285
 
286
		// Vérification des colonnes obligatoires et en même temps du séparateur
287
		if(count($colonnes) < 2 || !array_intersect(array_keys($this->colonnes_obligatoires), $colonnes)) {
288
			$erreur = "Le fichier ne contient pas les colonnes obligatoires : ".implode(',', array_keys($this->colonnes_obligatoires))."\n";
289
			$erreur .= "ou bien n'est pas séparé par le caractère ';' ";
290
			throw new Exception($erreur);
291
		}
292
 
1862 aurelien 293
 
294
		//TODO: vérifier si les deux index ci dessous ne font pas double emploi
295
 
296
		// Création d'un index des colonnes qui seront importées dans la fiche en les associant
297
		// au numéro de colonne dans la feuille csv
1856 aurelien 298
		$index_colonnes_importees = array_intersect(array_keys($this->colonnes_acceptees), $colonnes);
299
		$colonnes_importees = array();
300
		foreach($index_colonnes_importees as $index_colonne_importee) {
301
			$colonnes_importees[] = $this->colonnes_acceptees[$index_colonne_importee];
302
		}
303
 
304
		$index_colonnes_refusees = array_keys(array_diff($colonnes, array_keys($this->colonnes_acceptees)));
305
		// Création d'un index associant chaque numéro de colonne importée à son rôle
306
		// pour y apporter des traitement spécifiques
307
		$index_colonnes_importees = $colonnes;
308
		foreach($index_colonnes_refusees as $colonne_refusee) {
309
			unset($index_colonnes_importees[$colonne_refusee]);
310
		}
1862 aurelien 311
 
312
		$roles_a_num_colonnes = array_flip($index_colonnes_importees);
1882 aurelien 313
 
314
		// Ajout de la colonne nom complet aux champs de la requête
315
		$colonnes_importees[] = 'cpu_fmt_nom_complet';
1856 aurelien 316
 
1882 aurelien 317
		$nb_publis_inserees = 0;
1856 aurelien 318
		$lignes = array();
319
		while($ligne = fgetcsv($pointeur, 0, ";")) {
320
			$ligne_inseree = array();
1882 aurelien 321
 
322
			// Traitement des champs suivant leur role
1856 aurelien 323
			foreach($ligne as $index => &$valeur) {
324
				if(!in_array($index, $index_colonnes_refusees)) {
325
					$ligne_inseree[] = $this->traiterChamp($valeur, $index_colonnes_importees[$index]);
326
				}
327
			}
1882 aurelien 328
 
1856 aurelien 329
			// Ajout du nom complet formaté de la publication
1862 aurelien 330
			$nom_complet = $this->bdd->proteger($this->formaterNomComplet($ligne, $index_colonnes_importees));
331
			$ligne_inseree[] = $nom_complet;
1882 aurelien 332
 
333
			$id_publication = $this->insererPublication($colonnes_importees, $ligne_inseree);
334
			// TODO: quoi faire en cas d'échec pour une publication ?
335
			if(!empty($id_publication)) {
336
				$nb_publis_inserees++;
337
				// Pour aller plus vite on pourrait éventuellement faire une grosse requete d'ajout des publications
338
				// à personne à la fin, mais ça nous priverait de faire une transaction (TODO: faire une transaction)
339
				$nb_auteurs_lies = $this->insererLiensPublicationAuteurs($id_publication, $ligne[$roles_a_num_colonnes['auteur']]);
340
			}
1862 aurelien 341
 
1856 aurelien 342
		}
1862 aurelien 343
 
344
		return $nb_publis_inserees;
1855 delphine 345
	}
1856 aurelien 346
 
1882 aurelien 347
 
348
	private function insererPublication(&$colonnes, &$publication) {
349
		$requete = "INSERT INTO ".$this->table_publication." ".
350
				"(".implode(',', $colonnes).") ".
351
				"VALUES (".implode(",", $publication).")";
352
 
353
		$insertion = $this->bdd->executer($requete);
354
		$id_publi = $this->bdd->recupererIdDernierAjout();
355
 
356
		// Historisation de l'ajout
357
		$histo = $this->creerXmlHisto(array_combine($colonnes, $publication));
358
		$id_meta = $this->historiser($this->id_table_publication, $id_publi, $histo);
359
		// Affectation des méta données concernat l'ajout à la publication
360
		$requete_affectation_meta = "UPDATE  ".$this->table_publication." ".
361
				"SET cpu_ce_meta = ".$id_meta." ".
362
				"WHERE cpu_id_publication = ".$id_publi;
363
 
364
		$this->bdd->executer($requete_affectation_meta);
365
 
366
		return $id_publi;
1862 aurelien 367
	}
368
 
1882 aurelien 369
	protected function insererLiensPublicationAuteurs($id_publication, &$auteurs) {
370
		$colonnes = array('cpuap_id_publication', 'cpuap_id_personne', 'cpuap_id_role', 'cpuap_ce_truk_type', 'cpuap_ordre', 'cpuap_ce_meta');
371
		$requete = "INSERT IGNORE INTO ".$this->table_publication_a_auteur." ".
372
				"(".implode(",", $colonnes).") VALUES ";
373
 
374
		// L'ordre des auteurs commence à 1
375
		$ordre_auteur = 1;
376
 
377
		// Découpage des différents auteurs
378
		$auteurs_tab = explode(',', $auteurs);
379
		$auteurs_tab = array_filter($auteurs_tab);
380
 
381
		// Les auteurs sont normalement cités dans l'ordre dans l'import
382
		foreach($auteurs_tab as $auteur) {
383
			// si les infos auteurs sont un tableau dans le cache alors l'id existe bien en base de données
384
			if(is_array($this->cache_auteur[$auteur])) {
385
				$id_auteur = $this->cache_auteur[$auteur]['cp_id_personne'];
1862 aurelien 386
 
1882 aurelien 387
				$valeurs = array($id_publication, $id_auteur, $this->id_role_auteur, "NULL", $ordre_auteur, "0");
1862 aurelien 388
 
1882 aurelien 389
				$requete_insertion = $requete." (".implode(',', $valeurs).") ";
390
				$liaison = $this->bdd->executer($requete_insertion);
391
 
392
				// Historisation de l'ajout
393
				$histo = $this->creerXmlHisto(array_combine($colonnes, $liaison));
394
				$cle_liaison = $id_publication.'-'.$this->id_role_auteur.'-'.$id_auteur;
395
				$id_meta = $this->historiser($this->id_table_publication_personne, $cle_liaison, $histo);
1862 aurelien 396
 
1882 aurelien 397
				// Affectation des méta données concernant l'ajout à la publication à auteur
398
				$requete_affectation_meta = "UPDATE  ".$this->table_publication_a_auteur." ".
399
						"SET cpuap_ce_meta = ".$id_meta;
400
				$this->bdd->executer($requete_affectation_meta);
401
			}
402
			// L'ordre des auteurs est conservé même pour ceux qui n'existe pas dans la bdd
403
			$ordre_auteur++;
1862 aurelien 404
		}
405
	}
406
 
1882 aurelien 407
	protected function creerXmlHisto($donnees) {
408
		// Création du xml de l'enregistrement à historiser
409
		$info = null;
410
		$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";
411
		$xml = null;
412
 
413
		foreach ($donnees as $cle => $valeur) {
414
			// Pour éviter un éventuel double échappement des valeurs
415
			$valeur = stripslashes($valeur);
416
			$valeur = trim($valeur, "'");
417
			if (!is_null($valeur) && $valeur != '') {
418
				$xml .= "<$cle>$valeur</$cle>\n";
419
			}
420
		}
421
		if ($xml !== null) {
422
			$info = sprintf($xml_tpl, $xml);
423
			$info = $this->bdd->proteger($info);
424
		}
425
 
426
		return $info;
427
	}
428
 
429
	protected function historiser($table_id, $ligne_cle, $info) {
430
		date_default_timezone_set('Europe/Paris');
431
		// Pré-traitement des variables
432
		$info = (is_null($info)) ? 'NULL' : $info;
433
 
434
		// Historisation (Ajout des méta-données)
435
		$requete = 	'INSERT INTO coel_meta_historique_ligne '.
436
				'	(cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.
437
				'VALUES ('.
438
				"		$table_id, ".
439
				'		"'.$ligne_cle.'", '.
440
				"		$info, ".
441
				'		"'.date('Y-m-d H:i:s', time()).'", '.
442
				"		$this->id_utilisateur, ".
443
				"		".self::ETAT_AJOUTER.", ".
444
				'		"'.$this->ip_utilisateur.'", '.
445
				'		"'.$this->id_session.'") ';
446
		$resultat = $this->bdd->executer($requete);
447
		return $this->bdd->recupererIdDernierAjout();
448
	}
449
 
1856 aurelien 450
	protected function formaterNomComplet($ligne, $roles) {
1857 aurelien 451
 
452
		$roles = array_flip($roles);
453
 
454
		// Intitulé de la publication complet : fmt_auteur, date_parution(année). titre. Editeur (nom), collection, fascicule, indication_nvt. pages.
455
		// indication_nvt = serie_tome
456
		$champs_nom_complet = array('auteur', 'annee', 'titre', 'editeur', 'intitule_revue', 'fascicule', 'serie_tome', 'pages');
457
		$champs_fmt = array();
458
 
459
		$fmt_nom_complet = "";
460
 
461
		foreach($champs_nom_complet as $champ) {
462
			$index = $roles[$champ];
463
			if(!isset($ligne[$index])) {
464
				$champs_fmt[$champ] = "";
465
			} else {
466
				$champs_fmt[$champ] = $ligne[$index];
467
			}
468
		}
469
 
470
		$indication_nvt_pages = array($champs_fmt['serie_tome'], $champs_fmt['pages']);
471
		$indication_nvt_pages = array_filter($indication_nvt_pages, 'strlen');
472
		$indication_nvt_pages = trim(implode(". ", $indication_nvt_pages));
473
		$indication_nvt_pages .= !empty($indication_nvt_pages) ? "." : "";
474
 
475
		$annee_titre_editeur = array($champs_fmt['annee'], $champs_fmt['titre'], $champs_fmt['editeur']);
476
		$annee_titre_editeur = array_filter($annee_titre_editeur, 'strlen');
477
		$annee_titre_editeur = trim(implode(". ", $annee_titre_editeur));
478
 
479
		$fmt_nom_complet =  array($champs_fmt['auteur'],
480
							$annee_titre_editeur,
481
							$champs_fmt['intitule_revue'],
482
							$champs_fmt['fascicule'],
483
							$indication_nvt_pages);
484
 
485
		$fmt_nom_complet = array_filter($fmt_nom_complet, 'strlen');
486
		$fmt_nom_complet = implode(", ", $fmt_nom_complet);
487
 
488
		return $fmt_nom_complet;
1856 aurelien 489
	}
490
 
491
	private function traiterChamp($valeur, $role) {
492
		switch($role) {
493
			case 'auteur':
1862 aurelien 494
				$valeur = $this->traiterChampAuteur($valeur);
1856 aurelien 495
			break;
496
			case 'editeur':
1862 aurelien 497
				$valeur = 'AUTRE##'.$valeur;
1856 aurelien 498
			break;
499
		}
500
 
501
		return $this->bdd->proteger($valeur);
502
	}
1862 aurelien 503
 
504
	private function traiterChampAuteur($auteur_intitule) {
505
		$auteurs_fmt = array();
506
		$auteurs_tab = explode(',', $auteur_intitule);
507
		foreach($auteurs_tab as $auteur) {
1875 aurelien 508
			if(!empty(trim($auteur))) {
509
				$auteurs_fmt[] = $this->obtenirInfosAuteur($auteur);
510
			}
1862 aurelien 511
		}
512
 
513
		return implode(', ', $auteurs_fmt);
514
	}
1856 aurelien 515
 
1857 aurelien 516
	private function obtenirInfosAuteur($auteur_intitule) {
1862 aurelien 517
		$retour = $auteur_intitule;
518
		// Si on déjà recherché et trouvé (ou non l'auteur)
1857 aurelien 519
		if(isset($this->cache_auteur[$auteur_intitule])) {
1876 aurelien 520
			// On renvoie son nom complet formaté s'il existe en bdd ou sinon
1862 aurelien 521
			// le nom qui a été donné dans la feuille csv
1876 aurelien 522
			$retour = !empty($this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet']) ?
523
				$this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet'] :
524
				$auteur_intitule;
1856 aurelien 525
		} else {
1862 aurelien 526
			// Recherche de l'auteur sur un maximum du combinaisons possible des variations
527
			// de son nom et prénom
1857 aurelien 528
			$auteur = $this->fabriquerCombinaisonsAuteur($auteur_intitule);
1856 aurelien 529
			$auteur_req = "(".implode(', ', $auteur).")";
530
 
1857 aurelien 531
			$requete = "SELECT cp_id_personne, cp_fmt_nom_complet FROM ".$this->table_auteur." WHERE cp_fmt_nom_complet IN ".$auteur_req;
1856 aurelien 532
			$infos_auteur = $this->bdd->recupererTous($requete);
1882 aurelien 533
 
1862 aurelien 534
			// Stockage en cache de la ligne de bdd si trouvé,
535
			// de la valeur brute sinon
1856 aurelien 536
			if(!empty($infos_auteur)) {
1862 aurelien 537
				$retour = $infos_auteur[0]['cp_fmt_nom_complet'];
1857 aurelien 538
				$this->cache_auteur[$auteur_intitule] = $infos_auteur[0];
1882 aurelien 539
				// Stocker le nom d'auteur sous les deux formes (fmt nom complet et tel que saisi), facilite la recherche
540
				// plus tard lors de la liaison des publications aux auteurs
541
				$this->cache_auteur[$infos_auteur[0]['cp_fmt_nom_complet']] = $infos_auteur[0];
1856 aurelien 542
			} else {
1857 aurelien 543
				$retour = $auteur_intitule;
544
				$this->cache_auteur[$auteur_intitule] = $auteur_intitule;
1856 aurelien 545
			}
546
		}
547
 
548
		return $retour;
549
	}
550
 
551
	private function fabriquerCombinaisonsAuteur($auteur) {
552
 
553
		$auteur = trim($auteur);
554
		$auteurs_formates = array($this->bdd->proteger($auteur));
555
 
556
		// Séparation des élements de l'auteur des espaces pour obtenir
557
		// les noms et prénoms (Ex. "Carl Von Linné" => "Carl", "Von", "Linné")
558
		$auteur_tab = explode(' ', $auteur);
559
		$auteur_tab = array_filter($auteur_tab);
560
 
561
		$combinaisons = array();
562
		foreach($auteur_tab as &$element_auteur) {
563
			$combinaisons[] = array(
564
								// élement tel quel (Ex: "Linné")
565
								$element_auteur,
566
								// possibilité de l'initiale seule (Ex: "L")
567
								substr($element_auteur, 0, 1),
568
								// possibilité de l'initiale avec un point du genre (Ex: "L.")
569
								substr($element_auteur, 0, 1)."."
570
							);
571
		}
572
 
573
		// Fabrication de toutes les combinaisons possibles des parties de noms ci-dessus
574
		// pour deux et trois élements en faisant plusieurs produits cartésiens
575
		// car le nom peut être combiné différement de celui en base de données
576
		// (Ex. : "Carl Von Linné" VS "C. Von Linné" ou "C. V. Linné" ou encore "Von Linné C." etc...)
577
 
578
		// C'est moche et pas très élégant mais bon ça marche dans 90% des cas
579
		// On ne teste pas plus que 3 combinaisons, car ça serait très très couteux
580
		// TODO: faire mieux et factoriser les appels ci dessous
581
		if(count($auteur_tab) > 2) {
582
			// Cas du nom à trois parties (genre "Carl Von Linné")
583
			$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1], $combinaisons[2]));
584
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[0], $combinaisons[2], $combinaisons[1])));
585
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[2], $combinaisons[0])));
586
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0], $combinaisons[2])));
587
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[1], $combinaisons[0])));
588
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[0], $combinaisons[1])));
589
		} else {
590
			// Cas du nom à trois parties (genre "Carl Linné")
591
			$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1]));
592
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0])));
593
		}
594
 
595
		$auteurs_formates = array();
596
		foreach($possibilites_auteurs as &$possibilite) {
597
			$initiales = true;
598
			// Suppression des possibilités ne contenant que des initiales avec ou sans point
599
			foreach($possibilite as &$chars) {
600
				$initiales = $initiales && mb_strlen($chars) <= 2;
601
			}
1855 delphine 602
 
1856 aurelien 603
			if(!$initiales) {
604
				$auteurs_formates[] = $this->bdd->proteger(implode(" ", $possibilite));
605
			}
606
		}
607
 
608
		return $auteurs_formates;
609
	}
610
 
611
	// http://stackoverflow.com/questions/6311779/finding-cartesian-product-with-php-associative-arrays
612
	function cartesian($input) {
613
		// filter out empty values
614
		$input = array_filter($input);
615
 
616
		$result = array(array());
617
 
618
		foreach ($input as $key => $values) {
619
			$append = array();
620
 
621
			foreach($result as $product) {
622
				foreach($values as $item) {
623
					$product[$key] = $item;
624
					$append[] = $product;
625
				}
626
			}
627
 
628
			$result = $append;
629
		}
630
 
631
		return $result;
632
	}
1855 delphine 633
}
634
?>