Subversion Repositories Applications.annuaire

<?php

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

/**

 * Modèle d'accès à la base de données des listes

 * d'ontologies

 *

 * PHP Version 5

 *

 * @package   Framework

 * @category  Class

 * @author	aurelien <aurelien@tela-botanica.org>

 * @copyright 2009 Tela-Botanica

 * @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL

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

 * @version   SVN: $$Id: ListeAdmin.php 128 2009-09-02 12:20:55Z aurelien $$

 * @link	  /doc/framework/

 *

 */

class AnnuaireModele extends Modele {

	private $config = array();

	/**

	 * Charge la liste complète des listes

	 * return array un tableau contenant des objets d'informations sur les listes

	 * @return array un tableau d'objets contenant la liste des listes

	 */

   	public function chargerListeAnnuaire() {

		$requete = 	'SELECT * '.

					'FROM  annu_annuaire '.

					'ORDER BY aa_id_annuaire';

		$resultat = $this->requeteTous($requete);

		$annuaires = array();

		foreach ($resultat as $ligne) {

			$annuaires[] = $ligne;

		}

		return $annuaires;

	}

	/**

	 * Charge la liste complète des champs d'un annuaire

	 * @param int $identifiant l'identifiant de l'annuaire demandé

	 * @param boolean $charger_liste_champs indique si l'on doit ou non charger la liste des noms des champs

	 * @return array un tableau contenant des objets d'informations sur les annuaires

	 */

   	public function chargerAnnuaire($identifiant, $charger_liste_champs = true) {

		$requete = 	'SELECT * '.

					'FROM  annu_annuaire '.

					'WHERE aa_id_annuaire = '.$identifiant.' ';

		$resultat = $this->requeteTous($requete);

		$annuaire = array();

		foreach ($resultat as $ligne) {

			$annuaire['informations'] = $ligne;

		}

		if($charger_liste_champs) {

			$requete = 'DESCRIBE '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'];

			$resultat = $this->requeteTous($requete);

			foreach ($resultat as $colonne) {

				$annuaire['colonnes'][] = $colonne;

			}

		}

		return $annuaire;

	}

	/** Charge le nombre d'inscrits d'une table annuaire mappée

	 * @param int $identifiant l'identifiant de l'annuaire mappé

	 *

	 */

   	public function chargerNombreAnnuaireListeInscrits($identifiant) {

		$requete_informations_annuaire = 	'SELECT aa_bdd, aa_table '.

					'FROM  annu_annuaire '.

					'WHERE aa_id_annuaire = '.$identifiant.' ';

		$resultat_informations_annuaire = $this->requeteUn($requete_informations_annuaire);

		if(!$resultat_informations_annuaire) {

			trigger_error('impossible de récupérer les informations de la table '.$identifiant);

		}

		$requete_nombre_inscrits = 'SELECT COUNT(*) as nom_inscrits'.

				' FROM '.$resultat_informations_annuaire['aa_bdd'].'.'.$resultat_informations_annuaire['aa_table'];

		if(!$resultat_informations_annuaire) {

			trigger_error('impossible de récupérer le nombre d\'inscrits de la table '.$resultat_informations_annuaire['aa_bdd'].'.'.$resultat_informations_annuaire['aa_table']);

		}

		$resultat_nombre_inscrits = $this->requeteUn($requete_nombre_inscrits);

		return $resultat_nombre_inscrits['nom_inscrits'] ;

	}

	/**

	 * Charge les inscrits d'une table annuaire mappée, en ne conservant que les champs de mappage indiqués

	 * @param int $identifiant l'identifiant de l'annuaire mappé

	 * @param Array $champs_mappage les champs de mappage à retenir

	 * @param int $numero_page le numéro de la page demandée

	 * @param int $taille_page la taille de la page demandée

	 *

	 */

   	public function chargerAnnuaireListeInscrits($identifiant, $champs_mappage, $numero_page = 1, $taille_page = 50) {

		$requete = 	'SELECT * '.

					'FROM  annu_annuaire '.

					'WHERE aa_id_annuaire = '.$identifiant.' ';

		$resultat = $this->requeteTous($requete);

		$annuaire = array();

		foreach ($resultat as $ligne) {

			$annuaire['informations'] = $ligne;

		}

		$annuaire['colonnes'] = $champs_mappage;

		$string_champs_mappage = implode(",", $champs_mappage);

		$requete = 'SELECT '.$string_champs_mappage.

				' FROM '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'].

				' ORDER BY '.$champs_mappage['champ_id'].

				' LIMIT '.(($numero_page-1)*$taille_page).','.($taille_page);

		$resultat = $this->requeteTous($requete);

		foreach ($resultat as $colonne) {

			$annuaire['inscrits'][] = $colonne;

		}

		return $annuaire;

	}

	/**

	 * Insère une nouvelle ligne dans la table d'inscription temporaire, contenant

	 * les données sérialisées d'un utilisateur

	 * @param string $identifiant l'identifiant de cette tentative

	 * @param string $donnees les données d'inscription (une variable sérialisée))

	 * @return PdoStatement en cas de succès, false sinon

	 */

	public function ajouterNouvelleInscriptionTemporaire($identifiant, $donnees) {

		// on protège et on sérialise les données

		$identifiant = $this->proteger($identifiant);

		$donnees = serialize($donnees);

		$donnees = $this->proteger($donnees);

		// FIXME: les accents sautent alors que l'encodage est le bon ! Pourquoi ?

		$requete = 	'INSERT INTO annu_inscription_temp '.

					'VALUES '.

					'('.$identifiant.','.$donnees.', NOW()) ';

		return $this->requete($requete);

	}

	/**

	 * Récupère une ligne dans la table d'inscription temporaire, contenant

	 * les données sérialisées d'un utilisateur

	 * @param string $identifiant l'identifiant de la tentative

	 * @return Array en cas de succès, false sinon

	 */

	public function chargerDonneesInscriptionTemporaire($identifiant) {

		$identifiant = $this->proteger($identifiant);

		$requete = 	'SELECT * FROM annu_inscription_temp '.

					'WHERE '.

					'ait_id = '.$identifiant;

		$donnees_inscription = $this->requeteUn($requete);

		if($donnees_inscription) {

			return unserialize($donnees_inscription['ait_donnees']);

		}

		return false;

	}

	/**

	 * Supprime une ligne dans la table d'inscription temporaire, contenant

	 * les données sérialisées d'un utilisateur

	 * @param string $identifiant l'identifiant de la tentative

	 * @return PDOStatement en cas de succès, false sinon

	 */

	public function supprimerDonneesInscriptionTemporaire($identifiant) {

		$identifiant = $this->proteger($identifiant);

		$requete = 	'DELETE FROM annu_inscription_temp '.

					'WHERE '.

					'ait_id = '.$identifiant;

		return $this->requete($requete);

	}

	/**

	 * Ajoute les valeurs données dans l'annuaire indiqué

	 * @param int $id_annuaire	l'identifiant de l'annuaire dans lequel on va travailler

	 * @param Array $valeurs_mappees un tableau de valeurs à ajouter

	 * @param string $nom_champs les noms des champs dans lesquels on va ajouter les données

	 * @return int l'identifiant du nouvel enregistrement

	 */

	public function ajouterDansAnnuaireMappe($id_annuaire, $valeurs_mappees, $nom_champs) {

		$requete_infos_annuaire = 'SELECT * '.

					'FROM  annu_annuaire '.

					'WHERE aa_id_annuaire = '.$id_annuaire.' ';

		$resultat = $this->requeteUn($requete_infos_annuaire);

		$annuaire = array();

		//en cas d'erreur on renvoie false

		//TODO: lever une exception

		if(!$resultat) {

			return false;

		}

		$annuaire = $resultat;

		$valeurs_prot = array_map(array($this,'proteger'),$valeurs_mappees);

		$valeurs = implode(',',$valeurs_prot);

		$champs = implode(',',array_keys($valeurs_mappees));

		$requete_insertion_annuaire = 'INSERT INTO '.$annuaire['aa_bdd'].'.'.$annuaire['aa_table'].' '.

			'('.$champs.') '.

			'VALUES ('.$valeurs.')';

		$id_nouvel_enregistrement = false;

		//en cas d'erreur on renvoie false

		//TODO: lever une exception

		if(!$this->requete($requete_insertion_annuaire)) {

			return $id_nouvel_enregistrement;

		}

		// le mail est censé être unique donc on l'utilise pour faire une selection pour retrouver l'enregistrement

		// (je n'aime pas les requete du style SELECT MAX(id)... qui ne garantissent pas qu'on récupère le bon id

		// si une autre insertion a eu lieu entre temps)

		// TODO: voir si le standard sql propose quelque chose pour ce problème

		$requete_nouvel_id = 	'SELECT '.$nom_champs['champ_id'].' '.

								'FROM '.$annuaire['aa_bdd'].'.'.$annuaire['aa_table'].' '.

								'WHERE '.

								$nom_champs['champ_mail'].' = '.$this->proteger($valeurs_mappees[$nom_champs['champ_mail']]);

		$resultat_nouvel_id = $this->requeteUn($requete_nouvel_id);

		// en cas d'erreur on renvoie false

		// TODO: lever une exception

		if(!$resultat_nouvel_id) {

			return $id_nouvel_enregistrement;

		}

		$id_nouvel_enregistrement = $resultat_nouvel_id[$nom_champs['champ_id']];

		return $id_nouvel_enregistrement;

	}

	/**

	 * Récupère les champs demandé dans l'annuaire indiqué

	 * @param int $id_annuaire	l'identifiant de l'annuaire dans lequel on va travailler

	 * @param int $id_utilisateur l'identifiant de l'utilisateur dont on veut les informations

	 * @param Array $champs_mappage les noms des champs que l'on veut récupérer

	 * @return Array les informations demandées

	 */

	public function obtenirValeursUtilisateur($id_annuaire, $id_utilisateur,$champs_mappage) {

		$requete_infos_annuaire = 'SELECT * '.

					'FROM annu_annuaire '.

					'WHERE aa_id_annuaire = '.$id_annuaire.' ';

		$resultat_infos_annuaire = $this->requeteUn($requete_infos_annuaire);

		// en cas d'erreur on renvoie false

		// TODO: lever une exception

		if(!$resultat_infos_annuaire) {

			return false;

		}

		$champs_mappage_str = implode(',',$champs_mappage);

		$id_utilisateur = $this->proteger($id_utilisateur);

		$requete_selection_utilisateur = 'SELECT '.$champs_mappage_str.' '.

										 'FROM '.$resultat_infos_annuaire['aa_bdd'].'.'.$resultat_infos_annuaire['aa_table'].' '.

										 'WHERE '.$champs_mappage['champ_id'].' = '.$id_utilisateur;

		$resultat_selection_utilisateur = $this->requeteUn($requete_selection_utilisateur);

		// en cas d'erreur on renvoie false

		// TODO: lever une exception

		if(!$resultat_selection_utilisateur) {

			return false;

		} else {

			return $resultat_selection_utilisateur;

		}

	}

}

?>