WebSVN – eFlore/Applications.cel – Diff – /trunk/jrest/services/InventoryImportMail.php


<?php
// ATTENTION ! Classe compatible uniquement avec nouveau format de bdd du cel //
 
/**
 * 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['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);
	}
	
	/**
	 * 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) {			
				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');
			} else {
				
				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');
			}
		}
	
		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;
			}
			
			$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('courriel_utilisateur' => $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;
	}
}
?>

Subversion Repositories eFlore/Applications.cel

(root)/trunk/jrest/services/InventoryImportMail.php – Rev 767 → 858

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