Subversion Repositories eFlore/Applications.del

Rev

Rev 1381 | Show entire file | Ignore 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 
 
- 
 
 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 
	);
Line 19... Line 108...
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) {
44
- 
 
45 
		// Gestion des configuration du script
 - 
 
46 
		$this->configurer($ressources);
 131 
		if (!$ressources || count($ressources) != 1 ) {
47 
		$this->verifierConfiguration();
 - 
 
48
- 
 
49 
		// Lancement du service
 - 
 
50 
		$liaisons = $this->chargerLiaisons();
 - 
 
51 
		$observation = array();
 - 
 
52 
 
 - 
 
53 
		if($liaisons) {
 - 
 
54 
			$observation = $this->chargerObservation($liaisons);
 132 
			throw new Exception("Le service observation accepte un unique identifiant d'observation", RestServeur::HTTP_CODE_ERREUR);
55 
			// modifie $observation
 - 
 
56 
			$this->chargerImages($observation);
 - 
 
57 
			// modifie $observation
 - 
 
58 
			$this->chargerCommentaires($observation);
 - 
 
59 
		}
 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 
 
- 
 
 143 
 
- 
 
 144 
		// Gestion des configuration du script
- 
 
 145 
		$idobs = $ressources[0];
- 
 
 146 
		$protocole = isset($parametres['protocole']) && is_numeric($parametres['protocole']) ?intval($parametres['protocole']) : NULL;
- 
 
 147 
 
- 
 
 148 
		// 1) récupération de l'observation (et de ses images (v_del_image est une vue utilisant des INNER JOIN))
- 
 
 149 
		$liaisons = self::chargerObservation($this->bdd, $idobs);
- 
 
 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)
63 
			throw(new Exception());
 154 
			throw(new Exception());
64 
		}
 155 
		}
Line -... Line 156...
- 
 
 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...
- 
 
 183 
		if(!is_numeric($observation['auteur.id'])) $observation['auteur.id'] = "0";
- 
 
 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();
68 
		$resultat->corps = $observation;
 188 
		$resultat->corps = $observation;
69 
		return $resultat;
 189 
		return $resultat;
70 
	}
 - 
 
71
- 
 
72 
	/*-------------------------------------------------------------------------------
 - 
 
73 
	 							CONFIGURATION DU SERVICE
 - 
 
74 
	 --------------------------------------------------------------------------------*/
 - 
 
75 
	/**
 - 
 
76 
	 * Configuration du service en fonction du fichier de config config_del.ini
 - 
 
77 
	 * */
 - 
 
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 {
 - 
 
86 
			$this->id_observation = $ressources[0];
 - 
 
87 
		}
 - 
 
88 
	}
 - 
 
89
- 
 
90 
	/**
 - 
 
91 
	 * Vérifier que le service est bien configuré
- 
 
92 
	 * */
 - 
 
93 
	private function verifierConfiguration() {
 - 
 
94
- 
 
95 
		$erreurs = array();
 - 
 
96 
		$tableauImages = $this->conteneur->getParametre('observations');
 - 
 
97 
		if (empty($tableauImages)) {
 - 
 
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) {
 - 
 
101 
				$erreurs[] = '- paramètre "url_service" manquant ;';
 - 
 
102 
			}
 - 
 
103
- 
 
104 
			if ($this->conteneur->getParametre('url_images') == null) {
 - 
 
105 
				$erreurs[] = '- paramètre "url_images" manquant ;';
 - 
 
106 
			}
 - 
 
107
- 
 
Line 108... Line 190...
108 
		}
 190 
	}
109 
 
 - 
 
110 
		if (empty($this->mappingObservation)) {
 - 
 
111 
			$erreurs[] = '- le fichier de configuration ne contient pas le tableau [mapping_observation] ou celui-ci est vide ;';
 - 
 
112 
		} else {
 191 
 
113 
			$champsMappingObs = array('id_observation', 'date_observation', 'date_transmission', 'famille', 'nom_sel', 'nom_sel_nn', 'nt',
 - 
 
114 
								'ce_zone_geo', 'zone_geo', 'lieudit', 'station', 'courriel', 'ce_utilisateur', 'nom', 'prenom');
 - 
 
115
- 
 
116 
			foreach ($champsMappingObs as $champ) {
 192 
	static function chargerObservation($db, $idobs) {
117 
				if (!isset($this->mappingObservation[$champ])) {
 - 
 
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) {
 193 
		// prenom_utilisateur, nom_utilisateur, courriel_utilisateur sont exclus du mapping
128 
				if (!isset($this->mappingCommentaire[$champ])) {
 - 
 
129 
					$erreurs[] = '- le mapping du champ "'.$champ.'" pour le commentaire est manquant ;';
 - 
 
130 
				}
 - 
 
131 
			}
 194 
		// car nous utilisons une construction SQL élaborée pour eux (cf IFNULL ci-dessous)
132 
		}
 - 
 
133
195 
		$obs_fields = self::sqlFieldsToAlias(self::$mappings['observations'], NULL, 'dob');
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);
 - 
 
138 
		}
 196 
 
139 
	}
 - 
 
140
- 
 
141 
	/*-------------------------------------------------------------------------------
 - 
 
142 
								CHARGEMENT DES OBSERVATIONS
- 
 
143 
	--------------------------------------------------------------------------------*/
 197 
		$image_fields = self::sqlFieldsToAlias(self::$mappings['images'], NULL, 'dob');
144 
	/**
 - 
 
145 
	* Chargement depuis la bdd de toutes les liaisons entre images et observations
 - 
 
146 
	* */
 - 
 
147 
	private function chargerLiaisons() {
 198 
 
148
199 
		// champs de l'annuaire (del_utilisateur): id_utilisateur prenom, nom, courriel
149 
		$requeteLiaisons = 'SELECT *, dob.commentaire as dob_commentaire '.
 200 
		$annuaire_fields = implode(', ', array("IFNULL(du.prenom, prenom_utilisateur) AS `auteur.prenom`",
150 
						   'FROM '.$this->gestionBdd->formaterTable('del_observation', 'dob').
 201 
											   "IFNULL(du.nom, nom_utilisateur) AS `auteur.nom`",
151 
						   'INNER JOIN '.$this->gestionBdd->formaterTable('del_obs_image', 'doi').
 202 
											   "IFNULL(du.courriel, courriel_utilisateur) AS observateur"));
152 
						   'ON doi.id_observation = dob.id_observation '.
 203 
		return $db->recupererTous(sprintf(
153 
						   'LEFT JOIN del_utilisateur du '.
 204 
			'SELECT %s, %s, %s FROM v_del_image as dob'.
154 
						   'ON du.id_utilisateur = dob.ce_utilisateur '.
 - 
 
155 
						   'WHERE doi.id_observation = '.$this->id_observation;
 205 
			' LEFT JOIN del_utilisateur du ON CAST(du.id_utilisateur AS CHAR) = CAST(dob.ce_utilisateur AS CHAR)'.
156 
		$requeteLiaisons .=  ' GROUP BY doi.id_observation';
 - 
 
157 
		$requeteLiaisons .= ' ORDER BY date_transmission DESC ';
 - 
 
158 
		$requeteLiaisons .= $this->gestionBdd->getLimitSql();
 - 
 
159
206 
			' WHERE dob.id_observation = %d -- %s',
- 
 
 207 
			$obs_fields, $image_fields, $annuaire_fields, $idobs, __FILE__ . ':' . __LINE__));
Line 160... Line -...
160 
		return $this->bdd->recuperer($requeteLiaisons);
 - 
 
161 
	}
 208 
	}
162
209 
 
163 
	/**
 - 
 
164 
	* Retourner un tableau d'images formaté en fonction des liaisons trouvées
 210
165 
	* @param $liaisons les liaisons de la table del_obs_images
 211 
	// Charger les images et leurs votes associés
166 
	* */
 212 
	static function chargerVotesImage($db, $images, $protocole = NULL) {
167 
	private function chargerObservation($liaison) {
 213 
		if(!$images) return NULL;
- 
 
 214 
 
168 
 
 215 
 		$select = array('votes' =>
169 
		if($liaison['ce_utilisateur'] == 0) {
 - 
 
- 
 
 216 
						array('id_vote', 'ce_image', 'ce_protocole', 'ce_utilisateur', 'valeur', 'date', /* del_image_vote */),
- 
 
 217 
						'protocole' =>
Line 170... Line -...
170 
			$liaison['nom'] = $liaison['nom_utilisateur'];
 - 
 
171 
			$liaison['prenom'] =$liaison['prenom_utilisateur'];
 218 
						array('id_protocole', 'intitule', 'descriptif', 'tag' /* del_image_protocole */ ));
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(
 - 
 
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'),
 219 
		$vote_fields = self::sqlFieldsToAlias(self::$mappings['votes'], $select['votes'], 'v'); // "v": cf alias dans la requête
186 
			$this->gestionBdd->formaterTable('del_image', 'di'),
 - 
 
187 
			$observation['id_observation']));
 - 
 
188 
		if(!$images) return;
 - 
 
189 
		$images = $this->formaterImages($images);
 - 
 
190 
		// modifie $images
 - 
 
191 
		$this->chargerVotesImage($images);
 - 
 
192 
		$observation['images'] = $images;
 - 
 
193 
	}
 - 
 
194
- 
 
195 
	/**
 - 
 
196 
	* Charger les votes pour chaque image
 220 
		$proto_fields = self::sqlFieldsToAlias(self::$mappings['protocoles'], $select['protocole'], 'p');
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',
 - 
 
Line 201... Line -...
201 
			$this->gestionBdd->formaterTable('del_image_vote', 'v'),
 - 
 
202 
			$this->chargerClauseWhereVotesImage(),
 - 
 
203 
			__FILE__ . ':' . __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 
			}
 221
213 
		}
 - 
 
214 
	}
 222 
		$where = array();
215
223 
		$where[] = sprintf('v.ce_image IN (%s)',
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) : '';
 - 
 
226 
		return $where;
 - 
 
227 
	}
 - 
 
228
- 
 
229 
	/**
 - 
 
230 
	* Récupérer tous les commentaires au total
 - 
 
231 
	* @param array $observations la liste des observations à mettre à jour
 - 
 
232 
	* */
 - 
 
Line 233... Line 224...
233 
	private function chargerCommentaires(&$observation) {
 224 
						   implode(',', array_values(array_map(create_function('$a', 'return $a["id_image"];'), $images))));
234 
		$requeteCommentaires = 'SELECT * FROM '.$this->gestionBdd->formaterTable('del_commentaire', 'dc').
 225 
 
235 
							   'WHERE ce_observation = '.$observation['id_observation'];
 - 
 
236 
		$commentaires = $this->bdd->recupererTous($requeteCommentaires);
 - 
 
237 
		if(!$commentaires) return;
 - 
 
238 
 
 - 
 
239 
		$commentaires_formates = array();
 226 
		if ($protocole) {
240 
		foreach ($commentaires as $commentaire) {
 - 
 
241 
			$commentaire = $this->formaterCommentaire($commentaire);
 - 
 
242 
			if (isset($commentaire['nom_sel']) && $commentaire['nom_sel'] != null) {
 - 
 
243 
				$commentaire['votes'] = $this->chargerVotes($commentaire['id_commentaire']);
 - 
 
244 
			}
 - 
 
245 
			$commentaires_formates[$commentaire['id_commentaire']] = $commentaire;
 227 
			$where[] = "v.ce_protocole = $protocole";
246 
		}
 - 
 
247 
		$observation['commentaires'] = $commentaires_formates;
 - 
 
248 
	}
 - 
 
249
228 
		}
250 
	private function chargerVotes($id_commentaire) {
 229 
 
251 
		$requeteVotes = 'SELECT * FROM '.
 230 
		return $db->recupererTous(sprintf(
252 
			$this->gestionBdd->formaterTable('del_commentaire_vote').
 - 
 
253 
			'WHERE ce_proposition = '.$this->proteger($id_commentaire);
 - 
 
254 
		$resultatsVotes = $this->bdd->recupererTous($requeteVotes);
 - 
 
255 
		$votes = array();
 231 
			'SELECT %s, %s FROM del_image_vote AS v'.
Line 256... Line -...
256 
		foreach ($resultatsVotes as $vote) {
 - 
 
257 
			$id_vote = $vote['id_vote'];
 - 
 
258 
			$votes[$id_vote] = $this->formaterVote($vote);
 - 
 
259 
		}
 - 
 
260 
		return $votes;
 - 
 
261 
	}
 232 
			' INNER JOIN del_image_protocole p ON v.ce_protocole = p.id_protocole'.
262
233 
			' WHERE %s -- %s',
263
234 
			$vote_fields, $proto_fields,
- 
 
 235 
			$where ? implode(' AND ', $where) : 1,
- 
 
 236 
			__FILE__ . ':' . __LINE__));
- 
 
 237 
	}
264 
	/*-------------------------------------------------------------------------------
 238
- 
 
 239 
	/**
- 
 
 240 
	 * Formater une observation depuis une ligne liaison
- 
 
 241 
	 * @param $liaison liaison issue de la recherche
265 
								FORMATER ET METTRE EN FORME
 242 
	 * @return $observation l'observation mise en forme
266 
	--------------------------------------------------------------------------------*/
 243 
	 * Exemple: vote, au sortir de MySQL contient:
267
244 
	 * 'xxx' => 'blah', 'descriptif' => 'foo', 'valeur' => 3
- 
 
 245 
	 * et le tableau de mapping contient:
- 
 
 246 
	 * descriptif = protocole.descriptif, valeur = vote
268 
	/**
 247 
	 * Alors $retour[ contient:
- 
 
 248 
	 *
- 
 
 249 
	 * */
Line 269... Line 250...
269 
	 * Formater les images d'une observation
 250 
	static function mapVotesToImages($votes, &$images) {
270 
	 * @param array $images les images de l'observation
 - 
 
271 
	 * // TODO: en faire le maximum dans le SELECT
 251 
		if(!$votes) return;
272 
	 * */
 - 
 
273 
	private function formaterImages($images) {
 - 
 
274 
		$imagesRetour = array();
 - 
 
275 
		foreach ($images as $image) {
 - 
 
Line 276... Line -...
276
- 
 
277 
			$this->imageIds[] = $image['id_image'];
 - 
 
278 
			$imageCourante = array();
 - 
 
279 
			$imageCourante['id_image'] = $image['id_image'];
 - 
 
280 
			$imageCourante['date'] = $image['date_prise_de_vue'];
 - 
 
281 
			$imageCourante['binaire.href'] = sprintf($this->conteneur->getParametre('url_images'), $image['id_image']);
 - 
 
282 
			$imageCourante['hauteur'] = $image['hauteur'];
 - 
 
283 
			$imageRetour['largeur'] = $image['largeur'];
 252 
 
284
253 
		// pour chaque vote
285 
			$imagesRetour[] = $imageCourante;
 254 
		foreach ($votes as $vote) {
286 
		}
 - 
 
287
- 
 
288 
		return $imagesRetour;
 - 
 
289 
	}
- 
 
290
255 
			$imgid = $vote['image.id'];
291 
	/**
 256 
			$protoid = $vote['protocole.id'];
292 
	*  Formater une observation depuis une ligne liaison
 257
293 
	*  @param $liaison liaison issue de la recherche
 - 
 
294 
	*  @return $observation l'observation mise en forme
 - 
 
Line 295... Line -...
295 
	* */
 - 
 
296 
	private function formaterObservation($liaison) {
 - 
 
297 
		$observation = array();
 - 
 
298
- 
 
299 
		foreach ($this->mappingObservation as $nomOriginal => $nomFinal) {
 - 
 
300 
			$observation[$nomFinal] = $liaison[$nomOriginal];
 258 
			// un vote sans image associée ? est-ce possible ?
301 
		}
 - 
 
302
259 
			// if(!isset($images[$imgid])) continue;
303 
		$observation['images'] = array();
 260
304 
 
 261 
			if(!array_key_exists('protocoles_votes', $images[$imgid]) ||
305 
		return $observation;
 262 
			   !array_key_exists($protoid, $images[$imgid]['protocoles_votes'])) {
- 
 
 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
306 
	}
 274 
	static function chargerCommentaires($db, &$observation) {
- 
 
 275 
		$select = array('votes' =>
- 
 
 276 
						array('id_vote', 'ce_proposition', 'ce_utilisateur', 'valeur', 'date' /* del_commentaire_vote */),
- 
 
 277 
						'commentaires' =>
- 
 
 278 
						array('id_commentaire', 'ce_observation', 'ce_proposition', 'ce_commentaire_parent', 'texte',
- 
 
 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'));
- 
 
 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');
- 
 
 284 
 
- 
 
 285 
		$commentaires = $db->recupererTous(sprintf(
307
286 
			"SELECT %s, %s FROM del_commentaire as dc".
308 
	private function proteger($valeur) {
 287 
			// LEFT JOIN optionnel, mais explicatif:
309 
		if (is_array($valeur)) {
 288 
			// on ne récupère des infos de vote que pour les commentaires comportant un
310 
			return $this->bdd->protegerTableau($valeur);
 289 
			// nom_sel "valide"
311 
		} else {
 290 
			" LEFT JOIN del_commentaire_vote cv".
312 
			return $this->bdd->proteger($valeur);
 291 
			" ON cv.ce_proposition = dc.id_commentaire AND dc.nom_sel != '' AND dc.nom_sel IS NOT NULL".
- 
 
 292 
			" WHERE ce_observation = %d -- %s",
- 
 
 293 
			$comment_fields, $vote_fields,
- 
 
 294 
			$observation['id_observation'],
313 
		}
 295 
			__FILE__ . ':' . __LINE__));
- 
 
 296 
 
- 
 
 297 
		if(!$commentaires) return;
- 
 
 298 
 
314 
	}
 299 
		// les commentaires réunifiées et dont les votes sont mergés
- 
 
 300 
		$ret = array();
- 
 
 301 
		foreach ($commentaires as $comment) {
- 
 
 302 
			$commentid = $comment['id_commentaire'];
- 
 
 303 
			$voteid = $comment['vote.id'];
- 
 
 304 
 
315
305 
			if(!array_key_exists($commentid, $ret)) {
- 
 
 306 
				$comment_extract = array_intersect_key($comment, array_flip(self::$mappings['commentaires']));
- 
 
 307 
				// cas particulier: conflit d'aliases avec del_commentaire_vote
- 
 
 308 
				$comment_extract['auteur.id'] = $comment_extract['__auteur_com'];
- 
 
 309 
				$comment_extract['date'] = $comment_extract['__date_com'];
316 
	/**
 310 
				unset($comment_extract['__auteur_com'], $comment_extract['__date_com']);
317 
	*
 311 
 
318 
	* Formate un commentaire en fonction du fichier de configuration
 312 
				// toujours un éléments "votes", quand bien même il n'y en aurait pas
- 
 
 313 
				$comment_extract['votes'] = array();
319 
	*/
 314 
				$ret[$commentid] = $comment_extract;
320 
	private function formaterCommentaire($commentaire) {
 315 
			}
321 
		$commentaire_formate = array();
 316 
 
322 
		foreach ($this->mappingCommentaire as $nomOriginal => $nomFinal) {
 317 
			if(!$comment['nom_sel'] || ! $voteid) continue;
- 
 
 318 
			$vote = array_intersect_key($comment, array_flip(self::$mappings['votes']));
- 
 
 319 
			$ret[$commentid]['votes'][$voteid] = $vote;
323 
			if (isset($commentaire[$nomOriginal])) {
 320 
		}
324 
			$commentaire_formate[$nomFinal] = $commentaire[$nomOriginal];
 321 
		$observation['commentaires'] = $ret;
- 
 
 322 
	}
325 
			}
 323 
 
326 
		}
 324 
 
- 
 
 325 
	/* SQL helper
- 
 
 326 
	   Converti un tableau associatif et un préfix optionnel en une chaîne de champs adéquate
327 
		return $commentaire_formate;
 327 
	   à un SELECT MySQL.
328 
	}
 328 
	   $select (optionnel) restreint les champs mappés aux valeurs de $select.
329
329 
	   Si $select n'est pas fourni, toutes les clefs présentes dans $map seront présentes dans
330 
	/**
 330 
	   le SELECT en sortie */
Line 331... Line -...
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();
 - 
 
349 
		foreach ($votes as $vote) {
 - 
 
350 
			$retour_vote = array();
 - 
 
351 
			foreach ($vote as $param=>$valeur) {
 - 
 
352 
				if (strpos($this->mappingVotes[$param], 'protocole.') === 0) {
 - 
 
353 
					$retour_protocole[$this->mappingVotes[$param]] = $valeur;
 - 
 
354 
				} else {
 - 
 
355 
					$retour_vote[$this->mappingVotes[$param]] = $valeur;
 - 
 
356 
				}
 - 
 
357 
			}
 331 
	static function sqlFieldsToAlias($map, $select = NULL, $prefix = NULL) {
- 
 
 332 
		if($select) $arr = array_intersect_key($map, array_flip($select));
358 
			if (!isset($retour[$vote['ce_image']][$vote['ce_protocole']])) {
 333 
		else $arr = $map;