Loading src/main/java/es/redmic/es/geodata/geofixedstation/repository/GeoFixedBaseESRepository.java +3 −3 Original line number Diff line number Diff line Loading @@ -48,8 +48,8 @@ public abstract class GeoFixedBaseESRepository<TModel extends Feature<GeoDataPro /* * Función que sobrescribe a getTermQuery de RElasticSearchRepository para * añadir implementación específica para crear una query a apartir de una * serie de términos obtenidos por el controlador. * añadir implementación específica para crear una query a apartir de una serie * de términos obtenidos por el controlador. */ @SuppressWarnings("unchecked") @Override Loading @@ -60,7 +60,7 @@ public abstract class GeoFixedBaseESRepository<TModel extends Feature<GeoDataPro query.must(QueryBuilders.nestedQuery("properties.measurements", QueryBuilders.termsQuery("properties.measurements.parameter.path.hierarchy", ids), ScoreMode.Avg)); } return query; return super.getTermQuery(terms, query); } @Override Loading src/main/java/es/redmic/es/geodata/geofixedstation/repository/GeoFixedTimeSeriesESRepository.java +17 −1 Original line number Diff line number Diff line package es.redmic.es.geodata.geofixedstation.repository; import java.util.Map; import org.elasticsearch.index.query.BoolQueryBuilder; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.springframework.stereotype.Repository; import es.redmic.es.common.queryFactory.geodata.GeoFixedTimeSeriesQueryUtils; Loading @@ -12,4 +17,15 @@ public class GeoFixedTimeSeriesESRepository extends GeoFixedBaseESRepository<Geo super(); setInternalQuery(GeoFixedTimeSeriesQueryUtils.INTERNAL_QUERY); } @Override public QueryBuilder getTermQuery(Map<String, Object> terms, BoolQueryBuilder query) { String dashboardProperty = "properties.site.dashboard"; if (terms.containsKey(dashboardProperty) && ((Boolean) terms.get(dashboardProperty)).equals(true)) { query.must(QueryBuilders.existsQuery(dashboardProperty)); } return super.getTermQuery(terms, query); } } No newline at end of file Loading
src/main/java/es/redmic/es/geodata/geofixedstation/repository/GeoFixedBaseESRepository.java +3 −3 Original line number Diff line number Diff line Loading @@ -48,8 +48,8 @@ public abstract class GeoFixedBaseESRepository<TModel extends Feature<GeoDataPro /* * Función que sobrescribe a getTermQuery de RElasticSearchRepository para * añadir implementación específica para crear una query a apartir de una * serie de términos obtenidos por el controlador. * añadir implementación específica para crear una query a apartir de una serie * de términos obtenidos por el controlador. */ @SuppressWarnings("unchecked") @Override Loading @@ -60,7 +60,7 @@ public abstract class GeoFixedBaseESRepository<TModel extends Feature<GeoDataPro query.must(QueryBuilders.nestedQuery("properties.measurements", QueryBuilders.termsQuery("properties.measurements.parameter.path.hierarchy", ids), ScoreMode.Avg)); } return query; return super.getTermQuery(terms, query); } @Override Loading
src/main/java/es/redmic/es/geodata/geofixedstation/repository/GeoFixedTimeSeriesESRepository.java +17 −1 Original line number Diff line number Diff line package es.redmic.es.geodata.geofixedstation.repository; import java.util.Map; import org.elasticsearch.index.query.BoolQueryBuilder; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.springframework.stereotype.Repository; import es.redmic.es.common.queryFactory.geodata.GeoFixedTimeSeriesQueryUtils; Loading @@ -12,4 +17,15 @@ public class GeoFixedTimeSeriesESRepository extends GeoFixedBaseESRepository<Geo super(); setInternalQuery(GeoFixedTimeSeriesQueryUtils.INTERNAL_QUERY); } @Override public QueryBuilder getTermQuery(Map<String, Object> terms, BoolQueryBuilder query) { String dashboardProperty = "properties.site.dashboard"; if (terms.containsKey(dashboardProperty) && ((Boolean) terms.get(dashboardProperty)).equals(true)) { query.must(QueryBuilders.existsQuery(dashboardProperty)); } return super.getTermQuery(terms, query); } } No newline at end of file