| Line 2... |
Line 2... |
| 2 |
// declare(encoding='UTF-8');
|
2 |
// declare(encoding='UTF-8');
|
| 3 |
/**
|
3 |
/**
|
| 4 |
* Le script récupère tous les commentaires et déterminations fait ce jour et envoie un mail
|
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
|
5 |
* aux auteurs des observations récapitulant celle-ci
|
| 6 |
*
|
6 |
*
|
| 7 |
* @category php 5.2
|
7 |
* @category php 5.4
|
| 8 |
* @package del
|
8 |
* @package DEL
|
| 9 |
* @subpackage scripts
|
9 |
* @subpackage Scripts
|
| 10 |
* @author Aurélien PERONNET <aurelien@tela-botanica.org>
|
10 |
* @author Aurélien PERONNET <aurelien@tela-botanica.org>
|
| 11 |
* @copyright Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org)
|
11 |
* @copyright Copyright (c) 2012-2014, Tela Botanica (accueil@tela-botanica.org)
|
| 12 |
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
|
12 |
* @license CeCILL v2 http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt
|
| 13 |
* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
|
13 |
* @license GNU-GPL http://www.gnu.org/licenses/gpl.html
|
| 14 |
* @version $Id$
|
- |
|
| 15 |
*/
|
14 |
*/
|
| Line 16... |
Line 15... |
| 16 |
|
15 |
|
| Line 17... |
Line -... |
| 17 |
class AlerteMailCommentaires {
|
- |
|
| 18 |
|
16 |
class AlerteMailCommentaires {
|
| Line 19... |
Line 17... |
| 19 |
private $parametres;
|
17 |
|
| 20 |
private $conteneur;
|
- |
|
| 21 |
|
18 |
private $conteneur;
|
| Line 22... |
Line 19... |
| 22 |
private $observations_concernees = array();
|
19 |
|
| 23 |
private $id_observation_commentees = array();
|
- |
|
| 24 |
private $correspondance_id_obs_auteurs = array();
|
20 |
private $observations_concernees = array();
|
| 25 |
|
21 |
private $correspondance_id_obs_auteurs = array();
|
| Line 26... |
Line 22... |
| 26 |
public function __construct($parametres, $conteneur) {
|
22 |
|
| 27 |
$this->parametres = $parametres;
|
23 |
public function __construct($conteneur) {
|
| 28 |
$this->conteneur = $conteneur;
|
24 |
$this->conteneur = $conteneur;
|
| 29 |
}
|
25 |
}
|
| 30 |
|
26 |
|
| 31 |
public function executer() {
|
27 |
public function executer() {
|
| 32 |
try {
|
28 |
try {
|
| 33 |
$observations = $this->chargerObservationsCommentees();
|
29 |
$observations = $this->chargerObservationsCommentees();
|
| 34 |
if (!empty($observations)) {
|
30 |
if (!empty($observations)) {
|
| 35 |
$this->formaterObservations($observations);
|
31 |
$this->formaterObservations($observations);
|
| 36 |
$commentaires = $this->chargerCommentairesAjourdhui();
|
32 |
$commentaires = $this->chargerCommentairesDuJour();
|
| 37 |
$this->formaterCommentaires($commentaires);
|
33 |
$this->formaterCommentaires($commentaires);
|
| 38 |
$this->parcourirListeCommentairesEtEnvoyerMessage($this->observations_concernees);
|
34 |
$this->envoyerMessageAuxDestinataires();
|
| Line 39... |
Line -... |
| 39 |
}
|
- |
|
| 40 |
} catch (Exception $e) {
|
- |
|
| 41 |
$this->traiterErreur($e->getMessage());
|
- |
|
| 42 |
}
|
- |
|
| 43 |
}
|
- |
|
| 44 |
|
- |
|
| 45 |
protected function chargerCommentairesAjourdhui() {
|
- |
|
| 46 |
// TODO: optimiser la requête si beaucoup de mails sont envoyés
|
- |
|
| 47 |
$requete = "SELECT * ".
|
- |
|
| 48 |
"FROM del_commentaire AS dc ".
|
- |
|
| 49 |
// commentaires qui ont été fait sur une observation
|
- |
|
| 50 |
"WHERE dc.ce_observation != '0' ".
|
- |
|
| 51 |
"AND dc.id_commentaire NOT IN ".
|
- |
|
| 52 |
// commentaires qui ne sont pas la proposition initiale
|
- |
|
| 53 |
"( ".
|
- |
|
| 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 |
// et qui ont été fait dans la journée
|
- |
|
| 61 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
35 |
}
|
| 62 |
"ORDER BY dc.ce_observation";
|
36 |
} catch (Exception $e) {
|
| 63 |
$commentaires = $this->conteneur->getBdd()->recupererTous($requete);
|
37 |
$this->traiterErreur($e->getMessage());
|
| 64 |
return $commentaires;
|
38 |
}
|
| 65 |
}
|
39 |
}
|
| 66 |
|
40 |
|
| Line 94... |
Line 68... |
| 94 |
"ORDER BY do.ce_utilisateur, do.id_observation ";
|
68 |
"ORDER BY do.ce_utilisateur, do.id_observation ";
|
| 95 |
$observations = $this->conteneur->getBdd()->recupererTous($requete);
|
69 |
$observations = $this->conteneur->getBdd()->recupererTous($requete);
|
| 96 |
return $observations;
|
70 |
return $observations;
|
| 97 |
}
|
71 |
}
|
| Line 98... |
Line -... |
| 98 |
|
- |
|
| 99 |
protected function convertirCodeZoneGeoVersDepartement($code_zone_geo) {
|
- |
|
| 100 |
$code_departement = '';
|
- |
|
| 101 |
if ($this->estUnCodeInseeDepartement($code_zone_geo)) {
|
- |
|
| 102 |
$code_departement = substr(ltrim($code_zone_geo, 'INSEE-C:'), 0, 2);
|
- |
|
| 103 |
}
|
- |
|
| 104 |
|
- |
|
| 105 |
return $code_departement;
|
- |
|
| 106 |
}
|
- |
|
| 107 |
|
- |
|
| 108 |
protected function estUnCodeInseeDepartement($code_a_tester) {
|
- |
|
| 109 |
return preg_match('/^INSEE-C:[0-9]{5}/',$code_a_tester);
|
- |
|
| 110 |
}
|
- |
|
| 111 |
|
72 |
|
| 112 |
protected function formaterObservations($liste_obs) {
|
73 |
private function formaterObservations($liste_obs) {
|
| 113 |
foreach ($liste_obs as $obs) {
|
74 |
foreach ($liste_obs as $obs) {
|
| 114 |
$id_obs = $obs['id_observation'];
|
75 |
$id_obs = $obs['id_observation'];
|
| 115 |
$auteur_obs = $obs['ce_utilisateur'];
|
76 |
$auteur_obs = $obs['ce_utilisateur'];
|
| 116 |
$obs['date'] = $this->formaterDateObs($obs['date_observation']);
|
77 |
$obs['date'] = $this->formaterDateObs($obs['date_observation']);
|
| Line 120... |
Line 81... |
| 120 |
$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
|
81 |
$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
|
| 121 |
$this->observations_concernees[$auteur_obs][$id_obs] = $obs;
|
82 |
$this->observations_concernees[$auteur_obs][$id_obs] = $obs;
|
| 122 |
}
|
83 |
}
|
| 123 |
}
|
84 |
}
|
| Line -... |
Line 85... |
| - |
|
85 |
|
| - |
|
86 |
private function formaterDateObs($date) {
|
| - |
|
87 |
$time = strtotime($date);
|
| - |
|
88 |
return date('d/m/Y', $time);
|
| - |
|
89 |
}
|
| 124 |
|
90 |
|
| 125 |
protected function formaterLieuObservation($obs) {
|
91 |
private function formaterLieuObservation($obs) {
|
| 126 |
$lieux = array();
|
92 |
$lieux = array();
|
| 127 |
if (!empty($obs['zone_geo'])) {
|
93 |
if (!empty($obs['zone_geo'])) {
|
| 128 |
$zone_geo = $obs['zone_geo'];
|
94 |
$zone_geo = $obs['zone_geo'];
|
| 129 |
$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
|
95 |
$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
|
| Line 133... |
Line 99... |
| 133 |
$lieux[] = $obs['lieudit'];
|
99 |
$lieux[] = $obs['lieudit'];
|
| 134 |
}
|
100 |
}
|
| 135 |
if (!empty($obs['station'])) {
|
101 |
if (!empty($obs['station'])) {
|
| 136 |
$lieux[] = $obs['station'];
|
102 |
$lieux[] = $obs['station'];
|
| 137 |
}
|
103 |
}
|
| 138 |
return implode(" > ", $lieux);
|
104 |
return implode(' > ', $lieux);
|
| - |
|
105 |
}
|
| - |
|
106 |
|
| - |
|
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;
|
| 139 |
}
|
148 |
}
|
| Line 140... |
Line 149... |
| 140 |
|
149 |
|
| 141 |
protected function formaterCommentaires($liste_commentaires) {
|
- |
|
| 142 |
$liste_commentaires_formatee = array();
|
150 |
protected function formaterCommentaires($liste_commentaires) {
|
| 143 |
foreach ($liste_commentaires as $commentaire) {
|
151 |
foreach ($liste_commentaires as $commentaire) {
|
| 144 |
$id_obs = $commentaire['ce_observation'];
|
152 |
$id_obs = $commentaire['ce_observation'];
|
| 145 |
if (isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
|
153 |
if (isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
|
| 146 |
$auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']];
|
154 |
$auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']];
|
| 147 |
$commentaire['auteur'] = $this->formaterAuteur($commentaire);
|
155 |
$commentaire['auteur'] = $this->formaterAuteur($commentaire);
|
| 148 |
$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;
|
156 |
$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;
|
| 149 |
}
|
157 |
}
|
| 150 |
}
|
158 |
}
|
| Line -... |
Line 159... |
| - |
|
159 |
}
|
| - |
|
160 |
|
| - |
|
161 |
private function formaterAuteur($commentaire) {
|
| - |
|
162 |
return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
|
| 151 |
}
|
163 |
}
|
| 152 |
|
164 |
|
| 153 |
protected function parcourirListeCommentairesEtEnvoyerMessage($liste_obs_a_auteur) {
|
165 |
protected function envoyerMessageAuxDestinataires() {
|
| 154 |
foreach ($liste_obs_a_auteur as $auteur => $liste_obs) {
|
166 |
foreach ($this->observations_concernees as $auteur => $liste_obs) {
|
| 155 |
$message = $this->formaterMessagePourAuteur($liste_obs,$auteur);
|
167 |
$message = $this->formaterMessagePourAuteur($liste_obs, $auteur);
|
| 156 |
$this->envoyerMessage($message, $auteur);
|
168 |
$this->envoyerMessage($message, $auteur);
|
| Line 157... |
Line 169... |
| 157 |
}
|
169 |
}
|
| Line 164... |
Line 176... |
| 164 |
$valeurs = array_values($liste_obs);
|
176 |
$valeurs = array_values($liste_obs);
|
| 165 |
$premiere_obs = array_shift($valeurs);
|
177 |
$premiere_obs = array_shift($valeurs);
|
| 166 |
$donnees['liste_observations'] = $liste_obs;
|
178 |
$donnees['liste_observations'] = $liste_obs;
|
| 167 |
$donnees['auteur'] = $auteur;
|
179 |
$donnees['auteur'] = $auteur;
|
| 168 |
$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);
|
180 |
$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);
|
| 169 |
$this->squelette_dossier = dirname(__FILE__).DIRECTORY_SEPARATOR.'squelettes'.DIRECTORY_SEPARATOR;
|
- |
|
| 170 |
return $this->conteneur->traiterSquelettePhp($this->squelette_dossier.'commentaires.tpl.html', $donnees);
|
- |
|
| 171 |
}
|
- |
|
| 172 |
|
- |
|
| 173 |
protected function formaterDateObs($date) {
|
- |
|
| 174 |
$time = strtotime($date);
|
- |
|
| 175 |
return date('d/m/Y', $time);
|
- |
|
| 176 |
}
|
- |
|
| Line 177... |
Line -... |
| 177 |
|
- |
|
| 178 |
private function formaterAuteur($commentaire) {
|
181 |
|
| 179 |
return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
|
- |
|
| 180 |
}
|
- |
|
| 181 |
|
182 |
$messageSquelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.html';
|
| 182 |
private function obtenirLienFicheObs($id_obs) {
|
183 |
$squelettePhp = $this->conteneur->getSquelettePhp();
|
| 183 |
return $this->conteneur->formaterUrl(Config::get('url_fiche_observation'), array('id' => $id_obs));
|
184 |
return $squelettePhp->analyser($messageSquelette, $donnees);
|
| Line 184... |
Line 185... |
| 184 |
}
|
185 |
}
|
| 185 |
|
186 |
|
| 186 |
protected function envoyerMessage($message, $auteur) {
|
187 |
protected function envoyerMessage($message, $auteur) {
|
| 187 |
$url_requete = $this->conteneur->formaterUrl(Config::get('url_service_messagerie'), array('id' => $auteur));
|
188 |
$url_requete = sprintf($this->conteneur->getParametre('url_service_messagerie'), $auteur);
|
| 188 |
$post = array(
|
189 |
$post = array(
|
| 189 |
'sujet' => Config::get('titre_message_recapitulatif'),
|
190 |
'sujet' => $this->conteneur->getParametre('titre_message_recapitulatif'),
|
| 190 |
'message' => $message,
|
191 |
'message' => $message,
|
| 191 |
'utilisateur_courriel' => Config::get('adresse_expediteur_recapitulatif'),
|
192 |
'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'),
|
| Line 192... |
Line 193... |
| 192 |
'format' => 'html'
|
193 |
'format' => 'html'
|
| 193 |
);
|
194 |
);
|
| Line 199... |
Line 200... |
| 199 |
CURLOPT_POST => 1,
|
200 |
CURLOPT_POST => 1,
|
| 200 |
CURLOPT_POSTFIELDS => $post,
|
201 |
CURLOPT_POSTFIELDS => $post,
|
| 201 |
CURLOPT_RETURNTRANSFER => true
|
202 |
CURLOPT_RETURNTRANSFER => true
|
| 202 |
);
|
203 |
);
|
| 203 |
curl_setopt_array($ch, $options);
|
204 |
curl_setopt_array($ch, $options);
|
| 204 |
$envoi = curl_exec($ch);
|
205 |
curl_exec($ch);
|
| 205 |
curl_close($ch);
|
206 |
curl_close($ch);
|
| 206 |
}
|
207 |
}
|
| 207 |
}
|
208 |
}
|
| 208 |
?>
|
- |
|
| 209 |
|
209 |
?>
|
| - |
|
210 |
|