Subversion Repositories eFlore/Applications.coel

Rev

Rev 1513 | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1513 Rev 1800
1 
package org.tela_botanica.client.modeles.collection;
 1 
package org.tela_botanica.client.modeles.collection;
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.synchronisation.Reponse;
 11 
import org.tela_botanica.client.synchronisation.Reponse;
12 
import org.tela_botanica.client.util.Debug;
 12 
import org.tela_botanica.client.util.Debug;
13 
import org.tela_botanica.client.util.UtilDAO;
 13 
import org.tela_botanica.client.util.UtilDAO;
14 
 
 14 
 
15 
import com.extjs.gxt.ui.client.Registry;
 15 
import com.extjs.gxt.ui.client.Registry;
16 
import com.google.gwt.core.client.GWT;
 16 
import com.google.gwt.core.client.GWT;
17 
import com.google.gwt.http.client.URL;
 17 
import com.google.gwt.http.client.URL;
18 
import com.google.gwt.json.client.JSONArray;
 18 
import com.google.gwt.json.client.JSONArray;
19 
import com.google.gwt.json.client.JSONObject;
 19 
import com.google.gwt.json.client.JSONObject;
20 
import com.google.gwt.json.client.JSONValue;
 20 
import com.google.gwt.json.client.JSONValue;
21 
 
 21 
 
22 
public class CollectionAPublicationAsyncDao {
 22 
public class CollectionAPublicationAsyncDao {
23 
	private static final String SERVICE_NOM = "CoelCollectionAPublication";
 23 
	private static final String SERVICE_NOM = "CoelCollectionAPublication";
24 
 
 24 
 
25 
	private String utilisateurId = null;
 25 
	private String utilisateurId = null;
26 
	private Rafraichissable vueARafraichir = null;
 26 
	private Rafraichissable vueARafraichir = null;
27 
 
 27 
 
28 
	public CollectionAPublicationAsyncDao(Rafraichissable vueARafraichirCourrante) {
 28 
	public CollectionAPublicationAsyncDao(Rafraichissable vueARafraichirCourrante) {
29 
		if (Mediateur.DEBUG) System.out.println("|| CollectionAPublicationAsyncDao > vueARafraichir = "+vueARafraichirCourrante.getClass().toString());
 29 
		if (Mediateur.DEBUG) System.out.println("|| CollectionAPublicationAsyncDao > vueARafraichir = "+vueARafraichirCourrante.getClass().toString());
30 
		vueARafraichir = vueARafraichirCourrante;
 30 
		vueARafraichir = vueARafraichirCourrante;
31 
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
 31 
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
32 
	}
 32 
	}
33
33
34 
	public void selectionner(final boolean paginationProgressive, final String collectionId, final String recherche, final int start, final int nbElements, final Integer seqId) {
 34 
	public void selectionner(final boolean paginationProgressive, final String collectionId, final String recherche, final int start, final int nbElements, final Integer seqId) {
35 
 
 35 
 
36 
		String[] parametres = {collectionId};
 36 
		String[] parametres = {collectionId};
37
37
38 
		HashMap<String, String> restrictions = new HashMap<String, String>();
 38 
		HashMap<String, String> restrictions = new HashMap<String, String>();
39
39
40 
		if (nbElements != -1)	{
 40 
		if (nbElements != -1)	{
41 
			restrictions.put("limit", String.valueOf(nbElements));
 41 
			restrictions.put("limit", String.valueOf(nbElements));
42 
		}
 42 
		}
43
43
44 
		restrictions.put("orderby", "cpu_fmt_auteur");
 44 
		restrictions.put("orderby", "cpu_fmt_auteur");
45 
 
 45 
 
46 
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
 46 
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
47 
		if (paginationProgressive) {
 47 
		if (paginationProgressive) {
48 
 
 48 
 
49 
			/** DEFINITION DU TUPLE DE DEPART **/
 49 
			/** DEFINITION DU TUPLE DE DEPART **/
50 
			restrictions.put("start", String.valueOf(start));
 50 
			restrictions.put("start", String.valueOf(start));
51
51
52 
			/** CONSTRUCTION DE LA REQUETE **/
 52 
			/** CONSTRUCTION DE LA REQUETE **/
53 
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
 53 
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
54
54
55 
    		/** ENVOI DE LA REQUETE **/
 55 
    		/** ENVOI DE LA REQUETE **/
56 
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
 56 
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
57 
    		{
 57 
    		{
58 
    			/** RECEPTION DE LA REPONSE **/
 58 
    			/** RECEPTION DE LA REPONSE **/
59 
    			public void surReponse(JSONValue responseValue)
 59 
    			public void surReponse(JSONValue responseValue)
60 
    			{
60 
    			{
61 
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
 61 
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
62 
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
 62 
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
63
63
64 
					if (seqId != null)	{
 64 
					if (seqId != null)	{
65 
						if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste paginée, retour au sequenceur");
 65 
						if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste paginée, retour au sequenceur");
66 
						Reponse reponseRequete = new Reponse(responseValue, seqId);
 66 
						Reponse reponseRequete = new Reponse(responseValue, seqId);
67 
						vueARafraichir.rafraichir(reponseRequete);
 67 
						vueARafraichir.rafraichir(reponseRequete);
68 
					}
 68 
					}
69 
					else	{
 69 
					else	{
70 
						if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste paginée, retour à "+vueARafraichir.getClass().toString());
 70 
						if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste paginée, retour à "+vueARafraichir.getClass().toString());
71 
						vueARafraichir.rafraichir(responseValue);
 71 
						vueARafraichir.rafraichir(responseValue);
72 
					}
 72 
					}
73 
    			}
 73 
    			}
74 
    		});
 74 
    		});
75 
		}
 75 
		}
76 
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
 76 
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
77 
		else {
 77 
		else {
78
78
79 
			/** DEFINITION DU TUPLE DE DEPART **/
 79 
			/** DEFINITION DU TUPLE DE DEPART **/
80 
			restrictions.put("start", String.valueOf(start*nbElements));
 80 
			restrictions.put("start", String.valueOf(start*nbElements));
81
81
82 
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
 82 
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
83
83
84 
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
 84 
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
85 
				@Override
 85 
				@Override
86 
				public void surReponse(JSONValue responseValue) {
 86 
				public void surReponse(JSONValue responseValue) {
87
87
88 
					Information info = new Information("liste_collection_a_publication");
 88 
					Information info = new Information("liste_collection_a_publication");
89 
 
 89 
 
90 
					if (responseValue != null) {
 90 
					if (responseValue != null) {
91 
 
 91 
 
92 
						JSONObject responseObject = responseValue.isObject();
 92 
						JSONObject responseObject = responseValue.isObject();
93 
						if (responseObject != null) {
 93 
						if (responseObject != null) {
94 
							// Si la réponse est un tableau, alors c'est une liste de collections qui a été retournée
 94 
							// Si la réponse est un tableau, alors c'est une liste de collections qui a été retournée
95 
							if (responseObject.get("collectionsAPublication").isArray() != null) {
 95 
							if (responseObject.get("collectionsAPublication").isArray() != null) {
96 
 
 96 
 
97 
								final JSONArray reponse = responseObject.get("collectionsAPublication").isArray();
 97 
								final JSONArray reponse = responseObject.get("collectionsAPublication").isArray();
98
98
99 
								// Transformation du tableau JSON réponse en ListeInstitution
 99 
								// Transformation du tableau JSON réponse en ListeInstitution
100 
								CollectionAPublicationListe publications = new CollectionAPublicationListe(reponse);
 100 
								CollectionAPublicationListe publications = new CollectionAPublicationListe(reponse);
101 
								info.setDonnee(0, publications);
 101 
								info.setDonnee(0, publications);
102
102
103 
								// et on met à jour le demandeur des données
 103 
								// et on met à jour le demandeur des données
104 
								if (seqId != null)	{
 104 
								if (seqId != null)	{
105 
									if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste non paginée, retour au sequenceur");
 105 
									if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste non paginée, retour au sequenceur");
106 
									Reponse reponseRequete = new Reponse(info, seqId);
 106 
									Reponse reponseRequete = new Reponse(info, seqId);
107 
									vueARafraichir.rafraichir(reponseRequete);
 107 
									vueARafraichir.rafraichir(reponseRequete);
108 
								}
 108 
								}
109 
								else	{
 109 
								else	{
110 
									if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste non paginée, retour au sequenceur");
 110 
									if (Mediateur.DEBUG) System.out.println("<-- CollectionAPublicationAsyncDao > Liste non paginée, retour au sequenceur");
111 
									vueARafraichir.rafraichir(info);
 111 
									vueARafraichir.rafraichir(info);
112 
								}
 112 
								}
113 
							// Si la réponse est un objet, alors c'est une unique collection qui a été retournée
 113 
							// Si la réponse est un objet, alors c'est une unique collection qui a été retournée
114 
							} else if (responseObject.get("collectionsAPublication").isObject() != null) {
 114 
							} else if (responseObject.get("collectionsAPublication").isObject() != null) {
115 
								GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un tableau JSON et vaut : "+responseValue.toString(), null);
 115 
								GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un tableau JSON et vaut : "+responseValue.toString(), null);
116 
							}
 116 
							}
117 
						}
 117 
						}
118 
					} else {
 118 
					} else {
119 
						// Dans le cas, où nous demandons toutes les institutions et qu'il n'y en a pas, nous retournons un objet vide
 119 
						// Dans le cas, où nous demandons toutes les institutions et qu'il n'y en a pas, nous retournons un objet vide
120 
						if (collectionId == null) {
 120 
						if (collectionId == null) {
121 
							info.setMessage("Aucune relations entre la collection et les publications");
 121 
							info.setMessage("Aucune relations entre la collection et les publications");
122 
							vueARafraichir.rafraichir(info);
 122 
							vueARafraichir.rafraichir(info);
123 
						}
 123 
						}
124 
					}
 124 
					}
125 
				}
 125 
				}
126 
			});
 126 
			});
127 
		}
 127 
		}
128 
	}
128 
	}
129 
 
 129 
 
130 
	public void ajouter(String collectionId, CollectionAPublication publications) {
 130 
	public void ajouter(String collectionId, CollectionAPublication publications) {
131 
		String postDonneesEncodees = construirePost(collectionId, publications);
 131 
		String postDonneesEncodees = construirePost(collectionId, publications);
132 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
132 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
133 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
 133 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
134 
			@Override
 134 
			@Override
135 
			public void surReponse(JSONValue responseValue) {
135 
			public void surReponse(JSONValue responseValue) {
136 
				// Si la requête est un succès, reception d'une chaine
 136 
				// Si la requête est un succès, reception d'une chaine
137 
				if (responseValue.isString() != null) {
 137 
				if (responseValue.isString() != null) {
138 
					Information info = new Information("ajout_collection_a_publication");
 138 
					Information info = new Information("ajout_collection_a_publication");
139 
					info.setMessage(responseValue.isString().stringValue());
 139 
					info.setMessage(responseValue.isString().stringValue());
140 
					vueARafraichir.rafraichir(info);
 140 
					vueARafraichir.rafraichir(info);
141 
				} else {
 141 
				} else {
142 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
 142 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
143 
				}
 143 
				}
144 
			}
 144 
			}
145 
		});
 145 
		});
146 
	}
 146 
	}
147
147
148 
	public void modifier(CollectionAPublication publications) {
 148 
	public void modifier(CollectionAPublication publications) {
149 
		String[] parametres = {publications.getIdCollection(), publications.getIdPublication()};
 149 
		String[] parametres = {publications.getIdCollection(), publications.getIdPublication()};
150 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
 150 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
151
151
152 
		String postDonneesEncodees = construirePost(publications.getIdCollection(), publications);
 152 
		String postDonneesEncodees = construirePost(publications.getIdCollection(), publications);
153
153
154 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
 154 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
155 
			@Override
 155 
			@Override
156 
			public void surReponse(JSONValue responseValue) {
 156 
			public void surReponse(JSONValue responseValue) {
157 
				Information info = new Information("modif_collection_a_publication");
 157 
				Information info = new Information("modif_collection_a_publication");
158 
				// Si la requête est un succès, reception d'une chaine
 158 
				// Si la requête est un succès, reception d'une chaine
159 
				if (responseValue.isString() != null) {
 159 
				if (responseValue.isString() != null) {
160 
					info.setMessage(responseValue.isString().stringValue());
 160 
					info.setMessage(responseValue.isString().stringValue());
161 
					vueARafraichir.rafraichir(info);
 161 
					vueARafraichir.rafraichir(info);
162 
				} else {
 162 
				} else {
163 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
 163 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
164 
				}
 164 
				}
165 
			}
 165 
			}
166 
		});
 166 
		});
167 
	}
 167 
	}
168
168
169 
	public void supprimer(String idCollectionAPublication) {
 169 
	public void supprimer(String idCollectionAPublication) {
170 
		String[] parametres = {utilisateurId, idCollectionAPublication};
 170 
		String[] parametres = {utilisateurId, idCollectionAPublication};
171 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
 171 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
172 
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
 172 
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
173 
			@Override
 173 
			@Override
174 
			public void surReponse(JSONValue responseValue) {
 174 
			public void surReponse(JSONValue responseValue) {
175 
				if (responseValue.isString() != null) {
 175 
				if (responseValue.isString() != null) {
176 
					Information info = new Information("suppression_collection_a_publication");
 176 
					Information info = new Information("suppression_collection_a_publication");
177 
					info.setMessage(responseValue.isString().stringValue());
 177 
					info.setMessage(responseValue.isString().stringValue());
178 
					vueARafraichir.rafraichir(info);
 178 
					vueARafraichir.rafraichir(info);
179 
				} else {
 179 
				} else {
180 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
 180 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
181 
				}
 181 
				}
182 
			}
 182 
			}
183 
		});
 183 
		});
184 
	}
 184 
	}
185
185
186 
	private String construirePost(String collectionId, CollectionAPublication publication) {
 186 
	private String construirePost(String collectionId, CollectionAPublication publication) {
187 
		String postDonnees = "cmhl_ce_modifier_par=" + URL.encodeComponent(utilisateurId) +
 187 
		String postDonnees = "cmhl_ce_modifier_par=" + URL.encodeComponent(utilisateurId) +
188 
			"&ccapu_id_collection=" + URL.encodeComponent(collectionId) +
 188 
			"&ccapu_id_collection=" + URL.encodeComponent(collectionId) +
189 
			"&ccapu_id_publication=" + URL.encodeComponent(publication.getIdPublication());
 189 
			"&ccapu_id_publication=" + URL.encodeComponent(publication.getIdPublication()) +
- 
 
 190 
			"&ccapu_source=" + URL.encodeComponent(publication.getSource());
190 
		return postDonnees;
 191 
		return postDonnees;
191 
	}
 192 
	}
192 
}
 193 
}