Subversion Repositories eFlore/Applications.coel

Rev

Go to most recent revision | Details | 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;
1046 gduche 11
import org.tela_botanica.client.modeles.structure.StructureListe;
1319 gduche 12
import org.tela_botanica.client.synchronisation.Reponse;
1235 cyprien 13
import org.tela_botanica.client.util.Debug;
751 jpm 14
import org.tela_botanica.client.util.UtilDAO;
106 aurelien 15
 
764 jpm 16
import com.extjs.gxt.ui.client.Registry;
238 aurelien 17
import com.google.gwt.core.client.GWT;
106 aurelien 18
import com.google.gwt.json.client.JSONArray;
238 aurelien 19
import com.google.gwt.json.client.JSONObject;
106 aurelien 20
import com.google.gwt.json.client.JSONValue;
21
 
268 jp_milcent 22
public class PublicationAsyncDao {
23
	private static final String SERVICE_NOM = "CoelPublication";
764 jpm 24
 
25
	private String utilisateurId = null;
707 jp_milcent 26
	private Rafraichissable vueARafraichir = null;
106 aurelien 27
 
707 jp_milcent 28
	public PublicationAsyncDao(Rafraichissable vueARafraichirCourrante) {
1367 cyprien 29
		if (Mediateur.DEBUG) System.out.println("|| PublicationAsyncDao > vueARafraichir = "+vueARafraichirCourrante.getClass().toString());
707 jp_milcent 30
		vueARafraichir = vueARafraichirCourrante ;
764 jpm 31
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
106 aurelien 32
	}
33
 
1319 gduche 34
	public void selectionner(final String publicationId, String projetId, String nomComplet, final int nbElements, final int pageCourante, final Integer seqId) {
751 jpm 35
		String[] parametres = {projetId, publicationId, nomComplet};
106 aurelien 36
 
1046 gduche 37
		HashMap<String, String> restrictions = new HashMap<String, String>();
1051 gduche 38
		restrictions.put("start", String.valueOf(pageCourante*nbElements));
1046 gduche 39
		if (nbElements != -1)	{
40
			restrictions.put("limit", String.valueOf(nbElements));
41
		}
42
 
43
		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
707 jp_milcent 44
		rb.envoyerRequete(null, new JsonRestRequestCallback() {
45
			@Override
46
			public void surReponse(JSONValue responseValue) {
47
				if (responseValue != null) {
748 jpm 48
					// Si la requête est un succès, réception d'un objet ou d'un tableau
1046 gduche 49
					JSONArray responseArray = responseValue.isArray();
50
					if (responseArray.get(1).isObject() != null) {
1047 gduche 51
						final JSONObject reponse = responseArray.get(1).isObject();
707 jp_milcent 52
						// Transformation du tableau JSON réponse en ListeInstitution
53
						Publication publication = new Publication(reponse);
54
						// et on met à jour le demandeur des données
1319 gduche 55
						if (seqId!=null)	{
56
							Reponse reponseRequete = new Reponse(publication, seqId);
57
							vueARafraichir.rafraichir(reponseRequete);
58
						} else {
59
							vueARafraichir.rafraichir(publication);
60
						}
61
 
1046 gduche 62
					} else if (responseArray.get(1).isArray() != null) {
707 jp_milcent 63
						final JSONArray reponse = responseValue.isArray();
1047 gduche 64
						PublicationListe publications;
65
						if (reponse.get(1).isObject() != null)	{
66
							publications = new PublicationListe(reponse.get(1).isArray());
67
						} else	{
68
							publications = new PublicationListe(reponse.get(1).isArray(), reponse.get(0).isNumber(), vueARafraichir);
69
						}
1046 gduche 70
 
71
						publications.setTaillePage(nbElements);
72
						publications.setPageCourante(pageCourante);
73
 
1319 gduche 74
						if (seqId!=null)	{
75
							Reponse reponseRequete = new Reponse(publications, seqId);
76
							vueARafraichir.rafraichir(reponseRequete);
77
						} else {
78
							vueARafraichir.rafraichir(publications);
79
						}
80
 
707 jp_milcent 81
					} else {
723 jp_milcent 82
						GWT.log("La réponse n'est pas un objet ou un talbeau JSON et vaut : "+responseValue.toString(), null);
106 aurelien 83
					}
707 jp_milcent 84
				} else {
85
					// Dans le cas, où nous demandons toutes les publication et qu'il n'y en a pas, nous retournons un objet vide
86
					if (publicationId == null) {
87
						PublicationListe publications = new PublicationListe(0);
711 aurelien 88
						vueARafraichir.rafraichir(publications);
106 aurelien 89
					}
90
				}
707 jp_milcent 91
			}
92
		});
106 aurelien 93
	}
756 jpm 94
 
1319 gduche 95
	public void ajouter(Publication publication, final Integer seqId) {
756 jpm 96
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
711 aurelien 97
 
756 jpm 98
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
1235 cyprien 99
 
711 aurelien 100
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
101
			@Override
714 jp_milcent 102
			public void surReponse(JSONValue reponseValeur) {
1319 gduche 103
				traiterReponse(reponseValeur, "ajout_publication", seqId);
711 aurelien 104
			}
756 jpm 105
		}) ;
230 aurelien 106
	}
756 jpm 107
 
1319 gduche 108
	public void modifier(Publication publication, final Integer seqId) {
756 jpm 109
		String[] parametres = {publication.getId()};
110
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
111
 
786 jpm 112
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
756 jpm 113
 
711 aurelien 114
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
714 jp_milcent 115
			@Override
116
			public void surReponse(JSONValue reponseValeur) {
1319 gduche 117
				traiterReponse(reponseValeur, "modif_publication",  seqId);
711 aurelien 118
			}
756 jpm 119
		});
230 aurelien 120
	}
121
 
764 jpm 122
	public void supprimer(String publicationsId) {
756 jpm 123
		String[] parametres = {utilisateurId, publicationsId};
124
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
748 jpm 125
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
711 aurelien 126
			@Override
714 jp_milcent 127
			public void surReponse(JSONValue reponseValeur) {
1319 gduche 128
				traiterReponse(reponseValeur, "suppression_publication", null);
711 aurelien 129
			}
130
		});
238 aurelien 131
	}
714 jp_milcent 132
 
1319 gduche 133
	private void traiterReponse(JSONValue reponseValeur, String type, Integer seqId) {
714 jp_milcent 134
		Information info = new Information(type);
748 jpm 135
		// Si la requête est un succès, réception d'une chaîne
714 jp_milcent 136
		if (reponseValeur.isString() != null) {
1096 jpm 137
			String idOuMessage = reponseValeur.isString().stringValue();
138
			if (idOuMessage.matches("^[0-9]+$")) {
139
				info.setDonnee(idOuMessage);
140
			} else {
141
				info.setMessage(idOuMessage);
142
			}
714 jp_milcent 143
		} else {
144
			info.setDeboguage("La réponse n'est pas une chaine JSON.");
145
		}
1319 gduche 146
 
147
		if (seqId!=null)	{
148
			Reponse retourRequete = new Reponse(info, seqId);
149
			vueARafraichir.rafraichir(retourRequete);
150
		} else {
151
			vueARafraichir.rafraichir(info);
152
		}
714 jp_milcent 153
	}
238 aurelien 154
 
106 aurelien 155
}