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

 	//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';
+	const STATUT_EN_ECHEC = 'en_echec';
 	// 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
 		$this->bdd = new Bdd();
 		$cmd = $this->getParametre('a');
+		$this->mode_verbeux = $this->getParametre('v');
-		$this->mode_verbeux = $this->getParametre('v');
+		$retour = array();
 		switch($cmd) {
 			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 ?
 			default:
+		}
-		}
+		if($this->mode_verbeux) {
-		if($this->mode_verbeux) {
+			// echo pour que bash capte la sortie et stocke dans le log
-			print_r($retour);
+			echo 'Identifiants des mails traites : '.implode(',', $retour)."--";
+		}
 	}
 	private function traiterMailsEnAttente() {
 		// Gaston Lagaffe
-		$mails_en_retard = $this->remettreATraiterMailsEnRetard();
+		$mails_en_retard = $this->traiterMailsEnRetard();
 		$mails_a_traiter = $this->obtenirMailsEnAttente();
 		$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;
 				$envois_echoues = $this->envoyerMail($mail_a_moderer['expediteur'],
 		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);
+		// echo pour que bash capte la sortie et stocke dans le log
+		echo 'Envoi du mail au moderateur pour signaler un echec '."--";
+		return $envoi_avertissement;
+	}
+	private function avertirModerateurEchecTraitement($mails_en_echec) {
+		$ids_mails_en_echec = array();
+		foreach($mails_en_echec as $mail_echec) {
+			$ids_mails_en_echec[] = $mail_echec['adt_id'];
+		}
+		$corps_mail_mal_traite = "Échec de traitement pour : ".implode(',', $ids_mails_en_echec)." depuis plus de ".self::DELAI_MAX_TRAITEMENT." <br />";
+		$sujet = "Un ou plusieurs mails sont en échec de traitement";
+		$envoi_avertissement = $this->envoyerMail(Config::get('adresse_mail_annuaire'),
+				Config::get('mail_moderateur'),
+				$sujet,
-				Config::get('mail_moderateur'),
+				$corps_mail_mal_traite);
 				$sujet,
-				$corps_mail_echoue);
+		// echo pour que bash capte la sortie et stocke dans le log
+		echo 'Envoi du mail au moderateur pour signaler un traitement en echec depuis trop longtemps '."--";
 		return $envoi_avertissement;
-	}
+	}
 	private function obtenirMailsEnAttente() {
-	private function obtenirMailsEnAttente() {
+		$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
-		$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
+		$retour = $this->bdd->recupererTous($requete);
-		$retour = $this->bdd->recupererTous($requete);
+		// echo pour que bash capte la sortie et stocke dans le log
+		echo 'Il y a '.count($retour).' mails en attente '."--";
 		return $retour;
+	}
 	private function mettreMailsEnCoursDeTraitement() {
 		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ".
-	private function mettreMailsEnCoursDeTraitement() {
+					"WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
-		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ".
+		$maj = $this->bdd->executer($requete);
 		$requete = "UPDATE annu_donnees_temp ".
 					"SET adt_donnees = '".$mail_mal_traite."' ".
 					"WHERE adt_id = '".$mail_a_moderer['adt_id']."'";
-		$maj = $this->bdd->requeter($requete);
+		$maj = $this->bdd->executer($requete);
 		return $maj;
+	}
+	private function supprimerMailTraite($id) {
+		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
-	private function supprimerMailTraite($id) {
+					"AND adt_id = '".$id."'";
-		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
+		// echo pour que bash capte la sortie et stocke dans le log
-					"AND adt_id = '".$id."'";
+		echo'Suppression du mail '.$id.' qui a ete traite '."--";
-		$supp = $this->bdd->requeter($requete);
+		$supp = $this->bdd->executer($requete);
 		return $supp;
 	}
 	private function supprimerMailsEnCoursDeTraitement() {
 		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ";
-		$supp = $this->bdd->requeter($requete);
+		$supp = $this->bdd->executer($requete);
 		return $supp;
 	}
-	private function remettreATraiterMailsEnRetard() {
+	private function traiterMailsEnRetard() {
 		// Les mails a traiter depuis plus de 10 heures sont considérés comme échoués et donc remis à traiter
+		// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
+		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_ECHEC."', adt_date_debut_traitement = NULL ".
-		// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
+				"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
+				"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
+		$maj = $this->bdd->executer($requete);
+		// echo pour que bash capte la sortie et stocke dans le log
+		echo 'Gestion des mails en retard '."--";
+		if($maj !== false) {
+			$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_ECHEC."'";
+			$mails_en_echec = $this->bdd->recupererTous($requete);
-		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_A_TRAITER."', adt_date_debut_traitement = NULL ".
+			// echo pour que bash capte la sortie et stocke dans le log
-				"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
+			echo 'Avertissement, des mails sont en retard : '.count($mails_en_echec)."--";
-				"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
+			$this->avertirModerateurEchecTraitement($mails_en_echec);
+		}
-		$maj = $this->bdd->requeter($requete);
-		return ($maj !== false);
+		return $maj;
+	}
 	private function encoderDonneeTemporaire($donnee) {
 		return base64_encode(serialize($donnee));
 	}
 	private function decoderDonneeTemporaire($donnee_encodee) {
 		return unserialize(base64_decode($donnee_encodee['adt_donnees']));
 	}
 	/** Envoie un mail avec l'adresse de l'utilisateur donné en paramètre, à l'adresse donnée en paramètre.
 	 * ATTENTION : le sujet et le contenu envoyer à cette méthode doivent avoir le même encodage que l'application.
 	 *
 	 * @param string $expediteur l'expediteur du message
 	 * @param mixed $destinataires un string ou un tableau de mails qui contiennent les destinataire
 	 * @param string $sujet sujet du mail
 	 * @return boolean true ou false suivant le succès ou non de l'envoi
 	 */
 	public function envoyerMail($expediteur, $destinataires, $sujet, $message_html, $message_texte = '', $adresse_reponse = null) {
 		if (!is_array($destinataires)) {
 			$destinataires = array($destinataires);
 		}
 		if ($message_texte == '') {
 			$message_texte = $this->filtrerChaine($message_html);
 		}
 		$encodage = Config::get('appli_encodage');
 		$limite = "_----------=_parties_".md5(uniqid(rand()));
 		$eol = "\n";
 		$entetes = '';
 		// Définition d'un mail en texte simple et html
 		// multipart/alternative signifie même contenu de la forme la plus simple à la plus complexe
 		$entetes .= "X-Sender: <http://www.tela-botanica.org>".$eol.
 		"X-Mailer: PHP-ANNUAIRE-HTML".$eol.
 		"X-auth-smtp-user: annuaire@tela-botanica.org ".$eol.
 		"X-abuse-contact: annuaire@tela-botanica.org ".$eol.
 		'Date: '.date('r').$eol.
 		'From: '.$expediteur.$eol.
 		'MIME-Version: 1.0'.$eol;
 		if ($adresse_reponse !== null) {
 			$entetes .= 'Reply-To: '.$adresse_reponse.$eol;
 		}
 		$entetes .= "Content-Type: multipart/alternative; boundary=\"$limite\";".$eol.$eol;
 		// message en texte simple
 		$contenu = "--$limite".$eol.
 		"Content-Type: text/plain; charset=\"$encodage\";".$eol.
 		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
 		$message_texte.$eol.$eol.
 		// le message en html est préféré s'il est lisible
 		"--$limite".$eol.
 		"Content-Type: text/html; charset=\"$encodage\";".$eol.
 		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
+		$message_html.$eol.$eol.
+		"--$limite--".$eol.$eol;
-		$message_html.$eol.$eol.
-		"--$limite--".$eol.$eol;
+		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
+		$resultats_envois_echoues = array();
-		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
+		$ok = true;
-		$resultats_envois_echoues = array();
+		foreach ($destinataires as $destinataire) {
-		$ok = true;
+			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
-		foreach ($destinataires as $destinataire) {
+			if (!$ok) {
-			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
+				// echo pour que bash capte la sortie et stocke dans le log
-			if (!$ok) {
+				echo'Echec envoi a '.$destinataire."\n";
 				$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');

Subversion Repositories Applications.annuaire

(root)/trunk/scripts/modules/mail/Mail.php – Rev 493 → 503