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