WebSVN – Applications.referentiel – Diff – /trunk/services/modules/Traitement.php


<?php
/**
 * Service permettant d'enregistrer une demande de traitement ou de consulter les infos sur les traitements.
 * Encodage en entrée : utf8
 * Encodage en sortie : utf8
 *
 * @category	Php 5.2
 * @package		Referentiel
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @license		GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 * @license		CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 * @copyright	2010 Tela-Botanica
 * @version		$Id$
 */
class Traitement extends Ref {
	
	/**
	 * Méthode principale appelée avec une requête de type GET.
	 */
	public function getElement($params_url = array()) {
		// Initialisation des variables
		$info = array();
				
		// Nour recherchons le type de requête demandé
		$p = $this->traiterParametresUrl(array('type', 'projet'), $params_url, false);
		
		$type = $p['type'];
		$projet = $p['projet'];
		
		if (!is_null($type)) {
			if (!is_null($projet)) {
				$methode = 'getElement'.$type;
				if (method_exists($this, $methode)) {
					//array_shift($param);
					$info = $this->$methode($projet);
				} else {
					$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
				}
				
			} else {
				$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
			}
		} else {
			$this->messages[] = "Veuillez préciser le type de requête.";
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($info);
	}
	
	/**
	 * Retourne les infos sur la dernière demande de traitement pour un projet donné.
	 */
	public function getElementDerniereDemande($projet) {
		$projet = $this->bdd->quote($projet);
		$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
					'FROM ref_traitement '.
					"WHERE referentiel_code = $projet ".
					'	AND date_fin IS NULL '.
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
					'LIMIT 0,1 ';
		
		$this->debug[] = $requete;
		
		// Récupération des résultats
		try {
			$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
			if ($donnees === false) {
				$this->messages[] = "La requête a retourné aucun résultat.";
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
		}
		return $donnees;
	}
	
	/**
	 * Retourne les infos sur les traitements en cours ou en attentes.
	 */
	public function getElementEnCours($projet) {
		$projet = $this->bdd->quote($projet);
		$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
					'FROM ref_traitement '.
					"WHERE referentiel_code = $projet ".
					'	AND date_debut IS NOT NULL '.
					'	AND date_fin IS NULL '.
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
		$this->debug[] = $requete;
		
		// Récupération des résultats
		try {
			$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
			if ($donnees === false) {
				$this->messages[] = "La requête a retourné aucun résultat.";
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
		}
		return $donnees;
	}
	
	/**
	 * Retourne les id des demandes de traitements obsolètes.
	 */
	public function getElementObsolete($projet) {
		$projet = $this->bdd->quote($projet);
		try {
			$requete =	'SELECT MAX(date_debut) '.
						'FROM ref_traitement '.
						"WHERE referentiel_code = $projet ".
						'	AND date_debut IS NOT NULL '.
						'GROUP BY referentiel_code ';
			
			$date_max = $this->bdd->query($requete)->fetchColumn();
			if ($date_max === false) {
				$this->messages[] = "La requête de récupération de la date de début max a échouée.";
			} else {
				$date_max = $this->bdd->quote($date_max);
				$requete = 	'SELECT id_traitement '.
							'FROM ref_traitement '.
							"WHERE referentiel_code = $projet ".
							'	AND date_debut IS NULL '.
							'	AND date_fin IS NULL '.
							"	AND meta_date_creation < $date_max ";
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				}
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
		}
		// Pos-traitement
		$sortie = array();
		if ($donnees != false) {
			foreach ($donnees as $donnee) {
				$sortie[] = $donnee['id_traitement'];
			}
		}
		return $sortie;
	}
	
	/**
	 * Méthode appelée pour ajouter un traitement.
	 * Retour l'id du nouvel enregistrement ou false!
	 */
	public function createElement($params_post) {
		$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params_post);
		$meta_date_creation = date ("Y-m-d H:i:s");
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
		
		try {
			$requete = 	"INSERT INTO ref_traitement ".
   						' (referentiel_code, nom, meta_date_creation) '.
						" VALUES ({$params_proteges['referentiel_code']}, $nom, $meta_date_creation) ";
			$resultat = $this->bdd->exec($requete);
			if ($resultat === false) {
				$id = false;
				$this->debug[] = "Traitement NON ajouté.";
			} else {
				$id = $this->bdd->lastInsertId();
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
		}
	   	
	   	$this->envoyer($id);
	}
	
	/**
	 * Méthode principale appelée avec une requête de type POST.
	 */
	public function updateElement($params_url, $params_post) {
		// Initialisation des variables
		$info = array();
				
		// Nour recherchons le type de requête demandé
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
		extract($this->traiterParametresPost(array('action'), $params_post, false));
 
		if (!is_null($id)) {
			if (!is_null($action)) {
				$methode = 'updateElement'.$action;
				if (method_exists($this, $methode)) {
					//array_shift($param);
					$info = $this->$methode($id, $params_post);
				} else {
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
				}
			} else {
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
			}
		} else {
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($info);
	}
	
	/**
	 * Méthode pour indiquer le démarage d'un traitement.
	 */
	public function updateElementDebuter($id, $params_post) {
		$ok = true;
		try {
			$requete = 	'UPDATE ref_traitement '.
						'SET date_debut = NOW() '.
						"WHERE id_traitement = $id ";
			$this->debug[] = "$requete";
			$resultat = $this->bdd->exec($requete);
			if ($resultat === false) {
				$ok = false;
				$this->messages[] = "Traitement NON modifié.";
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
		}
	   	
	   	return $ok;
	}
	
	/**
	 * Méthode pour indiquer la fin d'un traitement.
	 */
	public function updateElementTerminer($id, $params_post) {
		$ok = true;
		try {
			$requete = 	'UPDATE ref_traitement '.
						'SET date_fin = NOW() '.
						"WHERE id_traitement = $id ";
			$this->debug[] = "$requete";
			$resultat = $this->bdd->exec($requete);
			if ($resultat === false) {
				$ok = false;
				$this->messages[] = "Traitement NON modifié.";
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
		}
	   	
	   	return $ok;
	}
	
	/**
	 * Méthode principale appelée avec une requête de type DELETE.
	 */
	public function deleteElement($params_url) {
		// Initialisation des variables
		$ok = true;
				
		// Extraction des paramètres de l'url
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
 
		if (!is_null($ids)) {
			try {
				$in_ids = $this->traiterBddClauseIn($ids);
				$requete = 	'DELETE FROM ref_traitement '.
							"WHERE id_traitement IN ($in_ids) ";
				$this->debug[] = "$requete";
				$resultat = $this->bdd->exec($requete);
				if ($resultat === false) {
					$ok = false;
					$this->messages[] = "Traitement(s) NON supprimé(s).";
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
			}
		} else {
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($ok);
	}
}
?>

Rev 26	Rev 30
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 = array();`	22	`$info = array();`
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', 'projet'), $params_url, false);`	25	`$p = $this->traiterParametresUrl(array('type', 'projet'), $params_url, false);`
26		26
27	`$type = $p['type'];`	27	`$type = $p['type'];`
28	`$projet = $p['projet'];`	28	`$projet = $p['projet'];`
29		29
30	`if (!is_null($type)) {`	30	`if (!is_null($type)) {`
31	`if (!is_null($projet)) {`	31	`if (!is_null($projet)) {`
32	`$methode = 'getElement'.$type;`	32	`$methode = 'getElement'.$type;`
33	`if (method_exists($this, $methode)) {`	33	`if (method_exists($this, $methode)) {`
34	`//array_shift($param);`	34	`//array_shift($param);`
35	`$info = $this->$methode($projet);`	35	`$info = $this->$methode($projet);`
36	`} else {`	36	`} else {`
37	`$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";`	37	`$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";`
38	`}`	38	`}`
39		39
40	`} else {`	40	`} else {`
41	`$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";`	41	`$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";`
42	`}`	42	`}`
43	`} else {`	43	`} else {`
44	`$this->messages[] = "Veuillez préciser le type de requête.";`	44	`$this->messages[] = "Veuillez préciser le type de requête.";`
45	`}`	45	`}`
46		46
47	`// Envoie sur la sortie standard`	47	`// Envoie sur la sortie standard`
48	`$this->envoyer($info);`	48	`$this->envoyer($info);`
49	`}`	49	`}`
50		50
51	`/**`	51	`/**`
52	`* Retourne les infos sur la dernière demande de traitement pour un projet donné.`	52	`* Retourne les infos sur la dernière demande de traitement pour un projet donné.`
53	`*/`	53	`*/`
54	`public function getElementDerniereDemande($projet) {`	54	`public function getElementDerniereDemande($projet) {`
55	`$projet = $this->bdd->quote($projet);`	55	`$projet = $this->bdd->quote($projet);`
56	`$requete = ($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.`	56	`$requete = ($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.`
57	`'FROM ref_traitement '.`	57	`'FROM ref_traitement '.`
58	`"WHERE referentiel_code = $projet ".`	58	`"WHERE referentiel_code = $projet ".`
59	`' AND date_fin IS NULL '.`	59	`' AND date_fin IS NULL '.`
60	`'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby : 'meta_date_creation DESC').' '.`	60	`'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby : 'meta_date_creation DESC').' '.`
61	`'LIMIT 0,1 ';`	61	`'LIMIT 0,1 ';`
62		62
63	`$this->debug[] = $requete;`	63	`$this->debug[] = $requete;`
64		64
65	`// Récupération des résultats`	65	`// Récupération des résultats`
66	`try {`	66	`try {`
67	`$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);`	67	`$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);`
68	`if ($donnees === false) {`	68	`if ($donnees === false) {`
69	`$this->messages[] = "La requête a retourné aucun résultat.";`	69	`$this->messages[] = "La requête a retourné aucun résultat.";`
70	`}`	70	`}`
71	`} catch (PDOException $e) {`	71	`} catch (PDOException $e) {`
72	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());`	72	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());`
73	`}`	73	`}`
74	`return $donnees;`	74	`return $donnees;`
75	`}`	75	`}`
76		76
77	`/**`	77	`/**`
78	`* Retourne les infos sur les traitements en cours ou en attentes.`	78	`* Retourne les infos sur les traitements en cours ou en attentes.`
79	`*/`	79	`*/`
80	`public function getElementEnCours($projet) {`	80	`public function getElementEnCours($projet) {`
81	`$projet = $this->bdd->quote($projet);`	81	`$projet = $this->bdd->quote($projet);`
82	`$requete = ($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.`	82	`$requete = ($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.`
83	`'FROM ref_traitement '.`	83	`'FROM ref_traitement '.`
84	`"WHERE referentiel_code = $projet ".`	84	`"WHERE referentiel_code = $projet ".`
-		85	`' AND date_debut IS NOT NULL '.`
85	`' AND date_fin IS NULL '.`	86	`' AND date_fin IS NULL '.`
86	`'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby : 'meta_date_creation DESC').' ';`	87	`'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby : 'meta_date_creation DESC').' ';`
87	`$this->debug[] = $requete;`	88	`$this->debug[] = $requete;`
88		89
89	`// Récupération des résultats`	90	`// Récupération des résultats`
90	`try {`	91	`try {`
91	`$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);`	92	`$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);`
92	`if ($donnees === false) {`	93	`if ($donnees === false) {`
93	`$this->messages[] = "La requête a retourné aucun résultat.";`	94	`$this->messages[] = "La requête a retourné aucun résultat.";`
94	`}`	95	`}`
95	`} catch (PDOException $e) {`	96	`} catch (PDOException $e) {`
96	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());`	97	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());`
97	`}`	98	`}`
98	`return $donnees;`	99	`return $donnees;`
99	`}`	100	`}`
100		101
101	`/**`	102	`/**`
102	`* Retourne les id des demandes de traitements obsolètes.`	103	`* Retourne les id des demandes de traitements obsolètes.`
103	`*/`	104	`*/`
104	`public function getElementObsolete($projet) {`	105	`public function getElementObsolete($projet) {`
105	`$projet = $this->bdd->quote($projet);`	106	`$projet = $this->bdd->quote($projet);`
106	`try {`	107	`try {`
107	`$requete = 'SELECT MAX(date_debut) '.`	108	`$requete = 'SELECT MAX(date_debut) '.`
108	`'FROM ref_traitement '.`	109	`'FROM ref_traitement '.`
109	`"WHERE referentiel_code = $projet ".`	110	`"WHERE referentiel_code = $projet ".`
110	`' AND date_debut IS NOT NULL '.`	111	`' AND date_debut IS NOT NULL '.`
111	`'GROUP BY referentiel_code ';`	112	`'GROUP BY referentiel_code ';`
112		113
113	`$date_max = $this->bdd->query($requete)->fetchColumn();`	114	`$date_max = $this->bdd->query($requete)->fetchColumn();`
114	`if ($date_max === false) {`	115	`if ($date_max === false) {`
115	`$this->messages[] = "La requête de récupération de la date de début max a échouée.";`	116	`$this->messages[] = "La requête de récupération de la date de début max a échouée.";`
116	`} else {`	117	`} else {`
117	`$date_max = $this->bdd->quote($date_max);`	118	`$date_max = $this->bdd->quote($date_max);`
118	`$requete = 'SELECT id_traitement '.`	119	`$requete = 'SELECT id_traitement '.`
119	`'FROM ref_traitement '.`	120	`'FROM ref_traitement '.`
120	`"WHERE referentiel_code = $projet ".`	121	`"WHERE referentiel_code = $projet ".`
121	`' AND date_debut IS NULL '.`	122	`' AND date_debut IS NULL '.`
122	`' AND date_fin IS NULL '.`	123	`' AND date_fin IS NULL '.`
123	`" AND meta_date_creation < $date_max ";`	124	`" AND meta_date_creation < $date_max ";`
124	`$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);`	125	`$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);`
125	`if ($donnees === false) {`	126	`if ($donnees === false) {`
126	`$this->messages[] = "La requête a retourné aucun résultat.";`	127	`$this->messages[] = "La requête a retourné aucun résultat.";`
127	`}`	128	`}`
128	`}`	129	`}`
129	`} catch (PDOException $e) {`	130	`} catch (PDOException $e) {`
130	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());`	131	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());`
131	`}`	132	`}`
132	`// Pos-traitement`	133	`// Pos-traitement`
133	`$sortie = array();`	134	`$sortie = array();`
134	`if ($donnees != false) {`	135	`if ($donnees != false) {`
135	`foreach ($donnees as $donnee) {`	136	`foreach ($donnees as $donnee) {`
136	`$sortie[] = $donnee['id_traitement'];`	137	`$sortie[] = $donnee['id_traitement'];`
137	`}`	138	`}`
138	`}`	139	`}`
139	`return $sortie;`	140	`return $sortie;`
140	`}`	141	`}`
141		142
142	`/**`	143	`/**`
143	`* Méthode appelée pour ajouter un traitement.`	144	`* Méthode appelée pour ajouter un traitement.`
144	`* Retour l'id du nouvel enregistrement ou false!`	145	`* Retour l'id du nouvel enregistrement ou false!`
145	`*/`	146	`*/`
146	`public function createElement($params_post) {`	147	`public function createElement($params_post) {`
147	`$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params_post);`	148	`$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params_post);`
148	`$meta_date_creation = date ("Y-m-d H:i:s");`	149	`$meta_date_creation = date ("Y-m-d H:i:s");`
149	`$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");`	150	`$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");`
150	`$meta_date_creation = $this->bdd->quote($meta_date_creation);`	151	`$meta_date_creation = $this->bdd->quote($meta_date_creation);`
151		152
152	`try {`	153	`try {`
153	`$requete = "INSERT INTO ref_traitement ".`	154	`$requete = "INSERT INTO ref_traitement ".`
154	`' (referentiel_code, nom, meta_date_creation) '.`	155	`' (referentiel_code, nom, meta_date_creation) '.`
155	`" VALUES ({$params_proteges['referentiel_code']}, $nom, $meta_date_creation) ";`	156	`" VALUES ({$params_proteges['referentiel_code']}, $nom, $meta_date_creation) ";`
156	`$resultat = $this->bdd->exec($requete);`	157	`$resultat = $this->bdd->exec($requete);`
157	`if ($resultat === false) {`	158	`if ($resultat === false) {`
158	`$id = false;`	159	`$id = false;`
159	`$this->debug[] = "Traitement NON ajouté.";`	160	`$this->debug[] = "Traitement NON ajouté.";`
160	`} else {`	161	`} else {`
161	`$id = $this->bdd->lastInsertId();`	162	`$id = $this->bdd->lastInsertId();`
162	`}`	163	`}`
163	`} catch (PDOException $e) {`	164	`} catch (PDOException $e) {`
164	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`	165	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`
165	`}`	166	`}`
166		167
167	`$this->envoyer($id);`	168	`$this->envoyer($id);`
168	`}`	169	`}`
169		170
170	`/**`	171	`/**`
171	`* Méthode principale appelée avec une requête de type POST.`	172	`* Méthode principale appelée avec une requête de type POST.`
172	`*/`	173	`*/`
173	`public function updateElement($params_url, $params_post) {`	174	`public function updateElement($params_url, $params_post) {`
174	`// Initialisation des variables`	175	`// Initialisation des variables`
175	`$info = array();`	176	`$info = array();`
176		177
177	`// Nour recherchons le type de requête demandé`	178	`// Nour recherchons le type de requête demandé`
178	`extract($this->traiterParametresUrl(array('id'), $params_url, true));`	179	`extract($this->traiterParametresUrl(array('id'), $params_url, true));`
179	`extract($this->traiterParametresPost(array('action'), $params_post, false));`	180	`extract($this->traiterParametresPost(array('action'), $params_post, false));`
180		181
181	`if (!is_null($id)) {`	182	`if (!is_null($id)) {`
182	`if (!is_null($action)) {`	183	`if (!is_null($action)) {`
183	`$methode = 'updateElement'.$action;`	184	`$methode = 'updateElement'.$action;`
184	`if (method_exists($this, $methode)) {`	185	`if (method_exists($this, $methode)) {`
185	`//array_shift($param);`	186	`//array_shift($param);`
186	`$info = $this->$methode($id, $params_post);`	187	`$info = $this->$methode($id, $params_post);`
187	`} else {`	188	`} else {`
188	`$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";`	189	`$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";`
189	`}`	190	`}`
190	`} else {`	191	`} else {`
191	`$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";`	192	`$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";`
192	`// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);`	193	`// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);`
193	`}`	194	`}`
194	`} else {`	195	`} else {`
195	`$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";`	196	`$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";`
196	`}`	197	`}`
197		198
198	`// Envoie sur la sortie standard`	199	`// Envoie sur la sortie standard`
199	`$this->envoyer($info);`	200	`$this->envoyer($info);`
200	`}`	201	`}`
201		202
202	`/**`	203	`/**`
203	`* Méthode pour indiquer le démarage d'un traitement.`	204	`* Méthode pour indiquer le démarage d'un traitement.`
204	`*/`	205	`*/`
205	`public function updateElementDebuter($id, $params_post) {`	206	`public function updateElementDebuter($id, $params_post) {`
206	`$ok = true;`	207	`$ok = true;`
207	`try {`	208	`try {`
208	`$requete = 'UPDATE ref_traitement '.`	209	`$requete = 'UPDATE ref_traitement '.`
209	`'SET date_debut = NOW() '.`	210	`'SET date_debut = NOW() '.`
210	`"WHERE id_traitement = $id ";`	211	`"WHERE id_traitement = $id ";`
-		212	`$this->debug[] = "$requete";`
-		213	`$resultat = $this->bdd->exec($requete);`
-		214	`if ($resultat === false) {`
-		215	`$ok = false;`
-		216	`$this->messages[] = "Traitement NON modifié.";`
-		217	`}`
-		218	`} catch (PDOException $e) {`
-		219	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`
-		220	`}`
-		221
-		222	`return $ok;`
-		223	`}`
-		224
-		225	`/**`
-		226	`* Méthode pour indiquer la fin d'un traitement.`
-		227	`*/`
-		228	`public function updateElementTerminer($id, $params_post) {`
-		229	`$ok = true;`
-		230	`try {`
-		231	`$requete = 'UPDATE ref_traitement '.`
-		232	`'SET date_fin = NOW() '.`
-		233	`"WHERE id_traitement = $id ";`
211	`$this->debug[] = "$requete";`	234	`$this->debug[] = "$requete";`
212	`$resultat = $this->bdd->exec($requete);`	235	`$resultat = $this->bdd->exec($requete);`
213	`if ($resultat === false) {`	236	`if ($resultat === false) {`
214	`$ok = false;`	237	`$ok = false;`
215	`$this->messages[] = "Traitement NON modifié.";`	238	`$this->messages[] = "Traitement NON modifié.";`
216	`}`	239	`}`
217	`} catch (PDOException $e) {`	240	`} catch (PDOException $e) {`
218	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`	241	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`
219	`}`	242	`}`
220		243
221	`return $ok;`	244	`return $ok;`
222	`}`	245	`}`
223		246
224	`/**`	247	`/**`
225	`* Méthode principale appelée avec une requête de type DELETE.`	248	`* Méthode principale appelée avec une requête de type DELETE.`
226	`*/`	249	`*/`
227	`public function deleteElement($params_url) {`	250	`public function deleteElement($params_url) {`
228	`// Initialisation des variables`	251	`// Initialisation des variables`
229	`$ok = true;`	252	`$ok = true;`
230		253
231	`// Extraction des paramètres de l'url`	254	`// Extraction des paramètres de l'url`
232	`extract($this->traiterParametresUrl(array('ids'), $params_url, true));`	255	`extract($this->traiterParametresUrl(array('ids'), $params_url, true));`
233		256
234	`if (!is_null($ids)) {`	257	`if (!is_null($ids)) {`
235	`try {`	258	`try {`
236	`$in_ids = $this->traiterBddClauseIn($ids);`	259	`$in_ids = $this->traiterBddClauseIn($ids);`
237	`$requete = 'DELETE FROM ref_traitement '.`	260	`$requete = 'DELETE FROM ref_traitement '.`
238	`"WHERE id_traitement IN ($in_ids) ";`	261	`"WHERE id_traitement IN ($in_ids) ";`
239	`$this->debug[] = "$requete";`	262	`$this->debug[] = "$requete";`
240	`$resultat = $this->bdd->exec($requete);`	263	`$resultat = $this->bdd->exec($requete);`
241	`if ($resultat === false) {`	264	`if ($resultat === false) {`
242	`$ok = false;`	265	`$ok = false;`
243	`$this->messages[] = "Traitement(s) NON supprimé(s).";`	266	`$this->messages[] = "Traitement(s) NON supprimé(s).";`
244	`}`	267	`}`
245	`} catch (PDOException $e) {`	268	`} catch (PDOException $e) {`
246	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`	269	`$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);`
247	`}`	270	`}`
248	`} else {`	271	`} else {`
249	`$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";`	272	`$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";`
250	`}`	273	`}`
251		274
252	`// Envoie sur la sortie standard`	275	`// Envoie sur la sortie standard`
253	`$this->envoyer($ok);`	276	`$this->envoyer($ok);`
254	`}`	277	`}`
255	`}`	278	`}`
256	`?>`	279	`?>`

Subversion Repositories Applications.referentiel

(root)/trunk/services/modules/Traitement.php – Rev 26 → 30