Subversion Repositories eFlore/Applications.del

Rev

Rev 1799 | Rev 1845 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1799 Rev 1840
Line 18... Line 18...
18
 
18
 
Line 19... Line 19...
19
// http://localhost/del/services/0.1/observations/#id => une observation donnée et ses images, SANS LES propositions & nombre de commentaire
19
// http://localhost/del/services/0.1/observations/#id => une observation donnée et ses images, SANS LES propositions & nombre de commentaire
Line 20... Line 20...
20
 
20
 
Line 21... Line 21...
21
require_once(dirname(__FILE__) . '/../DelTk.php');
21
require_once(dirname(__FILE__) . '/../DelTk.php');
22
 
22
 
23
class Observation {
-
 
24
 
-
 
25
	private $conteneur;
-
 
26
	private $bdd;
-
 
27
	/* Map les champs MySQL vers les champs utilisés dans le JSON pour les clients pour
-
 
28
	   chacune des différentes tables utilisées pour le chargement de résultats ci-dessous.
-
 
29
	   - chargerObservation() (v_del_image)
-
 
30
	   - chargerVotesImage() (del_image_vote, del_image_protocole)
-
 
31
	   - chargerCommentaires() (del_commentaire_vote, del_commentaire).
-
 
32
	   Si la valeur vaut 1, aucun alias ne sera défini (nom du champ d'origine), cf consulter() */
-
 
33
	static $mappings = array(
-
 
34
		'observations' => array( // v_del_image
-
 
35
			"id_observation" => 1,
-
 
36
			"date_observation" => 1,
-
 
37
			"date_transmission" => 1,
-
 
38
			"famille" => "determination.famille",
-
 
39
			"nom_sel" => "determination.ns",
-
 
40
			"nom_sel_nn" => "determination.nn",
-
 
41
			"nom_referentiel" => "determination.referentiel",
-
 
42
			"nt" => "determination.nt",
-
 
43
			"ce_zone_geo" => "id_zone_geo",
-
 
44
			"zone_geo" => 1,
-
 
45
			"lieudit" => 1,
-
 
46
			"station" => 1,
-
 
47
			"milieu" => 1,
-
 
48
			"ce_utilisateur" => "auteur.id",
-
 
49
			"mots_cles_texte" => "mots_cles_texte",
-
 
50
			"commentaire" => 1),
-
 
51
		/* exclus car issus de la jointure annuaire:
-
 
52
		   "nom" => "auteur.nom", // XXX: jointure annuaire
-
 
53
		   "prenom" => "auteur.prenom",  // XXX: jointure annuaire
-
 
54
		   "courriel" => "observateur",  // XXX: jointure annuaire */
-
 
55
		/* présents dans cel_obs mais exclus:
-
 
56
		   ordre, nom_ret, nom_ret_nn, latitude, longitude, altitude, geodatum
23
class ObservationDetails {
57
		   transmission, date_creation, date_modificationabondance, certitude, phenologie, code_insee_calcule */
24
 
58
 
-
 
59
		'images' => array( // v_del_image
-
 
60
			"id_image" => 1,
-
 
61
			"hauteur" => 1,
-
 
62
			// "largeur" => 1, inutile semble-t-il
-
 
63
			"date_prise_de_vue" => "date"),
-
 
64
		/* présents dans cel_images mais exclus:
-
 
65
		   i_commentaire, nom_original, publiable_eflore, i_mots_cles_texte, i_ordre,
-
 
66
		   i_ce_utilisateur, i_prenom_utilisateur, i_nom_utilisateur, i_courriel_utilisateur */
-
 
67
 
-
 
68
		'protocoles' => array( // del_image_protocole
-
 
69
			"ce_protocole" => "protocole.id",
25
	private $conteneur;
70
			"id_protocole" => "protocole.id",
-
 
71
			"intitule" => "protocole.intitule",
-
 
72
			"descriptif" => "protocole.descriptif",
-
 
73
			"tag" => "protocole.tag"),
-
 
74
 
-
 
75
		/* See desc del_commentaire_vote & desc del_image_vote;
-
 
76
		   Les deux schémas sont similaires, à l'exception de ce_protocole
-
 
77
		   spécifique à del_image_vote et ce_proposition => ce_image */
-
 
78
		'votes' => array( // del_image_vote et del_commentaire_vote
-
 
79
			"id_vote" => "vote.id",
-
 
80
			"ce_proposition" => "proposition.id",
-
 
81
			"ce_image" => "image.id",
-
 
82
			"ce_utilisateur" => "auteur.id", // attention, conflit avec commentaire, cf ci-dessous
-
 
83
			"valeur" => "vote",
-
 
84
			"date" => 1, // attention, conflit avec commentaire, cf ci-dessous
-
 
85
			// absents du JSON, et pourtant présents dans services/configurations/config_mapping_votes.ini
-
 
86
			// (nécessiterait une propre jointure sur del_utilisateur)
-
 
87
			/* "nom" => "auteur.nom",
-
 
88
			"prenom" => "auteur.prenom",
-
 
89
			"courriel" => "auteur.courriel" */),
26
	private $bdd;
90
 
-
 
91
		'commentaires' => array( // del_commentaire
-
 
92
			"id_commentaire" => 1,
-
 
93
			"ce_observation" => "observation",
-
 
94
			"ce_proposition" => "proposition",
-
 
95
			"ce_commentaire_parent" => "id_parent",
-
 
96
 
-
 
97
			// les deux alias suivants sont particuliers afin d'éviter un conflit d'alias
-
 
98
			// lors des jointures avec del_commentaire_vote ci-dessus
-
 
99
			// (cf cas particulier dans la boucle de chargerCommentaires())
-
 
100
			"ce_utilisateur" => "__auteur_com",
-
 
101
			"date" => "__date_com",
27
	private $sql;
102
 
-
 
103
			"texte" => 1,
-
 
104
			"utilisateur_nom" => "auteur.nom",
-
 
105
			"utilisateur_prenom" => "auteur.prenom",
-
 
106
			"utilisateur_courriel" => "auteur.courriel",
-
 
107
			"nom_sel" => 1,
-
 
108
			"nom_sel_nn" => 1,
-
 
109
			"nom_ret_nn" => 1,
28
	private $idObs;
110
			"nom_referentiel" => 1,
29
	private $protocole;
111
			"proposition_initiale" => 1),
30
	private $observation;
112
	);
-
 
113
 
-
 
114
	public function __construct(Conteneur $conteneur = null) {
-
 
115
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
31
	private $mappings = array();
116
		$this->conteneur->chargerConfiguration('config_votes.ini');
-
 
-
 
32
	
Line 117... Line -...
117
		$this->conteneur->chargerConfiguration('config_mapping_votes.ini');
-
 
118
		//$this->conteneur->chargerConfiguration('config_mapping_commentaires.ini');
33
	public function __construct(Conteneur $conteneur) {
119
		$this->bdd = $this->conteneur->getBdd();
34
		$this->conteneur = $conteneur;
120
	}
35
		$this->bdd = $this->conteneur->getBdd();
121
 
36
		$this->sql = $this->conteneur->getSql();
122
	/**
37
 
123
	 * Méthode principale de la classe.
-
 
124
	 * Lance la récupération des images dans la base et les place dans un objet ResultatService
38
		$this->mappings['observations'] = $this->conteneur->getParametreTableau('observations.mapping');
125
	 * pour l'afficher.
39
		$this->mappings['images'] = $this->conteneur->getParametreTableau('images.mapping');
126
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
-
 
127
	 * @param array $parametres les paramètres situés après le ? dans l'url
40
		$this->mappings['votes'] = $this->conteneur->getParametreTableau('votes.mapping');
Line 128... Line -...
128
	 * */
-
 
129
	public function consulter($ressources, $parametres) {
-
 
130
		if (!$ressources || count($ressources) != 1 ) {
-
 
131
			throw new Exception("Le service observation accepte un unique identifiant d'observation", RestServeur::HTTP_CODE_ERREUR);
-
 
132
		}
-
 
133
 
-
 
134
		// initialise les mappings:
-
 
135
		// substitue les valeurs à 1 par le nom de la clef (pas d'alias de champ)
-
 
136
		array_walk(self::$mappings['observations'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
-
 
137
		array_walk(self::$mappings['images'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
41
		$this->mappings['commentaires'] = $this->conteneur->getParametreTableau('commentaires.mapping');
138
		array_walk(self::$mappings['protocoles'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
42
		// les deux alias suivants sont particuliers afin d'éviter un conflit d'alias lors des jointures avec del_commentaire_vote
139
		array_walk(self::$mappings['votes'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
43
		$this->mappings['commentaires']['ce_utilisateur'] = '__auteur_com';
Line 140... Line 44...
140
		array_walk(self::$mappings['commentaires'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
44
		$this->mappings['commentaires']['date'] = '__date_com';
141
 
45
	}
142
 
-
 
143
		// Gestion des configuration du script
46
 
144
		$idobs = $ressources[0];
47
	public function consulter($ressources, $parametres) {
145
		$protocole = isset($parametres['protocole']) && is_numeric($parametres['protocole']) ?intval($parametres['protocole']) : NULL;
-
 
146
 
48
		$this->idObs = $ressources[0];
147
		// 1) récupération de l'observation (et de ses images (v_del_image est une vue utilisant des INNER JOIN))
49
		$this->protocole = isset($parametres['protocole']) && is_numeric($parametres['protocole']) ? intval($parametres['protocole']) : null;
148
		$liaisons = self::chargerObservation($this->bdd, $idobs);
-
 
149
 
-
 
150
		if(!$liaisons) {
-
 
151
			header('HTTP/1.0 404 Not Found');
-
 
152
			// don't die (phpunit)
-
 
153
			throw(new Exception());
-
 
154
		}
-
 
155
 
50
 
156
		// 2) réassocie les images "à plat" à leur observation (merge)
-
 
157
		// TODO: appliquer le formattage dépendant de la configuration en fin de processus
51
		// 1) récupération de l'observation (et de ses images (v_del_image est une vue utilisant des INNER JOIN))
158
		$observations = self::reformateObservationSimpleIndex($liaisons, $this->conteneur->getParametre('url_images'));
-
 
159
		// bien que dans notre cas il n'y ait qu'une seule observation, issue de plusieurs images
52
		$infos = $this->getInfosObservationEtImages();
160
		// dans $liaisons, $observation est un tableau (cf reformateObservation).
53
		if (! $infos) {
161
		// Considérons la chose comme telle au cas où le webservice doivent demain demander une paire
54
			$message = "Aucune observation ne possède d'identifiant '{$this->idObs}'.";
162
		// d'observations (... convergence avec ListeObservations & DelTk)
55
			throw new Exception($message, RestServeur::HTTP_CODE_RESSOURCE_INTROUVABLE);
163
 
56
		}
164
		$observation = array_pop($observations);
57
		$this->formaterObservation($infos);
Line 165... Line 58...
165
 
58
		//var_dump($this->observation);
166
		// 3) charge les données de votes et protocoles associés aux images
59
		// 3) charge les données de votes et protocoles associés aux images
167
		if ($observation['images']) {
60
		if ($this->observation['images']) {
Line 168... Line 61...
168
			$votes = self::chargerVotesImage($this->bdd, $observation['images'], $protocole);
61
			$idsImages = array_keys($this->observation['images']);
169
			// 3") merge/reformate les données retournées
62
			$votes = $this->sql->getVotesDesImages($idsImages, $this->protocole);
170
			self::mapVotesToImages($votes, $observation['images']);
63
			$this->sql->ajouterInfosVotesProtocoles($votes, $this->observation['images']);
171
		}
-
 
172
 
-
 
173
		// 4) charge les commentaires et les votes associés
-
 
174
		// modifie/créé $observation['commentaires']
-
 
175
		self::chargerCommentaires($this->bdd, $observation);
-
 
176
 
-
 
177
		// désindexe le tableau (tel qu'apparement attendu par les applis), c'est une exception
-
 
Line 178... Line 64...
178
		// corriger l'appli cliente pour utiliser les index puis supprimer cette ligne
64
		}
179
		$observation['images'] = array_values($observation['images']);
65
 
180
		// autre élément de post-processing: le ce_utilisateur de l'observation non-numeric...
-
 
Line 181... Line 66...
181
		if (!is_numeric($observation['auteur.id'])) {
66
		// 4) charge les commentaires et les votes associés -> modifie/créé $observation['commentaires']
182
			$observation['auteur.id'] = "0";
67
		$commentaires = $this->getCommentaires();
183
		}
68
		$this->ajouterCommentaires($commentaires);
184
		if (!isset($observation['auteur.nom'])) {
69
 
185
			$observation['auteur.nom'] = '[inconnu]';
70
		// désindexe le tableau (tel qu'apparement attendu par les applis), c'est une exception
Line 186... Line 71...
186
		}
71
		// TODO : corriger l'appli cliente pour utiliser les index puis supprimer cette ligne
187
 
-
 
188
		if (isset($parametres['justthrow'])) {
-
 
189
			return $observation;
72
		$this->observation['images'] = array_values($this->observation['images']);
190
		}
-
 
191
 
73
 
Line 192... Line 74...
192
		// Mettre en forme le résultat et l'envoyer pour affichage
74
		// autre élément de post-processing: le ce_utilisateur de l'observation non-numeric...
-
 
75
		$this->nettoyerAuteur();
193
		$resultat = new ResultatService();
76
 
194
		$resultat->corps = $observation;
77
		// Mettre en forme le résultat et l'envoyer pour affichage
195
		return $resultat;
78
		$resultat = new ResultatService();
196
	}
-
 
197
 
-
 
198
	static function chargerObservation($db, $idobs) {
-
 
199
		// prenom_utilisateur, nom_utilisateur, courriel_utilisateur sont exclus du mapping
-
 
200
		// car nous utilisons une construction SQL élaborée pour eux (cf IFNULL ci-dessous)
-
 
201
		$obs_fields = DelTk::sqlFieldsToAlias(self::$mappings['observations'], NULL, 'dob');
-
 
Line 202... Line -...
202
 
-
 
203
		$image_fields = DelTk::sqlFieldsToAlias(self::$mappings['images'], NULL, 'dob');
-
 
204
 
79
		$resultat->corps = $this->observation;
205
		// champs de l'annuaire (del_utilisateur): id_utilisateur prenom, nom, courriel
-
 
206
		$annuaire_fields = implode(', ', array("IFNULL(du.prenom, prenom_utilisateur) AS `auteur.prenom`",
-
 
207
											   "IFNULL(du.nom, nom_utilisateur) AS `auteur.nom`",
-
 
208
											   "IFNULL(du.courriel, courriel_utilisateur) AS `auteur.courriel`"));
-
 
209
		return $db->recupererTous(sprintf(
-
 
210
			'SELECT %s, %s, %s FROM v_del_image as dob'.
-
 
211
			' LEFT JOIN del_utilisateur du ON CAST(du.id_utilisateur AS CHAR) = CAST(dob.ce_utilisateur AS CHAR)'.
-
 
212
			' WHERE dob.id_observation = %d -- %s',
-
 
213
			$obs_fields, $image_fields, $annuaire_fields, $idobs, __FILE__ . ':' . __LINE__));
-
 
214
	}
-
 
215
 
-
 
216
 
80
		return $resultat;
217
	// Charger les images et leurs votes associés
-
 
218
	static function chargerVotesImage($db, $images, $protocole = NULL) {
-
 
219
		if (!$images) return NULL;
-
 
220
 
-
 
221
 		$select = array('votes' =>
-
 
222
						array('id_vote', 'ce_image', 'ce_protocole', 'ce_utilisateur', 'valeur', 'date', /* del_image_vote */),
-
 
223
						'protocole' =>
-
 
224
						array('id_protocole', 'intitule', 'descriptif', 'tag' /* del_image_protocole */ ));
-
 
225
		$vote_fields = DelTk::sqlFieldsToAlias(self::$mappings['votes'], $select['votes'], 'v'); // "v": cf alias dans la requête
-
 
226
		$proto_fields = DelTk::sqlFieldsToAlias(self::$mappings['protocoles'], $select['protocole'], 'p');
81
	}
227
 
82
 
228
		$where = array();
-
 
229
		$idsImages = array_values(array_map(create_function('$a', 'return $a["id_image"];'), $images));
-
 
230
		$where[] = sprintf('v.ce_image IN (%s)',
-
 
231
						   implode(',', $idsImages));
-
 
232
 
83
	private function getInfosObservationEtImages() {
233
		if ($protocole) {
-
 
234
			$where[] = "v.ce_protocole = $protocole";
84
		$obsChamps = $this->sql->getAliasDesChamps($this->mappings['observations'], null, 'dob');
235
		}
-
 
236
 
85
		$imgChamps = $this->sql->getAliasDesChamps($this->mappings['images'], null, 'dob');
237
		// pour une fois, on conserve l'ordre en ne luttant pas contre les IDs reçus
86
 
238
		$ordreDesIdsRecus = sprintf('FIELD(v.ce_image, %s)', implode(',', $idsImages));
87
		// champs de l'annuaire (del_utilisateur): id_utilisateur prenom, nom, courriel
239
		$req = sprintf(
88
		$annuaireChamps = implode(', ', array(
240
			'SELECT %s, %s FROM del_image_vote AS v'.
-
 
241
			' INNER JOIN del_image_protocole p ON v.ce_protocole = p.id_protocole'.
-
 
242
			' WHERE %s'.
-
 
243
			' ORDER BY %s -- %s',
89
			"IFNULL(du.prenom, prenom_utilisateur) AS `auteur.prenom`",
244
			$vote_fields,
-
 
245
			$proto_fields,
-
 
246
			($where ? implode(' AND ', $where) : 1),
-
 
247
			$ordreDesIdsRecus,
90
			"IFNULL(du.nom, nom_utilisateur) AS `auteur.nom`",
248
			__FILE__ . ':' . __LINE__);
-
 
249
 
-
 
250
		//echo "REQUETE: $req"; exit;
-
 
251
		return $db->recupererTous($req);
-
 
252
	}
91
			"IFNULL(du.courriel, courriel_utilisateur) AS `auteur.courriel`"));
253
 
92
 
254
	/**
93
		$requete = "SELECT $obsChamps, $imgChamps, $annuaireChamps ".
255
	 * Formater une observation depuis une ligne liaison
94
			"FROM v_del_image as dob ".
256
	 * @param $liaison liaison issue de la recherche
-
 
257
	 * @return $observation l'observation mise en forme
-
 
258
	 * Exemple: vote, au sortir de MySQL contient:
-
 
259
	 * 'xxx' => 'blah', 'descriptif' => 'foo', 'valeur' => 3
-
 
260
	 * et le tableau de mapping contient:
-
 
261
	 * descriptif = protocole.descriptif, valeur = vote
-
 
262
	 * Alors $retour[ contient:
95
			"LEFT JOIN del_utilisateur AS du ".
263
	 *
96
			"	ON CAST(du.id_utilisateur AS CHAR) = CAST(dob.ce_utilisateur AS CHAR) ".
264
	 * */
-
 
265
	static function mapVotesToImages($votes, &$images) {
97
			"WHERE dob.id_observation = {$this->idObs} ".
266
		if (!$votes) return;
-
 
267
 
-
 
268
		// pour chaque vote
98
			'-- '.__FILE__.':'.__LINE__;
269
		foreach ($votes as $vote) {
99
		//var_dump($requete);
270
			$imgid = $vote['image.id'];
100
		return $this->bdd->recupererTous($requete);
271
			$protoid = $vote['protocole.id'];
101
	}
272
 
102
 
Line 273... Line -...
273
			// un vote sans image associée ? est-ce possible ?
-
 
274
			// if(!isset($images[$imgid])) continue;
103
	private function formaterObservation($infos) {
275
 
-
 
276
			if(!array_key_exists('protocoles_votes', $images[$imgid]) ||
104
		$urlImgTpl = $this->conteneur->getParametre('cel_img_url_tpl');
277
			   !array_key_exists($protoid, $images[$imgid]['protocoles_votes'])) {
-
 
278
				// extrait les champs spécifique au protocole (le LEFT JOIN de chargerVotesImage les ramène en doublons
105
		$imageFormat = 'XL';
279
				$protocole = array_intersect_key($vote, array_flip(self::$mappings['protocoles']));
106
 
280
				$images[$imgid]['protocoles_votes'][$protoid] = $protocole;
107
		$infos = array_map('array_filter', $infos);
281
			}
108
		foreach ($infos as $info) {
-
 
109
			$image = array_intersect_key($info, array_flip(array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original')));
282
 
110
			$image['binaire.href'] = sprintf($urlImgTpl, $image['id_image'], $imageFormat);
283
			$vote = array_intersect_key($vote, array_flip(self::$mappings['votes']));
111
			unset($info['id_image'], $info['date'], $info['hauteur'], $info['largeur'], $info['nom_original']);
284
			$images[$imgid]['protocoles_votes'][$protoid]['votes'][$vote['vote.id']] = $vote;
112
 
285
		}
-
 
286
	}
-
 
287
 
113
			if (!isset($this->observation)) $this->observation = $info;
288
	// Charger les commentaires et leurs votes associés
114
			$this->observation['images'][$image['id_image']] = $image;
289
	static function chargerCommentaires($db, &$observation) {
115
		}
290
		$select = array('votes' =>
116
	}
291
						array('id_vote', 'ce_proposition', 'ce_utilisateur', 'valeur', 'date' /* del_commentaire_vote */),
117
 
292
						'commentaires' =>
118
	private function getCommentaires() {
293
						array('id_commentaire', 'ce_observation', 'ce_proposition', 'ce_commentaire_parent', 'texte',
119
		$selectVotes = array('id_vote', 'ce_proposition', 'ce_utilisateur', 'valeur', 'date');
-
 
120
		$selectCommentaires = array('id_commentaire', 'ce_observation', 'ce_proposition', 'ce_commentaire_parent', 'texte',
294
							  'ce_utilisateur', 'utilisateur_prenom', 'utilisateur_nom', 'utilisateur_courriel',
121
			'ce_utilisateur', 'utilisateur_prenom', 'utilisateur_nom', 'utilisateur_courriel',
295
							  'nom_sel', 'nom_sel_nn', 'nom_ret', 'nom_ret_nn', 'nt', 'famille', 'nom_referentiel', 'date',
122
			'nom_sel', 'nom_sel_nn', 'nom_ret', 'nom_ret_nn', 'nt', 'famille', 'nom_referentiel', 'date',
Line -... Line 123...
-
 
123
			'proposition_initiale');
-
 
124
 
-
 
125
		$voteChamps = $this->sql->getAliasDesChamps($this->mappings['votes'], $selectVotes, 'cv');
296
							  'proposition_initiale'));
126
		$commentaireChamps = $this->sql->getAliasDesChamps($this->mappings['commentaires'], $selectCommentaires, 'dc');
Line 297... Line -...
297
		$vote_fields = DelTk::sqlFieldsToAlias(self::$mappings['votes'], $select['votes'], 'cv'); // "v": cf alias dans la requête
-
 
298
		$comment_fields = DelTk::sqlFieldsToAlias(self::$mappings['commentaires'], $select['commentaires'], 'dc');
127
 
299
 
128
		// LEFT JOIN optionnel, mais explicatif : récupèration des infos de vote que pour les commentaires comportant un nom_sel "valide"
300
		$commentaires = $db->recupererTous(sprintf(
129
		$requete = "SELECT $commentaireChamps, $voteChamps ".
301
			"SELECT %s, %s FROM del_commentaire as dc".
130
			"FROM del_commentaire AS dc ".
-
 
131
			"	LEFT JOIN del_commentaire_vote AS cv ".
-
 
132
			"	ON (cv.ce_proposition = dc.id_commentaire AND dc.nom_sel != '' AND dc.nom_sel IS NOT NULL) ".
-
 
133
			"WHERE ce_observation = {$this->idObs} ".
Line 302... Line -...
302
			// LEFT JOIN optionnel, mais explicatif:
-
 
303
			// on ne récupère des infos de vote que pour les commentaires comportant un
-
 
304
			// nom_sel "valide"
134
			'-- '.__FILE__.':'.__LINE__;
305
			" LEFT JOIN del_commentaire_vote cv".
135
 
306
			" ON cv.ce_proposition = dc.id_commentaire AND dc.nom_sel != '' AND dc.nom_sel IS NOT NULL".
136
		$commentaires = $this->bdd->recupererTous($requete);
307
			" WHERE ce_observation = %d -- %s",
137
		return $commentaires;
Line 308... Line 138...
308
			$comment_fields, $vote_fields,
138
 
309
			$observation['id_observation'],
139
	}
310
			__FILE__ . ':' . __LINE__));
140
 
311
 
141
	private function ajouterCommentaires($commentaires) {
Line 312... Line 142...
312
		if (!$commentaires) return;
142
		if (!$commentaires) return;
313
 
143
 
314
		// les commentaires réunifiées et dont les votes sont mergés
144
		$ret = array();
315
		$ret = array();
145
		foreach ($commentaires as $comment) {
316
		foreach ($commentaires as $comment) {
146
			$commentId = $comment['id_commentaire'];
317
			$commentid = $comment['id_commentaire'];
147
			$voteId = $comment['vote.id'];
318
			$voteid = $comment['vote.id'];
148
 
319
 
-
 
320
			if (!array_key_exists($commentid, $ret)) {
-
 
321
				$comment_extract = array_intersect_key($comment, array_flip(self::$mappings['commentaires']));
149
			if (!array_key_exists($commentId, $ret)) {
322
				// cas particulier: conflit d'aliases avec del_commentaire_vote
150
				$comment_extract = array_intersect_key($comment, array_flip($this->mappings['commentaires']));
323
				$comment_extract['auteur.id'] = $comment_extract['__auteur_com'];
-
 
324
				$comment_extract['date'] = $comment_extract['__date_com'];
151
 
325
				unset($comment_extract['__auteur_com'], $comment_extract['__date_com']);
-
 
326
 
152
				// cas particulier: conflit d'aliases avec del_commentaire_vote
327
				// toujours un éléments "votes", quand bien même il n'y en aurait pas
-
 
328
				$comment_extract['votes'] = array();
-
 
329
				$ret[$commentid] = $comment_extract;
-
 
330
			}
-
 
331
 
153
				$comment_extract['auteur.id'] = $comment_extract['__auteur_com'];
332
			if (!$comment['nom_sel'] || ! $voteid) continue;
154
				$comment_extract['date'] = $comment_extract['__date_com'];
333
			$vote = array_intersect_key($comment, array_flip(self::$mappings['votes']));
155
				unset($comment_extract['__auteur_com'], $comment_extract['__date_com']);
334
			$ret[$commentid]['votes'][$voteid] = $vote;
-
 
335
		}
156
 
Line 336... Line 157...
336
		$observation['commentaires'] = $ret;
157
				// toujours un éléments "votes", quand bien même il n'y en aurait pas
337
	}
158
				$comment_extract['votes'] = array();
338
 
159
				$ret[$commentId] = $comment_extract;