Application: gvSIG desktop

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * 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 2

 * 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.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2008 Prodevelop S.L. main development

 */

package org.gvsig.geocoding.tasks;

import org.gvsig.andami.PluginServices;

import org.gvsig.fmap.dal.DataStore;

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

import org.gvsig.geocoding.Geocoder;

import org.gvsig.geocoding.GeocodingLocator;

import org.gvsig.geocoding.address.Literal;

import org.gvsig.geocoding.extension.GeocodingController;

import org.gvsig.geocoding.impl.LuceneGeocoderImpl;

import org.gvsig.geocoding.index.FeatureIndexedEvent;

import org.gvsig.geocoding.index.IndexListener;

import org.gvsig.geocoding.utils.GeocodingUtils;

import org.gvsig.utils.swing.threads.AbstractMonitorableTask;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * Geocoding task in background

 * 

 * @author <a href="mailto:jsanz@prodevelop.es"> Jorge Gaspar Sanz Salinas</a>

 * @author <a href="mailto:vsanjaime@prodevelop.es"> Vicent Sanjaime Calvet</a>

 */

public class IndexingTask extends AbstractMonitorableTask implements

                IndexListener {

        private static final Logger log = LoggerFactory

                        .getLogger(IndexingTask.class);

        private GeocodingController control;

        private long finalStep;

        private Geocoder geoco = null;

        private DataStore store = null;        

        private String textTask;

        /**

         * Constructor task

         * 

         * @param control

         */

        @SuppressWarnings("static-access")

        public IndexingTask(GeocodingController control) {

                this.control = control;

                // configure task

                setInitialStep(0);

                setStatusMessage(PluginServices.getText(this, "indexingrun"));

                setDeterminatedProcess(true);

                //

                GeocodingLocator loc = GeocodingLocator.getInstance();

                geoco = loc.getGeocoder();

                ((LuceneGeocoderImpl)geoco).registreIndexListener(this);

                try {

                        store = GeocodingUtils.searchLayerInCurrentView(control

                                        .getPattern());

                        FeatureSet fset = (FeatureSet) store.getDataSet();

                        finalStep = fset.getSize();

                        setFinalStep((int) finalStep);

                } catch (Exception e) {

                        log.debug("Error getting data store");

                }

                textTask = PluginServices.getText(this, "featuresindexed");

        }

        /**

         * run process

         */

        public void run() throws Exception {

                // desactivate search button in the main panel

                control.getGPanel().enableSearchButton(false);

                // index process

                log.debug("Indexing data store .....");

                Literal relLit = control.getPattern().getDataSource().getStyle()

                                .getRelationsLiteral();

                ((LuceneGeocoderImpl) this.geoco).indexer(store, relLit);

                // activate search button in the main panel

                control.getGPanel().enableSearchButton(true);

        }

        /**

         * 

         */

        public void featureIndexed(FeatureIndexedEvent e) {

                int posi = (int)e.getPositionFeature();

                setCurrentStep(posi+1);

                setNote(posi+1 + " " + textTask);

        }

}