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-2014, 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 AlerteMailCommentaires {

        private $conteneur;
        private $testeurCourriel = null;
        private $recapitulatifAdmin = [];

        private $observations_concernees = array();
        private $correspondance_id_obs_auteurs = array();

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

        public function executer() {
                try {
                        $this->verifierModeUtilisation();
                        $observations = $this->chargerObservationsCommentees();
                        if (!empty($observations)) {
                                $this->formaterObservations($observations);
                                $commentaires = $this->chargerCommentairesDuJour();
                                $this->formaterCommentaires($commentaires);
                                $this->envoyerMessageAuxDestinataires();
                        }
                } catch (Exception $e) {
                        $this->traiterErreur($e->getMessage());
                }
        }

        private function verifierModeUtilisation() {
                $testeurCourriel = $this->conteneur->getParametre('t');
                if ($testeurCourriel) {
                        if (filter_var($testeurCourriel, FILTER_VALIDATE_EMAIL)) {
                                $this->testeurCourriel = $testeurCourriel;
                        } else {
                                $msg = "Veuillez indiquer une adresse de courriel valide à la suite du paramètre «-t».";
                                new Exception($msg);
                        }
                }
        }

        private function chargerObservationsCommentees() {
                // Seuls les utilisateurs ayant explicitement refusé le mail sont ignorés
                $preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
                //TODO: optimiser la requête si beaucoup de mails sont envoyés
                $requete = "SELECT * FROM del_observation AS do ".
                        "WHERE do.id_observation IN ".
                                "( ".
                                        //TODO: essayer de factoriser cette sous requete entre ici et la fonction du dessus
                                        "SELECT dc.ce_observation ".
                                        "FROM del_commentaire AS dc ".
                                        "WHERE dc.ce_observation != '0' ".
                                        "AND dc.id_commentaire NOT IN ".
                                        "( ".
                                        "       SELECT dc.id_commentaire ".
                                        "       FROM del_commentaire AS dc, del_observation AS dob".
                                        "       WHERE dc.nom_sel = dob.nom_sel ".
                                        "               AND dc.ce_utilisateur = dob.ce_utilisateur ".
                                        "               AND dc.ce_observation = dob.id_observation ".
                                        ") ".
                                        "AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
                                ") ".
                                "AND do.ce_utilisateur NOT IN ".
                                        "( ".
                                        "       SELECT id_utilisateur ".
                                        "       FROM del_utilisateur_infos ".
                                        "       WHERE preferences LIKE $preferences ".
                                        ") ".
                        "ORDER BY do.ce_utilisateur, do.id_observation ";
                $observations = $this->conteneur->getBdd()->recupererTous($requete);
                return $observations;
        }

        private function formaterObservations($liste_obs) {
                foreach ($liste_obs as $obs) {
                        $id_obs = $obs['id_observation'];
                        $auteur_obs = $obs['ce_utilisateur'];
                        $obs['date'] = $this->formaterDateObs($obs['date_observation']);
                        $obs['lieu'] = $this->formaterLieuObservation($obs);
                        $obs['lien'] = $this->obtenirLienFicheObs($obs['id_observation']);
                        $obs['commentaires'] = array();
                        $this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
                        $this->observations_concernees[$auteur_obs][$id_obs] = $obs;
                }
        }

        private function formaterDateObs($date) {
                $time = strtotime($date);
                return date('d/m/Y', $time);
        }

        private function formaterLieuObservation($obs) {
                $lieux = array();
                if (!empty($obs['zone_geo'])) {
                        $zone_geo = $obs['zone_geo'];
                        $zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
                        $lieux[] = $zone_geo;
                }
                if (!empty($obs['lieudit'])) {
                        $lieux[] = $obs['lieudit'];
                }
                if (!empty($obs['station'])) {
                        $lieux[] = $obs['station'];
                }
                return implode(' > ', $lieux);
        }


        private function convertirCodeZoneGeoVersDepartement($code_zone_geo) {
                $code_departement = '';
                if ($this->estUnCodeInseeDepartement($code_zone_geo)) {
                        $code_departement = substr(ltrim($code_zone_geo, 'INSEE-C:'), 0, 2);
                }
                return $code_departement;
        }

        private function estUnCodeInseeDepartement($code_a_tester) {
                return preg_match('/^INSEE-C:[0-9]{5}/', $code_a_tester);
        }

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

        protected function chargerCommentairesDuJour() {
                $preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
                // TODO: optimiser la requête si beaucoup de mails sont envoyés
                $requete = "SELECT * ".
                        "FROM del_commentaire AS dc ".
                        "WHERE dc.ce_observation != '0' ".
                        "AND dc.id_commentaire NOT IN ".
                        "( ".
                        "       SELECT dc.id_commentaire ".
                        "       FROM del_commentaire AS dc, del_observation AS dob".
                        "       WHERE dc.nom_sel = dob.nom_sel ".
                        "               AND dc.ce_utilisateur = dob.ce_utilisateur ".
                        "               AND dc.ce_observation = dob.id_observation ".
                        ") ".
                        "AND dc.ce_utilisateur NOT IN ".
                        "( ".
                        "       SELECT id_utilisateur ".
                        "       FROM del_utilisateur_infos ".
                        "       WHERE preferences LIKE $preferences ".
                        ") ".
                        "AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
                        "ORDER BY dc.ce_observation";
                $commentaires = $this->conteneur->getBdd()->recupererTous($requete);
                return $commentaires;
        }

        protected function formaterCommentaires($liste_commentaires) {
                foreach ($liste_commentaires as $commentaire) {
                        $id_obs = $commentaire['ce_observation'];
                        if (isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
                                $id_auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']];
                                $commentaire['auteur'] = $this->formaterAuteur($commentaire);
                                $this->observations_concernees[$id_auteur_obs][$id_obs]['commentaires'][] = $commentaire;
                        }
                }
        }

        private function formaterAuteur($commentaire) {
                return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
        }

        protected function envoyerMessageAuxDestinataires() {
                foreach ($this->observations_concernees as $auteurId => $liste_obs) {
                        $message = $this->formaterMessagePourAuteur($liste_obs, $auteurId);
                        if ($this->testeurCourriel == null) {
                                $this->envoyerMessage($message, $auteurId);
                        }
                        $this->recapitulatifAdmin[$auteurId] = $message;
                }
                $this->envoyerMessageTesteur();
        }

        private function formaterMessagePourAuteur($liste_obs, $auteur) {
                $donnees = array();
                // copie de la première obs pour en obtenir le nom et prénom de l'auteur
                // (en deux fois pour éviter un warning en mode strict)
                $valeurs = array_values($liste_obs);
                $premiere_obs = array_shift($valeurs);
                $donnees['liste_observations'] = $liste_obs;
                $donnees['auteur'] = $auteur;
                $donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);

                $messageSquelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.html';
                $squelettePhp = $this->conteneur->getSquelettePhp();
                return $squelettePhp->analyser($messageSquelette, $donnees);
        }

        private function envoyerMessage($message, $id_destinataire) {
                $url = sprintf($this->conteneur->getParametre('url_service_messagerie'), $id_destinataire);
                $donnees = array(
                        'sujet' => $this->conteneur->getParametre('titre_message_recapitulatif'),
                        'message' => $message,
                        'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'),
                        'format' => 'html'
                );

                $clientRest = $this->conteneur->getRestClient();
                $clientRest->modifier($url, $donnees);
        }

        private function envoyerMessageTesteur() {
                if ($this->testeurCourriel != null) {
                        $clientRest = $this->conteneur->getRestClient();
                        $urlTpl = $this->conteneur->getParametre('url_service_utilisateur');

                        $msgRecap = '';
                        foreach ($this->recapitulatifAdmin as $utilisateurId => $message) {
                                $url = sprintf($urlTpl, $utilisateurId);
                                $json = $clientRest->consulter($url);
                                $infosUtilisateur = json_decode($json);
                                if (isset($infosUtilisateur->courriel) && isset($infosUtilisateur->intitule)) {
                                        $intitule = $infosUtilisateur->intitule.' ('.$infosUtilisateur->courriel.')';
                                } else {
                                        $intitule = "Utilisateur avec id $utilisateurId introuvable";
                                }
                                $separateur = str_repeat('-', 50);

                                $msgRecap += "Message envoyé à : $intitule\n$message\n$separateur\n";
                        }
                        $this->envoyerMessage($msgRecap, $this->testeurCourriel);
                }
        }
}