Subversion Repositories eFlore/Applications.del

Rev

Rev 2190 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1840 jpm 1
<?php
2
// declare(encoding='UTF-8');
3
/**
4
 * Classe contenant des méthodes permettant de construire les requêtes SQL complexe concernant les images et obs.
1881 jpm 5
 * Rempli un tableau des clauses "join", "where", "group by" et "oder by" nécessaire à la *recherche* des ids des
6
 * observations/images correspondantes aux filtres passés dans l'url du web service de recherche
7
 * (ListeImages et ListeObservations).
1840 jpm 8
 *
1881 jpm 9
 * Attention, cela signifie que toutes les tables ne sont pas *forcément* jointées, par exemple si aucune
10
 * contrainte ne le nécessite.
11
 * La requête construite ici est utile pour récupérer la liste des ids d'observations/images qui match.
12
 * Pour la récupération effective de "toutes" les données nécessaire au retour du web service en json, c'est une autre
13
 * requête directement dans le web service qui s'en charge. Cette technique en deux étapes est la plus rapide !
14
 *
15
 * Note: toujours rajouter les préfixes de table (di, do ou du), en fonction de ce que défini
16
 * les JOIN qui sont utilisés :
2156 mathias 17
 * - le préfixe de del_image est "di"
18
 * - le préfixe de del_observation est "do"
19
 * - le préfixe de del_utilisateur est "du"
1881 jpm 20
 *
1840 jpm 21
 * @category  DEL
22
 * @package   Services
23
 * @package   Bibliotheque
24
 * @version   0.1
25
 * @author    Mathias CHOUET <mathias@tela-botanica.org>
26
 * @author    Jean-Pascal MILCENT <jpm@tela-botanica.org>
27
 * @author    Aurelien PERONNET <aurelien@tela-botanica.org>
28
 * @license   GPL v3 <http://www.gnu.org/licenses/gpl.txt>
29
 * @license   CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
30
 * @copyright 1999-2014 Tela Botanica <accueil@tela-botanica.org>
31
 */
32
class Sql {
33
 
1871 jpm 34
	const APPLI_IMG = 'IMG';
35
	const APPLI_OBS = 'OBS';
36
 
1840 jpm 37
	private $conteneur;
38
	private $bdd;
39
	private $parametres = array();
1871 jpm 40
	private $appli;
1840 jpm 41
	private $requete = array(
42
		'join' => array(),
43
		'where' => array(),
44
		'groupby' => array(),
45
		'orderby' => array());
46
 
2004 mathias 47
	private $champsPrenom = array('prenom_utilisateur');
48
	private $champsNom = array('nom_utilisateur');
2199 delphine 49
	private $champsSousRequeteObs = array('masque.standard','masque.genre', 'masque.famille', 'masque.ns', 'masque.commune', 'masque.milieu', 'masque.pays');
1840 jpm 50
 
51
	public function __construct(Conteneur $conteneur) {
52
		$this->conteneur = $conteneur;
53
		$this->bdd = $this->conteneur->getBdd();
54
	}
55
 
56
	public function setParametres(Array $parametres) {
57
		$this->parametres = $parametres;
58
	}
59
 
1871 jpm 60
	public function setAppli($appliType) {
61
		if ($appliType == 'IMG' || $appliType == 'OBS') {
62
			$this->appli = $appliType;
63
		} else {
64
			throw new Exception("Les types d'appli disponible sont : IMG (pour PictoFlora) et OBS (pour IdentiPlante)");
65
		}
66
	}
67
 
68
	private function getPrefixe() {
69
		return $this->appli === 'IMG' ? 'di' : 'do';
70
	}
71
 
72
	private function etreAppliImg() {
2140 mathias 73
		return $this->appli === 'IMG';
1871 jpm 74
	}
75
 
76
	private function etreAppliObs() {
2140 mathias 77
		return $this->appli === 'OBS';
1871 jpm 78
	}
79
 
1840 jpm 80
	public function getRequeteSql() {
81
		return $this->requete;
82
	}
83
 
84
	private function addJoin($join) {
1871 jpm 85
		if (!isset($this->requete['join'][$join])) {
1922 jpm 86
			$this->requete['join'][$join] = $join;
1871 jpm 87
		}
1840 jpm 88
	}
89
 
90
	public function getJoin() {
91
		return ($this->requete['join'] ? implode(' ', array_unique($this->requete['join'])).' ' : '');
92
	}
93
 
94
	private function addJoinDis($join) {
95
		$this->requete['join']['dis'] = $join;
96
	}
97
 
98
	private function addWhere($idParam, $where) {
99
		if (isset($this->parametres['_parametres_condition_or_'])
100
				&& in_array($idParam, $this->parametres['_parametres_condition_or_'])) {
1922 jpm 101
			if ($this->etreAppliImg() && in_array($idParam, $this->champsSousRequeteObs)) {
102
				$this->requete['where']['OR_SOUS_REQUETE'][] = $where;
103
			} else {
104
				$this->requete['where']['OR'][] = $where;
105
			}
1840 jpm 106
		} else {
107
			$this->requete['where']['AND'][] = $where;
108
		}
109
	}
1922 jpm 110
 
1840 jpm 111
	public function getWhere() {
1922 jpm 112
		// Sous-requete spéciale pour éviter de rechercher dans la table obs jointe à img depuis Pictoflora...
2199 delphine 113
		//print_r($this->requete);
1922 jpm 114
		if (isset($this->requete['where']['OR_SOUS_REQUETE']) && count($this->requete['where']['OR_SOUS_REQUETE']) > 0) {
115
			$clauseWhereSousRequete = implode(' OR ', $this->requete['where']['OR_SOUS_REQUETE']);
116
			$sousRequete = 'di.ce_observation IN '.
1981 aurelien 117
				"(SELECT id_observation FROM del_observation AS do WHERE $clauseWhereSousRequete ) ";
1922 jpm 118
			$this->requete['where']['OR'][] = "( $sousRequete )";
2033 aurelien 119
			unset($this->requete['join'][$this->getSqlJointureObs()]);
1922 jpm 120
		}
121
 
1840 jpm 122
		if (isset($this->requete['where']['OR']) && count($this->requete['where']['OR']) > 0) {
123
			$this->requete['where']['AND'][] = '('.implode(' OR ', $this->requete['where']['OR']).')';
124
		}
125
 
126
		$where = ' TRUE ';
127
		if (isset($this->requete['where']['AND']) && count($this->requete['where']['AND']) > 0) {
128
			$where = implode(' AND ', $this->requete['where']['AND']).' ';
129
		}
130
		return $where;
131
	}
132
 
133
	private function addGroupBy($groupBy) {
134
		$this->requete['groupby'][] = $groupBy;
135
	}
136
 
137
	public function getGroupBy() {
138
		$groupby = '';
139
		if (isset($this->requete['groupby']) && count($this->requete['groupby']) > 0) {
140
			$groupby = 'GROUP BY '.implode(', ', array_unique($this->requete['groupby'])).' ';
141
		}
142
		return $groupby;
143
	}
144
 
145
	private function addOrderBy($orderby) {
146
		$this->requete['orderby'][] = $orderby;
147
	}
148
 
149
	public function getOrderBy() {
150
		$orderby = '';
151
		if (isset($this->requete['orderby']) && count($this->requete['orderby']) > 0) {
152
			$orderby = 'ORDER BY '.implode(', ', array_unique($this->requete['orderby'])).' ';
153
		}
154
		return $orderby;
155
	}
156
 
157
	public function getLimit() {
158
		return 'LIMIT '.$this->parametres['navigation.depart'].','.$this->parametres['navigation.limite'].' ';
159
	}
160
 
161
	/**
162
	 * @param $p les paramètres (notamment de masque) passés par l'URL et déjà traités/filtrés (sauf quotes)
163
	 * @param $req le tableau, passé par référence représentant les composants de la requête à bâtir
164
	 */
165
	public function ajouterContraintes() {
2199 delphine 166
		$this->ajouterContrainteStandard();
1840 jpm 167
		$this->ajouterContrainteAuteur();
168
		$this->ajouterContrainteDate();
1985 aurelien 169
		$this->ajouterContraintePays();
1840 jpm 170
		$this->ajouterContrainteDepartement();
171
		$this->ajouterContrainteIdZoneGeo();
172
		$this->ajouterContrainteGenre();
173
		$this->ajouterContrainteFamille();
174
		$this->ajouterContrainteNs();
175
		$this->ajouterContrainteNn();
176
		$this->ajouterContrainteReferentiel();
177
		$this->ajouterContrainteCommune();
2140 mathias 178
		$this->ajouterContraintePnInscrits();
1840 jpm 179
	}
180
 
2199 delphine 181
	private function ajouterContrainteStandard() {
182
		if (isset($this->parametres['masque.standard'])) {
183
			$donnees_standard = $this->parametres['masque.standard'];
184
			$this->addWhere('masque.standard', "do.donnees_standard = $donnees_standard");
185
			$this->ajouterJoinObsSiNecessaire();
186
		}
187
	}
188
 
1840 jpm 189
	private function ajouterContrainteAuteur() {
190
		if (isset($this->parametres['masque.auteur'])) {
191
			$auteur = $this->parametres['masque.auteur'];
192
			// id du poster de l'obs
1871 jpm 193
			$prefixe = $this->getPrefixe();
1840 jpm 194
 
195
			if (is_numeric($auteur)) {
196
				$this->ajouterContrainteAuteurId();
1871 jpm 197
			} elseif(preg_match('/@[a-z0-9-]+(?:\.[a-z0-9-]+)*\.[a-z]{2,}$/i', $auteur)) {
1840 jpm 198
				$this->ajouterContrainteAuteurEmail();
199
			} else {
200
				$this->ajouterContrainteAuteurIntitule();
201
			}
202
		}
203
	}
204
 
205
	private function ajouterContrainteAuteurId() {
206
		$id = $this->parametres['masque.auteur'];
1871 jpm 207
		$prefixe = $this->getPrefixe();
2048 mathias 208
		$sqlTpl = "($prefixe.ce_utilisateur = %1\$d)";
1840 jpm 209
		$whereAuteur = sprintf($sqlTpl, $id);
210
		$this->addWhere('masque.auteur', $whereAuteur);
211
	}
212
 
213
	private function ajouterContrainteAuteurEmail() {
214
		$email = $this->parametres['masque.auteur'];
1871 jpm 215
		$prefixe = $this->getPrefixe();
2048 mathias 216
		$sqlTpl = "($prefixe.courriel_utilisateur LIKE %1\$s )";
1840 jpm 217
		$emailP = $this->bdd->proteger("$email%");
218
		$whereAuteur = sprintf($sqlTpl, $emailP);
219
		$this->addWhere('masque.auteur', $whereAuteur);
220
	}
221
 
222
	/**
223
	 * Retourne une clause where du style:
224
	 * CONCAT(IF(du.prenom IS NULL, "", du.prenom), [...] vdi.i_nomutilisateur) REGEXP 'xxx'
225
	 */
226
	private function ajouterContrainteAuteurIntitule() {
227
		$auteurExplode = explode(' ', $this->parametres['masque.auteur']);
228
		$nbreMots = count($auteurExplode);
229
 
230
		if ($nbreMots == 1) {
231
			$this->ajouterContrainteAuteurPrenomOuNom();
232
		} else if ($nbreMots == 2) {
233
			$this->ajouterContrainteAuteurPrenomEtNom();
234
		}
235
	}
236
 
237
	private function ajouterContrainteAuteurPrenomOuNom() {
238
		$prenomOuNom = $this->parametres['masque.auteur'];
239
 
240
		$sqlTpl = 'CONCAT(%s,%s) LIKE %s';
1871 jpm 241
		$prefixe = $this->getPrefixe();
242
		$champsPrenomSql = self::ajouterIfNullPourConcat($this->champsPrenom, $prefixe);
243
		$champsNomSql = self::ajouterIfNullPourConcat($this->champsNom, $prefixe);
1840 jpm 244
		$auteurMotif = $this->bdd->proteger("%$prenomOuNom%");
245
 
246
		$auteurWhere = sprintf($sqlTpl, $champsPrenomSql, $champsNomSql, $auteurMotif);
247
		$this->addWhere('masque.auteur', $auteurWhere);
248
	}
249
 
250
	private function ajouterContrainteAuteurPrenomEtNom() {
251
		list($prenom, $nom) = explode(' ', $this->parametres['masque.auteur']);
252
 
253
		$sqlTpl = '(CONCAT(%1$s,%2$s) LIKE %3$s AND CONCAT(%1$s,%2$s) LIKE %4$s)';
1871 jpm 254
		$prefixe = $this->getPrefixe();
255
		$champsPrenomSql = self::ajouterIfNullPourConcat($this->champsPrenom, $prefixe);
256
		$champsNomSql = self::ajouterIfNullPourConcat($this->champsNom, $prefixe);
1840 jpm 257
		$prenomMotif = $this->bdd->proteger("%$prenom%");
258
		$nomMotif = $this->bdd->proteger("%$nom%");
259
 
260
		$auteurWhere = sprintf($sqlTpl, $champsPrenomSql, $champsNomSql, $prenomMotif, $nomMotif);
261
		$this->addWhere('masque.auteur', $auteurWhere);
262
	}
263
 
1881 jpm 264
	/**
265
	 * Lorsque l'on concatène des champs, un seul NULL prend le dessus.
1840 jpm 266
	 * Il faut donc utiliser la syntaxe IFNULL(%s, "").
1881 jpm 267
	 * Cette fonction effectue aussi l'implode() "final".
1840 jpm 268
	 */
1871 jpm 269
	private static function ajouterIfNullPourConcat($champs, $prefixe) {
1840 jpm 270
		$champsProteges = array();
271
		foreach ($champs as $champ) {
1871 jpm 272
			if (strstr($champ, '.') === false) {
273
				$champ = "$prefixe.$champ";
274
			}
1840 jpm 275
			$champsProteges[] = "IFNULL($champ, '')";
276
		}
277
		return implode(',', $champsProteges);
278
	}
279
 
280
	private function ajouterContrainteDate() {
281
		if (isset($this->parametres['masque.date'])) {
282
			$date = $this->parametres['masque.date'];
1871 jpm 283
			if (preg_match('/^\d{4}$/', $date) && $date < 2030 && $date > 1600) {
284
				$sqlTpl = "YEAR(do.date_observation) = %d";
1840 jpm 285
				$dateWhere = sprintf($sqlTpl, $date);
286
				$this->addWhere('masque.date', $dateWhere);
287
			} else {
1871 jpm 288
				$sqlTpl = "do.date_observation = %s";
289
				$dateP = $this->bdd->proteger($date);
1840 jpm 290
				$dateWhere = sprintf($sqlTpl, $dateP);
291
				$this->addWhere('masque.date', $dateWhere);
292
			}
1871 jpm 293
 
2031 aurelien 294
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 295
		}
296
	}
297
 
298
	private function ajouterContrainteDepartement() {
299
		if (isset($this->parametres['masque.departement'])) {
300
			$dept = $this->parametres['masque.departement'];
2183 delphine 301
			$deptMotif = $this->bdd->proteger("$dept");
2186 delphine 302
			$this->addWhere('masque.departement', "do.ce_zone_geo like $deptMotif");
1871 jpm 303
 
2031 aurelien 304
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 305
		}
306
	}
1985 aurelien 307
 
2048 mathias 308
	private function ajouterContraintePays() {
1985 aurelien 309
		if (isset($this->parametres['masque.pays'])) {
310
			// Attention le standard contient parfois FX pour la france métropolitaine
311
			// Dans ce cas particulier on cherche donc FR et FX
312
			$this->parametres['masque.pays'] = strtoupper($this->parametres['masque.pays']);
313
			if(strpos($this->parametres['masque.pays'], 'FR') !== false) {
314
				$this->parametres['masque.pays'] = str_replace('FR', 'FR,FX', $this->parametres['masque.pays']);
315
			}
2048 mathias 316
			$pays = explode(',', $this->parametres['masque.pays']);
317
			$pays = implode(',', $this->bdd->proteger($pays));
318
			$this->addWhere('masque.pays', "do.pays IN ($pays)");
319
 
320
			$this->ajouterJoinObsSiNecessaire();
321
		}
1985 aurelien 322
	}
1840 jpm 323
 
324
	private function ajouterContrainteIdZoneGeo() {
325
		if (isset($this->parametres['masque.id_zone_geo'])) {
326
			$idZgMotif = $this->bdd->proteger($this->parametres['masque.id_zone_geo']);
1871 jpm 327
			$this->addWhere('masque.id_zone_geo', "do.ce_zone_geo = $idZgMotif");
2031 aurelien 328
 
329
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 330
		}
331
	}
332
 
333
	private function ajouterContrainteGenre() {
334
		if (isset($this->parametres['masque.genre'])) {
335
			$genre = $this->parametres['masque.genre'];
2004 mathias 336
			$genreMotif = $this->bdd->proteger("$genre%");
1871 jpm 337
			$this->addWhere('masque.genre', "do.nom_sel LIKE $genreMotif");
338
 
2031 aurelien 339
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 340
		}
341
	}
342
 
343
	private function ajouterContrainteFamille() {
344
		if (isset($this->parametres['masque.famille'])) {
345
			$familleMotif = $this->bdd->proteger($this->parametres['masque.famille']);
1871 jpm 346
			$this->addWhere('masque.famille', "do.famille = $familleMotif");
347
 
2031 aurelien 348
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 349
		}
350
	}
351
 
352
	private function ajouterContrainteNs() {
353
		if (isset($this->parametres['masque.ns'])) {
354
			$ns = $this->parametres['masque.ns'];
355
			$nsMotif = $this->bdd->proteger("$ns%");
1871 jpm 356
			$this->addWhere('masque.ns', "do.nom_sel LIKE $nsMotif");
2031 aurelien 357
 
358
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 359
		}
360
	}
361
 
362
	private function ajouterContrainteNn() {
363
		if (isset($this->parametres['masque.nn'])) {
1871 jpm 364
			$sqlTpl = '(do.nom_sel_nn = %1$d OR do.nom_ret_nn = %1$d)';
1840 jpm 365
			$nnWhere = sprintf($sqlTpl, $this->parametres['masque.nn']);
366
			$this->addWhere('masque.nn', $nnWhere);
1871 jpm 367
 
2031 aurelien 368
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 369
		}
370
	}
371
 
372
	private function ajouterContrainteReferentiel() {
373
		if (isset($this->parametres['masque.referentiel'])) {
374
			$ref = $this->parametres['masque.referentiel'];
2181 delphine 375
			$refMotif = $this->bdd->proteger("$ref");
376
			$this->addWhere('masque.referentiel', "do.nom_referentiel = $refMotif");
1871 jpm 377
 
2031 aurelien 378
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 379
		}
380
	}
381
 
382
	private function ajouterContrainteCommune() {
383
		if (isset($this->parametres['masque.commune'])) {
384
			$commune = $this->parametres['masque.commune'];
385
			$communeMotif = $this->bdd->proteger("$commune%");
1871 jpm 386
			$this->addWhere('masque.commune', "do.zone_geo LIKE $communeMotif");
387
 
2031 aurelien 388
			$this->ajouterJoinObsSiNecessaire();
389
		}
390
	}
2140 mathias 391
 
392
	/**
393
	 * Si masque.pninscritsseulement vaut true, les observations ayant un tag
394
	 * "plantnet" mais dont l'auteur n'est pas inscrit à TB seront éliminées
395
	 * (décision FlorisTic 2016-09)
396
	 */
397
	protected function ajouterContraintePnInscrits() {
398
		if (isset($this->parametres['masque.pninscritsseulement'])) {
399
			// avec la classe ParametresFiltrage, on ne passe là que si le masque vaut 1
2189 delphine 400
			$motifMotClePlantnet = "'plantnet'";
401
			$this->addWhere('masque.pninscritsseulement', "((do.input_source != $motifMotClePlantnet) OR
2190 delphine 402
			    (do.input_source = $motifMotClePlantnet AND do.ce_utilisateur != 0))");
2140 mathias 403
 
404
			$this->ajouterJoinObsSiNecessaire();
405
		}
406
	}
2031 aurelien 407
 
408
	private function ajouterJoinObsSiNecessaire() {
1871 jpm 409
			if ($this->etreAppliImg()) {
2033 aurelien 410
				$this->addJoin($this->getSqlJointureObs());
1871 jpm 411
			}
1840 jpm 412
	}
2033 aurelien 413
 
2035 aurelien 414
	private function getSqlJointureObs() {
415
		$typeJointure = !empty($this->parametres['masque']) ? 'LEFT' : 'INNER';
416
		return $typeJointure.' JOIN del_observation AS do ON (di.ce_observation = do.id_observation) ';
2033 aurelien 417
	}
1840 jpm 418
 
2140 mathias 419
	// la constrainte de nostre bon roy
1845 jpm 420
	public function ajouterConstrainteAppliObs() {
421
		$this->ajouterContrainteTagCel();
422
		$this->ajouterContrainteType();
2140 mathias 423
		// TODO : ATTENTION -> vu que l'on utilise une vue basée sur les images, nous devons grouper par obs
1871 jpm 424
		$this->addGroupBy('do.id_observation');
1845 jpm 425
	}
426
 
427
	private function ajouterContrainteType() {
1933 aurelien 428
		// Les contraintes régissant les onglets sont issus de la réunion dont le compte rendu
429
		// disponible ici : http://tela-botanica.net/intranet/wakka.php?wiki=Octobre2014
430
		// Ce lien est à modifier pour pointer vers toute nouvelle réunion modifiant ce fonctionnement
431
 
1871 jpm 432
		if (isset($this->parametres['masque.type'])) {
433
			if (array_key_exists('adeterminer', $this->parametres['masque.type'])) {
1933 aurelien 434
				// A DETERMINER : toutes les observations qui ont le tag "aDeterminer"
435
				// *ou* qui n'ont pas de nom d'espèce
1871 jpm 436
				// *ou* qui ont la "certitude" à ("aDeterminer" *ou* "douteux")
437
				$this->addWhere('masque.type', '('.
2188 delphine 438
					'do.certitude = "à déterminer" '.
1871 jpm 439
					'OR do.certitude = "douteux" '.
440
					'OR do.mots_cles_texte LIKE "%aDeterminer%" '.
441
					'OR do.nom_sel_nn IS NULL '.
442
					'OR do.nom_sel_nn = 0 '.// il ne DEVRAIT pas y avoir d'entrées à 0, mais il y en a quand-même !!
443
					')');
444
			}
1933 aurelien 445
 
1871 jpm 446
			if (array_key_exists('validees', $this->parametres['masque.type'])) {
1933 aurelien 447
				// VALIDEES : toutes les observations ayant un commentaire doté de proposition_retenue = 1
448
				// ou bien possédant une proposition initiale avec un nom valide ayant totalisé un score d'au moins 4
449
				// (ce qui correspond à au moins deux votes positifs dans la plupart des cas, dont un identifié)
450
				$sous_requete_score_prop_votees = $this->getSousRequeteSommeVotesPropositions();
1871 jpm 451
				$this->addJoin('INNER JOIN del_commentaire AS dc '.
1933 aurelien 452
					'ON ( '.
453
						'do.id_observation = dc.ce_observation '.
454
						'AND ( '.
455
							'dc.proposition_retenue = 1 OR '.
456
							'( '.
457
								'dc.proposition_initiale = 1 '.
458
								'AND dc.nom_sel_nn != 0 '.
459
								'AND dc.nom_sel_nn IS NOT NULL '.
460
								' AND dc.id_commentaire IN ('.$sous_requete_score_prop_votees.' >= 4) '.
461
							') '.
462
						') '.
463
					')'
464
				);
1871 jpm 465
			}
1933 aurelien 466
 
467
			if(array_key_exists('aconfirmer', $this->parametres['masque.type'])) {
468
				// A CONFIRMER : toutes les observations moins les validées et à confirmer
469
				// i.e. : des observations avec un nom valide, qui ne sont pas à déterminer
470
				// (ni certitude "aDeterminer" ou "douteuse", ni mot clé),
471
				// ne possédant pas de proposition officiellement retenue
472
				// et ayant une proposition initiale totalisant un score de moins de 4
2048 mathias 473
				$sous_requete_score_prop_votees = $this->getSousRequeteSommeVotesPropositions();
1933 aurelien 474
				$this->addWhere('masque.type',
475
						'('.
476
							'do.id_observation IN ('.
477
								'SELECT dc.ce_observation FROM del_commentaire dc WHERE dc.proposition_retenue = 0'.
2048 mathias 478
								' AND ( '.
479
									'dc.proposition_initiale = 1 '.
480
									'AND dc.nom_sel_nn != 0 '.
481
									'AND dc.nom_sel_nn IS NOT NULL '.
482
									'AND dc.id_commentaire IN ('.$sous_requete_score_prop_votees.' < 4) '.
1933 aurelien 483
								') '.
484
							') AND do.id_observation NOT IN ('.
485
								'SELECT dc.ce_observation FROM del_commentaire dc '.
486
								'WHERE '.
487
								' dc.proposition_retenue = 1'.
488
							') '.
2048 mathias 489
							'AND do.certitude != "douteux" AND do.certitude != "aDeterminer" '.
490
							'AND do.mots_cles_texte NOT LIKE "%aDeterminer%" '.
491
							'AND do.nom_sel_nn != 0 '.
1933 aurelien 492
							'AND do.nom_sel_nn IS NOT NULL'.
493
						') '
494
					);
495
			}
1845 jpm 496
 
2033 aurelien 497
			$this->ajouterJoinObsSiNecessaire();
1845 jpm 498
		}
499
	}
1933 aurelien 500
 
501
	private function getSousRequeteSommeVotesPropositions() {
502
		// ATTENTION : un vote identifié compte 3 votes anonymes (dans les deux sens)
2048 mathias 503
		return  'SELECT ce_proposition '.
504
				'FROM del_commentaire_vote dcv '.
505
				'GROUP BY ce_proposition HAVING '.
506
				'SUM(CASE '.
507
				'	WHEN valeur = 1 AND dcv.ce_utilisateur REGEXP \'^-?[0-9]+$\' != 0 THEN 3 '.
508
				'	WHEN valeur = 0 AND dcv.ce_utilisateur REGEXP \'^-?[0-9]+$\' != 0 THEN -3 '.
509
				'	WHEN valeur = 1 AND dcv.ce_utilisateur REGEXP \'^-?[0-9]+$\' = 0 THEN 1 '.
510
				'	WHEN valeur = 0 AND dcv.ce_utilisateur REGEXP \'^-?[0-9]+$\' = 0 THEN -1 '.
511
				'END '.
1933 aurelien 512
			') ';
513
	}
1845 jpm 514
 
1840 jpm 515
	public function ajouterConstrainteAppliImg() {
516
		$this->ajouterContrainteMilieu();
517
		$this->ajouterContrainteTri();
518
		$this->ajouterContrainteTagCel();
519
		$this->ajouterContrainteTagDel();
2140 mathias 520
		$this->ajouterContraintePnInscrits();
1840 jpm 521
	}
522
 
523
	private function ajouterContrainteMilieu() {
524
		if (isset($this->parametres['masque.milieu'])) {
525
			$milieu = $this->parametres['masque.milieu'];
526
			$milieuMotif = $this->bdd->proteger("%$milieu%");
1871 jpm 527
			$this->addWhere('masque.milieu', "do.milieu LIKE $milieuMotif");
528
 
2033 aurelien 529
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 530
		}
531
	}
532
 
533
	private function ajouterContrainteTri() {
534
		if (isset($this->parametres['tri'])) {
535
			$tri = $this->parametres['tri'];
536
 
1863 jpm 537
			if (isset($this->parametres['protocole'])  && ($tri == 'moyenne-arithmetique' || $tri == 'points')) {
1840 jpm 538
				// $this->parametres['protocole'] *est* défini (cf Outils::filtrerUrlsParams...())
1871 jpm 539
				$sqlTpl = 'LEFT JOIN del_image_stat AS dis ON di.id_image = dis.ce_image AND dis.ce_protocole = %d';
1840 jpm 540
				$triSql = sprintf($sqlTpl, $this->parametres['protocole']);
541
				$this->addJoinDis($triSql);
542
			}
543
 
544
			if (isset($this->parametres['ordre']) && $tri == 'tags') {
545
				$typeJointure = ($this->parametres['ordre'] == 'desc') ? 'INNER' : 'LEFT';
1871 jpm 546
				$this->addJoin("$typeJointure JOIN del_image_stat AS dis ON di.id_image = dis.ce_image");
1840 jpm 547
			}
548
		}
549
	}
550
 
551
	private function ajouterContrainteTagCel() {
1845 jpm 552
		if (isset($this->parametres['masque.tag_cel'])) {
1840 jpm 553
			if (isset($this->parametres['masque.tag_cel']['AND'])) {
554
				$tags = $this->parametres['masque.tag_cel']['AND'];
555
				$clausesWhere = array();
556
				foreach ($tags as $tag) {
557
					$tagMotif = $this->bdd->proteger("%$tag%");
1922 jpm 558
					if ($this->etreAppliImg()) {
1981 aurelien 559
						$sousRequete = 'SELECT id_observation '.
1922 jpm 560
							'FROM del_observation '.
561
							"WHERE mots_cles_texte LIKE $tagMotif ";
562
						$sql = " (di.mots_cles_texte LIKE $tagMotif OR di.id_image IN ($sousRequete) ) ";
563
					} else {
564
						// WARNING : la sous-requête est la meilleure solution trouvée pour contrer le fonctionnement
565
						// étrange de l'optimiseur de MYSQL 5.6 (à retester avec Mysql 5.7 et suivant).
566
						$sousRequete = 'SELECT DISTINCT ce_observation '.
567
							'FROM del_image '.
568
							"WHERE mots_cles_texte LIKE $tagMotif ".
569
							'AND ce_observation IS NOT NULL';
570
						$sql = " (do.mots_cles_texte LIKE $tagMotif OR do.id_observation IN ($sousRequete)) ";
571
					}
572
					$clausesWhere[] = $sql;
1840 jpm 573
				}
574
				$whereTags = implode(' AND ', $clausesWhere);
575
				$this->addWhere('masque.tag_cel', "($whereTags)");
576
			} else if (isset($this->parametres['masque.tag_cel']['OR'])) {
577
				$tags = $this->parametres['masque.tag_cel']['OR'];
1922 jpm 578
				$tagMotif = $this->bdd->proteger(implode('|', $tags));
1871 jpm 579
				$sqlTpl = "CONCAT(IFNULL(do.mots_cles_texte,''),IFNULL(di.mots_cles_texte,'')) REGEXP %s";
1840 jpm 580
				$tagSql = sprintf($sqlTpl, $tagMotif);
1922 jpm 581
 
1840 jpm 582
				$this->addWhere('masque.tag_cel', $tagSql);
1922 jpm 583
 
584
				if ($this->etreAppliObs()) {
585
					$this->addJoin('LEFT JOIN del_image AS di ON (di.ce_observation = do.id_observation) ');
586
				}
1840 jpm 587
			}
2033 aurelien 588
			$this->ajouterJoinObsSiNecessaire();
1840 jpm 589
		}
590
	}
591
 
592
	/**
1881 jpm 593
	 * Plusieurs solutions sont disponibles dans les anciennes versions (voir DelTk et l'historique SVN de ce fichier).
1840 jpm 594
	 */
595
	private function ajouterContrainteTagDel() {
596
		if (isset($this->parametres['masque.tag_del'])) {
2029 aurelien 597
			$nbTags = $this->getNombreDeTags();
598
			if($nbTags > 1) {
2121 mathias 599
				// sous-requêtes car le GROUP BY avec GROUP_CONCAT est *trop* lent
600
				if (isset($this->parametres['masque.tag_del']['AND'])) {
601
					foreach ($this->parametres['masque.tag_del']['AND'] as $mc) {
602
						$sousRequete = 'SELECT ce_image '.
603
							'FROM del_image_tag '.
604
							'WHERE actif = 1 '.
605
							"AND tag_normalise LIKE '%$mc%' ";
606
						$this->addWhere('masque.tag_del', "di.id_image IN ($sousRequete)");
607
					}
608
				} else if (isset($this->parametres['masque.tag_del']['OR'])) {
609
					$tagsMotif = "'(" . implode('|', $this->parametres['masque.tag_del']['OR']) . ")'";
2029 aurelien 610
					$sousRequete = 'SELECT ce_image '.
611
						'FROM del_image_tag '.
612
						'WHERE actif = 1 '.
2121 mathias 613
						"AND tag_normalise REGEXP $tagsMotif ";
614
 
615
					$this->addWhere('masque.tag_del', "di.id_image IN ($sousRequete)");
2029 aurelien 616
				}
617
			} else {
2033 aurelien 618
				// Si un seul tag est demandé il se trouve dans le OR dans le cas de la recherche
619
				// spécifique et dans le AND dans le cas de la recherche générale
620
				// WTF?
621
				$tag = "";
622
				if(isset($this->parametres['masque.tag_del']['OR'][0])) {
623
					$tag = $this->parametres['masque.tag_del']['OR'][0];
624
				} else if(isset($this->parametres['masque.tag_del']['AND'][0])) {
625
					$tag = $this->parametres['masque.tag_del']['AND'][0];
626
				}
627
 
1922 jpm 628
				$sousRequete = 'SELECT ce_image '.
2029 aurelien 629
						'FROM del_image_tag '.
630
						'WHERE actif = 1 '.
631
						'AND tag_normalise LIKE '.$this->bdd->proteger($tag.'%');
2121 mathias 632
 
633
				$this->addWhere('masque.tag_del', "di.id_image IN ($sousRequete)");
1840 jpm 634
			}
2029 aurelien 635
 
1840 jpm 636
		}
637
	}
2029 aurelien 638
 
639
	private function getNombreDeTags() {
640
		$somme = 0;
641
		if (isset($this->parametres['masque.tag_del']['AND'])) {
642
			$somme = count($this->parametres['masque.tag_del']['AND']);
2048 mathias 643
		} else {
644
			$somme = count($this->parametres['masque.tag_del']['OR']);
2029 aurelien 645
		}
646
		return $somme;
647
	}
1840 jpm 648
 
649
	/**
650
	 * Partie spécifique à PictoFlora:
1863 jpm 651
	 * Attention : si le critère de tri n'est pas suffisant, les résultats affichés peuvent varier à chaque appel
652
	 * de la même page de résultat de PictoFlora.
1840 jpm 653
	 */
654
	public function definirOrdreSqlAppliImg() {
655
		$ordre = $this->parametres['ordre'];
1968 aurelien 656
 
657
		$tri = isset($this->parametres['tri']) ? $this->parametres['tri'] : '';
658
		switch ($tri) {
1863 jpm 659
			case 'moyenne-arithmetique' :
1888 jpm 660
				$this->addOrderBy("dis.moyenne $ordre, dis.nb_votes $ordre, id_image $ordre");
1840 jpm 661
				break;
662
			case 'points' :
1888 jpm 663
				$this->addOrderBy("dis.nb_points $ordre, dis.moyenne $ordre, dis.nb_votes $ordre, id_image $ordre");
1840 jpm 664
				break;
665
			case 'tags' :
1888 jpm 666
				$this->addOrderBy("dis.nb_tags $ordre, id_image $ordre");
1840 jpm 667
				break;
668
			case 'date_observation' :
1871 jpm 669
				$this->addOrderBy("date_observation $ordre, ce_observation $ordre");
1840 jpm 670
				break;
1863 jpm 671
			case 'date_transmission' :
1840 jpm 672
			default:
1871 jpm 673
				$this->addOrderBy("di.date_transmission $ordre, ce_observation $ordre");
1840 jpm 674
		}
675
	}
676
 
1845 jpm 677
	public function definirOrdreSqlAppliObs() {
678
		$ordre = $this->parametres['ordre'];
679
 
680
		// parmi self::$tri_possible
1968 aurelien 681
		$tri = isset($this->parametres['tri']) ? $this->parametres['tri'] : '';
682
			switch ($tri) {
1845 jpm 683
			case 'date_observation' :
684
				$this->addOrderBy("date_observation $ordre, id_observation $ordre");
1933 aurelien 685
				break;
2048 mathias 686
			case 'nb_commentaires' :
687
				$sql_nb_comms = '(SELECT COUNT(id_commentaire) FROM del_commentaire AS dc WHERE ce_observation = id_observation)';
688
				$this->addOrderBy("$sql_nb_comms $ordre, id_observation $ordre");
1845 jpm 689
				break;
1933 aurelien 690
			case 'date_transmission' :
1845 jpm 691
			default:
1871 jpm 692
				$this->addOrderBy("do.date_transmission $ordre, id_observation $ordre");
1845 jpm 693
		}
694
	}
695
 
1840 jpm 696
	public function getAliasDesChamps($champsEtAlias, $select = null, $prefix = null) {
697
		$arr = ($select) ? array_intersect_key($champsEtAlias, array_flip($select)) :  $champsEtAlias;
698
		$keys = array_keys($arr);
699
 
700
		if ($prefix) {
2184 delphine 701
		    array_walk($keys, function(&$val, $k, $prefix) { $val = sprintf("%s.`%s`", $prefix, $val);}, $prefix);
1840 jpm 702
		} else {
2184 delphine 703
		    array_walk($keys, function(&$val, $k) { $val = sprintf("`%s`", $val);});
1840 jpm 704
		}
705
 
2184 delphine 706
		return implode(', ', array_map(function($v, $k) {return sprintf("%s AS `%s`", $k, $v);}, $arr, $keys));
1840 jpm 707
	}
708
 
709
	public function getVotesDesImages($idsImages, $protocole = null) {
710
		if (!$idsImages) return;
711
 
712
		$mappingVotes = $this->conteneur->getParametreTableau('votes.mapping');
713
		$mappingProtocoles = $this->conteneur->getParametreTableau('protocoles.mapping');
714
 		$selectVotes = array('id_vote', 'ce_image', 'ce_protocole', 'ce_utilisateur', 'valeur', 'date');
715
		$selectProtocole = array('id_protocole', 'intitule', 'descriptif', 'tag');
716
		$voteChamps = $this->getAliasDesChamps($mappingVotes, $selectVotes, 'v'); // "v": cf alias dans la requête
717
		$protoChamps = $this->getAliasDesChamps($mappingProtocoles, $selectProtocole, 'p');
718
		$idImgsConcat = implode(',', $idsImages);
719
 
720
		$requete = "SELECT $voteChamps, $protoChamps ".
721
			'FROM del_image_vote AS v '.
722
			'	INNER JOIN del_image_protocole AS p ON (v.ce_protocole = p.id_protocole) '.
723
			"WHERE v.ce_image IN ($idImgsConcat) ".
724
			($protocole ? "	AND v.ce_protocole = $protocole " : '').
725
			"ORDER BY FIELD(v.ce_image, $idImgsConcat) ".
726
			'-- '.__FILE__.':'.__LINE__;
727
		return $this->bdd->recupererTous($requete);
728
	}
729
 
730
	/**
731
	 * Ajoute les informations sur le protocole et les votes aux images.
732
	 *
733
	 * ATTENTION : Subtilité, nous passons ici le tableau d'images indexé par id_image qui est bien
734
	 * plus pratique pour associer les vote à un tableau, puisque nous ne connaissons pas les id d'observation.
735
	 * Mais magiquement (par référence), cela va remplir notre tableau indexé par couple d'id (id_image, id_observation)
736
	 * cf ListeImages::reformateImagesDoubleIndex() à qui revient la tâche de créer ces deux versions
737
	 * simultanément lorsque c'est encore possible.
738
	 */
1881 jpm 739
	// TODO : supprimer cette "subtilité" source d'erreurs
1840 jpm 740
	public function ajouterInfosVotesProtocoles($votes, &$images) {
741
		if (!$votes) return;
1845 jpm 742
 
1840 jpm 743
		$mappingVotes = $this->conteneur->getParametreTableau('votes.mapping');
744
		$mappingProtocoles = $this->conteneur->getParametreTableau('protocoles.mapping');
745
 
746
		// pour chaque vote
747
		foreach ($votes as $vote) {
748
			$imgId = $vote['image.id'];
749
			$protoId = $vote['protocole.id'];
750
 
751
			if (!array_key_exists('protocoles_votes', $images[$imgId]) ||
1863 jpm 752
					!array_key_exists($protoId, $images[$imgId]['protocoles_votes'])) {
1840 jpm 753
				// extrait les champs spécifique au protocole (le LEFT JOIN de chargerVotesImage les ramène en doublons
754
				$protocole = array_intersect_key($vote, array_flip($mappingProtocoles));
755
				$images[$imgId]['protocoles_votes'][$protoId] = $protocole;
756
			}
757
 
758
			$chpsVotes = array('id_vote', 'ce_image', 'ce_utilisateur', 'valeur', 'date');
759
			$voteSelection = array_intersect_key($mappingVotes, array_flip($chpsVotes));
760
			$vote = array_intersect_key($vote, array_flip($voteSelection));
761
			$images[$imgId]['protocoles_votes'][$protoId]['votes'][$vote['vote.id']] = $vote;
762
		}
763
	}
1845 jpm 764
 
765
	public function getTotalLignesTrouvees() {
1888 jpm 766
		$resultat = $this->bdd->recuperer('SELECT FOUND_ROWS() AS nbre -- '.__FILE__.':'.__LINE__);
1845 jpm 767
		return intval($resultat['nbre']);
768
	}
2121 mathias 769
 
770
	public function getRequeteIdObsMonactiviteTout($id_utilisateur, $limite = "") {
771
		/*
772
		Une action c'est :
773
		- Quelqu'un commente mon observation
774
		- Quelqu'un fait une proposition sur mon observation
775
 
776
		- Quelqu'un vote pour ma proposition
777
		- Quelqu'un commente ma proposition ou mon commentaire
778
 
779
		- Quelqu'un vote pour une proposition sur mon observation
780
		- Quelqu'un commente une proposition ou un commentaire sur mon observation
2072 aurelien 781
		*/
782
 
783
		// on selectionne aussi la combinaison des champs de date afin que la liste soit triée correctement
2121 mathias 784
		// pas d'autre meilleure solution mais attention ce comportement dépend entièrement de mysql
785
		$requete = "SELECT SQL_CALC_FOUND_ROWS DISTINCT id_observation, ".$this->getCombinaisonChampsDateMax()." as date_max FROM del_observation do ".
786
				$this->getJointureMonActivite($id_utilisateur).
787
				$this->getConditionMonActivite($id_utilisateur).
788
				"ORDER BY date_max DESC ".
2049 aurelien 789
				$limite;
2121 mathias 790
 
791
		return $requete;
2049 aurelien 792
	}
793
 
794
	public function getRequeteNbEvenementsDepuisDate($id_utilisateur, $date) {
2121 mathias 795
		$requete = "SELECT COUNT(DISTINCT id_observation) as nb_evenements FROM del_observation do ".
796
				$this->getJointureMonActivite($id_utilisateur).
2049 aurelien 797
				$this->getConditionMonActivite($id_utilisateur).
2121 mathias 798
				"AND ".$this->getCombinaisonChampsDateMax()." > '".$date."' ".
799
				"ORDER BY ".$this->getCombinaisonChampsDateMax()." DESC ";
800
 
2049 aurelien 801
		return $requete;
802
	}
803
 
804
	public function getEvenementsObs($idsObsConcat, $id_utilisateur) {
2121 mathias 805
		$sous_champ_date_max = $this->getCombinaisonChampsDateMax()." as date_max";
2063 aurelien 806
		$sous_champ_date = "dc.date as date_com, dc.nom_sel as nom_sel_com, dcpr.ce_commentaire_parent as parent_com, dcv.date as date_vote, ".
807
							"do.date_observation as date_obs, dcp.date_validation as date_validation, dcpr.date as date_com_reponse, ".
2121 mathias 808
							"dcvp.nom_sel as nom_sel_com_parent";
2056 aurelien 809
		$sous_champs_utilisateurs = "dc.ce_utilisateur as utilisateur_commentaire, dcp.ce_utilisateur as utilisateur_commentaire_valide, ".
810
									"dcv.ce_utilisateur as utilisateur_vote_commentaire, do.ce_utilisateur as utilisateur_observation, ".
2063 aurelien 811
									"dcp.ce_validateur as utilisateur_validation, dcvp.ce_utilisateur as utilisateur_commentaire_vote, ".
2121 mathias 812
									"dcpr.ce_utilisateur as utilisateur_commentaire_reponse";
2067 aurelien 813
 
814
		$sous_champs_infos = "dc.nom_sel as proposition_commentaire_nom_sel, dc.texte as proposition_commentaire_texte, dcp.nom_sel as proposition_validee_nom_sel, ".
2121 mathias 815
							 "dcvp.nom_sel as proposition_commentaire_nom_sel_votee, dcpr.texte as proposition_commentaire_texte_commente";
2067 aurelien 816
 
2121 mathias 817
		$requete = "SELECT DISTINCT id_observation, ".$sous_champs_utilisateurs.", ".$sous_champ_date_max.", ".$sous_champ_date.", ".$sous_champs_infos." ".
818
				"FROM del_observation do ".
819
				$this->getJointureMonActivite($id_utilisateur).
820
				$this->getConditionMonActivite($id_utilisateur).
821
				"AND id_observation IN ($idsObsConcat) ORDER BY date_max DESC";
822
 
2049 aurelien 823
		$evenements = $this->bdd->recupererTous($requete);
824
		return $evenements;
825
	}
826
 
2121 mathias 827
	public function getJointureMonActivite($id_utilisateur) {
828
		return 	// quelqu'un commente mon observation ou fait une proposition
829
		"LEFT JOIN del_commentaire dc ON do.id_observation = dc.ce_observation ".
830
		"	AND do.ce_utilisateur = ".$id_utilisateur." ".
831
		"	AND dc.ce_utilisateur != ".$id_utilisateur." ".
832
		// quelqu'un valide ma proposition (et ce n'est pas moi qui l'ai validée)
833
		"LEFT JOIN del_commentaire dcp ON do.id_observation = dcp.ce_observation ".
834
		"	AND dcp.nom_sel IS NOT NULL AND dcp.ce_validateur != ".$id_utilisateur." ".
835
		"	AND dcp.ce_validateur != 0 ".
836
		"	AND dcp.date_validation IS NOT NULL ".
837
		"	AND dcp.ce_utilisateur = ".$id_utilisateur." ".
838
		// quelqu'un vote pour ma proposition ou sur une proposition sur une de mes observations
839
		"LEFT JOIN del_commentaire dcvp ON do.id_observation = dcvp.ce_observation ".
840
		"LEFT JOIN del_commentaire_vote dcv ON dcv.ce_proposition = dcvp.id_commentaire ".
2056 aurelien 841
		"AND (dcvp.ce_utilisateur = $id_utilisateur OR do.ce_utilisateur = $id_utilisateur) ".
2121 mathias 842
		"AND dcv.ce_utilisateur != $id_utilisateur ".
2063 aurelien 843
		"AND dcv.ce_utilisateur != dcvp.ce_utilisateur ".
2059 aurelien 844
		// Quelqu'un répond à l'un de mes commentaires ou commente une de mes propositions
2066 aurelien 845
		"LEFT JOIN del_commentaire dcpr ON do.id_observation = dcpr.ce_observation ".
2121 mathias 846
		"AND dcpr.ce_commentaire_parent = dcvp.id_commentaire AND dcvp.ce_utilisateur = $id_utilisateur ";
847
	}
848
 
849
	public function getConditionMonActivite($id_utilisateur, $type = "autres") {
850
		//TODO: gérer les cas suivants :
851
		// demander les activités des autres sur mes obs ou propositions (c'est dejà le cas)
852
		// demander mes activités
853
		// demander toutes les activités (combinaisons des deux cas ci dessus)
854
		return 	// Vérification que l'évènement me concerne (de près ou ou de loin)
855
		"WHERE (do.ce_utilisateur = $id_utilisateur OR dc.ce_utilisateur = $id_utilisateur ".
2056 aurelien 856
		"OR dcp.ce_utilisateur = $id_utilisateur OR dcv.ce_utilisateur = $id_utilisateur ".
2121 mathias 857
		"OR dcvp.ce_utilisateur = $id_utilisateur) AND ".
858
		// mais qu'il y a au moins eu une action de la part d'une autre personne
859
		"(dc.ce_utilisateur IS NOT NULL OR dcp.ce_utilisateur IS NOT NULL OR dcv.ce_utilisateur IS NOT NULL) ";
2049 aurelien 860
	}
2121 mathias 861
 
862
	private function getCombinaisonChampsDateMax() {
863
		return "GREATEST(IFNULL(dc.date,0), IFNULL(dcv.date,0), IFNULL(do.date_observation,0), IFNULL(dcp.date_validation,0), IFNULL(dcpr.date,0))";
2049 aurelien 864
	}
2199 delphine 865
}