Subversion Repositories eFlore/Projets.eflore-projets

Rev

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

Rev 864 Rev 918
Line 115... Line 115...
115
	// le pattern utilisé pour la recherche dite "floue"
115
	// le pattern utilisé pour la recherche dite "floue"
116
	static $soundex_scheme = '(%1$s LIKE %2$s OR SOUNDEX(%1$s) = SOUNDEX(%2$s) OR SOUNDEX(REVERSE(%1$s)) = SOUNDEX(REVERSE(%2$s)))';
116
	static $soundex_scheme = '(%1$s LIKE %2$s OR SOUNDEX(%1$s) = SOUNDEX(%2$s) OR SOUNDEX(REVERSE(%1$s)) = SOUNDEX(REVERSE(%2$s)))';
Line 117... Line 117...
117
 
117
 
118
	// contrainte du point d'entrée d'API webservice Tela lors d'un GET
118
	// contrainte du point d'entrée d'API webservice Tela lors d'un GET
119
	public function consulter($ressources, $parametres, $db = NULL) {
119
	public function consulter($ressources, $parametres, $db = NULL) {
120
		if(!$db) {
120
		if (!$db) {
121
			// http_response_code(500);
121
			// http_response_code(500);
122
			throw new Exception('no DB', 500);
122
			throw new Exception('no DB', 500);
Line 123... Line 123...
123
		}
123
		}
124
 
124
 
125
		// parser la requête et filtrer les paramètres valides
125
		// parser la requête et filtrer les paramètres valides
126
		// en cas d'accès HTTP
126
		// en cas d'accès HTTP
127
		if(array_key_exists('QUERY_STRING', $_SERVER)) {
-
 
128
			self::requestParse($uri, $params);
127
		if (array_key_exists('QUERY_STRING', $_SERVER)) {
129
		}
-
 
130
		// en cas d'accès phpunit
128
			self::requestParse($uri, $params);
131
		else {
129
		} else {// en cas d'accès phpunit
Line 132... Line 130...
132
			$uri = $ressources;
130
			$uri = $ressources;
133
		}
131
		}
-
 
132
 
-
 
133
		// renvoie du plain/text d'aide (cf fin de programme)
Line 134... Line 134...
134
 
134
		if (count($uri) == 1 && $uri[0] == 'aide') {
-
 
135
			return self::aide();
-
 
136
		}
135
		// renvoie du plain/text d'aide (cf fin de programme)
137
 
136
		if(count($uri) == 1 && $uri[0] == 'aide') return self::aide();
138
 
137
 
139
		if (is_null($parametres)) {
138
 
140
			$parametres = Array();
Line 146... Line 148...
146
		// de toolkits
148
		// de toolkits
147
		$req = self::getCosteInfo($params, $db);
149
		$req = self::getCosteInfo($params, $db);
Line 148... Line 150...
148
 
150
 
149
		$res = $db->recupererTous($req);
151
		$res = $db->recupererTous($req);
150
		$err = mysql_error();
152
		$err = mysql_error();
151
		if(!$res && $err) {
153
		if (!$res && $err) {
152
			// http_response_code(400);
154
			// http_response_code(400);
153
			// if(defined('DEBUG') && DEBUG) header("X-Debug: $req");
155
			// if(defined('DEBUG') && DEBUG) header("X-Debug: $req");
154
			throw new Exception('not found', 400);
156
			throw new Exception('not found', 400);
Line 155... Line 157...
155
		}
157
		}
156
 
158
 
Line 157... Line 159...
157
		// rapide formatage des résultats:
159
		// rapide formatage des résultats:
158
		$matches = 0;
160
		$matches = 0;
159
 
161
 
160
		if($res) {
162
		if ($res) {
161
			// nombre de matches (sans LIMIT) utilisé pour l'en-tête
163
			// nombre de matches (sans LIMIT) utilisé pour l'en-tête
Line 162... Line 164...
162
			$matches = $db->recuperer('SELECT FOUND_ROWS() AS total');
164
			$matches = $db->recuperer('SELECT FOUND_ROWS() AS total');
163
			$matches = intval($matches['total']);
165
			$matches = intval($matches['total']);
164
		}
166
		}
165
 
167
 
166
		// reformate les résultats pour les indexer par coste:nn par défaut
168
		// reformate les résultats pour les indexer par coste:nn par défaut
-
 
169
		// cependant le paramètre retour.indexBy permet de choisir une indexation par num_nom de bdtfx
167
		// cependant le paramètre retour.indexBy permet de choisir une indexation par num_nom de bdtfx
170
		$clef_index = $params['retour.indexBy'] == 'coste' ? 'coste:nn' : 'bdtfx:nn';
-
 
171
		$res2 = array();
168
		$clef_index = $params['retour.indexBy'] == 'coste' ? 'coste:nn' : 'bdtfx:nn';
172
		foreach ($res as $v) {
169
		$res2 = array();
173
			if (!$v[$clef_index]) {
Line 170... Line 174...
170
		foreach($res as $v) {
174
				throw new Exception('format error: index NULL, use retour.indexBy=coste', 409);
171
			if(!$v[$clef_index]) throw new Exception('format error: index NULL, use retour.indexBy=coste', 409);
175
			}
172
			$res2[$v[$clef_index]] = $v;
176
			$res2[$v[$clef_index]] = $v;
-
 
177
		}
173
		}
178
 
174
 
179
		// l'appelant s'occupera du json_encode()
175
		// l'appelant s'occupera du json_encode()
180
		// même si ça démange d'exit'er ici
176
		// même si ça démange d'exit'er ici
181
		header("Content-Type: application/json; charset=utf-8");
177
		header("Content-Type: application/json; charset=utf-8");
182
		return array('entete' => array(
Line 178... Line 183...
178
		return array('entete' => array('depart' => $params['navigation.depart'],
183
			'depart' => $params['navigation.depart'],
Line 179... Line 184...
179
									   'limite' => $params['navigation.limite'],
184
			'limite' => $params['navigation.limite'],
Line 195... Line 200...
195
		$champs_valides_non_formattes = NULL;
200
		$champs_valides_non_formattes = NULL;
196
		$champs_valides = self::sqlSelectFields($params, $champs_valides_non_formattes);
201
		$champs_valides = self::sqlSelectFields($params, $champs_valides_non_formattes);
Line 197... Line 202...
197
 
202
 
198
		// joins:
203
		// joins:
199
		$other_join = self::sqlAddJoins($params, $champs_valides_non_formattes);
-
 
200
		$req = sprintf(<<<EOF
204
		$other_join = self::sqlAddJoins($params, $champs_valides_non_formattes);
201
SELECT SQL_CALC_FOUND_ROWS  %s
205
		$requete_tpl = "SELECT SQL_CALC_FOUND_ROWS  %s".
202
FROM tb_eflore.coste_v2_00 c
206
			"FROM tb_eflore.coste_v2_00 c ".
203
LEFT JOIN tela_prod_wikini.florecoste_pages dsc ON c.page_wiki_dsc = dsc.tag AND dsc.latest = 'Y'
207
			"	LEFT JOIN tela_prod_wikini.florecoste_pages dsc ON c.page_wiki_dsc = dsc.tag AND dsc.latest = 'Y' ".
204
LEFT JOIN tela_prod_wikini.florecoste_pages cle ON c.page_wiki_cle = cle.tag AND cle.latest = 'Y'
208
			"	LEFT JOIN tela_prod_wikini.florecoste_pages cle ON c.page_wiki_cle = cle.tag AND cle.latest = 'Y' ".
205
%s
209
			" %s ".
206
WHERE %s ORDER BY c.num_nom LIMIT %u, %u -- %s
-
 
207
EOF
210
			"WHERE %s ORDER BY c.num_nom LIMIT %u, %u -- %s ";
208
					   ,
211
		$req = sprintf($requete_tpl,
209
					   $champs_valides, // dans le SELECT (parmi champs coste_v2_00)
212
			$champs_valides, // dans le SELECT (parmi champs coste_v2_00)
210
					   // autre join, si nécessaire
213
			// autre join, si nécessaire
-
 
214
			$other_join ? $other_join : '',
211
					   $other_join ? $other_join : '',
215
 
212
					   // where
216
			// where
213
					   $constraints ? implode(' AND ', $constraints) : '1',
217
			$constraints ? implode(' AND ', $constraints) : '1',
214
 
218
 
215
					   // limit
219
			// limit
216
					   $params['navigation.depart'],
220
			$params['navigation.depart'],
217
					   $params['navigation.limite'],
221
			$params['navigation.limite'],
218
					   __FILE__ . ':' . __LINE__);
222
			__FILE__ . ':' . __LINE__);
219
		
223
 
220
		return $req;
224
		return $req;
Line 221... Line -...
221
	}
-
 
222
 
-
 
223
 
-
 
224
 
225
	}
225
 
226
 
226
	// SQL helpers
227
	// SQL helpers
227
	// le préfix de coste_v2_00 est "c"
228
	// le préfix de coste_v2_00 est "c"
228
	// le préfix de florecoste_pages sur la description est est "dsc"
229
	// le préfix de florecoste_pages sur la description est est "dsc"
229
	// le préfix de florecoste_pages sur la clef de détermination est est "cle"
230
	// le préfix de florecoste_pages sur la clef de détermination est est "cle"
230
	static function sqlAddConstraint($params, $db) {
231
	static function sqlAddConstraint($params, $db) {
231
		$stack = array();
232
		$stack = array();
232
		if(!empty($params['masque.ns'])) {
233
		if (!empty($params['masque.ns'])) {
233
			if($params['recherche'] == 'etendue')
234
			if ($params['recherche'] == 'etendue') {
234
				$stack[] = 'c.nom_sci LIKE ' . $db->proteger('%' . trim($params['masque.ns']) . '%');
235
				$stack[] = 'c.nom_sci LIKE '.$db->proteger('%' . trim($params['masque.ns']).'%');
235
			elseif($params['recherche'] == 'floue')
236
			} elseif($params['recherche'] == 'floue') {
236
				$stack[] = sprintf(self::$soundex_scheme,
237
				$stack[] = sprintf(self::$soundex_scheme,
237
								   'c.nom_sci',
238
					'c.nom_sci',
238
								   $db->proteger('%' . trim($params['masque.ns']) . '%'));
239
					$db->proteger('%'.trim($params['masque.ns']).'%'));
-
 
240
			} else {
239
			else
241
				$stack[] = 'c.nom_sci = '.$db->proteger(trim($params['masque.ns']));
Line 240... Line 242...
240
				$stack[] = 'c.nom_sci = ' . $db->proteger(trim($params['masque.ns']));
242
			}
241
		}
243
		}
242
 
244
 
243
		// le masque sur texte est toujours un LIKE() "étendue", sauf si "floue" spécifié
245
		// le masque sur texte est toujours un LIKE() "étendue", sauf si "floue" spécifié
244
		if(!empty($params['masque.txt'])) {
246
		if(!empty($params['masque.txt'])) {
245
			if($params['recherche'] == 'floue') {
247
			if($params['recherche'] == 'floue') {
246
				$stack[] = sprintf(self::$soundex_scheme,
248
				$stack[] = sprintf(self::$soundex_scheme,
247
								   'dsc.body',
249
					'dsc.body',
248
								   $db->proteger('%' . trim($params['masque.txt']) . '%'));
250
					$db->proteger('%'.trim($params['masque.txt']).'%'));
249
			}
251
			}
250
			else {
252
			else {
Line 251... Line 253...
251
				$stack[] = 'dsc.body LIKE ' . $db->proteger('%' . trim($params['masque.txt']) . '%');
253
				$stack[] = 'dsc.body LIKE '.$db->proteger('%'.trim($params['masque.txt']).'%');
252
			}
254
			}
253
		}
255
		}
254
 
256
 
255
		if(!empty($params['masque.titre'])) {
257
		if(!empty($params['masque.titre'])) {
256
			if($params['recherche'] == 'stricte') {
258
			if($params['recherche'] == 'stricte') {
257
				$stack[] = sprintf('(dsc.tag = %1$s OR cle.tag = %1$s)',
259
				$stack[] = sprintf('(dsc.tag = %1$s OR cle.tag = %1$s)',
258
								   $db->proteger(trim($params['masque.titre'])));
260
					$db->proteger(trim($params['masque.titre'])));
259
			}
261
			}
260
			else {
262
			else {
Line 261... Line 263...
261
				$stack[] = sprintf('(dsc.tag LIKE %1$s OR cle.tag LIKE %1$s)',
263
				$stack[] = sprintf('(dsc.tag LIKE %1$s OR cle.tag LIKE %1$s)',
262
								   $db->proteger('%' .  trim($params['masque.titre']) . '%'));
264
					$db->proteger('%'.trim($params['masque.titre']).'%'));
263
			}
265
			}
Line 264... Line 266...
264
		}
266
		}
265
 
267
 
266
		if(array_key_exists('masque.famille', $params)) {
268
		if(array_key_exists('masque.famille', $params)) {
Line 267... Line 269...
267
			$stack[] = 'b.famille LIKE ' . $db->proteger(trim($params['masque.famille']));
269
			$stack[] = 'b.famille LIKE '.$db->proteger(trim($params['masque.famille']));
268
		}
270
		}
269
 
271
 
Line 270... Line 272...
270
		if(array_key_exists('masque.page', $params)) {
272
		if(array_key_exists('masque.page', $params)) {
271
			$stack[] = 'c.page = ' . intval($params['masque.page']);
273
			$stack[] = 'c.page = '.intval($params['masque.page']);
272
		}
274
		}
Line 273... Line 275...
273
 
275
 
274
		if(array_key_exists('masque.tome', $params)) {
276
		if(array_key_exists('masque.tome', $params)) {
275
			$stack[] = 'c.tome = ' . intval($params['masque.tome']);
277
			$stack[] = 'c.tome = '.intval($params['masque.tome']);
276
		}
278
		}
277
 
279
 
278
		if(array_key_exists('masque.nt', $params)) {
280
		if(array_key_exists('masque.nt', $params)) {
279
			$stack[] = 'c.flore_bdtfx_nt = ' . intval($params['masque.nt']);
281
			$stack[] = 'c.flore_bdtfx_nt = '.intval($params['masque.nt']);
280
		}
282
		}
281
 
283
 
282
		// ajout de la contrainte sur coste:nn ou bdtfx:nn si un composant d'URL supplémentaire
284
		// ajout de la contrainte sur coste:nn ou bdtfx:nn si un composant d'URL supplémentaire
283
		// comportant un #id existe, cf self::requestFilterIds()
285
		// comportant un #id existe, cf self::requestFilterIds()
-
 
286
		$o_stack = array();
284
		$o_stack = array();
287
		if (array_key_exists('_ids', $params) && $params['_ids']) {
-
 
288
			if ($params['_ids']['coste']) {
Line 285... Line 289...
285
		if(array_key_exists('_ids', $params) && $params['_ids']) {
289
				$o_stack[] = sprintf("c.num_nom IN (%s)", implode(',', $params['_ids']['coste']));
286
			if($params['_ids']['coste']) {
290
			}
Line 301... Line 305...
301
	// utilisable plus aisément dans sqlAddJoins() qui peut en avoir besoin
305
	// utilisable plus aisément dans sqlAddJoins() qui peut en avoir besoin
302
	static function sqlSelectFields($params, &$unmerged) {
306
	static function sqlSelectFields($params, &$unmerged) {
303
		$champs = $params['retour.champs'];
307
		$champs = $params['retour.champs'];
304
		// champs coste_v2_00
308
		// champs coste_v2_00
305
		$c = self::addSQLToFieldSynonym(explode(',', $champs));
309
		$c = self::addSQLToFieldSynonym(explode(',', $champs));
306
		if(isset($c['*'])) {
310
		if (isset($c['*'])) {
307
			$t = array_diff_key(self::$allow_champs, array_flip(self::$special_champs));
311
			$t = array_diff_key(self::$allow_champs, array_flip(self::$special_champs));
308
		}
-
 
309
		else {
312
		} else {
310
			// just loop below
313
			// just loop below
311
			$t = $c;
314
			$t = $c;
312
		}
315
		}
Line 313... Line 316...
313
 
316
 
Line 327... Line 330...
327
		$unmerged = $t;
330
		$unmerged = $t;
Line 328... Line 331...
328
 
331
 
329
		// XXX: PHP-5.3
332
		// XXX: PHP-5.3
330
		$ret = array();
333
		$ret = array();
331
		foreach($t as $k => $v) {
334
		foreach($t as $k => $v) {
332
			if(strpos($k, ':') !== FALSE) {
335
			if (strpos($k, ':') !== FALSE) {
333
				$ret[] = "$v AS \"$k\"";
336
				$ret[] = "$v AS \"$k\"";
334
			} else {
337
			} else {
335
				$ret[] = "$v AS $k";
338
				$ret[] = "$v AS $k";
336
			}
339
			}
Line 391... Line 394...
391
		}
394
		}
Line 392... Line 395...
392
 
395
 
393
		// TODO: use filter_input(INPUT_GET);
396
		// TODO: use filter_input(INPUT_GET);
394
		// renvoie FALSE ou NULL si absent ou invalide
397
		// renvoie FALSE ou NULL si absent ou invalide
395
		$p['navigation.limite'] = filter_var(@$params['navigation.limite'],
398
		$p['navigation.limite'] = filter_var(@$params['navigation.limite'],
396
												  FILTER_VALIDATE_INT,
399
			FILTER_VALIDATE_INT,
-
 
400
			array('options' => array(
397
												  array('options' => array('default' => NULL,
401
				'default' => NULL,
398
																		   'min_range' => 1,
402
				'min_range' => 1,
399
																		   'max_range' => _COSTE_TEXTE_MAX_RESULT_LIMIT)));
403
				'max_range' => _COSTE_TEXTE_MAX_RESULT_LIMIT)));
400
		$p['navigation.depart'] = filter_var(@$params['navigation.depart'],
404
		$p['navigation.depart'] = filter_var(@$params['navigation.depart'],
401
												  FILTER_VALIDATE_INT,
405
			FILTER_VALIDATE_INT,
-
 
406
			array('options' => array(
402
												  array('options' => array('default' => NULL,
407
				'default' => NULL,
403
																		   'min_range' => 0,
408
				'min_range' => 0,
404
																		   'max_range' => _COSTE_TEXTE_MAX_COSTE_NN)));
409
				'max_range' => _COSTE_TEXTE_MAX_COSTE_NN)));
405
		$p['masque.page'] = filter_var(@$params['masque.page'],
410
		$p['masque.page'] = filter_var(@$params['masque.page'],
406
												  FILTER_VALIDATE_INT,
411
			FILTER_VALIDATE_INT,
-
 
412
			array('options' => array(
407
												  array('options' => array('default' => NULL,
413
				'default' => NULL,
408
																		   'min_range' => 0,
414
				'min_range' => 0,
409
																		   'max_range' => _COSTE_TEXTE_MAX_COSTE_PAGE)));
415
				'max_range' => _COSTE_TEXTE_MAX_COSTE_PAGE)));
410
		$p['masque.tome'] = filter_var(@$params['masque.tome'],
416
		$p['masque.tome'] = filter_var(@$params['masque.tome'],
411
												  FILTER_VALIDATE_INT,
417
			FILTER_VALIDATE_INT,
-
 
418
			array('options' => array(
412
												  array('options' => array('default' => NULL,
419
				'default' => NULL,
413
																		   'min_range' => 0,
420
				'min_range' => 0,
414
																		   'max_range' => _COSTE_TEXTE_MAX_COSTE_TOME)));
421
				'max_range' => _COSTE_TEXTE_MAX_COSTE_TOME)));
415
		$p['masque.nt'] = filter_var(@$params['masque.nt'],
422
		$p['masque.nt'] = filter_var(@$params['masque.nt'],
416
												  FILTER_VALIDATE_INT,
423
			FILTER_VALIDATE_INT,
-
 
424
			array('options' => array(
417
												  array('options' => array('default' => NULL,
425
				'default' => NULL,
418
																		   'min_range' => 0,
426
				'min_range' => 0,
Line 419... Line 427...
419
																		   'max_range' => _COSTE_TEXTE_MAX_BDTFX_NT)));
427
				'max_range' => _COSTE_TEXTE_MAX_BDTFX_NT)));
420
 
428
 
421
		// on filtre les NULL, FALSE et '', mais pas les 0, d'où le callback()
429
		// on filtre les NULL, FALSE et '', mais pas les 0, d'où le callback()
422
		// TODO: PHP-5.3
430
		// TODO: PHP-5.3
Line 441... Line 449...
441
			// http_response_code(500);
449
			// http_response_code(500);
442
			throw new Exception('not supported', 500);
450
			throw new Exception('not supported', 500);
443
		}
451
		}
Line 444... Line 452...
444
 
452
 
445
		return array(
453
		return array(
446
			'coste' => array_slice($ids_coste, 0, intval(_COSTE_TEXTE_MAX_RESULT_LIMIT/2) ),
454
			'coste' => array_slice($ids_coste, 0, intval(_COSTE_TEXTE_MAX_RESULT_LIMIT / 2) ),
447
			'bdtfx' => array_slice($ids_bdtfx, 0, intval(_COSTE_TEXTE_MAX_RESULT_LIMIT/2) )
455
			'bdtfx' => array_slice($ids_bdtfx, 0, intval(_COSTE_TEXTE_MAX_RESULT_LIMIT / 2) )
448
		);
456
		);
Line 449... Line 457...
449
	}
457
	}
450
 
458
 
Line 464... Line 472...
464
* les paramètres acceptés sont les suivants: %s
472
* les paramètres acceptés sont les suivants: %s
465
* les champs retournés par défaut sont les suivants: %s
473
* les champs retournés par défaut sont les suivants: %s
466
* le paramètre \"recherche\" affecte les masques \"ns\" et \"texte\"
474
* le paramètre \"recherche\" affecte les masques \"ns\" et \"texte\"
467
* le paramètre \"famille\" est traité via LIKE et accepte les caractères '_' et '%'
475
* le paramètre \"famille\" est traité via LIKE et accepte les caractères '_' et '%'
468
* le paramètre \"retour.format\" est inutilisé pour l'instant",
476
* le paramètre \"retour.format\" est inutilisé pour l'instant",
469
					   implode(',', array_keys(self::$allow_champs)),
477
			implode(',', array_keys(self::$allow_champs)),
470
					   implode(',', self::$allow_params),
478
			implode(',', self::$allow_params),
471
					   self::$default_params['retour.champs']
479
			self::$default_params['retour.champs']
472
		);
480
		);
473
	}
481
	}
Line 474... Line 482...
474
 
482
 
475
	static function getNNCoste($refnn) {
483
	static function getNNCoste($refnn) {
476
		if(is_numeric($refnn)) {
484
		if (is_numeric($refnn)) {
477
			$t = intval($refnn);
485
			$t = intval($refnn);
478
			if($t >= 1 && $t < _COSTE_TEXTE_MAX_COSTE_NN) return $t;
486
			if ($t >= 1 && $t < _COSTE_TEXTE_MAX_COSTE_NN) return $t;
479
		}
487
		}
480
		return FALSE;
488
		return FALSE;
Line 481... Line 489...
481
	}
489
	}