Subversion Repositories eFlore/Applications.cel

<?php
// declare(encoding='UTF-8');
/**
 * Service de liaisons d'images à des observations
 * Cas d'utilisation :
 * 2: Le service lie une ou plusieurs images à une observation
 * 3: Le service renvoie l'observation liée à une image
 *
 * @internal   Mininum PHP version : 5.2
 * @category   CEL
 * @package    Services
 * @subpackage Images
 * @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 InventoryImageLink extends Cel {

        public function createElement($pairs) {
                // Controle detournement utilisateur
                $this->controleUtilisateur($pairs['ce_utilisateur']);
                $id_utilisateur = $pairs['ce_utilisateur'];

                if (!isset($pairs['id_image'])) {
                        die('err');
                }

                // filtrage des entiers
                $ids_observations = self::filterInt($pairs['id_observation']);
                $ids_images = self::filterInt($pairs['id_image']);
                if (empty($ids_images) || empty($ids_observations)) {
                        die('err');
                }
                // filtrage des entiers à partir des ids existant réellement en DB
                $ids_images_filtrees = $this->filtrerImgUtilisateur($ids_images, $id_utilisateur);
                $ids_observations_filtrees = $this->filtrerObsUtilisateur($ids_observations, $id_utilisateur);
                if (empty($ids_images_filtrees) || empty($ids_observations_filtrees)) {
                        die('err');
                }

                $values = array();
                foreach ($ids_images_filtrees as $id_img) {
                        foreach ($ids_observations_filtrees as $id_obs) {
                                $values[] = "($id_img, $id_obs, NOW())";
                        }
                }
                $clauseValues = implode(',', $values);
                $requete = 'INSERT INTO cel_images (id_image, ce_observation, date_liaison) '.
                        "VALUES $clauseValues ".
                        'ON DUPLICATE KEY UPDATE ce_observation = VALUES(ce_observation), date_liaison = NOW() '.
                        ' -- ' . __FILE__ . ':' . __LINE__;
                $resultat = Cel::db()->executer($requete);
                if ($resultat) {
                        exit('OK');
                }
                exit(); // peut-être qu'aucune mise à jour n'a eu lieu (ON DUPLICATE KEY)
        }

        /**
         * Retourne les identifiants des images liées à une observation ou l'identifiant de l'obs liée à une image, suivant le paramètre :
         * uid[0] : utilisateur obligatoire
         * uid[1] : id_observation=valeur ou bien id_image=valeur
         */
        public function getElement($uid) {
                // Controle detournement utilisateur
                $this->controleUtilisateur($uid[0]);

                if ($uid) {
                        $param = $uid[1] ;
                        //TODO utiliser le GET plutôt pour récuperer id image ou observation
                        list($field, $value) = explode('=', $param);
                        $valueP = Cel::db()->proteger($value);

                        if ($field == 'id_observation') {
                                $requete = 'SELECT id_image, hauteur , largeur '.
                                        'FROM cel_images '.
                                        "WHERE ce_observation = $valueP ".
                                        ' -- '.__FILE__.':'.__LINE__;
                        } else if ($field == 'id_image') {
                                $requete = 'SELECT co.* '.
                                        'FROM cel_obs AS co INNER JOIN cel_images AS ci ON (co.id_observation = ci.ce_observation) '.
                                        "WHERE id_image = $valueP ".
                                        ' -- '.__FILE__.':'.__LINE__;
                        }
                }
                $resultats = Cel::db()->requeter($requete);

                $liaisons = array();
                if (is_array($resultats) && count($resultats) > 0) {
                        $liaisons = $resultats;
                        if ($field == 'id_image') {
                                foreach ($liaisons as &$liaison) {
                                        $liaison['ce_zone_geo'] = $this->convertirCodeZoneGeoVersCodeInsee($liaison['ce_zone_geo']);
                                }
                        }
                }
                $this->envoyerJson($liaisons);
                return true;
        }

        public function updateElement($uid, $pairs) {

        }

        /**
         * Supprimme une ou plusieurs liaisons entre images et observations
         * uid[0] : utilisateur obligatoire
         * uid[1] : identifiant(s) image(s) obligatoire(s)
         * uid[2] : identifiant(s) observations
         */
        public function deleteElement($uid) {
                // Controle detournement utilisateur
                $this->controleUtilisateur($uid[0]);
                $id_utilisateur = $uid[0];
                $ids_images = self::filterInt($uid[1]);
                $ids_observations = self::filterInt($uid[2]);
                if (empty($ids_images) || empty($ids_observations) || ! $id_utilisateur) {
                        die('err');
                }
                $ids_images_filtrees = $this->filtrerImgUtilisateur($ids_images, $id_utilisateur);
                $ids_observations_filtrees = $this->filtrerObsUtilisateur($ids_observations, $id_utilisateur);

                if (empty($ids_images_filtrees) || empty($ids_observations_filtrees)) {
                        die('err');
                }

                $idsImgConcat = implode(',', $ids_images_filtrees);
                $idsObsConcat = implode(',', $ids_observations_filtrees);
                $requete = 'UPDATE cel_images '.
                        'SET ce_observation = NULL '.
                        "WHERE id_image IN ($idsImgConcat) AND ce_observation IN ($idsObsConcat)".
                        ' -- '.__FILE__.':'.__LINE__;
                $resultats = Cel::db()->executer($requete);
                if ($resultats) {
                        exit('OK');
                }
                die('err');
        }

        private function filtrerImgUtilisateur($ids_images, $id_utilisateur) {
                $idsImgConcat = implode(',', $ids_images);
                $requete = 'SELECT id_image '.
                        'FROM cel_images '.
                        "WHERE id_image IN ($idsImgConcat) ".
                        "AND ce_utilisateur = $id_utilisateur ".
                        ' -- '.__FILE__.':'.__LINE__;
                $resultats = Cel::db()->requeter($requete);
                return array_map(array(__CLASS__, 'getRequeteVal'), $resultats);
        }

        private function filtrerObsUtilisateur($ids_observations, $id_utilisateur) {
                $idsObsConcat = implode(',', $ids_observations);
                $requete = 'SELECT id_observation '.
                        'FROM cel_obs '.
                        "WHERE id_observation IN ($idsObsConcat) ".
                        "AND ce_utilisateur = $id_utilisateur ".
                        ' -- '.__FILE__.':'.__LINE__;
                $resultats = Cel::db()->requeter($requete);
                return array_map(array(__CLASS__, 'getRequeteVal'), $resultats);
        }

        static function filterInt($str_liste) {
                return array_filter(array_map('intval', explode(',', $str_liste)));
        }

        // extrait la première valeur d'un tableau, utile pour renvoyer un tableau de simple valeur
        // à partir d'une requête effectuée sur un seul champ.
        static function getRequeteVal($arr) {
                return array_shift($arr);
        }
}