Subversion Repositories Applications.annuaire

<?php
// Encodage : UTF-8
// +-------------------------------------------------------------------------------------------------------------------+
/**
* Traitement des mails en attente de modération de l'annuaire
*
* Description : classe permettant de gérer l'envoi des mails en attente de modération dans l'annuaire
* Utilisation : php script.php mail
*
//Auteur original :
* @author       Aurélien PERONNET <jpm@tela-botanica.org>
* @copyright    Tela-Botanica 1999-2014
* @licence              GPL v3 & CeCILL v2
* @version              $Id$
*/

class Mail extends Script {
        
        const STATUT_A_TRAITER = 'a_traiter';
        const STATUT_EN_TRAITEMENT = 'en_traitement';
        
        private $modele = null;
        
        public function executer() {    
                $this->bdd = new Bdd();
                
                $cmd = $this->getParametre('a');
                $this->mode_verbeux = $this->getParametre('v');
                
                switch($cmd) {
                        case "Tous":
                                $this->traiterMailsEnAttente();
                        break;
                        // TODO: case supplémentaire pour traiter un mail par son id ?
                        // TODO: option "force" pour traiter les mails quelques soient leur statut ?
                        default:        
                }
        }
        
        private function traiterMailsEnAttente() {
                // Gaston Lagaffe
                $mails_en_retard = $this->remettreATraiterMailsEnRetard();
                $mails_a_traiter = $this->obtenirMailsEnAttente();
                
                $retour = array();
                if(count($mails_a_traiter) > 0 && $this->mettreMailsEnCoursDeTraitement()) {
                        foreach($mails_a_traiter as $donnees_brutes_mail) {
                                $mail_a_moderer = $this->decoderDonneeTemporaire($donnees_brutes_mail);
                                $id_mail = $donnees_brutes_mail['adt_id'];
                                
                                $resultat_envoi = $this->envoyerMail($mail_a_moderer['expediteur'],
                                                $mail_a_moderer['destinataires'],
                                                $mail_a_moderer['sujet'],
                                                $mail_a_moderer['message']);
                                
                                if($resultat_envoi) {
                                        $this->supprimerMailTraite($id_mail);
                                }
                                // TODO: logger erreur d'envoi ? envoyer mail récapitulatif
                                $retour[$id_mail] = $resultat_envoi;
                        }
                }
                return $retour;
        }
        
        private function obtenirMailsEnAttente() {
                $requete = "SELECT * FROM annu_donnees_temp WHERE statut = '".self::STATUT_A_TRAITER."' ";
                $retour = $this->bdd->recupererTous($requete);
                
                return $retour;
        }
        
        private function mettreMailsEnCoursDeTraitement() {
                $requete = "UPDATE annu_donnees_temp SET statut = '".self::STATUT_EN_TRAITEMENT."', date_debut_traitement = NOW() ".
                                        "WHERE statut = '".self::STATUT_A_TRAITER."' ";
                $maj = $this->bdd->requeter($requete);
                return ($maj !== false);
        }
        
        private function supprimerMailTraite($id) {
                $requete = "DELETE FROM annu_donnees_temp WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ".
                                        "AND adt_id = '".$id."'";
                $supp = $this->bdd->requeter($requete);
                return $supp;
        }
        
        private function supprimerMailsEnCoursDeTraitement() {
                $requete = "DELETE FROM annu_donnees_temp WHERE statut = '".self::STATUT_EN_TRAITEMENT."' ";
                $supp = $this->bdd->requeter($requete);
                return $supp;
        }
        
        private function remettreATraiterMailsEnRetard() {
                $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 10 HOUR)) ";
                
                $maj = $this->bdd->requeter($requete);
                return ($maj !== false);
        }
        
        private function decoderDonneeTemporaire($donnee_encodee) {
                return unserialize(base64_decode($donnee_encodee['adt_donnees']));
        }
        
        /** Envoie un mail avec l'adresse de l'utilisateur donné en paramètre, à l'adresse donnée en paramètre.
         * ATTENTION : le sujet et le contenu envoyer à cette méthode doivent avoir le même encodage que l'application.
         *
         * @param string $expediteur l'expediteur du message
         * @param mixed $destinataires un string ou un tableau de mails qui contiennent les destinataire
         * @param string $sujet sujet du mail
         * @return boolean true ou false suivant le succès ou non de l'envoi
         */
        public function envoyerMail($expediteur, $destinataires, $sujet, $message_html, $message_texte = '', $adresse_reponse = null) {
                if (!is_array($destinataires)) {
                        $destinataires = array($destinataires);
                }
                $message_html = $this->encoderChainePourEnvoiMail($message_html);
                if ($message_texte == '') {
                        $message_texte = $this->filtrerChaine($message_html);
                }
        
                $encodage = Config::get('appli_encodage');
                $limite = "_----------=_parties_".md5(uniqid(rand()));
                $eol = "\n";
        
                $entetes = '';
                // Définition d'un mail en texte simple et html
                // multipart/alternative signifie même contenu de la forme la plus simple à la plus complexe
                $entetes .= "X-Sender: <http://www.tela-botanica.org>".$eol.
                "X-Mailer: PHP-ANNUAIRE-HTML".$eol.
                "X-auth-smtp-user: annuaire@tela-botanica.org ".$eol.
                "X-abuse-contact: annuaire@tela-botanica.org ".$eol.
                'Date: '.date('r').$eol.
                'From: '.$expediteur.$eol.
                'MIME-Version: 1.0'.$eol;
                if ($adresse_reponse !== null) {
                        $entetes .= 'Reply-To: '.$adresse_reponse.$eol;
                }
                $entetes .= "Content-Type: multipart/alternative; boundary=\"$limite\";".$eol.$eol;
        
                // message en texte simple
                $contenu = "--$limite".$eol.
                "Content-Type: text/plain; charset=\"$encodage\";".$eol.
                "Content-Transfer-Encoding: 8bit;".$eol.$eol.
                $message_texte.$eol.$eol.
                // le message en html est préféré s'il est lisible
                "--$limite".$eol.
                "Content-Type: text/html; charset=\"$encodage\";".$eol.
                "Content-Transfer-Encoding: 8bit;".$eol.$eol.
                $message_html.$eol.$eol.
                "--$limite--".$eol.$eol;
        
                $sujetEncode = mb_encode_mimeheader($this->encoderChainePourEnvoiMail($sujet), $encodage, "B", "\n");
                $ok = true;
                foreach ($destinataires as $destinataire) {
                        $ok = mail($destinataire, $sujetEncode, $contenu, $entetes);
                        if (!$ok) {
                                break;
                        }
                }
                return $ok;
        }
}
?>