Subversion Repositories eFlore/Applications.del

<?php
// declare(encoding='UTF-8');
/**
 * Le script récupère tous les commentaires et déterminations fait ce jour et envoie un mail
 * aux auteurs des observations récapitulant celle-ci
 *
 * @category    php 5.4
 * @package             DEL
 * @subpackage  Scripts
 * @author              Aurélien PERONNET <aurelien@tela-botanica.org>
 * @copyright   Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
 * @license             CeCILL v2 http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt
 * @license             GNU-GPL http://www.gnu.org/licenses/gpl.html
 */

class AlerteMailADeterminer {

        private $conteneur;

        private $observations_concernees = array();

        public function __construct($conteneur) {
                $this->conteneur = $conteneur;
        }

        public function executer() {
                try {
                        $observations = $this->chargerObsADeterminer();
                        if (!empty($observations)) {
                                $this->formaterObservations($observations);
                                $message = $this->genererMessage();
                                $this->envoyerMessageAuxDestinataires($message);
                        }
                } catch (Exception $e) {
                        $this->traiterErreur($e->getMessage());
                }
        }

        protected function chargerObsADeterminer() {
                //TODO: optimiser la requête si beaucoup de mails sont envoyés
                $requete = "SELECT * ".
                        "FROM del_obs_image AS doi ".
                        "       INNER JOIN del_observation AS do ON doi.id_observation = do.id_observation ".
                        "       LEFT JOIN del_utilisateur AS du ON do.ce_utilisateur = du.id_utilisateur AND do.ce_utilisateur != 0 ".
                        'WHERE (do.mots_cles_texte LIKE "%aDeterminer%" '.
                        '               OR nom_sel IS NULL OR nom_sel = "" '.
                        '               OR nom_ret IS NULL OR nom_ret = "") '.
                        '       AND ('.
                        '               do.date_transmission > DATE_SUB(CURDATE(), INTERVAL 1 DAY) '.
                        '               OR do.date_creation > DATE_SUB(CURDATE(), INTERVAL 1 DAY) '.
                        '               OR do.date_modification > DATE_SUB(CURDATE(), INTERVAL 1 DAY) '.
                        '       ) '.
                        "ORDER BY do.id_observation ";
                $obs = $this->conteneur->getBdd()->recupererTous($requete);
                return $obs;
        }

        private function formaterObservations($liste_obs) {
                foreach ($liste_obs as $obs) {
                        $id_obs = $obs['id_observation'];
                        $obs['date'] = $this->formaterDateObs($obs['date_observation']);
                        $obs['nom_propose'] = $this->formaterNomSci($obs);
                        $obs['lien'] = $this->obtenirLienFicheObs($id_obs);
                        $this->observations_concernees[$id_obs] = $obs;
                }
        }

        private function formaterDateObs($date) {
                $dateFmt = '(date inconnue)';
                if ($date != '0000-00-00 00:00:00') {
                        $time = strtotime($date);
                        $dateFmt = date('d/m/Y', $time);
                }
                return $dateFmt;
        }

        private function formaterNomSci($obs) {
                $nom = '';
                if ($obs['nom_ret'] != '') {
                        $nom = $obs['nom_ret'];
                } else if($obs['nom_sel'] != '') {
                        $nom = $obs['nom_sel'];
                }
                return $nom;
        }

        private function obtenirLienFicheObs($id_obs) {
                return  sprintf($this->conteneur->getParametre('url_fiche_observation'), $id_obs);
        }

        private function genererMessage() {
                $donnees = array();
                $donnees['liste_observations'] = $this->observations_concernees;
                $messageTpl = dirname(__FILE__).DS.'squelettes'.DS.'aDeterminer.tpl.html';
                $squelettePhp = $this->conteneur->getSquelettePhp();
                return $squelettePhp->analyser($messageTpl, $donnees);
        }

        private function envoyerMessageAuxDestinataires($message) {
                $this->envoyerMessageListeDetermination($message);

                $utilisateurs = $this->obtenirDestinatairesMailsRecapitulatif();
                foreach ($utilisateurs as $utilisateur) {
                        $this->envoyerMessage($message, $utilisateur['id_utilisateur']);
                }
        }

        private function obtenirDestinatairesMailsRecapitulatif() {
                $preference = $this->conteneur->getBdd()->proteger('%"mail_notification_toutes_obs":"1"%');
                $requete = "SELECT id_utilisateur ".
                        "FROM del_utilisateur_infos ".
                        "WHERE preferences LIKE $preference ";
                $utilisateurs = $this->conteneur->getBdd()->recupererTous($requete);
                return $utilisateurs;
        }

        /**
         * Appelle le web service message de l'annuaire afin d'envoyer un mail à l'utilisateur dont l'identifiant est donné
         * en paramètre
         * Enter description here ...
         * @param string $message
         * @param int $id_destinataire
         */
        private function envoyerMessage($message, $id_destinataire) {
                $url_requete = sprintf($this->conteneur->getParametre('url_service_messagerie'), $id_destinataire);
                $post = array(
                        'sujet' => 'Récapitulatif des dernières observations à déterminer',
                        'message' => $message,
                        'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'),
                        'format' => 'html'
                );

                $ch = curl_init();
                $options = array(
                        CURLOPT_URL => $url_requete,
                        CURLOPT_HEADER => false,
                        CURLOPT_POST => 1,
                        CURLOPT_POSTFIELDS => $post,
                        CURLOPT_RETURNTRANSFER => true
                );
                curl_setopt_array($ch, $options);
                curl_exec($ch);
                curl_close($ch);
        }

        /** La liste détermination n'étant pas un membre de tela botanica,
        * on lui envoie un message directement
        * @param string $message contenu du mail
        * @return boolean true ou false suivant le succès ou non de l'envoi
        */
        private function envoyerMessageListeDetermination($message) {
                $sujet = 'Récapitulatif des dernières observations à déterminer';
                $message_html = $message;
                $message_texte = $this->supprimerHtml($message);

                $limite = "_----------=_parties_".md5(uniqid (rand()));

                // Définition d'un mail en texte simple et html
                $entetes = "X-Sender: <http://www.tela-botanica.org>\n".
                        "X-Mailer: PHP\n".
                        "X-auth-smtp-user: ".$this->conteneur->getParametre('adresse_expediteur_recapitulatif')." \n".
                        "X-abuse-contact: ".$this->conteneur->getParametre('adresse_expediteur_recapitulatif')." \n".
                        "Date: ".date("D, j M Y G:i:s O")."\n".
                        'From: '.$this->conteneur->getParametre('adresse_expediteur_recapitulatif')."\n".
                        // multipart/alternative signifie même contenu de la forme la plus simple à la plus complexe
                        "Content-Type: multipart/alternative; boundary=\"".$limite."\";\n\n";

                $contenu = // message en texte simple
                        "--".$limite."\n".
                        "Content-Type: text/plain; charset=\"".$this->conteneur->getParametre('encodage_appli')."\";\n".
                        "Content-Transfer-Encoding: 7bit;\n\n".
                        $message_texte."\n".
                        // le message en html est préféré s'il est lisible
                        "--".$limite."\n".
                        "Content-Type: text/html;".
                        "charset=\"".$this->conteneur->getParametre('encodage_appli')."\";\n".
                        "Content-Transfer-Encoding: 7bit;\n\n".
                        $message_html."\n".
                        "--".$limite."--\n";

                $envoieStatut = mail(
                        $this->conteneur->getParametre('adresse_destinataire_recapitulatif_determination'),
                        $this->conteneur->getParametre('titre_message_recapitulatif_obs'),
                        $contenu,
                        $entetes
                );

                return $envoieStatut;
        }

        /** Transforme automatiquement le message html en message txt.
         *
         * Réalise un stip_tags et avant ça un remplacement des liens sur mesure pour les mettre au format email txt.
         */
        private function supprimerHtml($messageHtml) {
                $html = $this->ajouterHrefDansBalise($messageHtml);
                $messageTxt = strip_tags($html);
                return $messageTxt;
        }

        /**
         * Extrait la valeur de l'attribut href des balises HTML de liens (a) et ajoute le lien entre
         * chevrons (<>) dans le contenu de la balise "a".
         */
        private function ajouterHrefDansBalise($html) {
                $dom = new DOMDocument;
                $dom->loadHTML($html);
                foreach ($dom->getElementsByTagName('a') as $node) {
                        if ($node->hasAttribute( 'href' )) {
                                $href = $node->getAttribute('href');
                                $node->nodeValue = $node->nodeValue." ( $href )";
                        }
                }
                $html = $dom->saveHtml();
                return $html;
        }
}
?>