WebSVN – eFlore/Applications.coel – Diff – /branches/v1.11-okuzgozu/jrest/services/Coel.php


<?php
/**
 * Classe mère abstraite contenant les méthodes génériques des services.
 * Encodage en entrée : utf8
 * Encodage en sortie : utf8
 * 
 * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 * @version $Id$
 * @copyright 2009
 */
abstract class Coel {
	
	const ETAT_AJOUTER = 1;
	const ETAT_MODIFIER = 2;
	const ETAT_SUPPRIMER = 3;
	
	protected $sessionName = 'CoelSession';
	protected $sessionExpireTime = 8640000;// 60*60*24*100 = 100 jours
	protected static $cookieChemin = '';
	public $config;
	protected $bdd;
	protected $log = array();
	protected $messages = array();
	protected $debug = array();
	protected $distinct = false;
	protected $orderby = null;
	protected $formatRetour = 'objet';
	protected $start = 0; 
	protected $limit = 150;
	
	public function __construct($config, $demarrer_session = true) {
		// Tableau contenant la config de Jrest
		$this->config = $config;
		
		// Connection à la base de données
		$this->bdd = $this->connecterPDO($this->config, 'coel');
		
		$this->gererSession($demarrer_session);
		$this->gererIdentificationPermanente();
		
		// Nettoyage du $_GET (sécurité)
		if (isset($_GET)) {
			$get_params = array('orderby', 'distinct', 'start', 'limit', 'formatRetour');
			foreach ($get_params as $get) {
				$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');
				$_GET[$get] = str_replace($verifier, '', $_GET[$get]);
				if (isset($_GET[$get]) && $_GET[$get] != '') {
					$this->$get = $_GET[$get];
				} else {
					$_GET[$get] = null;
				}
			}
		}
	}
 
	/**
	 * Méthode appelée quand aucun paramètre n'est passé dans l'url et avec une requête de type GET.
	 */
	public function getRessource() {
		$this->getElement(array());
	}
	
	
	protected function creerXmlHisto($donnees) {
		// Création du xml de l'enregistrement à historiser
		$info = null;
		$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";
		$xml = null;
		 
		foreach ($donnees as $cle => $valeur) {
			if (!is_null($valeur) && $valeur != '') {
				$xml .= "<$cle>$valeur</$cle>\n";
			}
		}
		if ($xml !== null) {
			$info = sprintf($xml_tpl, $xml);
			$info = $this->bdd->quote($info);
		}
		
		return $info;
	}
	
	protected function getTableauDepuisXmlHisto($xml) {
		// Création du xml de l'enregistrement à historiser
		$info = array();
		
		if (!empty($xml) && preg_match_all('|<([^>]+)>(.*)</[^>]+>|U', $xml, $matches, PREG_SET_ORDER)) {
			foreach ($matches as $val) {
				$info[$val[1]] = $val[2];
			}
		}
		
		return $info;
	}
		
	protected function historiser($table_id, $ligne_cle, $info, $id_utilisateur, $etat, $id_session) {
		// Pré-traitement des variables
		$info = (is_null($info)) ? 'NULL' : $info;
		
		// Historisation (Ajout des méta-données)
		$requete = 	'INSERT INTO coel_meta_historique_ligne '. 
					'	(cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.
					'VALUES ('.
					"		$table_id, ".
					'		"'.$ligne_cle.'", '.
					"		$info, ".
 					'		"'.date('Y-m-d H:i:s', time()).'", '.
					"		$id_utilisateur, ".
					"		$etat, ".
					'		"'.$_SERVER['REMOTE_ADDR'].'", '.
					'		"'.$id_session.'") ';
		
   		// Exécution de la requêtre SQL et test d'éventuelles erreurs
		$resultat = $this->bdd->exec($requete);
		if ($resultat === false ) {
			$this->log[] = "Des données de la table '$table_id' (enrg. $ligne_cle) n'ont pas été historisées car la requête a échouée.";
		}
		return $this->bdd->lastInsertId();
	}
	
	protected function envoyer($donnees = null, $mime = 'text/html', $encodage = 'utf-8', $json = true) {
		// Traitements des messages d'erreurs et données
		if (count($this->messages) != 0) {
			header('HTTP/1.1 500 Internal Server Error');
			$mime = 'text/html';
			$encodage = 'utf-8';
			$json = true;
			$sortie = $this->messages;
		} else {
			$sortie = $donnees;
			if (is_null($donnees)) {
				$sortie = 'OK';
			}
		}
 
		// Gestion de l'envoie du déboguage
		$this->envoyerDebogage();
		
		// Encodage au format et JSON et envoie sur la sortie standard
		$contenu = $json ? json_encode($sortie) : $sortie;
		$this->envoyerContenu($encodage, $mime, $contenu);
	}
	
	protected function envoyerHTML($donnees = null) {
		// Traitements des messages d'erreurs et données
		$contenu = '';
		if (count($this->messages) > 0) {
			$contenu = '<p>'.implode('<br />', $this->messages).'</p>';
		} else {
			$contenu = $donnees;
			if (is_null($donnees)) {
				$contenu = 'OK';
			}
		}
 
		// Gestion de l'envoie du déboguage
		$this->envoyerDebogage();
		
		// Envoie sur la sortie standard
		$this->envoyerContenu($encodage, $mime, $contenu);
	}
	
	protected function envoyerEnteteMessage() {
		if (!is_array($this->messages)) {
			$this->messages[] = $this->messages;
		}
		if (count($this->messages) != 0) {
			foreach ($this->messages as $cle => $val) {
				if (is_array($val)) {
					$this->messages[$cle] = print_r($val, true);
				}
			}
			header('X-MessageJrest-Data: '.json_encode($this->messages));
		}
	}
 
	protected function envoyerDebogage() {
		$this->envoyerEnteteDebogage();
	}
	
	protected function envoyerEnteteDebogage() {
		if (!is_array($this->debug)) {
			$this->debug[] = $this->debug;
		}
		if (count($this->debug) != 0) {
			foreach ($this->debug as $cle => $val) {
				if (is_array($val)) {
					$this->debug[$cle] = print_r($val, true);
				}
			}
			header('X-DebugJrest-Data: '.json_encode($this->debug));
		}
	}
	
	protected function envoyerContenu($encodage, $mime, $contenu) {
		header("Content-Type: $mime; charset=$encodage");
		print $contenu;
	}
	
	private function connecterPDO($config, $base = 'database') {
        $cfg = $config[$base];
		$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];
		try {
    		$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);
		} catch (PDOException $e) {
    		echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();
		}
		// Passe en UTF-8 la connexion à la BDD
		$PDO->exec("SET NAMES 'utf8'");
		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        return $PDO;
	}
	
	protected function getTxt($id) {
		$sortie = '';
		switch ($id) {
			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
			default : $sortie = $id; 
		}
		return $sortie;
	}
	
	protected function concatenerChamps($champs, $prefixe = null) {
		$chaine = '';
		foreach ($champs as $cle => $valeur) {
			if (is_null($prefixe) || (!is_null($prefixe) && stristr($cle, $prefixe.'_'))) {
				$chaine .= ", $cle = $valeur";
			}
		}
		return ltrim($chaine, ', ');
	}
 
	protected function separerChampsValeurs($donnees, $prefixe = null) {
		$sortie = array('', '');
		// Concaténation des champs et des valeurs dans des chaines séparées
		foreach ($donnees as $cle => $valeur) {
			if (is_null($prefixe) || (!is_null($prefixe) && stristr($cle, $prefixe.'_'))) {
				$sortie[0] .= "$cle, ";
				$sortie[1] .= "$valeur, ";
			}
		}
		// Suppression de la virgule finale
		$sortie[0] = rtrim($sortie[0], ', ');
		$sortie[1] = rtrim($sortie[1], ', ');
		return $sortie;
	}
	
	
	protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {
		$sortie = array();
		foreach ($params_attendu as $num => $nom) {
			if (isset($params[$num]) && $params[$num] != '*') {
				if ($pourBDD) {
					$params[$num] = $this->bdd->quote($params[$num]);
				}
				$sortie[$nom] = $params[$num];
			}
		}
		return $sortie;
	}
	
	protected function traiterBddClauseIn($chaine) {
		$sortie = '';
		$chaine = trim($chaine, " '");
		if ($chaine != '') {
			$valeurs = explode(',', $chaine);
			foreach ($valeurs as $id => $valeur) {
				$valeurs[$id] = $this->bdd->quote($valeur);
			}
			$sortie = implode(',', $valeurs);
		}
		return $sortie;
	}
	
	protected function traiterParametresPost($params) {
		$sortie = array();
		foreach ($params as $cle => $valeur) {
			$sortie[$cle] = $this->bdd->quote($valeur);
		}
		return $sortie;
	}
	
	protected function getIdentification(&$params) {
		// Initialisation des variables
		$utilisateur = array(0, session_id());
		
		// L'id utilisateur est soit passé par le POST soit dans l'url
		if (is_array($params) && isset($params['cmhl_ce_modifier_par'])) {
		   	$utilisateur[0] = $params['cmhl_ce_modifier_par'];
			unset($params['cmhl_ce_modifier_par']);
		} else if (is_string($params)) {
			$utilisateur[0] = $params;
		}
		
		return $utilisateur;
	}
	
	protected function etreAutorise($id_utilisateur) {
		$autorisation = false;
		if (($_SESSION['coel_utilisateur'] != '') && $_SESSION['coel_utilisateur']['id'] != $id_utilisateur) {    	  
			$this->messages[] = 'Accès interdit.';
		} else if ($_SESSION['coel_utilisateur'] == '') {    	  
			$this->messages[] = 'Veuillez vous identifiez pour accéder à cette fonction.';
		} else {
			$autorisation = true;
		}
		return $autorisation;
	}
	
	protected function recupererCle($table) {
		$cle = null;
		if (isset($table['champs_valeurs_id'])) {
			$identifiants = array();
			// Trie des clés primaire pour avoir toujours le même ordre dans la table historique pour les clés multiples
			ksort($table['champs_valeurs_id']);
		   	foreach ($table['champs_valeurs_id'] as $id) {
		   		$identifiants[] = $id;
		   	}
		   	$cle = implode('-', $identifiants);
		}
		return $cle;
	}
	
	protected function avoirCleComplete($table) {
		$cle_complete = false;
		if (isset($table['champs_valeurs_id'])) {
		   	$ok = true;
			foreach ($table['id'] as $id) {
		   		if (!isset($table['champs_valeurs_id'][$id]) || $table['champs_valeurs_id'][$id] == '') {
		   			$ok = false;
		   			break;
		   		}
		   	}
		   	$cle_complete = $ok;
		}
		return $cle_complete;
	}
	
	protected function recupererEtat($table) {
		$etat = 1;// Ajout
		if ($this->avoirEnregistrement($table) === true) {
			$etat = 2;// Modification
		}
		return $etat;
	}
	
	protected function avoirEnregistrement($table) {
		$avoir_enregistrement = false;
   		$requete = 	'SELECT * '.
					"FROM {$table['nom']} ".
					"WHERE %s ";
   		
   		$where = $this->construireWhere($table['champs_valeurs_id']);
   		$requete = sprintf($requete, $where);
   		
	   	// Exécution de la requêtre SQL et test d'éventuelles erreurs
		$resultat = $this->bdd->query($requete, PDO::FETCH_ASSOC)->fetch();
		
		if ($resultat !== false) {
			$avoir_enregistrement = true;
		}
		return $avoir_enregistrement;
	}
	
	protected function contenirDonnees($requete) {
		$nbre = $this->bdd->query($requete)->fetchColumn();
		
		$presence = false;
		if ($nbre != 0) {
			$presence = true;
		}
		return $presence;
	}
	
	protected function construireWhere($table) {
		$where = '1';
	   	if (is_array($table) && count($table) > 0) {
			$table_where = array();
	   		foreach ($table as $chp => $id) {
	   			$table_where[] = "$chp = '$id'";
	   		}
	   		$where = implode(' AND ', $table_where);
	   	}
	   	return $where;
	}
	
	protected function recupererTablesAModifier($parametres) {
		$tables_a_modifier = $this->tables;
   		foreach ($this->tables as $table_id => $table) {
   			$tables_a_modifier[$table_id]['champs'] = null;
   			foreach ($parametres as $cle => $valeur) {
   				if (preg_match('/^'.$table['prefixe'].'_/', $cle)) {
   					// Contient les noms des champs seulements
   					$tables_a_modifier[$table_id]['champs'][] = $cle;
   					// Contient un tableau de résultats protégé pour l'inclusion en bdd
   					$tables_a_modifier[$table_id]['champs_valeurs_protege'][$cle] = $this->bdd->quote($valeur);
   					// Contient un tableau de résultats non protégé
   					$tables_a_modifier[$table_id]['champs_valeurs_brut'][$cle] = $valeur;
   					if (preg_match('/_id_/', $cle)) {
   						$tables_a_modifier[$table_id]['champs_valeurs_id'][$cle] = $valeur;
   					}
   				}
   			}  
   		}
   		return $tables_a_modifier;
	}
	
 
	protected function mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table) {
		if (!is_null($table['champs'])) {
	   		// Historisation (Ajout des méta-données)
	   		$cle = $this->recupererCle($table);
	   		$etat = $this->recupererEtat($table);
	   		$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
			$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);
			$champ_meta = "{$table['prefixe']}_ce_meta";
			$table['champs_valeurs_protege'][$champ_meta] = $this->bdd->quote($id_meta);
			
			// Mise à jour des données ou ajout en fonction de l'état
			if ($etat == 1) { // Ajout
				$this->ajouter($table);
			} else if ($etat == 2) { // Modif
				$this->modifier($table);
			}
   		}
	}
	
	protected function ajouter($table) {
		$requete = 	"INSERT INTO {$table['nom']} ".
   					' (%s) '.
					' VALUES (%s) ';
		
		$champs = $valeurs = '';
		foreach ($table['champs_valeurs_protege'] as $chp => $val) {
			$champs .= "$chp, ";
			$valeurs .= "$val, ";
		}
		$requete = sprintf($requete, rtrim($champs, ', '), rtrim($valeurs, ', '));
		
		$resultat = $this->bdd->exec($requete);
		$dernier_id = false;
		if ($resultat === false) {
			$cle = $this->recupererCle($table);
			$this->log[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été ajouté car la requête a échouée.";
		} else {
			$dernier_id = $this->bdd->lastInsertId();
		}
		return $dernier_id;
	}
	
	protected function modifier($table) {
		$requete = 	"UPDATE {$table['nom']} ".
   					'SET %s '.
   					'WHERE %s ';
		
		$champs_requete = '';
		foreach ($table['champs_valeurs_protege'] as $chp => $val) {
			$champs_requete .= "$chp = $val, ";
		}
		$where = $this->construireWhere($table['champs_valeurs_id']);
		$requete = sprintf($requete, rtrim($champs_requete, ', '), $where);
		$resultat = $this->bdd->exec($requete);
		if ($resultat === false) {
			$cle = $this->recupererCle($table);
			$this->log[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été mis à jour car la requête a échouée.";
		} else {
			$resultat = true;
		}
		return $resultat;
	}
	
	protected function supprimer($table) {
		$requete = 	"DELETE FROM {$table['nom']} ".
					'WHERE %s ';
		
		$where = $this->construireWhere($table['champs_valeurs_id']);
		$requete = sprintf($requete, $where);
		
		$resultat = $this->bdd->exec($requete);
		if ($resultat === false) {
			$cle = $this->recupererCle($table);
			$this->messages[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été supprimé car la requête a échouée.";
		} else {
			$resultat = true;
		}
		return $resultat;
	}
	
	private function gererSession($demarrage) {
		session_name($this->sessionName);
 
		// Configuration du cookie de session
		// Détermination du chemin pour les cookies nécessaire à Jrest
		/// ATTENTION : comme les cookies sont passés à Jrest, il faut utiliser l'url de Jrest pour établir le chemin
		$url_morceaux = parse_url($this->config['coel']['urlBaseJrest']);
		$this->cookieChemin = $this->reparerCheminCookie($url_morceaux['path']);
		unset($url_morceaux);
		session_set_cookie_params($this->sessionExpireTime, $this->cookieChemin);
		
		// Démarrage de la session
		if ($demarrage) {
			session_start();
		}
	}
	
	private function reparerCheminCookie($chemin) {
		// dirname renvoit / si le chemin vaut seulement /dossier/, cela renvoit /dossier si le chemin vaut /dossier//.
		$chemin = dirname($chemin.'/.');
		// Fixe la gestion des chemins pour les cookies sous les OS utilisant le \ comme séparteur de chemin
		$chemin = str_replace('\\', '/', $chemin);
		// Ajoute un '/' terminal sauf si on est à la racine web
		$chemin = ($chemin != '/' ? $chemin.'/' : '');
		return $chemin;
	}
	
	private function gererIdentificationPermanente() {
		// Pour maintenir l'utilisateur tjrs réellement identifié nous sommes obligé de recréer une SESSION et de le recharger depuis la bdd
		if ($this->getUtilisateur() == '' 
				&& isset($_COOKIE['coel_login']) 
				&& ($utilisateur = $this->chargerUtilisateur($_COOKIE['coel_login'], $_COOKIE['coel_mot_de_passe']))) {
			$this->setUtilisateur($utilisateur, $_COOKIE['coel_permanence']);
		}
	}
	
	protected function getUtilisateur() {
		return (isset($_SESSION['coel_utilisateur']) ? $_SESSION['coel_utilisateur'] : '');
	}
	
	protected function chargerUtilisateur($login, $mot_de_passe = null) {
		$sortie = false;
		$cp_ce_projet = $this->config['coel']['idProjetUtilisateurs'];
		$requete =	'SELECT cp_id_personne AS id, cp_fmt_nom_complet AS nom_complet, cp_prenom AS prenom, '.
					'	cp_nom AS nom, cp_login AS login, cp_mot_de_passe AS mot_de_passe, cp_parametre AS parametre, '.
					'	cp_ville AS ville, cp_code_postal AS code_postal, '.
					'	cp_mark_licence AS licence '.
					'FROM coel_personne '.
					"WHERE cp_login = {$this->bdd->quote($login)} ".
					"	AND cp_ce_projet = '$cp_ce_projet' ".
					((!is_null($mot_de_passe)) ? "AND cp_mot_de_passe = {$this->bdd->quote($mot_de_passe)} " : '');
		try {
			$resultat = $this->bdd->query($requete)->fetch();
			if ($resultat === false) {
				$this->debug[] = "L'utilisateur n'est pas enregistré comme utilisateur de COEL.";
			} else {
				$sortie = array('id' => $resultat['id'], 
					'login' => $login, 
					'mot_de_passe' => $resultat['mot_de_passe'], 
					'nom_complet' => $resultat['nom_complet'], 
					'nom' => $resultat['nom'], 
					'prenom' => $resultat['prenom'], 
					'parametre' => $resultat['parametre'],
					'ville' => $resultat['ville'], 
					'code_postal' => $resultat['code_postal'],  
					'licence' => $resultat['licence']);
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
		}
		
		return $sortie;
	}
	
	protected function setUtilisateur($utilisateur, $permanence = 1) {
		$_SESSION['coel_utilisateur'] = $utilisateur;
		$this->debug[] = $_SESSION['coel_utilisateur'];
		$this->setCookiePersistant('coel_login', $utilisateur['login'], $permanence);
		$this->setCookiePersistant('coel_mot_de_passe', $utilisateur['mot_de_passe'], $permanence);
		$this->setCookiePersistant('coel_licence', $utilisateur['licence'], $permanence);
		$this->setCookiePersistant('coel_permanence', $permanence, $permanence);
	}
	
	protected function setCookiePersistant($cookie_nom, $valeur, $permanence = 1) {
		setCookie($cookie_nom, $valeur, time() + ($permanence ? 100*24*60*60 : 60*60), $this->cookieChemin);
		$_COOKIE[$cookie_nom] = $valeur;
	}
	
	protected function supprimerCookie($cookie_nom) {
		setCookie($cookie_nom, '', 1, $this->cookieChemin);
		$_COOKIE[$cookie_nom] = '';
	}
	
	/**
	 * Méthode prenant en paramètre un chemin de fichier squelette et un tableau associatif de données,
	 * en extrait les variables, charge le squelette et retourne le résultat des deux combinés.
	 *
	 * @param String $fichier	le chemin du fichier du squelette
	 * @param Array  $donnees	un tableau associatif contenant les variables a injecter dans le squelette.
	 *
	 * @return boolean false si le squelette n'existe pas, sinon la chaine résultat.
	 */
	public static function traiterSquelettePhp($fichier, Array $donnees = array()) {
		$sortie = false;
		if (file_exists($fichier)) {
			// Extraction des variables du tableau de données
			extract($donnees);
			// Démarage de la bufferisation de sortie
			ob_start();
			// Si les tags courts sont activés
			if ((bool) @ini_get('short_open_tag') === true) {
				// Simple inclusion du squelette
				include $fichier;
			} else {
				// Sinon, remplacement des tags courts par la syntaxe classique avec echo
				$html_et_code_php = self::traiterTagsCourts($fichier);
				// Pour évaluer du php mélangé dans du html il est nécessaire de fermer la balise php ouverte par eval
				$html_et_code_php = '?>'.$html_et_code_php;
				// Interprétation du html et du php dans le buffer
				echo eval($html_et_code_php);
			}
			// Récupèration du contenu du buffer
			$sortie = ob_get_contents();
			// Suppression du buffer
			@ob_end_clean();
		} else {
			$msg = "Le fichier du squelette '$fichier' n'existe pas.";
			trigger_error($msg, E_USER_WARNING);
		}
		// Retourne le contenu
		return $sortie;
	}
	
	/**
	 * Fonction chargeant le contenu du squelette et remplaçant les tags court php (<?= ...) par un tag long avec echo.
	 *
	 * @param String $chemin_squelette le chemin du fichier du squelette
	 *
	 * @return string le contenu du fichier du squelette php avec les tags courts remplacés.
	 */
	private static function traiterTagsCourts($chemin_squelette) {
		$contenu = file_get_contents($chemin_squelette);
		// Remplacement de tags courts par un tag long avec echo
		$contenu = str_replace('<?=', '<?php echo ',  $contenu);
		// Ajout systématique d'un point virgule avant la fermeture php
		$contenu = preg_replace("/;*\s*\?>/", "; ?>", $contenu);
		return $contenu;
	}
	
	public static function debug($var) {
		echo '<pre>'.print_r($var, true).'</pre>';
	}
}
?>

Rev 1524	Rev 1527
1	`<?php`	1	`<?php`
2	`/**`	2	`/**`
3	`* Classe mère abstraite contenant les méthodes génériques des services.`	3	`* Classe mère abstraite contenant les méthodes génériques des services.`
4	`* Encodage en entrée : utf8`	4	`* Encodage en entrée : utf8`
5	`* Encodage en sortie : utf8`	5	`* Encodage en sortie : utf8`
6	`*`	6	`*`
7	`* @author Jean-Pascal MILCENT <jpm@tela-botanica.org>`	7	`* @author Jean-Pascal MILCENT <jpm@tela-botanica.org>`
8	`* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>`	8	`* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>`
9	`* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>`	9	`* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>`
10	`* @version $Id$`	10	`* @version $Id$`
11	`* @copyright 2009`	11	`* @copyright 2009`
12	`*/`	12	`*/`
13	`abstract class Coel {`	13	`abstract class Coel {`
14		14
15	`const ETAT_AJOUTER = 1;`	15	`const ETAT_AJOUTER = 1;`
16	`const ETAT_MODIFIER = 2;`	16	`const ETAT_MODIFIER = 2;`
17	`const ETAT_SUPPRIMER = 3;`	17	`const ETAT_SUPPRIMER = 3;`
18		18
19	`protected $sessionName = 'CoelSession';`	19	`protected $sessionName = 'CoelSession';`
20	`protected $sessionExpireTime = 8640000;// 606024*100 = 100 jours`	20	`protected $sessionExpireTime = 8640000;// 606024*100 = 100 jours`
21	`protected static $cookieChemin = '';`	21	`protected static $cookieChemin = '';`
22	`public $config;`	22	`public $config;`
23	`protected $bdd;`	23	`protected $bdd;`
24	`protected $log = array();`	24	`protected $log = array();`
25	`protected $messages = array();`	25	`protected $messages = array();`
26	`protected $debug = array();`	26	`protected $debug = array();`
27	`protected $distinct = false;`	27	`protected $distinct = false;`
28	`protected $orderby = null;`	28	`protected $orderby = null;`
29	`protected $formatRetour = 'objet';`	29	`protected $formatRetour = 'objet';`
30	`protected $start = 0;`	30	`protected $start = 0;`
31	`protected $limit = 150;`	31	`protected $limit = 150;`
32		32
33	`public function __construct($config, $demarrer_session = true) {`	33	`public function __construct($config, $demarrer_session = true) {`
34	`// Tableau contenant la config de Jrest`	34	`// Tableau contenant la config de Jrest`
35	`$this->config = $config;`	35	`$this->config = $config;`
36		36
37	`// Connection à la base de données`	37	`// Connection à la base de données`
38	`$this->bdd = $this->connecterPDO($this->config, 'coel');`	38	`$this->bdd = $this->connecterPDO($this->config, 'coel');`
39		39
40	`$this->gererSession($demarrer_session);`	40	`$this->gererSession($demarrer_session);`
41	`$this->gererIdentificationPermanente();`	41	`$this->gererIdentificationPermanente();`
42		42
43	`// Nettoyage du $_GET (sécurité)`	43	`// Nettoyage du $_GET (sécurité)`
44	`if (isset($_GET)) {`	44	`if (isset($_GET)) {`
45	`$get_params = array('orderby', 'distinct', 'start', 'limit', 'formatRetour');`	45	`$get_params = array('orderby', 'distinct', 'start', 'limit', 'formatRetour');`
46	`foreach ($get_params as $get) {`	46	`foreach ($get_params as $get) {`
47	`$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');`	47	`$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');`
48	`$_GET[$get] = str_replace($verifier, '', $_GET[$get]);`	48	`$_GET[$get] = str_replace($verifier, '', $_GET[$get]);`
49	`if (isset($_GET[$get]) && $_GET[$get] != '') {`	49	`if (isset($_GET[$get]) && $_GET[$get] != '') {`
50	`$this->$get = $_GET[$get];`	50	`$this->$get = $_GET[$get];`
51	`} else {`	51	`} else {`
52	`$_GET[$get] = null;`	52	`$_GET[$get] = null;`
53	`}`	53	`}`
54	`}`	54	`}`
55	`}`	55	`}`
56	`}`	56	`}`
57		57
58	`/**`	58	`/**`
59	`* Méthode appelée quand aucun paramètre n'est passé dans l'url et avec une requête de type GET.`	59	`* Méthode appelée quand aucun paramètre n'est passé dans l'url et avec une requête de type GET.`
60	`*/`	60	`*/`
61	`public function getRessource() {`	61	`public function getRessource() {`
62	`$this->getElement(array());`	62	`$this->getElement(array());`
63	`}`	63	`}`
64		64
65		65
66	`protected function creerXmlHisto($donnees) {`	66	`protected function creerXmlHisto($donnees) {`
67	`// Création du xml de l'enregistrement à historiser`	67	`// Création du xml de l'enregistrement à historiser`
68	`$info = null;`	68	`$info = null;`
69	`$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";`	69	`$xml_tpl = '<?xml version="1.0" encoding="UTF-8" ?>'."\n<resultset>\n<row>\n%s</row>\n</resultset>";`
70	`$xml = null;`	70	`$xml = null;`
71		71
72	`foreach ($donnees as $cle => $valeur) {`	72	`foreach ($donnees as $cle => $valeur) {`
73	`if (!is_null($valeur) && $valeur != '') {`	73	`if (!is_null($valeur) && $valeur != '') {`
74	`$xml .= "<$cle>$valeur</$cle>\n";`	74	`$xml .= "<$cle>$valeur</$cle>\n";`
75	`}`	75	`}`
76	`}`	76	`}`
77	`if ($xml !== null) {`	77	`if ($xml !== null) {`
78	`$info = sprintf($xml_tpl, $xml);`	78	`$info = sprintf($xml_tpl, $xml);`
79	`$info = $this->bdd->quote($info);`	79	`$info = $this->bdd->quote($info);`
80	`}`	80	`}`
81		81
82	`return $info;`	82	`return $info;`
83	`}`	83	`}`
84		84
85	`protected function getTableauDepuisXmlHisto($xml) {`	85	`protected function getTableauDepuisXmlHisto($xml) {`
86	`// Création du xml de l'enregistrement à historiser`	86	`// Création du xml de l'enregistrement à historiser`
87	`$info = array();`	87	`$info = array();`
88		88
89	`if (!empty($xml) && preg_match_all('\|<([^>]+)>(.*)</[^>]+>\|U', $xml, $matches, PREG_SET_ORDER)) {`	89	`if (!empty($xml) && preg_match_all('\|<([^>]+)>(.*)</[^>]+>\|U', $xml, $matches, PREG_SET_ORDER)) {`
90	`foreach ($matches as $val) {`	90	`foreach ($matches as $val) {`
91	`$info[$val[1]] = $val[2];`	91	`$info[$val[1]] = $val[2];`
92	`}`	92	`}`
93	`}`	93	`}`
94		94
95	`return $info;`	95	`return $info;`
96	`}`	96	`}`
97		97
98	`protected function historiser($table_id, $ligne_cle, $info, $id_utilisateur, $etat, $id_session) {`	98	`protected function historiser($table_id, $ligne_cle, $info, $id_utilisateur, $etat, $id_session) {`
99	`// Pré-traitement des variables`	99	`// Pré-traitement des variables`
100	`$info = (is_null($info)) ? 'NULL' : $info;`	100	`$info = (is_null($info)) ? 'NULL' : $info;`
101		101
102	`// Historisation (Ajout des méta-données)`	102	`// Historisation (Ajout des méta-données)`
103	`$requete = 'INSERT INTO coel_meta_historique_ligne '.`	103	`$requete = 'INSERT INTO coel_meta_historique_ligne '.`
104	`' (cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.`	104	`' (cmhl_ce_table, cmhl_cle_ligne, cmhl_enregistrement, cmhl_date_modification, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, cmhl_session_id) '.`
105	`'VALUES ('.`	105	`'VALUES ('.`
106	`" $table_id, ".`	106	`" $table_id, ".`
107	`' "'.$ligne_cle.'", '.`	107	`' "'.$ligne_cle.'", '.`
108	`" $info, ".`	108	`" $info, ".`
109	`' "'.date('Y-m-d H:i:s', time()).'", '.`	109	`' "'.date('Y-m-d H:i:s', time()).'", '.`
110	`" $id_utilisateur, ".`	110	`" $id_utilisateur, ".`
111	`" $etat, ".`	111	`" $etat, ".`
112	`' "'.$_SERVER['REMOTE_ADDR'].'", '.`	112	`' "'.$_SERVER['REMOTE_ADDR'].'", '.`
113	`' "'.$id_session.'") ';`	113	`' "'.$id_session.'") ';`
114		114
115	`// Exécution de la requêtre SQL et test d'éventuelles erreurs`	115	`// Exécution de la requêtre SQL et test d'éventuelles erreurs`
116	`$resultat = $this->bdd->exec($requete);`	116	`$resultat = $this->bdd->exec($requete);`
117	`if ($resultat === false ) {`	117	`if ($resultat === false ) {`
118	`$this->log[] = "Des données de la table '$table_id' (enrg. $ligne_cle) n'ont pas été historisées car la requête a échouée.";`	118	`$this->log[] = "Des données de la table '$table_id' (enrg. $ligne_cle) n'ont pas été historisées car la requête a échouée.";`
119	`}`	119	`}`
120	`return $this->bdd->lastInsertId();`	120	`return $this->bdd->lastInsertId();`
121	`}`	121	`}`
122		122
123	`protected function envoyer($donnees = null, $mime = 'text/html', $encodage = 'utf-8', $json = true) {`	123	`protected function envoyer($donnees = null, $mime = 'text/html', $encodage = 'utf-8', $json = true) {`
124	`// Traitements des messages d'erreurs et données`	124	`// Traitements des messages d'erreurs et données`
125	`if (count($this->messages) != 0) {`	125	`if (count($this->messages) != 0) {`
126	`header('HTTP/1.1 500 Internal Server Error');`	126	`header('HTTP/1.1 500 Internal Server Error');`
127	`$mime = 'text/html';`	127	`$mime = 'text/html';`
128	`$encodage = 'utf-8';`	128	`$encodage = 'utf-8';`
129	`$json = true;`	129	`$json = true;`
130	`$sortie = $this->messages;`	130	`$sortie = $this->messages;`
131	`} else {`	131	`} else {`
132	`$sortie = $donnees;`	132	`$sortie = $donnees;`
133	`if (is_null($donnees)) {`	133	`if (is_null($donnees)) {`
134	`$sortie = 'OK';`	134	`$sortie = 'OK';`
135	`}`	135	`}`
136	`}`	136	`}`
137		137
138	`// Gestion de l'envoie du déboguage`	138	`// Gestion de l'envoie du déboguage`
139	`$this->envoyerDebogage();`	139	`$this->envoyerDebogage();`
140		140
141	`// Encodage au format et JSON et envoie sur la sortie standard`	141	`// Encodage au format et JSON et envoie sur la sortie standard`
142	`$contenu = $json ? json_encode($sortie) : $sortie;`	142	`$contenu = $json ? json_encode($sortie) : $sortie;`
143	`$this->envoyerContenu($encodage, $mime, $contenu);`	143	`$this->envoyerContenu($encodage, $mime, $contenu);`
144	`}`	144	`}`
-		145
-		146	`protected function envoyerHTML($donnees = null) {`
-		147	`// Traitements des messages d'erreurs et données`
-		148	`$contenu = '';`
-		149	`if (count($this->messages) > 0) {`
-		150	`$contenu = '<p>'.implode('<br />', $this->messages).'</p>';`
-		151	`} else {`
-		152	`$contenu = $donnees;`
-		153	`if (is_null($donnees)) {`
-		154	`$contenu = 'OK';`
-		155	`}`
-		156	`}`
-		157
-		158	`// Gestion de l'envoie du déboguage`
-		159	`$this->envoyerDebogage();`
-		160
-		161	`// Envoie sur la sortie standard`
-		162	`$this->envoyerContenu($encodage, $mime, $contenu);`
-		163	`}`
-		164
-		165	`protected function envoyerEnteteMessage() {`
-		166	`if (!is_array($this->messages)) {`
-		167	`$this->messages[] = $this->messages;`
-		168	`}`
-		169	`if (count($this->messages) != 0) {`
-		170	`foreach ($this->messages as $cle => $val) {`
-		171	`if (is_array($val)) {`
-		172	`$this->messages[$cle] = print_r($val, true);`
-		173	`}`
-		174	`}`
-		175	`header('X-MessageJrest-Data: '.json_encode($this->messages));`
-		176	`}`
-		177	`}`
145		178
-		179	`protected function envoyerDebogage() {`
-		180	`$this->envoyerEnteteDebogage();`
-		181	`}`
-		182
146	`protected function envoyerDebogage() {`	183	`protected function envoyerEnteteDebogage() {`
147	`if (!is_array($this->debug)) {`	184	`if (!is_array($this->debug)) {`
148	`$this->debug[] = $this->debug;`	185	`$this->debug[] = $this->debug;`
149	`}`	186	`}`
150	`if (count($this->debug) != 0) {`	187	`if (count($this->debug) != 0) {`
151	`foreach ($this->debug as $cle => $val) {`	188	`foreach ($this->debug as $cle => $val) {`
152	`if (is_array($val)) {`	189	`if (is_array($val)) {`
153	`$this->debug[$cle] = print_r($val, true);`	190	`$this->debug[$cle] = print_r($val, true);`
154	`}`	191	`}`
155	`}`	192	`}`
156	`header('X-DebugJrest-Data:'.json_encode($this->debug));`	193	`header('X-DebugJrest-Data: '.json_encode($this->debug));`
157	`}`	194	`}`
158	`}`	195	`}`
159		196
160	`protected function envoyerContenu($encodage, $mime, $contenu) {`	197	`protected function envoyerContenu($encodage, $mime, $contenu) {`
161	`header("Content-Type: $mime; charset=$encodage");`	198	`header("Content-Type: $mime; charset=$encodage");`
162	`print $contenu;`	199	`print $contenu;`
163	`}`	200	`}`
164		201
165	`private function connecterPDO($config, $base = 'database') {`	202	`private function connecterPDO($config, $base = 'database') {`
166	`$cfg = $config[$base];`	203	`$cfg = $config[$base];`
167	`$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];`	204	`$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];`
168	`try {`	205	`try {`
169	`$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);`	206	`$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);`
170	`} catch (PDOException $e) {`	207	`} catch (PDOException $e) {`
171	`echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();`	208	`echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();`
172	`}`	209	`}`
173	`// Passe en UTF-8 la connexion à la BDD`	210	`// Passe en UTF-8 la connexion à la BDD`
174	`$PDO->exec("SET NAMES 'utf8'");`	211	`$PDO->exec("SET NAMES 'utf8'");`
175	`// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)`	212	`// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)`
176	`$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);`	213	`$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);`
177	`return $PDO;`	214	`return $PDO;`
178	`}`	215	`}`
179		216
180	`protected function getTxt($id) {`	217	`protected function getTxt($id) {`
181	`$sortie = '';`	218	`$sortie = '';`
182	`switch ($id) {`	219	`switch ($id) {`
183	`case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;`	220	`case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;`
184	`default : $sortie = $id;`	221	`default : $sortie = $id;`
185	`}`	222	`}`
186	`return $sortie;`	223	`return $sortie;`
187	`}`	224	`}`
188		225
189	`protected function concatenerChamps($champs, $prefixe = null) {`	226	`protected function concatenerChamps($champs, $prefixe = null) {`
190	`$chaine = '';`	227	`$chaine = '';`
191	`foreach ($champs as $cle => $valeur) {`	228	`foreach ($champs as $cle => $valeur) {`
192	`if (is_null($prefixe) \|\| (!is_null($prefixe) && stristr($cle, $prefixe.'_'))) {`	229	`if (is_null($prefixe) \|\| (!is_null($prefixe) && stristr($cle, $prefixe.'_'))) {`
193	`$chaine .= ", $cle = $valeur";`	230	`$chaine .= ", $cle = $valeur";`
194	`}`	231	`}`
195	`}`	232	`}`
196	`return ltrim($chaine, ', ');`	233	`return ltrim($chaine, ', ');`
197	`}`	234	`}`
198		235
199	`protected function separerChampsValeurs($donnees, $prefixe = null) {`	236	`protected function separerChampsValeurs($donnees, $prefixe = null) {`
200	`$sortie = array('', '');`	237	`$sortie = array('', '');`
201	`// Concaténation des champs et des valeurs dans des chaines séparées`	238	`// Concaténation des champs et des valeurs dans des chaines séparées`
202	`foreach ($donnees as $cle => $valeur) {`	239	`foreach ($donnees as $cle => $valeur) {`
203	`if (is_null($prefixe) \|\| (!is_null($prefixe) && stristr($cle, $prefixe.'_'))) {`	240	`if (is_null($prefixe) \|\| (!is_null($prefixe) && stristr($cle, $prefixe.'_'))) {`
204	`$sortie[0] .= "$cle, ";`	241	`$sortie[0] .= "$cle, ";`
205	`$sortie[1] .= "$valeur, ";`	242	`$sortie[1] .= "$valeur, ";`
206	`}`	243	`}`
207	`}`	244	`}`
208	`// Suppression de la virgule finale`	245	`// Suppression de la virgule finale`
209	`$sortie[0] = rtrim($sortie[0], ', ');`	246	`$sortie[0] = rtrim($sortie[0], ', ');`
210	`$sortie[1] = rtrim($sortie[1], ', ');`	247	`$sortie[1] = rtrim($sortie[1], ', ');`
211	`return $sortie;`	248	`return $sortie;`
212	`}`	249	`}`
213		250
214		251
215	`protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {`	252	`protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {`
216	`$sortie = array();`	253	`$sortie = array();`
217	`foreach ($params_attendu as $num => $nom) {`	254	`foreach ($params_attendu as $num => $nom) {`
218	`if (isset($params[$num]) && $params[$num] != '*') {`	255	`if (isset($params[$num]) && $params[$num] != '*') {`
219	`if ($pourBDD) {`	256	`if ($pourBDD) {`
220	`$params[$num] = $this->bdd->quote($params[$num]);`	257	`$params[$num] = $this->bdd->quote($params[$num]);`
221	`}`	258	`}`
222	`$sortie[$nom] = $params[$num];`	259	`$sortie[$nom] = $params[$num];`
223	`}`	260	`}`
224	`}`	261	`}`
225	`return $sortie;`	262	`return $sortie;`
226	`}`	263	`}`
227		264
228	`protected function traiterBddClauseIn($chaine) {`	265	`protected function traiterBddClauseIn($chaine) {`
229	`$sortie = '';`	266	`$sortie = '';`
230	`$chaine = trim($chaine, " '");`	267	`$chaine = trim($chaine, " '");`
231	`if ($chaine != '') {`	268	`if ($chaine != '') {`
232	`$valeurs = explode(',', $chaine);`	269	`$valeurs = explode(',', $chaine);`
233	`foreach ($valeurs as $id => $valeur) {`	270	`foreach ($valeurs as $id => $valeur) {`
234	`$valeurs[$id] = $this->bdd->quote($valeur);`	271	`$valeurs[$id] = $this->bdd->quote($valeur);`
235	`}`	272	`}`
236	`$sortie = implode(',', $valeurs);`	273	`$sortie = implode(',', $valeurs);`
237	`}`	274	`}`
238	`return $sortie;`	275	`return $sortie;`
239	`}`	276	`}`
240		277
241	`protected function traiterParametresPost($params) {`	278	`protected function traiterParametresPost($params) {`
242	`$sortie = array();`	279	`$sortie = array();`
243	`foreach ($params as $cle => $valeur) {`	280	`foreach ($params as $cle => $valeur) {`
244	`$sortie[$cle] = $this->bdd->quote($valeur);`	281	`$sortie[$cle] = $this->bdd->quote($valeur);`
245	`}`	282	`}`
246	`return $sortie;`	283	`return $sortie;`
247	`}`	284	`}`
248		285
249	`protected function getIdentification(&$params) {`	286	`protected function getIdentification(&$params) {`
250	`// Initialisation des variables`	287	`// Initialisation des variables`
251	`$utilisateur = array(0, session_id());`	288	`$utilisateur = array(0, session_id());`
252		289
253	`// L'id utilisateur est soit passé par le POST soit dans l'url`	290	`// L'id utilisateur est soit passé par le POST soit dans l'url`
254	`if (is_array($params) && isset($params['cmhl_ce_modifier_par'])) {`	291	`if (is_array($params) && isset($params['cmhl_ce_modifier_par'])) {`
255	`$utilisateur[0] = $params['cmhl_ce_modifier_par'];`	292	`$utilisateur[0] = $params['cmhl_ce_modifier_par'];`
256	`unset($params['cmhl_ce_modifier_par']);`	293	`unset($params['cmhl_ce_modifier_par']);`
257	`} else if (is_string($params)) {`	294	`} else if (is_string($params)) {`
258	`$utilisateur[0] = $params;`	295	`$utilisateur[0] = $params;`
259	`}`	296	`}`
260		297
261	`return $utilisateur;`	298	`return $utilisateur;`
262	`}`	299	`}`
263		300
264	`protected function etreAutorise($id_utilisateur) {`	301	`protected function etreAutorise($id_utilisateur) {`
265	`$autorisation = false;`	302	`$autorisation = false;`
266	`if (($_SESSION['coel_utilisateur'] != '') && $_SESSION['coel_utilisateur']['id'] != $id_utilisateur) {`	303	`if (($_SESSION['coel_utilisateur'] != '') && $_SESSION['coel_utilisateur']['id'] != $id_utilisateur) {`
267	`$this->messages[] = 'Accès interdit.';`	304	`$this->messages[] = 'Accès interdit.';`
268	`} else if ($_SESSION['coel_utilisateur'] == '') {`	305	`} else if ($_SESSION['coel_utilisateur'] == '') {`
269	`$this->messages[] = 'Veuillez vous identifiez pour accéder à cette fonction.';`	306	`$this->messages[] = 'Veuillez vous identifiez pour accéder à cette fonction.';`
270	`} else {`	307	`} else {`
271	`$autorisation = true;`	308	`$autorisation = true;`
272	`}`	309	`}`
273	`return $autorisation;`	310	`return $autorisation;`
274	`}`	311	`}`
275		312
276	`protected function recupererCle($table) {`	313	`protected function recupererCle($table) {`
277	`$cle = null;`	314	`$cle = null;`
278	`if (isset($table['champs_valeurs_id'])) {`	315	`if (isset($table['champs_valeurs_id'])) {`
279	`$identifiants = array();`	316	`$identifiants = array();`
280	`// Trie des clés primaire pour avoir toujours le même ordre dans la table historique pour les clés multiples`	317	`// Trie des clés primaire pour avoir toujours le même ordre dans la table historique pour les clés multiples`
281	`ksort($table['champs_valeurs_id']);`	318	`ksort($table['champs_valeurs_id']);`
282	`foreach ($table['champs_valeurs_id'] as $id) {`	319	`foreach ($table['champs_valeurs_id'] as $id) {`
283	`$identifiants[] = $id;`	320	`$identifiants[] = $id;`
284	`}`	321	`}`
285	`$cle = implode('-', $identifiants);`	322	`$cle = implode('-', $identifiants);`
286	`}`	323	`}`
287	`return $cle;`	324	`return $cle;`
288	`}`	325	`}`
289		326
290	`protected function avoirCleComplete($table) {`	327	`protected function avoirCleComplete($table) {`
291	`$cle_complete = false;`	328	`$cle_complete = false;`
292	`if (isset($table['champs_valeurs_id'])) {`	329	`if (isset($table['champs_valeurs_id'])) {`
293	`$ok = true;`	330	`$ok = true;`
294	`foreach ($table['id'] as $id) {`	331	`foreach ($table['id'] as $id) {`
295	`if (!isset($table['champs_valeurs_id'][$id]) \|\| $table['champs_valeurs_id'][$id] == '') {`	332	`if (!isset($table['champs_valeurs_id'][$id]) \|\| $table['champs_valeurs_id'][$id] == '') {`
296	`$ok = false;`	333	`$ok = false;`
297	`break;`	334	`break;`
298	`}`	335	`}`
299	`}`	336	`}`
300	`$cle_complete = $ok;`	337	`$cle_complete = $ok;`
301	`}`	338	`}`
302	`return $cle_complete;`	339	`return $cle_complete;`
303	`}`	340	`}`
304		341
305	`protected function recupererEtat($table) {`	342	`protected function recupererEtat($table) {`
306	`$etat = 1;// Ajout`	343	`$etat = 1;// Ajout`
307	`if ($this->avoirEnregistrement($table) === true) {`	344	`if ($this->avoirEnregistrement($table) === true) {`
308	`$etat = 2;// Modification`	345	`$etat = 2;// Modification`
309	`}`	346	`}`
310	`return $etat;`	347	`return $etat;`
311	`}`	348	`}`
312		349
313	`protected function avoirEnregistrement($table) {`	350	`protected function avoirEnregistrement($table) {`
314	`$avoir_enregistrement = false;`	351	`$avoir_enregistrement = false;`
315	`$requete = 'SELECT * '.`	352	`$requete = 'SELECT * '.`
316	`"FROM {$table['nom']} ".`	353	`"FROM {$table['nom']} ".`
317	`"WHERE %s ";`	354	`"WHERE %s ";`
318		355
319	`$where = $this->construireWhere($table['champs_valeurs_id']);`	356	`$where = $this->construireWhere($table['champs_valeurs_id']);`
320	`$requete = sprintf($requete, $where);`	357	`$requete = sprintf($requete, $where);`
321		358
322	`// Exécution de la requêtre SQL et test d'éventuelles erreurs`	359	`// Exécution de la requêtre SQL et test d'éventuelles erreurs`
323	`$resultat = $this->bdd->query($requete, PDO::FETCH_ASSOC)->fetch();`	360	`$resultat = $this->bdd->query($requete, PDO::FETCH_ASSOC)->fetch();`
324		361
325	`if ($resultat !== false) {`	362	`if ($resultat !== false) {`
326	`$avoir_enregistrement = true;`	363	`$avoir_enregistrement = true;`
327	`}`	364	`}`
328	`return $avoir_enregistrement;`	365	`return $avoir_enregistrement;`
329	`}`	366	`}`
330		367
331	`protected function contenirDonnees($requete) {`	368	`protected function contenirDonnees($requete) {`
332	`$nbre = $this->bdd->query($requete)->fetchColumn();`	369	`$nbre = $this->bdd->query($requete)->fetchColumn();`
333		370
334	`$presence = false;`	371	`$presence = false;`
335	`if ($nbre != 0) {`	372	`if ($nbre != 0) {`
336	`$presence = true;`	373	`$presence = true;`
337	`}`	374	`}`
338	`return $presence;`	375	`return $presence;`
339	`}`	376	`}`
340		377
341	`protected function construireWhere($table) {`	378	`protected function construireWhere($table) {`
342	`$where = '1';`	379	`$where = '1';`
343	`if (is_array($table) && count($table) > 0) {`	380	`if (is_array($table) && count($table) > 0) {`
344	`$table_where = array();`	381	`$table_where = array();`
345	`foreach ($table as $chp => $id) {`	382	`foreach ($table as $chp => $id) {`
346	`$table_where[] = "$chp = '$id'";`	383	`$table_where[] = "$chp = '$id'";`
347	`}`	384	`}`
348	`$where = implode(' AND ', $table_where);`	385	`$where = implode(' AND ', $table_where);`
349	`}`	386	`}`
350	`return $where;`	387	`return $where;`
351	`}`	388	`}`
352		389
353	`protected function recupererTablesAModifier($parametres) {`	390	`protected function recupererTablesAModifier($parametres) {`
354	`$tables_a_modifier = $this->tables;`	391	`$tables_a_modifier = $this->tables;`
355	`foreach ($this->tables as $table_id => $table) {`	392	`foreach ($this->tables as $table_id => $table) {`
356	`$tables_a_modifier[$table_id]['champs'] = null;`	393	`$tables_a_modifier[$table_id]['champs'] = null;`
357	`foreach ($parametres as $cle => $valeur) {`	394	`foreach ($parametres as $cle => $valeur) {`
358	`if (preg_match('/^'.$table['prefixe'].'_/', $cle)) {`	395	`if (preg_match('/^'.$table['prefixe'].'_/', $cle)) {`
359	`// Contient les noms des champs seulements`	396	`// Contient les noms des champs seulements`
360	`$tables_a_modifier[$table_id]['champs'][] = $cle;`	397	`$tables_a_modifier[$table_id]['champs'][] = $cle;`
361	`// Contient un tableau de résultats protégé pour l'inclusion en bdd`	398	`// Contient un tableau de résultats protégé pour l'inclusion en bdd`
362	`$tables_a_modifier[$table_id]['champs_valeurs_protege'][$cle] = $this->bdd->quote($valeur);`	399	`$tables_a_modifier[$table_id]['champs_valeurs_protege'][$cle] = $this->bdd->quote($valeur);`
363	`// Contient un tableau de résultats non protégé`	400	`// Contient un tableau de résultats non protégé`
364	`$tables_a_modifier[$table_id]['champs_valeurs_brut'][$cle] = $valeur;`	401	`$tables_a_modifier[$table_id]['champs_valeurs_brut'][$cle] = $valeur;`
365	`if (preg_match('/_id_/', $cle)) {`	402	`if (preg_match('/_id_/', $cle)) {`
366	`$tables_a_modifier[$table_id]['champs_valeurs_id'][$cle] = $valeur;`	403	`$tables_a_modifier[$table_id]['champs_valeurs_id'][$cle] = $valeur;`
367	`}`	404	`}`
368	`}`	405	`}`
369	`}`	406	`}`
370	`}`	407	`}`
371	`return $tables_a_modifier;`	408	`return $tables_a_modifier;`
372	`}`	409	`}`
373		410
374		411
375	`protected function mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table) {`	412	`protected function mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table) {`
376	`if (!is_null($table['champs'])) {`	413	`if (!is_null($table['champs'])) {`
377	`// Historisation (Ajout des méta-données)`	414	`// Historisation (Ajout des méta-données)`
378	`$cle = $this->recupererCle($table);`	415	`$cle = $this->recupererCle($table);`
379	`$etat = $this->recupererEtat($table);`	416	`$etat = $this->recupererEtat($table);`
380	`$info = $this->creerXmlHisto($table['champs_valeurs_brut']);`	417	`$info = $this->creerXmlHisto($table['champs_valeurs_brut']);`
381	`$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);`	418	`$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);`
382	`$champ_meta = "{$table['prefixe']}_ce_meta";`	419	`$champ_meta = "{$table['prefixe']}_ce_meta";`
383	`$table['champs_valeurs_protege'][$champ_meta] = $this->bdd->quote($id_meta);`	420	`$table['champs_valeurs_protege'][$champ_meta] = $this->bdd->quote($id_meta);`
384		421
385	`// Mise à jour des données ou ajout en fonction de l'état`	422	`// Mise à jour des données ou ajout en fonction de l'état`
386	`if ($etat == 1) { // Ajout`	423	`if ($etat == 1) { // Ajout`
387	`$this->ajouter($table);`	424	`$this->ajouter($table);`
388	`} else if ($etat == 2) { // Modif`	425	`} else if ($etat == 2) { // Modif`
389	`$this->modifier($table);`	426	`$this->modifier($table);`
390	`}`	427	`}`
391	`}`	428	`}`
392	`}`	429	`}`
393		430
394	`protected function ajouter($table) {`	431	`protected function ajouter($table) {`
395	`$requete = "INSERT INTO {$table['nom']} ".`	432	`$requete = "INSERT INTO {$table['nom']} ".`
396	`' (%s) '.`	433	`' (%s) '.`
397	`' VALUES (%s) ';`	434	`' VALUES (%s) ';`
398		435
399	`$champs = $valeurs = '';`	436	`$champs = $valeurs = '';`
400	`foreach ($table['champs_valeurs_protege'] as $chp => $val) {`	437	`foreach ($table['champs_valeurs_protege'] as $chp => $val) {`
401	`$champs .= "$chp, ";`	438	`$champs .= "$chp, ";`
402	`$valeurs .= "$val, ";`	439	`$valeurs .= "$val, ";`
403	`}`	440	`}`
404	`$requete = sprintf($requete, rtrim($champs, ', '), rtrim($valeurs, ', '));`	441	`$requete = sprintf($requete, rtrim($champs, ', '), rtrim($valeurs, ', '));`
405		442
406	`$resultat = $this->bdd->exec($requete);`	443	`$resultat = $this->bdd->exec($requete);`
407	`$dernier_id = false;`	444	`$dernier_id = false;`
408	`if ($resultat === false) {`	445	`if ($resultat === false) {`
409	`$cle = $this->recupererCle($table);`	446	`$cle = $this->recupererCle($table);`
410	`$this->log[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été ajouté car la requête a échouée.";`	447	`$this->log[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été ajouté car la requête a échouée.";`
411	`} else {`	448	`} else {`
412	`$dernier_id = $this->bdd->lastInsertId();`	449	`$dernier_id = $this->bdd->lastInsertId();`
413	`}`	450	`}`
414	`return $dernier_id;`	451	`return $dernier_id;`
415	`}`	452	`}`
416		453
417	`protected function modifier($table) {`	454	`protected function modifier($table) {`
418	`$requete = "UPDATE {$table['nom']} ".`	455	`$requete = "UPDATE {$table['nom']} ".`
419	`'SET %s '.`	456	`'SET %s '.`
420	`'WHERE %s ';`	457	`'WHERE %s ';`
421		458
422	`$champs_requete = '';`	459	`$champs_requete = '';`
423	`foreach ($table['champs_valeurs_protege'] as $chp => $val) {`	460	`foreach ($table['champs_valeurs_protege'] as $chp => $val) {`
424	`$champs_requete .= "$chp = $val, ";`	461	`$champs_requete .= "$chp = $val, ";`
425	`}`	462	`}`
426	`$where = $this->construireWhere($table['champs_valeurs_id']);`	463	`$where = $this->construireWhere($table['champs_valeurs_id']);`
427	`$requete = sprintf($requete, rtrim($champs_requete, ', '), $where);`	464	`$requete = sprintf($requete, rtrim($champs_requete, ', '), $where);`
428	`$resultat = $this->bdd->exec($requete);`	465	`$resultat = $this->bdd->exec($requete);`
429	`if ($resultat === false) {`	466	`if ($resultat === false) {`
430	`$cle = $this->recupererCle($table);`	467	`$cle = $this->recupererCle($table);`
431	`$this->log[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été mis à jour car la requête a échouée.";`	468	`$this->log[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été mis à jour car la requête a échouée.";`
432	`} else {`	469	`} else {`
433	`$resultat = true;`	470	`$resultat = true;`
434	`}`	471	`}`
435	`return $resultat;`	472	`return $resultat;`
436	`}`	473	`}`
437		474
438	`protected function supprimer($table) {`	475	`protected function supprimer($table) {`
439	`$requete = "DELETE FROM {$table['nom']} ".`	476	`$requete = "DELETE FROM {$table['nom']} ".`
440	`'WHERE %s ';`	477	`'WHERE %s ';`
441		478
442	`$where = $this->construireWhere($table['champs_valeurs_id']);`	479	`$where = $this->construireWhere($table['champs_valeurs_id']);`
443	`$requete = sprintf($requete, $where);`	480	`$requete = sprintf($requete, $where);`
444		481
445	`$resultat = $this->bdd->exec($requete);`	482	`$resultat = $this->bdd->exec($requete);`
446	`if ($resultat === false) {`	483	`if ($resultat === false) {`
447	`$cle = $this->recupererCle($table);`	484	`$cle = $this->recupererCle($table);`
448	`$this->messages[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été supprimé car la requête a échouée.";`	485	`$this->messages[] = "L'enregistrement '$cle' de la table {$table['nom']} n'a pas été supprimé car la requête a échouée.";`
449	`} else {`	486	`} else {`
450	`$resultat = true;`	487	`$resultat = true;`
451	`}`	488	`}`
452	`return $resultat;`	489	`return $resultat;`
453	`}`	490	`}`
454		491
455	`private function gererSession($demarrage) {`	492	`private function gererSession($demarrage) {`
456	`session_name($this->sessionName);`	493	`session_name($this->sessionName);`
457		494
458	`// Configuration du cookie de session`	495	`// Configuration du cookie de session`
459	`// Détermination du chemin pour les cookies nécessaire à Jrest`	496	`// Détermination du chemin pour les cookies nécessaire à Jrest`
460	`/// ATTENTION : comme les cookies sont passés à Jrest, il faut utiliser l'url de Jrest pour établir le chemin`	497	`/// ATTENTION : comme les cookies sont passés à Jrest, il faut utiliser l'url de Jrest pour établir le chemin`
461	`$url_morceaux = parse_url($this->config['coel']['urlBaseJrest']);`	498	`$url_morceaux = parse_url($this->config['coel']['urlBaseJrest']);`
462	`$this->cookieChemin = $this->reparerCheminCookie($url_morceaux['path']);`	499	`$this->cookieChemin = $this->reparerCheminCookie($url_morceaux['path']);`
463	`unset($url_morceaux);`	500	`unset($url_morceaux);`

Subversion Repositories eFlore/Applications.coel

(root)/branches/v1.11-okuzgozu/jrest/services/Coel.php @ 1953 – Rev 1524 → 1527