| 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');
|