teichmann@5831: package org.dive4elements.river.artifacts.states.extreme; felix@4116: felix@4116: import java.util.ArrayList; felix@4116: import java.util.List; felix@4116: felix@4116: import org.apache.log4j.Logger; felix@4116: felix@4116: import org.w3c.dom.Element; felix@4116: teichmann@5831: import org.dive4elements.artifacts.Artifact; teichmann@5831: import org.dive4elements.artifacts.CallContext; felix@4116: teichmann@5831: import org.dive4elements.river.artifacts.access.ExtremeAccess; teichmann@5831: teichmann@5831: import org.dive4elements.artifactdatabase.ProtocolUtils; teichmann@5831: import org.dive4elements.artifactdatabase.data.StateData; teichmann@5831: teichmann@5831: import org.dive4elements.artifacts.common.utils.XMLUtils; teichmann@5831: teichmann@5831: import org.dive4elements.river.artifacts.model.RiverFactory; teichmann@5831: import org.dive4elements.river.artifacts.model.WstValueTable; teichmann@4197: /* teichmann@5831: import org.dive4elements.river.model.Gauge; teichmann@5831: import org.dive4elements.river.model.Wst; teichmann@5831: import org.dive4elements.river.utils.FLYSUtils; teichmann@4197: */ teichmann@5831: import org.dive4elements.river.artifacts.model.Range; teichmann@5831: import org.dive4elements.river.model.River; felix@4116: teichmann@5831: import org.dive4elements.river.artifacts.FLYSArtifact; felix@4116: teichmann@5831: import org.dive4elements.river.artifacts.model.RangeWithValues; teichmann@5831: import org.dive4elements.river.artifacts.states.DefaultState; teichmann@5831: import org.dive4elements.river.artifacts.model.WstValueTableFactory; felix@4116: felix@4116: felix@4116: /** TODO Subclass WQAdapted. */ felix@4116: felix@4116: /** felix@4116: * State to input Q data in segments for extreme value calculations.. felix@4116: * The data item ranges is expected to have this format ;;:;;:... felix@4116: * (;;;:;;;:;;;:...) felix@4116: */ felix@4116: public class ExtremeQInput extends DefaultState { felix@4116: felix@4116: /** The logger used in this state.*/ felix@4116: private static Logger logger = Logger.getLogger(ExtremeQInput.class); felix@4116: felix@4116: felix@4116: /** Trivial, empty constructor. */ felix@4116: public ExtremeQInput() { felix@4116: } felix@4116: felix@4116: felix@4116: /** felix@4116: * Create one element for each 'segment' of the selected river that felix@4116: * is within the given kilometer range (TODO). Each element is a tuple of felix@4116: * (from;to) where from is the lower bounds of the segment or the felix@4116: * lower kilometer range. to is the upper bounds of the segment or felix@4116: * the upper kilometer range. felix@4116: * felix@4116: * @param cr The ElementCreator. felix@4116: * @param artifact The FLYS artifact. felix@4116: * @param name The name of the data item. felix@4116: * @param context The CallContext. felix@4116: * felix@4116: * @return a list of elements that consist of tuples of the intersected felix@4116: * segments of the selected river. felix@4116: */ felix@4116: @Override felix@4116: protected Element[] createItems( felix@4116: XMLUtils.ElementCreator cr, felix@4116: Artifact artifact, felix@4116: String name, felix@4116: CallContext context) felix@4116: { felix@4116: logger.debug("ExtremeQInput.createItems: " + name); felix@4116: felix@4116: FLYSArtifact flysArtifact = (FLYSArtifact) artifact; felix@4116: felix@4825: ExtremeAccess access = new ExtremeAccess(flysArtifact, context); felix@4116: River river = RiverFactory.getRiver(access.getRiver()); felix@4116: WstValueTable wstValueTable = WstValueTableFactory.getTable(river); felix@4116: felix@4116: List ranges = wstValueTable.findSegments(access.getFrom(), felix@4116: access.getTo()); felix@4116: felix@4116: int num = ranges != null ? ranges.size() : 0; felix@4116: felix@4116: if (num == 0) { felix@4116: logger.warn("Selected distance matches no segments."); felix@4116: return null; felix@4116: } felix@4116: felix@4116: List elements = new ArrayList(); felix@4116: felix@4116: for (Range range: ranges) { felix@4116: elements.add(createItem( felix@4116: cr, new String[] { range.getStart() + ";" + range.getEnd(), ""}, new double[] {0,100000})); felix@4116: } felix@4116: felix@4116: Element[] els = new Element[elements.size()]; felix@4116: felix@4116: return elements.toArray(els); felix@4116: } felix@4116: felix@4116: felix@4116: /** Create sub-item ('row') of data thing. */ felix@4116: protected Element createItem( felix@4116: XMLUtils.ElementCreator cr, felix@4116: Object obj, felix@4116: double[] q felix@4116: ) felix@4116: { felix@4116: Element item = ProtocolUtils.createArtNode(cr, "item", null, null); felix@4116: Element label = ProtocolUtils.createArtNode(cr, "label", null, null); felix@4116: Element value = ProtocolUtils.createArtNode(cr, "value", null, null); felix@4116: felix@4116: String[] arr = (String[]) obj; felix@4116: felix@4116: label.setTextContent(arr[0]); felix@4116: value.setTextContent(arr[1]); felix@4116: felix@4116: item.appendChild(label); felix@4116: item.appendChild(value); felix@4116: felix@4116: if (q != null) { felix@4116: Element qRange = createRangeElement(cr, q, "Q"); felix@4116: item.appendChild(qRange); felix@4116: } felix@4116: felix@4116: return item; felix@4116: } felix@4116: felix@4116: felix@4116: /** felix@4116: * Create elements to set min and max values of segments q (just min makes felix@4116: * sense for extremes. felix@4116: */ felix@4116: protected Element createRangeElement( felix@4116: XMLUtils.ElementCreator cr, felix@4116: double[] mm, felix@4116: String type) felix@4116: { felix@4116: Element range = ProtocolUtils.createArtNode( felix@4116: cr, "range", felix@4116: new String[] {"type"}, felix@4116: new String[] {type}); felix@4116: felix@4116: Element min = ProtocolUtils.createArtNode(cr, "min", null, null); felix@4116: min.setTextContent(String.valueOf(mm[0])); felix@4116: felix@4116: Element max = ProtocolUtils.createArtNode(cr, "max", null, null); felix@4116: max.setTextContent(String.valueOf(mm[1])); felix@4116: felix@4116: range.appendChild(min); felix@4116: range.appendChild(max); felix@4116: felix@4116: return range; felix@4116: } felix@4116: felix@4116: felix@4116: @Override felix@4116: protected String getUIProvider() { felix@4116: return "q_segmented_panel"; felix@4116: } felix@4116: felix@4116: felix@4116: /** Validate given data (return true). */ felix@4116: @Override felix@4116: public boolean validate(Artifact artifact) felix@4116: throws IllegalArgumentException felix@4116: { felix@4116: logger.debug("ExtremeQInput.validate"); felix@4116: felix@4116: FLYSArtifact flys = (FLYSArtifact) artifact; felix@4116: logger.debug("ExtremeQInput: " + getData(flys, "ranges")); felix@4116: felix@4116: /* felix@4116: // TODO sort out what has to be validated (prevent negative values?). felix@4116: RangeWithValues[] rwvs = extractInput(getData(flys, "ranges")); felix@4116: felix@4116: if (rwvs == null) { felix@4116: throw new IllegalArgumentException("error_missing_wq_data"); felix@4116: } felix@4116: felix@4116: List gauges = FLYSUtils.getGauges(flys); felix@4116: River river = FLYSUtils.getRiver(flys); felix@4116: Wst wst = WstFactory.getWst(river); felix@4116: felix@4116: for (Gauge gauge: gauges) { felix@4116: Range range = gauge.getRange(); felix@4116: double lower = range.getA().doubleValue(); felix@4116: double upper = range.getB().doubleValue(); felix@4116: felix@4116: for (RangeWithValues rwv: rwvs) { felix@4116: if (lower <= rwv.getStart() && upper >= rwv.getEnd()) { felix@4116: compareQsWithGauge(wst, gauge, rwv.getValues()); felix@4116: } felix@4116: } felix@4116: } felix@4116: */ felix@4116: felix@4116: return true; felix@4116: } felix@4116: felix@4116: felix@4116: /** Form RangeWithValue-Array from state data. */ felix@4116: protected RangeWithValues[] extractInput(StateData data) { felix@4116: if (data == null) { felix@4116: return null; felix@4116: } felix@4116: felix@4116: String dataString = (String) data.getValue(); felix@4116: String[] ranges = dataString.split(":"); felix@4116: felix@4116: List rwv = new ArrayList(); felix@4116: felix@4116: for (String range: ranges) { felix@4116: String[] parts = range.split(";"); felix@4116: felix@4116: double lower = Double.parseDouble(parts[0]); felix@4116: double upper = Double.parseDouble(parts[1]); felix@4116: felix@4116: String[] values = parts[2].split(","); felix@4116: felix@4116: int num = values.length; felix@4116: double[] res = new double[num]; felix@4116: felix@4116: for (int i = 0; i < num; i++) { felix@4116: try { felix@4116: res[i] = Double.parseDouble(values[i]); felix@4116: } felix@4116: catch (NumberFormatException nfe) { felix@4116: logger.warn(nfe, nfe); felix@4116: } felix@4116: } felix@4116: felix@4116: rwv.add(new RangeWithValues(lower, upper, res)); felix@4116: } felix@4116: felix@4116: return rwv.toArray(new RangeWithValues[rwv.size()]); felix@4116: } felix@4116: } felix@4116: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf-8 :