    001    //$HeadURL: https://svn.wald.intevation.org/svn/deegree/base/branches/2.4_testing/src/org/deegree/portal/standard/sos/control/DescribePlatformListener.java $
    002
    003    /*----------------------------------------------------------------------------
    004     This file is part of deegree, http://deegree.org/
    005     Copyright (C) 2001-2009 by:
    006       Department of Geography, University of Bonn
    007     and
    008       lat/lon GmbH
    009
    010     This library is free software; you can redistribute it and/or modify it under
    011     the terms of the GNU Lesser General Public License as published by the Free
    012     Software Foundation; either version 2.1 of the License, or (at your option)
    013     any later version.
    014     This library is distributed in the hope that it will be useful, but WITHOUT
    015     ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
    016     FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
    017     details.
    018     You should have received a copy of the GNU Lesser General Public License
    019     along with this library; if not, write to the Free Software Foundation, Inc.,
    020     59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
    021
    022     Contact information:
    023
    024     lat/lon GmbH
    025     Aennchenstr. 19, 53177 Bonn
    026     Germany
    027     http://lat-lon.de/
    028
    029     Department of Geography, University of Bonn
    030     Prof. Dr. Klaus Greve
    031     Postfach 1147, 53001 Bonn
    032     Germany
    033     http://www.geographie.uni-bonn.de/deegree/
    034
    035     e-mail: info@deegree.org
    036    ----------------------------------------------------------------------------*/
    037    package org.deegree.portal.standard.sos.control;
    038
    039    import java.util.HashMap;
    040    import java.util.Iterator;
    041
    042    import org.deegree.enterprise.control.RPCMethodCall;
    043    import org.deegree.enterprise.control.RPCParameter;
    044    import org.deegree.enterprise.control.RPCStruct;
    045    import org.deegree.framework.log.ILogger;
    046    import org.deegree.framework.log.LoggerFactory;
    047    import org.deegree.framework.xml.NamespaceContext;
    048    import org.deegree.framework.xml.XMLTools;
    049    import org.deegree.ogcbase.CommonNamespaces;
    050    import org.deegree.ogcwebservices.sos.describeplatform.PlatformMetadata;
    051    import org.deegree.ogcwebservices.sos.sensorml.Classifier;
    052    import org.deegree.ogcwebservices.sos.sensorml.ComponentDescription;
    053    import org.deegree.ogcwebservices.sos.sensorml.EngineeringCRS;
    054    import org.deegree.ogcwebservices.sos.sensorml.GeoPositionModel;
    055    import org.deegree.ogcwebservices.sos.sensorml.GeographicCRS;
    056    import org.deegree.ogcwebservices.sos.sensorml.Identifier;
    057    import org.deegree.ogcwebservices.sos.sensorml.LocationModel;
    058    import org.deegree.portal.standard.sos.Constants;
    059    import org.deegree.portal.standard.sos.SOSClientException;
    060    import org.w3c.dom.Document;
    061    import org.w3c.dom.Element;
    062
    063    /**
    064     * Listener for performing DescribePlatform requests against Sensor Observation Services.
    065     *
    066     * @author <a href="mailto:che@wupperverband.de.de">Christian Heier</a>
    067     * @version 0.1
    068     */
    069    public class DescribePlatformListener extends AbstractSOSListener {
    070
    071        private static final NamespaceContext nsContext = CommonNamespaces.getNamespaceContext();
    072
    073        private static final ILogger LOG = LoggerFactory.getLogger( DescribePlatformListener.class );
    074
    075        /**
    076         * validates the request to be performed.
    077         *
    078         * @param mc
    079         *            object containing the request to be performed
    080         */
    081        @Override
    082        protected void validateRequest( RPCMethodCall mc )
    083                                throws SOSClientException {
    084            RPCParameter[] params = mc.getParameters();
    085            if ( params == null || params.length != 1 ) {
    086                throw new SOSClientException( "one rpc parameter containing a struct "
    087                                              + "with requiered parameters must be set" );
    088            }
    089            RPCStruct struct = (RPCStruct) params[0].getValue();
    090            if ( struct.getMember( Constants.TYPENAME ) == null ) {
    091                // TODO "".equals( type value )
    092                throw new SOSClientException( "TypeName parameter must be set "
    093                                              + "to perform a Sensor Observation Service " + "DescribePlatform request" );
    094            }
    095
    096        }
    097
    098        /**
    099         * creates a SOS DescribePlatform request from the parameters contained in the passed
    100         * <tt>RPCMethodeCall</tt>.
    101         *
    102         * @param mc
    103         *            the RPCMethodCall
    104         * @return SOS DescribePlatform request
    105         * @throws SOSClientException
    106         */
    107        @Override
    108        protected String createRequest( RPCMethodCall mc )
    109                                throws SOSClientException {
    110
    111            RPCParameter[] params = mc.getParameters();
    112            RPCStruct struct = (RPCStruct) params[0].getValue();
    113
    114            StringBuffer sb = new StringBuffer( 1000 );
    115            sb.append( "<sos:DescribePlatform " );
    116            sb.append( "xmlns:sos='http://www.opengis.net/sos' " );
    117            sb.append( "outputFormat='SensorML' " );
    118            sb.append( "service='SOS' " );
    119            sb.append( "version='0.8.0'>" );
    120            sb.append( "<sos:TypeName>" );
    121            sb.append( struct.getMember( Constants.TYPENAME ).getValue() );
    122            sb.append( "</sos:TypeName>" );
    123            sb.append( "</sos:DescribePlatform>" );
    124            return sb.toString();
    125        }
    126
    127        /**
    128         * creates the result object to send to the next page from the parameters contained in the
    129         * passed <tt>RPCMethodeCall</tt> and the <tt>Document</tt> array.
    130         *
    131         * @param mc
    132         *            the RPCMethodCall
    133         * @param map
    134         *            the Document array
    135         * @return the data.
    136         */
    137        @Override
    138        protected Object createData( RPCMethodCall mc, HashMap<String, Document> map )
    139                                throws SOSClientException {
    140
    141            Identifier[] identifiedAs = null;
    142            Classifier[] classifiedAs = null;
    143            EngineeringCRS engineerCRS = null;
    144            LocationModel[] locatedUsing = null;
    145            ComponentDescription describedBy = null;
    146            String attachedTo = null;
    147            String[] carries = null;
    148
    149            PlatformMetadata[] platformDescriptions = new PlatformMetadata[map.size()];
    150
    151            int i = 0;
    152            try {
    153                Iterator<String> iterator = map.keySet().iterator();
    154                while ( iterator.hasNext() ) {
    155
    156                    String key = iterator.next();
    157                    Element e = map.get( key ).getDocumentElement();
    158
    159                    String[] ids = XMLTools.getNodesAsStrings(
    160                                                               e,
    161                                                               "/sml:Platforms/sml:Platform/sml:identifiedAs/sml:Identifier",
    162                                                               nsContext );
    163
    164                    identifiedAs = new Identifier[ids.length];
    165                    for ( int j = 0; j < ids.length; j++ ) {
    166                        identifiedAs[i] = new Identifier( ids[i] );
    167                    }
    168
    169                    String srcSRS = XMLTools.getNodeAsString(
    170                                                              e,
    171                                                              "/sml:Platforms/sml:Platform/sml:locatedUsing/sml:GeoPositionModel/sml:sourceCRS/gml:EngineeringCRS/gml:srsName",
    172                                                              nsContext, null );
    173
    174                    String refSRS = XMLTools.getNodeAsString(
    175                                                              e,
    176                                                              "/sml:Platforms/sml:Platform/sml:locatedUsing/sml:GeoPositionModel/sml:sourceCRS/gml:GeographicCRS/gml:srsName",
    177                                                              nsContext, null );
    178
    179                    locatedUsing = new LocationModel[1];
    180                    locatedUsing[0] = new GeoPositionModel( null, null, null, null, new EngineeringCRS( srcSRS ),
    181                                                            new GeographicCRS( refSRS ), new Object[0] );
    182
    183                    carries = XMLTools.getNodesAsStrings( e, "/sml:Platforms/sml:Platform/sml:carries/sml:Asset", nsContext );
    184
    185                    platformDescriptions[i] = new PlatformMetadata( identifiedAs, classifiedAs, engineerCRS, locatedUsing,
    186                                                                    describedBy, attachedTo, carries );
    187
    188                    i++;
    189                }
    190
    191            } catch ( Exception e ) {
    192                LOG.logError( "Error creating platform descriptions: " + e.getMessage() );
    193                throw new SOSClientException( "Couldn't create platform descriptions", e );
    194            }
    195            return platformDescriptions;
    196        }
    197
    198        @Override
    199        protected void setNextPageData( Object o ) {
    200            this.getRequest().setAttribute( Constants.PLATFORMDESCRIPTION, o );
    201        }
    202
    203    }