1 |
<?php
|
1 |
<?php
|
2 |
/**
|
2 |
/**
|
3 |
* Exemple lancement:
|
3 |
* Exemple lancement:
|
4 |
* /opt/lampp/bin/php -d memory_limit=3500M cli.php import -n
|
4 |
* /opt/lampp/bin/php -d memory_limit=3500M cli.php import -n
|
5 |
*/
|
5 |
*/
|
6 |
class Import extends Script {
|
6 |
class Import extends Script {
|
7 |
private $bdd = null;
|
7 |
private $bdd = null;
|
8 |
private $auteurs = array();
|
8 |
private $auteurs = array();
|
9 |
protected $parametres_autorises = array(
|
9 |
protected $parametres_autorises = array(
|
10 |
'-n' => array(true, false, 'Nom du fichier à importer.'));
|
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'));
|
11 |
|
12 |
|
12 |
protected $table_publication = null;
|
13 |
protected $table_publication = null;
|
13 |
protected $table_auteur = null;
|
14 |
protected $table_auteur = null;
|
14 |
protected $table_publication_a_auteur = null;
|
15 |
protected $table_publication_a_auteur = null;
|
- |
|
16 |
protected $table_meta = null;
|
- |
|
17 |
|
- |
|
18 |
protected $id_table_publication = null;
|
- |
|
19 |
protected $id_table_publication_personne = null;
|
15 |
|
20 |
|
16 |
protected $id_role_auteur = null;
|
21 |
protected $id_role_auteur = null;
|
17 |
|
22 |
|
18 |
protected $colonnes_obligatoires = array();
|
23 |
protected $colonnes_obligatoires = array();
|
19 |
protected $colonnes_acceptees = array();
|
24 |
protected $colonnes_acceptees = array();
|
20 |
|
25 |
|
21 |
protected $cache_auteur = array();
|
26 |
protected $cache_auteur = array();
|
22 |
protected $auteurs_a_publis = array();
|
27 |
protected $auteurs_a_publis = array();
|
23 |
protected $publis_a_auteurs = array();
|
28 |
protected $publis_a_auteurs = array();
|
- |
|
29 |
|
- |
|
30 |
protected $id_utilisateur = 0;
|
- |
|
31 |
protected $id_session = 0;
|
- |
|
32 |
protected $ip_utilisateur = "127.0.01";
|
- |
|
33 |
|
- |
|
34 |
const ETAT_AJOUTER = 1;
|
24 |
|
35 |
|
25 |
public function __construct($script_nom, $parametres) {
|
36 |
public function __construct($script_nom, $parametres) {
|
26 |
parent::__construct($script_nom, $parametres);
|
37 |
parent::__construct($script_nom, $parametres);
|
27 |
$this->bdd = new Bdd();
|
38 |
$this->bdd = new Bdd();
|
28 |
}
|
39 |
}
|
29 |
|
40 |
|
30 |
public function executer() {
|
41 |
public function executer() {
|
31 |
try {
|
42 |
try {
|
32 |
$this->initialiserScript();
|
43 |
$this->initialiserScript();
|
33 |
$cmd = $this->getParametre('a');
|
44 |
$cmd = $this->getParametre('a');
|
34 |
$fichier = $this->getParametre('n');
|
45 |
$fichier = $this->getParametre('n');
|
- |
|
46 |
$utilisateur = $this->getParametre('u');
|
- |
|
47 |
|
- |
|
48 |
$this->traiterInfosUtilisateur($utilisateur);
|
- |
|
49 |
|
35 |
switch ($cmd) {
|
50 |
switch ($cmd) {
|
36 |
case "import" :
|
51 |
case "import" :
|
37 |
$resultat = $this->charger($fichier); break;
|
52 |
$resultat = $this->charger($fichier); break;
|
38 |
default :
|
53 |
default :
|
39 |
$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
|
54 |
$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
|
40 |
}
|
55 |
}
|
41 |
} catch (Exception $erreur) {
|
56 |
} catch (Exception $erreur) {
|
42 |
$this->traiterErreur($erreur->getMessage());
|
57 |
$this->traiterErreur($erreur->getMessage());
|
43 |
}
|
58 |
}
|
44 |
|
59 |
|
45 |
// renvoi du résultat vers la sortie php
|
60 |
// renvoi du résultat vers la sortie php
|
46 |
// car le script est surtout destiné à être appelé par un web service
|
61 |
// car le script est surtout destiné à être appelé par un web service
|
47 |
echo $resultat;
|
62 |
echo $resultat;
|
48 |
exit;
|
63 |
exit;
|
49 |
}
|
64 |
}
|
- |
|
65 |
|
- |
|
66 |
private function traiterInfosUtilisateur($utilisateur) {
|
- |
|
67 |
$utilisateur_infos = json_decode($utilisateur, true);
|
- |
|
68 |
if(!empty($utilisateur_infos)) {
|
- |
|
69 |
$this->id_utilisateur = !empty($utilisateur_infos['id']) ? $utilisateur_infos['id'] : $this->id_utilisateur;
|
- |
|
70 |
$this->id_session = !empty($utilisateur_infos['session']) ? $utilisateur_infos['session'] : $this->id_session;
|
- |
|
71 |
$this->ip_utilisateur = !empty($utilisateur_infos['ip']) ? $utilisateur_infos['ip'] : $this->ip_utilisateur;
|
- |
|
72 |
}
|
- |
|
73 |
}
|
50 |
|
74 |
|
51 |
private function initialiserScript() {
|
75 |
private function initialiserScript() {
|
52 |
$fichierIni = $this->getScriptChemin().'import.ini';
|
76 |
$fichierIni = $this->getScriptChemin().'import.ini';
|
53 |
if (file_exists($fichierIni)) {
|
77 |
if (file_exists($fichierIni)) {
|
54 |
Config::charger($fichierIni);
|
78 |
Config::charger($fichierIni);
|
55 |
} else {
|
79 |
} else {
|
56 |
$erreur = "Veuillez configurer le projet en créant le fichier 'import.ini' ".
|
80 |
$erreur = "Veuillez configurer le projet en créant le fichier 'import.ini' ".
|
57 |
"dans le dossier du module de script du projet à partir du fichier 'import.defaut.ini'.";
|
81 |
"dans le dossier du module de script du projet à partir du fichier 'import.defaut.ini'.";
|
58 |
throw new Exception($erreur);
|
82 |
throw new Exception($erreur);
|
59 |
}
|
83 |
}
|
60 |
|
84 |
|
61 |
$this->colonnes_obligatoires= Config::get('champs_obligatoires');
|
85 |
$this->colonnes_obligatoires= Config::get('champs_obligatoires');
|
62 |
$this->colonnes_acceptees = Config::get('champs');
|
86 |
$this->colonnes_acceptees = Config::get('champs');
|
63 |
|
87 |
|
64 |
$tables = Config::get('tables');
|
88 |
$tables = Config::get('tables');
|
65 |
$this->table_publication = $tables['publication'];
|
89 |
$this->table_publication = $tables['publication'];
|
66 |
$this->table_auteur = $tables['auteur'];
|
90 |
$this->table_auteur = $tables['auteur'];
|
67 |
$this->table_publication_a_auteur = $tables['publication_a_auteur'];
|
91 |
$this->table_publication_a_auteur = $tables['publication_a_auteur'];
|
- |
|
92 |
$this->table_meta = $tables['meta'];
|
- |
|
93 |
|
- |
|
94 |
$this->id_table_publication = $tables['id_table_publication'];
|
- |
|
95 |
$this->id_table_publication_personne = $tables['id_table_publication_personne'];
|
68 |
|
96 |
|
69 |
$this->id_role_auteur = $tables['id_role_auteur'];
|
97 |
$this->id_role_auteur = $tables['id_role_auteur'];
|
70 |
}
|
98 |
}
|
71 |
|
99 |
|
72 |
private function charger($fichier) {
|
100 |
private function charger($fichier) {
|
73 |
|
101 |
|
74 |
// vérification existence fichier
|
102 |
// vérification existence fichier
|
75 |
if(!file_exists(Config::get('dossiertmp').$fichier)) {
|
103 |
if(!file_exists(Config::get('dossiertmp').$fichier)) {
|
76 |
$erreur = "Le fichier ".Config::get('dossiertmp').$fichier." n'existe pas.";
|
104 |
$erreur = "Le fichier ".Config::get('dossiertmp').$fichier." n'existe pas.";
|
77 |
throw new Exception($erreur);
|
105 |
throw new Exception($erreur);
|
78 |
}
|
106 |
}
|
79 |
|
107 |
|
80 |
$pointeur = fopen(Config::get('dossiertmp').$fichier, "r");
|
108 |
$pointeur = fopen(Config::get('dossiertmp').$fichier, "r");
|
81 |
// Chargement de la première colonne (qui contient les noms de colonnes à importer
|
109 |
// Chargement de la première colonne (qui contient les noms de colonnes à importer
|
82 |
$colonnes = fgetcsv($pointeur, 0, ";");
|
110 |
$colonnes = fgetcsv($pointeur, 0, ";");
|
83 |
|
111 |
|
84 |
// Vérification des colonnes obligatoires et en même temps du séparateur
|
112 |
// Vérification des colonnes obligatoires et en même temps du séparateur
|
85 |
if(count($colonnes) < 2 || !array_intersect(array_keys($this->colonnes_obligatoires), $colonnes)) {
|
113 |
if(count($colonnes) < 2 || !array_intersect(array_keys($this->colonnes_obligatoires), $colonnes)) {
|
86 |
$erreur = "Le fichier ne contient pas les colonnes obligatoires : ".implode(',', array_keys($this->colonnes_obligatoires))."\n";
|
114 |
$erreur = "Le fichier ne contient pas les colonnes obligatoires : ".implode(',', array_keys($this->colonnes_obligatoires))."\n";
|
87 |
$erreur .= "ou bien n'est pas séparé par le caractère ';' ";
|
115 |
$erreur .= "ou bien n'est pas séparé par le caractère ';' ";
|
88 |
throw new Exception($erreur);
|
116 |
throw new Exception($erreur);
|
89 |
}
|
117 |
}
|
90 |
|
118 |
|
91 |
|
119 |
|
92 |
//TODO: vérifier si les deux index ci dessous ne font pas double emploi
|
120 |
//TODO: vérifier si les deux index ci dessous ne font pas double emploi
|
93 |
|
121 |
|
94 |
// Création d'un index des colonnes qui seront importées dans la fiche en les associant
|
122 |
// Création d'un index des colonnes qui seront importées dans la fiche en les associant
|
95 |
// au numéro de colonne dans la feuille csv
|
123 |
// au numéro de colonne dans la feuille csv
|
96 |
$index_colonnes_importees = array_intersect(array_keys($this->colonnes_acceptees), $colonnes);
|
124 |
$index_colonnes_importees = array_intersect(array_keys($this->colonnes_acceptees), $colonnes);
|
97 |
$colonnes_importees = array();
|
125 |
$colonnes_importees = array();
|
98 |
foreach($index_colonnes_importees as $index_colonne_importee) {
|
126 |
foreach($index_colonnes_importees as $index_colonne_importee) {
|
99 |
$colonnes_importees[] = $this->colonnes_acceptees[$index_colonne_importee];
|
127 |
$colonnes_importees[] = $this->colonnes_acceptees[$index_colonne_importee];
|
100 |
}
|
128 |
}
|
101 |
|
129 |
|
102 |
$index_colonnes_refusees = array_keys(array_diff($colonnes, array_keys($this->colonnes_acceptees)));
|
130 |
$index_colonnes_refusees = array_keys(array_diff($colonnes, array_keys($this->colonnes_acceptees)));
|
103 |
// Création d'un index associant chaque numéro de colonne importée à son rôle
|
131 |
// Création d'un index associant chaque numéro de colonne importée à son rôle
|
104 |
// pour y apporter des traitement spécifiques
|
132 |
// pour y apporter des traitement spécifiques
|
105 |
$index_colonnes_importees = $colonnes;
|
133 |
$index_colonnes_importees = $colonnes;
|
106 |
foreach($index_colonnes_refusees as $colonne_refusee) {
|
134 |
foreach($index_colonnes_refusees as $colonne_refusee) {
|
107 |
unset($index_colonnes_importees[$colonne_refusee]);
|
135 |
unset($index_colonnes_importees[$colonne_refusee]);
|
108 |
}
|
136 |
}
|
109 |
|
137 |
|
110 |
$roles_a_num_colonnes = array_flip($index_colonnes_importees);
|
138 |
$roles_a_num_colonnes = array_flip($index_colonnes_importees);
|
- |
|
139 |
|
- |
|
140 |
// Ajout de la colonne nom complet aux champs de la requête
|
- |
|
141 |
$colonnes_importees[] = 'cpu_fmt_nom_complet';
|
- |
|
142 |
|
111 |
|
143 |
$nb_publis_inserees = 0;
|
112 |
$lignes = array();
|
144 |
$lignes = array();
|
113 |
while($ligne = fgetcsv($pointeur, 0, ";")) {
|
145 |
while($ligne = fgetcsv($pointeur, 0, ";")) {
|
114 |
$ligne_inseree = array();
|
146 |
$ligne_inseree = array();
|
- |
|
147 |
|
- |
|
148 |
// Traitement des champs suivant leur role
|
115 |
foreach($ligne as $index => &$valeur) {
|
149 |
foreach($ligne as $index => &$valeur) {
|
116 |
if(!in_array($index, $index_colonnes_refusees)) {
|
150 |
if(!in_array($index, $index_colonnes_refusees)) {
|
117 |
$ligne_inseree[] = $this->traiterChamp($valeur, $index_colonnes_importees[$index]);
|
151 |
$ligne_inseree[] = $this->traiterChamp($valeur, $index_colonnes_importees[$index]);
|
118 |
}
|
152 |
}
|
119 |
}
|
153 |
}
|
- |
|
154 |
|
120 |
// Ajout du nom complet formaté de la publication
|
155 |
// Ajout du nom complet formaté de la publication
|
121 |
$nom_complet = $this->bdd->proteger($this->formaterNomComplet($ligne, $index_colonnes_importees));
|
156 |
$nom_complet = $this->bdd->proteger($this->formaterNomComplet($ligne, $index_colonnes_importees));
|
122 |
$ligne_inseree[] = $nom_complet;
|
157 |
$ligne_inseree[] = $nom_complet;
|
- |
|
158 |
|
123 |
$lignes[] = "(".implode(",", $ligne_inseree).")";
|
159 |
$id_publication = $this->insererPublication($colonnes_importees, $ligne_inseree);
|
- |
|
160 |
// TODO: quoi faire en cas d'échec pour une publication ?
|
- |
|
161 |
if(!empty($id_publication)) {
|
- |
|
162 |
$nb_publis_inserees++;
|
- |
|
163 |
// Pour aller plus vite on pourrait éventuellement faire une grosse requete d'ajout des publications
|
- |
|
164 |
// à personne à la fin, mais ça nous priverait de faire une transaction (TODO: faire une transaction)
|
- |
|
165 |
$nb_auteurs_lies = $this->insererLiensPublicationAuteurs($id_publication, $ligne[$roles_a_num_colonnes['auteur']]);
|
- |
|
166 |
}
|
124 |
|
- |
|
125 |
$this->stockerAuteursPourLiaisons($ligne[$roles_a_num_colonnes['auteur']], $nom_complet);
|
167 |
|
126 |
}
|
- |
|
127 |
|
- |
|
128 |
// Ajout de la colonne nom complet aux champs de la requête
|
- |
|
129 |
$colonnes_importees[] = 'cpu_fmt_nom_complet';
|
- |
|
130 |
|
- |
|
131 |
// le script renvoie le nombre de publications importées
|
- |
|
132 |
$nb_publis_inserees = $this->insererPublications($colonnes_importees, $lignes);
|
- |
|
133 |
$nb_auteurs_lies = $this->insererLiensPublicationsAuteurs();
|
168 |
}
|
134 |
|
169 |
|
135 |
return $nb_publis_inserees;
|
170 |
return $nb_publis_inserees;
|
136 |
}
|
171 |
}
|
- |
|
172 |
|
137 |
|
173 |
|
- |
|
174 |
private function insererPublication(&$colonnes, &$publication) {
|
138 |
private function stockerAuteursPourLiaisons($infos_auteurs, $nom_complet_publication) {
|
175 |
$requete = "INSERT INTO ".$this->table_publication." ".
|
139 |
// Découpage des différents auteurs
|
176 |
"(".implode(',', $colonnes).") ".
|
- |
|
177 |
"VALUES (".implode(",", $publication).")";
|
140 |
$auteurs_tab = explode(',', $infos_auteurs);
|
178 |
|
- |
|
179 |
$insertion = $this->bdd->executer($requete);
|
- |
|
180 |
$id_publi = $this->bdd->recupererIdDernierAjout();
|
141 |
$auteurs_tab = array_filter($auteurs_tab);
|
181 |
|
142 |
foreach($auteurs_tab as $auteur) {
|
182 |
// Historisation de l'ajout
|
143 |
// si les infos auteurs sont un tableau dans le cache alors son id existe bien en base de données
|
183 |
$histo = $this->creerXmlHisto(array_combine($colonnes, $publication));
|
144 |
if(is_array($this->cache_auteur[$auteur])) {
|
184 |
$id_meta = $this->historiser($this->id_table_publication, $id_publi, $histo);
|
145 |
// ajout d'une correspondance entre le nom complet de la publi et l'auteur (pour liaison ultérieure)
|
185 |
// Affectation des méta données concernat l'ajout à la publication
|
146 |
// et vice versa, ce qui permet facilement de retrouver à quel auteur est lié quelle publi dans les deux sens
|
186 |
$requete_affectation_meta = "UPDATE ".$this->table_publication." ".
|
147 |
$this->auteurs_a_publi[$auteur][] = $nom_complet_publication;
|
187 |
"SET cpu_ce_meta = ".$id_meta." ".
|
148 |
$this->publis_a_auteurs[$nom_complet_publication][] = $auteur;
|
188 |
"WHERE cpu_id_publication = ".$id_publi;
|
- |
|
189 |
|
149 |
}
|
190 |
$this->bdd->executer($requete_affectation_meta);
|
- |
|
191 |
|
150 |
}
|
192 |
return $id_publi;
|
151 |
}
|
193 |
}
|
- |
|
194 |
|
- |
|
195 |
protected function insererLiensPublicationAuteurs($id_publication, &$auteurs) {
|
- |
|
196 |
$colonnes = array('cpuap_id_publication', 'cpuap_id_personne', 'cpuap_id_role', 'cpuap_ce_truk_type', 'cpuap_ordre', 'cpuap_ce_meta');
|
- |
|
197 |
$requete = "INSERT IGNORE INTO ".$this->table_publication_a_auteur." ".
|
- |
|
198 |
"(".implode(",", $colonnes).") VALUES ";
|
- |
|
199 |
|
- |
|
200 |
// L'ordre des auteurs commence à 1
|
- |
|
201 |
$ordre_auteur = 1;
|
- |
|
202 |
|
- |
|
203 |
// Découpage des différents auteurs
|
- |
|
204 |
$auteurs_tab = explode(',', $auteurs);
|
- |
|
205 |
$auteurs_tab = array_filter($auteurs_tab);
|
- |
|
206 |
|
- |
|
207 |
// Les auteurs sont normalement cités dans l'ordre dans l'import
|
- |
|
208 |
foreach($auteurs_tab as $auteur) {
|
- |
|
209 |
// si les infos auteurs sont un tableau dans le cache alors l'id existe bien en base de données
|
152 |
|
210 |
if(is_array($this->cache_auteur[$auteur])) {
|
153 |
protected function insererLiensPublicationsAuteurs() {
|
- |
|
154 |
|
- |
|
155 |
$champs = array('cpuap_id_publication', 'cpuap_id_personne', 'cpuap_id_role', 'cpuap_ce_truk_type', 'cpuap_ordre', 'cpuap_ce_meta');
|
- |
|
156 |
$requete = "INSERT IGNORE INTO ".$this->table_publication_a_auteur." ".
|
- |
|
- |
|
211 |
$id_auteur = $this->cache_auteur[$auteur]['cp_id_personne'];
|
157 |
"(".implode(",", $champs).") VALUES ";
|
212 |
|
158 |
|
213 |
$valeurs = array($id_publication, $id_auteur, $this->id_role_auteur, "NULL", $ordre_auteur, "0");
|
159 |
foreach($this->auteurs_a_publi as $auteur => $publis) {
|
- |
|
160 |
|
214 |
|
161 |
$id_auteur = $this->cache_auteur[$auteur]['cp_id_personne'];
|
215 |
$requete_insertion = $requete." (".implode(',', $valeurs).") ";
|
162 |
|
- |
|
163 |
// Pour chaque publication importée à laquelle est liée l'auteur
|
216 |
$liaison = $this->bdd->executer($requete_insertion);
|
164 |
// il peut avoir un ordre différent
|
217 |
|
165 |
foreach($publis as $publi) {
|
218 |
// Historisation de l'ajout
|
166 |
|
- |
|
167 |
// l'ordre des auteurs commence à 1, les auteurs sont stockés dans l'ordre dans publis_a_auteurs
|
219 |
$histo = $this->creerXmlHisto(array_combine($colonnes, $liaison));
|
168 |
$ordre_auteur = array_search($auteur, $this->publis_a_auteurs[$publi]) + 1;
|
220 |
$cle_liaison = $id_publication.'-'.$this->id_role_auteur.'-'.$id_auteur;
|
169 |
|
- |
|
170 |
// Le nom complet de la publication est normalement unique et donc peut servir à retrouver
|
- |
|
171 |
// les publications qui ont été insérées par lot (sans en récupérer l'id)
|
- |
|
172 |
$sous_requete_id_publi = "SELECT cpu_id_publication FROM coel_publication ".
|
- |
|
173 |
"WHERE cpu_fmt_nom_complet IN (".$publi.") ";
|
- |
|
174 |
|
- |
|
175 |
$requete_insertion = $requete." (".
|
- |
|
176 |
" (".$sous_requete_id_publi."), ".
|
- |
|
177 |
$this->bdd->proteger($id_auteur).", ".
|
- |
|
178 |
$this->id_role_auteur.", ".
|
221 |
$id_meta = $this->historiser($this->id_table_publication_personne, $cle_liaison, $histo);
|
179 |
"NULL ,".
|
222 |
|
- |
|
223 |
// Affectation des méta données concernant l'ajout à la publication à auteur
|
- |
|
224 |
$requete_affectation_meta = "UPDATE ".$this->table_publication_a_auteur." ".
|
180 |
$ordre_auteur.", ".
|
225 |
"SET cpuap_ce_meta = ".$id_meta;
|
- |
|
226 |
$this->bdd->executer($requete_affectation_meta);
|
- |
|
227 |
}
|
- |
|
228 |
// L'ordre des auteurs est conservé même pour ceux qui n'existe pas dans la bdd
|
181 |
"NULL".
|
229 |
$ordre_auteur++;
|
- |
|
230 |
}
|
- |
|
231 |
}
|
- |
|
232 |
|
- |
|
233 |
protected function creerXmlHisto($donnees) {
|
- |
|
234 |
// Création du xml de l'enregistrement à historiser
|
182 |
") ";
|
235 |
$info = null;
|
- |
|
236 |
$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";
|
- |
|
237 |
$xml = null;
|
- |
|
238 |
|
- |
|
239 |
foreach ($donnees as $cle => $valeur) {
|
- |
|
240 |
// Pour éviter un éventuel double échappement des valeurs
|
- |
|
241 |
$valeur = stripslashes($valeur);
|
- |
|
242 |
$valeur = trim($valeur, "'");
|
- |
|
243 |
if (!is_null($valeur) && $valeur != '') {
|
- |
|
244 |
$xml .= "<$cle>$valeur</$cle>\n";
|
- |
|
245 |
}
|
- |
|
246 |
}
|
- |
|
247 |
if ($xml !== null) {
|
- |
|
248 |
$info = sprintf($xml_tpl, $xml);
|
- |
|
249 |
$info = $this->bdd->proteger($info);
|
- |
|
250 |
}
|
- |
|
251 |
|
- |
|
252 |
return $info;
|
- |
|
253 |
}
|
- |
|
254 |
|
- |
|
255 |
protected function historiser($table_id, $ligne_cle, $info) {
|
- |
|
256 |
date_default_timezone_set('Europe/Paris');
|
- |
|
257 |
// Pré-traitement des variables
|
- |
|
258 |
$info = (is_null($info)) ? 'NULL' : $info;
|
- |
|
259 |
|
- |
|
260 |
// Historisation (Ajout des méta-données)
|
- |
|
261 |
$requete = 'INSERT INTO coel_meta_historique_ligne '.
|
- |
|
262 |
' (cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.
|
- |
|
263 |
'VALUES ('.
|
- |
|
264 |
" $table_id, ".
|
- |
|
265 |
' "'.$ligne_cle.'", '.
|
- |
|
266 |
" $info, ".
|
- |
|
267 |
' "'.date('Y-m-d H:i:s', time()).'", '.
|
- |
|
268 |
" $this->id_utilisateur, ".
|
183 |
$insertion = $this->bdd->executer($requete_insertion);
|
269 |
" ".self::ETAT_AJOUTER.", ".
|
184 |
}
|
270 |
' "'.$this->ip_utilisateur.'", '.
|
185 |
}
|
271 |
' "'.$this->id_session.'") ';
|
186 |
// TODO: quoi faire en ce qui concerne l'insertion des auteurs ?
|
272 |
$resultat = $this->bdd->executer($requete);
|
187 |
// et le nombre inséré, les éventuels échecs de la requête ?
|
273 |
return $this->bdd->recupererIdDernierAjout();
|
188 |
}
|
274 |
}
|
189 |
|
275 |
|
190 |
protected function formaterNomComplet($ligne, $roles) {
|
276 |
protected function formaterNomComplet($ligne, $roles) {
|
191 |
|
277 |
|
192 |
$roles = array_flip($roles);
|
278 |
$roles = array_flip($roles);
|
193 |
|
279 |
|
194 |
// Intitulé de la publication complet : fmt_auteur, date_parution(année). titre. Editeur (nom), collection, fascicule, indication_nvt. pages.
|
280 |
// Intitulé de la publication complet : fmt_auteur, date_parution(année). titre. Editeur (nom), collection, fascicule, indication_nvt. pages.
|
195 |
// indication_nvt = serie_tome
|
281 |
// indication_nvt = serie_tome
|
196 |
$champs_nom_complet = array('auteur', 'annee', 'titre', 'editeur', 'intitule_revue', 'fascicule', 'serie_tome', 'pages');
|
282 |
$champs_nom_complet = array('auteur', 'annee', 'titre', 'editeur', 'intitule_revue', 'fascicule', 'serie_tome', 'pages');
|
197 |
$champs_fmt = array();
|
283 |
$champs_fmt = array();
|
198 |
|
284 |
|
199 |
$fmt_nom_complet = "";
|
285 |
$fmt_nom_complet = "";
|
200 |
|
286 |
|
201 |
foreach($champs_nom_complet as $champ) {
|
287 |
foreach($champs_nom_complet as $champ) {
|
202 |
$index = $roles[$champ];
|
288 |
$index = $roles[$champ];
|
203 |
if(!isset($ligne[$index])) {
|
289 |
if(!isset($ligne[$index])) {
|
204 |
$champs_fmt[$champ] = "";
|
290 |
$champs_fmt[$champ] = "";
|
205 |
} else {
|
291 |
} else {
|
206 |
$champs_fmt[$champ] = $ligne[$index];
|
292 |
$champs_fmt[$champ] = $ligne[$index];
|
207 |
}
|
293 |
}
|
208 |
}
|
294 |
}
|
209 |
|
295 |
|
210 |
$indication_nvt_pages = array($champs_fmt['serie_tome'], $champs_fmt['pages']);
|
296 |
$indication_nvt_pages = array($champs_fmt['serie_tome'], $champs_fmt['pages']);
|
211 |
$indication_nvt_pages = array_filter($indication_nvt_pages, 'strlen');
|
297 |
$indication_nvt_pages = array_filter($indication_nvt_pages, 'strlen');
|
212 |
$indication_nvt_pages = trim(implode(". ", $indication_nvt_pages));
|
298 |
$indication_nvt_pages = trim(implode(". ", $indication_nvt_pages));
|
213 |
$indication_nvt_pages .= !empty($indication_nvt_pages) ? "." : "";
|
299 |
$indication_nvt_pages .= !empty($indication_nvt_pages) ? "." : "";
|
214 |
|
300 |
|
215 |
$annee_titre_editeur = array($champs_fmt['annee'], $champs_fmt['titre'], $champs_fmt['editeur']);
|
301 |
$annee_titre_editeur = array($champs_fmt['annee'], $champs_fmt['titre'], $champs_fmt['editeur']);
|
216 |
$annee_titre_editeur = array_filter($annee_titre_editeur, 'strlen');
|
302 |
$annee_titre_editeur = array_filter($annee_titre_editeur, 'strlen');
|
217 |
$annee_titre_editeur = trim(implode(". ", $annee_titre_editeur));
|
303 |
$annee_titre_editeur = trim(implode(". ", $annee_titre_editeur));
|
218 |
|
304 |
|
219 |
$fmt_nom_complet = array($champs_fmt['auteur'],
|
305 |
$fmt_nom_complet = array($champs_fmt['auteur'],
|
220 |
$annee_titre_editeur,
|
306 |
$annee_titre_editeur,
|
221 |
$champs_fmt['intitule_revue'],
|
307 |
$champs_fmt['intitule_revue'],
|
222 |
$champs_fmt['fascicule'],
|
308 |
$champs_fmt['fascicule'],
|
223 |
$indication_nvt_pages);
|
309 |
$indication_nvt_pages);
|
224 |
|
310 |
|
225 |
$fmt_nom_complet = array_filter($fmt_nom_complet, 'strlen');
|
311 |
$fmt_nom_complet = array_filter($fmt_nom_complet, 'strlen');
|
226 |
$fmt_nom_complet = implode(", ", $fmt_nom_complet);
|
312 |
$fmt_nom_complet = implode(", ", $fmt_nom_complet);
|
227 |
|
313 |
|
228 |
return $fmt_nom_complet;
|
314 |
return $fmt_nom_complet;
|
229 |
}
|
315 |
}
|
230 |
|
- |
|
231 |
private function insererPublications(&$colonnes, &$publications) {
|
- |
|
232 |
|
- |
|
233 |
// Une insertion par tranche de 1000 permet d'insérer sans avoir de mysql
|
- |
|
234 |
// timeout qui nécessite de réveiller la connexion de temps en temps.
|
- |
|
235 |
// TODO: transactions ?
|
- |
|
236 |
$tranches_publis = array_chunk($publications, 1000);
|
- |
|
237 |
$nb_publis_inserees = 0;
|
- |
|
238 |
|
- |
|
239 |
foreach($tranches_publis as $tranche) {
|
- |
|
240 |
|
- |
|
241 |
$requete = "INSERT INTO ".$this->table_publication." ".
|
- |
|
242 |
"(".implode(',', $colonnes).") ".
|
- |
|
243 |
"VALUES ".implode(","."\n", $tranche)."\n";
|
- |
|
244 |
|
- |
|
245 |
$nb_publis_inserees += $this->bdd->executer($requete);
|
- |
|
246 |
}
|
- |
|
247 |
|
- |
|
248 |
return $nb_publis_inserees;
|
- |
|
249 |
}
|
- |
|
250 |
|
316 |
|
251 |
private function traiterChamp($valeur, $role) {
|
317 |
private function traiterChamp($valeur, $role) {
|
252 |
switch($role) {
|
318 |
switch($role) {
|
253 |
case 'auteur':
|
319 |
case 'auteur':
|
254 |
$valeur = $this->traiterChampAuteur($valeur);
|
320 |
$valeur = $this->traiterChampAuteur($valeur);
|
255 |
break;
|
321 |
break;
|
256 |
case 'editeur':
|
322 |
case 'editeur':
|
257 |
$valeur = 'AUTRE##'.$valeur;
|
323 |
$valeur = 'AUTRE##'.$valeur;
|
258 |
break;
|
324 |
break;
|
259 |
}
|
325 |
}
|
260 |
|
326 |
|
261 |
return $this->bdd->proteger($valeur);
|
327 |
return $this->bdd->proteger($valeur);
|
262 |
}
|
328 |
}
|
263 |
|
329 |
|
264 |
private function traiterChampAuteur($auteur_intitule) {
|
330 |
private function traiterChampAuteur($auteur_intitule) {
|
265 |
$auteurs_fmt = array();
|
331 |
$auteurs_fmt = array();
|
266 |
$auteurs_tab = explode(',', $auteur_intitule);
|
332 |
$auteurs_tab = explode(',', $auteur_intitule);
|
267 |
foreach($auteurs_tab as $auteur) {
|
333 |
foreach($auteurs_tab as $auteur) {
|
268 |
if(!empty(trim($auteur))) {
|
334 |
if(!empty(trim($auteur))) {
|
269 |
$auteurs_fmt[] = $this->obtenirInfosAuteur($auteur);
|
335 |
$auteurs_fmt[] = $this->obtenirInfosAuteur($auteur);
|
270 |
}
|
336 |
}
|
271 |
}
|
337 |
}
|
272 |
|
338 |
|
273 |
return implode(', ', $auteurs_fmt);
|
339 |
return implode(', ', $auteurs_fmt);
|
274 |
}
|
340 |
}
|
275 |
|
341 |
|
276 |
private function obtenirInfosAuteur($auteur_intitule) {
|
342 |
private function obtenirInfosAuteur($auteur_intitule) {
|
277 |
$retour = $auteur_intitule;
|
343 |
$retour = $auteur_intitule;
|
278 |
// Si on déjà recherché et trouvé (ou non l'auteur)
|
344 |
// Si on déjà recherché et trouvé (ou non l'auteur)
|
279 |
if(isset($this->cache_auteur[$auteur_intitule])) {
|
345 |
if(isset($this->cache_auteur[$auteur_intitule])) {
|
280 |
// On renvoie son nom complet formaté s'il existe en bdd ou sinon
|
346 |
// On renvoie son nom complet formaté s'il existe en bdd ou sinon
|
281 |
// le nom qui a été donné dans la feuille csv
|
347 |
// le nom qui a été donné dans la feuille csv
|
282 |
$retour = !empty($this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet']) ?
|
348 |
$retour = !empty($this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet']) ?
|
283 |
$this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet'] :
|
349 |
$this->cache_auteur[$auteur_intitule]['cp_fmt_nom_complet'] :
|
284 |
$auteur_intitule;
|
350 |
$auteur_intitule;
|
285 |
} else {
|
351 |
} else {
|
286 |
// Recherche de l'auteur sur un maximum du combinaisons possible des variations
|
352 |
// Recherche de l'auteur sur un maximum du combinaisons possible des variations
|
287 |
// de son nom et prénom
|
353 |
// de son nom et prénom
|
288 |
$auteur = $this->fabriquerCombinaisonsAuteur($auteur_intitule);
|
354 |
$auteur = $this->fabriquerCombinaisonsAuteur($auteur_intitule);
|
289 |
$auteur_req = "(".implode(', ', $auteur).")";
|
355 |
$auteur_req = "(".implode(', ', $auteur).")";
|
290 |
|
356 |
|
291 |
$requete = "SELECT cp_id_personne, cp_fmt_nom_complet FROM ".$this->table_auteur." WHERE cp_fmt_nom_complet IN ".$auteur_req;
|
357 |
$requete = "SELECT cp_id_personne, cp_fmt_nom_complet FROM ".$this->table_auteur." WHERE cp_fmt_nom_complet IN ".$auteur_req;
|
292 |
$infos_auteur = $this->bdd->recupererTous($requete);
|
358 |
$infos_auteur = $this->bdd->recupererTous($requete);
|
293 |
|
359 |
|
294 |
// Stockage en cache de la ligne de bdd si trouvé,
|
360 |
// Stockage en cache de la ligne de bdd si trouvé,
|
295 |
// de la valeur brute sinon
|
361 |
// de la valeur brute sinon
|
296 |
if(!empty($infos_auteur)) {
|
362 |
if(!empty($infos_auteur)) {
|
297 |
$retour = $infos_auteur[0]['cp_fmt_nom_complet'];
|
363 |
$retour = $infos_auteur[0]['cp_fmt_nom_complet'];
|
298 |
$this->cache_auteur[$auteur_intitule] = $infos_auteur[0];
|
364 |
$this->cache_auteur[$auteur_intitule] = $infos_auteur[0];
|
- |
|
365 |
// Stocker le nom d'auteur sous les deux formes (fmt nom complet et tel que saisi), facilite la recherche
|
- |
|
366 |
// plus tard lors de la liaison des publications aux auteurs
|
- |
|
367 |
$this->cache_auteur[$infos_auteur[0]['cp_fmt_nom_complet']] = $infos_auteur[0];
|
299 |
} else {
|
368 |
} else {
|
300 |
$retour = $auteur_intitule;
|
369 |
$retour = $auteur_intitule;
|
301 |
$this->cache_auteur[$auteur_intitule] = $auteur_intitule;
|
370 |
$this->cache_auteur[$auteur_intitule] = $auteur_intitule;
|
302 |
}
|
371 |
}
|
303 |
}
|
372 |
}
|
304 |
|
373 |
|
305 |
return $retour;
|
374 |
return $retour;
|
306 |
}
|
375 |
}
|
307 |
|
376 |
|
308 |
private function fabriquerCombinaisonsAuteur($auteur) {
|
377 |
private function fabriquerCombinaisonsAuteur($auteur) {
|
309 |
|
378 |
|
310 |
$auteur = trim($auteur);
|
379 |
$auteur = trim($auteur);
|
311 |
$auteurs_formates = array($this->bdd->proteger($auteur));
|
380 |
$auteurs_formates = array($this->bdd->proteger($auteur));
|
312 |
|
381 |
|
313 |
// Séparation des élements de l'auteur des espaces pour obtenir
|
382 |
// Séparation des élements de l'auteur des espaces pour obtenir
|
314 |
// les noms et prénoms (Ex. "Carl Von Linné" => "Carl", "Von", "Linné")
|
383 |
// les noms et prénoms (Ex. "Carl Von Linné" => "Carl", "Von", "Linné")
|
315 |
$auteur_tab = explode(' ', $auteur);
|
384 |
$auteur_tab = explode(' ', $auteur);
|
316 |
$auteur_tab = array_filter($auteur_tab);
|
385 |
$auteur_tab = array_filter($auteur_tab);
|
317 |
|
386 |
|
318 |
$combinaisons = array();
|
387 |
$combinaisons = array();
|
319 |
foreach($auteur_tab as &$element_auteur) {
|
388 |
foreach($auteur_tab as &$element_auteur) {
|
320 |
$combinaisons[] = array(
|
389 |
$combinaisons[] = array(
|
321 |
// élement tel quel (Ex: "Linné")
|
390 |
// élement tel quel (Ex: "Linné")
|
322 |
$element_auteur,
|
391 |
$element_auteur,
|
323 |
// possibilité de l'initiale seule (Ex: "L")
|
392 |
// possibilité de l'initiale seule (Ex: "L")
|
324 |
substr($element_auteur, 0, 1),
|
393 |
substr($element_auteur, 0, 1),
|
325 |
// possibilité de l'initiale avec un point du genre (Ex: "L.")
|
394 |
// possibilité de l'initiale avec un point du genre (Ex: "L.")
|
326 |
substr($element_auteur, 0, 1)."."
|
395 |
substr($element_auteur, 0, 1)."."
|
327 |
);
|
396 |
);
|
328 |
}
|
397 |
}
|
329 |
|
398 |
|
330 |
// Fabrication de toutes les combinaisons possibles des parties de noms ci-dessus
|
399 |
// Fabrication de toutes les combinaisons possibles des parties de noms ci-dessus
|
331 |
// pour deux et trois élements en faisant plusieurs produits cartésiens
|
400 |
// pour deux et trois élements en faisant plusieurs produits cartésiens
|
332 |
// car le nom peut être combiné différement de celui en base de données
|
401 |
// car le nom peut être combiné différement de celui en base de données
|
333 |
// (Ex. : "Carl Von Linné" VS "C. Von Linné" ou "C. V. Linné" ou encore "Von Linné C." etc...)
|
402 |
// (Ex. : "Carl Von Linné" VS "C. Von Linné" ou "C. V. Linné" ou encore "Von Linné C." etc...)
|
334 |
|
403 |
|
335 |
// C'est moche et pas très élégant mais bon ça marche dans 90% des cas
|
404 |
// C'est moche et pas très élégant mais bon ça marche dans 90% des cas
|
336 |
// On ne teste pas plus que 3 combinaisons, car ça serait très très couteux
|
405 |
// On ne teste pas plus que 3 combinaisons, car ça serait très très couteux
|
337 |
// TODO: faire mieux et factoriser les appels ci dessous
|
406 |
// TODO: faire mieux et factoriser les appels ci dessous
|
338 |
if(count($auteur_tab) > 2) {
|
407 |
if(count($auteur_tab) > 2) {
|
339 |
// Cas du nom à trois parties (genre "Carl Von Linné")
|
408 |
// Cas du nom à trois parties (genre "Carl Von Linné")
|
340 |
$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1], $combinaisons[2]));
|
409 |
$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1], $combinaisons[2]));
|
341 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[0], $combinaisons[2], $combinaisons[1])));
|
410 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[0], $combinaisons[2], $combinaisons[1])));
|
342 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[2], $combinaisons[0])));
|
411 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[2], $combinaisons[0])));
|
343 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0], $combinaisons[2])));
|
412 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0], $combinaisons[2])));
|
344 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[1], $combinaisons[0])));
|
413 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[1], $combinaisons[0])));
|
345 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[0], $combinaisons[1])));
|
414 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[2], $combinaisons[0], $combinaisons[1])));
|
346 |
} else {
|
415 |
} else {
|
347 |
// Cas du nom à trois parties (genre "Carl Linné")
|
416 |
// Cas du nom à trois parties (genre "Carl Linné")
|
348 |
$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1]));
|
417 |
$possibilites_auteurs = $this->cartesian(array($combinaisons[0], $combinaisons[1]));
|
349 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0])));
|
418 |
$possibilites_auteurs = array_merge($possibilites_auteurs, $this->cartesian(array($combinaisons[1], $combinaisons[0])));
|
350 |
}
|
419 |
}
|
351 |
|
420 |
|
352 |
$auteurs_formates = array();
|
421 |
$auteurs_formates = array();
|
353 |
foreach($possibilites_auteurs as &$possibilite) {
|
422 |
foreach($possibilites_auteurs as &$possibilite) {
|
354 |
$initiales = true;
|
423 |
$initiales = true;
|
355 |
// Suppression des possibilités ne contenant que des initiales avec ou sans point
|
424 |
// Suppression des possibilités ne contenant que des initiales avec ou sans point
|
356 |
foreach($possibilite as &$chars) {
|
425 |
foreach($possibilite as &$chars) {
|
357 |
$initiales = $initiales && mb_strlen($chars) <= 2;
|
426 |
$initiales = $initiales && mb_strlen($chars) <= 2;
|
358 |
}
|
427 |
}
|
359 |
|
428 |
|
360 |
if(!$initiales) {
|
429 |
if(!$initiales) {
|
361 |
$auteurs_formates[] = $this->bdd->proteger(implode(" ", $possibilite));
|
430 |
$auteurs_formates[] = $this->bdd->proteger(implode(" ", $possibilite));
|
362 |
}
|
431 |
}
|
363 |
}
|
432 |
}
|
364 |
|
433 |
|
365 |
return $auteurs_formates;
|
434 |
return $auteurs_formates;
|
366 |
}
|
435 |
}
|
367 |
|
436 |
|
368 |
// http://stackoverflow.com/questions/6311779/finding-cartesian-product-with-php-associative-arrays
|
437 |
// http://stackoverflow.com/questions/6311779/finding-cartesian-product-with-php-associative-arrays
|
369 |
function cartesian($input) {
|
438 |
function cartesian($input) {
|
370 |
// filter out empty values
|
439 |
// filter out empty values
|
371 |
$input = array_filter($input);
|
440 |
$input = array_filter($input);
|
372 |
|
441 |
|
373 |
$result = array(array());
|
442 |
$result = array(array());
|
374 |
|
443 |
|
375 |
foreach ($input as $key => $values) {
|
444 |
foreach ($input as $key => $values) {
|
376 |
$append = array();
|
445 |
$append = array();
|
377 |
|
446 |
|
378 |
foreach($result as $product) {
|
447 |
foreach($result as $product) {
|
379 |
foreach($values as $item) {
|
448 |
foreach($values as $item) {
|
380 |
$product[$key] = $item;
|
449 |
$product[$key] = $item;
|
381 |
$append[] = $product;
|
450 |
$append[] = $product;
|
382 |
}
|
451 |
}
|
383 |
}
|
452 |
}
|
384 |
|
453 |
|
385 |
$result = $append;
|
454 |
$result = $append;
|
386 |
}
|
455 |
}
|
387 |
|
456 |
|
388 |
return $result;
|
457 |
return $result;
|
389 |
}
|
458 |
}
|
390 |
}
|
459 |
}
|
391 |
?>
|
460 |
?>
|