Subversion Repositories eFlore/Applications.coel

Rev

Rev 1497 | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1497 Rev 1519
1 
<?php
 1 
<?php
2 
/**
 2 
/**
3 
 * Service fournissant la liste des relations "structure à personne".
 3 
 * Service fournissant la liste des relations "structure à personne".
4 
 * Encodage en entrée : utf8
 4 
 * Encodage en entrée : utf8
5 
 * Encodage en sortie : utf8
 5 
 * Encodage en sortie : utf8
6 
 *
6 
 *
7 
 * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
 7 
 * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
8 
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 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>
 9 
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
10 
 * @version $Id$
 10 
 * @version $Id$
11 
 * @copyright 2009
 11 
 * @copyright 2009
12 
 */
 12 
 */
13 
class CoelCollectionACommentaire extends Coel {
 13 
class CoelCollectionACommentaire extends Coel {
14
14
15 
	const MODE_SUPPRESSION_PAR_COLLECTION = 'SuppressionParCollection';
 15 
	const MODE_SUPPRESSION_PAR_COLLECTION = 'SuppressionParCollection';
16 
	const MODE_SUPPRESSION_PAR_COMMENTAIRE = 'SuppressionParCommentaire';
 16 
	const MODE_SUPPRESSION_PAR_COMMENTAIRE = 'SuppressionParCommentaire';
17
17
18 
	/** Contient les infos sur les tables gérées par ce service.
 18 
	/** Contient les infos sur les tables gérées par ce service.
19 
	 * Bien respecter l'ordre avec en premier les tables liées et en dernier la table établissant la relation. */
 19 
	 * Bien respecter l'ordre avec en premier les tables liées et en dernier la table établissant la relation. */
20 
	protected $tables = array(	102 => array(	'nom' => 'coel_collection_a_commentaire',
20 
	protected $tables = array(	102 => array(	'nom' => 'coel_collection_a_commentaire',
21 
												'prefixe' => 'ccac',
21 
												'prefixe' => 'ccac',
22 
												'id' => array('ccac_id_collection', 'ccac_id_commentaire')));
22 
												'id' => array('ccac_id_collection', 'ccac_id_commentaire')));
23 
 
 23 
 
24 
	/**
 24 
	/**
25 
	 * Méthode appelée avec une requête de type GET.
 25 
	 * Méthode appelée avec une requête de type GET.
26 
	 */
 26 
	 */
27 
	public function getElement($param = array()) {
 27 
	public function getElement($param = array()) {
28 
		// Initialisation des variables
 28 
		// Initialisation des variables
29 
		$info = array();
 29 
		$info = array();
30
30
31 
		// Pré traitement des paramêtres
 31 
		// Pré traitement des paramêtres
32 
		$p = $this->traiterParametresUrl(array('id_collection', 'mark_public'), $param);
 32 
		$p = $this->traiterParametresUrl(array('id_collection', 'mark_public'), $param);
33
33
34 
		// Construction de la requête
 34 
		// Construction de la requête
35 
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT ' : 'SELECT ').
 35 
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT ' : 'SELECT ').
36 
					'	ccac.*, ccm.* '.
 36 
					'	ccac.*, ccm.* '.
37 
					'FROM coel_collection_a_commentaire AS ccac '.
 37 
					'FROM coel_collection_a_commentaire AS ccac '.
38 
					'	LEFT JOIN coel_meta_historique_ligne ON (ccac_ce_meta = cmhl_id_historique_ligne) '.
 38 
					'	LEFT JOIN coel_meta_historique_ligne ON (ccac_ce_meta = cmhl_id_historique_ligne) '.
39 
					'	LEFT JOIN coel_commentaire AS ccm ON (ccac_id_commentaire = ccm_id_commentaire) '.
 39 
					'	LEFT JOIN coel_commentaire AS ccm ON (ccac_id_commentaire = ccm_id_commentaire) '.
40 
					((count($p) != 0) ? 'WHERE ' : '').
 40 
					((count($p) != 0) ? 'WHERE ' : '').
41 
					(isset($p['id_collection']) ? "AND ccac_id_collection = {$p['id_collection']} " : '').
41 
					(isset($p['id_collection']) ? "AND ccac_id_collection = {$p['id_collection']} " : '').
42 
					(isset($p['mark_public']) 	? "AND ccm_mark_public = {$p['mark_public']} " : '').
 42 
					(isset($p['mark_public']) 	? "AND ccm_mark_public = {$p['mark_public']} " : '').
43 
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'ccac_ce_meta DESC').' ';
 43 
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'ccac_ce_meta DESC').' ';
44 
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
 44 
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
45 
		$requeteCount = $requete;
 45 
		$requeteCount = $requete;
46 
		$requete .= "LIMIT $this->start, $this->limit ";
 46 
		$requete .= "LIMIT $this->start, $this->limit ";
47 
 
 47 
 
48 
		// Récupération des résultats
 48 
		// Récupération des résultats
49 
		try {
 49 
		try {
50 
			$donnees = $this->bdd->query($requete)->fetchAll();
 50 
			$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
51 
			if ($donnees === false) {
 51 
			if ($donnees === false) {
52 
				$this->messages[] = "La requête a retourné aucun résultat.";
 52 
				$this->messages[] = "La requête a retourné aucun résultat.";
53 
			}
 53 
			}
54
54
55 
			$nbElements = $this->bdd->query($requeteCount)->rowCount();
 55 
			$nbElements = $this->bdd->query($requeteCount)->rowCount();
56
56
57 
			$info['nbElements'] = $nbElements;
 57 
			$info['nbElements'] = $nbElements;
58 
			$info['collectionsACommentaire'] = $donnees;
 58 
			$info['collectionsACommentaire'] = $donnees;
59
59
60 
		} catch (PDOException $e) {
 60 
		} catch (PDOException $e) {
61 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
 61 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
62 
		}
 62 
		}
63
63
64 
		// Envoie sur la sortie standard
 64 
		// Envoie sur la sortie standard
65 
		$this->envoyer($info);
 65 
		$this->envoyer($info);
66 
	}
 66 
	}
67
67
68 
	/**
 68 
	/**
69 
	 * Méthode appelée pour ajouter un élément.
 69 
	 * Méthode appelée pour ajouter un élément.
70 
	 */
 70 
	 */
71 
	public function createElement($params) {
 71 
	public function createElement($params) {
72 
		// Identification de l'utilisateur
 72 
		// Identification de l'utilisateur
73 
		list($id_utilisateur, $id_session) = $this->getIdentification($params);
 73 
		list($id_utilisateur, $id_session) = $this->getIdentification($params);
74
74
75 
		// Contrôle du non détournement de l'utilisateur
 75 
		// Contrôle du non détournement de l'utilisateur
76 
		if ($this->etreAutorise($id_utilisateur)) {
76 
		if ($this->etreAutorise($id_utilisateur)) {
77 
			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
 77 
			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
78 
   			$tables_a_modifier = $this->recupererTablesAModifier($params);
 78 
   			$tables_a_modifier = $this->recupererTablesAModifier($params);
79
79
80 
	   		try {
80 
	   		try {
81 
	   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
 81 
	   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
82 
	   			// Nous ne pouvons pas utiliser foreach car il travaille sur une copie du tableau or nous le modifions dynamiquement dans la boucle
 82 
	   			// Nous ne pouvons pas utiliser foreach car il travaille sur une copie du tableau or nous le modifions dynamiquement dans la boucle
83 
	   			reset($tables_a_modifier);
 83 
	   			reset($tables_a_modifier);
84 
				while (list($table_id, $table) = each($tables_a_modifier)) {
 84 
				while (list($table_id, $table) = each($tables_a_modifier)) {
85 
		   			if (!is_null($table['champs'])) {
 85 
		   			if (!is_null($table['champs'])) {
86 
		   				if (!$this->avoirCleComplete($table)) {
 86 
		   				if (!$this->avoirCleComplete($table)) {
87 
		   					$this->messages[] = 'Il est nécessaire de fournir toutes les clés à ce service.';
 87 
		   					$this->messages[] = 'Il est nécessaire de fournir toutes les clés à ce service.';
88 
			   			} else {
 88 
			   			} else {
89 
			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
 89 
			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
90 
			   			}
 90 
			   			}
91 
		   			}
 91 
		   			}
92 
		   		}
 92 
		   		}
93 
			} catch (PDOException $e) {
 93 
			} catch (PDOException $e) {
94 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
 94 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
95 
			}
 95 
			}
96 
	   	} else {
 96 
	   	} else {
97 
	   		$this->messages[] = "Il faut être identifié pour accéder à ce service";
 97 
	   		$this->messages[] = "Il faut être identifié pour accéder à ce service";
98 
	   	}
 98 
	   	}
99
99
100 
		// Envoie sur la sortie standard
 100 
		// Envoie sur la sortie standard
101 
		$this->envoyer();
 101 
		$this->envoyer();
102 
	}
 102 
	}
103
103
104 
	/**
 104 
	/**
105 
	 * Méthode appelée pour mettre à jour un élément
 105 
	 * Méthode appelée pour mettre à jour un élément
106 
	 */
 106 
	 */
107 
	public function updateElement($uid, $params) {
 107 
	public function updateElement($uid, $params) {
108 
		// Vérification de la présence des id passés par l'url
 108 
		// Vérification de la présence des id passés par l'url
109 
		if (!isset($uid[0]) && !isset($uid[1])) {
 109 
		if (!isset($uid[0]) && !isset($uid[1])) {
110 
			$this->messages[] = 'Aucun identifiant de collection a été passé. Vous ne devriez pas avoir accès à ce service.';
 110 
			$this->messages[] = 'Aucun identifiant de collection a été passé. Vous ne devriez pas avoir accès à ce service.';
111 
		} else {
 111 
		} else {
112 
			// Identification de l'utilisateur
 112 
			// Identification de l'utilisateur
113 
			list($id_utilisateur, $id_session) = $this->getIdentification($params);
 113 
			list($id_utilisateur, $id_session) = $this->getIdentification($params);
114
114
115 
			// Contrôle du non détournement de l'utilisateur
 115 
			// Contrôle du non détournement de l'utilisateur
116 
			if ($this->etreAutorise($id_utilisateur)) {
116 
			if ($this->etreAutorise($id_utilisateur)) {
117 
				// Vérification des tables à vraiment mettre à jour en fonction des données passées.
 117 
				// Vérification des tables à vraiment mettre à jour en fonction des données passées.
118 
   				$tables_a_modifier = $this->recupererTablesAModifier($params);
 118 
   				$tables_a_modifier = $this->recupererTablesAModifier($params);
119 
   				try {
119 
   				try {
120 
		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
 120 
		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
121 
			   		foreach ($tables_a_modifier as $table_id => $table) {
 121 
			   		foreach ($tables_a_modifier as $table_id => $table) {
122 
			   			$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
 122 
			   			$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
123 
			   		}
 123 
			   		}
124 
				} catch (PDOException $e) {
 124 
				} catch (PDOException $e) {
125 
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
 125 
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
126 
				}
 126 
				}
127 
			}
 127 
			}
128 
	   	}
 128 
	   	}
129
129
130 
		// Envoie sur la sortie standard
 130 
		// Envoie sur la sortie standard
131 
		$this->envoyer();
 131 
		$this->envoyer();
132 
	}
 132 
	}
133
133
134 
	/**
 134 
	/**
135 
	 * Méthode appelée pour supprimer un ou plusieurs éléments
 135 
	 * Méthode appelée pour supprimer un ou plusieurs éléments
136 
	 */
 136 
	 */
137 
	public function deleteElement($uid) {
 137 
	public function deleteElement($uid) {
138 
	   	// NOTES : la suppression ne supprime pas les personnes mais seulements les relations
 138 
	   	// NOTES : la suppression ne supprime pas les personnes mais seulements les relations
139 
 
 139 
 
140 
	    // Vérification de la présence des id passés par l'url
 140 
	    // Vérification de la présence des id passés par l'url
141 
		if (!isset($uid[0]) || !isset($uid[1])) {
 141 
		if (!isset($uid[0]) || !isset($uid[1])) {
142 
				$this->messages[] = "Identifiant de relations ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
 142 
				$this->messages[] = "Identifiant de relations ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
143 
		} else {
 143 
		} else {
144 
			// Identification de l'utilisateur
 144 
			// Identification de l'utilisateur
145 
			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
 145 
			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
146
146
147 
			// Mode de suppression
 147 
			// Mode de suppression
148 
			$mode_de_suppression = '';
 148 
			$mode_de_suppression = '';
149 
			if (isset($uid[2])) {
 149 
			if (isset($uid[2])) {
150 
				$mode_de_suppression = $uid[2];
 150 
				$mode_de_suppression = $uid[2];
151 
			}
 151 
			}
152
152
153 
			// Contrôle du non détournement de l'utilisateur
 153 
			// Contrôle du non détournement de l'utilisateur
154 
			if ($this->etreAutorise($id_utilisateur)) {
 154 
			if ($this->etreAutorise($id_utilisateur)) {
155 
				// Récupération des identifiant à supprimer
 155 
				// Récupération des identifiant à supprimer
156 
				$identifiants = array();
156 
				$identifiants = array();
157 
				$identifiants_agreges = explode(',', rtrim($uid[1], ','));
 157 
				$identifiants_agreges = explode(',', rtrim($uid[1], ','));
158 
				foreach ($identifiants_agreges as $identifiant) {
 158 
				foreach ($identifiants_agreges as $identifiant) {
159 
					$identifiants[] = explode('-', $identifiant);
 159 
					$identifiants[] = explode('-', $identifiant);
160 
				}
 160 
				}
161
161
162 
		   		if (count($identifiants) == 0) {
 162 
		   		if (count($identifiants) == 0) {
163 
		   			$this->messages[] = "Aucun enregistrement n'a été supprimé.";
 163 
		   			$this->messages[] = "Aucun enregistrement n'a été supprimé.";
164 
		   		} else {
 164 
		   		} else {
165 
			   		try {
 165 
			   		try {
166 
				   		foreach ($identifiants as $id) {
 166 
				   		foreach ($identifiants as $id) {
167 
				   			if (count($id) == 1) { // Seulement des id de collection
 167 
				   			if (count($id) == 1) { // Seulement des id de collection
168 
					   			if ($mode_de_suppression == MODE_SUPPRESSION_PAR_COLLECTION) {
 168 
					   			if ($mode_de_suppression == MODE_SUPPRESSION_PAR_COLLECTION) {
169 
					   				$params = array('ccac_id_collection' => $id[0]);
 169 
					   				$params = array('ccac_id_collection' => $id[0]);
170 
					   			} else if ($mode_de_suppression == MODE_SUPPRESSION_PAR_COMMENTAIRE) {
 170 
					   			} else if ($mode_de_suppression == MODE_SUPPRESSION_PAR_COMMENTAIRE) {
171 
					   				$params = array('ccac_id_commentaire' => $id[0]);
 171 
					   				$params = array('ccac_id_commentaire' => $id[0]);
172 
					   			} else {
 172 
					   			} else {
173 
					   				$params = array('ccac_id_collection' => $id[0]);
 173 
					   				$params = array('ccac_id_collection' => $id[0]);
174 
					   			}
 174 
					   			}
175 
					   		}	else if (count($id) == 2) { // Tous les id...
 175 
					   		}	else if (count($id) == 2) { // Tous les id...
176 
				   				$params = array('ccac_id_collection' => $id[0], 'ccac_id_commentaire' => $id[1]);
 176 
				   				$params = array('ccac_id_collection' => $id[0], 'ccac_id_commentaire' => $id[1]);
177 
					   		}
 177 
					   		}
178 
							$tables_a_modifier = $this->recupererTablesAModifier($params);
 178 
							$tables_a_modifier = $this->recupererTablesAModifier($params);
179 
							$table = $tables_a_modifier[102];
 179 
							$table = $tables_a_modifier[102];
180
180
181 
							if ($this->avoirEnregistrement($table)) {
 181 
							if ($this->avoirEnregistrement($table)) {
182 
								$resultat = $this->supprimer($table);
 182 
								$resultat = $this->supprimer($table);
183 
								if ($resultat === true) {
 183 
								if ($resultat === true) {
184 
									// Historisation (Ajout des méta-données)
 184 
									// Historisation (Ajout des méta-données)
185 
									$cle = $this->recupererCle($table);
 185 
									$cle = $this->recupererCle($table);
186 
									$this->historiser(102, $cle, 'NULL', $id_utilisateur, Coel::ETAT_SUPPRIMER, $id_session);
 186 
									$this->historiser(102, $cle, 'NULL', $id_utilisateur, Coel::ETAT_SUPPRIMER, $id_session);
187 
								}
 187 
								}
188 
							}
 188 
							}
189 
			   			}
 189 
			   			}
190 
				   	} catch (PDOException $e) {
 190 
				   	} catch (PDOException $e) {
191 
						$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
 191 
						$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
192 
					}
 192 
					}
193 
		   		}
 193 
		   		}
194 
			}
 194 
			}
195 
		}
 195 
		}
196
196
197 
		// Envoie sur la sortie standard
 197 
		// Envoie sur la sortie standard
198 
		$this->envoyer();
 198 
		$this->envoyer();
199 
	}
 199 
	}
200 
}
 200 
}
201 
?>
 201 
?>