WebSVN – eFlore/Applications.cel – Diff – /branches/v3.01-serpe/jrest/services/ImportXLS.php

 		"latitude",
 		"longitude");
 	/*
 	  Ces colonnes:
-	  - sont propre à tous les enregistrements uploadés
+	  - sont propres à l'ensemble des enregistrements uploadés
 	  - sont indépendantes du numéro de lignes
 	  - n'ont pas de valeur par défaut dans la structure de la table
 	  - nécessitent une initialisation dans le cadre de l'upload
 	*/
 	public $colonnes_statiques = Array(
 		"ce_utilisateur" => NULL,
 		"prenom_utilisateur" => NULL,
 		"nom_utilisateur" => NULL,
+		"courriel_utilisateur" => NULL,
-		"courriel_utilisateur" => NULL,
 		// fixes (fonction SQL)
-		// XXX: fixes (mais pourraient varier dans le futur si la mise-à-jour
+		// XXX future: mais pourraient varier dans le futur si la mise-à-jour
 		// d'observation est implémentée
-		"date_creation" => NULL, // ne peut initialiser d'une date ici
+		"date_creation" => "now()",
+		"date_modification" => "now()",
+	);
+	public $id_utilisateur = NULL;
-		"date_modification" => NULL, // idem, cf initialiser_colonnes_statiques()
+	// erreurs d'import
-	);
+	public $bilan = Array();
 	function ExportXLS($config) {
 		parent::__construct($config);
+	}
 	function createElement($pairs) {
+		if(!isset($pairs['utilisateur']) || trim($pairs['utilisateur']) == '') {
-		if(!isset($pairs['utilisateur']) || trim($pairs['utilisateur']) == '') {
+			echo '0'; exit;
 			echo '0'; exit;
 		$id_utilisateur = intval($pairs['utilisateur']);
 		$objReader->setReadDataOnly(true);
 		$objPHPExcel = $objReader->load($infos_fichier['tmp_name']);*/
+		//var_dump($donnees);
+		// renomme le fichier pour lui ajouter son extension initiale, ce qui
+		// permet (une sorte) d'autodétection du format.
+		$fichier = $infos_fichier['tmp_name'];
+		$extension = pathinfo($infos_fichier['name'], PATHINFO_EXTENSION);
+		if( (strlen($extension) == 3 || strlen($extension) == 4) &&
+			(rename($fichier, $fichier . '.' . $extension))) {
+			$fichier = $fichier . '.' . $extension;
-		//var_dump($donnees);
+		}
+		$objReader = PHPExcel_IOFactory::createReaderForFile($fichier);
+		$objReader->setReadDataOnly(true);
+		if(is_a($objReader, 'PHPExcel_Reader_CSV')) {
+			$objReader->setDelimiter(',')
+				->setEnclosure('"')
+				->setLineEnding("\n")
-		$objReader = PHPExcel_IOFactory::createReader("Excel5");
+				->setSheetIndex(0);
 		$objReader->setReadDataOnly(true);
 		// on ne conserve que l'en-tête
 		$filtre = new MyReadFilter();
 		$filtre->def_interval(1, 2);
 		$objReader->setReadFilter($filtre);
-		$objPHPExcel = $objReader->load($infos_fichier['tmp_name']);
+		$objPHPExcel = $objReader->load($fichier);
-		$obj_infos = $objReader->listWorksheetInfo($infos_fichier['tmp_name']);
+		$obj_infos = $objReader->listWorksheetInfo($fichier);
 		$obs_maj = 0;
 		$dernier_ordre = $this->requeter("SELECT MAX(ordre) AS ordre FROM cel_obs WHERE ce_utilisateur = $id_utilisateur");
 		$dernier_ordre = intval($dernier_ordre[0]['ordre']) + 1;
 		if(! $dernier_ordre) $dernier_ordre = 0;
+		// on catch to les trigger_error(E_USER_NOTICE);
+		set_error_handler(array($this, 'erreurs_stock'), E_USER_NOTICE);
 		// lecture par morceaux (chunks), NB_LIRE_LIGNE_SIMUL lignes à fois
 		// 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) {
 			$filtre->def_interval($ligne, NB_LIRE_LIGNE_SIMUL);
 			$objReader->setReadFilter($filtre);
 			/* recharge avec $filtre actif (filtre sur lignes colonnes):
 			   - exclue les colonnes inutiles/inutilisables)
 			   - ne selectionne que les lignes dans le range [$ligne - $ligne + NB_LIRE_LIGNE_SIMUL] */
-			$objPHPExcel = $objReader->load($infos_fichier['tmp_name']);
+			$objPHPExcel = $objReader->load($fichier);
 			$donnees = $objPHPExcel->getActiveSheet()->toArray(NULL, FALSE, FALSE, TRUE);
 			// ici on appel la fonction qui fera effectivement l'insertion multiple
+			// à partir des (au plus) NB_LIRE_LIGNE_SIMUL lignes
-			// à partir des (au plus) NB_LIRE_LIGNE_SIMUL lignes
+			// TODO: passer $this, ne sert que pour appeler des méthodes public qui pourraient être statiques
+			// notamment dans RechercheInfosTaxonBeta.php
+			list($enregistrements, $images) =
+				self::chargerLignes($this, $donnees, $this->colonnes_statiques, $dernier_ordre);
+			if(! $enregistrements) break;
 			$dernier_autoinc = self::stockerEnregistrements($this, $enregistrements);
+			$obs_ajouts += count($enregistrements);
-			// TODO: passer $this, ne sert que pour appeler des méthodes public qui pourraient être statiques
+			// $obs_maj += count($enregistrements_a_MAJ);
+			self::stockerImages($this, $enregistrements, $images, $dernier_autoinc);
+		}
+		restore_error_handler();
 			// notamment dans RechercheInfosTaxonBeta.php
-			self::chargerLignes($donnees, $this->colonnes_statiques, $dernier_ordre, $this, $obs_ajouts, $obs_maj);
+		if($this->bilan) echo implode("\n", $this->bilan) . "\n";
 		// fin: renvoi summary
-		die('end');
+		die("$obs_ajouts observations ajoutées");
 			$entete_simple = iconv('UTF-8', 'ASCII//TRANSLIT', strtolower(trim($v)));
 			foreach($cols as $col) {
 				$entete_officiel_simple = iconv('UTF-8', 'ASCII//TRANSLIT', strtolower(trim($col['nom'])));
 				$entete_officiel_abbrev = $col['abbrev'];
 				if($entete_simple == $entete_officiel_simple || $entete_simple == $entete_officiel_abbrev) {
-					// debug echo "define C_" . strtoupper($entete_officiel_abbrev) . ", $k\n";
+					//debug echo "define C_" . strtoupper($entete_officiel_abbrev) . ", $k ($v)\n";
 					define("C_" . strtoupper($entete_officiel_abbrev), $k);
 					$colonnes_reconnues[$k] = 1;
 					break;
+				}
+			}
+	}
 	/*
 	 * charge un groupe de lignes
 	 */
-	static function chargerLignes($lignes, $colonnes_statiques, &$dernier_ordre, $cel, &$inserted, &$updated) {
+	static function chargerLignes($cel, $lignes, $colonnes_statiques, &$dernier_ordre) {
 		$enregistrement = NULL;
 		$enregistrements = Array();
-		$images = Array();
+		$toutes_images = Array();
 		foreach($lignes as $ligne) {
+			//$ligne = array_filter($ligne, function($cell) { return !is_null($cell); });
+			//if(!$ligne) 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, function($cell) { return !is_null($cell); })) continue;
-			if( ($enregistrement = self::chargerLigne($ligne, $colonnes_statiques, $dernier_ordre, $cel)) ) {
+			if( ($enregistrement = self::chargerLigne($ligne, $dernier_ordre, $cel)) ) {
+				$enregistrements[] = array_merge($colonnes_statiques, $enregistrement);
 				$enregistrements[] = $enregistrement;
 				if(isset($enregistrement['_images'])) {
-				if(isset($enregistrement['_images'])) {
+					$pos = count($enregistrements) - 1;
-					$pos = count($enregistrements) - 1;
+					$last = &$enregistrements[$pos];
 					// 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
-					$images[] = Array("text" => $enregistrements[$pos]['_images'],
+					$toutes_images[] = Array("images" => $last['_images'],
-									  "obs_pos" => $pos);
+											 "obs_pos" => $pos);
 					// ce champ n'a pas a faire partie de l'insertion dans cel_obs,
 					// mais est utile pour cel_obs_images
-					unset($enregistrements[$pos]['_images']);
+					unset($last['_images']);
+				}
-				}
+				$dernier_ordre++;
+			}
+		}
-				$dernier_ordre++;
-			}
+		// XXX future: return Array($enregistrements_a_inserer, $enregistrements_a_MAJ, $toutes_images);
-		}
+		return Array($enregistrements, $toutes_images);
+	}
+	static function stockerEnregistrements($cel, $enregistrements) {
+		$req = '';
+		foreach($enregistrements as $enregistrement) {
-		if(!$enregistrements) die('AIE // XXX');
+			$enregistrement = self::sortArrayByArray($enregistrement, self::$ordre_BDD);
 			array_walk($enregistrement,
-		$req = '';
+					   function(&$item, $k, $obj) { $item = is_null($item) ? "NULL" : $item; },
+					   $cel);
+			$req .= implode(', ', $enregistrement) . "\n";
+		}
+		echo "$req\n";
+		// TODO: insert
+		// $cel->executer($req);
+		// transactionnel + auto-inc
+		return $cel->bdd->lastInsertId();
+	}
+	static function stockerImages($cel, $enregistrements, $toutes_images, $lastid) {
+		if(! $lastid) $lastid = rand();
 		foreach($enregistrements as $enregistrement)
-			$req .= implode(', ', self::sortArrayByArray($enregistrement, self::$ordre_BDD));
+		$images_insert =
-		print_r($req);
+			'INSERT INTO cel_obs_images (id_image, id_observation) VALUES'
+			.' %s '
+			.'ON DUPLICATE KEY UPDATE id_image = id_image';
+		$images_obs_assoc = Array();
+		foreach($toutes_images as $images_pour_obs) {
+			$obs = $enregistrements[$images_pour_obs["obs_pos"]];
+			$id_obs = $lastid // dernier autoinc inséré
+				- count($enregistrements) - 1 // correspondrait au premier autoinc
+				+ $images_pour_obs["obs_pos"]; // ordre d'insertion = ordre dans le tableau $enregistrements
+			foreach($images_pour_obs['images'] as $image) {
-		// $cel->executer($req);
+				$images_obs_assoc[] = sprintf('(%d,%d)',
-		// transactionnel + auto-inc
+											  $image['id_image'], // intval() useless
-		$lastid = $cel->bdd->lastInsertId();
+											  $id_obs); // intval() useless
 		foreach($images as $image) {
 			$obs = $enregistrements[$image["obs_pos"]];
 			$id_obs = $lastid // dernier autoinc inséré
-				- count($enregistrements) - 1 // correspondrait au premier autoinc
+		if($images_obs_assoc) {
-				+ $image["obs_pos"]; // ordre d'insertion = ordre dans le tableau $enregistrements
+			$requete = sprintf($images_insert, implode(', ', $images_obs_assoc));
+			echo "$requete\n";
 			// TODO: INSERT
+	}
-		}
+	static function chargerLigne($ligne, $dernier_ordre, $cel) {
 		// en premier car le résultat est utile pour
 		// traiter longitude et latitude (traiterLonLat())
+		$referentiel = self::identReferentiel($ligne[C_NOM_REFERENTIEL]);
 	static function chargerLigne($ligne, $colonnes_statiques, $dernier_ordre, $cel) {
+		// $espece est rempli de plusieurs informations
-		// en premier car le résultat est utile pour
+		$espece = Array(C_NOM_SEL => NULL, C_NOM_SEL_NN => NULL, C_NOM_RET => NULL,
-		// traiter longitude et latitude (traiterLonLat())
+						C_NOM_RET_NN => NULL, C_NT => NULL, C_FAMILLE => NULL);
-		$referentiel = self::identReferentiel($ligne[C_NOM_REFERENTIEL]);
+		self::traiterEspece($ligne, $espece, $cel);
-		// $espece est rempli de plusieurs informations
+		// $localisation est rempli à partir de plusieurs champs: C_ZONE_GEO et C_CE_ZONE_GEO
-		$espece = Array();
+		$localisation = Array(C_ZONE_GEO => NULL, C_CE_ZONE_GEO => NULL);
-		self::traiterEspece($ligne, $espece, $cel);
+		self::traiterLocalisation($ligne, $localisation, $cel);
+		// Dans ce tableau, seules devraient apparaître les données variable pour chaque ligne.
-		return array_merge($colonnes_statiques,
+		// Dans ce tableau, l'ordre des clefs n'importe pas (cf: self::sortArrayByArray())
+		$enregistrement = Array(
+			"ordre" => $dernier_ordre,
+			// $this->quoteNonNull() est déjà appliquée dans traiterEspece()
+			"nom_sel" => $espece[C_NOM_SEL],
+			"nom_sel_nn" => $espece[C_NOM_SEL_NN],
+			"nom_ret" => $espece[C_NOM_RET],
+			"nom_ret_nn" => $espece[C_NOM_RET_NN],
-						   // Dans ce tableau, seules devraient apparaître les données variable pour chaque ligne.
-						   // Dans ce tableau, l'ordre des clefs n'importe pas (cf: self::sortArrayByArray())
-						   Array(
-							   "ordre" => $dernier_ordre,
-							   "nom_sel" => $espece[C_NOM_SEL],
+			"nt" => $espece[C_NT],
+			"famille" => $espece[C_FAMILLE],
-							   "nom_sel_nn" => $espece[C_NOM_SEL_NN],
-							   "nom_ret" => $espece[C_NOM_RET],
+			"nom_referentiel" => $cel->quoteNonNull($referentiel),
-							   "nom_ret_nn" => $espece[C_NOM_RET_NN],
+			// $this->quoteNonNull() est déjà appliquée dans traiterLocalisation()
+			"zone_geo" => $localisation[C_ZONE_GEO],
+			"ce_zone_geo" => $localisation[C_CE_ZONE_GEO],
+			// $ligne: uniquement pour les infos en cas de gestion d'erreurs (date incompréhensible)
+			"date_observation" => $cel->quoteNonNull(self::traiterDateObs($ligne[C_DATE_OBSERVATION], $ligne)),
-							   "nt" => $espece[C_NT],
+			"lieudit" => $cel->quoteNonNull(trim($ligne[C_LIEUDIT])),
+			"station" => $cel->quoteNonNull(trim($ligne[C_STATION])),
+			"milieu" => $cel->quoteNonNull(trim($ligne[C_MILIEU])),
+			"commentaire" => $cel->quoteNonNull(trim($ligne[C_COMMENTAIRE])), // TODO: foreign-key
+			"transmission" => in_array(strtolower(trim($ligne[C_TRANSMISSION])), array(1, 'oui')) ? 1 : 0,
+			// $ligne: uniquement pour les infos en cas de gestion d'erreurs (lon/lat incompréhensible)
+			"latitude" => self::traiterLonLat(NULL, $ligne[C_LATITUDE], $referentiel, $ligne),
+			"longitude" => self::traiterLonLat($ligne[C_LONGITUDE], NULL, $referentiel, $ligne),
+		);
+		// passage de $enregistrement par référence, ainsi ['_images'] n'est défini
+		// que si des résultats sont trouvés
-							   "famille" => $espece[C_FAMILLE],
+		// "@" car PHPExcel supprime les colonnes null sur toute la feuille (ou tout le chunk)
 		if(@$ligne[C_IMAGES]) self::traiterImage($ligne[C_IMAGES], $cel, $enregistrement);
 							   "nom_referentiel" => $referentiel,
 		return $enregistrement;
-							   "zone_geo" => TODO,
+	}
 							   "ce_zone_geo" => self::traiterDepartement(trim($ligne[C_CE_ZONE_GEO])),
 	static function traiterImage($str, $cel, &$enregistrement) {
-							   "date_observation" => self::traiterDateObs($ligne[C_DATE_OBSERVATION]),
+		$liste_images = array_filter(explode("/", $str));
-							   "lieudit" => trim($ligne[C_LIEUDIT]),
+		array_walk($liste_images,
+				   function($item, $key, $obj) { $item = $obj->quoteNonNull(trim($item)); },
+				   $cel);
+		$requete = sprintf(
+			"SELECT id_image, nom_original FROM cel_images WHERE ce_utilisateur = %d AND nom_original IN (\"%s\")",
-							   "station" => trim($ligne[C_STATION]),
+			$cel->id_utilisateur,
-							   "milieu" => trim($ligne[C_MILIEU]),
+			implode('","', $liste_images));
 							   "commentaire" => trim($ligne[C_COMMENTAIRE]), // TODO: foreign-key
 		$resultat = $cel->requeter($requete);
 			// echo strftime("%Y/%m/%d 00:00:00", $timestamp); // NON
+		}
 		else {
 			$timestamp = strtotime($date);
+			if(! $timestamp) {
+				if($date) trigger_error("ligne \"{$ligne[C_NOM_SEL]}\": Attention: date erronée ($date)", E_USER_NOTICE);
+				return NULL;
 			if(!$timestamp) return NULL; // TODO: throw error
 			return strftime("%Y-%m-%d 00:00:00", strtotime($date));
+		}
+	}
 	static function identReferentiel($referentiel) {
 		// SELECT DISTINCT nom_referentiel, COUNT(id_observation) AS count FROM cel_obs GROUP BY nom_referentiel ORDER BY count DESC;
 		if(strpos(strtolower($referentiel), 'bdtfx') !== FALSE) return 'bdtfx:v1.01';
 		if(strpos(strtolower($referentiel), 'bdtxa') !== FALSE) return 'bdtxa:v1.00';
+		if(strpos(strtolower($referentiel), 'bdnff') !== FALSE) return 'bdnff:4.02';
+		if(strpos(strtolower($referentiel), 'isfan') !== FALSE) return 'isfan:v1.00';
+		if($referentiel) {
-		if(strpos(strtolower($referentiel), 'bdnff') !== FALSE) return 'bdnff:4.02';
+			trigger_error("ligne \"{$ligne[C_NOM_SEL]}\": Attention: référentiel inconnu", E_USER_NOTICE);
 		if(strpos(strtolower($referentiel), 'isfan') !== FALSE) return 'isfan:v1.00';
 		return NULL;
+		/* TODO: cf story,
+		   En cas de NULL faire une seconde passe de détection à partir du nom saisi
+		   + accepter les n° de version */
+	}
+	static function traiterLonLat($lon = NULL, $lat = NULL, $referentiel = 'bdtfx:v1.01', $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);
+		if($lat && is_string($lat)) $lat = str_replace(',', '.', $lat);
+		// 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($lon && is_numeric($lon) && $lon >= -180 && $lon <= 180) return sprintf('%.5F', $lon);
+		if($lat && is_numeric($lat) && $lat >= -90 && $lat <= 90) return sprintf('%.5F', $lat);
+		if($lon || $lat) {
+			trigger_error("ligne \"{$ligne[C_NOM_SEL]}\": " .
-		/* TODO: cf story,
+						  "Attention: longitude ou latitude erronée",
+						  E_USER_NOTICE);
+		}
-		   En cas de NULL faire une seconde passe de détection à partir du nom saisie */
+		return NULL;
 		/* limite france métropole si bdtfx ? ou bdtxa ? ...
-	/* NON!
+		   NON!
-	   Un taxon d'un référentiel donné peut être théoriquement observé n'importe où sur le globe.
+		   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 */
-	static function traiterLonLat($lon = NULL, $lat = NULL, $referentiel = 'bdtfx:v1.01') {
-		// verifier format decimal +
+		   Il n'y a pas lieu d'effectuer des restriction ici.
-		// + limite france si bdtfx ou bdtxa
+		   Cependant des erreurs fréquentes (0,0 ou lon/lat inversées) peuvent être détectés ici.
 		   TODO */
 		$bbox = self::getReferentielBBox($referentiel);
+		}
+	}
+	static function traiterEspece($ligne, Array &$espece, $cel) {
 		if(!$ligne[C_NOM_SEL]) return;
 	static function traiterEspece($ligne, Array &$espece, $cel) {
+		$taxon_info_webservice = new RechercheInfosTaxonBeta($cel->config);
 		$taxon_info_webservice = new RechercheInfosTaxonBeta($cel->config);
 		$ascii = iconv('UTF-8', 'ASCII//TRANSLIT', $ligne[C_NOM_SEL]);
-		$ascii = iconv('UTF-8', 'ASCII//TRANSLIT', $ligne[C_NOM_SEL]);
+		// FALSE = recherche étendue (LIKE x%)
 		$resultat_recherche_espece = $taxon_info_webservice->rechercherInfosSurTexteCodeOuNumTax($ligne[C_NOM_SEL]);
-		// on supprime les noms retenus et renvoi tel quel
+		// on supprime les noms retenus et renvoi tel quel
 		// on réutilise les define pour les noms d'indexes, tant qu'à faire
+		if (empty($resultat_recherche_espece['en_id_nom'])) {
-		if (empty($resultat_recherche_espece['en_id_nom'])) {
+			$espece[C_NOM_SEL] = $cel->quoteNonNull(trim($ligne[C_NOM_SEL]));
 			$espece[C_NOM_SEL] = $ligne[C_NOM_SEL];
-			$espece[C_NOM_SEL_NN] = $ligne[C_NOM_SEL_NN];
+			// le reste reste à NULL
 			// TODO: si empty(C_NOM_SEL) et !empty(C_NOM_SEL_NN) : recherche info à partir de C_NOM_SEL_NN
-			// TODO: si empty(C_NOM_SEL) et !empty(C_NOM_SEL_NN) : recherche info à partir de C_NOM_SEL_NN
+			$espece[C_NOM_SEL_NN] = $ligne[C_NOM_SEL_NN];
 			$espece[C_NOM_RET] = $ligne[C_NOM_RET];
 			$espece[C_NOM_RET_NN] = $ligne[C_NOM_RET_NN];
 			$espece[C_NT] = $ligne[C_NT];
 			$espece[C_FAMILLE] = $ligne[C_FAMILLE];
 			return;
 		}
 		// succès de la détection, récupération des infos
+		$espece[C_NOM_SEL] = $cel->quoteNonNull($resultat_recherche_espece['nom_sel']);
+		$espece[C_NOM_SEL_NN] = $cel->quoteNonNull($resultat_recherche_espece['en_id_nom']);
+		$complement = $taxon_info_webservice->rechercherInformationsComplementairesSurNumNom($resultat_recherche_espece['en_id_nom']);
+		$espece[C_NOM_RET] = $cel->quoteNonNull($complement['Nom_Retenu']);
+		$espece[C_NOM_RET_NN] = $cel->quoteNonNull($complement['Num_Nom_Retenu']);
+		$espece[C_NT] = $cel->quoteNonNull($complement['Num_Taxon']);
+		$espece[C_FAMILLE] = $cel->quoteNonNull($complement['Famille']);
 		$espece[C_NOM_SEL] = $resultat_recherche_espece['nom_sel'];
+	static function traiterLocalisation($ligne, Array &$localisation, $cel) {
-		$espece[C_NOM_SEL_NN] = $resultat_recherche_espece['en_id_nom'];
+	    $identifiant_commune = trim($ligne[C_ZONE_GEO]);
+		if(!$identifiant_commune) {
+			$departement = trim($ligne[C_CE_ZONE_GEO]);
+			goto testdepartement;
+		}
+		$select = "SELECT DISTINCT nom, code  FROM cel_zones_geo";
+		if (preg_match('/(.*) \((\d+)\)/', $identifiant_commune, $elements)) {
+			// commune + departement : montpellier (34)
+			$nom_commune=$elements[1];
+			$code_commune=$elements[2];
+	 	    $requete = sprintf("%s WHERE nom = %s AND code LIKE %s",
+							   $select, $cel->quoteNonNull($nom_commune), $cel->quoteNonNull($code_commune.'%'));
+		}
+		elseif (preg_match('/^(\d+|(2[ab]\d+))$/i', $identifiant_commune, $elements)) {
+			// Code insee seul
+			$code_insee_commune=$elements[1];
+	 	    $requete = sprintf("%s WHERE code = %s", $select, $cel->quoteNonNull($code_insee_commune));
+		}
+		else {
+			// Commune seule (le departement sera recupere dans la colonne departement si elle est presente)
+			// 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, $cel->quoteNonNull($nom_commune.'%'));
+		}
+		$resultat_commune = $cel->requeter($requete);
+		// TODO: levenstein sort ?
+		// cas de la commune introuvable dans le référentiel
+		// réinitialisation aux valeurs du fichier XLS
+		if(! $resultat_commune) {
+			$localisation[C_ZONE_GEO] = trim($ligne[C_ZONE_GEO]);
+			$localisation[C_CE_ZONE_GEO] = trim($ligne[C_CE_ZONE_GEO]);
-		$complement = $taxon_info_webservice->rechercherInformationsComplementairesSurNumNom($resultat_recherche_espece['en_id_nom']);
+		} else {
-		$espece[C_NOM_RET] = $complement['Nom_Retenu'];
+			$localisation[C_ZONE_GEO] = $resultat_commune[0]['nom'];
-		$espece[C_NOM_RET_NN] = $complement['Num_Nom_Retenu'];
+			$localisation[C_CE_ZONE_GEO] = $resultat_commune[0]['code'];
 		$espece[C_NT] = $complement['Num_Taxon'];
-		$espece[C_FAMILLE] = $complement['Famille'];
+		$departement = &$localisation[C_CE_ZONE_GEO];
+	testdepartement:
+		if(strpos($departement, "INSEE-C:", 0) === 0) goto protectloc;
 		if(!is_numeric($departement)) goto protectloc; // TODO ?
+		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
 	static function traiterDepartement($departement) {
-		if(strpos($departement, "INSEE-C:", 0) === 0) return $departement;
+		$departement = trim($departement); // TODO
 			'OUEST' => -5.2); // Ouessan
 		return FALSE;
+	}
-	public function initialiser_colonnes_statiques($id_utisateur) {
+	public function initialiser_colonnes_statiques() {
 		$this->colonnes_statiques = array_merge($this->colonnes_statiques,
 												Array(
-													"ce_utilisateur" => $id_utisateur,
+													"ce_utilisateur" => $this->id_utilisateur,
-													"prenom_utilisateur" => $this->utilisateur['prenom'],
+													"prenom_utilisateur" => $this->quoteNonNull($this->utilisateur['prenom']),
-													"nom_utilisateur" => $this->utilisateur['nom'],
-													"courriel_utilisateur" => $this->utilisateur['courriel'],
-													"date_creation" => date("Y-m-d H:i:s"),
+													"nom_utilisateur" => $this->quoteNonNull($this->utilisateur['nom']),
-													"date_modification" => date("Y-m-d H:i:s"),
+													"courriel_utilisateur" => $this->quoteNonNull($this->utilisateur['courriel']),
+												));
+	}
+	// équivalent à CEL->Bdd->proteger() (qui wrap PDO::quote),
+	// sans transformer NULL en ""
+	private function quoteNonNull($chaine) {
+		if(is_null($chaine)) return "NULL";
+		if(!is_string($chaine)) die("erreur __FILE__, __LINE__");
+		return $this->bdd->quote($chaine);
+	}
-												));
+	public function erreurs_stock($errno, $errstr) {

Subversion Repositories eFlore/Applications.cel

(root)/branches/v3.01-serpe/jrest/services/ImportXLS.php @ 3940 – Rev 1640 → 1642