Subversion Repositories eFlore/Applications.del

Rev

Rev 1798 | Rev 1855 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1798 Rev 1845
Line 1... Line 1...
1 
<?php
 1 
<?php
- 
 
 2 
// declare(encoding='UTF-8');
2 
/**
 3 
/**
3 
 * Le web service observations récupère toutes les observations et, pour chacune d'elle, les
 4 
 * Web service récupèrant toutes les observations et, pour chacune d'elle, les images qui lui sont associées.
4 
 * images qui lui sont associées.
 - 
 
5 
 * Basée sur la classe antérieure dans ListeObservations.php de
 - 
 
6 
 * Grégoire Duché et Aurélien Peronnet
 - 
 
7 
 * (formaterVote, formaterDeterminations, chargerNombreCommentaire, chargerVotes, chargerDeterminations)
 - 
 
8 
 *
 5 
 *
9 
 * @category	php 5.2
 - 
 
10 
 * @package		del
 - 
 
11 
 * @author		Raphaël Droz <raphael@tela-botanica.org>
 - 
 
12 
 * @copyright	Copyright (c) 2013 Tela Botanica (accueil@tela-botanica.org)
 6 
 * ATTENTION : le web service commence par récupérer seulement les id des obs (1er requete SQL), puis dans une
13 
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
 7 
 * deuxième requête SQL récupère les informations complémentaires. Il s'avère qu'en procédant ainsi le web service
14 
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
 8 
 * est 3 fois plus rapide !
15 
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Observations
 - 
 
16 
 *
 9 
 *
17 
 * TODO:
 10 
 * @category   DEL
- 
 
 11 
 * @package    Services
- 
 
 12 
 * @subpackage Observations
18 
 * PDO::prepare()
 13 
 * @version    0.1
- 
 
 14 
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
- 
 
 15 
 * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
19 
 * Sphinx pour auteur, genre, ns, commune, tag et masque-général
 16 
 * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
- 
 
 17 
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
- 
 
 18 
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
- 
 
 19 
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
20 
 */
 20 
 */
21 
 
 - 
 
22 
require_once(dirname(__FILE__) . '/../DelTk.php');
 - 
 
23 
/*
 - 
 
24 
  restore_error_handler();
 - 
 
25 
  restore_exception_handler();
 - 
 
26 
  error_reporting(E_ALL);
 - 
 
27 
*/
 - 
 
28 
 
 - 
 
29 
class ListeObservations {
 21 
class ListeObservations {
Line 30... Line 22...
30 
 
 22 
 
31 
	private $conteneur;
 23 
	private $conteneur;
- 
 
 24 
	private $bdd;
- 
 
 25 
	private $navigation;
- 
 
 26 
	private $filtrage;
32 
	private $bdd;
 27 
	private $sql;
33 
	private $parametres = array();
 28 
	private $parametres = array();
- 
 
 29 
	private $ressources = array();
- 
 
 30 
	private $mappings = array();
Line 34... Line -...
34 
	private $ressources = array();
 - 
 
35 
 
 - 
 
Line 36... Line -...
36 
	static $tris_possibles = array('date_observation');
 - 
 
37 
	// paramètres autorisés
 - 
 
38 
 
 - 
 
39 
	static $sql_fields_liaisons = array(
 - 
 
40 
		'dob' => array('id_observation', 'nom_sel AS `determination.ns`', 'nt AS `determination.nt`',
 - 
 
41 
			'nom_sel_nn AS `determination.nn`', 'famille AS `determination.famille`',
 - 
 
42 
			'nom_referentiel AS `determination.referentiel`',
 - 
 
43 
			'ce_zone_geo AS id_zone_geo', 'zone_geo', 'lieudit',
 - 
 
44 
			'station', 'milieu', 'date_observation', 'mots_cles_texte', 'date_transmission',
 - 
 
45 
			'ce_utilisateur AS `auteur.id`', 'prenom_utilisateur AS `auteur.prenom`',
 - 
 
46 
			'nom_utilisateur AS `auteur.nom`', 'courriel_utilisateur AS `auteur.courriel` ',
 - 
 
47 
			'commentaire'),
 - 
 
48 
		'di' => array('id_image', 'date_prise_de_vue AS `date`', 'hauteur',/* 'largeur','nom_original' // apparemment inutilisés */),
 - 
 
49 
		'du' => array('prenom', 'nom', 'courriel'),
 - 
 
50 
		'dc' => array('commentaire')
 31 
	private $paramsFiltres = array();
51 
	);
 32 
 
52 
 
 33 
 
53 
	public function __construct(Conteneur $conteneur = null) {
 - 
 
54 
		$this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
 - 
 
55 
		$this->conteneur->chargerConfiguration('config_departements_bruts.ini');
 - 
 
56 
		$this->conteneur->chargerConfiguration('config_observations.ini');
 - 
 
- 
 
 34 
	public function __construct(Conteneur $conteneur) {
57 
		$this->conteneur->chargerConfiguration('config_mapping_votes.ini');
 35 
		$this->conteneur = $conteneur;
- 
 
 36 
		$this->conteneur->chargerConfiguration('config_departements_bruts.ini');
58 
		//$this->conteneur->chargerConfiguration('config_mapping_commentaires.ini');
 37 
 
- 
 
 38 
		$this->bdd = $this->conteneur->getBdd();
Line 59... Line -...
59 
		$this->navigation = $conteneur->getNavigation();
 - 
 
60 
		$this->bdd = $this->conteneur->getBdd();
 - 
 
61 
    }
 - 
 
62 
 
 - 
 
63 
	static function reformateObservation($obs, $url_pattern = '') {
 - 
 
64 
		$obs = array_map('array_filter', $obs);
 - 
 
65 
		$obs_merged = array();
 - 
 
66 
		foreach ($obs as $o) {
 - 
 
67 
			$id = $o['id_observation'];
 - 
 
68 
 
 - 
 
69 
			// car auteur.id peut être un email, un hash, ou un annuaire_tela.U_ID
 - 
 
70 
			// mais dans les deux premiers cas SELECT courriel AS observateur fait déjà l'affaire
 - 
 
71 
			if (!isset($o['auteur.id']) || !is_numeric($o['auteur.id'])) $o['auteur.id'] = "0";
 39 
		$this->filtrage = $this->conteneur->getParametresFiltrage();
72 
			if (!isset($o['auteur.nom'])) $o['auteur.nom'] = '[inconnu]';
 40 
		$this->sql = $this->conteneur->getSql();
73 
 
 - 
 
74 
			$image = array_intersect_key($o, array_flip(array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original')));
 - 
 
75 
			$image['binaire.href'] = sprintf($url_pattern, $image['id_image']);
 41 
		$this->navigation = $this->conteneur->getNavigation();
76 
			unset($o['id_image'], $o['date'], $o['hauteur'], $o['largeur'], $o['nom_original']);
 - 
 
77 
			if (!isset($obs_merged['"' . $id . '"'])) $obs_merged['"' . $id . '"'] = $o;
 - 
 
Line 78... Line -...
78 
			$obs_merged['"' . $id . '"']['images'][] = $image;
 - 
 
79 
		}
 - 
 
80 
		return $obs_merged;
 - 
 
81 
    }
 - 
 
82 
 
 - 
 
83 
	/**
 - 
 
84 
	 * Méthode principale de la classe.
 - 
 
85 
	 * Lance la récupération des images dans la base et les place dans un objet ResultatService
 42 
 
86 
	 * pour l'afficher.
 43 
		$this->mappings['votes'] = $this->conteneur->getParametreTableau('votes.mapping');
87 
	 * @param array $ressources les ressources situées après l'url de base (ex : http://url/ressource1/ressource2)
 44 
		$this->mappings['commentaires'] = $this->conteneur->getParametreTableau('commentaires.mapping');
Line 88... Line 45...
88 
	 * @param array $parametres les paramètres situés après le ? dans l'url
 45 
	}
89 
	 **/
 46 
 
- 
 
 47 
	public function consulter($ressources, $parametres) {
90 
	public function consulter($ressources, $parametres) {
 48 
		$this->ressources = $ressources;
- 
 
 49 
		$this->parametres = $parametres;
Line 91... Line 50...
91 
		// SELECT, à terme, pourrait affecter getInfos(), mais en aucune manière getIdObs()
 50 
 
- 
 
 51 
		$this->paramsFiltres = $this->filtrage->filtrerUrlParamsAppliObs();
Line 92... Line -...
92 
		$req = array('select' => array(), 'join' => array(), 'where' => array(), 'groupby' => array(), 'having' => array());
 - 
 
93 
 
 - 
 
94 
		// toujours nécessaire puisque nous tapons sur v_del_image qui INNER JOIN cel_images, or nous voulons certes
 - 
 
95 
		// toutes les images, mais nous voulons $limite observations uniques.
 - 
 
96 
		$req['groupby'][] = 'vdi.id_observation';
 - 
 
97 
 
 - 
 
98 
		$db = $this->bdd;
 - 
 
99 
 
 - 
 
100 
		// filtrage de l'INPUT
 - 
 
101 
		$params = DelTk::requestFilterParams($parametres, DelTk::$parametres_autorises, $this->conteneur);
 - 
 
102 
 
 - 
 
103 
		$params['masque.tag'] = DelTk::buildTagsAST(@$parametres['masque.tag'], 'OR', ',');
 - 
 
104 
 
 - 
 
105 
		// ... et paramètres par défaut
 52 
		$this->sql->setParametres($this->paramsFiltres);
106 
		$params = array_merge(DelTk::$default_params, $params);
 53 
		$this->sql->ajouterContraintes();
107 
 
 - 
 
108 
		// création des contraintes (masques)
 54 
		$this->sql->ajouterConstrainteAppliObs();
109 
		DelTk::sqlAddConstraint($params, $db, $req);
 - 
 
110 
		self::sqlAddConstraint($params, $db, $req, $this->conteneur);
 55 
		$this->sql->definirOrdreSqlAppliObs();
111 
		self::sqlAddMasqueConstraint($params, $db, $req, $this->conteneur);
 - 
 
Line 112... Line 56...
112 
 
 56 
 
113 
		// 1) grunt-work: *la* requête de récupération des id valides (+ SQL_CALC_FOUND_ROWS)
 57 
		$idObs = $this->getIdObs();
114 
		$idobs_tab = self::getIdObs($params, $req, $db);
 58 
		$this->navigation->setTotal($this->sql->getTotalLignesTrouvees());
115 
		// idobs est une liste (toujours ordonnée) des id d'observations recherchées
 59 
 
Line 116... Line 60...
116 
		$idobs = array_values(array_map(create_function('$a', 'return $a["id_observation"];'), $idobs_tab));
 60 
		// Ce n'est pas la peine de continuer s'il n'y a pas eu de résultats
117 
 
 61 
		$resultat = new ResultatService();
Line 118... Line 62...
118 
		if ($idobs) {
 62 
		$resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => array());
119 
			$total = $db->recuperer('SELECT FOUND_ROWS() AS c'); $total = intval($total['c']);
 63 
		if (count($idObs) > 0) {
120 
 
 - 
 
121 
			// 2) récupération des données nécessaires pour ces observations (obs + images)
 64 
 
Line 122... Line 65...
122 
			// ici les champs récupérés sont issus de self::$sql_fields_liaisons mais sans préfixes
 65 
			// 2) récupération des données nécessaires pour ces observations (obs + images)
123 
			// car tout provient de v_del_image
 66 
			// ici les champs récupérés sont issus de self::$sql_fields_liaisons mais sans préfixes
124 
			$obs_unfmt = self::getInfos($idobs, $db);
 - 
 
125 
 
 - 
 
126 
			// 3) suppression, merge des données en tableau assez représentatif du futur JSON en output
 - 
 
127 
			$observations = self::reformateObservation($obs_unfmt, $this->conteneur->getParametre('url_images'));
 - 
 
128 
 
 - 
 
129 
			// 4) récupération des données nécessaires pour ces observations (commentaires + votes)
 - 
 
130 
			// modifie $observations
 - 
 
131 
			$this->configurer();
 - 
 
132 
			$this->chargerDeterminations($observations);
 - 
 
133 
 
 - 
 
134 
			// 5) restauration de l'ordre souhaité initialement
 - 
 
135 
			$observations = self::sortArrayByArray($observations, $idobs);
 - 
 
Line 136... Line -...
136 
		} else {
 - 
 
137 
			$observations = array();
 67 
			// car tout provient de v_del_image
138 
			$total = 0;
 - 
 
139 
		}
 - 
 
140 
 
 68 
			$obs_unfmt = $this->getInfos($idObs);
141 
		// 6) JSON output
 69 
 
142 
		$resultat = new ResultatService();
 - 
 
143 
		$resultat->corps = array('entete' => DelTk::makeJSONHeader($total, $params, Config::get('url_service')),
 70 
			// 3) suppression, merge des données en tableau assez représentatif du futur JSON en output
144 
			'resultats' => $observations);
 71 
			$observations = $this->formaterObservations($obs_unfmt);
145 
 
 72 
 
Line 146... Line 73...
146 
		return $resultat;
 73 
			// 4) récupération des données nécessaires pour ces observations (commentaires + votes)
147 
	}
 74 
			// modifie $observations
148 
 
 75 
			$this->chargerDeterminations($observations, $idObs);
Line 164... Line 91...
164 
	 *
 91 
	 *
165 
	 * @param p: $params (filtrés sauf escape-string)
 92 
	 * @param p: $params (filtrés sauf escape-string)
166 
	 * @param req: le tableau représentant les composants de la requete SQL
 93 
	 * @param req: le tableau représentant les composants de la requete SQL
167 
	 * @param db: l'instance de db
 94 
	 * @param db: l'instance de db
168 
	 */
 95 
	 */
169 
	static function getIdObs($p, $req, $db) {
 96 
	private function getIdObs() {
170 
		$req_s = sprintf('SELECT SQL_CALC_FOUND_ROWS id_observation' .
 97 
		$requete = 'SELECT SQL_CALC_FOUND_ROWS id_observation '.
171 
			' FROM v_del_image vdi'.
 98 
			'FROM v_del_image AS vdi '.
172 
			' %s' . // LEFT JOIN if any
 99 
			$this->sql->getJoin().
173 
			' WHERE %s'. // where-clause ou TRUE
 100 
			'WHERE '.$this->sql->getWhere().
174 
			' %s'. // group-by
 101 
			$this->sql->getGroupBy().
175 
			' %s'. // having (si commentaires)
 102 
			$this->sql->getOrderBy().
176 
			' ORDER BY %s %s %s'.
 103 
			$this->sql->getLimit().
177 
			' LIMIT %d, %d -- %s',
 104 
			' -- '.__FILE__.':'.__LINE__;
178 
 
 105 
 
179 
			$req['join'] ? implode(' ', $req['join']) : '',
 106 
		$resultats = $this->bdd->recupererTous($requete);
180 
			$req['where'] ? implode(' AND ', $req['where']) : 'TRUE',
 - 
 
181 
 
 - 
 
182 
			$req['groupby'] ? ('GROUP BY ' . implode(', ', array_unique($req['groupby']))) : '',
 - 
 
183 
			$req['having'] ? ('HAVING ' . implode(' AND ', $req['having'])) : '',
 - 
 
184 
 
 - 
 
185 
			$p['tri'], strtoupper($p['ordre']),
 - 
 
186 
			// date_transmission peut-être NULL et nous voulons de la consistence
 - 
 
187 
			// (sauf après r1860 de Cel)
 - 
 
188 
			$p['tri'] == 'date_transmission' ? ', id_observation' : '',
 - 
 
189 
 
 - 
 
190 
			$p['navigation.depart'], $p['navigation.limite'], __FILE__ . ':' . __LINE__);
 - 
 
191 
 
 107 
 
192 
		$res = $db->recupererTous($req_s);
 - 
 
193 
		$err = mysql_error();
 108 
		$idObs = array();
194 
		if (!$res && $err) {
 109 
		if ($resultats !== false ) {
195 
			// http_response_code(400);
 110 
			foreach ($resultats as $resultat) {
196 
			// if(defined('DEBUG') && DEBUG) header("X-Debug: $req_s");
 - 
 
197 
			throw new Exception('not found', 400);
 111 
				$idObs[] = $resultat['id_observation'];
- 
 
 112 
			}
198 
		}
 113 
		}
199 
		// ordre préservé, à partir d'ici c'est important.
 - 
 
200 
		return $res;
 114 
		return $idObs;
201 
	}
 115 
	}
Line 202... Line 116...
202 
 
 116 
 
203 
	/**
 - 
 
204 
	 * Champs récupérés:
 117 
	/**
205 
	 * Pour del_images, la vue retourne déjà ce que nous recherchons de cel_obs et cel_images
 - 
 
206 
	 * (cel_obs.* et cel_[obs_]images.{id_observation, id_image, date_prise_de_vue AS date, hauteur, largeur})
 118 
	 * Après avoir récupérer seulement les ids dans une première requête, nous récupérons maintenant les infos.
207 
	 * Pour del_commentaires: nous voulons *
 - 
 
208 
	 * Reste ensuite à formatter.
 - 
 
209 
	 * Note: le préfixe de table utilisé ici (vdi) n'impacte *aucune* autre partie du code car rien
 - 
 
210 
	 * n'en dépend pour l'heure. (inutilisation de $req['select'])
 119 
	 * Le web service est ainsi 3 fois plus rapide.
211 
	 */
 120 
	 */
212 
	static function getInfos($idobs, $db) {
 121 
	private function getInfos($idObs) {
213 
		/*$select_fields = implode(',', array_merge(
 122 
		$idsObsConcat = implode(',', $idObs);
214 
		 array_map(create_function('$a', 'return "vdi.".$a;'), self::$sql_fields_liaisons['dob']),
 123 
		$requete = "SELECT id_observation, nom_sel AS `determination.ns`, nt AS `determination.nt`, ".
215 
		 array_map(create_function('$a', 'return "vdi.".$a;'), self::$sql_fields_liaisons['di']),
 124 
			'nom_sel_nn AS `determination.nn`, famille AS `determination.famille`, '.
216 
		 array_map(create_function('$a', 'return "du.".$a;'), self::$sql_fields_liaisons['du'])));*/
 125 
			'nom_referentiel AS `determination.referentiel`, ce_zone_geo AS id_zone_geo, '.
217 
		$select_fields = array_merge(self::$sql_fields_liaisons['dob'], self::$sql_fields_liaisons['di']);
 126 
			'zone_geo, lieudit, station, milieu, date_observation, mots_cles_texte, '.
- 
 
 127 
			'date_transmission, commentaire, '.
- 
 
 128 
			'ce_utilisateur AS `auteur.id`, prenom_utilisateur AS `auteur.prenom`, '.
218 
		$req_s = sprintf('SELECT %s FROM v_del_image vdi'.
 129 
			'nom_utilisateur AS `auteur.nom`, courriel_utilisateur AS `auteur.courriel`, '.
219 
			// ' LEFT JOIN del_commentaire AS dc ON di.id_observation = dc.ce_observation AND dc.nom_sel IS NOT NULL'.
 130 
			'id_image, date_prise_de_vue AS `date`, hauteur, largeur, nom_original '.
220 
			' WHERE id_observation IN (%s)',
 131 
			'FROM v_del_image AS vdi '.
221 
			implode(',', $select_fields),
 132 
			"WHERE id_observation IN ($idsObsConcat) ".
222 
			implode(',', $idobs));
 133 
			' -- '.__FILE__.':'.__LINE__;
223 
		return $db->recupererTous($req_s);
 134 
		return $this->bdd->recupererTous($requete);
Line 224... Line 135...
224 
	}
 135 
	}
225 
 
 - 
 
226 
	/**
 - 
 
227 
	 * Complément à DelTk::sqlAddConstraint()
 136 
 
228 
	 *
 137 
	/**
229 
	 * @param $p les paramètres (notamment de masque) passés par l'URL et déjà traités/filtrés (sauf quotes)
 - 
 
230 
	 * @param $req le tableau, passé par référence représentant les composants de la requête à bâtir
 138 
	 * Les informations étant extraites d'une vue dont les infos des obs sont dupliquées pour chaque image,
231 
	 * @param $c conteneur, utilisé soit pour l'appel récursif à requestFilterParams() en cas de param "masque"
 139 
	 * il nous faut maintenant récupérer qu'une seule fois les données d'observations et y intégrer les données
232 
	 *								soit pour la définition du type (qui utilise la variable nb_commentaires_discussion)
 140 
	 * des images.
233 
	 */
 - 
 
234 
	static function sqlAddConstraint($p, $db, &$req, Conteneur $c = NULL) {
 - 
 
235 
		if (!empty($p['masque.tag'])) {
 141 
	 */
236 
			// TODO: remove LOWER() lorsqu'on est sur que les tags sont uniformés en minuscule
 - 
 
237 
			// i_mots_cles_texte provient de la VIEW v_del_image
 - 
 
238 
			if (isset($p['masque.tag']['AND'])) {
 - 
 
239 
				/* Lorsque nous interprêtons la chaîne provenant du masque général (cf: buildTagsAST($p['masque'], 'OR', ' ') dans sqlAddMasqueConstraint()),
 - 
 
240 
				nous sommes splittés par espace. Cependant, assurons que si une virgule à été saisie, nous n'aurons pas le motif
 - 
 
241 
				" AND CONCAT(mots_cles_texte, i_mots_cles_texte) REGEXP ',' " dans notre requête.
 142 
	private function formaterObservations($observations) {
242 
				XXX: Au 12/11/2013, une recherche sur tag depuis le masque général implique un OU, donc le problème ne se pose pas ici */
 143 
		$observations = array_map('array_filter', $observations);
- 
 
 144 
		$obsFormatees = array();
243 
				$subwhere = array();
 145 
		foreach ($observations as $obs) {
244 
				foreach ($p['masque.tag']['AND'] as $tag) {
 146 
			$this->nettoyerAuteur($obs);
245 
					if (trim($tag) == ',') continue;
 147 
			$image = $this->extraireInfosImage($obs);
246 
 
 - 
 
247 
					$subwhere[] = sprintf('LOWER(CONCAT(%s)) REGEXP %s',
 148 
 
248 
						DelTk::sqlAddIfNullPourConcat(array('vdi.mots_cles_texte', 'vdi.i_mots_cles_texte')),
 - 
 
249 
						$db->proteger(strtolower($tag)));
 149 
			$id = 'idx-'.$obs['id_observation'];
250 
				}
 - 
 
251 
				$req['where'][] = '(' . implode(' AND ', $subwhere) . ')';
 - 
 
252 
			} else {
 - 
 
253 
				$req['where'][] = sprintf('LOWER(CONCAT(%s)) REGEXP %s',
 - 
 
254 
					DelTk::sqlAddIfNullPourConcat(array('vdi.mots_cles_texte', 'vdi.i_mots_cles_texte')),
 150 
			if (!isset($obsFormatees[$id])) {
- 
 
 151 
				$obsFormatees[$id] = $obs;
255 
					$db->proteger(strtolower(implode('|', $p['masque.tag']['OR']))));
 152 
			}
256 
			}
 - 
 
257 
		}
 153 
			$obsFormatees[$id]['images'][] = $image;
258 
 
 - 
 
259 
		if (!empty($p['masque.type'])) {
 - 
 
260 
			self::addTypeConstraints($p['masque.type'], $db, $req, $c);
 154 
		}
Line 261... Line -...
261 
		}
 - 
 
262 
	}
 - 
 
263 
 
 - 
 
264 
	/** Le masque fait une recherche générique parmi de nombreux champs ci-dessus.
 - 
 
265 
	 * Nous initialisons donc ces paramètres (excepté masque biensur), et nous rappelons
 - 
 
266 
	 * récursivement. À la seule différence que nous n'utiliserons que $or_req['where']
 - 
 
267 
	 * imploded par des " OR ".
 - 
 
268 
	 */
 - 
 
269 
	static function sqlAddMasqueConstraint($p, $db, &$req, Conteneur $c = NULL) {
 - 
 
270 
		if (!empty($p['masque'])) {
 155 
		return $obsFormatees;
271 
			$or_params = array('masque.auteur' => $p['masque'],
 - 
 
272 
				'masque.departement' => $p['masque'],
 - 
 
273 
				'masque.id_zone_geo' => $p['masque'],
 - 
 
274 
				'masque.tag' => $p['masque'],
 - 
 
275 
				'masque.ns' => $p['masque'],
 - 
 
276 
				'masque.famille' => $p['masque'],
 - 
 
277 
				'masque.date' => $p['masque'],
 156 
	}
278 
				'masque.genre' => $p['masque'],
 157 
 
279 
				/* milieu: TODO ? */ );
 - 
 
280 
			/* Cependant les champs spécifiques ont priorité sur le masque général.
 - 
 
281 
			Pour cette raison nous supprimons la génération de SQL du masque général sur les
 - 
 
282 
			champ spécifiques qui feront l'objet d'un traitement avec une valeur propre. */
 - 
 
283 
			if (isset($p['masque.auteur'])) unset($or_params['masque.auteur']);
 158 
	private function nettoyerAuteur(&$obs) {
284 
			if (isset($p['masque.departement'])) unset($or_params['masque.departement']);
 - 
 
285 
			if (isset($p['masque.id_zone_geo'])) unset($or_params['masque.id_zone_geo']);
 - 
 
286 
			if (isset($p['masque.tag'])) unset($or_params['masque.tag']);
 - 
 
287 
			if (isset($p['masque.famille'])) unset($or_params['masque.famille']);
 - 
 
288 
			if (isset($p['masque.date'])) unset($or_params['masque.date']);
 - 
 
289 
			if (isset($p['masque.genre'])) unset($or_params['masque.genre']);
 - 
 
290 
 
 159 
		// car auteur.id peut être un email, un hash, ou un annuaire_tela.U_ID
291 
 
 - 
 
292 
			$or_masque = DelTk::requestFilterParams($or_params, array_keys($or_params), $c);
 160 
		// mais dans les deux premiers cas SELECT courriel AS observateur fait déjà l'affaire
293 
			if (isset($or_params['masque.tag'])) {
 - 
 
294 
				$or_masque['masque.tag'] = DelTk::buildTagsAST($p['masque'], 'OR', ' ');
 - 
 
295 
			}
 - 
 
296 
 
 - 
 
297 
			// $or_req = array('select' => array(), 'join' => array(), 'where' => array(), 'groupby' => array(), 'having' => array());
 - 
 
298 
			$or_req = array('join' => array(), 'where' => array());
 - 
 
299 
			DelTk::sqlAddConstraint($or_masque, $db, $or_req);
 161 
		if (!isset($obs['auteur.id']) || !is_numeric($obs['auteur.id'])) {
300 
			self::sqlAddConstraint($or_masque, $db, $or_req);
 - 
 
301 
 
 162 
			$obs['auteur.id'] = "0";
302 
			if ($or_req['where']) {
 - 
 
303 
				$req['where'][] = '(' . implode(' OR ', $or_req['where']) . ')';
 - 
 
304 
				// utile au cas ou des jointures seraient rajoutées
 163 
		}
305 
				$req['join'] = array_unique(array_merge($req['join'], $or_req['join']));
 164 
		if (!isset($obs['auteur.nom'])) {
Line 306... Line 165...
306 
			}
 165 
			$obs['auteur.nom'] = '[inconnu]';
307 
		}
 166 
		}
308 
	}
 167 
	}
309 
 
 - 
 
Line 310... Line -...
310 
	private function configurer() {
 - 
 
311 
		$this->mappingVotes = $this->conteneur->getParametre('mapping_votes');
 - 
 
312 
		$this->mappingCommentaire = $this->conteneur->getParametreTableau('commentaires.mapping');
 - 
 
313 
	}
 - 
 
314 
 
 - 
 
315 
	/**
 - 
 
316 
	 * @param $req: la représentation de la requête MySQL complète, à amender.
 168 
 
317 
	 */
 169 
	private function extraireInfosImage(&$obs) {
318 
	static function addTypeConstraints($val, $db, &$req, Conteneur $c) {
 - 
 
319 
		if (array_key_exists('adeterminer', $val)) {
 - 
 
320 
			// On récupère toutes les observations qui on le tag "aDeterminer" *ou* qui n'ont pas de nom d'espèce
 - 
 
321 
			// *ou* qui ont la "certitude" à ("aDeterminer" *ou* "douteux")
 - 
 
322 
			$req['where'][] = '(' . implode(' OR ', array(
 - 
 
323 
				'vdi.certitude = "aDeterminer"',
 - 
 
324 
				'vdi.certitude = "douteux"',
 - 
 
325 
				'vdi.mots_cles_texte LIKE "%aDeterminer%"',
 - 
 
326 
				'vdi.nom_sel_nn IS NULL',
 - 
 
327 
				'vdi.nom_sel_nn = 0', // il ne DEVRAIT pas y avoir d'entrées à 0, mais il y en a quand-même !!
 - 
 
328 
				)) . ')';
 - 
 
Line 329... Line -...
329 
		}
 - 
 
330 
		if (array_key_exists('validees', $val)) {
 - 
 
331 
			//On récupère toutes les observations ayant un commentaire doté de proposition_retenue = 1
 - 
 
332 
			$req['join'][] = 'INNER JOIN del_commentaire AS dc ON vdi.id_observation = dc.ce_observation AND dc.proposition_retenue = 1';
 170 
		$champsImageAffichables = array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original');
333 
		}
 - 
 
334 
 
 - 
 
335 
		// solution n°1: impraticable
 171 
		$image = array_intersect_key($obs, array_flip($champsImageAffichables));
336 
		if (false && array_key_exists('endiscussion', $val)) {
 - 
 
337 
			//Si on veut les observations en discussion,
 172 
 
Line -... Line 173...
- 
 
 173 
		$urlImgTpl = $this->conteneur->getParametre('cel_img_url_tpl');
- 
 
 174 
		$image['binaire.href'] = sprintf($urlImgTpl, $image['id_image'], 'XL');
- 
 
 175 
 
338 
			// on va récupérer les ids des observations dont le nombre de commentaire est supérieur à N
 176 
		unset($obs['id_image'], $obs['date'], $obs['hauteur'], $obs['largeur'], $obs['nom_original']);
339 
			$req['select'][] = 'COUNT(dc.id_commentaire) AS comm_count';
 177 
		return $image;
340 
			$req['join'][] = 'INNER JOIN del_commentaire AS dc ON vdi.id_observation = dc.ce_observation';
 178 
	}
- 
 
 179 
 
341 
			$req['groupby'][] = 'vdi.id_observation';
 180 
	private function ordonnerObservations($observations, $ordreDesObs) {
- 
 
 181 
		$obsOrdonnees = array();
342 
			$req['having'][] = "COUNT(id_commentaire) > " . $c->getParametre('nb_commentaires_discussion');
 182 
		foreach ($ordreDesObs as $id) {
Line 343... Line 183...
343 
		}
 183 
			if (array_key_exists("idx-$id", $observations)) {
344 
 
 184 
				$obsOrdonnees["idx-$id"] = $observations["idx-$id"];
345 
		if (array_key_exists('endiscussion', $val)) {
 185 
				unset($observations["idx-$id"]);
346 
			$req['where'][] = '(SELECT COUNT(id_commentaire) FROM del_commentaire AS dc'.
 186 
			}
347 
				' WHERE ce_observation = id_observation) > ' . intval($c->getParametre('nb_commentaires_discussion'));
 187 
		}
348 
		}
 188 
		return $obsOrdonnees + $observations;
- 
 
 189 
	}
- 
 
 190 
 
349 
	}
 191 
	/**
350 
 
 192 
	 * Récupérer toutes les déterminations et le nombre de commentaire au total
351 
	/**
 193 
	 * @param array $observations la liste des observations à mettre à jour
- 
 
 194 
	 */
352 
	 * Récupérer toutes les déterminations et le nombre de commentaire au total
 195 
	private function chargerDeterminations(&$observations, $idObs) {
353 
	 * @param array $observations la liste des observations à mettre à jour
 196 
		$idObsConcat = implode(',', $idObs);
354 
	 */
 197 
		$requete = 'SELECT * '.
355 
	private function chargerDeterminations(&$observations) {
 198 
			'FROM del_commentaire AS dc '.
356 
		$idObs = array_values(array_map(create_function('$a', 'return $a["id_observation"];'), $observations));
 199 
			'WHERE dc.nom_sel IS NOT NULL '.
357 
		$r = sprintf('SELECT * FROM del_commentaire AS dc WHERE dc.nom_sel IS NOT NULL AND ce_observation IN (%s) -- %s',
 200 
			"AND ce_observation IN ($idObsConcat) ".
- 
 
 201 
			'-- '.__FILE__.':'.__LINE__;
358 
			implode(',',$idObs),
 202 
 
- 
 
 203 
		$propositions = $this->bdd->recupererTous($requete);
359 
			__FILE__ . ':' . __LINE__);
 204 
		if ($propositions) {
360 
		$propositions = $this->bdd->recupererTous($r);
 205 
			foreach ($propositions as $proposition) {
361 
		if (!$propositions) return;
 206 
				$idObs = $proposition['ce_observation'];
Line 362... Line 207...
362 
		foreach ($propositions as $proposition) {
 207 
				$idComment = $proposition['id_commentaire'];
363 
			$idObs = $proposition['ce_observation'];
 208 
				$comment = $this->formaterDetermination($idComment, $proposition);
Line 364... Line 209...
364 
			$idComment = $proposition['id_commentaire'];
 209 
				if ($comment) {
365 
			$comment = $this->formaterDetermination($idComment, $proposition);
 210 
					$observations["idx-$idObs"]['commentaires'][$idComment] = $comment;
366 
			if ($comment) $observations['"' . $idObs . '"']['commentaires'][$idComment] = $comment;
 211 
				}
367 
 
 212 
			}
368 
		}
 213 
		}
369 
	}
 214 
	}
Line 370... Line 215...
370 
 
 215 
 
- 
 
 216 
	private function formaterDetermination($propositionId, $propositionInfos) {
- 
 
 217 
		if (!$propositionInfos) return NULL;
371 
	private function formaterDetermination($commentId, $proposition) {
 218 
 
372 
		if (!$proposition) return NULL;
 - 
 
373 
 
 - 
 
374 
		$proposition_formatee = array('nb_commentaires' => '0');
 219 
		$propositionFormatee = array();
375 
		foreach ($this->mappingCommentaire as $nomOriginal => $nomFinal) {
 220 
		foreach ($this->mappings['commentaires'] as $nomChamp => $nomAttributJson) {
376 
			if (isset($proposition[$nomOriginal])) {
 221 
			if (isset($propositionInfos[$nomChamp])) {
Line 377... Line -...
377 
				$proposition_formatee[$nomFinal] = $proposition[$nomOriginal];
 - 
 
378 
			}
 - 
 
379 
		}
 - 
 
380 
 
 - 
 
381 
		// Charger les votes sur les déterminations
 - 
 
382 
		$resultatsVotes = $this->bdd->recupererTous(
 - 
 
383 
			sprintf('SELECT * FROM del_commentaire_vote WHERE ce_proposition = %d', $commentId));
 - 
 
384 
 
 - 
 
385 
		foreach ($resultatsVotes as $vote) {
 - 
 
386 
			$proposition_formatee['votes'][$vote['id_vote']] = $this->formaterVote($vote);
 - 
 
387 
		}
 - 
 
388 
 
 - 
 
389 
		// chargerNombreCommentaire()
 - 
 
390 
		// Charger le nombre de commentaires (sans détermination) associé à l'observation
 - 
 
391 
		$listeCommentaires = $this->bdd->recupererTous(sprintf(
 - 
 
392 
			'SELECT ce_commentaire_parent, ce_proposition, COUNT( id_commentaire ) AS nb '.
 - 
 
393 
			'FROM del_commentaire WHERE ce_proposition = %d GROUP BY ce_proposition -- %s',
 222 
				$propositionFormatee[$nomAttributJson] = $propositionInfos[$nomChamp];
394 
			$commentId, __FILE__ . ':' . __LINE__));
 - 
 
395 
		foreach ($listeCommentaires as $ligneProposition) {
 - 
 
396 
			// ce test sert à exclure les proposition de 1er niveau qui sont elles aussi des commentaires
 - 
 
397 
			if ($ligneProposition['ce_commentaire_parent']) {
 - 
 
Line 398... Line 223...
398 
				// TODO/debug: id_commentaire_parent != $commentId ??
 223 
			}
399 
				// reprendre la "logique" du code... moins de boucles, moins de requêtes, ...
 224 
		}
Line 400... Line 225...
400 
				if ($ligneProposition['ce_commentaire_parent'] != $commentId) {
 225 
 
401 
					// restore_error_handler();
 226 
		// Charger les votes sur les déterminations
402 
					error_log(sprintf("possible error: nb_commentaires = %s: comment = %d, parent = %d, %s",
 227 
		$requete = "SELECT * FROM del_commentaire_vote WHERE ce_proposition = $propositionId".
403 
						$ligneProposition['nb'], $commentId, $ligneProposition['ce_commentaire_parent'], __FILE__));
 228 
			'-- '.__FILE__.':'.__LINE__;
404 
				}
 229 
		$resultatsVotes = $this->bdd->recupererTous($requete);
405 
				$proposition_formatee['nb_commentaires'] = $ligneProposition['nb'];
 230 
		foreach ($resultatsVotes as $vote) {
406 
			} else {
 231 
			$propositionFormatee['votes'][$vote['id_vote']] = $this->formaterVote($vote);
407 
				$proposition_formatee['observation']['nb_commentaires'] = $ligneProposition['nb'];
 232 
		}
408 
			}
 233 
 
409 
		}
 234 
		$propositionFormatee['nb_commentaires'] = $this->chargerNombreCommentaire($propositionId);
- 
 
 235 
 
- 
 
 236 
		return $propositionFormatee;
- 
 
 237 
	}
- 
 
 238 
 
- 
 
 239 
	/**
- 
 
 240 
	 * Formater un vote en fonction du fichier de configuration config_votes.ini
- 
 
 241 
	 * @param $votes array()
- 
 
 242 
	 */
- 
 
 243 
	private function formaterVote($vote) {
- 
 
 244 
		$voteFormate = array();
410 
 
 245 
		foreach ($vote as $nomChamp => $valeur) {
411 
		return $proposition_formatee;
 246 
			$voteFormate[$this->mappings['votes'][$nomChamp]] = $valeur;
412 
	}
 247 
		}