Subversion Repositories eFlore/Applications.del

Rev

Rev 1649 | Rev 1737 | Go to most recent revision | Details | Compare with Previous | 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;
1571 jpm 21
 
1020 aurelien 22
	private $observations_concernees = array();
23
	private $id_observation_commentees = array();
24
	private $correspondance_id_obs_auteurs = array();
1571 jpm 25
 
1020 aurelien 26
	public function __construct($parametres, $conteneur) {
27
		$this->parametres = $parametres;
28
		$this->conteneur = $conteneur;
29
	}
1571 jpm 30
 
1020 aurelien 31
	public function executer() {
32
		try {
33
			$observations = $this->chargerObservationsCommentees();
1571 jpm 34
			if (!empty($observations)) {
1349 aurelien 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
 
1571 jpm 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 ".
1678 aurelien 49
			// commentaires qui ont été fait sur une observation
1571 jpm 50
			"WHERE dc.ce_observation != '0' ".
51
			"AND dc.id_commentaire NOT IN ".
1678 aurelien 52
			// commentaires qui ne sont pas la proposition initiale
1571 jpm 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
			") ".
1678 aurelien 60
			// et qui ont été fait dans la journée
1571 jpm 61
			"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
62
			"ORDER BY dc.ce_observation";
1020 aurelien 63
		$commentaires = $this->conteneur->getBdd()->recupererTous($requete);
64
		return $commentaires;
65
	}
1571 jpm 66
 
1020 aurelien 67
	protected function chargerObservationsCommentees() {
1649 aurelien 68
		// Seuls les utilisateurs ayant explicitement refusé le mail sont ignorés
1571 jpm 69
		$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');
1020 aurelien 70
		//TODO: optimiser la requête si beaucoup de mails sont envoyés
1571 jpm 71
		$requete = "SELECT * FROM del_observation AS do ".
1575 jpm 72
			"WHERE do.id_observation IN ".
73
				"( ".
1678 aurelien 74
					//TODO: essayer de factoriser cette sous requete entre ici et la fonction du dessus
1575 jpm 75
					"SELECT dc.ce_observation ".
76
					"FROM del_commentaire AS dc ".
77
					"WHERE dc.ce_observation != '0' ".
78
					"AND dc.id_commentaire NOT IN ".
1571 jpm 79
					"( ".
1575 jpm 80
					"	SELECT dc.id_commentaire ".
81
					"	FROM del_commentaire AS dc, del_observation AS 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
					") ".
86
					"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".
87
				") ".
1649 aurelien 88
				"AND do.ce_utilisateur NOT IN ".
89
					"( ".
90
					"	SELECT id_utilisateur ".
91
					"	FROM del_utilisateur_infos ".
92
					"	WHERE preferences LIKE $preferences ".
93
					") ".
1575 jpm 94
			"ORDER BY do.ce_utilisateur, do.id_observation ";
1020 aurelien 95
		$observations = $this->conteneur->getBdd()->recupererTous($requete);
96
		return $observations;
97
	}
1571 jpm 98
 
1348 aurelien 99
	protected function convertirCodeZoneGeoVersDepartement($code_zone_geo) {
100
		$code_departement = '';
1571 jpm 101
		if ($this->estUnCodeInseeDepartement($code_zone_geo)) {
102
			$code_departement = substr(ltrim($code_zone_geo, 'INSEE-C:'), 0, 2);
1348 aurelien 103
		}
1571 jpm 104
 
1348 aurelien 105
		return $code_departement;
106
	}
1571 jpm 107
 
1348 aurelien 108
	protected function estUnCodeInseeDepartement($code_a_tester) {
109
		return preg_match('/^INSEE-C:[0-9]{5}/',$code_a_tester);
110
	}
1571 jpm 111
 
1020 aurelien 112
	protected function formaterObservations($liste_obs) {
113
		foreach ($liste_obs as $obs) {
114
			$id_obs = $obs['id_observation'];
115
			$auteur_obs = $obs['ce_utilisateur'];
116
			$obs['date'] = $this->formaterDateObs($obs['date_observation']);
1348 aurelien 117
			$obs['lieu'] = $this->formaterLieuObservation($obs);
1036 aurelien 118
			$obs['lien'] = $this->obtenirLienFicheObs($obs['id_observation']);
1276 aurelien 119
			$obs['commentaires'] = array();
1020 aurelien 120
			$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;
121
			$this->observations_concernees[$auteur_obs][$id_obs] = $obs;
122
		}
123
	}
1571 jpm 124
 
1348 aurelien 125
	protected function formaterLieuObservation($obs) {
126
		$lieux = array();
1571 jpm 127
		if (!empty($obs['zone_geo'])) {
1348 aurelien 128
			$zone_geo = $obs['zone_geo'];
129
			$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');
130
			$lieux[] = $zone_geo;
131
		}
1571 jpm 132
		if (!empty($obs['lieudit'])) {
1348 aurelien 133
			$lieux[] = $obs['lieudit'];
134
		}
1571 jpm 135
		if (!empty($obs['station'])) {
1348 aurelien 136
			$lieux[] = $obs['station'];
137
		}
138
		return implode(" > ", $lieux);
139
	}
1571 jpm 140
 
1020 aurelien 141
	protected function formaterCommentaires($liste_commentaires) {
142
		$liste_commentaires_formatee = array();
143
		foreach ($liste_commentaires as $commentaire) {
144
			$id_obs = $commentaire['ce_observation'];
1575 jpm 145
			if (isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {
1348 aurelien 146
				$auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']];
147
				$commentaire['auteur'] = $this->formaterAuteur($commentaire);
148
				$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;
149
			}
1020 aurelien 150
		}
151
	}
1571 jpm 152
 
1020 aurelien 153
	protected function parcourirListeCommentairesEtEnvoyerMessage($liste_obs_a_auteur) {
154
		foreach ($liste_obs_a_auteur as $auteur => $liste_obs) {
155
			$message = $this->formaterMessagePourAuteur($liste_obs,$auteur);
156
			$this->envoyerMessage($message, $auteur);
157
		}
158
	}
1571 jpm 159
 
1020 aurelien 160
	private function formaterMessagePourAuteur($liste_obs, $auteur) {
161
		$donnees = array();
1348 aurelien 162
		// copie de la première obs pour en obtenir le nom et prénom de l'auteur
1349 aurelien 163
		// (en deux fois pour éviter un warning en mode strict)
1348 aurelien 164
		$valeurs = array_values($liste_obs);
165
		$premiere_obs = array_shift($valeurs);
1020 aurelien 166
		$donnees['liste_observations'] = $liste_obs;
167
		$donnees['auteur'] = $auteur;
1348 aurelien 168
		$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);
1020 aurelien 169
		$this->squelette_dossier = dirname(__FILE__).DIRECTORY_SEPARATOR.'squelettes'.DIRECTORY_SEPARATOR;
170
		return $this->conteneur->traiterSquelettePhp($this->squelette_dossier.'commentaires.tpl.html', $donnees);
171
	}
1571 jpm 172
 
1020 aurelien 173
	protected function formaterDateObs($date) {
174
		$time = strtotime($date);
1571 jpm 175
		return date('d/m/Y', $time);
1020 aurelien 176
	}
1571 jpm 177
 
1020 aurelien 178
	private function formaterAuteur($commentaire) {
179
		return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];
180
	}
1571 jpm 181
 
1036 aurelien 182
	private function obtenirLienFicheObs($id_obs) {
1571 jpm 183
		return $this->conteneur->formaterUrl(Config::get('url_fiche_observation'), array('id' => $id_obs));
1036 aurelien 184
	}
1571 jpm 185
 
1020 aurelien 186
	protected function envoyerMessage($message, $auteur) {
1571 jpm 187
		$url_requete = $this->conteneur->formaterUrl(Config::get('url_service_messagerie'), array('id' => $auteur));
1020 aurelien 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();
1575 jpm 196
		$options = array(
197
			CURLOPT_URL => $url_requete,
1020 aurelien 198
			CURLOPT_HEADER => false,
199
			CURLOPT_POST => 1,
200
			CURLOPT_POSTFIELDS => $post,
201
			CURLOPT_RETURNTRANSFER => true
202
		);
203
		curl_setopt_array($ch, $options);
204
		$envoi = curl_exec($ch);
205
		curl_close($ch);
206
	}
207
}
208
?>