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

 <?php
 /**
  * Service fournissant la liste des structures 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 CoelStructure extends Coel {
 	// ATTENTION : tjrs garder la table principale en premier, puis mettre les tables spécialisées.
 	protected $tables = array(	120 => array(
 									'nom' => 'coel_structure',
 									'prefixe' => 'cs',
 									'id' => array('cs_id_structure')),
 => array(
 		   							'nom' => 'coel_structure_conservation',
 		   							'prefixe' => 'csc',
 		   							'id' => array('csc_id_structure')),
 => array(
 		   							'nom' => 'coel_structure_valorisation',
 		   							'prefixe' => 'csv',
 		   							'id' => array('csv_id_structure')));
 	/**
 	 * 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 :
 	 * /CoelStructure/_/_/_
 	 * ou les _ représentent dans l'ordre : id_projet, id_structure et 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_projet', 'id_structure', 'recherche'), $param);
 		// Construction de la requête
 		$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' cs.*, csc.*, csv.*, '.
 					'	cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip '.
 					'FROM coel_structure AS cs '.
 					'	LEFT JOIN coel_meta_historique_ligne ON (cs_ce_meta = cmhl_id_historique_ligne) '.
 					'	LEFT JOIN coel_structure_conservation AS csc ON (cs_id_structure = csc_id_structure) '.
 					'	LEFT JOIN coel_structure_valorisation AS csv ON (cs_id_structure = csv_id_structure) '.
 					((count($p) != 0) ? 'WHERE ' : '').
 					((isset($p['id_projet'])) ? "AND cs_ce_projet = {$p['id_projet']} " : '').
 					((isset($p['id_structure'])) ? "AND cs_id_structure = {$p['id_structure']} " : '').
 					(isset($p['recherche']) ? $this->construireWhereRecherche($p['recherche']) : '').
 					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'cs.cs_nom ASC').' ';
 		$requete = str_replace('WHERE AND', 'WHERE', $requete);
 		$requete_compte = $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 = ($this->formatRetour == 'objet' && isset($p['id_structure'])) ? $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.";
+			}
 			$elements_nbre = $this->bdd->query($requete_compte)->rowCount();
 			$info['nbElements'] = $elements_nbre;
 			$info['structures'] = $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 ".
 		"(".
 			"cs_nom LIKE {$recherche}  OR ".
 			"cs_ville LIKE {$recherche} ".
 		")";
 		return $recherche;
+	}
 	/* Méthode pour récupérer le nombre de structure par zone géographique.
 	 * Appelée avec les paramêtres d'url suivant :
 	 * /CoelStructure/ParZoneGeo/_
 	 * ou les _ représentent dans l'ordre : type.
 	 * ou type peut valoir: FRD (= département français)
 	 * Si un des paramêtres est abscent, il prendre la valeur *
 	 */
 	public function getElementParZoneGeo($param) {
 		// Initialisation des variables
 		$info = array();
 		// Pré traitement des paramêtres
 		$p = $this->traiterParametresUrl(array('type', 'projets'), $param);
 		if (!isset($p['type'])) {
 			$this->messages[] = "Il est obligatoire d'indiquer type de recherche pour utiliser ce service.";
 		} else {
 			// Construction de la requête
 			$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' '.
 						'	IF ( SUBSTRING( cs_code_postal FROM 1 FOR 2 ) >= 96, '.
 						'		SUBSTRING( cs_code_postal FROM 1 FOR 3 ), '.
 						'		SUBSTRING( cs_code_postal FROM 1 FOR 2 ) ) AS id, '.
 						'	COUNT( cs_id_structure ) AS nbre '.
 						'FROM coel_structure '.
 						'WHERE cs_ce_truk_pays = 2654 '.
 						(isset($p['projets']) ? "	AND cs_ce_projet IN ({$p['projets']}) " : '').
 						'GROUP BY IF ( SUBSTRING( cs_code_postal FROM 1 FOR 2 ) >= 96, '.
 						'	SUBSTRING( cs_code_postal FROM 1 FOR 3 ), '.
 						'	SUBSTRING( cs_code_postal FROM 1 FOR 2 ) ) '.
 						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'id ASC').' ';
 			// Récupération des résultats
 			try {
 				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
 				if ($donnees === false) {
 					$this->messages[] = "La requête a retourné aucun résultat.";
 				} else {
 					foreach ($donnees as $donnee) {
 						$info[$donnee['id']] = $donnee['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)) {
+		if (!$this->etreAutorise($id_utilisateur)) {
+			$this->envoyer();
+			return;
+		}
-			try {
+		try {
-	   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
+			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
-	   			$tables_a_modifier = $this->recupererTablesAModifier($params);
+			$tables_a_modifier = $this->recupererTablesAModifier($params);
-	   			reset($tables_a_modifier);
+			reset($tables_a_modifier);
-	   			$id_structure = null;
+			$id_structure = null;
-				while (list($table_id, $table) = each($tables_a_modifier)) {
+			while (list($table_id, $table) = each($tables_a_modifier)) {
-		   			if (!is_null($table['champs'])) {
+				if (is_null($table['champs'])) continue;
+				if ($this->avoirCleComplete($table)) {
+					$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
+					continue;
+				}
-				   		if (!$this->avoirCleComplete($table)) {
-		   					// Ajout des données à la table des données
+				// Ajout des données à la table des données
-		   					$id_structure = $this->ajouter($table);
+				$id_structure = $this->ajouter($table);
+				if ($id_structure === false) continue;
-		   					if ($id_structure !== false) {
-								$table['champs_valeurs_id']['cs_id_structure'] = $id_structure;
+				$table['champs_valeurs_id']['cs_id_structure'] = $id_structure;
-								$table['champs_valeurs_brut']['cs_id_structure'] = $id_structure;
+				$table['champs_valeurs_brut']['cs_id_structure'] = $id_structure;
-								$tables_a_modifier[122]['champs_valeurs_id']['csc_id_structure'] = $id_structure;
+				$tables_a_modifier[122]['champs_valeurs_id']['csc_id_structure'] = $id_structure;
-								$tables_a_modifier[122]['champs_valeurs_brut']['csc_id_structure'] = $id_structure;
+				$tables_a_modifier[122]['champs_valeurs_brut']['csc_id_structure'] = $id_structure;
-								$tables_a_modifier[122]['champs_valeurs_protege']['csc_id_structure'] = $this->bdd->quote($id_structure);
+				$tables_a_modifier[122]['champs_valeurs_protege']['csc_id_structure'] = $this->bdd->quote($id_structure);
-								$tables_a_modifier[123]['champs_valeurs_id']['csv_id_structure'] = $id_structure;
+				$tables_a_modifier[123]['champs_valeurs_id']['csv_id_structure'] = $id_structure;
-								$tables_a_modifier[123]['champs_valeurs_brut']['csv_id_structure'] = $id_structure;
+				$tables_a_modifier[123]['champs_valeurs_brut']['csv_id_structure'] = $id_structure;
-								$tables_a_modifier[123]['champs_valeurs_protege']['csv_id_structure'] = $this->bdd->quote($id_structure);
+				$tables_a_modifier[123]['champs_valeurs_protege']['csv_id_structure'] = $this->bdd->quote($id_structure);
-								// Historisation (Ajout des méta-données)
+				// Historisation (Ajout des méta-données)
-								$etat = 1; // Ajout
+				$etat = 1; // Ajout
-								$cle = $this->recupererCle($table);
+				$cle = $this->recupererCle($table);
-								$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
+				$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
-								$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);
+				$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
+				// Liaison de la table des données à ses méta-données
-						   		$champ_meta = "{$table['prefixe']}_ce_meta";
+				$champ_meta = "{$table['prefixe']}_ce_meta";
-						   		$table['champs_valeurs_protege'] = array($champ_meta => $id_meta);
+				$table['champs_valeurs_protege'] = array($champ_meta => $id_meta);
-						   		$this->modifier($table);
+				$this->modifier($table);
-		   					}
-			   			} else {
-			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
+			}
-		   			}
-				}
 				$this->ajouterGuid($params['cpr_abreviation'], $id_structure);
+			if(isset($params['cpr_abreviation']) && !empty($params['cpr_abreviation'])) {
+				$this->ajouterGuid($params['cpr_abreviation'], $id_structure);
-			} catch (PDOException $e) {
+			}
-				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
+		} catch (PDOException $e) {
 			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
+		}
 	   	$this->envoyer($id_structure);
+	}
 	/**
 	 * 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 structure manquant. Vous ne devriez pas avoir accès à ce service.";
+			$this->envoyer();
-		} else {
+			return;
+		}
-			// Identification de l'utilisateur
+		// Identification de l'utilisateur
-			list($id_utilisateur, $id_session) = $this->getIdentification($params);
+		list($id_utilisateur, $id_session) = $this->getIdentification($params);
-			// Contrôle du non détournement de l'utilisateur
+		// Contrôle du non détournement de l'utilisateur
-			if ($this->etreAutorise($id_utilisateur)) {
+		if (!$this->etreAutorise($id_utilisateur)) {
+			$this->envoyer();
+			return;
+		}
-		   		try {
+		try {
-		   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
+			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
-		   			$tables_a_modifier = $this->recupererTablesAModifier($params);
+			$tables_a_modifier = $this->recupererTablesAModifier($params);
-		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
+			// 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) {
+			foreach ($tables_a_modifier as $table_id => $table) {
-						$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
+				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
-					}
+			}
-				} catch (PDOException $e) {
+		} catch (PDOException $e) {
-					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
-				}
 			$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) {
 	   	// NOTES : une structure ne peut pas être supprimée si elle possède des collections liées.
 		// Vérification de la présence des id passés par l'url
 		if (!isset($uid[0]) || !isset($uid[1])) {
 				$this->messages[] = "Identifiant de structure 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_structure) {
 				   			// Vérification que la structure ne possède pas de collections liées
 							if ($this->verifierPresenceCollection($id_structure) === false) {
 								$params = array('cs_id_structure' => $id_structure, 'csc_id_structure' => $id_structure, 'csv_id_structure' => $id_structure);
 								$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);
+										}
+						   			}
+					   			}
 							} else {
 								$this->messages[] = "La structure '$id_structure' ne peut pas être supprimée car elle possède des collections liées.";
+							}
+			   			}
+		   			}
 			   	} 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 verifierPresenceCollection($id_structure) {
 		$requete = 	'SELECT COUNT(cc_id_collection) AS nbre_collection '.
 					'FROM coel_collection '.
 					"WHERE cc_ce_structure = '$id_structure' ".
 	   				'GROUP BY cc_ce_structure ';
 		// Vérification que la structure ne possède pas de collections liées
 		$nbre_collection = $this->bdd->query($requete)->fetchColumn();
 		$presence = false;
 		if ($nbre_collection != 0) {
 			$presence = true;
+		}
 		return $presence;
+	}
 	private function ajouterGuid($abr_projet, $id_structure) {
 		if ($id_structure !== false) {
 			$table_guid = $this->tables[120];
 			$table_guid['champs_valeurs_id']['cs_id_structure'] = $id_structure;
 			$table_guid['champs_valeurs_protege']['cs_guid'] = $this->bdd->quote(sprintf($this->config['coel']['guid'], $abr_projet, 'str'.$id_structure));
 			$this->modifier($table_guid);
+		}
+	}
+}
 ?>

Subversion Repositories eFlore/Applications.coel

(root)/trunk/jrest/services/CoelStructure.php – Rev 1636 → 1648