Subversion Repositories Sites.obs-saisons.fr

<?php

class OdsIndividu extends JRestService {

	const PREFIXE = 'get';

	/**

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

     *

     */

    function getElement($param = array()) {

    	$type = $param[0];

    	if ($type == '*' || is_numeric($type)) {

            $info = $this->getElementParDefaut($param);

        } else {

            $methode = self::PREFIXE.$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.";

            }

        }

        // 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','id_espece','id_station','individu_nom');

    	foreach($elements_requis as $requis) {

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

					//TODO: pourquoi est-ce que c'est commenté ça ?

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

    		}

    	}

    	if(!empty($erreurs)) {

    		$this->envoyer($erreurs);

    	}

			// commentaire optionnel

			$commentaire = !empty($params['individu_commentaire']) ? $params['individu_commentaire'] : '';

			// limité à 1000 caractères (pas besoin de renvoyer une erreur ici car c'est un cas très peu fréquent)

			$commentaire = substr($commentaire, 0, 1000);

    	$requete_creation_individu = 'INSERT INTO ods_individus '.

					'(oi_ce_espece, oi_ce_station, oi_nom, oi_commentaire) '.

					'VALUES ('.

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

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

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

							$this->proteger($commentaire).')';

			$creation_individu = $this->executerRequeteSimple($requete_creation_individu);

    	if(!$creation_individu) {

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

    	} else {

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

    	}

    	$this->envoyer($retour);

    }

    /**

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

     */

    public function updateElement($uid, $params)    {

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

    		$id_individu = $uid[0];

    	} else {

    		return;

    	}

			// commentaire optionnel

			$commentaire = !empty($params['individu_commentaire']) ? $params['individu_commentaire'] : '';

			// limité à 1000 caractères (pas besoin de renvoyer une erreur ici car c'est un cas très peu fréquent)

			$commentaire = substr($commentaire, 0, 1000);

      $requete_modification_individu = 'UPDATE ods_individus '.

			'SET oi_nom = '.$this->proteger($params['individu_nom']).' ';

			// mise à jour éventuelle du commentaire optionnel

			if(!empty($params['individu_commentaire'])) {

				$requete_modification_individu .= ', oi_commentaire = '.$this->proteger($params['individu_commentaire']).' ';

			}

      $requete_modification_individu .= 'WHERE oi_id_individu = '.$this->proteger($id_individu);

			$modification_individu = $this->executerRequeteSimple($requete_modification_individu);

      $this->envoyer();

    }

    /**

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

     */

    public function deleteElement($uid) {

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

    		$id_participant = $uid[0];

    	} else {

    		return;

    	}

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

    		$id_individu = $uid[1];

    	} else {

    		return;

    	}

    	$requete_suppression_individu = 'DELETE FROM ods_individus '.

    		'WHERE oi_id_individu = '.$this->proteger($id_individu).' '.

        	'AND oi_ce_station IN '.

        		'(SELECT os_id_station FROM ods_stations '.

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

    			')';

    	$suppression_individu = $this->executerRequeteSimple($requete_suppression_individu);

    	if(!$suppression_individu) {

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

    	}

        // Envoie sur la sortie standard

        $this->envoyer();

    }

    private function getElementParDefaut($params) {

    	return $this->getInformationsIndividu($params);

    }

    private function getInformationsIndividu($params) {

    	$id_individu = $params[0];

    	$requete_informations_individu = 'SELECT * FROM ods_individus '.

								'WHERE oi_id_individu = '.$this->proteger($id_individu);

    	$informations_individu = $this->executerRequete($requete_informations_individu);

    	if(!empty($informations_individu)) {

    		$informations_individu_formatees = $this->formaterTableauIndividuPourEnvoi($informations_individu[0]);

    	}

    	return $informations_individu_formatees;

    }

    private function getIndividusPourStation($params) {

    	$id_station = $params[0];

		$requete_individus_station = 'SELECT oi.* FROM ods_individus oi '.

		                             'INNER JOIN ods_especes oe '.

		                             'ON oi.oi_ce_espece = oe.oe_id_espece '.

		                             'AND oe.oe_espece_active = 1 '.

									 'WHERE oi_ce_station = '.$this->proteger($id_station);

    	$liste_individus_pour_station = $this->executerRequete($requete_individus_station);

    	foreach($liste_individus_pour_station as &$individu_pour_station) {

    		$individu_pour_station = $this->formaterTableauIndividuPourEnvoi($individu_pour_station);

    	}

    	return $liste_individus_pour_station;

    }

	private function getIndividusPourStationPourEspece($params) {

    	$id_station = $params[0];

    	$id_espece = $params[1];

		$requete_individus_station_espece = 'SELECT * FROM ods_individus '.

									 'WHERE oi_ce_station = '.$this->proteger($id_station).' '.

									 'AND oi_ce_espece ='.$this->proteger($id_espece);

    	$liste_individus_pour_station_pour_espece = $this->executerRequete($requete_individus_station_espece);

		foreach($liste_individus_pour_station_pour_espece as &$individu_pour_station_pour_espece) {

    		$individu_pour_station_pour_espece = $this->formaterTableauIndividuPourEnvoi($individu_pour_station_pour_espece);

    	}

    	return $liste_individus_pour_station_pour_espece;

    }

	private function formaterTableauIndividuPourEnvoi($individu) {

    	return array(

    	    'id_individu' => $individu['oi_id_individu'],

          'id_espece' => $individu['oi_ce_espece'],

          'id_station' => $individu['oi_ce_station'],

    	  	'nom' => $individu['oi_nom'],

					'commentaire' => $individu['oi_commentaire'],

      );

    }

}

?>