Subversion Repositories eFlore/Applications.del

<?php
// declare(encoding='UTF-8');
/**
 * Le web service récupére un identifiant de proposition et appelle un service web externe 
 * (du cel) afin de modifier le nom de l'observation associée par celui de la proposition
 *
 * @category    php 5.2
 * @package     del
 * @subpackage images
 * @author              Aurélien Peronnet <aurelien@tela-botanica.org>
 * @copyright   Copyright (c) 2013, Tela Botanica (accueil@tela-botanica.org)
 * @license     http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
 * @license     http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
 * @version     $Id$
 * @see http://www.tela-botanica.org/wikini/eflore/wakka.php?wiki=ApiIdentiplante01Images
 */

class ValiderDetermination {
        
        private $conteneur;
        private $navigation;
        private $masque;
        private $gestionBdd;
        private $bdd;
        private $parametres = array();
        private $ressources = array();
        
        public function __construct(Conteneur $conteneur = null) {
                $this->conteneur = $conteneur == null ? new Conteneur() : $conteneur;
                $this->conteneur->chargerConfiguration('config_determinations.ini');
                $this->gestionBdd = $conteneur->getGestionBdd();
                $this->bdd = $this->gestionBdd->getBdd();       
        }
        
        public function modifier($ressources, $parametres) {
                $this->verifierParametres($ressources, $parametres);
                $id_proposition = $ressources[1];
                
                if(!$this->modifierObservationParDetermination($id_proposition, $parametres))
                        throw new Exception($e, RestServeur::HTTP_CODE_ERREUR);

                RestServeur::envoyerEnteteStatutHttp(RestServeur::HTTP_CODE_OK);
        }
        
        public function verifierParametres($ressources, $parametres) {
                $erreurs = array();
                if (!is_numeric($ressources[1])) {
                        $erreurs[] = '- le paramètre indiquant l\'identifiant de la proposition doit être numérique ;';
                }

                //Le paramètre auteur.id (id de l'auteur de la détermination)
                // est là pour éviter que le $_POST ne soit vide
                if (!isset($parametres['auteur.id'])) {
                        $erreurs[] = '- paramètre "auteur.id" manquant ;';
                }
                
                if ($erreurs) {
                        throw new Exception("Erreur lors de la configuration :\n" . implode("\n", $erreurs),
                                                                RestServeur::HTTP_CODE_ERREUR);
                }
        }
        
        
        private function modifierObservationParDetermination($id_proposition, $parametres) {
                $informations_proposition = self::obtenirInformationDetermination($this->bdd, $id_proposition, $parametres['auteur.id']);
                if(! $informations_proposition) {
                        throw new Exception("Cette proposition est invalide.", RestServeur::HTTP_CODE_ERREUR);
                }

                $id_observation = $informations_proposition['ce_observation'];
                // obtenirInformationsObservation()
                $informations_observation = $this->bdd->recuperer(sprintf('SELECT * FROM del_observation WHERE id_observation = %d',
                                                                                                                                  intval($id_observation)));
                $est_autorise = $this->comparerAuteurObservationUtilisateurIdentifie($informations_observation['ce_utilisateur']);
                if(! $est_autorise) {
                        throw new Exception("Seul l'utilisateur ayant saisi l'observation peut la valider : veuillez vous identifier.\n",
                                                                RestServeur::HTTP_CODE_ERREUR);
                }

                $informations_proposition['ce_utilisateur'] = $informations_observation['ce_utilisateur'];

                $ret = $this->envoyerRequeteModificationObservation($id_observation, $informations_proposition);
                // cf cel/jrest/services/CelValidationObservation.php::updateElement()
                // TODO: check sur HTTP code == 200, plutôt que sur texte
                if($ret == 'ok' || $ret == 'OK') {
                        // remet à 0 le status "proposition_retenue" pour toutes les propositions faites sur cette
                        // observation à l'exception de celle désormais validée
                        $this->bdd->requeter(sprintf('UPDATE del_commentaire SET proposition_retenue = IF(id_commentaire = %d, 1, 0)' .
                                                                                 ' WHERE ce_observation = %d -- %s',
                                                                                 $informations_proposition['id_commentaire'], $id_observation, __FILE__ . ':' . __LINE__));
                }
                return $ret;
        }
        
        private function comparerAuteurObservationUtilisateurIdentifie($ce_utilisateur) {       
                $controle_utilisateur = new ControleAcces($this->conteneur);
                $utilisateur_connecte = $controle_utilisateur->getInfosUtilisateurConnecte();
                return $ce_utilisateur == $utilisateur_connecte['id_utilisateur'];
        }

        // pourrait servir de manière commune
        static function obtenirInformationDetermination($db, $id_proposition, $id_utilisateur) {
                $requete = "SELECT * FROM del_commentaire WHERE id_commentaire = ". intval($id_proposition)." ";
                if($id_utilisateur != 0 && $id_utilisateur != '') {
                    $requete .= "AND ce_utilisateur = ".$db->proteger($id_utilisateur);
                }
                // TODO: else { LIMIT 1 ? }
                return $db->recuperer($requete);
        }
        
        private function envoyerRequeteModificationObservation($id_observation, $parametres) {
                $url_requete = $this->conteneur->getParametre('url_service_validation_base') . $id_observation;
                $requeteur = $this->conteneur->getRestClient();
                $parametres_formates = array('id_observation' => $id_observation,
                                                                         'ce_utilisateur' => $parametres['ce_utilisateur'],
                                                                         'nom_sel' => $parametres['nom_sel'], 
                                                                         'nom_sel_nn' => $parametres['nom_sel_nn'],
                                                                         'nom_ret' => $parametres['nom_ret'], 
                                                                         'nom_ret_nn' => $parametres['nom_ret_nn'],
                                                                         'nom_referentiel' => $parametres['nom_referentiel']);
                return $requeteur->modifier($url_requete, $parametres_formates);
        }
}