WebSVN – eFlore/Applications.coel – Diff – /trunk/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.synchronisation.Reponse;
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) {
		if (Mediateur.DEBUG) System.out.println("|| PublicationAsyncDao > vueARafraichir = "+vueARafraichirCourrante.getClass().toString());
		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, final Integer seqId) {
		String[] parametres = {projetId, publicationId, nomComplet};
 
		HashMap<String, String> restrictions = new HashMap<String, String>();
		restrictions.put("orderby", "cpu_titre");
		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
						if (seqId!=null)	{
							Reponse reponseRequete = new Reponse(publication, seqId);
							vueARafraichir.rafraichir(reponseRequete);
						} else {
							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);
						
						if (seqId!=null)	{
							Reponse reponseRequete = new Reponse(publications, seqId);
							vueARafraichir.rafraichir(reponseRequete);
						} else {
							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, final Integer seqId) {
		String postDonneesEncodees = publication.obtenirChainePOST()+"&cmhl_ce_modifier_par="+utilisateurId;
		
		final JsonRestRequestBuilder rb = UtilDAO.construireRequetePost(SERVICE_NOM);
 
		rb.envoyerRequete(postDonneesEncodees, new JsonRestRequestCallback() {
			@Override
			public void surReponse(JSONValue reponseValeur) {
				traiterReponse(reponseValeur, "ajout_publication", seqId);
			}
		}) ;
	}
	
	public void modifier(Publication publication, final Integer seqId) {
		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",  seqId);
			}
		});
	}
 
	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", null);
			}
		});
	}
	
	private void traiterReponse(JSONValue reponseValeur, String type, Integer seqId) {
		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.");
		}
		
		if (seqId!=null)	{
			Reponse retourRequete = new Reponse(info, seqId);
			vueARafraichir.rafraichir(retourRequete);
		} else {
			vueARafraichir.rafraichir(info);
		}
	}
 
}

Subversion Repositories eFlore/Applications.coel

(root)/trunk/src/org/tela_botanica/client/modeles/publication/PublicationAsyncDao.java – Rev 1417 → 1428

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