Subversion Repositories eFlore/Applications.del

Rev

Rev 1915 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1375 raphael 1
<?php
1845 jpm 2
// declare(encoding='UTF-8');
1375 raphael 3
/**
1845 jpm 4
 * Web service récupèrant toutes les observations et, pour chacune d'elle, les images qui lui sont associées.
1375 raphael 5
 *
1845 jpm 6
 * ATTENTION : le web service commence par récupérer seulement les id des obs (1er requete SQL), puis dans une
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
8
 * est 3 fois plus rapide !
1375 raphael 9
 *
1845 jpm 10
 * @category   DEL
11
 * @package    Services
12
 * @subpackage Observations
13
 * @version    0.1
14
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
15
 * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
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>
1375 raphael 20
 */
1451 raphael 21
class ListeObservations {
1375 raphael 22
 
1793 jpm 23
	private $conteneur;
24
	private $bdd;
1845 jpm 25
	private $navigation;
26
	private $filtrage;
27
	private $sql;
1881 jpm 28
 
1845 jpm 29
	private $mappings = array();
30
	private $paramsFiltres = array();
1375 raphael 31
 
1881 jpm 32
	private $idsObsOrdonnees = array();
33
	private $infosObs = array();
34
	private $infosObsOrdonnee = array();
1375 raphael 35
 
1881 jpm 36
 
1845 jpm 37
	public function __construct(Conteneur $conteneur) {
38
		$this->conteneur = $conteneur;
39
		$this->conteneur->chargerConfiguration('config_departements_bruts.ini');
1375 raphael 40
 
1793 jpm 41
		$this->bdd = $this->conteneur->getBdd();
1845 jpm 42
		$this->filtrage = $this->conteneur->getParametresFiltrage();
43
		$this->sql = $this->conteneur->getSql();
44
		$this->navigation = $this->conteneur->getNavigation();
1375 raphael 45
 
1845 jpm 46
		$this->mappings['votes'] = $this->conteneur->getParametreTableau('votes.mapping');
47
		$this->mappings['commentaires'] = $this->conteneur->getParametreTableau('commentaires.mapping');
48
	}
1666 jpm 49
 
1793 jpm 50
	public function consulter($ressources, $parametres) {
1845 jpm 51
		$this->paramsFiltres = $this->filtrage->filtrerUrlParamsAppliObs();
1871 jpm 52
		$this->sql->setAppli(Sql::APPLI_OBS);
1845 jpm 53
		$this->sql->setParametres($this->paramsFiltres);
54
		$this->sql->ajouterContraintes();
55
		$this->sql->ajouterConstrainteAppliObs();
56
		$this->sql->definirOrdreSqlAppliObs();
1666 jpm 57
 
1881 jpm 58
		$this->idsObsOrdonnees = $this->getIdObs();
1845 jpm 59
		$this->navigation->setTotal($this->sql->getTotalLignesTrouvees());
1666 jpm 60
 
1845 jpm 61
		// Ce n'est pas la peine de continuer s'il n'y a pas eu de résultats
62
		$resultat = new ResultatService();
63
		$resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => array());
1881 jpm 64
		if (count($this->idsObsOrdonnees) > 0) {
1666 jpm 65
 
1793 jpm 66
			// 2) récupération des données nécessaires pour ces observations (obs + images)
1881 jpm 67
			$this->infosObs = $this->getInfosObs();
1666 jpm 68
 
1793 jpm 69
			// 3) suppression, merge des données en tableau assez représentatif du futur JSON en output
1881 jpm 70
			$this->infosObsOrdonnees = $this->formaterObservations();
1666 jpm 71
 
1881 jpm 72
			// 4) Ajouter commentaires + votes à $this->infosObsOrdonnees
73
			$this->chargerDeterminations();
1666 jpm 74
 
1845 jpm 75
			$resultat->corps = array(
76
				'entete' => $this->navigation->getEntete(),
1881 jpm 77
				//'resultats' => array_values($this->infosObsOrdonnees));
78
				// TODO : renvoyer un vrai tableau et non un objet
79
				'resultats' => $this->infosObsOrdonnees);
1618 mathias 80
		}
81
		return $resultat;
1793 jpm 82
	}
1375 raphael 83
 
1793 jpm 84
	// SQL helpers
85
	/*
86
	 * Retourne une liste ordonnée d'id d'observation correspondant aux critères
87
	 * passés dans p et aux clauses where/join présentes dans le tableau $req
88
	 *
89
	 * @param p: $params (filtrés sauf escape-string)
90
	 * @param req: le tableau représentant les composants de la requete SQL
91
	 * @param db: l'instance de db
92
	 */
1845 jpm 93
	private function getIdObs() {
94
		$requete = 'SELECT SQL_CALC_FOUND_ROWS id_observation '.
1871 jpm 95
			'FROM del_observation AS do '.
1845 jpm 96
			$this->sql->getJoin().
97
			'WHERE '.$this->sql->getWhere().
98
			$this->sql->getGroupBy().
99
			$this->sql->getOrderBy().
100
			$this->sql->getLimit().
101
			' -- '.__FILE__.':'.__LINE__;
1871 jpm 102
		//Debug::printr($requete);
1845 jpm 103
		$resultats = $this->bdd->recupererTous($requete);
1375 raphael 104
 
1845 jpm 105
		$idObs = array();
106
		if ($resultats !== false ) {
107
			foreach ($resultats as $resultat) {
108
				$idObs[] = $resultat['id_observation'];
109
			}
1793 jpm 110
		}
1845 jpm 111
		return $idObs;
1375 raphael 112
	}
113
 
1793 jpm 114
	/**
1845 jpm 115
	 * Après avoir récupérer seulement les ids dans une première requête, nous récupérons maintenant les infos.
116
	 * Le web service est ainsi 3 fois plus rapide.
1793 jpm 117
	 */
1881 jpm 118
	private function getInfosObs() {
119
		$idsObsConcat = implode(',', $this->idsObsOrdonnees);
1908 jpm 120
		// TODO : bizarement MYSQL 5.6 retourne plusieurs fois les mêmes enregistrements d'où le DISTINCT (normalement inutile)
121
		$requete = "SELECT DISTINCT id_observation, nom_sel AS `determination.ns`, nt AS `determination.nt`, ".
1845 jpm 122
			'nom_sel_nn AS `determination.nn`, famille AS `determination.famille`, '.
123
			'nom_referentiel AS `determination.referentiel`, ce_zone_geo AS id_zone_geo, '.
1871 jpm 124
			'zone_geo, lieudit, station, milieu, date_observation, do.mots_cles_texte, '.
125
			'do.date_transmission, do.commentaire, '.
126
			'do.ce_utilisateur AS `auteur.id`, do.prenom_utilisateur AS `auteur.prenom`, '.
127
			'do.nom_utilisateur AS `auteur.nom`, do.courriel_utilisateur AS `auteur.courriel`, '.
1845 jpm 128
			'id_image, date_prise_de_vue AS `date`, hauteur, largeur, nom_original '.
1871 jpm 129
			'FROM del_observation AS do '.
130
			'	LEFT JOIN del_image AS di ON (do.id_observation = di.ce_observation) '.
1845 jpm 131
			"WHERE id_observation IN ($idsObsConcat) ".
132
			' -- '.__FILE__.':'.__LINE__;
1909 jpm 133
		//Debug::printr($requete);
1845 jpm 134
		return $this->bdd->recupererTous($requete);
1793 jpm 135
	}
1375 raphael 136
 
1793 jpm 137
	/**
1845 jpm 138
	 * Les informations étant extraites d'une vue dont les infos des obs sont dupliquées pour chaque image,
139
	 * il nous faut maintenant récupérer qu'une seule fois les données d'observations et y intégrer les données
140
	 * des images.
1793 jpm 141
	 */
1881 jpm 142
	private function formaterObservations() {
143
		$observations = array_map('array_filter', $this->infosObs);
144
		$obsFormatees = array_flip($this->idsObsOrdonnees);// Permet de garder l'ordre de sortie !
1908 jpm 145
		foreach ($observations as &$obs) {
1845 jpm 146
			$this->nettoyerAuteur($obs);
1881 jpm 147
 
148
			$id = $obs['id_observation'];
1915 jpm 149
			// ATTENTION : la requête retourne de nombreuses lignes avec les mêmes données (test de l'existence nécessaire)
1909 jpm 150
			if (is_array($obsFormatees[$id]) === false) {
1908 jpm 151
				$obsFormatees[$id] = $obs;
152
			}
153
			$obsFormatees[$id]['images'][] = $this->extraireInfosImage($obs);
154
		}
1845 jpm 155
		return $obsFormatees;
156
	}
1494 raphael 157
 
1845 jpm 158
	private function nettoyerAuteur(&$obs) {
159
		// car auteur.id peut être un email, un hash, ou un annuaire_tela.U_ID
160
		// mais dans les deux premiers cas SELECT courriel AS observateur fait déjà l'affaire
161
		if (!isset($obs['auteur.id']) || !is_numeric($obs['auteur.id'])) {
162
			$obs['auteur.id'] = "0";
1375 raphael 163
		}
1845 jpm 164
		if (!isset($obs['auteur.nom'])) {
165
			$obs['auteur.nom'] = '[inconnu]';
166
		}
1416 raphael 167
	}
1375 raphael 168
 
1845 jpm 169
	private function extraireInfosImage(&$obs) {
170
		$champsImageAffichables = array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original');
171
		$image = array_intersect_key($obs, array_flip($champsImageAffichables));
172
		$urlImgTpl = $this->conteneur->getParametre('cel_img_url_tpl');
173
		$image['binaire.href'] = sprintf($urlImgTpl, $image['id_image'], 'XL');
1498 raphael 174
 
1845 jpm 175
		unset($obs['id_image'], $obs['date'], $obs['hauteur'], $obs['largeur'], $obs['nom_original']);
176
		return $image;
177
	}
1498 raphael 178
 
1793 jpm 179
	/**
180
	 * Récupérer toutes les déterminations et le nombre de commentaire au total
181
	 * @param array $observations la liste des observations à mettre à jour
182
	 */
1881 jpm 183
	private function chargerDeterminations() {
184
		$idObsConcat = implode(',', $this->idsObsOrdonnees);
1845 jpm 185
		$requete = 'SELECT * '.
186
			'FROM del_commentaire AS dc '.
187
			'WHERE dc.nom_sel IS NOT NULL '.
188
			"AND ce_observation IN ($idObsConcat) ".
189
			'-- '.__FILE__.':'.__LINE__;
1375 raphael 190
 
1845 jpm 191
		$propositions = $this->bdd->recupererTous($requete);
192
		if ($propositions) {
193
			foreach ($propositions as $proposition) {
194
				$idObs = $proposition['ce_observation'];
195
				$idComment = $proposition['id_commentaire'];
196
				$comment = $this->formaterDetermination($idComment, $proposition);
197
				if ($comment) {
1881 jpm 198
					$this->infosObsOrdonnees[$idObs]['commentaires'][$idComment] = $comment;
1845 jpm 199
				}
200
			}
1793 jpm 201
		}
1494 raphael 202
	}
203
 
1845 jpm 204
	private function formaterDetermination($propositionId, $propositionInfos) {
205
		if (!$propositionInfos) return NULL;
1494 raphael 206
 
1845 jpm 207
		$propositionFormatee = array();
208
		foreach ($this->mappings['commentaires'] as $nomChamp => $nomAttributJson) {
209
			if (isset($propositionInfos[$nomChamp])) {
210
				$propositionFormatee[$nomAttributJson] = $propositionInfos[$nomChamp];
1793 jpm 211
			}
212
		}
1666 jpm 213
 
1793 jpm 214
		// Charger les votes sur les déterminations
1845 jpm 215
		$requete = "SELECT * FROM del_commentaire_vote WHERE ce_proposition = $propositionId".
216
			'-- '.__FILE__.':'.__LINE__;
217
		$resultatsVotes = $this->bdd->recupererTous($requete);
1793 jpm 218
		foreach ($resultatsVotes as $vote) {
1845 jpm 219
			$propositionFormatee['votes'][$vote['id_vote']] = $this->formaterVote($vote);
1793 jpm 220
		}
1386 raphael 221
 
1845 jpm 222
		$propositionFormatee['nb_commentaires'] = $this->chargerNombreCommentaire($propositionId);
1386 raphael 223
 
1845 jpm 224
		return $propositionFormatee;
1494 raphael 225
	}
1375 raphael 226
 
1793 jpm 227
	/**
228
	 * Formater un vote en fonction du fichier de configuration config_votes.ini
229
	 * @param $votes array()
230
	 */
231
	private function formaterVote($vote) {
1845 jpm 232
		$voteFormate = array();
233
		foreach ($vote as $nomChamp => $valeur) {
234
			$voteFormate[$this->mappings['votes'][$nomChamp]] = $valeur;
1375 raphael 235
		}
1845 jpm 236
		return $voteFormate;
1375 raphael 237
	}
1845 jpm 238
 
239
	private function chargerNombreCommentaire($propositionId) {
240
		$requete = 'SELECT COUNT( id_commentaire ) AS nb '.
241
			'FROM del_commentaire '.
242
			"WHERE ce_proposition = $propositionId ".
243
			'GROUP BY ce_proposition '.
244
			'-- '.__FILE__.':'.__LINE__;
245
		$commentaires = $this->bdd->recuperer($requete);
246
		return $commentaires ? $commentaires['nb'] : 0;
247
	}
1793 jpm 248
}