Subversion Repositories eFlore/Applications.coel

Rev

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

Rev 1329 Rev 1367
1
package org.tela_botanica.client.modeles.personne;
1
package org.tela_botanica.client.modeles.personne;
2
 
2
 
3
import java.util.HashMap;
3
import java.util.HashMap;
4
 
4
 
5
import org.tela_botanica.client.Mediateur;
5
import org.tela_botanica.client.Mediateur;
6
import org.tela_botanica.client.RegistreId;
6
import org.tela_botanica.client.RegistreId;
7
import org.tela_botanica.client.http.JsonRestRequestBuilder;
7
import org.tela_botanica.client.http.JsonRestRequestBuilder;
8
import org.tela_botanica.client.http.JsonRestRequestCallback;
8
import org.tela_botanica.client.http.JsonRestRequestCallback;
9
import org.tela_botanica.client.interfaces.Rafraichissable;
9
import org.tela_botanica.client.interfaces.Rafraichissable;
10
import org.tela_botanica.client.modeles.Information;
10
import org.tela_botanica.client.modeles.Information;
11
import org.tela_botanica.client.synchronisation.Reponse;
11
import org.tela_botanica.client.synchronisation.Reponse;
12
import org.tela_botanica.client.synchronisation.Sequenceur;
12
import org.tela_botanica.client.synchronisation.Sequenceur;
13
import org.tela_botanica.client.util.Debug;
13
import org.tela_botanica.client.util.Debug;
14
import org.tela_botanica.client.util.UtilDAO;
14
import org.tela_botanica.client.util.UtilDAO;
15
import com.extjs.gxt.ui.client.Registry;
15
import com.extjs.gxt.ui.client.Registry;
16
import com.google.gwt.core.client.GWT;
16
import com.google.gwt.core.client.GWT;
17
import com.google.gwt.json.client.JSONArray;
17
import com.google.gwt.json.client.JSONArray;
18
import com.google.gwt.json.client.JSONObject;
18
import com.google.gwt.json.client.JSONObject;
19
import com.google.gwt.json.client.JSONValue;
19
import com.google.gwt.json.client.JSONValue;
20
 
20
 
21
public class PersonneAsyncDao {
21
public class PersonneAsyncDao {
22
	private static final String SERVICE_NOM = "CoelPersonne";
22
	private static final String SERVICE_NOM = "CoelPersonne";
23
	
23
	
24
	private String utilisateurId = null;
24
	private String utilisateurId = null;
25
	private Rafraichissable vueARafraichir = null;
25
	private Rafraichissable vueARafraichir = null;
26
	
26
	
27
	public PersonneAsyncDao(Rafraichissable vue) {
27
	public PersonneAsyncDao(Rafraichissable vue) {
-
 
28
		if (Mediateur.DEBUG) System.out.println("|| PersonneAsyncDao > vueARafraichir = "+vue.getClass().toString());
28
		vueARafraichir = vue;
29
		vueARafraichir = vue;
29
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
30
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
30
	}	
31
	}	
31
	
32
	
32
	/**
33
	/**
33
	 * @param paginationProgressive : définit le mode de consultation de la base de données
34
	 * @param paginationProgressive : définit le mode de consultation de la base de données
34
	 * 			- True :	la consultation des données est progressive, ce qui signifie que la liste est chargée (paginée) au
35
	 * 			- True :	la consultation des données est progressive, ce qui signifie que la liste est chargée (paginée) au
35
	 * 						fur et à mesure de la consultation des données par l'utilisateur.
36
	 * 						fur et à mesure de la consultation des données par l'utilisateur.
36
	 * 			- False :	la consultation des données est classique : un seul appel à la base de données est effectué, le retour
37
	 * 			- False :	la consultation des données est classique : un seul appel à la base de données est effectué, le retour
37
	 * 						est renvoyé à l'appelant
38
	 * 						est renvoyé à l'appelant
38
	 * 			// FIXME : si la taille de la liste est supérieure à la limite du JREST (150), ce deuxieme mode ne fonctionne pas
39
	 * 			// FIXME : si la taille de la liste est supérieure à la limite du JREST (150), ce deuxieme mode ne fonctionne pas
39
	 */	
40
	 */	
40
	public void selectionner(final boolean paginationProgressive, String personneId, String projetId, String nomComplet, final int start, final int nbElements, final Integer seqId) {
41
	public void selectionner(final boolean paginationProgressive, String personneId, String projetId, String nomComplet, final int start, final int nbElements, final Integer seqId) {
41
 
42
 
42
		String nom = (nomComplet == null) ? "%" : nomComplet+"%";		
43
		String nom = (nomComplet == null) ? "%" : nomComplet+"%";		
43
		String[] parametres = {personneId, projetId, nom};
44
		String[] parametres = {personneId, projetId, nom};
44
		
45
		
45
		HashMap<String, String> restrictions = new HashMap<String, String>();
46
		HashMap<String, String> restrictions = new HashMap<String, String>();
46
		
47
		
47
		if (nbElements != -1)	{
48
		if (nbElements != -1)	{
48
			restrictions.put("limit", String.valueOf(nbElements));
49
			restrictions.put("limit", String.valueOf(nbElements));
49
		}
50
		}
50
		
51
		
51
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
52
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
52
		if (paginationProgressive) {
53
		if (paginationProgressive) {
53
 
54
 
54
			/** DEFINITION DU TUPLE DE DEPART **/
55
			/** DEFINITION DU TUPLE DE DEPART **/
55
			restrictions.put("start", String.valueOf(start));
56
			restrictions.put("start", String.valueOf(start));
56
			
57
			
57
			/** CONSTRUCTION DE LA REQUETE **/
58
			/** CONSTRUCTION DE LA REQUETE **/
58
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
59
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
59
 
60
 
60
    		/** ENVOI DE LA REQUETE **/
61
    		/** ENVOI DE LA REQUETE **/
61
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
62
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
62
    		{
63
    		{
63
    			/** RECEPTION DE LA REPONSE **/
64
    			/** RECEPTION DE LA REPONSE **/
64
    			public void surReponse(JSONValue responseValue)
65
    			public void surReponse(JSONValue responseValue)
65
    			{
66
    			{
66
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
67
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
67
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
68
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
-
 
69
    				
-
 
70
					if (seqId != null)	{
-
 
71
						if (Mediateur.DEBUG) System.out.println("<-- PersonneAsyncDao > Liste paginée, retour au sequenceur");
-
 
72
						Reponse reponseRequete = new Reponse(responseValue, seqId);
-
 
73
						vueARafraichir.rafraichir(reponseRequete);
-
 
74
					}
-
 
75
					else	{
-
 
76
						if (Mediateur.DEBUG) System.out.println("<-- PersonneAsyncDao > Liste paginée, retour à "+vueARafraichir.getClass().toString());
68
    				vueARafraichir.rafraichir(responseValue);
77
						vueARafraichir.rafraichir(responseValue);
-
 
78
					}
69
    			}
79
    			}
70
    		});
80
    		});
71
		}
81
		}
72
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
82
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
73
		else {
83
		else {
74
			
84
			
75
			/** DEFINITION DU TUPLE DE DEPART **/
85
			/** DEFINITION DU TUPLE DE DEPART **/
76
			restrictions.put("start", String.valueOf(start*nbElements));
86
			restrictions.put("start", String.valueOf(start*nbElements));
77
			
87
			
78
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
88
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
79
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
89
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
80
				@Override
90
				@Override
81
				public void surReponse(JSONValue responseValue) {
91
				public void surReponse(JSONValue responseValue) {
82
					
92
					
83
					if (responseValue != null) {
93
					if (responseValue != null) {
84
						JSONObject reponseObject = responseValue.isObject();
94
						JSONObject reponseObject = responseValue.isObject();
85
						
95
						
86
						if (reponseObject.get("personnes").isArray() != null) {
96
						if (reponseObject.get("personnes").isArray() != null) {
87
							JSONArray reponse = responseValue.isArray();
97
							JSONArray reponse = responseValue.isArray();
88
							
98
							
89
							// Transformation du tableau JSON réponse en ListePersonne
99
							// Transformation du tableau JSON réponse en ListePersonne
90
							Information info = new Information("liste_personne");
100
							Information info = new Information("liste_personne");
91
							PersonneListe personnes;
101
							PersonneListe personnes;
92
							personnes = new PersonneListe(reponseObject.get("personnes").isArray(), reponseObject.get("nbElements").isNumber(), vueARafraichir);
102
							personnes = new PersonneListe(reponseObject.get("personnes").isArray(), reponseObject.get("nbElements").isNumber(), vueARafraichir);
93
							personnes.setTaillePage(nbElements);
103
							personnes.setTaillePage(nbElements);
94
							personnes.setPageCourante(start);							
104
							personnes.setPageCourante(start);							
95
							info.setDonnee(0, personnes);
105
							info.setDonnee(0, personnes);
96
							
106
							
97
							// et on met à jour le demandeur des données
107
							// et on met à jour le demandeur des données
98
							if (seqId != null)	{
108
							if (seqId != null)	{
-
 
109
								if (Mediateur.DEBUG) System.out.println("<-- PersonneAsyncDao > Liste non paginée, retour au sequenceur");
99
								Reponse reponseRequete = new Reponse(info, seqId);
110
								Reponse reponseRequete = new Reponse(info, seqId);
100
								vueARafraichir.rafraichir(reponseRequete);
111
								vueARafraichir.rafraichir(reponseRequete);
101
							}
112
							}
102
							else	{
113
							else	{
-
 
114
								if (Mediateur.DEBUG) System.out.println("<-- PersonneAsyncDao > Liste non paginée, retour à "+vueARafraichir.getClass().toString());
103
								vueARafraichir.rafraichir(info);
115
								vueARafraichir.rafraichir(info);
104
							}
116
							}
105
						}
117
						}
106
					} else {
118
					} else {
107
						GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un tableau JSON et vaut : "+responseValue.toString(), null);
119
						GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un tableau JSON et vaut : "+responseValue.toString(), null);
108
					}
120
					}
109
				}
121
				}
110
			});	
122
			});	
111
		}
123
		}
112
	}
124
	}
113
	
125
	
114
	public void ajouter(Personne personne) {		
126
	public void ajouter(Personne personne) {		
115
		String postDonneesEncodees = personne.obtenirChainePOST();
127
		String postDonneesEncodees = personne.obtenirChainePOST();
116
		postDonneesEncodees += "&cmhl_ce_modifier_par=" + utilisateurId;		
128
		postDonneesEncodees += "&cmhl_ce_modifier_par=" + utilisateurId;		
117
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);	
129
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);	
118
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
130
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
119
			@Override
131
			@Override
120
			public void surReponse(JSONValue responseValue) {
132
			public void surReponse(JSONValue responseValue) {
121
				if (responseValue.isString() != null) {
133
				if (responseValue.isString() != null) {
122
					Information info = new Information("ajout_personne");
134
					Information info = new Information("ajout_personne");
123
					String structureIdOuMessage = responseValue.isString().stringValue();
135
					String structureIdOuMessage = responseValue.isString().stringValue();
124
					if (structureIdOuMessage.matches("^[0-9]+$")) {
136
					if (structureIdOuMessage.matches("^[0-9]+$")) {
125
						info.setDonnee(structureIdOuMessage);
137
						info.setDonnee(structureIdOuMessage);
126
					} else {
138
					} else {
127
						info.setMessage(structureIdOuMessage);
139
						info.setMessage(structureIdOuMessage);
128
					}
140
					}
129
					vueARafraichir.rafraichir(info);
141
					vueARafraichir.rafraichir(info);
130
				} else {
142
				} else {
131
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
143
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
132
				}
144
				}
133
			}
145
			}
134
		});		
146
		});		
135
	}
147
	}
136
	
148
	
137
	public void modifier(Personne personne) {
149
	public void modifier(Personne personne) {
138
		String postDonneesEncodees = personne.obtenirChainePOST();
150
		String postDonneesEncodees = personne.obtenirChainePOST();
139
		postDonneesEncodees += "&cmhl_ce_modifier_par=" + utilisateurId;
151
		postDonneesEncodees += "&cmhl_ce_modifier_par=" + utilisateurId;
140
		GWT.log(postDonneesEncodees, null);
152
		GWT.log(postDonneesEncodees, null);
141
		String[] parametres = {personne.getId()};
153
		String[] parametres = {personne.getId()};
142
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
154
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
143
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
155
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
144
			@Override
156
			@Override
145
			public void surReponse(JSONValue responseValue) {
157
			public void surReponse(JSONValue responseValue) {
146
				// Si la requête est un succès, reception d'une chaine
158
				// Si la requête est un succès, reception d'une chaine
147
				if (responseValue.isString() != null) {
159
				if (responseValue.isString() != null) {
148
					Information info = new Information("modification_personne");
160
					Information info = new Information("modification_personne");
149
					info.setMessage(responseValue.isString().stringValue());
161
					info.setMessage(responseValue.isString().stringValue());
150
					vueARafraichir.rafraichir(info);
162
					vueARafraichir.rafraichir(info);
151
				} else {
163
				} else {
152
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
164
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
153
				}
165
				}
154
			}
166
			}
155
		});
167
		});
156
	}
168
	}
157
 
169
 
158
	public void supprimer(String personnesId) {		
170
	public void supprimer(String personnesId) {		
159
		String[] parametres = {utilisateurId, personnesId};
171
		String[] parametres = {utilisateurId, personnesId};
160
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
172
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
161
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
173
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
162
			@Override
174
			@Override
163
			public void surReponse(JSONValue responseValue) {
175
			public void surReponse(JSONValue responseValue) {
164
				if (responseValue.isString() != null) {
176
				if (responseValue.isString() != null) {
165
					Information info = new Information("suppression_personne");
177
					Information info = new Information("suppression_personne");
166
					info.setMessage(responseValue.isString().stringValue());
178
					info.setMessage(responseValue.isString().stringValue());
167
					vueARafraichir.rafraichir(info);
179
					vueARafraichir.rafraichir(info);
168
				} else {
180
				} else {
169
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
181
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
170
				}
182
				}
171
			}
183
			}
172
		});
184
		});
173
	}
185
	}
174
	
186
	
175
}
187
}