Subversion Repositories eFlore/Applications.coel

Rev

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

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