Subversion Repositories eFlore/Applications.coel

Rev

Rev 1470 | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

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