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>();
1369 cyprien 38
		restrictions.put("orderby", "cpu_titre");
1051 gduche 39
		restrictions.put("start", String.valueOf(pageCourante*nbElements));
1046 gduche 40
		if (nbElements != -1)	{
41
			restrictions.put("limit", String.valueOf(nbElements));
42
		}
43
 
44
		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
707 jp_milcent 45
		rb.envoyerRequete(null, new JsonRestRequestCallback() {
46
			@Override
47
			public void surReponse(JSONValue responseValue) {
48
				if (responseValue != null) {
748 jpm 49
					// Si la requête est un succès, réception d'un objet ou d'un tableau
1046 gduche 50
					JSONArray responseArray = responseValue.isArray();
51
					if (responseArray.get(1).isObject() != null) {
1047 gduche 52
						final JSONObject reponse = responseArray.get(1).isObject();
707 jp_milcent 53
						// Transformation du tableau JSON réponse en ListeInstitution
54
						Publication publication = new Publication(reponse);
55
						// et on met à jour le demandeur des données
1319 gduche 56
						if (seqId!=null)	{
57
							Reponse reponseRequete = new Reponse(publication, seqId);
58
							vueARafraichir.rafraichir(reponseRequete);
59
						} else {
60
							vueARafraichir.rafraichir(publication);
61
						}
62
 
1046 gduche 63
					} else if (responseArray.get(1).isArray() != null) {
707 jp_milcent 64
						final JSONArray reponse = responseValue.isArray();
1047 gduche 65
						PublicationListe publications;
66
						if (reponse.get(1).isObject() != null)	{
67
							publications = new PublicationListe(reponse.get(1).isArray());
68
						} else	{
69
							publications = new PublicationListe(reponse.get(1).isArray(), reponse.get(0).isNumber(), vueARafraichir);
70
						}
1046 gduche 71
 
72
						publications.setTaillePage(nbElements);
73
						publications.setPageCourante(pageCourante);
74
 
1319 gduche 75
						if (seqId!=null)	{
76
							Reponse reponseRequete = new Reponse(publications, seqId);
77
							vueARafraichir.rafraichir(reponseRequete);
78
						} else {
79
							vueARafraichir.rafraichir(publications);
80
						}
81
 
707 jp_milcent 82
					} else {
723 jp_milcent 83
						GWT.log("La réponse n'est pas un objet ou un talbeau JSON et vaut : "+responseValue.toString(), null);
106 aurelien 84
					}
707 jp_milcent 85
				} else {
86
					// Dans le cas, où nous demandons toutes les publication et qu'il n'y en a pas, nous retournons un objet vide
87
					if (publicationId == null) {
88
						PublicationListe publications = new PublicationListe(0);
711 aurelien 89
						vueARafraichir.rafraichir(publications);
106 aurelien 90
					}
91
				}
707 jp_milcent 92
			}
93
		});
106 aurelien 94
	}
756 jpm 95
 
1319 gduche 96
	public void ajouter(Publication publication, final Integer seqId) {
756 jpm 97
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
711 aurelien 98
 
756 jpm 99
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
1235 cyprien 100
 
711 aurelien 101
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
102
			@Override
714 jp_milcent 103
			public void surReponse(JSONValue reponseValeur) {
1319 gduche 104
				traiterReponse(reponseValeur, "ajout_publication", seqId);
711 aurelien 105
			}
756 jpm 106
		}) ;
230 aurelien 107
	}
756 jpm 108
 
1319 gduche 109
	public void modifier(Publication publication, final Integer seqId) {
756 jpm 110
		String[] parametres = {publication.getId()};
111
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
112
 
786 jpm 113
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
756 jpm 114
 
711 aurelien 115
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
714 jp_milcent 116
			@Override
117
			public void surReponse(JSONValue reponseValeur) {
1319 gduche 118
				traiterReponse(reponseValeur, "modif_publication",  seqId);
711 aurelien 119
			}
756 jpm 120
		});
230 aurelien 121
	}
122
 
764 jpm 123
	public void supprimer(String publicationsId) {
756 jpm 124
		String[] parametres = {utilisateurId, publicationsId};
125
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
748 jpm 126
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
711 aurelien 127
			@Override
714 jp_milcent 128
			public void surReponse(JSONValue reponseValeur) {
1319 gduche 129
				traiterReponse(reponseValeur, "suppression_publication", null);
711 aurelien 130
			}
131
		});
238 aurelien 132
	}
714 jp_milcent 133
 
1319 gduche 134
	private void traiterReponse(JSONValue reponseValeur, String type, Integer seqId) {
714 jp_milcent 135
		Information info = new Information(type);
1428 cyprien 136
 
748 jpm 137
		// Si la requête est un succès, réception d'une chaîne
714 jp_milcent 138
		if (reponseValeur.isString() != null) {
1096 jpm 139
			String idOuMessage = reponseValeur.isString().stringValue();
140
			if (idOuMessage.matches("^[0-9]+$")) {
141
				info.setDonnee(idOuMessage);
142
			} else {
143
				info.setMessage(idOuMessage);
144
			}
714 jp_milcent 145
		} else {
146
			info.setDeboguage("La réponse n'est pas une chaine JSON.");
147
		}
1319 gduche 148
 
149
		if (seqId!=null)	{
150
			Reponse retourRequete = new Reponse(info, seqId);
151
			vueARafraichir.rafraichir(retourRequete);
152
		} else {
153
			vueARafraichir.rafraichir(info);
154
		}
714 jp_milcent 155
	}
238 aurelien 156
 
106 aurelien 157
}