Application: gvSIG desktop » gvSIG raster

import java.awt.geom.Rectangle2D;

import java.io.File;

import java.io.IOException;

import java.net.URL;

import java.util.Hashtable;

import java.util.List;

import javax.swing.ImageIcon;

import org.cresques.cts.ICoordTrans;

import org.cresques.cts.IProjection;

import org.gvsig.compat.net.ICancellable;

import org.gvsig.fmap.crs.CRSFactory;

import org.gvsig.fmap.dal.DALLocator;

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

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

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

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.store.props.HistogramComputer;

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

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

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

import org.gvsig.fmap.dal.spi.DataManagerProviderServices;

import org.gvsig.fmap.dal.spi.DataStoreProviderServices;

import org.gvsig.remoteclient.utils.Utilities;

import org.gvsig.remoteclient.wms.WMSStatus;

import org.gvsig.tools.ToolsLocator;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

	private static final Logger         logger                    = LoggerFactory.getLogger(WMSProvider.class);

	private static final int            FIXED_SIZE               = 800;

	private Extent                      viewRequest              = null;

	                                    drivers                  = new Hashtable<String, WMSConnector> ();

	private boolean                     open                     = false;

	private DataStoreTransparency       fileTransparency         = null;

	private File                        fileLayerPixelSize       = null;

	private File                        lastRequest              = null;

	private AbstractRasterProvider       lastRequestProvider      = null;

	public static void register() {

		DataManagerProviderServices dataman = (DataManagerProviderServices) DALLocator.getDataManager();

		if (dataman != null && !dataman.getStoreProviders().contains(NAME)) {

		}

		dataman.registerStoreFactory(NAME, DefaultStoreFactory.class);

	}

	public WMSProvider() throws NotSupportedExtensionException {

		super();

	}

	public void registerTileProviderFormats(Class<RasterProvider> c) {

	}

	/**

	 * Constructor. Abre el dataset.

	 * @param proj Proyecci?n

	 * @param fName Nombre del fichero

	 * @throws NotSupportedExtensionException

	 */

	public WMSProvider(WMSDataParameters params,

			DataStoreProviderServices storeServices) throws InitializeException {

		super(params, storeServices, ToolsLocator.getDynObjectManager()

								DataStore.METADATA_DEFINITION_NAME)));

		init(params, storeServices);

	}

	/**

	 * Gets the connector from the URL

	 * @return

		WMSDataParameters p = (WMSDataParameters)parameters;

		URL url = null;

		try {

		} catch (Exception e) {

			throw new RemoteServiceException("Malformed URL",e);

		}

			throw new RemoteServiceException("Error getting the connector",e);

		}

	}

	/**

	 * Crea las referencias al fichero y carga

	 * las estructuras con la informaci?n y los metadatos.

			throw new InitializeException(e.getMessage(), e);

		}

	}

	/**

	 * is not available. Only after the first time a raster has been downloaded it can be know.

	 * @param newDataType

	 * @param buf

	 * @param bandList

	 * @return

	 */

	private void loadInitialInfo() throws RasterDriverException {

		WMSDataParametersImpl p = (WMSDataParametersImpl)parameters;

			}

		}

		WMSStatus wmsStatus = loadWMSStatus(bBox);

		lastRequest = downloadFile(wmsStatus, ext.getULX(), ext.getULY(), ext.getLRX(), ext.getLRY(), w, h);

		AbstractRasterProvider driver;

		try {

			throw new RasterDriverException("", e);

		}

	}

	public static final WMSConnector getConnectorFromURL(URL url, boolean updating) throws IOException {

		WMSConnector drv = null;

		if(!updating) {

			if(drivers.get(url.toString()) != null)

				drivers.remove(url.toString());

		}

		if (drv == null) {

			drv = new WMSConnector(url);

			drivers.put(url.toString(), drv);

		}

		return drv;

	}

	/**

	 * Obtiene el objeto que contiene que contiene la interpretaci?n de

	 * color por banda

		}

		return super.getColorInterpretation();

	}

	public AffineTransform getAffineTransform() {

		WMSDataParameters p = (WMSDataParameters)parameters;

		if(p.isSizeFixed()) {

			double psX = e.width() / (p.getWidth() - 1);

			double psY = -(e.height() / (p.getHeight() - 1));

			ownTransformation = new AffineTransform(

					e.getULX() - (psX / 2),

					e.getULY() - (psY / 2));

		} else {

			double psX = bbox.getWidth() / p.getWidth();

			double psY = -(bbox.getHeight() / p.getHeight());

			ownTransformation = new AffineTransform(

					psY,

					bbox.getX(),

					(bbox.getY()+bbox.getHeight())); // FIXME: check for other CRSs such as 4326

		externalTransformation = (AffineTransform) ownTransformation.clone();

		return ownTransformation;

	}

	/**

	 * Calcula el extent en coordenadas del mundo real

	 * @return Extent

	public Extent getExtent() {

		WMSDataParameters p = (WMSDataParameters)parameters;

		Vector<?> layerNames = Utilities.createVector(p.getLayerQuery(), ",");

		String[] ln = new String[layerNames.size()];

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

			ln[i] = (String)layerNames.get(i);

				if (r == null) {

					r = getConnector().getLayersExtent(ln, "CRS:84");

				}

				IProjection reqProj = CRSFactory.getCRS(p.getSRSCode());

				IProjection latLonProj = CRSFactory.getCRS(latLonID);

				if ((reqProj != null) && (latLonProj != null)) {

	public RasterProvider load() {

		return this;

	}

	public boolean isOpen() {

		return open;

	}

	public void close() {

		open = false;

	}

	public Transparency getTransparency() {

		if(fileTransparency == null)

			fileTransparency = new DataStoreTransparency(getColorInterpretation());

		return fileTransparency;

	}

	}

	public void setView(Extent e) {

	public Extent getView() {

		return viewRequest;

	}

	public double getWidth() {

		WMSDataParameters p = (WMSDataParameters)parameters;

		return p.getWidth();

		WMSDataParameters p = (WMSDataParameters)parameters;

		return p.getHeight();

	}

	/**

	 * Gets WMS parameters

	 * @return

		throws InvalidSetViewException, FileNotOpenException, RasterDriverException {

		return null;

	}

	/**

	 * File layer has in the long side FIXED_SIZE pixels and the bounding box is complete. This file could be

	 * useful to build an histogram or calculate statistics. This represents a sample of data.

	 * @return

	public File getFileLayer() throws RasterDriverException {

		if(fileLayerPixelSize != null)

			return fileLayerPixelSize;

		WMSDataParameters p = (WMSDataParameters)parameters;

		Extent e = getExtent();

		Rectangle2D bBox = new Rectangle2D.Double(e.getULX(), e.getLRY(), e.width(), e.height());

		WMSStatus wmsStatus = loadWMSStatus(bBox);

		if(!p.isSizeFixed()) {

			int w = 0;

			int h = 0;

			wmsStatus.setHeight(h);

			fileLayerPixelSize = downloadFile(wmsStatus, e.getULX(), e.getULY(), e.getLRX(), e.getLRY(), w, h);

		} else {

					p.getFixedSize().width, p.getFixedSize().height);

		}

		return fileLayerPixelSize;

	 * Reads a complete block of data and returns an tridimensional array of the right type. This function is useful

	 * to read a file very fast without setting a view. In a WMS service when the size is fixed then it will read the

	 * entire image but when the source hasn't pixel size it will read a sample of data. This set of data will have

	 * @param pos Posici?n donde se empieza  a leer

	 * @param blockHeight Altura m?xima del bloque leido

	 * @return Object que es un array tridimendional del tipo de datos del raster. (Bandas X Filas X Columnas)

	 * @throws FileNotOpenException

	 * @throws RasterDriverException

	 */

	throws InvalidSetViewException, FileNotOpenException, RasterDriverException, ProcessInterruptedException {

		File lastFile = getFileLayer();

		BandList bandList = new BandListImpl();

			throw new RasterDriverException("Error building GdalDriver", exc);

		}

	}

	public double getLastRequestHeight() throws RasterDriverException {

		if(lastRequestProvider == null) {

			try {

		}

		return lastRequestProvider.getHeight();

	}

	public double getLastRequestWidth() throws RasterDriverException {

		if(lastRequestProvider == null) {

			try {

		}

		return lastRequestProvider.getWidth();

	}

	public File getLastRequest() {

		return lastRequest;

	}

	public Buffer getBufferLastRequest() throws ProcessInterruptedException, RasterDriverException {

		try {

			lastRequestProvider = openLastRequest();

			throw new RasterDriverException("Error building GdalDriver", e);

		}

	}

	/**

	 * Opens the last request downloaded

	 * @return

		throws InvalidSetViewException, FileNotOpenException, RasterDriverException {

		return null;

	}

	/**

	 * Gets the georeferencing file name form a raster file

	 * @param file

	 * @return

	 * a georeferencing file

	 */

		String worldFile = file;

		int index = file.lastIndexOf(".");

			worldFile = file.substring(0, index) + getExtensionWorldFile();

		}

		return worldFile;

	}

	/**

	 * Obtiene la extensi?n del fichero de georreferenciaci?n

	 * @return String con la extensi?n del fichero de georreferenciaci?n dependiendo

		}

		return extWorldFile;

	}

	public WMSStatus loadWMSStatus(Rectangle2D bBox) {

		WMSDataParameters p = (WMSDataParameters)parameters;

		WMSStatus wmsStatus = new WMSStatus();

		wmsStatus.setFormat(p.getFormat());

		wmsStatus.setInfoFormat(p.getInfoFormat());

		List<RemoteWMSStyle> listStyles = p.getStyles();

		wmsStatus.setStyles(v);

		wmsStatus.setDimensions(p.getDimensions());

		wmsStatus.setTransparency(p.isWmsTransparent());

			wmsStatus.setProjected(proj.isProjected());

		return wmsStatus;

	}

	/**

	 * This function downloads the file and creates the georeferencing file

	 * @param wmsStatus

		} catch (RemoteServiceException e) {

			throw new RasterDriverException(e.getMessage(), e);

		}

		if(lastRequest == null)

			return null;

		String nameWorldFile = getWorldFile(lastRequest.getPath());

		try {

			if(p.isSizeFixed()) {

		return lastRequest;

	}

	@Override

			throws ProcessInterruptedException, RasterDriverException {

		Extent bbox = q.getRequestBoundingBox();

		lastWidthRequest = q.getBufWidth();

		lastHeightRequest = q.getBufHeight();

		WMSStatus wmsStatus = loadWMSStatus(bbox.toRectangle2D());

				q.getBufHeight());

		if (lastRequest == null) {

			return;

		}

		Buffer b = null;

		try {

			b = getDownloadedRaster(lastRequest);

		}

		q.setBufferResult(b);

	}

	private Buffer getDownloadedRaster(File f) throws ProcessInterruptedException, QueryException, ProviderNotRegisteredException, InitializeException {

		AbstractRasterProvider provider = DefaultProviderServices.loadProvider(new File(f.getPath()));

		setColorTable(provider.getColorTable());

		return getDownloadedRaster(provider);

	}

	private Buffer getDownloadedRaster(AbstractRasterProvider provider) throws ProcessInterruptedException, QueryException, ProviderNotRegisteredException, InitializeException {

		DefaultRasterStore store = new DefaultRasterStore();

		store.setProvider(provider);

			q.setDrawableBands(getColorInterpretation().buildRenderBands());

		if(store.getBandCount() > 3)

			q.forceARGBRequest();

			q.forceRGBRequest();

		Buffer buf = store.query(q);

		store.close();

		return buf;

	}

	/**

	 * Assigns the list of bands RGB and read a window of data

	 * @param rasterBuf

	 * @throws RasterDriverException

	 * @throws ProcessInterruptedException

	 */

			double ulx, double uly, double lrx, double lry) throws RasterDriverException, ProcessInterruptedException {

		try {

			//El nombre de fichero que ha puesto en el bandList es el del servidor y no el del fichero en disco

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(lastFile.getPath());

			}

			AbstractRasterProvider driver = DefaultProviderServices.loadProvider(new File(lastFile.getPath()));

			setColorTable(driver.getColorTable());

			DefaultRasterQuery q = (DefaultRasterQuery)RasterLocator.getManager().createQuery();

			q.setAreaOfInterest(new ExtentImpl(ulx, uly, lrx, lry));

			q.setBandList(bandList);

			q.setBuffer(rasterBuf);

			Buffer buf = driver.getDataSet(q);

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(serverName);

			}

			return buf;

		} catch (ProviderNotRegisteredException e) {

			throw new RasterDriverException("Error building GdalDriver", e);

			throw new RasterDriverException("Error building GdalDriver", e);

		}

	}*/

			BandList bandList, TileListener listener, TaskStatus status) throws ProcessInterruptedException, RasterDriverException {

		Buffer raster = DefaultRasterManager.getInstance().createBuffer(getDataType()[0], bufWidth, bufHeight, 3, true);

		listener.endReading();

	}*/

		throws ProcessInterruptedException, RasterDriverException {

		Rectangle2D bBox = ex.toRectangle2D();

		lastWidthRequest = rasterBuf.getWidth();

		lastHeightRequest = rasterBuf.getHeight();

		WMSStatus wmsStatus = loadWMSStatus(bBox);

		lastRequest = downloadFile(wmsStatus, ex.getULX(), ex.getULY(), ex.getLRX(), ex.getLRY(), rasterBuf.getWidth(), rasterBuf.getHeight());

		if (lastRequest == null) {

			return rasterBuf;

		}

		try {

			//El nombre de fichero que ha puesto en el bandList es el del servidor y no el del fichero en disco

			String serverName = bandList.getBand(0).getFileName();

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(lastRequest.getPath());

			}

			AbstractRasterProvider driver = DefaultProviderServices.loadProvider(new File(lastRequest.getPath()));

			setColorTable(driver.getColorTable());

			DefaultRasterQuery q = (DefaultRasterQuery)RasterLocator.getManager().createQuery();

			q.setAreaOfInterest(ex);

			q.setBandList(bandList);

			q.setBuffer(rasterBuf);

			Buffer buf = driver.getDataSet(q);

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(serverName);

			}

		}

	}*/

			BandList bandList, Buffer rasterBuf, boolean adjustToExtent, TaskStatus status) throws ProcessInterruptedException, RasterDriverException {

		Rectangle2D bBox = new Rectangle2D.Double(ulx, uly, w, h);

		lastWidthRequest = rasterBuf.getWidth();

		lastHeightRequest = rasterBuf.getHeight();

		WMSStatus wmsStatus = loadWMSStatus(bBox);

		lastRequest = downloadFile(wmsStatus, ulx, uly, ulx + w, uly - h, rasterBuf.getWidth(), rasterBuf.getHeight());

		if (lastRequest == null) {

			return rasterBuf;

		}

		try {

			//El nombre de fichero que ha puesto en el bandList es el del servidor y no el del fichero en disco

			String serverName = bandList.getBand(0).getFileName();

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(lastRequest.getPath());

			}

			AbstractRasterProvider driver = DefaultProviderServices.loadProvider(new File(lastRequest.getPath()));

			setColorTable(driver.getColorTable());

			DefaultRasterQuery q = (DefaultRasterQuery)RasterLocator.getManager().createQuery();

			q.setAreaOfInterest(ulx, uly, w, h);

			q.setBandList(bandList);

			q.setBuffer(rasterBuf);

			q.setAdjustToExtent(adjustToExtent);

			Buffer buf = driver.getDataSet(q);

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(serverName);

			}

			return buf;

		} catch (ProviderNotRegisteredException e) {

			throw new RasterDriverException("Error building GdalDriver", e);

		}

	}*/

			BandList bandList, Buffer rasterBuf, boolean adjustToExtent, TaskStatus status) throws ProcessInterruptedException, RasterDriverException {

		Rectangle2D bBox = extent.toRectangle2D();//new Rectangle2D.Double(ulx, lry, Math.abs(lrx - ulx), Math.abs(lry - uly));

		lastWidthRequest = rasterBuf.getWidth();

		lastHeightRequest = rasterBuf.getHeight();

		WMSStatus wmsStatus = loadWMSStatus(bBox);

		lastRequest = downloadFile(wmsStatus, extent.getULX(), extent.getULY(), extent.getLRX(), extent.getLRY(), rasterBuf.getWidth(), rasterBuf.getHeight());

		if (lastRequest == null) {

			return rasterBuf;

		}

		try {

			//El nombre de fichero que ha puesto en el bandList es el del servidor y no el del fichero en disco

			String serverName = bandList.getBand(0).getFileName();

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(lastRequest.getPath());

			}

			AbstractRasterProvider driver = DefaultProviderServices.loadProvider(new File(lastRequest.getPath()));

			setColorTable(driver.getColorTable());

			DefaultRasterQuery q = (DefaultRasterQuery)RasterLocator.getManager().createQuery();

			q.setAreaOfInterest(extent, bufWidth, bufHeight);

			q.setBandList(bandList);

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(serverName);

			}

			return buf;

		} catch (ProviderNotRegisteredException e) {

			throw new RasterDriverException("Error building GdalDriver", e);

		}

	}*/

//			BandList bandList, Buffer rasterBuf) throws ProcessInterruptedException, RasterDriverException {

//		int w = rasterBuf.getWidth();

//		int h = rasterBuf.getHeight();

//		lastHeightRequest = rasterBuf.getHeight();

//		Rectangle2D bBox = new Rectangle2D.Double(p1.getX(), p1.getY(), Math.abs(p1.getX() - p1.getX()), Math.abs(p1.getY() - p2.getY()));

//		WMSStatus wmsStatus = loadWMSStatus(bBox);

//		lastRequest = downloadFile(wmsStatus, p1.getX(), p1.getY(), p2.getX(), p2.getY(), rasterBuf.getWidth(), rasterBuf.getHeight());

//		if (lastRequest == null) {

//			return rasterBuf;

//		}

//			for (int i = 0; i < bandList.getBandCount(); i++) {

//				bandList.getBand(i).setFileName(lastRequest.getPath());

//			}

//			driver = DefaultProviderServices.loadProvider(new File(lastRequest.getPath()));

//			Buffer buf = driver.getWindow(0, 0, w, h, bandList, rasterBuf);

//

//			for (int i = 0; i < bandList.getBandCount(); i++) {

//				bandList.getBand(i).setFileName(serverName);

//			}

//			return buf;

//		} catch (ProviderNotRegisteredException e) {

//			throw new RasterDriverException("Error building GdalDriver", e);

//		}

//	}

			BandList bandList, Buffer rasterBuf, TaskStatus status) throws ProcessInterruptedException, RasterDriverException {

		Point2D p1 = rasterToWorld(new Point2D.Double(x, y));

		Point2D p2 = rasterToWorld(new Point2D.Double(x + w, y + h));

		lastHeightRequest = rasterBuf.getHeight();

		Rectangle2D bBox = new Rectangle2D.Double(p1.getX(), p1.getY(), Math.abs(p1.getX() - p1.getX()), Math.abs(p1.getY() - p2.getY()));

		WMSStatus wmsStatus = loadWMSStatus(bBox);

		lastRequest = downloadFile(wmsStatus, p1.getX(), p1.getY(), p2.getX(), p2.getY(), rasterBuf.getWidth(), rasterBuf.getHeight());

		if (lastRequest == null) {

			return rasterBuf;

		}

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(lastRequest.getPath());

			}

			driver = DefaultProviderServices.loadProvider(new File(lastRequest.getPath()));

			setColorTable(driver.getColorTable());

			DefaultRasterQuery q = (DefaultRasterQuery)RasterLocator.getManager().createQuery();

			q.setAreaOfInterest(0, 0, w, h);

			q.setBandList(bandList);

			for (int i = 0; i < bandList.getBandCount(); i++) {

				bandList.getBand(i).setFileName(serverName);

			}

			return buf;

		} catch (ProviderNotRegisteredException e) {

			throw new RasterDriverException("Error building GdalDriver", e);

	}

	public void setAffineTransform(AffineTransform t){

	}

	public int getOverviewCount(int band) throws BandAccessException, RasterDriverException {

	public String getProviderName() {

		return NAME;

	}

	public String getName() {

		return this.getParameters().getName();

	}

	public String getFullName() {

	}

	/**

	 * Convierte un punto desde coordenadas pixel a coordenadas del mundo.

	 * @param pt Punto a transformar

		}

		return p;

	}

	public void setStatus(RasterProvider provider) {

		if(provider instanceof WMSProvider) {

		}

	}

	/**

	 * ASigna el par?metro de inicializaci?n del driver.

	 */

			this.uri = ((WMSDataParameters)param).getURI();

		this.param = param;

	}

	public String getInfoByPoint(int x, int y, Extent bbox, int w, int h, ICancellable cancellable) throws InfoByPointException {

		WMSDataParameters p = (WMSDataParameters)parameters;

		WMSStatus wmsStatus = new WMSStatus();

			throw new InfoByPointException("Error in getFeatureInfo", e);

		}

	}

	/**

	 * Gets the suffix of the downloaded image

	 * @return

		}

		if (format.indexOf("png") >= 0){

	        return "png";

	    if (format.indexOf("xml") >= 0){

	        return "xml";

	    if (format.indexOf("gif") >= 0){

	        return "gif";

	    }

	    }

	    if (format.indexOf("jpg") >= 0

	        || format.indexOf("jpeg") >= 0){

	    }

		return "xml";

	}

	public TileServer getTileServer() {

		if(tileServer == null) {

			DefaultRasterStore store = new DefaultRasterStore();

		}

		return tileServer;

	}

	public boolean isRasterEnclosed() {

		WMSDataParameters p = (WMSDataParameters)parameters;

		if(p.isSizeFixed()) {

		}

		return true;

	}

		if(lastRequest != null)

		return null;

	}

	public HistogramComputer getHistogramComputer() {

		if (histogram == null)

			histogram = new RemoteStoreHistogram(this);

		return histogram;

	}

}