Subversion Repositories eFlore/Applications.moissonnage

<?php

class Observations {

	private $longitude = null;

	private $latitude = null;

	private $utilisateur = '';

	private $taxon = null;

	private $referentiel = '';

	private $sousTaxons = array();

	private $bdd;

	public function __construct() {}

	public function consulter($ressources, $parametres) {

		extract($parametres);

		$this->utilisateur = $utilisateur != '*' ? $utilisateur : '';

		$this->departement = $dept != '*' ? $dept : '';

		$this->traiterParametresCoordonnees($parametres);

		if (is_null($this->longitude) || is_null($this->latitude)) {

			$message = "Recherche des observations impossible : coordonnees de la station hors du plan";

			return new Exception($message, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);

		}

		// recherche du taxon dans les referentiels bdtfx et bdtxa et verification de sa validite

		if ($referentiel != '*') {

			$this->referentiel = $this->verifierExistenceReferentiel($referentiel);

			if (is_null($this->referentiel)) {

				$message = "Recherche des stations impossible : referentiel inconnu\n"

					+ "Voici les referentiels disponibles : "

					+ implode(', ', Referentiel::listeReferentielsDisponibles());

				return new Exception($message, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);

			}

		}

		if ($num_taxon != '*') {

			$this->traiterParametresTaxon($num_taxon);

			if (is_null($this->taxon)) {

				$message = "Recherche des stations impossible : taxon non trouve dans les referentiels";

				return new Exception($message, RestServeur::HTTP_CODE_MAUVAISE_REQUETE);

			}

			// recuperer les sous-taxons

			$referentiel = new Referentiel($this->referentiel);

			$this->sousTaxons = $referentiel->recupererSousTaxons();

		}

		// recuperer les informations sur les stations repondant a ces parametres

		$observations = $this->recupererObservations();

		$nomSite = $this->obtenirNomSite();

		// mettre en forme les informations au format JSON

		$formateurJSON = new FormateurJson();

		$donneesFormatees = $formateurJSON->formaterObservations($observations, $nomSite);

		return $donneesFormatees;

	}

	//-------------------------------------------------------------------------------

	//    Recuperation et verification des parametres

	//-------------------------------------------------------------------------------

	private function traiterParametresCoordonnees($parametres) {

		$this->longitude = $this->verifierCoordonnees($parametres['longitude'], 'lng');

		$this->latitude  = $this->verifierCoordonnees($parametres['latitude'],  'lat');

	}

	private function verifierCoordonnees($valeur, $axe) {

		$limites = array(

			'ouest' => floatval(Config::get('carte.limite_ouest')),

			'est'   => floatval(Config::get('carte.limite_est')),

			'sud'   => floatval(Config::get('carte.limite_sud')),

			'nord'  => floatval(Config::get('carte.limite_nord'))

		);

		if (($axe=='lng' && floatval($valeur) >= $limites['ouest'] && floatval($valeur) <= $limites['est'])

			|| ($axe=='lat' && floatval($valeur) >= $limites['sud'] && floatval($valeur) <= $limites['nord'])) {

			return $valeur;

		}

		return null;

	}

	private function traiterParametresTaxon($numeroTaxon) {

		if ($numeroTaxon != '*') {

			if ($this->referentiel != '') {

				$referentiel = new Referentiel($this->referentiel);

				$this->taxon = $referentiel->recupererTaxon($numeroTaxon);

			} else {

				$this->taxon = $this->verifierExistenceTaxon($numeroTaxon);

			}

		}

	}

	private function verifierExistenceReferentiel($referentiel) {

		if ($referentiel == '*') {

			return '';

		}

		$listeReferentiels = Referentiel::listeReferentielsDisponibles();

		foreach ($listeReferentiels as $nomReferentiel) {

			if (strstr($nomReferentiel, $referentiel) !== false) {

				$this->referentiel = $nomReferentiel;

				break;

			}

		}

		return null;

	}

	private function verifierExistenceTaxon($numTaxon) {

		$listeReferentiels = Referentiel::listeReferentielsDisponibles();

		// tester chaque referentiel jusqu'a trouver un taxon correspondant

		// a tous les criteres demandes dans les masques

		foreach ($listeReferentiels as $nomReferentiel) {

			$referentiel = new Referentiel($nomReferentiel);

			$taxon = $referentiel->recupererTaxon($numTaxon);

			if (!is_null($taxon)) {

				$this->referentiel = $nomReferentiel;

				return $taxon;

			}

		}

		return null;

	}

	//-------------------------------------------------------------------------------

	//    Recuperation des donnees dans la base de donnees

	//    et mise sous forme d'objet geographique en fonction du niveau de zoom

	//-------------------------------------------------------------------------------

	private function recupererObservations() {

		$requete = 'SELECT ' . $this->construireColonnesSelection() . ' FROM cel_obs'

			. ' WHERE transmission=1' . $this->construireWhereUtilisateur()

			. $this->construireWhereTaxon() . $this->construireWhereCoordonnees()

			. ' ORDER BY nom_ret, date, observateur';

		return $this->getBdd()->recupererTous($requete);

	}

	private function getBdd() {

		if (!isset($this->bdd)) {

			$this->bdd = new Bdd();

		}

		$this->bdd->requeter("USE tb_cel");

		return $this->bdd;

	}

	private function construireColonnesSelection() {

		$colonnes = array(

			'idObs' => 'id_observation',

			'nn' => 'nom_ret_nn',

			'nomSci' => 'nom_ret',

			'date' => 'Date(date_transmission)',

			'lieu' => 'milieu',

			'observateur' => "Concat(prenom_utilisateur, ' ', nom_utilisateur)",

			'observateurId' => 'ce_utilisateur',

			'urlEflore' => "If(nom_ret_nn IS NULL, NULL, Concat('http://www.tela-botanica.org/bdtfx-nn-', nom_ret_nn))"

		);

		$selectSql = '';

		foreach ($colonnes as $renvoi => $colonne) {

			$selectSql .= (strlen($selectSql) == 0 ? '' : ', ') . "{$colonne} AS {$renvoi}";

		}

		return $selectSql;

	}

	private function construireWhereTaxon() {

		$sql = '';

		if (!is_null($this->taxon)) {

			$criteres = "nom_ret LIKE '" . addslashes($this->taxon['nom']) . "%'";

			foreach ($this->sousTaxons as $sousTaxon) {

				$criteres .= " OR nom_ret LIKE '" . addslashes($sousTaxon['nom']) . "%'";

			}

			$sql = " AND ($criteres)";

		}

		return $sql;

	}

	private function construireWhereUtilisateur() {

		$sql = '';

		if ($this->utilisateur != '') {

			$utilisateur = $this->getBdd()->proteger($this->utilisateur);

			$sql = " AND courriel_utilisateur = $utilisateur ";

		}

		return $sql;

	}

	private function construireWhereCoordonnees() {

		// coordonnees du point qui correspondent a une commune ?

		$requete = "SELECT id_zone_geo FROM cel_zones_geo WHERE wgs84_longitude=" . $this->longitude

		. " AND wgs84_latitude=" . $this->latitude;

		$commune = $this->getBdd()->recuperer($requete);

		$sql = ' AND ((longitude=' .  $this->longitude . ' AND latitude=' . $this->latitude . ')';

		if ($commune != false) {

			$sql .= " OR (longitude IS NULL AND latitude IS NULL AND ce_zone_geo='"

				. $commune['id_zone_geo'] . "')";

		}

		$sql .= ')';

		return $sql;

	}

	private function obtenirNomSite() {

		// coordonnees du point qui correspondent a une commune ?

		$requete = 'SELECT code, nom FROM cel_zones_geo WHERE wgs84_longitude=' . $this->longitude

			. ' AND wgs84_latitude=' . $this->latitude;

		$site = $this->getBdd()->recuperer($requete);

		if (!$site) {

			// recuperer les informations de la station

			$requete = 'SELECT DISTINCT lieudit AS "nom" FROM cel_obs WHERE longitude='

				. $this->longitude . ' AND latitude = ' . $this->latitude;

			$site = $this->getBdd()->recuperer($requete);

		}

		if (!$site)

			return null;

		return is_null($site['nom']) ? '' : $site['nom'];

	}

}

?>