WebSVN – eFlore/Applications.del – Diff – //trunk/services/modules/0.1/observations/ListeObservations.php

 error_reporting(E_ALL);
 class ListeObservations2 {
-	private $conteneur;
 	private $navigation;
-	private $masque;
+	private $conteneur;
 	private $gestionBdd;
 	private $bdd;
-	private $parametres = array();
-	private $ressources = array();
-	private $tri = 'date_transmission';
+	private $parametres = array();
-	private $directionTri = 'desc';
+	private $ressources = array();
 	static $tris_possibles = array('date_observation');
 					   'ce_zone_geo AS id_zone_geo', 'zone_geo', 'lieudit',
 					   'station', 'milieu', 'date_observation', 'mots_cles_texte', 'date_transmission',
 					   'ce_utilisateur AS `auteur.id`', 'prenom_utilisateur AS `auteur.prenom`',
 					   'nom_utilisateur AS `auteur.nom`', 'courriel_utilisateur AS observateur',
 					   'commentaire'),
-		'di' => array('id_image', 'date_prise_de_vue AS `date`', 'hauteur' , 'largeur' /* 'nom_original'//apparemment inutilisé */),
+		'di' => array('id_image', 'date_prise_de_vue AS `date`', 'hauteur',/* 'largeur','nom_original' // apparemment inutilisés */),
 		'du' => array('prenom', 'nom', 'courriel'),
 		'dc' => array('commentaire')
 	);
 		$this->masque = $conteneur->getMasque();
 		$this->gestionBdd = $conteneur->getGestionBdd();
 		$this->bdd = $this->gestionBdd->getBdd();
+	}
-	static function reformateObservation($obs, Conteneur $c = NULL) {
+	static function reformateObservation($obs, $url_pattern = '') {
 		$obs = array_map('array_filter', $obs);
 		$obs_merged = array();
 		foreach($obs as $o) {
+			$id = $o['id_observation'];
+			// car auteur.id peut être un email, un hash, ou un annuaire_tela.U_ID
+			// mais dans les deux premiers cas SELECT courriel AS observateur fait déjà l'affaire
+			if(!is_numeric($o['auteur.id'])) $o['auteur.id'] = "0";
+			if(!isset($o['auteur.nom'])) $o['auteur.nom'] = '[inconnu]';
 			$id = $o['id_observation'];
 			$image = array_intersect_key($o, array_flip(array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original')));
-			$image['binaire.href'] = sprintf($c->getParametre('url_images'), $image['id_image']);
+			$image['binaire.href'] = sprintf($url_pattern, $image['id_image']);
 			unset($o['id_image'], $o['date'], $o['hauteur'], $o['largeur'], $o['nom_original']);
 			if(!isset($obs_merged['"' . $id . '"'])) $obs_merged['"' . $id . '"'] = $o;
 			$obs_merged['"' . $id . '"']['images'][] = $image;
+		}
 		return $obs_merged;
+	}
+	// utilisée uniquement par Observation.php
+	static function reformateObservationSimpleIndex($obs, $url_pattern = '') {
+		// XXX: cf Observation.php::consulter(), nous pourriouns ici
+		// conserver les valeurs vides (pour les phptests notamment, ou non)
+		$obs = array_map('array_filter', $obs);
+		$obs_merged = array();
+		foreach($obs as $o) {
+			$id = $o['id_observation'];
+			$image = array_intersect_key($o, array_flip(array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original')));
+			$image['binaire.href'] = sprintf($url_pattern, $image['id_image']);
+			unset($o['id_image'], $o['date'], $o['hauteur'], $o['largeur'], $o['nom_original']);
+			if(!isset($obs_merged[$id])) $obs_merged[$id] = $o;
+			$obs_merged[$id]['images'][$image['id_image']] = $image;
+		}
+		return $obs_merged;
+	}
+	// utilisée uniquement par ListeImages.php
+	static function reformateImagesDoubleIndex($obs, $url_pattern = '', $image_format = 'XL') {
+		// XXX: cf Observation.php::consulter(), nous pourriouns ici
+		// conserver les valeurs vides (pour les phptests notamment, ou non)
+		// $obs = array_map('array_filter', $obs);
+		$obs_merged = $obs_keyed_by_id_image = array();
+		foreach($obs as $o) {
+			// ceci nous complique la tâche pour le reste du processing...
+			$id = $o['jsonindex'];
+			// ainsi nous utilisons deux tableaux: le final, indexé par couple d'id(image-obs)
+			// et celui indexé par simple id_image qui est fort utile pour mapVotesToImages()
+			// mais tout deux partage leur référence à "protocole"
+			$image = array(
+				'id_image' => $o['id_image'],
+				'binaire.href' => sprintf($url_pattern, $o['id_image'], $image_format),
+				'mots_cles_texte' => @$o['i_mots_cles_texte'], // @, peut avoir été filtré par array_map() ci-dessus
+			);
+			unset($o['id_image'], $o['i_mots_cles_texte'], $o['jsonindex']);
+			if(!isset($obs_merged[$id])) $obs_merged[$id] = $image;
+			$obs_merged[$id]['observation'] = $o;
+			$obs_merged[$id]['protocoles_votes'] = array();
+			$obs_keyed_by_id_image[$image['id_image']]['protocoles_votes'] = &$obs_merged[$id]['protocoles_votes'];
+		}
+		return array($obs_merged,$obs_keyed_by_id_image);
+	}
 	/**
 	 * Méthode principale de la classe.
 	 * Lance la récupération des images dans la base et les place dans un objet ResultatService
 		$req['groupby'][] = 'dob.id_observation';
 		$db = $this->bdd;
 		// filtrage de l'INPUT
-		$params = self::requestFilterParams($parametres, $this->conteneur);
+		$params = self::requestFilterParams($parametres, self::$parametres_autorises, $this->conteneur);
 		// création des contraintes (masques)
 		self::sqlAddConstraint($params, $db, $req, $this->conteneur);
 			// 2) récupération des données nécessaires pour ces observations (obs + images)
 			$obs_unfmt = self::getInfos($idobs, $db);
 			// 3) suppression, merge des données en tableau assez représentatif du futur JSON en output
-			$observations = self::reformateObservation($obs_unfmt, $this->conteneur);
+			$observations = self::reformateObservation($obs_unfmt, $this->conteneur->getParametre('url_images'));
 			// 4) récupération des données nécessaires pour ces observations (commentaires + votes)
 			$total = 0;
+		}
 		// 6) JSON output
-		$resultat = new ResultatService();
-		$prev_url = $next_url = NULL;
-		$next_offset = $params['navigation.depart'] + $params['navigation.limite'];
-		if($next_offset < $total) {
-			$next_url = sprintf("http://%s?%s", isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : Config::get('url_service'),
-								http_build_query(array_merge($params, array('navigation.depart' => $next_offset))));
-		}
-		$prev_offset = $params['navigation.depart'] - $params['navigation.limite'];
-		if($prev_offset > 0) {
+		$resultat = new ResultatService();
-			$prev_url = sprintf("http://%s?%s", isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : Config::get('url_service'),
-								http_build_query(array_merge($params, array('navigation.depart' => $prev_offset))));
-		}
-		$resultat->corps = array('entete' => array(
-			'masque' => http_build_query(array_diff_key($params, array_flip(array('navigation.depart', 'navigation.limite', 'tri', 'ordre')))),
-			'total' => $total,
-			'depart' => $params['navigation.depart'],
-			'limite' => $params['navigation.limite'],
-			'href.precedent' => $prev_url,
-			'href.suivant' => $next_url
-		),
+		$resultat->corps = array('entete' => self::makeJSONHeader($total, $params, Config::get('url_service')),
 								 'resultats' => $observations);
+		}
 		if(!empty($p['masque.ns'])) {
 			$req['where'][] = 'dob.nom_sel LIKE '.$db->proteger($p['masque.ns'].'%');
+		}
 		if(!empty($p['masque.nn'])) {
-			$req['where'][] = sprintf('dob.nom_sel_nn = %d', $p['masque.nn']);
+			$req['where'][] = sprintf('dob.nom_sel_nn = %1$d OR dob.nom_ret_nn = %1$d', $p['masque.nn']);
+		}
 		if(!empty($p['masque.referentiel'])) {
-			$req['where'][] = sprintf('dob.nom_referentiel = %s', $db->proteger($p['masque.referentiel']));
+			$req['where'][] = sprintf('dob.nom_referentiel LIKE %s', $db->proteger($p['masque.referentiel'].'%'));
+		}
 		if(!empty($p['masque.commune'])) {
 			$req['where'][] = 'dob.zone_geo LIKE '.$db->proteger($p['masque.commune'].'%');
+		}
 		if(!empty($p['masque.tag'])) {
 							   'masque.ns' => $p['masque'],
 							   'masque.famille' => $p['masque'],
 							   'masque.date' => $p['masque'],
 							   'masque.genre' => $p['masque'],
 							   /* milieu: TODO */ );
-			$or_masque = self::requestFilterParams($or_params, $c);
+			$or_masque = self::requestFilterParams($or_params, array_keys($or_params), $c);
 			// $or_req = array('select' => array(), 'join' => array(), 'where' => array(), 'groupby' => array(), 'having' => array());
 			$or_req = array('join' => array(), 'where' => array());
 			self::sqlAddConstraint($or_masque, $db, $or_req);
 	 */
 	static function addTypeConstraints($val, $db, &$req, Conteneur $c) {
 		if(array_key_exists('adeterminer', $val)) {
 			//On récupère toutes les observations qui on le tag "aDeterminer" *ou* qui n'ont pas de nom d'espèce
 			$req['where'][] = '(' . implode(' OR ', array(
-				'dob.certitude = "aDeterminer"'.
+				'dob.certitude = "aDeterminer"',
 				'dob.mots_cles_texte LIKE "%aDeterminer%"',
 				'dob.nom_sel_nn IS NULL', // TODO: ensure pas d'entrée à 0
 			)) . ')';
+		}
 		if(array_key_exists('aconfirmer', $val)) {
 					 __FILE__ . ':' . __LINE__);
 		$propositions = $this->bdd->recupererTous($r);
 		if(!$propositions) return;
 		foreach ($propositions as $proposition) {
 			$idObs = $proposition['ce_observation'];
+			$idComment = $proposition['id_commentaire'];
+			$comment = $this->formaterDetermination($idComment, $proposition);
-			$observations['"' . $idObs . '"']['commentaires'][] = $this->formaterDeterminations($proposition);
+			if($comment) $observations['"' . $idObs . '"']['commentaires'][$idComment] = $comment;
+		}
+	}
+	private function formaterDetermination($commentId, $proposition) {
+		if(!$proposition) return NULL;
+		$proposition_formatee = array('nb_commentaires' => '0');
-	/**
+		foreach ($this->mappingCommentaire as $nomOriginal => $nomFinal) {
-	 * Charger les votes sur les déterminations
+			if (isset($proposition[$nomOriginal])) {
-	 * @param Array $observations le tableau des observations à mettre à jour
+				$proposition_formatee[$nomFinal] = $proposition[$nomOriginal];
+			}
+		}
-	* */
-	private function chargerVotes($ids_proposition, &$propositions) {
+		// Charger les votes sur les déterminations
-		$resultatsVotes = $this->bdd->recupererTous(sprintf('SELECT * FROM del_commentaire_vote WHERE ce_proposition IN (%s)',
+		$resultatsVotes = $this->bdd->recupererTous(
+			sprintf('SELECT * FROM del_commentaire_vote WHERE ce_proposition = %d', $commentId));
 															implode(',', $ids_proposition)));
 		foreach ($resultatsVotes as $vote) {
-			$propositions[$vote['ce_proposition']]['votes'][$vote['id_vote']] = $this->formaterVote($vote);
+			$proposition_formatee['votes'][$vote['id_vote']] = $this->formaterVote($vote);
-		}
-	}
+		}
-	/**
-	 * Charger le nombre de commentaires (sans détermination) associé à l'observation
-	 * @param Array $observations le tableau des observatins à mettre à jour
+		// chargerNombreCommentaire()
-	 * */
+		// Charger le nombre de commentaires (sans détermination) associé à l'observation
-	private function chargerNombreCommentaire($ids_proposition, &$propositions) {
+		$listeCommentaires = $this->bdd->recupererTous(sprintf(
-		$listeCommentaires = $this->bdd->recupererTous(sprintf('SELECT ce_commentaire_parent, ce_proposition, COUNT( id_commentaire ) AS nb '.
+			'SELECT ce_commentaire_parent, ce_proposition, COUNT( id_commentaire ) AS nb '.
-															   'FROM del_commentaire WHERE ce_proposition IN (%s) GROUP BY ce_proposition',
+			'FROM del_commentaire WHERE ce_proposition = %d GROUP BY ce_proposition -- %s',
-															   implode(',', $ids_proposition)));
+			$commentId, __FILE__ . ':' . __LINE__));
+		foreach ($listeCommentaires as $ligneProposition) {
+			// ce test sert à exclure les proposition de 1er niveau qui sont elles aussi des commentaires
+			if($ligneProposition['ce_commentaire_parent']) {
+				// TODO/debug: id_commentaire_parent != $commentId ??
+				// reprendre la "logique" du code... moins de boucles, moins de requêtes, ...
+				if($ligneProposition['ce_commentaire_parent'] != $commentId) {
-		foreach ($listeCommentaires as $ligneProposition) {
+					// restore_error_handler();
+					error_log(sprintf("possible error: nb_commentaires = %s: comment = %d, parent = %d, %s",
-			// ce test sert à exclure les proposition de 1er niveau qui sont elles aussi des commentaires
+									  $ligneProposition['nb'], $commentId, $ligneProposition['ce_commentaire_parent'], __FILE__));
 			if($ligneProposition['ce_commentaire_parent'] != null && $ligneProposition['ce_commentaire_parent'] != 0) {
-				$propositions[$ligneProposition['ce_commentaire_parent']]['nb_commentaires'] = $ligneProposition['nb'];
+				$proposition_formatee['nb_commentaires'] = $ligneProposition['nb'];
 			} else {
-				$propositions[$ligneProposition['ce_proposition']]['observation']['nb_commentaires'] = $ligneProposition['nb'];
+				$proposition_formatee['observation']['nb_commentaires'] = $ligneProposition['nb'];
-			}
-		}
-	}
-	/**
-	 *
-	 * Formate une liste de proposition en fonction du fichier de configuration
-	 */
-	private function formaterDeterminations($proposition) {
-		if(!$proposition) return array();
-		$propositions_format = array();
-		$ids_proposition[] = $proposition['id_commentaire'];
-		$proposition_formatee = array('nb_commentaires' => '0');
-		foreach ($this->mappingCommentaire as $nomOriginal => $nomFinal) {
-			if (isset($proposition[$nomOriginal])) {
-				$proposition_formatee[$nomFinal] = $proposition[$nomOriginal];
-			}
-		}
-		$propositions_format[$proposition['id_commentaire']] = $proposition_formatee;
-		// modifie $propositions_format
-		$this->chargerVotes($ids_proposition, $propositions_format);
+			}
 		// modifie $propositions_format
 		$this->chargerNombreCommentaire($ids_proposition, $propositions_format);
-		return $propositions_format;
+		return $proposition_formatee;
+	}
+	}
 	/* filtre et valide les paramètres reconnus.
 	   Effectue *toute* la sanitization *sauf* l'escape-string */
-	static function requestFilterParams(Array $params, Conteneur $c = NULL /* pour la récup des départements */ ) {
+	static function requestFilterParams(Array $params, $parametres_autorises, Conteneur $c = NULL /* pour la récup des départements */ ) {
-		$params = array_intersect_key($params, array_flip(self::$parametres_autorises));
+		$params = array_intersect_key($params, array_flip($parametres_autorises));
 		$p['tri'] = self::unsetIfInvalid($params, 'tri', array('date_observation'));
 		$p['ordre'] = self::unsetIfInvalid($params, 'ordre', array('asc','desc'));
-		$p['referentiel'] = self::unsetIfInvalid($params, 'referentiel', array('bdtfx','bdtxa','isfan'));
+		$p['masque.referentiel'] = self::unsetIfInvalid($params, 'masque.referentiel', array('bdtfx','bdtxa','isfan'));
 		$p = array_merge(self::$default_params, $p);
 		return $p;
+	}
+	static function makeJSONHeader($total, $params, $url_service) {
+		$prev_url = $next_url = NULL;
+		$next_offset = $params['navigation.depart'] + $params['navigation.limite'];
+		if($next_offset < $total) {
+			$next_url = sprintf("http://%s?%s", isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : $url_service,
+								http_build_query(array_merge($params, array('navigation.depart' => $next_offset))));
+		}
+		$prev_offset = $params['navigation.depart'] - $params['navigation.limite'];
+		if($prev_offset > 0) {
+			$prev_url = sprintf("http://%s?%s", isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : $url_service,
+								http_build_query(array_merge($params, array('navigation.depart' => $prev_offset))));
+		}
+		return array(
+			'masque' => http_build_query(array_diff_key($params, array_flip(array('navigation.depart', 'navigation.limite', 'tri', 'ordre')))),
+			'total' => $total,
+			'depart' => $params['navigation.depart'],
+			'limite' => $params['navigation.limite'],
+			'href.precedent' => $prev_url,
+			'href.suivant' => $next_url
 		);

Subversion Repositories eFlore/Applications.del

(root)//trunk/services/modules/0.1/observations/ListeObservations.php – Rev 1381 → 1413