152 lines
4.9 KiB
Java
152 lines
4.9 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.portlets.user.geoportaldataviewer.server.gis;
|
|
|
|
import java.io.IOException;
|
|
import java.io.InputStream;
|
|
import java.net.URL;
|
|
import java.net.URLEncoder;
|
|
import java.util.ArrayList;
|
|
import java.util.Arrays;
|
|
import java.util.HashMap;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
import org.apache.commons.io.IOUtils;
|
|
import org.gcube.portlets.user.geoportaldataviewer.client.GeoportalDataViewerConstants;
|
|
import org.gcube.portlets.user.geoportaldataviewer.server.util.URLParserUtil;
|
|
import org.gcube.portlets.user.geoportaldataviewer.shared.FeatureRow;
|
|
import org.gcube.portlets.user.geoportaldataviewer.shared.GeoNaDataObject;
|
|
import org.gcube.portlets.user.geoportaldataviewer.shared.gis.BoundsMap;
|
|
import org.gcube.portlets.user.geoportaldataviewer.shared.gis.LayerItem;
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
|
|
|
|
/**
|
|
* The Class FeatureParser.
|
|
*
|
|
* @author Francesco Mangiacrapa at ISTI-CNR (francesco.mangiacrapa@isti.cnr.it)
|
|
*
|
|
* Oct 29, 2020
|
|
*/
|
|
public class FeatureParser {
|
|
|
|
private static Logger LOG = LoggerFactory.getLogger(FeatureParser.class);
|
|
|
|
|
|
/**
|
|
* Gets the data results.
|
|
*
|
|
* @param layerItems the layer items
|
|
* @param mapSrsName the map srs name
|
|
* @param mapBBOX the map BBOX
|
|
* @param maxWFSFeature the max WFS feature
|
|
* @return the data results
|
|
*/
|
|
public static List<GeoNaDataObject> getDataResults(List<LayerItem> layerItems, String mapSrsName, BoundsMap mapBBOX, int maxWFSFeature) {
|
|
|
|
if(maxWFSFeature<0) {
|
|
maxWFSFeature = GeoportalDataViewerConstants.MAX_WFS_FEATURES;
|
|
}
|
|
|
|
//IF WFS IS AVAILABLE USE WFS REQUEST OTHERWHISE TRY TO USE WPS SERVICE
|
|
for (LayerItem layerItem : layerItems){
|
|
List<FeatureRow> rows = getWFSFeatureProperties(layerItem, mapSrsName, mapBBOX, maxWFSFeature);
|
|
}
|
|
return null;
|
|
}
|
|
|
|
|
|
/**
|
|
* Gets the WFS feature properties.
|
|
*
|
|
* @param layerItem the layer item
|
|
* @param mapSrsName the map srs name
|
|
* @param mapBBOX the map BBOX
|
|
* @param maxWFSFeature the max WFS feature
|
|
* @return the WFS feature properties
|
|
*/
|
|
@SuppressWarnings("unchecked")
|
|
private static List<FeatureRow> getWFSFeatureProperties(LayerItem layerItem, String mapSrsName, BoundsMap mapBBOX, int maxWFSFeature) {
|
|
|
|
LOG.info("getTableFromJson -> Creating WfsTable to layerItem: "+layerItem.getName());
|
|
InputStream is = null;
|
|
List<FeatureRow> listFeaturesRow = new ArrayList<FeatureRow>();
|
|
try {
|
|
String url = GisMakers.buildWFSFeatureQuery(layerItem, mapSrsName, mapBBOX, maxWFSFeature, GisMakers.JSON);
|
|
String cqlFilterValue = URLParserUtil.extractValueOfParameterFromURL(GisMakers.CQL_FILTER_PARAMETER, url);
|
|
LOG.info("Found CQL filter value into query string: "+cqlFilterValue);
|
|
|
|
if(cqlFilterValue!=null) {
|
|
String notEncodedCQLFilter = String.format("%s=%s",GisMakers.CQL_FILTER_PARAMETER,cqlFilterValue);
|
|
//log.info("Found CQL filter: "+notEncodedCQLFilter);
|
|
String toEncodeCQLFilter = String.format("%s=%s",GisMakers.CQL_FILTER_PARAMETER,URLEncoder.encode(cqlFilterValue,"UTF-8"));
|
|
LOG.debug("Encoded CQL filter: "+toEncodeCQLFilter);
|
|
url = url.replace(notEncodedCQLFilter, toEncodeCQLFilter);
|
|
}
|
|
|
|
LOG.info("getTableFromJson -> WFS URL: "+url);
|
|
is = new URL(url).openStream();
|
|
String jsonTxt = IOUtils.toString(is);
|
|
|
|
if(jsonTxt==null || jsonTxt.isEmpty()){
|
|
jsonTxt = "{\"type\":\"FeatureCollection\",\"features\":[]}";
|
|
}
|
|
|
|
// get json object
|
|
JSONObject json = new JSONObject(jsonTxt);
|
|
// iterate features
|
|
JSONArray features = json.getJSONArray("features");
|
|
if(features.length()==0) {
|
|
LOG.info("No features detected in the response, returning empty list");
|
|
return listFeaturesRow;
|
|
}
|
|
|
|
for (int i=0; i<features.length(); i++) {
|
|
final FeatureRow row = new FeatureRow();
|
|
JSONObject theFeature = ((JSONObject)features.get(i));
|
|
LOG.debug("Building at index: "+i);
|
|
// // iterate properties
|
|
JSONObject properties = theFeature.getJSONObject("properties");
|
|
Map<String,List<String>> mapProperties = new HashMap<String,List<String>>();
|
|
@SuppressWarnings("unchecked")
|
|
Iterator<String> ii = properties.keys();
|
|
while (ii.hasNext()) {
|
|
String key = ii.next();
|
|
String value = properties.optString(key,"");
|
|
|
|
List<String> theValues = mapProperties.get(key);
|
|
if(theValues==null)
|
|
mapProperties.put(key, Arrays.asList(value));
|
|
else {
|
|
theValues.add(value);
|
|
mapProperties.put(key, theValues);
|
|
}
|
|
}
|
|
|
|
row.setMapProperties(mapProperties);
|
|
listFeaturesRow.add(row);
|
|
|
|
LOG.info("Added row "+row+" to exported properties");
|
|
}
|
|
|
|
} catch (IOException e) {
|
|
LOG.error("Error for layerItem name: "+layerItem.getName(), e);
|
|
} catch (JSONException e) {
|
|
LOG.error("Error for layerItem name: "+layerItem.getName(), e);
|
|
}finally{
|
|
IOUtils.closeQuietly(is);
|
|
}
|
|
|
|
return listFeaturesRow;
|
|
}
|
|
}
|