Subversion Repositories Applications.annuaire

Rev

Rev 491 | Rev 503 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 491 Rev 493
Line 102... Line 102...
102
102
103 
		return $envoi_avertissement;
 103 
		return $envoi_avertissement;
Line 104... Line 104...
104 
	}
 104 
	}
105
105
106 
	private function obtenirMailsEnAttente() {
 106 
	private function obtenirMailsEnAttente() {
Line 107... Line 107...
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);
Line 109... Line 109...
109
109
110 
		return $retour;
 110 
		return $retour;
111 
	}
 111 
	}
112
112
113 
	private function mettreMailsEnCoursDeTraitement() {
 113 
	private function mettreMailsEnCoursDeTraitement() {
114 
		$requete = "UPDATE annu_donnees_temp SET statut = '".self::STATUT_EN_TRAITEMENT."', date_debut_traitement = NOW() ".
 114 
		$requete = "UPDATE annu_donnees_temp SET adt_statut = '".self::STATUT_EN_TRAITEMENT."', adt_date_debut_traitement = NOW() ".
Line 115... Line 115...
115 
					"WHERE statut = '".self::STATUT_A_TRAITER."' ";
 115 
					"WHERE adt_statut = '".self::STATUT_A_TRAITER."' ";
Line 130... Line 130...
130 
		$maj = $this->bdd->requeter($requete);
 130 
		$maj = $this->bdd->requeter($requete);
131 
		return $maj;
 131 
		return $maj;
132 
	}
 132 
	}
Line 133... Line 133...
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."'";
137 
		$supp = $this->bdd->requeter($requete);
 137 
		$supp = $this->bdd->requeter($requete);
138 
		return $supp;
 138 
		return $supp;
Line 139... Line 139...
139 
	}
 139 
	}
140
140
141 
	private function supprimerMailsEnCoursDeTraitement() {
 141 
	private function supprimerMailsEnCoursDeTraitement() {
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);
Line 144... Line 144...
144 
		return $supp;
 144 
		return $supp;
145 
	}
 145 
	}
146
146
147 
	private function remettreATraiterMailsEnRetard() {
 147 
	private function remettreATraiterMailsEnRetard() {
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)
Line 150... Line 150...
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 ".
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.")) ";