WebSVN – eFlore/Applications.del – Diff – /trunk/services/modules/0.1/commentaires/AjouterCommentaire.php

 <?php
 // declare(encoding='UTF-8');
 /**
  * Permet d'ajouter un commentaire.
+ *
  * @category   DEL
  * @package    Services
  * @subpackage Commentaires
  * @version    0.1
  * @author     Mathias CHOUET <mathias@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>
  */
 class AjouterCommentaire {
 	private $conteneur;
 	private $navigation;
 	private $bdd;
 	private $parametres = array();
 	private $mapping = array();
+	private $erreurs = array();
 	public function __construct(Conteneur $conteneur) {
 		$this->conteneur = $conteneur;
 		$this->navigation =  $this->conteneur->getNavigation();
 		$this->bdd = $this->conteneur->getBdd();
 		$this->mapping = $this->conteneur->getParametreTableau('commentaires.mapping');
+	}
 	public function ajouter($parametres) {
 		$this->parametres = $parametres;
 		$this->verifierParametres();
 		$this->completerParametresUtilisateur();
 		$this->gererPropositionInitiale();
 		$idCommentaireAjoute = $this->insererCommentaire();
 		// Mettre en forme le résultat et l'envoyer pour affichage
 		$resultat = new ResultatService();
 		$resultat->corps = array('id_commentaire' => $idCommentaireAjoute);
 		return $resultat;
+	}
 	private function verifierParametres() {
-		$erreurs = array();
 		if (!isset($this->parametres['observation'])) {
-			$erreurs[] = "Impossible d'ajouter un commentaire sans identifiant d'observation (paramètre 'observation').";
+			$this->erreurs[] = "Impossible d'ajouter un commentaire sans identifiant d'observation (paramètre 'observation').";
+		}
 		if (!isset($this->parametres['auteur.id'])) {
-			$paramsAuteur = array('auteur.nom', 'auteur.prenom', 'auteur.courriel');
-			$paramsAuteurManquant = array();
-			foreach ($paramsAuteur as $param) {
-				if (!isset($this->parametres[$param])) {
-					$paramsAuteurManquant[] = $param;
-				}
-			}
-			if (!empty($paramsAuteurManquant)) {
+			$this->verifierParamsAuteurAnonyme();
-				$msgAuteurTpl = "Si le parametre 'auteur.id' n'est pas utilisé, il est nécessaire d'indiquer les ".
-				"nom (paramètre 'auteur.nom'), prénom (paramètre 'auteur.prenom') et courriel ".
-				"(paramètre 'auteur.courriel') de l'auteur.\nLes paramètres suivant sont abscents : %s\n";
-				$erreurs[] = sprintf($msgAuteurTpl, implode(', ', $paramsAuteurManquant));
-			}
+		}
+		$this->verifierParamsNonVide();
-		if (isset($this->parametres['nom_sel']) && trim($this->parametres['nom_sel']) == '' ) {
+		if (isset($this->parametres['nom_sel_nn']) && !isset($this->parametres['nom_referentiel'])) {
-			$erreurs[] = "S'il est présent le paramètre «nom_sel» ne peut pas être vide.";
+			$this->erreurs[] = "Si le paramètre «nom_sel_nn» est présent, le paramètre «nom_referentiel» doit l'être aussi.";
-		}
+		}
-		//TODO : Gérer le cas d'une proposition
-		if (!empty($erreurs)) {
+		if (!empty($this->erreurs)) {
-			$msg = "Erreur de configuration :\n".implode("\n\n", $erreurs);
+			$msg = "Erreur de configuration :\n".implode("\n\n", $this->erreurs);
+			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
+		}
+	}
+	private function verifierParamsAuteurAnonyme() {
+		$paramsAuteur = array('auteur.nom', 'auteur.prenom', 'auteur.courriel');
+		$paramsAuteurManquant = array();
+		foreach ($paramsAuteur as $param) {
+			if (!isset($this->parametres[$param])) {
+				$paramsAuteurManquant[] = $param;
+			}
+		}
+		if (!empty($paramsAuteurManquant)) {
+			$msgAuteurTpl = "Si le parametre 'auteur.id' n'est pas utilisé, il est nécessaire d'indiquer les ".
+			"nom (paramètre 'auteur.nom'), prénom (paramètre 'auteur.prenom') et courriel ".
+			"(paramètre 'auteur.courriel') de l'auteur.\nLes paramètres suivant sont abscents : %s\n";
+			$this->erreurs[] = sprintf($msgAuteurTpl, implode(', ', $paramsAuteurManquant));
+		}
+	}
+	private function verifierParamsNonVide() {
+		$paramsNonVide = array('nom_sel', 'nom_referentiel', 'nom_sel_nn');
+		foreach ($paramsNonVide as $param) {
+			if (isset($this->parametres[$param]) && trim($this->parametres[$param]) == '' ) {
+				$this->erreurs[] = "S'il est présent le paramètre «$param» ne peut pas être vide.";
 			throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
+		}
+	}
 	private function completerParametresUtilisateur() {
 		$utilisateur =  (isset($this->parametres['auteur.id'])) ? $this->obtenirUtilisateurAvecId() : $this->obtenirUtilisateurSansId();
 		if ($utilisateur !== false) {
 			foreach ($utilisateur as $param => $valeur) {
 				$this->parametres[$param] = $valeur;
+			}
+		}
+	}
 	private function obtenirUtilisateurAvecId() {
 		$auteurIdP = $this->bdd->proteger($this->parametres['auteur.id']);
 		$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', courriel AS 'auteur.courriel' ".
 			'FROM del_utilisateur '.
 			"WHERE id_utilisateur = $auteurIdP ".
 			' -- '.__FILE__.' : '.__LINE__;
 		$utilisateur = $this->bdd->recuperer($requete);
 		return $utilisateur;
+	}
 	private function obtenirUtilisateurSansId() {
 		$nomP = $this->bdd->proteger($this->parametres['auteur.nom']);
 		$prenomP = $this->bdd->proteger($this->parametres['auteur.prenom']);
 		$courrielP = $this->bdd->proteger($this->parametres['auteur.courriel']);
 		$requete = "SELECT id_utilisateur AS 'auteur.id', nom AS 'auteur.nom', prenom AS 'auteur.prenom', ".
 			"courriel AS 'auteur.courriel' ".
 			'FROM del_utilisateur '.
 			"WHERE courriel = $courrielP AND nom = $nomP AND prenom = $prenomP ".
 			' -- '.__FILE__.' : '.__LINE__;
 		$utilisateur = $this->bdd->recuperer($requete);
 		return $utilisateur;
+	}
 	private function gererPropositionInitiale() {
 		if ($this->verifierExistencePropositionInitiale() === false) {
 			$this->creerPropositionInitiale();
 			// TODO : en cas d'échec de la création de la proposition ajouter un log...
+		}
+	}
 	private function verifierExistencePropositionInitiale() {
 		$idObsP =  $this->bdd->proteger($this->parametres['observation']);
 		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
 			'FROM del_commentaire '.
 			"WHERE ce_observation = $idObsP ".
 			'	AND proposition_initiale = 1 '.
 			' -- '.__FILE__.' : '.__LINE__;
 		$resultat = $this->bdd->recuperer($requete);
 		return $resultat['existe'] == 1;
+	}
 	private function creerPropositionInitiale() {
 		$idObsP =  $this->bdd->proteger($this->parametres['observation']);
 		$requete = 'INSERT IGNORE INTO del_commentaire '.
 			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, utilisateur_courriel, '.
 			'nom_sel, nom_sel_nn, nom_ret, nom_ret_nn, nt, famille, nom_referentiel, date, proposition_initiale) '.
 			'SELECT id_observation, ce_utilisateur, prenom, nom, courriel, nom_sel, '.
 			"IF(nom_sel_nn = 0, NULL, nom_sel_nn), IF(nom_ret = '', NULL, nom_ret), IF(nom_ret_nn = 0, NULL, nom_ret_nn), ".
 			"IF(nt = 0, NULL, nt), IF(famille = '', NULL, famille), IF(nom_sel_nn = 0, NULL, nom_referentiel), NOW(), '1' ".
 			'FROM del_observation AS do '.
 			'	LEFT JOIN del_utilisateur AS du '.
 			'		ON do.ce_utilisateur = du.id_utilisateur '.
 			"WHERE id_observation = $idObsP ".
 			' -- '.__FILE__.' : '.__LINE__;
 		$resultat = $this->bdd->executer($requete);
 		return $resultat;
+	}
 	private function insererCommentaire() {
 		$champs = $this->creerEnteteChamps();
 		$values = $this->creerClauseValues();
 		$requete = "INSERT INTO del_commentaire (date, $champs) VALUES (NOW(), $values) ".
 			' -- '.__FILE__.' : '.__LINE__;
 		$retour = $this->bdd->executer($requete);
 		if ($retour == null) {
 			$msgTpl = "Erreur inopinée lors de l'insertion du commentaire lié à l'observation «%s».";
 			$msg = sprintf($msgTpl, $this->parametres['observation']);
 			throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
+		}
 		$idCommentaire = $this->bdd->recupererIdDernierAjout();
 		return $idCommentaire;
+	}
 	private function creerEnteteChamps() {
 		return $this->creerSuiteChampsOuValeurs('champs');
+	}
 	private function creerClauseValues() {
 		return $this->creerSuiteChampsOuValeurs('valeurs');
+	}
 	private function creerSuiteChampsOuValeurs($mode) {
 		$suite = array();
 		foreach ($this->mapping as $nomChampBdd => $nomAttributSortie) {
 			if (isset($this->parametres[$nomAttributSortie]) && $this->parametres[$nomAttributSortie] != null) {
 				if ($mode == 'valeurs') {
 					$suite[] = $this->bdd->proteger($this->parametres[$nomAttributSortie]);
 				} else if ($mode == 'champs') {
 					$suite[] = $nomChampBdd;
 				} else {
 					$msg = "Erreur interne : mauvais paramètre passé à la méthode 'creerSuiteChampsOuValeurs'";
 					throw new Exception($msg, RestServeur::HTTP_CODE_ERREUR);
+				}
+			}
+		}
 		return implode(', ', $suite);
+	}
+}

Subversion Repositories eFlore/Applications.del

(root)/trunk/services/modules/0.1/commentaires/AjouterCommentaire.php – Rev 1803 → 1805