Mercurial > dive4elements > river
view flys-client/src/main/java/de/intevation/flys/client/server/FixingsOverviewServiceImpl.java @ 4247:5da024c2af62
Refactor GaugeOverviewInfoService and MeasurementStationInfoService
Refactor RiverInfoService out of GaugeOverviewInfoService and
MeasurementStationInfoService to share common code of both classes in a base
class.
author | Björn Ricks <bjoern.ricks@intevation.de> |
---|---|
date | Wed, 24 Oct 2012 16:36:59 +0200 |
parents | 653dd9d7f5d5 |
children |
line wrap: on
line source
package de.intevation.flys.client.server; import com.google.gwt.user.server.rpc.RemoteServiceServlet; import de.intevation.artifacts.common.utils.XMLUtils; import de.intevation.artifacts.common.utils.XSLTransformer; import de.intevation.artifacts.httpclient.exceptions.ConnectionException; import de.intevation.artifacts.httpclient.http.HttpClient; import de.intevation.artifacts.httpclient.http.HttpClientImpl; import de.intevation.flys.client.client.services.FixingsOverviewService; import de.intevation.flys.client.shared.exceptions.ServerException; import de.intevation.flys.client.shared.model.FixingsOverviewInfo.FixEvent; import de.intevation.flys.client.shared.model.FixingsOverviewInfo.Sector; import de.intevation.flys.client.shared.model.FixingsOverviewInfo; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.List; import javax.xml.xpath.XPathConstants; import org.apache.log4j.Logger; import org.w3c.dom.Document; import org.w3c.dom.Element; import org.w3c.dom.NodeList; public class FixingsOverviewServiceImpl extends RemoteServiceServlet implements FixingsOverviewService { private static final Logger log = Logger.getLogger(FixingsOverviewServiceImpl.class); public static final String SERVICE_NAME = "fixings-overview"; public static final String XSL_TRANSFORM = "/WEB-INF/stylesheets/fixoverview2html.xsl"; protected static final String XPATH_RID = "/fixings/river/@rid"; protected static final String XPATH_RIVER = "/fixings/river/@name"; protected static final String XPATH_RFROM = "/fixings/river/@from"; protected static final String XPATH_RTO = "/fixings/river/@to"; protected static final String XPATH_EVENT = "/fixings/events/event"; @Override public FixingsOverviewInfo generateOverview( String locale, String uuid, String filter, boolean checkboxes, String callback ) throws ServerException { log.info("FixingsOverviewServiceImpl.doGet"); if (filter == null || filter.length() == 0) { log.warn("Missing 'filter' parameter."); return null; } boolean debug = log.isDebugEnabled(); if (debug) { log.debug("JSON filter: ------------------"); log.debug(filter); } Document filterDoc = XMLUtils.jsonToXML(filter); if (filterDoc == null) { log.warn("Creating filter document failed."); return null; } if (debug) { log.debug("XML filter: ------------------"); log.debug(XMLUtils.toString(filterDoc)); } try { String url = getServletContext().getInitParameter("server-url"); HttpClient client = new HttpClientImpl(url, locale); Document resultDoc = client.callService(url, SERVICE_NAME, filterDoc); if (debug) { log.debug("Result XML: -----------"); log.debug(XMLUtils.toString(resultDoc)); } FixingsOverviewInfo i = getInfo( locale, resultDoc, uuid, checkboxes, callback); return i; } catch (ConnectionException ce) { log.error(ce); } return null; } protected FixingsOverviewInfo getInfo( String locale, Document doc, String uuid, boolean checkboxes, String callback ) { // TODO: Find a more general solution. locale = locale == null || locale.toLowerCase().startsWith("de") ? "de" : "en"; InputStream transform = getServletContext() .getResourceAsStream(XSL_TRANSFORM); if (transform == null) { log.warn("transform not found"); return null; } String result = null; try { XSLTransformer xformer = new XSLTransformer(); xformer.addParameter("locale", locale); xformer.addParameter("project-uuid", uuid); xformer.addParameter( "render-checkboxes", checkboxes ? Boolean.TRUE : Boolean.FALSE); xformer.addParameter("callback", callback); result = xformer.transform(doc, transform); } finally { try { transform.close(); } catch (IOException ioe) {} } if (log.isDebugEnabled()) { log.debug("--------------------------------------"); log.debug(result); log.debug("--------------------------------------"); } int rid = -1; double from = -1; double to = -1; String rid_str = XMLUtils.xpathString(doc, XPATH_RID, null); String river = XMLUtils.xpathString(doc, XPATH_RIVER, null); String from_str = XMLUtils.xpathString(doc, XPATH_RFROM, null); String to_str = XMLUtils.xpathString(doc, XPATH_RTO, null); try { rid = Integer.parseInt(rid_str); from = Double.parseDouble(from_str); to = Double.parseDouble(to_str); } catch(NumberFormatException nfe) { log.warn(nfe, nfe); } List<FixEvent> fixEvents = getFixEvents(doc); return new FixingsOverviewInfo( rid, river, from, to, fixEvents, result); } protected List<FixEvent> getFixEvents(Document doc) { List<FixEvent> list = new ArrayList<FixEvent>(); NodeList events = (NodeList) XMLUtils.xpath( doc, XPATH_EVENT, XPathConstants.NODESET, null); if (events == null || events.getLength() == 0) { log.warn("No events in Overview!"); return list; } for (int i = 0, E = events.getLength(); i < E; i++) { Element n = (Element)events.item(i); List<Sector> sectors = getSectors(n); String cid = n.getAttribute("cid"); String date = n.getAttribute("date");; String name = n.getAttribute("description"); list.add(new FixEvent( cid, date, name, sectors)); } return list; } protected List<Sector> getSectors(Element event) { NodeList sectors = event.getElementsByTagName("sector"); if (sectors.getLength() == 0) { log.warn("No Sectors in Event!"); return null; } List<Sector> list = new ArrayList<Sector>(); for (int i = 0, S = sectors.getLength(); i < S; i++) { Element n = (Element)sectors.item(i); int cls = -1; double from = -1; double to = -1; String cls_str = n.getAttribute("class"); String from_str = n.getAttribute("from"); String to_str = n.getAttribute("to"); try { cls = Integer.parseInt(cls_str); from = Double.parseDouble(from_str); to = Double.parseDouble(to_str); } catch(NumberFormatException nfe) { log.warn(nfe, nfe); } list.add(new Sector(cls, from, to)); } return list; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :