Subversion Repositories Applications.referentiel

Rev

Rev 142 | 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
?>