| New file |
|---|
| 0,0 → 1,212 |
|---|
| <?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`")); |
| |
| // TODO : bizarement MYSQL 5.6 retourne plusieurs fois les mêmes enregistrements d'où le DISTINCT (normalement inutile) |
| $requete = "SELECT DISTINCT $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; |
| } |
| } |
| Property changes: |
|---|
| Added: svnkit:entry:sha1-checksum |
|---|
| +4089895a5dcb7422fbe6b5f30ea02926993bd44b |
|---|
| \ No newline at end of property |
|---|