Subversion Repositories Applications.annuaire

Rev

Rev 492 | Rev 502 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 492 Rev 494
Line 43... Line 43...
43
			default:	
43
			default:	
44
		}
44
		}
Line 45... Line 45...
45
		
45
		
46
		if($this->mode_verbeux) {
46
		if($this->mode_verbeux) {
47
			print_r($retour);
47
			print_r($retour);
48
		}
48
		}
Line 49... Line 49...
49
	}
49
	}
50
	
50
	
51
	private function traiterMailsEnAttente() {
51
	private function traiterMailsEnAttente() {
Line 57... Line 57...
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'];
Line 61... Line 61...
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'],
Line 66... Line 66...
66
						$mail_a_moderer['message']);
66
						$mail_a_moderer['message']);
67
				
67
				
68
				if(empty($envois_echoues)) {
68
				if(empty($envois_echoues)) {
Line 82... Line 82...
82
		return $retour;
82
		return $retour;
83
	}
83
	}
Line 84... Line 84...
84
	
84
	
Line 85... Line 85...
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 />";
Line 92... Line 92...
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'),
Line 99... Line 99...
99
				Config::get('mail_moderateur'),
99
				Config::get('mail_moderateur'),
100
				$sujet,
100
				$sujet,
Line 101... Line 101...
101
				$corps_mail_echoue);
101
				$corps_mail_echoue);
102
		
102
		
103
		return $envoi_avertissement;
103
		return $envoi_avertissement;
Line 104... Line 104...
104
	}
104
	}
105
	
105
	
Line 106... Line 106...
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 adt_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
	}
Line 112... Line 112...
112
	
112
	
Line 125... Line 125...
125
		
125
		
126
		$requete = "UPDATE annu_donnees_temp ".
126
		$requete = "UPDATE annu_donnees_temp ".
127
					"SET adt_donnees = '".$mail_mal_traite."' ".
127
					"SET adt_donnees = '".$mail_mal_traite."' ".
Line 128... Line 128...
128
					"WHERE adt_id = '".$mail_a_moderer['adt_id']."'";
128
					"WHERE adt_id = '".$mail_a_moderer['adt_id']."'";
129
		
129
		
130
		$maj = $this->bdd->requeter($requete);
130
		$maj = $this->bdd->requeter($requete);
Line 131... Line 131...
131
		return $maj;
131
		return $maj;
132
	}
132
	}
133
	
133
	
134
	private function supprimerMailTraite($id) {
134
	private function supprimerMailTraite($id) {
135
		$requete = "DELETE FROM annu_donnees_temp WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ".
135
		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
136
					"AND adt_id = '".$id."'";
136
					"AND adt_id = '".$id."'";
Line 137... Line 137...
137
		$supp = $this->bdd->requeter($requete);
137
		$supp = $this->bdd->requeter($requete);
138
		return $supp;
138
		return $supp;
139
	}
139
	}
140
	
140
	
141
	private function supprimerMailsEnCoursDeTraitement() {
141
	private function supprimerMailsEnCoursDeTraitement() {
Line 142... Line 142...
142
		$requete = "DELETE FROM annu_donnees_temp WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ";
142
		$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ";
143
		$supp = $this->bdd->requeter($requete);
143
		$supp = $this->bdd->requeter($requete);
144
		return $supp;
144
		return $supp;
145
	}
145
	}
146
	
146
	
147
	private function remettreATraiterMailsEnRetard() {
147
	private function remettreATraiterMailsEnRetard() {
Line 148... Line 148...
148
		// 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
149
		// (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)
150
		$requete = "UPDATE annu_donnees_temp SET statut = '".self::STATUT_A_TRAITER."', date_debut_traitement = NULL ".
150
		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_A_TRAITER."', adt_date_debut_traitement = NULL ".
Line 151... Line 151...
151
				"WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ".
151
				"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
152
				"AND date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
152
				"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
153
		
153
		
Line 154... Line 154...
154
		$maj = $this->bdd->requeter($requete);
154
		$maj = $this->bdd->requeter($requete);
155
		return ($maj !== false);
155
		return ($maj !== false);
156
	}
156
	}
Line 157... Line 157...
157
	
157
	
158
	private function encoderDonneeTemporaire($donnee) {
158
	private function encoderDonneeTemporaire($donnee) {
159
		return base64_encode(serialize($donnee));
159
		return base64_encode(serialize($donnee));
160
	}
160
	}
161
	
161
	
162
	private function decoderDonneeTemporaire($donnee_encodee) {
162
	private function decoderDonneeTemporaire($donnee_encodee) {
163
		return unserialize(base64_decode($donnee_encodee['adt_donnees']));
163
		return unserialize(base64_decode($donnee_encodee['adt_donnees']));
164
	}
164
	}
165
	
165
	
166
	/** 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.
167
	 * 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.
168
	 *
168
	 *
169
	 * @param string $expediteur l'expediteur du message
169
	 * @param string $expediteur l'expediteur du message
170
	 * @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
171
	 * @param string $sujet sujet du mail
171
	 * @param string $sujet sujet du mail
172
	 * @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
173
	 */
173
	 */
174
	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) {
175
		if (!is_array($destinataires)) {
175
		if (!is_array($destinataires)) {
176
			$destinataires = array($destinataires);
176
			$destinataires = array($destinataires);
177
		}
177
		}
178
		if ($message_texte == '') {
178
		if ($message_texte == '') {
179
			$message_texte = $this->filtrerChaine($message_html);
179
			$message_texte = $this->filtrerChaine($message_html);
180
		}
180
		}
181
	
181
	
182
		$encodage = Config::get('appli_encodage');
182
		$encodage = Config::get('appli_encodage');
183
		$limite = "_----------=_parties_".md5(uniqid(rand()));
183
		$limite = "_----------=_parties_".md5(uniqid(rand()));
184
		$eol = "\n";
184
		$eol = "\n";
185
	
185
	
186
		$entetes = '';
186
		$entetes = '';
187
		// Définition d'un mail en texte simple et html
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
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.
189
		$entetes .= "X-Sender: <http://www.tela-botanica.org>".$eol.
190
		"X-Mailer: PHP-ANNUAIRE-HTML".$eol.
190
		"X-Mailer: PHP-ANNUAIRE-HTML".$eol.
191
		"X-auth-smtp-user: annuaire@tela-botanica.org ".$eol.
191
		"X-auth-smtp-user: annuaire@tela-botanica.org ".$eol.
192
		"X-abuse-contact: annuaire@tela-botanica.org ".$eol.
192
		"X-abuse-contact: annuaire@tela-botanica.org ".$eol.
193
		'Date: '.date('r').$eol.
193
		'Date: '.date('r').$eol.
194
		'From: '.$expediteur.$eol.
194
		'From: '.$expediteur.$eol.
195
		'MIME-Version: 1.0'.$eol;
195
		'MIME-Version: 1.0'.$eol;
196
		if ($adresse_reponse !== null) {
196
		if ($adresse_reponse !== null) {
197
			$entetes .= 'Reply-To: '.$adresse_reponse.$eol;
197
			$entetes .= 'Reply-To: '.$adresse_reponse.$eol;
198
		}
198
		}
199
		$entetes .= "Content-Type: multipart/alternative; boundary=\"$limite\";".$eol.$eol;
199
		$entetes .= "Content-Type: multipart/alternative; boundary=\"$limite\";".$eol.$eol;
200
	
200
	
201
		// message en texte simple
201
		// message en texte simple
202
		$contenu = "--$limite".$eol.
202
		$contenu = "--$limite".$eol.
203
		"Content-Type: text/plain; charset=\"$encodage\";".$eol.
203
		"Content-Type: text/plain; charset=\"$encodage\";".$eol.
204
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
204
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
205
		$message_texte.$eol.$eol.
205
		$message_texte.$eol.$eol.
206
		// 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
207
		"--$limite".$eol.
207
		"--$limite".$eol.
208
		"Content-Type: text/html; charset=\"$encodage\";".$eol.
208
		"Content-Type: text/html; charset=\"$encodage\";".$eol.
209
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
209
		"Content-Transfer-Encoding: 8bit;".$eol.$eol.
210
		$message_html.$eol.$eol.
210
		$message_html.$eol.$eol.
211
		"--$limite--".$eol.$eol;
211
		"--$limite--".$eol.$eol;
212
	
212
	
213
		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
213
		$sujetEncode = mb_encode_mimeheader($sujet, mb_internal_encoding(), "B", "\n");
214
		$resultats_envois_echoues = array();
214
		$resultats_envois_echoues = array();
215
		$ok = true;
215
		$ok = true;
216
		foreach ($destinataires as $destinataire) {
216
		foreach ($destinataires as $destinataire) {
217
			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
217
			$ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
218
			if (!$ok) {
218
			if (!$ok) {
219
				$resultats_envois_echoues[] = $destinataire;
219
				$resultats_envois_echoues[] = $destinataire;
220
			}
220
			}
221
		}
221
		}
222
		return $resultats_envois_echoues;
222
		return $resultats_envois_echoues;
223
	}
223
	}
224
	
224
	
225
	/** Transforme automatiquement le message html en message txt.
225
	/** Transforme automatiquement le message html en message txt.
226
	 *
226
	 *
227
	 * 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.
228
	 */
228
	 */
229
	private function filtrerChaine($messageHtml) {
229
	private function filtrerChaine($messageHtml) {
230
		$messageTxt = strip_tags($messageHtml);
230
		$messageTxt = strip_tags($messageHtml);
231
		if ($messageHtml != $messageTxt) {
231
		if ($messageHtml != $messageTxt) {
232
			$html = $this->ajouterHrefDansBalise($messageHtml);
232
			$html = $this->ajouterHrefDansBalise($messageHtml);
233
			$messageAvecEntites = strip_tags($html);
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...
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);
235
			$messageTxt = html_entity_decode($messageAvecEntites, ENT_QUOTES);
236
		}
236
		}
237
		return $messageTxt;
237
		return $messageTxt;
238
	}
238
	}
239
	
239
	
240
	/**
240
	/**
241
	 * 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
242
	 * chevrons (<>) dans le contenu de la balise "a".
242
	 * chevrons (<>) dans le contenu de la balise "a".
243
	 */
243
	 */
244
	private function ajouterHrefDansBalise($html) {
244
	private function ajouterHrefDansBalise($html) {
245
		$dom = new DOMDocument;
245
		$dom = new DOMDocument;
246
		$dom->loadHTML($html);
246
		$dom->loadHTML($html);
247
		foreach ($dom->getElementsByTagName('a') as $node) {
247
		foreach ($dom->getElementsByTagName('a') as $node) {
248
			if ($node->hasAttribute( 'href' )) {
248
			if ($node->hasAttribute( 'href' )) {
249
				$href = $node->getAttribute('href');
249
				$href = $node->getAttribute('href');