Subversion Repositories eFlore/Applications.del

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

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