Subversion Repositories eFlore/Applications.cel

<?php

// declare(encoding='UTF-8');

/**

 * Service d'import d'image à partir d'e-mails.

 *

 * @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 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['mail_utilisateur'] = $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['mail_utilisateur'],'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['mail_utilisateur'],'Problème lors de reception du message',$message_echec);

		}

		exit();

	}

	private function stockerMailTemporaire($parametres_ajout, $contenu_mail) {

		$expediteur = $parametres_ajout['mail_utilisateur'];

		$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, $contenu_mail);

	}

	/**

	 * 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['mail_utilisateur'] = $params['-s'];

		$ids_stockage = $this->traiterMail($parametres_ajout, $contenu_mail);

		foreach ($ids_stockage as $nom_image => $id_stockage) {

			if ($id_stockage) {

				$sujet = "Votre image a été ajoutée au Carnet en ligne";

				$msg = "Votre image $nom_image a été ajoutée avec succès";

				mail($parametres_ajout['mail_utilisateur'], $sujet, $msg);

			} else {

				$sujet = "Problème lors de l'ajout au Carnet en ligne";

				$msg = "Votre image $nom_image n'a pas pu être ajoutée";

				mail($parametres_ajout['mail_utilisateur'], $sujet, $msg);

			}

		}

		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();

		$infos_utilisateur = $this->getInfosComplementairesUtilisateurPourMail($params['mail_utilisateur']);

		$params['ce_utilisateur'] = $infos_utilisateur['id_utilisateur'];

		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;

			}

			$nom_fichier = $fichier_ou_dossier->getFilename();

			$expediteur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier);

			$parametres = array('courriel_utilisateur' => $expediteur_mail);

			$chemin_fichier = $fichier_a_stocker->getPathname();

			$contenu_mail = file_get_contents($chemin_fichier);

			$this->traiterMail($parametres, $contenu_mail);

			unlink($chemin_fichier);

		}

	}

	private function extrairePiecesJointes($mail) {

		$args['include_bodies'] = true;

		$args['decode_bodies'] = true;

		$args['decode_headers'] = true;

		$args['input'] = $mail;

		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];

		$pieces_jointes = array();

		$tableau_mail_decode = Mail_mimeDecode::decode($args);

		foreach ($tableau_mail_decode->parts as $partie) {

			if ($partie->ctype_primary == 'image' && $partie->ctype_secondary == 'jpeg') {

				$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);

				$pieces_jointes[] = array(

					'tmp_name' => $chemin_temp,

					'name' => $nom_original,

					'type' => 'image/jpeg',

					'size' => filesize($chemin_temp));

			}

		}

  		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;

	}

}