Subversion Repositories eFlore/Applications.cel

Rev

Rev 858 | Go to most recent revision | Show entire file | Regard 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 
		}
Line 41... Line 41...
41 
		exit;
 41 
		exit();
42 
	}
 - 
 
43
42 
	}
44 
	private function stockerMailTemporaire($parametres_ajout, $contenu_mail) {
 43 
 
45
- 
 
46 
		$expediteur = $parametres_ajout['mail_utilisateur'];
 44 
	private function stockerMailTemporaire($parametres_ajout, $contenu_mail) {
47 
		$nom_fichier_temp = $this->fabriquerNomTemporaireStockageMail($expediteur);
 45 
		$expediteur = $parametres_ajout['mail_utilisateur'];
Line 48... Line 46...
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'];
Line 50... Line 48...
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
- 
 
59 
	 *
- 
 
60 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
 56 
	 * expediteur
61 
	 */
 - 
 
62 
	public function traiterMailCli($params)
 57 
	 *
63 
	{
 58 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué avec le paramètre -s
64 
 
 - 
 
65 
		$contenu_mail = file_get_contents('php://stdin');
 59 
	 */
Line 66... Line 60...
66 
 
 60 
	public function traiterMailCli($params) {
67 
		$parametres_ajout = array();
 - 
 
68 
		$parametres_ajout['mail_utilisateur'] = $params['-s'];
 61 
		$contenu_mail = file_get_contents('php://stdin');
- 
 
 62 
		$parametres_ajout = array();
69 
 
 63 
		$parametres_ajout['mail_utilisateur'] = $params['-s'];
- 
 
 64 
		$ids_stockage = $this->traiterMail($parametres_ajout, $contenu_mail);
70 
		$ids_stockage = $this->traiterMail($parametres_ajout, $contenu_mail);
 65 
 
71
- 
 
- 
 
 66 
		foreach ($ids_stockage as $nom_image => $id_stockage) {
- 
 
 67 
			if ($id_stockage) {
72 
		foreach($ids_stockage as $nom_image => $id_stockage) {
 68 
				$sujet = "Votre image a été ajoutée au Carnet en ligne";
73
69 
				$msg = "Votre image $nom_image a été ajoutée avec succès";
74 
			if($id_stockage) {
70 
				mail($parametres_ajout['mail_utilisateur'], $sujet, $msg);
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');
 - 
 
76 
			} else {
 71 
			} else {
77
72 
				$sujet = "Problème lors de l'ajout au Carnet en ligne";
Line 78... Line 73...
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');
 73 
				$msg = "Votre image $nom_image n'a pas pu être ajoutée";
79 
			}
 74 
				mail($parametres_ajout['mail_utilisateur'], $sujet, $msg);
80 
		}
 75 
			}
81
76 
		}
82 
		exit();
 77 
		exit();
83 
	}
 78 
	}
84
79 
 
85 
	/**
 - 
 
86 
	 * Traite le mail fourni en paramètre extrait les images en pièces jointes,
80 
	/**
87 
	 * et les ajoute au cel de l'utilisateur expediteur
- 
 
88 
	 *
81 
	 * Traite le mail fourni en paramètre extrait les images en pièces jointes,
89 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué dans la case 'identifiant'
 - 
 
90 
	*/
 82 
	 * et les ajoute au cel de l'utilisateur expediteur
91 
	public function traiterMail($params, $contenu_mail)
 - 
 
92 
	{
83 
	 *
93 
		$pieces_jointes = $this->extrairePiecesJointes($contenu_mail);
 - 
 
94 
 
 84 
	 * @param array $params les paramètres du script client, l'utilisateur est indiqué dans la case 'identifiant'
95 
		$stockeur_image = new InventoryImage($this->config);
 85 
	*/
96
- 
 
97 
		$ids = array();
 86 
	public function traiterMail($params, $contenu_mail) {
Line 98... Line 87...
98
87 
		$pieces_jointes = $this->extrairePiecesJointes($contenu_mail);
99 
		$infos_utilisateur = $this->getInfosComplementairesUtilisateurPourMail($params['mail_utilisateur']);
 - 
 
100
88 
		$stockeur_image = new InventoryImage($this->config);
101 
		$params['ce_utilisateur'] = $infos_utilisateur['id_utilisateur'];
 - 
 
102 
		foreach($pieces_jointes as $piece_jointe) {
 89 
		$ids = array();
103
- 
 
104 
			$nouvel_id_image = $stockeur_image->ajouterImageSurDdEtBdd($params, $piece_jointe);
90 
		$infos_utilisateur = $this->getInfosComplementairesUtilisateurPourMail($params['mail_utilisateur']);
105
91 
		$params['ce_utilisateur'] = $infos_utilisateur['id_utilisateur'];
106 
			if($nouvel_id_image)
 92 
		foreach ($pieces_jointes as $piece_jointe) {
Line 107... Line 93...
107 
			{
93 
			$nouvel_id_image = $stockeur_image->ajouterImageSurDdEtBdd($params, $piece_jointe);
Line 121... Line 107...
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 
	*/
 111 
	*/
126 
	public function parserDossierMail()
 112 
	public function parserDossierMail() {
127 
	{
 - 
 
128
- 
 
129 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
 113 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
130 
		$chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
 114 
		$chemin_stockage_image_temp = $dossier_stockage_temp.'/mails/';
131
- 
 
132 
		foreach (new DirectoryIterator($chemin_stockage_image_temp) as $fichier_a_stocker) {
 115 
		foreach (new DirectoryIterator($chemin_stockage_image_temp) as $fichier_a_stocker) {
133
- 
 
134 
			if($fichier_ou_dossier->isDot()) {
 116 
			if ($fichier_ou_dossier->isDot()) {
135 
				continue;
 117 
				continue;
136 
			}
 118 
			}
137
- 
 
138 
			$chemin_fichier = $fichier_a_stocker->getPathname();
 - 
 
139 
			$nom_fichier = $fichier_ou_dossier->getFilename();
 119 
			$nom_fichier = $fichier_ou_dossier->getFilename();
140
- 
 
141 
			$expediteur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier);
 120 
			$expediteur_mail = $this->obtenirExpediteurPourNomTemporaireMail($nom_fichier);
142 
			$contenu_mail = file_get_contents($chemin_fichier);
 - 
 
143
- 
 
144 
			$parametres = array('courriel_utilisateur' => $expediteur_mail);
 121 
			$parametres = array('courriel_utilisateur' => $expediteur_mail);
145
- 
 
- 
 
 122 
			$chemin_fichier = $fichier_a_stocker->getPathname();
- 
 
 123 
			$contenu_mail = file_get_contents($chemin_fichier);
146 
			$this->traiterMail($parametres, $contenu_mail);
 124 
			$this->traiterMail($parametres, $contenu_mail);
147
- 
 
148 
			unlink($chemin_fichier);
 125 
			unlink($chemin_fichier);
149 
		}
 126 
		}
150 
	}
 127 
	}
Line 151... Line 128...
151
128 
 
152 
	private function extrairePiecesJointes($mail) {
 - 
 
153 
 
 - 
 
154 
		$pieces_jointes = array();
 - 
 
155
129 
	private function extrairePiecesJointes($mail) {
156 
		$args['include_bodies'] = true;
 130 
		$args['include_bodies'] = true;
157 
		$args['decode_bodies'] = true;
 131 
		$args['decode_bodies'] = true;
158 
		$args['decode_headers'] = true;
 132 
		$args['decode_headers'] = true;
159 
		$args['input'] = $mail;
 - 
 
160
133 
		$args['input'] = $mail;
Line -... Line 134...
- 
 
 134 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
161 
		$dossier_stockage_temp = $this->config['chemin_stockage_temp'];
 135 
 
162
- 
 
163 
		$tableau_mail_decode = Mail_mimeDecode::decode($args);
 136 
		$pieces_jointes = array();
164
- 
 
165 
		foreach ($tableau_mail_decode->parts as $partie) {
 137 
		$tableau_mail_decode = Mail_mimeDecode::decode($args);
166
- 
 
167 
			if ($partie->ctype_primary == 'image' && $partie->ctype_secondary == 'jpeg') {
 - 
 
168
- 
 
169 
				$informations = array();
 138 
		foreach ($tableau_mail_decode->parts as $partie) {
170
139 
			if ($partie->ctype_primary == 'image' && $partie->ctype_secondary == 'jpeg') {
171 
				$nom_original = $partie->ctype_parameters['name'];
 - 
 
172 
				$fichier =  $partie->body;
 140 
				$nom_original = $partie->ctype_parameters['name'];
173
- 
 
174 
				$hash = md5(time());
 141 
				$fichier =  $partie->body;
Line 175... Line 142...
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+');
Line -... Line 146...
- 
 
 146 
				fwrite($temp,$fichier);
179 
				fwrite($temp,$fichier);
 147 
				fclose($temp);
180 
				fclose($temp);
 - 
 
- 
 
 148 
				chmod($chemin_temp, 0777);
- 
 
 149 
 
181 
				chmod($chemin_temp, 0777);
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
- 
 
185 
				$pieces_jointes[] = $informations;
 153 
					'type' => 'image/jpeg',
186 
			}
 154 
					'size' => filesize($chemin_temp));
Line 187... Line 155...
187 
		}
 155 
			}
188 
 
 156 
		}
189 
  		return $pieces_jointes;
 157 
  		return $pieces_jointes;
Line 190... Line 158...
190 
	}
 158 
	}
191
- 
 
192 
	private function fabriquerNomTemporaireStockageMail($expediteur) {
 159 
 
193 
		return time().'_'.$expediteur;
 - 
 
194 
	}
 160 
	private function fabriquerNomTemporaireStockageMail($expediteur) {
195
- 
 
196 
	private function obtenirExpediteurPourNomTemporaireMail($nom_temp) {
 161 
		return time().'_'.$expediteur;
197
162 
	}
198 
		$chaine_separee = explode('_', $nom_temp,1);
 163 
 
199
- 
 
200 
		$nom_expediteur = false;
 164 
	private function obtenirExpediteurPourNomTemporaireMail($nom_temp) {
201
165 
		$chaine_separee = explode('_', $nom_temp,1);
202 
		if($chaine_separee && count($chaine_separee) > 1) {
 166 
		$nom_expediteur = false;
203 
			$nom_expediteur = $chaine_separee[1];
 - 
 
204 
		}
 167 
		if ($chaine_separee && count($chaine_separee) > 1) {