Subversion Repositories eFlore/Applications.coel

Rev

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

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