Application: gvSIG desktop

/*

 * ============================================================================

 * Copyright 2006 Government of Canada

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *     http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * ============================================================================

*/

/*

 $Id: 

 $HeadURL: 

*/

/*

   **    **  *******   *****       *****    **   **     *****  

   **    **        ** **   **     **   **   **   **    **   ** 

   ** ** **  **    ** **          **  ***   **   **    **  *** 

   ** ** **  *******   *****      ** * **   **   **    ** * ** 

   ** ** **  **            **     ***  **   *******    ***  ** 

   ** ** **  **       **   **     **   ** **     ** ** **   ** 

    *******  **        *****       *****  **     ** **  *****  

 Generated from WPS 0.4.0 Code Generator Tool version 0.9.0 at Thu Feb 21 12:05:11 GMT+01:00 2008 By PS, RC, MC

*/

package org.tigris.frogs.plugin.wpsint.impl_0_4_0.operation.streetsmap;

import java.awt.geom.Rectangle2D;

import java.io.*;

import java.math.BigInteger;

import java.util.Iterator;

import java.util.List;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.tigris.frogs.InitParameters;

import org.tigris.frogs.OWSExceptionVersion1_0_0;

import org.tigris.frogs.commons.*;

import org.tigris.frogs.plugin.wpsint.impl_0_4_0.*;

import org.tigris.frogs.plugin.wpsint.impl_0_4_0.DataOutputsType.ValueFormChoice;

import org.tigris.frogs.StandardSessionDataRequested;

import es.logex.callejero.core.Callejero;

import es.logex.callejero.core.LayerFile;

import es.logex.callejero.modelo.BoundingBox;

import es.logex.utils.Manager;

import es.logex.utils.WPSConfiguration;

 /**

  * To be documented 

  *

  */

public class Process_GetMap extends ProcessDeclarationRunnable {

    //         Logger object for logging in this class

        protected final Log logger = LogFactory.getLog(getClass());

        // ---- DESCRIBEPROCESS REQUEST/RESPONSE SECTION

        private final static String VERSION = "0.1.0";

        private final static String PROCESSNAME = "GetMap";

        private InputType[] inputs = null;

        private OutputType[] outputs = null;

        private org.tigris.frogs.ows.CodeType codeProcess = null;

        // ---- EXECUTE REQUEST/RESPONSE SECTION

        private org.tigris.frogs.ows.ExceptionReportType processFailedExceptionReport = null;

        private DataOutputsType[] responseProcessOutputs = null;

        private ExecuteRequestType executeProcess = null;

        private ByteArrayOutputStream pureOutBytes = null;

        private boolean sendXMLResponseBack = true;

        private LocalizationTextProcess textProcess = null;

        // INPUTS and OUTPUTS defined

        private InputType argInputdetailLevel = null;

        private InputType argInputlayerName = null;

        private InputType argInputbBox = null;

        private OutputType argOutputUrisOut = null;

        /* (non-Javadoc)

         * @see org.tigris.frogs.plugin.wpsint.impl_0_4_0.ProcessDeclarationRunnable#initialize(java.lang.String)

         */

        public void initialize() throws  OWSExceptionVersion1_0_0, Throwable {

                // Create Text Object to retrieve Localization Info

                this.textProcess = new LocalizationTextProcess(PROCESSNAME);

       this.textProcess.setLanguage( getOperationLanguage() );

                // Define the process name

                this.codeProcess = new org.tigris.frogs.plugin.wpsint.Code();

                this.codeProcess.setValue( PROCESSNAME );

                // Create all inputs and outputs

                this.argInputdetailLevel = getInputdetailLevel();

                this.argInputlayerName = getInputlayerName();

                this.argInputbBox = getInputbBox();

                this.argOutputUrisOut = getOutputUrisOut();

                // Put as many Input you want to be used for your process

                this.inputs = new InputType[] {

                                this.argInputdetailLevel,

                                this.argInputlayerName,

                                this.argInputbBox,

                                        };                

                // Put as many Ouput you want to be served for output

                this.outputs = new OutputType[] {

                                this.argOutputUrisOut,

                                        };

        }

        /* (non-Javadoc)

         * @see org.tigris.frogs.plugin.wpsint.impl_0_4_0.ProcessDeclarationRunnable#test()

         */

        public void test() throws  org.tigris.frogs.OWSExceptionVersion1_0_0, Throwable {

                // Put your operation unit test here

        }

     /**

      * To be documented

      *

      * @param newExecuteProcess

      * @throws  org.tigris.frogs.OWSExceptionVersion1_0_0

      * @throws Throwable

      *

      */

    public void run(ExecuteRequestType newExecuteProcess) throws OWSExceptionVersion1_0_0, Throwable {

             // Compute Elapse Time Total end-to-end

        long startTimeTotal = System.currentTimeMillis();

        String elapse;

        String inputLayerName = "";

        // Don't try exception, it will be catch by the PlugIn

        this.executeProcess = newExecuteProcess;

        // Always direct answer if a direct response to the client is asked with no possibility to store

        this.sendXMLResponseBack = true;

        try {

                         Callejero callejero = null;

                Rectangle2D rec2D = null;

                         inputLayerName = getInputValue(this.argInputlayerName, "");

                         Double[] lowersExtent = WpsUtils.getRequestInputLowerCorner(this.argInputbBox,this.executeProcess);

                         Double[] uppersExtent = WpsUtils.getRequestInputUpperCorner(this.argInputbBox,this.executeProcess);

                         String crsExtent = WpsUtils.getRequestInputCrs(this.argInputbBox,this.executeProcess);

                         BigInteger dimensionsExtent = WpsUtils.getRequestInputDimensions(this.argInputbBox,this.executeProcess);

                         String inputDetailLevel = getInputValue(this.argInputdetailLevel, "");

                         if ( this.executeProcess.isSimulation() ) {

                       // This flag indicates that you are being called from the main.

                       // Useful to test different scenario without any call from the Internet

                //OutputComplexData ocd = new OutputComplexData();

                ValueFormChoice value = DataOutputs.newValueFormChoiceImpl();

                ExecuteComplexDataReference ecd = new ExecuteComplexDataReference();

                ecd.setReference("http://www.logex.es");

                value.setComplexValueReferenceOr(ecd);

                DataOutputs dataOutputs = new DataOutputs();

                dataOutputs.setOutputFormChoice(value);

                responseProcessOutputs = new DataOutputsType[] {  dataOutputs };

            }

            else {

                // Send XML directly to the client. Might override your behavior asked. Just remove it

               //  this.sendXMLResponseBack = false;

                Manager mgr = Manager.getInstance();

                                  /* if (inputLayerName == null || inputLayerName == "") {

                                           //devolvemos todas las layers.

                                          List list = WPSConfiguration.getInstance().getLayerList();

                                           responseProcessOutputs = new DataOutputsType[list.size()];

                                          Iterator itr = list.iterator();

                                          int i = 0;

                                          while (itr.hasNext()) {

                                                  String layerName = (String)itr.next();

                                                  if (lowersExtent[0] == 0 && lowersExtent[1] == 0 && 

                                                      uppersExtent[0] == 0 && uppersExtent[1] == 0) {

                                              //coger el máximo extent de la capa.

                                              callejero = new Callejero(mgr.connect());

                                              rec2D = callejero.getMaxExtent(layerName);

                                              lowersExtent[0] = rec2D.getMinX();

                                              lowersExtent[1] = rec2D.getMinY();

                                              uppersExtent[0] = rec2D.getMaxX();

                                              uppersExtent[1] = rec2D.getMaxY();

                                     }

                                      BoundingBox box = new BoundingBox(lowersExtent, uppersExtent,crsExtent);

                                                   LayerFile layer = new LayerFile(layerName, mgr.connect());

                                                     File file = layer.FromDbToFile(box);

                                                     ValueFormChoice value = DataOutputs.newValueFormChoiceImpl();

                                   ExecuteComplexDataReference ecd = new ExecuteComplexDataReference(WPSConfiguration.getInstance().getHost() + file.getName(),        null, "UTF-8", "");

                                   value.setComplexValueReferenceOr(ecd);

                                   DataOutputs dataOutputs = new DataOutputs();

                                 dataOutputs.setOutputFormChoice(value);

                                 responseProcessOutputs[i] = dataOutputs;

                                 layer = null;

                                 i++;

                                          }

                                   } else {*/

                                          /*if (lowersExtent[0] == 0 && lowersExtent[1] == 0 && 

                                              uppersExtent[0] == 0 && uppersExtent[1] == 0) {

                                      //coger el máximo extent de la capa.

                                      callejero = new Callejero(mgr.connect());

                                      rec2D = callejero.getMaxExtent(inputLayerName);

                                      lowersExtent[0] = rec2D.getMinX();

                                      lowersExtent[1] = rec2D.getMinY();

                                      uppersExtent[0] = rec2D.getMaxX();

                                      uppersExtent[1] = rec2D.getMaxY();

                             } */

                     BoundingBox box = new BoundingBox(lowersExtent, uppersExtent,crsExtent);

                             LayerFile layer = new LayerFile(inputLayerName, mgr.connect());

                                           File file = layer.FromDbToFile(box);

                                           ValueFormChoice value = DataOutputs.newValueFormChoiceImpl();

                         ExecuteComplexDataReference ecd = new ExecuteComplexDataReference(WPSConfiguration.getInstance().getHost() + file.getName(),        null, "UTF-8", "");

                         value.setComplexValueReferenceOr(ecd);

                         DataOutputs dataOutputs = new DataOutputs();

                         dataOutputs.setOutputFormChoice(value);

                         responseProcessOutputs = new DataOutputsType[] {  dataOutputs };

                                   }

        }

        // These error must be sent as is to the client

        // start

        /*catch (OWSException ex) {

            throw ex;

        }*/

        // end

        // If we reach this point, the error can't be handled properly

        // You could fine tune your exception handling

        // start

        catch (Throwable ex) {

            warn("Throwable in running this class [" + this.getClass().getName() + "]");

            throw new StreetsMapException("General", getOperationLanguage(), ex);

        }

        // end

        finally {

            long endTimeTotal = System.currentTimeMillis();

            elapse = Long.toString( endTimeTotal - startTimeTotal );

            warn(this.getClass().getName() + " elapsed time total:" + elapse);

        }

    }

    @Override

    public  boolean isProcessSucceeded() { 

            return true;

    }

    @Override 

    public boolean isProcessAccepted(){

            return false;

    }

    @Override 

    public boolean isProcessStarted(){

            return false;

    }

    /* (non-Javadoc)

     * @see org.tigris.frogs.plugin.wpsint.impl_0_4_0.ProcessDeclarationRunnable#terminate()

     */

    public void terminate() {

        // Clean Up: You should cleanp all your objects before leaving

        // Loop inputs and outputs

        this.argInputdetailLevel = null;

        this.argInputlayerName = null;

        this.argInputbBox = null;

        this.argOutputUrisOut = null;

        if ( this.inputs != null ) {

            for (int index=0; index<this.inputs.length; index++)

                this.inputs[index] = null;

            this.inputs = null;

        }

        if ( this.outputs != null ) {

            for (int index=0; index<this.outputs.length; index++)

                this.outputs[index] = null;

            this.outputs = null;

        }

        this.textProcess = null;

    }

    /**

      * To be documented

      *

      * @return org.tigris.frogs.ows.CodeType

      *

      */

    public org.tigris.frogs.ows.CodeType getIdentifier() {

        return this.codeProcess;

    }

     /* (non-Javadoc)

     * @see org.tigris.frogs.plugin.wpsint.impl_0_4_0.ProcessDeclaration#getAbstract()

     */

    public String getAbstract() {

        return this.textProcess.getAbstract();

    }

    /* (non-Javadoc)

     * @see org.tigris.frogs.plugin.wpsint.impl_0_4_0.ProcessDeclaration#getTitle()

     */

    public String getTitle() {

        return this.textProcess.getTitle();

    }

     /**

      * To be documented

      *

      * @return String

      *

      */

    public String getVersion() {

        return VERSION;

    }

     /**

      * To be documented

      *

      * @return InputType[]

      *

      */

    public InputType[] getInputs() {

        return this.inputs;

    }

     /**

      * To be documented

      *

      * @return OutputType[]

      *

      */

    public OutputType[] getOutputs() {

        return this.outputs;

    }

     /**

      * To be documented

      *

      * @return org.tigris.frogs.ows.ExceptionReportType

      *

      */

    public org.tigris.frogs.ows.ExceptionReportType getProcessFailedExceptionReport() {

        return this.processFailedExceptionReport;

    }

     /**

      * To be documented

      *

      * @return DataOutputsType[]

      *

      */

    public DataOutputsType[] getResponseDataOutputs() {

        return this.responseProcessOutputs;

    }

     /**

      * To be documented

      *

      * @return ByteArrayOutputStream

      *

      */

    public ByteArrayOutputStream getOut() {

        return this.pureOutBytes;

    }

     /**

      * To be documented

      *

      * @return boolean

      *

      */

    public boolean isSendXMLResponseBack() {

        return this.sendXMLResponseBack;

    }

     /**

      * To be documented

      *

      * @return String

      *

      */

    public String getOutCharset() {

        return "UTF-8";

    }

     /**

      * To be documented

      *

      * @return String

      *

      */

    public String getOutMimeType() {

        return "text/xml";

    }

    public boolean getStoreSupported() {

        return true;

    } 

     /**

      * To be documented

      *

      * @return boolean

      *

      */

    public boolean getStatusSupported() {

        return true;

    }

         /**

          * To be documented

          *

          * @return InputType

          *

          */

        static final String FIELD_NAME_detailLevel = "detailLevel";

        private InputType getInputdetailLevel() {

                // // Optional

                Input input = new Input(FIELD_NAME_detailLevel,false);

                input.setAbstract( textProcess.getFieldAbstract(FIELD_NAME_detailLevel) );

                input.setTitle( textProcess.getFieldTitle(FIELD_NAME_detailLevel) );

                WpsUtils.createLiteralValue(input,null,null,null,null,false);

                return input;

        }

         /**

          * To be documented

          *

          * @return InputType

          *

          */

        static final String FIELD_NAME_layerName = "layerName";

        private InputType getInputlayerName() {

                // // Optional

                Input input = new Input(FIELD_NAME_layerName,false);

                input.setAbstract( textProcess.getFieldAbstract(FIELD_NAME_layerName) );

                input.setTitle( textProcess.getFieldTitle(FIELD_NAME_layerName) );

                WpsUtils.createLiteralValue(input,null,null,null,null,false);

                return input;

        }

         /**

          * To be documented

          *

          * @return InputType

          *

          */

        static final String FIELD_NAME_bBox = "bBox";

        private InputType getInputbBox() {

                // // Mondatory

                Input input = new Input(FIELD_NAME_bBox,true);

                input.setAbstract( textProcess.getFieldAbstract(FIELD_NAME_bBox) );

                input.setTitle( textProcess.getFieldTitle(FIELD_NAME_bBox) );

                WpsUtils.createBoundingBoxValue(input,null,null);

                return input;

        }        

         /**

          * To be documented

          *

          * @return OutputType

          *

          */

        static final String FIELD_NAME_UrisOut = "UrisOut";

        private OutputType getOutputUrisOut() {

                Output output = new Output(FIELD_NAME_UrisOut);

                output.setAbstract( textProcess.getFieldAbstract(FIELD_NAME_UrisOut) );

                output.setTitle( textProcess.getFieldTitle(FIELD_NAME_UrisOut) );

                WpsUtils.createComplexData(output,getOutMimeType(),getOutCharset(),"");

                return output;

        }

         /**

          * To be documented

          *

          * @param inputParameter

          * @param defaultValue

          * @return String

          *

          */

        private String getInputValue(

                        InputType inputParameter,

                        String defaultValue        ) {

                Object[] Field_Method_Values =        WpsUtils.getRequestInputValue(inputParameter, this.executeProcess);

                if ( ! Utils.isEmptyObject(Field_Method_Values) )

                        return (String)Field_Method_Values[0];

                else

                        return defaultValue;

        }

         /**

          * To be documented

          *

          * @param inputParameter

          * @param defaultValue

          * @return String

          *

          */

        private String getInputFormat(

                        InputType inputParameter,

                        String defaultValue        ) {

                String value =        WpsUtils.getRequestInputFormat(inputParameter,this.executeProcess);

                if ( ! Utils.isEmptyString(value) )

                        return value;

                else

                        return defaultValue;

        }

         /**

          * To be documented

          *

          * @param inputParameter

          * @param defaultValue

          * @return String

          *

          */

        private String getInputEncoding(

                        InputType inputParameter,

                        String defaultValue        ) {

                String value = WpsUtils.getRequestInputEncoding(inputParameter,this.executeProcess);

                if ( ! Utils.isEmptyString(value) )

                        return value;

                else

                        return defaultValue;

        }

    /**

     * Message to display in debug mode

     *

     * @param message

     *

     */

   private void log(String message) {

                if ( logger.isTraceEnabled() ) { logger.debug(message) ; }

   }

   /**

    * Message to display in warning mode with a tracable Exception

    *

    * @param message

    * @param exception

    *

    */

   private void warn(String message) {

           logger.warn(message);

   }

    /**

     * Message to display in error mode with a tracable Exception

     *

     * @param message

     * @param exception

     *

     */

   private void error(String message, Throwable ex) {

                logger.error(message,ex);

   }

   /**

    * Main Unit Test without be invked by the FROGS Framework

    */

   public static void main(String[] args) {

       System.out.println("Simulating from main...");

       try {

           InitParameters inits = new InitParameters();

           // If needed

           //inits.add("name", "value", "decription");

           ProcessDeclarationRunnable.simulateCallProcess

                    (

                                                new StandardSessionDataRequested(

                                                                "http://server/test123",

                                                                "http://server/test123",

                                                                org.tigris.frogs.plugin.wpsint.Constants.REQUEST_EXECUTE,

                                                                StandardSessionDataRequested.NOT_DEFINED_YET,

                                                                StandardSessionDataRequested.NOT_DEFINED_YET,

                                                                StandardSessionDataRequested.NOT_DEFINED_YET,

                                                                StandardSessionDataRequested.NOT_DEFINED_YET,

                                                                false,false,false,

                                                                Language.getDefaultCode()),

                       inits,

                       new Process_GetMap(),

                       new SimulateDataValueType[] {

                           new SimulateDataValueLiteral(FIELD_NAME_detailLevel, "test", null, null)

,                           new SimulateDataValueLiteral(FIELD_NAME_layerName, "test", null, null)

,                           new SimulateDataValueBoundingBox(FIELD_NAME_bBox, new Double[] { new Double(0), new Double(1) }, new Double[] { new Double(3), new Double(4) }, new java.math.BigInteger("2"), "EPSG" )

,                       }

                   );

           System.out.println("Execute done!");

       }

       // Throw Error

       catch (Throwable ex) {

           System.err.println("nop???");

       }

       System.out.println("Over!!!");

   }

}