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 Raphaël Droz <raphael@tela-botanica.org>
  * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
+ * @Copyright (c) 2009, 2013 Tela Botanica (accueil@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 {
-    static $optional_bool_fields = array(
+	static $optional_bool_fields = array(
-        'cs_nbre_personne',
+		'cs_nbre_personne',
-        'csc_mark_formation', 'csc_mark_formation_interet',
+		'csc_mark_formation', 'csc_mark_formation_interet',
-        /*'csc_mark_collection_commune',*/ 'csc_mark_acces_controle', 'csc_mark_restauration', 'csc_mark_traitement',
+		/*'csc_mark_collection_commune',*/ 'csc_mark_acces_controle', 'csc_mark_restauration', 'csc_mark_traitement',
+		'csc_mark_acquisition_collection', 'csc_mark_acquisition_echantillon',
-        'csc_mark_acquisition_collection', 'csc_mark_acquisition_echantillon'
+		'cs_latitude', 'cs_longitude',
-    );
+	);
 	// ATTENTION : tjrs garder la table principale en premier, puis mettre les tables spécialisées.
-	protected $tables = array(	120 => array(
+	static $tables = array(	120 => array(
-									'nom' => 'coel_structure',
+        'nom' => 'coel_structure',
-									'prefixe' => 'cs',
+        'prefixe' => 'cs',
-									'id' => array('cs_id_structure')),
+        'id' => array('cs_id_structure')),
 => array(
-									'nom' => 'coel_structure_conservation',
+        'nom' => 'coel_structure_conservation',
-									'prefixe' => 'csc',
+        'prefixe' => 'csc',
-									'id' => array('csc_id_structure')),
+        'id' => array('csc_id_structure')),
 => array(
-									'nom' => 'coel_structure_valorisation',
+        'nom' => 'coel_structure_valorisation',
-									'prefixe' => 'csv',
+        'prefixe' => 'csv',
-									'id' => array('csv_id_structure')));
+        'id' => array('csv_id_structure')));
 	/**
 	 */
 	public function getElementParDefaut($p) {
 		// Initialisation des variables
 		$info = array();
-        $whereClause = array();
+		$whereClause = array();
-        if(isset($p['id_projet'])) $whereClause[] = "cs_ce_projet = {$p['id_projet']}";
+		if(isset($p['id_projet'])) $whereClause[] = "cs_ce_projet = {$p['id_projet']}";
-        if(isset($p['id_structure'])) $whereClause[] = "cs_id_structure = {$p['id_structure']}";
+		if(isset($p['id_structure'])) $whereClause[] = "cs_id_structure = {$p['id_structure']}";
-        if(isset($p['recherche'])) {
+		if(isset($p['recherche'])) {
-            if(@$this->searchCity && trim($this->searchCity) == true) {
+			if(@$this->searchCity && trim($this->searchCity) == true) {
-                $whereClause[] = "(" . implode(" OR ", array("cs_nom LIKE {$p['recherche']}", "cs_ville LIKE {$p['recherche']}")) . ")";
+				$whereClause[] = "(" . implode(" OR ", array("cs_nom LIKE {$p['recherche']}", "cs_ville LIKE {$p['recherche']}")) . ")";
-            } else {
+			} else {
-                $whereClause[] = "cs_nom LIKE {$p['recherche']}";
+				$whereClause[] = "cs_nom LIKE {$p['recherche']}";
-            }
+			}
+		}
 		// Construction de la requête
 		$requete = sprintf(
-            'SELECT SQL_CALC_FOUND_ROWS %s cs.*, csc.*, csv.*, cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip '
+			'SELECT SQL_CALC_FOUND_ROWS %s cs.*, csc.*, csv.*, cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip '
-            . ' FROM coel_structure AS cs '
+			. ' FROM coel_structure AS cs '
-            . ' LEFT JOIN coel_meta_historique_ligne ON (cs_ce_meta = cmhl_id_historique_ligne) '
+			. ' 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_conservation AS csc ON (cs_id_structure = csc_id_structure) '
-            . ' LEFT JOIN coel_structure_valorisation AS csv ON (cs_id_structure = csv_id_structure) '
+			. ' LEFT JOIN coel_structure_valorisation AS csv ON (cs_id_structure = csv_id_structure) '
-            . ' WHERE %s ORDER BY %s LIMIT %d, %d -- %s:%d',
+			. ' WHERE %s ORDER BY %s LIMIT %d, %d -- %s:%d',
-            $this->distinct ? 'DISTINCT' : '',
+			$this->distinct ? 'DISTINCT' : '',
-            $whereClause ? implode(" AND ", $whereClause) : TRUE,
+			$whereClause ? implode(" AND ", $whereClause) : TRUE,
-            is_null($this->orderby) ? 'cs.cs_nom ASC' : $this->orderby,
+			is_null($this->orderby) ? 'cs.cs_nom ASC' : $this->orderby,
-            $this->start, $this->limit,
+			$this->start, $this->limit,
-            __FILE__, __LINE__);
+			__FILE__, __LINE__);
-        // Récupération des résultats
+		// 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.";
 			}
-            // l'UI java n'aime pas les NULL
+			// l'UI java n'aime pas les NULL
-            if(!is_array($donnees)) {
+			if(!is_array($donnees)) {
-                // $donnees est un objet PHP
+				// $donnees est un objet PHP
-                array_walk($donnees, create_function('&$val', '$val = is_null($val) ? "" : $val;'));
+				array_walk($donnees, create_function('&$val', '$val = is_null($val) ? "" : $val;'));
-            }
+			}
-            else {
+			else {
-                // $donnees est un tableau d'objets PHP
+				// $donnees est un tableau d'objets PHP
-                foreach($donnees as &$structure) {
+				foreach($donnees as &$structure) {
-                    array_walk($structure, create_function('&$val', '$val = is_null($val) ? "" : $val;'));
+					array_walk($structure, create_function('&$val', '$val = is_null($val) ? "" : $val;'));
+				}
+			}
 	 * 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) {
+            return array();
-					$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;
-	}
+        // 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').' ';
-    static function NULLifNotNum(&$params, $keys_to_null) {
+        // Récupération des résultats
-        foreach($keys_to_null as $v) {
+        try {
+            $donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
-            if(array_key_exists($v, $params) && !is_numeric($params[$v])) {
+        } catch (PDOException $e) {
+            $this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
+        }
+        if ($donnees === false) {
-                $params[$v] = NULL;
+            $this->messages[] = "La requête a retourné aucun résultat.";
+            return array();
+        }
+        $info = array();
+        foreach ($donnees as $donnee) {
+            $info[$donnee['id']] = $donnee['nbre'];
+        }
+        return $info;
+    }
+	static function NULLifNotNum(&$params, $keys_to_null) {
+		foreach($keys_to_null as $v) {
+			if(array_key_exists($v, $params) && !is_numeric($params[$v])) {
+				$params[$v] = NULL;
+			}
+		}
+	}
 	/**
 		if (!$this->etreAutorise($id_utilisateur)) {
 			$this->envoyer();
 			return;
+		}
 		try {
-			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
-			if( (! @$params['cs_latitude'] || ! @$params['cs_longitude']) &&
-				(@$params['cs_adresse_01'] || @$params['cs_code_postal'] || @$params['cs_ville']) ) {
-				$lonlat = array();
-				if(Coel::coordGuess(Coel::addrReStruct($params), $lonlat)) {
+			$form_needs_refresh = self::callNominatim($params);
-					$params['cs_latitude'] = $lonlat['lat'];
-					$params['cs_longitude'] = $lonlat['lon'];
-				}
-			}
+			self::NULLifNotNum($params, self::$optional_bool_fields);
             self::NULLifNotNum($params, self::$optional_bool_fields);
 			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
 			$tables_a_modifier = $this->recupererTablesAModifier($params);
 			reset($tables_a_modifier);
 			$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) {
 		if (!$this->etreAutorise($id_utilisateur)) {
 			$this->envoyer();
 			return;
+		}
 		try {
-			$form_needs_refresh = FALSE;
+			$form_needs_refresh = self::callNominatim($params);
-			if( (! @$params['cs_latitude'] || ! @$params['cs_longitude']) &&
-				(@$params['cs_adresse_01'] || @$params['cs_code_postal'] || @$params['cs_ville']) ) {
-				$lonlat = array();
-				if(Coel::coordGuess(Coel::addrReStruct($params), $lonlat)) {
-					$params['cs_latitude'] = $lonlat['lat'];
-					$params['cs_longitude'] = $lonlat['lon'];
-					$form_needs_refresh = TRUE;
-				}
-			}
-            self::NULLifNotNum($params, self::$optional_bool_fields);
+			self::NULLifNotNum($params, self::$optional_bool_fields);
 			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
 			$tables_a_modifier = $this->recupererTablesAModifier($params);
 	 */
 	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.";
+            $this->messages[] = "Identifiant de structure ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
+            $this->envoyer();
+            return;
-		} else {
+		}
-			// Identification de l'utilisateur
+        // Identification de l'utilisateur
-			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
+        list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
-			// 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;
+        }
-				// Récupération des id passés par l'url
+        // Récupération des id passés par l'url
-				$identifiants = explode(',', rtrim($uid[1], ','));
+        $identifiants = explode(',', rtrim($uid[1], ','));
+        if (count($identifiants) == 0) {
+            $this->messages[] = "Aucun enregistrement n'a été supprimé.";
+            $this->envoyer();
+            return;
+        }
-				try {
-					if (count($identifiants) == 0) {
-						$this->messages[] = "Aucun enregistrement n'a été supprimé.";
-					} else {
+        try {
-						foreach ($identifiants as $id_structure) {
+            foreach ($identifiants as $id_structure) {
-							// Vérification que la structure ne possède pas de collections liées
+                // Vérification que la structure ne possède pas de collections liées
+                if (self::verifierPresenceCollection($this->bdd, $id_structure)) {
+                    $this->messages[] = "La structure '$id_structure' ne peut pas être supprimée car elle possède des collections liées.";
+                    continue;
+                }
-							if ($this->verifierPresenceCollection($id_structure) === false) {
-								$params = array('cs_id_structure' => $id_structure, 'csc_id_structure' => $id_structure, 'csv_id_structure' => $id_structure);
+                $params = array('cs_id_structure' => $id_structure, 'csc_id_structure' => $id_structure, 'csv_id_structure' => $id_structure);
-								$tables_a_modifier = $this->recupererTablesAModifier($params);
+                $tables_a_modifier = $this->recupererTablesAModifier($params);
+                foreach ($tables_a_modifier as $table_id => $table) {
-								foreach ($tables_a_modifier as $table_id => $table) {
+                    if (! $this->avoirEnregistrement($table)) continue;
-									if ($this->avoirEnregistrement($table)) {
-										$resultat = $this->supprimer($table);
-										if ($resultat === true) {
+                    if ($this->supprimer($table) === true) {
-											// Historisation (Ajout des méta-données)
+                        // Historisation (Ajout des méta-données)
-											$cle = $this->recupererCle($table);
+                        $cle = $this->recupererCle($table);
-											$this->historiser($table_id, $cle, 'NULL', $id_utilisateur, 3, $id_session);
-										}
-									}
+                        $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) {
+        } 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();
-	}
-	private function verifierPresenceCollection($id_structure) {
-		$requete =	'SELECT COUNT(cc_id_collection) AS nbre_collection '.
-					'FROM coel_collection '.
+		$this->envoyer();
+	}
+	static function verifierPresenceCollection($db, $id_structure) {
-					"WHERE cc_ce_structure = '$id_structure' ".
+		// Vérification que la structure ne possède pas de collections liées
+        return ($db->query(sprintf(
-					'GROUP BY cc_ce_structure ';
+            'SELECT COUNT(cc_id_collection) AS nbre_collection FROM coel_collection ' .
+            ' WHERE cc_ce_structure = %d GROUP BY cc_ce_structure ',
+            $id_structure))->fetchColumn() != 0);
+	}
+	static function callNominatim(&$params) {
-		// Vérification que la structure ne possède pas de collections liées
+		if ( (! @$params['cs_latitude'] || ! @$params['cs_longitude']) &&
+		(@$params['cs_adresse_01'] || @$params['cs_code_postal'] || @$params['cs_ville']) ) {
-		$nbre_collection = $this->bdd->query($requete)->fetchColumn();
+			$lonlat = array();
+			if(Coel::coordGuess(Coel::addrReStruct($params), $lonlat)) {
 				$params['cs_latitude'] = $lonlat['lat'];
-		$presence = false;
+				$params['cs_longitude'] = $lonlat['lon'];
-		if ($nbre_collection != 0) {
+				$form_needs_refresh = TRUE;
 			$presence = true;
+		}
-		return $presence;
+		return FALSE;
+	}
 	private function ajouterGuid($abr_projet, $id_structure) {
 		if ($id_structure !== false) {
-			$table_guid = $this->tables[120];
+			$table_guid = self::$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);
+			$table_guid['champs_valeurs_protege']['cs_guid'] = $this->bdd->quote(sprintf($this->config['coel']['guid'], $abr_projet, 'str'.$id_structure));

Subversion Repositories eFlore/Applications.coel

(root)/trunk/jrest/services/CoelStructure.php – Rev 1695 → 1706