| Line 175... |
Line 175... |
| 175 |
}
|
175 |
}
|
| Line 176... |
Line 176... |
| 176 |
|
176 |
|
| 177 |
private function traiterMailsEnRetard() {
|
177 |
private function traiterMailsEnRetard() {
|
| 178 |
// Les mails a traiter depuis plus de 10 heures sont considérés comme échoués et donc remis à traiter
|
178 |
// Les mails a traiter depuis plus de 10 heures sont considérés comme échoués et donc remis à traiter
|
| 179 |
// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
|
179 |
// (en cas de plantage du script ou du serveur de mail pendant leur traitement)
|
| 180 |
$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_ECHEC."', adt_date_debut_traitement = NULL ".
|
180 |
$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_ECHEC."' ".
|
| 181 |
"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
|
181 |
"WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ".
|
| Line 182... |
Line 182... |
| 182 |
"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
|
182 |
"AND adt_date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) ";
|
| 183 |
|
183 |
|
| 184 |
$maj = $this->bdd->executer($requete);
|
184 |
$maj = $this->bdd->executer($requete);
|
| 185 |
// echo pour que bash capte la sortie et stocke dans le log
|
185 |
// echo pour que bash capte la sortie et stocke dans le log
|
| 186 |
echo 'Gestion des mails en retard '."--";
|
186 |
echo 'Gestion des mails en retard '."--";
|
| 187 |
if($maj !== false) {
|
187 |
if($maj !== false && $maj != 0) {
|
| - |
|
188 |
$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_ECHEC."' AND adt_date_debut_traitement IS NOT NULL";
|
| 188 |
$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_ECHEC."'";
|
189 |
$mails_en_echec = $this->bdd->recupererTous($requete);
|
| 189 |
$mails_en_echec = $this->bdd->recupererTous($requete);
|
190 |
|
| 190 |
// echo pour que bash capte la sortie et stocke dans le log
|
191 |
// echo pour que bash capte la sortie et stocke dans le log
|
| - |
|
192 |
echo 'Avertissement, des mails sont en retard : '.count($mails_en_echec)."--";
|
| - |
|
193 |
$this->avertirModerateurEchecTraitement($mails_en_echec);
|
| - |
|
194 |
|
| - |
|
195 |
// Réinitialisation de la date pour éviter que l'avertissement soit réenvoyé plusieurs fois
|
| - |
|
196 |
$requete = "UPDATE annu_donnees_temp SET adt_date_debut_traitement = NULL ".
|
| 191 |
echo 'Avertissement, des mails sont en retard : '.count($mails_en_echec)."--";
|
197 |
"WHERE adt_statut = '".self::STATUT_EN_ECHEC."' ";
|
| Line 192... |
Line 198... |
| 192 |
$this->avertirModerateurEchecTraitement($mails_en_echec);
|
198 |
$maj = $this->bdd->executer($requete);
|
| 193 |
}
|
199 |
}
|