Application: gvSIG desktop » gvSIG raster

#Thu Jun 15 08:09:26 CEST 2017

buildNumber=101

<assembly>

  <id>gvsig-plugin-package</id>

  <formats>

    <format>zip</format>

  </formats>

  <baseDirectory>${project.artifactId}</baseDirectory>

  <includeBaseDirectory>true</includeBaseDirectory>

  <files>

    <file>

      <source>target/${project.artifactId}-${project.version}.jar</source>

      <outputDirectory>lib</outputDirectory>

    </file>

    <file>

      <source>target/package.info</source>

    </file>

  </files>

  <fileSets>

    <fileSet>

      <directory>src/main/resources-plugin</directory>

      <outputDirectory>.</outputDirectory>

    </fileSet>

  </fileSets>

  <dependencySets>

    <dependencySet>

      <useProjectArtifact>false</useProjectArtifact>

	  <useTransitiveDependencies>false</useTransitiveDependencies>

      <outputDirectory>lib</outputDirectory>

      <includes> 

				<include>org.gvsig:org.gvsig.raster.tools.app.basic:jar</include>

				<include>org.gvsig:org.gvsig.raster.tools.algorithm.layerdatatype:jar</include>

				<include>org.gvsig:org.gvsig.raster.tools.algorithm.saveraster:jar</include>

				<include>org.gvsig:org.gvsig.raster.tools.algorithm.swing.api:jar</include>

				<include>org.gvsig:org.gvsig.raster.tools.algorithm.swing.impl:jar</include>

				<include>org.gvsig:org.gvsig.raster.tools.toolbox.algorithm:jar</include>

	  </includes>

	</dependencySet>

  </dependencySets>

</assembly>

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

* 

*/

package org.gvsig.raster.tools.app.basic.raster.process;

import java.awt.Rectangle;

import java.awt.geom.AffineTransform;

import java.awt.geom.Point2D;

import java.io.File;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

import org.cresques.cts.IProjection;

import org.gvsig.app.project.ProjectManager;

import org.gvsig.app.project.documents.Document;

import org.gvsig.app.project.documents.view.BaseViewDocument;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorer;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

import org.gvsig.fmap.dal.coverage.RasterLibrary;

import org.gvsig.fmap.dal.coverage.RasterLocator;

import org.gvsig.fmap.dal.coverage.RasterManager;

import org.gvsig.fmap.dal.coverage.dataset.Buffer;

import org.gvsig.fmap.dal.coverage.datastruct.Extent;

import org.gvsig.fmap.dal.coverage.datastruct.NoData;

import org.gvsig.fmap.dal.coverage.datastruct.Params;

import org.gvsig.fmap.dal.coverage.exception.NotSupportedExtensionException;

import org.gvsig.fmap.dal.coverage.exception.ProcessInterruptedException;

import org.gvsig.fmap.dal.coverage.exception.QueryException;

import org.gvsig.fmap.dal.coverage.exception.ROIException;

import org.gvsig.fmap.dal.coverage.exception.RasterDriverException;

import org.gvsig.fmap.dal.coverage.exception.RmfSerializerException;

import org.gvsig.fmap.dal.coverage.process.BaseIncrementableTask;

import org.gvsig.fmap.dal.coverage.store.DataServerWriter;

import org.gvsig.fmap.dal.coverage.store.RasterDataStore;

import org.gvsig.fmap.dal.coverage.store.RasterQuery;

import org.gvsig.fmap.dal.coverage.store.parameter.NewRasterStoreParameters;

import org.gvsig.fmap.dal.coverage.store.parameter.RemoteStoreParameters;

import org.gvsig.fmap.dal.coverage.store.props.ColorInterpretation;

import org.gvsig.fmap.dal.coverage.store.props.ColorTable;

import org.gvsig.fmap.dal.coverage.util.RasterUtils;

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

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

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

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

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

import org.gvsig.fmap.mapcontext.layers.FLayer;

import org.gvsig.fmap.mapcontext.layers.FLayers;

import org.gvsig.i18n.Messages;

import org.gvsig.raster.algorithm.process.DataProcess;

import org.gvsig.raster.fmap.layers.DefaultFLyrRaster;

import org.gvsig.raster.mainplugin.RasterMainPluginUtils;

import org.gvsig.raster.roi.ROI;

import org.gvsig.raster.swing.RasterSwingLibrary;

import org.gvsig.raster.util.RasterNotLoadException;

import org.slf4j.LoggerFactory;

/**

 * <code>ClippingProcess</code> es un proceso que usa un <code>Thread</code>

 * para aplicar un recorte a una capa y guardarlo en disco. Muestra una barra

 * de incremento informativa.

 *

 * @author BorSanZa - Borja S?nchez Zamorano

 */

public class ClippingProcess extends DataProcess {

	public static final String            PROCESS_LABEL       = "ClippingProcess";

	public static String                  FILENAME            = "filename";

	public static String                  SUFFIX              = "suffix";

	public static String                  VIEWNAME            = "viewname";

	public static String                  PX_COORDS           = "pixelcoordinates";

	public static String                  WORLD_COORDS        = "realcoordinates";

	public static String                  RASTER_STORE        = "layer";

	public static String                  DRAWABLE_BANDS      = "drawablebands";

	public static String                  ONE_LYE_PER_BAND    = "onelayerperband";

	public static String                  INTERP_METHOD       = "interpolationmethod";

	public static String                  AT                  = "affinetransform";

	public static String                  COLOR_INTERPR       = "colorInterpretation";

	public static String                  SELECTED_ROIS       = "selectedrois";

	public static String                  RESOLUTION          = "resolution";

	public static String                  DRIVER_PARAMS       = "driverparams";

	public static String                  VIEW_PROJ           = "viewProjection";

	private String                        fileName            = "";

	private String                        suffix              = ".tif";

	private RasterDataStore               dataStore           = null;

	private boolean                       oneLayerPerBand     = false;

	private int[]                         drawableBands       = { 0, 1, 2 };

	private double[]                      pValues             = null;

	private int                           interpolationMethod = Buffer.INTERPOLATION_Undefined;

	private String                        viewName            = "";

	private Params                        params              = null;

	private ColorInterpretation           colorInterp         = null;

	private ArrayList<ROI>                selectedRois        = null;

	private AffineTransform               affineTransform     = null;

	private double[]                      wcValues            = null;

	private RasterManager                 rManager            = RasterLocator.getManager();

	private BaseIncrementableTask         processIncrement    = null; 

	/**

	 * Variables de la resoluci?n de salida

	 */

	private int                           resolutionWidth     = 0;

	private int                           resolutionHeight    = 0;

	private Buffer                        buffer              = null;

	private IProjection                   viewProjection      = null;

	public static void registerParameters() {

		registerInputParameter(FILENAME, String.class, PROCESS_LABEL);

		registerInputParameter(SUFFIX, String.class, PROCESS_LABEL);

		registerInputParameter(VIEWNAME, String.class, PROCESS_LABEL);

		registerInputParameter(PX_COORDS, Double.class, PROCESS_LABEL);

		registerInputParameter(WORLD_COORDS, Double.class, PROCESS_LABEL);

		registerInputParameter(RASTER_STORE, RasterDataStore.class, PROCESS_LABEL);

		registerInputParameter(DRAWABLE_BANDS, Integer[].class, PROCESS_LABEL);

		registerInputParameter(ONE_LYE_PER_BAND, Boolean.class, PROCESS_LABEL);

		registerInputParameter(INTERP_METHOD, Integer.class, PROCESS_LABEL);

		registerInputParameter(AT, AffineTransform.class, PROCESS_LABEL);

		registerInputParameter(COLOR_INTERPR, ColorInterpretation.class, PROCESS_LABEL);

		registerInputParameter(SELECTED_ROIS, ArrayList.class, PROCESS_LABEL);

		registerInputParameter(RESOLUTION, Integer[].class, PROCESS_LABEL);

		registerInputParameter(DRIVER_PARAMS, Params.class, PROCESS_LABEL);

		registerInputParameter(VIEW_PROJ, IProjection.class, PROCESS_LABEL);

		//TODO: Falta definir salidas y asignarlas en el Map

		registerOutputParameter(FILENAME, String.class, PROCESS_LABEL);

	}

	/**

	 * Par?metros obligatorios al proceso:

	 * <UL>

	 * <LI>filename: Nombre del fichero de salida</LI>

	 * <LI>datawriter: Escritor de datos</LI>

	 * <LI>viewname: Nombre de la vista sobre la que se carga la capa al acabar el proceso</LI>

	 * <LI>pixelcoordinates: Coordenadas pixel del recorte (ulx, uly, lrx, lry)</LI>

	 * <LI>layer: Capa de entrada para el recorte</LI>

	 * <LI>drawablebands: Bandas de entrada</LI>

	 * <LI>onelayerperband: booleano que informa de si escribimos una banda por fichero de salida o todas en un fichero</LI>

	 * <LI>interpolationmethod: M?todo de interpolaci?n.</LI>

	 * <LI>affinetransform: Transformaci?n que informa al dataset de salida de su referencia geografica</LI>

	 * <LI>resolution: Ancho y alto de la capa de salida</LI>

	 * </UL> 

	 */

	@SuppressWarnings("unchecked")

	public void init() {

		fileName = getStringParam("filename");

		suffix = getStringParam("suffix");

		viewName = getStringParam("viewname");

		pValues = getDoubleArrayParam("pixelcoordinates");

		wcValues = getDoubleArrayParam("realcoordinates");

		dataStore = getParam("layer") != null ? (RasterDataStore)getParam("layer") : null;

		drawableBands = getIntArrayParam("drawablebands");

		oneLayerPerBand = getBooleanParam("onelayerperband");

		interpolationMethod = getIntParam("interpolationmethod");

		affineTransform = (AffineTransform)getParam("affinetransform");

		colorInterp = (ColorInterpretation)getParam("colorInterpretation");

		selectedRois = (ArrayList<ROI>)getParam("selectedrois");

		if(getIntArrayParam("resolution") != null) {

			resolutionWidth = getIntArrayParam("resolution")[0];

			resolutionHeight = getIntArrayParam("resolution")[1];

		}

		params = (Params) getParam("driverparams");

		viewProjection = getParam("viewProjection") != null ? (IProjection)getParam("viewProjection") : null;

	}

	/**

	 * Salva la tabla de color al fichero rmf.

	 * @param fName

	 * @throws IOException

	 */

	private void saveToRmf(String fileName) {

		int limitNumberOfRequests = 20;

		while (dataStore == null && limitNumberOfRequests > 0) {

			try {

			} catch (IndexOutOfBoundsException e) {

				//En ocasiones, sobre todo con servicios remotos al pedir un datasource da una excepci?n de este tipo

				//se supone que es porque hay un refresco en el mismo momento de la petici?n por lo que como es m?s lento de

				//gestionar pilla a la capa sin datasources asociados ya que est? reasignandolo. Si volvemos a pedirlo debe

				//haberlo cargado ya.

				try {

					Thread.sleep(200);

				} catch (InterruptedException e1) {

				}

			}

			limitNumberOfRequests--;

		}

		if (dataStore == null) {

			//RasterToolsUtil.messageBoxError("error_load_layer", this, new Exception("Error writing RMF. limitNumberOfRequests=" + limitNumberOfRequests));

			return;

		}

		// Guardamos en el RMF el valor NoData

		if(dataStore.getNoDataValue() != null) {

			NoData nodata = (NoData)dataStore.getNoDataValue();

			nodata.setFileName(fileName);

			nodata.save();

		}

		// Guardamos en el RMF la tabla de color

		ColorTable colorTable = dataStore.getColorTable();

		try {

			rManager.getProviderServices().saveObjectToRmfFile(fileName, ColorTable.class, colorTable);

		} catch (RmfSerializerException e) {

			RasterSwingLibrary.messageBoxError("error_salvando_rmf", this, e);

		}

	}

	/**

	 * Tarea de recorte

	 */

	@SuppressWarnings("deprecation")

	public void process() throws ProcessInterruptedException {

		RasterDataStore dstoreCopy = null;

		RasterUtils util = RasterLocator.getManager().getRasterUtils();

		try {

			long t2;

			long t1 = new java.util.Date().getTime();

			try {

				Thread.sleep(1000);

			} catch (InterruptedException e1) {

				e1.printStackTrace();

			}

			insertLineLog(Messages.getText("leyendo_raster"));

			dstoreCopy = dataStore.newNotTiledDataStore();

			RasterQuery query = rManager.createQuery();

			query.setDrawableBands(drawableBands);

			if(dstoreCopy.getParameters() instanceof RemoteStoreParameters &&

				!((RemoteStoreParameters)dstoreCopy.getParameters()).isSizeFixed()) {

				insertLineLog(Messages.getText("downloading_image"));

				((RemoteStoreParameters)dstoreCopy.getParameters()).setWidth(resolutionWidth);

				((RemoteStoreParameters)dstoreCopy.getParameters()).setHeight(resolutionHeight);

				Extent bbox = RasterLocator.getManager().getDataStructFactory().createExtent(wcValues[0], wcValues[1], wcValues[2], wcValues[3]);

				query.setAreaOfInterest(bbox, resolutionWidth, resolutionHeight);

				try {

					buffer = dstoreCopy.query(query);

				} catch (QueryException e) {

					RasterSwingLibrary.messageBoxError("No se ha podido asignar la vista al inicial el proceso de recorte.", this, e);

				}

			} else {

				if(interpolationMethod != Buffer.INTERPOLATION_Undefined) {

					try {

						if(pValues != null) {

							if (util.isBufferTooBig(new double[] { pValues[0], pValues[3], pValues[2], pValues[1] }, drawableBands.length))

								query.setReadOnly(true);

							Rectangle r = new Rectangle((int)pValues[0], (int)pValues[1], (int)Math.abs(pValues[2] - pValues[0]) + 1, (int)Math.abs(pValues[3] - pValues[1]) + 1);

							query.setAreaOfInterest(r);

						} else if(wcValues != null) {

							query.setReadOnly(true);

							Extent e = RasterLocator.getManager().getDataStructFactory().createExtent(

									wcValues[0], wcValues[1], wcValues[2], wcValues[3]);

							query.setAreaOfInterest(e);

							//query.setAreaOfInterest(wcValues[0], wcValues[1], Math.abs(wcValues[0] - wcValues[2]), Math.abs(wcValues[1] - wcValues[3]));

						}

						buffer = dstoreCopy.query(query);

					} catch (QueryException e) {

						RasterSwingLibrary.messageBoxError("No se ha podido asignar la vista al inicial el proceso de recorte.", this, e);

					}

					insertLineLog(Messages.getText("interpolando"));

					Buffer bufTmp = buffer;

					processIncrement = bufTmp.getIncrementableTask(Buffer.INCREMENTABLE_INTERPOLATION);

					buffer = bufTmp.getAdjustedWindow(resolutionWidth, resolutionHeight, interpolationMethod);

					if(bufTmp != buffer)

						bufTmp.dispose();

				} else {

					try {

						if (util.isBufferTooBig(new double[] { 0, 0, resolutionWidth, resolutionHeight }, drawableBands.length))

							query.setReadOnly(true);

						if(pValues != null) {

							Rectangle r = new Rectangle(

									(int)pValues[0], 

									(int)pValues[3], 

									(int)Math.abs(pValues[2] - pValues[0]) + 1, 

									(int)Math.abs(pValues[1] - pValues[3]) + 1);

							query.setAreaOfInterest(r, resolutionWidth, resolutionHeight);

						}

						else if(wcValues != null) {

							Extent bbox = RasterLocator.getManager().getDataStructFactory().createExtent(wcValues[0], wcValues[1], wcValues[2], wcValues[3]);

							query.setAreaOfInterest(bbox, resolutionWidth, resolutionHeight);

						}

						buffer = dstoreCopy.query(query);

					} catch (QueryException e) {

						RasterSwingLibrary.messageBoxError("No se ha podido asignar la vista al inicial el proceso de recorte.", this, e);

					}

				}

			}

			//TODO: FUNCIONALIDAD: Poner los getWriter con la proyecci?n del fichero fuente

			if ((selectedRois != null) && (!query.isReadOnly())){

				if (selectedRois.size() > 0){

					int despX = 0;

					int despY = 0;

					if (pValues != null){

						despX = (int)pValues[0];

						despY = (int)pValues[1];

					} else if (wcValues != null){

						despX = (int)dstoreCopy.worldToRaster(new Point2D.Double(wcValues[0], wcValues[1])).getX();

						despY = (int)dstoreCopy.worldToRaster(new Point2D.Double(wcValues[0], wcValues[1])).getY();

					}

					drawOnlyROIs(buffer, selectedRois, despX, despY);

				}

			}

			insertLineLog(Messages.getText("salvando_imagen"));

			DataManager manager = DALLocator.getDataManager();

			String provider = "Gdal Store";

			DataServerExplorerParameters eparams = manager.createServerExplorerParameters("FilesystemExplorer");

			String finalFileName = "";

			NewRasterStoreParameters sparams = null;

			processIncrement = RasterLocator.getManager().createDataServerWriter();

			if (oneLayerPerBand) {

				long[] milis = new long[drawableBands.length];

				String[] fileNames = new String[drawableBands.length];

				for (int i = 0; i < drawableBands.length; i++) {

					fileNames[i] = fileName + "_B" + drawableBands[i] + suffix;

					int index = fileNames[i].lastIndexOf(File.separator);

					if(index < 0)

						index = fileNames[i].length();

					String path = fileNames[i].substring(0, index);

					String file = fileNames[i].substring(index + 1, fileNames[i].length());

					eparams.setDynValue("initialpath", path);

					DataServerExplorer serverExplorer = manager.openServerExplorer(eparams.getExplorerName(), eparams);

					sparams = (NewRasterStoreParameters)serverExplorer.getAddParameters(provider);

					sparams.setDataServer((DataServerWriter)processIncrement);

					sparams.setDestination(path, file);

					sparams.setBuffer(buffer);

					sparams.setColorInterpretation(new String[]{ColorInterpretation.GRAY_BAND});

					sparams.setWktProjection(dstoreCopy.getWktProjection());

					sparams.setBand(i);

					sparams.setAffineTransform(affineTransform);

					sparams.setDriverParams(params);

					serverExplorer.add(provider, sparams, true);

					saveToRmf(fileNames[i]);

					t2 = new java.util.Date().getTime();

					milis[i] = (t2 - t1);

					t1 = new java.util.Date().getTime();

				}

				if (incrementableTask != null) {

					incrementableTask.processFinalize();

					incrementableTask = null;

				}

				if(viewName != null) {

					if (RasterSwingLibrary.messageBoxYesOrNot("cargar_toc", this)) {

						try {

							for (int i = 0; i < drawableBands.length; i++) {

								FLayer lyr = RasterMainPluginUtils.loadLayer(viewName, fileNames[i], null);

								if(lyr != null && lyr instanceof DefaultFLyrRaster) {

									if(dataStore.getProjection() != null)

										((DefaultFLyrRaster)lyr).setRois(dataStore.getRois(dataStore.getProjection()));

									else

										((DefaultFLyrRaster)lyr).setRois(dataStore.getRois(viewProjection));

								}

							}

						} catch (RasterNotLoadException e) {

							RasterSwingLibrary.messageBoxError("error_load_layer", this, e);

						}

					}

				}

				for (int i = 0; i < drawableBands.length; i++) {

					if (externalActions != null)

						externalActions.end(new Object[] { fileName + "_B" + drawableBands[i] + suffix, new Long(milis[i]) });

				}

			} else {

				if (isUsingFile(fileName)) {

					incrementableTask.hideWindow();

					RasterSwingLibrary.messageBoxError("error_opened_file", this);

					return;

				}

				File f = new File(fileName);

				if (f.exists()) {

					f.delete();

				}

				f = null;

				if(suffix != null)

					finalFileName = fileName.endsWith(suffix) ? fileName : fileName + suffix;

				else

					finalFileName = fileName;

				int index = finalFileName.lastIndexOf(File.separator);

				if(index < 0)

					index = finalFileName.length();

				String path = finalFileName.substring(0, index);

				String file = finalFileName.substring(index + 1, finalFileName.length());

				eparams.setDynValue("initialpath", path);

				DataServerExplorer serverExplorer = manager.openServerExplorer(eparams.getExplorerName(), eparams);

				try {

					provider = rManager.createWriter(finalFileName).getProviderName();

				} catch (NotSupportedExtensionException e1) {

					RasterSwingLibrary.messageBoxError("no_driver_escritura", this, e1);

				} catch (RasterDriverException e1) {

					RasterSwingLibrary.messageBoxError("no_driver_escritura", this, e1);

				}

				sparams = (NewRasterStoreParameters)serverExplorer.getAddParameters(provider);

				sparams.setDataServer((DataServerWriter)processIncrement);

				sparams.setDestination(path, file);

				sparams.setBuffer(buffer);

				if(colorInterp != null)

					sparams.setColorInterpretation(colorInterp.getValues());

				sparams.setWktProjection(dstoreCopy.getWktProjection());

				sparams.setAffineTransform(affineTransform);

				sparams.setDriverParams(params);

				sparams.setBand(-1);

				serverExplorer.add(provider, sparams, true);

				saveToRmf(finalFileName);

				t2 = new java.util.Date().getTime();

				if (incrementableTask != null) {

					incrementableTask.processFinalize();

					incrementableTask = null;

				}

				//Damos tiempo a parar el Thread del incrementable para que no se cuelgue la ventana

				//El tiempo es como m?nimo el de un bucle del run de la tarea incrementable

				try {

					Thread.sleep(600);

				} catch (InterruptedException e) {

					throw new ProcessInterruptedException(e);

				}

				cutFinalize(finalFileName, (t2 - t1));

			}

		} catch (RasterDriverException e) {

			RasterSwingLibrary.messageBoxError("error_writer", this, e);

		} catch (ValidateDataParametersException e) {

			RasterSwingLibrary.messageBoxError("error_georasterwriter", this);

		} catch (ProviderNotRegisteredException e) {

			RasterSwingLibrary.messageBoxError("error_georasterwriter", this, e);

		} catch (InitializeException e) {

			RasterSwingLibrary.messageBoxError("error_georasterwriter", this, e);

		} catch (DataException e) {

			RasterSwingLibrary.messageBoxError("error_georasterwriter", this, e);

		} catch (Exception e) {

			e.printStackTrace();

		} finally {

			if (dstoreCopy != null)

				try {

					dstoreCopy.close();

				} catch (CloseException e) {

					LoggerFactory.getLogger(ClippingProcess.class).debug(Messages.getText("error_writer"), e);

				}

			buffer = null;

		}

	}

	/**

	 * Acciones para poner a NoData los pixels que est?n fuera de las

	 * regiones de inter?s seleccionadas.

	 * @param buffer

	 */

	private void drawOnlyROIs(Buffer buffer, List<ROI> rois, int despX, int despY){

		for (int i = 0 ; i < buffer.getWidth() ; i++){

			for (int j = 0 ; j < buffer.getHeight() ; j++){

				boolean  inside = false;

				for (int k = 0 ; k < rois.size() ; k++){

					ROI roi = rois.get(k);

					//TODO: Hacer la comprobacion por coordenadas del mundo en lugar de coordenadas pixel.

					if (roi.isInsideOfPolygon(i + despX, j + despY)){

						inside = true;

					}

				}

				if (!inside){

					for (int l = 0 ; l < buffer.getBandCount() ; l++){

						if (buffer.getDataType() == Buffer.TYPE_BYTE){

							buffer.setElem(j, i, l, 

									buffer.getNoDataValue().isDefined() ? buffer.getNoDataValue().getValue().byteValue() : RasterLibrary.defaultByteNoDataValue);

						} else if (buffer.getDataType() == Buffer.TYPE_SHORT){

							buffer.setElem(j, i, l, 

									buffer.getNoDataValue().isDefined() ? buffer.getNoDataValue().getValue().shortValue() : RasterLibrary.defaultShortNoDataValue);

						} else if (buffer.getDataType() == Buffer.TYPE_INT){

							buffer.setElem(j, i, l, 

									buffer.getNoDataValue().isDefined() ? buffer.getNoDataValue().getValue().intValue() : RasterLibrary.defaultIntegerNoDataValue);

						} else if (buffer.getDataType() == Buffer.TYPE_FLOAT){

							buffer.setElem(j, i, l, 

									buffer.getNoDataValue().isDefined() ? buffer.getNoDataValue().getValue().floatValue() : RasterLibrary.defaultFloatNoDataValue);

						} else if (buffer.getDataType() == Buffer.TYPE_DOUBLE){

							buffer.setElem(j, i, l, 

									buffer.getNoDataValue().isDefined() ? buffer.getNoDataValue().getValue().doubleValue() : RasterLibrary.defaultDoubleNoDataValue);

						}

					}

				}

			}

		}

	}

	/**

	 * Returns true if there is a layer in the current project using the file named with

	 * fileName.

	 * @param fileName

	 * @return

	 */

	private boolean isUsingFile(String fileName) {

		List<Document> docs = ProjectManager.getInstance().getCurrentProject().getDocuments();

		for (int i = 0 ;i < docs.size() ;i++) {

			if (docs.get(i) instanceof BaseViewDocument) {

				FLayers lyrs = ((BaseViewDocument)docs.get(i)).getMapContext().getLayers();

				for (int j = 0 ;j < lyrs.getLayersCount() ;j++) {

					if (lyrs.getLayer(j) instanceof DefaultFLyrRaster) {

						DefaultFLyrRaster lyr = (DefaultFLyrRaster)lyrs.getLayer(j);						

						if (lyr.getDataStore() != null ){							

							if (fileName.equals(lyr.getDataStore().getName())) {

								return true;

							}

						}		

					}

				}

			}

		}

		return false;

	}

	/**

	 * Acciones que se realizan al finalizar de crear los recortes de imagen.

	 * Este m?todo es llamado por el thread TailRasterProcess al finalizar.

	 */

	private void cutFinalize(String fileName, long milis) {

		if (!new File(fileName).exists())

			return;

		if(viewName != null) {

			if (RasterSwingLibrary.messageBoxYesOrNot("cargar_toc", null)) {

				try {

					FLayer lyr = RasterMainPluginUtils.loadLayer(viewName, fileName, null);

					if(lyr != null && lyr instanceof DefaultFLyrRaster) {

						if(dataStore.getProjection() != null)

							((DefaultFLyrRaster)lyr).setRois(dataStore.getRois(dataStore.getProjection()));

						else

							((DefaultFLyrRaster)lyr).setRois(dataStore.getRois(viewProjection));

					}

				} catch (RasterNotLoadException e) {

					RasterSwingLibrary.messageBoxError("error_load_layer", this, e);

				} catch (ROIException e) {

					RasterSwingLibrary.messageBoxError("error_load_layer", this, e);

				}

			}

		}

		if (externalActions != null)

			externalActions.end(new Object[]{fileName, new Long(milis)});

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.gui.beans.incrementabletask.IIncrementable#getPercent()

	 */

	public int getPercent() {

		return (processIncrement != null) ? processIncrement.getPercent() : 0;

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.gui.beans.incrementabletask.IIncrementable#getTitle()

	 */

	public String getTitle() {

		return Messages.getText("incremento_recorte");

	}

	/*

	 * (non-Javadoc)

	 * @see java.lang.Object#finalize()

	 */

	protected void finalize() throws Throwable {

		fileName            = null;

		suffix              = null;

		dataStore            = null;

		drawableBands       = null;

		pValues             = null;

		viewName            = null;

		params              = null;

		colorInterp         = null;

		affineTransform     = null;

		wcValues            = null;

		buffer              = null;

		processIncrement    = null;

		if(selectedRois != null) {

			selectedRois.clear();

			selectedRois = null;

		}

		super.finalize();

	}

}

package org.gvsig.raster.tools.app.basic.raster.process;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

import javax.swing.SwingUtilities;

import org.cresques.cts.IProjection;

import org.gvsig.fmap.dal.coverage.RasterLocator;

import org.gvsig.fmap.dal.coverage.RasterManager;

import org.gvsig.fmap.dal.coverage.dataset.Buffer;

import org.gvsig.fmap.dal.coverage.datastruct.NoData;

import org.gvsig.fmap.dal.coverage.exception.FilterManagerException;

import org.gvsig.fmap.dal.coverage.exception.FilterTypeException;

import org.gvsig.fmap.dal.coverage.exception.NotSupportedExtensionException;

import org.gvsig.fmap.dal.coverage.exception.ProcessInterruptedException;

import org.gvsig.fmap.dal.coverage.exception.QueryException;

import org.gvsig.fmap.dal.coverage.exception.ROIException;

import org.gvsig.fmap.dal.coverage.exception.RasterDriverException;

import org.gvsig.fmap.dal.coverage.filter.FilterLoader;

import org.gvsig.fmap.dal.coverage.grid.RasterFilterList;

import org.gvsig.fmap.dal.coverage.grid.RasterFilterListManager;

import org.gvsig.fmap.dal.coverage.store.DataServerWriter;

import org.gvsig.fmap.dal.coverage.store.RasterDataStore;

import org.gvsig.fmap.dal.coverage.store.RasterQuery;

import org.gvsig.fmap.dal.coverage.store.RasterWriter;

import org.gvsig.fmap.dal.coverage.store.props.ColorInterpretation;

import org.gvsig.fmap.dal.coverage.store.props.Transparency;

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

import org.gvsig.i18n.Messages;

import org.gvsig.raster.fmap.layers.FLyrRaster;

import org.gvsig.raster.roi.ROI;

import org.gvsig.raster.tools.app.basic.raster.bean.previewbase.ParamStruct;

/**

 * Clase donde se hara todo el proceso de aplicar una lista de filtros a una

 * capa. Muestra una ventana de dialogo de incremento informativa.

 *

 * @author BorSanZa - Borja S?nchez Zamorano 

 */

public class FilterProcess extends RasterProcess {

	private String                   filename         = "";

	private RasterDataStore          rasterDataSource = null;

	private ArrayList<ParamStruct>   listFilterUsed   = null;

	private RasterFilterList         rasterFilterList = null;

	private RasterWriter             geoRasterWriter  = null;

	private FLyrRaster               lyr              = null;

	private RasterManager            rManager         = RasterLocator.getManager();

	public void init() {

		filename = getStringParam("filename");

		listFilterUsed = (ArrayList) getParam("listfilterused");

		lyr = (FLyrRaster)getParam("layer");

		rasterDataSource = lyr.getDataStore();

	}

	/**

	 * Devuelve una interpretacion de color. Es usado cuando no conseguimos un

	 * rendering y no podemos saber que interpretacion l?gica ten?a antes.

	 * @param geoRasterWriter

	 */

	private ColorInterpretation getColorIntepretation(Buffer buffer, RasterFilterList filterList) {

		ColorInterpretation colorInterpretation = null;

		do {

			// Si tiene una tabla de color asignamos las tres bandas

			if (filterList.isActive("colortable")) {

				colorInterpretation = rManager.getDataStructFactory().createColorInterpretation(

						new String[] { 

								ColorInterpretation.RED_BAND, 

								ColorInterpretation.GREEN_BAND, 

								ColorInterpretation.BLUE_BAND,

								ColorInterpretation.ALPHA_BAND 

								});

				break;

			}

			// Si el numero de bandas coincide asignamos la misma interpretacion que tenia antes

			if (buffer.getBandCount() == rasterDataSource.getBandCount()) {

				colorInterpretation = rasterDataSource.getColorInterpretation();

				break;

			}

			String[] colorInterp = new String[rasterDataSource.getColorInterpretation().getValues().length];

			for (int i = 0; i < rasterDataSource.getColorInterpretation().getValues().length; i++) {

				if (rasterDataSource.getColorInterpretation().getValues()[i].equals(ColorInterpretation.UNDEF_BAND)) {

					colorInterp[i] = ColorInterpretation.GRAY_BAND;

					continue;

				}

				colorInterp[i] = rasterDataSource.getColorInterpretation().getValues()[i];

			}

			colorInterpretation = rManager.getDataStructFactory().createColorInterpretation(colorInterp);

		} while (false);

		return colorInterpretation;

	}

	public void process() throws ProcessInterruptedException, ProcessException {

		DataServerWriter writerBufferServer = null;

		if(lyr != null)

			lyr.setReadingData(Thread.currentThread().getId() + "");

		RasterDataStore dstoreCopy = null;

		RasterQuery query          = null;

		Buffer buffer              = null;

		Buffer buff                = null;

		Buffer alpha               = null;

		try {

			insertLineLog(Messages.getText("leyendo_raster"));

			//Creaci?n del BufferFactory

			dstoreCopy = rasterDataSource.newNotTiledDataStore();

			query = rManager.createQuery();

			//if (!RasterBuffer.loadInMemory(dsetCopy))

			query.setReadOnly(true);

			//Asignaci?n de bandas

			int[] renderBands = lyr.getRender().getRenderColorInterpretation().buildRenderBands();

			if (renderBands != null) {

				// Si es gris, se reduce a una sola banda

				if ((renderBands.length == 3) && (renderBands[0] == renderBands[1]) && (renderBands[1] == renderBands[2])) 

					renderBands = new int[] { renderBands[0] };

				query.setDrawableBands(renderBands);

			} else

				query.setAllDrawableBands();

			query.setAreaOfInterest();

			buff = dstoreCopy.query(query);

			if(buff.isReadOnlyBuffer()) 

				buff.addDrawableBands(renderBands);

			insertLineLog(Messages.getText("aplicando_filtros"));

			Transparency processTransparency = dstoreCopy.getTransparency().cloneTransparency();

			processTransparency.setColorInterpretation(lyr.getRender().getRenderColorInterpretation().cloneColorInterpretation());

			List<ROI> roi = null;

			try {

				IProjection proj = dstoreCopy.getProjection();

				if(proj == null)

					proj = lyr.getMapContext().getProjection();

				roi = (List<ROI>)dstoreCopy.getRois(proj);

			} catch (ROIException e) {

			}

			rasterFilterList = rManager.createEmptyFilterList(dstoreCopy.getDataType()[0]);

			FilterLoader filterLoader = RasterLocator.getManager().createFilterLoader(rasterFilterList);

			filterLoader.addSrcBandCount(dstoreCopy.getBandCount());

			filterLoader.addSrcDataType(dstoreCopy.getDataType()[0]);

			filterLoader.addSrcStatistics(dstoreCopy.getStatistics());

			filterLoader.addSrcROI(roi);

			filterLoader.addTransparency(processTransparency);

			filterLoader.addSrcHistogram(dstoreCopy.getHistogramComputer());

			addSelectedFilters(rasterFilterList, listFilterUsed);

			buffer = filterLoader.applyFilters(buff);

			insertLineLog(Messages.getText("guardando_capa"));

			writerBufferServer = rManager.createDataServerWriter();

			writerBufferServer.setBuffer(buffer, -1);

			// TODO: FUNCIONALIDAD: Poner los getWriter con la proyecci?n del fichero fuente

			ColorInterpretation colorInterpretation = getColorInterpretation(buffer.getBandCount(), buffer.getDataType());

			geoRasterWriter = rManager.createWriter(writerBufferServer, 

					filename,

					buffer.getBandCount(), 

					rasterDataSource.getAffineTransform(), 

					buffer.getWidth(), 

					buffer.getHeight(), 

					buffer.getDataType(), 

					rManager.createWriter(filename).getParams(), 

					null);

			if (lyr.getRender() == null)

				colorInterpretation = getColorIntepretation(buffer, rasterFilterList);

			geoRasterWriter.setColorBandsInterpretation(colorInterpretation.getValues());

			geoRasterWriter.dataWrite();

			geoRasterWriter.writeClose();

			geoRasterWriter = null;

			// Guardamos en el RMF el valor NoData

			//Si el del buffer tiene valor es porque alg?n filtro le ha salvado valor nodata por lo que se pone ese

			//sino se pone el de la imagen original

			NoData nodataOrigin = (NoData)rasterDataSource.getNoDataValue();

			NoData nodataBuffer =  (NoData)buffer.getNoDataValue();

			if(nodataBuffer != null && nodataBuffer.isDefined()) {

				nodataBuffer.setFileName(filename);

				nodataBuffer.save();

			} else if(nodataOrigin != null && nodataOrigin.isDefined()) {

				nodataOrigin.setFileName(filename);

				nodataOrigin.save();

			}

			SwingUtilities.invokeLater(new Runnable() {

				public void run() {

					if (externalActions != null)

						externalActions.end(filename);

				}

			});

		} catch (NotSupportedExtensionException e) {

			throw new ProcessException("error_writer_notsupportedextension", e);

		} catch (RasterDriverException e) {

			throw new ProcessException("error_writer", e);

		} catch (IOException e) {

			throw new ProcessException("error_writer", e);

		} catch (FilterTypeException e) {

			throw new ProcessException("error_adding_filters", e);

		} catch (QueryException e) {

			throw new ProcessException("error_loading_data", e);

		} catch (FilterManagerException e) {

			throw new ProcessException("error_adding_filters", e);

		} finally {

			if(writerBufferServer != null)

				writerBufferServer.dispose();

			if(buff != null)

				buff.dispose();

			if(rasterFilterList != null)

				rasterFilterList.dispose();

			if(alpha != null)

				alpha.dispose();

			if(dstoreCopy != null)

				try {

					dstoreCopy.close();

				} catch (CloseException e) {

				}

			if(lyr != null)

				lyr.setReadingData(null);

			dispose();

		}

	}

	private ColorInterpretation getColorInterpretation(int nBands, int dataType) {

		//Si la fuente es con paleta, al aplicarle un filtro se genera un ARGB

		if(lyr.existColorTable()) 

			return rManager.getDataStructFactory().createColorInterpretation(

					new String[] { ColorInterpretation.RED_BAND, ColorInterpretation.GREEN_BAND, ColorInterpretation.BLUE_BAND, ColorInterpretation.ALPHA_BAND });

		if(dataType == Buffer.TYPE_BYTE) {

			if(nBands == 3)

				return rManager.getDataStructFactory().createColorInterpretation(

						new String[] { ColorInterpretation.RED_BAND, ColorInterpretation.GREEN_BAND, ColorInterpretation.BLUE_BAND });

			if(nBands == 4)

				return rManager.getDataStructFactory().createColorInterpretation(

						new String[] { ColorInterpretation.RED_BAND, ColorInterpretation.GREEN_BAND, ColorInterpretation.BLUE_BAND, ColorInterpretation.ALPHA_BAND });

			if(nBands == 2 || nBands > 4) {

				return lyr.getRender().getRenderColorInterpretation();

				/*int[] renderBands = lyr.getRender().getRenderBands();

				String[] ci = new String[renderBands.length];

				for (int i = 0; i < renderBands.length; i++) {

					switch (renderBands[i]) {

					case 0:ci[i] = ColorInterpretation.RED_BAND; break;

					case 1:ci[i] = ColorInterpretation.GREEN_BAND; break;

					case 2:ci[i] = ColorInterpretation.BLUE_BAND; break;

					default: ci[i] = ColorInterpretation.UNDEF_BAND; 

					}

				}

				return rManager.getDataStructFactory().createColorInterpretation(ci);*/

			}

		}

		if(nBands == 1)

			return rManager.getDataStructFactory().createColorInterpretation(

				new String[] { ColorInterpretation.GRAY_BAND });

		else {

			String[] ci = new String[nBands];

			for (int i = 0; i < ci.length; i++) {

				ci[i] = ColorInterpretation.UNDEF_BAND;

			}

			return rManager.getDataStructFactory().createColorInterpretation(ci);

		}

	}

	/**

	 * Sustituye la lista de filtros de filterList por la que le pasamos en forma

	 * de ArrayList

	 * @param filterList

	 * @param listFilterUsed

	 * @throws FilterTypeException 

	 * @throws FilterTypeException 

	 */

	public void addSelectedFilters(RasterFilterList filterList, ArrayList<ParamStruct> listFilterUsed) throws FilterManagerException, FilterTypeException {

		filterList.clear();

		for (int i = 0; i < listFilterUsed.size(); i++) {

			ParamStruct aux = (ParamStruct) listFilterUsed.get(i);

			RasterFilterListManager filterManager = filterList.getManagerByFilterClass(aux.getFilterClass());

			filterManager.addFilter(aux.getFilterClass(), aux.getFilterParam());

		}

		filterList.resetPercent();

	}

	public int getPercent() {

		if (rasterFilterList == null)

			return 0;

		if (rasterFilterList.getPercent() < 100)

			return rasterFilterList.getPercent();

		if (geoRasterWriter == null)

			return 0;

		return geoRasterWriter.getPercent();

	}

	public String getTitle() {

		return Messages.getText("aplicando_filtros");

	}

	public void dispose() {

		rasterDataSource = null;

		if(listFilterUsed != null) {

			listFilterUsed.clear();

			listFilterUsed = null;

		}

		rasterFilterList = null;

		geoRasterWriter  = null;

		lyr              = null;

	}

	@Override

	protected void finalize() throws Throwable {

		dispose();

		super.finalize();

	}

}

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

* 

*/

package org.gvsig.raster.tools.app.basic.raster.process;

/**

 * Acciones que puede ejecutar un proceso sobre un objeto externo. Un proceso

 * debe ser independiente de objetos que sean dependientes de su funcionalidad. Es

 * decir, cualquier extensi?n debe poder usar un proceso y este ejecutar metodos

 * de la funcionalidad. Esto se hace ha trav?s de este interfaz.

 * 

 * @version 26/09/2007

 * @author Nacho Brodin (nachobrodin@gmail.com)

 *

 */

public interface IProcessActions {

	/**

	 * El proceso comunica que ha sido interrumpido

	 *

	 */

	public void interrupted();

	/**

	 * Acciones de finalizaci?n del proceso

	 */

	public void end(Object param);

}

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

*

*/

package org.gvsig.raster.tools.app.basic.raster.process;

import java.io.File;

import java.net.URI;

import org.gvsig.andami.PluginServices;

import org.gvsig.fmap.dal.coverage.RasterLocator;

import org.gvsig.fmap.dal.coverage.exception.OverviewException;

import org.gvsig.fmap.dal.coverage.process.BaseIncrementableTask;

import org.gvsig.fmap.dal.coverage.process.overview.OverviewBuilder;

import org.gvsig.raster.fmap.layers.FLyrRaster;

import org.gvsig.raster.mainplugin.config.Configuration;

/**

 * Proceso para la generaci?n de overviews.

 *

 * 10/12/2007

 * @author Nacho Brodin nachobrodin@gmail.com

 */

public class OverviewsProcess extends RasterProcess implements BaseIncrementableTask {

	private FLyrRaster   rasterSE      = null;

	private int          value         = 0;

	private int          resamplingAlg = OverviewBuilder.AVERAGE;

	private int[]        overviews     = new int[] { 2, 4, 8, 16 };

	private String       builder       = "GDAL";

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.rastertools.RasterProcess#init()

	 */

	public void init() {

		rasterSE = getLayerParam("layer");

		builder = getStringParam("builder") != null ? getStringParam("builder") : builder;

		int overviewsRate = 2;

		int nOverviews = 4;

		overviewsRate = Configuration.getValue("overviews_rate", new Integer(overviewsRate)).intValue();

		nOverviews = Configuration.getValue("overviews_number", new Integer(nOverviews)).intValue();

		resamplingAlg = Configuration.getValue("overviews_resampling_algorithm", new Integer(resamplingAlg)).intValue();

		// Leemos de la configuraci?n los valores de algoritmo a usar,

		// n?mero de overviews a generar y proporci?n de la primera overview

		overviews = new int[nOverviews];

		overviews[0] = overviewsRate;

		for (int i = 1; i < nOverviews; i++)

			overviews[i] = overviewsRate * overviews[i - 1];

	}

	/**

	 * M?todo donde se ejecutar? el Thread, aqu? se generaran las

	 * overviews

	 * @throws ProcessException

	 */

	public void process() throws ProcessException {

		insertLineLog(PluginServices.getText(this, "overviews_generating"));

		OverviewBuilder overviewBuilder = RasterLocator.getManager().getOverviewBuilder(builder);

		overviewBuilder.setIncrementListener(this);

		try {

			URI[] uri = rasterSE.getDataStore().getURIByProvider();

			for (int i = 0; i < uri.length; i++) {

				insertLineLog(" Dataset: " + i);

				overviewBuilder.buildOverviews(resamplingAlg, new File(uri[i]).getAbsolutePath(), overviews);

			}

			if (externalActions != null)

				externalActions.end(rasterSE);

		} catch (OverviewException e) {

			if (incrementableTask != null)

				incrementableTask.hideWindow();

			throw new ProcessException("error_write_overviews", e);

		}

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.gui.beans.incrementabletask.IIncrementable#getPercent()

	 */

	public int getPercent() {

		return value;

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.addo.IOverviewIncrement#setPercent(int)

	 */

	public void setPercent(int value) {

		this.value = value;

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.gui.beans.incrementabletask.IIncrementable#getTitle()

	 */

	public String getTitle() {

		return PluginServices.getText(this, "incremento_overview");

	}

	/*

	 * (non-Javadoc)

	 * @see java.lang.Object#finalize()

	 */

	protected void finalize() throws Throwable {

		rasterSE           = null;

		overviews           = null;

		super.finalize();

	}

}

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

* 

*/

package org.gvsig.raster.tools.app.basic.raster.process;

import javax.swing.SwingUtilities;

import org.gvsig.andami.PluginServices;

import org.gvsig.fmap.dal.coverage.exception.FileNotOpenException;

import org.gvsig.fmap.dal.coverage.exception.ProcessInterruptedException;

import org.gvsig.fmap.dal.coverage.exception.RasterDriverException;

import org.gvsig.fmap.dal.coverage.store.props.Statistics;

import org.gvsig.raster.fmap.layers.FLyrRaster;

/**

 * Proceso para la generaci?n de estad?sticas.

 *

 * @author Nacho Brodin nachobrodin@gmail.com

 */

public class StatisticsProcess extends RasterProcess {

	private FLyrRaster            lyr   = null;

	private Statistics            stats = null;

	private boolean               force = false;

	private double                scale = 1;

	/**

	 * Lanzador del procesos de estad?sticas

	 * @param lyr Capa a calcular las estad?sticas

	 * @param actions Clase que recoge eventos del proceso

	 */

	public static void launcher(FLyrRaster lyr, IProcessActions actions) {

		RasterProcess process = new StatisticsProcess();

		process.addParam("layer", lyr);

		process.addParam("force", new Boolean(false));

		process.setActions(actions);

		process.start();	

	}

	public void init() {

		lyr = getLayerParam("layer");

		force = getBooleanParam("force");

		double s = getDoubleParam("scale");

		if(s > 0 && s < 1)

			scale = s;

	}

	/**

	 * M?todo donde se ejecutar? el Thread, aqu? se calcular?n las 

	 * estad?sticas.

	 * @throws ProcessException 

	 */

	public void process() throws ProcessInterruptedException, ProcessException {

		insertLineLog(PluginServices.getText(this, "statistics_generation"));

		if(lyr == null || lyr.getDataStore() == null)

			return;

		stats = lyr.getDataStore().getStatistics();

		lyr.setReadingData(Thread.currentThread().getId() + "");

		if (force)

			stats.forceToRecalc();

		try {

			stats.calculate(scale);

			SwingUtilities.invokeLater(new Runnable() {

				public void run() {

					if (externalActions != null)

						externalActions.end(lyr);

				}

			});

		} catch (FileNotOpenException e) {

			throw new ProcessException("No se ha podido escribir en el fichero rmf", e);

		} catch (RasterDriverException e) {

			throw new ProcessException("Error leyendo bloques de datos para calcular estad?sticas", e);

		} finally {

			lyr.setReadingData(null);

		}

	}

	public int getPercent() {

		return (stats != null) ? stats.getPercent() : 0;

	}

	public String getTitle() {

		return PluginServices.getText(this, "increase_statistics");

	}

}

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

* 

*/

package org.gvsig.raster.tools.app.basic.raster.process;

import org.gvsig.raster.util.Queue;

import org.slf4j.LoggerFactory;

/**

 * Cola de procesos de ejecuci?n exclusiva. Los procesos de esta lista se ir?n ejecutando

 * por orden de llegada impidiendo que se ejecuten dos al mismo tiempo.

 * 

 * 16/05/2008

 * @author Nacho Brodin nachobrodin@gmail.com

 */

public class UniqueProcessQueue implements IProcessActions {

	private static final int          LAPSE_TIME       = 1000;

	private Queue                     queue            = new Queue();

	private RasterProcess             executionProcess = null;

	static private UniqueProcessQueue singleton        = new UniqueProcessQueue();

	/**

	 * Dejamos el constructor privado para que nadie pueda referenciarlo

	 */

	private UniqueProcessQueue() {}

	/**

	 * Devuelve una instancia al unico objeto de UniqueProcessQueue que puede existir.

	 * @return

	 */

	static public UniqueProcessQueue getSingleton() {

		return singleton;

	}

	/**

	 * A?ade un proceso a la cola.

	 * @param id Identificador del proceso

	 * @param process Proceso

	 */

	public synchronized void add(RasterProcess process) {

		queue.put(process);

		process.setUniqueProcessActions(this);

		//Decisi?n de arranque

		if(queue.size() >= 1 && executionProcess != null)

			start();

	}

	/**

	 * Pone en marcha el primer proceso de la lista

	 */

	public void start() {

		nextProcess();

	}

	private void nextProcess() {

		executionProcess = ((RasterProcess) queue.get());

		if (executionProcess != null)

			executionProcess.start();

	}

	/**

	 * Evento de finalizaci?n de un proceso. Cuando un proceso acaba se 

	 * pone en marcha el siguiente de la lista si existe. Se asigna un tiempo de latencia para

	 * la ejecuci?n del siguiente marcado por LAPSE_TIME.  

	 */

	public void end(Object param) {

		try {

			Thread.sleep(LAPSE_TIME);

		} catch (InterruptedException e) {

			LoggerFactory.getLogger(UniqueProcessQueue.class).debug("sleep Exception", e);

		}

		nextProcess();

	}

	/**

	 * How many elements are there in this queue?

	 */

	public int size() {

		return queue.size();

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.raster.IProcessActions#interrupted()

	 */

	public void interrupted() {}	

}