| New file |
|---|
| 0,0 → 1,349 |
|---|
| <?php |
| // declare(encoding='UTF-8'); |
| /** |
| * 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 DEL |
| * @package Scripts |
| * @subpackage ADeterminer |
| * @author Mathias CHOUET <mathias@tela-botanica.org> |
| * @author Jean-Pascal MILCENT <jpm@tela-botanica.org> |
| * @author Aurelien PERONNET <aurelien@tela-botanica.org> |
| * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt> |
| * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt> |
| * @copyright 1999-2014 Tela Botanica <accueil@tela-botanica.org> |
| */ |
| class AlerteMailADeterminer { |
| |
| private $conteneur; |
| private $testeurCourriel = null; |
| private $recapitulatifAdmin = []; |
| private $messageRecapitulatif = null; |
| |
| private $dateRenvoi = null; |
| |
| private $observations_concernees = array(); |
| private $messageHtml = null; |
| private $messageTxt = null; |
| private $utilisateursInfos = array(); |
| |
| public function __construct($conteneur) { |
| $this->conteneur = $conteneur; |
| } |
| |
| public function executer() { |
| try { |
| $this->verifierModeUtilisation(); |
| $this->verifierDateRenvoi(); |
| $observations = $this->chargerObsADeterminer(); |
| if (!empty($observations)) { |
| $this->formaterObservations($observations); |
| $this->genererMessage(); |
| $this->envoyerMessageAuxDestinataires(); |
| } |
| } catch (Exception $e) { |
| $this->traiterErreur($e->getMessage()); |
| } |
| } |
| |
| protected function traiterErreur($msg) { |
| echo "ERREUR: $msg\n"; |
| } |
| |
| 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 verifierDateRenvoi() { |
| $dateRenvoi = $this->conteneur->getParametre('d'); |
| if ($dateRenvoi) { |
| if (preg_match('/^[0-9]{4}-[0-1][0-9]-[0-3][0-9]$/', $dateRenvoi)) { |
| $this->dateRenvoi = $dateRenvoi; |
| } else { |
| $msg = "Veuillez indiquer une date au format yyyy-mm-dd valide à la suite du paramètre «-d»."; |
| new Exception($msg); |
| } |
| } |
| } |
| |
| protected function chargerObsADeterminer() { |
| //TODO: optimiser la requête si beaucoup de mails sont envoyés |
| $date = ($this->dateRenvoi == null) ? 'CURDATE()' : "'$this->dateRenvoi'"; |
| $requete = 'SELECT id_observation, do.courriel_utilisateur, '. |
| ' date_observation, nom_ret, nom_sel, '. |
| ' ce_zone_geo, zone_geo, lieudit, station '. |
| 'FROM del_observation AS do '. |
| 'WHERE do.ce_utilisateur != 0 '. |
| ' AND do.ce_utilisateur IS NOT NULL '. |
| " AND (do.mots_cles_texte LIKE '%aDeterminer%' ". |
| " OR (do.certitude = 'aDeterminer' OR do.certitude = 'A déterminer' OR do.certitude = 'douteux') ". |
| " OR nom_sel IS NULL OR nom_sel = '' ". |
| " OR nom_ret IS NULL OR nom_ret = '') ". |
| ' AND ('. |
| " TO_DAYS($date) - TO_DAYS(do.date_transmission) IN (0, 1) ". |
| " OR TO_DAYS($date) - TO_DAYS(do.date_creation) IN (0, 1) ". |
| " OR TO_DAYS($date) - TO_DAYS(do.date_modification) IN (0, 1) ". |
| ' ) '. |
| "ORDER BY do.id_observation "; |
| $obs = $this->conteneur->getBdd()->recupererTous($requete); |
| return $obs; |
| } |
| |
| private function formaterObservations($liste_obs) { |
| // lister les courriels |
| $courriels = array(); |
| foreach ($liste_obs as $obs) { |
| $courriels[] = $obs['courriel_utilisateur']; |
| } |
| $courriels = array_unique($courriels); |
| $courriels = array_filter($courriels); |
| |
| // récupérer les pseudos |
| $identites = TelaBotanica\Del\Commun\Utilisateurs::identiteUtilisateurs($courriels, $this->conteneur->getParametre('url_service_utilisateur')); |
| |
| // emboîter tout |
| foreach ($liste_obs as $obs) { |
| // identité de l'utilisateur : pseudo, nom-prénom ou courriel tronqué |
| $identiteUtil = $obs['courriel_utilisateur']; // sera tronqué si rien de mieux n'a été trouvé |
| if (isset($identites[$obs['courriel_utilisateur']])) { |
| $identiteUtil = $identites[$obs['courriel_utilisateur']]; |
| } |
| $identiteUtil = TelaBotanica\Del\Commun\Utilisateurs::identiteAAfficher($identiteUtil); |
| |
| $id_obs = $obs['id_observation']; |
| $infos = array(); |
| $infos['id'] = $id_obs; |
| $infos['date'] = $this->formaterDateObs($obs['date_observation']); |
| $infos['nom_propose'] = $this->formaterNomSci($obs); |
| $infos['lien'] = $this->obtenirLienFicheObs($id_obs); |
| $infos['lieu'] = $this->formaterLieu($obs); |
| $infos['auteur'] = $identiteUtil; |
| $this->observations_concernees[$id_obs] = $infos; |
| } |
| } |
| |
| 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 = 'Espèce indéterminée'; |
| 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 formaterLieu($obs) { |
| $lieuInfos = []; |
| $champsLieu = ['zone_geo', 'lieudit', 'station']; |
| foreach ($champsLieu as $champ) { |
| if (trim($obs[$champ]) == '') { |
| continue; |
| } |
| |
| $lieuIntitule = $obs[$champ]; |
| if ($champ == 'zone_geo') { |
| $codeDept = $this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']); |
| $lieuIntitule .= empty($codeDept) ? '' : " ($codeDept)"; |
| } |
| $lieuInfos[] = $lieuIntitule; |
| } |
| $lieu = (count($lieuInfos) > 0) ? implode(' > ', $lieuInfos) : '(lieu inconnu)'; |
| return $lieu; |
| } |
| |
| private function convertirCodeZoneGeoVersDepartement($code_zone_geo) { |
| $code_departement = ''; |
| if (preg_match('/^([0-9]{2})[0-9]{3}$/', $code_zone_geo, $match)) { |
| $code_departement = $match[1]; |
| } |
| return $code_departement; |
| } |
| |
| private function genererMessage() { |
| if ($this->messageHtml == null && $this->messageTxt == null) { |
| $donnees = array(); |
| $donnees['liste_observations'] = $this->observations_concernees; |
| |
| $squelettePhp = $this->conteneur->getSquelettePhp(); |
| $messageHtmlTpl = dirname(__FILE__).DS.'squelettes'.DS.'aDeterminer.tpl.html'; |
| $this->messageHtml = $squelettePhp->analyser($messageHtmlTpl, $donnees); |
| $messageTxtTpl = dirname(__FILE__).DS.'squelettes'.DS.'aDeterminer.tpl.txt'; |
| $this->messageTxt = $squelettePhp->analyser($messageTxtTpl, $donnees); |
| } |
| } |
| |
| private function envoyerMessageAuxDestinataires() { |
| if ($this->testeurCourriel == null) { |
| $this->envoyerMessageAuxUtilisateurs(); |
| $this->envoyerMessageListeDetermination(); |
| $this->envoyerMessageRecap(); |
| } else { |
| $this->envoyerMessageTesteur(); |
| } |
| } |
| |
| private function envoyerMessageAuxUtilisateurs() { |
| $utilisateurs = $this->obtenirDestinatairesMailsRecapitulatif(); |
| foreach ($utilisateurs as $idUtilisateur) { |
| $this->envoyerMessage($idUtilisateur); |
| } |
| } |
| |
| private function obtenirDestinatairesMailsRecapitulatif() { |
| if (count($this->recapitulatifAdmin) == 0) { |
| $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); |
| |
| foreach ($utilisateurs as $utilisateur) { |
| $this->recapitulatifAdmin[] = $utilisateur['id_utilisateur']; |
| } |
| } |
| return $this->recapitulatifAdmin; |
| } |
| |
| /** |
| * 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($id_destinataire) { |
| $url = sprintf($this->conteneur->getParametre('url_service_messagerie'), $id_destinataire); |
| $dateFmt = $this->formaterDateCourante(); |
| $sujet = sprintf($this->conteneur->getParametre('titre_message_recapitulatif_obs'), $dateFmt); |
| |
| $donnees = array( |
| 'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'), |
| 'format' => 'html', |
| 'sujet' => $sujet, |
| 'message' => $this->messageHtml, |
| 'message_txt' => $this->messageTxt |
| ); |
| |
| $clientRest = $this->conteneur->getRestClient(); |
| $clientRest->modifier($url, $donnees); |
| } |
| |
| private function formaterDateCourante() { |
| $date = ($this->dateRenvoi == null) ? time() : strtotime($this->dateRenvoi); |
| $dateFmt = date('d-m-Y', $date); |
| return $dateFmt; |
| } |
| |
| /** La liste détermination n'étant pas un membre de tela botanica, |
| * on lui envoie un message directement |
| * @return boolean true ou false suivant le succès ou non de l'envoi |
| */ |
| private function envoyerMessageListeDetermination() { |
| $destinataires = $this->conteneur->getParametre('adresse_destinataire_recapitulatif_determination'); |
| $dateFmt = $this->formaterDateCourante(); |
| $sujet = sprintf($this->conteneur->getParametre('titre_message_recapitulatif_obs'), $dateFmt); |
| |
| $messagerie = $this->conteneur->getMessagerie(); |
| $envoieStatut = $messagerie->envoyerHtml($destinataires, $sujet, $this->messageHtml, $this->messageTxt); |
| return $envoieStatut; |
| } |
| |
| private function envoyerMessageRecap() { |
| $msgRecap = $this->obtenirMessageRecap(); |
| $dateFmt = $this->formaterDateCourante(); |
| $sujet = "IdentiPlante : obs du $dateFmt"; |
| $messagerie = $this->conteneur->getMessagerie(); |
| $destinataire = $this->conteneur->getParametre('email_recap'); |
| $messagerie->envoyerTxt($destinataire, $sujet, $msgRecap); |
| } |
| |
| private function obtenirMessageRecap() { |
| if ($this->messageRecapitulatif == null) { |
| $utilisateursIntitules = $this->obtenirInfosUtilisateurs(); |
| $intituleRecap = implode("\n", $utilisateursIntitules); |
| $separateur = str_repeat('-', 50); |
| $msgTpl = "Messages envoyés aux utilisateurs suivant :\n%s\n%s\n%s"; |
| $this->messageRecapitulatif = sprintf($msgTpl, $intituleRecap, $separateur, $this->messageTxt); |
| } |
| return $this->messageRecapitulatif; |
| } |
| |
| private function obtenirInfosUtilisateurs() { |
| $utilisateursIntitules = []; |
| $utilisateurs = $this->obtenirDestinatairesMailsRecapitulatif(); |
| foreach ($utilisateurs as $utilisateurId) { |
| $infosUtilisateur = $this->telechargerUtilisateurInfos($utilisateurId); |
| $intitule = $this->formaterUtilisateurInfos($infosUtilisateur); |
| $utilisateursIntitules[$utilisateurId] = $intitule; |
| } |
| asort($utilisateursIntitules); |
| return $utilisateursIntitules; |
| } |
| |
| protected function telechargerUtilisateurInfos($utilisateurId) { |
| if (! isset($this->utilisateursInfos[$utilisateurId])) { |
| $urlTpl = $this->conteneur->getParametre('url_service_utilisateur'); |
| $url = sprintf($urlTpl, $utilisateurId); |
| $clientRest = $this->conteneur->getRestClient(); |
| $json = $clientRest->consulter($url); |
| $infos = json_decode($json, true); |
| if (is_array($infos)) { |
| $infos = array_shift($infos); |
| } |
| $this->utilisateursInfos[$utilisateurId] = isset($infos['id']) ? $infos : $utilisateurId; |
| } |
| return $this->utilisateursInfos[$utilisateurId]; |
| } |
| |
| protected function formaterUtilisateurInfos($infos) { |
| $utilisateurId = isset($infos['id']) ? $infos['id'] : intval($infos); |
| if (isset($infos['courriel']) && isset($infos['intitule'])) { |
| $prenomNom = $infos['nom'].' '.$infos['prenom']; |
| $pseudo = empty($infos['pseudo']) ? '' : '['.$infos['pseudo'].'] '; |
| $courriel = $infos['courriel']; |
| $intitule = "$prenomNom $pseudo($courriel) - id#$utilisateurId"; |
| } else { |
| $intitule = "Utilisateur avec id $utilisateurId introuvable"; |
| } |
| return $intitule; |
| } |
| |
| private function envoyerMessageTesteur() { |
| if ($this->testeurCourriel != null) { |
| $messagerie = $this->conteneur->getMessagerie(); |
| $dateFmt = $this->formaterDateCourante(); |
| |
| $sujet = "TESTEUR : obs du $dateFmt"; |
| $msgRecap = $this->obtenirMessageRecap(); |
| $messagerie->envoyerTxt($this->testeurCourriel, $sujet, $msgRecap); |
| |
| $sujet = "TESTEUR : HTML - obs du $dateFmt"; |
| $messagerie->envoyerHtml($this->testeurCourriel, $sujet, $this->messageHtml, $this->messageTxt); |
| |
| $sujet = "TESTEUR : TXT - obs du $dateFmt"; |
| $messagerie->envoyerTxt($this->testeurCourriel, $sujet, $this->messageTxt); |
| } |
| } |
| } |