Subversion Repositories eFlore/Applications.del

Rev

Rev 1678 | Rev 1737 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1678 Rev 1683
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