Subversion Repositories Sites.obs-saisons.fr

Rev

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

Rev 46 Rev 210
1
<?php
1
<?php
2
 
2
 
3
class OdsIndividu extends JRestService {
3
class OdsIndividu extends JRestService {
4
 
4
 
5
	const PREFIXE = 'get';
5
	const PREFIXE = 'get';
6
	
6
	
7
	/**
7
	/**
8
     * Méthode appelée avec une requête de type GET.
8
     * Méthode appelée avec une requête de type GET.
9
     *
9
     *
10
     */
10
     */
11
    function getElement($param = array()) {
11
    function getElement($param = array()) {
12
    	    	
12
    	    	
13
    	$type = $param[0];
13
    	$type = $param[0];
14
    	
14
    	
15
    	if ($type == '*' || is_numeric($type)) {
15
    	if ($type == '*' || is_numeric($type)) {
16
            $info = $this->getElementParDefaut($param);
16
            $info = $this->getElementParDefaut($param);
17
        } else {
17
        } else {
18
            $methode = self::PREFIXE.$type;
18
            $methode = self::PREFIXE.$type;
19
            if (method_exists($this, $methode)) {
19
            if (method_exists($this, $methode)) {
20
                array_shift($param);
20
                array_shift($param);
21
                $info = $this->$methode($param);
21
                $info = $this->$methode($param);
22
            } else {
22
            } else {
23
                $this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
23
                $this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
24
            }
24
            }
25
        }
25
        }
26
       
26
       
27
        // Envoi sur la sortie standard
27
        // Envoi sur la sortie standard
28
        $this->envoyer($info);
28
        $this->envoyer($info);
29
    }
29
    }
30
   
30
   
31
    /**
31
    /**
32
     * Méthode appelée pour ajouter un élément.
32
     * Méthode appelée pour ajouter un élément.
33
     */
33
     */
34
    public function createElement($params) {
34
    public function createElement($params) {
35
    	
35
    	
36
        $elements_requis = array('id_participant','id_espece','id_station','individu_nom');
36
        $elements_requis = array('id_participant','id_espece','id_station','individu_nom');
37
        
37
        
38
    	foreach($elements_requis as $requis) {
38
    	foreach($elements_requis as $requis) {
39
    		if(!isset($params[$requis])) {
39
    		if(!isset($params[$requis])) {
40
    			//$erreurs[$requis] = 'erreur ';
40
    			//$erreurs[$requis] = 'erreur ';
41
    		}
41
    		}
42
    	}
42
    	}
43
    	
43
    	
44
    	if(!empty($erreurs)) {
44
    	if(!empty($erreurs)) {
45
    		$this->envoyer($erreurs);
45
    		$this->envoyer($erreurs);
46
    	}
46
    	}
47
    	
47
    	
48
    	$id_participant = $params['id_participant'];
48
    	$id_participant = $params['id_participant'];
49
    	
49
    	
50
    	$requete_creation_individu = 'INSERT INTO ods_individus '.
50
    	$requete_creation_individu = 'INSERT INTO ods_individus '.
51
					'(oi_ce_espece, oi_ce_station, oi_nom) '.
51
					'(oi_ce_espece, oi_ce_station, oi_nom) '.
52
					'VALUES ('.
52
					'VALUES ('.
53
							$this->proteger($params['id_espece']).','.
53
							$this->proteger($params['id_espece']).','.
54
							$this->proteger($params['id_station']).','.		
54
							$this->proteger($params['id_station']).','.		
55
							$this->proteger($params['individu_nom']).')';	
55
							$this->proteger($params['individu_nom']).')';	
56
		$creation_individu = $this->executerRequeteSimple($requete_creation_individu);
56
		$creation_individu = $this->executerRequeteSimple($requete_creation_individu);
57
		
57
		
58
    	
58
    	
59
    	if(!$creation_individu) {
59
    	if(!$creation_individu) {
60
    		$retour['erreurs'] = 'erreur d\'insertion';
60
    		$retour['erreurs'] = 'erreur d\'insertion';
61
    	} else {
61
    	} else {
62
    		$retour['id_nouvel_individu'] = $this->renvoyerDernierIdInsere();
62
    		$retour['id_nouvel_individu'] = $this->renvoyerDernierIdInsere();
63
    	}
63
    	}
64
    	
64
    	
65
    	$this->envoyer($retour);
65
    	$this->envoyer($retour);
66
    }
66
    }
67
   
67
   
68
    /**
68
    /**
69
     * Méthode appelée pour mettre à jour un élément
69
     * Méthode appelée pour mettre à jour un élément
70
     */
70
     */
71
    public function updateElement($uid, $params)    {
71
    public function updateElement($uid, $params)    {
-
 
72
    	
72
        //Mise à jour de la personne
73
        if(isset($uid[0])) {
73
        // Identification de l'utilisateur
74
    		$id_individu = $uid[0];
-
 
75
    	} else {
74
        list($id_utilisateur, $id_session) = $this->getIdentification($params);
76
    		return;
-
 
77
    	}
75
       
78
    	
76
        // Contrôle du non détournement de l'utilisateur
79
        $requete_modification_individu = 'UPDATE ods_individus '.
77
        if ($this->etreAutorise($id_utilisateur)) {
80
					'SET oi_nom = '.$this->proteger($params['individu_nom']).' '.
78
            try {
81
        			'WHERE oi_id_individu = '.$this->proteger($id_individu);
79
 
82
        
80
            } catch (PDOException $e) {
-
 
81
                $messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
83
		$modification_individu = $this->executerRequeteSimple($requete_modification_individu);
82
            }
-
 
83
        }
-
 
84
       
84
       
85
        $this->envoyer();      
85
        $this->envoyer();      
86
    }
86
    }
87
   
87
   
88
    /**
88
    /**
89
     * Méthode appelée pour supprimer un élément
89
     * Méthode appelée pour supprimer un élément
90
     */
90
     */
91
    public function deleteElement($uid) {
91
    public function deleteElement($uid) {
-
 
92
    	
92
        // Vérification de la présence des id passés par l'url
93
        if(isset($uid[0])) {
93
        if (!isset($uid[0]) || !isset($uid[1])) {
94
    		$id_participant = $uid[0];
94
            $this->messages[] = "Identifiant d'utilisateur ou de personne manquant. Vous ne devriez pas avoir accès à ce service.";
-
 
95
        } else {
95
    	} else {
96
            list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
96
    		return;
-
 
97
    	}
97
           
98
    	
98
            // Contrôle du non détournement de l'utilisateur     
-
 
99
            if ($this->etreAutorise($id_utilisateur)) {
99
    	if(isset($uid[1])) {
100
                // Récupération des id passés par l'url     
100
    		$id_individu = $uid[1];
101
                $identifiants = explode(',', rtrim($uid[1], ','));
101
    	} else {
102
                if (count($identifiants) == 0) {
102
    		return;
-
 
103
    	}
-
 
104
    	    	
103
                    $this->messages[] = "Aucun enregistrement n'a été supprimé.";
105
    	$requete_suppression_individu = 'DELETE FROM ods_individus '.
104
                } else {
-
 
105
                    foreach ($identifiants as $id_personne) {
106
    		'WHERE oi_id_individu = '.$this->proteger($id_individu).' '.
106
                        try {
107
        	'AND oi_ce_station IN '.
107
                        } catch (PDOException $e) {
108
        		'(SELECT os_id_station FROM ods_stations '.
108
                            $this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
109
        			'WHERE os_ce_participant = '.$this->proteger($id_participant).' '.
109
                        }
110
    			')';
-
 
111
    	
110
                    }
112
    	$suppression_individu = $this->executerRequeteSimple($requete_suppression_individu);
-
 
113
    	
111
                }
114
    	if(!$suppression_individu) {
112
            }
115
    		// TODO: comment gère t'on les erreurs ?
113
        }
116
    	}
114
       
117
       
115
        // Envoie sur la sortie standard
118
        // Envoie sur la sortie standard
116
        $this->envoyer();
119
        $this->envoyer();
117
    }
120
    }
118
    
121
    
119
    private function getElementParDefaut($params) {
122
    private function getElementParDefaut($params) {
120
    	return $this->getInformationsIndividu($params);
123
    	return $this->getInformationsIndividu($params);
121
    }
124
    }
122
    
125
    
123
    private function getInformationsIndividu($params) {
126
    private function getInformationsIndividu($params) {
124
    	
127
    	
125
    	$id_individu = $params[0];
128
    	$id_individu = $params[0];
126
 
129
 
127
    	$requete_informations_individu = 'SELECT * FROM ods_individus '. 
130
    	$requete_informations_individu = 'SELECT * FROM ods_individus '. 
128
								'WHERE oi_id_individu = '.$this->proteger($id_individu);
131
								'WHERE oi_id_individu = '.$this->proteger($id_individu);
129
    	
132
    	
130
    	$informations_individu = $this->executerRequete($requete_informations_individu);
133
    	$informations_individu = $this->executerRequete($requete_informations_individu);
131
    	
134
    	
132
    	if(!empty($informations_individu)) {
135
    	if(!empty($informations_individu)) {
133
    		$informations_individu_formatees = $this->formaterTableauIndividuPourEnvoi($informations_individu[0]);
136
    		$informations_individu_formatees = $this->formaterTableauIndividuPourEnvoi($informations_individu[0]);
134
    	}
137
    	}
135
    	
138
    	
136
    	return $informations_individu_formatees;
139
    	return $informations_individu_formatees;
137
    	
140
    	
138
    }
141
    }
139
    
142
    
140
    private function getIndividusPourStation($params) {
143
    private function getIndividusPourStation($params) {
141
    	
144
    	
142
    	$id_station = $params[0];
145
    	$id_station = $params[0];
143
    		    	
146
    		    	
144
		$requete_individus_station = 'SELECT * FROM ods_individus '. 
147
		$requete_individus_station = 'SELECT * FROM ods_individus '. 
145
									 'WHERE oi_ce_station = '.$this->proteger($id_station);
148
									 'WHERE oi_ce_station = '.$this->proteger($id_station);
146
    	$liste_individus_pour_station = $this->executerRequete($requete_individus_station);
149
    	$liste_individus_pour_station = $this->executerRequete($requete_individus_station);
147
 
150
 
148
    	foreach($liste_individus_pour_station as &$individu_pour_station) {
151
    	foreach($liste_individus_pour_station as &$individu_pour_station) {
149
    		
152
    		
150
    		$individu_pour_station = $this->formaterTableauIndividuPourEnvoi($individu_pour_station);   		
153
    		$individu_pour_station = $this->formaterTableauIndividuPourEnvoi($individu_pour_station);   		
151
    	}
154
    	}
152
    	
155
    	
153
    	return $liste_individus_pour_station;
156
    	return $liste_individus_pour_station;
154
    }
157
    }
155
    
158
    
156
	private function getIndividusPourStationPourEspece($params) {
159
	private function getIndividusPourStationPourEspece($params) {
157
    	
160
    	
158
    	$id_station = $params[0];
161
    	$id_station = $params[0];
159
    	$id_espece = $params[1];
162
    	$id_espece = $params[1];
160
    		    	
163
    		    	
161
		$requete_individus_station_espece = 'SELECT * FROM ods_individus '. 
164
		$requete_individus_station_espece = 'SELECT * FROM ods_individus '. 
162
									 'WHERE oi_ce_station = '.$this->proteger($id_station).' '.
165
									 'WHERE oi_ce_station = '.$this->proteger($id_station).' '.
163
									 'AND oi_ce_espece ='.$this->proteger($id_espece);
166
									 'AND oi_ce_espece ='.$this->proteger($id_espece);
164
		
167
		
165
    	$liste_individus_pour_station_pour_espece = $this->executerRequete($requete_individus_station_espece);
168
    	$liste_individus_pour_station_pour_espece = $this->executerRequete($requete_individus_station_espece);
166
 
169
 
167
		foreach($liste_individus_pour_station_pour_espece as &$individu_pour_station_pour_espece) {
170
		foreach($liste_individus_pour_station_pour_espece as &$individu_pour_station_pour_espece) {
168
    		
171
    		
169
    		$individu_pour_station_pour_espece = $this->formaterTableauIndividuPourEnvoi($individu_pour_station_pour_espece);   		
172
    		$individu_pour_station_pour_espece = $this->formaterTableauIndividuPourEnvoi($individu_pour_station_pour_espece);   		
170
    	}
173
    	}
171
    	
174
    	
172
    	return $liste_individus_pour_station_pour_espece;
175
    	return $liste_individus_pour_station_pour_espece;
173
    }
176
    }
174
    
177
    
175
	private function formaterTableauIndividuPourEnvoi($individu) {
178
	private function formaterTableauIndividuPourEnvoi($individu) {
176
    	
179
    	
177
    	return array( 
180
    	return array( 
178
    	    'id_individu' => $individu['oi_id_individu'],
181
    	    'id_individu' => $individu['oi_id_individu'],
179
            'id_espece' => $individu['oi_ce_espece'],
182
            'id_espece' => $individu['oi_ce_espece'],
180
            'id_station' => $individu['oi_ce_station'],
183
            'id_station' => $individu['oi_ce_station'],
181
    	    'nom' => $individu['oi_nom']
184
    	    'nom' => $individu['oi_nom']
182
        );
185
        );
183
    	
186
    	
184
    }
187
    }
185
}
188
}
186
?>
189
?>