Subversion Repositories eFlore/Applications.coel

Rev

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

Rev Author Line No. Line
985 jpm 1
package org.tela_botanica.client.modeles.commentaire;
2
 
1049 gduche 3
import java.util.HashMap;
4
 
985 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;
10
import org.tela_botanica.client.modeles.Information;
1367 cyprien 11
import org.tela_botanica.client.synchronisation.Reponse;
985 jpm 12
import org.tela_botanica.client.util.UtilDAO;
13
 
14
import com.extjs.gxt.ui.client.Registry;
15
import com.google.gwt.core.client.GWT;
16
import com.google.gwt.json.client.JSONArray;
17
import com.google.gwt.json.client.JSONObject;
18
import com.google.gwt.json.client.JSONValue;
19
 
20
public class CommentaireAsyncDao {
21
	private static final String SERVICE_NOM = "CoelCommentaire";
22
 
23
	private String utilisateurId = null;
24
	private Rafraichissable vueARafraichir = null;
25
 
26
	public CommentaireAsyncDao(Rafraichissable vueARafraichirCourrante) {
1367 cyprien 27
		if (Mediateur.DEBUG) System.out.println("|| CommentaireAsyncDao > vueARafraichir = "+vueARafraichirCourrante.getClass().toString());
985 jpm 28
		vueARafraichir = vueARafraichirCourrante ;
29
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
30
	}
31
 
1513 jpm 32
 
33
	/**
34
	 *
35
	 * @param paginationProgressive : définit le mode de consultation de la base de données
36
	 * 			- True :	la consultation des données est progressive, ce qui signifie que la liste est chargée (paginée) au
37
	 * 						fur et à mesure de la consultation des données par l'utilisateur.
38
	 * 			- False :	la consultation des données est classique : un seul appel à la base de données est effectué, le retour
39
	 * 						est renvoyé à l'appelant
40
	 * 			// FIXME : si la taille de la liste est supérieure à la limite du JREST (150), ce deuxieme mode ne fonctionne pas
41
	 */
42
	public void selectionner(final boolean paginationProgressive, final String commentaireId, final String projetId, final String titre, final int start, final int nbElements, final Integer seqId) {
43
 
44
		// Ajout des paramètres et données à selectionner dans l'URL
45
		String nom = (titre == null) ? "%" : titre+"%";
46
		String[] parametres = {projetId, commentaireId, nom};
1049 gduche 47
 
48
		HashMap<String, String> restrictions = new HashMap<String, String>();
1513 jpm 49
 
1049 gduche 50
		if (nbElements != -1)	{
51
			restrictions.put("limit", String.valueOf(nbElements));
52
		}
1513 jpm 53
		restrictions.put("orderby", "ccm_titre ASC");
1049 gduche 54
 
1513 jpm 55
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
56
		if (paginationProgressive) {
57
 
58
			/** DEFINITION DU TUPLE DE DEPART **/
59
			restrictions.put("start", String.valueOf(start));
60
 
61
			/** CONSTRUCTION DE LA REQUETE **/
62
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
63
 
64
    		/** ENVOI DE LA REQUETE **/
65
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
66
    		{
67
    			/** RECEPTION DE LA REPONSE **/
68
    			public void surReponse(JSONValue responseValue)
69
    			{
70
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
71
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
72
 
73
					if (seqId != null)	{
74
						if (Mediateur.DEBUG) System.out.println("<-- CommentairesASyncDao > Liste paginée, retour au sequenceur");
75
						Reponse reponseRequete = new Reponse(responseValue, seqId);
76
						vueARafraichir.rafraichir(reponseRequete);
77
					}
78
					else	{
79
						if (Mediateur.DEBUG) System.out.println("<-- CommentairesASyncDao > Liste paginée, retour à "+vueARafraichir.getClass().toString());
80
						vueARafraichir.rafraichir(responseValue);
81
					}
82
    			}
83
    		});
84
		}
85
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
86
		else {
87
 
88
			/** DEFINITION DU TUPLE DE DEPART **/
89
			restrictions.put("start", String.valueOf(start*nbElements));
90
 
91
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
92
 
93
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
94
				@Override
95
				public void surReponse(JSONValue responseValue) {
96
					if (responseValue != null) {
97
 
98
						JSONObject responseObject = responseValue.isObject();
99
 
100
						if (responseObject != null) {
101
							// Si la réponse est un tableau, alors c'est une liste de commentaires qui a été retournée
102
							if (responseObject.get("commentaires").isArray() != null) {
103
 
104
								final JSONArray reponse = responseObject.get("commentaires").isArray();
105
 
106
								CommentaireListe commentaires = new CommentaireListe(reponse, responseObject.get("nbElements").isNumber(), vueARafraichir);
107
 
108
								commentaires.setTaillePage(nbElements);
109
								commentaires.setPageCourante(start);
110
 
111
								vueARafraichir.rafraichir(commentaires);
112
 
113
							// Si la réponse est un objet, alors c'est un unique commentaire qui a été retournée
114
							} else if (responseObject.get("commentaires").isObject() != null) {
115
 
116
								final JSONObject reponse = responseObject.get("commentaires").isObject();
117
								Commentaire commentaire = new Commentaire(reponse);
118
 
119
								// et on met à jour le demandeur des données
120
								if (seqId != null)	{
121
									if (Mediateur.DEBUG) System.out.println("<-- CommentairesASyncDao > Liste non paginée, retour au sequenceur");
122
									Reponse reponseRequete = new Reponse(commentaire, seqId);
123
									vueARafraichir.rafraichir(reponseRequete);
124
								}
125
								else	{
126
									if (Mediateur.DEBUG) System.out.println("<-- CommentairesASyncDao > Liste non paginée, retour à "+vueARafraichir.getClass().toString());
127
									vueARafraichir.rafraichir(commentaire);
128
								}
129
							}
130
						} else {
131
							GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un objet ou un talbeau JSON et vaut : "+responseValue.toString(), null);
1367 cyprien 132
						}
985 jpm 133
					} else {
1513 jpm 134
						// Dans le cas, où nous demandons toutes les institutions et qu'il n'y en a pas, nous retournons un objet vide
135
						if (commentaireId == null) {
136
							CommentaireListe commentaires = new CommentaireListe(0);
137
							if (seqId != null)	{
138
								Reponse reponseRequete = new Reponse(commentaires, seqId);
139
								vueARafraichir.rafraichir(reponseRequete);
140
							}
141
							else {
142
								vueARafraichir.rafraichir(commentaires);
143
							}
1367 cyprien 144
						}
985 jpm 145
					}
146
				}
1513 jpm 147
			});
148
		}
985 jpm 149
	}
150
 
151
	public void ajouter(Commentaire commentaire) {
152
		String postDonneesEncodees = commentaire.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
153
 
154
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
155
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
156
			@Override
157
			public void surReponse(JSONValue reponseValeur) {
158
				traiterReponse(reponseValeur, "ajout_commentaire");
159
			}
160
		}) ;
161
	}
162
 
163
	public void modifier(Commentaire commentaire) {
164
		String[] parametres = {commentaire.getId()};
165
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
166
 
167
		String postDonneesEncodees = commentaire.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
168
 
169
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
170
			@Override
171
			public void surReponse(JSONValue reponseValeur) {
172
				traiterReponse(reponseValeur, "modif_commentaire");
173
			}
174
		});
175
	}
176
 
177
	public void supprimer(String commentairesId) {
178
		String[] parametres = {utilisateurId, commentairesId};
179
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
180
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
181
			@Override
182
			public void surReponse(JSONValue reponseValeur) {
183
				traiterReponse(reponseValeur, "suppression_commentaire");
184
			}
185
		});
186
	}
187
 
188
	private void traiterReponse(JSONValue reponseValeur, String type) {
189
		Information info = new Information(type);
190
		// Si la requête est un succès, réception d'une chaîne
191
		if (reponseValeur.isString() != null) {
192
			String idOuMessage = reponseValeur.isString().stringValue();
193
			if (idOuMessage.matches("^[0-9]+$")) {
194
				info.setDonnee(idOuMessage);
195
			} else {
196
				info.setMessage(idOuMessage);
197
			}
198
		} else {
199
			info.setDeboguage("La réponse n'est pas une chaine JSON.");
200
		}
201
		vueARafraichir.rafraichir(info);
202
	}
203
 
204
}