| gvSIG desktop 1

 * Revision 1.5  2006-03-15 18:34:31  azabala

 * *** empty log message ***

 *

 * Revision 1.4  2006/03/14 18:32:46  fjp

import com.iver.cit.gvsig.fmap.drivers.DriverIOException;

import com.iver.cit.gvsig.fmap.edition.EditionException;

import com.iver.cit.gvsig.fmap.layers.FBitSet;

import com.iver.cit.gvsig.fmap.operations.CancellableMonitorable;

import com.iver.cit.gvsig.fmap.operations.DefaultCancellableMonitorable;

import com.iver.gvsig.geoprocessing.impl.difference.DifferenceVisitor;

import com.iver.gvsig.geoprocessing.impl.intersection.IntersectVisitor;

import com.iver.gvsig.geoprocessing.impl.jtsprocessors.DeferredFeaturePersisterProcessor;

import com.iver.utiles.swing.threads.IMonitorableTask;

	public IMonitorableTask createTask() {

		try {

			return new SpatialJoinMonitorableTask();

		} catch (DriverIOException e) {

			return null;

		}

	}

	class SpatialJoinMonitorableTask implements IMonitorableTask {

		private CancellableMonitorable cancelMonitor = null;

		private boolean finished = false;

		SpatialJoinMonitorableTask() throws DriverIOException {

			initialize();

		}

		void initialize() throws DriverIOException {

			cancelMonitor = createCancelMonitor();

		}

		private CancellableMonitorable createCancelMonitor()

				throws DriverIOException {

			DefaultCancellableMonitorable monitor = new 

							DefaultCancellableMonitorable();

			monitor.setInitialStep(0);

			monitor.setDeterminatedProcess(true);

			int numSteps = 0;

			if (onlyFirstLayerSelection) {

				FBitSet selection = firstLayer.getRecordset().getSelection();

				numSteps += (2 * selection.cardinality());

			} else {

				numSteps += 2 * firstLayer.getSource().getShapeCount();

			}

			monitor.setFinalStep(numSteps);

			return monitor;

		}

		public int getInitialStep() {

			return cancelMonitor.getInitialStep();

		}

		public int getFinishStep() {

			return cancelMonitor.getFinalStep();

		}

		public int getCurrentStep() {

			return cancelMonitor.getCurrentStep();

		}

		public String getStatusMessage() {

			// FIXME Cambiar esto por un mecanismo de eventos,

			// de forma que la tarea lo que tenga sea un escuchador

			// que cambie el mensaje de estado segun los eventos

			// de tareas que se est?n realizando

			return "Spatial Join Geoprocess...";

		}

		public String getNote() {

			// FIXME Cambiar esto por un mecanismo de eventos,

			// de forma que la tarea lo que tenga sea un escuchador

			// que cambie el mensaje de estado segun los eventos

			// de tareas que se est?n realizando

			return "Joining " + getCurrentStep() + " of " + getFinishStep();

		}

		public void cancel() {

			((DefaultCancellableMonitorable) cancelMonitor).setCanceled(true);

		}

		public void run() throws GeoprocessException {

			Strategy strategy =

				StrategyManager.getStrategy(firstLayer);

			Strategy secondLyrStrategy =

				StrategyManager.getStrategy(secondLayer);

			visitor.setCancelableStrategy(secondLyrStrategy);

			visitor.setOnlySecondLyrSelection(onlySecondLayerSelection);

			try {

				if(onlyFirstLayerSelection){

					strategy.process(visitor, 

							firstLayer.getRecordset().

							getSelection(),

							cancelMonitor);

				}else{

					strategy.process(visitor, cancelMonitor);

				}

			} catch (DriverException e) {

				throw new GeoprocessException("Error al acceder a los datos durante un spatial join");

			} catch (VisitException e) {

				throw new GeoprocessException("Error al procesar los datos durante un spatial join");

			}

			finally{

				finished = true;

			}

		}

		public boolean isDefined() {

			return cancelMonitor.isDeterminatedProcess();

		}

		public boolean isCanceled() {

			return cancelMonitor.isCanceled();

		}

		public boolean isFinished() {

			return finished;

		}

	}