Subversion Repositories Applications.annuaire

Compare Revisions

Ignore whitespace Rev 501 → Rev 502

/branches/v1.3-balance/scripts/modules/mail/Mail.php
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,25 → 159,37
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) {
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;
}
}