Subversion Repositories Applications.referentiel

Rev

Rev 159 | 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
39 jpm 22 
		$info = null;
23 jpm 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) {
45 jpm 79 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 80 
		extract($p);
26 jpm 81 
 
33 jpm 82 
		$donnees = false;
45 jpm 83 
		if (isset($projet) && isset($script)) {
33 jpm 84 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
85 
						'FROM ref_traitement '.
142 delphine 86 
						"WHERE ".(($projet == "'tout'") ? '' : 'referentiel_code = '.$projet.' AND ') .
87 
							" script = $script ".
159 jpm 88 
							' AND date_debut IS NULL '.
142 delphine 89 
							' AND date_fin IS NULL '.
33 jpm 90 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
91 
						'LIMIT 0,1 ';
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.";
39 jpm 98 
				} else if (0 == count($donnees)) {
99 
					$donnees = null;
33 jpm 100 
				}
101 
			} catch (PDOException $e) {
102 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 103 
			}
33 jpm 104 
		} else {
45 jpm 105 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
106 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
26 jpm 107 
		}
33 jpm 108 
 
26 jpm 109 
		return $donnees;
110 
	}
111 
 
112 
	/**
38 jpm 113 
	 * Retourne les infos sur les traitements en attente.
114 
	 */
115 
	public function getElementEnAttente($params_url) {
39 jpm 116 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
38 jpm 117 
		extract($p);
118 
 
39 jpm 119 
		$donnees = null;
120 
		if (isset($projet) && isset($script)) {
38 jpm 121 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
122 
						'FROM ref_traitement '.
123 
						"WHERE referentiel_code = $projet ".
142 delphine 124 
							" AND script = $script ".
125 
							' AND date_debut IS NULL '.
126 
							' AND date_fin IS NULL '.
38 jpm 127 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
128 
 
129 
			// Récupération des résultats
130 
			try {
131 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
132 
				if ($donnees === false) {
133 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 134 
				} else if (0 == count($donnees)) {
135 
					$donnees = null;
38 jpm 136 
				}
137 
			} catch (PDOException $e) {
138 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
139 
			}
140 
		} else {
39 jpm 141 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
142 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
38 jpm 143 
		}
144 
 
145 
		return $donnees;
146 
	}
147 
 
148 
	/**
33 jpm 149 
	 * Retourne les infos sur les traitements en cours.
24 jpm 150 
	 */
33 jpm 151 
	public function getElementEnCours($params_url) {
39 jpm 152 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 153 
		extract($p);
24 jpm 154 
 
39 jpm 155 
		$donnees = null;
156 
		if (isset($projet) && isset($script)) {
33 jpm 157 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
158 
						'FROM ref_traitement '.
159 
						"WHERE referentiel_code = $projet ".
39 jpm 160 
						"	AND script = $script ".
33 jpm 161 
						'	AND date_debut IS NOT NULL '.
162 
						'	AND date_fin IS NULL '.
163 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
164 
 
165 
			// Récupération des résultats
166 
			try {
167 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
168 
				if ($donnees === false) {
169 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 170 
				} else if (0 == count($donnees)) {
171 
					$donnees = null;
33 jpm 172 
				}
173 
			} catch (PDOException $e) {
174 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
24 jpm 175 
			}
33 jpm 176 
		} else {
39 jpm 177 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
178 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
24 jpm 179 
		}
33 jpm 180 
 
24 jpm 181 
		return $donnees;
182 
	}
183 
 
184 
	/**
26 jpm 185 
	 * Retourne les id des demandes de traitements obsolètes.
186 
	 */
33 jpm 187 
	public function getElementObsolete($params_url) {
45 jpm 188 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 189 
		extract($p);
190 
 
45 jpm 191 
		$sortie = null;
192 
		if (isset($projet) && isset($script)) {
33 jpm 193 
			try {
194 
				$requete =	'SELECT MAX(date_debut) '.
195 
							'FROM ref_traitement '.
196 
							"WHERE referentiel_code = $projet ".
45 jpm 197 
							"	AND script = $script ".
33 jpm 198 
							'	AND date_debut IS NOT NULL '.
199 
							'GROUP BY referentiel_code ';
200 
 
201 
				$date_max = $this->bdd->query($requete)->fetchColumn();
202 
				if ($date_max === false) {
203 
					$this->messages[] = "La requête de récupération de la date de début max a échouée.";
204 
				} else {
205 
					$date_max = $this->bdd->quote($date_max);
206 
					$requete = 	'SELECT id_traitement '.
207 
								'FROM ref_traitement '.
208 
								"WHERE referentiel_code = $projet ".
45 jpm 209 
								"	AND script = $script ".
33 jpm 210 
								'	AND date_debut IS NULL '.
211 
								'	AND date_fin IS NULL '.
212 
								"	AND meta_date_creation < $date_max ";
213 
					$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
214 
					if ($donnees === false) {
215 
						$this->messages[] = "La requête a retourné aucun résultat.";
216 
					}
217 
				}
218 
			} catch (PDOException $e) {
219 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
220 
			}
221 
			// Pos-traitement
45 jpm 222 
 
33 jpm 223 
			if ($donnees != false) {
224 
				foreach ($donnees as $donnee) {
225 
					$sortie[] = $donnee['id_traitement'];
226 
				}
227 
			}
228 
		} else {
45 jpm 229 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
230 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
33 jpm 231 
		}
232 
 
233 
		return $sortie;
234 
	}
235 
 
236 
	/**
237 
	 * Retourne les infos sur les traitements terminés.
238 
	 */
239 
	public function getElementTermines($params_url) {
39 jpm 240 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 241 
		extract($p);
242 
 
39 jpm 243 
		$donnees = null;
244 
		if (isset($projet) && isset($script)) {
33 jpm 245 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
26 jpm 246 
						'FROM ref_traitement '.
247 
						"WHERE referentiel_code = $projet ".
39 jpm 248 
						"	AND script = $script ".
26 jpm 249 
						'	AND date_debut IS NOT NULL '.
33 jpm 250 
						'	AND date_fin IS NOT NULL '.
251 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
26 jpm 252 
 
33 jpm 253 
			// Récupération des résultats
254 
			try {
26 jpm 255 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
256 
				if ($donnees === false) {
257 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 258 
				} else if (0 == count($donnees)) {
259 
					$donnees = null;
26 jpm 260 
				}
33 jpm 261 
			} catch (PDOException $e) {
262 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 263 
			}
33 jpm 264 
		} else {
39 jpm 265 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
266 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
26 jpm 267 
		}
33 jpm 268 
 
269 
		return $donnees;
26 jpm 270 
	}
271 
 
272 
	/**
23 jpm 273 
	 * Méthode appelée pour ajouter un traitement.
274 
	 * Retour l'id du nouvel enregistrement ou false!
275 
	 */
26 jpm 276 
	public function createElement($params_post) {
49 jpm 277 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code', 'script', 'script_parametres'), $params_post);
278 
		$meta_date_creation = date ('Y-m-d H:i:s');
26 jpm 279 
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
23 jpm 280 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
281 
 
282 
		try {
283 
			$requete = 	"INSERT INTO ref_traitement ".
49 jpm 284 
   						' (referentiel_code, script, script_parametres, nom, meta_date_creation) '.
51 jpm 285 
						" VALUES ({$params_proteges['referentiel_code']}, {$params_proteges['script']}, {$params_proteges['script_parametres']}, $nom, $meta_date_creation) ";
23 jpm 286 
			$resultat = $this->bdd->exec($requete);
287 
			if ($resultat === false) {
288 
				$id = false;
289 
				$this->debug[] = "Traitement NON ajouté.";
290 
			} else {
291 
				$id = $this->bdd->lastInsertId();
292 
			}
293 
		} catch (PDOException $e) {
294 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
295 
		}
296 
 
297 
	   	$this->envoyer($id);
298 
	}
26 jpm 299 
 
300 
	/**
301 
	 * Méthode principale appelée avec une requête de type POST.
302 
	 */
303 
	public function updateElement($params_url, $params_post) {
304 
		// Initialisation des variables
305 
		$info = array();
306 
 
307 
		// Nour recherchons le type de requête demandé
308 
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
309 
		extract($this->traiterParametresPost(array('action'), $params_post, false));
310 
 
311 
		if (!is_null($id)) {
312 
			if (!is_null($action)) {
313 
				$methode = 'updateElement'.$action;
314 
				if (method_exists($this, $methode)) {
315 
					//array_shift($param);
316 
					$info = $this->$methode($id, $params_post);
317 
				} else {
318 
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
319 
				}
320 
			} else {
321 
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
322 
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
323 
			}
324 
		} else {
325 
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
326 
		}
327 
 
328 
		// Envoie sur la sortie standard
329 
		$this->envoyer($info);
330 
	}
331 
 
332 
	/**
333 
	 * Méthode pour indiquer le démarage d'un traitement.
334 
	 */
335 
	public function updateElementDebuter($id, $params_post) {
336 
		$ok = true;
337 
		try {
338 
			$requete = 	'UPDATE ref_traitement '.
339 
						'SET date_debut = NOW() '.
340 
						"WHERE id_traitement = $id ";
341 
			$this->debug[] = "$requete";
342 
			$resultat = $this->bdd->exec($requete);
343 
			if ($resultat === false) {
344 
				$ok = false;
345 
				$this->messages[] = "Traitement NON modifié.";
346 
			}
347 
		} catch (PDOException $e) {
348 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
349 
		}
350 
 
351 
	   	return $ok;
352 
	}
353 
 
354 
	/**
30 jpm 355 
	 * Méthode pour indiquer la fin d'un traitement.
356 
	 */
357 
	public function updateElementTerminer($id, $params_post) {
358 
		$ok = true;
359 
		try {
360 
			$requete = 	'UPDATE ref_traitement '.
33 jpm 361 
						'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
30 jpm 362 
						"WHERE id_traitement = $id ";
363 
			$this->debug[] = "$requete";
364 
			$resultat = $this->bdd->exec($requete);
365 
			if ($resultat === false) {
366 
				$ok = false;
367 
				$this->messages[] = "Traitement NON modifié.";
368 
			}
369 
		} catch (PDOException $e) {
370 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
371 
		}
372 
 
373 
	   	return $ok;
374 
	}
375 
 
376 
	/**
26 jpm 377 
	 * Méthode principale appelée avec une requête de type DELETE.
378 
	 */
379 
	public function deleteElement($params_url) {
380 
		// Initialisation des variables
381 
		$ok = true;
382 
 
383 
		// Extraction des paramètres de l'url
384 
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
385 
 
386 
		if (!is_null($ids)) {
387 
			try {
388 
				$in_ids = $this->traiterBddClauseIn($ids);
389 
				$requete = 	'DELETE FROM ref_traitement '.
390 
							"WHERE id_traitement IN ($in_ids) ";
391 
				$this->debug[] = "$requete";
392 
				$resultat = $this->bdd->exec($requete);
393 
				if ($resultat === false) {
394 
					$ok = false;
395 
					$this->messages[] = "Traitement(s) NON supprimé(s).";
396 
				}
397 
			} catch (PDOException $e) {
398 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
399 
			}
400 
		} else {
401 
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
402 
		}
403 
 
404 
		// Envoie sur la sortie standard
405 
		$this->envoyer($ok);
406 
	}
23 jpm 407 
}
408 
?>