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; |
} |
} |