Subversion Repositories eFlore/Applications.cel

<?php
// declare(encoding='UTF-8');
/**
 * Service de liaisons de mots clés à des observations.
 * Le service lie une ou plusieurs mots clés à une ou plusieurs observations
 * 
 * Encodage en entrée : utf8
 * Encodage en sortie : utf8
 *
 * Cas d'utilisation :
 *
 * @author Aurélien 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>
 * @version $Id$
 * @copyright © 2011, Tela-Botanica
 */
class InventoryKeyWordObsLink extends Cel {
        
        const SEPARATEUR_MOT_CLE_TEXTE = '##';
        const SEPARATEUR_MOT_CLE_ID = ';';
        
        public function getRessource() {
                //$this->migrerMotsClesDansTableLiaison();      
        }
        
        public function getElement($uid) {
        
        }
        
        public function createElement($pairs) {
                
                // Controle detournement utilisateur
                session_start();
                $this->controleUtilisateur($pairs['ce_utilisateur']);
        
                if (!isset($pairs['mots_cles']) || !isset($pairs['observations']) || !isset($pairs['ce_utilisateur'])) {
                        return;
                }
                
                $observations = explode(',',$pairs['observations']);
                $mots_cles = explode(',',$pairs['mots_cles']);
                
                $gestionnaire_observation = new RechercheObservation($this->config);
                $ids_obs = $gestionnaire_observation->obtenirIdObservationsPourOrdre($pairs['ce_utilisateur'],$observations);
                                
                $requete_liaison_mots_cles = 'INSERT INTO cel_obs_mots_cles '.
                                                                   '(id_observation, id_mot_cle_utilisateur)'.
                                                                   'VALUES (';
                                                                   
                foreach($ids_obs as $obs) {
                        foreach($mots_cles as $mot) {
                                $requete_liaison_mots_cles .= '('.$obs.','.$mot.')';
                        }
                        $this->regenererIndexTexteMotCleObservation($obs, $pairs['ce_utilisateur']);
                }

                $resultat_liaison_mots_cles = $this->executer($requete_liaison_mots_cles);
                
                if(!$resultat_liaison_mots_cles) {
                        $this->logger('CEL_bugs', "Erreur d'ajout de mots clés à des obs : ".$requete_liaison_mots_cles);     
                }
                
                return $resultat_liaison_mots_cles;             
        }

        public function deleteElement($uid){
                $retour = false;
                
                // Controle detournement utilisateur
                session_start();
                $this->controleUtilisateur($uid[0]);
        
                if (!isset($uid[0]) || !isset($uid[1]) || !isset($uid[2])) {
                        return;
                }
                
                $mots_cle = $this->nettoyerMotsCles($uid[2]);
                $mots_cle = $this->proteger($mots_cle);
                
                $ordre_observations = $uid[1];
                $id_utilisateur = $uid[0];
                
                $gestionnaire_observation = new RechercheObservation($this->config);
                $ids_obs = $gestionnaire_observation->obtenirIdObservationsPourOrdre($id_utilisateur,$ordre_observations);
                
                $requete_suppression_liaison_mot_cle = 'DELETE FROM cel_obs_mots_cles WHERE ';
                                                                                           'id_observation IN ('.implode(',',$ids_obs).') '.
                                                                                           'AND id_mot_cle_utilisateur IN ('.$mots_cle.')';
                
                $resultat_suppression_mot_cle = $this->executer($requete_suppression_liaison_mot_cle);
                
                if ($resultat_suppression_mot_cle) {
                        $retour = true;
                } else {
                        $message = "Erreur de suppression des mots clés de plusieurs observations : $requete";
                        $this->logger($message);
                }
                
                foreach($ids_obs as $obs) {
                        $this->regenererIndexTexteMotCleObservation($obs, $id_utilisateur);     
                }

                return $retour;
        }
        
        private function regenererIndexTexteMotCleObservation($id_observation, $identifiant_utilisateur) {
                $mots_cles_obs = $this->obtenirMotsClesObs($id_observation, $identifiant_utilisateur);
                
                if (count($mots_cles_obs) > 0) {
                        $tableau_texte_mots_cles = $this->obtenirMotClesTexte($mots_cles_obs[0]['mots_cles'], $identifiant_utilisateur);
                        $mots_cles_texte_chaine = $this->formaterTableauMotCleTextePourInsertion($tableau_texte_mots_cles);
                        $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $id_observation, $identifiant_utilisateur);
                }
        }
        
        //TODO : a refaire 
        
        private function executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $id_observation, $identifiant_utilisateur) {
                $requete =      'UPDATE cel_obs '.
                                        'SET mots_cles_texte = '.$this->proteger($mots_cles_texte_chaine).' '.
                                        'WHERE id_observation = '.$this->proteger($id_observation).
                                        '       AND identifiant = '.$this->proteger($identifiant_utilisateur);
                
                $this->executerRequeteSimple($requete);
        }
        
        private function obtenirMotsClesTexte($id_observation, $identifiant_utilisateur) {
                $requete =      'SELECT mots_cles_texte '.
                                        'FROM cel_obs '.
                                        'WHERE id_observation = '.$this->proteger($id_observation).
                                        '       AND identifiant = '.$this->proteger($identifiant_utilisateur);
                
                $resultats = $this->executerRequete($requete);
                                
                return $resultats;
        }
        
        private function formaterChaineMotClePourConditionSql($chaine_mot_cle_obs) {
                $chaine_mot_cle_obs = $this->nettoyerMotsCles($chaine_mot_cle_obs);
                $chaine_mot_cle_obs = str_replace(self::SEPARATEUR_MOT_CLE_ID, ',', $chaine_mot_cle_obs);
                $chaine_mot_cle_obs = trim($chaine_mot_cle_obs, ',');
                
                return $chaine_mot_cle_obs;
        }
        
        private function formaterTableauMotCleTextePourInsertion($tableau_mots_cles_texte) {
                $mot_cles_texte_chaine = '';
                
                if (is_array($tableau_mots_cles_texte)) { 
                        foreach ($tableau_mots_cles_texte as $mot_cle) {
                                $mot_cles_texte_chaine .= $mot_cle['cmc_mot_cle'].self::SEPARATEUR_MOT_CLE_TEXTE;
                        }
                }
                
                $mot_cles_texte_chaine = rtrim($mot_cles_texte_chaine, self::SEPARATEUR_MOT_CLE_TEXTE);
                
                return $mot_cles_texte_chaine;
        }
        
        private function nettoyerMotsCles($chaine) {
                $valeur = str_replace('null', '', $chaine);
                $valeur = trim($valeur, ';;');
                
                return $valeur;
        }
        
        private function migrerMotsClesDansTableLiaison() {
                $requete =      'SELECT id, ordre, identifiant, mots_cles '.
                                        'FROM cel_inventory '.
                                        'WHERE TRIM(mots_cles) != "" ';
                $obs_mots_cles = $this->executerRequete($requete);
                
                echo '<pre>'.print_r($obs_mots_cles, true).'</pre>';
                
                $max = 20000;
                $i = 0;
                foreach ($obs_mots_cles as $obs_mc) {
                        $mots_cles_nettoyes = $this->nettoyerMotsCles($obs_mc['mots_cles']);
                        $tableau_mots_cles_codes = split(self::SEPARATEUR_MOT_CLE_ID, $mots_cles_nettoyes);
                        
                        $requete_values = '';
                        
                        if (count($tableau_mots_cles_codes) > 0) {
                                foreach($tableau_mots_cles_codes as $mots_cles_codes) {
                                        $mots_cles_codes = trim($mots_cles_codes, self::SEPARATEUR_MOT_CLE_ID);
                                        if ($this->estUnIdentifiantMotCle($mots_cles_codes)) {                                                  
                                                $requete_values .= '('.$mots_cles_codes.','.$obs_mc['id'].'),';
                                        }
                                }
                                
                                $requete_values = rtrim($requete_values, ',');
                                if (trim($requete_values) != '') { 
                                        $requete =      'INSERT IGNORE INTO cel_obs_mots_cles (id_observation, id_mot_cle_utilisateur) '.
                                                                'VALUES '.$requete_values.' ';
                                        echo $requete.'<br />';
                                        $i++;
                                }
                        }
                }
        }
        
        private function estUnIdentifiantMotCle($chaine) {
                return trim($chaine) != '' && preg_match('/[0-9A-Z]+\.[0-9A-Z]+/i', $chaine);
        }
}
?>