WebSVN – eFlore/Applications.cel – Diff – //branches/v1.5-cisaille/jrest/services/Cel.php

  * @copyright © 2010, Jean-Pascal MILCENT
  */
 abstract class Cel {
 	const TYPE_OBS = 'observation';
 	const TYPE_IMG = 'image';
+	const SQL_MODE_ASSOC = PDO::FETCH_ASSOC;
+	const SQL_MODE_OBJET = PDO::FETCH_OBJ;
+	const SQL_RETOUR_COMPLET = 'All';
+	const SQL_RETOUR_LIGNE = 'Row';
+	const SQL_RETOUR_COLONNE = 'Column';
+	const SQL_RETOUR_BRUT = 'Raw';
 	public $config;
 	private $ressources;
 	private $parametres;
 	protected $bdd;
 	protected $messages = array();
 		setlocale(LC_ALL, $this->config['settings']['locale']);
 		date_default_timezone_set($this->config['settings']['fuseauHoraire']);
 		// Connection à la base de données
 		$this->bdd = $this->connecterPDO($this->config, 'database_cel');
 		// Nettoyage du _GET (sécurité)
 		$this->recupererParametresUrl();
 		$this->definirParametresUrlParDefaut();
 		// Définition de variable générale dans la config
 		$this->config['settings']['baseURLAbsoluDyn'] = 'http://'.$_SERVER['SERVER_NAME'].$this->config['settings']['baseURL'].'%s';
+	}
+		}
 		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
 		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
         return $PDO;
+	}
+	/**
+	* Encapsule executerRequete.
+	* @param String $requete
+	*/
-	protected function executerRequete($requete, $retour = 'All', $mode = PDO::FETCH_ASSOC) {
+	protected function requeter($requete, $retour = self::SQL_RETOUR_COMPLET, $mode = PDO::FETCH_ASSOC) {
+		return $this->executerRequete($requete, $retour, $mode);
+	}
+	/**
+	 * Encapsule executerRequeteSimple
+	 * @param String $requete
+	 */
+	protected function executer($requete) {
+		return $this->executerRequeteSimple($requete);
+	}
+/**
+	 * @deprecated utiliser executer() à la place
+	 * @see executer()
+	 */
+	protected function executerRequeteSimple($requete) {
+		$resultat = false;
 		try {
-			switch ($retour) {
-				case 'All' :
-					$resultat = $this->bdd->query($requete)->fetchAll($mode);
-					break;
-				case 'Column' :
-					$resultat = $this->bdd->query($requete)->fetchColumn();
+			$resultat = $this->bdd->exec($requete);
-					break;
-				default:
-					$resultat = false;
-					$this->messages[] = "Le type de retour '$retour' est inconnu.";
-			}
 			if ($resultat === false) {
-				$this->messages[] = "La requête a retourné aucun résultat.";
+				$this->debug[] = "La requête a échoué : $requete";
+			}
 		} catch (PDOException $e) {
-			$this->messages[] = sprintf($this->getTxt('sql_erreur_requete'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
+			$this->debug[] = sprintf($this->getTxt('sql_erreur_requete'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
+		}
 		return $resultat;
+	}
+	/**
-	protected function executerRequeteSimple($requete) {
+	 * @deprecated utiliser requeter() à la place
+	 * @see requeter()
+	 */
+	protected function executerRequete($requete, $retour = self::SQL_RETOUR_COMPLET, $mode = PDO::FETCH_ASSOC) {
+		$resultat = false;
 		try {
-				$resultat = false;
+			switch ($retour) {
+				case self::SQL_RETOUR_COMPLET :
+					$resultat = $this->bdd->query($requete)->fetchAll($mode);// Retourne toutes les lignes
+					break;
+				case self::SQL_RETOUR_LIGNE :
-				$resultat = $this->bdd->query($requete);
+					$resultat = $this->bdd->query($requete)->fetch($mode);// Retourne la première ligne
+					break;
+				case self::SQL_RETOUR_COLONNE :
+					$resultat = $this->bdd->query($requete)->fetchColumn();// Retourne la première colonne de la première ligne
+					break;
+				case self::SQL_RETOUR_BRUT :
+					$resultat = $this->bdd->query($requete);// Retourne l'objet brut pour être utilisé dans une boucle de type foreach
+					break;
+				default:
+					$this->debug[] = "Le type de retour '$retour' est inconnu.";
+			}
 			if ($resultat === false) {
-				$this->messages[] = "La requête a retourné aucun résultat.";
+				$this->debug[] = "La requête a retourné aucun résultat : $requete";
+			}
 		} catch (PDOException $e) {
-			$this->messages[] = sprintf($this->getTxt('sql_erreur_requete'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
+			$this->debug[] = sprintf($this->getTxt('sql_erreur_requete'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
+		}
 		return $resultat;
+	}
 	protected function proteger($chaine) {
 		return $this->bdd->quote($chaine);
+	}
+	protected function protegerTableau(Array $tableau) {
+		foreach ($tableau as $id => $val) {
+			$tableau[$id] = $this->proteger($val);
+		}
+		return $tableau;
+	}
 	protected function getTxt($id) {
 		$sortie = '';
 		switch ($id) {
 			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
 		return $sortie;
+	}
 	//+----------------------------------------------------------------------------------------------------------------+
 	// TRAITEMENT des URLs et des PARAMÊTRES
 	private function recupererParametresUrl() {
 		if (isset($_GET)) {
 			$get_params = array('orderby', 'distinct', 'start', 'limit', 'formatRetour');
 			foreach ($get_params as $get) {
+					}
+				}
+			}
+		}
+	}
 	protected function verifierSecuriteParametreUrl($param) {
 		$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');
 		$param = strip_tags(str_replace($verifier, '', $param));
 		return $param;
+	}
 	private function definirParametresUrlParDefaut() {
 		if (!isset($this->start)) {
 			$this->start = 0;
+		}
 		if (!isset($this->limit)) {
 			$this->limit = 150;
+		}
+	}
 	protected function traiterParametres($params_attendu, $params, $pourBDD = true) {
 		$sortie = array();
 		foreach ($params_attendu as $num => $nom) {
 			if (isset($params[$num]) && $params[$num] != '*') {
 				if ($pourBDD) {
 	protected function envoyerJson($donnees, $encodage = 'utf-8') {
 		$contenu = json_encode($donnees);
 		$this->envoyer($contenu, 'application/json', $encodage);
 	}
 	protected function envoyerJsonVar($variable, $donnees = null, $encodage = 'utf-8') {
 		$contenu = "var $variable = ".json_encode($donnees);
 		$this->envoyer($contenu, 'text/html', $encodage);
 	}
 	protected function envoyerJsonp($donnees = null, $encodage = 'utf-8') {
 		$contenu = $_GET['callback'].'('.json_encode($donnees).');';
 		$this->envoyer($contenu, 'text/html', $encodage);
 		} else if (!is_null($mime) && is_null($encodage)) {
 			header("Content-Type: $mime");
+		}
 		print $contenu;
+	}
 	private function envoyerAuth($message_accueil, $message_echec) {
 		header('HTTP/1.0 401 Unauthorized');
 		header('WWW-Authenticate: Basic realm="'.mb_convert_encoding($message_accueil, 'ISO-8859-1', 'UTF-8').'"');
 		header('Content-type: text/plain; charset=UTF-8');
 		print $message_echec;
 		exit(0);
+	}
 	//+----------------------------------------------------------------------------------------------------------------+
 	// GESTION DU DAO
 	protected function getDao() {
 		if (isset($this->dao)) {
 			return $this->dao;
 		} else {
 			$e = "Le DAO n'a pas été initialisé. Utiliser la méthode initialiserDao().";
 			trigger_error($e, E_USER_WARNING);
+		}
+	}
 	protected function initialiserDao($url_services_distant) {
 		if (is_null($this->dao)) {
 			$this->dao = new CelDao($url_services_distant);
 		} else {
 			$this->dao->url_jrest = $url_services_distant;
+		}
+	}
 	//+----------------------------------------------------------------------------------------------------------------+
 	// GESTION DE L'IDENTIFICATION
 	protected function getAuthIdentifiant() {
 		$id = (isset($_SERVER['PHP_AUTH_USER'])) ? $_SERVER['PHP_AUTH_USER'] : null;
 		return $id;
+	}
 	protected function getAuthMotDePasse() {
 		$mdp = (isset($_SERVER['PHP_AUTH_PW'])) ? $_SERVER['PHP_AUTH_PW'] : null;
 		return $mdp;
+	}
 	public function authentifierAdmin() {
 		$message_accueil = "Veuillez vous identifier avec votre compte Tela Botanica.";
 		$message_echec = "Accès limité aux administrateurs du CEL.\n".
 			"Votre tentative d'identification a échoué.\n".
 			"Actualiser la page pour essayer à nouveau si vous êtes bien inscrit comme administrateur.";
 		return $this->authentifier($message_accueil, $message_echec, 'Admin');
+	}
 	public function authentifierUtilisateur() {
 		$message_accueil = "Veuillez vous identifier avec votre compte Tela Botanica.";
 		$message_echec = "Accès limité aux utilisateur du CEL.\n".
 			"Inscrivez vous http://www.tela-botanica.org/page:inscription pour le devenir.\n".
 			"Votre tentative d'identification a échoué.\n".
 			"Actualiser la page pour essayer à nouveau si vous êtes déjà inscrit ou contacter 'accueil@tela-botanica.org'.";
 		return $this->authentifier($message_accueil, $message_echec, 'Utilisateur');
+	}
 	public function isAdmin($id) {
 		$admins = $this->config['jrest_admin']['admin'];
 		$admin_tab = split(',',$admins);
 		Log::setTimeZone($this->config['log']['timezone']);
 		Log::setTailleMax($this->config['log']['taillemax']);
 		Log::ajouterEntree($index,$chaine);
 	}
 	private function authentifier($message_accueil, $message_echec, $type) {
 		$id = $this->getAuthIdentifiant();
 		if (!isset($id)) {
 			$this->envoyerAuth($message_accueil, $message_echec);
 			if ($autorisation == false) {
 				$this->envoyerAuth($message_accueil, $message_echec);
+			}
+		}
 		return true;
 	}
 	public function etreUtilisateurAutorise() {
 		$this->initialiserDao('http://www.tela-botanica.org/client/annuaire_nouveau/actuelle/jrest/');
 		$identifiant = $this->getAuthIdentifiant();
 		$mdp = md5($this->getAuthMotDePasse());
 		$url = $this->getDao()->url_jrest."TestLoginMdp/$identifiant/$mdp";
 		$json = $this->getDao()->envoyerRequeteConsultation($url);
 		$existe = json_decode($json);
 		$autorisation = (isset($existe) && $existe) ? true :false;
 		return $autorisation;
+	}
 	public function etreAdminAutorise() {
 		$identifiant = $this->getAuthIdentifiant();
 		$autorisation = ($this->etreUtilisateurAutorise() && $this->etreAdminCel($identifiant)) ? true : false;
 		return $autorisation;
+	}
 	public function etreAdminCel($courriel) {
 		$admins = $this->config['jrest_admin']['admin'];
 		$courriels_autorises = explode(',', $admins);
 		$autorisation = (in_array($courriel, $courriels_autorises)) ? true : false ;
 		return $autorisation;
+	}
 	//+----------------------------------------------------------------------------------------------------------------+
 	// GESTION DE MÉTHODES COMMUNES ENTRE LES SERVICES
 	protected function getUrlImage($id, $format = 'L') {
 		$url_tpl = $this->config['settings']['celImgUrlTpl'];
 		$id = sprintf('%09s', $id).$format;
 		$url = sprintf($url_tpl, $id);
 		return $url;
+	}
 	protected function creerAuteur($courriel, $pourAdmin = false) {
 		$auteur = ($pourAdmin) ? $courriel : $this->tronquerCourriel($courriel);
 		return $auteur;
+	}
 	protected function creerAuteurs(array $courriels, $pourAdmin = false) {
 		$auteurs = ($pourAdmin) ? $courriels : $this->recupererUtilisateursNomPrenom($courriels);
 		return $auteurs;
+	}
 	protected function recupererUtilisateursNomPrenom(array $courriels) {
 		// Récupération des données au format Json
 		$service = "utilisateur/prenom-nom-par-courriel/".implode(',', $courriels);
 		foreach ($courriels as $courriel) {
 			if (isset($utilisateurs->$courriel)) {
 				$noms[$courriel] = $utilisateurs->$courriel->prenom.' '.$utilisateurs->$courriel->nom;
 			} else {
 				$noms[$courriel] = $this->tronquerCourriel($courriel);
 			}
 		}
 		return $noms;
+	}
 	protected function tronquerCourriel($courriel) {
 		$courriel = preg_replace('/[^@]+$/i', '...', $courriel);
 		return $courriel;
+	}
 	protected function nettoyerTableau(Array $tableau) {
 		foreach ($tableau as $cle => $valeur) {
 			if (is_array($valeur)) {
 				$valeur = $this->nettoyerTableau($valeur);
 			} else {
+			}
 			$tableau[$cle] = $valeur;
+		}
 		return $tableau;
+	}
 	/**
 	 * Fonction nettoyant les caractères spéciaux (&,<) et les valeurs nulles du CEL dans un texte comprenant du HTML.
 	 */
 	protected function nettoyerTexte($txt) {
 		$txt = preg_replace('/&(?!([a-z]+|#[0-9]+|#x[0-9][a-f]+);)/i', '&amp;', $txt);
 		//$txt = preg_replace('/<(?!([a-z][a-z0-9]*)\b[^>]*>(.*?)<\/\1>|\/\s*([a-z][a-z0-9]*)\s*>)/i', '&lt;', $txt);
 		//$txt = preg_replace('/(?!<([a-z][a-z0-9]*)\b[^>]*)>(?!(.*?)<\/\1>)/i', '&gt;', $txt);
 		$txt = preg_replace('/(?:000null|null)/i', '', $txt);
 		return $txt;
+	}
 	/**
 	 * Fonction nettoyant les caractères spéciaux HTML pour les champs de saisie libre du CEL.
 	 */
 	protected function protegerCaracteresHtmlDansChamps($donnees) {
 		$champs = array('ci_meta_mots_cles', 'ci_meta_comment',
 			'mots_cles', 'location', 'lieudit', 'station', 'milieu', 'commentaire', 'nom_sel');
 		foreach ($champs as $champ) {
 			if (isset($donnees[$champ])) {
 				$donnees[$champ] = htmlspecialchars($donnees[$champ]);
+			}
+		}
 		return $donnees;
+	}
 	protected function convertirDateHeureMysqlEnTimestamp($date_heure_mysql){
        $val = explode(' ', $date_heure_mysql);
        $date = explode('-', $val[0]);
        $heure = explode(':', $val[1]);
        return mktime((int) $heure[0], (int) $heure[1], (int) $heure[2], (int) $date[1], (int) $date[2], (int) $date[0]);
+	}
 	protected function etreNull($valeur) {
 		$etre_null = false;
 		if ($valeur == '' || $valeur == null || $valeur == '000null' || $valeur == 'null') {
 			$etre_null = true;
+		}
 		return $etre_null;
+	}
 	protected function formaterDate($date_heure_mysql, $format = '%A %d %B %Y à %H:%M') {
 		$date_formatee = '';
 		if (!$this->etreNull($date_heure_mysql)) {
 			$timestamp = $this->convertirDateHeureMysqlEnTimestamp($date_heure_mysql);
 			$date_formatee = strftime($format, $timestamp);
+		}
 		return $date_formatee;
+	}
 	protected function encoderMotCle($mot_cle) {
 		return md5(mb_strtolower($mot_cle));
+	}
 	protected function decoderMotsClesObs($utilisateur_id, $mots_cles) {
 		return $this->decoderMotsCles($utilisateur_id, $mots_cles, self::TYPE_OBS);
+	}
 	protected function decoderMotsClesImg($utilisateur_id, $mots_cles) {
 		return $this->decoderMotsCles($utilisateur_id, $mots_cles, self::TYPE_IMG);
+	}
 	private function decoderMotsCles($utilisateur_id, $mots_cles, $type) {
 		$mots = array();
 		if (! $this->etreNull($mots_cles)) {
 			$utilisateur_id = $this->bdd->quote($utilisateur_id);
 			$mots_cles = $this->protegerMotsCles($mots_cles, $type);
 			if (! $this->etreNull($mots_cles)) {
 				$table = ($type == self::TYPE_IMG) ? 'cel_mots_cles_images' : 'cel_mots_cles_obs' ;
 				$requete = 'SELECT cmc_mot_cle '.
 					"FROM $table ".
 					"WHERE cmc_id_mot_cle_utilisateur IN ($mots_cles) ".
 					"AND cmc_id_proprietaire = $utilisateur_id ";
 				$elements = $this->executerRequete($requete);
 				foreach ($elements as $mot) {
 					$mots[] = $mot['cmc_mot_cle'];
+				}
+			}
+		}
 		return $mots;
+	}
 	private function protegerMotsCles($mots_cles, $type) {
 		$separateur = ($type == self::TYPE_IMG) ? ',' : ';' ;
 		$mots_cles = $this->traiterValeursMultiples($mots_cles, $separateur);
 		return $mots_cles;
+	}
 	protected function traiterValeursMultiples($valeurs, $separateur_entree = ',' , $separateur_sortie = ',') {
 		if (! $this->etreNull($valeurs)) {
 			$valeurs_a_proteger = explode($separateur_entree,trim(trim($valeurs), $separateur_entree));
 			foreach ($valeurs_a_proteger as $valeur) {
 				$valeurs_protegees[] = $this->bdd->quote($valeur);
+			}
 			$valeurs = implode($separateur_sortie, $valeurs_protegees);
+		}
 		return ($this->etreNull($valeurs)) ? null : $valeurs;
+	}
 	//+----------------------------------------------------------------------------------------------------------------+
 	// GESTION DES SQUELETTES PHP
 	/**

Subversion Repositories eFlore/Applications.cel

(root)//branches/v1.5-cisaille/jrest/services/Cel.php – Rev 798 → 1066