Mercurial > dive4elements > river
view artifacts/src/main/java/org/dive4elements/river/artifacts/GaugeDischargeArtifact.java @ 6693:88bb0c794833
issue1391: Enable GaugeDischarge artifact to directly load a table by its ID
This allows us to use the GaugeDischargeArtifact for any discharge
tables that we have in our database. The name of the created facet
is taken from the ids string as is also usual in the WMS artifacts.
author | Andre Heinecke <aheinecke@intevation.de> |
---|---|
date | Mon, 29 Jul 2013 12:19:57 +0200 |
parents | 20a32dbdbb59 |
children | 8d5ca5175038 |
line wrap: on
line source
/* Copyright (C) 2011, 2012, 2013 by Bundesanstalt für Gewässerkunde * Software engineering by Intevation GmbH * * This file is Free Software under the GNU AGPL (>=v3) * and comes with ABSOLUTELY NO WARRANTY! Check out the * documentation coming with Dive4Elements River for details. */ package org.dive4elements.river.artifacts; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Map; import java.util.HashMap; import org.apache.log4j.Logger; import org.w3c.dom.Document; import org.dive4elements.artifactdatabase.state.Facet; import org.dive4elements.artifacts.Artifact; import org.dive4elements.artifacts.ArtifactFactory; import org.dive4elements.artifacts.CallMeta; import org.dive4elements.river.artifacts.model.FacetTypes; import org.dive4elements.river.artifacts.model.WQKms; import org.dive4elements.river.artifacts.states.DefaultState; import org.dive4elements.river.artifacts.model.Calculation; import org.dive4elements.river.artifacts.model.CalculationResult; import org.dive4elements.river.artifacts.model.DischargeTables; import org.dive4elements.river.model.Gauge; import org.dive4elements.river.model.River; import org.dive4elements.river.model.DischargeTable; import org.dive4elements.river.utils.RiverUtils; /** * Artifact to get discharge curves at gauges. */ public class GaugeDischargeArtifact extends WINFOArtifact implements FacetTypes { /** The logger for this class. */ private static Logger logger = Logger.getLogger(GaugeDischargeArtifact.class); /** The name of the artifact. */ public static final String ARTIFACT_NAME = "gaugedischarge"; /** The name a facet should have */ protected String facetWishName; /** * Trivial Constructor. */ public GaugeDischargeArtifact() { logger.debug("GaugeDischargeArtifact.GaugeDischargeArtifact()"); } /** * Gets called from factory, to set things up. * Especially, when loaded via datacage mechanisms, provide the * data document. * @param data filled with stuff from dc, if any. */ @Override public void setup( String identifier, ArtifactFactory factory, Object context, CallMeta callMeta, Document data) { logger.debug("GaugeDischargeArtifact.setup"); String ids = StaticD4EArtifact.getDatacageIDValue(data); addStringData("ids", ids); logger.debug("id for gaugedischarge: " + ids); String[] splitIds = ids.split(";"); /* We assume that if an id's string with a ; is given that the * format is <gauge_name>;<discharge_table_id>;<facet_desc> * so that a specific discharge table can be selected */ if (splitIds.length > 2) { facetWishName = splitIds[2]; } super.setup(identifier, factory, context, callMeta, data); } /** Return the name of this artifact. */ public String getName() { return ARTIFACT_NAME; } /** * Setup state and facet, copy from master artifact. */ @Override protected void initialize(Artifact art, Object context, CallMeta meta) { logger.debug("GaugeDischargeArtifact.initialize"); List<Facet> fs = new ArrayList<Facet>(); D4EArtifact artifact = (D4EArtifact) art; importData(artifact, "river"); // Get the location(s) //importData(artifact, "ld_mode", ld_from, ld_to, ld_locations addStringData("ld_from", "0"); addStringData("ld_to", "1000"); addStringData("ld_mode", "distance"); DefaultState state = (DefaultState) getCurrentState(context); state.computeInit(this, hash(), context, meta, fs); if (!fs.isEmpty()) { logger.debug("Facets to add in GaugeDischargeArtifact.initialize. (" + state.getID() + "/ " + getCurrentStateId() + ")."); addFacets(getCurrentStateId(), fs); } else { logger.debug("No facets to add in GaugeDischargeArtifact.initialize (" + state.getID() + "/ "+getCurrentStateId()+")."); } } /** Get the Gauges name which came with datacage data-document. */ public String getGaugeName() { if (getDataAsString("ids") == null) { return null; } return getDataAsString("ids").split(";")[0]; } /** Get the Gauges which came with datacage data-document. */ public Gauge getGauge() { River river = RiverUtils.getRiver(this); return river.determineGaugeByName(getGaugeName()); } /** * Returns the data that is used to create discharge curves. * @return CalculationResult with WQKms. */ public CalculationResult getDischargeCurveData() { River river = RiverUtils.getRiver(this); if (river == null) { return error(new WQKms[0], "no.river.selected"); } /* // This one would allow to automatically pick the right Gauge. double [] distance = RiverUtils.getKmRange(this); logger.debug("getDischargeCurveData: get range"); if (distance == null) { return error(new WQKms[0], "no.range.found"); } List<Gauge> gauges = river.determineGauges(distance[0], distance[1]); logger.debug("getDischargeCurveData: got " + gauges.size() + " gauges"); if (gauges.isEmpty()) { return error(new WQKms[0], "no.gauge.selected"); } String [] names = new String[gauges.size()]; for (int i = 0; i < names.length; ++i) { names[i] = gauges.get(i).getName(); logger.debug("getDischargeCurveData: name " + names[i]); } */ Map<String, double [][]> map; String[] ids = getDataAsString("ids").split(";"); if (ids.length > 1) { /* We assume that if an id's string with a ; is given that the * format is <gauge_name>;<discharge_table_id>;<facet_desc> * so that a specific discharge table can be selected */ int tableId = 0; try { tableId = Integer.parseInt(ids[1]); } catch (NumberFormatException e) { logger.error("Discharge tables ids string is wrong." + " Fromat is <gauge_name>;<discharge_table_id>;<facet_desc>" + " Fix your Datacage!"); // Let's rather break down completly then show the wrong data. return null; } DischargeTable table = DischargeTable.getDischargeTableById(tableId); map = new HashMap<String, double [][]>(); map.put(getGaugeName(), DischargeTables.loadDischargeTableValues(table)); } else { DischargeTables dt = new DischargeTables(river.getName(), getGaugeName()); map = dt.getValues(); } ArrayList<WQKms> res = new ArrayList<WQKms>(); Gauge gauge = river.determineGaugeByName(getGaugeName()); String name = getGaugeName(); double [][] values = map.get(name); if (values == null) { logger.error("No values for this gauge / discharge found."); return error(new WQKms[0], "no.gauge.found"); } for (int i = 0 ; i < values[0].length; i++) { values[0][i] += gauge.getDatum().doubleValue(); } double [] kms = new double[values[0].length]; Arrays.fill(kms, gauge.getStation().doubleValue()); res.add(new WQKms(kms, values[0], values[1], name, WQKms.CENTIMETER_AT_GAUGE)); return new CalculationResult( res.toArray(new WQKms[res.size()]), new Calculation()); } /** Gets the facet wish name. * * This is a hack to enable setting the name of the facet / theme in the * UI from the datacage setting. */ public String getFacetWishName() { return facetWishName; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :