Mercurial > dive4elements > river
changeset 2725:8dbc86a0948d
Fixing analysis: Access to state data.
flys-artifacts/trunk@4456 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
---|---|
date | Tue, 22 May 2012 12:55:52 +0000 |
parents | 43474b346272 |
children | f53173a8736b |
files | flys-artifacts/ChangeLog flys-artifacts/src/main/java/de/intevation/flys/artifacts/FixationArtifactAccess.java |
diffstat | 2 files changed, 386 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- a/flys-artifacts/ChangeLog Tue May 22 10:05:01 2012 +0000 +++ b/flys-artifacts/ChangeLog Tue May 22 12:55:52 2012 +0000 @@ -1,3 +1,8 @@ +2012-05-22 Sascha L. Teichmann <sascha.teichmann@intevation.de> + + * src/main/java/de/intevation/flys/artifacts/FixationArtifactAccess.java: + New. Access the state data of fixings artifacts. + 2012-05-22 Sascha L. Teichmann <sascha.teichmann@intevation.de> * doc/conf/artifacts/fixanalysis.xml: Make "start" and "end" parameters
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/flys-artifacts/src/main/java/de/intevation/flys/artifacts/FixationArtifactAccess.java Tue May 22 12:55:52 2012 +0000 @@ -0,0 +1,381 @@ +package de.intevation.flys.artifacts; + +import java.util.Arrays; + +import de.intevation.artifactdatabase.data.StateData; + +import gnu.trove.TDoubleArrayList; + +import de.intevation.flys.utils.FLYSUtils; + +import org.apache.log4j.Logger; + +public class FixationArtifactAccess +{ + private static Logger log = Logger.getLogger(FixationArtifactAccess.class); + + protected FLYSArtifact artifact; + + protected String river; + + protected String calculationMode; + + protected Double from; + protected Double to; + protected Double step; + + protected Long start; + protected Long end; + + protected Integer qSectorStart; + protected Integer qSectorEnd; + + protected Long referenceStart; + protected Long referenceEnd; + + protected long [][] analysisPeriods; + + protected int [] events; + + protected Boolean preprocessing; + + protected String function; + + protected double [] qs; + + public FixationArtifactAccess() { + } + + public FixationArtifactAccess(FLYSArtifact artifact) { + this.artifact = artifact; + } + + public FLYSArtifact getArtifact() { + return artifact; + } + + public String getRiver() { + if (river == null) { + StateData sd = artifact.getData("river"); + if (sd == null) { + log.warn("missing 'river' value"); + return null; + } + river = (String)sd.getValue(); + } + if (log.isDebugEnabled()) { + log.debug("river: '" + river + "'"); + } + return river; + } + + public String getCalculationMode() { + if (calculationMode == null) { + StateData sd = artifact.getData("calculation.mode"); + if (sd == null) { + log.warn("missing 'calculation.mode' value"); + return null; + } + calculationMode = (String)sd.getValue(); + } + + if (log.isDebugEnabled()) { + log.debug("calculationMode: '" + calculationMode + "'"); + } + return calculationMode; + } + + public Double getFrom() { + + if (from == null) { + StateData sd = artifact.getData("from"); + if (sd == null) { + log.warn("missing 'from' value"); + return null; + } + try { + from = Double.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("from '" + sd.getValue() + "' is not numeric."); + } + } + + if (log.isDebugEnabled()) { + log.debug("from: '" + from + "'"); + } + + return from; + } + + public Double getTo() { + + if (to == null) { + StateData sd = artifact.getData("to"); + if (sd == null) { + log.warn("missing 'to' value"); + return null; + } + try { + to = Double.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("to '" + sd.getValue() + "' is not numeric."); + } + } + + if (log.isDebugEnabled()) { + log.debug("to: '" + to + "'"); + } + + return to; + } + + public Double getStep() { + + if (step == null) { + StateData sd = artifact.getData("step"); + if (sd == null) { + log.warn("missing 'step' value"); + return null; + } + try { + step = Double.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("step '" + sd.getValue() + "' is not numeric."); + } + } + + if (log.isDebugEnabled()) { + log.debug("step: '" + step + "'"); + } + + return step; + } + + public Long getStart() { + + if (start == null) { + StateData sd = artifact.getData("start"); + if (sd == null) { + log.warn("missing 'start' value"); + return null; + } + try { + start = Long.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("start '" + sd.getValue() + "' is not an integer."); + } + } + + if (log.isDebugEnabled()) { + log.debug("start: '" + start + "'"); + } + + return start; + } + + public Long getEnd() { + + if (end == null) { + StateData sd = artifact.getData("end"); + if (sd == null) { + log.warn("missing 'end' value"); + return null; + } + try { + end = Long.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("end '" + sd.getValue() + "' is not an integer."); + } + } + + if (log.isDebugEnabled()) { + log.debug("end: '" + end + "'"); + } + + return end; + } + + public Integer getQSectorStart() { + + if (qSectorStart == null) { + StateData sd = artifact.getData("q1"); + if (sd == null) { + log.warn("missing 'q1' value"); + return null; + } + try { + qSectorStart = Integer.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("q1 '" + sd.getValue() + "' is not an integer."); + } + } + + return qSectorStart; + } + + public Integer getQSectorEnd() { + + if (qSectorEnd == null) { + StateData sd = artifact.getData("q2"); + if (sd == null) { + log.warn("missing 'q2' value"); + return null; + } + try { + qSectorEnd = Integer.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("q2 '" + sd.getValue() + "' is not an integer."); + } + } + + return qSectorEnd; + } + + public int [] getEvents() { + if (events == null) { + StateData sd = artifact.getData("events"); + if (sd == null) { + log.warn("missing 'events' value"); + return null; + } + events = FLYSUtils.intArrayFromString((String)sd.getValue()); + } + return events; + } + + public Long getReferenceStart() { + if (referenceStart == null) { + StateData sd = artifact.getData("ref_start"); + if (sd == null) { + log.warn("missing 'ref_start' value"); + return null; + } + try { + referenceStart = Long.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("ref_start '" + + sd.getValue() + "' is not an integer."); + } + } + + if (log.isDebugEnabled()) { + log.debug("referenceStart: '" + referenceStart + "'"); + } + + return referenceStart; + } + + public Long getReferenceEnd() { + if (referenceEnd == null) { + StateData sd = artifact.getData("ref_end"); + if (sd == null) { + log.warn("missing 'ref_end' value"); + return null; + } + try { + referenceEnd = Long.valueOf((String)sd.getValue()); + } + catch (NumberFormatException nfe) { + log.warn("ref_end '" + + sd.getValue() + "' is not an integer."); + } + } + + if (log.isDebugEnabled()) { + log.debug("referenceEnd: '" + referenceEnd + "'"); + } + + return referenceEnd; + } + + public long [][] getAnalysisPeriods() { + if (analysisPeriods == null) { + /** TODO: Use real arrays here! */ + StateData sdStart = artifact.getData("ana_start"); + StateData sdEnd = artifact.getData("ana_end"); + + if (sdStart == null || sdEnd == null) { + log.warn("missing 'ana_start' or 'ana_end'"); + return null; + } + + try { + analysisPeriods = new long [][] { + { Long.parseLong((String)sdStart.getValue()), + Long.parseLong((String)sdEnd.getValue()) } + }; + } + catch (NumberFormatException nfe) { + log.warn("'ana_start' or 'ana_end' is not an integer."); + return null; + } + } + + if (log.isDebugEnabled()) { + for (int i = 0; i < analysisPeriods.length; ++i) { + long [] ap = analysisPeriods[i]; + log.debug("analysis period " + ap[0] + " - " + ap[1]); + } + } + + return analysisPeriods; + } + + public Boolean getPreprocessing() { + if (preprocessing == null) { + StateData sd = artifact.getData("preprocessing"); + if (sd == null) { + log.warn("missing 'preprocessing'"); + return null; + } + preprocessing = Boolean.valueOf((String)sd.getValue()); + } + return preprocessing; + } + + public String getFunction() { + if (function == null) { + StateData sd = artifact.getData("function"); + if (sd == null) { + log.warn("missing 'function'"); + return null; + } + function = (String)sd.getValue(); + } + return function; + } + + public double [] getQs() { + if (qs == null) { + StateData sd = artifact.getData("qs"); + if (sd == null) { + log.warn("missing 'qs'"); + return null; + } + String [] parts = ((String)sd.getValue()).split("[\\s;]"); + TDoubleArrayList list = new TDoubleArrayList(parts.length); + for (String part: parts) { + try { + list.add(Double.parseDouble(part)); + } + catch (NumberFormatException nfe) { + log.warn("'" + part + "' is not numeric."); + } + } + qs = list.toNativeArray(); + } + if (log.isDebugEnabled()) { + log.debug("qs: " + Arrays.toString(qs)); + } + return qs; + } +} +// vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :