* @license GPL v3 * @license CECILL v2 * @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; } } ?>