104,7 → 104,7 |
} |
|
private function obtenirMailsEnAttente() { |
$requete = "SELECT * FROM annu_donnees_temp WHERE statut = '".self::STATUT_A_TRAITER."' "; |
$requete = "SELECT * FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_A_TRAITER."' "; |
$retour = $this->bdd->recupererTous($requete); |
|
return $retour; |
111,8 → 111,8 |
} |
|
private function mettreMailsEnCoursDeTraitement() { |
$requete = "UPDATE annu_donnees_temp SET statut = '".self::STATUT_EN_TRAITEMENT."', date_debut_traitement = NOW() ". |
"WHERE statut = '".self::STATUT_A_TRAITER."' "; |
$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); |
return ($maj !== false); |
} |
132,7 → 132,7 |
} |
|
private function supprimerMailTraite($id) { |
$requete = "DELETE FROM annu_donnees_temp WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ". |
$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' ". |
"AND adt_id = '".$id."'"; |
$supp = $this->bdd->requeter($requete); |
return $supp; |
139,7 → 139,7 |
} |
|
private function supprimerMailsEnCoursDeTraitement() { |
$requete = "DELETE FROM annu_donnees_temp WHERE statut = '".self::STATUT_EN_TRAITEMENT."' "; |
$requete = "DELETE FROM annu_donnees_temp WHERE adt_statut = '".self::STATUT_EN_TRAITEMENT."' "; |
$supp = $this->bdd->requeter($requete); |
return $supp; |
} |
147,9 → 147,9 |
private function remettreATraiterMailsEnRetard() { |
// 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 statut = '".self::STATUT_A_TRAITER."', date_debut_traitement = NULL ". |
"WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ". |
"AND date_debut_traitement < (DATE_SUB(now(), INTERVAL ".self::DELAI_MAX_TRAITEMENT.")) "; |
$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_A_TRAITER."', 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); |