Subversion Repositories eFlore/Applications.del

<?php

// declare(encoding='UTF-8');

/**

 * Le script récupère tous les commentaires et déterminations fait ce jour et envoie un mail

 * aux auteurs des observations récapitulant celle-ci

 *

 * @category	php 5.4

 * @package		DEL

 * @subpackage 	Scripts

 * @author		Aurélien PERONNET <aurelien@tela-botanica.org>

 * @copyright	Copyright (c) 2012-2014, Tela Botanica (accueil@tela-botanica.org)

 * @license		CeCILL v2 http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt

 * @license		GNU-GPL http://www.gnu.org/licenses/gpl.html

 */

class AlerteMailCommentaires {

	private $conteneur;

	private $testeurCourriel = null;

	private $observations_concernees = array();

	private $correspondance_id_obs_auteurs = array();

	public function __construct($conteneur) {

		$this->conteneur = $conteneur;

	}

	public function executer() {

		try {

			$this->verifierModeUtilisation();

			$observations = $this->chargerObservationsCommentees();

			if (!empty($observations)) {

				$this->formaterObservations($observations);

				$commentaires = $this->chargerCommentairesDuJour();

				$this->formaterCommentaires($commentaires);

				$this->envoyerMessageAuxDestinataires();

			}

		} catch (Exception $e) {

			$this->traiterErreur($e->getMessage());

		}

	}

	private function verifierModeUtilisation() {

		$testeurCourriel = $this->conteneur->getParametre('t');

		if ($testeurCourriel) {

			if (filter_var($testeurCourriel, FILTER_VALIDATE_EMAIL)) {

				$this->testeurCourriel = $testeurCourriel;

			} else {

				$msg = "Veuillez indiquer une adresse de courriel valide à la suite du paramètre «-t».";

				new Exception($msg);

			}

		}

	}

	private function chargerObservationsCommentees() {

		// Seuls les utilisateurs ayant explicitement refusé le mail sont ignorés

		$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');

		//TODO: optimiser la requête si beaucoup de mails sont envoyés

		$requete = "SELECT * FROM del_observation AS do ".

			"WHERE do.id_observation IN ".

				"( ".

					//TODO: essayer de factoriser cette sous requete entre ici et la fonction du dessus

					"SELECT dc.ce_observation ".

					"FROM del_commentaire AS dc ".

					"WHERE dc.ce_observation != '0' ".

					"AND dc.id_commentaire NOT IN ".

					"( ".

					"	SELECT dc.id_commentaire ".

					"	FROM del_commentaire AS dc, del_observation AS dob".

					"	WHERE dc.nom_sel = dob.nom_sel ".

					"		AND dc.ce_utilisateur = dob.ce_utilisateur ".

					"		AND dc.ce_observation = dob.id_observation ".

					") ".

					"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".

				") ".

				"AND do.ce_utilisateur NOT IN ".

					"( ".

					"	SELECT id_utilisateur ".

					"	FROM del_utilisateur_infos ".

					"	WHERE preferences LIKE $preferences ".

					") ".

			"ORDER BY do.ce_utilisateur, do.id_observation ";

		$observations = $this->conteneur->getBdd()->recupererTous($requete);

		return $observations;

	}

	private function formaterObservations($liste_obs) {

		foreach ($liste_obs as $obs) {

			$id_obs = $obs['id_observation'];

			$auteur_obs = $obs['ce_utilisateur'];

			$obs['date'] = $this->formaterDateObs($obs['date_observation']);

			$obs['lieu'] = $this->formaterLieuObservation($obs);

			$obs['lien'] = $this->obtenirLienFicheObs($obs['id_observation']);

			$obs['commentaires'] = array();

			$this->correspondance_id_obs_auteurs[$id_obs] = $auteur_obs;

			$this->observations_concernees[$auteur_obs][$id_obs] = $obs;

		}

	}

	private function formaterDateObs($date) {

		$time = strtotime($date);

		return date('d/m/Y', $time);

	}

	private function formaterLieuObservation($obs) {

		$lieux = array();

		if (!empty($obs['zone_geo'])) {

			$zone_geo = $obs['zone_geo'];

			$zone_geo.= (!empty($obs['ce_zone_geo']) ? ' ('.$this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']).')' : '');

			$lieux[] = $zone_geo;

		}

		if (!empty($obs['lieudit'])) {

			$lieux[] = $obs['lieudit'];

		}

		if (!empty($obs['station'])) {

			$lieux[] = $obs['station'];

		}

		return implode(' > ', $lieux);

	}

	private function convertirCodeZoneGeoVersDepartement($code_zone_geo) {

		$code_departement = '';

		if ($this->estUnCodeInseeDepartement($code_zone_geo)) {

			$code_departement = substr(ltrim($code_zone_geo, 'INSEE-C:'), 0, 2);

		}

		return $code_departement;

	}

	private function estUnCodeInseeDepartement($code_a_tester) {

		return preg_match('/^INSEE-C:[0-9]{5}/', $code_a_tester);

	}

	private function obtenirLienFicheObs($id_obs) {

		return sprintf($this->conteneur->getParametre('url_fiche_observation'), $id_obs);

	}

	protected function chargerCommentairesDuJour() {

		$preferences = $this->conteneur->getBdd()->proteger('%"mail_notification_mes_obs":"0"%');

		// TODO: optimiser la requête si beaucoup de mails sont envoyés

		$requete = "SELECT * ".

			"FROM del_commentaire AS dc ".

			"WHERE dc.ce_observation != '0' ".

			"AND dc.id_commentaire NOT IN ".

			"( ".

			"	SELECT dc.id_commentaire ".

			"	FROM del_commentaire AS dc, del_observation AS dob".

			"	WHERE dc.nom_sel = dob.nom_sel ".

			"		AND dc.ce_utilisateur = dob.ce_utilisateur ".

			"		AND dc.ce_observation = dob.id_observation ".

			") ".

			"AND dc.ce_utilisateur NOT IN ".

			"( ".

			"	SELECT id_utilisateur ".

			"	FROM del_utilisateur_infos ".

			"	WHERE preferences LIKE $preferences ".

			") ".

			"AND TO_DAYS(NOW()) - TO_DAYS(dc.date) <= 1 ".

			"ORDER BY dc.ce_observation";

		$commentaires = $this->conteneur->getBdd()->recupererTous($requete);

		return $commentaires;

	}

	protected function formaterCommentaires($liste_commentaires) {

		foreach ($liste_commentaires as $commentaire) {

			$id_obs = $commentaire['ce_observation'];

			if (isset($this->correspondance_id_obs_auteurs[$commentaire['ce_observation']])) {

				$auteur_obs = $this->correspondance_id_obs_auteurs[$commentaire['ce_observation']];

				$commentaire['auteur'] = $this->formaterAuteur($commentaire);

				$this->observations_concernees[$auteur_obs][$id_obs]['commentaires'][] = $commentaire;

			}

		}

	}

	private function formaterAuteur($commentaire) {

		return $commentaire['utilisateur_prenom'].' '.$commentaire['utilisateur_nom'];

	}

	protected function envoyerMessageAuxDestinataires() {

		foreach ($this->observations_concernees as $auteur => $liste_obs) {

			$message = $this->formaterMessagePourAuteur($liste_obs, $auteur);

			if ($this->testeurCourriel == null) {

				$this->envoyerMessage($message, $auteur);

			} else {

				$this->envoyerMessage($message, $this->testeurCourriel);

			}

		}

	}

	private function formaterMessagePourAuteur($liste_obs, $auteur) {

		$donnees = array();

		// copie de la première obs pour en obtenir le nom et prénom de l'auteur

		// (en deux fois pour éviter un warning en mode strict)

		$valeurs = array_values($liste_obs);

		$premiere_obs = array_shift($valeurs);

		$donnees['liste_observations'] = $liste_obs;

		$donnees['auteur'] = $auteur;

		$donnees['auteur_formate'] = ucfirst($premiere_obs['prenom_utilisateur']).' '.ucfirst($premiere_obs['nom_utilisateur']);

		$messageSquelette = dirname(__FILE__).DS.'squelettes'.DS.'commentaires.tpl.html';

		$squelettePhp = $this->conteneur->getSquelettePhp();

		return $squelettePhp->analyser($messageSquelette, $donnees);

	}

	protected function envoyerMessage($message, $auteur) {

		$url_requete = sprintf($this->conteneur->getParametre('url_service_messagerie'), $auteur);

		$post = array(

			'sujet' => $this->conteneur->getParametre('titre_message_recapitulatif'),

			'message' => $message,

			'utilisateur_courriel' => $this->conteneur->getParametre('adresse_expediteur_recapitulatif'),

			'format' => 'html'

		);

		$ch = curl_init();

		$options = array(

			CURLOPT_URL => $url_requete,

			CURLOPT_HEADER => false,

			CURLOPT_POST => 1,

			CURLOPT_POSTFIELDS => $post,

			CURLOPT_RETURNTRANSFER => true

		);

		curl_setopt_array($ch, $options);

		curl_exec($ch);

		curl_close($ch);

	}

}

?>