1636 |
raphael |
1 |
<?php
|
|
|
2 |
/**
|
|
|
3 |
* @category PHP
|
|
|
4 |
* @package jrest
|
|
|
5 |
* @author Raphaël Droz <raphael@tela-botania.org>
|
|
|
6 |
* @copyright 2013 Tela-Botanica
|
|
|
7 |
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
|
|
|
8 |
* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
|
|
|
9 |
*/
|
|
|
10 |
|
|
|
11 |
/**
|
|
|
12 |
* Service d'import de données d'observation du CEL au format XLS
|
1649 |
raphael |
13 |
*
|
|
|
14 |
* Sont define()'d commme n° de colonne tous les abbrevs retournés par
|
1656 |
raphael |
15 |
* FormateurGroupeColonne::nomEnsembleVersListeColonnes() préfixés par C_ cf: detectionEntete()
|
1649 |
raphael |
16 |
*
|
|
|
17 |
* Exemple d'un test:
|
|
|
18 |
* $ GET "/jrest/ExportXLS/22506?format=csv&range=*&limite=13" \
|
|
|
19 |
* | curl -F "upload=@-" -F utilisateur=22506 "/jrest/ImportXLS"
|
|
|
20 |
* # 13 observations importées
|
|
|
21 |
* + cf MySQL general_log = 1
|
|
|
22 |
*
|
|
|
23 |
**/
|
1636 |
raphael |
24 |
|
|
|
25 |
set_include_path(get_include_path() . PATH_SEPARATOR . dirname(dirname(realpath(__FILE__))) . '/lib');
|
|
|
26 |
// TERM
|
|
|
27 |
error_reporting(-1);
|
|
|
28 |
ini_set('html_errors', 0);
|
|
|
29 |
ini_set('xdebug.cli_color', 2);
|
|
|
30 |
require_once('lib/PHPExcel/Classes/PHPExcel.php');
|
1656 |
raphael |
31 |
require_once('FormateurGroupeColonne.php');
|
1636 |
raphael |
32 |
|
1640 |
raphael |
33 |
|
|
|
34 |
date_default_timezone_set("Europe/Paris");
|
|
|
35 |
|
|
|
36 |
// nombre d'INSERT à cumuler par requête SQL
|
|
|
37 |
// (= nombre de lignes XLS à bufferiser)
|
1648 |
raphael |
38 |
//define('NB_LIRE_LIGNE_SIMUL', 30);
|
|
|
39 |
define('NB_LIRE_LIGNE_SIMUL', 5);
|
1640 |
raphael |
40 |
|
|
|
41 |
// Numbers of days between January 1, 1900 and 1970 (including 19 leap years)
|
|
|
42 |
// see traiterDateObs()
|
1675 |
raphael |
43 |
// define("MIN_DATES_DIFF", 25569);
|
1640 |
raphael |
44 |
|
|
|
45 |
|
1636 |
raphael |
46 |
class MyReadFilter implements PHPExcel_Reader_IReadFilter {
|
1640 |
raphael |
47 |
// exclusion de colonnes
|
1638 |
raphael |
48 |
public $exclues = array();
|
1640 |
raphael |
49 |
|
|
|
50 |
// lecture par morceaux
|
|
|
51 |
public $ligne_debut = 0;
|
|
|
52 |
public $ligne_fin = 0;
|
|
|
53 |
|
1636 |
raphael |
54 |
public function __construct() {}
|
1640 |
raphael |
55 |
public function def_interval($debut, $nb) {
|
|
|
56 |
$this->ligne_debut = $debut;
|
|
|
57 |
$this->ligne_fin = $debut + $nb;
|
|
|
58 |
}
|
1638 |
raphael |
59 |
public function readCell($colonne, $ligne, $worksheetName = '') {
|
|
|
60 |
if(@$this->exclues[$colonne]) return false;
|
1640 |
raphael |
61 |
// si des n° de morceaux ont été initialisés, on filtre...
|
|
|
62 |
if($this->ligne_debut && ($ligne < $this->ligne_debut || $ligne >= $this->ligne_fin)) return false;
|
1636 |
raphael |
63 |
return true;
|
|
|
64 |
}
|
|
|
65 |
}
|
|
|
66 |
|
1675 |
raphael |
67 |
// XXX: PHP 5.3
|
|
|
68 |
function __anonyme_1($v) { return !$v['importable']; }
|
|
|
69 |
function __anonyme_2(&$v) { $v = $v['nom']; }
|
|
|
70 |
function __anonyme_3($cell) { return !is_null($cell); };
|
|
|
71 |
function __anonyme_5($item) { return is_null($item) ? '?' : $item; }
|
|
|
72 |
function __anonyme_6() { return NULL; }
|
|
|
73 |
|
1636 |
raphael |
74 |
class ImportXLS extends Cel {
|
1765 |
raphael |
75 |
static function __anonyme_4(&$item, $key) { $item = self::quoteNonNull(trim($item)); }
|
1636 |
raphael |
76 |
|
|
|
77 |
static $ordre_BDD = Array(
|
|
|
78 |
"ce_utilisateur",
|
|
|
79 |
"prenom_utilisateur",
|
|
|
80 |
"nom_utilisateur",
|
|
|
81 |
"courriel_utilisateur",
|
|
|
82 |
"ordre",
|
|
|
83 |
"nom_sel",
|
|
|
84 |
"nom_sel_nn",
|
|
|
85 |
"nom_ret",
|
|
|
86 |
"nom_ret_nn",
|
|
|
87 |
"nt",
|
|
|
88 |
"famille",
|
|
|
89 |
"nom_referentiel",
|
|
|
90 |
"zone_geo",
|
|
|
91 |
"ce_zone_geo",
|
|
|
92 |
"date_observation",
|
|
|
93 |
"lieudit",
|
|
|
94 |
"station",
|
|
|
95 |
"milieu",
|
1649 |
raphael |
96 |
"mots_cles_texte",
|
1636 |
raphael |
97 |
"commentaire",
|
|
|
98 |
"transmission",
|
|
|
99 |
"date_creation",
|
|
|
100 |
"date_modification",
|
1649 |
raphael |
101 |
"date_transmission",
|
1636 |
raphael |
102 |
"latitude",
|
1648 |
raphael |
103 |
"longitude",
|
1699 |
raphael |
104 |
"altitude",
|
1649 |
raphael |
105 |
"abondance",
|
|
|
106 |
"certitude",
|
1648 |
raphael |
107 |
"phenologie",
|
|
|
108 |
"code_insee_calcule"
|
|
|
109 |
);
|
1636 |
raphael |
110 |
|
1649 |
raphael |
111 |
// cf: initialiser_pdo_ordered_statements()
|
1648 |
raphael |
112 |
// eg: "INSERT INTO cel_obs (ce_utilisateur, ..., phenologie, code_insee_calcule) VALUES"
|
|
|
113 |
// colonnes statiques d'abord, les autres ensuite, dans l'ordre de $ordre_BDD
|
|
|
114 |
static $insert_prefix_ordre;
|
|
|
115 |
// eg: "(<id>, <prenom>, <nom>, <email>, now(), now(), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
|
|
|
116 |
// dont le nombre de placeholder dépend du nombre de colonnes non-statiques
|
|
|
117 |
// colonnes statiques d'abord, les autres ensuite, dans l'ordre de $ordre_BDD
|
|
|
118 |
static $insert_ligne_pattern_ordre;
|
|
|
119 |
|
1649 |
raphael |
120 |
// seconde (meilleure) possibilité
|
|
|
121 |
// cf: initialiser_pdo_statements()
|
|
|
122 |
// eg: "INSERT INTO cel_obs (ce_utilisateur, ..., date_creation, ...phenologie, code_insee_calcule) VALUES"
|
|
|
123 |
static $insert_prefix;
|
1648 |
raphael |
124 |
// eg: "(<id>, <prenom>, <nom>, <email>, ?, ?, ?, now(), now(), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
|
|
|
125 |
// dont le nombre de placeholder dépend du nombre de colonnes non-statiques
|
|
|
126 |
static $insert_ligne_pattern;
|
|
|
127 |
|
1640 |
raphael |
128 |
/*
|
|
|
129 |
Ces colonnes:
|
1642 |
raphael |
130 |
- sont propres à l'ensemble des enregistrements uploadés
|
1640 |
raphael |
131 |
- sont indépendantes du numéro de lignes
|
|
|
132 |
- n'ont pas de valeur par défaut dans la structure de la table
|
|
|
133 |
- nécessitent une initialisation dans le cadre de l'upload
|
1649 |
raphael |
134 |
|
|
|
135 |
initialiser_colonnes_statiques() y merge les données d'identification utilisateur
|
1640 |
raphael |
136 |
*/
|
|
|
137 |
public $colonnes_statiques = Array(
|
|
|
138 |
"ce_utilisateur" => NULL,
|
|
|
139 |
"prenom_utilisateur" => NULL,
|
|
|
140 |
"nom_utilisateur" => NULL,
|
|
|
141 |
"courriel_utilisateur" => NULL,
|
|
|
142 |
|
1642 |
raphael |
143 |
// fixes (fonction SQL)
|
|
|
144 |
// XXX future: mais pourraient varier dans le futur si la mise-à-jour
|
1640 |
raphael |
145 |
// d'observation est implémentée
|
1642 |
raphael |
146 |
"date_creation" => "now()",
|
|
|
147 |
"date_modification" => "now()",
|
1640 |
raphael |
148 |
);
|
|
|
149 |
|
1642 |
raphael |
150 |
public $id_utilisateur = NULL;
|
1649 |
raphael |
151 |
|
1642 |
raphael |
152 |
// erreurs d'import
|
|
|
153 |
public $bilan = Array();
|
|
|
154 |
|
1649 |
raphael |
155 |
|
1732 |
raphael |
156 |
function ImportXLS($config) {
|
1636 |
raphael |
157 |
parent::__construct($config);
|
|
|
158 |
}
|
|
|
159 |
|
|
|
160 |
function createElement($pairs) {
|
|
|
161 |
if(!isset($pairs['utilisateur']) || trim($pairs['utilisateur']) == '') {
|
1770 |
raphael |
162 |
exit('0');
|
1636 |
raphael |
163 |
}
|
1649 |
raphael |
164 |
|
1640 |
raphael |
165 |
$id_utilisateur = intval($pairs['utilisateur']);
|
1642 |
raphael |
166 |
$this->id_utilisateur = $id_utilisateur; // pour traiterImage();
|
1640 |
raphael |
167 |
|
1636 |
raphael |
168 |
if(!isset($_SESSION)) session_start();
|
1640 |
raphael |
169 |
$this->controleUtilisateur($id_utilisateur);
|
1636 |
raphael |
170 |
|
1640 |
raphael |
171 |
$this->utilisateur = $this->getInfosComplementairesUtilisateur($id_utilisateur);
|
1649 |
raphael |
172 |
|
1640 |
raphael |
173 |
$this->initialiser_colonnes_statiques($id_utilisateur);
|
1636 |
raphael |
174 |
|
1648 |
raphael |
175 |
// initialisation du statement PDO/MySQL
|
1649 |
raphael |
176 |
// première version, pattern de requête pas génial
|
|
|
177 |
/* list(self;;$insert_prefix_ordre, self::$insert_ligne_pattern_ordre) =
|
|
|
178 |
$this->initialiser_pdo_ordered_statements($this->colonnes_statiques); */
|
|
|
179 |
list(self::$insert_prefix, self::$insert_ligne_pattern) =
|
|
|
180 |
$this->initialiser_pdo_statements($this->colonnes_statiques);
|
1640 |
raphael |
181 |
|
1636 |
raphael |
182 |
$infos_fichier = array_pop($_FILES);
|
|
|
183 |
|
|
|
184 |
/*$objPHPExcel = PHPExcel_IOFactory::load($infos_fichier['tmp_name']);
|
1638 |
raphael |
185 |
$donnees = $objPHPExcel->getActiveSheet()->toArray(NULL,FALSE,FALSE,TRUE);*/
|
1636 |
raphael |
186 |
|
|
|
187 |
/*$objReader = PHPExcel_IOFactory::createReader("Excel5");
|
|
|
188 |
$objReader->setReadDataOnly(true);
|
|
|
189 |
$objPHPExcel = $objReader->load($infos_fichier['tmp_name']);*/
|
|
|
190 |
|
1638 |
raphael |
191 |
//var_dump($donnees);
|
1636 |
raphael |
192 |
|
1642 |
raphael |
193 |
// renomme le fichier pour lui ajouter son extension initiale, ce qui
|
|
|
194 |
// permet (une sorte) d'autodétection du format.
|
|
|
195 |
$fichier = $infos_fichier['tmp_name'];
|
|
|
196 |
$extension = pathinfo($infos_fichier['name'], PATHINFO_EXTENSION);
|
|
|
197 |
if( (strlen($extension) == 3 || strlen($extension) == 4) &&
|
1747 |
raphael |
198 |
(@rename($fichier, $fichier . '.' . $extension))) { // XXX: @ safe-mode
|
1642 |
raphael |
199 |
$fichier = $fichier . '.' . $extension;
|
|
|
200 |
}
|
|
|
201 |
|
|
|
202 |
$objReader = PHPExcel_IOFactory::createReaderForFile($fichier);
|
1818 |
raphael |
203 |
// TODO: check if compatible with toArray(<1>,<2>,TRUE,<4>)
|
1636 |
raphael |
204 |
$objReader->setReadDataOnly(true);
|
1640 |
raphael |
205 |
|
1698 |
raphael |
206 |
// TODO: is_a obsolete entre 5.0 et 5.3, retirer le @ à terme
|
|
|
207 |
if(@is_a($objReader, 'PHPExcel_Reader_CSV')) {
|
1642 |
raphael |
208 |
$objReader->setDelimiter(',')
|
|
|
209 |
->setEnclosure('"')
|
|
|
210 |
->setLineEnding("\n")
|
|
|
211 |
->setSheetIndex(0);
|
|
|
212 |
}
|
|
|
213 |
|
1640 |
raphael |
214 |
// on ne conserve que l'en-tête
|
|
|
215 |
$filtre = new MyReadFilter();
|
|
|
216 |
$filtre->def_interval(1, 2);
|
|
|
217 |
$objReader->setReadFilter($filtre);
|
|
|
218 |
|
1642 |
raphael |
219 |
$objPHPExcel = $objReader->load($fichier);
|
|
|
220 |
$obj_infos = $objReader->listWorksheetInfo($fichier);
|
1640 |
raphael |
221 |
// XXX: indépendant du readFilter ?
|
|
|
222 |
$nb_lignes = $obj_infos[0]['totalRows'];
|
1636 |
raphael |
223 |
|
1818 |
raphael |
224 |
$donnees = $objPHPExcel->getActiveSheet()->toArray(NULL, FALSE, TRUE, TRUE);
|
1640 |
raphael |
225 |
$filtre->exclues = self::detectionEntete($donnees[1]);
|
1636 |
raphael |
226 |
|
1640 |
raphael |
227 |
$obs_ajouts = 0;
|
|
|
228 |
$obs_maj = 0;
|
1677 |
raphael |
229 |
$nb_images_ajoutees = 0;
|
|
|
230 |
$nb_mots_cle_ajoutes = 0;
|
|
|
231 |
|
1765 |
raphael |
232 |
$dernier_ordre = Cel::db()->requeter("SELECT MAX(ordre) AS ordre FROM cel_obs WHERE ce_utilisateur = $id_utilisateur");
|
1640 |
raphael |
233 |
$dernier_ordre = intval($dernier_ordre[0]['ordre']) + 1;
|
|
|
234 |
if(! $dernier_ordre) $dernier_ordre = 0;
|
|
|
235 |
|
1642 |
raphael |
236 |
// on catch to les trigger_error(E_USER_NOTICE);
|
|
|
237 |
set_error_handler(array($this, 'erreurs_stock'), E_USER_NOTICE);
|
|
|
238 |
|
1640 |
raphael |
239 |
// lecture par morceaux (chunks), NB_LIRE_LIGNE_SIMUL lignes à fois
|
|
|
240 |
// pour aboutir des requêtes SQL d'insert groupés.
|
|
|
241 |
for($ligne = 2; $ligne < $nb_lignes + NB_LIRE_LIGNE_SIMUL; $ligne += NB_LIRE_LIGNE_SIMUL) {
|
|
|
242 |
$filtre->def_interval($ligne, NB_LIRE_LIGNE_SIMUL);
|
|
|
243 |
$objReader->setReadFilter($filtre);
|
|
|
244 |
|
|
|
245 |
/* recharge avec $filtre actif (filtre sur lignes colonnes):
|
|
|
246 |
- exclue les colonnes inutiles/inutilisables)
|
|
|
247 |
- ne selectionne que les lignes dans le range [$ligne - $ligne + NB_LIRE_LIGNE_SIMUL] */
|
1818 |
raphael |
248 |
$objPHPExcel = $objReader->load($fichier)->getActiveSheet();
|
1640 |
raphael |
249 |
|
1818 |
raphael |
250 |
// set col typing
|
|
|
251 |
if(C_CE_ZONE_GEO != 'C_CE_ZONE_GEO')
|
|
|
252 |
$objPHPExcel->getStyle(C_CE_ZONE_GEO . '2:' . C_CE_ZONE_GEO . $objPHPExcel->getHighestRow())->getNumberFormat()->setFormatCode('00000');
|
|
|
253 |
|
|
|
254 |
// TODO: set to string type
|
|
|
255 |
if(C_ZONE_GEO != 'C_ZONE_GEO')
|
|
|
256 |
$objPHPExcel->getStyle(C_ZONE_GEO . '2:' . C_ZONE_GEO . $objPHPExcel->getHighestRow())->getNumberFormat()->setFormatCode('00000');
|
|
|
257 |
|
|
|
258 |
$donnees = $objPHPExcel->toArray(NULL, FALSE, TRUE, TRUE);
|
|
|
259 |
|
1640 |
raphael |
260 |
// ici on appel la fonction qui fera effectivement l'insertion multiple
|
|
|
261 |
// à partir des (au plus) NB_LIRE_LIGNE_SIMUL lignes
|
|
|
262 |
|
1677 |
raphael |
263 |
// TODO: passer $this, ne sert que pour appeler des méthodes publiques qui pourraient être statiques
|
1640 |
raphael |
264 |
// notamment dans RechercheInfosTaxonBeta.php
|
1677 |
raphael |
265 |
list($enregistrements, $images, $mots_cle) =
|
1642 |
raphael |
266 |
self::chargerLignes($this, $donnees, $this->colonnes_statiques, $dernier_ordre);
|
|
|
267 |
if(! $enregistrements) break;
|
|
|
268 |
|
1648 |
raphael |
269 |
self::trierColonnes($enregistrements);
|
|
|
270 |
// normalement: NB_LIRE_LIGNE_SIMUL, sauf si une enregistrement ne semble pas valide
|
|
|
271 |
// ou bien lors du dernier chunk
|
|
|
272 |
|
|
|
273 |
$nb_rec = count($enregistrements);
|
|
|
274 |
$sql_pattern = self::$insert_prefix .
|
|
|
275 |
str_repeat(self::$insert_ligne_pattern_ordre . ', ', $nb_rec - 1) .
|
|
|
276 |
self::$insert_ligne_pattern_ordre;
|
|
|
277 |
|
|
|
278 |
$sql_pattern = self::$insert_prefix .
|
|
|
279 |
str_repeat(self::$insert_ligne_pattern . ', ', $nb_rec - 1) .
|
|
|
280 |
self::$insert_ligne_pattern;
|
|
|
281 |
|
1765 |
raphael |
282 |
Cel::db()->beginTransaction();
|
|
|
283 |
$stmt = Cel::db()->prepare($sql_pattern);
|
1648 |
raphael |
284 |
$donnees = array();
|
|
|
285 |
foreach($enregistrements as $e) $donnees = array_merge($donnees, array_values($e));
|
|
|
286 |
|
1678 |
raphael |
287 |
/* debug ici: echo $sql_pattern . "\n"; var_dump($enregistrements, $donnees); die;*/
|
1648 |
raphael |
288 |
|
|
|
289 |
$stmt->execute($donnees);
|
|
|
290 |
|
|
|
291 |
// $stmt->debugDumpParams(); // https://bugs.php.net/bug.php?id=52384
|
1765 |
raphael |
292 |
$dernier_autoinc = Cel::db()->lastInsertId();
|
|
|
293 |
Cel::db()->commit();
|
1648 |
raphael |
294 |
|
1650 |
raphael |
295 |
if(! $dernier_autoinc) trigger_error("l'insertion semble avoir échoué", E_USER_NOTICE);
|
1648 |
raphael |
296 |
|
1642 |
raphael |
297 |
$obs_ajouts += count($enregistrements);
|
1648 |
raphael |
298 |
// $obs_ajouts += count($enregistrements['insert']);
|
|
|
299 |
// $obs_maj += count($enregistrements['update']);
|
1765 |
raphael |
300 |
$nb_images_ajoutees += self::stockerImages($enregistrements, $images, $dernier_autoinc);
|
|
|
301 |
$nb_mots_cle_ajoutes += self::stockerMotsCle($enregistrements, $mots_cle, $dernier_autoinc);
|
1640 |
raphael |
302 |
}
|
1642 |
raphael |
303 |
|
|
|
304 |
restore_error_handler();
|
|
|
305 |
|
|
|
306 |
if($this->bilan) echo implode("\n", $this->bilan) . "\n";
|
1792 |
raphael |
307 |
printf('%1$d observation%2$s ajoutée%2$s' . "\n" .
|
|
|
308 |
'%3$d image%4$s attachée%4$s' . "\n" .
|
1781 |
raphael |
309 |
// '%5$d mot%6$c-clef ajouté%6$c [TODO]' . "\n" . // TODO
|
1792 |
raphael |
310 |
(count($filtre->exclues) > 0 ? 'colonne%7$s non-traitée%7$s: %8$s' . "\n" : ''),
|
|
|
311 |
|
1781 |
raphael |
312 |
$obs_ajouts,
|
1812 |
raphael |
313 |
$obs_ajouts > 1 ? 's' : '',
|
1781 |
raphael |
314 |
$nb_images_ajoutees,
|
1812 |
raphael |
315 |
$nb_images_ajoutees > 1 ? 's' : '',
|
1781 |
raphael |
316 |
$nb_mots_cle_ajoutes,
|
1812 |
raphael |
317 |
$nb_mots_cle_ajoutes > 1 ? 's' : '',
|
1792 |
raphael |
318 |
count($filtre->exclues) > 1 ? 's' : '',
|
1781 |
raphael |
319 |
implode(', ', $filtre->exclues));
|
|
|
320 |
die();
|
1636 |
raphael |
321 |
}
|
|
|
322 |
|
|
|
323 |
static function detectionEntete($entete) {
|
|
|
324 |
$colonnes_reconnues = Array();
|
1678 |
raphael |
325 |
$cols = FormateurGroupeColonne::nomEnsembleVersListeColonnes('standard,avance');
|
1636 |
raphael |
326 |
foreach($entete as $k => $v) {
|
1781 |
raphael |
327 |
// traite les colonnes en faisant fi de la casse et des accents
|
1636 |
raphael |
328 |
$entete_simple = iconv('UTF-8', 'ASCII//TRANSLIT', strtolower(trim($v)));
|
|
|
329 |
foreach($cols as $col) {
|
|
|
330 |
$entete_officiel_simple = iconv('UTF-8', 'ASCII//TRANSLIT', strtolower(trim($col['nom'])));
|
1638 |
raphael |
331 |
$entete_officiel_abbrev = $col['abbrev'];
|
|
|
332 |
if($entete_simple == $entete_officiel_simple || $entete_simple == $entete_officiel_abbrev) {
|
1648 |
raphael |
333 |
// debug echo "define C_" . strtoupper($entete_officiel_abbrev) . ", $k ($v)\n";
|
1638 |
raphael |
334 |
define("C_" . strtoupper($entete_officiel_abbrev), $k);
|
1636 |
raphael |
335 |
$colonnes_reconnues[$k] = 1;
|
|
|
336 |
break;
|
|
|
337 |
}
|
|
|
338 |
}
|
|
|
339 |
}
|
1770 |
raphael |
340 |
// défini tous les index que nous utilisons à une valeur d'index de colonne Excel qui n'existe pas dans
|
|
|
341 |
// le tableau renvoyé par PHPExcel
|
|
|
342 |
// Attention cependant d'utiliser des indexes différenciés car traiterLonLat() et traiterEspece()
|
|
|
343 |
// les utilisent
|
|
|
344 |
foreach($cols as $col) {
|
|
|
345 |
if(!defined("C_" . strtoupper($col['abbrev'])))
|
|
|
346 |
define("C_" . strtoupper($col['abbrev']), "C_" . strtoupper($col['abbrev']));
|
|
|
347 |
}
|
1636 |
raphael |
348 |
|
1640 |
raphael |
349 |
// prépare le filtre de PHPExcel qui évitera le traitement de toutes les colonnes superflues
|
|
|
350 |
|
|
|
351 |
// eg: diff ( Array( H => Commune, I => rien ) , Array( H => 1, K => 1 )
|
|
|
352 |
// ==> Array( I => rien )
|
1636 |
raphael |
353 |
$colonnesID_non_reconnues = array_diff_key($entete, $colonnes_reconnues);
|
|
|
354 |
|
1656 |
raphael |
355 |
// des colonnes de FormateurGroupeColonne::nomEnsembleVersListeColonnes()
|
1640 |
raphael |
356 |
// ne retient que celles marquées "importables"
|
1675 |
raphael |
357 |
$colonnes_automatiques = array_filter($cols, '__anonyme_1');
|
1640 |
raphael |
358 |
|
1636 |
raphael |
359 |
// ne conserve que le nom long pour matcher avec la ligne XLS d'entête
|
1675 |
raphael |
360 |
array_walk($colonnes_automatiques, '__anonyme_2');
|
1640 |
raphael |
361 |
|
|
|
362 |
// intersect ( Array ( N => Milieu, S => Ordre ), Array ( ordre => Ordre, phenologie => Phénologie ) )
|
|
|
363 |
// ==> Array ( S => Ordre, AA => Phénologie )
|
1636 |
raphael |
364 |
$colonnesID_a_exclure = array_intersect($entete, $colonnes_automatiques);
|
|
|
365 |
|
1640 |
raphael |
366 |
// TODO: pourquoi ne pas comparer avec les abbrevs aussi ?
|
|
|
367 |
// merge ( Array( I => rien ) , Array ( S => Ordre, AA => Phénologie ) )
|
|
|
368 |
// ==> Array ( I => rien, AA => Phénologie )
|
1636 |
raphael |
369 |
return array_merge($colonnesID_non_reconnues, $colonnesID_a_exclure);
|
|
|
370 |
}
|
|
|
371 |
|
1640 |
raphael |
372 |
/*
|
|
|
373 |
* charge un groupe de lignes
|
|
|
374 |
*/
|
1642 |
raphael |
375 |
static function chargerLignes($cel, $lignes, $colonnes_statiques, &$dernier_ordre) {
|
1640 |
raphael |
376 |
$enregistrement = NULL;
|
|
|
377 |
$enregistrements = Array();
|
1642 |
raphael |
378 |
$toutes_images = Array();
|
1678 |
raphael |
379 |
$tous_mots_cle = Array();
|
1640 |
raphael |
380 |
|
|
|
381 |
foreach($lignes as $ligne) {
|
1642 |
raphael |
382 |
//$ligne = array_filter($ligne, function($cell) { return !is_null($cell); });
|
|
|
383 |
//if(!$ligne) continue;
|
|
|
384 |
// on a besoin des NULL pour éviter des notice d'index indéfini
|
1675 |
raphael |
385 |
if(! array_filter($ligne, '__anonyme_3')) continue;
|
1640 |
raphael |
386 |
|
1642 |
raphael |
387 |
if( ($enregistrement = self::chargerLigne($ligne, $dernier_ordre, $cel)) ) {
|
1648 |
raphael |
388 |
// $enregistrements[] = array_merge($colonnes_statiques, $enregistrement);
|
|
|
389 |
$enregistrements[] = $enregistrement;
|
1677 |
raphael |
390 |
$pos = count($enregistrements) - 1;
|
|
|
391 |
$last = &$enregistrements[$pos];
|
1640 |
raphael |
392 |
|
|
|
393 |
if(isset($enregistrement['_images'])) {
|
|
|
394 |
// ne dépend pas de cel_obs, et seront insérées *après* les enregistrements
|
|
|
395 |
// mais nous ne voulons pas nous priver de faire des INSERT multiples pour autant
|
1642 |
raphael |
396 |
$toutes_images[] = Array("images" => $last['_images'],
|
|
|
397 |
"obs_pos" => $pos);
|
1677 |
raphael |
398 |
// ce champ n'a pas à faire partie de l'insertion dans cel_obs,
|
1640 |
raphael |
399 |
// mais est utile pour cel_obs_images
|
1642 |
raphael |
400 |
unset($last['_images']);
|
1640 |
raphael |
401 |
}
|
|
|
402 |
|
1677 |
raphael |
403 |
if(isset($enregistrement['_mots_cle'])) {
|
|
|
404 |
// ne dépend pas de cel_obs, et seront insérés *après* les enregistrements
|
|
|
405 |
// mais nous ne voulons pas nous priver de faire des INSERT multiples pour autant
|
|
|
406 |
$tous_mots_cle[] = Array("mots_cle" => $last['_mots_cle'],
|
|
|
407 |
"obs_pos" => $pos);
|
|
|
408 |
// la version inlinée des mots est enregistrées dans cel_obs
|
|
|
409 |
// mais cel_mots_cles_obs fait foi.
|
|
|
410 |
// XXX: postponer l'ajout de ces informations dans cel_obs *après* l'insertion effective
|
|
|
411 |
// des records dans cel_mots_cles_obs ?
|
|
|
412 |
unset($last['_mots_cle']);
|
|
|
413 |
}
|
|
|
414 |
|
1640 |
raphael |
415 |
$dernier_ordre++;
|
|
|
416 |
}
|
1636 |
raphael |
417 |
}
|
1640 |
raphael |
418 |
|
1642 |
raphael |
419 |
// XXX future: return Array($enregistrements_a_inserer, $enregistrements_a_MAJ, $toutes_images);
|
1677 |
raphael |
420 |
return Array($enregistrements, $toutes_images, $tous_mots_cle);
|
1642 |
raphael |
421 |
}
|
1640 |
raphael |
422 |
|
1642 |
raphael |
423 |
|
1648 |
raphael |
424 |
static function trierColonnes(&$enregistrements) {
|
|
|
425 |
foreach($enregistrements as &$enregistrement) {
|
1642 |
raphael |
426 |
$enregistrement = self::sortArrayByArray($enregistrement, self::$ordre_BDD);
|
1648 |
raphael |
427 |
//array_walk($enregistrement, function(&$item, $k) { $item = is_null($item) ? "NULL" : $item; });
|
|
|
428 |
//$req .= implode(', ', $enregistrement) . "\n";
|
1642 |
raphael |
429 |
}
|
|
|
430 |
}
|
|
|
431 |
|
|
|
432 |
|
1765 |
raphael |
433 |
static function stockerMotsCle($enregistrements, $tous_mots_cle, $lastid) {
|
1678 |
raphael |
434 |
$c = 0;
|
|
|
435 |
// debug: var_dump($tous_mots_cle);die;
|
|
|
436 |
foreach($tous_mots_cle as $v) $c += count($v['mots_cle']['to_insert']);
|
|
|
437 |
return $c;
|
1677 |
raphael |
438 |
}
|
|
|
439 |
|
1765 |
raphael |
440 |
static function stockerImages($enregistrements, $toutes_images, $lastid) {
|
1650 |
raphael |
441 |
$images_insert = 'INSERT INTO cel_obs_images (id_image, id_observation) VALUES %s ON DUPLICATE KEY UPDATE id_image = id_image';
|
1642 |
raphael |
442 |
$images_obs_assoc = Array();
|
|
|
443 |
|
|
|
444 |
foreach($toutes_images as $images_pour_obs) {
|
|
|
445 |
$obs = $enregistrements[$images_pour_obs["obs_pos"]];
|
1640 |
raphael |
446 |
$id_obs = $lastid // dernier autoinc inséré
|
1650 |
raphael |
447 |
- count($enregistrements) + 1 // correspondrait au premier autoinc
|
|
|
448 |
+ $images_pour_obs["obs_pos"]; // ordre d'insertion = ordre dans le tableau $enregistrements (commence à 0)
|
1642 |
raphael |
449 |
foreach($images_pour_obs['images'] as $image) {
|
|
|
450 |
$images_obs_assoc[] = sprintf('(%d,%d)',
|
|
|
451 |
$image['id_image'], // intval() useless
|
|
|
452 |
$id_obs); // intval() useless
|
|
|
453 |
}
|
1640 |
raphael |
454 |
}
|
1642 |
raphael |
455 |
|
|
|
456 |
if($images_obs_assoc) {
|
|
|
457 |
$requete = sprintf($images_insert, implode(', ', $images_obs_assoc));
|
1650 |
raphael |
458 |
// debug echo "$requete\n";
|
1765 |
raphael |
459 |
Cel::db()->requeter($requete);
|
1642 |
raphael |
460 |
}
|
1650 |
raphael |
461 |
|
|
|
462 |
return count($images_obs_assoc);
|
1636 |
raphael |
463 |
}
|
|
|
464 |
|
1649 |
raphael |
465 |
/*
|
|
|
466 |
Aucune des valeurs présentes dans $enregistrement n'est quotée
|
|
|
467 |
cad aucune des valeurs retournée par traiter{Espece|Localisation}()
|
|
|
468 |
car ce tableau est passé à un PDO::preparedStatement() qui applique
|
|
|
469 |
proprement les règle d'échappement.
|
|
|
470 |
*/
|
1642 |
raphael |
471 |
static function chargerLigne($ligne, $dernier_ordre, $cel) {
|
1770 |
raphael |
472 |
// évite des notices d'index lors des trigger_error()
|
|
|
473 |
$ref_ligne = !empty($ligne[C_NOM_SEL]) ? trim($ligne[C_NOM_SEL]) : '';
|
|
|
474 |
|
1636 |
raphael |
475 |
// en premier car le résultat est utile pour
|
1751 |
raphael |
476 |
// * traiter espèce (traiterEspece())
|
|
|
477 |
// * traiter longitude et latitude (traiterLonLat())
|
1770 |
raphael |
478 |
$referentiel = self::identReferentiel(trim(strtolower(@$ligne[C_NOM_REFERENTIEL])), $ligne, $ref_ligne);
|
1636 |
raphael |
479 |
|
1640 |
raphael |
480 |
// $espece est rempli de plusieurs informations
|
1642 |
raphael |
481 |
$espece = Array(C_NOM_SEL => NULL, C_NOM_SEL_NN => NULL, C_NOM_RET => NULL,
|
|
|
482 |
C_NOM_RET_NN => NULL, C_NT => NULL, C_FAMILLE => NULL);
|
1751 |
raphael |
483 |
self::traiterEspece($ligne, $espece, $referentiel, $cel);
|
1636 |
raphael |
484 |
|
1852 |
raphael |
485 |
if(!$espece[C_NOM_SEL]) $referentiel = Cel::$fallback_referentiel;
|
|
|
486 |
if($espece[C_NOM_SEL] && !$espece[C_NOM_SEL_NN]) $referentiel = Cel::$fallback_referentiel;
|
|
|
487 |
|
1642 |
raphael |
488 |
// $localisation est rempli à partir de plusieurs champs: C_ZONE_GEO et C_CE_ZONE_GEO
|
|
|
489 |
$localisation = Array(C_ZONE_GEO => NULL, C_CE_ZONE_GEO => NULL);
|
1765 |
raphael |
490 |
self::traiterLocalisation($ligne, $localisation);
|
1636 |
raphael |
491 |
|
1649 |
raphael |
492 |
// $transmission est utilisé pour date_transmission
|
1675 |
raphael |
493 |
// XXX: @ contre "Undefined index"
|
|
|
494 |
@$transmission = in_array(strtolower(trim($ligne[C_TRANSMISSION])), array(1, 'oui')) ? 1 : 0;
|
1649 |
raphael |
495 |
|
|
|
496 |
|
1642 |
raphael |
497 |
// Dans ce tableau, seules devraient apparaître les données variable pour chaque ligne.
|
|
|
498 |
// Dans ce tableau, l'ordre des clefs n'importe pas (cf: self::sortArrayByArray())
|
|
|
499 |
$enregistrement = Array(
|
|
|
500 |
"ordre" => $dernier_ordre,
|
1640 |
raphael |
501 |
|
1642 |
raphael |
502 |
"nom_sel" => $espece[C_NOM_SEL],
|
|
|
503 |
"nom_sel_nn" => $espece[C_NOM_SEL_NN],
|
|
|
504 |
"nom_ret" => $espece[C_NOM_RET],
|
|
|
505 |
"nom_ret_nn" => $espece[C_NOM_RET_NN],
|
|
|
506 |
"nt" => $espece[C_NT],
|
|
|
507 |
"famille" => $espece[C_FAMILLE],
|
1640 |
raphael |
508 |
|
1649 |
raphael |
509 |
"nom_referentiel" => $referentiel,
|
1640 |
raphael |
510 |
|
1642 |
raphael |
511 |
"zone_geo" => $localisation[C_ZONE_GEO],
|
|
|
512 |
"ce_zone_geo" => $localisation[C_CE_ZONE_GEO],
|
1640 |
raphael |
513 |
|
1642 |
raphael |
514 |
// $ligne: uniquement pour les infos en cas de gestion d'erreurs (date incompréhensible)
|
1770 |
raphael |
515 |
"date_observation" => isset($ligne[C_DATE_OBSERVATION]) ? self::traiterDateObs($ligne[C_DATE_OBSERVATION], $ref_ligne) : NULL,
|
1640 |
raphael |
516 |
|
1747 |
raphael |
517 |
"lieudit" => isset($ligne[C_LIEUDIT]) ? trim($ligne[C_LIEUDIT]) : NULL,
|
|
|
518 |
"station" => isset($ligne[C_STATION]) ? trim($ligne[C_STATION]) : NULL,
|
|
|
519 |
"milieu" => isset($ligne[C_MILIEU]) ? trim($ligne[C_MILIEU]) : NULL,
|
1642 |
raphael |
520 |
|
1649 |
raphael |
521 |
"mots_cles_texte" => NULL, // TODO: foreign-key
|
1675 |
raphael |
522 |
// XXX: @ contre "Undefined index"
|
1747 |
raphael |
523 |
"commentaire" => isset($ligne[C_COMMENTAIRE]) ? trim($ligne[C_COMMENTAIRE]) : NULL,
|
1642 |
raphael |
524 |
|
1649 |
raphael |
525 |
"transmission" => $transmission,
|
|
|
526 |
"date_transmission" => $transmission ? date("Y-m-d H:i:s") : NULL, // pas de fonction SQL dans un PDO statement, <=> now()
|
1642 |
raphael |
527 |
|
|
|
528 |
// $ligne: uniquement pour les infos en cas de gestion d'erreurs (lon/lat incompréhensible)
|
1770 |
raphael |
529 |
"latitude" => isset($ligne[C_LATITUDE]) ? self::traiterLonLat(NULL, $ligne[C_LATITUDE], $referentiel, $ref_ligne) : NULL,
|
|
|
530 |
"longitude" => isset($ligne[C_LONGITUDE]) ? self::traiterLonLat($ligne[C_LONGITUDE], NULL, $referentiel, $ref_ligne) : NULL,
|
1747 |
raphael |
531 |
"altitude" => isset($ligne[C_ALTITUDE]) ? intval($ligne[C_ALTITUDE]) : NULL, // TODO: guess alt from lon/lat
|
1648 |
raphael |
532 |
|
|
|
533 |
// @ car potentiellement optionnelles ou toutes vides => pas d'index dans PHPExcel (tableau optimisé)
|
|
|
534 |
"abondance" => @$ligne[C_ABONDANCE],
|
|
|
535 |
"certitude" => @$ligne[C_CERTITUDE],
|
|
|
536 |
"phenologie" => @$ligne[C_PHENOLOGIE],
|
|
|
537 |
|
1649 |
raphael |
538 |
"code_insee_calcule" => substr($localisation[C_CE_ZONE_GEO], -5) // varchar(5)
|
1642 |
raphael |
539 |
);
|
|
|
540 |
|
|
|
541 |
// passage de $enregistrement par référence, ainsi ['_images'] n'est défini
|
|
|
542 |
// que si des résultats sont trouvés
|
|
|
543 |
// "@" car PHPExcel supprime les colonnes null sur toute la feuille (ou tout le chunk)
|
1765 |
raphael |
544 |
if(@$ligne[C_IMAGES]) self::traiterImage($ligne[C_IMAGES], $cel->id_utilisateur, $enregistrement);
|
1642 |
raphael |
545 |
|
1765 |
raphael |
546 |
if(@$ligne[C_MOTS_CLES_TEXTE]) self::traiterMotsCle($ligne[C_MOTS_CLES_TEXTE], $cel->id_utilisateur, $enregistrement);
|
1677 |
raphael |
547 |
|
1642 |
raphael |
548 |
return $enregistrement;
|
1636 |
raphael |
549 |
}
|
|
|
550 |
|
1765 |
raphael |
551 |
static function traiterImage($str, $id_utilisateur, &$enregistrement) {
|
1642 |
raphael |
552 |
$liste_images = array_filter(explode("/", $str));
|
1675 |
raphael |
553 |
|
1765 |
raphael |
554 |
//array_walk($liste_images, '__anonyme_4');
|
|
|
555 |
array_walk($liste_images, array(__CLASS__, '__anonyme_4'));
|
1642 |
raphael |
556 |
$requete = sprintf(
|
1756 |
raphael |
557 |
"SELECT id_image, nom_original FROM cel_images WHERE ce_utilisateur = %d AND nom_original IN (%s)",
|
1765 |
raphael |
558 |
$id_utilisateur,
|
1756 |
raphael |
559 |
implode(',', $liste_images));
|
1640 |
raphael |
560 |
|
1765 |
raphael |
561 |
$resultat = Cel::db()->requeter($requete);
|
1640 |
raphael |
562 |
|
1642 |
raphael |
563 |
if($resultat) $enregistrement['_images'] = $resultat;
|
|
|
564 |
}
|
|
|
565 |
|
1765 |
raphael |
566 |
static function traiterMotsCle($str, $id_utilisateur, &$enregistrement) {
|
1678 |
raphael |
567 |
$liste_mots_cle = $liste_mots_cle_recherche = array_map("trim", array_unique(array_filter(explode(",", $str))));
|
1765 |
raphael |
568 |
array_walk($liste_mots_cle_recherche, array(__CLASS__, '__anonyme_4'));
|
1678 |
raphael |
569 |
|
1677 |
raphael |
570 |
// TODO!!!! remplace > (pour les tests uniquement) par un = et supprimer le group by mot_cle
|
|
|
571 |
$requete = sprintf("SELECT id_mot_cle_obs, mot_cle FROM cel_mots_cles_obs WHERE id_utilisateur > %d ".
|
1678 |
raphael |
572 |
"AND mot_cle IN (%s) ".
|
1677 |
raphael |
573 |
"GROUP BY mot_cle",
|
1765 |
raphael |
574 |
$id_utilisateur,
|
1678 |
raphael |
575 |
implode(',', $liste_mots_cle_recherche));
|
1642 |
raphael |
576 |
|
1765 |
raphael |
577 |
$resultat_sql = Cel::db()->requeter($requete);
|
1677 |
raphael |
578 |
if(!$resultat_sql) return;
|
|
|
579 |
|
|
|
580 |
$resultat = array();
|
|
|
581 |
foreach($resultat_sql as $v) $resultat[$v['id_mot_cle_obs']] = $v['mot_cle'];
|
|
|
582 |
|
1678 |
raphael |
583 |
$enregistrement['mots_cles_texte'] = implode(',', $liste_mots_cle);
|
|
|
584 |
$enregistrement['_mots_cle'] = array("existing" => $resultat,
|
|
|
585 |
"to_insert" => array_diff($liste_mots_cle, $resultat));
|
1677 |
raphael |
586 |
}
|
|
|
587 |
|
|
|
588 |
|
1640 |
raphael |
589 |
/* FONCTIONS de TRANSFORMATION de VALEUR DE CELLULE */
|
|
|
590 |
|
|
|
591 |
// TODO: PHP 5.3, utiliser date_parse_from_format()
|
|
|
592 |
// TODO: parser les heures (cf product-owner)
|
|
|
593 |
// TODO: passer par le timestamp pour s'assurer de la validité
|
1770 |
raphael |
594 |
static function traiterDateObs($date, $ref_ligne) {
|
1640 |
raphael |
595 |
// TODO: see https://github.com/PHPOffice/PHPExcel/issues/208
|
1818 |
raphael |
596 |
// TODO: PHPExcel_Shared_Date::ExcelToPHP()
|
1640 |
raphael |
597 |
if(is_double($date)) {
|
|
|
598 |
if($date > 0)
|
|
|
599 |
return PHPExcel_Style_NumberFormat::toFormattedString($date, PHPExcel_Style_NumberFormat::FORMAT_DATE_YYYYMMDD2) . " 00:00:00";
|
1770 |
raphael |
600 |
trigger_error("ligne \"{$ref_ligne}\": " .
|
1642 |
raphael |
601 |
"Attention: date antérieure à 1970 et format de cellule \"DATE\" utilisés ensemble",
|
|
|
602 |
E_USER_NOTICE);
|
1770 |
raphael |
603 |
|
1642 |
raphael |
604 |
// throw new Exception("erreur: date antérieure à 1970 et format de cellule \"DATE\" utilisés ensemble");
|
1640 |
raphael |
605 |
|
|
|
606 |
// attention, UNIX timestamp, car Excel les décompte depuis 1900
|
|
|
607 |
// cf http://fczaja.blogspot.fr/2011/06/convert-excel-date-into-timestamp.html
|
|
|
608 |
// $timestamp = ($date - MIN_DATES_DIFF) * 60 * 60 * 24 - time(); // NON
|
|
|
609 |
|
|
|
610 |
// $timestamp = PHPExcel_Calculation::getInstance()->calculateFormula("=" . $date . "-DATE(1970,1,1)*60*60*24"); // NON
|
|
|
611 |
|
|
|
612 |
// echo strftime("%Y/%m/%d 00:00:00", $timestamp); // NON
|
|
|
613 |
}
|
|
|
614 |
else {
|
1698 |
raphael |
615 |
// attend l'un des formats de
|
|
|
616 |
// http://www.php.net/manual/fr/datetime.formats.date.php
|
1760 |
raphael |
617 |
// le plus simple: YYYY/MM/DD (utilisé à l'export), mais DD-MM-YYYY est aussi supporté
|
|
|
618 |
$matches = NULL;
|
|
|
619 |
// et on essaie d'être sympa et supporter aussi DD/MM/YYYY
|
|
|
620 |
if(preg_match(';^([0-3]?\d)/([01]\d)/([12]\d\d\d)$;', $date, $matches)) {
|
|
|
621 |
$date = $matches[3] . '/' . $matches[2] . '/' . $matches[1];
|
|
|
622 |
}
|
1640 |
raphael |
623 |
$timestamp = strtotime($date);
|
1779 |
raphael |
624 |
if(! $timestamp || $timestamp > time() + 3600 * 24 * 1) { // une journée d'avance maxi autorisée (décallage horaire ?)
|
1770 |
raphael |
625 |
if($date) trigger_error("ligne \"{$ref_ligne}\": Attention: date erronée ($date)", E_USER_NOTICE);
|
1642 |
raphael |
626 |
return NULL;
|
|
|
627 |
}
|
1698 |
raphael |
628 |
return strftime("%Y-%m-%d 00:00:00", $timestamp);
|
1640 |
raphael |
629 |
}
|
1636 |
raphael |
630 |
}
|
|
|
631 |
|
1770 |
raphael |
632 |
static function identReferentiel($referentiel, $ligne, $ref_ligne) {
|
1640 |
raphael |
633 |
// SELECT DISTINCT nom_referentiel, COUNT(id_observation) AS count FROM cel_obs GROUP BY nom_referentiel ORDER BY count DESC;
|
1814 |
raphael |
634 |
if(strpos($referentiel, 'bdtfx') !== FALSE) return 'bdtfx'; //:v1.01';
|
|
|
635 |
if(strpos($referentiel, 'bdtxa') !== FALSE) return 'bdtxa'; //:v1.00';
|
|
|
636 |
//if(strpos($referentiel, 'bdnff') !== FALSE) return 'bdnff'; //:4.02';
|
|
|
637 |
if(strpos($referentiel, 'bdnff') !== FALSE) return 'bdtfx';
|
|
|
638 |
if(strpos($referentiel, 'isfan') !== FALSE) return 'isfan'; //:v1.00';
|
1751 |
raphael |
639 |
if(strpos($referentiel, 'autre') !== FALSE) return 'autre';
|
1642 |
raphael |
640 |
|
1770 |
raphael |
641 |
if($referentiel && isset($ligne[C_NOM_SEL]) && $ligne[C_NOM_SEL]) {
|
1869 |
raphael |
642 |
trigger_error("ligne \"{$ref_ligne}\": Attention: référentiel \"{$referentiel}\" inconnu", E_USER_NOTICE);
|
1760 |
raphael |
643 |
return 'autre';
|
1642 |
raphael |
644 |
}
|
1770 |
raphael |
645 |
|
|
|
646 |
// pas de référentiel ou pas de NOM_SEL: NULL
|
1640 |
raphael |
647 |
return NULL;
|
|
|
648 |
/* TODO: cf story,
|
1642 |
raphael |
649 |
En cas de NULL faire une seconde passe de détection à partir du nom saisi
|
|
|
650 |
+ accepter les n° de version */
|
1636 |
raphael |
651 |
}
|
|
|
652 |
|
1814 |
raphael |
653 |
static function traiterLonLat($lon = NULL, $lat = NULL, $referentiel = 'bdtfx', $ref_ligne) {
|
1642 |
raphael |
654 |
// en CSV ces valeurs sont des string, avec séparateur en français (","; cf défauts dans ExportXLS)
|
|
|
655 |
if($lon && is_string($lon)) $lon = str_replace(',', '.', $lon);
|
|
|
656 |
if($lat && is_string($lat)) $lat = str_replace(',', '.', $lat);
|
1640 |
raphael |
657 |
|
1642 |
raphael |
658 |
// sprintf applique une précision à 5 décimale (comme le ferait MySQL)
|
|
|
659 |
// tout en uniformisant le format de séparateur des décimales (le ".")
|
|
|
660 |
if($lon && is_numeric($lon) && $lon >= -180 && $lon <= 180) return sprintf('%.5F', $lon);
|
|
|
661 |
if($lat && is_numeric($lat) && $lat >= -90 && $lat <= 90) return sprintf('%.5F', $lat);
|
|
|
662 |
|
|
|
663 |
if($lon || $lat) {
|
1770 |
raphael |
664 |
trigger_error("ligne \"{$ref_ligne}\": " .
|
1642 |
raphael |
665 |
"Attention: longitude ou latitude erronée",
|
|
|
666 |
E_USER_NOTICE);
|
|
|
667 |
}
|
|
|
668 |
return NULL;
|
|
|
669 |
|
|
|
670 |
/* limite france métropole si bdtfx ? ou bdtxa ? ...
|
|
|
671 |
NON!
|
|
|
672 |
Un taxon d'un référentiel donné peut être théoriquement observé n'importe où sur le globe.
|
|
|
673 |
Il n'y a pas lieu d'effectuer des restriction ici.
|
|
|
674 |
Cependant des erreurs fréquentes (0,0 ou lon/lat inversées) peuvent être détectés ici.
|
|
|
675 |
TODO */
|
1640 |
raphael |
676 |
$bbox = self::getReferentielBBox($referentiel);
|
|
|
677 |
if(!$bbox) return NULL;
|
|
|
678 |
|
|
|
679 |
if($lon) {
|
|
|
680 |
if($lon < $bbox['EST'] && $lon > $bbox['OUEST']) return is_numeric($lon) ? $lon : NULL;
|
|
|
681 |
else return NULL;
|
|
|
682 |
}
|
|
|
683 |
if($lat) {
|
|
|
684 |
if($lat < $bbox['NORD'] && $lat > $bbox['SUD']) return is_numeric($lat) ? $lat : NULL;
|
|
|
685 |
return NULL;
|
|
|
686 |
}
|
1636 |
raphael |
687 |
}
|
|
|
688 |
|
1698 |
raphael |
689 |
/*
|
|
|
690 |
TODO: s'affranchir du webservice pour la détermination du nom scientifique en s'appuyant sur cel_references,
|
|
|
691 |
pour des questions de performances
|
|
|
692 |
*/
|
1784 |
raphael |
693 |
static function traiterEspece($ligne, Array &$espece, &$referentiel, $cel) {
|
1852 |
raphael |
694 |
if(empty($ligne[C_NOM_SEL])) {
|
|
|
695 |
// TODO: nous ne déclarons pas "Numéro nomenclatural" comme colonne importable
|
|
|
696 |
// Nous ne pouvons donc pas tenter d'être sympa sur la détermination par num_nom
|
|
|
697 |
/* if(!empty($ligne[C_NOM_SEL_NN]) && $referentiel != Cel::$fallback_referentiel)
|
|
|
698 |
$ligne[C_NOM_SEL] = $referentiel . ':nn:' . $ligne[C_NOM_SEL_NN];
|
|
|
699 |
else */
|
|
|
700 |
return;
|
|
|
701 |
}
|
1642 |
raphael |
702 |
|
1651 |
raphael |
703 |
// nom_sel reste toujours celui de l'utilisateur
|
|
|
704 |
$espece[C_NOM_SEL] = trim($ligne[C_NOM_SEL]);
|
|
|
705 |
|
1778 |
raphael |
706 |
// XXX/attention, nous ne devrions pas accepter un référentiel absent !
|
|
|
707 |
if(!$referentiel) $referentiel = 'bdtfx';
|
1751 |
raphael |
708 |
$taxon_info_webservice = new RechercheInfosTaxonBeta($cel->config, $referentiel);
|
1640 |
raphael |
709 |
$ascii = iconv('UTF-8', 'ASCII//TRANSLIT', $ligne[C_NOM_SEL]);
|
1651 |
raphael |
710 |
|
|
|
711 |
// TODO: si empty(C_NOM_SEL) et !empty(C_NOM_SEL_NN) : recherche info à partir de C_NOM_SEL_NN
|
1698 |
raphael |
712 |
// echo "rechercherInformationsComplementairesSurNom()\n";
|
1688 |
raphael |
713 |
/*
|
|
|
714 |
SELECT num_nom, nom_sci, num_nom_retenu ,auteur, annee, biblio_origine, nom_sci,auteur FROM bdtfx_v1_01 WHERE (nom_sci LIKE 'Heliotropium europaeum') ORDER BY nom_sci ASC LIMIT 0, 1
|
|
|
715 |
#
|
|
|
716 |
SELECT num_nom, nom_sci, num_nom_retenu ,auteur, annee, biblio_origine, nom_sci,auteur FROM bdtfx_v1_01 WHERE (nom_sci LIKE 'eliotropium euro') ORDER BY nom_sci ASC LIMIT 0, 1
|
|
|
717 |
SELECT num_nom, nom_sci, num_nom_retenu ,auteur, annee, biblio_origine, nom_sci,auteur FROM bdtfx_v1_01 WHERE (nom_sci LIKE 'eliotropium') ORDER BY nom_sci ASC LIMIT 0, 1
|
|
|
718 |
SELECT num_nom, nom_sci, num_nom_retenu ,auteur, annee, biblio_origine, nom_sci,auteur FROM bdtfx_v1_01 WHERE (nom_sci LIKE 'eliotropium% euro%') ORDER BY nom_sci ASC LIMIT 0, 1
|
|
|
719 |
#
|
1640 |
raphael |
720 |
|
1688 |
raphael |
721 |
SELECT nom_sci, num_nom_retenu, nom_sci_html, auteur, annee, biblio_origine FROM bdtfx_v1_01 WHERE num_nom = 31468
|
|
|
722 |
*/
|
1781 |
raphael |
723 |
// $determ = $taxon_info_webservice->rechercherInformationsComplementairesSurNom($ligne[C_NOM_SEL]);
|
1784 |
raphael |
724 |
// permet une reconnaissance de bdtfx:nn:XXXX
|
1781 |
raphael |
725 |
$determ = $taxon_info_webservice->rechercherInfosSurTexteCodeOuNumTax(trim($ligne[C_NOM_SEL]));
|
1688 |
raphael |
726 |
|
1747 |
raphael |
727 |
// note: rechercherInfosSurTexteCodeOuNumTax peut ne retourner qu'une seule clef "nom_sel"
|
1781 |
raphael |
728 |
if (! $determ) {
|
1747 |
raphael |
729 |
// on supprime les noms retenus et renvoi tel quel
|
|
|
730 |
// on réutilise les define pour les noms d'indexes, tant qu'à faire
|
1651 |
raphael |
731 |
// XXX; tout à NULL sauf C_NOM_SEL ci-dessus ?
|
1778 |
raphael |
732 |
$espece[C_NOM_SEL_NN] = @$ligne[C_NOM_SEL_NN];
|
|
|
733 |
$espece[C_NOM_RET] = @$ligne[C_NOM_RET];
|
|
|
734 |
$espece[C_NOM_RET_NN] = @$ligne[C_NOM_RET_NN];
|
|
|
735 |
$espece[C_NT] = @$ligne[C_NT];
|
|
|
736 |
$espece[C_FAMILLE] = @$ligne[C_FAMILLE];
|
1640 |
raphael |
737 |
|
|
|
738 |
return;
|
|
|
739 |
}
|
|
|
740 |
|
1781 |
raphael |
741 |
// succès de la détection, mais résultat partiel
|
|
|
742 |
if(!isset($determ->id))
|
|
|
743 |
$determ = $taxon_info_webservice->effectuerRequeteInfosComplementairesSurNumNom($determ->{"nom_retenu.id"});
|
|
|
744 |
|
|
|
745 |
// ne devrait jamais arriver !
|
|
|
746 |
if(!$determ) die("erreur critique: " . __FILE__ . ':' . __LINE__);
|
|
|
747 |
|
1784 |
raphael |
748 |
// un schéma <ref>:(nt|nn):<num> (ie: bdtfx:nt:8503) a été passé
|
|
|
749 |
// dans ce cas on met à jour le référentiel avec celui passé dans le champ espèce
|
|
|
750 |
if(isset($determ->ref)) {
|
|
|
751 |
$referentiel = $determ->ref;
|
|
|
752 |
}
|
|
|
753 |
|
|
|
754 |
// succès de la détection
|
|
|
755 |
// nom_sel est remplacé, mais seulement si un motif spécial à été utilisé (bdtfx:nn:4567)
|
|
|
756 |
if($taxon_info_webservice->is_notation_spe) {
|
|
|
757 |
$espece[C_NOM_SEL] = $determ->nom_sci;
|
|
|
758 |
}
|
|
|
759 |
|
|
|
760 |
// écrasement des numéros (nomenclatural, taxonomique) saisis...
|
1781 |
raphael |
761 |
$espece[C_NOM_SEL_NN] = $determ->id;
|
|
|
762 |
$espece[C_NOM_RET] = RechercheInfosTaxonBeta::supprimerBiblio($determ->nom_retenu_complet);
|
|
|
763 |
$espece[C_NOM_RET_NN] = $determ->{"nom_retenu.id"};
|
|
|
764 |
$espece[C_NT] = $determ->num_taxonomique;
|
|
|
765 |
$espece[C_FAMILLE] = $determ->famille;
|
|
|
766 |
return;
|
1651 |
raphael |
767 |
// et des info complémentaires
|
1698 |
raphael |
768 |
|
1688 |
raphael |
769 |
/*
|
|
|
770 |
// GET /service:eflore:0.1/bdtfx/noms/31468?retour.champs=nom_sci,auteur,id,nom_retenu_complet,nom_retenu.id,num_taxonomique,famille
|
|
|
771 |
/home/raphael/eflore/projets/services/modules/0.1/bdtfx/Noms.php:280
|
|
|
772 |
SELECT *, nom_sci FROM bdtfx_v1_01 WHERE num_nom = '31468'
|
|
|
773 |
SELECT nom_sci, num_nom_retenu, nom_sci_html, auteur, annee, biblio_origine FROM bdtfx_v1_01 WHERE num_nom = 31468
|
|
|
774 |
SELECT nom_sci, num_nom_retenu, nom_sci_html, auteur, annee, biblio_origine FROM bdtfx_v1_01 WHERE num_nom = 86535
|
|
|
775 |
*/
|
1781 |
raphael |
776 |
|
|
|
777 |
|
1770 |
raphael |
778 |
//var_dump($complement, $espece);die;
|
1640 |
raphael |
779 |
}
|
|
|
780 |
|
1765 |
raphael |
781 |
static function detectFromNom($nom) {
|
|
|
782 |
$r = Cel::db()->requeter(sprintf("SELECT num_nom, num_tax_sup FROM bdtfx_v1_01 WHERE (nom_sci LIKE '%s') ".
|
1688 |
raphael |
783 |
"ORDER BY nom_sci ASC LIMIT 0, 1",
|
1765 |
raphael |
784 |
Cel::db()->proteger($nom)));
|
1688 |
raphael |
785 |
if($r) return $r;
|
1640 |
raphael |
786 |
|
1765 |
raphael |
787 |
Cel::db()->requeter(sprintf("SELECT num_nom, num_tax_sup FROM bdtfx_v1_01 WHERE (nom_sci LIKE '%s' OR nom LIKE '%s') ".
|
1688 |
raphael |
788 |
"ORDER BY nom_sci ASC LIMIT 0, 1",
|
1765 |
raphael |
789 |
Cel::db()->proteger($nom),
|
|
|
790 |
Cel::db()->proteger(str_replace(' ', '% ', $nom))));
|
1688 |
raphael |
791 |
return $r;
|
|
|
792 |
}
|
|
|
793 |
|
1697 |
raphael |
794 |
|
1797 |
raphael |
795 |
/*
|
|
|
796 |
* TODO: analyse rigoureuse:
|
|
|
797 |
* == Identifiant Commune
|
|
|
798 |
* - INSEE-C:\d{5}
|
|
|
799 |
* - \d{5}
|
|
|
800 |
* - \d{2}
|
|
|
801 |
* == Commune
|
|
|
802 |
* - \w+ (\d{2})
|
|
|
803 |
* - \w+ (\d{5})
|
|
|
804 |
* - \w+
|
|
|
805 |
*
|
|
|
806 |
*/
|
1765 |
raphael |
807 |
static function traiterLocalisation($ligne, Array &$localisation) {
|
1770 |
raphael |
808 |
if(empty($ligne[C_ZONE_GEO])) $ligne[C_ZONE_GEO] = NULL;
|
|
|
809 |
if(empty($ligne[C_CE_ZONE_GEO])) $ligne[C_CE_ZONE_GEO] = NULL;
|
|
|
810 |
|
1642 |
raphael |
811 |
$identifiant_commune = trim($ligne[C_ZONE_GEO]);
|
|
|
812 |
if(!$identifiant_commune) {
|
|
|
813 |
$departement = trim($ligne[C_CE_ZONE_GEO]);
|
1697 |
raphael |
814 |
if(strpos($departement, "INSEE-C:", 0) === 0) {
|
1797 |
raphael |
815 |
$localisation[C_CE_ZONE_GEO] = trim($ligne[C_CE_ZONE_GEO]);
|
|
|
816 |
$nom = Cel::db()->requeter(sprintf("SELECT nom FROM cel_zones_geo WHERE code = %s LIMIT 1",
|
|
|
817 |
self::quoteNonNull(substr($localisation[C_CE_ZONE_GEO], strlen("INSEE-C:")))));
|
|
|
818 |
if($nom) $localisation[C_ZONE_GEO] = $nom[0]['nom'];
|
|
|
819 |
return;
|
1697 |
raphael |
820 |
}
|
|
|
821 |
|
|
|
822 |
if(!is_numeric($departement)) {
|
1797 |
raphael |
823 |
$localisation[C_CE_ZONE_GEO] = $ligne[C_CE_ZONE_GEO];
|
|
|
824 |
return;
|
1697 |
raphael |
825 |
}
|
|
|
826 |
|
1818 |
raphael |
827 |
if( ($resultat_commune = Cel::db()->requeter(sprintf("SELECT DISTINCT nom, CONCAT('INSEE-C:', code) AS code FROM cel_zones_geo WHERE code = %s LIMIT 1",
|
|
|
828 |
self::quoteNonNull($departement)))) ) {
|
|
|
829 |
$localisation[C_ZONE_GEO] = $resultat_commune[0]['nom'];
|
|
|
830 |
$localisation[C_CE_ZONE_GEO] = $resultat_commune[0]['code'];
|
|
|
831 |
return;
|
|
|
832 |
}
|
|
|
833 |
;
|
|
|
834 |
// if(strlen($departement) == 4) $departement = "INSEE-C:0" . $departement;
|
|
|
835 |
// if(strlen($departement) == 5) $departement = "INSEE-C:" . $departement;
|
1697 |
raphael |
836 |
// if(strlen($departement) <= 9) return "INSEE-C:0" . $departement; // ? ... TODO
|
|
|
837 |
|
|
|
838 |
$departement = trim($departement); // TODO
|
|
|
839 |
|
1797 |
raphael |
840 |
$localisation[C_CE_ZONE_GEO] = $ligne[C_CE_ZONE_GEO];
|
1756 |
raphael |
841 |
return;
|
1697 |
raphael |
842 |
}
|
|
|
843 |
|
|
|
844 |
|
1818 |
raphael |
845 |
$select = "SELECT DISTINCT nom, code FROM cel_zones_geo";
|
1697 |
raphael |
846 |
|
1797 |
raphael |
847 |
if (preg_match('/(.+) \((\d{1,5})\)/', $identifiant_commune, $elements)) {
|
1697 |
raphael |
848 |
// commune + departement : montpellier (34)
|
|
|
849 |
$nom_commune=$elements[1];
|
|
|
850 |
$code_commune=$elements[2];
|
1797 |
raphael |
851 |
if(strlen($code_commune) <= 2) {
|
|
|
852 |
$requete = sprintf("%s WHERE nom = %s AND code LIKE %s",
|
|
|
853 |
$select, self::quoteNonNull($nom_commune),
|
|
|
854 |
self::quoteNonNull($code_commune.'%'));
|
|
|
855 |
}
|
|
|
856 |
else {
|
|
|
857 |
$requete = sprintf("%s WHERE nom = %s AND code = %d",
|
|
|
858 |
$select, self::quoteNonNull($nom_commune),
|
|
|
859 |
$code_commune);
|
|
|
860 |
}
|
1697 |
raphael |
861 |
}
|
|
|
862 |
elseif (preg_match('/^(\d+|(2[ab]\d+))$/i', $identifiant_commune, $elements)) {
|
|
|
863 |
// Code insee seul
|
|
|
864 |
$code_insee_commune=$elements[1];
|
1765 |
raphael |
865 |
$requete = sprintf("%s WHERE code = %s", $select, self::quoteNonNull($code_insee_commune));
|
1697 |
raphael |
866 |
}
|
|
|
867 |
else {
|
|
|
868 |
// Commune seule (le departement sera recupere dans la colonne departement si elle est presente)
|
|
|
869 |
// on prend le risque ici de retourner une mauvaise Commune
|
|
|
870 |
$nom_commune = str_replace(" ", "%", iconv('UTF-8', 'ASCII//TRANSLIT', $identifiant_commune));
|
1765 |
raphael |
871 |
$requete = sprintf("%s WHERE nom LIKE %s", $select, self::quoteNonNull($nom_commune.'%'));
|
1697 |
raphael |
872 |
}
|
|
|
873 |
|
1765 |
raphael |
874 |
$resultat_commune = Cel::db()->requeter($requete);
|
1697 |
raphael |
875 |
// TODO: levenstein sort ?
|
1797 |
raphael |
876 |
// TODO: count résultat !
|
1697 |
raphael |
877 |
|
|
|
878 |
// cas de la commune introuvable dans le référentiel
|
|
|
879 |
// réinitialisation aux valeurs du fichier XLS
|
|
|
880 |
if(! $resultat_commune) {
|
|
|
881 |
$localisation[C_ZONE_GEO] = trim($ligne[C_ZONE_GEO]);
|
|
|
882 |
$localisation[C_CE_ZONE_GEO] = trim($ligne[C_CE_ZONE_GEO]);
|
|
|
883 |
} else {
|
|
|
884 |
$localisation[C_ZONE_GEO] = $resultat_commune[0]['nom'];
|
1797 |
raphael |
885 |
$localisation[C_CE_ZONE_GEO] = "INSEE-C:" . $resultat_commune[0]['code'];
|
|
|
886 |
return;
|
1697 |
raphael |
887 |
}
|
|
|
888 |
|
|
|
889 |
$departement = &$localisation[C_CE_ZONE_GEO];
|
|
|
890 |
|
|
|
891 |
if(strpos($departement, "INSEE-C:", 0) === 0) {
|
|
|
892 |
$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
|
|
|
893 |
$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
|
|
|
894 |
}
|
|
|
895 |
|
|
|
896 |
|
|
|
897 |
if(!is_numeric($departement)) {
|
|
|
898 |
$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
|
|
|
899 |
$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
|
|
|
900 |
}
|
|
|
901 |
|
|
|
902 |
if(strlen($departement) == 4) $departement = "INSEE-C:0" . $departement;
|
|
|
903 |
if(strlen($departement) == 5) $departement = "INSEE-C:" . $departement;
|
|
|
904 |
// if(strlen($departement) <= 9) return "INSEE-C:0" . $departement; // ? ... TODO
|
|
|
905 |
|
|
|
906 |
$departement = trim($departement); // TODO
|
|
|
907 |
|
|
|
908 |
$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
|
|
|
909 |
$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
|
|
|
910 |
}
|
|
|
911 |
|
|
|
912 |
/*
|
1765 |
raphael |
913 |
static function traiterLocalisation($ligne, Array &$localisation) {
|
1697 |
raphael |
914 |
$identifiant_commune = trim($ligne[C_ZONE_GEO]);
|
|
|
915 |
if(!$identifiant_commune) {
|
|
|
916 |
$departement = trim($ligne[C_CE_ZONE_GEO]);
|
1642 |
raphael |
917 |
goto testdepartement;
|
|
|
918 |
}
|
|
|
919 |
|
|
|
920 |
|
|
|
921 |
$select = "SELECT DISTINCT nom, code FROM cel_zones_geo";
|
|
|
922 |
|
|
|
923 |
if (preg_match('/(.*) \((\d+)\)/', $identifiant_commune, $elements)) {
|
|
|
924 |
// commune + departement : montpellier (34)
|
|
|
925 |
$nom_commune=$elements[1];
|
|
|
926 |
$code_commune=$elements[2];
|
|
|
927 |
$requete = sprintf("%s WHERE nom = %s AND code LIKE %s",
|
1765 |
raphael |
928 |
$select, self::quoteNonNull($nom_commune), self::quoteNonNull($code_commune.'%'));
|
1642 |
raphael |
929 |
}
|
|
|
930 |
elseif (preg_match('/^(\d+|(2[ab]\d+))$/i', $identifiant_commune, $elements)) {
|
|
|
931 |
// Code insee seul
|
|
|
932 |
$code_insee_commune=$elements[1];
|
1765 |
raphael |
933 |
$requete = sprintf("%s WHERE code = %s", $select, self::quoteNonNull($code_insee_commune));
|
1642 |
raphael |
934 |
}
|
|
|
935 |
else {
|
|
|
936 |
// Commune seule (le departement sera recupere dans la colonne departement si elle est presente)
|
|
|
937 |
// on prend le risque ici de retourner une mauvaise Commune
|
|
|
938 |
$nom_commune = str_replace(" ", "%", iconv('UTF-8', 'ASCII//TRANSLIT', $identifiant_commune));
|
1765 |
raphael |
939 |
$requete = sprintf("%s WHERE nom LIKE %s", $select, self::quoteNonNull($nom_commune.'%'));
|
1642 |
raphael |
940 |
}
|
|
|
941 |
|
1765 |
raphael |
942 |
$resultat_commune = Cel::db()->requeter($requete);
|
1642 |
raphael |
943 |
// TODO: levenstein sort ?
|
|
|
944 |
|
|
|
945 |
// cas de la commune introuvable dans le référentiel
|
|
|
946 |
// réinitialisation aux valeurs du fichier XLS
|
|
|
947 |
if(! $resultat_commune) {
|
|
|
948 |
$localisation[C_ZONE_GEO] = trim($ligne[C_ZONE_GEO]);
|
|
|
949 |
$localisation[C_CE_ZONE_GEO] = trim($ligne[C_CE_ZONE_GEO]);
|
|
|
950 |
} else {
|
|
|
951 |
$localisation[C_ZONE_GEO] = $resultat_commune[0]['nom'];
|
|
|
952 |
$localisation[C_CE_ZONE_GEO] = $resultat_commune[0]['code'];
|
|
|
953 |
}
|
|
|
954 |
|
|
|
955 |
$departement = &$localisation[C_CE_ZONE_GEO];
|
|
|
956 |
|
|
|
957 |
testdepartement:
|
|
|
958 |
if(strpos($departement, "INSEE-C:", 0) === 0) goto protectloc;
|
|
|
959 |
|
|
|
960 |
if(!is_numeric($departement)) goto protectloc; // TODO ?
|
|
|
961 |
if(strlen($departement) == 4) $departement = "INSEE-C:0" . $departement;
|
|
|
962 |
if(strlen($departement) == 5) $departement = "INSEE-C:" . $departement;
|
1640 |
raphael |
963 |
// if(strlen($departement) <= 9) return "INSEE-C:0" . $departement; // ? ... TODO
|
1642 |
raphael |
964 |
|
|
|
965 |
$departement = trim($departement); // TODO
|
|
|
966 |
|
|
|
967 |
protectloc:
|
1649 |
raphael |
968 |
$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
|
|
|
969 |
$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
|
1640 |
raphael |
970 |
}
|
1697 |
raphael |
971 |
*/
|
1640 |
raphael |
972 |
|
|
|
973 |
|
|
|
974 |
/* HELPERS */
|
|
|
975 |
|
1636 |
raphael |
976 |
// http://stackoverflow.com/questions/348410/sort-an-array-based-on-another-array
|
1741 |
raphael |
977 |
// XXX; utilisé aussi (temporairement ?) par FormateurGroupeColonne.
|
1640 |
raphael |
978 |
static function sortArrayByArray($array, $orderArray) {
|
1636 |
raphael |
979 |
$ordered = array();
|
|
|
980 |
foreach($orderArray as $key) {
|
|
|
981 |
if(array_key_exists($key, $array)) {
|
|
|
982 |
$ordered[$key] = $array[$key];
|
|
|
983 |
unset($array[$key]);
|
|
|
984 |
}
|
|
|
985 |
}
|
|
|
986 |
return $ordered + $array;
|
|
|
987 |
}
|
1640 |
raphael |
988 |
|
|
|
989 |
// retourne une BBox [N,S,E,O) pour un référentiel donné
|
|
|
990 |
static function getReferentielBBox($referentiel) {
|
1814 |
raphael |
991 |
if($referentiel == 'bdtfx') return Array(
|
1640 |
raphael |
992 |
'NORD' => 51.2, // Dunkerque
|
|
|
993 |
'SUD' => 41.3, // Bonifacio
|
|
|
994 |
'EST' => 9.7, // Corse
|
|
|
995 |
'OUEST' => -5.2); // Ouessan
|
|
|
996 |
return FALSE;
|
|
|
997 |
}
|
|
|
998 |
|
1649 |
raphael |
999 |
// ces valeurs ne sont pas inséré via les placeholders du PDO::preparedStatement
|
|
|
1000 |
// et doivent donc être échappées correctement.
|
1642 |
raphael |
1001 |
public function initialiser_colonnes_statiques() {
|
1640 |
raphael |
1002 |
$this->colonnes_statiques = array_merge($this->colonnes_statiques,
|
|
|
1003 |
Array(
|
1812 |
raphael |
1004 |
"ce_utilisateur" => self::quoteNonNull($this->id_utilisateur), // peut-être un hash ou un id
|
1765 |
raphael |
1005 |
"prenom_utilisateur" => self::quoteNonNull($this->utilisateur['prenom']),
|
|
|
1006 |
"nom_utilisateur" => self::quoteNonNull($this->utilisateur['nom']),
|
|
|
1007 |
"courriel_utilisateur" => self::quoteNonNull($this->utilisateur['courriel']),
|
1640 |
raphael |
1008 |
));
|
|
|
1009 |
|
|
|
1010 |
}
|
1642 |
raphael |
1011 |
|
1649 |
raphael |
1012 |
static function initialiser_pdo_ordered_statements($colonnes_statiques) {
|
|
|
1013 |
return Array(
|
|
|
1014 |
// insert_ligne_pattern_ordre
|
|
|
1015 |
sprintf('INSERT INTO cel_obs (%s, %s) VALUES',
|
|
|
1016 |
implode(', ', array_keys($colonnes_statiques)),
|
|
|
1017 |
implode(', ', array_diff(self::$ordre_BDD, array_keys($colonnes_statiques)))),
|
|
|
1018 |
|
|
|
1019 |
// insert_ligne_pattern_ordre
|
|
|
1020 |
sprintf('(%s, %s ?)',
|
|
|
1021 |
implode(', ', $colonnes_statiques),
|
|
|
1022 |
str_repeat('?, ', count(self::$ordre_BDD) - count($colonnes_statiques) - 1))
|
|
|
1023 |
);
|
1648 |
raphael |
1024 |
}
|
|
|
1025 |
|
1649 |
raphael |
1026 |
static function initialiser_pdo_statements($colonnes_statiques) {
|
|
|
1027 |
return Array(
|
|
|
1028 |
// insert_prefix
|
|
|
1029 |
sprintf('INSERT INTO cel_obs (%s) VALUES ',
|
|
|
1030 |
implode(', ', self::$ordre_BDD)),
|
|
|
1031 |
|
1650 |
raphael |
1032 |
|
|
|
1033 |
// insert_ligne_pattern, cf: self::$insert_ligne_pattern
|
1649 |
raphael |
1034 |
'(' .
|
1650 |
raphael |
1035 |
// 3) créé une chaîne de liste de champ à inséré en DB
|
|
|
1036 |
implode(', ', array_values(
|
|
|
1037 |
// 2) garde les valeurs fixes (de $colonnes_statiques),
|
|
|
1038 |
// mais remplace les NULL par des "?"
|
1675 |
raphael |
1039 |
array_map('__anonyme_5',
|
1650 |
raphael |
1040 |
// 1) créé un tableau genre (nom_sel_nn => NULL) depuis self::$ordre_BDD
|
|
|
1041 |
// et écrase certaines valeurs avec $colonnes_statiques (initilisé avec les données utilisateur)
|
1675 |
raphael |
1042 |
array_merge(array_map('__anonyme_6', array_flip(self::$ordre_BDD)), $colonnes_statiques
|
1649 |
raphael |
1043 |
)))) .
|
|
|
1044 |
')'
|
|
|
1045 |
);
|
|
|
1046 |
}
|
|
|
1047 |
|
1765 |
raphael |
1048 |
// équivalent à Bdd2->proteger() (qui wrap PDO::quote),
|
1642 |
raphael |
1049 |
// sans transformer NULL en ""
|
1765 |
raphael |
1050 |
static function quoteNonNull($chaine) {
|
1642 |
raphael |
1051 |
if(is_null($chaine)) return "NULL";
|
1812 |
raphael |
1052 |
if(!is_string($chaine) && !is_integer($chaine)) {
|
|
|
1053 |
die("erreur: " . __FILE__ . ':' . __LINE__);
|
|
|
1054 |
}
|
1765 |
raphael |
1055 |
return Cel::db()->quote($chaine);
|
1642 |
raphael |
1056 |
}
|
|
|
1057 |
|
|
|
1058 |
public function erreurs_stock($errno, $errstr) {
|
|
|
1059 |
$this->bilan[] = $errstr;
|
|
|
1060 |
}
|
1636 |
raphael |
1061 |
}
|