WebSVN – eFlore/Applications.coel – Diff – /branches/v1.0-syrah/src/org/tela_botanica/client/modeles/publication/PublicationAsyncDao.java


package org.tela_botanica.client.modeles.publication;
 
import java.util.HashMap;
 
import org.tela_botanica.client.Mediateur;
import org.tela_botanica.client.RegistreId;
import org.tela_botanica.client.http.JsonRestRequestBuilder;
import org.tela_botanica.client.http.JsonRestRequestCallback;
import org.tela_botanica.client.interfaces.Rafraichissable;
import org.tela_botanica.client.modeles.Information;
import org.tela_botanica.client.modeles.structure.StructureListe;
import org.tela_botanica.client.util.Debug;
import org.tela_botanica.client.util.UtilDAO;
 
import com.extjs.gxt.ui.client.Registry;
import com.google.gwt.core.client.GWT;
import com.google.gwt.json.client.JSONArray;
import com.google.gwt.json.client.JSONObject;
import com.google.gwt.json.client.JSONValue;
 
public class PublicationAsyncDao {
	private static final String SERVICE_NOM = "CoelPublication";
	
	private String utilisateurId = null;
	private Rafraichissable vueARafraichir = null;
	
	public PublicationAsyncDao(Rafraichissable vueARafraichirCourrante) {
		vueARafraichir = vueARafraichirCourrante ;
		utilisateurId = ((Mediateur) Registry.get(RegistreId.MEDIATEUR)).getUtilisateurId();
	}
 
	public void selectionner(final String publicationId, String projetId, String nomComplet, final int nbElements, final int pageCourante) {
		String[] parametres = {projetId, publicationId, nomComplet};
 
		HashMap<String, String> restrictions = new HashMap<String, String>();
		restrictions.put("start", String.valueOf(pageCourante*nbElements));
		if (nbElements != -1)	{
			restrictions.put("limit", String.valueOf(nbElements));
		}
		
		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres, restrictions);
		rb.envoyerRequete(null, new JsonRestRequestCallback() {
			@Override
			public void surReponse(JSONValue responseValue) {
				if (responseValue != null) {
					// Si la requête est un succès, réception d'un objet ou d'un tableau
					JSONArray responseArray = responseValue.isArray();
					if (responseArray.get(1).isObject() != null) {
						final JSONObject reponse = responseArray.get(1).isObject();
						// Transformation du tableau JSON réponse en ListeInstitution
						Publication publication = new Publication(reponse);
						// et on met à jour le demandeur des données
						vueARafraichir.rafraichir(publication);
					} else if (responseArray.get(1).isArray() != null) {
						final JSONArray reponse = responseValue.isArray();
						PublicationListe publications;
						if (reponse.get(1).isObject() != null)	{
							publications = new PublicationListe(reponse.get(1).isArray());
						} else	{
							publications = new PublicationListe(reponse.get(1).isArray(), reponse.get(0).isNumber(), vueARafraichir);
						}
						
						publications.setTaillePage(nbElements);
						publications.setPageCourante(pageCourante);
						
						vueARafraichir.rafraichir(publications);
					} else {
						GWT.log("La réponse n'est pas un objet ou un talbeau JSON et vaut : "+responseValue.toString(), null);
					}
				} else {
					// Dans le cas, où nous demandons toutes les publication et qu'il n'y en a pas, nous retournons un objet vide
					if (publicationId == null) {
						PublicationListe publications = new PublicationListe(0);
						vueARafraichir.rafraichir(publications);
					}
				}
			}
		});
	}
 
	public void ajouter(Publication publication) {
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
		
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
		
Debug.log("|> PublicationAsyncDao.ajouter(Publication publication) : postDonneesEncodees="+postDonneesEncodees);
 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
			@Override
			public void surReponse(JSONValue reponseValeur) {
				traiterReponse(reponseValeur, "ajout_publication");
			}
		}) ;
	}
	
	public void modifier(Publication publication) {
		String[] parametres = {publication.getId()};
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
		
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
		
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
			@Override
			public void surReponse(JSONValue reponseValeur) {
				traiterReponse(reponseValeur, "modif_publication");
			}
		});
	}
 
	public void supprimer(String publicationsId) {
		String[] parametres = {utilisateurId, publicationsId};
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM, parametres);
		rb.envoyerRequeteSuppression(new JsonRestRequestCallback() {
			@Override
			public void surReponse(JSONValue reponseValeur) {
				traiterReponse(reponseValeur, "suppression_publication");
			}
		});
	}
	
	private void traiterReponse(JSONValue reponseValeur, String type) {
		Information info = new Information(type);
		// Si la requête est un succès, réception d'une chaîne
		if (reponseValeur.isString() != null) {
			String idOuMessage = reponseValeur.isString().stringValue();
			if (idOuMessage.matches("^[0-9]+$")) {
				info.setDonnee(idOuMessage);
			} else {
				info.setMessage(idOuMessage);
			}
		} else {
			info.setDeboguage("La réponse n'est pas une chaine JSON.");
		}
		vueARafraichir.rafraichir(info);
	}
 
}

Subversion Repositories eFlore/Applications.coel

(root)/branches/v1.0-syrah/src/org/tela_botanica/client/modeles/publication/PublicationAsyncDao.java @ 1330 – Rev 1136 → 1218

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