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, 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 AlerteMailADeterminer {

	private $conteneur;

	private $testeurCourriel = null;

	private $recapitulatifAdmin = [];

	private $messageRecapitulatif = null;

	private $observations_concernees = array();

	private $messageHtml = null;

	private $messageTxt = null;

	public function __construct($conteneur) {

		$this->conteneur = $conteneur;

	}

	public function executer() {

		try {

			$this->verifierModeUtilisation();

			$observations = $this->chargerObsADeterminer();

			if (!empty($observations)) {

				$this->formaterObservations($observations);

				$this->genererMessage();

				$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);

			}

		}

	}

	protected function chargerObsADeterminer() {

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

		$requete = "SELECT * ".

			"FROM del_obs_image AS doi ".

			"	INNER JOIN del_observation AS do ON doi.id_observation = do.id_observation ".

			"	LEFT JOIN del_utilisateur AS du ON do.ce_utilisateur = du.id_utilisateur AND do.ce_utilisateur != 0 ".

			'WHERE (do.mots_cles_texte LIKE "%aDeterminer%" '.

			'		OR nom_sel IS NULL OR nom_sel = "" '.

			'		OR nom_ret IS NULL OR nom_ret = "") '.

			'	AND ('.

			'		do.date_transmission > DATE_SUB(CURDATE(), INTERVAL 1 DAY) '.

			'		OR do.date_creation > DATE_SUB(CURDATE(), INTERVAL 1 DAY) '.

			'		OR do.date_modification > DATE_SUB(CURDATE(), INTERVAL 1 DAY) '.

			'	) '.

			"ORDER BY do.id_observation ";

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

		return $obs;

	}

	private function formaterObservations($liste_obs) {

		foreach ($liste_obs as $obs) {

			$id_obs = $obs['id_observation'];

			$infos = array();

			$infos['id'] = $id_obs;

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

			$infos['nom_propose'] = $this->formaterNomSci($obs);

			$infos['lien'] = $this->obtenirLienFicheObs($id_obs);

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

			$this->observations_concernees[$id_obs] = $infos;

		}

	}

	private function formaterDateObs($date) {

		$dateFmt = '(date inconnue)';

		if ($date != '0000-00-00 00:00:00') {

			$time = strtotime($date);

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

		}

		return $dateFmt;

	}

	private function formaterNomSci($obs) {

		$nom = 'Espèce indéterminée';

		if ($obs['nom_ret'] != '') {

			$nom = $obs['nom_ret'];

		} else if($obs['nom_sel'] != '') {

			$nom = $obs['nom_sel'];

		}

		return $nom;

	}

	private function obtenirLienFicheObs($id_obs) {

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

	}

	private function formaterLieu($obs) {

		$lieuInfos = [];

		$champsLieu = ['zone_geo', 'lieudit', 'station'];

		foreach ($champsLieu as $champ) {

			if (trim($obs[$champ]) != '') {

				$lieuIntitule = $obs[$champ];

				if ($champ == 'zone_geo') {

					$codeDept = $this->convertirCodeZoneGeoVersDepartement($obs['ce_zone_geo']);

					$lieuIntitule .= empty($codeDept) ? '' : " ($codeDept)";

				}

				$lieuInfos[] = $lieuIntitule;

			}

		}

		$lieu = (count($lieuInfos) > 0) ? implode(' > ', $lieuInfos) : '(lieu inconnu)';

		return $lieu;

	}

	private function convertirCodeZoneGeoVersDepartement($code_zone_geo) {

		$code_departement = '';

		if (preg_match('/^INSEE-C:([0-9]){2}[0-9]{3}$/', $code_a_tester, $match)) {

			$code_departement = $match[1];

		}

		return $code_departement;

	}

	private function genererMessage() {

		if ($this->messageHtml == null && $this->messageTxt == null) {

			$donnees = array();

			$donnees['liste_observations'] = $this->observations_concernees;

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

			$messageHtmlTpl = dirname(__FILE__).DS.'squelettes'.DS.'aDeterminer.tpl.html';

			$this->messageHtml =  $squelettePhp->analyser($messageHtmlTpl, $donnees);

			$messageTxtTpl = dirname(__FILE__).DS.'squelettes'.DS.'aDeterminer.tpl.txt';

			$this->messageTxt =  $squelettePhp->analyser($messageTxtTpl, $donnees);

		}

	}

	private function envoyerMessageAuxDestinataires() {

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

			$this->envoyerMessageAuxUtilisateurs();

			$this->envoyerMessageListeDetermination();

			$this->envoyerMessageRecap();

		} else {

			$this->envoyerMessageTesteur();

		}

	}

	private function envoyerMessageAuxUtilisateurs() {

		$utilisateurs = $this->obtenirDestinatairesMailsRecapitulatif();

		foreach ($utilisateurs as $utilisateur) {

			$this->envoyerMessage($utilisateur['id_utilisateur']);

		}

	}

	private function obtenirDestinatairesMailsRecapitulatif() {

		if (count($this->recapitulatifAdmin) == 0) {

			$preference = $this->conteneur->getBdd()->proteger('%"mail_notification_toutes_obs":"1"%');

			$requete = "SELECT id_utilisateur ".

				"FROM del_utilisateur_infos ".

				"WHERE preferences LIKE $preference ";

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

			foreach ($utilisateurs as $utilisateur) {

				$this->recapitulatifAdmin[] = $utilisateur['id_utilisateur'];

			}

		}

		return $this->recapitulatifAdmin;

	}

	/**

	 * Appelle le web service message de l'annuaire afin d'envoyer un mail à l'utilisateur dont l'identifiant est donné

	 * en paramètre

	 * Enter description here ...

	 * @param string $message

	 * @param int $id_destinataire

	 */

	private function envoyerMessage($id_destinataire) {

		$url = sprintf($this->conteneur->getParametre('url_service_messagerie'), $id_destinataire);

		$donnees = array(

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

			'format' => 'html',

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

			'message' => $this->messageHtml,

			'message_txt' => $this->messageTxt

		);

		$clientRest = $this->conteneur->getRestClient();

		$clientRest->modifier($url, $donnees);

	}

	/** La liste détermination n'étant pas un membre de tela botanica,

	* on lui envoie un message directement

	* @return boolean true ou false suivant le succès ou non de l'envoi

	*/

	private function envoyerMessageListeDetermination() {

		$destinataires = $this->conteneur->getParametre('adresse_destinataire_recapitulatif_determination');

		$sujet = $this->conteneur->getParametre('titre_message_recapitulatif_obs');

		$messagerie = $this->conteneur->getMessagerie();

		$envoieStatut = $messagerie->envoyerHtml($destinataires, $sujet, $this->messageHtml, $this->messageTxt);

		return $envoieStatut;

	}

	private function envoyerMessageRecap() {

		$msgRecap = $this->obtenirMessageRecap();

		$sujet = "IdentiPlante : récapitulatif envoies alertes à déterminer";

		$messagerie = $this->conteneur->getMessagerie();

		$destinataire = $this->conteneur->getParametre('email_recap');

		$messagerie->envoyerTxt($destinataire, $sujet, $msgRecap);

	}

	private function obtenirMessageRecap() {

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

			$utilisateursIntitules = $this->obtenirInfosUtilisateurs();

			$intituleRecap = implode("\n", $utilisateursIntitules);

			$separateur = str_repeat('-', 50);

			$msgTpl = "Messages envoyés aux utilisateurs suivant :\n%s\n%s\n%s";

			$this->messageRecapitulatif = sprintf($msgTpl, $intituleRecap, $separateur, $this->messageTxt);

		}

		return $this->messageRecapitulatif;

	}

	private function obtenirInfosUtilisateurs() {

		$clientRest = $this->conteneur->getRestClient();

		$urlTpl = $this->conteneur->getParametre('url_service_utilisateur');

		$utilisateursIntitules = [];

		$utilisateurs = $this->obtenirDestinatairesMailsRecapitulatif();

		foreach ($utilisateurs as $utilisateurId) {

			$url = sprintf($urlTpl, $utilisateurId);

			$json = $clientRest->consulter($url);

			$infosUtilisateur = json_decode($json);

			if (isset($infosUtilisateur->courriel) && isset($infosUtilisateur->intitule)) {

				$prenomNom = $infosUtilisateur->nom.' '.$infosUtilisateur->prenom;

				$pseudo = $infosUtilisateur->pseudoUtilise ? ' ['.$infosUtilisateur->pseudo.']' : '';

				$courriel = $infosUtilisateur->courriel;

				$intitule = "$prenomNom $pseudo ($courriel) - id#$utilisateurId";

			} else {

				$intitule = "Utilisateur avec id $utilisateurId introuvable";

			}

			$utilisateursIntitules[$utilisateurId] = $intitule;

		}

		asort($utilisateursIntitules);

		return $utilisateursIntitules;

	}

	private function envoyerMessageTesteur() {

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

			$messagerie = $this->conteneur->getMessagerie();

			$sujet = "TESTEUR : récapitulatif envoies alertes à déterminer";

			$msgRecap = $this->obtenirMessageRecap();

			$messagerie->envoyerTxt($this->testeurCourriel, $sujet, $msgRecap);

			$sujet = "TESTEUR : exemple message HTML - alerte à déterminer";

			$messagerie->envoyerHtml($this->testeurCourriel, $sujet, $this->messageHtml, $this->messageTxt);

			$sujet = "TESTEUR : exemple message TXT - alerte à déterminer";

			$messagerie->envoyerTxt($this->testeurCourriel, $sujet, $this->messageTxt);

		}

	}

}