Subversion Repositories Applications.annuaire

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
486 aurelien 1
<?php
2
// Encodage : UTF-8
3
// +-------------------------------------------------------------------------------------------------------------------+
4
/**
5
* Traitement des mails en attente de modération de l'annuaire
6
*
7
* Description : classe permettant de gérer l'envoi des mails en attente de modération dans l'annuaire
8
* Utilisation : php script.php mail
9
*
10
//Auteur original :
11
* @author       Aurélien PERONNET <jpm@tela-botanica.org>
12
* @copyright	Tela-Botanica 1999-2014
13
* @licence		GPL v3 & CeCILL v2
14
* @version		$Id$
15
*/
16
 
17
class Mail extends Script {
490 aurelien 18
	//TODO: cette classe est en doublon avec du code de l'annuaire
19
	// une fois passé à la dernière version du framework, il faudrait factoriser ces fonctions
20
	// dans une lib commune accessible aux scripts et au code standard
486 aurelien 21
	const STATUT_A_TRAITER = 'a_traiter';
22
	const STATUT_EN_TRAITEMENT = 'en_traitement';
23
 
490 aurelien 24
	// Définit le délai au bout du quel on remet des mails en traitement à traiter
25
	// au format (avec la syntaxe utilisée avec INTERVAL en SQL)
26
	// http://dev.mysql.com/doc/refman/5.0/fr/date-and-time-functions.html
27
	const DELAI_MAX_TRAITEMENT = '10 HOUR';
28
 
486 aurelien 29
	private $modele = null;
30
 
31
	public function executer() {
32
		$this->bdd = new Bdd();
33
 
34
		$cmd = $this->getParametre('a');
35
		$this->mode_verbeux = $this->getParametre('v');
36
 
37
		switch($cmd) {
490 aurelien 38
			case "tous":
39
				$retour = $this->traiterMailsEnAttente();
486 aurelien 40
			break;
41
			// TODO: case supplémentaire pour traiter un mail par son id ?
42
			// TODO: option "force" pour traiter les mails quelques soient leur statut ?
43
			default:
490 aurelien 44
		}
45
 
46
		if($this->mode_verbeux) {
47
			print_r($retour);
486 aurelien 48
		}
49
	}
50
 
51
	private function traiterMailsEnAttente() {
52
		// Gaston Lagaffe
53
		$mails_en_retard = $this->remettreATraiterMailsEnRetard();
54
		$mails_a_traiter = $this->obtenirMailsEnAttente();
55
 
56
		$retour = array();
57
		if(count($mails_a_traiter) > 0 && $this->mettreMailsEnCoursDeTraitement()) {
58
			foreach($mails_a_traiter as $donnees_brutes_mail) {
59
				$mail_a_moderer = $this->decoderDonneeTemporaire($donnees_brutes_mail);
60
				$id_mail = $donnees_brutes_mail['adt_id'];
490 aurelien 61
 
62
				$resultat_envoi = true;
63
				$envois_echoues = $this->envoyerMail($mail_a_moderer['expediteur'],
486 aurelien 64
						$mail_a_moderer['destinataires'],
65
						$mail_a_moderer['sujet'],
66
						$mail_a_moderer['message']);
67
 
490 aurelien 68
				if(empty($envois_echoues)) {
486 aurelien 69
					$this->supprimerMailTraite($id_mail);
490 aurelien 70
				} else {
71
					// TODO: supprimer les destinataires qui ont fonctionné, et mettre à jour
72
					// le mail dans les données temporaire avec les destinataires qui restent
73
					// pour pouvoir finir de l'envoyer
74
					$this->avertirModerateurEchecEnvoi($envois_echoues, $mail_a_moderer);
75
					$resultat_envoi = false;
486 aurelien 76
				}
490 aurelien 77
 
78
				// TODO: logger également erreur d'envoi ?
486 aurelien 79
				$retour[$id_mail] = $resultat_envoi;
80
			}
81
		}
82
		return $retour;
83
	}
84
 
490 aurelien 85
	private function avertirModerateurEchecEnvoi($envois_echoues, $mail_a_moderer) {
86
 
87
		$corps_mail_echoue = "L'envoi d'un mail modéré à échoué pour les destinataires suivants (".count($envois_echoues)." au total) : <br />";
88
		$corps_mail_echoue .= implode(", ", $envois_echoues);
89
		$corps_mail_echoue .= "<br /><br /><br />";
90
		$corps_mail_echoue .= "--- <i> Message original ---</i><br />";
91
		$corps_mail_echoue .= "Expéditeur  : ".$mail_a_moderer['expediteur']."<br />";
92
		$corps_mail_echoue .= "Sujet  : ".$mail_a_moderer['sujet']."<br />";
93
		$corps_mail_echoue .= "Message original : ".$mail_a_moderer['message']."<br />";
94
 
95
		$sujet = "L'envoi d'un mail modéré a échoué pour un ou plusieurs destinataires";
96
 
97
		// TODO: Que faire si l'envoi de mail d'avertissement échoue également ?
98
		$envoi_avertissement = $this->envoyerMail(Config::get('adresse_mail_annuaire'),
99
				Config::get('mail_moderateur'),
100
				$sujet,
101
				$corps_mail_echoue);
102
 
103
		return $envoi_avertissement;
104
	}
105
 
486 aurelien 106
	private function obtenirMailsEnAttente() {
493 aurelien 107
		$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
486 aurelien 108
		$retour = $this->bdd->recupererTous($requete);
109
 
110
		return $retour;
111
	}
112
 
113
	private function mettreMailsEnCoursDeTraitement() {
493 aurelien 114
		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ".
115
					"WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
486 aurelien 116
		$maj = $this->bdd->requeter($requete);
117
		return ($maj !== false);
118
	}
119
 
491 aurelien 120
	private function mettreAJourMailMalTraite($id_mail_mal_traite, $mail_mal_traite, $envois_echoues) {
121
		// TODO: utiliser cette fonction lors de l'echec de plusieurs destinataires et renvoyer le lien
122
		// de confirmation
123
		$mail_mal_traite['destinataires'] = $envois_echoues;
124
		$mail_mal_traite = $this->encoderDonneeTemporaire($mail_mal_traite);
125
 
126
		$requete = "UPDATE annu_donnees_temp ".
127
					"SET adt_donnees = '".$mail_mal_traite."' ".
128
					"WHERE adt_id = '".$mail_a_moderer['adt_id']."'";
129
 
130
		$maj = $this->bdd->requeter($requete);
131
		return $maj;
132
	}
133
 
486 aurelien 134
	private function supprimerMailTraite($id) {
493 aurelien 135
		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
486 aurelien 136
					"AND adt_id = '".$id."'";
137
		$supp = $this->bdd->requeter($requete);
138
		return $supp;
139
	}
140
 
141
	private function supprimerMailsEnCoursDeTraitement() {
493 aurelien 142
		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ";
486 aurelien 143
		$supp = $this->bdd->requeter($requete);
144
		return $supp;
145
	}
146
 
147
	private function remettreATraiterMailsEnRetard() {
490 aurelien 148
		// Les mails a traiter depuis plus de 10 heures sont considérés comme échoués et donc remis à traiter
149
		// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
493 aurelien 150
		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_A_TRAITER."', adt_date_debut_traitement = NULL ".
151
				"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
152
				"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
486 aurelien 153
 
154
		$maj = $this->bdd->requeter($requete);
155
		return ($maj !== false);
156
	}
157
 
491 aurelien 158
	private function encoderDonneeTemporaire($donnee) {
159
		return base64_encode(serialize($donnee));
160
	}
161
 
486 aurelien 162
	private function decoderDonneeTemporaire($donnee_encodee) {
163
		return unserialize(base64_decode($donnee_encodee['adt_donnees']));
164
	}
165
 
166
	/** Envoie un mail avec l'adresse de l'utilisateur donné en paramètre, à l'adresse donnée en paramètre.
167
	 * ATTENTION : le sujet et le contenu envoyer à cette méthode doivent avoir le même encodage que l'application.
168
	 *
169
	 * @param string $expediteur l'expediteur du message
170
	 * @param mixed $destinataires un string ou un tableau de mails qui contiennent les destinataire
171
	 * @param string $sujet sujet du mail
172
	 * @return boolean true ou false suivant le succès ou non de l'envoi
173
	 */
174
	public function envoyerMail($expediteur, $destinataires, $sujet, $message_html, $message_texte = '', $adresse_reponse = null) {
175
		if (!is_array($destinataires)) {
176
			$destinataires = array($destinataires);
177
		}
178
		if ($message_texte == '') {
179
			$message_texte = $this->filtrerChaine($message_html);
180
		}
181
 
182
		$encodage = Config::get('appli_encodage');
183
		$limite = "_----------=_parties_".md5(uniqid(rand()));
184
		$eol = "\n";
185
 
186
		$entetes = '';
187
		// Définition d'un mail en texte simple et html
188
		// multipart/alternative signifie même contenu de la forme la plus simple à la plus complexe
189
		$entetes .= "X-Sender: <http://www.tela-botanica.org>".$eol.
190
		"X-Mailer: PHP-ANNUAIRE-HTML".$eol.
191
		"X-auth-smtp-user: annuaire@tela-botanica.org ".$eol.
192
		"X-abuse-contact: annuaire@tela-botanica.org ".$eol.
193
		'Date: '.date('r').$eol.
194
		'From: '.$expediteur.$eol.
195
		'MIME-Version: 1.0'.$eol;
196
		if ($adresse_reponse !== null) {
197
			$entetes .= 'Reply-To: '.$adresse_reponse.$eol;
198
		}
199
		$entetes .= "Content-Type: multipart/alternative; boundary=\"$limite\";".$eol.$eol;
200
 
201
		// message en texte simple
202
		$contenu = "--$limite".$eol.
203
		"Content-Type: text/plain; charset=\"$encodage\";".$eol.
204
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
205
		$message_texte.$eol.$eol.
206
		// le message en html est préféré s'il est lisible
207
		"--$limite".$eol.
208
		"Content-Type: text/html; charset=\"$encodage\";".$eol.
209
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
210
		$message_html.$eol.$eol.
211
		"--$limite--".$eol.$eol;
212
 
490 aurelien 213
		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
214
		$resultats_envois_echoues = array();
486 aurelien 215
		$ok = true;
216
		foreach ($destinataires as $destinataire) {
217
			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
218
			if (!$ok) {
490 aurelien 219
				$resultats_envois_echoues[] = $destinataire;
486 aurelien 220
			}
221
		}
490 aurelien 222
		return $resultats_envois_echoues;
486 aurelien 223
	}
490 aurelien 224
 
225
	/** Transforme automatiquement le message html en message txt.
226
	 *
227
	 * Réalise un strip_tags et avant ça un remplacement des liens sur mesure pour les mettre au format email txt.
228
	 */
229
	private function filtrerChaine($messageHtml) {
230
		$messageTxt = strip_tags($messageHtml);
231
		if ($messageHtml != $messageTxt) {
232
			$html = $this->ajouterHrefDansBalise($messageHtml);
233
			$messageAvecEntites = strip_tags($html);
234
			// TODO : en précisant l'encodage de l'appli dans html_entity_decode un double encodage UTF-8 se produit...
235
			$messageTxt = html_entity_decode($messageAvecEntites, ENT_QUOTES);
236
		}
237
		return $messageTxt;
238
	}
239
 
240
	/**
241
	 * Extrait la valeur de l'attribut href des balises HTML de liens (a) et ajoute le lien entre
242
	 * chevrons (<>) dans le contenu de la balise "a".
243
	 */
244
	private function ajouterHrefDansBalise($html) {
245
		$dom = new DOMDocument;
246
		$dom->loadHTML($html);
247
		foreach ($dom->getElementsByTagName('a') as $node) {
248
			if ($node->hasAttribute( 'href' )) {
249
				$href = $node->getAttribute('href');
250
				$node->nodeValue = $node->nodeValue." < $href >";
251
			}
252
		}
253
		$html = $dom->saveHtml();
254
		return $html;
255
	}
486 aurelien 256
}
257
?>