ecological-engine-geospatia.../src/main/java/org/gcube/dataanalysis/geo/batch/EnvriLayersInsertDev.java

133 lines
5.5 KiB
Java

package org.gcube.dataanalysis.geo.batch;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import org.gcube.dataanalysis.geo.connectors.netcdf.NetCDFDataExplorer;
import org.gcube.dataanalysis.geo.meta.GenericLayerMetadata;
import org.gcube.dataanalysis.geo.meta.OGCFormatter;
import org.opengis.metadata.identification.TopicCategory;
import ucar.nc2.dataset.CoordinateAxis;
import ucar.nc2.dt.GridDatatype;
import ucar.nc2.dt.grid.GridDataset;
public class EnvriLayersInsertDev {
// static String geonetworkurl = "http://geoserver-dev2.d4science-ii.research-infrastructures.eu/geonetwork/";
static String geonetworkurl = "http://geoserver-last.d4science-ii.research-infrastructures.eu/geonetwork/";
/*
static String geonetworkurl = "http://geonetwork.d4science.org/geonetwork/";
static String geoserverurl = "http://geoserver.d4science-ii.research-infrastructures.eu/geoserver";
*/
//static String geoserverurl = "http://geoserver-dev.d4science-ii.research-infrastructures.eu/geoserver";
static String user = "admin";
static String password = "admin";
static String[] envrilayers = {
"geo_filt_070620-070725-sim_HDR_4rlks.nc",
"geo_filt_070620-070829-sim_HDR_4rlks.nc",
"geo_filt_070620-071003-sim_HDR_4rlks.nc",
"geo_filt_070620-071107-sim_HDR_4rlks.nc",
"geo_filt_070620-071212-sim_HDR_4rlks.nc",
"geo_filt_070620-080326-sim_HDR_4rlks.nc",
"geo_filt_070620-080604-sim_HDR_4rlks.nc",
"geo_filt_070620-080709-sim_HDR_4rlks.nc",
"geo_filt_070620-080813-sim_HDR_4rlks.nc",
"geo_filt_070620-080917-sim_HDR_4rlks.nc",
"geo_filt_070620-081022-sim_HDR_4rlks.nc",
"geo_filt_070620-081231-sim_HDR_4rlks.nc"};
static String threddsbaseURL= "thredds.d4science.org";
static String threddsURL = "http://"+threddsbaseURL+"/thredds/catalog/public/netcdf/catalog.xml";
public static void main(String[] args) throws Exception{
for (int i=1;i<envrilayers.length+1;i++) {
envriEtnalayers(i);
// break;
}
}
//gebco
private static void envriEtnalayers(int index) throws Exception{
GenericLayerMetadata metadataInserter = new GenericLayerMetadata();
metadataInserter.setGeonetworkUrl(geonetworkurl);
metadataInserter.setGeonetworkUser(user);
metadataInserter.setGeonetworkPwd(password);
String title = "Etna Volcano SAR Analysis ";
String filename = envrilayers[index-1];
String layername = "band_1";
int minusInt = filename.indexOf("-");
int minusInt2 = filename.lastIndexOf("-");
String datastart = filename.substring("geo_filt_".length(),minusInt);
String dataend = filename.substring(minusInt,minusInt2);
System.out.println("DataStart: "+datastart);
System.out.println("DataEnd: "+dataend);
metadataInserter.setTitle(title+index);
metadataInserter.setCategoryTypes("_"+TopicCategory.ENVIRONMENT.name()+"_");
metadataInserter.setResolution(0.0083);
metadataInserter.setAbstractField("SAR analysis of the Etna volcano. Produced by the Istituto Nazionale di Geofisica e Vulcanologia (INGV). Hosted on the D4Science Thredds Catalog: "+threddsURL);
metadataInserter.setCustomTopics("D4Science","ENVRI","Etna","SAR Analysis","Istituto Nazionale di Geofisica e Vulcanologia","INGV","Thredds");
metadataInserter.setAuthor("D4Science");
String url = OGCFormatter.getOpenDapURL(threddsURL, filename);
System.out.println("URL "+url);
GridDataset gds = ucar.nc2.dt.grid.GridDataset.open(url);
List<GridDatatype> gridTypes = gds.getGrids();
GridDatatype gdt = gridTypes.get(0);
double minX = NetCDFDataExplorer.getMinX(gdt.getCoordinateSystem());
double maxX = NetCDFDataExplorer.getMaxX(gdt.getCoordinateSystem());
double minY = NetCDFDataExplorer.getMinY(gdt.getCoordinateSystem());
double maxY = NetCDFDataExplorer.getMaxY(gdt.getCoordinateSystem());
System.out.println("minX: "+minX+" minY: "+minY+" maxX:"+maxX+" maxY:"+maxY);
String wms = OGCFormatter.getWmsNetCDFUrl(url, layername, OGCFormatter.buildBoundingBox(minX, minY, maxX, maxY)).replace("width=676", "width=640").replace("height=330", "height=480");
System.out.println("WMS "+wms);
String wcs = OGCFormatter.getWcsNetCDFUrl(url, layername, OGCFormatter.buildBoundingBox(minX, minY, maxX, maxY)).replace("width=676", "width=640").replace("height=330", "height=480");
System.out.println("WCS "+wcs);
String [] urls = {"http://thredds.research-infrastructures.eu/thredds/fileServer/public/netcdf/"+filename,wms,wcs,url};
String [] protocols = {"HTTP","WMS","WCS","OPeNDAP"};
DateFormat formatter = new SimpleDateFormat("yyMMdd");
Date datestart = formatter.parse(datastart);
Date dateend = formatter.parse(dataend);
metadataInserter.setStartDate(datestart);
metadataInserter.setEndDate(dateend);
metadataInserter.setXLeftLow(minX);
metadataInserter.setYLeftLow(minY);
metadataInserter.setXRightUpper(maxX);
metadataInserter.setYRightUpper(maxY);
CoordinateAxis xAxis = gdt.getCoordinateSystem().getXHorizAxis();
CoordinateAxis yAxis = gdt.getCoordinateSystem().getYHorizAxis();
double resolutionX = Math.abs((double) (xAxis.getMaxValue() - xAxis.getMinValue()) / (double) xAxis.getShape()[0]);
double resolutionY = Math.abs((double) (yAxis.getMaxValue() - yAxis.getMinValue()) / (double) yAxis.getShape()[0]);
metadataInserter.setResolution(Math.max(resolutionX, resolutionY));
System.out.println("Resolution: "+Math.max(resolutionX, resolutionY));
metadataInserter.customMetaDataInsert(urls,protocols);
}
}