commit 6552a8cea18b012cf4e5a4e8b5c5f125335e40d2 Author: Marc NICOLAS Date: Wed Apr 22 15:46:52 2015 +0200 Add all old java development for hesiod diff --git a/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.converter.ConverterHelper b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.converter.ConverterHelper new file mode 100644 index 0000000..0fe1010 --- /dev/null +++ b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.converter.ConverterHelper @@ -0,0 +1,2 @@ +fr.ias.sitools.converters.FileSizeConverter +fr.ias.sitools.converters.RaDecToXYZConverter \ No newline at end of file diff --git a/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.filter.FilterHelper b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.filter.FilterHelper new file mode 100644 index 0000000..fcca242 --- /dev/null +++ b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.filter.FilterHelper @@ -0,0 +1,10 @@ +fr.ias.sitools.filters.basic.BooleanCorotAsteroAndExo +fr.ias.sitools.filters.basic.BooleanCustom +fr.ias.sitools.filters.basic.GroupCheckBoxMasterLigthCurves +fr.ias.sitools.filters.basic.NThreeVariability +fr.ias.sitools.filters.basic.TextFieldSQLLikeFilter +fr.ias.sitools.filters.basic.DateBeginEndFilter +fr.ias.sitools.filters.basic.SingleValueLikeFilter +fr.ias.sitools.filters.basic.ListBoxSpectralTypeCorot +fr.ias.sitools.filters.basic.ListBoxLumClassCorot +fr.ias.sitools.filters.basic.TextAreaCorotFilter \ No newline at end of file diff --git a/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.applications.ApplicationHelper b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.applications.ApplicationHelper new file mode 100644 index 0000000..e69de29 diff --git a/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.filters.FilterHelper b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.filters.FilterHelper new file mode 100644 index 0000000..e69de29 diff --git a/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.resources.ResourceHelper b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.resources.ResourceHelper new file mode 100644 index 0000000..0774e94 --- /dev/null +++ b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.plugins.resources.ResourceHelper @@ -0,0 +1,5 @@ +fr.ias.sitools.resources.spectrofits.GetFitsDataSpectroModel +fr.ias.sitools.resources.fits.ShowHeaderModel +fr.ias.sitools.astro.resolverName.CorotIdResolverModel +fr.ias.sitools.resources.vo.SimpleSpectralAccessResourceModel +fr.ias.sitools.resources.geojson.DatasetToJsonModel \ No newline at end of file diff --git a/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.units.UnitsHelper b/hesiod/javaExt/src/META-INF/services/fr.cnes.sitools.units.UnitsHelper new file mode 100644 index 0000000..e69de29 diff --git a/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/CorotIdResolverModel.java b/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/CorotIdResolverModel.java new file mode 100644 index 0000000..330a75b --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/CorotIdResolverModel.java @@ -0,0 +1,117 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.astro.resolverName; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.ConstraintViolationLevel; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.plugins.resources.model.DataSetSelectionType; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.plugins.resources.model.ResourceParameterType; + +import java.util.HashSet; +import java.util.Map; +import java.util.Set; +import java.util.logging.Level; + +/** + * + * @author marc + */ +public class CorotIdResolverModel extends ResourceModel { + + + public CorotIdResolverModel(){ + super(); + setClassAuthor("Marc NICOLAS"); + setClassOwner("IAS"); + setClassVersion("0.6.1"); + setName("Corot ID Resolver service"); + setDescription("This service provides a resolver name from corotID"); + setResourceClassName(fr.ias.sitools.astro.resolverName.CorotIdResolverResource.class.getName()); + + ResourceParameter paramExo = new ResourceParameter("exoBool", "true if it's a exo dataset, false in other cases", + ResourceParameterType.PARAMETER_USER_INPUT); + paramExo.setValueType("xs:boolean"); + this.addParam(paramExo); + + ResourceParameter paramRaCol = new ResourceParameter("raCol", "Colum containing the right ascension.", + ResourceParameterType.PARAMETER_INTERN); + paramRaCol.setValueType("xs:dataset.columnAlias"); + this.addParam(paramRaCol); + + ResourceParameter paramDecCol = new ResourceParameter("decCol", "Colum containing the declination.", + ResourceParameterType.PARAMETER_INTERN); + paramDecCol.setValueType("xs:dataset.columnAlias"); + this.addParam(paramDecCol); + + ResourceParameter paramcorotIdCol = new ResourceParameter("corotIdCol", "Colum containing the Corot ID.", + ResourceParameterType.PARAMETER_INTERN); + paramcorotIdCol.setValueType("xs:dataset.columnAlias"); + this.addParam(paramcorotIdCol); + + this.setApplicationClassName(DataSetApplication.class.getName()); + this.setDataSetSelection(DataSetSelectionType.SINGLE); + this.getParameterByName("methods").setValue("GET"); + this.completeAttachUrlWith("/corotIdResolver/EQUATORIAL/{corotID}"); + } + + @Override + public Validator getValidator() { + return new Validator() { + + @Override + public Set validate(ResourceModel item) { + Set constraints = new HashSet(); + Map params = item.getParametersMap(); + ResourceParameter param = params.get("exoBool"); + + String value = param.getValue(); + if (value == null || value.equals("")) { + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("The boolean exoBool must be set."); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + + param = params.get("raCol"); + value = param.getValue(); + if (value == null || value.equals("")) { + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("The attribute for RA must be set."); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + + param = params.get("decCol"); + value = param.getValue(); + if (value == null || value.equals("")) { + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("The attribute for DEC must be set."); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + + param = params.get("corotIdCol"); + value = param.getValue(); + if (value == null || value.equals("")) { + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("The attribute for CorotID must be set."); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + return constraints; + } + }; + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/CorotIdResolverResource.java b/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/CorotIdResolverResource.java new file mode 100644 index 0000000..6debc3c --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/CorotIdResolverResource.java @@ -0,0 +1,206 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.astro.resolverName; + +import fr.cnes.sitools.astro.representation.GeoJsonRepresentation; +import fr.cnes.sitools.common.resource.SitoolsParameterizedResource; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.database.DatabaseRequest; +import fr.cnes.sitools.dataset.database.DatabaseRequestFactory; +import fr.cnes.sitools.dataset.database.DatabaseRequestParameters; +import fr.cnes.sitools.dataset.database.common.DataSetExplorerUtil; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.datasource.jdbc.model.AttributeValue; +import fr.cnes.sitools.datasource.jdbc.model.Record; +import fr.cnes.sitools.extensions.astro.application.opensearch.datamodel.FeatureDataModel; +import fr.cnes.sitools.extensions.astro.application.opensearch.datamodel.FeaturesDataModel; +import fr.cnes.sitools.extensions.common.AstroCoordinate; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.resources.order.utils.OrderResourceUtils; +import java.util.Map; +import java.util.logging.Level; +import org.restlet.Context; +import org.restlet.data.MediaType; +import org.restlet.data.Status; +import org.restlet.ext.wadl.MethodInfo; +import org.restlet.representation.Representation; +import org.restlet.representation.Variant; +import org.restlet.resource.Get; +import org.restlet.resource.ResourceException; + + + +public class CorotIdResolverResource extends SitoolsParameterizedResource{ + + String corotIDValueStr; + Boolean exoBool; + + Double raValue; + Double decValue; + ResourceParameter corotIDParam; + ResourceParameter raParam; + ResourceParameter decParam; + + @Override + public void sitoolsDescribe() { + setName("CorotIdResolverResource"); + setDescription("Get Star coordinates from corotID"); + } + + @Override + public void doInit() { + super.doInit(); + this.corotIDValueStr = (String) this.getRequestAttributes().get("corotID"); + this.exoBool = Boolean.parseBoolean(getModel().getParametersMap().get("exoBool").getValue()); + + try{ + int corotIdValuInt = Integer.parseInt(corotIDValueStr); + }catch(NumberFormatException e){ + throw new ResourceException(Status.CLIENT_ERROR_BAD_REQUEST, "CorotID must be a number."); + } + if(this.corotIDValueStr.length() != 9 && exoBool){ + throw new ResourceException(Status.CLIENT_ERROR_BAD_REQUEST, "CorotID must be composed of 9 digits."); + } + } + + /** + * Get HTML + * + * @return Representation the HTML result + */ + @Get + public Representation getCorotIdResolver() { + return execute(); + } + + @Override + protected void describeGet(MethodInfo info) { + this.addInfo(info); + info.setIdentifier("get ra and dec coordinates from corotID"); + info.setDocumentation("Method to retrieve coordinates of a star from its corotID"); + addStandardGetRequestInfo(info); + DataSetExplorerUtil.addDatasetExplorerGetRequestInfo(info); + DataSetApplication application = (DataSetApplication) getApplication(); + DataSetExplorerUtil.addDatasetExplorerGetFilterInfo(info, application.getFilterChained()); + addStandardResponseInfo(info); + addStandardInternalServerErrorInfo(info); + } + + @Override + protected Representation get(Variant variant) { + Representation repr = super.get(); + if(repr == null){ + throw new ResourceException(Status.CLIENT_ERROR_NOT_FOUND,"No reccord matches with your query"); + } + repr.setMediaType(MediaType.APPLICATION_JSON); + return repr; + } + + /** + * Execute the request and return a Representation + * + * @return the HTML representation + */ + private Representation execute() { + + + Representation repr = null; + + // Get context + Context context = getContext(); + + // generate the DatabaseRequest + DataSetApplication datasetApp = (DataSetApplication) getApplication(); + DataSetExplorerUtil dsExplorerUtil = new DataSetExplorerUtil(datasetApp, getRequest(), getContext()); + + + this.corotIDParam = this.getModel().getParameterByName("corotIdCol"); + this.raParam = this.getModel().getParameterByName("raCol"); + this.decParam = this.getModel().getParameterByName("decCol"); + + + // Get request parameters + if (datasetApp.getConverterChained() != null) { + datasetApp.getConverterChained().getContext().getAttributes().put("REQUEST", getRequest()); + } + // Get DatabaseRequestParameters + DatabaseRequestParameters params = dsExplorerUtil.getDatabaseParams(); + DataSet ds = datasetApp.getDataSet(); + createQueryCorotID(params,ds); + DatabaseRequest databaseRequest = DatabaseRequestFactory.getDatabaseRequest(params); + + try { + + if (params.getDistinct()) { + databaseRequest.createDistinctRequest(); + }else { + databaseRequest.createRequest(); + } + // Recuperation dans la base du fichiers fits + context.getLogger().log(Level.INFO, "nbr de resultat : "+databaseRequest.getCount()); + while (databaseRequest.nextResult()) { + Record rec = databaseRequest.getRecord(); + this.raValue = Double.parseDouble(OrderResourceUtils.getInParam(raParam, rec).getValue().toString()); + this.decValue = Double.parseDouble(OrderResourceUtils.getInParam(decParam, rec).getValue().toString()); + + Map a = getDataModel(); + repr = new GeoJsonRepresentation(a); + + } + } catch (Exception e) { + throw new ResourceException(Status.SERVER_ERROR_INTERNAL,e.getMessage()); + } + return repr; + } + + public Map getDataModel(){ + final FeaturesDataModel features = new FeaturesDataModel(); + final FeatureDataModel feature = new FeatureDataModel(); + AstroCoordinate a = new AstroCoordinate(this.raValue,this.decValue); + + feature.createGeometry(String.format("[%s,%s]", this.raValue,this.decValue),"Point"); + feature.createCrs(a.getCoordinateSystem().getCrs()); + feature.addProperty("credits", "CDS"); + feature.addProperty("identifier", "CDS0"); + features.addFeature(feature); + return features.getFeatures(); + } + + private void createQueryCorotID(DatabaseRequestParameters params, DataSet ds){ + Column corotIDCol = ds.findByColumnAlias(this.corotIDParam.getValue()); + Predicat pred = new Predicat(); + pred.setLogicOperator("AND"); + pred.setLeftAttribute(corotIDCol); + pred.setCompareOperator(Operator.EQ); + pred.setRightValue(this.corotIDValueStr); + params.getPredicats().add(pred); + if(exoBool){ + pred = new Predicat(); + Column en2WinDescCol = ds.findByColumnAlias("en2_windescriptor"); + pred.setLogicOperator("AND"); + pred.setLeftAttribute(en2WinDescCol); + pred.setCompareOperator(Operator.EQ); + pred.setRightValue("false"); + params.getPredicats().add(pred); + } + } +} \ No newline at end of file diff --git a/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/resource/CorotIdResolverAstero.java b/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/resource/CorotIdResolverAstero.java new file mode 100644 index 0000000..3beeb71 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/astro/resolverName/resource/CorotIdResolverAstero.java @@ -0,0 +1,188 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.astro.resolverName.resource; + +import fr.cnes.sitools.astro.resolver.AbstractNameResolver; +import fr.cnes.sitools.astro.resolver.NameResolverException; +import fr.cnes.sitools.astro.resolver.NameResolverResponse; +import fr.cnes.sitools.util.ClientResourceProxy; +import java.io.IOException; +import java.util.logging.Level; +import java.util.logging.Logger; +import org.json.JSONArray; +import org.json.JSONException; +import org.json.JSONObject; +import org.restlet.Client; +import org.restlet.data.Method; +import org.restlet.data.Protocol; +import org.restlet.data.Status; +import org.restlet.resource.ClientResource; +import org.restlet.resource.ResourceException; + +/** + * Queries the Corot name resolver and returns the list of coordinates for a given identifier.
A CorotIdResolver lets you get a sky + * position given a Corot identifier + * + * @author Marc NICOLAS + */ +public class CorotIdResolverAstero extends AbstractNameResolver { + + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(CorotIdResolverAstero.class.getName()); + /** + * Credits to return for CDS. + */ + private static final String CREDITS_NAME = "IAS Astero/CNES"; + /** + * Template URL for the Corot identifier resolver service. + */ + private static final String TEMPLATE_NAME_RESOLVER = "http://idoc-corotn2-public-v2.ias.u-psud.fr/ds/astero/plugin/corotIdResolver/EQUATORIAL/"; + /** + * Corot service response. + */ + private String corotId; + + /** + * Empty constructor. + */ + protected CorotIdResolverAstero() { + } + + /** + * Constructs a new CorotId resolver. + * + * @param corotIdVal Corot ID + */ + public CorotIdResolverAstero(final String corotIdVal) { + setCorotId(corotIdVal); + checkInputParameters(); + } + /** + * Sets the Corot Id. + * @param corotIdVal the Corot ID to set + */ + protected final void setCorotId(final String corotIdVal) { + this.corotId = corotIdVal; + } + /** + * Returns the Corot ID. + * @return the Corot ID + */ + protected final String getCorotId() { + return this.corotId; + } + /** + * Tests if the coroID is set. + * + *

+ * Returns IllegalArgumentException if corotId is null or empty. + *

+ */ + protected final void checkInputParameters() { + if (getCorotId() == null || getCorotId().isEmpty()) { + throw new IllegalArgumentException("corotId must be set."); + } + } + + @Override + public final NameResolverResponse getResponse() { + NameResolverResponse response = new NameResolverResponse(CREDITS_NAME); + LOG.log(Level.SEVERE, "JE RENTRE DANS LE NAMERESOLVERRESPONSE de l'Astero !!"); + try { + final String query = TEMPLATE_NAME_RESOLVER.replace("", corotId); + final JSONObject json = parseResponse(query); + + final String[] coordinates = parseCoordinates(json); + final double rightAscension = Double.valueOf(coordinates[0]); + final double declination = Double.valueOf(coordinates[1]); + + response.addAstroCoordinate(rightAscension, declination); + } catch (NameResolverException ex) { + if (getSuccessor() == null) { + response.setError(ex); + } else { + response = getSuccessor().getResponse(); + } + } finally { + return response; + } + } + + /** + * Queries the SITools2 service at IAS and stores the result in json. + * + * @param query query the Corot service + * @return the response from the server + * @throws NameResolverException if a problem occurs while the response is being parsed + */ + private JSONObject parseResponse(final String query) throws NameResolverException { + assert query != null; + LOG.log(Level.INFO, "Call IAS name resolver: {0}", query); + final ClientResourceProxy proxy = new ClientResourceProxy(query, Method.GET); + final ClientResource client = proxy.getClientResource(); + //client.setChallengeResponse(new ChallengeResponse(ChallengeScheme.HTTP_BASIC, "guest", "sitools2public")); + final Client clientHTTP = new Client(Protocol.HTTP); + clientHTTP.setConnectTimeout(AbstractNameResolver.SERVER_TIMEOUT); + client.setNext(clientHTTP); + final Status status = client.getStatus(); + if (status.isSuccess()) { + JSONObject json; + try { + json = new JSONObject(client.get().getText()); + } catch (IOException ex) { + throw new NameResolverException(Status.SERVER_ERROR_INTERNAL, ex); + } catch (JSONException ex) { + LOG.log(Level.WARNING, "the response of Corot server may changed"); + throw new NameResolverException(Status.CLIENT_ERROR_NOT_ACCEPTABLE, ex); + } catch (ResourceException ex) { + throw new NameResolverException(Status.SERVER_ERROR_SERVICE_UNAVAILABLE, ex); + } + return json; + } else { + throw new NameResolverException(status, status.getThrowable()); + } + } + + /** + * Parses the coordinates from CDS response and return them. + * @param json the server's response + * @return the following array [rightAscension,declination] + * @throws NameResolverException - if empty response from Corot + */ + private String[] parseCoordinates(final JSONObject json) throws NameResolverException { + try { + //final JSONArray jsonArray = json.getJSONArray("data"); + final JSONArray jsonArray = json.getJSONArray("features"); + final JSONArray coords = jsonArray.getJSONObject(0).getJSONObject("geometry").getJSONArray("coordinates"); + + if (jsonArray.length() != 1) { + throw new NameResolverException(Status.CLIENT_ERROR_NOT_FOUND, "Not found"); + } + + if (coords.get(0).equals("") || coords.get(1).toString().equals("")) { + throw new NameResolverException(Status.CLIENT_ERROR_NOT_FOUND, "Not found"); + } + return new String[]{coords.get(0).toString(),coords.get(1).toString()}; + } catch (JSONException ex) { + throw new NameResolverException(Status.SERVER_ERROR_INTERNAL, "cannot parse the coordinates"); + } + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/converters/FileSizeConverter.java b/hesiod/javaExt/src/fr/ias/sitools/converters/FileSizeConverter.java new file mode 100644 index 0000000..e032fea --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/converters/FileSizeConverter.java @@ -0,0 +1,116 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.converters; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.ConstraintViolationLevel; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.converter.business.AbstractConverter; +import fr.cnes.sitools.dataset.converter.model.ConverterParameter; +import fr.cnes.sitools.dataset.converter.model.ConverterParameterType; +import fr.cnes.sitools.datasource.jdbc.model.AttributeValue; +import fr.cnes.sitools.datasource.jdbc.model.Record; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; +import java.util.logging.Level; +import java.util.logging.Logger; + +/** + * + * @author Marc + */ +public class FileSizeConverter extends AbstractConverter { + + /** Class logger */ + private static final Logger LOGGER = Logger.getLogger(FileSizeConverter.class.getName()); + + public FileSizeConverter() { + + this.setName("FileSizeConverter"); + this.setDescription("A converter applying an unit conversion from bytes into Kb or Mb or Gb"); + this.setClassAuthor("Marc NICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + + ConverterParameter colFileSize = new ConverterParameter("colFileSizeInBytes", "row of dataset with the filesize in bytes",ConverterParameterType.CONVERTER_PARAMETER_IN); + ConverterParameter colFileSizeConvert = new ConverterParameter("colFileSizeConvert", "File Size converted", ConverterParameterType.CONVERTER_PARAMETER_OUT); + this.addParam(colFileSize); + this.addParam(colFileSizeConvert); + + LOGGER.log(Level.INFO, "Converter :{0} version {1}", new Object[] { this.getName(), this.getClassVersion() }); + } + + @Override + public Record getConversionOf(Record record) throws Exception { + Record out = record; + String result = ""; + + AttributeValue attrOut = this.getOutParam("colFileSizeConvert", out); + + AttributeValue attrIn = this.getInParam("colFileSizeInBytes", out); + + if (!isNull(attrIn) && !isNull(attrOut)) { + try{ + double input = Double.parseDouble(attrIn.getValue().toString()); + if(input>0 && input<1024){ + result = (double)Math.round(input*10)/10 +" o"; + }else if(input >= 1024 && input < Math.pow(1024, 2) ){ + result = (double)Math.round((input/1024)*10)/10+" Ko"; + }else if(input >=Math.pow(1024, 2) && input < Math.pow(1024, 3)){ + result = (double)Math.round((input/Math.pow(1024, 2))*10)/10+" Mo" ; + }else if( input >= Math.pow(1024, 3) && input < Math.pow(1024, 4)){ + result = (double)Math.round((input/Math.pow(1024, 3))*10)/10+" Go" ; + } + + if(!result.isEmpty()){ + attrOut.setValue(result); + } + }catch (Exception e) { + attrOut.setValue(Double.NaN); + } + } + + return out; + } + + @Override + public Validator getValidator() { + // TODO Auto-generated method stub + return new Validator() { + + @Override + public Set validate(AbstractConverter item) { + Set constraints = new HashSet(); + Map params = item.getParametersMap(); + ConverterParameter param = params.get("colFileSizeInBytes"); + + if(param.getAttachedColumn().isEmpty()){ + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("You must choose the column with filesize in bytes data"); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + + param = params.get("colFileSizeConvert"); + + if(param.getAttachedColumn().isEmpty()){ + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("You must choose the output column"); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + + return constraints; + } + }; + } + + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/converters/RaDecToXYZConverter.java b/hesiod/javaExt/src/fr/ias/sitools/converters/RaDecToXYZConverter.java new file mode 100644 index 0000000..6577318 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/converters/RaDecToXYZConverter.java @@ -0,0 +1,140 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.converters; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.ConstraintViolationLevel; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.converter.business.AbstractConverter; +import fr.cnes.sitools.dataset.converter.model.ConverterParameter; +import fr.cnes.sitools.dataset.converter.model.ConverterParameterType; +import fr.cnes.sitools.datasource.jdbc.model.AttributeValue; +import fr.cnes.sitools.datasource.jdbc.model.Record; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; +import java.util.logging.Level; +import java.util.logging.Logger; + +/** + * + * @author marc + */ +public class RaDecToXYZConverter extends AbstractConverter { + + /* + Formule de changement de coordonée : + + X=cos(DEC)*cos(RA) + Y=cos(DEC)*sin(RA) + Z=sin(DEC) + + */ + + /** Class logger */ + private static final Logger LOGGER = Logger.getLogger(RaDecToXYZConverter.class.getName()); + + public RaDecToXYZConverter() { + + this.setName("RaDecToXYZConverter"); + this.setDescription("A converter applying an unit conversion from Ra and Dec into X, Y and Z coordinates"); + this.setClassAuthor("Marc NICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + + ConverterParameter colRa = new ConverterParameter("colRa", "row of dataset with the ra coordinate",ConverterParameterType.CONVERTER_PARAMETER_IN); + ConverterParameter colDec = new ConverterParameter("colDec", "row of dataset with the dec coordinate",ConverterParameterType.CONVERTER_PARAMETER_IN); + + ConverterParameter colX = new ConverterParameter("colX", "Column for coordiante X", ConverterParameterType.CONVERTER_PARAMETER_OUT); + ConverterParameter colY = new ConverterParameter("colY", "Column for coordiante Y", ConverterParameterType.CONVERTER_PARAMETER_OUT); + ConverterParameter colZ = new ConverterParameter("colZ", "Column for coordiante Z", ConverterParameterType.CONVERTER_PARAMETER_OUT); + + this.addParam(colRa); + this.addParam(colDec); + this.addParam(colX); + this.addParam(colY); + this.addParam(colZ); + + LOGGER.log(Level.INFO, "Converter :{0} version {1}", new Object[] { this.getName(), this.getClassVersion() }); + } + + + + @Override + public Record getConversionOf(Record record) throws Exception { + Record out = record; + Double x, y, z; + + AttributeValue attrOutX = this.getOutParam("colX", out); + AttributeValue attrOutY = this.getOutParam("colY", out); + AttributeValue attrOutZ = this.getOutParam("colZ", out); + + AttributeValue attrInRa = this.getInParam("colRa", out); + AttributeValue attrInDec = this.getInParam("colDec", out); + + if(!isNull(attrInRa) && !isNull(attrInRa)/* && !isNull(attrOutX) && !isNull(attrOutY) && !isNull(attrOutZ)*/){ + try{ + Double ra = Double.parseDouble(attrInRa.getValue().toString()); + Double dec = Double.parseDouble(attrInDec.getValue().toString()); + + x = Math.cos(dec)*Math.cos(ra); + y = Math.cos(dec)*Math.sin(ra); + z = Math.sin(dec); + + if(!x.isNaN()){ + attrOutX.setValue(x); + } + if(!y.isNaN()){ + attrOutY.setValue(y); + } + if(!z.isNaN()){ + + attrOutZ.setValue(z); + } + }catch(NumberFormatException e){ + + } + } + + return out; + } + + @Override + public Validator getValidator() { + // TODO Auto-generated method stub + return new Validator() { + + @Override + public Set validate(AbstractConverter item) { + Set constraints = new HashSet(); + /*Map params = item.getParametersMap(); + ConverterParameter param = params.get("colFileSizeInBytes"); + + if(param.getAttachedColumn().isEmpty()){ + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("You must choose the column with filesize in bytes data"); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + } + + param = params.get("colFileSizeConvert"); + + if(param.getAttachedColumn().isEmpty()){ + ConstraintViolation constraint = new ConstraintViolation(); + constraint.setMessage("You must choose the output column"); + constraint.setLevel(ConstraintViolationLevel.CRITICAL); + constraint.setValueName(param.getName()); + constraints.add(constraint); + }*/ + + return constraints; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/BooleanCorotAsteroAndExo.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/BooleanCorotAsteroAndExo.java new file mode 100644 index 0000000..44e395d --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/BooleanCorotAsteroAndExo.java @@ -0,0 +1,154 @@ +package fr.ias.sitools.filters.basic; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +//import java.util.logging.Logger; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.database.common.RequestFactory; +import fr.cnes.sitools.dataset.database.jdbc.RequestSql; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import fr.cnes.sitools.datasource.jdbc.business.SitoolsSQLDataSource; +import fr.cnes.sitools.datasource.jdbc.business.SitoolsSQLDataSourceFactory; +import fr.cnes.sitools.util.SQLUtils; + +public class BooleanCorotAsteroAndExo extends AbstractFormFilter { + + /** + * The index of TYPE + */ + private static final int TYPE = 0; + /** + * The index of COLUMN + */ + private static final int COLUMN = 1; + /** + * The index of Values + */ + private static final int VALUES = 2; + /** + * The number of values + */ + private static final int NUMBER_OF_VALUES = 4; + + private String[] values; + + private enum TYPE_COMPONENT { + /** DefaultType */ + BOOLEAN_CHECKBOX_COROT, + CHECKBOX_COROT_ASTERO + } + // private static final Logger LOGGER = Logger.getLogger(BooleanCorot.class.getName()); + + public BooleanCorotAsteroAndExo() { + super(); + this.setName("BooleanCorotAsteroAndExo"); + this.setDescription("Required when using BooleanCorot for exo or astero data checkbox"); + this.setClassAuthor("MNICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo param1 = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "BOOLEAN_CHECKBOX_COROT|columnAlias1,columnAlias2" + + ",columnAlias3,columnAlias4|long|short|center|anticenter"); + rpd.put("0", param1); + ParameterInfo param2 = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "CHECKBOX_COROT_ASTERO|columnAlias1,columnAlias2" + + ",columnAlias3,columnAlias4|long|short|center|anticenter"); + rpd.put("1", param2); + this.setRequestParamsDescription(rpd); + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + DataSetApplication dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + DataSet ds = dsApplication.getDataSet(); + + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + while (filterExists) { + String index = TEMPLATE_PARAM.replace("#", Integer.toString(i++)); + String formParam = params.getFirstValue(index); + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (checkValues(parameters)) { + String[] columnsAlias = parameters[COLUMN].split(","); + ArrayList columns = new ArrayList(); + for (String columnAlias : columnsAlias) { + Column col = ds.findByColumnAlias(columnAlias); + if (col != null) { + columns.add(col); + } + } + SitoolsSQLDataSource dsource = SitoolsSQLDataSourceFactory.getDataSource(ds.getDatasource().getId()); + RequestSql requestSql = RequestFactory.getRequest(dsource.getDsModel().getDriverClass()); + + String longRunColStr = requestSql.convertColumnToString(columns.get(0)); + String shortRunColStr = requestSql.convertColumnToString(columns.get(1)); + String centerColStr = requestSql.convertColumnToString(columns.get(2)); + String anticenterColStr = requestSql.convertColumnToString(columns.get(3)); + + boolean longRunValue = Boolean.valueOf(SQLUtils.escapeString(values[0])); + boolean shortRunValue = Boolean.valueOf(SQLUtils.escapeString(values[1])); + boolean centerValue = Boolean.valueOf(SQLUtils.escapeString(values[2])); + boolean anticenterValue = Boolean.valueOf(SQLUtils.escapeString(values[3])); + + + Predicat predicat = new Predicat(); + + predicat.setStringDefinition(" AND ("+longRunColStr+" = "+longRunValue+" OR "+shortRunColStr+" = "+shortRunValue+")"+" AND ("+centerColStr+ " = "+ centerValue+" OR "+anticenterColStr+" = "+anticenterValue+")"); + predicats.add(predicat); + + } + } + }else { + filterExists = false; + } + } + return predicats; + } + + + /** + * Check the number of values + * + * @param parameters + * the values + * @return true if the number of values is correct + */ + private boolean checkValues(String[] parameters) { + values = Arrays.copyOfRange(parameters, VALUES, VALUES + NUMBER_OF_VALUES); + if (values.length == NUMBER_OF_VALUES) { + return true; + } + return false; + } + + @Override + public Validator getValidator() { + // TODO Auto-generated method stub + return null; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/BooleanCustom.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/BooleanCustom.java new file mode 100644 index 0000000..6874aab --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/BooleanCustom.java @@ -0,0 +1,198 @@ +/******************************************************************************* + * Copyright 2011 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Set; +import java.util.logging.Logger; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.util.SQLUtils; + +/** + * Filter defined for Single Value Component + * + * + * @author d.arpin + */ +public final class BooleanCustom extends AbstractFilter { + /** + * The index of TYPE + */ + private static final int TYPE = 0; + /** + * The index of COLUMN + */ + private static final int COLUMN = 1; + /** + * The index of Values + */ + private static final int VALUES = 2; + + /** + * The number of values + */ + private static final int NUMBER_OF_VALUES = 1; + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** Boolean Custom type */ + BOOLEAN_CUSTOM + } + + private String[] values; + + private static final Logger LOGGER = Logger.getLogger(BooleanCustom.class.getName()); + + /** The TEMPLATE_PARAM */ + private static final String TEMPLATE_PARAM = "p[#]"; + + /** + * Default constructor + */ + public BooleanCustom() { + + super(); + this.setName("BooleanCustom"); + this.setDescription("Required when using Boolean Custom Component"); + this.setClassAuthor("Marc NICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.9"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "BOOLEAN_CUSTOM|columnAlias|value"); + rpd.put("0", paramInfo); + this.setRequestParamsDescription(rpd); + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + + DataSetApplication dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + DataSet ds = dsApplication.getDataSet(); + + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + String index = TEMPLATE_PARAM.replace("#", Integer.toString(i++)); + String formParam = params.getFirstValue(index); + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + + if (trouve) { + if (checkValues(parameters)) { + String columnAlias = null; + if (parameters.length >= VALUES) { + + columnAlias = parameters[COLUMN]; + Column col = ds.findByColumnAlias(columnAlias); + if (col != null && col.getFilter() != null && col.getFilter()) { + // get the value and escape it to avoid SQL injection + String value = SQLUtils.escapeString(parameters[VALUES]); + Predicat predicat = new Predicat(); + if (value != null) { + predicat.setLeftAttribute(col); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.EQ); + predicat.setRightValue("'" + value + "'"); + if(value.equalsIgnoreCase("false")){ + predicats.add(predicat); + } + } + } + } + } + } + } + + else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Check the number of values + * + * @param parameters + * the values + * @return true if the number of values is correct + */ + private boolean checkValues(String[] parameters) { + if(parameters.length >= 3){ + values = Arrays.copyOfRange(parameters, VALUES, VALUES + NUMBER_OF_VALUES); + if (values.length == NUMBER_OF_VALUES) { + return true; + } + return false; + }else{ + return false; + } + } + + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + // TODO Auto-generated method stub + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/DateBeginEndFilter.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/DateBeginEndFilter.java new file mode 100644 index 0000000..a7fd79d --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/DateBeginEndFilter.java @@ -0,0 +1,203 @@ +/******************************************************************************* + * Copyright 2011 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Set; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.util.SQLUtils; + +/** + * Filter defined for Date Between Component + * + * + * @author d.arpin + * [3411383]
+ * 2011/09/19 d.arpin {add quotes arround date Value} + */ +public final class DateBeginEndFilter extends AbstractFilter { + /** + * The index of TYPE + */ + private static final int TYPE = 0; + /** + * The index of COLUMN + */ + private static final int COLUMN = 1; + /** + * The index of Values + */ + private static final int VALUES = 2; + + /** The TEMPLATE_PARAM */ + private static final String TEMPLATE_PARAM = "p[#]"; + /** + * the values from to + */ + private String[] values; + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** DefaultType */ + DATE_BEGIN_END + } + + /** + * Default constructor + */ + public DateBeginEndFilter() { + + super(); + this.setName("DateBeginEndFilter"); + this.setDescription("Required when using Date Between Components between 2 columns"); + + this.setClassAuthor("HUSSON@IAS"); + this.setClassAuthor("HUSSON@IAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, + "DATE_BEGIN_END|columnFrom,columnTo|valueFrom|valueTo"); + rpd.put("0", paramInfo); + this.setRequestParamsDescription(rpd); + // + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + // Get the dataset + DataSetApplication dsApplication = null; + DataSet ds = null; + + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + String index = TEMPLATE_PARAM.replace("#", Integer.toString(i++)); + String formParam = params.getFirstValue(index); + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (dsApplication == null) { + dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + ds = dsApplication.getDataSet(); + } + String columnfrom = null; + String columnto = null; + if (parameters.length >= VALUES) { + columnfrom = parameters[COLUMN].split(",")[0]; + columnto = parameters[COLUMN].split(",")[1]; + + Column colfrom = ds.findByColumnAlias(columnfrom); + Column colto = ds.findByColumnAlias(columnto); + + if (colfrom != null && colfrom.getFilter() != null && colfrom.getFilter() && checkValues(parameters) && colto != null && colto.getFilter() != null && colto.getFilter()) { + // escape the values to avoid SQL injection + String valuefrom = "'" + SQLUtils.escapeString(values[0]) + "'"; + String valueto = "'" + SQLUtils.escapeString(values[1]) + "'"; + + Predicat predicat = new Predicat(); + predicat.setLeftAttribute(colfrom); + predicat.setNbOpenedParanthesis(1); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.GTE); + predicat.setRightValue(valuefrom); + predicats.add(predicat); + predicat = new Predicat(); + predicat.setLeftAttribute(colto); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(1); + predicat.setCompareOperator(Operator.LTE); + predicat.setRightValue(valueto); + predicats.add(predicat); + } + + } + } + } + + else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Check values of the form + * + * @param parameters + * the parameters of the filter + * @return true if values agree + */ + private boolean checkValues(String[] parameters) { + values = Arrays.copyOfRange(parameters, VALUES, parameters.length); + if (values.length == 2) { + return true; + } + return false; + } + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/GroupCheckBoxMasterLigthCurves.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/GroupCheckBoxMasterLigthCurves.java new file mode 100644 index 0000000..fd15929 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/GroupCheckBoxMasterLigthCurves.java @@ -0,0 +1,140 @@ +package fr.ias.sitools.filters.basic; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import fr.cnes.sitools.util.SQLUtils; + +public class GroupCheckBoxMasterLigthCurves extends AbstractFormFilter { + + /** + * The index of TYPE + */ + private static final int TYPE = 0; + /** + * The index of COLUMN + */ + private static final int COLUMN = 1; + /** + * The index of Values + */ + private static final int VALUES = 2; + /** + * The number of values + */ + private static final int NUMBER_OF_VALUES = 4; + + private String[] values; + + private enum TYPE_COMPONENT { + /** DefaultType */ + GROUP_CHECKBOX_LIGHTCURVES_COROT + } + //private static final Logger LOGGER = Logger.getLogger(GroupCheckBoxMasterLigthCurves.class.getName()); + + public GroupCheckBoxMasterLigthCurves() { + super(); + this.setName("GroupCheckBoxLightCurves"); + this.setDescription("Required when using the LightCurves checkbox component"); + this.setClassAuthor("MNICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo param1 = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "GROUP_CHECKBOX_LIGHTCURVES_COROT|columnAlias1,columnAlias2" + + ",columnAlias3,columnAlias4|starChr|starMon|star512|star32"); + rpd.put("0", param1); + this.setRequestParamsDescription(rpd); + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + DataSetApplication dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + DataSet ds = dsApplication.getDataSet(); + + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + while (filterExists) { + String index = TEMPLATE_PARAM.replace("#", Integer.toString(i++)); + String formParam = params.getFirstValue(index); + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (checkValues(parameters)) { + String[] columnsAlias = parameters[COLUMN].split(","); + ArrayList columns = new ArrayList(); + for (String columnAlias : columnsAlias) { + Column col = ds.findByColumnAlias(columnAlias); + if (col != null) { + columns.add(col); + } + } + + int k =0; + for(Column col : columns){ + Predicat predicat = new Predicat(); + predicat.setLeftAttribute(col); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.EQ); + predicat.setRightValue("'" + Boolean.valueOf(SQLUtils.escapeString(values[k])) + "'"); + if(!(Boolean.valueOf(SQLUtils.escapeString(values[k])))){ + predicats.add(predicat); + } + k++; + } + } + } + }else { + filterExists = false; + } + } + return predicats; + } + + + /** + * Check the number of values + * + * @param parameters + * the values + * @return true if the number of values is correct + */ + private boolean checkValues(String[] parameters) { + values = Arrays.copyOfRange(parameters, VALUES, VALUES + NUMBER_OF_VALUES); + if (values.length == NUMBER_OF_VALUES) { + return true; + } + return false; + } + + @Override + public Validator getValidator() { + // TODO Auto-generated method stub + return null; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxLumClassCorot.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxLumClassCorot.java new file mode 100644 index 0000000..5d4522f --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxLumClassCorot.java @@ -0,0 +1,219 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Set; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM_CONCEPT; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TYPE; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.VALUES; +import java.util.logging.Level; + +/** + * Filter defined for Multiple Value Component + * + * + * @author d.arpin + */ +public final class ListBoxLumClassCorot extends AbstractFormFilter { + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** List box Lum class for Corot */ + LISTBOXLUMCLASSCOROT + } + + /* + Pour EXO : + "" + "I" + "II" + "III" + "III:" + "IV" + "null" + "V" + "" + + Pour Astero : + "" + "I" + "II" + "III" + "III-IV" + "IV" + "V" + + */ + + /** + * Default constructor + */ + public ListBoxLumClassCorot() { + + super(); + this.setName("ListBoxLumClassCorot"); + this.setDescription("Required when using List Box Lum Class for Corot Components"); + + this.setClassAuthor("Mnicolas"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, + "LISTBOXLUMCLASSCOROT|columnAlias|value1|...|value n"); + rpd.put("0", paramInfo); + this.setRequestParamsDescription(rpd); + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + // Get the dataset + DataSetApplication dsApplication = null; + DataSet ds = null; + boolean isConcept = true; + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + // first check if the filter is applied on a Concept or not + String index = TEMPLATE_PARAM_CONCEPT.replace("#", Integer.toString(i)); + String formParam = params.getFirstValue(index); + if (formParam == null) { + isConcept = false; + index = TEMPLATE_PARAM.replace("#", Integer.toString(i)); + formParam = params.getFirstValue(index); + } + i++; + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (dsApplication == null) { + dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + ds = dsApplication.getDataSet(); + } + String columnAlias = null; + if (parameters.length >= VALUES) { + + /* + * columnsAlias = parameters[COLUMN].split(","); ArrayList columns = new ArrayList(); for + * (String columnAlias : columnsAlias) { Column col = ds.findByColumnAlias(columnAlias); if (col != null) { + * columns.add(col); } + * + * } + */ + columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + List lumClassSeeked = new ArrayList(); + + if (col != null && col.getFilter() != null && col.getFilter()) { + String[] values = Arrays.copyOfRange(parameters, VALUES, parameters.length); + Predicat predicat = new Predicat(); + if (values != null) { + predicat.setLeftAttribute(col); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.IN); + + boolean all = false; + for (String value : values) { + if(value.equalsIgnoreCase("All")){ + all = true; + }else{ + if(value.equalsIgnoreCase(" ")){ + lumClassSeeked.add(value); + lumClassSeeked.add("null"); + }else if(value.equalsIgnoreCase("III")){ + lumClassSeeked.add(value); + lumClassSeeked.add("III:"); + }else{ + lumClassSeeked.add(value); + } + } + } + getContext().getLogger().log(Level.INFO, "lumClassSeeked : "+lumClassSeeked.toArray().toString()); + if(!lumClassSeeked.isEmpty() && !all) { + predicat.setRightValue(lumClassSeeked); + predicats.add(predicat); + } + } + } + } + + } + } + }else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + // TODO Auto-generated method stub + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxMultipleIAS.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxMultipleIAS.java new file mode 100644 index 0000000..81b469b --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxMultipleIAS.java @@ -0,0 +1,196 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Set; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM_CONCEPT; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.VALUES; +import fr.cnes.sitools.util.SQLUtils; + + +/** + * Filter defined for Multiple Value Component + * + * + * @author d.arpin + */ +public final class ListBoxMultipleIAS extends AbstractFormFilter { + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** List box type */ + LISTBOXMULTIPLE_IAS, + } + + /** + * Default constructor + */ + public ListBoxMultipleIAS() { + + super(); + this.setName("ListBoxMultipleIAS"); + this.setDescription("Required when using Multiple Value Components"); + + this.setClassAuthor("Marc NICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, + "LISTBOXMULTIPLE|columnAlias|value1|...|value n"); + rpd.put("0", paramInfo); + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, + "CHECKBOX|columnAlias|value1|...|value n"); + rpd.put("1", paramInfo); + + paramInfo = new ParameterInfo("c[#]", false, "xs:string", ParameterStyle.QUERY, + "LISTBOXMULTIPLE|dictionaryName,conceptName|value1|...|value n"); + rpd.put("2", paramInfo); + /*paramInfo = new ParameterInfo("c[#]", false, "xs:string", ParameterStyle.QUERY, + "CHECKBOX|dictionaryName,conceptName|value1|...|value n"); + rpd.put("3", paramInfo); + this.setRequestParamsDescription(rpd);*/ + // + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + // Get the dataset + DataSetApplication dsApplication = null; + DataSet ds = null; + boolean isConcept = true; + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + // first check if the filter is applied on a Concept or not + String index = TEMPLATE_PARAM_CONCEPT.replace("#", Integer.toString(i)); + String formParam = params.getFirstValue(index); + if (formParam == null) { + isConcept = false; + index = TEMPLATE_PARAM.replace("#", Integer.toString(i)); + formParam = params.getFirstValue(index); + } + i++; + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (dsApplication == null) { + dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + ds = dsApplication.getDataSet(); + } + String columnAlias = null; + if (parameters.length >= VALUES) { + + /* + * columnsAlias = parameters[COLUMN].split(","); ArrayList columns = new ArrayList(); for + * (String columnAlias : columnsAlias) { Column col = ds.findByColumnAlias(columnAlias); if (col != null) { + * columns.add(col); } + * + * } + */ + columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + + if (col != null && col.getFilter() != null && col.getFilter()) { + String[] values = Arrays.copyOfRange(parameters, VALUES, parameters.length); + Predicat predicat = new Predicat(); + if (values != null) { + predicat.setLeftAttribute(col); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.IN); + + List in = new ArrayList(); + + for (String value : values) { + // escape every value to avoid SQL injections + in.add(SQLUtils.escapeString(value)); + } + predicat.setRightValue(in); + + predicats.add(predicat); + } + } + } + + } + } + } + + else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + // TODO Auto-generated method stub + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxSpectralTypeCorot.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxSpectralTypeCorot.java new file mode 100644 index 0000000..ad0b9e5 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/ListBoxSpectralTypeCorot.java @@ -0,0 +1,207 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Set; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM_CONCEPT; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.VALUES; + +/** + * Filter defined for Multiple Value Component + * + * + * @author d.arpin + */ +public final class ListBoxSpectralTypeCorot extends AbstractFormFilter { + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** List box Spectral Type for Corot */ + LISTBOXSPECTRALTYPECOROT + } + + private final List spectralTypeO = Arrays.asList("O5","O6","O8","O8.5","O9"); + private final List spectralTypeB = Arrays.asList("B0","B1","B2","B3","B5","B6","B8","B9","B2.5","B.5"); + private final List spectralTypeA = Arrays.asList("A0","A1","A2","A3","A4","A5","A6","A7","A8","A9"); + private final List spectralTypeF = Arrays.asList("F0","F1","F2","F3","F4","F5","F6","F7","F8","F9"); + private final List spectralTypeG = Arrays.asList("G0","G1","G2","G3","G4","G5","G6","G7","G8","G9"); + private final List spectralTypeK = Arrays.asList("K0","K1","K2","K3","K4","K5","K6","K7","K8","K9"); + private final List spectralTypeM = Arrays.asList("M","M0","M1","M2","M3","M4","M5","M6","M7","M8","M9"); + + /** + * Default constructor + */ + public ListBoxSpectralTypeCorot() { + + super(); + this.setName("ListBoxSpectralTypeCorot"); + this.setDescription("Required when using List Box Spectral Type for Corot Components"); + + this.setClassAuthor("Mnicolas"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, + "LISTBOXSPECTRALTYPECOROT|columnAlias|value1|...|value n"); + rpd.put("0", paramInfo); + this.setRequestParamsDescription(rpd); + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + // Get the dataset + DataSetApplication dsApplication = null; + DataSet ds = null; + boolean isConcept = true; + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + // first check if the filter is applied on a Concept or not + String index = TEMPLATE_PARAM_CONCEPT.replace("#", Integer.toString(i)); + String formParam = params.getFirstValue(index); + if (formParam == null) { + isConcept = false; + index = TEMPLATE_PARAM.replace("#", Integer.toString(i)); + formParam = params.getFirstValue(index); + } + i++; + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (dsApplication == null) { + dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + ds = dsApplication.getDataSet(); + } + String columnAlias = null; + if (parameters.length >= VALUES) { + + /* + * columnsAlias = parameters[COLUMN].split(","); ArrayList columns = new ArrayList(); for + * (String columnAlias : columnsAlias) { Column col = ds.findByColumnAlias(columnAlias); if (col != null) { + * columns.add(col); } + * + * } + */ + columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + + if (col != null && col.getFilter() != null && col.getFilter()) { + String[] values = Arrays.copyOfRange(parameters, VALUES, parameters.length); + Predicat predicat = new Predicat(); + if (values != null) { + predicat.setLeftAttribute(col); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.IN); + + boolean all = false; + List spectralTypeSeeked = new ArrayList(); + for (String value : values) { + if(value.equalsIgnoreCase("O")){ + spectralTypeSeeked.addAll(this.spectralTypeO); + }else if(value.equalsIgnoreCase("B")){ + spectralTypeSeeked.addAll(this.spectralTypeB); + }else if(value.equalsIgnoreCase("A")){ + spectralTypeSeeked.addAll(this.spectralTypeA); + }else if(value.equalsIgnoreCase("F")){ + spectralTypeSeeked.addAll(this.spectralTypeF); + }else if(value.equalsIgnoreCase("G")){ + spectralTypeSeeked.addAll(this.spectralTypeG); + }else if(value.equalsIgnoreCase("K")){ + spectralTypeSeeked.addAll(this.spectralTypeK); + }else if(value.equalsIgnoreCase("M")){ + spectralTypeSeeked.addAll(this.spectralTypeM); + }else if(value.equalsIgnoreCase("All")){ + all = true; + } + + //in.add(SQLUtils.escapeString(value)); + } + if(!spectralTypeSeeked.isEmpty()&& !all) { + predicat.setRightValue(spectralTypeSeeked); + predicats.add(predicat); + } + } + } + } + + } + } + }else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + // TODO Auto-generated method stub + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/NThreeVariability.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/NThreeVariability.java new file mode 100644 index 0000000..1f00c55 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/NThreeVariability.java @@ -0,0 +1,209 @@ +/******************************************************************************* + * Copyright 2011 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.Set; +import java.util.logging.Level; +import java.util.logging.Logger; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.exception.SitoolsException; +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.util.SQLUtils; + +/** + * Filter defined for Single Value Component + * + * + * @author d.arpin + */ +public final class NThreeVariability extends AbstractFilter { + /** + * The index of TYPE + */ + private static final int TYPE = 0; + /** + * The index of COLUMN + */ + private static final int COLUMN = 1; + /** + * The index of Values + */ + private static final int VALUES = 2; + + private static final int NUMBER_OF_VALUES = 2; + + private String[] values; + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** Boolean Custom type */ + NTHREE_VARIABILITY + } + + /** The TEMPLATE_PARAM */ + private static final String TEMPLATE_PARAM = "p[#]"; + + private static final Logger LOGGER = Logger.getLogger(NThreeVariability.class.getName()); + + /** + * Colonnes de la base ou sont les probabilitées + */ + private String probClass1Col = "prbclas1_from"; + private String probClass2Col = "prbclas2_from"; + private String probClass3Col = "prbclas3_from"; + + /** + * Colonnes de la base ou sont les class de variabilité associée aux probabilitées + */ + private String varClass1 = "varclas1_from"; + private String varClass2 = "varclas2_from"; + private String varClass3 = "varclas3_from"; + + /** + * Nome de la table + */ + private String tableName = "exo_n2_view"; + + private char doubleQuote = '"'; + + /** + * Default constructor + */ + public NThreeVariability() { + + super(); + this.setName("NThreeVariability"); + this.setDescription("Required when using NThreeVariability Component"); + + this.setClassAuthor("Marc NICOLAS"); + this.setClassAuthor("IAS"); + this.setClassOwner("MN@IAS"); + this.setClassVersion("1.0"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "NTHREE_VARIABILITY|columnAlias|value"); + rpd.put("0", paramInfo); + this.setRequestParamsDescription(rpd); + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + DataSetApplication dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + DataSet ds = dsApplication.getDataSet(); + + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + String index = TEMPLATE_PARAM.replace("#", Integer.toString(i++)); + String formParam = params.getFirstValue(index); + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if(trouve){ + if (checkValues(parameters)) { + + String varClassSeek = null; + Double probValue = null; + try{ + varClassSeek = SQLUtils.escapeString(values[0]); + probValue = Double.valueOf(values[1]); + }catch(SitoolsException e){ + e.printStackTrace(); + LOGGER.log(Level.SEVERE,"Probleme lors de la récupération des valeurs dans le NThreeVariability, message d'erreur : "+e.getMessage()); + } + + Predicat predicat = new Predicat(); + predicat.setStringDefinition(" AND ("+doubleQuote+tableName+doubleQuote+"."+varClass1+" = "+"'"+varClassSeek+"'"+" AND "+doubleQuote+tableName+doubleQuote+"."+probClass1Col+" >= "+ probValue+") OR " + + "("+doubleQuote+tableName+doubleQuote+"."+varClass2+" = "+"'"+varClassSeek+"'"+" AND "+doubleQuote+tableName+doubleQuote+"."+probClass2Col+" >= "+ probValue+") OR ("+ + doubleQuote+tableName+doubleQuote+"."+varClass3+" = "+"'"+varClassSeek+"'"+" AND "+doubleQuote+tableName+doubleQuote+"."+probClass3Col+" >= "+ probValue+")"); + predicats.add(predicat); + + } + } + } + + else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Check the number of values + * + * @param parameters + * the values + * @return true if the number of values is correct + */ + private boolean checkValues(String[] parameters) { + values = Arrays.copyOfRange(parameters, VALUES, VALUES + NUMBER_OF_VALUES); + for(String value : values){ + } + if (values.length == NUMBER_OF_VALUES) { + return true; + } + return false; + } + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + // TODO Auto-generated method stub + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/SingleValueLikeFilter.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/SingleValueLikeFilter.java new file mode 100644 index 0000000..00ec973 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/SingleValueLikeFilter.java @@ -0,0 +1,183 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.filters.basic; + +import java.util.HashMap; +import java.util.List; +import java.util.Set; + +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.filter.business.AbstractFilter; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM_CONCEPT; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.VALUES; +import fr.cnes.sitools.util.SQLUtils; + +/** + * Filter defined for Single Value Component + * + * + * @author d.arpin + */ +public final class SingleValueLikeFilter extends AbstractFormFilter { + + /** + * The list of component that uses this filter + */ + private enum TYPE_COMPONENT { + /** Hd Number field type */ + HDNUMBERFIELD, + } + + /** + * Default constructor + */ + public SingleValueLikeFilter() { + + super(); + this.setName("SingleValueLikeFilter"); + this.setDescription("Required when using Hd Number Text Field Component"); + + this.setClassAuthor("MNICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.1"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo paramInfo; + paramInfo = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "HDNUMBERFIELD|columnAlias|value"); + rpd.put("0", paramInfo); + paramInfo = new ParameterInfo("c[#]", false, "xs:string", ParameterStyle.QUERY, + "HDNUMBERFIELD|dictionaryName,conceptName|value"); + rpd.put("1", paramInfo); + + this.setRequestParamsDescription(rpd); + // + + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + DataSetApplication dsApplication = null; + DataSet ds = null; + boolean isConcept = true; + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + // Build predicat for filters param + while (filterExists) { + // first check if the filter is applied on a Concept or not + String index = TEMPLATE_PARAM_CONCEPT.replace("#", Integer.toString(i)); + String formParam = params.getFirstValue(index); + if (formParam == null) { + isConcept = false; + index = TEMPLATE_PARAM.replace("#", Integer.toString(i)); + formParam = params.getFirstValue(index); + } + i++; + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (dsApplication == null) { + dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + ds = dsApplication.getDataSet(); + } + String columnAlias = null; + if (parameters.length >= VALUES) { + + columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + if (col != null && col.getFilter() != null && col.getFilter()) { + // get the value and escape it to avoid SQL injection + String value = SQLUtils.escapeString(parameters[VALUES]); + Predicat predicat = new Predicat(); + if (value != null) { + predicat.setLeftAttribute(col); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + if (parameters[TYPE].equals(TYPE_COMPONENT.HDNUMBERFIELD.name())) { + if(value.contains("HD")){ + if(value.charAt(2) != ' '){ + value = value.substring(2); + value = "%"+value+"%"; + } + + }else{ + value = "%"+value+"%"; + } + predicat.setCompareOperator(Operator.LIKE); + }else { + predicat.setCompareOperator(Operator.EQ); + } + predicat.setRightValue("'" + value + "'"); + + predicats.add(predicat); + } + } + } + } + } + } + + else { + filterExists = false; + } + } + + return predicats; + } + + /** + * Gets the validator for this Filter + * + * @return the validator for the filter + */ + @Override + public Validator getValidator() { + return new Validator() { + @Override + public Set validate(AbstractFilter item) { + // TODO Auto-generated method stub + return null; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/filters/basic/TextAreaCorotFilter.java b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/TextAreaCorotFilter.java new file mode 100644 index 0000000..b603410 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/filters/basic/TextAreaCorotFilter.java @@ -0,0 +1,315 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.filters.basic; + +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.model.Column; +import fr.cnes.sitools.dataset.model.DataSet; +import fr.cnes.sitools.dataset.model.Operator; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter; +import static fr.cnes.sitools.dataset.plugins.filters.core.AbstractFormFilter.TEMPLATE_PARAM; +import fr.cnes.sitools.datasource.jdbc.business.SitoolsSQLDataSource; +import fr.cnes.sitools.datasource.jdbc.business.SitoolsSQLDataSourceFactory; +import fr.cnes.sitools.util.SQLUtils; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashMap; +import java.util.List; +import java.util.logging.Level; +import org.restlet.Request; +import org.restlet.data.Form; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; + +/** + * + * @author marc + */ +public class TextAreaCorotFilter extends AbstractFormFilter { + + private enum TYPE_COMPONENT { + /** DefaultType */ + TEXTAREA, + TEXTAREAHDNUMBERCOROT + } + + private String[] values; + /** + * The index of TYPE + */ + private static final int TYPE = 0; + /** + * The index of COLUMN + */ + private static final int COLUMN = 1; + /** + * The index of Values + */ + private static final int VALUES = 2; + + /** + * The number of values + */ + private static final int NUMBER_OF_VALUES = 1; + + public TextAreaCorotFilter() { + super(); + this.setName("TextAreaCorotFilter"); + this.setDescription("Required when using TextAreaCorot component"); + this.setClassAuthor("MNICOLAS"); + this.setClassOwner("IAS"); + this.setClassVersion("0.2"); + this.setDefaultFilter(true); + + HashMap rpd = new HashMap(); + + ParameterInfo param1 = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "TEXTAREA|columnAlias|value"); + rpd.put("0", param1); + ParameterInfo param2 = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "TEXTAREAHDNUMBERCOROT|columnAlias|value"); + rpd.put("1", param2); + + ParameterInfo param3 = new ParameterInfo("c[#]", false, "xs:string", ParameterStyle.QUERY,"TEXTAREA|dictionaryName,conceptName|value"); + rpd.put("2", param3); + ParameterInfo param4 = new ParameterInfo("c[#]", false, "xs:string", ParameterStyle.QUERY,"TEXTAREAHDNUMBERCOROT|dictionaryName,conceptName|value"); + rpd.put("3", param4); + + this.setRequestParamsDescription(rpd); + + } + + + @Override + public List createPredicats(Request rqst, List predicats) throws Exception { + DataSetApplication dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + DataSet ds = dsApplication.getDataSet(); + boolean isConcept = true; + Form params = rqst.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + while (filterExists) { + String index = TEMPLATE_PARAM_CONCEPT.replace("#", Integer.toString(i)); + String formParam = params.getFirstValue(index); + if (formParam == null) { + isConcept = false; + index = TEMPLATE_PARAM.replace("#", Integer.toString(i)); + formParam = params.getFirstValue(index); + } + i++; + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + + if (trouve && parameters[TYPE].equalsIgnoreCase("TEXTAREA")) { + if (checkValues(parameters)) { + String[] columnsAlias = parameters[COLUMN].split(","); + ArrayList columns = new ArrayList(); + for (String columnAlias : columnsAlias) { + Column col = ds.findByColumnAlias(columnAlias); + if (col != null) { + columns.add(col); + } + } + String value = String.valueOf(SQLUtils.escapeString(values[0])); + + List valuesFilter = getValuesCorotId(value); + + if(valuesFilter != null){ + + String columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + Predicat predicat = new Predicat(); + if (!value.isEmpty()) { + predicat.setLeftString(col.getColumnAlias()); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.IN); + predicat.setRightValue(valuesFilter); + predicats.add(predicat); + } + } + } + } + }else if(trouve && parameters[TYPE].equalsIgnoreCase("TEXTAREAHDNUMBERCOROT")){ + if (checkValues(parameters)) { + + String[] columnsAlias = parameters[COLUMN].split(","); + ArrayList columns = new ArrayList(); + for (String columnAlias : columnsAlias) { + Column col = ds.findByColumnAlias(columnAlias); + if (col != null) { + columns.add(col); + } + } + + String value = String.valueOf(SQLUtils.escapeString(values[0])); + List valuesFilter = getValuesHdNumber(value); + if(valuesFilter != null){ + String columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + Predicat predicat = new Predicat(); + if (!value.isEmpty()) { + predicat.setLeftString(col.getColumnAlias()); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + predicat.setCompareOperator(Operator.IN); + predicat.setRightValue(valuesFilter); + predicats.add(predicat); + } + } + } + } + } + }else { + filterExists = false; + } + } + return predicats; + } + + /** + * Check the number of values + * + * @param parameters + * the values + * @return true if the number of values is correct + */ + private boolean checkValues(String[] parameters) { + values = Arrays.copyOfRange(parameters, VALUES, VALUES + NUMBER_OF_VALUES); + if (values.length == NUMBER_OF_VALUES) { + return true; + } + return false; + } + + @Override + public Validator getValidator() { + // TODO Auto-generated method stub + return null; + } + + private List getValuesCorotId(String value){ + List valuesFilter = new ArrayList(); + List valuesFilterTmp = new ArrayList(); + List valuesToSearchTmp = new ArrayList(); + String separator = null; + value = value.replaceAll("\\\\n", "!"); + for(int j =0;j getValuesHdNumber(String value){ + List valuesToSearchTmp = new ArrayList(); + List valuesToSearch = new ArrayList(); + List tmp = new ArrayList(); + String separator = null; + + value = value.replaceAll("\\\\n", "!"); + for(int j =0;j rpd = new HashMap(); + + ParameterInfo param1 = new ParameterInfo("p[#]", false, "xs:string", ParameterStyle.QUERY, "TEXTFIELDSQLLIKEINSENSITIVE|columnAlias|value"); + rpd.put("0", param1); + + param1 = new ParameterInfo("c[#]", false, "xs:string", ParameterStyle.QUERY, + "TEXTFIELDSQLLIKEINSENSITIVE|dictionaryName,conceptName|value"); + rpd.put("2", param1); + + this.setRequestParamsDescription(rpd); + } + + @Override + public List createPredicats(Request request, List predicats) throws Exception { + DataSetApplication dsApplication = null; + getContext().getLogger().log(Level.CONFIG,"*********************** Je rentre dans le createPredicats du TEXTFIELDSQLLIKEINSENSITIVE"); + DataSet ds = null; + boolean isConcept = true; + Form params = request.getResourceRef().getQueryAsForm(); + boolean filterExists = true; + int i = 0; + + while (filterExists) { + // first check if the filter is applied on a Concept or not + String index = TEMPLATE_PARAM_CONCEPT.replace("#", Integer.toString(i)); + String formParam = params.getFirstValue(index); + if (formParam == null) { + isConcept = false; + index = TEMPLATE_PARAM.replace("#", Integer.toString(i)); + formParam = params.getFirstValue(index); + } + i++; + if (formParam != null) { + String[] parameters = formParam.split("\\|"); + TYPE_COMPONENT[] types = TYPE_COMPONENT.values(); + Boolean trouve = false; + for (TYPE_COMPONENT typeCmp : types) { + if (typeCmp.name().equals(parameters[TYPE])) { + trouve = true; + } + } + if (trouve) { + if (dsApplication == null) { + dsApplication = (DataSetApplication) getContext().getAttributes().get("DataSetApplication"); + ds = dsApplication.getDataSet(); + } + String columnAlias = null; + if (parameters.length >= VALUES) { + + columnAlias = getColumnAlias(isConcept, parameters, dsApplication); + if (columnAlias != null) { + Column col = ds.findByColumnAlias(columnAlias); + if (col != null && col.getFilter() != null && col.getFilter()) { + // get the value and escape it to avoid SQL injection + String value = SQLUtils.escapeString(parameters[VALUES]); + + Predicat predicat = new Predicat(); + if (value != null) { + predicat.setLeftString("UPPER("+col.getColumnAlias()+")"); + predicat.setNbOpenedParanthesis(0); + predicat.setNbClosedParanthesis(0); + value = value.replace("*", "%"); + + predicat.setCompareOperator(Operator.LIKE); + predicat.setRightValue("'" + value.toUpperCase() + "'"); + + predicats.add(predicat); + } + } + } + } + } + } + + else { + filterExists = false; + } + } + + return predicats; + } + + @Override + public Validator getValidator() { + // TODO Auto-generated method stub + return null; + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/resources/fits/ShowHeader.java b/hesiod/javaExt/src/fr/ias/sitools/resources/fits/ShowHeader.java new file mode 100644 index 0000000..39795b1 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/resources/fits/ShowHeader.java @@ -0,0 +1,240 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.resources.fits; + +import fr.cnes.sitools.common.exception.SitoolsException; +import fr.cnes.sitools.common.resource.SitoolsParameterizedResource; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.database.DatabaseRequest; +import fr.cnes.sitools.dataset.database.DatabaseRequestFactory; +import fr.cnes.sitools.dataset.database.DatabaseRequestParameters; +import fr.cnes.sitools.dataset.database.common.DataSetExplorerUtil; +import fr.cnes.sitools.datasource.jdbc.model.AttributeValue; +import fr.cnes.sitools.datasource.jdbc.model.Record; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.resources.order.utils.OrderResourceUtils; +import java.io.IOException; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.logging.Level; +import java.util.logging.Logger; +import java.util.regex.Matcher; +import java.util.regex.Pattern; +import nom.tam.fits.Fits; +import nom.tam.fits.FitsException; +import nom.tam.fits.FitsFactory; +import nom.tam.fits.Header; +import nom.tam.fits.HeaderCard; +import org.json.JSONException; +import org.json.JSONObject; +import org.restlet.data.MediaType; +import org.restlet.ext.json.JsonRepresentation; +import org.restlet.ext.wadl.MethodInfo; +import org.restlet.representation.Representation; +import org.restlet.representation.Variant; +import org.restlet.resource.Get; + +/** + * + * @author mnicolas + */ +public class ShowHeader extends SitoolsParameterizedResource { + + @Override + public void sitoolsDescribe() { + setName("GetFitsDataSpectro"); + setDescription("Get cube fits file data"); + } + + @Override + public void doInit() { + super.doInit(); + } + + /** + * Get HTML + * + * @return Representation the HTML result + */ + @Get + public Representation get() { + return execute(); + } + + @Override + protected void describeGet(MethodInfo info) { + this.addInfo(info); + info.setIdentifier("retrieve records and extract data and metadata from fits file"); + info.setDocumentation("Method to get the data and metadata from a fits file"); + addStandardGetRequestInfo(info); + DataSetExplorerUtil.addDatasetExplorerGetRequestInfo(info); + DataSetApplication application = (DataSetApplication) getApplication(); + DataSetExplorerUtil.addDatasetExplorerGetFilterInfo(info, application.getFilterChained()); + addStandardResponseInfo(info); + addStandardInternalServerErrorInfo(info); + } + + @Override + protected Representation head(Variant variant) { + Representation repr = super.head(); + repr.setMediaType(MediaType.APPLICATION_JSON); + return repr; + } + + private Representation execute() { + Representation repr = null; + + // generate the DatabaseRequest + DataSetApplication datasetApp = (DataSetApplication) getApplication(); + DataSetExplorerUtil dsExplorerUtil = new DataSetExplorerUtil(datasetApp, getRequest(), getContext()); + + // Get request parameters + if (datasetApp.getConverterChained() != null) { + datasetApp.getConverterChained().getContext().getAttributes().put("REQUEST", getRequest()); + } + // Get DatabaseRequestParameters + DatabaseRequestParameters params = dsExplorerUtil.getDatabaseParams(); + + DatabaseRequest databaseRequest = DatabaseRequestFactory.getDatabaseRequest(params); + + if (params.getDistinct()) { + try { + databaseRequest.createDistinctRequest(); + }catch (SitoolsException e) { + e.printStackTrace(); + } + } else { + try { + databaseRequest.createRequest(); + }catch (SitoolsException e) { + e.printStackTrace(); + } + } + + ResourceParameter urlName = this.getModel().getParameterByName("colUrl"); + + if (databaseRequest != null) { + + // Next for reading first record + try { + databaseRequest.nextResult(); + Record rec = databaseRequest.getRecord(); + + AttributeValue attributeValueURL = OrderResourceUtils.getInParam(urlName, rec); + + if (attributeValueURL.getValue() != null){ + // get the file path + String filePath = (String) attributeValueURL.getValue(); + Fits fits = new Fits(filePath); + FitsFactory.setUseHierarch(true); + Header.setLongStringsEnabled(true); + + JSONObject jSON = new JSONObject(); + + int waveHDU = -1; + + int nberHDUs = fits.size(); + System.out.println("Number of HDUs: "+nberHDUs); + jSON.put("HDUs", nberHDUs); + + // Headers from fits + System.out.println("Getting Headers..."); + List headers = new ArrayList(nberHDUs); + List>> headersList = new ArrayList>>(nberHDUs); + + for (int i=0;i mapHierarch = new HashMap(); + for (int j=0; j"; + } + + //List of extensions -- List of List of Cards + List> cardList = new ArrayList>(nbreCards); + for (int j=0; j keyValueComment = new ArrayList(nbreCards); + HeaderCard card = header.findCard(header.getKey(j)); + + if ( card!=null ) { + //key + if (mapHierarch.containsKey(card.getKey())) { + keyValueComment.add( "HIERARCH "+mapHierarch.get(card.getKey()) ); + }else { + keyValueComment.add(card.getKey()); + } + + //value + keyValueComment.add(card.getValue()); + + if ( card.getKey().contains("EXTNAME") && card.getValue().contains("ImageIndex") ) { + System.out.println("ImageIndex in HDU "+i); + waveHDU=i; + } + + //comment + String commentCard = card.getComment(); + if (commentCard!=null) { + + if (commentCard.contains("&")) { + //System.out.println(j+" "+commentCard); + commentCard = commentCard.substring(0, commentCard.length()-1); + int jTmp = j; + while(header.getCard(jTmp+1).startsWith("COMMENT")){ + String commentCardNext = header.getCard(jTmp+1); + if (commentCardNext.contains("&")) { commentCardNext = commentCardNext.substring(0, commentCardNext.length()-1); } + commentCard += commentCardNext.split("COMMENT ")[1]; + jTmp++; + } + keyValueComment.add(commentCard); + }else { + keyValueComment.add(commentCard); + } + } else { + keyValueComment.add(""); + } + cardList.add(keyValueComment); + } + } + headersList.add(cardList); + headers.add(headerStr); + } + jSON.put("HEADERSGRID", headersList); + getContext().getLogger().log(Level.INFO,"In Show Header Resources : Headers - Done !"); + repr = new JsonRepresentation(jSON); + } + } catch (FitsException ex) { + Logger.getLogger(ShowHeader.class.getName()).log(Level.SEVERE, null, ex); + } catch (JSONException ex) { + Logger.getLogger(ShowHeader.class.getName()).log(Level.SEVERE, null, ex); + }catch (SitoolsException ex) { + Logger.getLogger(ShowHeader.class.getName()).log(Level.SEVERE, null, ex); + } catch (IOException ex) { + Logger.getLogger(ShowHeader.class.getName()).log(Level.SEVERE, null, ex); + } + } + return repr; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/resources/fits/ShowHeaderModel.java b/hesiod/javaExt/src/fr/ias/sitools/resources/fits/ShowHeaderModel.java new file mode 100644 index 0000000..d7fb44d --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/resources/fits/ShowHeaderModel.java @@ -0,0 +1,61 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.resources.fits; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.plugins.resources.model.DataSetSelectionType; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.plugins.resources.model.ResourceParameterType; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; + +/** + * + * @author mnicolas + */ +public class ShowHeaderModel extends ResourceModel { + + public ShowHeaderModel(){ + super(); + setClassAuthor("Marc NICOLAS"); + setClassOwner("IAS"); + setClassVersion("0.1"); + setName("ShowHeaderModel"); + setDescription("Getting metadata from a fits file"); + setClassName("fr.ias.sitools.resources.spectrofits.ShowHeaderModel"); + setResourceClassName(fr.ias.sitools.resources.fits.ShowHeader.class.getName()); + + ResourceParameter paramColUrl = new ResourceParameter("colUrl", "Colum containing the url of the fits file.", + ResourceParameterType.PARAMETER_INTERN); + paramColUrl.setValueType("xs:dataset.columnAlias"); + this.addParam(paramColUrl); + + this.setApplicationClassName(DataSetApplication.class.getName()); + this.setDataSetSelection(DataSetSelectionType.SINGLE); + this.getParameterByName("methods").setValue("GET"); + this.completeAttachUrlWith("/getHeaderFits"); + } + + @Override + public Validator getValidator() { + return new Validator() { + + @Override + public Set validate(ResourceModel item) { + Set constraints = new HashSet(); + Map params = item.getParametersMap(); + + return constraints; + } + }; + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/resources/geojson/DatasetToJson.java b/hesiod/javaExt/src/fr/ias/sitools/resources/geojson/DatasetToJson.java new file mode 100644 index 0000000..8f06dca --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/resources/geojson/DatasetToJson.java @@ -0,0 +1,363 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.resources.geojson; + +import fr.cnes.sitools.common.exception.SitoolsException; +import fr.cnes.sitools.common.resource.SitoolsParameterizedResource; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.database.DatabaseRequest; +import fr.cnes.sitools.dataset.database.DatabaseRequestFactory; +import fr.cnes.sitools.dataset.database.DatabaseRequestParameters; +import fr.cnes.sitools.dataset.database.common.DataSetExplorerUtil; +import fr.cnes.sitools.dataset.dto.ColumnConceptMappingDTO; +import fr.cnes.sitools.dataset.dto.DictionaryMappingDTO; +import fr.cnes.sitools.datasource.jdbc.model.AttributeValue; +import fr.cnes.sitools.datasource.jdbc.model.Record; +import fr.cnes.sitools.dictionary.model.Concept; +import java.io.IOException; +import java.io.Writer; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.logging.Level; +import java.util.logging.Logger; +import org.restlet.data.MediaType; +import org.restlet.ext.wadl.MethodInfo; +import org.restlet.representation.Representation; +import org.restlet.representation.Variant; +import org.restlet.resource.Get; +// IMPORT POUR LE JSON +import org.restlet.representation.WriterRepresentation; + +//------------------------- + +/** + * + * @author marc + */ +public class DatasetToJson extends SitoolsParameterizedResource { + + private static final Logger LOG = Logger.getLogger(DatasetToJson.class.getName()); + + private String dicoNameString = new String(); + + final private String mimeTypeFits = "application/fits"; + + final private int maxResultsSend = 999999999; + + final private double ratioSpolyToRaDec = 57.295779513; + + @Override + public void sitoolsDescribe() { + setName("DatasetToJson"); + setDescription("retrieves Dataset to Json file"); + } + + @Override + public void doInit() { + super.doInit(); + } + + /** + * Get HTML + * + * @return Representation the HTML result + */ + @Get + public Representation get() { + return execute(); + } + + @Override + protected void describeGet(MethodInfo info) { + this.addInfo(info); + info.setIdentifier("retrieve records and "); + info.setDocumentation("Method to get Json file from a dataset"); + addStandardGetRequestInfo(info); + DataSetExplorerUtil.addDatasetExplorerGetRequestInfo(info); + DataSetApplication application = (DataSetApplication) getApplication(); + DataSetExplorerUtil.addDatasetExplorerGetFilterInfo(info, application.getFilterChained()); + addStandardResponseInfo(info); + addStandardInternalServerErrorInfo(info); + } + + @Override + protected Representation head(Variant variant) { + Representation repr = super.head(); + //repr.setMediaType(MediaType.APPLICATION_JSON); + return repr; + } + + private Representation execute() { + + dicoNameString = DatasetToJsonModel.DICO_PARAM_NAME; + + final Representation repr; + repr = new WriterRepresentation(MediaType.APPLICATION_JSON) { ; + //repr = + @Override + public void write(Writer writer) throws IOException { + boolean jsonP = false; + String cb = getRequest().getResourceRef().getQueryAsForm().getFirstValue("callback"); + String limit = null; + limit = getRequest().getResourceRef().getQueryAsForm().getFirstValue("limit"); + + if (cb != null) { + jsonP = true; + //getResponse().set //setContentType("text/javascript"); + this.setMediaType(MediaType.TEXT_JAVASCRIPT); + } else { + this.setMediaType(MediaType.APPLICATION_JSON); + } + + + // generate the DatabaseRequest + DataSetApplication datasetApp = (DataSetApplication) getApplication(); + DataSetExplorerUtil dsExplorerUtil = new DataSetExplorerUtil(datasetApp, getRequest(), getContext()); + DictionaryMappingDTO dico =null; + + String dicoName = getParameterValue(dicoNameString); + // Get the HashMap with as key the concept and value the columnAlias + final HashMap conceptsColumns = getcolumnAliasFromDico(dicoName, dico, datasetApp); + + // Get request parameters + if (datasetApp.getConverterChained() != null) { + datasetApp.getConverterChained().getContext().getAttributes().put("REQUEST", getRequest()); + } + // Get DatabaseRequestParameters + final DatabaseRequestParameters params = dsExplorerUtil.getDatabaseParams(); + LOG.log(Level.INFO,"***************************************** limit : "+ limit); + if(limit == null){ + LOG.log(Level.INFO," ------------------- JE SUIS DANS LE IF"); + params.setPaginationExtend(maxResultsSend); + }else if(limit.equals("25")){ + LOG.log(Level.INFO," ------------------- JE SUIS DANS LE ELSE IF"); + params.setPaginationExtend(maxResultsSend); + }else{ + LOG.log(Level.INFO," ------------------- JE SUIS DANS LE ELSE"); + params.setPaginationExtend(Integer.parseInt(limit)); + } + //params.setPaginationExtend(maxResultsSend); + //params.setPaginationExtend(datasetApp.getDataSet().getNbRecords()); + DatabaseRequest databaseRequest = DatabaseRequestFactory.getDatabaseRequest(params); + + try { + databaseRequest.createRequest(); + + }catch (SitoolsException e) { + e.printStackTrace(); + } + if(jsonP){ + writer.write(cb + "("); + } + String response = ""; + //response = "{"; + writer.write("{"); + //response += "\"type\":\"FeatureCollection\","; + writer.write("\"type\":\"FeatureCollection\","); + // start features + //response +="\"totalResults\":" + databaseRequest.getTotalCount() + ","; + writer.write("\"totalResults\":" + databaseRequest.getTotalCount() + ","); + //response +="\"features\":["; + writer.write("\"features\":["); + // Next for reading first record + + try { + boolean first = true; + while (databaseRequest.nextResult()) { + Record rec = databaseRequest.getRecord(); + if (!first) { + //response += ","; + writer.write(","); + } + else { + first = false; + } + // creates a geometry and a properties string + String geometry = ""; + String services = ""; + String properties = ""; + boolean firstProp = true; + String coords[] = new String[2]; + String coordinateReference = ""; + String urlDownloadFits = ""; + String spoly = ""; + + for(Concept concept : conceptsColumns.keySet()){ + /*if(cpt%100 == 0){ + LOG.log(Level.INFO, "Je suis dans le DANS la boucle WHILE sur les records, et dans la boucle FOR des concepts et cpt = "+cpt); + }*/ + concept.getPropertyFromName("category"); + String colAlias = conceptsColumns.get(concept); + for(AttributeValue attr : rec.getAttributeValues()){ + if(attr.getName().equals(colAlias) && attr.getValue() != null && !attr.getValue().equals("")){ + if(concept.getPropertyFromName("category").getValue().contains("properties")){ + if (!firstProp) { + properties += ","; + } + else { + firstProp = false; + } + properties += "\"" + concept.getName().toString() + "\":\"" + attr.getValue() + "\""; + } + if(concept.getPropertyFromName("category").getValue().contains("geometry")){ + if(concept.getName().equals("ra")){ + coords[0]= attr.getValue().toString(); + }else if(concept.getName().equals("dec")){ + coords[1]= attr.getValue().toString(); + } + if(concept.getName().equals("coordref")){ + coordinateReference = attr.getValue().toString(); + } + if(concept.getName().equals("spoly")){ + spoly = attr.getValue().toString(); + } + } + if(concept.getPropertyFromName("category").getValue().contains("services")){ + if(concept.getName().equals("download")){ + urlDownloadFits = attr.getValue().toString(); + } + } + + } + } + } + + // Set the geometry + geometry = setGeometry(coords, coordinateReference, spoly); + // Set The services + if(!urlDownloadFits.isEmpty()){ + services = setServices(urlDownloadFits); + } + // start feature + //response += "{"; + writer.write("{"); + //response += "\"type\":\"feature\","; + writer.write("\"type\":\"feature\","); + // start geometry + //response += "\"geometry\":{"; + writer.write("\"geometry\":{"); + //response += geometry; + writer.write(geometry); + //response += "}"; + writer.write("}"); + // end geometry + //response += ","; + writer.write(","); + // start properties + //response += "\"properties\":{"; + writer.write("\"properties\":{"); + //response += properties; + writer.write(properties); + // end properties + //response += "}"; + writer.write("}"); + + // start services + if(!services.equals("")){ + //response += ","; + writer.write(","); + //response += "\"services\":{"; + writer.write("\"services\":{"); + //response += services; + writer.write(services); + // end services + //response += "}"; + writer.write("}"); + } + + // end feature + //response += "}"; + writer.write("}"); + } + // end features + //response += "]"; + writer.write("]"); + + }catch (SitoolsException ex) { + Logger.getLogger(DatasetToJson.class.getName()).log(Level.SEVERE, null, ex); + }finally { + //response += "}"; + writer.write("}"); + if (databaseRequest != null) { + try { + databaseRequest.close(); + }catch (SitoolsException e) { + e.printStackTrace(); + } + } + if (writer != null) { + //LOG.log(Level.INFO, "Je suis dans le finally avant le if jsonP"); + if(jsonP){ + //LOG.log(Level.INFO, "Je suis dans le finally dans le IF du if jsonP"); + //String response2 = cb + "("+response +");"; + writer.write(");"); + writer.flush(); + }else{ + //LOG.log(Level.INFO, "Je suis dans le finally dans le ELSE du if jsonP"); + //writer.write(response); + writer.flush(); + } + } + } + } + }; + return repr; + + } + + private HashMap getcolumnAliasFromDico(String dicoName, DictionaryMappingDTO dico, DataSetApplication datasetApp){ + + dico = datasetApp.getColumnConceptMappingDTO(dicoName); + final List colConceptMappingDTOList = dico.getMapping(); + final HashMap conceptColumn = new HashMap(); + + for(ColumnConceptMappingDTO concepts : colConceptMappingDTOList){ + conceptColumn.put(concepts.getConcept(), concepts.getColumnAlias()); + } + return conceptColumn; + } + + private String setGeometry(String[] coords, String coordRef, String spoly){ + String geometry = new String(); + String[] spolyStringTmp = new String[4]; + String[] spolyConverted = new String[4]; + if(spoly.equals("")){ + geometry = "\"coordinates\": ["+coords[0]+","+coords[1]+"],"; + geometry += "\"referencesystem\": \""+coordRef+"\",\"type\": \"Point\""; + }else{ + + String[] tmpString = spoly.split("\\)"); + //LOG.log(Level.INFO, " SPOLY : "+spoly); + tmpString[0] = tmpString[0].substring(2, tmpString[0].length()); + spolyStringTmp[0] = tmpString[0]; + //LOG.log(Level.INFO, " i : 0 = "+spolyStringTmp[0]); + for(int i=1;i<4;i++){ + spolyStringTmp[i] = tmpString[i].substring(2, tmpString[i].length()); + //LOG.log(Level.INFO, "spolyStringTmp i :"+i+ " = "+spolyStringTmp[i]); + } + + for(int k=0;k conceptsColumns = getcolumnAliasFromDico(dicoName, dico, datasetApp); + + // Get request parameters + if (datasetApp.getConverterChained() != null) { + datasetApp.getConverterChained().getContext().getAttributes().put("REQUEST", getRequest()); + } + // Get DatabaseRequestParameters + final DatabaseRequestParameters params = dsExplorerUtil.getDatabaseParams(); + params.setPaginationExtend(maxResultsSend); + //params.setPaginationExtend(datasetApp.getDataSet().getNbRecords()); + DatabaseRequest databaseRequest = DatabaseRequestFactory.getDatabaseRequest(params); + + try { + databaseRequest.createRequest(); + + }catch (SitoolsException e) { + e.printStackTrace(); + } + writer.write("{"); + writer.write("\"type\":\"FeatureCollection\","); + // start features + writer.write("\"totalResults\":" + databaseRequest.getTotalCount() + ","); + writer.write("\"features\":["); + // Next for reading first record + + try { + boolean first = true; + + while (databaseRequest.nextResult()) { + Record rec = databaseRequest.getRecord(); + if (!first) { + writer.write(","); + } + else { + first = false; + } + // creates a geometry and a properties string + String geometry = ""; + String services = ""; + String properties = ""; + boolean firstProp = true; + String coords[] = new String[2]; + String coordinateReference = ""; + String urlDownloadFits = ""; + String spoly = ""; + + for(Concept concept : conceptsColumns.keySet()){ + concept.getPropertyFromName("category"); + String colAlias = conceptsColumns.get(concept); + for(AttributeValue attr : rec.getAttributeValues()){ + if(attr.getName().equals(colAlias) && attr.getValue() != null && !attr.getValue().equals("")){ + if(concept.getPropertyFromName("category").getValue().contains("properties")){ + if (!firstProp) { + properties += ","; + } + else { + firstProp = false; + } + properties += "\"" + concept.getName().toString() + "\":\"" + attr.getValue() + "\""; + } + if(concept.getPropertyFromName("category").getValue().contains("geometry")){ + if(concept.getName().equals("ra")){ + coords[0]= attr.getValue().toString(); + }else if(concept.getName().equals("dec")){ + coords[1]= attr.getValue().toString(); + } + if(concept.getName().equals("coordref")){ + coordinateReference = attr.getValue().toString(); + } + if(concept.getName().equals("spoly")){ + spoly = attr.getValue().toString(); + } + } + if(concept.getPropertyFromName("category").getValue().contains("services")){ + if(concept.getName().equals("download")){ + urlDownloadFits = attr.getValue().toString(); + } + } + + } + } + } + + // Set the geometry + geometry = setGeometry(coords, coordinateReference, spoly); + // Set The services + if(!urlDownloadFits.isEmpty()){ + services = setServices(urlDownloadFits); + } + // start feature + writer.write("{"); + writer.write("\"type\":\"feature\","); + // start geometry + writer.write("\"geometry\":{"); + writer.write(geometry); + writer.write("}"); + // end geometry + writer.write(","); + // start properties + writer.write("\"properties\":{"); + writer.write(properties); + // end properties + writer.write("}"); + + // start services + if(!services.equals("")){ + writer.write(","); + writer.write("\"services\":{"); + + writer.write(services); + // end services + writer.write("}"); + } + + // end feature + writer.write("}"); + + } + + // end features + writer.write("]"); + + + + }catch (SitoolsException ex) { + Logger.getLogger(DatasetToJsonORIG.class.getName()).log(Level.SEVERE, null, ex); + }finally { + writer.write("}"); + if (databaseRequest != null) { + try { + databaseRequest.close(); + }catch (SitoolsException e) { + e.printStackTrace(); + } + } + if (writer != null) { + writer.flush(); + } + } + } + }; + return repr; + + } + + private HashMap getcolumnAliasFromDico(String dicoName, DictionaryMappingDTO dico, DataSetApplication datasetApp){ + + dico = datasetApp.getColumnConceptMappingDTO(dicoName); + final List colConceptMappingDTOList = dico.getMapping(); + final HashMap conceptColumn = new HashMap(); + + for(ColumnConceptMappingDTO concepts : colConceptMappingDTOList){ + conceptColumn.put(concepts.getConcept(), concepts.getColumnAlias()); + } + return conceptColumn; + } + + private String setGeometry(String[] coords, String coordRef, String spoly){ + String geometry = new String(); + String[] spolyStringTmp = new String[4]; + String[] spolyConverted = new String[4]; + if(spoly.equals("")){ + geometry = "\"coordinates\": ["+coords[0]+","+coords[1]+"],"; + geometry += "\"referencesystem\": \""+coordRef+"\",\"type\": \"Point\""; + }else{ + + String[] tmpString = spoly.split("\\)"); + //LOG.log(Level.INFO, " SPOLY : "+spoly); + tmpString[0] = tmpString[0].substring(2, tmpString[0].length()); + spolyStringTmp[0] = tmpString[0]; + //LOG.log(Level.INFO, " i : 0 = "+spolyStringTmp[0]); + for(int i=1;i<4;i++){ + spolyStringTmp[i] = tmpString[i].substring(2, tmpString[i].length()); + //LOG.log(Level.INFO, "spolyStringTmp i :"+i+ " = "+spolyStringTmp[i]); + } + + for(int k=0;k. + ******************************************************************************/ +package fr.ias.sitools.resources.spectrofits; + +import java.io.IOException; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +import org.restlet.data.MediaType; +import org.restlet.ext.json.JsonRepresentation; +import org.restlet.ext.wadl.MethodInfo; +import org.restlet.representation.Representation; +import org.restlet.representation.Variant; +import org.restlet.resource.Get; + +import fr.cnes.sitools.common.exception.SitoolsException; +import fr.cnes.sitools.common.resource.SitoolsParameterizedResource; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.database.DatabaseRequestFactory; +import fr.cnes.sitools.dataset.database.DatabaseRequestParameters; +import fr.cnes.sitools.dataset.database.common.DataSetExplorerUtil; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.resources.order.utils.OrderResourceUtils; +import fr.cnes.sitools.dataset.database.DatabaseRequest; +import fr.cnes.sitools.datasource.jdbc.model.AttributeValue; +import fr.cnes.sitools.datasource.jdbc.model.Record; + +import nom.tam.fits.*; + +import org.json.JSONArray; +import org.json.JSONException; +import org.json.JSONObject; + +/** + * HTML resource + * + * + * @author b.hasnoun + */ +public class GetFitsDataSpectro extends SitoolsParameterizedResource { + + @Override + public void sitoolsDescribe() { + setName("GetFitsDataSpectro"); + setDescription("Get cube fits file data"); + } + + @Override + public void doInit() { + super.doInit(); + } + + /** + * Get HTML + * + * @return Representation the HTML result + */ + @Get + public Representation getCsv() { + return execute(); + } + + @Override + protected void describeGet(MethodInfo info) { + this.addInfo(info); + info.setIdentifier("retrieve records and extract data and metadata from fits file"); + info.setDocumentation("Method to get the data and metadata from a fits file"); + addStandardGetRequestInfo(info); + DataSetExplorerUtil.addDatasetExplorerGetRequestInfo(info); + DataSetApplication application = (DataSetApplication) getApplication(); + DataSetExplorerUtil.addDatasetExplorerGetFilterInfo(info, application.getFilterChained()); + addStandardResponseInfo(info); + addStandardInternalServerErrorInfo(info); + } + + @Override + protected Representation head(Variant variant) { + Representation repr = super.head(); + repr.setMediaType(MediaType.APPLICATION_JSON); + return repr; + } + + /** + * Execute the request and return a Representation + * + * @return the HTML representation + */ + private Representation execute() { + + Representation repr = null; + + // generate the DatabaseRequest + DataSetApplication datasetApp = (DataSetApplication) getApplication(); + DataSetExplorerUtil dsExplorerUtil = new DataSetExplorerUtil(datasetApp, getRequest(), getContext()); + + // Get request parameters + if (datasetApp.getConverterChained() != null) { + datasetApp.getConverterChained().getContext().getAttributes().put("REQUEST", getRequest()); + } + // Get DatabaseRequestParameters + DatabaseRequestParameters params = dsExplorerUtil.getDatabaseParams(); + + DatabaseRequest databaseRequest = DatabaseRequestFactory.getDatabaseRequest(params); + + if (params.getDistinct()) { + try { + databaseRequest.createDistinctRequest(); + } + catch (SitoolsException e) { + + e.printStackTrace(); + } + } else { + try { + databaseRequest.createRequest(); + } + catch (SitoolsException e) { + + e.printStackTrace(); + } + } + + ResourceParameter urlName = this.getModel().getParameterByName("colUrl"); + int hdu = Integer.parseInt(this.getModel().getParameterByName("hduCube").getValue()); + String waveLocation = this.getModel().getParameterByName("wave").getValue(); + + if (databaseRequest != null) { + + // Next for reading first record + try { + databaseRequest.nextResult(); + Record rec = databaseRequest.getRecord(); + + AttributeValue attributeValueURL = OrderResourceUtils.getInParam(urlName, rec); + + if (attributeValueURL.getValue() != null){ + // get the file path + String filePath = (String) attributeValueURL.getValue(); + try { + + Fits fits = new Fits(filePath); + FitsFactory.setUseHierarch(true); + Header.setLongStringsEnabled(true); + + JSONObject jSON = new JSONObject(); + + int waveHDU = -1; + + int nberHDUs = fits.size(); + System.out.println("Number of HDUs: "+nberHDUs); + jSON.put("HDUs", nberHDUs); + + // Headers from fits + System.out.println("Getting Headers..."); + List headers = new ArrayList(nberHDUs); + List>> headersList = new ArrayList>>(nberHDUs); + + for (int i=0;i mapHierarch = new HashMap(); + for (int j=0; j"; + } + + //List of extensions -- List of List of Cards + List> cardList = new ArrayList>(nbreCards); + for (int j=0; j keyValueComment = new ArrayList(nbreCards); + HeaderCard card = header.findCard(header.getKey(j)); + + if ( card!=null ) { + + //key + if (mapHierarch.containsKey(card.getKey())) { + keyValueComment.add( "HIERARCH "+mapHierarch.get(card.getKey()) ); + } + else { + keyValueComment.add(card.getKey()); + } + + //value + keyValueComment.add(card.getValue()); + + if ( card.getKey().contains("EXTNAME") && card.getValue().contains("ImageIndex") ) { + System.out.println("ImageIndex in HDU "+i); + waveHDU=i; + } + + //comment + String commentCard = card.getComment(); + if (commentCard!=null) { + + if (commentCard.contains("&")) { + //System.out.println(j+" "+commentCard); + commentCard = commentCard.substring(0, commentCard.length()-1); + int jTmp = j; + while(header.getCard(jTmp+1).startsWith("COMMENT")){ + String commentCardNext = header.getCard(jTmp+1); + if (commentCardNext.contains("&")) { commentCardNext = commentCardNext.substring(0, commentCardNext.length()-1); } + commentCard += commentCardNext.split("COMMENT ")[1]; + jTmp++; + } + keyValueComment.add(commentCard); + } + else { keyValueComment.add(commentCard); } + + } else {keyValueComment.add("");} + + cardList.add(keyValueComment); + + } + + } + + headersList.add(cardList); + + headers.add(headerStr); + + } + + + jSON.put("HEADERSGRID", headersList); + System.out.println("Headers - Done !"); + + + System.out.println("Getting Wave..."); + int hhdduu = -1; + for (int i=0;i>> cube3DL = new ArrayList>>(naxis1); + //float cube[][][] = new float[naxis1][naxis2][naxis3]; + for (int x=0;x> list2 = new ArrayList>(naxis2); + for (int y=0;y list3 = new ArrayList(naxis3); + for (int z=0;z>> cube3DL = new ArrayList>>(naxis1); + for (int i = 0; i < naxis1; i++) { + List> list2 = new ArrayList>(naxis2); + for (int j = 0; j < naxis2; j++) { + List list3 = new ArrayList(naxis3); + for (int k = 0; k < naxis3; k++) { + list3.add(cube[i][j][k]); + } + list2.add(list3); + } + cube3DL.add(list2); + } + */ + + JSONArray cubeJL= new JSONArray(cube3DL.toString()); + jSON.put("SPECTRUM", cubeJL); + + System.out.println(" Cube - Done !"); + + repr = new JsonRepresentation(jSON); + + + } + catch (FitsException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + catch (JSONException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + } + databaseRequest.close(); + + } + catch (SitoolsException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + } + + return repr; + + } + +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/resources/spectrofits/GetFitsDataSpectroModel.java b/hesiod/javaExt/src/fr/ias/sitools/resources/spectrofits/GetFitsDataSpectroModel.java new file mode 100644 index 0000000..fbaca64 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/resources/spectrofits/GetFitsDataSpectroModel.java @@ -0,0 +1,89 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.resources.spectrofits; + +import java.util.HashSet; +import java.util.Map; +import java.util.Set; + +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.plugins.resources.model.DataSetSelectionType; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.plugins.resources.model.ResourceParameterType; + +/* + * The Model for show fits header resource + * + * + * @author b.hasnoun + */ +public class GetFitsDataSpectroModel extends ResourceModel { + + /** + * Constructor + */ + public GetFitsDataSpectroModel() { + + super(); + setClassAuthor("Boualem HASNOUN"); + setClassOwner("IAS2"); + setClassVersion("1.0"); + setName("GetFitsDataSpectroModel"); + setDescription("Getting data and metadata from a fits file"); + setClassName("fr.ias.sitools.resources.spectrofits.GetFitsDataSpectroModel"); + setResourceClassName(fr.ias.sitools.resources.spectrofits.GetFitsDataSpectro.class.getName()); + + ResourceParameter paramColUrl = new ResourceParameter("colUrl", "Colum containing the url of the fits file.", + ResourceParameterType.PARAMETER_INTERN); + paramColUrl.setValueType("xs:dataset.columnAlias"); + this.addParam(paramColUrl); + + ResourceParameter paramHDU = new ResourceParameter("hduCube", "HDU number where to find the spectral cube.", + ResourceParameterType.PARAMETER_INTERN); + paramHDU.setValueType("xs:integer"); + this.addParam(paramHDU); + + ResourceParameter paramWaveFromWCS = new ResourceParameter("wave", "HDU Table and column number where to find the wave data if you can't build the wave array from the WCS metadata of the spectral cube. Ex: 4-0", + ResourceParameterType.PARAMETER_INTERN); + paramWaveFromWCS.setValueType("xs:string"); + this.addParam(paramWaveFromWCS); + + this.setApplicationClassName(DataSetApplication.class.getName()); + this.setDataSetSelection(DataSetSelectionType.SINGLE); + this.getParameterByName("methods").setValue("GET"); + this.completeAttachUrlWith("/getFitsDataSpectro"); + } + + @Override + public Validator getValidator() { + return new Validator() { + + @Override + public Set validate(ResourceModel item) { + Set constraints = new HashSet(); + Map params = item.getParametersMap(); + + return constraints; + } + }; + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/resources/vo/SimpleSpectralAccessResource.java b/hesiod/javaExt/src/fr/ias/sitools/resources/vo/SimpleSpectralAccessResource.java new file mode 100644 index 0000000..2b112d9 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/resources/vo/SimpleSpectralAccessResource.java @@ -0,0 +1,132 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.resources.vo; + +import fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary; +import fr.cnes.sitools.common.resource.SitoolsParameterizedResource; +import fr.cnes.sitools.dataset.DataSetApplication; +import java.util.ArrayList; +import java.util.List; +import java.util.logging.Logger; +import org.restlet.data.Disposition; +import org.restlet.data.MediaType; +import org.restlet.data.Status; +import org.restlet.ext.wadl.DocumentationInfo; +import org.restlet.ext.wadl.MethodInfo; +import org.restlet.ext.wadl.ParameterInfo; +import org.restlet.ext.wadl.ParameterStyle; +import org.restlet.ext.wadl.RepresentationInfo; +import org.restlet.representation.Representation; +import org.restlet.representation.Variant; +import org.restlet.resource.Get; + +/** + * Queries the dataset and retrieves the result using the Simple Image Access Protocol. + * @see SimpleImageAccessResourcePlugin the plugin + * @see SimpleSpectralAccessProtocolLibrary the library that we use for SIAP. + * @author Jean-Christophe Malapert + */ +public class SimpleSpectralAccessResource extends SitoolsParameterizedResource { + + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(SimpleSpectralAccessResource.class.getName()); + + /** + * Initialize. + */ + @Override + public final void doInit() { + super.doInit(); + } + + /** + * Returns the supported representation. + * + * @param variant variant + * @return XML mediaType + */ + @Override + protected final Representation head(final Variant variant) { + final Representation repr = super.head(); + repr.setMediaType(MediaType.TEXT_XML); + return repr; + } + + /** + * Returns the VOTable response. + * + * @return VOTable response + */ + @Get + public final Representation getVOResponse() { + LOG.finest(String.format("SSA : %s", getRequest())); + final SimpleSpectralAccessProtocolLibrary sia = new SimpleSpectralAccessProtocolLibrary((DataSetApplication) this.getApplication(), + this.getModel(), this.getRequest(), this.getContext()); + final Representation rep = sia.getResponse(); + if (fileName != null && !"".equals(fileName)) { + final Disposition disp = new Disposition(Disposition.TYPE_ATTACHMENT); + disp.setFilename(fileName); + rep.setDisposition(disp); + } + return rep; + } + + /** + * Describes SITools2 in the WADL. + */ + @Override + public final void sitoolsDescribe() { + setName("Simple Spectral Access Protocol"); + setDescription("This class implements the Simple Spectral Access Protocol for Virtual Observatory. " + + "See http://ivoa.net web site for information about this protocol."); + } + + /** + * Describe GET method in the WADL. + * + * @param info information + */ + @Override + protected final void describeGet(final MethodInfo info) { + this.addInfo(info); + info.setIdentifier("SimpleSpectralAccessProtocol"); + info.setDocumentation("Interoperability service to distribute spectrum through the Simple Spectral Access Protocol"); + + final List parametersInfo = new ArrayList(); + parametersInfo.add(new ParameterInfo("POS", true, "string", ParameterStyle.QUERY, + "Box Central position (decimal degree) in ICRS such as RA,DEC.")); + parametersInfo.add(new ParameterInfo("SIZE", true, "string", ParameterStyle.QUERY, + "Size of the box in decimal degree such as width,height or width.")); + info.getRequest().setParameters(parametersInfo); + + info.getResponse().getStatuses().add(Status.SUCCESS_OK); + + final DocumentationInfo documentation = new DocumentationInfo(); + documentation.setTitle("SIAP"); + documentation.setTextContent("Simple Spectral Access Protocol"); + + final List representationsInfo = new ArrayList(); + final RepresentationInfo representationInfo = new RepresentationInfo(MediaType.TEXT_XML); + representationInfo.setDocumentation(documentation); + representationsInfo.add(representationInfo); + info.getResponse().setRepresentations(representationsInfo); + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/resources/vo/SimpleSpectralAccessResourceModel.java b/hesiod/javaExt/src/fr/ias/sitools/resources/vo/SimpleSpectralAccessResourceModel.java new file mode 100644 index 0000000..f940fdb --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/resources/vo/SimpleSpectralAccessResourceModel.java @@ -0,0 +1,200 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.resources.vo; + +import fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary; +import fr.cnes.sitools.common.validator.ConstraintViolation; +import fr.cnes.sitools.common.validator.ConstraintViolationLevel; +import fr.cnes.sitools.common.validator.Validator; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.plugins.resources.model.DataSetSelectionType; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import fr.cnes.sitools.plugins.resources.model.ResourceParameter; +import fr.cnes.sitools.plugins.resources.model.ResourceParameterType; +import fr.cnes.sitools.util.Util; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; +import java.util.logging.Logger; + +/** + * Plugin for publishing a dataset through the Simple Image Access Protocol. + * + *

+ * The plugin answers to the need of the following user story:
+ * As administrator, I publish my data through SIAP so that the users can + * request my images by the use of an interoperability standard. + *
+ * + *
+ * In addition, this plugin has several dependencies with different + * components:
+ * + *
+ *

+ * + * @author Jean-Christophe Malapert + * @startuml SIAP-usecase.png title Publishing data through SIAP User --> (SIAP + * service) : requests Admin --> (SIAP service) : adds and configures the SIAP + * service from the dataset. (SIAP service) .. (dataset) : uses + * @enduml + * @startuml package "Services" { HTTP - [SimpleImageAccessResourcePlugin] } + * database "Database" { frame "Data" { [myData] } } package "Dataset" { HTTP - + * [Dataset] [VODictionary] } folder "DataStorage" { HTTP - [directory] } + * [SimpleImageAccessResourcePlugin] --> [Dataset] [Dataset] --> [directory] + * [Dataset] --> [myData] [Dataset] --> [VODictionary] + * @enduml + */ +public class SimpleSpectralAccessResourceModel extends ResourceModel { + + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(SimpleSpectralAccessResourceModel.class.getName()); + + /** + * Constructs the configuration panel of the plugin. + */ + public SimpleSpectralAccessResourceModel() { + super(); + setClassAuthor("Mnicoals"); + setClassOwner("IAS"); + setClassVersion("0.1"); + setName("Simple Spectral Access Protocol"); + setDescription("This plugin provides an access to your data through the Simple Image Access Protocol"); + setResourceClassName(fr.ias.sitools.resources.vo.SimpleSpectralAccessResource.class.getName()); + + this.setApplicationClassName(DataSetApplication.class.getName()); + this.setDataSetSelection(DataSetSelectionType.SINGLE); + this.getParameterByName("methods").setValue("GET"); + this.completeAttachUrlWith("/services/vo/ssa"); + setConfiguration(); + /* + this.setApplicationClassName(DataSetApplication.class.getName()); + + //we set to NONE because this is a web service for Virtual Observatory + // and we do not want to see it in the web user interface + this.setDataSetSelection(DataSetSelectionType.NONE); + setConfiguration();*/ + } + + /** + * Sets the configuration for the administrator. + */ + private void setConfiguration() { + final ResourceParameter dico = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.DICTIONARY, "Dictionary name that sets up the service.", + ResourceParameterType.PARAMETER_INTERN); + dico.setValueType("xs:dictionary"); + this.addParam(dico); + + final ResourceParameter intersect = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.INTERSECT, + "how matched images should intersect the region of interest", + ResourceParameterType.PARAMETER_INTERN); + //String intersectEnum = "xs:enum[COVERS, ENCLOSED, CENTER, OVERLAPS]"; + intersect.setValueType("xs:enum[CENTER, OVERLAPS]"); + intersect.setValue("OVERLAPS"); + addParam(intersect); + + final ResourceParameter verb = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.VERB, + "Verbosity determines how many columns are to be returned in the resulting table", + ResourceParameterType.PARAMETER_INTERN); + verb.setValueType("xs:enum[0, 1, 2, 3]"); + verb.setValue("1"); + addParam(verb); + + final ResourceParameter responsibleParty = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.RESPONSIBLE_PARTY, + "The data provider's name and email", ResourceParameterType.PARAMETER_INTERN); + addParam(responsibleParty); + + final ResourceParameter serviceName = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.SERVICE_NAME, + "The name of the service", + ResourceParameterType.PARAMETER_INTERN); + serviceName.setValueType("xs:enum[Spectral Archive Service, Spectral Cutout Service, Spectral Mosaicing Service, Spectral Extraction Service]"); + serviceName.setValue("Spectral Archive Service"); + addParam(serviceName); + + final ResourceParameter description = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.DESCRIPTION, + "A couple of paragraphs of text that describe the nature of the service and its wider context", + ResourceParameterType.PARAMETER_INTERN); + addParam(description); + + final ResourceParameter instrument = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.INSTRUMENT, + "The instrument that made the observations, for example STScI.HST.WFPC2", + ResourceParameterType.PARAMETER_INTERN); + addParam(instrument); + + final ResourceParameter maxQuerySize = new ResourceParameter( + fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.MAX_QUERY_SIZE, + "The largest search area, given in decimal degrees, that will be accepted by the service without returning an error condition." + + " A value of 64800 indicates that there is no restriction", + ResourceParameterType.PARAMETER_INTERN); + maxQuerySize.setValue("64800"); + addParam(maxQuerySize); + + final ResourceParameter maxImageSize = new ResourceParameter( + fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.MAX_IMAGE_SIZE, + "The largest image area, given in decimal degrees, that will be returned by the service", + ResourceParameterType.PARAMETER_INTERN); + addParam(maxImageSize); + + final ResourceParameter maxFileSize = new ResourceParameter( + fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.MAX_FILE_SIZE, + "The largest file size, given in Bytes, that will be returned by the service", + ResourceParameterType.PARAMETER_INTERN); + addParam(maxFileSize); + + final ResourceParameter maxRecords = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.MAX_RECORDS, + "The largest number of records that the service will return", ResourceParameterType.PARAMETER_INTERN); + maxRecords.setValue("-1"); + addParam(maxRecords); + + final ResourceParameter geoAttribut = new ResourceParameter(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.GEO_ATTRIBUT, + "Geographical attribut for OVERLAPS mode. The geographical attribut must be spoly datatype from pgsphere", + ResourceParameterType.PARAMETER_INTERN); + geoAttribut.setValueType("xs:dataset.columnAlias"); + addParam(geoAttribut); + + } + + /** + * Validates the configuration that has been set by the administrator. + * + * @return the error or warning + */ + @Override + public final Validator getValidator() { + return new Validator() { + @Override + public final Set validate(final ResourceModel item) { + final Set constraintList = new HashSet(); + final Map params = item.getParametersMap(); + final ResourceParameter dico = params.get(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.DICTIONARY); + + if (!Util.isNotEmpty(dico.getValue())) { + final ConstraintViolation constraint = new ConstraintViolation(); + constraint.setLevel(ConstraintViolationLevel.WARNING); + constraint.setMessage("A dictionary must be set"); + constraint.setValueName(fr.ias.sitools.vo.ssa.SimpleSpectralAccessProtocolLibrary.DICTIONARY); + constraintList.add(constraint); + } + return constraintList; + } + }; + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/validation/vo/TimeValidation.java b/hesiod/javaExt/src/fr/ias/sitools/validation/vo/TimeValidation.java new file mode 100644 index 0000000..7edce73 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/validation/vo/TimeValidation.java @@ -0,0 +1,118 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ + +package fr.ias.sitools.validation.vo; + +import fr.cnes.sitools.extensions.common.NumberArrayValidation; +import fr.cnes.sitools.extensions.common.Validation; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.HashMap; +import java.util.Map; +import java.util.logging.Level; +import java.util.logging.Logger; + +/** + * + * @author marc + */ +public class TimeValidation extends NumberArrayValidation{ + + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(TimeValidation.class.getName()); + + /** + * private time to check + */ + private String timeRange; + /** + * private band to check + */ + private double[] bandRange; + /** + * Char time split + */ + String timeYearCharSplit = "-"; + /** + * Char Hour split + */ + String timeHourCharSplit = ":"; + /** + * Char Date split + */ + String timeDateCharSplit = "T"; + /** + * + * First element of the range. + */ + private static final int MIN = 0; + /** + * Last element of the range. + */ + private static final int MAX = 1; + + public TimeValidation(final Validation validation,final String keyword,final String timeToCheck) { + super(validation, keyword, ",", 2); + this.timeRange = timeToCheck; + } + + + + @Override + protected Map localValidation() { + final Map error = new HashMap(); + if(getTimeRange().split(",").length == 2){ + String timeMin = getTimeRange().split(",")[MIN]; + String timeMax = getTimeRange().split(",")[MAX]; + if(timeMin.contains(timeDateCharSplit)){ + if(timeMin.split(timeDateCharSplit).length > 2 ){ + error.put("Time", "Time value must be in ISO8601 format, eg yyyy-mm-ddThh:mm:ss"); + } + if(!isValidDate(timeMin)){ + error.put("Time", timeMin+" is not a valide date ! Time value must be in ISO8601 format, eg yyyy-mm-ddThh:mm:ss"); + } + } + if(timeMax.contains(timeDateCharSplit)){ + if(timeMax.split(timeDateCharSplit).length > 2 ){ + error.put("Time", "Time value must be in ISO8601 format, eg yyyy-mm-ddThh:mm:ss"); + } + if(!isValidDate(timeMax)){ + error.put("Time", timeMax+" is not a valide date ! Time value must be in ISO8601 format, eg yyyy-mm-ddThh:mm:ss"); + } + } + }else{ + String time = getTimeRange(); + if(!isValidDate(time)){ + error.put("Time", time+" is not a valide date ! Time value must be in ISO8601 format, eg yyyy-mm-ddThh:mm:ss"); + } + } + return error; + } + + /** + * @return the timeRange + */ + public String getTimeRange() { + return timeRange; + } + + public static boolean isValidDate(String text) { + if (text == null || !text.matches("\\d{4}-[01]\\d-[0-3]\\dT[0-9]{2}:[0-9]{2}:[0-9]{2}")){ + return false; + } + + SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss"); + df.setLenient(false); + try { + df.parse(text); + return true; + } catch (ParseException ex) { + return false; + } + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/AbstractSqlGeometryConstraint.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/AbstractSqlGeometryConstraint.java new file mode 100644 index 0000000..30f8222 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/AbstractSqlGeometryConstraint.java @@ -0,0 +1,229 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; +import java.util.logging.Logger; + +/** + * Interface to define a SQL spatial constraint. + * @author Jean-Christophe Malapert + */ +public abstract class AbstractSqlGeometryConstraint { + + /** + * LOGGER + */ + private static final Logger LOG = Logger.getLogger(AbstractSqlGeometryConstraint.class.getName()); + + /** + * Index where the min value of a range is located. + */ + protected static final int MIN = 0; + /** + * Index where the max value of a range is located. + */ + protected static final int MAX = 1; + + /** + * Size parameter given by the user. + */ + private transient double[] sizeArray = new double[2]; + /** + * Central position along right ascension axis. + */ + private transient double raUser; + /** + * Central position along declination axis. + */ + private transient double decUser; + /** + * time. + */ + private transient String[] timeUser = new String[2]; + /** + * band. + */ + private transient double[] bandUser = new double[2]; + + /** + * Sets the geometry attribute. + * @param geometry the geometry attribute + */ + public abstract void setGeometry(final Object geometry); + + /** + * Sets user input parameters. + * @param inputParameters user input parameters + */ + public final void setInputParameters(final SimpleSpectralAccessInputParameters inputParameters) { + this.raUser = inputParameters.getRa(); + this.decUser = inputParameters.getDec(); + if (inputParameters.getBand().length == 2) { + this.bandUser = inputParameters.getBand(); + }else{ + this.bandUser[0] = inputParameters.getBand()[0]; + this.bandUser[1] = inputParameters.getBand()[0]; + } + if (inputParameters.getTime().length == 2) { + this.timeUser = inputParameters.getTime(); + }else{ + + this.timeUser[0] = inputParameters.getTime()[0]; + this.timeUser[1] = inputParameters.getTime()[0]; + } + if (inputParameters.getSize().length == 2) { + this.sizeArray = inputParameters.getSize(); + } else { + this.sizeArray[0] = inputParameters.getSize()[0]; + this.sizeArray[1] = inputParameters.getSize()[0]; + } + } + + /** + * Detects when the SSA request has a collition with South pole. + * @return True when the SSA request has a collition with South pole otherwise False + */ + protected final boolean isSouthPoleCollision() { + return (decUser - sizeArray[1] / 2.0 <= SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_DECLINATION) ? true : false; + } + + /** + * Detects when the SSA request has a collition with North pole. + * @return True when the SSA request has a collition with North pole otherwise False + */ + protected final boolean isNorthPoleCollision() { + return (decUser + sizeArray[1] / 2.0 >= SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_DECLINATION) ? true : false; + } + + /** + * Detects when the SSA request has a collition with both North and South pole. + * @return True when the SSA request has a collition with both North and South pole otherwise False + */ + protected final boolean isPolesCollision() { + return (isNorthPoleCollision() && isSouthPoleCollision()) ? true : false; + } + + /** + * Detects when the SSA request is a large polygon. + * + *

+ * A large polygon is a polygon where two points is separated by MAX_VALUE_FOR_RIGHT_ASCENSION / 2.0 + * along right ascension axis. + *

+ * @return True when the SSA request is a large polygon otherwise False + */ + protected final boolean isLargePolygon() { + return (sizeArray[0] >= SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION / 2.0) ? true : false; + } + + /** + * Detects there is a collision with RA=MAX_VALUE_FOR_RIGHT_ASCENSION. + * @return True when there is a collision with RA=MAX_VALUE_FOR_RIGHT_ASCENSION otherwise False + */ + protected final boolean isMaxRaCollision() { + return (raUser + sizeArray[0] / 2.0 >= SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION) ? true : false; + } + + /** + * Detects there is a collision with RA=MIN_VALUE_FOR_RIGHT_ASCENSION. + * @return True when there is a collision with RA=MIN_VALUE_FOR_RIGHT_ASCENSION otherwise False + */ + protected final boolean isMinRaCollision() { + return (raUser - sizeArray[0] / 2.0 <= SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION) ? true : false; + } + + /** + * Detects if the SSA request has a collision with the border of CAR projection centered on 0,0. + * @return True when the SSA request has a collision with the borders otherwise False + */ + protected final boolean isBorderRaCollision() { + return (isMinRaCollision() && isMaxRaCollision()) ? true : false; + } + + /** + * Detects if the SSA request is a ring on the sphere. + * @return True when the SSA request is a ring otherwise False + */ + protected final boolean isRing() { + return (sizeArray[0] == SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION) ? true : false; + } + + /** + * SQL geometry predicat to add to the SQL constraint. + * @return SQL geometry predicat + */ + public abstract String getSqlPredicat(); + + /** + * Computes ranges of the SSA request along right ascension and declination axes. + * + *

+ * For the declination axis, returns [decmin, decmax].
+ * For the right ascension axis, returns List. The ranges are computed + * based on the CAR projection. + *

+ * + * @return an array [List, Dec[min,max]) + */ + protected final Object computeRange() { + final List raRange = new ArrayList(); + final double[] decRange = new double[2]; + if (this.isPolesCollision()) { + decRange[MIN] = SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_DECLINATION; + decRange[MAX] = SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_DECLINATION; + raRange.add(new Double[]{SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION, SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } else if (this.isNorthPoleCollision()) { + decRange[MIN] = decUser - sizeArray[1] / 2.0; + decRange[MAX] = SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_DECLINATION; + raRange.add(new Double[]{SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION, SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } else if (this.isSouthPoleCollision()) { + decRange[MIN] = SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_DECLINATION; + decRange[MAX] = decUser + sizeArray[1] / 2.0; + raRange.add(new Double[]{SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION, SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } else { + decRange[MIN] = decUser - sizeArray[1] / 2.0; + decRange[MAX] = decUser + sizeArray[1] / 2.0; + if (this.isBorderRaCollision()) { + raRange.add(new Double[]{SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION, + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } else if (this.isMaxRaCollision()) { + raRange.add(new Double[]{raUser - sizeArray[0] / 2.0, + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + raRange.add(new Double[]{SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION, + (raUser + sizeArray[0] / 2.0 + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION) % SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } else if (this.isMinRaCollision()) { + raRange.add(new Double[]{SimpleSpectralAccessProtocolLibrary.MIN_VALUE_FOR_RIGHT_ASCENSION, + raUser + sizeArray[0] / 2.0}); + raRange.add(new Double[]{(raUser - sizeArray[0] / 2.0 + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION) % SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION, + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } else { + raRange.add(new Double[]{(raUser - sizeArray[0] / 2.0 + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION) % SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION, + (raUser + sizeArray[0] / 2.0 + SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION) % SimpleSpectralAccessProtocolLibrary.MAX_VALUE_FOR_RIGHT_ASCENSION}); + } + } + return Arrays.asList(raRange, decRange); + } + protected final Object computeTimeAndBandRange() { + + return Arrays.asList(timeUser, bandUser); + } +} \ No newline at end of file diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/CenterModeIntersection.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/CenterModeIntersection.java new file mode 100644 index 0000000..4b933d1 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/CenterModeIntersection.java @@ -0,0 +1,125 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.List; +import java.util.concurrent.TimeUnit; +import java.util.logging.Level; +import java.util.logging.Logger; + + /** + * Constructs SQL predicat for Center mode intersection. + */ + public class CenterModeIntersection extends AbstractSqlGeometryConstraint { + /** + * LOGGER + */ + private static final Logger LOG = Logger.getLogger(CenterModeIntersection.class.getName()); + /** + * Right ascension attribut. + */ + private transient String raCol; + /** + * Declination attribut. + */ + private transient String decCol; + /** + * Time attribut. + */ + private transient String timeCol; + /** + * Band attribut. + */ + private transient String bandCol; + + @Override + public final void setGeometry(final Object geometry) { + + if (geometry instanceof String[]) { + final String[] geometryArray = (String[]) geometry; + + if (geometryArray.length != 4) { + throw new IllegalArgumentException("geometry must be an array of four elements that contains racolName, decColName, timeColName and bandColName"); + } else { + this.raCol = geometryArray[0]; + this.decCol = geometryArray[1]; + this.timeCol = geometryArray[2]; + this.bandCol = geometryArray[3]; + } + } else { + throw new IllegalArgumentException("geometry must be an array of four elements that contains racolName, decColName, timeColName and bandColName"); + } + } + + @Override + public final String getSqlPredicat() { + if (isPolesCollision()) { + return null; + } + final List rangeSsa = (List) computeTimeAndBandRange(); + + final String[] timeRange = (String[]) rangeSsa.get(0); + final double[] bandRange = (double[]) rangeSsa.get(1); + + + final List ranges = (List) computeRange(); + final List raRanges = (List) ranges.get(0); + final double[] decRange = (double[]) ranges.get(1); + String predicatDefinition; + if (raRanges.size() == 1) { + final Double[] raRange = raRanges.get(0); + predicatDefinition = String.format(" AND ( %s BETWEEN %s AND %s ) AND ( %s BETWEEN %s AND %s )", decCol, decRange[0], decRange[1], raCol, raRange[0], raRange[1]); + } else { + final Double[] raRange1 = raRanges.get(0); + final Double[] raRange2 = raRanges.get(1); + predicatDefinition = String.format(" AND ( %s BETWEEN %s AND %s ) AND (( %s BETWEEN %s AND %s ) OR ( %s BETWEEN %s AND %s ))", + decCol, decRange[0], decRange[1], + raCol, raRange1[0], raRange1[1], raCol, raRange2[0], raRange2[1]); + } + + if(timeRange[0].equals(timeRange[1])){ + timeRange[1] = addHourinTimeRange(timeRange[0]); + } + predicatDefinition += String.format(" AND ( %s BETWEEN %s AND %s ) AND ( %s BETWEEN '%s' AND '%s' )", + bandCol, bandRange[0], bandRange[1],timeCol, timeRange[0], timeRange[1]); + LOG.log(Level.SEVERE,"predicatDefinition : "+predicatDefinition); + return predicatDefinition; + } + + private String addHourinTimeRange(String timeTo){ + String a = null; + SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS"); + try { + Date date = df.parse(timeTo); + Date newDate = new Date(date.getTime()+TimeUnit.HOURS.toMillis(1)); + a = newDate.toString(); + LOG.log(Level.INFO," ************************ : newDate.toString : "+a); + LOG.log(Level.INFO," ************************ : newDate.toString : "+newDate.toGMTString()); + LOG.log(Level.INFO," ************************ : newDate.toString : "+newDate.toLocaleString()); + } catch (ParseException ex) { + Logger.getLogger(CenterModeIntersection.class.getName()).log(Level.SEVERE, null, ex); + a=timeTo; + } + + return a; + } + } diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/DataModelInterface.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/DataModelInterface.java new file mode 100644 index 0000000..cbefa7f --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/DataModelInterface.java @@ -0,0 +1,36 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import java.util.Map; + +/** + * Provides an interface to get the data model. + * + * @author Jean-Christophe Malapert + */ +public interface DataModelInterface { + + /** + * Returns the data model. + * + * @return data model + */ + Map getDataModel(); +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/OverlapsModeIntersection.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/OverlapsModeIntersection.java new file mode 100644 index 0000000..7460a9b --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/OverlapsModeIntersection.java @@ -0,0 +1,193 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import fr.cnes.sitools.searchgeometryengine.Resampling; +import java.util.List; +import java.util.logging.Level; +import java.util.logging.Logger; + +/** + * Constructs SQL predicat for Overlaps mode intersection. + * @author Jean-Christophe Malapert + */ +public class OverlapsModeIntersection extends AbstractSqlGeometryConstraint { + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(OverlapsModeIntersection.class.getName()); + /** + * Default value for resampling along right ascension axis. + */ + private static final double DEFAULT_SAMPLING_VALUE_RA = 20; + /** + * Default value for resampling along declination axis. + */ + private static final double DEFAULT_SAMPLING_VALUE_DEC = 20; + /** + * geometry attribut. + */ + private transient String geomCol; + + @Override + public final void setGeometry(final Object geometry) { + if (geometry instanceof String) { + this.geomCol = String.valueOf(geometry); + }else if(geometry instanceof List) { + + } else { + throw new IllegalArgumentException("geometry must be a String"); + } + /* } else { + throw new IllegalArgumentException("geometry must be a String"); + }*/ + } + + @Override + public final String getSqlPredicat() { + if (this.isPolesCollision()) { + return null; + } + + final List ranges = (List) computeRange(); + final List raRanges = (List) ranges.get(0); + final double[] decRange = (double[]) ranges.get(1); + + String predicatDefinition; + if (isNorthPoleCollision()) { + LOG.log(Level.FINEST, "North collision case"); + predicatDefinition = String.format(" AND (spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}')", geomCol, 0.0, decRange[0], 45.0, 90.0, 90.0, decRange[0]); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}')", geomCol, 90.0, decRange[MIN], 135.0, 90.0, 180.0, decRange[MIN])); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}')", geomCol, 180.0, decRange[MIN], 225.0, 90.0, 270.0, decRange[MIN])); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}'))", geomCol, 270.0, decRange[MIN], 325.0, 90.0, 360.0, decRange[MIN])); + LOG.log(Level.FINEST, predicatDefinition); + + } else if (isSouthPoleCollision()) { + LOG.log(Level.FINEST, "South collision case"); + predicatDefinition = String.format(" AND (spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}')", geomCol, 0.0, decRange[MAX], 45.0, -90.0, 90.0, decRange[MAX]); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}')", geomCol, 90.0, decRange[MAX], 135.0, -90.0, 180.0, decRange[MAX])); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}')", geomCol, 180.0, decRange[MAX], 225.0, -90.0, 270.0, decRange[MAX])); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd)}'))", geomCol, 270.0, decRange[MAX], 325.0, -90.0, 360.0, decRange[MAX])); + LOG.log(Level.FINEST, predicatDefinition); + + } else if (isRing()) { + LOG.log(Level.FINEST, "Ring case"); + predicatDefinition = String.format(" AND (spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd), (%sd,%sd)}')", geomCol, 0.0, decRange[MIN], 90.0, decRange[MIN], 90.0, decRange[MAX], 0.0, decRange[MAX]); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd), (%sd,%sd)}')", geomCol, 90.0, decRange[MIN], 180.0, decRange[MIN], 180.0, decRange[MAX], 90.0, decRange[MAX])); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd), (%sd,%sd)}')", geomCol, 180.0, decRange[MIN], 270.0, decRange[MIN], 270.0, decRange[MAX], 180.0, decRange[MAX])); + predicatDefinition = predicatDefinition.concat(String.format(" OR spoly_overlap_polygon(%s,'{(%sd,%sd),(%sd,%sd),(%sd,%sd), (%sd,%sd)}'))", geomCol, 270.0, decRange[MIN], 0.0, decRange[MIN], 0.0, decRange[MAX], 270.0, decRange[MAX])); + LOG.log(Level.FINEST, predicatDefinition); + + } else if (raRanges.size() == 1 && isLargePolygon()) { + LOG.log(Level.FINEST, "Large polygon case"); + final Double[] raRange1 = raRanges.get(0); + final double mean = (raRange1[MIN] + raRange1[MAX]) / 2.0; + raRanges.add(new Double[]{mean, raRange1[MAX]}); + raRanges.set(0, new Double[]{raRange1[MIN], mean}); + predicatDefinition = buildMultiPolygon(raRanges, decRange); + LOG.log(Level.FINEST, predicatDefinition); + } else { + LOG.log(Level.FINEST, "other case"); + predicatDefinition = buildMultiPolygon(raRanges, decRange); + LOG.log(Level.FINEST, predicatDefinition); + } + return predicatDefinition; + } + + /** + * Builds a multi-polygon syntax for PgSphere based on a set right ascension ranges and a declination range. + * + *

+ * A range is an array that is composed of two values : min and max value. + *

+ * + * @param raRanges set of right ascension ranges + * @param decRange declination range + * @return the SQL predicat + */ + private String buildMultiPolygon(final List raRanges, final double[] decRange) { + final StringBuilder stringBuilder = new StringBuilder(" AND ("); + buildPolygon(stringBuilder, raRanges.get(0), decRange); + if (raRanges.size() == 2) { + stringBuilder.append(" OR "); + buildPolygon(stringBuilder, raRanges.get(1), decRange); + } + stringBuilder.append(")"); + return stringBuilder.toString(); + } + + /** + * Build a polygon syntax for PgSphere based on the SQL predicat to complete, the right ascension and declination range. + *

+ * A range is an array that is composed of two values : min and max value. + *

+ * @param stringBuilder SQL predicat to complete + * @param raRange right ascension range [min,max] + * @param decRange declination range [min,max] + */ + private void buildPolygon(final StringBuilder stringBuilder, final Double[] raRange, final double[] decRange) { + stringBuilder.append(String.format("spoly_overlap_polygon(%s,'{", geomCol)); + final double[] pointsRa = Resampling.hourCircle(raRange[MIN], raRange[MAX], DEFAULT_SAMPLING_VALUE_RA); + final double[] pointsDec = Resampling.decCircle(decRange[MIN], decRange[MAX], DEFAULT_SAMPLING_VALUE_DEC); + buildRaLine(stringBuilder, pointsRa, decRange[MIN], false); + buildDecLine(stringBuilder, pointsDec, raRange[MAX], false); + buildRaLine(stringBuilder, pointsRa, decRange[MAX], true); + buildDecLine(stringBuilder, pointsDec, raRange[MIN], true); + stringBuilder.deleteCharAt(stringBuilder.length() - 1); + stringBuilder.append("}')"); + } + + /** + * Builds a line of the polygon for the SIAP request along the right ascension axis. + * @param stringBuilder polygon to complete + * @param raCoordinates values in the line along right ascension axis + * @param staticDecCoordinate constant declination. + * @param isReverseOrder indicates if the order where raCoordinates array must be read + */ + private void buildRaLine(final StringBuilder stringBuilder, final double[] raCoordinates, final double staticDecCoordinate, final boolean isReverseOrder) { + if (isReverseOrder) { + for (int i = raCoordinates.length - 1; i > 0; i--) { + stringBuilder.append(String.format("(%sd,%sd),", raCoordinates[i], staticDecCoordinate)); + } + } else { + for (int i = 0; i < raCoordinates.length - 1; i++) { + stringBuilder.append(String.format("(%sd,%sd),", raCoordinates[i], staticDecCoordinate)); + } + } + } + + /** + * Builds a line of the polygon for the SIAP request along the declination axis. + * @param stringBuilder polygon to complete + * @param decCoordinates values in the line along declination axis + * @param staticRaCoordinate constant right ascension. + * @param isReverseOrder indicates if the order where raCoordinates array must be read + */ + private void buildDecLine(final StringBuilder stringBuilder, final double[] decCoordinates, final double staticRaCoordinate, final boolean isReverseOrder) { + if (isReverseOrder) { + for (int i = decCoordinates.length - 1; i > 0; i--) { + stringBuilder.append(String.format("(%sd,%sd),", staticRaCoordinate, decCoordinates[i])); + } + } else { + for (int i = 0; i < decCoordinates.length - 1; i++) { + stringBuilder.append(String.format("(%sd,%sd),", staticRaCoordinate, decCoordinates[i])); + } + } + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessDataModelInterface.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessDataModelInterface.java new file mode 100644 index 0000000..2069de3 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessDataModelInterface.java @@ -0,0 +1,33 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import java.util.Map; + +/** + * Interface for the use of a SIA. + * @author Jean-Christophe Malapert + */ +interface SimpleSpectralAccessDataModelInterface { + /** + * Returns the data model. + * @return the data model + */ + Map getDataModel(); +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessException.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessException.java new file mode 100644 index 0000000..e9cdb19 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessException.java @@ -0,0 +1,54 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +/** + * Exception for graph package. + * @author Jean-Christophe Malapert + */ +public class SimpleSpectralAccessException extends Exception { + /** + * Empty constructor. + */ + public SimpleSpectralAccessException() { + super(); + } + /** + * Constructs an Exception with a message. + * @param message message + */ + public SimpleSpectralAccessException(final String message) { + super(message); + } + /** + * Constructs an Exception with a cause. + * @param cause cause + */ + public SimpleSpectralAccessException(final Throwable cause) { + super(cause); + } + /** + * Constructs an Exception with a message and a cause. + * @param message message + * @param cause cause + */ + public SimpleSpectralAccessException(final String message, final Throwable cause) { + super(message, cause); + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessInputParameters.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessInputParameters.java new file mode 100644 index 0000000..953f5b7 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessInputParameters.java @@ -0,0 +1,397 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.extensions.common.InputsValidation; +import fr.cnes.sitools.extensions.common.NotNullAndNotEmptyValidation; +import fr.cnes.sitools.extensions.common.NumberArrayValidation; +import fr.cnes.sitools.extensions.common.NumberValidation; +import fr.cnes.sitools.extensions.common.SpatialGeoValidation; +import fr.cnes.sitools.extensions.common.StatusValidation; +import fr.cnes.sitools.extensions.common.Validation; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import fr.cnes.sitools.util.Util; +import fr.ias.sitools.validation.vo.TimeValidation; +import java.util.ArrayList; +import java.util.Collections; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.logging.Level; +import java.util.logging.Logger; +import net.ivoa.xml.votable.v1.AnyTEXT; +import net.ivoa.xml.votable.v1.DataType; +import net.ivoa.xml.votable.v1.Info; +import net.ivoa.xml.votable.v1.Option; +import net.ivoa.xml.votable.v1.Param; +import net.ivoa.xml.votable.v1.Values; +import org.restlet.Context; +import org.restlet.Request; + +/** + * Input parameters for SIA. + * + * @author Jean-Crhistophe Malapert + */ +public class SimpleSpectralAccessInputParameters implements DataModelInterface { + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(SimpleSpectralAccessInputParameters.class.getName()); + /** + * Init value for right ascension parameter of the user input. + */ + private transient double ra = 0.0; + /** + * Init value for declination parameter of the user input. + */ + private transient double dec = 0.0; + /** + * Array that stores the size parameter of the user input. + */ + private transient double[] size; + /** + * Array that stores time paramater of the user input time + */ + private transient String[] time; + + /** + * Array that stores time paramater of the user input time + */ + private transient double[] band; + /** + * Default value for the verb parameter of the user input. + */ + private transient int verb = 0; + /** + * Data model that stores the metadata response of the service. + */ + private final transient Map dataModel = new HashMap(); + /** + * Request. + */ + private final transient Request request; + /** + * Context. + */ + private final transient Context context; + /** + * Application where this resources is linked. + */ + private final transient DataSetApplication datasetApp; + /** + * Configuration parameters of this resource. + */ + private final transient ResourceModel resourceModel; + + /** + * Constructs the objet that returns the metadata of the service. + * @param datasetAppVal application + * @param requestVal request + * @param contextVal context + * @param resourceModelVal configuration parameters + */ + public SimpleSpectralAccessInputParameters(final DataSetApplication datasetAppVal, final Request requestVal, final Context contextVal, final ResourceModel resourceModelVal) { + this.datasetApp = datasetAppVal; + this.context = contextVal; + this.request = requestVal; + this.resourceModel = resourceModelVal; + final String posInput = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.POS); + final String sizeInput = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.SIZE); + final String format = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.FORMAT); + final String intersect = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.INTERSECT); + final String verbosity = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.VERB); + final String timeInput = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.TIME); + final String bandInput = this.request.getResourceRef().getQueryAsForm().getFirstValue(SimpleSpectralAccessProtocolLibrary.BAND); + //TODO check the differentParameters + if(posInput == null && sizeInput == null){ + final Info info = new Info(); + final List listInfos = new ArrayList(); + info.setName("QUERY_STATUS"); + info.setValueAttribute("ERROR"); + listInfos.add(info); + this.dataModel.put("infos", listInfos); + }else{ + if (Util.isSet(format) && format.equals(SimpleSpectralAccessProtocolLibrary.ParamStandardFormat.METADATA.name())) { + fillMetadataFormat(); + } else { + checkInputParameters(posInput, sizeInput, timeInput, bandInput); + } + } + } + + /** + * Fills metadata response. + */ + private void fillMetadataFormat() { + + this.dataModel.put("description", this.resourceModel.getParameterByName(SimpleSpectralAccessProtocolLibrary.DESCRIPTION).getValue()); + + final List listInfos = new ArrayList(); + Info info = new Info(); + info.setName("QUERY_STATUS"); + info.setValueAttribute("OK"); + info = new Info(); + listInfos.add(info); + info.setName("SERVICE_PROTOCOL"); + info.setValue("1.1"); + info.setValueAttribute("SSAP"); + listInfos.add(info); + + this.dataModel.put("infos", listInfos); + + final List listParam = new ArrayList(); + Param param = new Param(); + param.setName("INPUT:POS"); + param.setValue("0,0"); + param.setDatatype(DataType.DOUBLE); + AnyTEXT anyText = new AnyTEXT(); + anyText.getContent().add("Search Position in the form ra,dec where ra and dec are given in decimal degrees in the ICRS coordinate system."); + param.setDESCRIPTION(anyText); + listParam.add(param); + + param = new Param(); + param.setName("INPUT:SIZE"); + param.setValue("0.05"); + param.setDatatype(DataType.DOUBLE); + anyText = new AnyTEXT(); + anyText.getContent().add("Size of search region in the RA and Dec directions."); + param.setDESCRIPTION(anyText); + listParam.add(param); + + param = new Param(); + param.setName("INPUT:FORMAT"); + param.setValue(SimpleSpectralAccessProtocolLibrary.ParamStandardFormat.ALL.name()); + param.setDatatype(DataType.CHAR); + param.setArraysize("*"); + anyText = new AnyTEXT(); + anyText.getContent().add("Requested format of images."); + param.setDESCRIPTION(anyText); + final List formatList = SimpleSpectralAccessProtocolLibrary.ParamStandardFormat.getCtes(); + final Values values = new Values(); + for (String formatIter : formatList) { + final Option option = new Option(); + option.setValue(formatIter); + values.getOPTION().add(option); + } + param.setVALUES(values); + //TODO : le faire pour chaque format + listParam.add(param); + + param = new Param(); + param.setName("INPUT:INTERSECT"); + param.setValue(this.resourceModel.getParameterByName(SimpleSpectralAccessProtocolLibrary.INTERSECT).getValue()); + param.setDatatype(DataType.CHAR); + anyText = new AnyTEXT(); + anyText.getContent().add("Choice of overlap with requested region."); + param.setDESCRIPTION(anyText); + listParam.add(param); + + param = new Param(); + param.setName("INPUT:VERB"); + param.setValue(this.resourceModel.getParameterByName(SimpleSpectralAccessProtocolLibrary.VERB).getValue()); + param.setDatatype(DataType.INT); + anyText = new AnyTEXT(); + anyText.getContent().add("Verbosity level, controlling the number of columns returned."); + param.setDESCRIPTION(anyText); + listParam.add(param); + + dataModel.put("params", listParam); + } + + /** + * Checks input parameters. + * @param posInput input parameter for POS + * @param sizeInput input parameter for SIZE + */ + private void checkInputParameters(final String posInput, final String sizeInput, final String timeInput, final String bandInput) { + final List infos = new ArrayList(); + final Map validationMap = new HashMap(); + validationMap.put(SimpleSpectralAccessProtocolLibrary.POS, posInput); + validationMap.put(SimpleSpectralAccessProtocolLibrary.SIZE, sizeInput); + validationMap.put(SimpleSpectralAccessProtocolLibrary.TIME, timeInput); + validationMap.put(SimpleSpectralAccessProtocolLibrary.BAND, bandInput); + Validation validation = new InputsValidation(validationMap); + validation = new NotNullAndNotEmptyValidation(validation, SimpleSpectralAccessProtocolLibrary.POS); + validation = new NotNullAndNotEmptyValidation(validation, SimpleSpectralAccessProtocolLibrary.SIZE); + // ------------------------ RAJOUT POUR LE SSA --------------------------------------- + if(timeInput!= null){ + validation = new TimeValidation(validation, SimpleSpectralAccessProtocolLibrary.TIME, timeInput); + } + if(bandInput != null){ + validation = new NumberArrayValidation(validation, SimpleSpectralAccessProtocolLibrary.BAND, ","); + } + //*************** FIN DU RAJOUT ********************************* + if(validation.validate().isValid()){ + validation = new SpatialGeoValidation(validation, SimpleSpectralAccessProtocolLibrary.POS, 0, 1, new double[]{0.0, 360.0}, new double[]{-90.0, 90.0}); + // LA LIGNE SUIVANTE A ETE AJOUTEE POUR VERIFIER QUE LA SIZE EST BIEN UN NOMBRE + validation = new NumberValidation(validation, SimpleSpectralAccessProtocolLibrary.SIZE, true); + //----------------------------------------------------------------------------------------------- + } + StatusValidation status = validation.validate(); + if (status.isValid()) { + final String pos = validation.getMap().get(SimpleSpectralAccessProtocolLibrary.POS); + final String[] arrayPos = pos.split(","); + + this.ra = Double.valueOf(arrayPos[0]); + this.dec = Double.valueOf(arrayPos[1]); + + final String size = validation.getMap().get(SimpleSpectralAccessProtocolLibrary.SIZE); + final String[] arraySize = size.split(","); + if(arraySize.length == 1) { + this.size = new double[1]; + this.size[0] = Double.valueOf(arraySize[0]); + } else { + this.size = new double[2]; + this.size[0] = Double.valueOf(arraySize[0]); + this.size[1] = Double.valueOf(arraySize[1]); + } + //--------------- RAJOUT POUR LE PROTOCOLE SSA ----------------- + if(timeInput!= null){ + final String time = timeInput; + + final String[] arrayTime = time.split(","); + if(arrayTime.length == 1) { + this.time = new String[1]; + this.time[0] = arrayTime[0]; + } else { + this.time = new String[2]; + this.time[0] = arrayTime[0]; + this.time[1] = arrayTime[1]; + } + } + if(bandInput!= null){ + final String band = bandInput; + final String[] arrayBand = band.split(","); + if(arrayBand.length == 1) { + this.band = new double[1]; + this.band[0] = Double.valueOf(arrayBand[0]); + } else { + this.band = new double[2]; + this.band[0] = Double.valueOf(arrayBand[0]); + this.band[1] = Double.valueOf(arrayBand[1]); + } + } + //*************** FIN DU RAJOUT ********************************* + + } else { + Info info = new Info(); + info.setName("QUERY_STATUS"); + info.setValueAttribute("ERROR"); + infos.add(info); + final Map errors = status.getMessages(); + final Set> entries = errors.entrySet(); + for (Map.Entry entry : entries) { + info = new Info(); + info.setID(entry.getKey()); + info.setName("Error in " + entry.getKey()); + info.setValueAttribute("Error in input " + entry.getKey() + ": " + entry.getValue()); + infos.add(info); + LOG.log(Level.FINEST, "{0}: {1}", new Object[]{entry.getKey(), entry.getValue()}); + } + + } + + if (!infos.isEmpty()) { + this.dataModel.put("infos", infos); + } + } + + @Override + public final Map getDataModel() { + return Collections.unmodifiableMap(this.dataModel); + } + + /** + * Get Ra. + * + * @return Ra + */ + public final double getRa() { + return this.ra; + } + + /** + * Get Dec. + * + * @return Dec + */ + public final double getDec() { + return this.dec; + } + + /** + * Get Sr. + * + * @return Sr + */ + public final double[] getSize() { + final double[] copySize = new double[this.size.length]; + System.arraycopy(this.size, 0, copySize, 0, this.size.length); + return copySize; + } + + /** + * Get the request. + * + * @return Request + */ + public final Request getRequest() { + return this.request; + } + + /** + * Get the context. + * + * @return Context + */ + public final Context getContext() { + return this.context; + } + + /** + * Get DatasetApplication. + * + * @return Dataset application + */ + public final DataSetApplication getDatasetApplication() { + return this.datasetApp; + } + + /** + * Get verb. + * @return verb + */ + public final int getVerb() { + return this.verb; + } + + public final String[] getTime() { + final String[] copyTime = new String[this.time.length]; + System.arraycopy(this.time, 0, copyTime, 0,this.time.length); + return copyTime; + } + public final double[] getBand() { + final double[] copyBand = new double[this.band.length]; + System.arraycopy(this.band, 0, copyBand, 0, this.band.length); + return copyBand; + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessProtocolLibrary.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessProtocolLibrary.java new file mode 100644 index 0000000..48391c5 --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessProtocolLibrary.java @@ -0,0 +1,698 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import fr.cnes.sitools.astro.representation.VOTableRepresentation; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collections; +import java.util.List; +import java.util.Map; +import java.util.logging.Level; +import java.util.logging.Logger; +import net.ivoa.xml.votable.v1.DataType; +import org.restlet.Context; +import org.restlet.Request; + +/** + * + * @author malapert + */ +public class SimpleSpectralAccessProtocolLibrary { + + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(SimpleSpectralAccessProtocolLibrary.class.getName()); + + /** + * + */ + public static final String DICTIONARY = "PARAM_Dictionary"; + /** + * + */ + public static final String INTERSECT = "INTERSECT"; + /** + * + */ + public static final String POS = "POS"; + /** + * + */ + public static final String VERB = "VERB"; + /** + * + */ + public static final String SIZE = "SIZE"; + /** + * + */ + public static final String FORMAT = "FORMAT"; + /** + * + */ + public static final String RA_COL = "COLUMN_RA"; + /** + * + */ + public static final String DEC_COL = "COLUMN_DEC"; + /** + * + */ + public static final List REQUIRED_UCD_CONCEPTS = Arrays.asList("VOX:Image_Title", + "POS_EQ_RA_MAIN", + "POS_EQ_DEC_MAIN", + /*"VOX:Image_Naxes", + "VOX:Image_Naxis", + "VOX:Image_Scale", + "VOX:Image_Format",*/ + "VOX:Image_AccessReference", + "TIME_MAIN", + "BAND_MAIN"); + /** + * + */ + public static final String RESPONSIBLE_PARTY = "Responsible party"; + /** + * + */ + public static final String SERVICE_NAME = "Image service"; + /** + * + */ + public static final String DESCRIPTION = "Description"; + /** + * + */ + public static final String INSTRUMENT = "Instrument"; + /** + * + */ + public static final String WAVEBAND = "Waveband Coverage"; + /** + * + */ + public static final String COVERAGE = "Spatial Coverage"; + /** + * + */ + public static final String TEMPORAL = "Temporal Coverage"; + /** + * + */ + public static final String MAX_QUERY_SIZE = "Max query size"; + /** + * + */ + public static final String MAX_IMAGE_SIZE = "Max image size"; + /** + * + */ + public static final String MAX_FILE_SIZE = "Max file size"; + /** + * + */ + public static final String MAX_RECORDS = "Max records"; + /** + * spoly column from pgsphere. + */ + + // ******************************************** RAJOUTER POUR SSAP *********************************** + public static final String SERVICE_PROTOCOL = "SERVICE PROTOCOL"; + + public static final String TIME = "TIME"; + + public static final String BAND = "BAND"; + + + //-------------------------------------------------------------------------------------------------------- + public static final String GEO_ATTRIBUT = "geoAttribut"; + private transient DataSetApplication datasetApp; + private transient ResourceModel resourceModel; + private transient Request request; + private transient Context context; + + /** + * Maximum value of the declination axis. + */ + public static final double MAX_VALUE_FOR_DECLINATION = 90.0; + /** + * Minimum value of the declination axis. + */ + public static final double MIN_VALUE_FOR_DECLINATION = -90.0; + /** + * Maximum value of the right ascension axis. + */ + public static final double MAX_VALUE_FOR_RIGHT_ASCENSION = 360.0; + /** + * Minimum value of the right ascension axis. + */ + public static final double MIN_VALUE_FOR_RIGHT_ASCENSION = 0.0; + /** + * + */ + public enum Intersect { + + /** + * + */ + COVERS, /* The candidate image covers or includes the entire ROI */ + /** + * + */ + ENCLOSED, /* The candidate image is entirely enclosed by the ROI */ + /** + * + */ + CENTER, /* The candidate image overlaps the center of the ROI */ + /** + * + */ + OVERLAPS /* The candidate image overlaps some part of the ROI */ + + }; + + /** + * + */ + public enum SpectrumService { + + /** + * + */ + POINTED_SPECTRAL_ARCHIVE("Spectral Archive Service"), + SPECTRAL_CUTOUT_SERVICE("Spectral Cutout Service"), + SPECTRAL_MOSAICING_SERVICE("Spectral Mosaicing Service"), + SPECTRAL_EXTRACTION_SERVICE("Spectral Extraction Service"); + public final String serviceName; + + SpectrumService(String serviceName) { + this.serviceName = serviceName; + } + + /** + * + * @return + */ + public final String getServiceName() { + return this.serviceName; + } + } + + /** + * + */ + public enum ImageGenerationParameters { + + /** + * + */ + NAXIS, + /** + * + */ + CFRAME, + /** + * + */ + EQUINOX, + /** + * + */ + CRPIX, + /** + * + */ + CRVAL, + /** + * + */ + CDELT, + /** + * + */ + ROTANG, + /** + * + */ + PROJ + }; + + /** + * + */ + public enum Verb { + + /** + * + */ + VERBOSITY_0(0), /* The output table should contain only the minimum columns required */ + /** + * + */ + VERBOSITY_1(1), /* In addition to level 0, the output table should contain columns sufficient for uniquely describing the image */ + /** + * + */ + VERBOSITY_2(2), /* In addition to level 1, the output table should contain, if possible, columns that contain values for all parameters supported as query constraints */ + /** + * + */ + VERBOSITY_3(3); /* The output table should return as much information about the images as possible. A table metadata query automatically implies the highest level of verbosity */ + + /** + * + */ + public final int verbosityMode; + + Verb(final int verbosityMode) { + this.verbosityMode = verbosityMode; + } + + /** + * + * @return + */ + public final int getVerbosityMode() { + return this.verbosityMode; + } + } + + /** + * List of format for internet browser. + */ + public enum GraphicBrowser { + + /** + * JPEG format. + */ + JPEG("image/jpeg"), + /** + * PNG format. + */ + PNG("image/png"), + /** + * GIF format. + */ + GIF("image/gif"); + /** + * Format. + */ + private final String format; + + /** + * new Instance of Graphic browser. + * + * @param format Format name. + */ + GraphicBrowser(final String format) { + this.format = format; + } + + /** + * Get Format Name. + * + * @return Returns format name. + */ + public String getFormat() { + return format; + } + + /** + * Check if val is a graphic format. + * + * @param val Format. + * @return Returns True when val is contained in the list of Graphic format otherwise False. + */ + public static boolean contains(final String val) { + for (GraphicBrowser it : GraphicBrowser.values()) { + if (it.getFormat().equals(val)) { + return true; + } + } + return false; + } + } + + /** + * List of supported format. + */ + public enum ParamStandardFormat { + + /** + * All format. + */ + ALL("ALL", new ArrayList()), + /** + * Graphic format. + */ + GRAPHIC("GRAPHIC", new ArrayList()), + /** + * METADATA format. + */ + METADATA("METADATA", new ArrayList()), + /** + * GRAPHIC Format. + */ + GRAPHIC_ALL("GRAPHIC-ALL", new ArrayList()); + /** + * format. + */ + private final String format; + /** + * All formats. + */ + private List formats; + + /** + * New instance of Standard Format. + * + * @param val format name. + * @param formats values for this format name. + */ + ParamStandardFormat(final String val, final List formats) { + this.format = val; + this.formats = formats; + } + + /** + * Get the format name. + * + * @return Returns the format name. + */ + public String getFormatName() { + return format; + } + + /** + * Get the list of format. + * + * @return Returns the list of format for a format name. + */ + public List getFormats() { + return Collections.unmodifiableList(formats); + } + + /** + * Add a format to the format name. + * + * @param val new supported format value. + */ + private void addFormat(final String val) { + this.formats.add(val); + } + + /** + * Set the list of format for a format name. + * + * @param val Set a list of formats for a format name. + */ + private void setFormat(final List val) { + this.formats.addAll(val); + } + + /** + * Add a format value for a format name. + * + * @param format format Name. + * @param specialValue Value for a format name. + */ + private static void addFormat(final String format, final ParamStandardFormat specialValue) { + for (ParamStandardFormat it : ParamStandardFormat.values()) { + if (it.equals(specialValue) && !ParamStandardFormat.hasFormat(format)) { + it.addFormat(format); + } + } + } + + /** + * Set a list of format for a format name. + * + * @param format Format name. + * @param specialValue List of format. + */ + private static void setFormat(final List format, final ParamStandardFormat specialValue) { + for (ParamStandardFormat it : ParamStandardFormat.values()) { + if (it.equals(specialValue)) { + it.setFormat(format); + } + } + } + + /** + * Get the list of supported format for a format name. + * + * @param format Format name. + * @return Returns the list of supported formats. + */ + public static List getFormats(final ParamStandardFormat format) { + for (ParamStandardFormat it : ParamStandardFormat.values()) { + if (it.equals(format)) { + return it.getFormats(); + } + } + throw new IllegalAccessError(); + } + + /** + * Get the list of supported format for a format name. + * + * @param format Format name. + * @return Returns the list of supported formats. + */ + public static List getFormats(final String format) { + for (ParamStandardFormat it : ParamStandardFormat.values()) { + if (it.getFormatName().equals(format)) { + return it.getFormats(); + } + } + throw new IllegalAccessError(); + } + + /** + * Get Format names. + * + * @return Returns format names. + */ + public static List getCtes() { + final List formats = new ArrayList(); + for (ParamStandardFormat it : ParamStandardFormat.values()) { + formats.add(it.getFormatName()); + } + return formats; + } + + /** + * Test if format is included in the list of formats. + * + * @param format format to test + * @return Returns true when the format is included in the list otherwise false. + */ + public static boolean hasFormat(final String format) { + for (ParamStandardFormat it : ParamStandardFormat.values()) { + if (it.getFormats().contains(format)) { + return true; + } + } + return false; + } + }; + + /** + * + */ + public enum ParamStandardInput { + + /** + * + */ + POS("POS", Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE), + "The position of the region of interest, expressed as the right-ascension and declination of the field center, in decimal degrees using the ICRS coordinate system. A comma should delimit the two values; embedded whitespace is not permitted.", null, DataType.DOUBLE), + + /** + * + */ + SIZE("SIZE", Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE), + "The coordinate angular size of the region given in decimal degrees. The region may be specified using either one or two values. If only one value is given it applies to both coordinate axes. If two values are given the first value is the angular width in degrees of the right-ascension axis of the region, and the second value is the angular width in degrees of the declination axis.", null, DataType.DOUBLE), + /** + * + */ + TIME("TIME",Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE),"zefzefze",null,DataType.DOUBLE), + /** + * + */ + BAND("BAND",Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE),"zefzefze",null,DataType.DOUBLE), + /** + * + */ + INTERSECT("INTERSECT", Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE), + "A parameter that indicates how matched images should intersect the region of interest", Intersect.OVERLAPS.name(), DataType.CHAR), + /** + * + */ + FORMAT("FORMAT", Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE), + "indicate the desired format or formats of the images referenced by the output table", "ALL", DataType.CHAR), + /** + * + */ + VERB("VERB", Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE), + "This parameter indicates the desired level of information to be returned in the output table, particularly the number of columns to be returned to describe each image.", null, DataType.INT); + /** + * + */ + //NAXIS("NAXIS", Arrays.asList(SpectrumService.POINTED_SPECTRAL_ARCHIVE), + //"The size of the output image in pixels. This is a vector-valued quantity, expressed as \"NAXIS=,\". If only one value is given it applies to both image axes", null, DataType.INT), + /** + * + */ + //CFRAME("CFRAME", Arrays.asList(SpectrumService.IMAGE_CUTOUT_SERVICE, SpectrumService.IMAGE_MOSAICING_SERVICE), + //"The coordinate system reference frame, selected from ICRS, FK5, FK4, ECL, GAL, and SGAL (these abbreviations follow CDS Aladin). Default: ICRS. ", "ICRS", DataType.CHAR), + /** + * + */ + //EQUINOX("EQUINOX", Arrays.asList(SpectrumService.IMAGE_CUTOUT_SERVICE, SpectrumService.IMAGE_MOSAICING_SERVICE), + //"Epoch of the mean equator and equinox for the specified coordinate system reference frame (CFRAME). Not required for ICRS. Default: B1950 for FK4, otherwise J2000.", "J2000", DataType.CHAR), + /** + * + */ + //CRPIX("CRPIX", Arrays.asList(SpectrumService.IMAGE_CUTOUT_SERVICE, SpectrumService.IMAGE_MOSAICING_SERVICE), + //"The coordinates of the reference pixel, expressed in the pixel coordinates of the output image, with [1,1] being the center of the first pixel of the first row of the image. This is a vector-valued quantity; if only one value is given it applies to both image axes. Default: the image center.", null, DataType.DOUBLE), + /** + * + */ + //CRVAL("CRVAL", Arrays.asList(SpectrumService.IMAGE_CUTOUT_SERVICE, SpectrumService.IMAGE_MOSAICING_SERVICE), + //"The world coordinates relative to CFRAME at the reference pixel. This is a vector-valued quantity; both array values are required. Default: the region center coordinates (POS) at the center of the image, transformed to the output coordinate system reference frame if other than ICRS. If CRPIX is specified to be other than the image center the corresponding CRVAL can be computed, but should be specified explicitly by the client.", null, DataType.DOUBLE), + /** + * + */ + //CDELT("CDELT", Arrays.asList(SpectrumService.IMAGE_CUTOUT_SERVICE, SpectrumService.IMAGE_MOSAICING_SERVICE), + //"The scale of the output image in decimal degrees per pixel. A negative value implies an axis flip. Since the default image orientation is N up and E to the left, the default sign of CDELT is [-1,1].", null, DataType.DOUBLE), + /** + * + */ + //ROTANG("ROTANG", Arrays.asList(SpectrumService.IMAGE_CUTOUT_SERVICE, SpectrumService.IMAGE_MOSAICING_SERVICE), + //"The rotation angle of the image in degrees relative to CFRAME (an image which is unrotated in one reference frame may be rotated in another). This is the rotation of the WCS declination or latitude axis with respect to the second axis of the image, measured in the counterclockwise direction (as for FITS WCS, which is in turn based on the old AIPS convention). Default: 0 (no rotation).", "0", DataType.DOUBLE), + + + private String inputParameterName; + private List supportedImageService; + private String description; + private String defaultValue; + private DataType dataType; + + ParamStandardInput(final String inputParameterName, final List supportedImageService, final String description, final String defaultValue, final DataType dataType) { + this.inputParameterName = inputParameterName; + this.supportedImageService = supportedImageService; + this.description = description; + this.defaultValue = defaultValue; + this.dataType = dataType; + } + + /** + * + * @return + */ + public final String getInputParameterName() { + return this.inputParameterName; + } + + /** + * + * @return + */ + public final List getSupportedImageService() { + return Collections.unmodifiableList(this.supportedImageService); + } + + /** + * + * @return + */ + public final String getDescription() { + return this.description; + } + + /** + * + * @return + */ + public final String getDefaultValue() { + return this.defaultValue; + } + + /** + * + * @return + */ + public final DataType getDataType() { + return this.dataType; + } + }; + //public enum ImageFormat{}//public enum ImageFormat{}//public enum ImageFormat{}//public enum ImageFormat{} + + /** + * Constructor. + * + * @param datasetApp Dataset Application + * @param resourceModel Data model + * @param request Request + * @param context Context + */ + public SimpleSpectralAccessProtocolLibrary(final DataSetApplication datasetApp, final ResourceModel resourceModel, final Request request, final Context context) { + this.datasetApp = datasetApp; + this.resourceModel = resourceModel; + this.request = request; + this.context = context; + } + + /** + * Fill data Model that will be used in the template. + * + * @return data model for the template + */ + private Map fillDataModel() { + // init + Map dataModel; + + // Handling input parameters + final DataModelInterface inputParameters = new SimpleSpectralAccessInputParameters(datasetApp, request, this.context, this.resourceModel); + + // data model response + if (inputParameters.getDataModel().containsKey("infos")) { + dataModel = inputParameters.getDataModel(); + } else { + final SimpleSpectralAccessDataModelInterface response = new SimpleSpectralAccessResponse((SimpleSpectralAccessInputParameters) inputParameters, resourceModel); + dataModel = response.getDataModel(); + } + return dataModel; + } + + /** + * VOTable response. + * + * @return VOTable response + */ + public final VOTableRepresentation getResponse() { + final Map dataModel = fillDataModel(); + return new VOTableRepresentation(dataModel); + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessResponse.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessResponse.java new file mode 100644 index 0000000..13db01d --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SimpleSpectralAccessResponse.java @@ -0,0 +1,600 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +import fr.cnes.sitools.astro.representation.DatabaseRequestModel; +import fr.cnes.sitools.common.SitoolsSettings; +import fr.cnes.sitools.common.application.ContextAttributes; +import fr.cnes.sitools.common.exception.SitoolsException; +import fr.cnes.sitools.dataset.DataSetApplication; +import fr.cnes.sitools.dataset.converter.business.ConverterChained; +import fr.cnes.sitools.dataset.database.DatabaseRequest; +import fr.cnes.sitools.dataset.database.DatabaseRequestFactory; +import fr.cnes.sitools.dataset.database.DatabaseRequestParameters; +import fr.cnes.sitools.dataset.database.common.DataSetExplorerUtil; +import fr.cnes.sitools.dataset.dto.ColumnConceptMappingDTO; +import fr.cnes.sitools.dataset.dto.DictionaryMappingDTO; +import fr.cnes.sitools.dataset.model.Predicat; +import fr.cnes.sitools.dictionary.model.Concept; +import fr.cnes.sitools.plugins.resources.model.ResourceModel; +import fr.cnes.sitools.util.Util; +import freemarker.template.TemplateSequenceModel; +import java.math.BigInteger; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collections; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.logging.Level; +import java.util.logging.Logger; +import net.ivoa.xml.votable.v1.AnyTEXT; +import net.ivoa.xml.votable.v1.DataType; +import net.ivoa.xml.votable.v1.Field; +import net.ivoa.xml.votable.v1.Info; +import net.ivoa.xml.votable.v1.Param; + + + +/** + * Votable response for cone search. + * + * @author Jean-Christophe Malapert + */ +public class SimpleSpectralAccessResponse implements SimpleSpectralAccessDataModelInterface { + + /** + * Logger. + */ + private static final Logger LOG = Logger.getLogger(SimpleSpectralAccessResponse.class.getName()); + + /** + * Data model. + */ + private final transient Map dataModel = new HashMap(); + + /** + * Sitools Settings + */ + private SitoolsSettings sitoolsSettings = null; + /** + * Right Ascenscion. + */ + private final double ra; + /** + * Declination. + */ + private final double dec; + + /** + * Time + */ + private final String[] time; + /** + * Band + */ + private final double[] band; + + /** + * Constructor. + * + * @param inputParameters input parameters + * @param model data model + */ + public SimpleSpectralAccessResponse(final SimpleSpectralAccessInputParameters inputParameters, final ResourceModel model) { + this.sitoolsSettings = (SitoolsSettings) inputParameters.getContext().getAttributes().get(ContextAttributes.SETTINGS); + this.ra = inputParameters.getRa(); + this.dec = inputParameters.getDec(); + this.time= inputParameters.getTime(); + this.band = inputParameters.getBand(); + createResponse(inputParameters, model); + } + + /** + * Creates VOTable response. + * + * @param inputParameters Input parameters + * @param model data model + */ + private void createResponse(final SimpleSpectralAccessInputParameters inputParameters, final ResourceModel model) { + // createResponse + final String dictionaryName = model.getParameterByName(SimpleSpectralAccessProtocolLibrary.DICTIONARY).getValue(); + + // Set Votable parameters + setVotableParametersFromConfiguration(dataModel, model); + + // Set Votable resources + setVotableResource(inputParameters.getDatasetApplication(), inputParameters, model, dictionaryName); + + } + + /** + * Sets VOTable parameters coming from administration configuration. + * + * @param dataModel data model to set + * @param model parameters from administration + */ + private void setVotableParametersFromConfiguration(final Map dataModel, final ResourceModel model) { + final List params = new ArrayList(); + //setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.COVERAGE, DataType.CHAR); + //setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.TEMPORAL, DataType.CHAR); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.INSTRUMENT, DataType.CHAR); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.MAX_FILE_SIZE, DataType.LONG); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.RESPONSIBLE_PARTY, DataType.CHAR); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.SERVICE_NAME, DataType.CHAR); + //setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.WAVEBAND, DataType.CHAR); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.MAX_RECORDS, DataType.INT); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.MAX_QUERY_SIZE, DataType.CHAR); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.MAX_IMAGE_SIZE, DataType.CHAR); + setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.VERB, DataType.INT); +/* POURQUOI BOOLEAN ?? Alors qu'il peut prendre 0,1,2 ou 3 comme valeurs setVotableParam(params, model, SimpleSpectralAccessProtocolLibrary.VERB, DataType.BOOLEAN);*/ + if (Util.isSet(params)) { + dataModel.put("params", params); + } + } + + /** + * Sets Votable Param. + * + * @param params List of params + * @param model data model + * @param parameterName parameter name + * @param datatype datatype + */ + private void setVotableParam(final List params, final ResourceModel model, final String parameterName, + final DataType datatype) { + final String parameterValue = model.getParameterByName(parameterName).getValue(); + if (Util.isNotEmpty(parameterValue)) { + final Param param = new Param(); + param.setName(parameterName); + param.setValue(parameterValue); + param.setDatatype(datatype); + params.add(param); + } + } + + /** + * Creates the response based on Table. + * + * @param datasetApp Dataset application + * @param inputParameters Input Parameters + * @param model data model + * @param dictionaryName Cone search dictionary + */ + private void setVotableResource(final DataSetApplication datasetApp, final SimpleSpectralAccessInputParameters inputParameters, + final ResourceModel model, final String dictionaryName) { + + final List fieldList = new ArrayList(); + final List columnList = new ArrayList(); + DatabaseRequest databaseRequest = null; + + try { + // Get the concepts from the dictionary + List mappingList = getDicoFromConfiguration(datasetApp, dictionaryName); + + mappingList = checkRequiredMapping(mappingList, inputParameters.getVerb()); + + // Get query parameters + final DatabaseRequestParameters dbParams = setQueryParameters(datasetApp, model, inputParameters, mappingList); + databaseRequest = DatabaseRequestFactory.getDatabaseRequest(dbParams); + // Execute query + databaseRequest.createRequest(); + + LOG.log(Level.FINEST, "DB request: {0}", databaseRequest.getRequestAsString()); + + //Fill the template with query status and param + fillInfosParamAboutQuery(model); + + // complete data model with fields + setFields(fieldList, columnList, mappingList); + dataModel.put("fields", fieldList); + dataModel.put("sqlColAlias", columnList); + Map conceptColAlias = new HashMap(); + for (ColumnConceptMappingDTO map:mappingList) { + conceptColAlias.put(map.getColumnAlias(), map.getConcept().getPropertyFromName("ucd").getValue()); + } + dataModel.put("mappingColAliasConceptSql", conceptColAlias); + + // Complete data model with data + final int count = (databaseRequest.getCount() > dbParams.getPaginationExtend()) ? dbParams.getPaginationExtend() : databaseRequest.getCount(); + dataModel.put("nrows", count); + final ConverterChained converterChained = datasetApp.getConverterChained(); + + final TemplateSequenceModel rows = new DatabaseRequestModel(databaseRequest, converterChained); + ((DatabaseRequestModel) rows).setSize(count); + dataModel.put("rows", rows); + + } catch (SitoolsException ex) { + try { + if (Util.isSet(databaseRequest)) { + databaseRequest.close(); + } + } catch (SitoolsException ex1) { + LOG.log(Level.FINER, null, ex1); + } finally { + final List infos = new ArrayList(); + LOG.log(Level.FINEST, "ERROR: {0}", ex.getMessage()); + setVotableError(infos, "Query", "Error in query", "Error in input query: " + ex.getMessage()); + if (!infos.isEmpty()) { + this.dataModel.put("infos", infos); + } + } + } + } + + /** + * Set Query parameters to the database. + * + * @param datasetApp Dataset Application + * @param model Data model + * @param inputParameters Input Parameters + * @return DatabaseRequestParamerters object + */ + @SuppressWarnings("empty-statement") + private DatabaseRequestParameters setQueryParameters(final DataSetApplication datasetApp, final ResourceModel model, + final SimpleSpectralAccessInputParameters inputParameters, List mappingList) { + + // Get the dataset + final DataSetExplorerUtil dsExplorerUtil = new DataSetExplorerUtil(datasetApp, inputParameters.getRequest(), + inputParameters.getContext()); + + // Get query parameters + final DatabaseRequestParameters dbParams = dsExplorerUtil.getDatabaseParams(); + + // Get dataset records + final int nbRecordsInDataSet = datasetApp.getDataSet().getNbRecords(); + + // Get max records that is defined by admin + int nbMaxRecords = Integer.valueOf(model.getParameterByName(SimpleSpectralAccessProtocolLibrary.MAX_RECORDS).getValue()); + nbMaxRecords = (nbMaxRecords > nbRecordsInDataSet || nbMaxRecords == -1) ? nbRecordsInDataSet : nbMaxRecords; + + // Set max records + dbParams.setPaginationExtend(nbMaxRecords); + + // Create predicat definition + String raColTarget = null; + String decColTarget = null; + String timeColTarget = null; + String bandColTarget = null; + for (ColumnConceptMappingDTO mapIter : mappingList) { + final String ucd = mapIter.getConcept().getPropertyFromName("ucd").getValue(); + if (ucd.equals(SimpleSpectralAccessProtocolLibrary.REQUIRED_UCD_CONCEPTS.get(1))) { + raColTarget = mapIter.getColumnAlias(); + } + if (ucd.equals(SimpleSpectralAccessProtocolLibrary.REQUIRED_UCD_CONCEPTS.get(2))) { + decColTarget = mapIter.getColumnAlias(); + } + if (ucd.equals(SimpleSpectralAccessProtocolLibrary.REQUIRED_UCD_CONCEPTS.get(4))) { + timeColTarget = mapIter.getColumnAlias(); + } + if (ucd.equals(SimpleSpectralAccessProtocolLibrary.REQUIRED_UCD_CONCEPTS.get(5))) { + bandColTarget = mapIter.getColumnAlias(); + } + } + final AbstractSqlGeometryConstraint sql = SqlGeometryFactory.create(String.valueOf(model.getParameterByName(SimpleSpectralAccessProtocolLibrary.INTERSECT).getValue())); + sql.setInputParameters(inputParameters); + String[] geo = null; + if(!Util.isNotEmpty(model.getParameterByName(SimpleSpectralAccessProtocolLibrary.GEO_ATTRIBUT).getValue())){ + geo = new String[]{raColTarget, decColTarget,timeColTarget,bandColTarget}; + } + + final Object geometry = (Util.isNotEmpty(model.getParameterByName(SimpleSpectralAccessProtocolLibrary.GEO_ATTRIBUT).getValue())) + ? model.getParameterByName(SimpleSpectralAccessProtocolLibrary.GEO_ATTRIBUT).getValue() + : geo;//Arrays.asList(raColTarget, decColTarget,timeColTarget,bandColTarget); + //final Object geometry = + sql.setGeometry(geometry); + if (sql.getSqlPredicat() != null) { + final Predicat predicat = new Predicat(); + predicat.setStringDefinition(sql.getSqlPredicat()); + final List predicatList = dbParams.getPredicats(); + predicatList.add(predicat); + dbParams.setPredicats(predicatList); + } + return dbParams; + } + + /** + * Set the votable error. + * + * @param infos infos + * @param id id + * @param name name + * @param value value + */ + private void setVotableError(final List infos, final String id, final String name, final String value) { + if (Util.isNotEmpty(name)) { + final Info info = new Info(); + info.setID(id); + info.setName(name); + info.setValueAttribute(value); + infos.add(info); + } + } + + /** + * Returns the data model. + * @return the data model + */ + @Override + public final Map getDataModel() { + return Collections.unmodifiableMap(this.dataModel); + } + + /** + * Provide the mapping between SQL column/concept for a given dictionary. + * + * @param datasetApp Application where this service is attached + * @param dicoToFind Dictionary name to find + * @return Returns a mapping SQL column/Concept + * @throws SitoolsException No mapping has been done or cannot find the dico + */ + private List getDicoFromConfiguration(final DataSetApplication datasetApp, + final String dicoToFind) throws SitoolsException { + List colConceptMappingDTOList = null; + + // Get the list of dictionnaries related to the datasetApplication + final List dicoMappingList = datasetApp.getDictionaryMappings(); + if (!Util.isSet(dicoMappingList) || dicoMappingList.isEmpty()) { + throw new SitoolsException("No mapping with VO concepts has been done. please contact the administrator"); + } + + // For each dictionary, find the interesting one and return the mapping SQLcolumn/concept + for (DictionaryMappingDTO dicoMappingIter : dicoMappingList) { + final String dicoName = dicoMappingIter.getDictionaryName(); + if (dicoToFind.equals(dicoName)) { + colConceptMappingDTOList = dicoMappingIter.getMapping(); + break; + } + } + return colConceptMappingDTOList; + } + + /** + * Set Fields and columnSqlAliasList. + * + * @param fieldList List of fields to display on the VOTable + * @param columnList List of SQL column + * @param mappingList List of SQL column/concept + */ + private void setFields(final List fieldList, final List columnList, final List mappingList) { + + for (ColumnConceptMappingDTO mappingIter : mappingList) { + + String id = null; + String name = null; + String ucd = null; + String utype = null; + String ref = null; + String datatype = null; + String width = null; + String precision = null; + String unit = null; + String type = null; + String xtype = null; + String arraysize = null; + String descriptionValue = null; + columnList.add(mappingIter.getColumnAlias()); + final Concept concept = mappingIter.getConcept(); + if (concept.getName() != null) { + name = concept.getName(); + } + if (concept.getPropertyFromName("ID").getValue() != null) { + id = concept.getPropertyFromName("ID").getValue(); + } + if (concept.getPropertyFromName("ucd").getValue() != null) { + ucd = concept.getPropertyFromName("ucd").getValue(); + } + if (concept.getPropertyFromName("utype").getValue() != null) { + utype = concept.getPropertyFromName("utype").getValue(); + } + if (concept.getPropertyFromName("ref").getValue() != null) { + ref = concept.getPropertyFromName("ref").getValue(); + } + if (concept.getPropertyFromName("datatype").getValue() != null) { + datatype = concept.getPropertyFromName("datatype").getValue(); + } + if (concept.getPropertyFromName("width").getValue() != null) { + width = concept.getPropertyFromName("width").getValue(); + } + if (concept.getPropertyFromName("precision").getValue() != null) { + precision = concept.getPropertyFromName("precision").getValue(); + } + if (concept.getPropertyFromName("unit").getValue() != null) { + unit = concept.getPropertyFromName("unit").getValue(); + } + if (concept.getPropertyFromName("type").getValue() != null) { + type = concept.getPropertyFromName("type").getValue(); + } + if (concept.getPropertyFromName("xtype").getValue() != null) { + xtype = concept.getPropertyFromName("xtype").getValue(); + } + if (concept.getPropertyFromName("arraysize").getValue() != null) { + arraysize = concept.getPropertyFromName("arraysize").getValue(); + } + if (concept.getDescription() != null) { + descriptionValue = concept.getDescription(); + } + final Field field = new Field(); + field.setID(id); + field.setName(name); + field.setUcd(ucd); + field.setUtype(utype); + field.setRef(ref); + field.setDatatype(DataType.fromValue(datatype)); + if (width != null) { + field.setWidth(BigInteger.valueOf(Long.valueOf(width))); + } + field.setPrecision(precision); + field.setUnit(unit); + field.setType(type); + field.setXtype(xtype); + field.setArraysize(arraysize); + final AnyTEXT anyText = new AnyTEXT(); + anyText.getContent().add(descriptionValue); + field.setDESCRIPTION(anyText); + fieldList.add(field); + } + } + + /** + * Checks required mapping and filter columns to map according to VERB. + * + * @param mappingList list of mapping defined by the administrator + * @param verb VERB of Cone search protocol + * @return Returns the new mapping according to VERB + * @throws SitoolsException columns with UCD ID_MAIN, POS_EQ_RA_MAIN, POS_EQ_DEC_MAIN must be mapped + */ + private List checkRequiredMapping(final List mappingList, final int verb) + throws SitoolsException { + + final int nbConceptToMap = SimpleSpectralAccessProtocolLibrary.REQUIRED_UCD_CONCEPTS.size(); + int nbConcept = 0; + final List conceptToMap = new ArrayList(mappingList); + for (ColumnConceptMappingDTO mappingIter : mappingList) { + final Concept concept = mappingIter.getConcept(); + final String ucdValue = concept.getPropertyFromName("ucd").getValue(); + if (Util.isNotEmpty(ucdValue) && SimpleSpectralAccessProtocolLibrary.REQUIRED_UCD_CONCEPTS.contains(ucdValue)) { + nbConcept++; + } else if (verb == 1) { + conceptToMap.remove(mappingIter); + } + } + if (nbConceptToMap != nbConcept) { + + final StringBuilder buffer = new StringBuilder("columns with "); + for (ColumnConceptMappingDTO mappingIter : mappingList) { + buffer.append(mappingIter.getConcept().getName()).append(" "); + } + buffer.append("must be mapped"); + throw new SitoolsException(buffer.toString()); + } + + return conceptToMap; + + } + + private void fillInfosParamAboutQuery(final ResourceModel model){ + final List listQueryInfos = new ArrayList(); + + final Info info = new Info(); + info.setName("QUERY_STATUS"); + info.setValueAttribute("OK"); + listQueryInfos.add(info); + this.dataModel.put("queryInfos", listQueryInfos); + + final List listQueryParam = new ArrayList(); + Param param = new Param(); + param.setName("POS"); + param.setValue(this.ra+","+this.dec); + param.setUnit("deg"); + param.setDatatype(DataType.DOUBLE); + listQueryParam.add(param); + +//-------------------------- AJOUT POUR LE PROTOCOLE SSA -------------------------------------------- + /* + param = new Param(); + param.setName("TIME"); + param.setValue(this.time.toString()); + //param.setUnit(""); + param.setDatatype(DataType.CHAR); + listQueryParam.add(param); + + param = new Param(); + param.setName("BAND"); + param.setValue(this.band.toString()); + param.setUnit("m"); + param.setDatatype(DataType.DOUBLE); + listQueryParam.add(param); + */ + addTimeBandAndSize(listQueryParam); +//**************************** FIN DU RAJOUT ********************************* + param = new Param(); + param.setName("FORMAT"); + param.setValue(SimpleSpectralAccessProtocolLibrary.ParamStandardFormat.ALL.name().toLowerCase()); + param.setDatatype(DataType.CHAR); + param.setArraysize("*"); + listQueryParam.add(param); + + param = new Param(); + param.setName("INTERSECT"); + param.setValue(model.getParameterByName(SimpleSpectralAccessProtocolLibrary.INTERSECT).getValue()); + param.setDatatype(DataType.CHAR); + listQueryParam.add(param); + + param = new Param(); + param.setName("VERB"); + param.setValue(model.getParameterByName(SimpleSpectralAccessProtocolLibrary.VERB).getValue()); + param.setDatatype(DataType.INT); + listQueryParam.add(param); + + dataModel.put("queryParams", listQueryParam); + } + + private List addTimeBandAndSize(List listOfParams){ + // ADD TIME + if(this.time.length == 2){ + Param param = new Param(); + param.setName("TIME"); + param.setValue("From : "+this.time[0]+" to "+this.time[1]); + param.setDatatype(DataType.CHAR); + listOfParams.add(param); + }else{ + Param param = new Param(); + param.setName("TIME"); + param.setValue(this.time[0]); + param.setDatatype(DataType.CHAR); + listOfParams.add(param); + } + // ADD BAND + if(this.band.length == 2){ + Double bandMin = this.band[0]; + Double bandMax = this.band[1]; + Param param = new Param(); + param.setName("BAND"); + param.setValue(bandMin.toString()+" , "+bandMax); + param.setUnit("m"); + param.setDatatype(DataType.DOUBLE); + listOfParams.add(param); + }else{ + Double bandValue = this.band[0]; + Param param = new Param(); + param.setName("BAND"); + param.setValue(bandValue.toString()); + param.setUnit("m"); + param.setDatatype(DataType.DOUBLE); + listOfParams.add(param); + } + // ADD SIZE + /* + if(this.time.length == 2){ + Param param = new Param(); + param.setName("TIME"); + param.setValue("From : "+this.time[0]+" to "+this.time[1]); + param.setDatatype(DataType.CHAR); + listOfParams.add(param); + }else{ + Param param = new Param(); + param.setName("TIME"); + param.setValue(this.time[0]); + param.setDatatype(DataType.CHAR); + listOfParams.add(param); + }*/ + return listOfParams; + } +} diff --git a/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SqlGeometryFactory.java b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SqlGeometryFactory.java new file mode 100644 index 0000000..caa00ce --- /dev/null +++ b/hesiod/javaExt/src/fr/ias/sitools/vo/ssa/SqlGeometryFactory.java @@ -0,0 +1,53 @@ + /******************************************************************************* + * Copyright 2010-2013 CNES - CENTRE NATIONAL d'ETUDES SPATIALES + * + * This file is part of SITools2. + * + * SITools2 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 3 of the License, or + * (at your option) any later version. + * + * SITools2 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 SITools2. If not, see . + ******************************************************************************/ +package fr.ias.sitools.vo.ssa; + +/** + * Chooses the implementation of the SQL request + * based on the geometry intersection algorithm. + * @author Jean-Christophe Malapert + */ +public final class SqlGeometryFactory { + /** + * Empty constructor. + */ + private SqlGeometryFactory() { + } + /** + * Returns the Object responsible of creating the SQL request to send to the server. + * + *

+ * The supported geometryIntersection is either CENTER or OVERLAPS otherwise + * an IllegalArgumentException is raised. + *

+ * @param geometryIntersection Geometry Intersection algorithm + * @return the Object responsible of creating the SQL request to send to the server + */ + public static AbstractSqlGeometryConstraint create(final String geometryIntersection) { + AbstractSqlGeometryConstraint result; + if ("OVERLAPS".equals(geometryIntersection)) { + result = new OverlapsModeIntersection(); + } else if ("CENTER".equals(geometryIntersection)) { + result = new CenterModeIntersection(); + } else { + throw new IllegalArgumentException("geometryMode " + geometryIntersection + " is unknown or not supported"); + } + return result; + } +}