| New file |
|---|
| 0,0 → 1,203 |
|---|
| <?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(); |
| |
| $expditeur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier) |
| $contenu_mail = file_get_contents($chemin_fichier); |
| |
| $this->traiterMail($contenu_mail); |
| |
| } |
| } |
| |
| 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; |
| } |
| } |
| ?> |