WebSVN – Applications.annuaire – Diff – /trunk/scripts/modules/mail/Mail.php

 * @licence		GPL v3 & CeCILL v2
 * @version		$Id$
 */
-class Mail extends Script {
+class Mail extends Script {
+	//TODO: cette classe est en doublon avec du code de l'annuaire
+	// une fois passé à la dernière version du framework, il faudrait factoriser ces fonctions
 	// dans une lib commune accessible aux scripts et au code standard
 	const STATUT_A_TRAITER = 'a_traiter';
+	const STATUT_EN_TRAITEMENT = 'en_traitement';
+	// Définit le délai au bout du quel on remet des mails en traitement à traiter
+	// au format (avec la syntaxe utilisée avec INTERVAL en SQL)
+	// http://dev.mysql.com/doc/refman/5.0/fr/date-and-time-functions.html
-	const STATUT_EN_TRAITEMENT = 'en_traitement';
+	const DELAI_MAX_TRAITEMENT = '10 HOUR';
 	private $modele = null;
 	public function executer() {
 		$this->bdd = new Bdd();
 		$cmd = $this->getParametre('a');
 		$this->mode_verbeux = $this->getParametre('v');
 		switch($cmd) {
-			case "Tous":
+			case "tous":
+				$retour = $this->traiterMailsEnAttente();
+			break;
+			// TODO: case supplémentaire pour traiter un mail par son id ?
+			// TODO: option "force" pour traiter les mails quelques soient leur statut ?
-				$this->traiterMailsEnAttente();
+			default:
 			break;
 			// TODO: case supplémentaire pour traiter un mail par son id ?
-			// TODO: option "force" pour traiter les mails quelques soient leur statut ?
+		if($this->mode_verbeux) {
 		$retour = array();
 		if(count($mails_a_traiter) > 0 && $this->mettreMailsEnCoursDeTraitement()) {
 			foreach($mails_a_traiter as $donnees_brutes_mail) {
 				$mail_a_moderer = $this->decoderDonneeTemporaire($donnees_brutes_mail);
 				$id_mail = $donnees_brutes_mail['adt_id'];
+				$resultat_envoi = true;
-				$resultat_envoi = $this->envoyerMail($mail_a_moderer['expediteur'],
+				$envois_echoues = $this->envoyerMail($mail_a_moderer['expediteur'],
 						$mail_a_moderer['destinataires'],
 						$mail_a_moderer['sujet'],
 						$mail_a_moderer['message']);
-				if($resultat_envoi) {
+				if(empty($envois_echoues)) {
+					$this->supprimerMailTraite($id_mail);
+				} else {
+					// TODO: supprimer les destinataires qui ont fonctionné, et mettre à jour
+					// le mail dans les données temporaire avec les destinataires qui restent
+					// pour pouvoir finir de l'envoyer
+					$this->avertirModerateurEchecEnvoi($envois_echoues, $mail_a_moderer);
-					$this->supprimerMailTraite($id_mail);
+					$resultat_envoi = false;
+				}
-				}
-				// TODO: logger erreur d'envoi ? envoyer mail récapitulatif
+				// TODO: logger également erreur d'envoi ?
 				$retour[$id_mail] = $resultat_envoi;
+			}
+		}
 		return $retour;
+	}
+	private function avertirModerateurEchecEnvoi($envois_echoues, $mail_a_moderer) {
+		$corps_mail_echoue = "L'envoi d'un mail modéré à échoué pour les destinataires suivants (".count($envois_echoues)." au total) : <br />";
+		$corps_mail_echoue .= implode(", ", $envois_echoues);
+		$corps_mail_echoue .= "<br /><br /><br />";
+		$corps_mail_echoue .= "--- <i> Message original ---</i><br />";
+		$corps_mail_echoue .= "Expéditeur  : ".$mail_a_moderer['expediteur']."<br />";
+		$corps_mail_echoue .= "Sujet  : ".$mail_a_moderer['sujet']."<br />";
+		$corps_mail_echoue .= "Message original : ".$mail_a_moderer['message']."<br />";
+		$sujet = "L'envoi d'un mail modéré a échoué pour un ou plusieurs destinataires";
+		// TODO: Que faire si l'envoi de mail d'avertissement échoue également ?
+		$envoi_avertissement = $this->envoyerMail(Config::get('adresse_mail_annuaire'),
+				Config::get('mail_moderateur'),
+				$sujet,
+				$corps_mail_echoue);
+		return $envoi_avertissement;
+	}
 	private function obtenirMailsEnAttente() {
 		$requete = "SELECT * FROM annu_donnees_temp WHERE statut = '".self::STATUT_A_TRAITER."' ";
 		$supp = $this->bdd->requeter($requete);
 		return $supp;
+	}
+	private function remettreATraiterMailsEnRetard() {
+		// Les mails a traiter depuis plus de 10 heures sont considérés comme échoués et donc remis à traiter
-	private function remettreATraiterMailsEnRetard() {
+		// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
 		$requete = "UPDATE annu_donnees_temp SET statut = '".self::STATUT_A_TRAITER."', date_debut_traitement = NULL ".
 				"WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ".
-				"AND date_debut_traitement < (DATE_SUB(now(), INTERVAL 10 HOUR)) ";
+				"AND date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
 		$maj = $this->bdd->requeter($requete);
 	 */
 	public function envoyerMail($expediteur, $destinataires, $sujet, $message_html, $message_texte = '', $adresse_reponse = null) {
 		if (!is_array($destinataires)) {
 			$destinataires = array($destinataires);
+		}
-		$message_html = $this->encoderChainePourEnvoiMail($message_html);
 		if ($message_texte == '') {
 			$message_texte = $this->filtrerChaine($message_html);
+		}
 		"Content-Type: text/html; charset=\"$encodage\";".$eol.
 		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
 		$message_html.$eol.$eol.
 		"--$limite--".$eol.$eol;
+		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
-		$sujetEncode = mb_encode_mimeheader($this->encoderChainePourEnvoiMail($sujet), $encodage, "B", "\n");
+		$resultats_envois_echoues = array();
 		$ok = true;
 		foreach ($destinataires as $destinataire) {
 			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
+			if (!$ok) {
-			if (!$ok) {
+				$resultats_envois_echoues[] = $destinataire;
+			}
+		}
+		return $resultats_envois_echoues;
+	}
+	/** Transforme automatiquement le message html en message txt.
+	 *
+	 * Réalise un strip_tags et avant ça un remplacement des liens sur mesure pour les mettre au format email txt.
+	 */
+	private function filtrerChaine($messageHtml) {
+		$messageTxt = strip_tags($messageHtml);
+		if ($messageHtml != $messageTxt) {
+			$html = $this->ajouterHrefDansBalise($messageHtml);
+			$messageAvecEntites = strip_tags($html);
+			// TODO : en précisant l'encodage de l'appli dans html_entity_decode un double encodage UTF-8 se produit...
+			$messageTxt = html_entity_decode($messageAvecEntites, ENT_QUOTES);
+		}
+		return $messageTxt;
+	}
+	/**
+	 * Extrait la valeur de l'attribut href des balises HTML de liens (a) et ajoute le lien entre
+	 * chevrons (<>) dans le contenu de la balise "a".
+	 */
+	private function ajouterHrefDansBalise($html) {
+		$dom = new DOMDocument;
+		$dom->loadHTML($html);
+		foreach ($dom->getElementsByTagName('a') as $node) {
+			if ($node->hasAttribute( 'href' )) {
+				$href = $node->getAttribute('href');
-				break;
+				$node->nodeValue = $node->nodeValue." < $href >";
+			}
+		}
-		}
+		$html = $dom->saveHtml();
-		return $ok;
+		return $html;
+	}
+}
 ?>

Subversion Repositories Applications.annuaire

(root)/trunk/scripts/modules/mail/Mail.php – Rev 486 → 490