WebSVN – eFlore/Applications.cel – Diff – /trunk/jrest/services/ImportXLS.php

 <?php
-/**
- * @category  PHP
- * @package   jrest
- * @author    Raphaël Droz <raphael@tela-botania.org>
- * @copyright 2013 Tela-Botanica
+// declare(encoding='UTF-8');
- * @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
- * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
- */
 /**
  * Service d'import de données d'observation du CEL au format XLS
+ *
  * Sont define()'d commme n° de colonne tous les abbrevs retournés par
  * FormateurGroupeColonne::nomEnsembleVersListeColonnes() préfixés par C_  cf: detectionEntete()
  * $ GET "/jrest/ExportXLS/22506?format=csv&range=*&limite=13" \
  *   | curl -F "upload=@-" -F utilisateur=22506 "/jrest/ImportXLS"
  * # 13 observations importées
  * + cf MySQL general_log = 1
+ *
+ * @category   DEL
+ * @package    Services
+ * @subpackage Communes
+ * @version    0.1
+ * @author     Mathias CHOUET <mathias@tela-botanica.org>
+ * @author     Raphaël DROZ <raphael@tela-botanica.org>
+ * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
+ * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
+ * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
+ * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
+ * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
- **/
+ */
 set_include_path(get_include_path() . PATH_SEPARATOR . dirname(dirname(realpath(__FILE__))) . '/lib');
 // TERM
 error_reporting(-1);
 ini_set('html_errors', 0);
 ini_set('xdebug.cli_color', 2);
 require_once('lib/PHPExcel/Classes/PHPExcel.php');
 require_once('FormateurGroupeColonne.php');
-date_default_timezone_set("Europe/Paris");
+date_default_timezone_set('Europe/Paris');
 // nombre d'INSERT à cumuler par requête SQL
 // (= nombre de lignes XLS à bufferiser)
 define('QUICK_CSV_IMPORT', TRUE);
 // Numbers of days between January 1, 1900 and 1970 (including 19 leap years)
 // see traiterDateObs()
-// define("MIN_DATES_DIFF", 25569);
 // define("MIN_DATES_DIFF", 25569);
 class MyReadFilter implements PHPExcel_Reader_IReadFilter {
-    // exclusion de colonnes
+	// exclusion de colonnes
-    public $exclues = array();
+	public $exclues = array();
-    public $ligne_fin = 0;
+	public $ligne_fin = 0;
-    public static $gestion_mots_cles = null;
+	public static $gestion_mots_cles = null;
 	public function __construct() {}
     public function __construct() {}
-    public function def_interval($debut, $nb) {
+	public function def_interval($debut, $nb) {
-	$this->ligne_debut = $debut;
+		$this->ligne_debut = $debut;
+		$this->ligne_fin = $debut + $nb;
 	$this->ligne_fin = $debut + $nb;
-    public function readCell($colonne, $ligne, $worksheetName = '') {
+	public function readCell($colonne, $ligne, $worksheetName = '') {
-	if(@$this->exclues[$colonne]) return false;
+		if(@$this->exclues[$colonne]) return false;
-	// si des n° de morceaux ont été initialisés, on filtre...
+		// si des n° de morceaux ont été initialisés, on filtre...
-	if($this->ligne_debut && ($ligne < $this->ligne_debut || $ligne >= $this->ligne_fin)) return false;
+		if($this->ligne_debut && ($ligne < $this->ligne_debut || $ligne >= $this->ligne_fin)) return false;
-	return true;
+		return true;
-    }
+	}
+}
 // XXX: PHP 5.3
 function __anonyme_1($v) {	return !$v['importable']; }
 function __anonyme_2(&$v) {	$v = $v['nom']; }
-      Ces colonnes:
+	 Ces colonnes:
-      - sont propres à l'ensemble des enregistrements uploadés
+	 - sont propres à l'ensemble des enregistrements uploadés
-      - sont indépendantes du numéro de lignes
+	 - sont indépendantes du numéro de lignes
-      - n'ont pas de valeur par défaut dans la structure de la table
+	 - n'ont pas de valeur par défaut dans la structure de la table
-      - nécessitent une initialisation dans le cadre de l'upload
+	 - nécessitent une initialisation dans le cadre de l'upload
-      initialiser_colonnes_statiques() y merge les données d'identification utilisateur
+	 initialiser_colonnes_statiques() y merge les données d'identification utilisateur
-    */
+	*/
-    public $colonnes_statiques = Array(
+	public $colonnes_statiques = array(
-	"ce_utilisateur" => NULL,
+		"ce_utilisateur" => NULL,
-	"prenom_utilisateur" => NULL,
+		"prenom_utilisateur" => NULL,
-	"nom_utilisateur" => NULL,
+		"nom_utilisateur" => NULL,
-	"courriel_utilisateur" => NULL,
+		"courriel_utilisateur" => NULL,
+		}
-	$id_utilisateur = intval($pairs['utilisateur']);
+		$id_utilisateur = intval($pairs['utilisateur']);
-	$this->id_utilisateur = $id_utilisateur; // pour traiterImage();
+		$this->id_utilisateur = $id_utilisateur; // pour traiterImage();
+		if (!isset($_SESSION)) {
 			session_start();
 	if(!isset($_SESSION)) session_start();
-	$this->controleUtilisateur($id_utilisateur);
-	$this->utilisateur = $this->getInfosComplementairesUtilisateur($id_utilisateur);
 		$this->controleUtilisateur($id_utilisateur);
-	$this->initialiser_colonnes_statiques($id_utilisateur);
-	// initialisation du statement PDO/MySQL
-	// première version, pattern de requête pas génial
-	/* list(self;;$insert_prefix_ordre, self::$insert_ligne_pattern_ordre) =
-	   $this->initialiser_pdo_ordered_statements($this->colonnes_statiques); */
+		$this->utilisateur = $this->getInfosComplementairesUtilisateur($id_utilisateur);
-	list(self::$insert_prefix, self::$insert_ligne_pattern) =
-	    $this->initialiser_pdo_statements($this->colonnes_statiques);
-	$infos_fichier = array_pop($_FILES);
-	/*$objPHPExcel = PHPExcel_IOFactory::load($infos_fichier['tmp_name']);
-	  $donnees = $objPHPExcel->getActiveSheet()->toArray(NULL,FALSE,FALSE,TRUE);*/
-	/*$objReader = PHPExcel_IOFactory::createReader("Excel5");
-	  $objReader->setReadDataOnly(true);
+		$this->initialiser_colonnes_statiques($id_utilisateur);
-	  $objPHPExcel = $objReader->load($infos_fichier['tmp_name']);*/
+		list(self::$insert_prefix, self::$insert_ligne_pattern) = $this->initialiser_pdo_statements($this->colonnes_statiques);
-	//var_dump($donnees);
+		$infos_fichier = array_pop($_FILES);
-	// renomme le fichier pour lui ajouter son extension initiale, ce qui
-	// permet (une sorte) d'autodétection du format.
+		// renomme le fichier pour lui ajouter son extension initiale, ce qui
-	$fichier = $infos_fichier['tmp_name'];
+		// permet (une sorte) d'autodétection du format.
-	$extension = pathinfo($infos_fichier['name'], PATHINFO_EXTENSION);
+		$fichier = $infos_fichier['tmp_name'];
-	if( (strlen($extension) == 3 || strlen($extension) == 4) &&
+		$extension = pathinfo($infos_fichier['name'], PATHINFO_EXTENSION);
-	    (@rename($fichier, $fichier . '.' . $extension))) { // XXX: @ safe-mode
+		if ( (strlen($extension) == 3 || strlen($extension) == 4) && (@rename($fichier, "$fichier.$extension"))) {
-	    $fichier = $fichier . '.' . $extension;
+			$fichier = "$fichier.$extension";
+		}
+		$objReader = PHPExcel_IOFactory::createReaderForFile($fichier);
-	$objReader = PHPExcel_IOFactory::createReaderForFile($fichier);
+		// TODO: check if compatible with toArray(<1>,<2>,TRUE,<4>)
+		$objReader->setReadDataOnly(true);
 	// TODO: check if compatible with toArray(<1>,<2>,TRUE,<4>)
-	$objReader->setReadDataOnly(true);
+		// TODO: is_a obsolete entre 5.0 et 5.3, retirer le @ à terme
+		$IS_CSV = @is_a($objReader, 'PHPExcel_Reader_CSV') && QUICK_CSV_IMPORT;
+		// en cas d'usage de fgetcsv, testons que nous pouvons compter les lignes
+		if ($IS_CSV) {
-	// TODO: is_a obsolete entre 5.0 et 5.3, retirer le @ à terme
+			$nb_lignes = intval(exec("wc -l $fichier"));
 	$IS_CSV = @is_a($objReader, 'PHPExcel_Reader_CSV') && QUICK_CSV_IMPORT;
-	// en cas d'usage de fgetcsv, testons que nous pouvons compter les lignes
+		// et, le cas échéant, fallback sur PHPExcel à nouveau. La raison de ce test ici est
-	if($IS_CSV) $nb_lignes = intval(exec("wc -l $fichier"));
+		// l'instabilité du serveur (safe_mode, safe_mode_exec_dir, symlink vers binaires pour exec(), ... multiples points-of-failure)
-	$nb_mots_cle_ajoutes = 0;
+		$nb_mots_cle_ajoutes = 0;
-	$nb_champs_etendus_inseres = 0;
+		$nb_champs_etendus_inseres = 0;
-	$dernier_ordre = Cel::db()->requeter("SELECT MAX(ordre) AS ordre FROM cel_obs WHERE ce_utilisateur = $id_utilisateur");
+		$dernier_ordre = Cel::db()->requeter("SELECT MAX(ordre) AS ordre FROM cel_obs WHERE ce_utilisateur = $id_utilisateur");
-	$dernier_ordre = intval($dernier_ordre[0]['ordre']) + 1;
+		$dernier_ordre = intval($dernier_ordre[0]['ordre']) + 1;
+		if (! $dernier_ordre) {
+			$dernier_ordre = 0;
 	if(! $dernier_ordre) $dernier_ordre = 0;
-	// on catch to les trigger_error(E_USER_NOTICE);
+		// on catch to les trigger_error(E_USER_NOTICE);
-	set_error_handler(array($this, 'erreurs_stock'), E_USER_NOTICE);
-	$this->taxon_info_webservice = new RechercheInfosTaxonBeta($this->config, NULL);
+		set_error_handler(array($this, 'erreurs_stock'), E_USER_NOTICE);
 		$this->taxon_info_webservice = new RechercheInfosTaxonBeta($this->config, NULL);
-	// lecture par morceaux (chunks), NB_LIRE_LIGNE_SIMUL lignes à fois
+		// lecture par morceaux (chunks), NB_LIRE_LIGNE_SIMUL lignes à fois
-	// pour aboutir des requêtes SQL d'insert groupés.
+		// pour aboutir des requêtes SQL d'insert groupés.
-	for($ligne = 2; $ligne < $nb_lignes + NB_LIRE_LIGNE_SIMUL; $ligne += NB_LIRE_LIGNE_SIMUL) {
+		for ($ligne = 2; $ligne < $nb_lignes + NB_LIRE_LIGNE_SIMUL; $ligne += NB_LIRE_LIGNE_SIMUL) {
-	    if(!$IS_CSV) {
-		$filtre->def_interval($ligne, NB_LIRE_LIGNE_SIMUL);
-		$objReader->setReadFilter($filtre);
 			if (!$IS_CSV) {
-		/* recharge avec $filtre actif (filtre sur lignes colonnes):
+				$filtre->def_interval($ligne, NB_LIRE_LIGNE_SIMUL);
-		   - exclue les colonnes inutiles/inutilisables)
+				$objReader->setReadFilter($filtre);
 		   - ne selectionne que les lignes dans le range [$ligne - $ligne + NB_LIRE_LIGNE_SIMUL] */
-		$objPHPExcel = $objReader->load($fichier)->getActiveSheet();
+				$objPHPExcel = $objReader->load($fichier)->getActiveSheet();
-		// set col typing
+				// set col typing
-		if(C_CE_ZONE_GEO != 'C_CE_ZONE_GEO')
+				if (C_CE_ZONE_GEO != 'C_CE_ZONE_GEO') {
-		    $objPHPExcel->getStyle(C_CE_ZONE_GEO . '2:' . C_CE_ZONE_GEO . $objPHPExcel->getHighestRow())->getNumberFormat()->setFormatCode('00000');
-		// TODO: set to string type
+					$objPHPExcel->getStyle(C_CE_ZONE_GEO . '2:' . C_CE_ZONE_GEO . $objPHPExcel->getHighestRow())->getNumberFormat()->setFormatCode('00000');
+				}
-		if(C_ZONE_GEO != 'C_ZONE_GEO')
+				// TODO: set to string type
-		    $objPHPExcel->getStyle(C_ZONE_GEO . '2:' . C_ZONE_GEO . $objPHPExcel->getHighestRow())->getNumberFormat()->setFormatCode('00000');
+				if (C_ZONE_GEO != 'C_ZONE_GEO') {
 					$objPHPExcel->getStyle(C_ZONE_GEO . '2:' . C_ZONE_GEO . $objPHPExcel->getHighestRow())->getNumberFormat()->setFormatCode('00000');
 		$donnees = $objPHPExcel->toArray(NULL, FALSE, TRUE, TRUE);
 				$donnees = $objPHPExcel->toArray(NULL, FALSE, TRUE, TRUE);
-	    else {
+			} else {
+				$i = NB_LIRE_LIGNE_SIMUL;
+				$donnees = array();
-		$i = NB_LIRE_LIGNE_SIMUL;
+				while ($i--) {
-		$donnees = array();
+					$tab = fgetcsv($csvFileHandler);
-		while($i--) {
-		    $tab = fgetcsv($csvFileHandler);
+					if (!$tab) {
-		    if(!$tab) continue;
-		    $donnees[] = array_diff_key($tab, $filtre->exclues);
-		}
-	    }
-	    // var_dump($donnees, get_defined_constants(true)['user']);die;
+						continue;
-	    // ici on appel la fonction qui fera effectivement l'insertion multiple
+					}
+					$donnees[] = array_diff_key($tab, $filtre->exclues);
+				}
 	    // à partir des (au plus) NB_LIRE_LIGNE_SIMUL lignes
-	    // TODO: passer $this, ne sert que pour appeler des méthodes publiques qui pourraient être statiques
+			list($enregistrements, $images, $mots_cle, $champs_etendus) = self::chargerLignes($this, $donnees, $this->colonnes_statiques, $dernier_ordre);
-	    list($enregistrements, $images, $mots_cle, $champs_etendus) =
+			if (! $enregistrements) {
-		self::chargerLignes($this, $donnees, $this->colonnes_statiques, $dernier_ordre);
+				break;
-	    if(! $enregistrements) break;
-	    self::trierColonnes($enregistrements);
-	    // normalement: NB_LIRE_LIGNE_SIMUL, sauf si une enregistrement ne semble pas valide
 	    // ou bien lors du dernier chunk
-	    $nb_rec = count($enregistrements);
+			self::trierColonnes($enregistrements);
-	    $sql_pattern = self::$insert_prefix .
+			// normalement: NB_LIRE_LIGNE_SIMUL, sauf si une enregistrement ne semble pas valide
-		str_repeat(self::$insert_ligne_pattern_ordre . ', ', $nb_rec - 1) .
+			// ou bien lors du dernier chunk
-		self::$insert_ligne_pattern_ordre;
+			$nb_rec = count($enregistrements);
+			$sql_pattern = self::$insert_prefix.
-	    $sql_pattern = self::$insert_prefix .
-		str_repeat(self::$insert_ligne_pattern . ', ', $nb_rec - 1) .
+				str_repeat(self::$insert_ligne_pattern.', ', $nb_rec - 1).
-		self::$insert_ligne_pattern;
 				self::$insert_ligne_pattern;
 	    Cel::db()->beginTransaction();
+			Cel::db()->beginTransaction();
-	    $stmt = Cel::db()->prepare($sql_pattern);
+			$stmt = Cel::db()->prepare($sql_pattern);
+			$donnees = array();
-	    $donnees = array();
+			foreach ($enregistrements as $e) {
-	    foreach($enregistrements as $e) $donnees = array_merge($donnees, array_values($e));
-	     // echo $sql_pattern . "\n"; var_dump($enregistrements, $donnees); die; // debug ici
+				$donnees = array_merge($donnees, array_values($e));
+			}
 	    $stmt->execute($donnees);
 			$stmt->execute($donnees);
 	    // $stmt->debugDumpParams(); // https://bugs.php.net/bug.php?id=52384
-	    $dernier_autoinc = Cel::db()->lastInsertId();
+			$dernier_autoinc = Cel::db()->lastInsertId();
+			Cel::db()->commit();
-	    Cel::db()->commit();
+			if (! $dernier_autoinc) {
 				trigger_error("l'insertion semble avoir échoué", E_USER_NOTICE);
 	    if(! $dernier_autoinc) trigger_error("l'insertion semble avoir échoué", E_USER_NOTICE);
 	    $obs_ajouts += count($enregistrements);
-	    // $obs_ajouts += count($enregistrements['insert']);
+			$obs_ajouts += count($enregistrements);
 	    // $obs_maj += count($enregistrements['update']);
 			$ordre_ids = self::chargerCorrespondancesIdOrdre($this, $enregistrements);
-	// défini tous les index que nous utilisons à une valeur d'index de colonne Excel qui n'existe pas dans
+		// défini tous les index que nous utilisons à une valeur d'index de colonne Excel qui n'existe pas dans
-	// le tableau renvoyé par PHPExcel
+		// le tableau renvoyé par PHPExcel
-	// Attention cependant d'utiliser des indexes différenciés car traiterLonLat() et traiterEspece()
+		// Attention cependant d'utiliser des indexes différenciés car traiterLonLat() et traiterEspece()
-	// les utilisent
+		// les utilisent
-	foreach($cols as $col) {
+		foreach ($cols as $col) {
-	    if(!defined("C_" . strtoupper($col['abbrev'])))
+			if (!defined('C_'.strtoupper($col['abbrev']))) {
-		define("C_" . strtoupper($col['abbrev']), "C_" . strtoupper($col['abbrev']));
+				define('C_'.strtoupper($col['abbrev']), 'C_'.strtoupper($col['abbrev']));
+			}
+		}
-	// prépare le filtre de PHPExcel qui évitera le traitement de toutes les colonnes superflues
-	// eg: diff ( Array( H => Commune, I => rien ) , Array( H => 1, K => 1 )
-	// ==> Array( I => rien )
+		// prépare le filtre de PHPExcel qui évitera le traitement de toutes les colonnes superflues
-	$colonnesID_non_reconnues = array_diff_key($entete, $colonnes_reconnues);
+		$colonnesID_non_reconnues = array_diff_key($entete, $colonnes_reconnues);
-	// des colonnes de FormateurGroupeColonne::nomEnsembleVersListeColonnes()
+		// des colonnes de FormateurGroupeColonne::nomEnsembleVersListeColonnes()
-	// ne retient que celles marquées "importables"
+		// ne retient que celles marquées "importables"
-	$colonnes_automatiques = array_filter($cols, '__anonyme_1');
+		$colonnes_automatiques = array_filter($cols, '__anonyme_1');
-	// ne conserve que le nom long pour matcher avec la ligne XLS d'entête
 	array_walk($colonnes_automatiques, '__anonyme_2');
 		// ne conserve que le nom long pour matcher avec la ligne XLS d'entête
-	// intersect ( Array ( N => Milieu, S => Ordre ), Array ( ordre => Ordre, phenologie => Phénologie ) )
+		array_walk($colonnes_automatiques, '__anonyme_2');
 	// ==> Array ( S => Ordre, AA => Phénologie )
-	$colonnesID_a_exclure = array_intersect($entete, $colonnes_automatiques);
-	if($numeric_keys) {
-	    return $colonnesID_non_reconnues + $colonnesID_a_exclure;
+		$colonnesID_a_exclure = array_intersect($entete, $colonnes_automatiques);
-	// TODO: pourquoi ne pas comparer avec les abbrevs aussi ?
+		if ($numeric_keys) {
-	// merge ( Array( I => rien ) , Array ( S => Ordre, AA => Phénologie ) )
-	// ==> Array ( I => rien, AA => Phénologie )
+			return $colonnesID_non_reconnues + $colonnesID_a_exclure;
-	return array_merge($colonnesID_non_reconnues, $colonnesID_a_exclure);
-    }
+		}
-    static function chargerCorrespondancesIdOrdre($cel, $lignes) {
+		return array_merge($colonnesID_non_reconnues, $colonnesID_a_exclure);
+	}
-    	$ordre_ids = array();
+	static function chargerCorrespondancesIdOrdre($cel, $lignes) {
-    	$requete_obs_ids = "SELECT id_observation, ordre FROM cel_obs WHERE ordre IN (";
-    	foreach($lignes as &$ligne) {
+		$ordresObs = array();
+		foreach ($lignes as &$ligne) {
+			$ordresObs[] = $ligne['ordre'];
+		}
+		$ordresObsConcat = implode(',', $ordresObs);
-    		$requete_obs_ids .= $ligne['ordre'].',';
+		$idUtilisateurP = Cel::db()->proteger($cel->id_utilisateur);
+		$requete = 'SELECT id_observation, ordre '.
-    	}
+			'FROM cel_obs '.
-    	$requete_obs_ids = rtrim($requete_obs_ids, ',');
+			"WHERE ordre IN ($ordresObsConcat) ".
-    	$requete_obs_ids .= ") AND ce_utilisateur = ".Cel::db()->proteger($cel->id_utilisateur);
+			"AND ce_utilisateur = $idUtilisateurP ".
+			' -- '.__FILE__.':'.__LINE__;
 		$resultats = Cel::db()->requeter($requete);
-    	$obs_ids = Cel::db()->requeter($requete_obs_ids);
+		$ordresIds = array();
-    	foreach($obs_ids as &$obs) {
+		foreach ($resultats as &$infos) {
-    		$ordre_ids[$obs['ordre']] = $obs['id_observation'];
+			$ordresIds[$infos['ordre']] = $infos['id_observation'];
+		}
-    	return $ordre_ids;
+		return $ordresIds;
-    }
+	}
-    /*
+	/*
-     * charge un groupe de lignes
+	 * charge un groupe de lignes
-     */
+	 */
-    static function chargerLignes($cel, $lignes, $colonnes_statiques, &$dernier_ordre) {
-	$enregistrement = NULL;
+	static function chargerLignes($cel, $lignes, $colonnes_statiques, &$dernier_ordre) {
-	$enregistrements = Array();
+		$enregistrement = NULL;
+		$enregistrements = array();
+		$toutes_images = array();
-	$toutes_images = Array();
-	$tous_mots_cle = Array();
-	$tous_champs_etendus = array();
+		$tous_mots_cle = array();
+		$tous_champs_etendus = array();
+		foreach ($lignes as $ligne) {
-	foreach($lignes as $ligne) {
+			// dans le cas de fgetcsv, on peut avoir des false additionnel (cf do/while l. 279)
 			if ($ligne === false) {
-	    // dans le cas de fgetcsv, on peut avoir des false additionnel (cf do/while l. 279)
+				continue;
 	    if($ligne === false) continue;
-	    //$ligne = array_filter($ligne, function($cell) { return !is_null($cell); });
+			// on a besoin des NULL pour éviter des notice d'index indéfini
-	    //if(!$ligne) continue;
+			if (! array_filter($ligne, '__anonyme_3')) {
-	    // on a besoin des NULL pour éviter des notice d'index indéfini
+				continue;
+			}
-	    if(! array_filter($ligne, '__anonyme_3')) continue;
+			if ($enregistrement = self::chargerLigne($ligne, $dernier_ordre, $cel)) {
-	    if( ($enregistrement = self::chargerLigne($ligne, $dernier_ordre, $cel)) ) {
+				// $enregistrements[] = array_merge($colonnes_statiques, $enregistrement);
-		// $enregistrements[] = array_merge($colonnes_statiques, $enregistrement);
+				$enregistrements[] = $enregistrement;
-		$enregistrements[] = $enregistrement;
+				$pos = count($enregistrements) - 1;
-		$pos = count($enregistrements) - 1;
+				$last = &$enregistrements[$pos];
 		$last = &$enregistrements[$pos];
 				if (isset($enregistrement['_images'])) {
-		if(isset($enregistrement['_images'])) {
+					// ne dépend pas de cel_obs, et seront insérées *après* les enregistrements
+					// mais nous ne voulons pas nous priver de faire des INSERT multiples pour autant
-		    // ne dépend pas de cel_obs, et seront insérées *après* les enregistrements
+					$toutes_images[] = array(
-		    // mais nous ne voulons pas nous priver de faire des INSERT multiples pour autant
+						'images' => $last['_images'],
-		    $toutes_images[] = Array("images" => $last['_images'],
-					     "obs_pos" => $pos);
-		    // ce champ n'a pas à faire partie de l'insertion dans cel_obs,
-		    // mais est utile pour cel_obs_images
-		    unset($last['_images']);
+						'obs_pos' => $pos);
 					// ce champ n'a pas à faire partie de l'insertion dans cel_obs,
 					// mais est utile pour la liaison avec les images
+					unset($last['_images']);
-		if(isset($enregistrement['_mots_cle'])) {
+				}
-		    // ne dépend pas de cel_obs, et seront insérés *après* les enregistrements
-		    // mais nous ne voulons pas nous priver de faire des INSERT multiples pour autant
+				if (isset($enregistrement['_mots_cle'])) {
-		    $tous_mots_cle[] = Array("mots_cle" => $last['_mots_cle'],
+					// ne dépend pas de cel_obs, et seront insérés *après* les enregistrements
-					     "obs_pos" => $pos);
+					// mais nous ne voulons pas nous priver de faire des INSERT multiples pour autant
-		    // la version inlinée des mots est enregistrées dans cel_obs
+					$tous_mots_cle[] = array(
-		    // mais cel_mots_cles_obs fait foi.
+						'mots_cle' => $last['_mots_cle'],
-		    // XXX: postponer l'ajout de ces informations dans cel_obs *après* l'insertion effective
-		    // des records dans cel_mots_cles_obs ?
-		    unset($last['_mots_cle']);
+						'obs_pos' => $pos);
 					unset($last['_mots_cle']);
 		if(isset($enregistrement['_champs_etendus'])) {
 			$tous_champs_etendus[] = Array("champs_etendus" => $last['_champs_etendus'],
-					"ordre" => $dernier_ordre);
+				if (isset($enregistrement['_champs_etendus'])) {
-			unset($last['_champs_etendus']);
-		}
-		$dernier_ordre++;
+					$tous_champs_etendus[] = array(
 						'champs_etendus' => $last['_champs_etendus'],
-	}
 						'ordre' => $dernier_ordre);
-	// XXX future: return Array($enregistrements_a_inserer, $enregistrements_a_MAJ, $toutes_images);
+					unset($last['_champs_etendus']);
 	return Array($enregistrements, $toutes_images, $tous_mots_cle, $tous_champs_etendus);
+				$dernier_ordre++;
-    }
+			}
+		}
 		return array($enregistrements, $toutes_images, $tous_mots_cle, $tous_champs_etendus);
+	}
     static function trierColonnes(&$enregistrements) {
-	foreach($enregistrements as &$enregistrement) {
-	    $enregistrement = self::sortArrayByArray($enregistrement, self::$ordre_BDD);
+	static function trierColonnes(&$enregistrements) {
-	    //array_walk($enregistrement, function(&$item, $k) { $item = is_null($item) ? "NULL" : $item; });
-	    //$req .= implode(', ', $enregistrement) . "\n";
+		foreach ($enregistrements as &$enregistrement) {
-	}
+			$enregistrement = self::sortArrayByArray($enregistrement, self::$ordre_BDD);
+		}
+	}
-    static function stockerMotsCle($enregistrements, $tous_mots_cle, $lastid) {
-	$c = 0;
-	// debug: var_dump($tous_mots_cle);die;
+	static function stockerMotsCle($enregistrements, $tous_mots_cle, $lastid) {
-	foreach($tous_mots_cle as $v) $c += count($v['mots_cle']['to_insert']);
+		$c = 0;
-	return $c;
+		// debug: var_dump($tous_mots_cle);die;
-    }
+		foreach ($tous_mots_cle as $v) {
+			$c += count($v['mots_cle']['to_insert']);
+		}
+		return $c;
+	}
-    static function stockerImages($enregistrements, $toutes_images, $ordre_ids) {
+	static function stockerImages($enregistrements, $toutes_images, $ordre_ids) {
-	$images_insert = 'INSERT INTO cel_obs_images (id_image, id_observation) VALUES %s ON DUPLICATE KEY UPDATE id_image = id_image';
+		$idsImagesObs = array();
-	$images_obs_assoc = Array();
+		foreach ($toutes_images as $images_pour_obs) {
-	foreach($toutes_images as $images_pour_obs) {
+			$obs = $enregistrements[$images_pour_obs['obs_pos']];
-	    $obs = $enregistrements[$images_pour_obs["obs_pos"]];
+			$id_obs = $ordre_ids[$obs['ordre']]; // id réel de l'observation correspondant à l'ordre
-	    $id_obs = $ordre_ids[$obs['ordre']]; // id réel de l'observation correspondant à l'ordre
+			foreach ($images_pour_obs['images'] as $image) {
-	    foreach($images_pour_obs['images'] as $image) {
+				$idsImagesObs[] = sprintf('(%d,%d, NOW())', $image['id_image'], $id_obs);
-	// * traiter espèce (traiterEspece())
+		// * traiter espèce (traiterEspece())
-	// * traiter longitude et latitude (traiterLonLat())
+		// * traiter longitude et latitude (traiterLonLat())
-	$referentiel = self::identReferentiel(trim(strtolower(@$ligne[C_NOM_REFERENTIEL])), $ligne, $ref_ligne);
+		$referentiel = self::identReferentiel(trim(strtolower(@$ligne[C_NOM_REFERENTIEL])), $ligne, $ref_ligne);
+		// $espece est rempli de plusieurs informations
+		$espece = array(
-	// $espece est rempli de plusieurs informations
+			C_NOM_SEL => NULL,
+			C_NOM_SEL_NN => NULL,
-	$espece = Array(C_NOM_SEL => NULL, C_NOM_SEL_NN => NULL, C_NOM_RET => NULL,
+			C_NOM_RET => NULL,
+			C_NOM_RET_NN => NULL,
+			C_NT => NULL,
-			C_NOM_RET_NN => NULL, C_NT => NULL, C_FAMILLE => NULL);
+			C_FAMILLE => NULL);
+		self::traiterEspece($ligne, $espece, $referentiel, $cel->taxon_info_webservice);
-	self::traiterEspece($ligne, $espece, $referentiel, $cel->taxon_info_webservice);
+		if (!$espece[C_NOM_SEL]) {
+			$referentiel = Cel::$fallback_referentiel;
+		}
+		if ($espece[C_NOM_SEL] && !$espece[C_NOM_SEL_NN]) {
-	if(!$espece[C_NOM_SEL]) $referentiel = Cel::$fallback_referentiel;
+			$referentiel = Cel::$fallback_referentiel;
 	if($espece[C_NOM_SEL] && !$espece[C_NOM_SEL_NN]) $referentiel = Cel::$fallback_referentiel;
-	);
+		);
-	// passage de $enregistrement par référence, ainsi ['_images'] n'est défini
+		// passage de $enregistrement par référence, ainsi ['_images'] n'est défini
-	// que si des résultats sont trouvés
+		// que si des résultats sont trouvés
+		// "@" car PHPExcel supprime les colonnes null sur toute la feuille (ou tout le chunk)
-	// "@" car PHPExcel supprime les colonnes null sur toute la feuille (ou tout le chunk)
+		if (@$ligne[C_IMAGES]) {
+			self::traiterImage($ligne[C_IMAGES], $cel->id_utilisateur, $enregistrement);
+		}
-	if(@$ligne[C_IMAGES]) self::traiterImage($ligne[C_IMAGES], $cel->id_utilisateur, $enregistrement);
+		if (@$ligne[C_MOTS_CLES_TEXTE]) {
 			self::traiterMotsCle($ligne[C_MOTS_CLES_TEXTE], $cel->id_utilisateur, $enregistrement);
 	if(@$ligne[C_MOTS_CLES_TEXTE]) self::traiterMotsCle($ligne[C_MOTS_CLES_TEXTE], $cel->id_utilisateur, $enregistrement);
-	$champs_etendus = self::traiterChampsEtendus($ligne, self::$indexes_colonnes_etendues);
+		$champs_etendus = self::traiterChampsEtendus($ligne, self::$indexes_colonnes_etendues);
-	if(!empty($champs_etendus)) {
+		if (!empty($champs_etendus)) {
-		$enregistrement["_champs_etendus"] = $champs_etendus;
+			$enregistrement['_champs_etendus'] = $champs_etendus;
+		}
-    	return $champs_etendus_indexes;
+		return $champs_etendus_indexes;
+	}
-    static function traiterImage($str, $id_utilisateur, &$enregistrement) {
+	static function traiterImage($str, $id_utilisateur, &$enregistrement) {
-	$liste_images = array_filter(explode("/", $str));
-	//array_walk($liste_images, '__anonyme_4');
+		$liste_images = array_filter(explode('/', $str));
-	array_walk($liste_images, array(__CLASS__, '__anonyme_4'));
-	$requete = sprintf(
-	    "SELECT id_image, nom_original FROM cel_images WHERE ce_utilisateur = %d AND nom_original IN (%s)",
-	    $id_utilisateur,
+		array_walk($liste_images, array(__CLASS__, '__anonyme_4'));
+		$nomsOrignalConcat = implode(',', $liste_images);
+		$requete = 'SELECT id_image, nom_original '.
+			'FROM cel_images '.
-	    implode(',', $liste_images));
+			"WHERE ce_utilisateur = $id_utilisateur AND nom_original IN ($nomsOrignalConcat) ".
+			' -- '.__FILE__.':'.__LINE__;
+		$resultat = Cel::db()->requeter($requete);
-	$resultat = Cel::db()->requeter($requete);
+		if ($resultat) {
 			$enregistrement['_images'] = $resultat;
-	if($resultat) $enregistrement['_images'] = $resultat;
+		}
+	}
-    static function traiterMotsCle($str, $id_utilisateur, &$enregistrement) {
+	static function traiterMotsCle($str, $id_utilisateur, &$enregistrement) {
-	$liste_mots_cle = $liste_mots_cle_recherche = array_map("trim", array_unique(array_filter(explode(",", $str))));
+		$liste_mots_cle = $liste_mots_cle_recherche = array_map('trim', array_unique(array_filter(explode(',', $str))));
-	foreach($mots_cles_ids as $mot_cle) {
+		foreach ($mots_cles_ids as $mot_cle) {
-		$resultat[$mot_cle['id_mot_cle']] = $mot_cle['mot_cle'];
+			$resultat[$mot_cle['id_mot_cle']] = $mot_cle['mot_cle'];
+		}
-	$enregistrement['mots_cles_texte'] = implode(',', $liste_mots_cle);
+		$enregistrement['mots_cles_texte'] = implode(',', $liste_mots_cle);
+		$enregistrement['_mots_cle'] = array(
-	$enregistrement['_mots_cle'] = array("existing" => $resultat,
+			'existing' => $resultat,
-					     "to_insert" => array_diff($liste_mots_cle, $resultat));
+			'to_insert' => array_diff($liste_mots_cle, $resultat));
+	}
     /* FONCTIONS de TRANSFORMATION de VALEUR DE CELLULE */
 	/* FONCTIONS de TRANSFORMATION de VALEUR DE CELLULE */
-    // TODO: PHP 5.3, utiliser date_parse_from_format()
+	// TODO: PHP 5.3, utiliser date_parse_from_format()
-    // TODO: parser les heures (cf product-owner)
+	// TODO: parser les heures (cf product-owner)
-    // TODO: passer par le timestamp pour s'assurer de la validité
+	// TODO: passer par le timestamp pour s'assurer de la validité
-    static function traiterDateObs($date, $ref_ligne) {
+	static function traiterDateObs($date, $ref_ligne) {
-	// TODO: see https://github.com/PHPOffice/PHPExcel/issues/208
+		// TODO: see https://github.com/PHPOffice/PHPExcel/issues/208
-	// TODO: PHPExcel_Shared_Date::ExcelToPHP()
+		// TODO: PHPExcel_Shared_Date::ExcelToPHP()
-	if(is_double($date)) {
-	    if($date > 0)
-		return PHPExcel_Style_NumberFormat::toFormattedString($date, PHPExcel_Style_NumberFormat::FORMAT_DATE_YYYYMMDD2) . " 00:00:00";
-	    trigger_error("ligne \"{$ref_ligne}\": " .
-			  "Attention: date antérieure à 1970 et format de cellule \"DATE\" utilisés ensemble",
-			  E_USER_NOTICE);
-	    // throw new Exception("erreur: date antérieure à 1970 et format de cellule \"DATE\" utilisés ensemble");
-	    // attention, UNIX timestamp, car Excel les décompte depuis 1900
-	    // cf http://fczaja.blogspot.fr/2011/06/convert-excel-date-into-timestamp.html
-	    // $timestamp = ($date - MIN_DATES_DIFF) * 60 * 60 * 24 - time(); // NON
-	    // $timestamp = PHPExcel_Calculation::getInstance()->calculateFormula("=" . $date . "-DATE(1970,1,1)*60*60*24"); // NON
+		if (is_double($date)) {
+			if ($date > 0) {
+				return PHPExcel_Style_NumberFormat::toFormattedString($date, PHPExcel_Style_NumberFormat::FORMAT_DATE_YYYYMMDD2) . " 00:00:00";
+			}
-	    // echo strftime("%Y/%m/%d 00:00:00", $timestamp); // NON
+			$msg = "ligne «{$ref_ligne}»: Attention: date antérieure à 1970 et format de cellule «DATE» utilisés ensemble";
 			trigger_error($msg, E_USER_NOTICE);
-	else {
+		} else {
-	    // attend l'un des formats de
+			// attend l'un des formats de
-	    // http://www.php.net/manual/fr/datetime.formats.date.php
+			// http://www.php.net/manual/fr/datetime.formats.date.php
-	    // le plus simple: YYYY/MM/DD (utilisé à l'export), mais DD-MM-YYYY est aussi supporté
+			// le plus simple: YYYY/MM/DD (utilisé à l'export), mais DD-MM-YYYY est aussi supporté
-	    $matches = NULL;
+			$matches = NULL;
-	    // et on essaie d'être sympa et supporter aussi DD/MM/YYYY
+			// et on essaie d'être sympa et supporter aussi DD/MM/YYYY
-	    if(preg_match(';^([0-3]?\d)/([01]\d)/([12]\d\d\d)$;', $date, $matches)) {
+			if (preg_match(';^([0-3]?\d)/([01]\d)/([12]\d\d\d)$;', $date, $matches)) {
-		$date = $matches[3] . '/' . $matches[2] . '/' . $matches[1];
+				$date = $matches[3] . '/' . $matches[2] . '/' . $matches[1];
+			}
-	    }
+			$timestamp = strtotime($date);
+			if (! $timestamp || $timestamp > time() + 3600 * 24 * 1) { // une journée d'avance maxi autorisée (décallage horaire ?)
+				if ($date) {
-	    $timestamp = strtotime($date);
+					$msg = "ligne «{$ref_ligne}»: Attention: date erronée ($date)";
-	    if(! $timestamp || $timestamp > time() + 3600 * 24 * 1) { // une journée d'avance maxi autorisée (décallage horaire ?)
+					trigger_error($msg, E_USER_NOTICE);
-		if($date) trigger_error("ligne \"{$ref_ligne}\": Attention: date erronée ($date)", E_USER_NOTICE);
+				}
-		return NULL;
+				return NULL;
+			}
-	    return strftime("%Y-%m-%d 00:00:00", $timestamp);
+			return strftime('%Y-%m-%d 00:00:00', $timestamp);
+		}
-    }
+	}
+	static function identReferentiel($referentiel, $ligne, $ref_ligne) {
+		// SELECT DISTINCT nom_referentiel, COUNT(id_observation) AS count FROM cel_obs GROUP BY nom_referentiel ORDER BY count DESC;
+		if (strpos($referentiel, 'bdtfx') !== FALSE) {
+			return 'bdtfx'; //:v1.01';
-    static function identReferentiel($referentiel, $ligne, $ref_ligne) {
+		}
+		if (strpos($referentiel, 'bdtxa') !== FALSE) {
+			return 'bdtxa'; //:v1.00';
-	// SELECT DISTINCT nom_referentiel, COUNT(id_observation) AS count FROM cel_obs GROUP BY nom_referentiel ORDER BY count DESC;
+		}
-	if(strpos($referentiel, 'bdtfx') !== FALSE) return 'bdtfx'; //:v1.01';
+		if (strpos($referentiel, 'bdnff') !== FALSE) {
+			return 'bdtfx';
-	if(strpos($referentiel, 'bdtxa') !== FALSE) return 'bdtxa'; //:v1.00';
+		}
+		if (strpos($referentiel, 'isfan') !== FALSE) {
+			return 'isfan'; //:v1.00';
-	//if(strpos($referentiel, 'bdnff') !== FALSE) return 'bdnff'; //:4.02';
+		}
+		if (strpos($referentiel, 'apd') !== FALSE) {
+			return 'apd'; //:v1.00';
 	if(strpos($referentiel, 'bdnff') !== FALSE) return 'bdtfx';
-	if(strpos($referentiel, 'isfan') !== FALSE) return 'isfan'; //:v1.00';
+		if (strpos($referentiel, 'autre') !== FALSE) {
+			return 'autre';
 	if(strpos($referentiel, 'apd') !== FALSE) return 'apd'; //:v1.00';
 	if(strpos($referentiel, 'autre') !== FALSE) return 'autre';
-	if($referentiel && isset($ligne[C_NOM_SEL]) && $ligne[C_NOM_SEL]) {
-	    trigger_error("ligne \"{$ref_ligne}\": Attention: référentiel \"{$referentiel}\" inconnu", E_USER_NOTICE);
+		if ($referentiel && isset($ligne[C_NOM_SEL]) && $ligne[C_NOM_SEL]) {
-	    return 'autre';
-	}
-	// pas de référentiel ou pas de NOM_SEL: NULL
+			$msg = "ligne «{$ref_ligne}»: Attention: référentiel «{$referentiel}» inconnu";
-	return NULL;
+			trigger_error($msg, E_USER_NOTICE);
-	/* TODO: cf story,
+			return 'autre';
+		}
-	   En cas de NULL faire une seconde passe de détection à partir du nom saisi
+		return NULL;
+	}
-	   + accepter les n° de version */
+	static function traiterLonLat($lon = NULL, $lat = NULL, $referentiel = 'bdtfx', $ref_ligne) {
+		// en CSV ces valeurs sont des string, avec séparateur en français (","; cf défauts dans ExportXLS)
 		if ($lon && is_string($lon)) {
 			$lon = str_replace(',', '.', $lon);
-    static function traiterLonLat($lon = NULL, $lat = NULL, $referentiel = 'bdtfx', $ref_ligne) {
+		}
+		if ($lat && is_string($lat)) {
+			$lat = str_replace(',', '.', $lat);
-	// en CSV ces valeurs sont des string, avec séparateur en français (","; cf défauts dans ExportXLS)
+		}
+		// sprintf applique une précision à 5 décimale (comme le ferait MySQL)
-	if($lon && is_string($lon)) $lon = str_replace(',', '.', $lon);
+		// tout en uniformisant le format de séparateur des décimales (le ".")
-	if($lat && is_string($lat)) $lat = str_replace(',', '.', $lat);
+		if ($lon && is_numeric($lon) && $lon >= -180 && $lon <= 180) {
 			return sprintf('%.5F', $lon);
 	// sprintf applique une précision à 5 décimale (comme le ferait MySQL)
-	// tout en uniformisant le format de séparateur des décimales (le ".")
+		if ($lat && is_numeric($lat) && $lat >= -90 && $lat <= 90) {
-	if($lon && is_numeric($lon) && $lon >= -180 && $lon <= 180) return sprintf('%.5F', $lon);
+			return sprintf('%.5F', $lat);
-	if($lat && is_numeric($lat) && $lat >= -90 && $lat <= 90) return sprintf('%.5F', $lat);
-	if($lon || $lat) {
-	    trigger_error("ligne \"{$ref_ligne}\": " .
-			  "Attention: longitude ou latitude erronée",
-			  E_USER_NOTICE);
-	}
-	return NULL;
-	/* limite france métropole si bdtfx ? ou bdtxa ? ...
-	   NON!
-	   Un taxon d'un référentiel donné peut être théoriquement observé n'importe où sur le globe.
-	   Il n'y a pas lieu d'effectuer des restriction ici.
-	   Cependant des erreurs fréquentes (0,0 ou lon/lat inversées) peuvent être détectés ici.
-	   TODO */
-	$bbox = self::getReferentielBBox($referentiel);
-	if(!$bbox) return NULL;
 	if($lon) {
 	    if($lon < $bbox['EST'] && $lon > $bbox['OUEST']) return is_numeric($lon) ? $lon : NULL;
-	    else return NULL;
+		if ($lon || $lat) {
 			trigger_error("ligne \"{$ref_ligne}\": " .
-	if($lat) {
+				  "Attention: longitude ou latitude erronée",
-	    if($lat < $bbox['NORD'] && $lat > $bbox['SUD']) return is_numeric($lat) ? $lat : NULL;
+				  E_USER_NOTICE);
 	    return NULL;
-	}
-    }
-    /*
-      TODO: s'affranchir du webservice pour la détermination du nom scientifique en s'appuyant sur cel_references,
-      pour des questions de performances
+		return NULL;
     */
     static function traiterEspece($ligne, Array &$espece, &$referentiel, $taxon_info_webservice) {
-	if(empty($ligne[C_NOM_SEL])) {
+	/*
-	    // TODO: nous ne déclarons pas "Numéro nomenclatural" comme colonne importable
+	  TODO: s'affranchir du webservice pour la détermination du nom scientifique en s'appuyant sur cel_references,
+	  pour des questions de performances
-	    // Nous ne pouvons donc pas tenter d'être sympa sur la détermination par num_nom
+	*/
+	static function traiterEspece($ligne, Array &$espece, &$referentiel, $taxon_info_webservice) {
-	    /* if(!empty($ligne[C_NOM_SEL_NN]) && $referentiel != Cel::$fallback_referentiel)
+		if (empty($ligne[C_NOM_SEL])) {
-	       $ligne[C_NOM_SEL] = $referentiel . ':nn:' . $ligne[C_NOM_SEL_NN];
+			return;
-	       else */
-	    return;
-	}
-	// nom_sel reste toujours celui de l'utilisateur
-	$espece[C_NOM_SEL] = trim($ligne[C_NOM_SEL]);
-	// XXX/attention, nous ne devrions pas accepter un référentiel absent !
-	if(!$referentiel) $referentiel = 'bdtfx';
-	$taxon_info_webservice->setReferentiel($referentiel);
-	$ascii = iconv('UTF-8', 'ASCII//TRANSLIT', $ligne[C_NOM_SEL]);
-	// TODO: si empty(C_NOM_SEL) et !empty(C_NOM_SEL_NN) : recherche info à partir de C_NOM_SEL_NN
-	// echo "rechercherInformationsComplementairesSurNom()\n";
 	/*
 	  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
 		// nom_sel reste toujours celui de l'utilisateur
-	  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
+		$espece[C_NOM_SEL] = trim($ligne[C_NOM_SEL]);
-	    return;
+			return;
+		}
-	// succès de la détection, mais résultat partiel
+		// succès de la détection, mais résultat partiel
+		if (!isset($determ->id)) {
-	if(!isset($determ->id))
+			$determ = $taxon_info_webservice->effectuerRequeteInfosComplementairesSurNumNom($determ->{"nom_retenu.id"});
+		}
-	    $determ = $taxon_info_webservice->effectuerRequeteInfosComplementairesSurNumNom($determ->{"nom_retenu.id"});
+		// ne devrait jamais arriver !
 		if (!$determ) {
-	// ne devrait jamais arriver !
+			die("erreur critique: " . __FILE__ . ':' . __LINE__);
 	if(!$determ) die("erreur critique: " . __FILE__ . ':' . __LINE__);
-	$espece[C_NOM_RET] = RechercheInfosTaxonBeta::supprimerBiblio($determ->nom_retenu_complet);
+		$espece[C_NOM_RET] = RechercheInfosTaxonBeta::supprimerBiblio($determ->nom_retenu_complet);
-	$espece[C_NOM_RET_NN] = $determ->{"nom_retenu.id"};
+		$espece[C_NOM_RET_NN] = $determ->{"nom_retenu.id"};
-	$espece[C_NT] = $determ->num_taxonomique;
+		$espece[C_NT] = $determ->num_taxonomique;
-	$espece[C_FAMILLE] = $determ->famille;
+		$espece[C_FAMILLE] = $determ->famille;
-	return;
+		return;
-	// et des info complémentaires
-	/*
-	// GET /service:eflore:0.1/bdtfx/noms/31468?retour.champs=nom_sci,auteur,id,nom_retenu_complet,nom_retenu.id,num_taxonomique,famille
-	/home/raphael/eflore/projets/services/modules/0.1/bdtfx/Noms.php:280
-	SELECT  *, nom_sci   FROM bdtfx_v1_01	 WHERE num_nom = '31468'
-	SELECT nom_sci, num_nom_retenu, nom_sci_html, auteur, annee, biblio_origine FROM bdtfx_v1_01 WHERE num_nom = 31468
-	SELECT nom_sci, num_nom_retenu, nom_sci_html, auteur, annee, biblio_origine FROM bdtfx_v1_01 WHERE num_nom = 86535
-	*/
-	//var_dump($complement, $espece);die;
+	}
-    static function detectFromNom($nom) {
+	static function detectFromNom($nom) {
-	$r = Cel::db()->requeter(sprintf("SELECT num_nom, num_tax_sup FROM bdtfx_v1_01 WHERE (nom_sci LIKE '%s') ".
+		$r = Cel::db()->requeter(sprintf("SELECT num_nom, num_tax_sup FROM bdtfx_v1_01 WHERE (nom_sci LIKE '%s') ".
-					 "ORDER BY nom_sci ASC LIMIT 0, 1",
+			"ORDER BY nom_sci ASC LIMIT 0, 1",
+			Cel::db()->proteger($nom)));
-					 Cel::db()->proteger($nom)));
+		if ($r) {
+			return $r;
 	if($r) return $r;
-	Cel::db()->requeter(sprintf("SELECT num_nom, num_tax_sup FROM bdtfx_v1_01 WHERE (nom_sci LIKE '%s' OR nom LIKE '%s') ".
+		Cel::db()->requeter(sprintf("SELECT num_nom, num_tax_sup FROM bdtfx_v1_01 WHERE (nom_sci LIKE '%s' OR nom LIKE '%s') ".
-				    "ORDER BY nom_sci ASC LIMIT 0, 1",
+			"ORDER BY nom_sci ASC LIMIT 0, 1",
-				    Cel::db()->proteger($nom),
+			Cel::db()->proteger($nom),
-				    Cel::db()->proteger(str_replace(' ', '% ', $nom))));
+			Cel::db()->proteger(str_replace(' ', '% ', $nom))));
-	return $r;
-    }
-    /*
-     * TODO: analyse rigoureuse:
-     * == Identifiant Commune
-     * - INSEE-C:\d{5}
-     * - \d{5}
-     * - \d{2}
-     * == Commune
-     * - \w+ (\d{2})
-     * - \w+ (\d{5})
-     * - \w+
+		return $r;
-     *
+	}
+	static function traiterLocalisation($ligne, Array &$localisation) {
-     */
+		if (empty($ligne[C_ZONE_GEO])) {
+			$ligne[C_ZONE_GEO] = NULL;
+		}
-    static function traiterLocalisation($ligne, Array &$localisation) {
+		if (empty($ligne[C_CE_ZONE_GEO])) {
-	if(empty($ligne[C_ZONE_GEO])) $ligne[C_ZONE_GEO] = NULL;
+			$ligne[C_CE_ZONE_GEO] = NULL;
 	if(empty($ligne[C_CE_ZONE_GEO])) $ligne[C_CE_ZONE_GEO] = NULL;
-	$identifiant_commune = trim($ligne[C_ZONE_GEO]);
+		$identifiant_commune = trim($ligne[C_ZONE_GEO]);
-	if(!$identifiant_commune) {
+		if (!$identifiant_commune) {
-	    $departement = trim($ligne[C_CE_ZONE_GEO]);
+			$departement = trim($ligne[C_CE_ZONE_GEO]);
-	    if(strpos($departement, "INSEE-C:", 0) === 0) {
-		$localisation[C_CE_ZONE_GEO] = trim($ligne[C_CE_ZONE_GEO]);
+			if (strpos($departement, 'INSEE-C:', 0) === 0) {
-		if(array_key_exists($localisation[C_CE_ZONE_GEO], self::$cache['geo'])) {
+				$localisation[C_CE_ZONE_GEO] = trim($ligne[C_CE_ZONE_GEO]);
+				if (array_key_exists($localisation[C_CE_ZONE_GEO], self::$cache['geo'])) {
-		    $localisation[C_ZONE_GEO] = self::$cache['geo'][$localisation[C_CE_ZONE_GEO]];
+					$localisation[C_ZONE_GEO] = self::$cache['geo'][$localisation[C_CE_ZONE_GEO]];
+				} else {
 					$nom = Cel::db()->requeter(sprintf("SELECT nom FROM cel_zones_geo WHERE code = %s LIMIT 1",
-		else {
+						self::quoteNonNull(substr($localisation[C_CE_ZONE_GEO], strlen("INSEE-C:")))));
-		    $nom = Cel::db()->requeter(sprintf("SELECT nom FROM cel_zones_geo WHERE code = %s LIMIT 1",
+					if ($nom) {
-						       self::quoteNonNull(substr($localisation[C_CE_ZONE_GEO], strlen("INSEE-C:")))));
+						$localisation[C_ZONE_GEO] = $nom[0]['nom'];
-		    $localisation[C_CE_ZONE_GEO] = self::$cache['geo'][$departement][1];
+					$localisation[C_CE_ZONE_GEO] = self::$cache['geo'][$departement][1];
-		    return;
+					return;
+				}
+			}
+			$requete = "SELECT DISTINCT nom, CONCAT('INSEE-C:', code) AS code ".
+				'FROM cel_zones_geo '.
+				'WHERE code = %s '.
+				'LIMIT 1 '.
+				' -- '.__FILE__.':'.__LINE__;
-	    if(! $cache_attempted && ($resultat_commune = Cel::db()->requeter(sprintf("SELECT DISTINCT nom, CONCAT('INSEE-C:', code) AS code FROM cel_zones_geo WHERE code = %s LIMIT 1",
+			$resultat_commune = Cel::db()->requeter(sprintf($requete, self::quoteNonNull($departement)));
-										      self::quoteNonNull($departement)))) ) {
+			if (! $cache_attempted && $resultat_commune) {
-		$localisation[C_ZONE_GEO] = $resultat_commune[0]['nom'];
+				$localisation[C_ZONE_GEO] = $resultat_commune[0]['nom'];
-		$localisation[C_CE_ZONE_GEO] = $resultat_commune[0]['code'];
+				$localisation[C_CE_ZONE_GEO] = $resultat_commune[0]['code'];
-		self::$cache['geo'][$departement] = array($resultat_commune[0]['nom'], $resultat_commune[0]['code']);
+				self::$cache['geo'][$departement] = array($resultat_commune[0]['nom'], $resultat_commune[0]['code']);
-		return;
+				return;
-	    }
-	    ;
-	    // if(strlen($departement) == 4) $departement = "INSEE-C:0" . $departement;
-	    // if(strlen($departement) == 5) $departement = "INSEE-C:" . $departement;
-	    // if(strlen($departement) <= 9) return "INSEE-C:0" . $departement; // ? ... TODO
-	    $departement = trim($departement); // TODO
+			}
-	    $localisation[C_CE_ZONE_GEO] = $ligne[C_CE_ZONE_GEO];
+			$localisation[C_CE_ZONE_GEO] = $ligne[C_CE_ZONE_GEO];
-	    return;
+			return;
-	}
+		}
-	$select = "SELECT DISTINCT nom, code FROM cel_zones_geo";
+		$select = "SELECT DISTINCT nom, code FROM cel_zones_geo";
-	if (preg_match('/(.+) \((\d{1,5})\)/', $identifiant_commune, $elements)) {
+		if (preg_match('/(.+) \((\d{1,5})\)/', $identifiant_commune, $elements)) {
-	    // commune + departement : montpellier (34)
+			// commune + departement : montpellier (34)
-	    $nom_commune=$elements[1];
+			$nom_commune=$elements[1];
-	    $code_commune=$elements[2];
+			$code_commune=$elements[2];
-	    if(strlen($code_commune) <= 2) {
+			if (strlen($code_commune) <= 2) {
-		$requete = sprintf("%s WHERE nom = %s AND code LIKE %s",
-				   $select, self::quoteNonNull($nom_commune),
+				$requete = sprintf("%s WHERE nom = %s AND code LIKE %s",
-				   self::quoteNonNull($code_commune.'%'));
+					$select, self::quoteNonNull($nom_commune),
 					self::quoteNonNull($code_commune.'%'));
-	    else {
+			} else {
-		$requete = sprintf("%s WHERE nom = %s AND code = %d",
+				$requete = sprintf("%s WHERE nom = %s AND code = %d",
-				   $select, self::quoteNonNull($nom_commune),
-				   $code_commune);
+					$select, self::quoteNonNull($nom_commune),
 					$code_commune);
+			}
-	elseif (preg_match('/^(\d+|(2[ab]\d+))$/i', $identifiant_commune, $elements)) {
+		} elseif (preg_match('/^(\d+|(2[ab]\d+))$/i', $identifiant_commune, $elements)) {
-	    // Code insee seul
-	    $code_insee_commune=$elements[1];
+			// Code insee seul
-	    $requete = sprintf("%s WHERE code = %s", $select, self::quoteNonNull($code_insee_commune));
+			$code_insee_commune=$elements[1];
 			$requete = sprintf("%s WHERE code = %s", $select, self::quoteNonNull($code_insee_commune));
-	else {
+		} else {
-	    // Commune seule (le departement sera recupere dans la colonne departement si elle est presente)
+			// Commune seule (le departement sera recupere dans la colonne departement si elle est presente)
-	    // on prend le risque ici de retourner une mauvaise Commune
+			// on prend le risque ici de retourner une mauvaise Commune
-	    $nom_commune = str_replace(" ", "%", iconv('UTF-8', 'ASCII//TRANSLIT', $identifiant_commune));
-	    $requete = sprintf("%s WHERE nom LIKE %s", $select, self::quoteNonNull($nom_commune.'%'));
+			$nom_commune = str_replace(" ", "%", iconv('UTF-8', 'ASCII//TRANSLIT', $identifiant_commune));
 			$requete = sprintf("%s WHERE nom LIKE %s", $select, self::quoteNonNull($nom_commune.'%'));
+		}
 	if(array_key_exists($identifiant_commune, self::$cache['geo'])) {
-	    $resultat_commune = self::$cache['geo'][$identifiant_commune];
+		if (array_key_exists($identifiant_commune, self::$cache['geo'])) {
 			$resultat_commune = self::$cache['geo'][$identifiant_commune];
-	else {
-	    $resultat_commune = Cel::db()->requeter($requete);
-	    self::$cache['geo'][$identifiant_commune] = $resultat_commune;
+		} else {
 			$resultat_commune = Cel::db()->requeter($requete);
-	// TODO: levenstein sort ?
+			self::$cache['geo'][$identifiant_commune] = $resultat_commune;
 	// TODO: count résultat !
-	if(strpos($departement, "INSEE-C:", 0) === 0) {
+		if (strpos($departement, "INSEE-C:", 0) === 0) {
-	    $localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
+			$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
-	    $localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
+			$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
+		}
-	if(!is_numeric($departement)) {
+		if (!is_numeric($departement)) {
-	    $localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
+			$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
-	    $localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
+			$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
+		}
-	}
+		if (strlen($departement) == 4) {
+			$departement = "INSEE-C:0$departement";
-	if(strlen($departement) == 4) $departement = "INSEE-C:0" . $departement;
+		}
-	if(strlen($departement) == 5) $departement = "INSEE-C:" . $departement;
+		if (strlen($departement) == 5) {
-	// if(strlen($departement) <= 9) return "INSEE-C:0" . $departement; // ? ... TODO
+			$departement = "INSEE-C:$departement";
+		}
-	$departement = trim($departement); // TODO
+		$departement = trim($departement);
-	$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
-	$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
+		$localisation[C_ZONE_GEO] = $localisation[C_ZONE_GEO];
 		$localisation[C_CE_ZONE_GEO] = $localisation[C_CE_ZONE_GEO];
+	}
-    public static function stockerChampsEtendus($champs_etendus, $ordre_ids, $config) {
+	public static function stockerChampsEtendus($champs_etendus, $ordre_ids, $config) {
-    				$champs_etendus_obs[] = $champ_etendu_a_inserer;
+					$champs_etendus_obs[] = $champ_etendu_a_inserer;
+				}
+			}
+		}
-    	$insertion = self::$gestion_champs_etendus->ajouterParLots($champs_etendus_obs);
+		self::$gestion_champs_etendus->ajouterParLots($champs_etendus_obs);
-    	//TODO: que faire si l'insertion des champs étendus échoue ?
+		//TODO: que faire si l'insertion des champs étendus échoue ?
-    	return count($champs_etendus_obs);
+		return count($champs_etendus_obs);
+	}
-	return $ordered + $array;
+		return $ordered + $array;
+	}
-    // retourne une BBox [N,S,E,O) pour un référentiel donné
+	// retourne une BBox [N,S,E,O) pour un référentiel donné
-    static function getReferentielBBox($referentiel) {
+	static function getReferentielBBox($referentiel) {
+		if ($referentiel == 'bdtfx') {
-	if($referentiel == 'bdtfx') return Array(
+			return Array(
-	    'NORD' => 51.2, // Dunkerque
+				'NORD' => 51.2, // Dunkerque
-	    'SUD' => 41.3, // Bonifacio
+				'SUD' => 41.3, // Bonifacio
-	    'EST' => 9.7, // Corse
+				'EST' => 9.7, // Corse
+				'OUEST' => -5.2); // Ouessan
 	    'OUEST' => -5.2); // Ouessan
-	return FALSE;
+		return FALSE;
+	}
-    // ces valeurs ne sont pas inséré via les placeholders du PDO::preparedStatement
+	// ces valeurs ne sont pas inséré via les placeholders du PDO::preparedStatement
-    // et doivent donc être échappées correctement.
+	// et doivent donc être échappées correctement.
-    public function initialiser_colonnes_statiques() {
+	public function initialiser_colonnes_statiques() {
-	$this->colonnes_statiques = array_merge($this->colonnes_statiques,
+		$this->colonnes_statiques = array_merge($this->colonnes_statiques,
-						Array(
+			array(
-						    "ce_utilisateur" => self::quoteNonNull($this->id_utilisateur), // peut-être un hash ou un id
+				'ce_utilisateur' => self::quoteNonNull($this->id_utilisateur), // peut-être un hash ou un id
-						    "prenom_utilisateur" => self::quoteNonNull($this->utilisateur['prenom']),
+				'prenom_utilisateur' => self::quoteNonNull($this->utilisateur['prenom']),
-						    "nom_utilisateur" => self::quoteNonNull($this->utilisateur['nom']),
+				'nom_utilisateur' => self::quoteNonNull($this->utilisateur['nom']),
-						    "courriel_utilisateur" => self::quoteNonNull($this->utilisateur['courriel']),
-						));
+				'courriel_utilisateur' => self::quoteNonNull($this->utilisateur['courriel']),
 			));
+	}
+	}
-    // équivalent à Bdd2->proteger() (qui wrap PDO::quote),
+	// équivalent à Bdd2->proteger() (qui wrap PDO::quote),
-    // sans transformer NULL en ""
+	// sans transformer NULL en ""
-    static function quoteNonNull($chaine) {
+	static function quoteNonNull($chaine) {
+		if (is_null($chaine)) {
+			return 'NULL';
 	if(is_null($chaine)) return "NULL";
-	if(!is_string($chaine) && !is_integer($chaine)) {
+		if (!is_string($chaine) && !is_integer($chaine)) {
-	    die("erreur: " . __FILE__ . ':' . __LINE__);
+			die('erreur: ' . __FILE__ . ':' . __LINE__);
+		}
-	return Cel::db()->quote($chaine);
+		return Cel::db()->quote($chaine);
+	}

Subversion Repositories eFlore/Applications.cel

(root)/trunk/jrest/services/ImportXLS.php – Rev 2394 → 2447