raimund@245: package de.intevation.flys.client.server;
raimund@245: 
raimund@245: import java.util.ArrayList;
raimund@245: import java.util.List;
raimund@245: 
raimund@245: import javax.xml.xpath.XPathConstants;
raimund@245: 
raimund@245: import org.w3c.dom.Document;
raimund@245: import org.w3c.dom.Element;
raimund@245: import org.w3c.dom.Node;
raimund@245: import org.w3c.dom.NodeList;
raimund@245: 
ingo@1367: import org.apache.log4j.Logger;
ingo@1367: 
raimund@245: import com.google.gwt.user.server.rpc.RemoteServiceServlet;
raimund@245: 
raimund@245: import de.intevation.artifacts.common.ArtifactNamespaceContext;
raimund@245: import de.intevation.artifacts.common.utils.XMLUtils;
raimund@245: 
raimund@245: import de.intevation.artifacts.httpclient.exceptions.ConnectionException;
raimund@245: import de.intevation.artifacts.httpclient.http.HttpClient;
raimund@245: import de.intevation.artifacts.httpclient.http.HttpClientImpl;
raimund@245: 
raimund@245: import de.intevation.flys.client.shared.exceptions.ServerException;
raimund@245: import de.intevation.flys.client.client.services.WQInfoService;
raimund@245: import de.intevation.flys.client.shared.model.WQInfoObject;
raimund@245: import de.intevation.flys.client.shared.model.WQInfoObjectImpl;
raimund@245: 
raimund@245: 
raimund@245: /**
raimund@245:  * @author <a href="mailto:ingo.weinzierl@intevation.de">Ingo Weinzierl</a>
raimund@245:  */
raimund@245: public class WQInfoServiceImpl
raimund@245: extends      RemoteServiceServlet
raimund@245: implements   WQInfoService
raimund@245: {
ingo@1367:     private static final Logger logger =
ingo@1367:         Logger.getLogger(WQInfoServiceImpl.class);
ingo@1367: 
ingo@1367: 
raimund@245:     public static final String ERROR_NO_WQINFO_FOUND =
raimund@245:         "error_no_wqinfo_found";
raimund@245: 
raimund@245:     public static final String XPATH_WQS = "art:service/art:mainvalues/art:mainvalue";
raimund@245: 
raimund@245: 
raimund@245:     public WQInfoObject[] getWQInfo(
raimund@245:         String url,
raimund@245:         String locale,
raimund@245:         String river,
raimund@245:         double from,
raimund@245:         double to)
raimund@245:     throws ServerException
raimund@245:     {
ingo@1367:         logger.info("WQInfoServiceImpl.getWQInfo");
raimund@245: 
raimund@245:         Document doc = XMLUtils.newDocument();
raimund@245: 
raimund@245:         XMLUtils.ElementCreator ec = new XMLUtils.ElementCreator(
raimund@245:             doc,
raimund@245:             ArtifactNamespaceContext.NAMESPACE_URI,
raimund@245:             ArtifactNamespaceContext.NAMESPACE_PREFIX);
raimund@245: 
raimund@245:         Element mainvalues = ec.create("mainvalues");
raimund@245:         Element riverEl = ec.create("river");
raimund@245:         Element startEl = ec.create("start");
raimund@245:         Element endEl   = ec.create("end");
raimund@245: 
raimund@245:         riverEl.setTextContent(river);
raimund@245:         startEl.setTextContent(Double.valueOf(from).toString());
raimund@245:         endEl.setTextContent(Double.valueOf(to).toString());
raimund@245: 
raimund@245:         mainvalues.appendChild(riverEl);
raimund@245:         mainvalues.appendChild(startEl);
raimund@245:         mainvalues.appendChild(endEl);
raimund@245: 
raimund@245:         doc.appendChild(mainvalues);
raimund@245: 
raimund@245:         HttpClient client = new HttpClientImpl(url, locale);
raimund@245: 
raimund@245:         try {
raimund@245:             Document result = client.callService(url, "mainvalues", doc);
raimund@245: 
ingo@1367:             logger.debug("Extract wq info objects now.");
raimund@245:             WQInfoObject[] objects = extractWQInfoObjects(result);
raimund@245: 
raimund@245:             if (objects != null && objects.length > 0) {
raimund@245:                 return objects;
raimund@245:             }
raimund@245:         }
raimund@245:         catch (ConnectionException ce) {
ingo@1367:             logger.error(ce, ce);
raimund@245:         }
raimund@245: 
raimund@245:         throw new ServerException(ERROR_NO_WQINFO_FOUND);
raimund@245:     }
raimund@245: 
raimund@245: 
raimund@245:     /**
raimund@245:      * Extracts all wq info objects from <i>result</i> document.
raimund@245:      *
raimund@245:      * @param result The document retrieved by the server.
raimund@245:      *
raimund@245:      * @return a list of WQInfoObjects.
raimund@245:      */
raimund@245:     protected WQInfoObject[] extractWQInfoObjects(Document result)
raimund@245:     throws    ServerException
raimund@245:     {
raimund@245:         NodeList list = (NodeList) XMLUtils.xpath(
raimund@245:             result,
raimund@245:             XPATH_WQS,
raimund@245:             XPathConstants.NODESET,
raimund@245:             ArtifactNamespaceContext.INSTANCE);
raimund@245: 
raimund@245:         if (list == null || list.getLength() == 0) {
ingo@1367:             logger.warn("No wq info found.");
raimund@245: 
raimund@245:             throw new ServerException(ERROR_NO_WQINFO_FOUND);
raimund@245:         }
raimund@245: 
raimund@245:         int num = list.getLength();
ingo@1367:         logger.debug("Response contains " + num + " objects.");
raimund@245: 
raimund@245:         List<WQInfoObject> objects =
raimund@245:             new ArrayList<WQInfoObject>(num);
raimund@245: 
raimund@245:         for (int i = 0; i < num; i++) {
raimund@245:             WQInfoObject obj = buildWQInfoObject(list.item(i));
raimund@245: 
raimund@245:             if (obj != null) {
raimund@245:                 objects.add(obj);
raimund@245:             }
raimund@245:         }
raimund@245: 
ingo@1367:         logger.debug("Retrieved " + objects.size() + " wq values");
raimund@245: 
raimund@245:         return (WQInfoObject[])
raimund@245:             objects.toArray(new WQInfoObject[num]);
raimund@245:     }
raimund@245: 
raimund@245: 
raimund@245:     /**
raimund@245:      * Extracts information for a single wq info object and intializes an
raimund@245:      * WQInfoObject with them.
raimund@245:      *
raimund@245:      * @param node The node that contains the information.
raimund@245:      *
raimund@245:      * @return a valid WQInfoObject.
raimund@245:      */
raimund@245:     protected WQInfoObject buildWQInfoObject(Node node) {
raimund@245:         String name = XMLUtils.xpathString(
raimund@245:             node, "@name", ArtifactNamespaceContext.INSTANCE);
raimund@245: 
raimund@245:         String type = XMLUtils.xpathString(
raimund@245:             node, "@type", ArtifactNamespaceContext.INSTANCE);
raimund@245: 
raimund@245:         String value = XMLUtils.xpathString(
raimund@245:             node, "@value", ArtifactNamespaceContext.INSTANCE);
raimund@245: 
raimund@245: 
raimund@245:         if (name != null && type != null) {
raimund@245:             try {
raimund@245:                 return new WQInfoObjectImpl(
raimund@245:                     name,
raimund@245:                     type,
raimund@245:                     new Double(value));
raimund@245:             }
raimund@245:             catch (NumberFormatException nfe) {
ingo@1367:                 logger.warn(nfe.getLocalizedMessage());
raimund@245:             }
raimund@245:         }
raimund@245: 
ingo@1367:         logger.warn("Invalid wq info object found.");
raimund@245: 
raimund@245:         return null;
raimund@245:     }
raimund@245: }
raimund@245: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :