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 |
?>
|