Line 16... |
Line 16... |
16 |
|
16 |
|
Line 17... |
Line 17... |
17 |
class AlerteMailCommentaires {
|
17 |
class AlerteMailCommentaires {
|
18 |
|
18 |
|
19 |
private $parametres;
|
19 |
private $parametres;
|
20 |
private $conteneur;
|
20 |
private $conteneur;
|
21 |
|
21 |
|
22 |
private $observations_concernees = array();
|
22 |
private $observations_concernees = array();
|
23 |
private $id_observation_commentees = array();
|
23 |
private $id_observation_commentees = array();
|
24 |
private $correspondance_id_obs_auteurs = array();
|
24 |
private $correspondance_id_obs_auteurs = array();
|
25 |
|
25 |
|
26 |
public function __construct($parametres, $conteneur) {
|
26 |
public function __construct($parametres, $conteneur) {
|
27 |
$this->parametres = $parametres;
|
27 |
$this->parametres = $parametres;
|
28 |
$this->conteneur = $conteneur;
|
28 |
$this->conteneur = $conteneur;
|
29 |
}
|
29 |
}
|
30 |
|
30 |
|
31 |
public function executer() {
|
31 |
public function executer() {
|
32 |
try {
|
32 |
try {
|
33 |
$observations = $this->chargerObservationsCommentees();
|
33 |
$observations = $this->chargerObservationsCommentees();
|
34 |
if(!empty($observations)) {
|
34 |
if (!empty($observations)) {
|
35 |
$this->formaterObservations($observations);
|
35 |
$this->formaterObservations($observations);
|
36 |
$commentaires = $this->chargerCommentairesAjourdhui();
|
36 |
$commentaires = $this->chargerCommentairesAjourdhui();
|
37 |
$this->formaterCommentaires($commentaires);
|
37 |
$this->formaterCommentaires($commentaires);
|
38 |
$this->parcourirListeCommentairesEtEnvoyerMessage($this->observations_concernees);
|
38 |
$this->parcourirListeCommentairesEtEnvoyerMessage($this->observations_concernees);
|
39 |
}
|
39 |
}
|
40 |
} catch (Exception $e) {
|
40 |
} catch (Exception $e) {
|
41 |
$this->traiterErreur($e->getMessage());
|
41 |
$this->traiterErreur($e->getMessage());
|
Line 42... |
Line 42... |
42 |
}
|
42 |
}
|
- |
|
43 |
}
|
43 |
}
|
44 |
|
44 |
|
45 |
protected function chargerCommentairesAjourdhui() {
|
45 |
protected function chargerCommentairesAjourdhui() {
|
46 |
$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
|
46 |
//TODO: optimiser la requête si beaucoup de mails sont envoyés
|
47 |
// TODO: optimiser la requête si beaucoup de mails sont envoyés
|
47 |
$requete = "SELECT * ".
|
48 |
$requete = "SELECT * ".
|
48 |
"FROM del_commentaire dc ".
|
49 |
"FROM del_commentaire AS dc ".
|
49 |
"WHERE dc.ce_observation != '0' ".
|
50 |
"WHERE dc.ce_observation != '0' ".
|
50 |
"AND dc.id_commentaire NOT IN ".
|
51 |
"AND dc.id_commentaire NOT IN ".
|
51 |
"( ".
|
52 |
"( ".
|
52 |
" SELECT dc.id_commentaire ".
|
53 |
" SELECT dc.id_commentaire ".
|
53 |
" FROM del_commentaire dc, del_observation dob".
|
54 |
" FROM del_commentaire AS dc, del_observation AS dob".
|
54 |
" WHERE dc.nom_sel = dob.nom_sel ".
|
55 |
" WHERE dc.nom_sel = dob.nom_sel ".
|
55 |
" AND dc.ce_utilisateur = dob.ce_utilisateur ".
|
56 |
" AND dc.ce_utilisateur = dob.ce_utilisateur ".
|
56 |
" AND dc.ce_observation = dob.id_observation ".
|
57 |
" AND dc.ce_observation = dob.id_observation ".
|
57 |
") ".
|
58 |
") ".
|
58 |
"AND dc.ce_utilisateur NOT IN ".
|
59 |
"AND dc.ce_utilisateur NOT IN ".
|
59 |
"( ".
|
60 |
"( ".
|
60 |
" SELECT id_utilisateur ".
|
61 |
" SELECT id_utilisateur ".
|
61 |
" FROM del_utilisateur_infos ".
|
62 |
" FROM del_utilisateur_infos ".
|
62 |
" WHERE preferences LIKE ".$this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%')." ".
|
63 |
" WHERE preferences LIKE $preferences ".
|
63 |
") ".
|
64 |
") ".
|
64 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
65 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
65 |
"ORDER BY dc.ce_observation";
|
66 |
"ORDER BY dc.ce_observation";
|
66 |
$commentaires = $this->conteneur->getBdd()->recupererTous($requete);
|
67 |
$commentaires = $this->conteneur->getBdd()->recupererTous($requete);
|
67 |
return $commentaires;
|
68 |
return $commentaires;
|
- |
|
69 |
}
|
68 |
}
|
70 |
|
69 |
|
71 |
protected function chargerObservationsCommentees() {
|
70 |
protected function chargerObservationsCommentees() {
|
72 |
$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
|
71 |
//TODO: optimiser la requête si beaucoup de mails sont envoyés
|
73 |
//TODO: optimiser la requête si beaucoup de mails sont envoyés
|
72 |
$requete = "SELECT * FROM del_observation do ".
|
74 |
$requete = "SELECT * FROM del_observation AS do ".
|
73 |
"WHERE do.id_observation IN ".
|
75 |
"WHERE do.id_observation IN ".
|
74 |
"( ".
|
76 |
"( ".
|
75 |
"SELECT dc.ce_observation ".
|
77 |
"SELECT dc.ce_observation ".
|
76 |
"FROM del_commentaire dc ".
|
78 |
"FROM del_commentaire AS dc ".
|
77 |
"WHERE dc.ce_observation != '0' ".
|
79 |
"WHERE dc.ce_observation != '0' ".
|
78 |
"AND dc.id_commentaire NOT IN ".
|
80 |
"AND dc.id_commentaire NOT IN ".
|
79 |
"( ".
|
81 |
"( ".
|
80 |
" SELECT dc.id_commentaire ".
|
82 |
" SELECT dc.id_commentaire ".
|
81 |
" FROM del_commentaire dc, del_observation dob".
|
83 |
" FROM del_commentaire AS dc, del_observation AS dob".
|
82 |
" WHERE dc.nom_sel = dob.nom_sel ".
|
84 |
" WHERE dc.nom_sel = dob.nom_sel ".
|
83 |
" AND dc.ce_utilisateur = dob.ce_utilisateur ".
|
85 |
" AND dc.ce_utilisateur = dob.ce_utilisateur ".
|
84 |
" AND dc.ce_observation = dob.id_observation ".
|
86 |
" AND dc.ce_observation = dob.id_observation ".
|
85 |
") ".
|
87 |
") ".
|
86 |
"AND dc.ce_utilisateur NOT IN ".
|
88 |
"AND dc.ce_utilisateur NOT IN ".
|
87 |
"( ".
|
89 |
"( ".
|
88 |
" SELECT id_utilisateur ".
|
90 |
" SELECT id_utilisateur ".
|
89 |
" FROM del_utilisateur_infos ".
|
91 |
" FROM del_utilisateur_infos ".
|
90 |
" WHERE preferences LIKE ".$this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%')." ".
|
92 |
" WHERE preferences LIKE $preferences ".
|
91 |
") ".
|
93 |
") ".
|
92 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
94 |
"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
|
93 |
") ".
|
95 |
") ".
|
94 |
"ORDER BY do.ce_utilisateur, do.id_observation ";
|
96 |
"ORDER BY do.ce_utilisateur, do.id_observation ";
|
95 |
$observations = $this->conteneur->getBdd()->recupererTous($requete);
|
97 |
$observations = $this->conteneur->getBdd()->recupererTous($requete);
|
96 |
return $observations;
|
98 |
return $observations;
|
97 |
}
|
- |
|
98 |
|
99 |
}
|
99 |
protected function convertirCodeZoneGeoVersDepartement($code_zone_geo) {
|
100 |
|
100 |
|
101 |
protected function convertirCodeZoneGeoVersDepartement($code_zone_geo) {
|
101 |
$code_departement = '';
|
102 |
$code_departement = '';
|
102 |
if($this->estUnCodeInseeDepartement($code_zone_geo)) {
|
103 |
if ($this->estUnCodeInseeDepartement($code_zone_geo)) {
|
103 |
$code_departement = substr(ltrim($code_zone_geo,'INSEE-C:'),0,2);
|
104 |
$code_departement = substr(ltrim($code_zone_geo, 'INSEE-C:'), 0, 2);
|
104 |
}
|
105 |
}
|
105 |
|
106 |
|
106 |
return $code_departement;
|
107 |
return $code_departement;
|
107 |
}
|
108 |
}
|
108 |
|
109 |
|
109 |
protected function estUnCodeInseeDepartement($code_a_tester) {
|
110 |
protected function estUnCodeInseeDepartement($code_a_tester) {
|
110 |
return preg_match('/^INSEE-C:[0-9]{5}/',$code_a_tester);
|
111 |
return preg_match('/^INSEE-C:[0-9]{5}/',$code_a_tester);
|
111 |
}
|
112 |
}
|
112 |
|
113 |
|
113 |
protected function formaterObservations($liste_obs) {
|
114 |
protected function formaterObservations($liste_obs) {
|
114 |
foreach ($liste_obs as $obs) {
|
115 |
foreach ($liste_obs as $obs) {
|
Line 120... |
Line 121... |
120 |
$obs['commentaires'] = array();
|
121 |
$obs['commentaires'] = array();
|
121 |
$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
|
122 |
$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
|
122 |
$this->observations_concernees[$auteur_obs][$id_obs] = $obs;
|
123 |
$this->observations_concernees[$auteur_obs][$id_obs] = $obs;
|
123 |
}
|
124 |
}
|
124 |
}
|
125 |
}
|
125 |
|
126 |
|
126 |
protected function formaterLieuObservation($obs) {
|
127 |
protected function formaterLieuObservation($obs) {
|
127 |
$lieux = array();
|
128 |
$lieux = array();
|
128 |
if(!empty($obs['zone_geo'])) {
|
129 |
if (!empty($obs['zone_geo'])) {
|
129 |
$zone_geo = $obs['zone_geo'];
|
130 |
$zone_geo = $obs['zone_geo'];
|
130 |
$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
|
131 |
$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
|
131 |
$lieux[] = $zone_geo;
|
132 |
$lieux[] = $zone_geo;
|
132 |
}
|
133 |
}
|
133 |
if(!empty($obs['lieudit'])) {
|
134 |
if (!empty($obs['lieudit'])) {
|
134 |
$lieux[] = $obs['lieudit'];
|
135 |
$lieux[] = $obs['lieudit'];
|
135 |
}
|
136 |
}
|
136 |
if(!empty($obs['station'])) {
|
137 |
if (!empty($obs['station'])) {
|
137 |
$lieux[] = $obs['station'];
|
138 |
$lieux[] = $obs['station'];
|
138 |
}
|
139 |
}
|
139 |
return implode(" > ", $lieux);
|
140 |
return implode(" > ", $lieux);
|
140 |
}
|
141 |
}
|
141 |
|
142 |
|
142 |
protected function formaterCommentaires($liste_commentaires) {
|
143 |
protected function formaterCommentaires($liste_commentaires) {
|
143 |
$liste_commentaires_formatee = array();
|
144 |
$liste_commentaires_formatee = array();
|
144 |
foreach ($liste_commentaires as $commentaire) {
|
145 |
foreach ($liste_commentaires as $commentaire) {
|
145 |
$id_obs = $commentaire['ce_observation'];
|
146 |
$id_obs = $commentaire['ce_observation'];
|
146 |
if(isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
|
147 |
if(isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
|
Line 148... |
Line 149... |
148 |
$commentaire['auteur'] = $this->formaterAuteur($commentaire);
|
149 |
$commentaire['auteur'] = $this->formaterAuteur($commentaire);
|
149 |
$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;
|
150 |
$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;
|
150 |
}
|
151 |
}
|
151 |
}
|
152 |
}
|
152 |
}
|
153 |
}
|
153 |
|
154 |
|
154 |
protected function parcourirListeCommentairesEtEnvoyerMessage($liste_obs_a_auteur) {
|
155 |
protected function parcourirListeCommentairesEtEnvoyerMessage($liste_obs_a_auteur) {
|
155 |
foreach ($liste_obs_a_auteur as $auteur => $liste_obs) {
|
156 |
foreach ($liste_obs_a_auteur as $auteur => $liste_obs) {
|
156 |
$message = $this->formaterMessagePourAuteur($liste_obs,$auteur);
|
157 |
$message = $this->formaterMessagePourAuteur($liste_obs,$auteur);
|
157 |
$this->envoyerMessage($message, $auteur);
|
158 |
$this->envoyerMessage($message, $auteur);
|
158 |
}
|
159 |
}
|
159 |
}
|
160 |
}
|
160 |
|
161 |
|
161 |
private function formaterMessagePourAuteur($liste_obs, $auteur) {
|
162 |
private function formaterMessagePourAuteur($liste_obs, $auteur) {
|
162 |
$donnees = array();
|
163 |
$donnees = array();
|
163 |
// copie de la première obs pour en obtenir le nom et prénom de l'auteur
|
164 |
// copie de la première obs pour en obtenir le nom et prénom de l'auteur
|
164 |
// (en deux fois pour éviter un warning en mode strict)
|
165 |
// (en deux fois pour éviter un warning en mode strict)
|
165 |
$valeurs = array_values($liste_obs);
|
166 |
$valeurs = array_values($liste_obs);
|
Line 168... |
Line 169... |
168 |
$donnees['auteur'] = $auteur;
|
169 |
$donnees['auteur'] = $auteur;
|
169 |
$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);
|
170 |
$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);
|
170 |
$this->squelette_dossier = dirname(__FILE__).DIRECTORY_SEPARATOR.'squelettes'.DIRECTORY_SEPARATOR;
|
171 |
$this->squelette_dossier = dirname(__FILE__).DIRECTORY_SEPARATOR.'squelettes'.DIRECTORY_SEPARATOR;
|
171 |
return $this->conteneur->traiterSquelettePhp($this->squelette_dossier.'commentaires.tpl.html', $donnees);
|
172 |
return $this->conteneur->traiterSquelettePhp($this->squelette_dossier.'commentaires.tpl.html', $donnees);
|
172 |
}
|
173 |
}
|
173 |
|
174 |
|
174 |
protected function formaterDateObs($date) {
|
175 |
protected function formaterDateObs($date) {
|
175 |
$time = strtotime($date);
|
176 |
$time = strtotime($date);
|
176 |
return date('d/m/Y', $time);
|
177 |
return date('d/m/Y', $time);
|
177 |
}
|
178 |
}
|
178 |
|
179 |
|
179 |
private function formaterAuteur($commentaire) {
|
180 |
private function formaterAuteur($commentaire) {
|
180 |
return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
|
181 |
return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
|
181 |
}
|
182 |
}
|
182 |
|
183 |
|
183 |
private function obtenirLienFicheObs($id_obs) {
|
184 |
private function obtenirLienFicheObs($id_obs) {
|
184 |
return $this->conteneur->formaterUrl(Config::get('url_fiche_observation'), array('id' => $id_obs));
|
185 |
return $this->conteneur->formaterUrl(Config::get('url_fiche_observation'), array('id' => $id_obs));
|
185 |
}
|
186 |
}
|
186 |
|
187 |
|
187 |
protected function envoyerMessage($message, $auteur) {
|
188 |
protected function envoyerMessage($message, $auteur) {
|
188 |
|
- |
|
189 |
$url_requete = $this->conteneur->formaterUrl(Config::get('url_service_messagerie'), array('id' => $auteur));
|
189 |
$url_requete = $this->conteneur->formaterUrl(Config::get('url_service_messagerie'), array('id' => $auteur));
|
190 |
$post = array(
|
190 |
$post = array(
|
191 |
'sujet' => Config::get('titre_message_recapitulatif'),
|
191 |
'sujet' => Config::get('titre_message_recapitulatif'),
|
192 |
'message' => $message,
|
192 |
'message' => $message,
|
193 |
'utilisateur_courriel' => Config::get('adresse_expediteur_recapitulatif'),
|
193 |
'utilisateur_courriel' => Config::get('adresse_expediteur_recapitulatif'),
|
194 |
'format' => 'html'
|
194 |
'format' => 'html'
|