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