WebSVN – eFlore/Applications.del – Diff – /trunk/services/modules/0.1/observations/VoteObservation.php

  * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
  * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
  */
 class VoteObservation extends RestService {
-	protected $conteneur;
+	private $conteneur;
-	protected $bdd;
+	private $bdd;
-	protected $navigation;
+	private $navigation;
+	private $mapping;
+	private $ressources;
 	private $parametres;
 	public function __construct(Conteneur $conteneur = null) {
 		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
-		$this->bdd = $this->conteneur->getBdd();
-		$this->navigation = $conteneur->getNavigation();
-		$this->conteneur->chargerConfiguration('config_mapping_votes.ini');
-	}
-	/**
-	* Configuration du service en fonction du fichier de config config_del.ini
+		$this->bdd = $this->conteneur->getBdd();
-	* */
+		$this->navigation = $conteneur->getNavigation();
-	private function configurer() {
-		$this->mappingVotes = $this->conteneur->getParametre('mapping_votes');
-	}
-	/**
+		$this->mapping = $this->conteneur->getParametreTableau('votes.mapping');
+	}
-	 * Méthode seulement présente pour interdire proprement l'accès à la consultation
-	 * */
-	public function consulter($ressources, $parametres) {
-		$this->configurer();
+	public function consulter($ressources, $parametres) {
 		$this->ressources = $ressources;
-		//TODO: faut il vérifier quelque chose, si on n'a pas renseigné les valeurs correctement
+		$this->parametres = $parametres;
 		// dans ressource, le service n'est même pas appelé
-		$votes = $this->chargerVotes($ressources[1]);
+		$votes = $this->chargerVotes();
 		$this->conteneur->getNavigation()->setTotal(count($votes));
 		// Mettre en forme le résultat et l'envoyer pour affichage
 		$resultat = new ResultatService();
 		$resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => $votes);
 		return $resultat;
 	}
+	private function chargerVotes() {
-	private function chargerVotes($id_commentaire) {
+		$idCommentaireP = $this->bdd->proteger($this->ressources[1]);
-		$id_commentaire = $this->proteger($id_commentaire);
+		$requete = 'SELECT * '.
-		$requeteVotes = 'SELECT * '.
+			'FROM del_commentaire_vote '.
-			'FROM del_commentaire_vote '.
+			"WHERE ce_proposition = $idCommentaireP ";
-			"WHERE ce_proposition = $id_commentaire ";
+			' -- '.__FILE__.':'.__LINE__;
-		$resultatsVotes = $this->bdd->recupererTous($requeteVotes);
+		$resultats = $this->bdd->recupererTous($requete);
 		$votes = array();
-		foreach ($resultatsVotes as $vote) {
+		foreach ($resultats as $vote) {
 			$votes[$vote['id_vote']] = $this->formaterVotes($vote);
 			$utilisateur = $this->chercherUtilisateur($vote['ce_utilisateur']);
+			if (count($utilisateur) > 0) {
+				$votes[$vote['id_vote']] = array_merge($votes[$vote['id_vote']], $utilisateur);
+			}
+		}
-			if ($utilisateur) {
+		return $votes;
-				$votes[$vote['id_vote']] = array_merge($votes[$vote['id_vote']], $utilisateur);
-			}
+	}
-		}
+	private function formaterVotes($vote) {
-		return $votes;
+		$retour = array();
 		foreach ($vote as $param => $valeur) {
 			$retour[$this->mapping[$param]] = $valeur;
 	/**
-	* Trouver l'utilisateur en fonction des paramètres ou de la base de données si le nom, prénom et courriel ne sont pas donnés
+		return $retour;
+	}
 	* @return le tableau utilisateur
-	* */
+	private function chercherUtilisateur($id) {
-	private function chercherUtilisateur($id) {
+		// par défaut, pas d'info
-		// par défaut, pas d'info
+		$utilisateur = array();
+		// Si l'id utilisateur est un hash de session, on ne cherche rien
-		$utilisateur = array();
+		if (is_numeric($id)) {
-		// Si l'id utilisateur est un hash de session, on ne cherche rien
+			$idUtilisateurP = $this->bdd->proteger($id);
-		if (is_numeric($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 = '.$this->bdd->proteger($id);
-			$utilisateur = $this->bdd->recuperer($requete);
-		}
-		return $utilisateur;
-	}
-	/**
-	*  Formater un vote en fonction du fichier de configuration config_votes.ini
-	*  @param $votes array()
-	* */
-	private function formaterVotes($vote) {
-		$retour = array();
-		foreach ($vote as $param => $valeur) {
-			$retour[$this->mappingVotes[$param]] = $valeur;
-		}
-		return $retour;
-	}
-	/**
+				'FROM del_utilisateur '.
+				"WHERE id_utilisateur = $idUtilisateurP ".
+				' -- '.__FILE__.':'.__LINE__;
-	* Ajoute un vote à une proposition grâce aux informations passées en paramètres
+			$utilisateur = $this->bdd->recuperer($requete);
 	* @param array $ressources tableau des informations contenues dans l'url après le nom du service
-	* @param array $parametres contenu du post
+		return $utilisateur;
+	}
-	*
-	* @return void
+	public function ajouter($ressources, $parametres) {
-	*
+		$this->ressources = $ressources;
+		$this->parametres = $parametres;
+		$this->verifierParametresAjoutModif();
+		// Vérifie si la proposition existe, et la crée sinon
+		// (cas du vote sur la proposition fabriquée à partir de l'observation originale)
+		$idProposition = $this->ressources[1];
-	* */
-	public function ajouter($ressources, $parametres) {
-		$this->verifierParametresAjoutModif($ressources, $parametres);
-		// Vérifie si la proposition existe, et la crée sinon
+		if ($idProposition == 0) {
-		// (cas du vote sur la proposition fabriquée à partir de l'observation originale)
+			$idProposition = $this->renvoyerIdOuCreerPropositionDeterminationInitiale($idProposition);
 		if($ressources[1] == 0) {
-			$ressources[1] = $this->renvoyerIdOuCreerPropositionDeterminationInitiale($ressources[0]);
+		$idPropositionP = $this->bdd->proteger($idProposition);
 		$idUtilisateurP = $this->bdd->proteger($parametres['utilisateur']);
 		$valeurP = $this->bdd->proteger($parametres['valeur']);
-		$insertion = 'INSERT INTO del_commentaire_vote '.
+		$requete = 'INSERT INTO del_commentaire_vote (ce_proposition , ce_utilisateur , valeur , date) '.
-			'(ce_proposition , ce_utilisateur , valeur , date) '.
-			'VALUES ('.$this->proteger($ressources[1]).','.$this->proteger($parametres['utilisateur']).','.
-			$this->proteger($parametres['valeur']).', NOW());';
-		$resultatsVotes = $this->bdd->requeter($insertion);
-		if ($resultatsVotes == false) {
-			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
-		} else {
-			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_CREATION_OK);
-		}
-	}
-	private function renvoyerIdPropositionObservation($id_observation) {
-		$id_commentaire = null;
-		// Récupération de l'utilisateur + nom sel de l'observation originale
-		$requete_selection_obs = 'SELECT ce_utilisateur, nom_sel '.
-			'FROM del_observation '.
-			'WHERE id_observation ='.$this->proteger($id_observation);
-		$obs = $this->bdd->recuperer($requete_selection_obs);
-		if (is_array($obs) && isset($obs['ce_utilisateur'])) {
-			// On considère que la proposition faite par le même utilisateur et ayant le même
-			// nom sélectionné est bien la proposition composée à partir de l'obs originale
-			$requete_selection_comm = 'SELECT id_commentaire '.
-				'FROM del_commentaire '.
-				'WHERE ce_observation = '.$this->proteger($id_observation).' '.
-				' AND nom_sel = '.$this->proteger($obs['nom_sel']).' AND '.
-				' ce_utilisateur = '.$this->proteger($obs['ce_utilisateur']);
 			"VALUES ($idPropositionP, $idUtilisateurP, $valeurP, NOW()) ".
-			$commentaire = $this->bdd->recuperer($requete_selection_comm);
+			' -- '.__FILE__.' : '.__LINE__;
 			$id_commentaire = null;
-			if (is_array($commentaire) && $commentaire['id_commentaire'] != null) {
+		$resultats = $this->bdd->requeter($requete);
-				$id_commentaire = $commentaire['id_commentaire'];
+		if ($resultats == false) {
 			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
 		} else {
 			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_CREATION_OK);
-		return $id_commentaire;
+		}
+	}
 	private function renvoyerIdOuCreerPropositionDeterminationInitiale($id_observation) {
-	private function renvoyerIdOuCreerPropositionDeterminationInitiale($id_observation) {
+		$proposition_existe = $this->propositionInitialeExiste($id_observation);
-		$proposition_existe = $this->propositionInitialeExiste($id_observation);
+		if(!$proposition_existe) {
-		if(!$proposition_existe) {
+			$id_proposition = $this->creerPropositionAPartirObservation($id_observation);
-			$id_proposition = $this->creerPropositionAPartirObservation($id_observation);
+		} else {
-		} else {
+			$requete = 'SELECT id_commentaire '.
-			$requete = 'SELECT id_commentaire '.
+				'FROM del_commentaire '.
-				'FROM del_commentaire '.
+				"WHERE ce_observation = $id_observation ".
-				"WHERE ce_observation = $id_observation ".
+				'AND proposition_initiale = 1 '.
+				' -- '.__FILE__.' : '.__LINE__;
-				'AND proposition_initiale = 1 ';
+			$resultat = $this->bdd->recuperer($requete);
-			$resultat = $this->bdd->recuperer($requete);
+			$id_proposition = $resultat['id_commentaire'];
 			$id_proposition = $resultat['id_commentaire'];
 		return $id_proposition;
+	}
-		return $id_proposition;
 	private function propositionInitialeExiste($id_observation) {
 		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
-	private function propositionInitialeExiste($id_observation) {
+			'FROM del_commentaire '.
-		$requete = 'SELECT COUNT(*) >= 1 AS existe '.
+			"WHERE ce_observation = $id_observation ".
-			'FROM del_commentaire '.
+			'AND proposition_initiale = 1 '.
-			"WHERE ce_observation = $id_observation ".
+			' -- '.__FILE__.' : '.__LINE__;
-			'AND proposition_initiale = 1 ';
+		$resultat = $this->bdd->recuperer($requete);
-		$resultat = $this->bdd->recuperer($requete);
+		return $resultat['existe'] == 1;
+	}
-		return $resultat['existe'] == 1;
 	private function creerPropositionAPartirObservation($id_observation) {
 		$idObservationP = $this->bdd->proteger($id_observation);
-	private function creerPropositionAPartirObservation($id_observation) {
+		$requete = 'INSERT IGNORE INTO del_commentaire '.
-		$insertion = 'INSERT IGNORE INTO del_commentaire '.
+			'(ce_observation, ce_utilisateur, utilisateur_prenom, utilisateur_nom, utilisateur_courriel, '.
-			'(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, nom_sel_nn, nom_ret, nom_ret_nn, '.
-			"		nt, famille, 'bdtfx_v1', NOW(), '1' ".
-			'FROM del_observation do '.
-			'	LEFT JOIN del_utilisateur du ON (do.ce_utilisateur = du.id_utilisateur) '.
-			'WHERE id_observation = '.$this->proteger($id_observation);
 			'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, nom_sel_nn, nom_ret, nom_ret_nn, '.
-		$resultat = $this->bdd->requeter($insertion);
+			"		nt, famille, 'bdtfx_v1', NOW(), '1' ".
 			'FROM del_observation do '.
-		// Attention à l'abstraction utilisée, récupérer le dernier id en mysql ou msqli ça marche bien, mais pour d'autres moins
+			'	LEFT JOIN del_utilisateur du ON (do.ce_utilisateur = du.id_utilisateur) '.
-		$id = $this->bdd->recupererIdDernierAjout();
+			"WHERE id_observation = $idObservationP ".
-		return $id;
+			' -- '.__FILE__.' : '.__LINE__;
-	}
+		$this->bdd->executer($requete);
-	/**
+		// Attention à l'abstraction utilisée, récupérer le dernier id en mysql ou msqli ça marche bien, mais pour d'autres moins
-	* Modifie un vote associé à une proposition grâce aux informations passées en paramètres
+		$id = $this->bdd->recupererIdDernierAjout();
-	* @param array $ressources tableau des informations contenues dans l'url après le nom du service
-	* @param array $parametres contenu du post
-	*
+		return $id;
 	* @return void
+	public function modifier($ressources, $parametres) {
+		$this->ressources = $ressources;
+		$this->parametres = $parametres;
+		$this->verifierParametresAjoutModif();
+		// Si l'identifiant de proposition vaut 0, c'est un vote sur une proposition
+		// fabriquée à partir de l'observation originale, dont on doit obtenir l'id
-	* */
-	public function modifier($ressources, $parametres) {
-		$this->verifierParametresAjoutModif($ressources, $parametres);
-		// Si l'identifiant de proposition vaut 0, c'est un vote sur une proposition
-		// fabriquée à partir de l'observation originale, dont on doit obtenir l'id
 		// (cas où l'on vient de voter pour celle et cela a créé la proposition, puis
 		// on revote pour celle ci en changeant d'avis sans recharger la page)
-		if($ressources[1] == 0) {
+		$idProposition = $this->ressources[1];
-			$id_proposition = $this->renvoyerIdOuCreerPropositionDeterminationInitiale($ressources[0]);
+		if ($idProposition == 0) {
-			if($id_proposition == null) {
+			$idProposition = $this->renvoyerIdOuCreerPropositionDeterminationInitiale($idProposition);
-				$this->envoyerMessageErreurIdProposition();
+			if ($idProposition == null) {
-				exit;
+				$msg = "Aucun identifiant de proposition n'est lié à cette observation.";
-			} else {
+				throw new Exception($msg, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
 				$ressources[1] = $id_proposition;
-			}
-		}
-		$modification = 'UPDATE del_commentaire_vote '.
+		}
-			'SET valeur ='.$this->proteger($parametres['valeur']).', '.
+		$idPropositionP = $this->bdd->proteger($idProposition);
-			'date = NOW() '.
+		$idUtilisateurP = $this->bdd->proteger($parametres['utilisateur']);
-			'WHERE ce_proposition = '.$this->proteger($ressources[1]).' '.
+		$valeurP = $this->bdd->proteger($parametres['valeur']);
-			'AND ce_utilisateur = '.$this->proteger($parametres['utilisateur']);
+		$requete = 'UPDATE del_commentaire_vote '.
 			"SET valeur = $valeurP, date = NOW() ".
-		$resultatsVotes = $this->bdd->requeter($modification);
+			"WHERE ce_proposition = $idPropositionP AND ce_utilisateur = $idUtilisateurP ".
-		if ($resultatsVotes == false) {
+			' -- '.__FILE__.' : '.__LINE__;
-			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
-		} else {
+		$resultats = $this->bdd->requeter($requete);
-			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_OK);
+		if ($resultats == false) {
 			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_MAUVAISE_REQUETE);
 		} else {
+			RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_OK);
-	public function verifierParametresAjoutModif($ressources, $parametres) {
-		$erreurs = array();
-		if (!is_numeric($ressources[1])) {
+		}
-			$erreurs[] = '- le paramètre indiquant l\'identifiant de la proposition doit être numérique ;';
-		}
-		if (!isset($parametres['utilisateur'])) {
-			$erreurs[] = '- paramètre "utilisateur" manquant ;';
-		}
-		if (!isset($parametres['valeur'])) {
-			$erreurs[] = '- paramètre "valeur" manquant ;';
-		} else {
-			if (!is_numeric($parametres['valeur'])) {
-				$erreurs[] = '- le paramètre "valeur" doit être numérique ;';
-			} elseif($parametres['valeur'] != 0 && $parametres['valeur'] != 1) {
-				$erreurs[] = '- le paramètre "valeur" ne peut prendre que la valeur 0 ou 1 ;';
-			}
-		}
+	}
 		if (!empty($erreurs)) {
-			$e = 'Erreur lors de la configuration : '."\n";
+	private function verifierParametresAjoutModif() {
-			$e .= implode("\n", $erreurs);
+		$erreurs = array();

Subversion Repositories eFlore/Applications.del

(root)/trunk/services/modules/0.1/observations/VoteObservation.php – Rev 1845 → 1848