Subversion Repositories Applications.annuaire

Rev

Rev 504 | Rev 509 | Go to most recent revision | Details | Compare with Previous | 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';
502 aurelien 23
	const STATUT_EN_ECHEC = 'en_echec';
486 aurelien 24
 
490 aurelien 25
	// Définit le délai au bout du quel on remet des mails en traitement à traiter
26
	// au format (avec la syntaxe utilisée avec INTERVAL en SQL)
27
	// http://dev.mysql.com/doc/refman/5.0/fr/date-and-time-functions.html
28
	const DELAI_MAX_TRAITEMENT = '10 HOUR';
29
 
486 aurelien 30
	private $modele = null;
31
 
32
	public function executer() {
33
		$this->bdd = new Bdd();
34
 
35
		$cmd = $this->getParametre('a');
36
		$this->mode_verbeux = $this->getParametre('v');
37
 
503 aurelien 38
		$retour = array();
39
 
486 aurelien 40
		switch($cmd) {
490 aurelien 41
			case "tous":
42
				$retour = $this->traiterMailsEnAttente();
486 aurelien 43
			break;
44
			// TODO: case supplémentaire pour traiter un mail par son id ?
45
			// TODO: option "force" pour traiter les mails quelques soient leur statut ?
46
			default:
490 aurelien 47
		}
48
 
49
		if($this->mode_verbeux) {
503 aurelien 50
			// echo pour que bash capte la sortie et stocke dans le log
51
			echo 'Identifiants des mails traites : '.implode(',', $retour)."--";
494 aurelien 52
		}
486 aurelien 53
	}
54
 
55
	private function traiterMailsEnAttente() {
56
		// Gaston Lagaffe
502 aurelien 57
		$mails_en_retard = $this->traiterMailsEnRetard();
486 aurelien 58
		$mails_a_traiter = $this->obtenirMailsEnAttente();
59
 
60
		$retour = array();
61
		if(count($mails_a_traiter) > 0 && $this->mettreMailsEnCoursDeTraitement()) {
62
			foreach($mails_a_traiter as $donnees_brutes_mail) {
63
				$mail_a_moderer = $this->decoderDonneeTemporaire($donnees_brutes_mail);
64
				$id_mail = $donnees_brutes_mail['adt_id'];
490 aurelien 65
 
494 aurelien 66
				$resultat_envoi = true;
67
				$envois_echoues = $this->envoyerMail($mail_a_moderer['expediteur'],
68
						$mail_a_moderer['destinataires'],
69
						$mail_a_moderer['sujet'],
486 aurelien 70
						$mail_a_moderer['message']);
71
 
490 aurelien 72
				if(empty($envois_echoues)) {
486 aurelien 73
					$this->supprimerMailTraite($id_mail);
490 aurelien 74
				} else {
75
					// TODO: supprimer les destinataires qui ont fonctionné, et mettre à jour
76
					// le mail dans les données temporaire avec les destinataires qui restent
77
					// pour pouvoir finir de l'envoyer
78
					$this->avertirModerateurEchecEnvoi($envois_echoues, $mail_a_moderer);
79
					$resultat_envoi = false;
486 aurelien 80
				}
490 aurelien 81
 
82
				// TODO: logger également erreur d'envoi ?
486 aurelien 83
				$retour[$id_mail] = $resultat_envoi;
84
			}
85
		}
86
		return $retour;
87
	}
88
 
490 aurelien 89
	private function avertirModerateurEchecEnvoi($envois_echoues, $mail_a_moderer) {
90
 
494 aurelien 91
		$corps_mail_echoue = "L'envoi d'un mail modéré à échoué pour les destinataires suivants (".count($envois_echoues)." au total) : <br />";
92
		$corps_mail_echoue .= implode(", ", $envois_echoues);
93
		$corps_mail_echoue .= "<br /><br /><br />";
94
		$corps_mail_echoue .= "--- <i> Message original ---</i><br />";
95
		$corps_mail_echoue .= "Expéditeur  : ".$mail_a_moderer['expediteur']."<br />";
96
		$corps_mail_echoue .= "Sujet  : ".$mail_a_moderer['sujet']."<br />";
490 aurelien 97
		$corps_mail_echoue .= "Message original : ".$mail_a_moderer['message']."<br />";
98
 
494 aurelien 99
		$sujet = "L'envoi d'un mail modéré a échoué pour un ou plusieurs destinataires";
100
 
101
		// TODO: Que faire si l'envoi de mail d'avertissement échoue également ?
102
		$envoi_avertissement = $this->envoyerMail(Config::get('adresse_mail_annuaire'),
103
				Config::get('mail_moderateur'),
104
				$sujet,
490 aurelien 105
				$corps_mail_echoue);
502 aurelien 106
		// echo pour que bash capte la sortie et stocke dans le log
107
		echo 'Envoi du mail au moderateur pour signaler un echec '."--";
108
		return $envoi_avertissement;
109
	}
110
 
111
	private function avertirModerateurEchecTraitement($mails_en_echec) {
490 aurelien 112
 
502 aurelien 113
		$ids_mails_en_echec = array();
114
		foreach($mails_en_echec as $mail_echec) {
115
			$ids_mails_en_echec[] = $mail_echec['adt_id'];
116
		}
117
 
118
		$corps_mail_mal_traite = "Échec de traitement pour : ".implode(',', $ids_mails_en_echec)." depuis plus de ".self::DELAI_MAX_TRAITEMENT." <br />";
119
		$sujet = "Un ou plusieurs mails sont en échec de traitement";
120
 
121
		$envoi_avertissement = $this->envoyerMail(Config::get('adresse_mail_annuaire'),
122
				Config::get('mail_moderateur'),
123
				$sujet,
124
				$corps_mail_mal_traite);
125
 
126
		// echo pour que bash capte la sortie et stocke dans le log
127
		echo 'Envoi du mail au moderateur pour signaler un traitement en echec depuis trop longtemps '."--";
490 aurelien 128
		return $envoi_avertissement;
129
	}
130
 
486 aurelien 131
	private function obtenirMailsEnAttente() {
494 aurelien 132
		$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
486 aurelien 133
		$retour = $this->bdd->recupererTous($requete);
502 aurelien 134
		// echo pour que bash capte la sortie et stocke dans le log
135
		echo 'Il y a '.count($retour).' mails en attente '."--";
486 aurelien 136
		return $retour;
137
	}
138
 
139
	private function mettreMailsEnCoursDeTraitement() {
494 aurelien 140
		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ".
141
					"WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
502 aurelien 142
		$maj = $this->bdd->executer($requete);
143
		// echo pour que bash capte la sortie et stocke dans le log
144
		echo $maj.' mails ont été mis en traitement '."--";
486 aurelien 145
		return ($maj !== false);
146
	}
147
 
491 aurelien 148
	private function mettreAJourMailMalTraite($id_mail_mal_traite, $mail_mal_traite, $envois_echoues) {
149
		// TODO: utiliser cette fonction lors de l'echec de plusieurs destinataires et renvoyer le lien
150
		// de confirmation
151
		$mail_mal_traite['destinataires'] = $envois_echoues;
152
		$mail_mal_traite = $this->encoderDonneeTemporaire($mail_mal_traite);
153
 
154
		$requete = "UPDATE annu_donnees_temp ".
155
					"SET adt_donnees = '".$mail_mal_traite."' ".
156
					"WHERE adt_id = '".$mail_a_moderer['adt_id']."'";
157
 
502 aurelien 158
		$maj = $this->bdd->executer($requete);
491 aurelien 159
		return $maj;
160
	}
161
 
486 aurelien 162
	private function supprimerMailTraite($id) {
494 aurelien 163
		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
164
					"AND adt_id = '".$id."'";
502 aurelien 165
		// echo pour que bash capte la sortie et stocke dans le log
166
		echo'Suppression du mail '.$id.' qui a ete traite '."--";
167
		$supp = $this->bdd->executer($requete);
486 aurelien 168
		return $supp;
169
	}
170
 
494 aurelien 171
	private function supprimerMailsEnCoursDeTraitement() {
172
		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ";
502 aurelien 173
		$supp = $this->bdd->executer($requete);
494 aurelien 174
		return $supp;
486 aurelien 175
	}
176
 
502 aurelien 177
	private function traiterMailsEnRetard() {
490 aurelien 178
		// Les mails a traiter depuis plus de 10 heures sont considérés comme échoués et donc remis à traiter
179
		// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
504 aurelien 180
		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_ECHEC."' ".
494 aurelien 181
				"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
182
				"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
486 aurelien 183
 
502 aurelien 184
		$maj = $this->bdd->executer($requete);
185
		// echo pour que bash capte la sortie et stocke dans le log
186
		echo 'Gestion des mails en retard '."--";
505 aurelien 187
		if($maj !== false && $maj != 0) {
188
			$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_ECHEC."' AND adt_date_debut_traitement IS NOT NULL";
502 aurelien 189
			$mails_en_echec = $this->bdd->recupererTous($requete);
505 aurelien 190
 
502 aurelien 191
			// echo pour que bash capte la sortie et stocke dans le log
192
			echo 'Avertissement, des mails sont en retard : '.count($mails_en_echec)."--";
193
			$this->avertirModerateurEchecTraitement($mails_en_echec);
504 aurelien 194
 
195
			// Réinitialisation de la date pour éviter que l'avertissement soit réenvoyé plusieurs fois
196
			$requete = "UPDATE annu_donnees_temp SET adt_date_debut_traitement = NULL ".
197
					"WHERE adt_statut = '".self::STATUT_EN_ECHEC."' ";
198
			$maj = $this->bdd->executer($requete);
502 aurelien 199
		}
200
 
201
		return $maj;
486 aurelien 202
	}
203
 
494 aurelien 204
	private function encoderDonneeTemporaire($donnee) {
205
		return base64_encode(serialize($donnee));
491 aurelien 206
	}
207
 
494 aurelien 208
	private function decoderDonneeTemporaire($donnee_encodee) {
209
		return unserialize(base64_decode($donnee_encodee['adt_donnees']));
486 aurelien 210
	}
211
 
494 aurelien 212
	/** Envoie un mail avec l'adresse de l'utilisateur donné en paramètre, à l'adresse donnée en paramètre.
213
	 * ATTENTION : le sujet et le contenu envoyer à cette méthode doivent avoir le même encodage que l'application.
214
	 *
215
	 * @param string $expediteur l'expediteur du message
216
	 * @param mixed $destinataires un string ou un tableau de mails qui contiennent les destinataire
217
	 * @param string $sujet sujet du mail
218
	 * @return boolean true ou false suivant le succès ou non de l'envoi
219
	 */
220
	public function envoyerMail($expediteur, $destinataires, $sujet, $message_html, $message_texte = '', $adresse_reponse = null) {
221
		if (!is_array($destinataires)) {
222
			$destinataires = array($destinataires);
223
		}
224
		if ($message_texte == '') {
225
			$message_texte = $this->filtrerChaine($message_html);
226
		}
227
 
228
		$encodage = Config::get('appli_encodage');
229
		$limite = "_----------=_parties_".md5(uniqid(rand()));
230
		$eol = "\n";
231
 
232
		$entetes = '';
233
		// Définition d'un mail en texte simple et html
234
		// multipart/alternative signifie même contenu de la forme la plus simple à la plus complexe
235
		$entetes .= "X-Sender: <http://www.tela-botanica.org>".$eol.
236
		"X-Mailer: PHP-ANNUAIRE-HTML".$eol.
237
		"X-auth-smtp-user: annuaire@tela-botanica.org ".$eol.
238
		"X-abuse-contact: annuaire@tela-botanica.org ".$eol.
239
		'Date: '.date('r').$eol.
240
		'From: '.$expediteur.$eol.
241
		'MIME-Version: 1.0'.$eol;
242
		if ($adresse_reponse !== null) {
243
			$entetes .= 'Reply-To: '.$adresse_reponse.$eol;
244
		}
245
		$entetes .= "Content-Type: multipart/alternative; boundary=\"$limite\";".$eol.$eol;
246
 
247
		// message en texte simple
248
		$contenu = "--$limite".$eol.
249
		"Content-Type: text/plain; charset=\"$encodage\";".$eol.
250
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
251
		$message_texte.$eol.$eol.
252
		// le message en html est préféré s'il est lisible
253
		"--$limite".$eol.
254
		"Content-Type: text/html; charset=\"$encodage\";".$eol.
255
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
256
		$message_html.$eol.$eol.
257
		"--$limite--".$eol.$eol;
258
 
490 aurelien 259
		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
494 aurelien 260
		$resultats_envois_echoues = array();
261
		$ok = true;
262
		foreach ($destinataires as $destinataire) {
263
			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
264
			if (!$ok) {
502 aurelien 265
				// echo pour que bash capte la sortie et stocke dans le log
266
				echo'Echec envoi a '.$destinataire."\n";
494 aurelien 267
				$resultats_envois_echoues[] = $destinataire;
268
			}
269
		}
270
		return $resultats_envois_echoues;
486 aurelien 271
	}
490 aurelien 272
 
494 aurelien 273
	/** Transforme automatiquement le message html en message txt.
274
	 *
275
	 * Réalise un strip_tags et avant ça un remplacement des liens sur mesure pour les mettre au format email txt.
276
	 */
277
	private function filtrerChaine($messageHtml) {
278
		$messageTxt = strip_tags($messageHtml);
279
		if ($messageHtml != $messageTxt) {
280
			$html = $this->ajouterHrefDansBalise($messageHtml);
281
			$messageAvecEntites = strip_tags($html);
282
			// TODO : en précisant l'encodage de l'appli dans html_entity_decode un double encodage UTF-8 se produit...
283
			$messageTxt = html_entity_decode($messageAvecEntites, ENT_QUOTES);
284
		}
285
		return $messageTxt;
490 aurelien 286
	}
287
 
494 aurelien 288
	/**
289
	 * Extrait la valeur de l'attribut href des balises HTML de liens (a) et ajoute le lien entre
290
	 * chevrons (<>) dans le contenu de la balise "a".
291
	 */
292
	private function ajouterHrefDansBalise($html) {
293
		$dom = new DOMDocument;
294
		$dom->loadHTML($html);
295
		foreach ($dom->getElementsByTagName('a') as $node) {
296
			if ($node->hasAttribute( 'href' )) {
297
				$href = $node->getAttribute('href');
298
				$node->nodeValue = $node->nodeValue." < $href >";
299
			}
300
		}
301
		$html = $dom->saveHtml();
302
		return $html;
490 aurelien 303
	}
486 aurelien 304
}
305
?>