Subversion Repositories eFlore/Applications.del

<?php
// declare(encoding='UTF-8');
/**
 * Web service récupèrant toutes les observations et, pour chacune d'elle, les images qui lui sont associées.
 *
 * ATTENTION : le web service commence par récupérer seulement les id des obs (1er requete SQL), puis dans une
 * deuxième requête SQL récupère les informations complémentaires. Il s'avère qu'en procédant ainsi le web service
 * est 3 fois plus rapide !
 *
 * @category   DEL
 * @package    Services
 * @subpackage Observations
 * @version    0.1
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
 * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @author     Aurelien PERONNET <aurelien@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>
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
 */
class ListeObservations {

        private $conteneur;
        private $bdd;
        private $navigation;
        private $filtrage;
        private $sql;
        private $mappings = array();
        private $paramsFiltres = array();


        public function __construct(Conteneur $conteneur) {
                $this->conteneur = $conteneur;
                $this->conteneur->chargerConfiguration('config_departements_bruts.ini');

                $this->bdd = $this->conteneur->getBdd();
                $this->filtrage = $this->conteneur->getParametresFiltrage();
                $this->sql = $this->conteneur->getSql();
                $this->navigation = $this->conteneur->getNavigation();

                $this->mappings['votes'] = $this->conteneur->getParametreTableau('votes.mapping');
                $this->mappings['commentaires'] = $this->conteneur->getParametreTableau('commentaires.mapping');
        }

        public function consulter($ressources, $parametres) {
                $this->paramsFiltres = $this->filtrage->filtrerUrlParamsAppliObs();
                $this->sql->setParametres($this->paramsFiltres);
                $this->sql->ajouterContraintes();
                $this->sql->ajouterConstrainteAppliObs();
                $this->sql->definirOrdreSqlAppliObs();

                $idObs = $this->getIdObs();
                $this->navigation->setTotal($this->sql->getTotalLignesTrouvees());

                // Ce n'est pas la peine de continuer s'il n'y a pas eu de résultats
                $resultat = new ResultatService();
                $resultat->corps = array('entete' => $this->navigation->getEntete(), 'resultats' => array());
                if (count($idObs) > 0) {

                        // 2) récupération des données nécessaires pour ces observations (obs + images)
                        // ici les champs récupérés sont issus de self::$sql_fields_liaisons mais sans préfixes
                        // car tout provient de v_del_image
                        $obs_unfmt = $this->getInfos($idObs);

                        // 3) suppression, merge des données en tableau assez représentatif du futur JSON en output
                        $observations = $this->formaterObservations($obs_unfmt);

                        // 4) récupération des données nécessaires pour ces observations (commentaires + votes)
                        // modifie $observations
                        $this->chargerDeterminations($observations, $idObs);

                        // 5) restauration de l'ordre souhaité initialement
                        $observations = $this->ordonnerObservations($observations, $idObs);

                        $resultat->corps = array(
                                'entete' => $this->navigation->getEntete(),
                                'resultats' => $observations);
                }
                return $resultat;
        }

        // SQL helpers
        /*
         * Retourne une liste ordonnée d'id d'observation correspondant aux critères
         * passés dans p et aux clauses where/join présentes dans le tableau $req
         *
         * @param p: $params (filtrés sauf escape-string)
         * @param req: le tableau représentant les composants de la requete SQL
         * @param db: l'instance de db
         */
        private function getIdObs() {
                $requete = 'SELECT SQL_CALC_FOUND_ROWS id_observation '.
                        'FROM v_del_image AS vdi '.
                        $this->sql->getJoin().
                        'WHERE '.$this->sql->getWhere().
                        $this->sql->getGroupBy().
                        $this->sql->getOrderBy().
                        $this->sql->getLimit().
                        ' -- '.__FILE__.':'.__LINE__;

                $resultats = $this->bdd->recupererTous($requete);

                $idObs = array();
                if ($resultats !== false ) {
                        foreach ($resultats as $resultat) {
                                $idObs[] = $resultat['id_observation'];
                        }
                }
                return $idObs;
        }

        /**
         * Après avoir récupérer seulement les ids dans une première requête, nous récupérons maintenant les infos.
         * Le web service est ainsi 3 fois plus rapide.
         */
        private function getInfos($idObs) {
                $idsObsConcat = implode(',', $idObs);
                $requete = "SELECT id_observation, nom_sel AS `determination.ns`, nt AS `determination.nt`, ".
                        'nom_sel_nn AS `determination.nn`, famille AS `determination.famille`, '.
                        'nom_referentiel AS `determination.referentiel`, ce_zone_geo AS id_zone_geo, '.
                        'zone_geo, lieudit, station, milieu, date_observation, mots_cles_texte, '.
                        'date_transmission, commentaire, '.
                        'ce_utilisateur AS `auteur.id`, prenom_utilisateur AS `auteur.prenom`, '.
                        'nom_utilisateur AS `auteur.nom`, courriel_utilisateur AS `auteur.courriel`, '.
                        'id_image, date_prise_de_vue AS `date`, hauteur, largeur, nom_original '.
                        'FROM v_del_image AS vdi '.
                        "WHERE id_observation IN ($idsObsConcat) ".
                        ' -- '.__FILE__.':'.__LINE__;
                return $this->bdd->recupererTous($requete);
        }

        /**
         * Les informations étant extraites d'une vue dont les infos des obs sont dupliquées pour chaque image,
         * il nous faut maintenant récupérer qu'une seule fois les données d'observations et y intégrer les données
         * des images.
         */
        private function formaterObservations($observations) {
                $observations = array_map('array_filter', $observations);
                $obsFormatees = array();
                foreach ($observations as $obs) {
                        $this->nettoyerAuteur($obs);
                        $image = $this->extraireInfosImage($obs);

                        $id = 'idx-'.$obs['id_observation'];
                        if (!isset($obsFormatees[$id])) {
                                $obsFormatees[$id] = $obs;
                        }
                        $obsFormatees[$id]['images'][] = $image;
                }
                return $obsFormatees;
        }

        private function nettoyerAuteur(&$obs) {
                // car auteur.id peut être un email, un hash, ou un annuaire_tela.U_ID
                // mais dans les deux premiers cas SELECT courriel AS observateur fait déjà l'affaire
                if (!isset($obs['auteur.id']) || !is_numeric($obs['auteur.id'])) {
                        $obs['auteur.id'] = "0";
                }
                if (!isset($obs['auteur.nom'])) {
                        $obs['auteur.nom'] = '[inconnu]';
                }
        }

        private function extraireInfosImage(&$obs) {
                $champsImageAffichables = array('id_image', 'date', 'hauteur' , 'largeur', 'nom_original');
                $image = array_intersect_key($obs, array_flip($champsImageAffichables));

                $urlImgTpl = $this->conteneur->getParametre('cel_img_url_tpl');
                $image['binaire.href'] = sprintf($urlImgTpl, $image['id_image'], 'XL');

                unset($obs['id_image'], $obs['date'], $obs['hauteur'], $obs['largeur'], $obs['nom_original']);
                return $image;
        }

        private function ordonnerObservations($observations, $ordreDesObs) {
                $obsOrdonnees = array();
                foreach ($ordreDesObs as $id) {
                        if (array_key_exists("idx-$id", $observations)) {
                                $obsOrdonnees["idx-$id"] = $observations["idx-$id"];
                                unset($observations["idx-$id"]);
                        }
                }
                return $obsOrdonnees + $observations;
        }

        /**
         * Récupérer toutes les déterminations et le nombre de commentaire au total
         * @param array $observations la liste des observations à mettre à jour
         */
        private function chargerDeterminations(&$observations, $idObs) {
                $idObsConcat = implode(',', $idObs);
                $requete = 'SELECT * '.
                        'FROM del_commentaire AS dc '.
                        'WHERE dc.nom_sel IS NOT NULL '.
                        "AND ce_observation IN ($idObsConcat) ".
                        '-- '.__FILE__.':'.__LINE__;

                $propositions = $this->bdd->recupererTous($requete);
                if ($propositions) {
                        foreach ($propositions as $proposition) {
                                $idObs = $proposition['ce_observation'];
                                $idComment = $proposition['id_commentaire'];
                                $comment = $this->formaterDetermination($idComment, $proposition);
                                if ($comment) {
                                        $observations["idx-$idObs"]['commentaires'][$idComment] = $comment;
                                }
                        }
                }
        }

        private function formaterDetermination($propositionId, $propositionInfos) {
                if (!$propositionInfos) return NULL;

                $propositionFormatee = array();
                foreach ($this->mappings['commentaires'] as $nomChamp => $nomAttributJson) {
                        if (isset($propositionInfos[$nomChamp])) {
                                $propositionFormatee[$nomAttributJson] = $propositionInfos[$nomChamp];
                        }
                }

                // Charger les votes sur les déterminations
                $requete = "SELECT * FROM del_commentaire_vote WHERE ce_proposition = $propositionId".
                        '-- '.__FILE__.':'.__LINE__;
                $resultatsVotes = $this->bdd->recupererTous($requete);
                foreach ($resultatsVotes as $vote) {
                        $propositionFormatee['votes'][$vote['id_vote']] = $this->formaterVote($vote);
                }

                $propositionFormatee['nb_commentaires'] = $this->chargerNombreCommentaire($propositionId);

                return $propositionFormatee;
        }

        /**
         * Formater un vote en fonction du fichier de configuration config_votes.ini
         * @param $votes array()
         */
        private function formaterVote($vote) {
                $voteFormate = array();
                foreach ($vote as $nomChamp => $valeur) {
                        $voteFormate[$this->mappings['votes'][$nomChamp]] = $valeur;
                }
                return $voteFormate;
        }

        private function chargerNombreCommentaire($propositionId) {
                $requete = 'SELECT COUNT( id_commentaire ) AS nb '.
                        'FROM del_commentaire '.
                        "WHERE ce_proposition = $propositionId ".
                        'GROUP BY ce_proposition '.
                        '-- '.__FILE__.':'.__LINE__;
                $commentaires = $this->bdd->recuperer($requete);
                return $commentaires ? $commentaires['nb'] : 0;
        }
}