Subversion Repositories Applications.annuaire

Rev

Rev 490 | Rev 493 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

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