WebSVN – Applications.referentiel – Diff – /trunk/bibliotheque/dao/Dao.php


<?php
// declare(encoding='UTF-8');
/**
* Classe modèle spécifique à l'application, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.
* Elle est abstraite donc doit obligatoirement être étendue.
*
* @category		Php5
* @package 		Referentiel
* @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
* @copyright	2010 Tela-Botanica
* @license		http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
* @license		http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
* @version		SVN: $Id$
*/
abstract class Dao {
	const HTTP_REQUETE_SEPARATEUR = '&';
	protected $distinction = '0';
	protected $limite_debut = null;
	protected $limite_nbre = null;
	protected $url_jrest = null;
	
	public function __construct() {
		$this->url_jrest = Config::get('url_jrest');
	}
	
	//+----------------------------------------------------------------------------------------------------------------+
	// ACCESSEURS
	
	public function avoirLimitation() {
		$limitation = false;
		if (!is_null($this->limite_debut) && !is_null($this->limite_nbre)) {
			$limitation = true;
		}
		return $limitation;
	}
	
	public function setDistinction($distinct) {
		$this->distinction = $distinct;
	}
	
	public function getDistinction() {
		return $this->distinction;
	}
	
	public function setLimitation($limite_debut, $limite_nbre) {
		$this->limite_debut = $limite_debut;
		$this->limite_nbre = $limite_nbre;
	}
	
	public function getLimiteDebut() {
		return $this->limite_debut;
	}
	public function getLimiteNbre() {
		return $this->limite_nbre;
	}
	
	//+----------------------------------------------------------------------------------------------------------------+
	// MÉTHODES
	
	protected function envoyerRequeteConsultation($url) {
		$retour = $this->envoyerRequete($url, 'GET');
		return $retour;
	}
	
	protected function envoyerRequeteAjout($url, Array $donnees) {
		$retour = $this->envoyerRequete($url, 'PUT', $donnees);
		return $retour;
	}
	
	protected function envoyerRequeteModif($url, Array $donnees) {
		$retour = $this->envoyerRequete($url, 'POST', $donnees);
		return $retour;
	}
	
	protected function envoyerRequeteSuppression($url) {
		$retour = $this->envoyerRequete($url, 'DELETE');
		return $retour;
	}
	
	private function envoyerRequete($url, $mode, Array $donnees = array()) {
		$contenu = false;
		if ($mode != 'GET' && $mode != 'PUT' && $mode != 'POST' && $mode != 'DELETE') {
			$e = "Le mode de requête '$mode' n'est pas accepté!";
			trigger_error($e, E_USER_WARNING);
		} else {
			$contexte = stream_context_create(array(
				'http' => array(
      				'method' => $mode,
					'header' => "Content-type: application/x-www-form-urlencoded\r\n",
      				'content' => http_build_query($donnees, null, HTTP_REQUETE_SEPARATEUR))));
			$flux = @fopen($url, 'r', false, $contexte);
			if (!$flux) {
				$this->traiterEntete($http_response_header, $url);
				$e = "L'ouverture de l'url '$url' a échoué!";
				trigger_error($e, E_USER_WARNING);
			} else {
				// Informations sur les en-têtes et métadonnées du flux
				$entetes = stream_get_meta_data($flux);
				$this->traiterEntete($entetes, $url);
				
				// Contenu actuel de $url
				$contenu = stream_get_contents($flux);
				
				fclose($flux);
			}
		}
		return $contenu;
	}
	
	private function traiterEntete($entetes, $uri) {
		$infos = $this->analyserEntete($entetes, $uri);
		$this->traiterEnteteDebug($infos);
		$this->traiterEnteteMessage($infos);
	}
	
	private function analyserEntete($entetes, $uri) {
		$infos = array('date' => null, 'uri' => $uri, 'debugs' => null, 'messages' => null);
		
		if (isset($entetes['wrapper_data'])) {
			$entetes = $entetes['wrapper_data'];
		}
		foreach ($entetes as $entete) {
			if (preg_match('/^X-DebugJrest-Data: (.+)$/', $entete, $match)) {
				$infos['debugs'] = json_decode($match[1]);
			}
			if (preg_match('/^X-MessageJrest-Data: (.+)$/', $entete, $match)) {
				$infos['messages'] = json_decode($match[1]);
			}
			if (preg_match('/^Date: .+ ([012][0-9]:[012345][0-9]:[012345][0-9]) .*$/', $entete, $match)) {
				$infos['date'] = $match[1];
			}
		}
		return $infos;
	}
	
	private function traiterEnteteDebug($entetes) {
		if (isset($entetes['debugs'])) {
			$date = $entetes['date'];
			$uri = $entetes['uri'];
			$debugs = $entetes['debugs'];
			foreach ($debugs as $debug) {
				Debug::printr("DEBUG : $date - $uri :\n$debug");
			}
		}
	}
	
	private function traiterEnteteMessage($entetes) {
		if (isset($entetes['messages'])) {
			$date = $entetes['date'];
			$uri = $entetes['uri'];
			$messages = $entetes['messages'];
			foreach ($messages as $message) {
				Debug::printr("MESSAGE : $date - $uri :\n$message");
			}
		}
	}
}

Subversion Repositories Applications.referentiel

(root)/trunk/bibliotheque/dao/Dao.php @ 26 – Rev 26 → 36

Rev 26		Rev 36
1	`<?php`	1	`<?php`
2	`// declare(encoding='UTF-8');`	2	`// declare(encoding='UTF-8');`
3	`/**`	3	`/**`
4	`* Classe modèle spécifique à l'application, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.`	4	`* Classe modèle spécifique à l'application, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.`
5	`* Elle est abstraite donc doit obligatoirement être étendue.`	5	`* Elle est abstraite donc doit obligatoirement être étendue.`
6	`*`	6	`*`
7	`* @category Php5`	7	`* @category Php5`
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	`* @copyright 2010 Tela-Botanica`	10	`* @copyright 2010 Tela-Botanica`
11	`* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL`	11	`* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL`
12	`* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL`	12	`* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL`
13	`* @version SVN: $Id$`	13	`* @version SVN: $Id$`
14	`*/`	14	`*/`
15	`abstract class Dao {`	15	`abstract class Dao {`
-		16	`const HTTP_REQUETE_SEPARATEUR = '&';`
16	`protected $distinction = '0';`	17	`protected $distinction = '0';`
17	`protected $limite_debut = null;`	18	`protected $limite_debut = null;`
18	`protected $limite_nbre = null;`	19	`protected $limite_nbre = null;`
19	`protected $url_jrest = null;`	20	`protected $url_jrest = null;`
20		21
21	`public function __construct() {`	22	`public function __construct() {`
22	`$this->url_jrest = Config::get('url_jrest');`	23	`$this->url_jrest = Config::get('url_jrest');`
23	`}`	24	`}`
24		25
25	`//+----------------------------------------------------------------------------------------------------------------+`	26	`//+----------------------------------------------------------------------------------------------------------------+`
26	`// ACCESSEURS`	27	`// ACCESSEURS`
27		28
28	`public function avoirLimitation() {`	29	`public function avoirLimitation() {`
29	`$limitation = false;`	30	`$limitation = false;`
30	`if (!is_null($this->limite_debut) && !is_null($this->limite_nbre)) {`	31	`if (!is_null($this->limite_debut) && !is_null($this->limite_nbre)) {`
31	`$limitation = true;`	32	`$limitation = true;`
32	`}`	33	`}`
33	`return $limitation;`	34	`return $limitation;`
34	`}`	35	`}`
35		36
36	`public function setDistinction($distinct) {`	37	`public function setDistinction($distinct) {`
37	`$this->distinction = $distinct;`	38	`$this->distinction = $distinct;`
38	`}`	39	`}`
39		40
40	`public function getDistinction() {`	41	`public function getDistinction() {`
41	`return $this->distinction;`	42	`return $this->distinction;`
42	`}`	43	`}`
43		44
44	`public function setLimitation($limite_debut, $limite_nbre) {`	45	`public function setLimitation($limite_debut, $limite_nbre) {`
45	`$this->limite_debut = $limite_debut;`	46	`$this->limite_debut = $limite_debut;`
46	`$this->limite_nbre = $limite_nbre;`	47	`$this->limite_nbre = $limite_nbre;`
47	`}`	48	`}`
48		49
49	`public function getLimiteDebut() {`	50	`public function getLimiteDebut() {`
50	`return $this->limite_debut;`	51	`return $this->limite_debut;`
51	`}`	52	`}`
52	`public function getLimiteNbre() {`	53	`public function getLimiteNbre() {`
53	`return $this->limite_nbre;`	54	`return $this->limite_nbre;`
54	`}`	55	`}`
55		56
56	`//+----------------------------------------------------------------------------------------------------------------+`	57	`//+----------------------------------------------------------------------------------------------------------------+`
57	`// MÉTHODES`	58	`// MÉTHODES`
58		59
59	`protected function envoyerRequeteConsultation($url) {`	60	`protected function envoyerRequeteConsultation($url) {`
60	`$retour = $this->envoyerRequete($url, 'GET');`	61	`$retour = $this->envoyerRequete($url, 'GET');`
61	`return $retour;`	62	`return $retour;`
62	`}`	63	`}`
63		64
64	`protected function envoyerRequeteAjout($url, Array $donnees) {`	65	`protected function envoyerRequeteAjout($url, Array $donnees) {`
65	`$retour = $this->envoyerRequete($url, 'PUT', $donnees);`	66	`$retour = $this->envoyerRequete($url, 'PUT', $donnees);`
66	`return $retour;`	67	`return $retour;`
67	`}`	68	`}`
68		69
69	`protected function envoyerRequeteModif($url, Array $donnees) {`	70	`protected function envoyerRequeteModif($url, Array $donnees) {`
70	`$retour = $this->envoyerRequete($url, 'POST', $donnees);`	71	`$retour = $this->envoyerRequete($url, 'POST', $donnees);`
71	`return $retour;`	72	`return $retour;`
72	`}`	73	`}`
73		74
74	`protected function envoyerRequeteSuppression($url) {`	75	`protected function envoyerRequeteSuppression($url) {`
75	`$retour = $this->envoyerRequete($url, 'DELETE', $donnees);`	76	`$retour = $this->envoyerRequete($url, 'DELETE');`
76	`return $retour;`	77	`return $retour;`
77	`}`	78	`}`
78		79
79	`private function envoyerRequete($url, $mode, Array $donnees = array()) {`	80	`private function envoyerRequete($url, $mode, Array $donnees = array()) {`
80	`$contenu = false;`	81	`$contenu = false;`
81	`if ($mode != 'GET' && $mode != 'PUT' && $mode != 'POST' && $mode != 'DELETE') {`	82	`if ($mode != 'GET' && $mode != 'PUT' && $mode != 'POST' && $mode != 'DELETE') {`
82	`$e = "Le mode de requête '$mode' n'est pas accepté!";`	83	`$e = "Le mode de requête '$mode' n'est pas accepté!";`
83	`trigger_error($e, E_USER_WARNING);`	84	`trigger_error($e, E_USER_WARNING);`
84	`} else {`	85	`} else {`
85	`$contexte = stream_context_create(array(`	86	`$contexte = stream_context_create(array(`
86	`'http' => array(`	87	`'http' => array(`
87	`'method' => $mode,`	88	`'method' => $mode,`
88	`'header' => "Content-type: application/x-www-form-urlencoded\r\n",`	89	`'header' => "Content-type: application/x-www-form-urlencoded\r\n",`
89	`'content' => http_build_query($donnees))));`	90	`'content' => http_build_query($donnees, null, HTTP_REQUETE_SEPARATEUR))));`
90	`$flux = @fopen($url, 'r', false, $contexte);`	91	`$flux = @fopen($url, 'r', false, $contexte);`
91	`if (!$flux) {`	92	`if (!$flux) {`
92	`$this->traiterEntete($http_response_header, $url);`	93	`$this->traiterEntete($http_response_header, $url);`
93	`$e = "L'ouverture de l'url '$url' a échoué!";`	94	`$e = "L'ouverture de l'url '$url' a échoué!";`
94	`trigger_error($e, E_USER_WARNING);`	95	`trigger_error($e, E_USER_WARNING);`
95	`} else {`	96	`} else {`
96	`// Informations sur les en-têtes et métadonnées du flux`	97	`// Informations sur les en-têtes et métadonnées du flux`
97	`$entetes = stream_get_meta_data($flux);`	98	`$entetes = stream_get_meta_data($flux);`
98	`$this->traiterEntete($entetes, $url);`	99	`$this->traiterEntete($entetes, $url);`
99		100
100	`// Contenu actuel de $url`	101	`// Contenu actuel de $url`
101	`$contenu = stream_get_contents($flux);`	102	`$contenu = stream_get_contents($flux);`
102		103
103	`fclose($flux);`	104	`fclose($flux);`
104	`}`	105	`}`
105	`}`	106	`}`
106	`return $contenu;`	107	`return $contenu;`
107	`}`	108	`}`
108		109
109	`private function traiterEntete($entetes, $uri) {`	110	`private function traiterEntete($entetes, $uri) {`
110	`$infos = $this->analyserEntete($entetes, $uri);`	111	`$infos = $this->analyserEntete($entetes, $uri);`
111	`$this->traiterEnteteDebug($infos);`	112	`$this->traiterEnteteDebug($infos);`
112	`$this->traiterEnteteMessage($infos);`	113	`$this->traiterEnteteMessage($infos);`
113	`}`	114	`}`
114		115
115	`private function analyserEntete($entetes, $uri) {`	116	`private function analyserEntete($entetes, $uri) {`
116	`$infos = array('date' => null, 'uri' => $uri, 'debugs' => null, 'messages' => null);`	117	`$infos = array('date' => null, 'uri' => $uri, 'debugs' => null, 'messages' => null);`
117		118
118	`if (isset($entetes['wrapper_data'])) {`	119	`if (isset($entetes['wrapper_data'])) {`
119	`$entetes = $entetes['wrapper_data'];`	120	`$entetes = $entetes['wrapper_data'];`
120	`}`	121	`}`
121	`foreach ($entetes as $entete) {`	122	`foreach ($entetes as $entete) {`
122	`if (preg_match('/^X-DebugJrest-Data: (.+)$/', $entete, $match)) {`	123	`if (preg_match('/^X-DebugJrest-Data: (.+)$/', $entete, $match)) {`
123	`$infos['debugs'] = json_decode($match[1]);`	124	`$infos['debugs'] = json_decode($match[1]);`
124	`}`	125	`}`
125	`if (preg_match('/^X-MessageJrest-Data: (.+)$/', $entete, $match)) {`	126	`if (preg_match('/^X-MessageJrest-Data: (.+)$/', $entete, $match)) {`
126	`$infos['messages'] = json_decode($match[1]);`	127	`$infos['messages'] = json_decode($match[1]);`
127	`}`	128	`}`
128	`if (preg_match('/^Date: .+ ([012][0-9]:[012345][0-9]:[012345][0-9]) .*$/', $entete, $match)) {`	129	`if (preg_match('/^Date: .+ ([012][0-9]:[012345][0-9]:[012345][0-9]) .*$/', $entete, $match)) {`
129	`$infos['date'] = $match[1];`	130	`$infos['date'] = $match[1];`
130	`}`	131	`}`
131	`}`	132	`}`
132	`return $infos;`	133	`return $infos;`
133	`}`	134	`}`
134		135
135	`private function traiterEnteteDebug($entetes) {`	136	`private function traiterEnteteDebug($entetes) {`
136	`if (isset($entetes['debugs'])) {`	137	`if (isset($entetes['debugs'])) {`
137	`$date = $entetes['date'];`	138	`$date = $entetes['date'];`
138	`$uri = $entetes['uri'];`	139	`$uri = $entetes['uri'];`
139	`$debugs = $entetes['debugs'];`	140	`$debugs = $entetes['debugs'];`
140	`foreach ($debugs as $debug) {`	141	`foreach ($debugs as $debug) {`
141	`Debug::printr("DEBUG : $date - $uri :\n$debug");`	142	`Debug::printr("DEBUG : $date - $uri :\n$debug");`
142	`}`	143	`}`
143	`}`	144	`}`
144	`}`	145	`}`
145		146
146	`private function traiterEnteteMessage($entetes) {`	147	`private function traiterEnteteMessage($entetes) {`
147	`if (isset($entetes['messages'])) {`	148	`if (isset($entetes['messages'])) {`
148	`$date = $entetes['date'];`	149	`$date = $entetes['date'];`
149	`$uri = $entetes['uri'];`	150	`$uri = $entetes['uri'];`
150	`$messages = $entetes['messages'];`	151	`$messages = $entetes['messages'];`
151	`foreach ($messages as $message) {`	152	`foreach ($messages as $message) {`
152	`Debug::printr("MESSAGE : $date - $uri :\n$message");`	153	`Debug::printr("MESSAGE : $date - $uri :\n$message");`
153	`}`	154	`}`
154	`}`	155	`}`
155	`}`	156	`}`
156	`}`	157	`}`