Subversion Repositories eFlore/Applications.coel

Rev

Rev 1468 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
935 jpm 1
package org.tela_botanica.client.modeles.collection;
875 jpm 2
 
1468 jpm 3
import java.util.HashMap;
4
 
875 jpm 5
import org.tela_botanica.client.Mediateur;
6
import org.tela_botanica.client.RegistreId;
7
import org.tela_botanica.client.http.JsonRestRequestBuilder;
8
import org.tela_botanica.client.http.JsonRestRequestCallback;
9
import org.tela_botanica.client.interfaces.Rafraichissable;
935 jpm 10
import org.tela_botanica.client.modeles.Information;
1367 cyprien 11
import org.tela_botanica.client.synchronisation.Reponse;
883 jpm 12
import org.tela_botanica.client.util.Debug;
875 jpm 13
import org.tela_botanica.client.util.UtilDAO;
14
 
15
import com.extjs.gxt.ui.client.Registry;
16
import com.google.gwt.core.client.GWT;
17
import com.google.gwt.http.client.URL;
18
import com.google.gwt.json.client.JSONArray;
1468 jpm 19
import com.google.gwt.json.client.JSONObject;
875 jpm 20
import com.google.gwt.json.client.JSONValue;
21
 
22
public class CollectionAPersonneAsyncDao {
23
	private static final String SERVICE_NOM = "CoelCollectionAPersonne";
24
 
25
	private String utilisateurId = null;
26
	private Rafraichissable vueARafraichir = null;
27
 
28
	public CollectionAPersonneAsyncDao(Rafraichissable vueARafraichirCourrante) {
1367 cyprien 29
		if (Mediateur.DEBUG) System.out.println("|| CollectionAPersonneAsyncDao > vueARafraichir = "+vueARafraichirCourrante.getClass().toString());
875 jpm 30
		vueARafraichir = vueARafraichirCourrante;
31
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
32
	}
33
 
1468 jpm 34
	public void selectionner(final boolean paginationProgressive, final String collectionId, final String roleId, final String recherche, final int start, final int nbElements, final Integer seqId) {
35
 
875 jpm 36
		String[] parametres = {collectionId, roleId};
37
 
1468 jpm 38
		HashMap<String, String> restrictions = new HashMap<String, String>();
39
 
40
		if (nbElements != -1)	{
41
			restrictions.put("limit", String.valueOf(nbElements));
42
		}
43
 
44
		restrictions.put("orderby", "cp_nom");
1329 cyprien 45
 
1468 jpm 46
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
47
		if (paginationProgressive) {
48
 
49
			/** DEFINITION DU TUPLE DE DEPART **/
50
			restrictions.put("start", String.valueOf(start));
51
 
52
			/** CONSTRUCTION DE LA REQUETE **/
53
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
54
 
55
    		/** ENVOI DE LA REQUETE **/
56
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
57
    		{
58
    			/** RECEPTION DE LA REPONSE **/
59
    			public void surReponse(JSONValue responseValue)
60
    			{
61
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
62
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
63
 
64
					if (seqId != null)	{
65
						if (Mediateur.DEBUG) System.out.println("<-- CollectionAPersonneAsyncDao > Liste paginée, retour au sequenceur");
66
						Reponse reponseRequete = new Reponse(responseValue, seqId);
67
						vueARafraichir.rafraichir(reponseRequete);
68
					}
69
					else	{
70
						if (Mediateur.DEBUG) System.out.println("<-- CollectionAPersonneAsyncDao > Liste paginée, retour à "+vueARafraichir.getClass().toString());
71
						vueARafraichir.rafraichir(responseValue);
72
					}
73
    			}
74
    		});
75
		}
76
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
77
		else {
78
 
79
			/** DEFINITION DU TUPLE DE DEPART **/
80
			restrictions.put("start", String.valueOf(start*nbElements));
81
 
82
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
83
 
84
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
85
				@Override
86
				public void surReponse(JSONValue responseValue) {
87
					if (responseValue != null) {
88
 
89
						JSONObject responseObject = responseValue.isObject();
90
						Information info = new Information("liste_collection_a_personne");
91
 
92
						if (responseObject != null) {
93
							// Si la réponse est un tableau, alors c'est une liste de collections qui a été retournée
94
							if (responseObject.get("collectionsAPersonne").isArray() != null) {
95
								final JSONArray reponse = responseObject.get("collectionsAPersonne").isArray();
96
								// Transformation du tableau JSON réponse en ListeInstitution
97
								CollectionAPersonneListe personnes = new CollectionAPersonneListe(reponse);
98
								info.setDonnee(0, personnes);
99
								// et on met à jour le demandeur des données
100
								if (seqId != null)	{
101
									Reponse reponseRequete = new Reponse(info, seqId);
102
									vueARafraichir.rafraichir(reponseRequete);
103
								}
104
								else	{
105
									vueARafraichir.rafraichir(info);
106
								}
107
							// Si la réponse est un objet, alors c'est une unique collection qui a été retournée
108
							} else if (responseObject.get("collectionsAPersonne").isObject() != null) {
109
								GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un tableau JSON et vaut : "+responseValue.toString(), null);
110
							}
1367 cyprien 111
						}
1468 jpm 112
					} else {
113
						// Dans le cas, où nous demandons toutes les institutions et qu'il n'y en a pas, nous retournons un objet vide
114
						if (collectionId == null) {
115
							// Dans le cas, où nous demandons toutes les relations Collection à Personne et qu'il n'y en a pas, nous retournons un message d'information
116
							Information info = new Information("liste_collection_a_personne");
117
							info.setMessage("Aucune relations entre la collection et les personnes");
1367 cyprien 118
							vueARafraichir.rafraichir(info);
119
						}
875 jpm 120
					}
121
				}
1468 jpm 122
			});
123
		}
875 jpm 124
	}
125
 
1513 jpm 126
	public void ajouter(String collectionId, CollectionAPersonne personnes) {
875 jpm 127
		String postDonneesEncodees = construirePost(collectionId, personnes);
128
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
129
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
130
			@Override
131
			public void surReponse(JSONValue responseValue) {
132
				// Si la requête est un succès, reception d'une chaine
133
				if (responseValue.isString() != null) {
134
					Information info = new Information("ajout_collection_a_personne");
135
					info.setMessage(responseValue.isString().stringValue());
136
					vueARafraichir.rafraichir(info);
137
				} else {
138
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
139
				}
140
			}
141
		});
142
	}
143
 
144
	public void modifier(CollectionAPersonne personnes) {
145
		String[] parametres = {personnes.getIdCollection(), personnes.getIdPersonne(), personnes.getIdRole()};
146
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
147
 
148
		String postDonneesEncodees = construirePost(personnes.getIdCollection(), personnes);
1329 cyprien 149
 
875 jpm 150
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
151
			@Override
152
			public void surReponse(JSONValue responseValue) {
153
				Information info = new Information("modif_collection_a_personne");
154
				// Si la requête est un succès, reception d'une chaine
155
				if (responseValue.isString() != null) {
156
					info.setMessage(responseValue.isString().stringValue());
157
					vueARafraichir.rafraichir(info);
158
				} else {
159
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
160
				}
161
			}
162
		});
163
	}
164
 
165
	public void supprimer(String idCollectionAPersonne) {
166
		String[] parametres = {utilisateurId, idCollectionAPersonne};
167
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
168
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
169
			@Override
170
			public void surReponse(JSONValue responseValue) {
171
				if (responseValue.isString() != null) {
172
					Information info = new Information("suppression_collection_a_personne");
173
					info.setMessage(responseValue.isString().stringValue());
174
					vueARafraichir.rafraichir(info);
175
				} else {
176
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
177
				}
178
			}
179
		});
180
	}
181
 
182
	private String construirePost(String collectionId, CollectionAPersonne personne) {
183
		String postDonnees = "cmhl_ce_modifier_par=" + URL.encodeComponent(utilisateurId) +
184
			"&ccap_id_collection=" + URL.encodeComponent(collectionId) +
185
			"&ccap_id_personne=" + URL.encodeComponent(personne.getIdPersonne()) +
186
			"&ccap_id_role=" + URL.encodeComponent(personne.getIdRole());
187
		return postDonnees;
188
	}
189
}