Subversion Repositories Sites.obs-saisons.fr

<?php

class OdsStation extends OdsTriple {

	/**

     * Méthode appelée avec une requête de type GET.

     *

     */

    function getElement($param = array()) {

    	if(isset($param[0])) {

    		$id_participant = $param[0];

    	} else {

    		return;

    	}

		if($param[1] == "*") {

			$info = $this->obtenirListeStationPourParticipant($id_participant);

		} else if(is_numeric($param[1])) {

			$id_station = $param[1];

			$info = $this->obtenirInformationsStation($id_station);

		}

        // Envoi sur la sortie standard

        $this->envoyer($info);

    }

    /**

     * Méthode appelée pour ajouter un élément.

     */

    public function createElement($params) {

    	$elements_requis = array('id_participant','station_nom', 'station_commune', 'station_lat', 'station_lon','station_milieu','station_alt');

    	$erreurs = array();

    	foreach($elements_requis as $requis) {

    		if(!isset($params[$requis])) {

    			//$erreurs[$requis] = 'erreur ';

    		}

    	}

    	if(!empty($erreurs)) {

    		$this->envoyer($erreurs);

    	}

    	$id_participant = $params['id_participant'];

    	if(isset($params['station_code_insee'])) {

    		$commune = $params['station_code_insee'];

    	} else {

    		$commune = $params['station_commune'];

    	}

    	$requete_creation_station = 'INSERT INTO ods_stations '.

					'(os_ce_participant, os_nom, os_ce_commune, os_latitude, os_longitude, os_altitude, os_ce_environnement, os_commentaire) '.

					'VALUES ('.

							$this->proteger($id_participant).','.

							$this->proteger($params['station_nom']).','.

							$commune.','.

							$this->proteger($params['station_lat']).','.

							$this->proteger($params['station_lon']).','.

							$this->proteger($params['station_alt']).','.

							$this->proteger($params['station_milieu']).','.

							$this->proteger($params['station_description']).')';

		$creation_station = $this->executerRequeteSimple($requete_creation_station);

		if(!$creation_station) {

    		$retour['erreurs'] = 'erreur d\'insertion';

    	} else {

    		$retour['id_nouvelle_station'] = $this->renvoyerDernierIdInsere();

    	}

    	$this->envoyer($retour);

    }

    /**

     * Méthode appelée pour mettre à jour un élément

     */

    public function updateElement($uid, $params)    {

	    $elements_requis = array('id_participant','station_nom', 'station_commune', 'station_lat', 'station_lon','station_milieu','station_alt');

    	$erreurs = array();

    	foreach($elements_requis as $requis) {

    		if(!isset($params[$requis])) {

    			$erreurs[$requis] = 'erreur ';

    		}

    	}

    	if(!empty($erreurs)) {

    		$this->envoyer($erreurs);

    	}

    	$id_participant = $params['id_participant'];

    	if(!isset($uid[0])) {

    		return;

    	} else {

    		$id_station = $uid[0];;

    	}

        if(isset($params['station_code_insee'])) {

    		$commune = $params['station_code_insee'];

    	} else {

    		$commune = $params['station_commune'];

    	}

        $requete_modification_station = 'UPDATE ods_stations '.

			'SET '.

			'os_nom ='.$this->proteger($params['station_nom']).','.

        	'os_ce_commune ='.$commune.','.

			'os_latitude ='.$this->proteger($params['station_lat']).','.

			'os_longitude ='.$this->proteger($params['station_lon']).','.

			'os_altitude ='.$this->proteger($params['station_alt']).','.

			'os_ce_environnement ='.$this->proteger($params['station_milieu']).','.

			'os_commentaire ='.$this->proteger($params['station_description']).' '.

			'WHERE os_ce_participant = '.$this->proteger($id_participant).' '.

        	'AND os_id_station = '.$this->proteger($id_station);

		$modification_station = $this->executerRequeteSimple($requete_modification_station);

		$retour = array();

		if(!$modification_station) {

    		$retour['erreurs'] = 'Erreur lors de la modification de la station';

    	} else {

    		$retour['reponse'] = 'OK';

    	}

    	$this->envoyer($retour);

    }

    /**

     * Méthode appelée pour supprimer un élément

     */

    public function deleteElement($uid) {

    	// Pour le moment, pas de suppression des stations

    	return ;

    	if(!isset($uid[0])) {

    		$id_participant = $uid[0];

    	} else {

    		return;

    	}

    	if(!isset($uid[1])) {

    		$id_station = $uid[1];

    	} else {

    		return;

    	}

    	$requete_suppression_station = 'DELETE FROM ods_stations '.

    	'WHERE os_ce_particant = '.$this->proteger($id_participant).' '.

        	'AND os_id_station = '.$this->proteger($id_station);

    	// TODO : supprimer également tout ce qui est associé à la station (observations, etc...)

    	$suppression_station = $this->executerRequeteSimple($requete_suppression_station);

    	if(!$suppression_station) {

    		// TODO: comment gère t'on les erreurs ?

    	}

    	$this->envoyer();

    }

    // +---------------------------------------------------------------------------------------------------------------+

    // METHODES D'ACCES A LA BASE DE DONNEES

	private function obtenirListeStationPourParticipant($id_participant) {

    	$requete_liste_station = 'SELECT * FROM ods_stations WHERE os_ce_participant = '.$this->proteger($id_participant);

    	$liste_station = $this->executerRequete($requete_liste_station);

    	$liste_station_formatees = array();

    	foreach($liste_station as $indice => $station) {

    		$station_champs_formates = $this->formaterChampsStationPourEnvoi($station);

		    $liste_station_formatees[$station['os_id_station']] = $station_champs_formates;

    	}

    	return $liste_station_formatees;

	}

    private function obtenirInformationsStation($id_station) {

    	$requete_infos_station = 'SELECT * FROM ods_stations WHERE os_id_station = '.$this->proteger($id_station);

    	$infos_station = $this->executerRequete($requete_infos_station);

    	$infos_station_formatees = array();

    	if(!empty($infos_station)) {

    		$infos_station = $infos_station[0];

    		$infos_station_formatees = $this->formaterChampsStationPourEnvoi($infos_station);

    	}

    	return $infos_station_formatees;

    }

    private function formaterChampsStationPourEnvoi($station) {

    	if(is_numeric($station['os_ce_commune'])) {

    		$commune = $this->obtenirInformationsCommuneParCodeInsee($station['os_ce_commune']);

    	} else {

    		$commune = $station['os_ce_commune'];

    	}

    	$station_champs_formates = array(

		    	'id' => $station['os_id_station'],

		    	'nom' => $station['os_nom'],

				'code_insee' => $station['os_ce_commune'],

    			'commune' => $commune,

				'id_milieu' => $station['os_ce_environnement'],

    			'milieu' => $this->obtenirInformationsMilieuParId($station['os_ce_environnement']),

				'latitude' => $station['os_latitude'],

				'longitude' => $station['os_longitude'],

    			'altitude' => $station['os_altitude'],

				'description' => $station['os_commentaire']

		    );

		return $station_champs_formates;

    }

	private function obtenirInformationsCommuneParCodeInsee($code_insee_commune) {

    	$requete_infos_commune = 'SELECT * FROM ods_communes WHERE oc_code_insee = '.$this->proteger($code_insee_commune);

    	$infos_commune = $this->executerRequete($requete_infos_commune);

		//TODO: en attendant de stocker les ids

		return $infos_commune[0]['oc_nom'];

    	//return $infos_commune;

    }

    private function obtenirInformationsMilieuParId($id_milieu) {

    	$informations_milieu = $this->obtenirValeurTripleParId($id_milieu);

    	return $informations_milieu;

    }

}

?>