Subversion Repositories eFlore/Applications.coel

Rev

Rev 1733 | 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) {
1708 raphael 163
				// Si la requête a impliquées des valeurs autogénérées, l'objet modifié est retourné
164
				JSONObject obj;
165
				if ((obj = responseValue.isObject()) != null) {
166
					if (obj.get("structures").isObject() != null) {
167
						Information info = new Information("ajout_structure");
168
						Structure structure = new Structure(obj.get("structures").isObject());
169
						info.setDonnee(structure);
170
						vueARafraichir.rafraichir(info);
171
					}
172
				}
173
				else if (responseValue.isString() != null) {
770 jpm 174
					Information info = new Information("ajout_structure");
175
					String structureIdOuMessage = responseValue.isString().stringValue();
176
					if (structureIdOuMessage.matches("^[0-9]+$")) {
177
						info.setDonnee(structureIdOuMessage);
156 jp_milcent 178
					} else {
770 jpm 179
						info.setMessage(structureIdOuMessage);
156 jp_milcent 180
					}
770 jpm 181
					vueARafraichir.rafraichir(info);
182
				} else {
183
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
156 jp_milcent 184
				}
770 jpm 185
			}
186
		});
156 jp_milcent 187
	}
770 jpm 188
 
189
	public void modifier(String structureId, Structure str, StructureConservation conservation, StructureValorisation valorisation) {
190
		String postDonneesEncodees = construirePost(structureId, str, conservation, valorisation);
772 jpm 191
		String[] parametres = {structureId};
192
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
193
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
194
			@Override
195
			public void surReponse(JSONValue responseValue) {
1673 raphael 196
				// Si la requête a impliquées des valeurs autogénérées, l'objet modifié est retourné
197
				JSONObject obj;
198
				if ((obj = responseValue.isObject()) != null) {
199
					if (obj.get("structures").isObject() != null) {
200
						Structure structure = new Structure(obj.get("structures").isObject());
201
						Information info = new Information("modif_structure");
202
						info.setDonnee(structure);
203
						vueARafraichir.rafraichir(info);
204
					}
205
				}
772 jpm 206
				// Si la requête est un succès, reception d'une chaine
1673 raphael 207
				else if (responseValue.isString() != null) {
772 jpm 208
					Information info = new Information("modif_structure");
209
					info.setMessage(responseValue.isString().stringValue());
210
					vueARafraichir.rafraichir(info);
211
				} else {
212
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
121 jpm 213
				}
772 jpm 214
			}
215
		});
121 jpm 216
	}
770 jpm 217
 
772 jpm 218
	public void supprimer(String structuresId) {
219
		String[] parametres = {utilisateurId, structuresId};
220
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
221
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
222
			@Override
223
			public void surReponse(JSONValue responseValue) {
224
				if (responseValue.isString() != null) {
225
					Information info = new Information("suppression_structure");
226
					info.setMessage(responseValue.isString().stringValue());
227
					vueARafraichir.rafraichir(info);
228
				} else {
229
					GWT.log(rb.getUrl()+"\n\tLa réponse n'est pas une chaine JSON.", null);
133 jpm 230
				}
772 jpm 231
			}
232
		});
133 jpm 233
	}
169 jp_milcent 234
 
770 jpm 235
	private String construirePost(String structureId, Structure str, StructureConservation conservation, StructureValorisation valorisation) {
865 jpm 236
		String postDonnees = "cmhl_ce_modifier_par=" + URL.encodeComponent(utilisateurId);
237
 
602 jp_milcent 238
		if (str != null) {
612 jp_milcent 239
			if (structureId != null) {
240
				postDonnees += "&cs_id_structure=" + URL.encodeComponent(structureId);
241
			}
1369 cyprien 242
 
243
			postDonnees += "&cpr_abreviation=" + URL.encodeComponent(str.getAbreviationProjet());
602 jp_milcent 244
			postDonnees += "&cs_ce_projet=" + URL.encodeComponent(str.getIdProjet()) +
245
				"&cs_ce_mere=" + URL.encodeComponent(str.getIdMere()) +
246
				"&cs_guid=" + URL.encodeComponent(str.getGuid()) +
247
				"&cs_truk_identifiant_alternatif=" + URL.encodeComponent(str.getIdAlternatif()) +
248
				"&cs_nom=" + URL.encodeComponent(str.getNom()) +
249
				"&cs_truk_nom_alternatif=" + URL.encodeComponent(str.getNomAlternatif()) +
1173 jpm 250
				"&cs_description=" + URL.encodeComponent(str.getDescription()) +
602 jp_milcent 251
				"&cs_ce_type=" + URL.encodeComponent(str.getType()) +
252
				"&cs_ce_truk_type_prive=" + URL.encodeComponent(str.getTypePrive()) +
253
				"&cs_ce_truk_type_public=" + URL.encodeComponent(str.getTypePublic()) +
254
				"&cs_adresse_01=" + URL.encodeComponent(str.getAdresse()) +
255
				"&cs_adresse_02=" + URL.encodeComponent(str.getAdresseComplement()) +
256
				"&cs_date_fondation=" + URL.encodeComponent(str.getDateFondationFormatMysql()) +
257
				"&cs_code_postal=" + URL.encodeComponent(str.getCodePostal()) +
258
				"&cs_ville=" + URL.encodeComponent(str.getVille()) +
1037 gduche 259
				"&cs_ce_truk_region=" + URL.encodeComponent(str.get("ce_truk_region").toString()) +
602 jp_milcent 260
				"&cs_ce_truk_pays=" + URL.encodeComponent(str.getPays()) +
1173 jpm 261
				"&cs_latitude=" + URL.encodeComponent(str.getLatitude()) +
262
				"&cs_longitude=" + URL.encodeComponent(str.getLongitude()) +
602 jp_milcent 263
				"&cs_truk_telephone=" + URL.encodeComponent(str.getTelephone()) +
264
				"&cs_truk_url=" + URL.encodeComponent(str.getUrl()) +
1685 raphael 265
				"&cs_nbre_personne=" + (str.getNbrePersonne() != null ? str.getNbrePersonne() : "") +
1173 jpm 266
				"&cs_condition_acces=" + URL.encodeComponent(str.getConditionAcces())+
267
				"&cs_condition_usage=" + URL.encodeComponent(str.getConditionUsage())+
1039 gduche 268
				"&cs_courriel=" + URL.encodeComponent(str.getCourriel());
602 jp_milcent 269
		}
270
		if (conservation != null) {
612 jp_milcent 271
			if (structureId != null) {
272
				postDonnees += "&csc_id_structure=" + URL.encodeComponent(structureId);
273
			}
1693 raphael 274
			postDonnees += "&csc_mark_formation=" + (conservation.getFormation() != null ? conservation.getFormation() : "") +
602 jp_milcent 275
				"&csc_formation=" + URL.encodeComponent(conservation.getFormationInfo()) +
1693 raphael 276
				"&csc_mark_formation_interet=" + (conservation.getFormationInteret() != null ? conservation.getFormationInteret() : "") +
602 jp_milcent 277
				"&csc_truk_stockage_local=" + URL.encodeComponent(conservation.getStockageLocal()) +
278
				"&csc_truk_stockage_meuble=" + URL.encodeComponent(conservation.getStockageMeuble()) +
279
				"&csc_truk_stockage_parametre=" + URL.encodeComponent(conservation.getStockageParametre()) +
1695 raphael 280
				"&csc_mark_collection_commune=" + (conservation.getCollectionCommune() != null ? conservation.getCollectionCommune() : "") +
602 jp_milcent 281
				"&csc_truk_collection_autre=" + URL.encodeComponent(conservation.getCollectionAutre()) +
1695 raphael 282
				"&csc_mark_acces_controle=" + (conservation.getAccesControle() != null ? conservation.getAccesControle() : "") +
283
				"&csc_mark_restauration=" + (conservation.getRestauration() != null ? conservation.getRestauration() : "") +
602 jp_milcent 284
				"&csc_truk_restauration_operation=" + URL.encodeComponent(conservation.getRestaurationOperation()) +
285
				"&csc_ce_materiel_conservation=" + URL.encodeComponent(conservation.getMaterielConservation()) +
286
				"&csc_truk_materiel_autre=" + URL.encodeComponent(conservation.getMaterielAutre()) +
1695 raphael 287
				"&csc_mark_traitement=" + (conservation.getTraitement() != null ? conservation.getTraitement() : "") +
602 jp_milcent 288
				"&csc_truk_traitement=" + URL.encodeComponent(conservation.getTraitements()) +
1695 raphael 289
				"&csc_mark_acquisition_collection=" + (conservation.getAcquisitionCollection() != null ? conservation.getAcquisitionCollection() : "") +
290
				"&csc_mark_acquisition_echantillon=" + (conservation.getAcquisitionEchantillon() != null ? conservation.getAcquisitionEchantillon() : "") +
602 jp_milcent 291
				"&csc_mark_acquisition_traitement=" + URL.encodeComponent(conservation.getAcquisitionTraitement()) +
292
				"&csc_truk_acquisition_traitement_poison=" + URL.encodeComponent(conservation.getAcquisitionTraitementPoison()) +
293
				"&csc_truk_acquisition_traitement_insecte=" + URL.encodeComponent(conservation.getAcquisitionTraitementInsecte());
294
		}
295
		if (valorisation != null) {
612 jp_milcent 296
			if (structureId != null) {
632 jp_milcent 297
				postDonnees += "&csv_id_structure=" + URL.encodeComponent(structureId);
612 jp_milcent 298
			}
1733 raphael 299
			postDonnees += "&csv_mark_action=" + (valorisation.getAction() != null ? valorisation.getAction() : "") +
300
			    "&csv_truk_action=" + URL.encodeComponent(valorisation.getActionInfo()) +
301
			    "&csv_publication=" + URL.encodeComponent(valorisation.getPublication()) +
302
			    "&csv_collection_autre=" + URL.encodeComponent(valorisation.getCollectionAutre()) +
303
			    "&csv_mark_action_future=" + (valorisation.getActionFuture() != null ? valorisation.getActionFuture() : "") +
304
			    "&csv_action_future=" + URL.encodeComponent(valorisation.getActionFutureInfo()) +
305
			    "&csv_mark_recherche=" + (valorisation.getRecherche() != null ? valorisation.getRecherche() : "") +
306
			    "&csv_truk_recherche_provenance=" + URL.encodeComponent(valorisation.getRechercheProvenance()) +
307
			    "&csv_truk_recherche_type=" + URL.encodeComponent(valorisation.getRechercheType()) +
308
			    "&csv_mark_acces_ss_motif=" + (valorisation.getAccesSansMotif() != null ? valorisation.getAccesSansMotif() : "") +
309
			    "&csv_acces_ss_motif=" + URL.encodeComponent(valorisation.getAccesSansMotifInfo()) +
310
			    "&csv_mark_visite_avec_motif=" + (valorisation.getVisiteAvecMotif() != null ? valorisation.getVisiteAvecMotif() : "") +
311
			    "&csv_visite_avec_motif=" + URL.encodeComponent(valorisation.getVisiteAvecMotifInfo());
602 jp_milcent 312
		}
313
		return postDonnees;
314
	}
1673 raphael 315
}