Subversion Repositories eFlore/Applications.coel

Rev

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