| 16,9 → 16,13 |
|---|
| class AlerteMailCommentaires { |
| |
| private $conteneur; |
| private $testeurCourriel = null; |
| private $recapitulatifAdmin = []; |
| private $messageRecapitulatif = null; |
| |
| private $observations_concernees = array(); |
| private $correspondance_id_obs_auteurs = array(); |
| private $utilisateursInfos = array(); |
| |
| public function __construct($conteneur) { |
| $this->conteneur = $conteneur; |
| 26,6 → 30,7 |
|---|
| |
| public function executer() { |
| try { |
| $this->verifierModeUtilisation(); |
| $observations = $this->chargerObservationsCommentees(); |
| if (!empty($observations)) { |
| $this->formaterObservations($observations); |
| 38,6 → 43,18 |
|---|
| } |
| } |
| |
| 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"%'); |
| 73,51 → 90,68 |
|---|
| 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; |
| $id_auteur_obs = $obs['ce_utilisateur']; |
| |
| $infos = array(); |
| $infos['id'] = $id_obs; |
| $infos['nom_sci'] = $this->formaterNomSci($obs); |
| $infos['date'] = $this->formaterDate($obs['date_observation']); |
| $infos['lieu'] = $this->formaterLieu($obs); |
| $infos['lien'] = $this->obtenirLienFiche($id_obs); |
| $infos['commentaires'] = array(); |
| |
| $this->correspondance_id_obs_auteurs[$id_obs] = $id_auteur_obs; |
| $this->observations_concernees[$id_auteur_obs][$id_obs] = $infos; |
| } |
| } |
| |
| private function formaterDateObs($date) { |
| $time = strtotime($date); |
| return date('d/m/Y', $time); |
| 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 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; |
| private function formaterDate($date) { |
| $dateFmt = '(date inconnue)'; |
| if ($date != '0000-00-00 00:00:00') { |
| $time = strtotime($date); |
| $dateFmt = date('d/m/Y', $time); |
| } |
| if (!empty($obs['lieudit'])) { |
| $lieux[] = $obs['lieudit']; |
| return $dateFmt; |
| } |
| |
| 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; |
| } |
| if (!empty($obs['station'])) { |
| $lieux[] = $obs['station']; |
| } |
| return implode(' > ', $lieux); |
| $lieu = (count($lieuInfos) > 0) ? implode(' > ', $lieuInfos) : '(lieu inconnu)'; |
| return $lieu; |
| } |
| |
| |
| 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); |
| if (preg_match('/^INSEE-C:([0-9]){2}[0-9]{3}$/', $code_zone_geo, $match)) { |
| $code_departement = $match[1]; |
| } |
| 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) { |
| private function obtenirLienFiche($id_obs) { |
| return sprintf($this->conteneur->getParametre('url_fiche_observation'), $id_obs); |
| } |
| |
| 150,10 → 184,10 |
|---|
| 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']])) { |
| $auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']]; |
| if (isset($this->correspondance_id_obs_auteurs[$id_obs])) { |
| $id_auteur_obs = $this->correspondance_id_obs_auteurs[$id_obs]; |
| $commentaire['auteur'] = $this->formaterAuteur($commentaire); |
| $this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire; |
| $this->observations_concernees[$id_auteur_obs][$id_obs]['commentaires'][] = $commentaire; |
| } |
| } |
| } |
| 163,47 → 197,142 |
|---|
| } |
| |
| protected function envoyerMessageAuxDestinataires() { |
| foreach ($this->observations_concernees as $auteur => $liste_obs) { |
| $message = $this->formaterMessagePourAuteur($liste_obs, $auteur); |
| $this->envoyerMessage($message, $auteur); |
| foreach ($this->observations_concernees as $auteurId => $liste_obs) { |
| $donnees = $this->formaterDonneesPourMessage($auteurId, $liste_obs); |
| $messageTxt = $this->formaterMessageTxt($donnees); |
| $messageHtml = $this->formaterMessageHtml($donnees); |
| $this->recapitulatifAdmin[$auteurId] = array('txt' => $messageTxt, 'html' => $messageHtml); |
| |
| if ($this->testeurCourriel == null) { |
| $this->envoyerMessage($messageHtml, $messageTxt, $auteurId); |
| } |
| } |
| if ($this->testeurCourriel == null) { |
| $this->envoyerMessageRecap(); |
| } |
| $this->envoyerMessagesTesteur(); |
| } |
| |
| private function formaterMessagePourAuteur($liste_obs, $auteur) { |
| private function formaterMessageHtml($donnees) { |
| $squelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.html'; |
| $squelettePhp = $this->conteneur->getSquelettePhp(); |
| $msgHtml = $squelettePhp->analyser($squelette, $donnees); |
| return $msgHtml; |
| } |
| |
| private function formaterMessageTxt($donnees) { |
| $squelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.txt'; |
| $squelettePhp = $this->conteneur->getSquelettePhp(); |
| $msgTxt = $squelettePhp->analyser($squelette, $donnees); |
| // Nettoyage des tabulations pour indentation du code PHP |
| $msgTxt = str_replace("\t", '', $msgTxt); |
| return $msgTxt; |
| } |
| |
| private function formaterDonneesPourMessage($auteurId, $liste_obs) { |
| $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']); |
| $infosUtilisateur = $this->telechargerUtilisateurInfos($auteurId); |
| $donnees['auteur_formate'] = $this->formaterIntituleUtilisateur($infosUtilisateur); |
| return $donnees; |
| } |
| |
| $messageSquelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.html'; |
| $squelettePhp = $this->conteneur->getSquelettePhp(); |
| return $squelettePhp->analyser($messageSquelette, $donnees); |
| private function formaterIntituleUtilisateur($infos) { |
| $intituleUtilisateur = isset($infos->intitule) ? $infos->intitule : ''; |
| return $intituleUtilisateur; |
| } |
| |
| protected function envoyerMessage($message, $auteur) { |
| $url_requete = sprintf($this->conteneur->getParametre('url_service_messagerie'), $auteur); |
| $post = array( |
| private function envoyerMessage($messageHtml, $messageTxt, $id_destinataire) { |
| $url = sprintf($this->conteneur->getParametre('url_service_messagerie'), $id_destinataire); |
| $donnees = array( |
| 'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'), |
| 'format' => 'html', |
| 'sujet' => $this->conteneur->getParametre('titre_message_recapitulatif'), |
| 'message' => $message, |
| 'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'), |
| 'format' => 'html' |
| 'message' => $messageHtml, |
| 'message_txt' => $messageTxt |
| ); |
| |
| $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); |
| $clientRest = $this->conteneur->getRestClient(); |
| $clientRest->modifier($url, $donnees); |
| } |
| } |
| ?> |
| |
| private function envoyerMessageRecap() { |
| $msgRecap = $this->obtenirMessageRecap(); |
| $sujet = "IdentiPlante : récapitulatif envoies alertes commentaires"; |
| $messagerie = $this->conteneur->getMessagerie(); |
| $destinataire = $this->conteneur->getParametre('email_recap'); |
| $messagerie->envoyerTxt($destinataire, $sujet, $msgRecap); |
| } |
| |
| private function obtenirMessageRecap() { |
| if ($this->messageRecapitulatif == null) { |
| $msgRecap = ''; |
| $separateur = str_repeat('-', 50); |
| $utilisateursIntitules = $this->obtenirInfosUtilisateurs(); |
| foreach ($this->recapitulatifAdmin as $utilisateurId => $message) { |
| $messageTxt = $message['txt']; |
| $intitule = $utilisateursIntitules[$utilisateurId]; |
| $msgRecap .= "Message envoyé à : $intitule\n\n$messageTxt\n$separateur\n"; |
| } |
| $intituleRecap = implode("\n", $utilisateursIntitules); |
| |
| $msgTpl = "Messages envoyés aux utilisateurs suivant :\n%s\n%s\n%s"; |
| $this->messageRecapitulatif = sprintf($msgTpl, $intituleRecap, $separateur, $msgRecap); |
| } |
| return $this->messageRecapitulatif; |
| } |
| |
| private function envoyerMessagesTesteur() { |
| if ($this->testeurCourriel != null) { |
| $messagerie = $this->conteneur->getMessagerie(); |
| |
| $sujet = "TESTEUR : récapitulatif envoies alertes commentaires"; |
| $msgRecap = $this->obtenirMessageRecap(); |
| $messagerie->envoyerTxt($this->testeurCourriel, $sujet, $msgRecap); |
| |
| $message = $this->recapitulatifAdmin[array_rand($this->recapitulatifAdmin)]; |
| $sujet = "TESTEUR : exemple message HTML - alerte commentaire"; |
| $messagerie->envoyerHtml($this->testeurCourriel, $sujet, $message['html'], $message['txt']); |
| |
| $sujet = "TESTEUR : exemple message TXT - alerte commentaire"; |
| $messagerie->envoyerTxt($this->testeurCourriel, $sujet, $message['txt']); |
| } |
| } |
| |
| private function obtenirInfosUtilisateurs() { |
| $idUtilisateurs = array_keys($this->recapitulatifAdmin); |
| $utilisateursIntitules = []; |
| foreach ($idUtilisateurs as $utilisateurId) { |
| $infosUtilisateur = $this->telechargerUtilisateurInfos($utilisateurId); |
| $intitule = $this->formaterUtilisateurInfos($infosUtilisateur); |
| $utilisateursIntitules[$utilisateurId] = $intitule; |
| } |
| asort($utilisateursIntitules); |
| return $utilisateursIntitules; |
| } |
| |
| private 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); |
| $this->utilisateursInfos[$utilisateurId] = isset($infos->id) ? $infos : $utilisateurId; |
| } |
| return $this->utilisateursInfos[$utilisateurId]; |
| } |
| |
| private 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; |
| } |
| } |