gvSIG projects pool

package org.gvsig.busquedacatastral.lib.impl;

import java.io.File;

import java.util.List;

import javax.xml.rpc.ServiceException;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.busquedacatastral.lib.api.BusquedaCatastralManager;

import org.gvsig.busquedacatastral.lib.api.exceptions.BusquedaCatastralException;

import org.gvsig.busquedacatastral.lib.api.exceptions.BusquedaCatastralGettingParamsException;

import org.gvsig.busquedacatastral.lib.api.exceptions.BusquedaCatastralRemoteServiceException;

import org.gvsig.busquedacatastral.lib.impl.ws.CallejeroCatastroWSLocator;

import org.gvsig.busquedacatastral.lib.impl.ws.CallejeroCatastroWSSoap;

import org.gvsig.busquedacatastral.lib.impl.ws.classes.cxf.Err;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.ValidateDataParametersException;

import org.gvsig.fmap.dal.feature.EditableFeatureType;

import org.gvsig.fmap.dal.feature.FeatureQuery;

import org.gvsig.fmap.dal.feature.FeatureSet;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.NewFeatureStoreParameters;

import org.gvsig.fmap.dal.feature.paging.FeaturePagingHelper;

import org.gvsig.fmap.dal.serverexplorer.filesystem.FilesystemServerExplorer;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.DynObject;

import org.gvsig.tools.exception.BaseException;

import org.gvsig.tools.i18n.I18nManager;

import org.gvsig.tools.locator.LocatorException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * Used for classes wich need data from the webservice.

 * Offers methods to manage webservice and cache files

 * @author dmartinezizquierdo

 *

 */

public  abstract class WSObjectsFactory {

    private static final Logger logger = LoggerFactory

        .getLogger(WSObjectsFactory.class);

    private final static String DBF_PROVIDER_NAME="DBF";

    protected BusquedaCatastralManager manager;

    protected WSObjectsFactory(BusquedaCatastralManager manager){

        this.manager=manager;

    }

    protected CallejeroCatastroWSSoap getCatastroWS() throws BusquedaCatastralException{

        try {

            CallejeroCatastroWSLocator locator=

                new CallejeroCatastroWSLocator();

            CallejeroCatastroWSSoap callejeroWS =

                locator.getCallejeroCatastroSoap();

            return callejeroWS;

        } catch (ServiceException e) {

            logger.error("Error obtaining webservice",e);

            I18nManager i18nManager = ToolsLocator.getI18nManager();

            throw new BusquedaCatastralRemoteServiceException(i18nManager.getTranslation("_error_obtaining_catastro_webservice"), e);

        }

    }

    protected void createDBF(File file)

        throws BusquedaCatastralException{

        FeatureStore dbfStore = null;

        try {

            if (!file.exists()) {

                File folder=file.getParentFile();

                if (!folder.exists()){

                    folder.mkdirs();

                }

            }

            DataManager datamanager = DALLocator.getDataManager();

            DataServerExplorerParameters explorerParameters =

                (DataServerExplorerParameters) datamanager

                    .createServerExplorerParameters(FilesystemServerExplorer.NAME);

            FilesystemServerExplorer explorer =

                (FilesystemServerExplorer) datamanager.openServerExplorer(

                    FilesystemServerExplorer.NAME, explorerParameters

                    );

            NewFeatureStoreParameters addParams = (NewFeatureStoreParameters) explorer.getAddParameters(DBF_PROVIDER_NAME);

            addParams.setDynValue("DbfFile",file);

            EditableFeatureType type = addParams.getDefaultFeatureType();

            defineType(type);

            explorer.add(DBF_PROVIDER_NAME, addParams, true);

            DataStoreParameters parameters = datamanager.createStoreParameters(DBF_PROVIDER_NAME);

            parameters.setDynValue("DbfFile", file);

            dbfStore =

                (FeatureStore) datamanager.openStore(DBF_PROVIDER_NAME, parameters);

            dbfStore.edit(FeatureStore.MODE_APPEND);

            writeFileData(dbfStore);

            dbfStore.finishEditing();

            dbfStore.dispose();

        } catch (BusquedaCatastralException  e) {

            logger.error("Error getting feature store");

            I18nManager i18nManager = ToolsLocator.getI18nManager();

            if(dbfStore!=null && dbfStore.isEditing()) {

                try {

                    dbfStore.cancelEditing();

                } catch (DataException e1) {

                    logger.error("Error cancelling edition of feature store");

                    throw new BusquedaCatastralGettingParamsException(i18nManager.getTranslation("_error_cancelling_edition_of_feature_store"),e);

                }

            }

            throw e;

        } catch (Exception  e) {

            logger.error("Error getting feature store");

            I18nManager i18nManager = ToolsLocator.getI18nManager();

            if(dbfStore!=null && dbfStore.isEditing()) {

                try {

                    dbfStore.cancelEditing();

                } catch (DataException e1) {

                    logger.error("Error cancelling edition of feature store");

                    throw new BusquedaCatastralGettingParamsException(i18nManager.getTranslation("_error_cancelling_edition_of_feature_store"),e);

                }

            }

            throw new BusquedaCatastralGettingParamsException(i18nManager.getTranslation("_error_getting_feature_store"),e);

        }

    }

    protected List<DynObject> getListFromDBF(File file) throws BaseException {

        DataManager datamanager = DALLocator.getDataManager();

        DataStoreParameters parameters = datamanager.createStoreParameters(DBF_PROVIDER_NAME);

        parameters.setDynValue("DbfFile", file);

        FeatureStore dbf = (FeatureStore) datamanager.openStore(DBF_PROVIDER_NAME, parameters);

        String expressionQuery=getExpressionQuery();

        FeaturePagingHelper pager;

        if(StringUtils.isEmpty(expressionQuery)){

            pager = datamanager.createFeaturePagingHelper(dbf, 500);

        }else{

            FeatureQuery featureQuery = dbf.createFeatureQuery();

            featureQuery.setFilter( datamanager.createExpresion(expressionQuery) );

            pager = datamanager.createFeaturePagingHelper(dbf,featureQuery, 500);

        }

        return pager.asListOfDynObjects();

    }

    protected void webserviceErrors(List<Err>errores) throws BusquedaCatastralException{

        if (errores!=null && !errores.isEmpty()){

            StringBuilder descErrores=new StringBuilder();

            I18nManager i18nManager = ToolsLocator.getI18nManager();

            descErrores.append(i18nManager.getTranslation("_errors_found_by_ws")+":");

            for (Err error:errores){

                descErrores.append("\n"+error.getDes());

                logger.error(descErrores.toString());

                throw new BusquedaCatastralGettingParamsException(descErrores.toString(), null);

            }

        }

    }

    abstract protected void defineType(EditableFeatureType type) throws BusquedaCatastralException;

    abstract protected void writeFileData(FeatureStore featureStore) throws BusquedaCatastralException, DataException;

    abstract protected String getExpressionQuery();

}