Subversion Repositories eFlore/Applications.del

Rev

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

Rev 1381 Rev 1385
Line 1... Line 1...
1
<?php
1
<?php
2
// declare(encoding='UTF-8');
-
 
3
/**
2
/**
4
	* Le web service observations récupère toutes les observations et, pour chacune d'elle, les
3
 * Le web service observations récupère toutes les information pour une observation:
5
	* images qui lui sont associées.
4
 * images, votes sur image et protocole, commentaires, votes sur commentaires, ...
6
 *
5
 *
7
 * @category	php 5.2
6
 * @category	php 5.2
8
 * @package	del
-
 
9
 * @subpackage images
-
 
10
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
7
 * @author		Raphaël Droz <raphael@tela-botanica.org>
11
 * @copyright	Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
8
 * @copyright	Copyright (c) 2013, Tela Botanica (accueil@tela-botanica.org)
12
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
9
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
13
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
10
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
14
 * @version	$Id: Bdd.php 403 2012-02-22 14:35:20Z gduche $
-
 
15
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Observations
11
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Observations
-
 
12
 *
-
 
13
 * @config-depend: "url_image" (dans configurations/config_observations.ini)
-
 
14
 *				   ex: http://www.tela-botanica.org/appli:cel-img:%09dXL.jpg
16
 */
15
 */
Line 17... Line 16...
17
 
16
 
-
 
17
// http://localhost/del/services/0.1/observations/#id => une observation donnée et ses images, SANS LES propositions & nombre de commentaire
-
 
18
 
-
 
19
require_once(dirname(__FILE__) . '/ListeObservations2.php');
18
// http://localhost/del/services/0.1/observations/#id => une observation donnée et ses images, SANS LES propositions & nombre de commentaire
20
 
Line -... Line 21...
-
 
21
class Observation {
-
 
22
 
-
 
23
	/* Map les champs MySQL vers les champs utilisés dans le JSON pour les clients pour
-
 
24
	   chacune des différentes tables utilisées pour le chargement de résultats ci-dessous.
-
 
25
	   - chargerObservation() (v_del_image)
-
 
26
	   - chargerVotesImage() (del_image_vote, del_image_protocole)
-
 
27
	   - chargerCommentaires() (del_commentaire_vote, del_commentaire).
-
 
28
	   Si la valeur vaut 1, aucun alias ne sera défini (nom du champ d'origine), cf consulter() */
-
 
29
	static $mappings = array(
-
 
30
		'observations' => array( // v_del_image
-
 
31
			"id_observation" => 1,
-
 
32
			"date_observation" => 1,
-
 
33
			"date_transmission" => 1, 
-
 
34
			"famille" => "determination.famille",
-
 
35
			"nom_sel" => "determination.ns",
-
 
36
			"nom_sel_nn" => "determination.nn",
-
 
37
			"nom_referentiel" => "determination.referentiel",
-
 
38
			"nt" => "determination.nt",
-
 
39
			"ce_zone_geo" => "id_zone_geo",
-
 
40
			"zone_geo" => 1,
-
 
41
			"lieudit" => 1,
-
 
42
			"station" => 1,
-
 
43
			"milieu" => 1,
-
 
44
			"ce_utilisateur" => "auteur.id",
-
 
45
			"mots_cles_texte" => "mots_cles_texte",
-
 
46
			"commentaire" => 1),
-
 
47
		/* exclus car issus de la jointure annuaire:
-
 
48
		   "nom" => "auteur.nom", // XXX: jointure annuaire
-
 
49
		   "prenom" => "auteur.prenom",  // XXX: jointure annuaire
-
 
50
		   "courriel" => "observateur",  // XXX: jointure annuaire */
-
 
51
		/* présents dans cel_obs mais exclus:
-
 
52
		   ordre, nom_ret, nom_ret_nn, latitude, longitude, altitude, geodatum
-
 
53
		   transmission, date_creation, date_modificationabondance, certitude, phenologie, code_insee_calcule */
-
 
54
 
-
 
55
		'images' => array( // v_del_image
-
 
56
			"id_image" => 1,
-
 
57
			"hauteur" => 1,
-
 
58
			// "largeur" => 1, inutile semble-t-il
-
 
59
			"date_prise_de_vue" => "date"),
-
 
60
		/* présents dans cel_images mais exclus:
-
 
61
		   i_commentaire, nom_original, publiable_eflore, i_mots_cles_texte, i_ordre,
-
 
62
		   i_ce_utilisateur, i_prenom_utilisateur, i_nom_utilisateur, i_courriel_utilisateur */
-
 
63
 
-
 
64
		'protocoles' => array( // del_image_protocole
-
 
65
			"ce_protocole" => "protocole.id",
-
 
66
			"id_protocole" => "protocole.id",
-
 
67
			"intitule" => "protocole.intitule",
-
 
68
			"descriptif" => "protocole.descriptif",
-
 
69
			"tag" => "protocole.tag"),
-
 
70
 
-
 
71
		/* See desc del_commentaire_vote & desc del_image_vote;
-
 
72
		   Les deux schémas sont similaires, à l'exception de ce_protocole
-
 
73
		   spécifique à del_image_vote et ce_proposition => ce_image */
-
 
74
		'votes' => array( // del_image_vote et del_commentaire_vote
-
 
75
			"id_vote" => "vote.id",
-
 
76
			"ce_proposition" => "proposition.id",
-
 
77
			"ce_image" => "image.id",
-
 
78
			"ce_utilisateur" => "auteur.id", // attention, conflit avec commentaire, cf ci-dessous
-
 
79
			"valeur" => "vote",
-
 
80
			"date" => 1, // attention, conflit avec commentaire, cf ci-dessous
-
 
81
			// absents du JSON, et pourtant présents dans services/configurations/config_mapping_votes.ini
-
 
82
			// (nécessiterait une propre jointure sur del_utilisateur)
-
 
83
			/* "nom" => "auteur.nom",
-
 
84
			"prenom" => "auteur.prenom",
-
 
85
			"courriel" => "auteur.courriel" */),
-
 
86
 
-
 
87
		'commentaires' => array( // del_commentaire
-
 
88
			"id_commentaire" => 1,
-
 
89
			"ce_observation" => "observation",
-
 
90
			"ce_proposition" => "proposition",
-
 
91
			"ce_commentaire_parent" => "id_parent",
-
 
92
 
-
 
93
			// les deux alias suivants sont particuliers afin d'éviter un conflit d'alias
-
 
94
			// lors des jointures avec del_commentaire_vote ci-dessus
-
 
95
			// (cf cas particulier dans la boucle de chargerCommentaires())
-
 
96
			"ce_utilisateur" => "__auteur_com",
-
 
97
			"date" => "__date_com",
-
 
98
 
-
 
99
			"texte" => 1,
-
 
100
			"utilisateur_nom" => "auteur.nom",
-
 
101
			"utilisateur_prenom" => "auteur.prenom",
-
 
102
			"utilisateur_courriel" => "auteur.courriel",
-
 
103
			"nom_sel" => 1,
-
 
104
			"nom_sel_nn" => 1,
-
 
105
			"nom_ret_nn" => 1,
-
 
106
			"proposition_initiale" => 1),
-
 
107
	);
19
class Observation {
108
 
20
	
109
	
21
	private $conteneur;
110
	private $conteneur;
22
	private $gestionBdd;
-
 
23
	private $bdd;
-
 
Line 24... Line 111...
24
	private $id_observation;
111
	private $gestionBdd;
25
	private $imageIds;
112
	private $bdd;
26
	
113
	
27
	public function __construct(Conteneur $conteneur = null) {
114
	public function __construct(Conteneur $conteneur = null) {
Line 39... Line 126...
39
	 * pour l'afficher.
126
	 * pour l'afficher.
40
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
127
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
41
	 * @param array $parametres les paramètres situés après le ? dans l'url
128
	 * @param array $parametres les paramètres situés après le ? dans l'url
42
	 * */
129
	 * */
43
	public function consulter($ressources, $parametres) {
130
	public function consulter($ressources, $parametres) {
-
 
131
		if (!$ressources || count($ressources) != 1 ) {
-
 
132
			throw new Exception("Le service observation accepte un unique identifiant d'observation", RestServeur::HTTP_CODE_ERREUR);
-
 
133
		}
-
 
134
 
-
 
135
		// initialise les mappings:
-
 
136
		// substitue les valeurs à 1 par le nom de la clef (pas d'alias de champ)
-
 
137
		array_walk(self::$mappings['observations'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
-
 
138
		array_walk(self::$mappings['images'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
-
 
139
		array_walk(self::$mappings['protocoles'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
-
 
140
		array_walk(self::$mappings['votes'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
-
 
141
		array_walk(self::$mappings['commentaires'], create_function('&$val, $k', 'if($val==1) $val = $k;'));
-
 
142
 
Line 44... Line 143...
44
		
143
 
45
		// Gestion des configuration du script
144
		// Gestion des configuration du script
46
		$this->configurer($ressources);
145
		$idobs = $ressources[0];
Line 47... Line 146...
47
		$this->verifierConfiguration();
146
		$protocole = isset($parametres['protocole']) && is_numeric($parametres['protocole']) ?intval($parametres['protocole']) : NULL;
48
		
147
 
49
		// Lancement du service
-
 
50
		$liaisons = $this->chargerLiaisons();
148
		// 1) récupération de l'observation (et de ses images (v_del_image est une vue utilisant des INNER JOIN))
51
		$observation = array();
149
		$liaisons = self::chargerObservation($this->bdd, $idobs);
52
 
-
 
53
		if($liaisons) {
-
 
54
			$observation = $this->chargerObservation($liaisons);
-
 
55
			// modifie $observation
-
 
56
			$this->chargerImages($observation);
-
 
57
			// modifie $observation
-
 
58
			$this->chargerCommentaires($observation);
-
 
59
		}
150
	
60
		else {
151
		if(!$liaisons) {
61
			header('HTTP/1.0 404 Not Found');
152
			header('HTTP/1.0 404 Not Found');
62
			// don't die (phpunit)
153
			// don't die (phpunit)
Line -... Line 154...
-
 
154
			throw(new Exception());
-
 
155
		}
-
 
156
 
-
 
157
		// 2) réassocie les images "à plat" à leur observation (merge)
-
 
158
		$observations = ListeObservations2::reformateObservationSimpleIndex($liaisons, $this->conteneur->getParametre('url_images'));
-
 
159
		// bien que dans notre cas il n'y est qu'une seule observation, issu de plusieurs images
-
 
160
		// dans $liaisons, $observation est un tableau (cf reformateObservation).
-
 
161
		// Considérons la chose comme telle au cas où le webservice doivent demain demander une paire
-
 
162
		// d'observations (... convergence ListeObservations)
-
 
163
 
-
 
164
		$observation = array_pop($observations);
-
 
165
 
-
 
166
		// 3) charge les données de votes et protocoles associés aux images
-
 
167
		if($observation['images']) {
-
 
168
			$votes = self::chargerVotesImage($this->bdd, $observation['images'], $protocole);
-
 
169
			// 3") merge/reformate les données retournées
-
 
170
			self::mapVotesToImages($votes,
-
 
171
								   $observation['images']);
-
 
172
		}
-
 
173
 
-
 
174
		// 4) charge les commentaires et les votes associés
-
 
175
		// modifie/créé $observation['commentaires']
-
 
176
		self::chargerCommentaires($this->bdd, $observation);
-
 
177
 
-
 
178
 
-
 
179
		// désindexe le tableau (tel qu'apparement attendu par les applis), c'est une exception
-
 
180
		// corriger l'appli cliente pour utiliser les index puis supprimer cette ligne
-
 
181
		$observation['images'] = array_values($observation['images']);
-
 
182
		// autre élément de post-processing: le ce_utilisateur de l'observation non-numeric...
63
			throw(new Exception());
183
		if(!is_numeric($observation['auteur.id'])) $observation['auteur.id'] = "0";
64
		}
184
		if(!isset($observation['auteur.nom'])) $observation['auteur.nom'] = '[inconnu]';
65
 
185
	
66
		// Mettre en forme le résultat et l'envoyer pour affichage
186
		// Mettre en forme le résultat et l'envoyer pour affichage
67
		$resultat = new ResultatService();
187
		$resultat = new ResultatService();
Line 68... Line -...
68
		$resultat->corps = $observation;
-
 
69
		return $resultat;
-
 
70
	}
-
 
71
	
-
 
72
	/*-------------------------------------------------------------------------------
-
 
73
	 							CONFIGURATION DU SERVICE
-
 
74
	 --------------------------------------------------------------------------------*/
188
		$resultat->corps = $observation;
75
	/**
189
		return $resultat;
76
	 * Configuration du service en fonction du fichier de config config_del.ini
190
	}
77
	 * */
191
 
78
	private function configurer($ressources) {
-
 
79
		$this->mappingObservation = $this->conteneur->getParametre('mapping_observation');
-
 
80
		$this->mappingVotes = $this->conteneur->getParametre('mapping_votes');
-
 
81
		$this->mappingCommentaire = $this->conteneur->getParametre('mapping_commentaire');
-
 
82
		if (empty($ressources) || sizeof($ressources) > 1 ) {
-
 
83
			$e = 'Le service observation accepete 1 et 1 seule ressource';
-
 
84
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
-
 
85
		} else {
192
	static function chargerObservation($db, $idobs) {
86
			$this->id_observation = $ressources[0];
-
 
87
		}
193
		// prenom_utilisateur, nom_utilisateur, courriel_utilisateur sont exclus du mapping
88
	}
-
 
89
	
-
 
90
	/**
194
		// car nous utilisons une construction SQL élaborée pour eux (cf IFNULL ci-dessous)
91
	 * Vérifier que le service est bien configuré 
-
 
92
	 * */
195
		$obs_fields = self::sqlFieldsToAlias(self::$mappings['observations'], NULL, 'dob');
93
	private function verifierConfiguration() {
-
 
94
	
196
 
95
		$erreurs = array();
-
 
96
		$tableauImages = $this->conteneur->getParametre('observations');
-
 
97
		if (empty($tableauImages)) {
197
		$image_fields = self::sqlFieldsToAlias(self::$mappings['images'], NULL, 'dob');
98
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [images] ou celui-ci est vide ;'; 
-
 
99
		} else {
-
 
100
			if ($this->conteneur->getParametre('url_service') == null) {
198
 
101
				$erreurs[] = '- paramètre "url_service" manquant ;';
199
		// champs de l'annuaire (del_utilisateur): id_utilisateur prenom, nom, courriel
102
			}
-
 
103
			
-
 
104
			if ($this->conteneur->getParametre('url_images') == null) {
-
 
105
				$erreurs[] = '- paramètre "url_images" manquant ;';
-
 
106
			}
200
		$annuaire_fields = implode(', ', array("IFNULL(du.prenom, prenom_utilisateur) AS `auteur.prenom`",
107
			
-
 
108
		}
-
 
109
 
-
 
110
		if (empty($this->mappingObservation)) {
201
											   "IFNULL(du.nom, nom_utilisateur) AS `auteur.nom`",
111
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_observation] ou celui-ci est vide ;';
-
 
112
		} else {
-
 
113
			$champsMappingObs = array('id_observation', 'date_observation', 'date_transmission', 'famille', 'nom_sel', 'nom_sel_nn', 'nt',
202
											   "IFNULL(du.courriel, courriel_utilisateur) AS observateur"));
114
								'ce_zone_geo', 'zone_geo', 'lieudit', 'station', 'courriel', 'ce_utilisateur', 'nom', 'prenom');
203
		return $db->recupererTous(sprintf(
115
			
-
 
116
			foreach ($champsMappingObs as $champ) {
-
 
117
				if (!isset($this->mappingObservation[$champ])) {
204
			'SELECT %s, %s, %s FROM v_del_image as dob'.
Line 118... Line -...
118
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour l\'observation est manquant ;';
-
 
119
				}				
-
 
120
			}
-
 
121
		}
-
 
122
		
-
 
123
		if (empty($this->mappingCommentaire)) {
-
 
124
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_commentaire] ou celui-ci est vide ;';
-
 
125
		} else {
-
 
126
			$champsMappingCom = array('id_commentaire', 'texte', 'ce_utilisateur', 'utilisateur_nom', 'utilisateur_prenom', 'utilisateur_courriel', 'date');
-
 
127
			foreach ($champsMappingCom as $champ) {
-
 
Line -... Line 205...
-
 
205
			' LEFT JOIN del_utilisateur du ON CAST(du.id_utilisateur AS CHAR) = CAST(dob.ce_utilisateur AS CHAR)'.
-
 
206
			' WHERE dob.id_observation = %d -- %s',
128
				if (!isset($this->mappingCommentaire[$champ])) {
207
			$obs_fields, $image_fields, $annuaire_fields, $idobs, __FILE__ . ':' . __LINE__));
-
 
208
	}
129
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour le commentaire est manquant ;';
209
 
-
 
210
	
-
 
211
	// Charger les images et leurs votes associés
-
 
212
	static function chargerVotesImage($db, $images, $protocole = NULL) {
-
 
213
		if(!$images) return NULL;
-
 
214
 
-
 
215
 		$select = array('votes' =>
-
 
216
						array('id_vote', 'ce_image', 'ce_protocole', 'ce_utilisateur', 'valeur', 'date', /* del_image_vote */),
130
				}
217
						'protocole' => 
-
 
218
						array('id_protocole', 'intitule', 'descriptif', 'tag' /* del_image_protocole */ ));
-
 
219
		$vote_fields = self::sqlFieldsToAlias(self::$mappings['votes'], $select['votes'], 'v'); // "v": cf alias dans la requête
-
 
220
		$proto_fields = self::sqlFieldsToAlias(self::$mappings['protocoles'], $select['protocole'], 'p');
131
			}
221
		
132
		}
222
		$where = array();
-
 
223
		$where[] = sprintf('v.ce_image IN (%s)',
-
 
224
						   implode(',', array_values(array_map(create_function('$a', 'return $a["id_image"];'), $images))));
-
 
225
 
-
 
226
		if ($protocole) {
-
 
227
			$where[] = "v.ce_protocole = $protocole";
-
 
228
		}
-
 
229
 
-
 
230
		return $db->recupererTous(sprintf(
133
		
231
			'SELECT %s, %s FROM del_image_vote AS v'.
Line 134... Line -...
134
		if (!empty($erreurs)) {
-
 
135
			$e = 'Erreur lors de la configuration : '."\n";
-
 
136
			$e .= implode("\n", $erreurs);
-
 
137
			throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);
232
			' INNER JOIN del_image_protocole p ON v.ce_protocole = p.id_protocole'.
138
		}
233
			' WHERE %s -- %s',
-
 
234
			$vote_fields, $proto_fields,
-
 
235
			$where ? implode(' AND ', $where) : 1,
-
 
236
			__FILE__ . ':' . __LINE__));
-
 
237
	}
-
 
238
	
-
 
239
	/**
-
 
240
	 * Formater une observation depuis une ligne liaison
-
 
241
	 * @param $liaison liaison issue de la recherche
139
	}
242
	 * @return $observation l'observation mise en forme
140
	
243
	 * Exemple: vote, au sortir de MySQL contient:
141
	/*-------------------------------------------------------------------------------
-
 
142
								CHARGEMENT DES OBSERVATIONS 
-
 
143
	--------------------------------------------------------------------------------*/
-
 
144
	/**
-
 
145
	* Chargement depuis la bdd de toutes les liaisons entre images et observations
-
 
146
	* */
244
	 * 'xxx' => 'blah', 'descriptif' => 'foo', 'valeur' => 3
147
	private function chargerLiaisons() {
-
 
148
	
-
 
149
		$requeteLiaisons = 'SELECT *, dob.commentaire as dob_commentaire '.
-
 
150
						   'FROM '.$this->gestionBdd->formaterTable('del_observation', 'dob').
-
 
151
						   'INNER JOIN '.$this->gestionBdd->formaterTable('del_obs_image', 'doi').
-
 
Line 152... Line 245...
152
						   'ON doi.id_observation = dob.id_observation '.
245
	 * et le tableau de mapping contient:
153
						   'LEFT JOIN del_utilisateur du '.
-
 
154
						   'ON du.id_utilisateur = dob.ce_utilisateur '.
-
 
155
						   'WHERE doi.id_observation = '.$this->id_observation;
-
 
156
		$requeteLiaisons .=  ' GROUP BY doi.id_observation';
246
	 * descriptif = protocole.descriptif, valeur = vote
157
		$requeteLiaisons .= ' ORDER BY date_transmission DESC ';
247
	 * Alors $retour[ contient:
158
		$requeteLiaisons .= $this->gestionBdd->getLimitSql();
-
 
159
		
248
	 *
Line 160... Line -...
160
		return $this->bdd->recuperer($requeteLiaisons);
-
 
161
	}
249
	 * */
162
	
250
	static function mapVotesToImages($votes, &$images) {
163
	/**
-
 
Line 164... Line 251...
164
	* Retourner un tableau d'images formaté en fonction des liaisons trouvées
251
		if(!$votes) return;
-
 
252
 
-
 
253
		// pour chaque vote
-
 
254
		foreach ($votes as $vote) {
165
	* @param $liaisons les liaisons de la table del_obs_images
255
			$imgid = $vote['image.id'];
-
 
256
			$protoid = $vote['protocole.id'];
-
 
257
			
-
 
258
			// un vote sans image associée ? est-ce possible ?
-
 
259
			// if(!isset($images[$imgid])) continue;
166
	* */
260
			
167
	private function chargerObservation($liaison) {
-
 
168
 
-
 
169
		if($liaison['ce_utilisateur'] == 0) {
-
 
170
			$liaison['nom'] = $liaison['nom_utilisateur'];
-
 
171
			$liaison['prenom'] =$liaison['prenom_utilisateur'];
-
 
172
		}
-
 
173
		
-
 
174
		$observation = $this->formaterObservation($liaison);
-
 
175
		return $observation;
-
 
176
	}
-
 
177
	
-
 
178
	/**
-
 
179
	 * Sélectionner toutes les images de chaque observation
-
 
180
	 * @param array $observations la liste des observations 
-
 
181
	 * */
-
 
182
	private function chargerImages(&$observation) {
-
 
183
		$images = $this->bdd->recupererTous(sprintf(
261
			if(!array_key_exists('protocoles_votes', $images[$imgid]) ||
Line 184... Line -...
184
			'SELECT * FROM %s INNER JOIN %s ON doi.id_image = di.id_image WHERE doi.id_observation = %d',
-
 
185
			$this->gestionBdd->formaterTable('del_obs_image', 'doi'),
262
			   !array_key_exists($protoid, $images[$imgid]['protocoles_votes'])) {
186
			$this->gestionBdd->formaterTable('del_image', 'di'),
-
 
187
			$observation['id_observation']));
263
				// extrait les champs spécifique au protocole (le LEFT JOIN de chargerVotesImage les ramène en doublons
-
 
264
				$protocole = array_intersect_key($vote, array_flip(self::$mappings['protocoles']));
-
 
265
				$images[$imgid]['protocoles_votes'][$protoid] = $protocole;
-
 
266
			}
-
 
267
 
-
 
268
			$vote = array_intersect_key($vote, array_flip(self::$mappings['votes']));
-
 
269
			$images[$imgid]['protocoles_votes'][$protoid]['votes'][$vote['vote.id']] = $vote;
-
 
270
		}
-
 
271
	}
-
 
272
 
-
 
273
	// Charger les commentaires et leurs votes associés
188
		if(!$images) return;
274
	static function chargerCommentaires($db, &$observation) {
-
 
275
		$select = array('votes' =>
-
 
276
						array('id_vote', 'ce_proposition', 'ce_utilisateur', 'valeur', 'date' /* del_commentaire_vote */),
189
		$images = $this->formaterImages($images);
277
						'commentaires' =>
-
 
278
						array('id_commentaire', 'ce_observation', 'ce_proposition', 'ce_commentaire_parent', 'texte',
190
		// modifie $images
279
							  'ce_utilisateur', 'utilisateur_prenom', 'utilisateur_nom', 'utilisateur_courriel',
-
 
280
							  'nom_sel', 'nom_sel_nn', 'nom_ret', 'nom_ret_nn', 'nt', 'famille', 'nom_referentiel', 'date',
-
 
281
							  'proposition_initiale'));
191
		$this->chargerVotesImage($images);
282
		$vote_fields = self::sqlFieldsToAlias(self::$mappings['votes'], $select['votes'], 'cv'); // "v": cf alias dans la requête
-
 
283
		$comment_fields = self::sqlFieldsToAlias(self::$mappings['commentaires'], $select['commentaires'], 'dc');
192
		$observation['images'] = $images;
284
 
193
	}
-
 
194
	
-
 
195
	/**
-
 
196
	* Charger les votes pour chaque image
-
 
197
	* */
-
 
198
	private function chargerVotesImage(&$images) {
-
 
199
		$resultatsVotes = $this->bdd->recupererTous(sprintf(
-
 
200
			'SELECT v.*, p.* FROM %s INNER JOIN del_image_protocole p ON v.ce_protocole = p.id_protocole %s -- %s',
-
 
201
			$this->gestionBdd->formaterTable('del_image_vote', 'v'),
-
 
202
			$this->chargerClauseWhereVotesImage(),
-
 
203
			__FILE__ . ':' . __LINE__));
-
 
Line 204... Line -...
204
		if(!$resultatsVotes) return;
-
 
205
 
-
 
206
		$votes = $this->formaterVotesImages($resultatsVotes);
-
 
207
		foreach ($images as $id => $image) {
-
 
208
			if (isset($votes[$image['id_image']])) {
-
 
209
				foreach($votes[$image['id_image']] as $id_vote => $vote_image) {
-
 
210
					$images[$id]['protocoles_votes'][$id_vote] = $vote_image;
-
 
211
				}
-
 
212
			}
-
 
213
		}
-
 
214
	}
-
 
215
	
-
 
216
	private function chargerClauseWhereVotesImage() {
-
 
217
		if (sizeof($this->imageIds) > 0) {
-
 
218
			$chaineImageIds = implode(',', $this->imageIds);
-
 
219
			$where[] = 'v.ce_image  IN ('.$chaineImageIds.')';
-
 
220
		}
-
 
221
		if (isset($this->parametres['protocole'])) {
-
 
222
			$where[] = 'v.ce_protocole = '.$this->proteger($this->parametres['protocole']);
-
 
223
		}
-
 
224
	
-
 
225
		$where = (!empty($where)) ? 'WHERE '.implode(' AND ', $where) : '';
285
		$commentaires = $db->recupererTous(sprintf(
Line 226... Line -...
226
		return $where;
-
 
227
	}
-
 
228
	
286
			"SELECT %s, %s FROM del_commentaire as dc".
229
	/**
-
 
230
	* Récupérer tous les commentaires au total
-
 
231
	* @param array $observations la liste des observations à mettre à jour
-
 
232
	* */
-
 
233
	private function chargerCommentaires(&$observation) {
-
 
234
		$requeteCommentaires = 'SELECT * FROM '.$this->gestionBdd->formaterTable('del_commentaire', 'dc').
-
 
235
							   'WHERE ce_observation = '.$observation['id_observation'];
-
 
236
		$commentaires = $this->bdd->recupererTous($requeteCommentaires);
-
 
237
		if(!$commentaires) return;
-
 
238
 
-
 
239
		$commentaires_formates = array();
-
 
240
		foreach ($commentaires as $commentaire) {
-
 
241
			$commentaire = $this->formaterCommentaire($commentaire);
-
 
242
			if (isset($commentaire['nom_sel']) && $commentaire['nom_sel'] != null) {
287
			// LEFT JOIN optionnel, mais explicatif:
243
				$commentaire['votes'] = $this->chargerVotes($commentaire['id_commentaire']);
288
			// on ne récupère des infos de vote que pour les commentaires comportant un
244
			}
289
			// nom_sel "valide"
245
			$commentaires_formates[$commentaire['id_commentaire']] = $commentaire;
290
			" LEFT JOIN del_commentaire_vote cv".
246
		}
-
 
247
		$observation['commentaires'] = $commentaires_formates;
-
 
248
	}
-
 
249
	
-
 
250
	private function chargerVotes($id_commentaire) {
291
			" ON cv.ce_proposition = dc.id_commentaire AND dc.nom_sel != '' AND dc.nom_sel IS NOT NULL".
251
		$requeteVotes = 'SELECT * FROM '.
-
 
252
			$this->gestionBdd->formaterTable('del_commentaire_vote').
292
			" WHERE ce_observation = %d -- %s",
253
			'WHERE ce_proposition = '.$this->proteger($id_commentaire);
293
			$comment_fields, $vote_fields,
254
		$resultatsVotes = $this->bdd->recupererTous($requeteVotes);
-
 
255
		$votes = array();
-
 
256
		foreach ($resultatsVotes as $vote) {
294
			$observation['id_observation'],
257
			$id_vote = $vote['id_vote'];
295
			__FILE__ . ':' . __LINE__));
258
			$votes[$id_vote] = $this->formaterVote($vote);
296
 
259
		}
-
 
260
		return $votes;
297
		if(!$commentaires) return;
261
	}
-
 
262
	
-
 
263
	
298
 
264
	/*-------------------------------------------------------------------------------
299
		// les commentaires réunifiées et dont les votes sont mergés
265
								FORMATER ET METTRE EN FORME
300
		$ret = array();
266
	--------------------------------------------------------------------------------*/
-
 
267
	
-
 
268
	/**
-
 
269
	 * Formater les images d'une observation
-
 
270
	 * @param array $images les images de l'observation
-
 
271
	 * // TODO: en faire le maximum dans le SELECT
-
 
272
	 * */
301
		foreach ($commentaires as $comment) {
273
	private function formaterImages($images) {
302
			$commentid = $comment['id_commentaire'];
274
		$imagesRetour = array();
-
 
275
		foreach ($images as $image) {
-
 
276
			
-
 
277
			$this->imageIds[] = $image['id_image'];
303
			$voteid = $comment['vote.id'];
278
			$imageCourante = array();
-
 
279
			$imageCourante['id_image'] = $image['id_image'];
304
 
280
			$imageCourante['date'] = $image['date_prise_de_vue'];
305
			if(!array_key_exists($commentid, $ret)) {
281
			$imageCourante['binaire.href'] = sprintf($this->conteneur->getParametre('url_images'), $image['id_image']);
306
				$comment_extract = array_intersect_key($comment, array_flip(self::$mappings['commentaires']));
282
			$imageCourante['hauteur'] = $image['hauteur'];
307
				// cas particulier: conflit d'aliases avec del_commentaire_vote
283
			$imageRetour['largeur'] = $image['largeur'];
-
 
284
			
308
				$comment_extract['auteur.id'] = $comment_extract['__auteur_com'];
285
			$imagesRetour[] = $imageCourante;
-
 
286
		}
-
 
287
		
-
 
288
		return $imagesRetour;
309
				$comment_extract['date'] = $comment_extract['__date_com'];
Line 289... Line -...
289
	} 
-
 
Line -... Line 310...
-
 
310
				unset($comment_extract['__auteur_com'], $comment_extract['__date_com']);
-
 
311
 
-
 
312
				// toujours un éléments "votes", quand bien même il n'y en aurait pas
-
 
313
				$comment_extract['votes'] = array();
-
 
314
				$ret[$commentid] = $comment_extract;
290
	
315
			}
-
 
316
 
-
 
317
			if(!$comment['nom_sel'] || ! $voteid) continue;
291
	/**
318
			$vote = array_intersect_key($comment, array_flip(self::$mappings['votes']));
-
 
319
			$ret[$commentid]['votes'][$voteid] = $vote;
Line 292... Line 320...
292
	*  Formater une observation depuis une ligne liaison
320
		}
293
	*  @param $liaison liaison issue de la recherche
-
 
294
	*  @return $observation l'observation mise en forme
321
		$observation['commentaires'] = $ret;
295
	* */
-
 
296
	private function formaterObservation($liaison) {
-
 
297
		$observation = array();
-
 
298
		
-
 
Line 299... Line -...
299
		foreach ($this->mappingObservation as $nomOriginal => $nomFinal) {
-
 
300
			$observation[$nomFinal] = $liaison[$nomOriginal];
-
 
301
		}
322
	}
302
		
-
 
303
		$observation['images'] = array();
-
 
304
 
-
 
305
		return $observation;
-
 
306
	}
-
 
307
	
-
 
308
	private function proteger($valeur) {
-
 
309
		if (is_array($valeur)) {
-
 
310
			return $this->bdd->protegerTableau($valeur);
-
 
311
		} else {
323
 
Line 312... Line -...
312
			return $this->bdd->proteger($valeur);
-
 
313
		}
-
 
314
	}
-
 
315
	
-
 
316
	/**
-
 
317
	*
-
 
318
	* Formate un commentaire en fonction du fichier de configuration
-
 
319
	*/
-
 
320
	private function formaterCommentaire($commentaire) {
-
 
321
		$commentaire_formate = array();
-
 
322
		foreach ($this->mappingCommentaire as $nomOriginal => $nomFinal) {
-
 
323
			if (isset($commentaire[$nomOriginal])) {
-
 
324
			$commentaire_formate[$nomFinal] = $commentaire[$nomOriginal];
-
 
325
			}
-
 
326
		}
-
 
327
		return $commentaire_formate;
-
 
328
	}
-
 
329
	
-
 
330
	/**
-
 
331
	*  Formater un vote en fonction du fichier de configuration config_votes.ini
-
 
332
	*  @param $votes array()
-
 
333
	* */
-
 
334
	private function formaterVote($vote) {
-
 
335
		$retour = array();
-
 
336
		foreach ($vote as $param => $valeur) {
-
 
337
			$retour[$this->mappingVotes[$param]] = $valeur;
-
 
338
		}
-
 
339
		return $retour;
-
 
340
	}
-
 
341
	
-
 
342
	/**
-
 
343
	*  Formater une observation depuis une ligne liaison
-
 
344
	*  @param $liaison liaison issue de la recherche
-
 
345
	*  @return $observation l'observation mise en forme
-
 
346
	* */
-
 
347
	private function formaterVotesImages($votes) {
-
 
348
		$retour = array();
324
 
349
		foreach ($votes as $vote) {
-
 
350
			$retour_vote = array();
325
	/* SQL helper