Subversion Repositories eFlore/Applications.coel

Rev

Rev 1691 | Rev 1695 | 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.structure;
121 jpm 2 
 
1040 gduche 3 
import java.util.HashMap;
4 
 
770 jpm 5 
import org.tela_botanica.client.Mediateur;
121 jpm 6 
import org.tela_botanica.client.RegistreId;
770 jpm 7 
import org.tela_botanica.client.http.JsonRestRequestBuilder;
8 
import org.tela_botanica.client.http.JsonRestRequestCallback;
121 jpm 9 
import org.tela_botanica.client.interfaces.Rafraichissable;
935 jpm 10 
import org.tela_botanica.client.modeles.Information;
1040 gduche 11 
import org.tela_botanica.client.modeles.personne.PersonneListe;
935 jpm 12 
import org.tela_botanica.client.modeles.projet.ProjetListe;
1319 gduche 13 
import org.tela_botanica.client.synchronisation.Reponse;
770 jpm 14 
import org.tela_botanica.client.util.UtilDAO;
121 jpm 15 
 
16 
import com.extjs.gxt.ui.client.Registry;
133 jpm 17 
import com.google.gwt.core.client.GWT;
121 jpm 18 
import com.google.gwt.http.client.URL;
19 
import com.google.gwt.json.client.JSONArray;
156 jp_milcent 20 
import com.google.gwt.json.client.JSONObject;
121 jpm 21 
import com.google.gwt.json.client.JSONValue;
1633 aurelien 22 
import com.google.gwt.user.client.Window;
121 jpm 23 
 
24 
public class StructureAsyncDao {
268 jp_milcent 25 
	private static final String SERVICE_NOM = "CoelStructure";
264 jp_milcent 26 
 
770 jpm 27 
	private String utilisateurId = null;
28 
	private Rafraichissable vueARafraichir = null;
29 
 
30 
	public StructureAsyncDao(Rafraichissable vue) {
1367 cyprien 31 
		if (Mediateur.DEBUG) System.out.println("|| StructureAsyncDao > vueARafraichir = "+vue.getClass().toString());
770 jpm 32 
		vueARafraichir = vue;
33 
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
34 
	}
1329 cyprien 35 
 
36 
	/**
37 
	 *
38 
	 * @param paginationProgressive : définit le mode de consultation de la base de données
39 
	 * 			- True :	la consultation des données est progressive, ce qui signifie que la liste est chargée (paginée) au
40 
	 * 						fur et à mesure de la consultation des données par l'utilisateur.
41 
	 * 			- False :	la consultation des données est classique : un seul appel à la base de données est effectué, le retour
42 
	 * 						est renvoyé à l'appelant
43 
	 * 			// FIXME : si la taille de la liste est supérieure à la limite du JREST (150), ce deuxieme mode ne fonctionne pas
44 
	 */
1691 raphael 45 
	public void selectionner(final boolean paginationProgressive, final String projetId, final String structureId, final String nomStructure, final String formatRetour, final int start, final int nbElements, final Integer seqId, final boolean searchCity) {
46 
		String[] parametres = {projetId, structureId, nomStructure};
47 
 
1040 gduche 48 
		HashMap<String, String> restrictions = new HashMap<String, String>();
1468 jpm 49 
 
1040 gduche 50 
		if (nbElements != -1)	{
51 
			restrictions.put("limit", String.valueOf(nbElements));
52 
		}
1691 raphael 53 
		restrictions.put("searchCity", String.valueOf(searchCity));
1040 gduche 54 
 
1526 jpm 55 
		if ((formatRetour != null) && (formatRetour != "")) {
56 
			restrictions.put("formatRetour", formatRetour);
57 
		}
58 
 
1329 cyprien 59 
		/** GESTION DE LA REQUETE dans le cas d'une liste paginée progressive **/
60 
		if (paginationProgressive) {
61 
 
62 
			/** DEFINITION DU TUPLE DE DEPART **/
63 
			restrictions.put("start", String.valueOf(start));
64 
 
65 
			/** CONSTRUCTION DE LA REQUETE **/
66 
    		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
1319 gduche 67 
 
1329 cyprien 68 
    		/** ENVOI DE LA REQUETE **/
69 
    		rb.envoyerRequete(null, new JsonRestRequestCallback()
70 
    		{
71 
    			/** RECEPTION DE LA REPONSE **/
72 
    			public void surReponse(JSONValue responseValue)
73 
    			{
74 
					if (seqId != null)	{
75 
						Reponse reponseRequete = new Reponse(responseValue, seqId);
76 
						vueARafraichir.rafraichir(reponseRequete);
77 
					}
78 
 
79 
    				/** Dans le cas d'une liste paginée, vueARafraichir est un objet Proxy.
80 
    				 * On retourne l'objet JSON au proxy afin que ce soit lui qui le traite **/
81 
					else vueARafraichir.rafraichir(responseValue);
82 
    			}
83 
    		});
84 
		}
85 
		/** GESTION DE LA REQUETE dans le cas d'une liste NON paginée progressive **/
86 
		else {
87 
 
88 
			/** DEFINITION DU TUPLE DE DEPART **/
89 
			restrictions.put("start", String.valueOf(start*nbElements));
90 
 
91 
			final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
92 
 
93 
			rb.envoyerRequete(null, new JsonRestRequestCallback() {
94 
 
95 
				public void surReponse(JSONValue responseValue) {
96 
 
97 
					if (responseValue != null) {
1319 gduche 98 
 
1329 cyprien 99 
						Information info = new Information("selection_structure");
100 
 
101 
						JSONObject responseObject = responseValue.isObject();
102 
 
103 
						if (responseObject != null) {
104 
 
105 
							// Si la réponse est un tableau, alors c'est une liste de structure qui a été retournée
106 
							if (responseObject.get("structures").isArray() != null) {
107 
 
108 
								JSONObject reponse = responseObject;
109 
								StructureListe structures;
110 
								structures = new StructureListe(reponse.get("structures").isArray(), reponse.get("nbElements").isNumber(), vueARafraichir);
111 
								structures.setTaillePage(nbElements);
112 
								structures.setPageCourante(start);
113 
 
114 
								info.setDonnee(0, structures);
115 
 
116 
								if (seqId != null)	{
117 
									Reponse reponseRequete = new Reponse(info, seqId);
118 
									vueARafraichir.rafraichir(reponseRequete);
119 
								}
120 
								else vueARafraichir.rafraichir(structures);
121 
 
122 
							// Si la réponse est un objet, alors c'est une unique structure qui a été retournée
123 
							} else if (responseObject.get("structures").isObject() != null) {
124 
 
125 
								JSONObject reponse = responseObject.get("structures").isObject();
126 
								Structure structure = new Structure(reponse);
127 
								StructureConservation structureConservation = new StructureConservation(reponse);
128 
								StructureValorisation structureValorisation = new StructureValorisation(reponse);
129 
 
130 
								info.setDonnee(0, structure);
131 
								info.setDonnee(1, structureConservation);
132 
								info.setDonnee(2, structureValorisation);
133 
 
134 
								if (seqId != null)	{
135 
									Reponse reponseRequete = new Reponse(info, seqId);
136 
									vueARafraichir.rafraichir(reponseRequete);
137 
								}
138 
								else vueARafraichir.rafraichir(info);
139 
							}
140 
						} else {
141 
							GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas un objet ou un talbeau JSON et vaut : "+responseValue.toString(), null);
1040 gduche 142 
						}
1329 cyprien 143 
					} else {
144 
						if (structureId == null) {
145 
							// Dans le cas, où nous demandons toutes les institutions et qu'il n'y en a pas, nous retournons un objet vide
146 
							StructureListe structures = new StructureListe(0);
147 
							vueARafraichir.rafraichir(structures);
1319 gduche 148 
						}
770 jpm 149 
					}
150 
				}
1329 cyprien 151 
			});
152 
		}
770 jpm 153 
	}
154 
 
1329 cyprien 155 
 
770 jpm 156 
	public void ajouter(final Structure str, StructureConservation conservation, StructureValorisation valorisation) {
157 
		String postDonneesEncodees = construirePost(null, str, conservation, valorisation);
156 jp_milcent 158 
 
770 jpm 159 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
160 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
161 
			@Override
162 
			public void surReponse(JSONValue responseValue) {
163 
				if (responseValue.isString() != null) {
164 
					Information info = new Information("ajout_structure");
165 
					String structureIdOuMessage = responseValue.isString().stringValue();
166 
					if (structureIdOuMessage.matches("^[0-9]+$")) {
167 
						info.setDonnee(structureIdOuMessage);
156 jp_milcent 168 
					} else {
770 jpm 169 
						info.setMessage(structureIdOuMessage);
156 jp_milcent 170 
					}
770 jpm 171 
					vueARafraichir.rafraichir(info);
172 
				} else {
173 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
156 jp_milcent 174 
				}
770 jpm 175 
			}
176 
		});
156 jp_milcent 177 
	}
770 jpm 178 
 
179 
	public void modifier(String structureId, Structure str, StructureConservation conservation, StructureValorisation valorisation) {
180 
		String postDonneesEncodees = construirePost(structureId, str, conservation, valorisation);
772 jpm 181 
		String[] parametres = {structureId};
182 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
183 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
184 
			@Override
185 
			public void surReponse(JSONValue responseValue) {
1673 raphael 186 
				// Si la requête a impliquées des valeurs autogénérées, l'objet modifié est retourné
187 
				JSONObject obj;
188 
				if ((obj = responseValue.isObject()) != null) {
189 
					if (obj.get("structures").isObject() != null) {
190 
						Structure structure = new Structure(obj.get("structures").isObject());
191 
						Information info = new Information("modif_structure");
192 
						info.setDonnee(structure);
193 
						vueARafraichir.rafraichir(info);
194 
					}
195 
				}
772 jpm 196 
				// Si la requête est un succès, reception d'une chaine
1673 raphael 197 
				else if (responseValue.isString() != null) {
772 jpm 198 
					Information info = new Information("modif_structure");
199 
					info.setMessage(responseValue.isString().stringValue());
200 
					vueARafraichir.rafraichir(info);
201 
				} else {
202 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
121 jpm 203 
				}
772 jpm 204 
			}
205 
		});
121 jpm 206 
	}
770 jpm 207 
 
772 jpm 208 
	public void supprimer(String structuresId) {
209 
		String[] parametres = {utilisateurId, structuresId};
210 
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
211 
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
212 
			@Override
213 
			public void surReponse(JSONValue responseValue) {
214 
				if (responseValue.isString() != null) {
215 
					Information info = new Information("suppression_structure");
216 
					info.setMessage(responseValue.isString().stringValue());
217 
					vueARafraichir.rafraichir(info);
218 
				} else {
219 
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
133 jpm 220 
				}
772 jpm 221 
			}
222 
		});
133 jpm 223 
	}
169 jp_milcent 224 
 
770 jpm 225 
	private String construirePost(String structureId, Structure str, StructureConservation conservation, StructureValorisation valorisation) {
865 jpm 226 
		String postDonnees = "cmhl_ce_modifier_par=" + URL.encodeComponent(utilisateurId);
227 
 
602 jp_milcent 228 
		if (str != null) {
612 jp_milcent 229 
			if (structureId != null) {
230 
				postDonnees += "&cs_id_structure=" + URL.encodeComponent(structureId);
231 
			}
1369 cyprien 232 
 
233 
			postDonnees += "&cpr_abreviation=" + URL.encodeComponent(str.getAbreviationProjet());
602 jp_milcent 234 
			postDonnees += "&cs_ce_projet=" + URL.encodeComponent(str.getIdProjet()) +
235 
				"&cs_ce_mere=" + URL.encodeComponent(str.getIdMere()) +
236 
				"&cs_guid=" + URL.encodeComponent(str.getGuid()) +
237 
				"&cs_truk_identifiant_alternatif=" + URL.encodeComponent(str.getIdAlternatif()) +
238 
				"&cs_nom=" + URL.encodeComponent(str.getNom()) +
239 
				"&cs_truk_nom_alternatif=" + URL.encodeComponent(str.getNomAlternatif()) +
1173 jpm 240 
				"&cs_description=" + URL.encodeComponent(str.getDescription()) +
602 jp_milcent 241 
				"&cs_ce_type=" + URL.encodeComponent(str.getType()) +
242 
				"&cs_ce_truk_type_prive=" + URL.encodeComponent(str.getTypePrive()) +
243 
				"&cs_ce_truk_type_public=" + URL.encodeComponent(str.getTypePublic()) +
244 
				"&cs_adresse_01=" + URL.encodeComponent(str.getAdresse()) +
245 
				"&cs_adresse_02=" + URL.encodeComponent(str.getAdresseComplement()) +
246 
				"&cs_date_fondation=" + URL.encodeComponent(str.getDateFondationFormatMysql()) +
247 
				"&cs_code_postal=" + URL.encodeComponent(str.getCodePostal()) +
248 
				"&cs_ville=" + URL.encodeComponent(str.getVille()) +
1037 gduche 249 
				"&cs_ce_truk_region=" + URL.encodeComponent(str.get("ce_truk_region").toString()) +
602 jp_milcent 250 
				"&cs_ce_truk_pays=" + URL.encodeComponent(str.getPays()) +
1173 jpm 251 
				"&cs_latitude=" + URL.encodeComponent(str.getLatitude()) +
252 
				"&cs_longitude=" + URL.encodeComponent(str.getLongitude()) +
602 jp_milcent 253 
				"&cs_truk_telephone=" + URL.encodeComponent(str.getTelephone()) +
254 
				"&cs_truk_url=" + URL.encodeComponent(str.getUrl()) +
1685 raphael 255 
				"&cs_nbre_personne=" + (str.getNbrePersonne() != null ? str.getNbrePersonne() : "") +
1173 jpm 256 
				"&cs_condition_acces=" + URL.encodeComponent(str.getConditionAcces())+
257 
				"&cs_condition_usage=" + URL.encodeComponent(str.getConditionUsage())+
1039 gduche 258 
				"&cs_courriel=" + URL.encodeComponent(str.getCourriel());
602 jp_milcent 259 
		}
260 
		if (conservation != null) {
612 jp_milcent 261 
			if (structureId != null) {
262 
				postDonnees += "&csc_id_structure=" + URL.encodeComponent(structureId);
263 
			}
1693 raphael 264 
			postDonnees += "&csc_mark_formation=" + (conservation.getFormation() != null ? conservation.getFormation() : "") +
602 jp_milcent 265 
				"&csc_formation=" + URL.encodeComponent(conservation.getFormationInfo()) +
1693 raphael 266 
				"&csc_mark_formation_interet=" + (conservation.getFormationInteret() != null ? conservation.getFormationInteret() : "") +
602 jp_milcent 267 
				"&csc_truk_stockage_local=" + URL.encodeComponent(conservation.getStockageLocal()) +
268 
				"&csc_truk_stockage_meuble=" + URL.encodeComponent(conservation.getStockageMeuble()) +
269 
				"&csc_truk_stockage_parametre=" + URL.encodeComponent(conservation.getStockageParametre()) +
270 
				"&csc_mark_collection_commune=" + URL.encodeComponent(conservation.getCollectionCommune()) +
271 
				"&csc_truk_collection_autre=" + URL.encodeComponent(conservation.getCollectionAutre()) +
272 
				"&csc_mark_acces_controle=" + URL.encodeComponent(conservation.getAccesControle()) +
273 
				"&csc_mark_restauration=" + URL.encodeComponent(conservation.getRestauration()) +
274 
				"&csc_truk_restauration_operation=" + URL.encodeComponent(conservation.getRestaurationOperation()) +
275 
				"&csc_ce_materiel_conservation=" + URL.encodeComponent(conservation.getMaterielConservation()) +
276 
				"&csc_truk_materiel_autre=" + URL.encodeComponent(conservation.getMaterielAutre()) +
277 
				"&csc_mark_traitement=" + URL.encodeComponent(conservation.getTraitement()) +
278 
				"&csc_truk_traitement=" + URL.encodeComponent(conservation.getTraitements()) +
279 
				"&csc_mark_acquisition_collection=" + URL.encodeComponent(conservation.getAcquisitionCollection()) +
280 
				"&csc_mark_acquisition_echantillon=" + URL.encodeComponent(conservation.getAcquisitionEchantillon()) +
281 
				"&csc_mark_acquisition_traitement=" + URL.encodeComponent(conservation.getAcquisitionTraitement()) +
282 
				"&csc_truk_acquisition_traitement_poison=" + URL.encodeComponent(conservation.getAcquisitionTraitementPoison()) +
283 
				"&csc_truk_acquisition_traitement_insecte=" + URL.encodeComponent(conservation.getAcquisitionTraitementInsecte());
284 
		}
285 
		if (valorisation != null) {
612 jp_milcent 286 
			if (structureId != null) {
632 jp_milcent 287 
				postDonnees += "&csv_id_structure=" + URL.encodeComponent(structureId);
612 jp_milcent 288 
			}
602 jp_milcent 289 
			postDonnees += "&csv_mark_action=" + URL.encodeComponent(valorisation.getAction()) +
290 
				"&csv_truk_action=" + URL.encodeComponent(valorisation.getActionInfo()) +
291 
				"&csv_publication=" + URL.encodeComponent(valorisation.getPublication()) +
292 
				"&csv_collection_autre=" + URL.encodeComponent(valorisation.getCollectionAutre()) +
293 
				"&csv_mark_action_future=" + URL.encodeComponent(valorisation.getActionFuture()) +
294 
				"&csv_action_future=" + URL.encodeComponent(valorisation.getActionFutureInfo()) +
295 
				"&csv_mark_recherche=" + URL.encodeComponent(valorisation.getRecherche()) +
296 
				"&csv_truk_recherche_provenance=" + URL.encodeComponent(valorisation.getRechercheProvenance()) +
297 
				"&csv_truk_recherche_type=" + URL.encodeComponent(valorisation.getRechercheType()) +
298 
				"&csv_mark_acces_ss_motif=" + URL.encodeComponent(valorisation.getAccesSansMotif()) +
299 
				"&csv_acces_ss_motif=" + URL.encodeComponent(valorisation.getAccesSansMotifInfo()) +
300 
				"&csv_mark_visite_avec_motif=" + URL.encodeComponent(valorisation.getVisiteAvecMotif()) +
301 
				"&csv_visite_avec_motif=" + URL.encodeComponent(valorisation.getVisiteAvecMotifInfo());
302 
		}
303 
		return postDonnees;
304 
	}
1673 raphael 305 
}