Subversion Repositories Applications.referentiel

Rev

Rev 33 | Rev 39 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
23 jpm 1 
<?php
2 
/**
3 
 * Service permettant d'enregistrer une demande de traitement ou de consulter les infos sur les traitements.
4 
 * Encodage en entrée : utf8
5 
 * Encodage en sortie : utf8
6 
 *
7 
 * @category	Php 5.2
8 
 * @package		Referentiel
9 
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
10 
 * @license		GPL v3 <http://www.gnu.org/licenses/gpl.txt>
11 
 * @license		CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
12 
 * @copyright	2010 Tela-Botanica
13 
 * @version		$Id$
14 
 */
15 
class Traitement extends Ref {
24 jpm 16 
 
23 jpm 17 
	/**
18 
	 * Méthode principale appelée avec une requête de type GET.
19 
	 */
26 jpm 20 
	public function getElement($params_url = array()) {
23 jpm 21 
		// Initialisation des variables
22 
		$info = array();
23 
 
24 
		// Nour recherchons le type de requête demandé
33 jpm 25 
		$p = $this->traiterParametresUrl(array('type'), $params_url, false);
26 
		extract($p);
23 jpm 27 
 
28 
		if (!is_null($type)) {
33 jpm 29 
			$methode = 'getElement'.$type;
30 
			if (method_exists($this, $methode)) {
31 
				array_shift($params_url);
32 
				$info = $this->$methode($params_url);
23 jpm 33 
			} else {
33 jpm 34 
				$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
23 jpm 35 
			}
36 
		} else {
37 
			$this->messages[] = "Veuillez préciser le type de requête.";
38 
		}
39 
 
40 
		// Envoie sur la sortie standard
41 
		$this->envoyer($info);
42 
	}
43 
 
33 jpm 44 
	/** Méthode pour récupérer les infos d'un traitement.
45 
	* Appelée avec les paramêtres d'url suivant :
46 
	* /Traitement/Info/id_traitement
47 
	*
48 
	* @return mixed les infos du traitement ou false en cas d'échec.
49 
	*/
50 
	public function getElementInfo($params_url) {
51 
		$p = $this->traiterParametresUrl(array('id'), $params_url);
52 
		extract($p);
53 
 
54 
		$infos = false;
55 
		if (!is_null($id)) {
56 
			$requete =	'SELECT * '.
57 
						"FROM ref_traitement ".
58 
						"WHERE id_traitement = $id ";
59 
			// Récupération des résultats
60 
			try {
61 
				$infos = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
62 
				if ($infos === false) {
63 
					$this->messages[] = "La requête a retourné aucun résultat.";
64 
				}
65 
			} catch (PDOException $e) {
66 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
67 
			}
68 
		} else {
69 
			$this->messages[] = "Veuillez préciser l'identifinat du traitement comme premier paramêtre (ex. : 38).";
70 
		}
71 
 
72 
		return $infos;
73 
	}
74 
 
23 jpm 75 
	/**
26 jpm 76 
	 * Retourne les infos sur la dernière demande de traitement pour un projet donné.
77 
	 */
33 jpm 78 
	public function getElementDerniereDemande($params_url) {
79 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
80 
		extract($p);
26 jpm 81 
 
33 jpm 82 
		$donnees = false;
83 
		if (!is_null($projet)) {
84 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
85 
						'FROM ref_traitement '.
86 
						"WHERE referentiel_code = $projet ".
87 
						'	AND date_fin IS NULL '.
88 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
89 
						'LIMIT 0,1 ';
90 
 
91 
			$this->debug[] = $requete;
92 
 
93 
			// Récupération des résultats
94 
			try {
95 
				$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
96 
				if ($donnees === false) {
97 
					$this->messages[] = "La requête a retourné aucun résultat.";
98 
				}
99 
			} catch (PDOException $e) {
100 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 101 
			}
33 jpm 102 
		} else {
103 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
26 jpm 104 
		}
33 jpm 105 
 
26 jpm 106 
		return $donnees;
107 
	}
108 
 
109 
	/**
38 jpm 110 
	 * Retourne les infos sur les traitements en attente.
111 
	 */
112 
	public function getElementEnAttente($params_url) {
113 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
114 
		extract($p);
115 
 
116 
		$donnees = false;
117 
		if (!is_null($projet)) {
118 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
119 
						'FROM ref_traitement '.
120 
						"WHERE referentiel_code = $projet ".
121 
						'	AND date_debut IS NULL '.
122 
						'	AND date_fin IS NULL '.
123 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
124 
 
125 
			// Récupération des résultats
126 
			try {
127 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
128 
				if ($donnees === false) {
129 
					$this->messages[] = "La requête a retourné aucun résultat.";
130 
				}
131 
			} catch (PDOException $e) {
132 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
133 
			}
134 
		} else {
135 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
136 
		}
137 
 
138 
		return $donnees;
139 
	}
140 
 
141 
	/**
33 jpm 142 
	 * Retourne les infos sur les traitements en cours.
24 jpm 143 
	 */
33 jpm 144 
	public function getElementEnCours($params_url) {
145 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
146 
		extract($p);
24 jpm 147 
 
33 jpm 148 
		$donnees = false;
149 
		if (!is_null($projet)) {
150 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
151 
						'FROM ref_traitement '.
152 
						"WHERE referentiel_code = $projet ".
153 
						'	AND date_debut IS NOT NULL '.
154 
						'	AND date_fin IS NULL '.
155 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
156 
 
157 
			// Récupération des résultats
158 
			try {
159 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
160 
				if ($donnees === false) {
161 
					$this->messages[] = "La requête a retourné aucun résultat.";
162 
				}
163 
			} catch (PDOException $e) {
164 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
24 jpm 165 
			}
33 jpm 166 
		} else {
167 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
24 jpm 168 
		}
33 jpm 169 
 
24 jpm 170 
		return $donnees;
171 
	}
172 
 
173 
	/**
26 jpm 174 
	 * Retourne les id des demandes de traitements obsolètes.
175 
	 */
33 jpm 176 
	public function getElementObsolete($params_url) {
177 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
178 
		extract($p);
179 
 
180 
		$sortie = false;
181 
		if (!is_null($projet)) {
182 
			try {
183 
				$requete =	'SELECT MAX(date_debut) '.
184 
							'FROM ref_traitement '.
185 
							"WHERE referentiel_code = $projet ".
186 
							'	AND date_debut IS NOT NULL '.
187 
							'GROUP BY referentiel_code ';
188 
 
189 
				$date_max = $this->bdd->query($requete)->fetchColumn();
190 
				if ($date_max === false) {
191 
					$this->messages[] = "La requête de récupération de la date de début max a échouée.";
192 
				} else {
193 
					$date_max = $this->bdd->quote($date_max);
194 
					$requete = 	'SELECT id_traitement '.
195 
								'FROM ref_traitement '.
196 
								"WHERE referentiel_code = $projet ".
197 
								'	AND date_debut IS NULL '.
198 
								'	AND date_fin IS NULL '.
199 
								"	AND meta_date_creation < $date_max ";
200 
					$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
201 
					if ($donnees === false) {
202 
						$this->messages[] = "La requête a retourné aucun résultat.";
203 
					}
204 
				}
205 
			} catch (PDOException $e) {
206 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
207 
			}
208 
			// Pos-traitement
209 
			$sortie = array();
210 
			if ($donnees != false) {
211 
				foreach ($donnees as $donnee) {
212 
					$sortie[] = $donnee['id_traitement'];
213 
				}
214 
			}
215 
		} else {
216 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
217 
		}
218 
 
219 
		return $sortie;
220 
	}
221 
 
222 
	/**
223 
	 * Retourne les infos sur les traitements terminés.
224 
	 */
225 
	public function getElementTermines($params_url) {
226 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
227 
		extract($p);
228 
 
229 
		$donnees = false;
230 
		if (!is_null($projet)) {
231 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
26 jpm 232 
						'FROM ref_traitement '.
233 
						"WHERE referentiel_code = $projet ".
234 
						'	AND date_debut IS NOT NULL '.
33 jpm 235 
						'	AND date_fin IS NOT NULL '.
236 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
26 jpm 237 
 
33 jpm 238 
			// Récupération des résultats
239 
			try {
26 jpm 240 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
241 
				if ($donnees === false) {
242 
					$this->messages[] = "La requête a retourné aucun résultat.";
243 
				}
33 jpm 244 
			} catch (PDOException $e) {
245 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 246 
			}
33 jpm 247 
		} else {
248 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
26 jpm 249 
		}
33 jpm 250 
 
251 
		return $donnees;
26 jpm 252 
	}
253 
 
254 
	/**
23 jpm 255 
	 * Méthode appelée pour ajouter un traitement.
256 
	 * Retour l'id du nouvel enregistrement ou false!
257 
	 */
26 jpm 258 
	public function createElement($params_post) {
259 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params_post);
23 jpm 260 
		$meta_date_creation = date ("Y-m-d H:i:s");
26 jpm 261 
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
23 jpm 262 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
263 
 
264 
		try {
265 
			$requete = 	"INSERT INTO ref_traitement ".
266 
   						' (referentiel_code, nom, meta_date_creation) '.
267 
						" VALUES ({$params_proteges['referentiel_code']}, $nom, $meta_date_creation) ";
268 
			$resultat = $this->bdd->exec($requete);
269 
			if ($resultat === false) {
270 
				$id = false;
271 
				$this->debug[] = "Traitement NON ajouté.";
272 
			} else {
273 
				$id = $this->bdd->lastInsertId();
274 
			}
275 
		} catch (PDOException $e) {
276 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
277 
		}
278 
 
279 
	   	$this->envoyer($id);
280 
	}
26 jpm 281 
 
282 
	/**
283 
	 * Méthode principale appelée avec une requête de type POST.
284 
	 */
285 
	public function updateElement($params_url, $params_post) {
286 
		// Initialisation des variables
287 
		$info = array();
288 
 
289 
		// Nour recherchons le type de requête demandé
290 
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
291 
		extract($this->traiterParametresPost(array('action'), $params_post, false));
292 
 
293 
		if (!is_null($id)) {
294 
			if (!is_null($action)) {
295 
				$methode = 'updateElement'.$action;
296 
				if (method_exists($this, $methode)) {
297 
					//array_shift($param);
298 
					$info = $this->$methode($id, $params_post);
299 
				} else {
300 
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
301 
				}
302 
			} else {
303 
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
304 
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
305 
			}
306 
		} else {
307 
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
308 
		}
309 
 
310 
		// Envoie sur la sortie standard
311 
		$this->envoyer($info);
312 
	}
313 
 
314 
	/**
315 
	 * Méthode pour indiquer le démarage d'un traitement.
316 
	 */
317 
	public function updateElementDebuter($id, $params_post) {
318 
		$ok = true;
319 
		try {
320 
			$requete = 	'UPDATE ref_traitement '.
321 
						'SET date_debut = NOW() '.
322 
						"WHERE id_traitement = $id ";
323 
			$this->debug[] = "$requete";
324 
			$resultat = $this->bdd->exec($requete);
325 
			if ($resultat === false) {
326 
				$ok = false;
327 
				$this->messages[] = "Traitement NON modifié.";
328 
			}
329 
		} catch (PDOException $e) {
330 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
331 
		}
332 
 
333 
	   	return $ok;
334 
	}
335 
 
336 
	/**
30 jpm 337 
	 * Méthode pour indiquer la fin d'un traitement.
338 
	 */
339 
	public function updateElementTerminer($id, $params_post) {
340 
		$ok = true;
341 
		try {
342 
			$requete = 	'UPDATE ref_traitement '.
33 jpm 343 
						'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
30 jpm 344 
						"WHERE id_traitement = $id ";
345 
			$this->debug[] = "$requete";
346 
			$resultat = $this->bdd->exec($requete);
347 
			if ($resultat === false) {
348 
				$ok = false;
349 
				$this->messages[] = "Traitement NON modifié.";
350 
			}
351 
		} catch (PDOException $e) {
352 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
353 
		}
354 
 
355 
	   	return $ok;
356 
	}
357 
 
358 
	/**
26 jpm 359 
	 * Méthode principale appelée avec une requête de type DELETE.
360 
	 */
361 
	public function deleteElement($params_url) {
362 
		// Initialisation des variables
363 
		$ok = true;
364 
 
365 
		// Extraction des paramètres de l'url
366 
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
367 
 
368 
		if (!is_null($ids)) {
369 
			try {
370 
				$in_ids = $this->traiterBddClauseIn($ids);
371 
				$requete = 	'DELETE FROM ref_traitement '.
372 
							"WHERE id_traitement IN ($in_ids) ";
373 
				$this->debug[] = "$requete";
374 
				$resultat = $this->bdd->exec($requete);
375 
				if ($resultat === false) {
376 
					$ok = false;
377 
					$this->messages[] = "Traitement(s) NON supprimé(s).";
378 
				}
379 
			} catch (PDOException $e) {
380 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
381 
			}
382 
		} else {
383 
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
384 
		}
385 
 
386 
		// Envoie sur la sortie standard
387 
		$this->envoyer($ok);
388 
	}
23 jpm 389 
}
390 
?>