bjoern@3739: package de.intevation.flys.artifacts.services;
bjoern@3739:
bjoern@3739: import java.math.BigDecimal;
bjoern@3739: import java.util.List;
bjoern@3739:
bjoern@3739: import org.apache.log4j.Logger;
bjoern@3739:
bjoern@3739: import org.w3c.dom.Document;
bjoern@3739: import org.w3c.dom.Element;
bjoern@3739:
bjoern@3739: import de.intevation.artifacts.CallMeta;
bjoern@3739: import de.intevation.artifacts.GlobalContext;
bjoern@3739: import de.intevation.artifacts.common.ArtifactNamespaceContext;
bjoern@3739: import de.intevation.artifacts.common.utils.XMLUtils;
bjoern@3739:
bjoern@3739: import de.intevation.flys.artifacts.model.RiverFactory;
bjoern@3739: import de.intevation.flys.model.Gauge;
bjoern@3739: import de.intevation.flys.model.MinMaxWQ;
bjoern@3739: import de.intevation.flys.model.Range;
bjoern@3739: import de.intevation.flys.model.River;
bjoern@3739:
bjoern@3739: /**
bjoern@3739: * @author Björn Ricks
bjoern@3739: */
bjoern@3739: public class GaugeOverviewInfoService extends FLYSService {
bjoern@3739:
bjoern@3739: private static final Logger logger = Logger.getLogger(
bjoern@3739: GaugeOverviewInfoService.class);
bjoern@3739:
bjoern@3739: public static final String RIVER_XPATH = "/art:river/text()";
bjoern@3739:
bjoern@3739: @Override
bjoern@3739: public Document doProcess(
bjoern@3739: Document data,
bjoern@3739: GlobalContext globalContext,
bjoern@3739: CallMeta callMeta
bjoern@3739: ) {
bjoern@3739: logger.debug("GaugeOverviewInfoService.process");
bjoern@3739:
bjoern@3739: String riverstr = XMLUtils.xpathString(
bjoern@3739: data, RIVER_XPATH, ArtifactNamespaceContext.INSTANCE);
bjoern@3739:
bjoern@3739: River river = RiverFactory.getRiver(riverstr);
bjoern@3739:
bjoern@3739: Document result = XMLUtils.newDocument();
bjoern@3739:
bjoern@3739: if (river == null) {
bjoern@3739: logger.warn("No river with name " + riverstr + " found.");
bjoern@3739: return result;
bjoern@3739: }
bjoern@3739:
bjoern@3739: XMLUtils.ElementCreator ec = new XMLUtils.ElementCreator(
bjoern@3739: result,
bjoern@3739: ArtifactNamespaceContext.NAMESPACE_URI,
bjoern@3739: ArtifactNamespaceContext.NAMESPACE_PREFIX);
bjoern@3739:
bjoern@3739: Element go = ec.create("gauge-info");
bjoern@3739:
bjoern@3753: double[] minmax = river.determineMinMaxDistance();
bjoern@3753: double[] minmaxq = river.determineMinMaxQ();
bjoern@3739:
bjoern@3739: Element r = ec.create("river");
bjoern@3739: ec.addAttr(r, "name", river.getName(), true);
bjoern@3739: ec.addAttr(r, "start", Double.toString(minmax[0]), true);
bjoern@3739: ec.addAttr(r, "end", Double.toString(minmax[1]), true);
bjoern@3739: ec.addAttr(r, "wstunit", river.getWstUnit().getName(), true);
bjoern@3739: ec.addAttr(r, "kmup", Boolean.toString(river.getKmUp()), true);
bjoern@3753: ec.addAttr(r, "minq", Double.toString(minmaxq[0]), true);
bjoern@3753: ec.addAttr(r, "maxq", Double.toString(minmaxq[1]), true);
bjoern@3912: ec.addAttr(r, "official", Long.toString(river.getOfficialNumber()),
bjoern@3912: true);
bjoern@3739:
bjoern@3739: Element egs = ec.create("gauges");
bjoern@3739:
bjoern@3739: List gauges = river.getGauges();
sascha@3748:
sascha@3748: if (logger.isDebugEnabled()) {
sascha@3748: logger.debug("Loaded gauges: " + gauges);
sascha@3748: }
sascha@3748:
bjoern@3739: for (Gauge gauge: river.getGauges()) {
bjoern@3739: Element eg = ec.create("gauge");
sascha@3748:
bjoern@3739: String name = gauge.getName();
bjoern@3739: if (name != null) {
bjoern@3739: ec.addAttr(eg, "name", gauge.getName(), true);
bjoern@3739: }
bjoern@3739:
sascha@3748: String aeo = getGaugeValue(gauge.getAeo());
sascha@3748: if (aeo != null) {
sascha@3748: ec.addAttr(eg, "aeo", aeo, true);
sascha@3748: }
sascha@3748:
sascha@3748: String datum = getGaugeValue(gauge.getDatum());
sascha@3748: if (datum != null) {
sascha@3748: ec.addAttr(eg, "datum", datum, true);
sascha@3748: }
sascha@3748:
bjoern@3739: Range range = gauge.getRange();
bjoern@3739: if (range != null) {
bjoern@3753: BigDecimal a = range.getA();
bjoern@3753: if (a != null) {
bjoern@3753: double min = a.doubleValue();
bjoern@3753: ec.addAttr(eg, "start", Double.toString(min), true);
bjoern@3753: }
bjoern@3739:
bjoern@3739: BigDecimal b = range.getB();
bjoern@3739: if (b != null) {
bjoern@3739: double max = range.getB().doubleValue();
bjoern@3739: ec.addAttr(eg, "end", Double.toString(max), true);
bjoern@3739: }
bjoern@3739: }
bjoern@3739: MinMaxWQ minmaxwq = gauge.fetchMaxMinWQ();
bjoern@3739: String minw = getGaugeValue(minmaxwq.getMinW());
bjoern@3739: String maxw = getGaugeValue(minmaxwq.getMaxW());
bjoern@3739: String minq = getGaugeValue(minmaxwq.getMinQ());
bjoern@3739: String maxq = getGaugeValue(minmaxwq.getMaxQ());
bjoern@3739:
bjoern@3739: if (minw != null) {
bjoern@3739: ec.addAttr(eg, "minw", minw, true);
bjoern@3739: }
bjoern@3739: if (maxw != null) {
bjoern@3739: ec.addAttr(eg, "maxw", maxw, true);
bjoern@3739: }
bjoern@3739: if (minq != null) {
bjoern@3739: ec.addAttr(eg, "minq", minq, true);
bjoern@3739: }
bjoern@3739: if (maxq != null) {
bjoern@3739: ec.addAttr(eg, "maxq", maxq, true);
bjoern@3739: }
bjoern@3739:
bjoern@3879: String station = getGaugeValue(gauge.getStation());
bjoern@3879: if (station != null) {
bjoern@3879: ec.addAttr(eg, "station", station, true);
bjoern@3879: }
bjoern@3879:
bjoern@3896: Long official = gauge.getOfficialNumber();
bjoern@3896: if (official != null) {
bjoern@3896: ec.addAttr(eg, "official", official.toString(), true);
bjoern@3896: }
bjoern@3896:
bjoern@3739: egs.appendChild(eg);
bjoern@3739: }
bjoern@3739:
bjoern@3739: go.appendChild(r);
bjoern@3739: go.appendChild(egs);
bjoern@3739: result.appendChild(go);
bjoern@3739:
bjoern@3739: return result;
bjoern@3739: }
bjoern@3739:
bjoern@3747: /**
bjoern@3747: * Returns a Double from a BigDecimal value or null if value is null
bjoern@3747: */
sascha@3748: private static String getGaugeValue(BigDecimal value) {
sascha@3748: return value != null
sascha@3748: ? Double.toString(value.doubleValue())
sascha@3748: : "";
bjoern@3739: }
bjoern@3739: }