20,6 → 20,7 |
// 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) |
50,7 → 51,7 |
|
private function traiterMailsEnAttente() { |
// Gaston Lagaffe |
$mails_en_retard = $this->remettreATraiterMailsEnRetard(); |
$mails_en_retard = $this->traiterMailsEnRetard(); |
$mails_a_traiter = $this->obtenirMailsEnAttente(); |
|
$retour = array(); |
99,7 → 100,28 |
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, |
$corps_mail_mal_traite); |
|
// 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; |
} |
|
106,7 → 128,8 |
private function obtenirMailsEnAttente() { |
$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_A_TRAITER."' "; |
$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; |
} |
|
113,7 → 136,9 |
private function mettreMailsEnCoursDeTraitement() { |
$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ". |
"WHERE adt_statut = '".self::STATUT_A_TRAITER."' "; |
$maj = $this->bdd->requeter($requete); |
$maj = $this->bdd->executer($requete); |
// echo pour que bash capte la sortie et stocke dans le log |
echo $maj.' mails ont été mis en traitement '."--"; |
return ($maj !== false); |
} |
|
127,7 → 152,7 |
"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; |
} |
|
134,27 → 159,39 |
private function supprimerMailTraite($id) { |
$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ". |
"AND adt_id = '".$id."'"; |
$supp = $this->bdd->requeter($requete); |
// echo pour que bash capte la sortie et stocke dans le log |
echo'Suppression du mail '.$id.' qui a ete traite '."--"; |
$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_A_TRAITER."', adt_date_debut_traitement = NULL ". |
$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_ECHEC."', adt_date_debut_traitement = NULL ". |
"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ". |
"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) "; |
|
$maj = $this->bdd->requeter($requete); |
return ($maj !== false); |
$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); |
// echo pour que bash capte la sortie et stocke dans le log |
echo 'Avertissement, des mails sont en retard : '.count($mails_en_echec)."--"; |
$this->avertirModerateurEchecTraitement($mails_en_echec); |
} |
|
return $maj; |
} |
|
private function encoderDonneeTemporaire($donnee) { |
return base64_encode(serialize($donnee)); |
} |
216,6 → 253,8 |
foreach ($destinataires as $destinataire) { |
$ok = mail($destinataire, $sujetEncode, $contenu, $entetes); |
if (!$ok) { |
// echo pour que bash capte la sortie et stocke dans le log |
echo'Echec envoi a '.$destinataire."\n"; |
$resultats_envois_echoues[] = $destinataire; |
} |
} |