Subversion Repositories eFlore/Applications.coel

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
1497 jpm 1
<?php
2
/**
3
 * Service fournissant la liste des structures et leurs informations.
4
 * Encodage en entrée : utf8
5
 * Encodage en sortie : utf8
6
 *
7
 * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
8
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
9
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
10
 * @version $Id$
11
 * @copyright 2009
12
 */
13
class CoelStructure extends Coel {
14
 
15
	// ATTENTION : tjrs garder la table principale en premier, puis mettre les tables spécialisées.
16
	protected $tables = array(	120 => array(
17
									'nom' => 'coel_structure',
18
									'prefixe' => 'cs',
19
									'id' => array('cs_id_structure')),
20
		   						122 => array(
21
		   							'nom' => 'coel_structure_conservation',
22
		   							'prefixe' => 'csc',
23
		   							'id' => array('csc_id_structure')),
24
		   						123 => array(
25
		   							'nom' => 'coel_structure_valorisation',
26
		   							'prefixe' => 'csv',
27
		   							'id' => array('csv_id_structure')));
28
 
29
	/**
30
	 * Méthode principale appelée avec une requête de type GET.
31
	 */
32
	public function getElement($param = array()) {
33
		// Initialisation des variables
34
		$info = array();
35
 
36
		// Nour recherchons le type de requête demandé
37
		$type = $param[0];
38
 
39
		if ($type == '*' || is_numeric($type)) {
40
			$info = $this->getElementParDefaut($param);
41
		} else {
42
			$methode = 'getElement'.$type;
43
			if (method_exists($this, $methode)) {
44
				array_shift($param);
45
				$info = $this->$methode($param);
46
			} else {
47
				$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
48
			}
49
		}
50
 
51
		// Envoie sur la sortie standard
52
		$this->envoyer($info);
53
	}
54
 
55
	/**
56
	 * Méthode par défaut pour garder la compatibilité avec Coel.
57
	 * Appelée avec les paramêtres d'url suivant :
58
	 * /CoelStructure/_/_/_
59
	 * ou les _ représentent dans l'ordre : id_projet, id_structure et nom
60
	 * Si un des paramêtres est abscent, il prendre la valeur *
61
	 */
62
	public function getElementParDefaut($param) {
63
		// Initialisation des variables
64
		$info = array();
65
 
66
		// Pré traitement des paramêtres
67
		$p = $this->traiterParametresUrl(array('id_projet', 'id_structure', 'nom'), $param);
68
 
69
		// Construction de la requête
70
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' cs.*, csc.*, csv.*, '.
71
					'	cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip '.
72
					'FROM coel_structure AS cs '.
73
					'	LEFT JOIN coel_meta_historique_ligne ON (cs_ce_meta = cmhl_id_historique_ligne) '.
74
					'	LEFT JOIN coel_structure_conservation AS csc ON (cs_id_structure = csc_id_structure) '.
75
					'	LEFT JOIN coel_structure_valorisation AS csv ON (cs_id_structure = csv_id_structure) '.
76
					((count($p) != 0) ? 'WHERE ' : '').
77
					((isset($p['id_projet'])) ? "AND cs_ce_projet = {$p['id_projet']} " : '').
78
					((isset($p['id_structure'])) ? "AND cs_id_structure = {$p['id_structure']} " : '').
79
					((isset($p['nom'])) ? "AND cs_nom LIKE {$p['nom']} " : '').
80
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'cs.cs_nom ASC').' ';
81
 
82
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
83
		$requete_compte = $requete;
84
		$requete .= "LIMIT $this->start, $this->limit ";
85
 
86
		// Récupération des résultats
87
		try {
88
			// SPÉCIAL :
89
			// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
1526 jpm 90
			$donnees = ($this->formatRetour == 'objet' && isset($p['id_structure'])) ? $this->bdd->query($requete)->fetch(PDO::FETCH_OBJ) : $this->bdd->query($requete)->fetchAll();
1497 jpm 91
			if ($donnees === false) {
92
				$this->messages[] = "La requête a retourné aucun résultat.";
93
			}
94
 
95
			$elements_nbre = $this->bdd->query($requete_compte)->rowCount();
96
			$info['nbElements'] = $elements_nbre;
97
			$info['structures'] = $donnees;
98
		} catch (PDOException $e) {
99
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
100
		}
101
 
102
		return $info;
103
	}
104
 
105
	/* Méthode pour récupérer le nombre de structure par zone géographique.
106
	 * Appelée avec les paramêtres d'url suivant :
107
	 * /CoelStructure/ParZoneGeo/_
108
	 * ou les _ représentent dans l'ordre : type.
109
	 * ou type peut valoir: FRD (= département français)
110
	 * Si un des paramêtres est abscent, il prendre la valeur *
111
	 */
112
	public function getElementParZoneGeo($param) {
113
		// Initialisation des variables
114
		$info = array();
115
 
116
		// Pré traitement des paramêtres
117
		$p = $this->traiterParametresUrl(array('type'), $param);
118
		if (!isset($p['type'])) {
119
			$this->messages[] = "Il est obligatoire d'indiquer type de recherche pour utiliser ce service.";
120
		} else {
121
			// Construction de la requête
122
			$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' '.
123
						'	IF ( SUBSTRING( cs_code_postal FROM 1 FOR 2 ) >= 96, '.
124
						'		SUBSTRING( cs_code_postal FROM 1 FOR 3 ), '.
125
						'		SUBSTRING( cs_code_postal FROM 1 FOR 2 ) ) AS id, '.
126
						'	COUNT( cs_id_structure ) AS nbre '.
127
						'FROM coel_structure '.
128
						'WHERE cs_ce_truk_pays = 2654 '.
129
						'GROUP BY IF ( SUBSTRING( cs_code_postal FROM 1 FOR 2 ) >= 96, '.
130
						'	SUBSTRING( cs_code_postal FROM 1 FOR 3 ), '.
131
						'	SUBSTRING( cs_code_postal FROM 1 FOR 2 ) ) '.
132
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'id ASC').' ';
133
			// Récupération des résultats
134
			try {
135
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
136
				if ($donnees === false) {
137
					$this->messages[] = "La requête a retourné aucun résultat.";
138
				} else {
139
					foreach ($donnees as $donnee) {
140
						$info[$donnee['id']] = $donnee['nbre'];
141
					}
142
				}
143
			} catch (PDOException $e) {
144
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
145
			}
146
		}
147
		return $info;
148
	}
149
 
150
	/**
151
	 * Méthode appelée pour ajouter un élément.
152
	 */
153
	public function createElement($params) {
154
		// Identification de l'utilisateur
155
		list($id_utilisateur, $id_session) = $this->getIdentification($params);
156
 
157
		// Contrôle du non détournement de l'utilisateur
158
		if ($this->etreAutorise($id_utilisateur)) {
159
			try {
160
	   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
161
	   			$tables_a_modifier = $this->recupererTablesAModifier($params);
162
	   			reset($tables_a_modifier);
163
 
164
	   			$id_structure = null;
165
				while (list($table_id, $table) = each($tables_a_modifier)) {
166
		   			if (!is_null($table['champs'])) {
167
				   		if (!$this->avoirCleComplete($table)) {
168
		   					// Ajout des données à la table des données
169
		   					$id_structure = $this->ajouter($table);
170
		   					if ($id_structure !== false) {
171
								$table['champs_valeurs_id']['cs_id_structure'] = $id_structure;
172
								$table['champs_valeurs_brut']['cs_id_structure'] = $id_structure;
173
								$tables_a_modifier[122]['champs_valeurs_id']['csc_id_structure'] = $id_structure;
174
								$tables_a_modifier[122]['champs_valeurs_brut']['csc_id_structure'] = $id_structure;
175
								$tables_a_modifier[122]['champs_valeurs_protege']['csc_id_structure'] = $this->bdd->quote($id_structure);
176
								$tables_a_modifier[123]['champs_valeurs_id']['csv_id_structure'] = $id_structure;
177
								$tables_a_modifier[123]['champs_valeurs_brut']['csv_id_structure'] = $id_structure;
178
								$tables_a_modifier[123]['champs_valeurs_protege']['csv_id_structure'] = $this->bdd->quote($id_structure);
179
 
180
								// Historisation (Ajout des méta-données)
181
								$etat = 1; // Ajout
182
								$cle = $this->recupererCle($table);
183
								$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
184
								$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);
185
 
186
						   		// Liaison de la table des données à ses méta-données
187
						   		$champ_meta = "{$table['prefixe']}_ce_meta";
188
						   		$table['champs_valeurs_protege'] = array($champ_meta => $id_meta);
189
						   		$this->modifier($table);
190
		   					}
191
			   			} else {
192
			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
193
			   			}
194
		   			}
195
				}
196
				$this->ajouterGuid($params['cpr_abreviation'], $id_structure);
197
			} catch (PDOException $e) {
198
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
199
			}
200
	   	}
201
 
202
	   	$this->envoyer($id_structure);
203
	}
204
 
205
	/**
206
	 * Méthode appelée pour mettre à jour un élément
207
	 */
208
	public function updateElement($uid, $params) {
209
		// Vérification de la présence des id passés par l'url
210
		if (!isset($uid[0])) {
211
			$this->messages[] = "Identifiant de structure manquant. Vous ne devriez pas avoir accès à ce service.";
212
		} else {
213
			// Identification de l'utilisateur
214
			list($id_utilisateur, $id_session) = $this->getIdentification($params);
215
 
216
			// Contrôle du non détournement de l'utilisateur
217
			if ($this->etreAutorise($id_utilisateur)) {
218
		   		try {
219
		   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
220
		   			$tables_a_modifier = $this->recupererTablesAModifier($params);
221
 
222
		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
223
			   		foreach ($tables_a_modifier as $table_id => $table) {
224
						$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
225
					}
226
				} catch (PDOException $e) {
227
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
228
				}
229
		   	}
230
		}
231
 
232
		// Envoie sur la sortie standard
233
		$this->envoyer();
234
	}
235
 
236
	/**
237
	 * Méthode appelée pour supprimer un élément
238
	 */
239
	public function deleteElement($uid) {
240
	   	// NOTES : une structure ne peut pas être supprimée si elle possède des collections liées.
241
		// Vérification de la présence des id passés par l'url
242
		if (!isset($uid[0]) || !isset($uid[1])) {
243
				$this->messages[] = "Identifiant de structure ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
244
		} else {
245
			// Identification de l'utilisateur
246
			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
247
 
248
			// Contrôle du non détournement de l'utilisateur
249
			if ($this->etreAutorise($id_utilisateur)) {
250
				// Récupération des id passés par l'url
251
				$identifiants = explode(',', rtrim($uid[1], ','));
252
 
253
		   		try {
254
		   			if (count($identifiants) == 0) {
255
		   				$this->messages[] = "Aucun enregistrement n'a été supprimé.";
256
		   			} else {
257
			   			foreach ($identifiants as $id_structure) {
258
				   			// Vérification que la structure ne possède pas de collections liées
259
							if ($this->verifierPresenceCollection($id_structure) === false) {
260
								$params = array('cs_id_structure' => $id_structure, 'csc_id_structure' => $id_structure, 'csv_id_structure' => $id_structure);
261
								$tables_a_modifier = $this->recupererTablesAModifier($params);
262
 
263
								foreach ($tables_a_modifier as $table_id => $table) {
264
						   			if ($this->avoirEnregistrement($table)) {
265
						   				$resultat = $this->supprimer($table);
266
										if ($resultat === true) {
267
											// Historisation (Ajout des méta-données)
268
											$cle = $this->recupererCle($table);
269
											$this->historiser($table_id, $cle, 'NULL', $id_utilisateur, 3, $id_session);
270
										}
271
						   			}
272
					   			}
273
							} else {
274
								$this->messages[] = "La structure '$id_structure' ne peut pas être supprimée car elle possède des collections liées.";
275
							}
276
			   			}
277
		   			}
278
			   	} catch (PDOException $e) {
279
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
280
				}
281
		   	}
282
		}
283
 
284
		// Envoie sur la sortie standard
285
		$this->envoyer();
286
	}
287
 
288
	private function verifierPresenceCollection($id_structure) {
289
		$requete = 	'SELECT COUNT(cc_id_collection) AS nbre_collection '.
290
					'FROM coel_collection '.
291
					"WHERE cc_ce_structure = '$id_structure' ".
292
	   				'GROUP BY cc_ce_structure ';
293
 
294
		// Vérification que la structure ne possède pas de collections liées
295
		$nbre_collection = $this->bdd->query($requete)->fetchColumn();
296
 
297
		$presence = false;
298
		if ($nbre_collection != 0) {
299
			$presence = true;
300
		}
301
		return $presence;
302
	}
303
 
304
	private function ajouterGuid($abr_projet, $id_structure) {
305
		if ($id_structure !== false) {
306
			$table_guid = $this->tables[120];
307
			$table_guid['champs_valeurs_id']['cs_id_structure'] = $id_structure;
308
			$table_guid['champs_valeurs_protege']['cs_guid'] = $this->bdd->quote(sprintf($this->config['coel']['guid'], $abr_projet, 'str'.$id_structure));
309
			$this->modifier($table_guid);
310
		}
311
	}
312
}
313
?>