Statistics
| Revision:

gvsig-raster / org.gvsig.raster.tilecache / branches / org.gvsig.raster.tilecache_dataaccess_refactoring / org.gvsig.raster.tilecache.io / src / main / java / org / gvsig / raster / tilecache / io / TileProvider.java @ 2329

History | View | Annotate | Download (33.5 KB)

1
package org.gvsig.raster.tilecache.io;
2

    
3
import java.awt.Image;
4
import java.awt.geom.AffineTransform;
5
import java.awt.geom.NoninvertibleTransformException;
6
import java.awt.geom.Point2D;
7
import java.io.File;
8
import java.io.FileNotFoundException;
9
import java.io.IOException;
10
import java.lang.reflect.Constructor;
11
import java.lang.reflect.InvocationTargetException;
12
import java.util.List;
13

    
14
import org.gvsig.compat.net.ICancellable;
15
import org.gvsig.fmap.dal.DALLocator;
16
import org.gvsig.fmap.dal.DataStore;
17
import org.gvsig.fmap.dal.DataStoreParameters;
18
import org.gvsig.fmap.dal.coverage.RasterLibrary;
19
import org.gvsig.fmap.dal.coverage.RasterLocator;
20
import org.gvsig.fmap.dal.coverage.dataset.Buffer;
21
import org.gvsig.fmap.dal.coverage.datastruct.BandList;
22
import org.gvsig.fmap.dal.coverage.datastruct.DatasetBand;
23
import org.gvsig.fmap.dal.coverage.datastruct.Extent;
24
import org.gvsig.fmap.dal.coverage.exception.BandAccessException;
25
import org.gvsig.fmap.dal.coverage.exception.BandNotFoundInListException;
26
import org.gvsig.fmap.dal.coverage.exception.FileNotOpenException;
27
import org.gvsig.fmap.dal.coverage.exception.FileNotSupportedException;
28
import org.gvsig.fmap.dal.coverage.exception.InfoByPointException;
29
import org.gvsig.fmap.dal.coverage.exception.InvalidSetViewException;
30
import org.gvsig.fmap.dal.coverage.exception.NotSupportedExtensionException;
31
import org.gvsig.fmap.dal.coverage.exception.ParsingException;
32
import org.gvsig.fmap.dal.coverage.exception.ProcessInterruptedException;
33
import org.gvsig.fmap.dal.coverage.exception.QueryException;
34
import org.gvsig.fmap.dal.coverage.exception.RasterDriverException;
35
import org.gvsig.fmap.dal.coverage.exception.RmfSerializerException;
36
import org.gvsig.fmap.dal.coverage.store.RasterQuery;
37
import org.gvsig.fmap.dal.coverage.store.parameter.MultiDimensionalStoreParameters;
38
import org.gvsig.fmap.dal.coverage.store.parameter.RasterDataParameters;
39
import org.gvsig.fmap.dal.coverage.store.parameter.RemoteStoreParameters;
40
import org.gvsig.fmap.dal.coverage.store.parameter.TileDataParameters;
41
import org.gvsig.fmap.dal.coverage.store.props.ColorInterpretation;
42
import org.gvsig.fmap.dal.coverage.store.props.ColorTable;
43
import org.gvsig.fmap.dal.coverage.util.MathUtils;
44
import org.gvsig.fmap.dal.exception.InitializeException;
45
import org.gvsig.fmap.dal.exception.ProviderNotRegisteredException;
46
import org.gvsig.fmap.dal.exception.ValidateDataParametersException;
47
import org.gvsig.fmap.dal.serverexplorer.filesystem.FilesystemServerExplorer;
48
import org.gvsig.fmap.dal.serverexplorer.filesystem.FilesystemServerExplorerParameters;
49
import org.gvsig.fmap.dal.serverexplorer.filesystem.FilesystemStoreParameters;
50
import org.gvsig.fmap.dal.spi.DataManagerProviderServices;
51
import org.gvsig.fmap.dal.spi.DataStoreProvider;
52
import org.gvsig.fmap.dal.spi.DataStoreProviderServices;
53
import org.gvsig.metadata.MetadataLocator;
54
import org.gvsig.raster.cache.tile.Tile;
55
import org.gvsig.raster.cache.tile.TileCache;
56
import org.gvsig.raster.cache.tile.TileCacheLibrary;
57
import org.gvsig.raster.cache.tile.TileCacheLocator;
58
import org.gvsig.raster.cache.tile.TileCacheManager;
59
import org.gvsig.raster.cache.tile.exception.TileBuildException;
60
import org.gvsig.raster.cache.tile.exception.TileGettingException;
61
import org.gvsig.raster.cache.tile.layer.TiledLayer;
62
import org.gvsig.raster.cache.tile.provider.CacheStruct;
63
import org.gvsig.raster.cache.tile.provider.TileServer;
64
import org.gvsig.raster.impl.buffer.SpiRasterQuery;
65
import org.gvsig.raster.impl.datastruct.BandListImpl;
66
import org.gvsig.raster.impl.datastruct.DatasetBandImpl;
67
import org.gvsig.raster.impl.datastruct.ExtentImpl;
68
import org.gvsig.raster.impl.provider.AbstractRasterProvider;
69
import org.gvsig.raster.impl.provider.MemoryTileMatrixBuffer;
70
import org.gvsig.raster.impl.provider.RasterProvider;
71
import org.gvsig.raster.impl.provider.RemoteRasterProvider;
72
import org.gvsig.raster.impl.provider.TiledRasterProvider;
73
import org.gvsig.raster.impl.store.DefaultRasterStore;
74
import org.gvsig.raster.impl.store.DefaultStoreFactory;
75
import org.gvsig.raster.impl.store.properties.DataStoreColorInterpretation;
76
import org.gvsig.raster.impl.store.properties.DataStoreTransparency;
77
import org.gvsig.raster.impl.store.properties.RemoteDataStoreStatistics;
78
import org.gvsig.tools.ToolsLocator;
79
import org.gvsig.tools.locator.LocatorException;
80
import org.slf4j.Logger;
81
import org.slf4j.LoggerFactory;
82

    
83
/**
84
 * Provider for WMTS service
85
 *
86
 * @author Nacho Brodin (nachobrodin@gmail.com)
87
 */
88
public class TileProvider extends AbstractRasterProvider implements TiledRasterProvider {
89
        public static String                NAME                     = "Tile Store";
90
        public static String                DESCRIPTION              = "Raster Tiled Source";
91
        public static final String          METADATA_DEFINITION_NAME = "TileStore";
92
        private static final Logger         logger                   = LoggerFactory.getLogger(TileProvider.class);
93
        private RasterProvider              provider                 = null;
94
        private boolean                     open                     = false;
95
        private Extent                      viewRequest              = null;
96
        private TiledLayer                  tiledLayer               = null;
97
        private MathUtils                   math                     = RasterLocator.getManager().getMathUtils();
98
        private TileServer                  secondLevelTileServer    = null;
99
         
100
        public static void register() {                
101
                DataManagerProviderServices dataman = (DataManagerProviderServices) DALLocator.getDataManager();
102
                if (dataman != null && !dataman.getStoreProviders().contains(NAME)) {
103
                        dataman.registerStoreProvider(NAME,
104
                                        TileProvider.class, TileDataParametersImpl.class);
105
                }
106

    
107
                /*if(DALFileLocator.getFilesystemServerExplorerManager() != null)
108
                        DALFileLocator.getFilesystemServerExplorerManager().registerProvider(
109
                                        NAME, DESCRIPTION,
110
                                        TileServerExplorer.class);*/
111
                
112
                if (!dataman.getExplorerProviders().contains(TileServerExplorer.NAME)) {
113
                        dataman.registerExplorerProvider(TileServerExplorer.NAME, TileServerExplorer.class, TileServerExplorerParameters.class);
114
                }
115
                dataman.registerStoreFactory(NAME, DefaultStoreFactory.class);
116
        }
117
        
118
        /**
119
         * Loads the specific provider to download data
120
         * @param file
121
         * @return
122
         * @throws NotSupportedExtensionException
123
         * @throws FileNotSupportedException 
124
         */
125
        @SuppressWarnings("unchecked")
126
        private RasterProvider loadProvider(TileDataParametersImpl params, DataStoreProviderServices storeServices) throws ProviderNotRegisteredException, InitializeException {
127
                Object obj = params.getDataParameters();
128
                DataManagerProviderServices dataManager = (DataManagerProviderServices)DALLocator.getDataManager();
129
                DataStoreProvider prov = null;
130
                
131
                if(obj != null && obj instanceof DataStoreParameters) //Remote 
132
                        prov = dataManager.createProvider(storeServices, (DataStoreParameters)obj);
133
                else { //File
134
                        if(params.getFile() != null) {
135
                                //We have to locate a provider's name which manages the selected file
136
                                //A FilesystemServerExplorer will give a getProviderNames service
137
                                FilesystemServerExplorerParameters paramsExplorer = (FilesystemServerExplorerParameters)dataManager.createServerExplorerParameters(FilesystemServerExplorer.NAME);
138
                                FilesystemServerExplorer serverExplorer = null;
139
                                try {
140
                                        paramsExplorer.setRoot(File.separator);
141
                                        serverExplorer = (FilesystemServerExplorer)dataManager.openServerExplorer(FilesystemServerExplorer.NAME, paramsExplorer);
142
                                } catch (ValidateDataParametersException e) {
143
                                        throw new InitializeException(e);
144
                                }
145
                                
146
                                //Gets the list of provider's name to manage the file
147
                                List<String> provName = serverExplorer.getProviderNameList(params.getFile());
148
                                if(provName.size() > 0) {
149
                                        for (int i = 0; i < provName.size(); i++) {
150
                                                //Gets the first provider what is not a TileProvider
151
                                                if(provName.get(i).compareTo(NAME) != 0) {
152
                                                        DataStoreParameters newparams = dataManager.createStoreParameters(provName.get(i));
153
                                                        ((FilesystemStoreParameters)newparams).setFile(params.getFile()); 
154
                                                        prov = dataManager.createProvider(storeServices, newparams);
155
                                                }
156
                                        }
157
                                }
158
                        }
159
                }
160
                
161
                if(prov != null && prov instanceof RasterProvider) {
162
                        if(((RasterProvider)prov).isRotated())
163
                                throw new InitializeException("Rotation not supported tiling files", new Throwable());
164

    
165
                        return (RasterProvider)prov;
166
                }
167
                
168
                return null;
169
        }
170
        
171
        /**
172
         * Gets the internal provider used to feed the TileProvider
173
         * @return
174
         */
175
        public RasterProvider getInternalProvider() {
176
                return provider;
177
        }
178
        
179
        public Image getImageLegend() {
180
                return provider.getImageLegend();
181
        }
182
        
183
        public ColorInterpretation getColorInterpretation() {
184
                return provider.getColorInterpretation();
185
        }
186
        
187
        public String getFileSuffix() {
188
                try {
189
                        return provider instanceof RemoteRasterProvider ? provider.getFileSuffix() : "tif";
190
                } catch(Throwable e) {
191
                        //if wmts doesn't exists in the classpath
192
                        return "tif";
193
                }
194
        }
195
        
196
        public String getRMFFile() {
197
                TileCacheManager  manager = TileCacheLocator.getManager();
198
                TileCache tileCache = manager.getTileCache(RasterLibrary.pathTileCache);
199
                
200
                String path = tiledLayer.getBaseLayerDirectory().substring(0, tiledLayer.getBaseLayerDirectory().lastIndexOf(File.separator) + 1) + 
201
                                          tileCache.getConfigurationDirectory() + File.separator + 
202
                                          tiledLayer.getID() + ".rmf";
203
                
204
                try {
205
                        if(!new File(path).exists() && 
206
                                provider != null && 
207
                                provider.getRMFFile() != null &&
208
                                new File(provider.getRMFFile()).exists()) 
209
                                RasterLocator.getManager().getFileUtils().copyFile(provider.getRMFFile(), path);
210
                        
211
                        if(provider != null && provider.getColorTable() != null) {        
212
                                ColorTable colorTable = provider.getColorTable();
213
                                RasterLocator.getManager().getProviderServices().saveObjectToRmfFile(path, ColorTable.class, colorTable);
214
                        }
215
                } catch (LocatorException e) {
216
                        logger.info("No se ha podido copiar el fichero RMF a la capa tileada", e);
217
                } catch (FileNotFoundException e) {
218
                        logger.info("No se ha podido copiar el fichero RMF a la capa tileada", e);
219
                } catch (IOException e) {
220
                        logger.info("No se ha podido copiar el fichero RMF a la capa tileada", e);
221
                } catch (RmfSerializerException e) {
222
                        logger.info("No se ha podido copiar la tabla de color a la capa tileada", e);
223
                }
224
                return path;
225
        }
226
        
227
        public TileProvider() throws NotSupportedExtensionException {
228
                super();
229
        }
230
        
231
        public void registerTileProviderFormats(Class<RasterProvider> c) {
232
                
233
        }
234
        
235
        /**
236
         * Assigns the provider associated to this tile server
237
         * @param prov
238
         * @throws NotSupportedExtensionException 
239
         */
240
        public void setProvider(RasterProvider prov) throws InitializeException  {
241
                this.provider = prov;
242
                init(getDataStoreParameters(), getStoreServices());
243
        }
244
        
245
        public TileProvider(TileDataParametersImpl params,
246
                        DataStoreProviderServices storeServices) throws InitializeException {
247
                super(params, storeServices, ToolsLocator.getDynObjectManager()
248
                                .createDynObject(
249
                                                MetadataLocator.getMetadataManager().getDefinition(
250
                                                                DataStore.METADATA_DEFINITION_NAME)));
251
                if(!params.isSecondLevelCache()) {
252
                        try {
253
                                provider = loadProvider(params, storeServices);
254
                        } catch (ProviderNotRegisteredException e) {
255
                                throw new InitializeException("Provider not registered", e);
256
                        }
257
                        init(params, storeServices);
258
                        if(provider.getFileSizeByProvider() != null && provider.getFileSizeByProvider().length > 0)
259
                                fileSize = provider.getFileSizeByProvider()[0];
260
                }
261
        }
262
        
263
        /**
264
         * Creates the second level cache if the client has set a <code>TileServer</code> and the
265
         * <code>CacheStruct</code> is different that the old one. 
266
         * <UL>
267
         * <LI>First level cache without TileServer from the client: do nothing</LI>
268
         * <LI>First level cache with TileServer from the client and the structure is 
269
         * different to the old one: Builds a second level TileProvider</LI>
270
         * <LI>First level cache with TileServer from the client and the structure is 
271
         * equal to the old one: do nothing</LI>
272
         * <LI>Second level cache: sets the TileServer</LI>
273
         * </UL>
274
         * @param params
275
         * @param storeServices
276
         * @throws NotSupportedExtensionException
277
         */
278
        /*private void createsSecondLevelCache(TileDataParametersImpl params) throws NotSupportedExtensionException {
279
                //Se obtiene el TileServer que haya pasado el cliente en los par?metros si ha pasado alguno.
280
                TileServer tileServer = params.getTileServer();
281
                //Se obtiene el CacheStruct y se compara con el del provider
282
                CacheStruct cacheStruct = null;
283
                if(tileServer != null)
284
                        cacheStruct = tileServer.getStruct();
285
                
286
                if(params.isSecondLevelCache()) { //Cache de segundo nivel
287
                        this.secondLevelTileServer = tileServer;
288
                } else if(cacheStruct != null && !provider.getTileServer().getStruct().compare(cacheStruct)) { //Cache de primer nivel
289
                        //Si son distintos habr? que crear una cach? de segundo nivel por lo que creamos un nuevo TileProvider
290
                        //que tenga como par?metro el provider viejo
291
                        TileDataParametersImpl par = new TileDataParametersImpl();
292
                        par.setDataParameters(provider.getDataParameters());
293
                        par.setTileServer(tileServer);
294
                        par.setSecondLevelCache(true);
295
                        TileProvider newProvider = new TileProvider(par, null);
296
                        newProvider.setProvider(this.provider);
297
                        //Al TileProvider actual se le asigna como provider el TileProvider creado
298
                        this.provider = newProvider;
299
                }
300
        }*/
301
        
302
        /**
303
         * Crea las referencias al fichero y carga
304
         * las estructuras con la informaci?n y los metadatos.
305
         * @param proj Proyecci?n
306
         * @param param Parametros de carga
307
         * @throws NotSupportedExtensionException
308
         */
309
        public void init (DataStoreParameters params,
310
                        DataStoreProviderServices storeServices) throws InitializeException  {
311
                setParam(storeServices, params);
312
                open = true;
313
                calculateDataType();
314
                calculateBandCount();
315
                calculateColorInterpretation();
316
                calculateTransparency();
317
                setColorTable(provider.getColorTable());
318
                noData = provider.getNoDataValue();
319
                setFName(provider.getURIOfFirstProvider());
320
                proj = provider.getProjection();
321
                ownTransformation = provider.getAffineTransform();
322
                externalTransformation = (AffineTransform)ownTransformation.clone();
323
                
324
                createTiledLayer();
325
                
326
                //Force to deletes the layer if the flag is to true
327
                if(tiledLayer != null) {
328
                        if(param instanceof TileDataParameters) {
329
                                if(((TileDataParameters)param).isDeletingCache()) {
330
                                        TileCacheManager  manager = TileCacheLocator.getManager();
331
                                        TileCache tileCache = manager.getTileCache(RasterLibrary.pathTileCache);
332
                                        tileCache.removeLayer(tiledLayer);
333
                                        ((TileDataParameters)param).deleteCache(false);
334
                                }
335
                        }
336
                }
337
                
338
                if(provider instanceof RemoteRasterProvider)
339
                        stats = new RemoteDataStoreStatistics(provider);
340
        }
341

    
342
        /**
343
         * Calculates the data type of this provider
344
         * @return 
345
         */
346
        public void calculateDataType() {
347
                int[] datatype = null;
348
                if(provider.getDataType()[0] == Buffer.TYPE_BYTE && provider.getBandCount() == 3)
349
                        datatype = new int[provider.getBandCount() + 1];
350
                else
351
                        datatype = new int[provider.getBandCount()];
352
                for (int i = 0; i < provider.getDataType().length; i++) {
353
                        datatype[i] = provider.getDataType()[i];
354
                }
355
                if(provider.getDataType()[0] == Buffer.TYPE_BYTE && provider.getBandCount() == 3)
356
                        datatype[datatype.length - 1] = Buffer.TYPE_BYTE;
357
                setDataType(datatype);
358
        }
359
        
360
        /**
361
         * Calculates the number of bands
362
         */
363
        public void calculateBandCount() {
364
                bandCount = provider.getBandCount();
365
                if(provider.getDataType()[0] == Buffer.TYPE_BYTE && provider.getBandCount() == 3)
366
                        bandCount ++;
367
        }
368

    
369
        /**
370
         * Calculates the color interpretation
371
         */
372
        public void calculateColorInterpretation() {
373
                ColorInterpretation ci = provider.getColorInterpretation();
374
                if(ci != null) {
375
                        if(ci.isRGB() || ci.isBGR()) {
376
                                ci = DataStoreColorInterpretation.createRGBAInterpretation();
377
                        } else
378
                                ci = ci.cloneColorInterpretation();
379
                } else {
380
                        if(provider.getDataType()[0] == Buffer.TYPE_BYTE) {
381
                                if(provider.getBandCount() == 3)
382
                                        ci = DataStoreColorInterpretation.createRGBAInterpretation();
383
                                else
384
                                        ci = DataStoreColorInterpretation.createDefaultInterpretation(getBandCount());
385
                        } else {
386
                                if(getBandCount() == 1)
387
                                        ci = DataStoreColorInterpretation.createGrayInterpretation();
388
                                else 
389
                                        ci = DataStoreColorInterpretation.createDefaultInterpretation(getBandCount());
390
                        }
391
                }
392

    
393
                super.setColorInterpretation(ci);
394
        }
395
        
396
        
397
        public void calculateTransparency() {
398
                if(provider.getTransparency() != null)
399
                        transparency = provider.getTransparency().cloneTransparency();
400
                else 
401
                        transparency = new DataStoreTransparency(getColorInterpretation());
402
                if(getColorInterpretation() != null) {
403
                        transparency.setColorInterpretation(getColorInterpretation());
404
                        transparency.setTransparencyBand(getColorInterpretation().getAlphaBand());
405
                        transparency.activeTransparency();
406
                }
407
        }
408
        
409
        /**
410
         * Creates a new tiled layer if this hasn't been created yet or the ID has changed. 
411
         * An ID could changed because the file type has changed when the user uses WMTS properties.
412
         */
413
        private void createTiledLayer() {
414
                TileCacheManager  manager = TileCacheLocator.getManager();
415
                TileCache tileCache = manager.getTileCache(RasterLibrary.pathTileCache);
416
                TiledLayer newLayer = tileCache.createLayer(provider.getTileServer(), TileCacheLibrary.DEFAULT_STRUCTURE);
417
                if(tiledLayer == null || newLayer.getID().compareTo(tiledLayer.getID()) != 0)
418
                        tiledLayer = newLayer;
419
        }
420
        
421
        public void reload() {
422
                try {
423
                        loadFromRmf(getRmfBlocksManager());
424
                        calculateColorInterpretation();
425
                        calculateTransparency();
426
                } catch (ParsingException e) {
427
                        logger.debug("No se ha podido leer el RMF", e);
428
                }
429
        }
430
        
431
        public int getZoomLevels() {
432
                if(provider.getTileServer() != null)
433
                        return provider.getTileServer().getStruct().getNumberOfLevels();
434
                return 0;
435
        }
436
        
437
        public int getNearestLevel(double pixelSize) {
438
                double[] pixelSizes = getPixelSizeByLevel();
439
                for (int i = 0; i < pixelSizes.length - 1; i++) {
440
                        if(pixelSize <= pixelSizes[i] && pixelSize > pixelSizes[i + 1]) {
441
                                return i;
442
                        }
443
                }
444
                if(pixelSize < pixelSizes[getZoomLevels() - 1])
445
                        return getZoomLevels() - 1;
446
                return 0;
447
        }
448
        
449
        /**
450
         * Returns a list of pixel sizes by level
451
         * @return
452
         */
453
        public double[] getPixelSizeByLevel() {
454
                double[] list = new double[getZoomLevels()];
455
                CacheStruct struct = provider.getTileServer().getStruct();
456
                for (int i = 0; i < struct.getNumberOfLevels(); i++) {
457
                        list[i] = math.adjustDouble(struct.getPixelSizeByLevel(i));
458
                }
459
                return list;
460
        }
461
        
462
        public Extent getCoordsInTheNearestLevel(Extent extent, int w, int h) {
463
                double[] pixelSizes = getPixelSizeByLevel();
464
                double currentPixelSize = extent.width() / (double)w;
465
                
466
                int level = 0;
467
                for (int i = 0; i < (pixelSizes.length - 1); i++) {
468
                        if(currentPixelSize < pixelSizes[i] && currentPixelSize >= pixelSizes[i + 1]) {
469
                                level = i + 1;
470
                                break;
471
                        }
472
                }
473
                
474
                return getZoomLevelCoordinates(level, extent, w, h);
475
        }
476
        
477
        public Extent getCoordsInLevel(Point2D viewCenter, int level, int w, int h) {
478
                level = adjustLevel(level);
479
                double pixelSize = provider.getTileServer().getStruct().getPixelSizeByLevel(level);
480
                
481
                /*Rectangle2D worldExtent = provider.getTileServer().getStruct().getWorldExtent();
482
                int nTiles = provider.getTileServer().getStruct().getLayerWidthOfTileMatrixByLevel(level);
483
                int[] nPixelsByTile = provider.getTileServer().getStruct().getTileSizeByLevel(level);
484
                
485
                double sizeWCByTile = worldExtent.getWidth() / (double)nTiles;
486
                double pixelSize = sizeWCByTile / (double)nPixelsByTile[0];*/
487
                
488
                double ulx = viewCenter.getX() - ((w / 2) * pixelSize);
489
                double uly = viewCenter.getY() - ((h / 2) * pixelSize);
490
                double lrx = ulx + (w * pixelSize);
491
                double lry = uly + (h * pixelSize);
492
                return new ExtentImpl(ulx, uly, lrx, lry);
493
        }
494
        
495
        /**
496
         * Adjust de level to the range
497
         * @param level
498
         * @return
499
         */
500
        private int adjustLevel(int level) {
501
                if(level < 0)
502
                        level = 0;
503
                if(level > getZoomLevels())
504
                        level = getZoomLevels();
505
                return level;
506
        }
507
        
508
        public AffineTransform getAffineTransform() {
509
                return provider.getAffineTransform();
510
        }
511
        
512
        /**
513
         * Gets the bounding box in world coordinates. If the layer has grid subsets (TileMatrixLimits) then
514
         * this will have a only extent but if the layer doesn't have grid subsets then this will have a different
515
         * extent in each level resolution. In this case we need to know the extent for each level.
516
         * @return Extent
517
         */
518
        public Extent getExtent() {
519
                return provider.getExtent();
520
        }
521

    
522
        public RasterProvider load() {
523
                return this;
524
        }
525
        
526
        public boolean isOpen() {
527
                return open;
528
        }
529

    
530
        public boolean isTiled() {
531
                return true;
532
        }
533
        
534
        public void close() {
535
                open = false;
536
                if(provider != null)
537
                        provider.close();
538
        }
539
        
540
        public String translateFileName(String fileName) {
541
                return fileName;
542
        }
543

    
544
        public void setView(Extent e) {
545
                viewRequest = e;
546
        }
547

    
548
        public Extent getView() {
549
                return viewRequest;
550
        }
551

    
552
        public double getWidth() {
553
                return provider.getWidth();
554
        }
555

    
556
        public double getHeight() {
557
                return provider.getHeight();
558
        }
559

    
560
        public Object readCompleteLine(int line, int band)
561
                throws InvalidSetViewException, FileNotOpenException, RasterDriverException {
562
                return null;
563
        }
564
        
565
        public File getFileLayer() throws RasterDriverException {
566
                return null;
567
        }
568

    
569
        @SuppressWarnings("deprecation")
570
        public Object readBlock(int pos, int blockHeight, double scale) 
571
        throws InvalidSetViewException, FileNotOpenException, RasterDriverException, ProcessInterruptedException {
572
                //TODO: temporal hasta que haya un generador de estad?sticas parciales para realce.
573
                //Pongo este m?todo deprecated porque el objetivo es eliminarlo de los proveedores.
574
                if(provider.getBandCount() < getBandCount()) {
575
                        switch (getDataType()[0]) {
576
                        case Buffer.TYPE_BYTE:
577
                                byte[][][] buf1 = (byte[][][])provider.readBlock(pos, blockHeight, scale);
578
                                byte[][][] b1 = new byte[buf1.length + 1][][];
579
                                for (int i = 0; i < buf1.length; i++) {
580
                                        b1[i] = buf1[i];
581
                                }
582
                                b1[b1.length - 1] = new byte[buf1[0].length][buf1[0][0].length];
583
                                return b1;
584
                        case Buffer.TYPE_SHORT:
585
                                short[][][] buf2 = (short[][][])provider.readBlock(pos, blockHeight, scale);
586
                                short[][][] b2 = new short[buf2.length + 1][][];
587
                                for (int i = 0; i < buf2.length; i++) {
588
                                        b2[i] = buf2[i];
589
                                }
590
                                b2[b2.length - 1] = new short[buf2[0].length][buf2[0][0].length];
591
                                return b2;
592
                        case Buffer.TYPE_FLOAT:
593
                                float[][][] buf3 = (float[][][])provider.readBlock(pos, blockHeight, scale);
594
                                float[][][] b3 = new float[buf3.length + 1][][];
595
                                for (int i = 0; i < buf3.length; i++) {
596
                                        b3[i] = buf3[i];
597
                                }
598
                                b3[b3.length - 1] = new float[buf3[0].length][buf3[0][0].length];
599
                                return b3;
600
                        case Buffer.TYPE_DOUBLE: 
601
                                double[][][] buf4 = (double[][][])provider.readBlock(pos, blockHeight, scale);
602
                                double[][][] b4 = new double[buf4.length + 1][][];
603
                                for (int i = 0; i < buf4.length; i++) {
604
                                        b4[i] = buf4[i];
605
                                }
606
                                b4[b4.length - 1] = new double[buf4[0].length][buf4[0][0].length];
607
                                return b4;
608
                        case Buffer.TYPE_INT:
609
                                int[][][] buf5 = (int[][][])provider.readBlock(pos, blockHeight, scale);
610
                                int[][][] b5 = new int[buf5.length + 1][][];
611
                                for (int i = 0; i < buf5.length; i++) {
612
                                        b5[i] = buf5[i];
613
                                }
614
                                b5[b5.length - 1] = new int[buf5[0].length][buf5[0][0].length];
615
                                return b5;
616
                        }
617
                        
618
                }
619
                return provider.readBlock(pos, blockHeight, scale);
620
        }
621

    
622
        public Object getData(int x, int y, int band)
623
                throws InvalidSetViewException, FileNotOpenException, RasterDriverException {
624
                return provider.getData(x, y, band);
625
        }
626
        
627
        /**
628
         * Assigns the list of bands RGB and read a window of data
629
         * @param rasterBuf
630
         * @param bandList
631
         * @param lastFile
632
         * @param ulx
633
         * @param uly
634
         * @param lrx
635
         * @param lry
636
         * @return
637
         * @throws RasterDriverException
638
         * @throws ProcessInterruptedException
639
         */
640
        public Buffer getBuffer(Buffer rasterBuf, BandList bandList, File lastFile, 
641
                        double ulx, double uly, double lrx, double lry) throws RasterDriverException, ProcessInterruptedException {
642
                return null;
643
        }
644
        
645
        /**
646
         * Calculates the extent of a zoom level using other extent as a reference. The new extent is 
647
         * calculated with the same coordinate at the center. 
648
         * @param level
649
         * @param extent
650
         * @param w
651
         * @param h
652
         * @return
653
         */
654
        public Extent getZoomLevelCoordinates(int level, Extent extent, int w, int h) {
655
                double centerX = extent.getCenterX();
656
                double centerY = extent.getCenterY();
657
                return getCoordsInLevel(new Point2D.Double(centerX, centerY), level, w, h);
658
        }
659
        
660
        public boolean isRasterEnclosed() {
661
                if(provider != null)
662
                        return provider.isRasterEnclosed();
663
                return super.isRasterEnclosed();
664
        }
665
        
666
        /**
667
         * Gets the tile list in a selected extent
668
         * @param ex
669
         * @param bandList
670
         * @param bufWidth
671
         * @param bufHeight
672
         * @return
673
         * @throws TileBuildException 
674
         */
675
        private List<Tile> getTileList(SpiRasterQuery q) throws TileBuildException {
676
                TileServer tileServer = provider.getTileServer();
677
                CacheStruct struct = tileServer.getStruct();
678
                tileServer.setFileSuffix(getFileSuffix());
679
                
680
                createTiledLayer(); //Creates a new layer when the file type changes
681
                
682
                double pixelSizeRequest = q.getRequestBoundingBox().width() / q.getBufWidth();
683
                
684
                List<Tile> tileList = struct.getTileList(
685
                                        q.getAdjustedRequestBoundingBox().getUL(), 
686
                                        q.getAdjustedRequestBoundingBox().getLR(), 
687
                                        pixelSizeRequest);
688

    
689
                for (int i = 0; i < tileList.size(); i++) {
690
                        loadTileTimeParameters(tileList.get(i));
691
                }
692
                
693
                for (int i = 0; i < tileList.size(); i++) {
694
                        tileList.get(i).setDownloaderParams("BandList", q.getBandList().clone());
695
                }
696
                return tileList;
697
        }
698
        
699
        /**
700
         * Loads the multidimensional parameters in a tile 
701
         * @param tile
702
         */
703
        private void loadTileTimeParameters(Tile tile) {
704
                if(provider.getDataParameters() instanceof MultiDimensionalStoreParameters) {
705
                        MultiDimensionalStoreParameters par = (MultiDimensionalStoreParameters)provider.getDataParameters();
706
                        tile.setVariable(par.getStringVariable());
707
                        tile.setZ(par.getStringLevel());
708
                        tile.setTimeInstant(par.getStringTime());
709
                }
710
        }
711
        
712
        public boolean needEnhanced() {
713
                return provider.needEnhanced();
714
        }
715
        
716
        public Tile getTile(SpiRasterQuery q) throws TileGettingException {
717
                if(q.getCacheStruct() == null)
718
                        q.setCacheStruct(provider.getTileServer().getStruct());
719
                else
720
                        provider.getTileServer().setStruct(q.getCacheStruct());
721
                
722
                Tile tile = null;
723
                try {
724
                        tile = q.getCacheStruct().getTileStructure(
725
                                        q.getResolutionLevel(), q.getTileCol(), q.getTileRow(), 
726
                                        q.getAdjustedRequestBoundingBox().getUL(), 
727
                                        q.getAdjustedRequestBoundingBox().getLR());
728
                } catch (TileBuildException e1) {
729
                        throw new TileGettingException(e1);
730
                }
731
                
732
                loadTileTimeParameters(tile);
733
                
734
                //Creamos un BandList con todas las bandas del fichero
735
                BandList bandList = new BandListImpl();
736
                for(int i = 0; i < provider.getBandCount(); i++) {
737
                        try {
738
                                DatasetBand band = new DatasetBandImpl(provider.getURIOfFirstProvider(), i, provider.getDataType()[i], provider.getBandCount());
739
                                bandList.addBand(band);
740
                        } catch(BandNotFoundInListException e) {
741
                                //No a?adimos la banda
742
                        }
743
                }
744
                bandList.setDrawableBands(new int[]{0, 1, 2});
745
                
746
                tile.setDownloaderParams("BandList", bandList);
747
                createTiledLayer();
748
                return tiledLayer.getTile(tile);
749
        }
750
        
751
        @Override
752
        public void loadBuffer(SpiRasterQuery q) 
753
                        throws ProcessInterruptedException, RasterDriverException {
754
                try {
755
                        
756
                        if(q.requestIsTiled()) {
757
                                List<Tile> tileList = getTileList(q);
758
                                tiledLayer.getTiles(tileList, q.getTileListener(), q.getTaskStatus());
759
                        } else {
760
                                if(provider.isTiled()) {
761
                                        queryToInternalTiledProvider(q);
762
                                } else {
763
                                        queryToInternalProvider(q);
764
                                }
765
                        }
766
                        
767
                } catch (TileGettingException e) {
768
                        throw new RasterDriverException("Error getting the tile list", e);
769
                } catch (TileBuildException e) {
770
                        throw new RasterDriverException("Error building the tile list", e);
771
                } catch (QueryException e) {
772
                        throw new RasterDriverException("Error querying to the internal provider", e);
773
                }
774
                
775
        }
776
        
777
        private void queryToInternalTiledProvider(SpiRasterQuery parentQuery) throws TileGettingException, TileBuildException {
778
                List<Tile> tileList = getTileList(parentQuery);
779
                for (int i = 0; i < tileList.size(); i++) {
780
                        tiledLayer.getTile(tileList.get(i));
781
                }
782
                MemoryTileMatrixBuffer matrixBuffer = new MemoryTileMatrixBuffer(tileList);
783
                Buffer buf = matrixBuffer.getWindow(parentQuery.getAdjustedRequestBoundingBox(), parentQuery.getBufWidth(), parentQuery.getBufHeight(), parentQuery.getBandList().getDrawableBandsCount());
784
                parentQuery.setBufferResult(buf);
785
        }
786
        
787
        private void queryToInternalProvider(SpiRasterQuery parentQuery) throws ProcessInterruptedException, QueryException {
788
                DefaultRasterStore store = new DefaultRasterStore();
789
                store.setProvider(provider);
790
                
791
                RasterQuery query = RasterLocator.getManager().createQuery();
792
                query.setAreaOfInterest(parentQuery.getAdjustedRequestBoundingBox(), parentQuery.getBufWidth(), parentQuery.getBufHeight());
793
                int[] dBands = null;
794
                if(parentQuery.getDrawableBands() != null) {
795
                        dBands = parentQuery.getDrawableBands().clone();
796
                        if(!((AbstractRasterProvider)provider).getTransparency().existAlphaBand() && getTransparency().existAlphaBand()) {
797
                                dBands[getTransparency().getAlphaBandNumber()] = -1; 
798
                        }
799
                }
800
                query.setReadOnly(((RasterQuery)parentQuery).isReadOnly());
801
                if(((RasterQuery)parentQuery).isforcingARGBRequest())
802
                        query.forceARGBRequest();
803
                if(((RasterQuery)parentQuery).isforcingRGBRequest())
804
                        query.forceRGBRequest();
805
                if(dBands == null)
806
                        query.setAllDrawableBands();
807
                else
808
                        query.setDrawableBands(dBands);
809
                query.setAdjustToExtent(true);
810
                store.query(query);
811
                parentQuery.setBufferResult(((SpiRasterQuery)query).getBufferForProviders());
812
        }
813

    
814
        public int getBlockSize() {
815
                return 0;
816
        }
817

    
818
        public void setAffineTransform(AffineTransform t){
819
                
820
        }
821

    
822
        public int getOverviewCount(int band) throws BandAccessException, RasterDriverException {
823
                return getZoomLevels();
824
        }
825

    
826
        public int getOverviewWidth(int band, int overview) throws BandAccessException, RasterDriverException {
827
                return provider.getTileServer().getStruct().getLayerWidthOfTileMatrixByLevel(overview) * 
828
                                provider.getTileServer().getStruct().getTileSizeByLevel(overview)[0];
829
        }
830

    
831
        public int getOverviewHeight(int band, int overview) throws BandAccessException, RasterDriverException {
832
                return provider.getTileServer().getStruct().getLayerHeightOfTileMatrixByLevel(overview) * 
833
                                provider.getTileServer().getStruct().getTileSizeByLevel(overview)[0];
834
        }
835

    
836
        public boolean isOverviewsSupported() {
837
                return false;
838
        }
839

    
840
        public String getName() {
841
                return NAME;
842
        }
843
        
844
        /**
845
         * Convierte un punto desde coordenadas pixel a coordenadas del mundo.
846
         * @param pt Punto a transformar
847
         * @return punto transformado en coordenadas del mundo
848
         */
849
        public Point2D rasterToWorld(Point2D pt) {
850
                Point2D p = new Point2D.Double();
851
                getAffineTransform().transform(pt, p);
852
                return p;
853
        }
854

    
855
        /**
856
         * Convierte un punto desde del mundo a coordenadas pixel.
857
         * @param pt Punto a transformar
858
         * @return punto transformado en coordenadas pixel
859
         */
860
        public Point2D worldToRaster(Point2D pt) {
861
                Point2D p = new Point2D.Double();
862
                try {
863
                        getAffineTransform().inverseTransform(pt, p);
864
                } catch (NoninvertibleTransformException e) {
865
                        return pt;
866
                }
867
                return p;
868
        }
869
        
870
        public void setStatus(RasterProvider provider) {
871
                if(provider instanceof TileProvider) {
872
                }
873
        }
874
        
875
        /**
876
         * ASigna el par?metro de inicializaci?n del driver.
877
         */
878
        @Override
879
        public void setParam(DataStoreProviderServices storeServices, DataStoreParameters param) {
880
                if(param instanceof RemoteStoreParameters)
881
                        this.uri = ((RasterDataParameters)param).getURI();
882
                this.param = param;
883
                this.storeServices = storeServices;
884
        }
885
        
886
        public String getInfoByPoint(double x, double y, ICancellable cancellable) throws InfoByPointException {
887
                if(provider != null)
888
                        return provider.getInfoByPoint(x, y, cancellable);
889
                return "Not implemented";
890
        }
891
        
892
        public String getInfoByPoint(int x, int y, Extent bbox, int w, int h, ICancellable cancellable) throws InfoByPointException {
893
                if(provider != null)
894
                        return provider.getInfoByPoint(x, y, bbox, w, h, cancellable);
895
                return "Not implemented";
896
        }
897
        
898
        public int[] getTileSize(int level) {
899
                return provider.getTileServer().getStruct().getTileSizeByLevel(level);
900
        }
901
        
902
        public void deleteLayerFromCache() {
903
                TileCacheManager  manager = TileCacheLocator.getManager();
904
                TileCache tileCache = manager.getTileCache(RasterLibrary.pathTileCache);
905
                if(tiledLayer != null)
906
                        tileCache.removeLayer(tiledLayer);
907
        }
908
        
909
        public TileServer getTileServer() {
910
                return secondLevelTileServer;
911
        }
912
        
913
        public void setSecondLevelTileServer(TileServer tileServer) {
914
                this.secondLevelTileServer = tileServer;
915
        }
916
        
917
        public void setTileServer(Class<?> tileServer) throws InitializeException {
918
                //TODO:Manejar excepciones
919
                //Crear par?metros
920
                TileDataParametersImpl par = new TileDataParametersImpl();
921
                par.setDataParameters(getDataParameters());
922
                par.setSecondLevelCache(true); //No crea un nuevo provider
923
                
924
                //Crea el proveedor de tiles de segundo nivel
925
                TileProvider newProvider = null;
926
                newProvider = new TileProvider(par, null);
927
                newProvider.setProvider(this.provider);
928

    
929
                //Instancia el TileServer pasado por el cliente con el TileProvider de segundo nivel
930
                Constructor<?> constructor;
931
                TileServer tServer = null;
932
                try {
933
                        constructor = tileServer.getConstructor(new Class<?>[]{AbstractRasterProvider.class});
934
                        Object [] args2 = {newProvider};
935
                        tServer = (TileServer)constructor.newInstance(args2);
936
                } catch (SecurityException e) {
937
                        e.printStackTrace();
938
                } catch (NoSuchMethodException e) {
939
                        e.printStackTrace();
940
                } catch (IllegalArgumentException e) {
941
                        e.printStackTrace();
942
                } catch (InstantiationException e) {
943
                        e.printStackTrace();
944
                } catch (IllegalAccessException e) {
945
                        e.printStackTrace();
946
                } catch (InvocationTargetException e) {
947
                        e.printStackTrace();
948
                }
949
                
950
                //Asigna el TileServer al nuevo provider de segundo nivel
951
                newProvider.setSecondLevelTileServer(tServer);
952
                
953
                //Asigna al provider de tiles de primer nivel el de segundo. 
954
                //Solo si las estructuras de cach? son diferentes
955
                if(!provider.getTileServer().getStruct().compare(tServer.getStruct())) {
956
                        this.setProvider(newProvider);
957
                        tiledLayer = null;
958
                }
959
        }
960
        
961
}