Subversion Repositories eFlore/Applications.del

Rev

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

Rev 1461 Rev 1571
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'