| gvSIG desktop 1

* Revision 1.7  2006-03-15 18:34:41  azabala

* *** empty log message ***

*

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

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

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

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

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

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

 * <br>

 *  Algorithm makes these three passes:

 *  a) computing intersections and saves them in a temp file.

 *  b) computing differences with first layer.

 *  c) computing differences with second layer.

	public IMonitorableTask createTask() {

		try {

			return new UnionMonitorableTask();

		} catch (DriverIOException e) {

			return null;

		}

	}

	/**

	 * IMonitorableTask that allows to run diff geoprocess in background,

	 * with cancelation requests.

	 * 

	 * @author azabala

	 * 

	 * FIXME INTERNACIONALIZAR TODOS LOS TEXTOS

	 * 

	 */

	class UnionMonitorableTask implements IMonitorableTask {

		private CancellableMonitorable cancelMonitor = null;

		// FIXME INTERNACIONALIZAR ESTO

		String FIRST_PASS_MESSAGE = "Computing intersections: ";

		String SECOND_PASS_MESSAGE = "Computing A-B difference:";

		String THIRD_PASS_MESSAGE = "Computing B-A difference:";

		String currentMessage = "";

		private boolean finished = false;

		UnionMonitorableTask() throws DriverIOException {

			initialize();

		}

		void initialize() throws DriverIOException {

			cancelMonitor = createCancelMonitor();

			currentMessage = "Initializing...";

		}

		private CancellableMonitorable createCancelMonitor()

				throws DriverIOException {

			DefaultCancellableMonitorable monitor = new 

							DefaultCancellableMonitorable();

			monitor.setInitialStep(0);

			monitor.setDeterminatedProcess(true);

			int numSteps = 0;

			//num steps = 2 * firstlayer (intersect + diff A-B)

			//+ second layer (diff B-A)

			if (onlyFirstLayerSelection) {

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

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

			} else {

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

			}

			if(onlyClipLayerSelection) {

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

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

			}else{

				numSteps += 2 * overlayLayer.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 "Union 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 currentMessage + getCurrentStep() + " of " + getFinishStep();

		}

		public void cancel() {

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

		}

		public void run() throws GeoprocessException {

			try {

				//FIXME Esto lo tenemos que hacer FUERA (en la GUI)

				schemaManager.createOrAlterSchema(createLayerDefinition());

				writer.preProcess();

				Strategy strategy = StrategyManager.getStrategy(firstLayer);

				Strategy strategy2 = StrategyManager.getStrategy(overlayLayer);

				DeferredFeaturePersisterProcessor featureProcessor =

					new DeferredFeaturePersisterProcessor(writer);

				IntersectVisitor visitor = new IntersectVisitor(overlayLayer, 

															featureProcessor,

															strategy2, 

															onlyClipLayerSelection);

				//FIXME Meter las selecciones

				currentMessage = FIRST_PASS_MESSAGE;

				if(onlyFirstLayerSelection){

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

					strategy.process(visitor, selection, cancelMonitor);

				}else{

					strategy.process(visitor, cancelMonitor);

				}

				currentMessage = SECOND_PASS_MESSAGE;

				DifferenceVisitor visitor2 = new DifferenceVisitor(overlayLayer,

						featureProcessor, strategy2, onlyClipLayerSelection);

				if(onlyFirstLayerSelection){

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

					strategy.process(visitor2, selection, cancelMonitor);

				}else{

					strategy.process(visitor2, cancelMonitor);

				}

				currentMessage = THIRD_PASS_MESSAGE;

				DifferenceVisitor visitor3 = new DifferenceVisitor(firstLayer,

						featureProcessor, strategy, onlyFirstLayerSelection);

				if(onlyClipLayerSelection){

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

					strategy2.process(visitor3, selection, cancelMonitor);

				}else{

					strategy2.process(visitor3, cancelMonitor);

				}

				writer.postProcess();

			} catch (EditionException e) {

				throw new GeoprocessException("Error al crear el esquema/fichero de la nueva capa");

			} catch (DriverException e) {

				throw new GeoprocessException("Error de driver al calcular el geoproceso interseccion");

			} catch (VisitException e) {

				throw new GeoprocessException("Error al procesar el feature de una capa durante el geoproceso interseccion");

			} catch (com.hardcode.gdbms.engine.data.driver.DriverException e) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			}finally{

				finished = true;

			}

		}

		public boolean isDefined() {

			return cancelMonitor.isDeterminatedProcess();

		}

		public boolean isCanceled() {

			return cancelMonitor.isCanceled();

		}

		public boolean isFinished() {

			return finished;

		}

	}