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

 	public function __construct($config) {
 		parent::__construct($config);
 		$this->rechercheObs = new RechercheObservation($config);
+		$this->chpsEtendus = new GestionChampsEtendus($config, 'obs');
+		$this->chargerNomsTablesReferentiels();
+	}
+	private function chargerNomsTablesReferentiels() {
+		// Créé des attributs avec le code du référentiel : bdtfx, bdtxa, bdtao, isfan
+		foreach ( $this->config['referentiels'] as $referentiel => $table) {
+			$this->$referentiel = $table;
 		$this->chpsEtendus = new GestionChampsEtendus($config, 'obs');
+	}
 	function getElement($ressources){
 		if ($this->controlerAccessibiliteWs()) {
 			if ($this->controleAppelIpAutorisee()) {
 				$idObs = isset($ressources[0]) ? $ressources[0] : '';
 				$this->verifierIdentifiantObs($idObs);
-				$idObs = explode(',', $idObs);
-				// Seulement la dépublication
-				if (isset($this->donnees['transmission']) && count($this->donnees) == 1) {
+				if (count($this->donnees) == 1) {
-					$gestionnaireObs = new GestionObservation($this->config);
-					$detransmissionObs = $gestionnaireObs->modifierTransmissionObservation($idObs, false);
+					$donneesObligatoires = array('transmission');
-					if ($detransmissionObs === false) {
-						$msg = "Un problème est survenu (voir log). Les observations n'ont pas pu être dépubliées.";
+					if ($this->verifierDonneesObligatoires($donneesObligatoires)) {
-						$this->envoyerMessageErreur(304, $msg);
+						$this->depublierObs($idObs);
 					}
-				} if (count($this->donnees) == 3) {
+				} else if (count($this->donnees) == 4) {
-					$donneesObligatoires = array('id_observation', 'ce_utilisateur', 'nom_sel');
+					$donneesObligatoires = array('id_observation', 'nom_sel_nn', 'nom_referentiel', 'id_utilisateur');
 					if ($this->verifierDonneesObligatoires($donneesObligatoires)) {
-						$this->modifierObservationDepuisDEL($idObs);
+						$this->accepterPropositionDEL($idObs);
+					}
 				} else {
-					$msg = "La modification complète d'une observation n'est pas implémentée. \n".
-						"Uniquement la dépublication pour l'instant fonctionne";
+					$msg = "La modification complète d'une observation n'est pas implémentée.";
 					$this->envoyerMessageErreur(501, $msg);
 				}
-				$this->envoyer('OK');
-			} else {
 				$msg = "Accès interdit. \n"."Vous n'êtes pas autorisé à accéder à ce service depuis '{$_SERVER['REMOTE_ADDR']}' !\n";
-				$this->envoyerMessageErreur(401, $msg);
+				$this->envoyer('ok');
+			}
-		}
-	}
-	private function modifierObservationDepuisDEL($idObs) {
-		$gestion_observation = new GestionObservation($this->config);
-		$pairs = array_map('trim', $this->donnees);
-		$utilisateur = $pairs['ce_utilisateur'];
-		unset($pairs['ce_utilisateur'], $pairs['id_observation']);
-		// mise à jour des mots-clefs suite à une validation:
-		// typiquement, DEL modifierObservationParDetermination()
-		// nous enverra obsKeywordDelete=aDeterminer en plus de certitude=Certaine
-		$obsKeywordDelete = @trim($pairs['obsKeywordDelete']);
-		// $imgKeywordDelete = @trim($pairs['imgKeywordDelete']);
-		unset($pairs['obsKeywordDelete']); // , $pairs['imgKeywordDelete']);
-		// complete les données de la proposition validée car:
-		// 1) la table tb_del.del_commentaire ne contient pas toutes les informations nécessaires
-		// 2) la table tb_del.del_commentaire ne *devrait* pas contenir beaucoup plus que nom_sel et nom_sel_nn
-		// 3) la génération de ces données ici, au moment de l'UPDATE, est le meilleur garant de leur fiabilité
-		$more_data = $this->NN2(@$pairs['nom_sel_nn'], @$pairs['nom_referentiel']);
-		if($more_data) $pairs = array_merge($pairs, $more_data);
-		$modification = $gestion_observation->modifierObservationPublique($utilisateur, $idObs, $pairs);
-		if($modification) {
-			$gestion_mots_cles = new GestionMotsClesChemin($this->config, 'obs');
-			// supression des éventuelles liaison de l'obs avec le mot clé contenu dans obsKeywordDelete
-			$supp_liaison_mot_cle = $gestion_mots_cles->supprimerLiaisonPourMotCleEtIdElementLie($obsKeywordDelete, $idObs, $utilisateur);
-			// TODO : quel impact de la valeur de retour ?
-			header("Content-Type: text/plain; charset=utf-8");
-			die("OK"); // attention, compatibilité avec ValiderDetermination.php de DEL !
-		}
-		// cf TODO: n'arrivera pas tant que l'UPDATE ajoutera systématiquement date_modification = now()
-		elseif($modification === 0) {
-            header("HTTP/1.0 304 Not Modified"); // XXX: PHP 5.4 // http_response_code(304); // Not Modified
-			header("Content-Type: text/plain; charset=utf-8");
-			die("Not Modified");
-		}
-		else {
-			header("HTTP/1.0 500 Internal Server Error"); // XXX: PHP: 5.4 // http_response_code(500); // Internal Server Error
-			header("Content-Type: text/plain; charset=utf-8");
-			die("Impossible de modifier l'observation associée à cet identifiant " . mysql_error());
+		}
 	}
 	private function verifierIdentifiantObs($chaine) {
-		$ok = preg_match('/^(?:[0-9]+,)*[0-9]+$/', $chaine);
+		$ok = preg_match('/^[0-9]+$/', $chaine);
 		if ($ok == false) {
-			$msg = "Indiquer un ou plusieurs identifiants d'obs séparés par des virgules.";
+			$msg = "Indiquer un seul identifiant numérique d'observation.";
 			$this->envoyerMessageErreur(412, $msg);
 			if (! isset($this->donnees[$param])) {
 				$msg = sprintf("Paramètre %s manquant (parmi %s)", $param, implode(', ', $champsObligatoires));
 				$this->envoyerMessageErreur(412, $msg);
+			}
+		}
+		return true;
+	}
+	private function depublierObs($idObs) {
+		$gestionnaireObs = new GestionObservation($this->config);
+		$depublication = $gestionnaireObs->modifierTransmissionObservation($idObs, false);
+		if ($depublication === false) {
+			$msg = "Un problème est survenu (voir log). Les observations n'ont pas pu être dépubliées.";
+			$this->envoyerMessageErreur(304, $msg);
+		}
+	}
+	/**
-	private function NN2($id, $ref) {
+	 * Modifie une observation aveec les infos d'une proposition :
-		if(!$db || !$id || !$ref) return FALSE;
+	 * Nous complétons les données de la proposition acceptée ici car:
-		switch($ref) {
+	 * 1) la table tb_del.del_commentaire ne contient pas toutes les informations nécessaires
-			case "bdtfx":
+	 * 2) la table tb_del.del_commentaire ne *devrait* pas contenir beaucoup plus que nom_sel et nom_sel_nn
-				return $this->bdd->query(sprintf(, self::db, self::bdtfx,  self::db, self::bdtfx, intval($id), __FILE__, __LINE__))->fetch(PDO::FETCH_ASSOC);
+	 * 3) la génération de ces données ici, au moment de l'UPDATE, est le meilleur garant de leur fiabilité
+	 */
-		case "bdtxa":
+	private function accepterPropositionDEL($idObs) {
-		  return $this->bdd->query(sprintf("SELECT o.num_nom_retenu AS nom_ret_nn, o.num_tax AS nt, CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel". // subtilité: "num_tax"
+		$gestion_observation = new GestionObservation($this->config);
+		$donnees = array_map('trim', $this->donnees);
-									" , o.famille, CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret".
+		$idUtilisateur = $donnees['id_utilisateur'];
-									" FROM %s.%s o".
+		$donneesAModifier = array(
-									" LEFT JOIN %s.%s ret ON o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom".
+			'certitude' => 'Certaine',
-									" WHERE o.num_nom = %d -- %s:%d", self::db, self::bdtxa,  self::db, self::bdtxa, intval($id), __FILE__, __LINE__))->fetch(PDO::FETCH_ASSOC);
+			'nom_referentiel' => $donnees['nom_referentiel'],
-		case "isfan":
+		);
-		  return $this->bdd->query(sprintf("SELECT o.num_nom_retenu AS nom_ret_nn, o.num_taxonomique AS nt, CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel".
+		// TODO : la récupération des infos du nom est aussi effectué par la suite voir ce qu'il faut garder
-									" , o.famille, CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret".
+		$infosNoms = $this->getNomInfos($donnees['nom_sel_nn'], $donnees['nom_referentiel']);
-									" FROM %s.%s o".
+		if ($infosNoms) {
+			$donneesAModifier = array_merge($donneesAModifier, $infosNoms);
+		}
-									" LEFT JOIN %s.%s ret ON o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom".
+		$modification = $gestion_observation->modifierObservationPublique($idObs, $donneesAModifier);
-									" WHERE o.num_nom = %d -- %s:%d", self::db, self::isfan,  self::db, self::isfan, intval($id), __FILE__, __LINE__))->fetch(PDO::FETCH_ASSOC);
-		case "bdtao":
+		if ($modification) {
-		  return $this->bdd->query(sprintf("SELECT o.num_nom_retenu AS nom_ret_nn, o.num_taxonomique AS nt, CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel".
+			// supression des éventuelles liaison de l'obs avec le mot clé contenu dans obsKeywordDelete
+			$gestionMotsClesObs = new GestionMotsClesChemin($this->config, 'obs');
-									" , o.famille, CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret".
+			$supp_liaison_mot_cle = $gestionMotsClesObs->supprimerLiaisonPourMotCleEtIdElementLie('aDeterminer', $idObs, $idUtilisateur);
-									" FROM %s.%s o".
+		} else {
-									" LEFT JOIN %s.%s ret ON o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom".
+			$msg = "Impossible de modifier l'observation associée à cet identifiant. Erreur mysql : " . mysql_error();
-									" WHERE o.num_nom = %d -- %s:%d", self::db, self::bdtao,  self::db, self::bdtao, intval($id), __FILE__, __LINE__))->fetch(PDO::FETCH_ASSOC);
+			$this->envoyerMessageErreur(500, $msg);// Internal Server Error
-		}
-		return FALSE;
+		}
 	}
+	// TODO : cette méthode et celles qui en dépendent sont peut être inutiles au vue de la méthode traiterEspece() de GestionObservation
+	private function getNomInfos($id_nom, $code_referentiel) {
+		$retour = false;
+		if ($id_nom && $code_referentiel) {
-	const db = 'tb_eflore';
+			switch ($code_referentiel) {
+				case 'bdtfx' :
+					$retour = $this->getInfosBdtfx($id_nom);
-	const bdtfx = 'bdtfx_v2_00';
+					break;
+				case 'bdtxa' :
+					$retour = $this->getInfosBdtxa($id_nom);
-	const bdtxa = 'bdtxa_v1_01';
+					break;
+				case 'isfan' :
+					$retour = $this->getInfosIsfan($id_nom);
-	const isfan = 'isfan_v2013';
+					break;
+				case 'bdtao' :
+					$retour = $this->getInfosBdtao($id_nom);
+					break;
+			}
+		}
+		return $retour;
 	const bdtao = 'bdtao_v1_00';
+	private function getInfosBdtfx($id_nom) {
+		$idNomP = CEL::db()->proteger($id_nom);
+		$requete = "SELECT o.num_nom_retenu AS nom_ret_nn, o.num_taxonomique AS nt, o.famille, ".
+			"	CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel, ".
+			"	CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret ".
+			"FROM {$this->bdtfx} AS o ".
+			"	LEFT JOIN {$this->bdtfx} AS ret ON (o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom) ".
+			"WHERE o.num_nom = $idNomP ".
+			' -- '.__FILE__.' : '.__LINE__;
+		$resultat = Cel::db()->requeterLigne($requete);
+		return $resultat;
+	}
+	private function getInfosBdtxa($id_nom) {
+		$idNomP = CEL::db()->proteger($id_nom);
+		// Champ "num_tax" au lieu de "num_taxonomique"
+		$requete = "SELECT o.num_nom_retenu AS nom_ret_nn, o.num_tax AS nt, o.famille, ".
+			"	CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel, ".
+			"	CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret ".
+			"FROM {$this->bdtxa} AS o ".
+			"	LEFT JOIN {$this->bdtxa} AS ret ON (o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom) ".
+			"WHERE o.num_nom = $idNomP ".
+			' -- '.__FILE__.' : '.__LINE__;
+		$resultat = Cel::db()->requeterLigne($requete);
+		return $resultat;
+	}
+	private function getInfosIsfan($id_nom) {
+		$idNomP = CEL::db()->proteger($id_nom);
+		// Champ "num_tax" au lieu de "num_taxonomique"
+		$requete = "SELECT o.num_nom_retenu AS nom_ret_nn, o.num_taxonomique AS nt, o.famille, ".
+			"	CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel, ".
+			"	CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret ".
+			"FROM {$this->isfan} AS o ".
+			"	LEFT JOIN {$this->isfan} AS ret ON (o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom) ".
+			"WHERE o.num_nom = $idNomP ".
+			' -- '.__FILE__.' : '.__LINE__;
+		$resultat = Cel::db()->requeterLigne($requete);
+		return $resultat;
+	}
+	private function getInfosBdtao($id_nom) {
-	private function getInfosBdtfx($id_nom) {
+		$idNomP = CEL::db()->proteger($id_nom);
-		$idNomP = $this->bdd->proteger($id_nom);
+		// Champ "num_tax" au lieu de "num_taxonomique"
 		$requete = "SELECT o.num_nom_retenu AS nom_ret_nn, o.num_taxonomique AS nt, o.famille, ".
 			"	CONCAT(o.nom_sci, ' ', o.auteur) AS nom_sel, ".
 			"	CONCAT(ret.nom_sci, ' ', ret.auteur) AS nom_ret ".
-			"FROM bdtfx_v2_00 AS o ".
+			"FROM {$this->bdtao} AS o ".
-			"	LEFT JOIN bdtfx_v2_00 AS ret ON (o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom) ".
+			"	LEFT JOIN {$this->bdtao} AS ret ON (o.num_nom_retenu != 0 AND o.num_nom_retenu = ret.num_nom) ".
 			"WHERE o.num_nom = $idNomP ".
 			' -- '.__FILE__.' : '.__LINE__;
-		$resultat = Cel::db()->executerRequete($requete, Cel::db::SQL_RETOUR_LIGNE);
+		$resultat = Cel::db()->requeterLigne($requete);
 		return $resultat;
+	}

Subversion Repositories eFlore/Applications.cel

(root)/trunk/jrest/services/CelObs.php – Rev 2143 → 2152