Subversion Repositories Applications.annuaire

Rev

Rev 4 | Rev 7 | Go to most recent revision | Only display areas with differences | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 4 Rev 5
1
<?php
1
<?php
2
// declare(encoding='UTF-8');
2
// declare(encoding='UTF-8');
3
/**
3
/**
4
 * Modèle d'accès à la base de données des listes
4
 * Modèle d'accès à la base de données des listes
5
 * d'ontologies
5
 * d'ontologies
6
 *
6
 *
7
 * PHP Version 5
7
 * PHP Version 5
8
 *
8
 *
9
 * @package   Framework
9
 * @package   Framework
10
 * @category  Class
10
 * @category  Class
11
 * @author	aurelien <aurelien@tela-botanica.org>
11
 * @author	aurelien <aurelien@tela-botanica.org>
12
 * @copyright 2009 Tela-Botanica
12
 * @copyright 2009 Tela-Botanica
13
 * @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
13
 * @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
14
 * @license   http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
14
 * @license   http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
15
 * @version   SVN: $$Id: ListeAdmin.php 128 2009-09-02 12:20:55Z aurelien $$
15
 * @version   SVN: $$Id: ListeAdmin.php 128 2009-09-02 12:20:55Z aurelien $$
16
 * @link	  /doc/framework/
16
 * @link	  /doc/framework/
17
 *
17
 *
18
 */
18
 */
19
class AnnuaireModele extends Modele {
19
class AnnuaireModele extends Modele {
20
 
20
 
21
	private $config = array();
21
	private $config = array();
22
 
22
 
23
	/**
23
	/**
24
	 * Charge la liste complète des listes
24
	 * Charge la liste complète des listes
25
	 * return array un tableau contenant des objets d'informations sur les listes
25
	 * return array un tableau contenant des objets d'informations sur les listes
26
	 * @return array un tableau d'objets contenant la liste des listes
26
	 * @return array un tableau d'objets contenant la liste des listes
27
	 */
27
	 */
28
   	public function chargerListeAnnuaire() {
28
   	public function chargerListeAnnuaire() {
29
		$requete = 	'SELECT * '.
29
		$requete = 	'SELECT * '.
30
					'FROM  annu_annuaire '.
30
					'FROM  annu_annuaire '.
31
					'ORDER BY aa_id_annuaire';
31
					'ORDER BY aa_id_annuaire';
32
		$resultat = $this->requeteTous($requete);
32
		$resultat = $this->requeteTous($requete);
33
		$annuaires = array();
33
		$annuaires = array();
34
		foreach ($resultat as $ligne) {
34
		foreach ($resultat as $ligne) {
35
			$annuaires[] = $ligne;
35
			$annuaires[] = $ligne;
36
		}
36
		}
37
		return $annuaires;
37
		return $annuaires;
38
	}
38
	}
39
 
39
 
40
	/**
40
	/**
41
	 * Charge la liste complète des champs d'un annuaire
41
	 * Charge la liste complète des champs d'un annuaire
42
	 * @param int $identifiant l'identifiant de l'annuaire demandé
42
	 * @param int $identifiant l'identifiant de l'annuaire demandé
43
	 * @param boolean $charger_liste_champs indique si l'on doit ou non charger la liste des noms des champs
43
	 * @param boolean $charger_liste_champs indique si l'on doit ou non charger la liste des noms des champs
44
	 * @return array un tableau contenant des objets d'informations sur les annuaires
44
	 * @return array un tableau contenant des objets d'informations sur les annuaires
45
	 */
45
	 */
46
   	public function chargerAnnuaire($identifiant, $charger_liste_champs = true) {
46
   	public function chargerAnnuaire($identifiant, $charger_liste_champs = true) {
47
 
47
 
48
		$requete = 	'SELECT * '.
48
		$requete = 	'SELECT * '.
49
					'FROM  annu_annuaire '.
49
					'FROM  annu_annuaire '.
50
					'WHERE aa_id_annuaire = '.$identifiant.' ';
50
					'WHERE aa_id_annuaire = '.$identifiant.' ';
51
		$resultat = $this->requeteTous($requete);
51
		$resultat = $this->requeteTous($requete);
52
		$annuaire = array();
52
		$annuaire = array();
53
		foreach ($resultat as $ligne) {
53
		foreach ($resultat as $ligne) {
54
			$annuaire['informations'] = $ligne;
54
			$annuaire['informations'] = $ligne;
55
		}
55
		}
56
 
56
 
57
		if($charger_liste_champs) {
57
		if($charger_liste_champs) {
58
			$requete = 'DESCRIBE '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'];
58
			$requete = 'DESCRIBE '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'];
59
			$resultat = $this->requeteTous($requete);
59
			$resultat = $this->requeteTous($requete);
60
			foreach ($resultat as $colonne) {
60
			foreach ($resultat as $colonne) {
61
				$annuaire['colonnes'][] = $colonne;
61
				$annuaire['colonnes'][] = $colonne;
62
			}
62
			}
63
		}
63
		}
64
 
64
 
65
		return $annuaire;
65
		return $annuaire;
66
	}
66
	}
67
 
67
 
68
	/**
68
	/**
69
	 * Charge les inscrits d'une table annuaire mappée, en ne conservant que les champs de mappage indiqués
69
	 * Charge les inscrits d'une table annuaire mappée, en ne conservant que les champs de mappage indiqués
70
	 */
70
	 */
71
   	public function chargerAnnuaireListeInscrits($identifiant, $champs_mappage, $page, $taille_page = 50) {
71
   	public function chargerAnnuaireListeInscrits($identifiant, $champs_mappage, $page, $taille_page = 50) {
72
 
72
 
73
		$requete = 	'SELECT * '.
73
		$requete = 	'SELECT * '.
74
					'FROM  annu_annuaire '.
74
					'FROM  annu_annuaire '.
75
					'WHERE aa_id_annuaire = '.$identifiant.' ';
75
					'WHERE aa_id_annuaire = '.$identifiant.' ';
76
		$resultat = $this->requeteTous($requete);
76
		$resultat = $this->requeteTous($requete);
77
		$annuaire = array();
77
		$annuaire = array();
78
		foreach ($resultat as $ligne) {
78
		foreach ($resultat as $ligne) {
79
			$annuaire['informations'] = $ligne;
79
			$annuaire['informations'] = $ligne;
80
		}
80
		}
81
 
81
 
82
		$annuaire['colonnes'] = $champs_mappage;
82
		$annuaire['colonnes'] = $champs_mappage;
83
 
83
 
84
		$string_champs_mappage = implode(",", $champs_mappage);
84
		$string_champs_mappage = implode(",", $champs_mappage);
85
 
85
 
86
		$requete = 'SELECT '.$string_champs_mappage.' FROM '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'].' LIMIT '.($page-1).','.($page*$taille_page);
86
		$requete = 'SELECT '.$string_champs_mappage.' FROM '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'].' LIMIT '.($page-1).','.($page*$taille_page);
87
 
87
 
88
		$resultat = $this->requeteTous($requete);
88
		$resultat = $this->requeteTous($requete);
89
		foreach ($resultat as $colonne) {
89
		foreach ($resultat as $colonne) {
90
			$annuaire['inscrits'][] = $colonne;
90
			$annuaire['inscrits'][] = $colonne;
91
		}
91
		}
92
 
92
 
93
		return $annuaire;
93
		return $annuaire;
94
	}
94
	}
95
 
95
 
96
	/**
96
	/**
97
	 * Insère une nouvelle ligne dans la table d'inscription temporaire, contenant
97
	 * Insère une nouvelle ligne dans la table d'inscription temporaire, contenant
98
	 * les données sérialisées d'un utilisateur
98
	 * les données sérialisées d'un utilisateur
99
	 * @param string $identifiant l'identifiant de cette tentative
99
	 * @param string $identifiant l'identifiant de cette tentative
100
	 * @param string $donnees les données d'inscription (une variable sérialisée))
100
	 * @param string $donnees les données d'inscription (une variable sérialisée))
101
	 * @return PdoStatement en cas de succès, false sinon
101
	 * @return PdoStatement en cas de succès, false sinon
102
	 */
102
	 */
103
	public function ajouterNouvelleInscriptionTemporaire($identifiant, $donnees) {
103
	public function ajouterNouvelleInscriptionTemporaire($identifiant, $donnees) {
104
 
104
 
105
		// on protège et on sérialise les données
105
		// on protège et on sérialise les données
106
		$identifiant = $this->proteger($identifiant);
106
		$identifiant = $this->proteger($identifiant);
107
		$donnees = serialize($donnees);
107
		$donnees = serialize($donnees);
108
		$donnees = $this->proteger($donnees);
108
		$donnees = $this->proteger($donnees);
109
 
109
 
110
		// FIXME: les accents sautent alors que l'encodage est le bon ! Pourquoi ?
110
		// FIXME: les accents sautent alors que l'encodage est le bon ! Pourquoi ?
111
 
-
 
112
		$requete = 	'INSERT INTO annu_inscription_temp '.
111
		$requete = 	'INSERT INTO annu_inscription_temp '.
113
					'VALUES '.
112
					'VALUES '.
114
					'('.$identifiant.','.$donnees.', NOW()) ';
113
					'('.$identifiant.','.$donnees.', NOW()) ';
115
 
114
 
116
		return $this->requete($requete);
115
		return $this->requete($requete);
117
	}
116
	}
118
 
117
 
119
	/**
118
	/**
120
	 * Récupère une ligne dans la table d'inscription temporaire, contenant
119
	 * Récupère une ligne dans la table d'inscription temporaire, contenant
121
	 * les données sérialisées d'un utilisateur
120
	 * les données sérialisées d'un utilisateur
122
	 * @param string $identifiant l'identifiant de la tentative
121
	 * @param string $identifiant l'identifiant de la tentative
123
	 * @return Array en cas de succès, false sinon
122
	 * @return Array en cas de succès, false sinon
124
	 */
123
	 */
125
	public function chargerDonneesInscriptionTemporaire($identifiant) {
124
	public function chargerDonneesInscriptionTemporaire($identifiant) {
126
 
125
 
127
		$identifiant = $this->proteger($identifiant);
126
		$identifiant = $this->proteger($identifiant);
128
 
127
 
129
		$requete = 	'SELECT * FROM annu_inscription_temp '.
128
		$requete = 	'SELECT * FROM annu_inscription_temp '.
130
					'WHERE '.
129
					'WHERE '.
131
					'ait_id = '.$identifiant;
130
					'ait_id = '.$identifiant;
132
 
131
 
133
		$donnees_inscription = $this->requeteUn($requete);
132
		$donnees_inscription = $this->requeteUn($requete);
134
 
133
 
135
		if($donnees_inscription) {
134
		if($donnees_inscription) {
136
			return unserialize($donnees_inscription['ait_donnees']);
135
			return unserialize($donnees_inscription['ait_donnees']);
137
		}
136
		}
138
 
137
 
139
		return false;
138
		return false;
140
	}
139
	}
141
 
140
 
142
	/**
141
	/**
143
	 * Supprime une ligne dans la table d'inscription temporaire, contenant
142
	 * Supprime une ligne dans la table d'inscription temporaire, contenant
144
	 * les données sérialisées d'un utilisateur
143
	 * les données sérialisées d'un utilisateur
145
	 * @param string $identifiant l'identifiant de la tentative
144
	 * @param string $identifiant l'identifiant de la tentative
146
	 * @return PDOStatement en cas de succès, false sinon
145
	 * @return PDOStatement en cas de succès, false sinon
147
	 */
146
	 */
148
	public function supprimerDonneesInscriptionTemporaire($identifiant) {
147
	public function supprimerDonneesInscriptionTemporaire($identifiant) {
149
 
148
 
150
		$identifiant = $this->proteger($identifiant);
149
		$identifiant = $this->proteger($identifiant);
151
 
150
 
152
		$requete = 	'DELETE FROM annu_inscription_temp '.
151
		$requete = 	'DELETE FROM annu_inscription_temp '.
153
					'WHERE '.
152
					'WHERE '.
154
					'ait_id = '.$identifiant;
153
					'ait_id = '.$identifiant;
155
 
154
 
156
		return $this->requete($requete);
155
		return $this->requete($requete);
157
	}
156
	}
-
 
157
 
-
 
158
	/**
-
 
159
	 * Ajoute les valeurs données dans l'annuaire indiqué
-
 
160
	 * @param int $id_annuaire	l'identifiant de l'annuaire dans lequel on va travailler
-
 
161
	 * @param Array $valeurs_mappees un tableau de valeurs à ajouter
-
 
162
	 * @param string $nom_champs les noms des champs dans lesquels on va ajouter les données
-
 
163
	 * @return int l'identifiant du nouvel enregistrement
158
 
164
	 */
159
	public function ajouterDansAnnuaireMappe($id_annuaire, $valeurs_mappees, $nom_champs) {
165
	public function ajouterDansAnnuaireMappe($id_annuaire, $valeurs_mappees, $nom_champs) {
160
 
166
 
161
		$requete_infos_annuaire = 'SELECT * '.
167
		$requete_infos_annuaire = 'SELECT * '.
162
					'FROM  annu_annuaire '.
168
					'FROM  annu_annuaire '.
163
					'WHERE aa_id_annuaire = '.$id_annuaire.' ';
169
					'WHERE aa_id_annuaire = '.$id_annuaire.' ';
164
 
170
 
165
		$resultat = $this->requeteTous($requete_infos_annuaire);
171
		$resultat = $this->requeteUn($requete_infos_annuaire);
-
 
172
		$annuaire = array();
-
 
173
 
-
 
174
		//en cas d'erreur on renvoie false
166
		$annuaire = array();
175
		//TODO: lever une exception
167
		foreach ($resultat as $ligne) {
176
		if(!$resultat) {
168
			$annuaire['informations'] = $ligne;
177
			return false;
-
 
178
		}
-
 
179
 
169
		}
180
		$annuaire = $resultat;
170
 
181
 
171
		$valeurs_prot = array_map(array($this,'proteger'),$valeurs_mappees);
182
		$valeurs_prot = array_map(array($this,'proteger'),$valeurs_mappees);
172
 
183
 
173
		$valeurs = implode(',',$valeurs_prot);
184
		$valeurs = implode(',',$valeurs_prot);
174
		$champs = implode(',',array_keys($valeurs_mappees));
185
		$champs = implode(',',array_keys($valeurs_mappees));
175
 
186
 
176
		$requete_insertion_annuaire = 'INSERT INTO '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'].' '.
187
		$requete_insertion_annuaire = 'INSERT INTO '.$annuaire['aa_bdd'].'.'.$annuaire['aa_table'].' '.
177
			'('.$champs.') '.
188
			'('.$champs.') '.
178
			'VALUES ('.$valeurs.')';
189
			'VALUES ('.$valeurs.')';
179
 
190
 
180
		$id_nouvel_enregistrement = false;
191
		$id_nouvel_enregistrement = false;
181
 
192
 
182
		//en cas d'erreur on renvoie false
193
		//en cas d'erreur on renvoie false
183
		//TODO: lever une exception
194
		//TODO: lever une exception
184
		if(!$this->requete($requete_insertion_annuaire)) {
195
		if(!$this->requete($requete_insertion_annuaire)) {
185
			return $id_nouvel_enregistrement;
196
			return $id_nouvel_enregistrement;
186
		}
197
		}
-
 
198
 
-
 
199
		// le mail est censé être unique donc on l'utilise pour faire une selection pour retrouver l'enregistrement
-
 
200
		// (je n'aime pas les requete du style SELECT MAX(id)... qui ne garantissent pas qu'on récupère le bon id
-
 
201
		// si une autre insertion a eu lieu entre temps)
187
 
202
		// TODO: voir si le standard sql propose quelque chose pour ce problème
188
		$requete_nouvel_id = 	'SELECT '.$nom_champs['champ_id'].' '.
203
		$requete_nouvel_id = 	'SELECT '.$nom_champs['champ_id'].' '.
189
								'FROM '.$annuaire['informations']['aa_bdd'].'.'.$annuaire['informations']['aa_table'].' '.
204
								'FROM '.$annuaire['aa_bdd'].'.'.$annuaire['aa_table'].' '.
190
								'WHERE '.
205
								'WHERE '.
191
								$nom_champs['champ_mail'].' = '.$this->proteger($valeurs_mappees[$nom_champs['champ_mail']]);
206
								$nom_champs['champ_mail'].' = '.$this->proteger($valeurs_mappees[$nom_champs['champ_mail']]);
192
 
207
 
193
		$resultat_nouvel_id = $this->requeteUn($requete_nouvel_id);
208
		$resultat_nouvel_id = $this->requeteUn($requete_nouvel_id);
194
 
209
 
195
		// en cas d'erreur on renvoie false
210
		// en cas d'erreur on renvoie false
196
		// TODO: lever une exception
211
		// TODO: lever une exception
197
		if(!$resultat_nouvel_id) {
212
		if(!$resultat_nouvel_id) {
198
			return $id_nouvel_enregistrement;
213
			return $id_nouvel_enregistrement;
199
		}
214
		}
200
 
215
 
201
		$id_nouvel_enregistrement = $resultat_nouvel_id[$nom_champs['champ_id']];
216
		$id_nouvel_enregistrement = $resultat_nouvel_id[$nom_champs['champ_id']];
202
 
217
 
203
		return $id_nouvel_enregistrement;
218
		return $id_nouvel_enregistrement;
204
	}
219
	}
-
 
220
 
-
 
221
	/**
-
 
222
	 * Récupère les champs demandé dans l'annuaire indiqué
-
 
223
	 * @param int $id_annuaire	l'identifiant de l'annuaire dans lequel on va travailler
-
 
224
	 * @param int $id_utilisateur l'identifiant de l'utilisateur dont on veut les informations
-
 
225
	 * @param Array $champs_mappage les noms des champs que l'on veut récupérer
-
 
226
	 * @return Array les informations demandées
205
 
227
	 */
206
	public function obtenirValeursUtilisateur($id_annuaire, $id_utilisateur,$champs_mappage) {
228
	public function obtenirValeursUtilisateur($id_annuaire, $id_utilisateur,$champs_mappage) {
207
 
229
 
208
		$requete_infos_annuaire = 'SELECT * '.
230
		$requete_infos_annuaire = 'SELECT * '.
209
					'FROM annu_annuaire '.
231
					'FROM annu_annuaire '.
210
					'WHERE aa_id_annuaire = '.$id_annuaire.' ';
232
					'WHERE aa_id_annuaire = '.$id_annuaire.' ';
211
 
233
 
212
		$resultat_infos_annuaire = $this->requeteUn($requete_infos_annuaire);
234
		$resultat_infos_annuaire = $this->requeteUn($requete_infos_annuaire);
-
 
235
 
213
		// en cas d'erreur on renvoie false
236
		// en cas d'erreur on renvoie false
214
		// TODO: lever une exception
237
		// TODO: lever une exception
215
		if(!$resultat_infos_annuaire) {
238
		if(!$resultat_infos_annuaire) {
216
			return false;
239
			return false;
217
		}
240
		}
218
 
241
 
219
		$champs_mappage_str = implode(',',$champs_mappage);
242
		$champs_mappage_str = implode(',',$champs_mappage);
220
		$id_utilisateur = $this->proteger($id_utilisateur);
243
		$id_utilisateur = $this->proteger($id_utilisateur);
221
 
244
 
222
		$requete_selection_utilisateur = 'SELECT '.$champs_mappage_str.' '.
245
		$requete_selection_utilisateur = 'SELECT '.$champs_mappage_str.' '.
223
										 'FROM '.$resultat_infos_annuaire['aa_bdd'].'.'.$resultat_infos_annuaire['aa_table'].' '.
246
										 'FROM '.$resultat_infos_annuaire['aa_bdd'].'.'.$resultat_infos_annuaire['aa_table'].' '.
224
										 'WHERE '.$champs_mappage['champ_id'].' = '.$id_utilisateur;
247
										 'WHERE '.$champs_mappage['champ_id'].' = '.$id_utilisateur;
225
 
248
 
226
		$resultat_selection_utilisateur = $this->requeteUn($requete_selection_utilisateur);
249
		$resultat_selection_utilisateur = $this->requeteUn($requete_selection_utilisateur);
227
 
250
 
228
		// en cas d'erreur on renvoie false
251
		// en cas d'erreur on renvoie false
229
		// TODO: lever une exception
252
		// TODO: lever une exception
230
		if(!$resultat_selection_utilisateur) {
253
		if(!$resultat_selection_utilisateur) {
231
			return false;
254
			return false;
232
		} else {
255
		} else {
233
			return $resultat_selection_utilisateur;
256
			return $resultat_selection_utilisateur;
234
		}
257
		}
235
	}
258
	}
236
}
259
}
237
?>
260
?>