Subversion Repositories eFlore/Applications.del

<?php

// declare(encoding='UTF-8');

/**

 * Web service retournant toutes les infos d'une observation donnée :

 * images, votes sur image et protocole, commentaires, votes sur commentaires, ...

 *

 * @category   DEL

 * @package    Services

 * @subpackage Observations

 * @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 ObservationDetails {

	private $conteneur;

	private $bdd;

	private $sql;

	private $idObs;

	private $protocole;

	private $observation;

	private $mappings = array();

	public function __construct(Conteneur $conteneur) {

		$this->conteneur = $conteneur;

		$this->bdd = $this->conteneur->getBdd();

		$this->sql = $this->conteneur->getSql();

		$this->mappings['observations'] = $this->conteneur->getParametreTableau('observations.mapping');

		$this->mappings['images'] = $this->conteneur->getParametreTableau('images.mapping');

		$this->mappings['votes'] = $this->conteneur->getParametreTableau('votes.mapping');

		$this->mappings['commentaires'] = $this->conteneur->getParametreTableau('commentaires.mapping');

		// les deux alias suivants sont particuliers afin d'éviter un conflit d'alias lors des jointures avec del_commentaire_vote

		$this->mappings['commentaires']['ce_utilisateur'] = '__auteur_com';

		$this->mappings['commentaires']['date'] = '__date_com';

	}

	public function consulter($ressources, $parametres) {

		$this->idObs = $ressources[0];

		$this->protocole = isset($parametres['protocole']) && is_numeric($parametres['protocole']) ? intval($parametres['protocole']) : null;

		$infos = $this->getInfosObservationEtImages();

		if (! $infos) {

			$message = "Aucune observation ne possède d'identifiant '{$this->idObs}'.";

			throw new Exception($message, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);

		}

		$this->formaterObservation($infos);

		// 3) charge les données de votes et protocoles associés aux images

		if ($this->observation['images']) {

			$idsImages = array_keys($this->observation['images']);

			$votes = $this->sql->getVotesDesImages($idsImages, $this->protocole);

			$this->sql->ajouterInfosVotesProtocoles($votes, $this->observation['images']);

		}

		// 4) charge les commentaires et les votes associés -> modifie/créé $observation['commentaires']

		$commentaires = $this->getCommentaires();

		$this->ajouterCommentaires($commentaires);

		// désindexe le tableau (tel qu'apparement attendu par les applis), c'est une exception

		// TODO : corriger l'appli cliente pour utiliser les index puis supprimer cette ligne

		$this->observation['images'] = array_values($this->observation['images']);

		// autre élément de post-processing: le ce_utilisateur de l'observation non-numeric...

		$this->nettoyerAuteur();

		// Mettre en forme le résultat et l'envoyer pour affichage

		$resultat = new ResultatService();

		$resultat->corps = $this->observation;

		return $resultat;

	}

	private function getInfosObservationEtImages() {

		$obsChamps = $this->sql->getAliasDesChamps($this->mappings['observations'], null, 'do');

		$imgChamps = $this->sql->getAliasDesChamps($this->mappings['images'], null, 'di');

		// champs de l'annuaire (del_utilisateur): id_utilisateur prenom, nom, courriel

		$annuaireChamps = implode(', ', array(

			"IFNULL(du.prenom, do.prenom_utilisateur) AS `auteur.prenom`",

			"IFNULL(du.nom, do.nom_utilisateur) AS `auteur.nom`",

			"IFNULL(du.courriel, do.courriel_utilisateur) AS `auteur.courriel`"));

		$requete = "SELECT $obsChamps, $imgChamps, $annuaireChamps ".

			"FROM del_observation AS do ".

			"	LEFT JOIN del_image AS di ON (do.id_observation = di.ce_observation) ".

			"	LEFT JOIN del_utilisateur AS du ON (do.ce_utilisateur = du.id_utilisateur) ".

			"WHERE do.id_observation = {$this->idObs} ".

			'-- '.__FILE__.':'.__LINE__;

		//Debug::printr($requete);

		return $this->bdd->recupererTous($requete);

	}

	private function formaterObservation($infos) {

		$infos = array_filter($infos);

		foreach ($infos as $info) {

			$image = array_intersect_key($info, array_flip(array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original')));

			$urlImgTpl = $this->conteneur->getParametre('cel_img_url_tpl');

			$imageFormat = 'XL';

			$image['binaire.href'] = sprintf($urlImgTpl, $image['id_image'], $imageFormat);

			unset($info['id_image'], $info['date'], $info['hauteur'], $info['largeur'], $info['nom_original']);

			// ATTENTION : la requête retourne de nombreuses lignes avec les mêmes données (test de l'existence nécessaire)

			if (!isset($this->observation)) {

				$this->observation = $info;

				$this->observation['images'] = array();

			}

			if (!isset($this->observation['images'][$image['id_image']])) {

				$this->observation['images'][$image['id_image']] = $image;

			}

		}

	}

	private function getCommentaires() {

		$selectVotes = array('id_vote', 'ce_proposition', 'ce_utilisateur', 'valeur', 'date');

		$selectCommentaires = array('id_commentaire', 'ce_observation', 'ce_proposition', 'ce_commentaire_parent', 'texte',

			'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','proposition_retenue');

		$voteChamps = $this->sql->getAliasDesChamps($this->mappings['votes'], $selectVotes, 'cv');

		$commentaireChamps = $this->sql->getAliasDesChamps($this->mappings['commentaires'], $selectCommentaires, 'dc');

		// LEFT JOIN optionnel, mais explicatif : récupèration des infos de vote que pour les commentaires comportant un nom_sel "valide"

		$requete = "SELECT $commentaireChamps, $voteChamps ".

			"FROM del_commentaire AS dc ".

			"	LEFT JOIN del_commentaire_vote AS cv ".

			"	ON (cv.ce_proposition = dc.id_commentaire AND dc.nom_sel != '' AND dc.nom_sel IS NOT NULL) ".

			"WHERE ce_observation = {$this->idObs} ".

			'-- '.__FILE__.':'.__LINE__;

		$commentaires = $this->bdd->recupererTous($requete);

		return $commentaires;

	}

	private function ajouterCommentaires($commentaires) {

		if (!$commentaires) return;

		$ret = array();

		foreach ($commentaires as $comment) {

			$commentId = $comment['id_commentaire'];

			$voteId = $comment['vote.id'];

			if (!array_key_exists($commentId, $ret)) {

				$comment_extract = array_intersect_key($comment, array_flip($this->mappings['commentaires']));

				// cas particulier: conflit d'aliases avec del_commentaire_vote

				$comment_extract['auteur.id'] = $comment_extract['__auteur_com'];

				$comment_extract['date'] = $comment_extract['__date_com'];

				unset($comment_extract['__auteur_com'], $comment_extract['__date_com']);

				// toujours un éléments "votes", quand bien même il n'y en aurait pas

				$comment_extract['votes'] = array();

				$ret[$commentId] = $comment_extract;

			}

			if (!$comment['nom_sel'] || ! $voteId) continue;

			$vote = array_intersect_key($comment, array_flip($this->mappings['votes']));

			$ret[$commentId]['votes'][$voteId] = $vote;

		}

		$this->observation['commentaires'] = $ret;

	}

	private function nettoyerAuteur() {

		if (!isset($this->observation['auteur.id']) || !is_numeric($this->observation['auteur.id'])) {

			$this->observation['auteur.id'] = '0';

		}

		if (!isset($this->observation['auteur.nom'])) {

			$this->observation['auteur.nom'] = '[inconnu]';

		}

	}

	/**

	 * Modifie une observation directement dans le CEL en faisant un appel à un web service du CEL.

	 * Utilisé uniquement par les admins.

	 * Permet de dépublier une observation.

	 *

	 * @param array		$ressources tableau des informations contenues dans l'url après le nom du service

	 * @param array		$parametres contenu du post

	 * @return mixed	Chaine "OK" (en majuscule) en cas de succès, booléen "false" en cas d'échec

	 */

	public function modifier($ressources, $parametres) {

		$controlAcces = $this->conteneur->getControleAcces();

		$controlAcces->etreUtilisateurAvecDroitAdmin();

		$retour = false;

		if (isset($parametres['transmission'])) {

			$idObs = $ressources[0];

			$clientRest = $this->conteneur->getRestClient();

			$urlTpl = $this->conteneur->getParametre('urlServiceCelObs');

			$url = $urlTpl.$idObs;

			$retourCel = $clientRest->modifier($url, $parametres);

			$retour = preg_match('/^OK$/i', $retourCel) ? 'OK' : false;

			if ($retour === false) {

				$message = "Erreur du web service CEL : ".$retourCel;

				$code = RestServeur::HTTP_CODE_MAUVAISE_REQUETE;

				throw new Exception($message, $code);

			}

		} else {

			$message = "Ce web service doit contenir un paramètre 'transmission'.";

			$code = RestServeur::HTTP_CODE_MAUVAISE_REQUETE;

			throw new Exception($message, $code);

		}

		return $retour;

	}

}