Subversion Repositories eFlore/Applications.cel

Rev

Rev 858 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 858 Rev 2458
Line 1... Line 1...
1 
<?php
 1 
<?php
2 
// ATTENTION ! Classe compatible uniquement avec nouveau format de bdd du cel //
 2 
// declare(encoding='UTF-8');
3 
 
 - 
 
4 
/**
 3 
/**
5 
 * Service d'import d'image à partir de mails
 4 
 * Service d'import d'image à partir d'e-mails.
6 
 * Encodage en entrée : utf8
 - 
 
7 
 * Encodage en sortie : utf8
 - 
 
8 
 *
 5 
 *
- 
 
 6 
 * @internal   Mininum PHP version : 5.2
- 
 
 7 
 * @category   CEL
- 
 
 8 
 * @package    Services
- 
 
 9 
 * @subpackage Images
- 
 
 10 
 * @version    0.1
- 
 
 11 
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
- 
 
 12 
 * @author     Jean-Pascal MILCENT <jpm@tela-botanica.org>
9 
 * @author Aurélien PERONNET <aurelien@tela-botanica.org>
 13 
 * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
10 
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 14 
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
11 
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 15 
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
12 
 * @version $Id$
 16 
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
13 
 */
 17 
 */
14 
Class InventoryImportMail extends Cel {
 18 
class InventoryImportMail extends Cel {
Line 15... Line 19...
15 
 
 19 
 
16 
	/**
 20 
	/**
17 
	 * Appelée en mode client, lit le mail envoyé sur l'entrée stdin
 21 
	 * Appelée en mode client, lit le mail envoyé sur l'entrée stdin
18 
	 * et le stocke dans le dossier temporaire en attendant
 22 
	 * et le stocke dans le dossier temporaire en attendant
19 
	 * qu'une tache périodique associée traite les mails en attente
 23 
	 * qu'une tache périodique associée traite les mails en attente
20 
	 *
24 
	 *
21 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
 25 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
22 
	 */
 26 
	 */
23 
	public function stockerMailCli($params)
 - 
 
24 
	{
 27 
	public function stockerMailCli($params) {
25 
		$contenu_mail = file_get_contents('php://stdin');
 - 
 
26 
 
 28 
		$contenu_mail = file_get_contents('php://stdin');
27 
		$parametres_ajout = array();
 29 
		$parametres_ajout = array();
Line 28... Line 30...
28 
		$parametres_ajout['mail_utilisateur'] = $params['-s'];
 30 
		$parametres_ajout['mail_utilisateur'] = $params['-s'];
29 
 
 - 
 
30 
		$stockage = $this->stockerMailTemporaire($parametres_ajout, $contenu_mail);
 31 
 
31
32 
		$stockage = $this->stockerMailTemporaire($parametres_ajout, $contenu_mail);
32 
		if($stockage) {
33 
		if ($stockage) {
33 
			$message_attente = 'Votre messsage a été reçu, et est en attente de traitement, '.
 34 
			$message_attente = 'Votre messsage a été reçu, et est en attente de traitement, '.
34 
									'vous recevrez un message lorsque celui-ci aura été effectué';
35 
				'vous recevrez un message lorsque celui-ci aura été effectué';
35 
			mail($parametres_ajout['mail_utilisateur'],'Votre message est en attente de traitement',$message_attente);
 36 
			mail($parametres_ajout['mail_utilisateur'],'Votre message est en attente de traitement',$message_attente);
36 
		} else {
 37 
		} else {
37 
			$message_echec = 'Votre messsage a été reçu, mais il n\'a pas pu être stocké';
38 
			$message_echec = 'Votre messsage a été reçu, mais il n\'a pas pu être stocké';
38 
			mail($parametres_ajout['mail_utilisateur'],'Problème lors de reception du message',$message_echec);
 - 
 
39 
		}
 39 
			mail($parametres_ajout['mail_utilisateur'],'Problème lors de reception du message',$message_echec);
40
40 
		}
41 
		exit;
 41 
		exit();
42 
	}
 42 
	}
43
- 
 
44 
	private function stockerMailTemporaire($parametres_ajout, $contenu_mail) {
 43 
 
45
44 
	private function stockerMailTemporaire($parametres_ajout, $contenu_mail) {
46 
		$expediteur = $parametres_ajout['mail_utilisateur'];
 - 
 
47 
		$nom_fichier_temp = $this->fabriquerNomTemporaireStockageMail($expediteur);
 45 
		$expediteur = $parametres_ajout['mail_utilisateur'];
48
46 
		$nom_fichier_temp = $this->fabriquerNomTemporaireStockageMail($expediteur);
49 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
 47 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
50 
		$chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
 48 
		$chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
51
49 
 
52 
		return file_put_contents($chemin_stockage_image_temp.$nom_fichier_temp);
 50 
		return file_put_contents($chemin_stockage_image_temp.$nom_fichier_temp, $contenu_mail);
53 
	}
 51 
	}
54
52 
 
55 
	/**
 53 
	/**
56 
	 * Appelée en mode client, lit le mail envoyé sur l'entrée stdin
 54 
	 * Appelée en mode client, lit le mail envoyé sur l'entrée stdin
57 
	 * extrait les images en pièces jointes, et les ajoute au cel de l'utilisateur
 55 
	 * extrait les images en pièces jointes, et les ajoute au cel de l'utilisateur
58 
	 * expediteur
56 
	 * expediteur
59 
	 *
57 
	 *
60 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
 58 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
61 
	 */
 - 
 
62 
	public function traiterMailCli($params)
 - 
 
63 
	{
 59 
	 */
64 
 
 - 
 
65 
		$contenu_mail = file_get_contents('php://stdin');
 60 
	public function traiterMailCli($params) {
66 
 
 61 
		$contenu_mail = file_get_contents('php://stdin');
67 
		$parametres_ajout = array();
 - 
 
68 
		$parametres_ajout['mail_utilisateur'] = $params['-s'];
 62 
		$parametres_ajout = array();
69 
 
 63 
		$parametres_ajout['mail_utilisateur'] = $params['-s'];
70 
		$ids_stockage = $this->traiterMail($parametres_ajout, $contenu_mail);
 64 
		$ids_stockage = $this->traiterMail($parametres_ajout, $contenu_mail);
71
- 
 
72 
		foreach($ids_stockage as $nom_image => $id_stockage) {
 65 
 
- 
 
 66 
		foreach ($ids_stockage as $nom_image => $id_stockage) {
73
67 
			if ($id_stockage) {
- 
 
 68 
				$sujet = "Votre image a été ajoutée au Carnet en ligne";
74 
			if($id_stockage) {
69 
				$msg = "Votre image $nom_image a été ajoutée avec succès";
75 
				mail($parametres_ajout['mail_utilisateur'],'Votre image a été ajoutée au Carnet en ligne','Votre image '.$nom_image.' a été ajoutée avec succès');
 - 
 
- 
 
 70 
				mail($parametres_ajout['mail_utilisateur'], $sujet, $msg);
- 
 
 71 
			} else {
76 
			} else {
 72 
				$sujet = "Problème lors de l'ajout au Carnet en ligne";
77
73 
				$msg = "Votre image $nom_image n'a pas pu être ajoutée";
78 
				mail($parametres_ajout['mail_utilisateur'],'Problème lors de l\'ajout au Carnet en ligne','Votre image '.$nom_image.' n\'a pas pu être ajoutée');
 74 
				mail($parametres_ajout['mail_utilisateur'], $sujet, $msg);
79 
			}
 - 
 
80 
		}
 75 
			}
81
76 
		}
82 
		exit();
 77 
		exit();
83 
	}
 78 
	}
84
79 
 
85 
	/**
 80 
	/**
86 
	 * Traite le mail fourni en paramètre extrait les images en pièces jointes,
81 
	 * Traite le mail fourni en paramètre extrait les images en pièces jointes,
87 
	 * et les ajoute au cel de l'utilisateur expediteur
82 
	 * et les ajoute au cel de l'utilisateur expediteur
88 
	 *
83 
	 *
89 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué dans la case 'identifiant'
 84 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué dans la case 'identifiant'
90 
	*/
 - 
 
91 
	public function traiterMail($params, $contenu_mail)
 85 
	*/
92 
	{
- 
 
93 
		$pieces_jointes = $this->extrairePiecesJointes($contenu_mail);
 86 
	public function traiterMail($params, $contenu_mail) {
94 
 
 - 
 
95 
		$stockeur_image = new InventoryImage($this->config);
 87 
		$pieces_jointes = $this->extrairePiecesJointes($contenu_mail);
96
- 
 
97 
		$ids = array();
 88 
		$stockeur_image = new InventoryImage($this->config);
98
- 
 
99 
		$infos_utilisateur = $this->getInfosComplementairesUtilisateurPourMail($params['mail_utilisateur']);
 89 
		$ids = array();
100
90 
		$infos_utilisateur = $this->getInfosComplementairesUtilisateurPourMail($params['mail_utilisateur']);
101 
		$params['ce_utilisateur'] = $infos_utilisateur['id_utilisateur'];
 - 
 
102 
		foreach($pieces_jointes as $piece_jointe) {
 91 
		$params['ce_utilisateur'] = $infos_utilisateur['id_utilisateur'];
103
92 
		foreach ($pieces_jointes as $piece_jointe) {
104 
			$nouvel_id_image = $stockeur_image->ajouterImageSurDdEtBdd($params, $piece_jointe);
93 
			$nouvel_id_image = $stockeur_image->ajouterImageSurDdEtBdd($params, $piece_jointe);
105
- 
 
106 
			if($nouvel_id_image)
 94 
 
107 
			{
- 
 
108 
				$ids[$piece_jointe['name']] = $nouvel_id_image;
 95 
			if($nouvel_id_image) {
109 
			}
 - 
 
110 
			else
 96 
				$ids[$piece_jointe['name']] = $nouvel_id_image;
111 
			{
 97 
			} else {
112 
				$ids[$piece_jointe['name']] = false;
 98 
				$ids[$piece_jointe['name']] = false;
113 
			}
 99 
			}
114 
		}
 100 
		}
115
101 
 
116 
		// TODO: permettre la création d'observations liées aux images à partir du mail
 102 
		// TODO: permettre la création d'observations liées aux images à partir du mail
117 
		// et d'une syntaxe simple à définir
 103 
		// et d'une syntaxe simple à définir
118 
		return $ids;
 104 
		return $ids;
119 
	}
 105 
	}
120
106 
 
121 
	/**
 107 
	/**
122 
	 * Appelée en mode client, parse le dossier ou sont stockés les mails
 108 
	 * Appelée en mode client, parse le dossier ou sont stockés les mails
123 
	 * extrait les images en pièces jointes, et les ajoute au cel de l'utilisateur
 109 
	 * extrait les images en pièces jointes, et les ajoute au cel de l'utilisateur
124 
	 *
110 
	 *
125 
	*/
 - 
 
126 
	public function parserDossierMail()
 - 
 
127 
	{
 111 
	*/
128
112 
	public function parserDossierMail() {
129 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
 - 
 
130 
		$chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
 113 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
131
- 
 
132 
		foreach (new DirectoryIterator($chemin_stockage_image_temp) as $fichier_a_stocker) {
 114 
		$chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
133
115 
		foreach (new DirectoryIterator($chemin_stockage_image_temp) as $fichier_a_stocker) {
134 
			if($fichier_ou_dossier->isDot()) {
 116 
			if ($fichier_ou_dossier->isDot()) {
135 
				continue;
 - 
 
136 
			}
 - 
 
137
117 
				continue;
138 
			$chemin_fichier = $fichier_a_stocker->getPathname();
 - 
 
139 
			$nom_fichier = $fichier_ou_dossier->getFilename();
 118 
			}
140
- 
 
141 
			$expediteur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier);
 - 
 
142 
			$contenu_mail = file_get_contents($chemin_fichier);
 119 
			$nom_fichier = $fichier_ou_dossier->getFilename();
143
- 
 
- 
 
 120 
			$expediteur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier);
- 
 
 121 
			$parametres = array('courriel_utilisateur' => $expediteur_mail);
144 
			$parametres = array('courriel_utilisateur' => $expediteur_mail);
 122 
			$chemin_fichier = $fichier_a_stocker->getPathname();
145
- 
 
146 
			$this->traiterMail($parametres, $contenu_mail);
 123 
			$contenu_mail = file_get_contents($chemin_fichier);
147
124 
			$this->traiterMail($parametres, $contenu_mail);
148 
			unlink($chemin_fichier);
 125 
			unlink($chemin_fichier);
149 
		}
 - 
 
150 
	}
 - 
 
Line 151... Line 126...
151
126 
		}
152 
	private function extrairePiecesJointes($mail) {
 - 
 
153 
 
 127 
	}
154 
		$pieces_jointes = array();
 128 
 
155
129 
	private function extrairePiecesJointes($mail) {
156 
		$args['include_bodies'] = true;
 130 
		$args['include_bodies'] = true;
157 
		$args['decode_bodies'] = true;
 - 
 
158 
		$args['decode_headers'] = true;
 131 
		$args['decode_bodies'] = true;
159 
		$args['input'] = $mail;
 132 
		$args['decode_headers'] = true;
- 
 
 133 
		$args['input'] = $mail;
160
134 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
161 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
 - 
 
162
135 
 
163 
		$tableau_mail_decode = Mail_mimeDecode::decode($args);
 - 
 
164
136 
		$pieces_jointes = array();
165 
		foreach ($tableau_mail_decode->parts as $partie) {
 - 
 
166
- 
 
167 
			if ($partie->ctype_primary == 'image' && $partie->ctype_secondary == 'jpeg') {
 - 
 
168
137 
		$tableau_mail_decode = Mail_mimeDecode::decode($args);
169 
				$informations = array();
 138 
		foreach ($tableau_mail_decode->parts as $partie) {
170
- 
 
171 
				$nom_original = $partie->ctype_parameters['name'];
 139 
			if ($partie->ctype_primary == 'image' && $partie->ctype_secondary == 'jpeg') {
172 
				$fichier =  $partie->body;
 - 
 
173
140 
				$nom_original = $partie->ctype_parameters['name'];
174 
				$hash = md5(time());
 141 
				$fichier =  $partie->body;
175
142 
				$hash = md5(time());
176 
				$chemin_temp = $dossier_stockage_temp.'/images/'.$hash.'.jpg';
 143 
				$chemin_temp = $dossier_stockage_temp.'/images/'.$hash.'.jpg';
177
144 
 
178 
				$temp = fopen($chemin_temp,'w+');
 145 
				$temp = fopen($chemin_temp,'w+');
179 
				fwrite($temp,$fichier);
 146 
				fwrite($temp,$fichier);
- 
 
 147 
				fclose($temp);
180 
				fclose($temp);
 148 
				chmod($chemin_temp, 0777);
181 
				chmod($chemin_temp, 0777);
- 
 
- 
 
 149 
 
- 
 
 150 
				$pieces_jointes[] = array(
182
151 
					'tmp_name' => $chemin_temp,
183 
				$informations = array('tmp_name' => $chemin_temp,'name' => $nom_original,'type' => 'image/jpeg','size' => filesize($chemin_temp));
 152 
					'name' => $nom_original,
184
153 
					'type' => 'image/jpeg',
185 
				$pieces_jointes[] = $informations;
 - 
 
186 
			}
 154 
					'size' => filesize($chemin_temp));
187 
		}
 155 
			}
188 
 
 156 
		}
189 
  		return $pieces_jointes;
 157 
  		return $pieces_jointes;
190 
	}
 158 
	}
191
159 
 
192 
	private function fabriquerNomTemporaireStockageMail($expediteur) {
 160 
	private function fabriquerNomTemporaireStockageMail($expediteur) {
193 
		return time().'_'.$expediteur;
 161 
		return time().'_'.$expediteur;
194 
	}
 - 
 
195
162 
	}
196 
	private function obtenirExpediteurPourNomTemporaireMail($nom_temp) {
 - 
 
197
163 
 
198 
		$chaine_separee = explode('_', $nom_temp,1);
 - 
 
199
164 
	private function obtenirExpediteurPourNomTemporaireMail($nom_temp) {
200 
		$nom_expediteur = false;
 165 
		$chaine_separee = explode('_', $nom_temp,1);
201
166 
		$nom_expediteur = false;
202 
		if($chaine_separee && count($chaine_separee) > 1) {
 - 
 
203 
			$nom_expediteur = $chaine_separee[1];
 167 
		if ($chaine_separee && count($chaine_separee) > 1) {
204 
		}
 168 
			$nom_expediteur = $chaine_separee[1];
205
- 
 
206 
		return $nom_expediteur;
 - 
 
207 
	}
 169 
		}
- 
 
 170 
		return $nom_expediteur;
208 
}
 171 
	}