Application: gvSIG desktop

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 gvSIG Association.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 3

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

package org.gvsig.remoteclient.wfs.wfs_1_0_0.request;

import java.util.Iterator;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

import org.gvsig.remoteclient.wfs.WFSProtocolHandler;

import org.gvsig.remoteclient.wfs.WFSStatus;

import org.gvsig.remoteclient.wfs.edition.IWFSTOperation;

import org.gvsig.remoteclient.wfs.edition.WFSTInsertOperation;

import org.gvsig.remoteclient.wfs.edition.WFSTTags;

import org.gvsig.remoteclient.wfs.edition.WFSTTransaction;

import org.gvsig.remoteclient.wfs.edition.WFSTUpdateOperation;

import org.gvsig.remoteclient.wfs.filters.filterencoding.FilterEncoding;

import org.gvsig.remoteclient.wfs.request.WFSTransactionRequest;

/**

 * @author gvSIG Team

 * @version $Id$

 *

 */

public class WFSTransactionRequest1_0_0 extends WFSTransactionRequest{

    /**

     * @param status

     * @param protocolHandler

     */

    public WFSTransactionRequest1_0_0(WFSStatus status,

        WFSProtocolHandler protocolHandler) {

        super(status, protocolHandler);      

    }

    protected String getHttpGetRequest(String onlineResource) {

        // TODO Auto-generated method stub

        return null;

    }

    protected String getHttpPostRequest(String onlineResource) {

        StringBuffer request = new StringBuffer();

        addHttpPostHeaderRequest(request);

        //Add the operations

        WFSTTransaction transaction = status.getTransaction();

        //Insert operations

        for (int i=0 ; i<transaction.getInsertOperationSize() ; i++){

            addInsertOperation(transaction.getInseOperationAt(i), request);            

        }

        //Update operations

        for (int i=0 ; i<transaction.getUpdateOperationSize() ; i++){

            addUpdateOperation(transaction.getUpdateOperationAt(i), request);            

        }

        //Delete operations. All of them in just one operation

        if (transaction.getDeleteOperationSize() > 0){            

            IWFSTOperation firstOperation = transaction.getDeleteOperationAt(0);

            addOperationHeader(firstOperation, request);

            FilterEncoding filterEncoding = new FilterEncoding(status);

            filterEncoding.setQualified(true);

            for (int i=0 ; i<transaction.getDeleteOperationSize() ; i++){               

                filterEncoding.addFeatureById(transaction.getDeleteOperationAt(i).getId());       

            }

            request.append(filterEncoding.toString(protocolHandler.getVersion()));

            addOperationEnd(firstOperation, request);

        }

        addHttpPostEndRequest(request);

        return request.toString();

    }

    private void addOperationHeader(IWFSTOperation operation, StringBuffer request){

        request.append("<" + CapabilitiesTags.WFS_NAMESPACE_PREFIX + ":");

        request.append(operation.getOperationName());

        if (operation.hasTypeName()){

            request.append(" typeName=\"" + status.getFeatureFullName() + "\"");

        }

        request.append(">");      

    }

    private void addOperationEnd(IWFSTOperation operation, StringBuffer request){

        request.append("</" + CapabilitiesTags.WFS_NAMESPACE_PREFIX + ":");

        request.append(operation.getOperationName() + ">");

    }

    private void addInsertOperation(WFSTInsertOperation insertOperation, StringBuffer request){

        addOperationHeader(insertOperation, request);

        request.append(createXMLStartTag(status.getFeatureFullName()));

        Iterator it = insertOperation.getKeysIterator();

        while (it.hasNext()){

            String attName = (String)it.next();

            request.append(createXMLStartTag(status.getNamespacePrefix() + ":" + attName));

            request.append(insertOperation.getValue(attName));

            request.append(createXMLEndtTag(status.getNamespacePrefix() + ":" + attName));

        }   

        request.append(createXMLEndtTag(status.getFeatureFullName()));

        addOperationEnd(insertOperation, request);

    }

    private void addUpdateOperation(WFSTUpdateOperation updateOperation, StringBuffer request){

        addOperationHeader(updateOperation, request);

        Iterator it = updateOperation.getKeysIterator();        

        while (it.hasNext()){

            String attName = (String)it.next();

            request.append(createXMLStartTag(UPDATE_PROPERTY_TAG));

            request.append(createXMLStartTag(UPDATE_NAME_TAG));

            request.append(status.getNamespacePrefix() + ":" + attName);

            request.append(createXMLEndtTag(UPDATE_NAME_TAG));

            request.append(createXMLStartTag(UPDATE_VALUE_TAG));

            request.append(updateOperation.getValue(attName));

            request.append(createXMLEndtTag(UPDATE_VALUE_TAG));           

            request.append(createXMLEndtTag(UPDATE_PROPERTY_TAG));

        }  

        //Add the filter encoding

        FilterEncoding filterEncoding = new FilterEncoding(status);

        filterEncoding.setQualified(true);

        filterEncoding.addFeatureById(updateOperation.getId());       

        request.append(filterEncoding.toString(protocolHandler.getVersion()));

        addOperationEnd(updateOperation, request);

    }

    private void addHttpPostHeaderRequest(StringBuffer request){       

        request.append(WFSTTags.XML_ROOT);

        request.append("<" + WFSTTags.WFS_NAMESPACE_PREFIX + ":");

        request.append(CapabilitiesTags.WFS_TRANSACTION + " ");

        request.append(CapabilitiesTags.VERSION + "=\"" + protocolHandler.getVersion() + "\" ");

        request.append(WFSTTags.WFST_RELEASEACTION + "=\"ALL\" ");

        request.append(WFSTTags.WFST_SERVICE + "=\"WFS\" ");

        request.append(WFSTTags.XMLNS + ":" + WFSTTags.OGC_NAMESPACE_PREFIX);

        request.append("=\"" + WFSTTags.OGC_NAMESPACE + "\" ");

        request.append(WFSTTags.XMLNS + ":" + WFSTTags.WFS_NAMESPACE_PREFIX);

        request.append("=\"" + WFSTTags.WFS_NAMESPACE + "\" ");

        request.append(WFSTTags.XMLNS + ":" + WFSTTags.XML_NAMESPACE_PREFIX);

        request.append("=\"" + WFSTTags.XML_NAMESPACE + "\" ");

        request.append(WFSTTags.XMLNS + ":" + WFSTTags.GML_NAMESPACE_PREFIX);

        request.append("=\"" + WFSTTags.GML_NAMESPACE + "\" ");

        request.append(WFSTTags.XMLNS + ":" + status.getNamespacePrefix());

        request.append("=\"" + status.getNamespaceLocation() + "\" ");        

        request.append(WFSTTags.XML_NAMESPACE_PREFIX + ":" + WFSTTags.XML_SCHEMALOCATION);

        request.append("=\"" + WFSTTags.WFS_NAMESPACE + " ");

        request.append(getSchemaLocation());

        request.append("\">");       

    }  

    private void addHttpPostEndRequest(StringBuffer request){       

        request.append("</" + WFSTTags.WFS_NAMESPACE_PREFIX + ":");

        request.append(CapabilitiesTags.WFS_TRANSACTION + ">");

    }

    protected String getSchemaLocation() {  

        return "../wfs/1.0.0/WFS-transaction.xsd";

    }

}