Subversion Repositories eFlore/Applications.cel

<?php
/**
 * Service d'import d'image à partir de mails
 * Encodage en entrée : utf8
 * Encodage en sortie : utf8
 *
 * @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$
 */
Class InventoryImportMail extends Cel {

        /**
         * Appelée en mode client, lit le mail envoyé sur l'entrée stdin
         * et le stocke dans le dossier temporaire en attendant
         * qu'une tache périodique associée traite les mails en attente
         * 
         * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
         */
        public function stockerMailCli($params)
        {
                $contenu_mail = file_get_contents('php://stdin');

                $parametres_ajout = array();
                $parametres_ajout['identifiant'] = $params['-s'];

                $stockage = $this->stockerMailTemporaire($parametres_ajout, $contenu_mail);
                        
                if($stockage) { 
                        $message_attente = 'Votre messsage a été reçu, et est en attente de traitement, '.
                                                                        'vous recevrez un message lorsque celui-ci aura été effectué';       
                        mail($parametres_ajout['identifiant'],'Votre message est en attente de traitement',$message_attente);
                } else {
                        $message_echec = 'Votre messsage a été reçu, mais il n\'a pas pu être stocké';     
                        mail($parametres_ajout['identifiant'],'Problème lors de reception du message',$message_echec);
                }
        
                exit;
        }
        
        private function stockerMailTemporaire($parametres_ajout, $contenu_mail) {
                
                $expediteur = $parametres_ajout['identifiant'];
                $nom_fichier_temp = $this->fabriquerNomTemporaireStockageMail($expediteur);
                
                $dossier_stockage_temp = $this->config['chemin_stockage_temp'];
                $chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
                
                return file_put_contents($chemin_stockage_image_temp.$nom_fichier_temp);
        }
        
        /**
         * Appelée en mode client, lit le mail envoyé sur l'entrée stdin
         * extrait les images en pièces jointes, et les ajoute au cel de l'utilisateur
         * expediteur 
         * 
         * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
         */
        public function traiterMailCli($params)
        {

                $contenu_mail = file_get_contents('php://stdin');

                $parametres_ajout = array();
                $parametres_ajout['identifiant'] = $params['-s'];

                $ids_stockage = $this->traiterMail($parametres_ajout, $contenu_mail);
                
                foreach($ids_stockage as $nom_image => $id_stockage) {
                        
                        if($id_stockage) {                      
                                mail($parametres_ajout['identifiant'],'Votre image a été ajoutée au Carnet en ligne','Votre image '.$nom_image.' a été ajoutée avec succès');
                        } else {
                                
                                mail($parametres_ajout['identifiant'],'Problème lors de l\'ajout au Carnet en ligne','Votre image '.$nom_image.' n\'a pas pu être ajoutée');
                        }
                }
        
                exit();
        }
        
        /**
         * Traite le mail fourni en paramètre extrait les images en pièces jointes, 
         * et les ajoute au cel de l'utilisateur expediteur 
         * 
         * @param array $params les paramètres du script client, l'utilisateur est indiqué dans la case 'identifiant'
        */
        public function traiterMail($params, $contenu_mail)
        {
                
                $pieces_jointes = $this->extrairePiecesJointes($contenu_mail);

                $stockeur_image = new InventoryImage($this->config);
                
                $ids = array();
                
                foreach($pieces_jointes as $piece_jointe) {
                        
                        $nouvel_id_image = $stockeur_image->ajouterImageSurDdEtBdd($params, $piece_jointe);             
                        
                        if($nouvel_id_image)
                        {               
                                $ids[$piece_jointe['name']] = $nouvel_id_image;
                        }
                        else
                        {
                                $ids[$piece_jointe['name']] = false;
                        }
                }
                
                // TODO: permettre la création d'observations liées aux images à partir du mail
                // et d'une syntaxe simple à définir
                
                return $ids;
        }
        
        /**
         * Appelée en mode client, parse le dossier ou sont stockés les mails
         * extrait les images en pièces jointes, et les ajoute au cel de l'utilisateur
         * 
        */
        public function parserDossierMail()
        {
                                
                $dossier_stockage_temp = $this->config['chemin_stockage_temp'];
                $chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
                
                foreach (new DirectoryIterator($chemin_stockage_image_temp) as $fichier_a_stocker) {
                                                        
                        if($fichier_ou_dossier->isDot()) {
                                continue;
                        }
                        
                        $chemin_fichier = $fichier_a_stocker->getPathname();
                        $nom_fichier = $fichier_ou_dossier->getFilename();
                        
                        $expediteur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier);
                        $contenu_mail = file_get_contents($chemin_fichier);
                        
                        $parametres = array('identifiant' => $expediteur_mail);
                        
                        $this->traiterMail($parametres, $contenu_mail);
                        
                        unlink($chemin_fichier);
                }
        }
        
        private function extrairePiecesJointes($mail) {

                $pieces_jointes = array();
        
                $args['include_bodies'] = true;
                $args['decode_bodies'] = true;
                $args['decode_headers'] = true;
                $args['input'] = $mail;
                
                $dossier_stockage_temp = $this->config['chemin_stockage_temp'];
        
                $tableau_mail_decode = Mail_mimeDecode::decode($args);
        
                foreach ($tableau_mail_decode->parts as $partie) {
        
                        if ($partie->ctype_primary == 'image' && $partie->ctype_secondary == 'jpeg') {
                        
                                $informations = array();
                                
                                $nom_original = $partie->ctype_parameters['name'];
                                $fichier =  $partie->body;
                                          
                                $hash = md5(time());
                                          
                                $chemin_temp = $dossier_stockage_temp.'/images/'.$hash.'.jpg';
                                          
                                $temp = fopen($chemin_temp,'w+');
                                fwrite($temp,$fichier);
                                fclose($temp);
                                chmod($chemin_temp, 0777); 
                        
                                $informations = array('tmp_name' => $chemin_temp,'name' => $nom_original,'type' => 'image/jpeg','size' => filesize($chemin_temp));
                          
                                $pieces_jointes[] = $informations;
                        }
                }

                return $pieces_jointes;
        }
        
        private function fabriquerNomTemporaireStockageMail($expediteur) {
                return time().'_'.$expediteur;
        }
        
        private function obtenirExpediteurPourNomTemporaireMail($nom_temp) {
                
                $chaine_separee = explode('_', $nom_temp,1);
                
                $nom_expediteur = false;
                
                if($chaine_separee && count($chaine_separee) > 1) {
                        $nom_expediteur = $chaine_separee[1];
                }
                
                return $nom_expediteur;
        }
}
?>