761 |
gduche |
1 |
<?php
|
1845 |
jpm |
2 |
// declare(encoding='UTF-8');
|
761 |
gduche |
3 |
/**
|
1684 |
jpm |
4 |
* Web service retournant toutes les infos d'une observation donnée :
|
1385 |
raphael |
5 |
* images, votes sur image et protocole, commentaires, votes sur commentaires, ...
|
761 |
gduche |
6 |
*
|
1845 |
jpm |
7 |
* @category DEL
|
|
|
8 |
* @package Services
|
|
|
9 |
* @subpackage Observations
|
|
|
10 |
* @version 0.1
|
|
|
11 |
* @author Mathias CHOUET <mathias@tela-botanica.org>
|
|
|
12 |
* @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
|
|
|
13 |
* @author Aurelien PERONNET <aurelien@tela-botanica.org>
|
|
|
14 |
* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
|
|
|
15 |
* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
|
|
|
16 |
* @copyright 1999-2014 Tela Botanica <accueil@tela-botanica.org>
|
761 |
gduche |
17 |
*/
|
1840 |
jpm |
18 |
class ObservationDetails {
|
1385 |
raphael |
19 |
|
1684 |
jpm |
20 |
private $conteneur;
|
|
|
21 |
private $bdd;
|
1840 |
jpm |
22 |
private $sql;
|
|
|
23 |
private $idObs;
|
|
|
24 |
private $protocole;
|
|
|
25 |
private $observation;
|
|
|
26 |
private $mappings = array();
|
1845 |
jpm |
27 |
|
1840 |
jpm |
28 |
public function __construct(Conteneur $conteneur) {
|
|
|
29 |
$this->conteneur = $conteneur;
|
|
|
30 |
$this->bdd = $this->conteneur->getBdd();
|
|
|
31 |
$this->sql = $this->conteneur->getSql();
|
1385 |
raphael |
32 |
|
1840 |
jpm |
33 |
$this->mappings['observations'] = $this->conteneur->getParametreTableau('observations.mapping');
|
|
|
34 |
$this->mappings['images'] = $this->conteneur->getParametreTableau('images.mapping');
|
|
|
35 |
$this->mappings['votes'] = $this->conteneur->getParametreTableau('votes.mapping');
|
|
|
36 |
$this->mappings['commentaires'] = $this->conteneur->getParametreTableau('commentaires.mapping');
|
|
|
37 |
// les deux alias suivants sont particuliers afin d'éviter un conflit d'alias lors des jointures avec del_commentaire_vote
|
|
|
38 |
$this->mappings['commentaires']['ce_utilisateur'] = '__auteur_com';
|
|
|
39 |
$this->mappings['commentaires']['date'] = '__date_com';
|
761 |
gduche |
40 |
}
|
1666 |
jpm |
41 |
|
761 |
gduche |
42 |
public function consulter($ressources, $parametres) {
|
1840 |
jpm |
43 |
$this->idObs = $ressources[0];
|
|
|
44 |
$this->protocole = isset($parametres['protocole']) && is_numeric($parametres['protocole']) ? intval($parametres['protocole']) : null;
|
1385 |
raphael |
45 |
|
1840 |
jpm |
46 |
$infos = $this->getInfosObservationEtImages();
|
|
|
47 |
if (! $infos) {
|
|
|
48 |
$message = "Aucune observation ne possède d'identifiant '{$this->idObs}'.";
|
|
|
49 |
throw new Exception($message, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);
|
1379 |
raphael |
50 |
}
|
1840 |
jpm |
51 |
$this->formaterObservation($infos);
|
1881 |
jpm |
52 |
|
1385 |
raphael |
53 |
// 3) charge les données de votes et protocoles associés aux images
|
1881 |
jpm |
54 |
|
1840 |
jpm |
55 |
if ($this->observation['images']) {
|
|
|
56 |
$idsImages = array_keys($this->observation['images']);
|
|
|
57 |
$votes = $this->sql->getVotesDesImages($idsImages, $this->protocole);
|
|
|
58 |
$this->sql->ajouterInfosVotesProtocoles($votes, $this->observation['images']);
|
1385 |
raphael |
59 |
}
|
|
|
60 |
|
1840 |
jpm |
61 |
// 4) charge les commentaires et les votes associés -> modifie/créé $observation['commentaires']
|
|
|
62 |
$commentaires = $this->getCommentaires();
|
|
|
63 |
$this->ajouterCommentaires($commentaires);
|
1385 |
raphael |
64 |
|
|
|
65 |
// désindexe le tableau (tel qu'apparement attendu par les applis), c'est une exception
|
1840 |
jpm |
66 |
// TODO : corriger l'appli cliente pour utiliser les index puis supprimer cette ligne
|
|
|
67 |
$this->observation['images'] = array_values($this->observation['images']);
|
|
|
68 |
|
1385 |
raphael |
69 |
// autre élément de post-processing: le ce_utilisateur de l'observation non-numeric...
|
1840 |
jpm |
70 |
$this->nettoyerAuteur();
|
1389 |
raphael |
71 |
|
761 |
gduche |
72 |
// Mettre en forme le résultat et l'envoyer pour affichage
|
|
|
73 |
$resultat = new ResultatService();
|
1840 |
jpm |
74 |
$resultat->corps = $this->observation;
|
761 |
gduche |
75 |
return $resultat;
|
|
|
76 |
}
|
1385 |
raphael |
77 |
|
1840 |
jpm |
78 |
private function getInfosObservationEtImages() {
|
1881 |
jpm |
79 |
$obsChamps = $this->sql->getAliasDesChamps($this->mappings['observations'], null, 'do');
|
|
|
80 |
$imgChamps = $this->sql->getAliasDesChamps($this->mappings['images'], null, 'di');
|
1385 |
raphael |
81 |
|
2156 |
mathias |
82 |
// rétrocompatibilité champs de l'annuaire après suppression de del_utilisateur
|
1840 |
jpm |
83 |
$annuaireChamps = implode(', ', array(
|
2156 |
mathias |
84 |
"do.prenom_utilisateur AS `auteur.prenom`",
|
|
|
85 |
"do.nom_utilisateur AS `auteur.nom`",
|
|
|
86 |
"do.courriel_utilisateur AS `auteur.courriel`"));
|
1385 |
raphael |
87 |
|
1978 |
aurelien |
88 |
$requete = "SELECT $obsChamps, $imgChamps, $annuaireChamps ".
|
1881 |
jpm |
89 |
"FROM del_observation AS do ".
|
|
|
90 |
" LEFT JOIN del_image AS di ON (do.id_observation = di.ce_observation) ".
|
|
|
91 |
"WHERE do.id_observation = {$this->idObs} ".
|
1840 |
jpm |
92 |
'-- '.__FILE__.':'.__LINE__;
|
1881 |
jpm |
93 |
//Debug::printr($requete);
|
1922 |
jpm |
94 |
return $this->bdd->recupererTous($requete);
|
1385 |
raphael |
95 |
}
|
|
|
96 |
|
1840 |
jpm |
97 |
private function formaterObservation($infos) {
|
1881 |
jpm |
98 |
$infos = array_filter($infos);
|
1922 |
jpm |
99 |
foreach ($infos as $info) {
|
|
|
100 |
$image = array_intersect_key($info, array_flip(array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original')));
|
|
|
101 |
$urlImgTpl = $this->conteneur->getParametre('cel_img_url_tpl');
|
|
|
102 |
$imageFormat = 'XL';
|
|
|
103 |
$image['binaire.href'] = sprintf($urlImgTpl, $image['id_image'], $imageFormat);
|
|
|
104 |
unset($info['id_image'], $info['date'], $info['hauteur'], $info['largeur'], $info['nom_original']);
|
1881 |
jpm |
105 |
|
1922 |
jpm |
106 |
// ATTENTION : la requête retourne de nombreuses lignes avec les mêmes données (test de l'existence nécessaire)
|
|
|
107 |
if (!isset($this->observation)) {
|
|
|
108 |
$this->observation = $info;
|
|
|
109 |
$this->observation['images'] = array();
|
|
|
110 |
}
|
|
|
111 |
if (!isset($this->observation['images'][$image['id_image']])) {
|
|
|
112 |
$this->observation['images'][$image['id_image']] = $image;
|
|
|
113 |
}
|
|
|
114 |
}
|
761 |
gduche |
115 |
}
|
1666 |
jpm |
116 |
|
1840 |
jpm |
117 |
private function getCommentaires() {
|
|
|
118 |
$selectVotes = array('id_vote', 'ce_proposition', 'ce_utilisateur', 'valeur', 'date');
|
|
|
119 |
$selectCommentaires = array('id_commentaire', 'ce_observation', 'ce_proposition', 'ce_commentaire_parent', 'texte',
|
|
|
120 |
'ce_utilisateur', 'utilisateur_prenom', 'utilisateur_nom', 'utilisateur_courriel',
|
|
|
121 |
'nom_sel', 'nom_sel_nn', 'nom_ret', 'nom_ret_nn', 'nt', 'famille', 'nom_referentiel', 'date',
|
1938 |
aurelien |
122 |
'proposition_initiale','proposition_retenue');
|
1385 |
raphael |
123 |
|
1840 |
jpm |
124 |
$voteChamps = $this->sql->getAliasDesChamps($this->mappings['votes'], $selectVotes, 'cv');
|
|
|
125 |
$commentaireChamps = $this->sql->getAliasDesChamps($this->mappings['commentaires'], $selectCommentaires, 'dc');
|
1666 |
jpm |
126 |
|
1840 |
jpm |
127 |
// LEFT JOIN optionnel, mais explicatif : récupèration des infos de vote que pour les commentaires comportant un nom_sel "valide"
|
|
|
128 |
$requete = "SELECT $commentaireChamps, $voteChamps ".
|
|
|
129 |
"FROM del_commentaire AS dc ".
|
|
|
130 |
" LEFT JOIN del_commentaire_vote AS cv ".
|
|
|
131 |
" ON (cv.ce_proposition = dc.id_commentaire AND dc.nom_sel != '' AND dc.nom_sel IS NOT NULL) ".
|
|
|
132 |
"WHERE ce_observation = {$this->idObs} ".
|
|
|
133 |
'-- '.__FILE__.':'.__LINE__;
|
1666 |
jpm |
134 |
|
1840 |
jpm |
135 |
$commentaires = $this->bdd->recupererTous($requete);
|
|
|
136 |
return $commentaires;
|
761 |
gduche |
137 |
|
|
|
138 |
}
|
1361 |
raphael |
139 |
|
1840 |
jpm |
140 |
private function ajouterCommentaires($commentaires) {
|
1684 |
jpm |
141 |
if (!$commentaires) return;
|
1358 |
raphael |
142 |
|
1385 |
raphael |
143 |
$ret = array();
|
|
|
144 |
foreach ($commentaires as $comment) {
|
1840 |
jpm |
145 |
$commentId = $comment['id_commentaire'];
|
|
|
146 |
$voteId = $comment['vote.id'];
|
1385 |
raphael |
147 |
|
1840 |
jpm |
148 |
if (!array_key_exists($commentId, $ret)) {
|
|
|
149 |
$comment_extract = array_intersect_key($comment, array_flip($this->mappings['commentaires']));
|
|
|
150 |
|
1385 |
raphael |
151 |
// cas particulier: conflit d'aliases avec del_commentaire_vote
|
|
|
152 |
$comment_extract['auteur.id'] = $comment_extract['__auteur_com'];
|
|
|
153 |
$comment_extract['date'] = $comment_extract['__date_com'];
|
|
|
154 |
unset($comment_extract['__auteur_com'], $comment_extract['__date_com']);
|
|
|
155 |
|
|
|
156 |
// toujours un éléments "votes", quand bien même il n'y en aurait pas
|
|
|
157 |
$comment_extract['votes'] = array();
|
1840 |
jpm |
158 |
$ret[$commentId] = $comment_extract;
|
787 |
delphine |
159 |
}
|
1385 |
raphael |
160 |
|
1840 |
jpm |
161 |
if (!$comment['nom_sel'] || ! $voteId) continue;
|
|
|
162 |
$vote = array_intersect_key($comment, array_flip($this->mappings['votes']));
|
|
|
163 |
$ret[$commentId]['votes'][$voteId] = $vote;
|
787 |
delphine |
164 |
}
|
1840 |
jpm |
165 |
$this->observation['commentaires'] = $ret;
|
761 |
gduche |
166 |
}
|
|
|
167 |
|
1840 |
jpm |
168 |
private function nettoyerAuteur() {
|
1881 |
jpm |
169 |
if (!isset($this->observation['auteur.id']) || !is_numeric($this->observation['auteur.id'])) {
|
1840 |
jpm |
170 |
$this->observation['auteur.id'] = '0';
|
1490 |
raphael |
171 |
}
|
1840 |
jpm |
172 |
if (!isset($this->observation['auteur.nom'])) {
|
|
|
173 |
$this->observation['auteur.nom'] = '[inconnu]';
|
|
|
174 |
}
|
1490 |
raphael |
175 |
}
|
1385 |
raphael |
176 |
|
1684 |
jpm |
177 |
/**
|
|
|
178 |
* Modifie une observation directement dans le CEL en faisant un appel à un web service du CEL.
|
|
|
179 |
* Utilisé uniquement par les admins.
|
|
|
180 |
* Permet de dépublier une observation.
|
|
|
181 |
*
|
|
|
182 |
* @param array $ressources tableau des informations contenues dans l'url après le nom du service
|
|
|
183 |
* @param array $parametres contenu du post
|
1689 |
jpm |
184 |
* @return mixed Chaine "OK" (en majuscule) en cas de succès, booléen "false" en cas d'échec
|
1684 |
jpm |
185 |
*/
|
|
|
186 |
public function modifier($ressources, $parametres) {
|
2077 |
mathias |
187 |
$gestionUtilisateurs = $this->conteneur->getUtilisateur();
|
|
|
188 |
$gestionUtilisateurs->etreUtilisateurAvecDroitAdmin();
|
1690 |
jpm |
189 |
|
1684 |
jpm |
190 |
$retour = false;
|
|
|
191 |
if (isset($parametres['transmission'])) {
|
|
|
192 |
$idObs = $ressources[0];
|
|
|
193 |
$clientRest = $this->conteneur->getRestClient();
|
|
|
194 |
$urlTpl = $this->conteneur->getParametre('urlServiceCelObs');
|
|
|
195 |
$url = $urlTpl.$idObs;
|
1689 |
jpm |
196 |
$retourCel = $clientRest->modifier($url, $parametres);
|
|
|
197 |
$retour = preg_match('/^OK$/i', $retourCel) ? 'OK' : false;
|
1697 |
jpm |
198 |
if ($retour === false) {
|
|
|
199 |
$message = "Erreur du web service CEL : ".$retourCel;
|
|
|
200 |
$code = RestServeur::HTTP_CODE_MAUVAISE_REQUETE;
|
|
|
201 |
throw new Exception($message, $code);
|
|
|
202 |
}
|
|
|
203 |
} else {
|
|
|
204 |
$message = "Ce web service doit contenir un paramètre 'transmission'.";
|
|
|
205 |
$code = RestServeur::HTTP_CODE_MAUVAISE_REQUETE;
|
|
|
206 |
throw new Exception($message, $code);
|
1684 |
jpm |
207 |
}
|
|
|
208 |
return $retour;
|
|
|
209 |
}
|
1385 |
raphael |
210 |
}
|