Subversion Repositories Applications.referentiel

Rev

Rev 49 | Rev 142 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

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