1020 |
aurelien |
1 |
<?php
|
|
|
2 |
// declare(encoding='UTF-8');
|
|
|
3 |
/**
|
|
|
4 |
* Le script récupère tous les commentaires et déterminations fait ce jour et envoie un mail
|
|
|
5 |
* aux auteurs des observations récapitulant celle-ci
|
|
|
6 |
*
|
1683 |
jpm |
7 |
* @category php 5.4
|
|
|
8 |
* @package DEL
|
|
|
9 |
* @subpackage Scripts
|
1020 |
aurelien |
10 |
* @author Aurélien PERONNET <aurelien@tela-botanica.org>
|
1683 |
jpm |
11 |
* @copyright Copyright (c) 2012-2014, Tela Botanica (accueil@tela-botanica.org)
|
|
|
12 |
* @license CeCILL v2 http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt
|
|
|
13 |
* @license GNU-GPL http://www.gnu.org/licenses/gpl.html
|
1020 |
aurelien |
14 |
*/
|
|
|
15 |
|
|
|
16 |
class AlerteMailCommentaires {
|
|
|
17 |
|
|
|
18 |
private $conteneur;
|
1571 |
jpm |
19 |
|
1020 |
aurelien |
20 |
private $observations_concernees = array();
|
|
|
21 |
private $correspondance_id_obs_auteurs = array();
|
1571 |
jpm |
22 |
|
1683 |
jpm |
23 |
public function __construct($conteneur) {
|
1020 |
aurelien |
24 |
$this->conteneur = $conteneur;
|
|
|
25 |
}
|
1571 |
jpm |
26 |
|
1020 |
aurelien |
27 |
public function executer() {
|
|
|
28 |
try {
|
|
|
29 |
$observations = $this->chargerObservationsCommentees();
|
1571 |
jpm |
30 |
if (!empty($observations)) {
|
1349 |
aurelien |
31 |
$this->formaterObservations($observations);
|
1683 |
jpm |
32 |
$commentaires = $this->chargerCommentairesDuJour();
|
1349 |
aurelien |
33 |
$this->formaterCommentaires($commentaires);
|
1683 |
jpm |
34 |
$this->envoyerMessageAuxDestinataires();
|
1349 |
aurelien |
35 |
}
|
1020 |
aurelien |
36 |
} catch (Exception $e) {
|
|
|
37 |
$this->traiterErreur($e->getMessage());
|
|
|
38 |
}
|
|
|
39 |
}
|
|
|
40 |
|
1683 |
jpm |
41 |
private function chargerObservationsCommentees() {
|
1649 |
aurelien |
42 |
// Seuls les utilisateurs ayant explicitement refusé le mail sont ignorés
|
1571 |
jpm |
43 |
$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
|
1020 |
aurelien |
44 |
//TODO: optimiser la requête si beaucoup de mails sont envoyés
|
1571 |
jpm |
45 |
$requete = "SELECT * FROM del_observation AS do ".
|
1575 |
jpm |
46 |
"WHERE do.id_observation IN ".
|
|
|
47 |
"( ".
|
1678 |
aurelien |
48 |
//TODO: essayer de factoriser cette sous requete entre ici et la fonction du dessus
|
1575 |
jpm |
49 |
"SELECT dc.ce_observation ".
|
|
|
50 |
"FROM del_commentaire AS dc ".
|
|
|
51 |
"WHERE dc.ce_observation != '0' ".
|
|
|
52 |
"AND dc.id_commentaire NOT IN ".
|
1571 |
jpm |
53 |
"( ".
|
1575 |
jpm |
54 |
" SELECT dc.id_commentaire ".
|
|
|
55 |
" FROM del_commentaire AS dc, del_observation AS dob".
|
|
|
56 |
" WHERE dc.nom_sel = dob.nom_sel ".
|
|
|
57 |
" AND dc.ce_utilisateur = dob.ce_utilisateur ".
|
|
|
58 |
" AND dc.ce_observation = dob.id_observation ".
|
|
|
59 |
") ".
|
|
|
60 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
|
|
61 |
") ".
|
1649 |
aurelien |
62 |
"AND do.ce_utilisateur NOT IN ".
|
|
|
63 |
"( ".
|
|
|
64 |
" SELECT id_utilisateur ".
|
|
|
65 |
" FROM del_utilisateur_infos ".
|
|
|
66 |
" WHERE preferences LIKE $preferences ".
|
|
|
67 |
") ".
|
1575 |
jpm |
68 |
"ORDER BY do.ce_utilisateur, do.id_observation ";
|
1020 |
aurelien |
69 |
$observations = $this->conteneur->getBdd()->recupererTous($requete);
|
|
|
70 |
return $observations;
|
|
|
71 |
}
|
1571 |
jpm |
72 |
|
1683 |
jpm |
73 |
private function formaterObservations($liste_obs) {
|
1020 |
aurelien |
74 |
foreach ($liste_obs as $obs) {
|
|
|
75 |
$id_obs = $obs['id_observation'];
|
|
|
76 |
$auteur_obs = $obs['ce_utilisateur'];
|
|
|
77 |
$obs['date'] = $this->formaterDateObs($obs['date_observation']);
|
1348 |
aurelien |
78 |
$obs['lieu'] = $this->formaterLieuObservation($obs);
|
1036 |
aurelien |
79 |
$obs['lien'] = $this->obtenirLienFicheObs($obs['id_observation']);
|
1276 |
aurelien |
80 |
$obs['commentaires'] = array();
|
1020 |
aurelien |
81 |
$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
|
|
|
82 |
$this->observations_concernees[$auteur_obs][$id_obs] = $obs;
|
|
|
83 |
}
|
|
|
84 |
}
|
1571 |
jpm |
85 |
|
1683 |
jpm |
86 |
private function formaterDateObs($date) {
|
|
|
87 |
$time = strtotime($date);
|
|
|
88 |
return date('d/m/Y', $time);
|
|
|
89 |
}
|
|
|
90 |
|
|
|
91 |
private function formaterLieuObservation($obs) {
|
1348 |
aurelien |
92 |
$lieux = array();
|
1571 |
jpm |
93 |
if (!empty($obs['zone_geo'])) {
|
1348 |
aurelien |
94 |
$zone_geo = $obs['zone_geo'];
|
|
|
95 |
$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
|
|
|
96 |
$lieux[] = $zone_geo;
|
|
|
97 |
}
|
1571 |
jpm |
98 |
if (!empty($obs['lieudit'])) {
|
1348 |
aurelien |
99 |
$lieux[] = $obs['lieudit'];
|
|
|
100 |
}
|
1571 |
jpm |
101 |
if (!empty($obs['station'])) {
|
1348 |
aurelien |
102 |
$lieux[] = $obs['station'];
|
|
|
103 |
}
|
1683 |
jpm |
104 |
return implode(' > ', $lieux);
|
1348 |
aurelien |
105 |
}
|
1571 |
jpm |
106 |
|
1683 |
jpm |
107 |
|
|
|
108 |
private function convertirCodeZoneGeoVersDepartement($code_zone_geo) {
|
|
|
109 |
$code_departement = '';
|
|
|
110 |
if ($this->estUnCodeInseeDepartement($code_zone_geo)) {
|
|
|
111 |
$code_departement = substr(ltrim($code_zone_geo, 'INSEE-C:'), 0, 2);
|
|
|
112 |
}
|
|
|
113 |
return $code_departement;
|
|
|
114 |
}
|
|
|
115 |
|
|
|
116 |
private function estUnCodeInseeDepartement($code_a_tester) {
|
|
|
117 |
return preg_match('/^INSEE-C:[0-9]{5}/', $code_a_tester);
|
|
|
118 |
}
|
|
|
119 |
|
|
|
120 |
private function obtenirLienFicheObs($id_obs) {
|
|
|
121 |
return sprintf($this->conteneur->getParametre('url_fiche_observation'), $id_obs);
|
|
|
122 |
}
|
|
|
123 |
|
|
|
124 |
protected function chargerCommentairesDuJour() {
|
|
|
125 |
$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
|
|
|
126 |
// TODO: optimiser la requête si beaucoup de mails sont envoyés
|
|
|
127 |
$requete = "SELECT * ".
|
|
|
128 |
"FROM del_commentaire AS dc ".
|
|
|
129 |
"WHERE dc.ce_observation != '0' ".
|
|
|
130 |
"AND dc.id_commentaire NOT IN ".
|
|
|
131 |
"( ".
|
|
|
132 |
" SELECT dc.id_commentaire ".
|
|
|
133 |
" FROM del_commentaire AS dc, del_observation AS dob".
|
|
|
134 |
" WHERE dc.nom_sel = dob.nom_sel ".
|
|
|
135 |
" AND dc.ce_utilisateur = dob.ce_utilisateur ".
|
|
|
136 |
" AND dc.ce_observation = dob.id_observation ".
|
|
|
137 |
") ".
|
|
|
138 |
"AND dc.ce_utilisateur NOT IN ".
|
|
|
139 |
"( ".
|
|
|
140 |
" SELECT id_utilisateur ".
|
|
|
141 |
" FROM del_utilisateur_infos ".
|
|
|
142 |
" WHERE preferences LIKE $preferences ".
|
|
|
143 |
") ".
|
|
|
144 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
|
|
145 |
"ORDER BY dc.ce_observation";
|
|
|
146 |
$commentaires = $this->conteneur->getBdd()->recupererTous($requete);
|
|
|
147 |
return $commentaires;
|
|
|
148 |
}
|
|
|
149 |
|
1020 |
aurelien |
150 |
protected function formaterCommentaires($liste_commentaires) {
|
|
|
151 |
foreach ($liste_commentaires as $commentaire) {
|
|
|
152 |
$id_obs = $commentaire['ce_observation'];
|
1575 |
jpm |
153 |
if (isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
|
1348 |
aurelien |
154 |
$auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']];
|
|
|
155 |
$commentaire['auteur'] = $this->formaterAuteur($commentaire);
|
|
|
156 |
$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;
|
|
|
157 |
}
|
1020 |
aurelien |
158 |
}
|
|
|
159 |
}
|
1571 |
jpm |
160 |
|
1683 |
jpm |
161 |
private function formaterAuteur($commentaire) {
|
|
|
162 |
return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
|
|
|
163 |
}
|
|
|
164 |
|
|
|
165 |
protected function envoyerMessageAuxDestinataires() {
|
|
|
166 |
foreach ($this->observations_concernees as $auteur => $liste_obs) {
|
|
|
167 |
$message = $this->formaterMessagePourAuteur($liste_obs, $auteur);
|
1020 |
aurelien |
168 |
$this->envoyerMessage($message, $auteur);
|
|
|
169 |
}
|
|
|
170 |
}
|
1571 |
jpm |
171 |
|
1020 |
aurelien |
172 |
private function formaterMessagePourAuteur($liste_obs, $auteur) {
|
|
|
173 |
$donnees = array();
|
1348 |
aurelien |
174 |
// copie de la première obs pour en obtenir le nom et prénom de l'auteur
|
1349 |
aurelien |
175 |
// (en deux fois pour éviter un warning en mode strict)
|
1348 |
aurelien |
176 |
$valeurs = array_values($liste_obs);
|
|
|
177 |
$premiere_obs = array_shift($valeurs);
|
1020 |
aurelien |
178 |
$donnees['liste_observations'] = $liste_obs;
|
|
|
179 |
$donnees['auteur'] = $auteur;
|
1348 |
aurelien |
180 |
$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);
|
1571 |
jpm |
181 |
|
1683 |
jpm |
182 |
$messageSquelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.html';
|
|
|
183 |
$squelettePhp = $this->conteneur->getSquelettePhp();
|
|
|
184 |
return $squelettePhp->analyser($messageSquelette, $donnees);
|
1020 |
aurelien |
185 |
}
|
1571 |
jpm |
186 |
|
1020 |
aurelien |
187 |
protected function envoyerMessage($message, $auteur) {
|
1683 |
jpm |
188 |
$url_requete = sprintf($this->conteneur->getParametre('url_service_messagerie'), $auteur);
|
1020 |
aurelien |
189 |
$post = array(
|
1683 |
jpm |
190 |
'sujet' => $this->conteneur->getParametre('titre_message_recapitulatif'),
|
1020 |
aurelien |
191 |
'message' => $message,
|
1683 |
jpm |
192 |
'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'),
|
1020 |
aurelien |
193 |
'format' => 'html'
|
|
|
194 |
);
|
|
|
195 |
|
|
|
196 |
$ch = curl_init();
|
1575 |
jpm |
197 |
$options = array(
|
|
|
198 |
CURLOPT_URL => $url_requete,
|
1020 |
aurelien |
199 |
CURLOPT_HEADER => false,
|
|
|
200 |
CURLOPT_POST => 1,
|
|
|
201 |
CURLOPT_POSTFIELDS => $post,
|
|
|
202 |
CURLOPT_RETURNTRANSFER => true
|
|
|
203 |
);
|
|
|
204 |
curl_setopt_array($ch, $options);
|
1683 |
jpm |
205 |
curl_exec($ch);
|
1020 |
aurelien |
206 |
curl_close($ch);
|
|
|
207 |
}
|
|
|
208 |
}
|
1683 |
jpm |
209 |
?>
|