Mercurial > dive4elements > river
view flys-artifacts/src/main/java/de/intevation/flys/artifacts/states/GaugeTimerangeState.java @ 5827:e308d4ecd35a
Fixed pom for etl process.
author | Sascha L. Teichmann <teichmann@intevation.de> |
---|---|
date | Thu, 25 Apr 2013 11:48:36 +0200 |
parents | 12766ab27a36 |
children |
line wrap: on
line source
package de.intevation.flys.artifacts.states; import java.util.Calendar; import java.util.List; import org.apache.log4j.Logger; import org.hibernate.SQLQuery; import org.hibernate.Session; import org.hibernate.type.StandardBasicTypes; import de.intevation.flys.artifacts.FLYSArtifact; import de.intevation.flys.backend.SessionHolder; import de.intevation.flys.model.Gauge; import de.intevation.flys.utils.FLYSUtils; /** * @author <a href="mailto:ingo.weinzierl@intevation.de">Ingo Weinzierl</a> */ public class GaugeTimerangeState extends IntRangeState { /** Private logger. */ private static final Logger logger = Logger.getLogger(GaugeTimerangeState.class); /** Get 'min' and 'max'times of gauge time intervals. */ protected long[] getLowerUpper(FLYSArtifact flys) { Gauge gauge = FLYSUtils.getReferenceGauge(flys); if (gauge == null) { logger.warn("No reference gauge specified!"); return new long[] { 0, 0 }; } Session session = SessionHolder.HOLDER.get(); SQLQuery query = session.createSQLQuery( "SELECT min(start_time) as min, max(stop_time) as max " + "FROM time_intervals WHERE id in " + "(SELECT time_interval_id FROM discharge_tables " + "WHERE gauge_id =:gid)"); query.addScalar("min", StandardBasicTypes.CALENDAR); query.addScalar("max", StandardBasicTypes.CALENDAR); query.setInteger("gid", gauge.getId()); List<?> results = query.list(); if (results != null) { Object[] res = (Object[]) results.get(0); Calendar lo = (Calendar) res[0]; Calendar up = (Calendar) res[1]; if (lo != null && up != null) { return new long[] { lo.getTimeInMillis(), up.getTimeInMillis() }; } } logger.warn("Could not determine time range for gauge: " + gauge); return null; } @Override protected Object getLower(FLYSArtifact flys) { long[] lowerUpper = getLowerUpper(flys); return lowerUpper != null ? lowerUpper[0] : 0; } @Override protected Object getUpper(FLYSArtifact flys) { long[] lowerUpper = getLowerUpper(flys); return lowerUpper != null ? lowerUpper[1] : 0; } @Override protected String getUIProvider() { return "gaugetimerange"; } @Override protected String getType() { return "longrange"; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf-8 :