Subversion Repositories eFlore/Applications.coel

Rev

Rev 1929 | 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
 
1930 mathias 21
	protected $id_table_publication = null;
1882 aurelien 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)) {
1930 mathias 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;
1882 aurelien 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');
1930 mathias 94
		$this->table_publication = $tables['publication'];
1857 aurelien 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
 
1930 mathias 99
		$this->id_table_publication = $tables['id_table_publication'];
1882 aurelien 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
 
1930 mathias 169
		// mettre à jour le GUID des collections et des structures
170
		$this->mettreAJourGUIDCollections();
171
		$this->mettreAJourGUIDStructures();
172
 
1928 delphine 173
		//ouvrir le fichier collection botanique
1929 mathias 174
		$pointeurCollectionsBota = fopen($fichierCollectionsBota, "r");
175
		// Chargement de la première colonne (qui contient les noms de colonnes à importer)
176
		$colonnesBota = fgetcsv($pointeurCollectionsBota, 0, $separateur);
177
		$colonnesBotaParNom = array_flip($colonnesBota);
178
		//var_dump($colonnesBota);
179
		//var_dump($colonnesBotaParNom);
180
 
1928 delphine 181
		// vérifier les colonnes
1929 mathias 182
		// @TODO on verra plus tard
183
 
184
		// parcours du fichier "-collections-bota.csv"
185
		while($ligne = fgetcsv($pointeurCollectionsBota, 0, $separateur)) {
186
			// remplacer les noms des collections par leur id (créé précédemment)
187
			$ligne[$colonnesBotaParNom['ccb_id_collection']] = $idCollectionsParIdTemp[$ligne[$colonnesBotaParNom['ccb_id_collection']]];
188
			// créer/importer
189
			// @TODO vérifier qu'elles existent pour ne pas insérer de doublons en relançant le script !!
190
			$this->creerCollectionBota($ligne, $colonnesBotaParNom);
191
		}
1928 delphine 192
 
193
	}
1855 delphine 194
 
1929 mathias 195
	/**
196
	 * Si une structure ayant pour nom $nomStructure existe, retourne son
197
	 * identifiant numérique, sinon retourne false
198
	 */
199
	protected function verifierExistenceStructureParNom($nomStructure) {
200
		$idStructure = false;
201
		$nsp = $this->bdd->proteger($nomStructure);
202
		$requete = "SELECT cs_id_structure FROM " . $this->table_structure
203
			. " WHERE cs_nom = $nsp";
204
 
205
		$resultat = $this->bdd->recupererTous($requete);
206
		// var_dump($resultat);
207
		if (count($resultat) > 0) {
208
			$idStructure = $resultat[0]['cs_id_structure'];
209
		}
210
		return $idStructure;
211
	}
212
 
213
	/**
214
	 * Crée une structure portant le nom $nomStructure, sans rien fournir d'autre, et
215
	 * retourne l'identifiant numérique du novueau tuple
216
	 */
217
	protected function creerStructure($nomStructure) {
218
		$nsp = $this->bdd->proteger($nomStructure);
219
		$requete = "INSERT INTO " . $this->table_structure . " (cs_nom)"
220
			. " VALUES ($nsp)";
221
		//echo "REQ INS: $requete\n";
1930 mathias 222
		$this->bdd->executer($requete);
1929 mathias 223
		$idStructure = $this->bdd->recupererIdDernierAjout();
224
 
225
		return $idStructure;
226
	}
227
 
228
	/**
229
	 * Crée une collection en la rattachant à la structure d'id $idStrucutre; la remplit
230
	 * avec les données issues de $ligne en se servant de $colonnesParNom pour accéder
231
	 * aux valeurs par clés textuelles; retourne l'identifiant numérique du novueau tuple
232
	 */
233
	protected function creerCollection($idStructure, $ligne, $colonnesParNom) {
234
		//echo "Insertion ! : "; var_dump($ligne); echo "<br/>";
235
		$nom = $this->bdd->proteger($ligne[$colonnesParNom['cc_nom']]);
236
		$desc = $this->bdd->proteger($ligne[$colonnesParNom['cc_description']]);
1930 mathias 237
		$type = $this->bdd->proteger($ligne[$colonnesParNom['cc_ce_type']]);
1929 mathias 238
		$pcd = $this->bdd->proteger($ligne[$colonnesParNom['cc_periode_constitution_debut']]);
239
		$pcf = $this->bdd->proteger($ligne[$colonnesParNom['cc_periode_constitution_fin']]);
240
		$tcl = $this->bdd->proteger($ligne[$colonnesParNom['cc_truk_couverture_lieu']]);
241
		$cst = $this->bdd->proteger($ligne[$colonnesParNom['cc_ce_specimen_type']]);
242
 
243
		$requete = "INSERT INTO " . $this->table_collection
1930 mathias 244
			. " (cc_ce_structure, cc_nom, cc_description, cc_ce_type, cc_periode_constitution_debut, cc_periode_constitution_fin, cc_truk_couverture_lieu, cc_ce_specimen_type)"
245
			. " VALUES ($idStructure, $nom, $desc, $type, $pcd, $pcf, $tcl, $cst)";
1929 mathias 246
		//echo "REQ INS: $requete\n";
1930 mathias 247
		$this->bdd->executer($requete);
1929 mathias 248
		$idCollection = $this->bdd->recupererIdDernierAjout();
249
 
250
		return $idCollection;
251
	}
252
 
253
	/**
1930 mathias 254
	 * Reconstruit les GUID des structures à partir de leurs ID
255
	 */
256
	protected function mettreAJourGUIDStructures() {
257
		$requete = "UPDATE coel_structure SET cs_guid = CONCAT('urn:lsid:tela-botanica.org:str', cs_id_structure)";
258
		$this->bdd->executer($requete);
259
	}
260
 
261
	/**
262
	 * Reconstruit les GUID des collections à partir de leurs ID
263
	 */
264
	protected function mettreAJourGUIDCollections() {
265
		$requete = "UPDATE coel_collection SET cc_guid = CONCAT('urn:lsid:tela-botanica.org:coll', cc_id_collection)";
266
		$this->bdd->executer($requete);
267
	}
268
 
269
	/**
1929 mathias 270
	 * Crée une collection botanique; la remplit avec les données issues de $ligne en se
271
	 * servant de $colonnesParNom pour accéder aux valeurs par clés textuelles
272
	 */
273
	protected function creerCollectionBota($ligne, $colonnesBotaParNom) {
274
		//echo "Insertion ! : "; var_dump($ligne); echo "<br/>";
275
		$id = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_id_collection']]);
276
		$ceg = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_ce_etat_general']]);
277
		$ne = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_nbre_echantillon']]);
278
		$spec = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_specialite']]);
279
		$ac = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_annotation_classement']]);
280
		$ct = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_ce_traitement']]);
281
		$ci = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_ce_inventaire']]);
282
		$ii = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_inventaire_info']]);
283
		$aur = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_autres_unite_rangement']]);
1930 mathias 284
		$nph = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_nb_planches_herbiers']]);
1929 mathias 285
		$tcpt = $this->bdd->proteger($ligne[$colonnesBotaParNom['ccb_truk_conservation_papier_type']]);
286
 
287
		// @TODO comment gérer la colonne "Nombre de parts" ? Faut la mettre dans quoi ?
288
		$requete = "INSERT INTO " . $this->table_collection_bota
289
			. " (ccb_id_collection, ccb_ce_etat_general, ccb_nbre_echantillon, ccb_specialite, ccb_annotation_classement, ccb_ce_traitement, ccb_ce_inventaire,"
1930 mathias 290
			. " ccb_inventaire_info, ccb_autres_unites_rangement, ccb_nb_planches_herbiers, ccb_truk_conservation_papier_type)"
291
			. " VALUES ($id, $ceg, $ne, $spec, $ac, $ct, $ci, $ii, $aur, $nph, $tcpt)";
1929 mathias 292
		//echo "REQ INS: $requete\n";
1930 mathias 293
		$this->bdd->executer($requete);
1929 mathias 294
	}
295
 
1928 delphine 296
	private function chargerPubli($fichier) {
1855 delphine 297
 
1856 aurelien 298
		// vérification existence fichier
299
		if(!file_exists(Config::get('dossiertmp').$fichier)) {
1930 mathias 300
			$erreur = "Le fichier ".Config::get('dossiertmp').$fichier." n'existe pas.";
1856 aurelien 301
			throw new Exception($erreur);
302
		}
303
 
304
		$pointeur = fopen(Config::get('dossiertmp').$fichier, "r");
305
		// Chargement de la première colonne (qui contient les noms de colonnes à importer
306
		$colonnes = fgetcsv($pointeur, 0, ";");
307
 
308
		// Vérification des colonnes obligatoires et en même temps du séparateur
309
		if(count($colonnes) < 2 || !array_intersect(array_keys($this->colonnes_obligatoires), $colonnes)) {
310
			$erreur = "Le fichier ne contient pas les colonnes obligatoires : ".implode(',', array_keys($this->colonnes_obligatoires))."\n";
1930 mathias 311
			$erreur .= "ou bien n'est pas séparé par le caractère ';' ";
1856 aurelien 312
			throw new Exception($erreur);
313
		}
314
 
1862 aurelien 315
 
316
		//TODO: vérifier si les deux index ci dessous ne font pas double emploi
317
 
318
		// Création d'un index des colonnes qui seront importées dans la fiche en les associant
319
		// au numéro de colonne dans la feuille csv
1856 aurelien 320
		$index_colonnes_importees = array_intersect(array_keys($this->colonnes_acceptees), $colonnes);
321
		$colonnes_importees = array();
322
		foreach($index_colonnes_importees as $index_colonne_importee) {
323
			$colonnes_importees[] = $this->colonnes_acceptees[$index_colonne_importee];
324
		}
325
 
326
		$index_colonnes_refusees = array_keys(array_diff($colonnes, array_keys($this->colonnes_acceptees)));
327
		// Création d'un index associant chaque numéro de colonne importée à son rôle
328
		// pour y apporter des traitement spécifiques
329
		$index_colonnes_importees = $colonnes;
330
		foreach($index_colonnes_refusees as $colonne_refusee) {
331
			unset($index_colonnes_importees[$colonne_refusee]);
332
		}
1862 aurelien 333
 
334
		$roles_a_num_colonnes = array_flip($index_colonnes_importees);
1930 mathias 335
 
336
		// Ajout de la colonne nom complet aux champs de la requête
1882 aurelien 337
		$colonnes_importees[] = 'cpu_fmt_nom_complet';
1856 aurelien 338
 
1882 aurelien 339
		$nb_publis_inserees = 0;
1856 aurelien 340
		$lignes = array();
341
		while($ligne = fgetcsv($pointeur, 0, ";")) {
342
			$ligne_inseree = array();
1882 aurelien 343
 
344
			// Traitement des champs suivant leur role
1856 aurelien 345
			foreach($ligne as $index => &$valeur) {
346
				if(!in_array($index, $index_colonnes_refusees)) {
347
					$ligne_inseree[] = $this->traiterChamp($valeur, $index_colonnes_importees[$index]);
348
				}
349
			}
1882 aurelien 350
 
1856 aurelien 351
			// Ajout du nom complet formaté de la publication
1862 aurelien 352
			$nom_complet = $this->bdd->proteger($this->formaterNomComplet($ligne, $index_colonnes_importees));
353
			$ligne_inseree[] = $nom_complet;
1882 aurelien 354
 
355
			$id_publication = $this->insererPublication($colonnes_importees, $ligne_inseree);
356
			// TODO: quoi faire en cas d'échec pour une publication ?
357
			if(!empty($id_publication)) {
358
				$nb_publis_inserees++;
359
				// Pour aller plus vite on pourrait éventuellement faire une grosse requete d'ajout des publications
1930 mathias 360
				// à personne à la fin, mais ça nous priverait de faire une transaction (TODO: faire une transaction)
1882 aurelien 361
				$nb_auteurs_lies = $this->insererLiensPublicationAuteurs($id_publication, $ligne[$roles_a_num_colonnes['auteur']]);
362
			}
1862 aurelien 363
 
1856 aurelien 364
		}
1862 aurelien 365
 
366
		return $nb_publis_inserees;
1855 delphine 367
	}
1856 aurelien 368
 
1882 aurelien 369
 
370
	private function insererPublication(&$colonnes, &$publication) {
371
		$requete = "INSERT INTO ".$this->table_publication." ".
372
				"(".implode(',', $colonnes).") ".
373
				"VALUES (".implode(",", $publication).")";
374
 
375
		$insertion = $this->bdd->executer($requete);
376
		$id_publi = $this->bdd->recupererIdDernierAjout();
377
 
378
		// Historisation de l'ajout
379
		$histo = $this->creerXmlHisto(array_combine($colonnes, $publication));
380
		$id_meta = $this->historiser($this->id_table_publication, $id_publi, $histo);
381
		// Affectation des méta données concernat l'ajout à la publication
382
		$requete_affectation_meta = "UPDATE  ".$this->table_publication." ".
383
				"SET cpu_ce_meta = ".$id_meta." ".
384
				"WHERE cpu_id_publication = ".$id_publi;
385
 
386
		$this->bdd->executer($requete_affectation_meta);
387
 
388
		return $id_publi;
1862 aurelien 389
	}
390
 
1882 aurelien 391
	protected function insererLiensPublicationAuteurs($id_publication, &$auteurs) {
1930 mathias 392
		$colonnes = array('cpuap_id_publication', 'cpuap_id_personne', 'cpuap_id_role', 'cpuap_ce_truk_type', 'cpuap_ordre', 'cpuap_ce_meta');
393
		$requete = "INSERT IGNORE INTO ".$this->table_publication_a_auteur." ".
1882 aurelien 394
				"(".implode(",", $colonnes).") VALUES ";
395
 
396
		// L'ordre des auteurs commence à 1
397
		$ordre_auteur = 1;
398
 
1930 mathias 399
		// Découpage des différents auteurs
400
		$auteurs_tab = explode(',', $auteurs);
1882 aurelien 401
		$auteurs_tab = array_filter($auteurs_tab);
402
 
1930 mathias 403
		// Les auteurs sont normalement cités dans l'ordre dans l'import
404
		foreach($auteurs_tab as $auteur) {
405
			// si les infos auteurs sont un tableau dans le cache alors l'id existe bien en base de données
406
			if(is_array($this->cache_auteur[$auteur])) {
1882 aurelien 407
				$id_auteur = $this->cache_auteur[$auteur]['cp_id_personne'];
1862 aurelien 408
 
1882 aurelien 409
				$valeurs = array($id_publication, $id_auteur, $this->id_role_auteur, "NULL", $ordre_auteur, "0");
1862 aurelien 410
 
1930 mathias 411
				$requete_insertion = $requete." (".implode(',', $valeurs).") ";
1882 aurelien 412
				$liaison = $this->bdd->executer($requete_insertion);
413
 
414
				// Historisation de l'ajout
415
				$histo = $this->creerXmlHisto(array_combine($colonnes, $liaison));
416
				$cle_liaison = $id_publication.'-'.$this->id_role_auteur.'-'.$id_auteur;
417
				$id_meta = $this->historiser($this->id_table_publication_personne, $cle_liaison, $histo);
1862 aurelien 418
 
1882 aurelien 419
				// Affectation des méta données concernant l'ajout à la publication à auteur
420
				$requete_affectation_meta = "UPDATE  ".$this->table_publication_a_auteur." ".
421
						"SET cpuap_ce_meta = ".$id_meta;
422
				$this->bdd->executer($requete_affectation_meta);
423
			}
424
			// L'ordre des auteurs est conservé même pour ceux qui n'existe pas dans la bdd
425
			$ordre_auteur++;
1862 aurelien 426
		}
427
	}
428
 
1930 mathias 429
	protected function creerXmlHisto($donnees) {
430
		// Création du xml de l'enregistrement à historiser
431
		$info = null;
432
		$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";
433
		$xml = null;
434
 
1882 aurelien 435
		foreach ($donnees as $cle => $valeur) {
436
			// Pour éviter un éventuel double échappement des valeurs
437
			$valeur = stripslashes($valeur);
1930 mathias 438
			$valeur = trim($valeur, "'");
439
			if (!is_null($valeur) && $valeur != '') {
440
				$xml .= "<$cle>$valeur</$cle>\n";
441
			}
442
		}
443
		if ($xml !== null) {
444
			$info = sprintf($xml_tpl, $xml);
445
			$info = $this->bdd->proteger($info);
446
		}
447
 
448
		return $info;
1882 aurelien 449
	}
450
 
1930 mathias 451
	protected function historiser($table_id, $ligne_cle, $info) {
452
		date_default_timezone_set('Europe/Paris');
453
		// Pré-traitement des variables
454
		$info = (is_null($info)) ? 'NULL' : $info;
455
 
456
		// Historisation (Ajout des méta-données)
457
		$requete = 	'INSERT INTO coel_meta_historique_ligne '.
458
				'	(cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.
459
				'VALUES ('.
460
				"		$table_id, ".
461
				'		"'.$ligne_cle.'", '.
462
				"		$info, ".
463
				'		"'.date('Y-m-d H:i:s', time()).'", '.
464
				"		$this->id_utilisateur, ".
465
				"		".self::ETAT_AJOUTER.", ".
466
				'		"'.$this->ip_utilisateur.'", '.
467
				'		"'.$this->id_session.'") ';
468
		$resultat = $this->bdd->executer($requete);
469
		return $this->bdd->recupererIdDernierAjout();
1882 aurelien 470
	}
471
 
1856 aurelien 472
	protected function formaterNomComplet($ligne, $roles) {
1857 aurelien 473
 
474
		$roles = array_flip($roles);
475
 
476
		// Intitulé de la publication complet : fmt_auteur, date_parution(année). titre. Editeur (nom), collection, fascicule, indication_nvt. pages.
477
		// indication_nvt = serie_tome
478
		$champs_nom_complet = array('auteur', 'annee', 'titre', 'editeur', 'intitule_revue', 'fascicule', 'serie_tome', 'pages');
479
		$champs_fmt = array();
480
 
481
		$fmt_nom_complet = "";
482
 
483
		foreach($champs_nom_complet as $champ) {
484
			$index = $roles[$champ];
485
			if(!isset($ligne[$index])) {
486
				$champs_fmt[$champ] = "";
487
			} else {
488
				$champs_fmt[$champ] = $ligne[$index];
489
			}
490
		}
491
 
492
		$indication_nvt_pages = array($champs_fmt['serie_tome'], $champs_fmt['pages']);
493
		$indication_nvt_pages = array_filter($indication_nvt_pages, 'strlen');
494
		$indication_nvt_pages = trim(implode(". ", $indication_nvt_pages));
495
		$indication_nvt_pages .= !empty($indication_nvt_pages) ? "." : "";
496
 
497
		$annee_titre_editeur = array($champs_fmt['annee'], $champs_fmt['titre'], $champs_fmt['editeur']);
498
		$annee_titre_editeur = array_filter($annee_titre_editeur, 'strlen');
499
		$annee_titre_editeur = trim(implode(". ", $annee_titre_editeur));
500
 
501
		$fmt_nom_complet =  array($champs_fmt['auteur'],
502
							$annee_titre_editeur,
503
							$champs_fmt['intitule_revue'],
504
							$champs_fmt['fascicule'],
505
							$indication_nvt_pages);
506
 
507
		$fmt_nom_complet = array_filter($fmt_nom_complet, 'strlen');
508
		$fmt_nom_complet = implode(", ", $fmt_nom_complet);
509
 
510
		return $fmt_nom_complet;
1856 aurelien 511
	}
512
 
513
	private function traiterChamp($valeur, $role) {
514
		switch($role) {
515
			case 'auteur':
1862 aurelien 516
				$valeur = $this->traiterChampAuteur($valeur);
1856 aurelien 517
			break;
518
			case 'editeur':
1862 aurelien 519
				$valeur = 'AUTRE##'.$valeur;
1856 aurelien 520
			break;
521
		}
522
 
523
		return $this->bdd->proteger($valeur);
524
	}
1862 aurelien 525
 
526
	private function traiterChampAuteur($auteur_intitule) {
527
		$auteurs_fmt = array();
528
		$auteurs_tab = explode(',', $auteur_intitule);
529
		foreach($auteurs_tab as $auteur) {
1875 aurelien 530
			if(!empty(trim($auteur))) {
531
				$auteurs_fmt[] = $this->obtenirInfosAuteur($auteur);
532
			}
1862 aurelien 533
		}
534
 
535
		return implode(', ', $auteurs_fmt);
536
	}
1930 mathias 537
 
1857 aurelien 538
	private function obtenirInfosAuteur($auteur_intitule) {
1862 aurelien 539
		$retour = $auteur_intitule;
1930 mathias 540
		// Si on déjà recherché et trouvé (ou non l'auteur)
1857 aurelien 541
		if(isset($this->cache_auteur[$auteur_intitule])) {
1876 aurelien 542
			// On renvoie son nom complet formaté s'il existe en bdd ou sinon
1862 aurelien 543
			// le nom qui a été donné dans la feuille csv
1876 aurelien 544
			$retour = !empty($this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet']) ?
545
				$this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet'] :
546
				$auteur_intitule;
1856 aurelien 547
		} else {
1862 aurelien 548
			// Recherche de l'auteur sur un maximum du combinaisons possible des variations
549
			// de son nom et prénom
1857 aurelien 550
			$auteur = $this->fabriquerCombinaisonsAuteur($auteur_intitule);
1856 aurelien 551
			$auteur_req = "(".implode(', ', $auteur).")";
552
 
1857 aurelien 553
			$requete = "SELECT cp_id_personne, cp_fmt_nom_complet FROM ".$this->table_auteur." WHERE cp_fmt_nom_complet IN ".$auteur_req;
1856 aurelien 554
			$infos_auteur = $this->bdd->recupererTous($requete);
1882 aurelien 555
 
1862 aurelien 556
			// Stockage en cache de la ligne de bdd si trouvé,
557
			// de la valeur brute sinon
1856 aurelien 558
			if(!empty($infos_auteur)) {
1862 aurelien 559
				$retour = $infos_auteur[0]['cp_fmt_nom_complet'];
1857 aurelien 560
				$this->cache_auteur[$auteur_intitule] = $infos_auteur[0];
1882 aurelien 561
				// Stocker le nom d'auteur sous les deux formes (fmt nom complet et tel que saisi), facilite la recherche
562
				// plus tard lors de la liaison des publications aux auteurs
563
				$this->cache_auteur[$infos_auteur[0]['cp_fmt_nom_complet']] = $infos_auteur[0];
1856 aurelien 564
			} else {
1857 aurelien 565
				$retour = $auteur_intitule;
566
				$this->cache_auteur[$auteur_intitule] = $auteur_intitule;
1856 aurelien 567
			}
568
		}
569
 
1930 mathias 570
		return $retour;
1856 aurelien 571
	}
572
 
573
	private function fabriquerCombinaisonsAuteur($auteur) {
574
 
575
		$auteur = trim($auteur);
576
		$auteurs_formates = array($this->bdd->proteger($auteur));
577
 
578
		// Séparation des élements de l'auteur des espaces pour obtenir
579
		// les noms et prénoms (Ex. "Carl Von Linné" => "Carl", "Von", "Linné")
580
		$auteur_tab = explode(' ', $auteur);
581
		$auteur_tab = array_filter($auteur_tab);
582
 
583
		$combinaisons = array();
584
		foreach($auteur_tab as &$element_auteur) {
585
			$combinaisons[] = array(
586
								// élement tel quel (Ex: "Linné")
587
								$element_auteur,
588
								// possibilité de l'initiale seule (Ex: "L")
589
								substr($element_auteur, 0, 1),
590
								// possibilité de l'initiale avec un point du genre (Ex: "L.")
591
								substr($element_auteur, 0, 1)."."
592
							);
593
		}
594
 
595
		// Fabrication de toutes les combinaisons possibles des parties de noms ci-dessus
596
		// pour deux et trois élements en faisant plusieurs produits cartésiens
597
		// car le nom peut être combiné différement de celui en base de données
598
		// (Ex. : "Carl Von Linné" VS "C. Von Linné" ou "C. V. Linné" ou encore "Von Linné C." etc...)
599
 
600
		// C'est moche et pas très élégant mais bon ça marche dans 90% des cas
601
		// On ne teste pas plus que 3 combinaisons, car ça serait très très couteux
602
		// TODO: faire mieux et factoriser les appels ci dessous
603
		if(count($auteur_tab) > 2) {
604
			// Cas du nom à trois parties (genre "Carl Von Linné")
605
			$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1], $combinaisons[2]));
606
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[0], $combinaisons[2], $combinaisons[1])));
607
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[2], $combinaisons[0])));
608
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0], $combinaisons[2])));
609
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[1], $combinaisons[0])));
610
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[0], $combinaisons[1])));
611
		} else {
612
			// Cas du nom à trois parties (genre "Carl Linné")
613
			$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1]));
614
			$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0])));
615
		}
616
 
617
		$auteurs_formates = array();
618
		foreach($possibilites_auteurs as &$possibilite) {
619
			$initiales = true;
620
			// Suppression des possibilités ne contenant que des initiales avec ou sans point
621
			foreach($possibilite as &$chars) {
622
				$initiales = $initiales && mb_strlen($chars) <= 2;
623
			}
1855 delphine 624
 
1856 aurelien 625
			if(!$initiales) {
626
				$auteurs_formates[] = $this->bdd->proteger(implode(" ", $possibilite));
627
			}
628
		}
629
 
630
		return $auteurs_formates;
631
	}
632
 
1930 mathias 633
	// http://stackoverflow.com/questions/6311779/finding-cartesian-product-with-php-associative-arrays
634
	function cartesian($input) {
635
		// filter out empty values
636
		$input = array_filter($input);
637
 
638
		$result = array(array());
639
 
640
		foreach ($input as $key => $values) {
641
			$append = array();
642
 
643
			foreach($result as $product) {
644
				foreach($values as $item) {
645
					$product[$key] = $item;
646
					$append[] = $product;
647
				}
648
			}
649
 
650
			$result = $append;
651
		}
652
 
653
		return $result;
1856 aurelien 654
	}
1855 delphine 655
}
656
?>