WebSVN – eFlore/Applications.coel – Diff – /trunk/jrest/services/CoelCollection.php


<?php
/**
 * Service fournissant la liste des collections et leurs informations.
 * 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
 */
class CoelCollection extends Coel {
 
	protected $tables = array(	101 => array(
									'nom' => 'coel_collection', 
									'prefixe' => 'cc',
									'id' => array('cc_id_collection')),
		   						106 => array(
		   							'nom' => 'coel_collection_botanique', 
		   							'prefixe' => 'ccb',
		   							'id' => array('ccb_id_collection')));	
 
	/**
	 * Méthode principale appelée avec une requête de type GET.
	 */
	public function getElement($param = array()) {
		// Initialisation des variables
		$info = array();
				
		// Nour recherchons le type de requête demandé
		$type = $param[0];
				 
		if ($type == '*' || is_numeric($type)) {
			$info = $this->getElementParDefaut($param);
		} else {
			$methode = 'getElement'.$type;
			if (method_exists($this, $methode)) {
				array_shift($param);
				$info = $this->$methode($param);
			} else {
				$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
			}
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($info);
	}
	
	/**
	 * Méthode par défaut pour garder la compatibilité avec Coel.
	 * Appelée avec les paramêtres d'url suivant :
	 * /CoelCollection/_/_/_
	 * ou les _ représentent dans l'ordre : id_collection ou nom
	 * Si un des paramêtres est abscent, il prendre la valeur *
	 */
	public function getElementParDefaut($param) {
		// Initialisation des variables
		$info = array();
				
		// Pré traitement des paramêtres
		$p = $this->traiterParametresUrl(array('id_collection', 'recherche'), $param);
				 
		// Construction de la requête
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' c.*, cb.*, '.
					'	cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, '.
					'	ccm.cc_nom AS _collection_mere_nom_, '.			
					'	cs_nom AS _structure_nom_, cs_ville AS _structure_ville_ '.
					'FROM coel_collection AS c'.
					'	LEFT JOIN coel_meta_historique_ligne AS cmhl ON (c.cc_ce_meta = cmhl_id_historique_ligne) '.
					'	LEFT JOIN coel_structure ON (c.cc_ce_structure = cs_id_structure) '.
					'	LEFT JOIN coel_collection AS ccm ON (c.cc_ce_mere = ccm.cc_id_collection) '.
					'	LEFT JOIN coel_collection_botanique AS cb ON (c.cc_id_collection = ccb_id_collection) '.
					((count($p) != 0) ? 'WHERE ' : '').			
 
					((isset($p['id_collection'])) ? "AND c.cc_id_collection = {$p['id_collection']} " : '').
					(isset($p['recherche']) ? $this->construireWhereRecherche($p['recherche']) : '').
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'c.cc_nom ASC').' ';
					
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
		$requeteCount = $requete;
		$requete .= "LIMIT $this->start, $this->limit ";
 
		// Récupération des résultats
		try {
			// SPÉCIAL :
			// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
			$donnees = (isset($p['id_collection'])) ? $this->bdd->query($requete)->fetch(PDO::FETCH_OBJ) : $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
			if ($donnees === false) {
				$this->messages[] = "La requête a retourné aucun résultat.";
			}
 
			$nbElements = $this->bdd->query($requeteCount)->rowCount();
			
			$info['nbElements'] = $nbElements;
			$info['collections'] = $donnees;
			
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
		}
 
		return $info;
	}
	
	private function construireWhereRecherche($recherche) {
		$recherche = "AND ".
						"(".
							"c.cc_nom LIKE {$recherche}  OR ".
							"cs_ville LIKE {$recherche} ".
						")";
		return $recherche;
	}
	
 	/* Méthode pour récupérer une liste de collection en fonction d'un id structure.
	 * Appelée avec les paramêtres d'url suivant :
	 * /CoelCollection/ParIdStructure/_
	 * ou les _ représentent dans l'ordre : id_structure
	 * Si un des paramêtres est abscent, il prendre la valeur *
	 */
	public function getElementParIdStructure($param) {
		// Initialisation des variables
		$info = array();
				
		// Pré traitement des paramêtres
		$p = $this->traiterParametresUrl(array('id_structure'), $param);
		if (!isset($p['id_structure'])) {
			$this->messages[] = "Il est obligatoire d'indiquer un id de structure pour utiliser ce service.";
		} else {
			// Construction de la requête
			$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' cc_nom, cc_id_collection '.
						'FROM coel_collection AS c '.
						'WHERE '.			
						"	c.cc_ce_structure = {$p['id_structure']} ".
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'c.cc_nom ASC').' '.
						"LIMIT $this->start, $this->limit ";
 
			// Récupération des résultats
			try {
				// SPÉCIAL :
				// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				} else {
					$info = $donnees;
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		}
		return $info;
	}
	
	/* Méthode pour récupérer le nombre de collection en fonction d'un id structure.
	 * Appelée avec les paramêtres d'url suivant :
	 * /CoelCollection/NbreParIdStructure/_
	 * ou les _ représentent dans l'ordre : id_structure
	 * Si un des paramêtres est abscent, il prendre la valeur *
	 */
	public function getElementNbreParIdStructure($param) {
		// Initialisation des variables
		$info = array();
				
		// Pré traitement des paramêtres
		$p = $this->traiterParametresUrl(array('id_structure'), $param);
		if (!isset($p['id_structure'])) {
			$this->messages[] = "Il est obligatoire d'indiquer un id de structure pour utiliser ce service.";
		} else {
			// Construction de la requête
			$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' COUNT(cc_id_collection) AS nbre '.
						'FROM coel_collection AS c '.
						'WHERE '.			
						"	c.cc_ce_structure = {$p['id_structure']} ".
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'c.cc_nom ASC');
 
			// Récupération des résultats
			try {
				// SPÉCIAL :
				// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
				$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				} else {
					$info = $donnees['nbre'];
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		}
		return $info;
	}
	
	/**
	 * Méthode appelée pour ajouter un élément.
	 */
	public function createElement($params) {
		// Identification de l'utilisateur
		list($id_utilisateur, $id_session) = $this->getIdentification($params);
		
		// Contrôle du non détournement de l'utilisateur
		if ($this->etreAutorise($id_utilisateur)) {
			try {
	   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
	   			$tables_a_modifier = $this->recupererTablesAModifier($params);
	   			reset($tables_a_modifier);
	   			
	   			$id_collection = null;
				while (list($table_id, $table) = each($tables_a_modifier)) {
		   			if (!is_null($table['champs'])) {
				   		if (!$this->avoirCleComplete($table)) {
		   					// Ajout des données à la table des données
		   					$id_collection = $this->ajouter($table);
		   					if ($id_collection !== false) {
								$table['champs_valeurs_id']['cc_id_collection'] = $id_collection;
								$table['champs_valeurs_brut']['cc_id_collection'] = $id_collection;
								$tables_a_modifier[106]['champs_valeurs_id']['ccb_id_collection'] = $id_collection;
								$tables_a_modifier[106]['champs_valeurs_brut']['ccb_id_collection'] = $id_collection;
								$tables_a_modifier[106]['champs_valeurs_protege']['ccb_id_collection'] = $this->bdd->quote($id_collection);
								
								// Historisation (Ajout des méta-données)
								$etat = 1; // Ajout
								$cle = $this->recupererCle($table);
								$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
								$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);
								
						   		// Liaison de la table des données à ses méta-données
						   		$champ_meta = "{$table['prefixe']}_ce_meta";
						   		$table['champs_valeurs_protege'] = array($champ_meta => $id_meta);
						   		$this->modifier($table);
		   					}
			   			} else {
			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
			   			}
		   			}
				}
				if(!isset($params['cpr_abreviation'])) {
					$params['cpr_abreviation'] = '';
				}
				$this->ajouterGuid($params['cpr_abreviation'], $id_collection);
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
			}
	   	}
	   	
	   	$this->envoyer($id_collection);
	}
	
	/**
	 * Méthode appelée pour mettre à jour un élément
	 */
	public function updateElement($uid, $params) {
		// Vérification de la présence des id passés par l'url
		if (!isset($uid[0])) {
			$this->messages[] = "Identifiant de collection manquant. Vous ne devriez pas avoir accès à ce service.";
		} else {
			// Identification de l'utilisateur
			list($id_utilisateur, $id_session) = $this->getIdentification($params);
			
			// Contrôle du non détournement de l'utilisateur
			if ($this->etreAutorise($id_utilisateur)) {
		   		try {
		   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
		   			$tables_a_modifier = $this->recupererTablesAModifier($params);
 
		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
			   		foreach ($tables_a_modifier as $table_id => $table) {
						$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
					}
				} catch (PDOException $e) {
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
				}
		   	}
		}
				
		// Envoie sur la sortie standard
		$this->envoyer();
	}
	
	/**
	 * Méthode appelée pour supprimer un élément
	 */
	public function deleteElement($uid) {
		// Vérification de la présence des id passés par l'url
		if (!isset($uid[0]) || !isset($uid[1])) {
			$this->messages[] = "Identifiant de collection ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
		} else {
			// Identification de l'utilisateur
			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
		
			// Contrôle du non détournement de l'utilisateur		
			if ($this->etreAutorise($id_utilisateur)) {
				// Récupération des id passés par l'url
				$identifiants = explode(',', rtrim($uid[1], ','));
	
		   		try {
		   			if (count($identifiants) == 0) {
		   				$this->messages[] = "Aucun enregistrement n'a été supprimé.";
		   			} else {
			   			foreach ($identifiants as $id_collection) {
				   			// Vérification que la structure ne possède pas de collections liées
							$params = array('cc_id_collection' => $id_collection, 'ccb_id_collection' => $id_collection);
							$tables_a_modifier = $this->recupererTablesAModifier($params);
							
							foreach ($tables_a_modifier as $table_id => $table) {
					   			if ($this->avoirEnregistrement($table)) {
					   				$resultat = $this->supprimer($table);
									if ($resultat === true) {
										// Historisation (Ajout des méta-données)
										$cle = $this->recupererCle($table);
										$this->historiser($table_id, $cle, 'NULL', $id_utilisateur, 3, $id_session);
									}
					   			}
				   			}
			   			}
		   			}
			   	} catch (PDOException $e) {
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
				}
		   	}
		}
 
		// Envoie sur la sortie standard
		$this->envoyer();
	}
	
	private function ajouterGuid($id_collection) {
		if ($id_collection !== false) {
			$table_guid = $this->tables[101];
			$table_guid['champs_valeurs_id']['cc_id_collection'] = $id_collection;
			$table_guid['champs_valeurs_protege']['cc_guid'] = $this->bdd->quote(sprintf($this->config['coel']['guid'], 'coll'.$id_collection));
			$this->modifier($table_guid);
		}
	}
}
?>

Subversion Repositories eFlore/Applications.coel

(root)/trunk/jrest/services/CoelCollection.php @ 1932 – Rev 1636 → 1765

Rev 1636		Rev 1765
1	`<?php`	1	`<?php`
2	`/**`	2	`/**`
3	`* Service fournissant la liste des collections et leurs informations.`	3	`* Service fournissant la liste des collections et leurs informations.`
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	`class CoelCollection extends Coel {`	13	`class CoelCollection extends Coel {`
14		14
15	`protected $tables = array( 101 => array(`	15	`protected $tables = array( 101 => array(`
16	`'nom' => 'coel_collection',`	16	`'nom' => 'coel_collection',`
17	`'prefixe' => 'cc',`	17	`'prefixe' => 'cc',`
18	`'id' => array('cc_id_collection')),`	18	`'id' => array('cc_id_collection')),`
19	`106 => array(`	19	`106 => array(`
20	`'nom' => 'coel_collection_botanique',`	20	`'nom' => 'coel_collection_botanique',`
21	`'prefixe' => 'ccb',`	21	`'prefixe' => 'ccb',`
22	`'id' => array('ccb_id_collection')));`	22	`'id' => array('ccb_id_collection')));`
23		23
24	`/**`	24	`/**`
25	`* Méthode principale appelée avec une requête de type GET.`	25	`* Méthode principale appelée avec une requête de type GET.`
26	`*/`	26	`*/`
27	`public function getElement($param = array()) {`	27	`public function getElement($param = array()) {`
28	`// Initialisation des variables`	28	`// Initialisation des variables`
29	`$info = array();`	29	`$info = array();`
30		30
31	`// Nour recherchons le type de requête demandé`	31	`// Nour recherchons le type de requête demandé`
32	`$type = $param[0];`	32	`$type = $param[0];`
33		33
34	`if ($type == '*' \|\| is_numeric($type)) {`	34	`if ($type == '*' \|\| is_numeric($type)) {`
35	`$info = $this->getElementParDefaut($param);`	35	`$info = $this->getElementParDefaut($param);`
36	`} else {`	36	`} else {`
37	`$methode = 'getElement'.$type;`	37	`$methode = 'getElement'.$type;`
38	`if (method_exists($this, $methode)) {`	38	`if (method_exists($this, $methode)) {`
39	`array_shift($param);`	39	`array_shift($param);`
40	`$info = $this->$methode($param);`	40	`$info = $this->$methode($param);`