Mercurial > dive4elements > river
diff artifacts/src/main/java/org/dive4elements/river/exports/WaterlevelExporter.java @ 9082:42c15e2f95fb
2.3.4.1.4 Wasserstand falsche Einheit
FixAnalysis PDF start
| author | gernotbelger |
|---|---|
| date | Fri, 25 May 2018 10:44:24 +0200 |
| parents | 5294114b1df4 |
| children | 740d65e4aa14 |
line wrap: on
line diff
--- a/artifacts/src/main/java/org/dive4elements/river/exports/WaterlevelExporter.java Fri May 25 09:10:19 2018 +0200 +++ b/artifacts/src/main/java/org/dive4elements/river/exports/WaterlevelExporter.java Fri May 25 10:44:24 2018 +0200 @@ -13,52 +13,45 @@ import java.text.DateFormat; import java.text.NumberFormat; import java.util.ArrayList; -import java.util.Map; +import java.util.Date; import java.util.HashMap; -import java.util.Date; import java.util.List; import java.util.Locale; +import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.apache.log4j.Logger; - -import au.com.bytecode.opencsv.CSVWriter; - -import gnu.trove.TDoubleArrayList; - -import org.dive4elements.river.artifacts.model.ConstantWQKms; - -import net.sf.jasperreports.engine.JasperExportManager; -import net.sf.jasperreports.engine.JasperFillManager; -import net.sf.jasperreports.engine.JasperPrint; -import net.sf.jasperreports.engine.JRException; - import org.dive4elements.artifacts.Artifact; import org.dive4elements.artifacts.CallMeta; import org.dive4elements.artifacts.common.utils.Config; - -import org.dive4elements.river.model.Gauge; - +import org.dive4elements.river.artifacts.D4EArtifact; +import org.dive4elements.river.artifacts.FixationArtifact; +import org.dive4elements.river.artifacts.StaticWQKmsArtifact; +import org.dive4elements.river.artifacts.WINFOArtifact; import org.dive4elements.river.artifacts.access.FixRealizingAccess; import org.dive4elements.river.artifacts.access.IsOfficialAccess; import org.dive4elements.river.artifacts.access.RangeAccess; -import org.dive4elements.river.artifacts.FixationArtifact; -import org.dive4elements.river.artifacts.D4EArtifact; -import org.dive4elements.river.artifacts.WINFOArtifact; -import org.dive4elements.river.artifacts.StaticWQKmsArtifact; import org.dive4elements.river.artifacts.model.CalculationResult; +import org.dive4elements.river.artifacts.model.ConstantWQKms; import org.dive4elements.river.artifacts.model.Segment; +import org.dive4elements.river.artifacts.model.WKmsJRDataSource; import org.dive4elements.river.artifacts.model.WQCKms; import org.dive4elements.river.artifacts.model.WQKms; +import org.dive4elements.river.artifacts.model.WQKmsResult; import org.dive4elements.river.artifacts.model.WstLine; -import org.dive4elements.river.artifacts.model.WKmsJRDataSource; -import org.dive4elements.river.artifacts.model.WQKmsResult; import org.dive4elements.river.artifacts.resources.Resources; - +import org.dive4elements.river.model.Gauge; +import org.dive4elements.river.utils.Formatter; import org.dive4elements.river.utils.RiverUtils; import org.dive4elements.river.utils.RiverUtils.WQ_MODE; -import org.dive4elements.river.utils.Formatter; + +import au.com.bytecode.opencsv.CSVWriter; +import gnu.trove.TDoubleArrayList; +import net.sf.jasperreports.engine.JRException; +import net.sf.jasperreports.engine.JasperExportManager; +import net.sf.jasperreports.engine.JasperFillManager; +import net.sf.jasperreports.engine.JasperPrint; /** * Generates different output formats (wst, csv, pdf) of data that resulted from @@ -68,7 +61,7 @@ */ public class WaterlevelExporter extends AbstractExporter { - /** The log used in this exporter.*/ + /** The log used in this exporter. */ private static Logger log = Logger.getLogger(WaterlevelExporter.class); public static final String FACET_WST = "wst"; @@ -76,166 +69,141 @@ /* This should be the same as in the StaticWQKmsArtifact */ public static final String STATICWQKMSNAME = "staticwqkms"; - public static final String CSV_KM_HEADER = - "export.waterlevel.csv.header.km"; - - public static final String CSV_W_HEADER = - "export.waterlevel.csv.header.w"; + public static final String CSV_KM_HEADER = "export.waterlevel.csv.header.km"; - public static final String CSV_Q_HEADER = - "export.waterlevel.csv.header.q"; + public static final String CSV_W_HEADER = "export.waterlevel.csv.header.w"; - /** - * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. - */ - @Deprecated - public static final String CSV_Q_DESC_HEADER = - "export.waterlevel.csv.header.q.desc"; + public static final String CSV_Q_HEADER = "export.waterlevel.csv.header.q"; /** * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. */ @Deprecated - public static final String CSV_W_DESC_HEADER = - "export.waterlevel.csv.header.w.desc"; - - public static final String CSV_LOCATION_HEADER = - "export.waterlevel.csv.header.location"; - - public static final String CSV_GAUGE_HEADER = - "export.waterlevel.csv.header.gauge"; - - public static final String CSV_META_RESULT = - "export.waterlevel.csv.meta.result"; - - public static final String CSV_META_CREATION = - "export.waterlevel.csv.meta.creation"; - - public static final String CSV_META_CALCULATIONBASE = - "export.waterlevel.csv.meta.calculationbase"; - - public static final String CSV_META_RIVER = - "export.waterlevel.csv.meta.river"; + public static final String CSV_Q_DESC_HEADER = "export.waterlevel.csv.header.q.desc"; - public static final String CSV_META_RANGE = - "export.waterlevel.csv.meta.range"; - - public static final String CSV_META_GAUGE = - "export.waterlevel.csv.meta.gauge"; - - public static final String CSV_META_Q = - "export.waterlevel.csv.meta.q"; - - public static final String CSV_META_W = - "export.waterlevel.csv.meta.w"; - - public static final String CSV_NOT_IN_GAUGE_RANGE = - "export.waterlevel.csv.not.in.gauge.range"; - - public static final Pattern NUMBERS_PATTERN = - Pattern.compile("\\D*(\\d++.\\d*)\\D*"); - - public static final String DEFAULT_CSV_KM_HEADER = "Fluss-Km"; - public static final String DEFAULT_CSV_W_HEADER = "W [NN + m]"; - public static final String DEFAULT_CSV_Q_HEADER = "Q [m\u00b3/s]"; /** * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. */ @Deprecated - public static final String DEFAULT_CSV_Q_DESC_HEADER = "Bezeichnung"; + public static final String CSV_W_DESC_HEADER = "export.waterlevel.csv.header.w.desc"; + + public static final String CSV_LOCATION_HEADER = "export.waterlevel.csv.header.location"; + + public static final String CSV_GAUGE_HEADER = "export.waterlevel.csv.header.gauge"; + + public static final String CSV_META_RESULT = "export.waterlevel.csv.meta.result"; + + public static final String CSV_META_CREATION = "export.waterlevel.csv.meta.creation"; + + public static final String CSV_META_CALCULATIONBASE = "export.waterlevel.csv.meta.calculationbase"; + + public static final String CSV_META_RIVER = "export.waterlevel.csv.meta.river"; + + public static final String CSV_META_RANGE = "export.waterlevel.csv.meta.range"; + + public static final String CSV_META_GAUGE = "export.waterlevel.csv.meta.gauge"; + + public static final String CSV_META_Q = "export.waterlevel.csv.meta.q"; + + public static final String CSV_META_W = "export.waterlevel.csv.meta.w"; + + public static final String CSV_NOT_IN_GAUGE_RANGE = "export.waterlevel.csv.not.in.gauge.range"; + + public static final Pattern NUMBERS_PATTERN = Pattern.compile("\\D*(\\d++.\\d*)\\D*"); + + public static final String DEFAULT_CSV_KM_HEADER = "Fluss-Km"; + public static final String DEFAULT_CSV_W_HEADER = "W [NN + m]"; + public static final String DEFAULT_CSV_Q_HEADER = "Q [m\u00b3/s]"; /** * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. */ @Deprecated - public static final String DEFAULT_CSV_W_DESC_HEADER = "W/Pegel [cm]"; + public static final String DEFAULT_CSV_Q_DESC_HEADER = "Bezeichnung"; + /** + * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. + */ + @Deprecated + public static final String DEFAULT_CSV_W_DESC_HEADER = "W/Pegel [cm]"; public static final String DEFAULT_CSV_LOCATION_HEADER = "Lage"; - public static final String DEFAULT_CSV_GAUGE_HEADER = "Bezugspegel"; - public static final String DEFAULT_CSV_NOT_IN_GAUGE_RANGE = - "außerhalb des gewählten Bezugspegels"; + public static final String DEFAULT_CSV_GAUGE_HEADER = "Bezugspegel"; + public static final String DEFAULT_CSV_NOT_IN_GAUGE_RANGE = "außerhalb des gewählten Bezugspegels"; public static final String PDF_HEADER_MODE = "export.waterlevel.pdf.mode"; - public static final String JASPER_FILE = "export.waterlevel.pdf.file"; + public static final String JASPER_FILE = "export.waterlevel.pdf.file"; - /** The storage that contains all WQKms objects that are calculated.*/ + /** The storage that contains all WQKms objects that are calculated. */ protected List<WQKms[]> data; - /** The storage that contains official fixings if available.*/ + /** The storage that contains official fixings if available. */ protected List<WQKms> officalFixings; public WaterlevelExporter() { - data = new ArrayList<WQKms[]>(); + this.data = new ArrayList<>(); } @Override - public void generate() - throws IOException - { + public void generate() throws IOException { log.debug("WaterlevelExporter.generate"); - /* Check for official fixings. They should also be included in the - * export but only the calculation result is added with addData */ - - officalFixings = new ArrayList<WQKms>(); + /* + * Check for official fixings. They should also be included in the + * export but only the calculation result is added with addData + */ - for (Artifact art: collection.getArtifactsByName( - STATICWQKMSNAME, context) - ) { + this.officalFixings = new ArrayList<>(); + + for (final Artifact art : this.collection.getArtifactsByName(STATICWQKMSNAME, this.context)) { if (art instanceof StaticWQKmsArtifact) { - IsOfficialAccess access = - new IsOfficialAccess((D4EArtifact)art); - StaticWQKmsArtifact sart = (StaticWQKmsArtifact) art; + final IsOfficialAccess access = new IsOfficialAccess((D4EArtifact) art); + final StaticWQKmsArtifact sart = (StaticWQKmsArtifact) art; if (!access.isOfficial()) { continue; } /* Check that we add the data only once */ - WQKms toAdd = sart.getWQKms(); - String newName = toAdd.getName(); + final WQKms toAdd = sart.getWQKms(); + final String newName = toAdd.getName(); boolean exists = false; - for (WQKms wqkm: officalFixings) { - /* The same official fixing could be in two - artifacts/outs so let's deduplicate */ + for (final WQKms wqkm : this.officalFixings) { + /* + * The same official fixing could be in two + * artifacts/outs so let's deduplicate + */ if (wqkm.getName().equals(newName)) { exists = true; } } if (!exists) { - officalFixings.add(toAdd); + this.officalFixings.add(toAdd); log.debug("Adding additional offical fixing: " + newName); } } } - if (facet != null && facet.equals(AbstractExporter.FACET_CSV)) { + if (this.facet != null && this.facet.equals(AbstractExporter.FACET_CSV)) { generateCSV(); - } - else if (facet != null && facet.equals(FACET_WST)) { + } else if (this.facet != null && this.facet.equals(FACET_WST)) { generateWST(); - } - else if (facet != null && facet.equals(AbstractExporter.FACET_PDF)) { + } else if (this.facet != null && this.facet.equals(AbstractExporter.FACET_PDF)) { generatePDF(); - } - else { + } else { throw new IOException("invalid facet for exporter"); } } - @Override protected void addData(Object d) { if (d instanceof CalculationResult) { - d = ((CalculationResult)d).getData(); - if (d instanceof WQKms []) { - data.add((WQKms [])d); - } - else if (d instanceof WQKmsResult) { - data.add(((WQKmsResult) d).getWQKms()); + d = ((CalculationResult) d).getData(); + if (d instanceof WQKms[]) { + this.data.add((WQKms[]) d); + } else if (d instanceof WQKmsResult) { + this.data.add(((WQKmsResult) d).getWQKms()); } } } - /** * Prepare the column titles of waterlevel exports. * Titles in this export include the Q value. If a Q value matches a named @@ -243,13 +211,15 @@ * title. This method resets the name of the <i>wqkms</i> object if such * named main value fits to the chosen Q. * - * @param winfo A WINFO Artifact. - * @param wqkms A WQKms object that should be prepared. + * @param winfo + * A WINFO Artifact. + * @param wqkms + * A WQKms object that should be prepared. */ - protected String getColumnTitle(WINFOArtifact winfo, WQKms wqkms) { + protected String getColumnTitle(final WINFOArtifact winfo, final WQKms wqkms) { log.debug("WaterlevelExporter.getColumnTitle"); - String name = wqkms.getName(); + final String name = wqkms.getName(); log.debug("Name of WQKms = '" + name + "'"); @@ -257,25 +227,25 @@ return name; } - Matcher m = NUMBERS_PATTERN.matcher(name); + final Matcher m = NUMBERS_PATTERN.matcher(name); if (m.matches()) { - String raw = m.group(1); + final String raw = m.group(1); try { - double v = Double.valueOf(raw); + final double v = Double.valueOf(raw); String nmv = RiverUtils.getNamedMainValue(winfo, v); if (nmv != null && nmv.length() > 0) { - nmv = RiverUtils.stripNamedMainValue(nmv); + nmv = RiverUtils.stripNamedMainValue(nmv); nmv += "=" + String.valueOf(v); log.debug("Set named main value '" + nmv + "'"); return nmv; } } - catch (NumberFormatException nfe) { + catch (final NumberFormatException nfe) { // do nothing here } } @@ -283,25 +253,24 @@ return name; } - /** * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. */ @Deprecated - protected String getCSVRowTitle(WINFOArtifact winfo, WQKms wqkms) { + protected String getCSVRowTitle(final WINFOArtifact winfo, final WQKms wqkms) { log.debug("WaterlevelExporter.prepareNamedValue"); - String name = wqkms.getName(); + final String name = wqkms.getName(); log.debug("Name of WQKms = '" + name + "'"); - WQ_MODE wqmode = RiverUtils.getWQMode(winfo); + final WQ_MODE wqmode = RiverUtils.getWQMode(winfo); if (wqmode == WQ_MODE.WFREE || wqmode == WQ_MODE.QGAUGE) { return localizeWQKms(winfo, wqkms); } - Double v = wqkms.getRawValue(); + final Double v = wqkms.getRawValue(); String nmv = RiverUtils.getNamedMainValue(winfo, v); @@ -315,42 +284,38 @@ return localizeWQKms(winfo, wqkms); } - /** * Get a string like 'W=' or 'Q=' with a number following in localized * format. - * + * * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. */ @Deprecated - protected String localizeWQKms(WINFOArtifact winfo, WQKms wqkms) { - WQ_MODE wqmode = RiverUtils.getWQMode(winfo); - Double rawValue = wqkms.getRawValue(); + protected String localizeWQKms(final WINFOArtifact winfo, final WQKms wqkms) { + final WQ_MODE wqmode = RiverUtils.getWQMode(winfo); + final Double rawValue = wqkms.getRawValue(); if (rawValue == null) { return wqkms.getName(); } - NumberFormat nf = Formatter.getRawFormatter(context); + final NumberFormat nf = Formatter.getRawFormatter(this.context); if (wqmode == WQ_MODE.WFREE || wqmode == WQ_MODE.WGAUGE) { return "W=" + nf.format(rawValue); - } - else { + } else { return "Q=" + nf.format(rawValue); } } - @Override - protected void writeCSVData(CSVWriter writer) { + protected void writeCSVData(final CSVWriter writer) { log.info("WaterlevelExporter.writeData"); - WQ_MODE mode = RiverUtils.getWQMode((D4EArtifact)master); - boolean atGauge = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.WGAUGE; - boolean isQ = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.QFREE; - RiverUtils.WQ_INPUT input - = RiverUtils.getWQInputMode((D4EArtifact)master); + final WQ_MODE mode = RiverUtils.getWQMode((D4EArtifact) this.master); + final boolean atGauge = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.WGAUGE; + final boolean isQ = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.QFREE; + final RiverUtils.WQ_INPUT input = RiverUtils.getWQInputMode((D4EArtifact) this.master); writeCSVMeta(writer); writeCSVHeader(writer, atGauge, isQ); @@ -358,19 +323,21 @@ Double first = Double.NaN; Double last = Double.NaN; - for (WQKms[] tmp: data) { - for (WQKms wqkms: tmp) { + for (final WQKms[] tmp : this.data) { + for (final WQKms wqkms : tmp) { wQKms2CSV(writer, wqkms, atGauge, isQ); - double[] firstLast = wqkms.getFirstLastKM(); + final double[] firstLast = wqkms.getFirstLastKM(); if (first.isNaN()) { /* Initialize */ first = firstLast[0]; last = firstLast[1]; } if (firstLast[0] > firstLast[1]) { - /* Calculating upstream we assert that it is + /* + * Calculating upstream we assert that it is * impossible that the direction changes during this - * loop */ + * loop + */ first = Math.max(first, firstLast[0]); last = Math.min(last, firstLast[1]); } else if (firstLast[0] < firstLast[1]) { @@ -382,35 +349,38 @@ } } /* Append the official fixing at the bottom */ - for (WQKms wqkms: officalFixings) { + for (final WQKms wqkms : this.officalFixings) { wQKms2CSV(writer, filterWQKms(wqkms, first, last), atGauge, isQ); } } - - /** Filter a wqkms object to a distance. + /** + * Filter a wqkms object to a distance. * * To handle upstream / downstream and to limit * the officialFixings to the calculation distance * we create a new wqkms object here and fill it only * with the relevant data. * - * @param wqkms: The WQKms Object to filter - * @param first: The fist kilometer of the range - * @param last: The last kilometer of the range + * @param wqkms: + * The WQKms Object to filter + * @param first: + * The fist kilometer of the range + * @param last: + * The last kilometer of the range * * @return A new WQKms with the relevant data sorted by direction */ - private WQKms filterWQKms(WQKms wqkms, Double first, Double last) { + private WQKms filterWQKms(final WQKms wqkms, final Double first, final Double last) { if (first.isNaN() || last.isNaN()) { log.warn("Filtering official fixing without valid first/last."); return wqkms; } - int firstIdx = first > last ? wqkms.size() - 1 : 0; - int lastIdx = first > last ? 0 : wqkms.size() -1; - WQKms filtered = new WQKms (wqkms.size()); + final int firstIdx = first > last ? wqkms.size() - 1 : 0; + final int lastIdx = first > last ? 0 : wqkms.size() - 1; + final WQKms filtered = new WQKms(wqkms.size()); filtered.setName(wqkms.getName()); - double [] dp = new double [3]; + double[] dp = new double[3]; if (first > last) { for (int i = wqkms.size() - 1; i >= 0; i--) { @@ -430,172 +400,101 @@ return filtered; } - - protected void writeCSVMeta(CSVWriter writer) { + protected void writeCSVMeta(final CSVWriter writer) { log.info("WaterlevelExporter.writeCSVMeta"); // TODO use Access instead of RiverUtils - CallMeta meta = context.getMeta(); - - D4EArtifact flys = (D4EArtifact) master; - - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_RESULT, - CSV_META_RESULT, - new Object[] { RiverUtils.getRivername(flys) }) - }); + final CallMeta meta = this.context.getMeta(); - Locale locale = Resources.getLocale(meta); - DateFormat df = DateFormat.getDateInstance(DateFormat.SHORT, locale); + final D4EArtifact flys = (D4EArtifact) this.master; - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_CREATION, - CSV_META_CREATION, - new Object[] { df.format(new Date()) }) - }); + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_RESULT, CSV_META_RESULT, new Object[] { RiverUtils.getRivername(flys) }) }); - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_CALCULATIONBASE, - CSV_META_CALCULATIONBASE, - new Object[] { "" }) // TODO what is required at this place? + final Locale locale = Resources.getLocale(meta); + final DateFormat df = DateFormat.getDateInstance(DateFormat.SHORT, locale); + + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_CREATION, CSV_META_CREATION, new Object[] { df.format(new Date()) }) }); + + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_CALCULATIONBASE, CSV_META_CALCULATIONBASE, new Object[] { "" }) // TODO what is required + // at this place? }); - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_RIVER, - CSV_META_RIVER, - new Object[] { RiverUtils.getRivername(flys) }) - }); + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_RIVER, CSV_META_RIVER, new Object[] { RiverUtils.getRivername(flys) }) }); - RangeAccess rangeAccess = new RangeAccess(flys); - double[] kms = rangeAccess.getKmRange(); - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_RANGE, - CSV_META_RANGE, - new Object[] { kms[0], kms[kms.length-1] }) - }); + final RangeAccess rangeAccess = new RangeAccess(flys); + final double[] kms = rangeAccess.getKmRange(); + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_RANGE, CSV_META_RANGE, new Object[] { kms[0], kms[kms.length - 1] }) }); - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_GAUGE, - CSV_META_GAUGE, - new Object[] { RiverUtils.getGaugename(flys) }) - }); + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_GAUGE, CSV_META_GAUGE, new Object[] { RiverUtils.getGaugename(flys) }) }); // TODO: code extracted into WaterlevelDescriptionBuilder, should be used instead. - RiverUtils.WQ_MODE wq = RiverUtils.getWQMode(flys); + final RiverUtils.WQ_MODE wq = RiverUtils.getWQMode(flys); if (wq == RiverUtils.WQ_MODE.QFREE || wq == RiverUtils.WQ_MODE.QGAUGE) { - double[] qs = RiverUtils.getQs(flys); - RiverUtils.WQ_INPUT input = RiverUtils.getWQInputMode(flys); + final double[] qs = RiverUtils.getQs(flys); + final RiverUtils.WQ_INPUT input = RiverUtils.getWQInputMode(flys); String data = ""; - if ((input == RiverUtils.WQ_INPUT.ADAPTED || - input == RiverUtils.WQ_INPUT.RANGE) && - qs != null && qs.length > 0) - { + if ((input == RiverUtils.WQ_INPUT.ADAPTED || input == RiverUtils.WQ_INPUT.RANGE) && qs != null && qs.length > 0) { data = String.valueOf(qs[0]); - data += " - " + String.valueOf(qs[qs.length-1]); - } - else if (input == RiverUtils.WQ_INPUT.SINGLE && qs != null){ + data += " - " + String.valueOf(qs[qs.length - 1]); + } else if (input == RiverUtils.WQ_INPUT.SINGLE && qs != null) { data = String.valueOf(qs[0]); for (int i = 1; i < qs.length; i++) { data += ", " + String.valueOf(qs[i]); } - } - else { + } else { log.warn("Could not determine Q range!"); } - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_Q, - CSV_META_Q, - new Object[] {data}) - }); - } - else { - double[] ws = RiverUtils.getWs(flys); + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_Q, CSV_META_Q, new Object[] { data }) }); + } else { + final double[] ws = RiverUtils.getWs(flys); String lower = ""; String upper = ""; if (ws != null && ws.length > 0) { lower = String.valueOf(ws[0]); - upper = String.valueOf(ws[ws.length-1]); - } - else { + upper = String.valueOf(ws[ws.length - 1]); + } else { log.warn("Could not determine W range!"); } - writer.writeNext(new String[] { - Resources.getMsg( - meta, - CSV_META_W, - CSV_META_W, - new Object[] { lower, upper }) - }); + writer.writeNext(new String[] { Resources.getMsg(meta, CSV_META_W, CSV_META_W, new Object[] { lower, upper }) }); } writer.writeNext(new String[] { "" }); } - /** * Write the header, with different headings depending on whether at a * gauge or at a location. */ - protected void writeCSVHeader( - CSVWriter writer, - boolean atGauge, - boolean isQ - ) { + protected void writeCSVHeader(final CSVWriter writer, final boolean atGauge, final boolean isQ) { log.info("WaterlevelExporter.writeCSVHeader"); - String unit = RiverUtils.getRiver( - (D4EArtifact) master).getWstUnit().getName(); + final String unit = RiverUtils.getRiver((D4EArtifact) this.master).getWstUnit().getName(); if (atGauge) { - writer.writeNext(new String[] { - msg(CSV_KM_HEADER, DEFAULT_CSV_KM_HEADER), - msg(CSV_W_HEADER, DEFAULT_CSV_W_HEADER, new Object[] { unit }), - msg(CSV_Q_HEADER, DEFAULT_CSV_Q_HEADER), - - // FIXME: use WaterlevelDescriptionBuilder instead and also remove all this duplicate code. - (isQ - ? msg(CSV_Q_DESC_HEADER, DEFAULT_CSV_Q_DESC_HEADER) - : msg(CSV_W_DESC_HEADER, DEFAULT_CSV_W_DESC_HEADER)), - msg(CSV_LOCATION_HEADER, DEFAULT_CSV_LOCATION_HEADER), - msg(CSV_GAUGE_HEADER, DEFAULT_CSV_GAUGE_HEADER) - }); - } - else { - writer.writeNext(new String[] { - msg(CSV_KM_HEADER, DEFAULT_CSV_KM_HEADER), + writer.writeNext(new String[] { msg(CSV_KM_HEADER, DEFAULT_CSV_KM_HEADER), msg(CSV_W_HEADER, DEFAULT_CSV_W_HEADER, new Object[] { unit }), + msg(CSV_Q_HEADER, DEFAULT_CSV_Q_HEADER), + + // FIXME: use WaterlevelDescriptionBuilder instead and also remove all this duplicate code. + (isQ ? msg(CSV_Q_DESC_HEADER, DEFAULT_CSV_Q_DESC_HEADER) : msg(CSV_W_DESC_HEADER, DEFAULT_CSV_W_DESC_HEADER)), + msg(CSV_LOCATION_HEADER, DEFAULT_CSV_LOCATION_HEADER), msg(CSV_GAUGE_HEADER, DEFAULT_CSV_GAUGE_HEADER) }); + } else { + writer.writeNext(new String[] { msg(CSV_KM_HEADER, DEFAULT_CSV_KM_HEADER), // TODO flys/issue1128 (unit per river) - msg(CSV_W_HEADER, DEFAULT_CSV_W_HEADER, new Object[] { unit }), - msg(CSV_Q_HEADER, DEFAULT_CSV_Q_HEADER), - msg(CSV_LOCATION_HEADER, DEFAULT_CSV_LOCATION_HEADER) - }); + msg(CSV_W_HEADER, DEFAULT_CSV_W_HEADER, new Object[] { unit }), msg(CSV_Q_HEADER, DEFAULT_CSV_Q_HEADER), + msg(CSV_LOCATION_HEADER, DEFAULT_CSV_LOCATION_HEADER) }); } } - /** Linearly search for gauge which is valid at km. */ - private static Gauge findGauge(double km, List<Gauge> gauges) { - for (Gauge gauge: gauges) { + private static Gauge findGauge(final double km, final List<Gauge> gauges) { + for (final Gauge gauge : gauges) { if (gauge.getRange().contains(km)) { return gauge; } @@ -603,8 +502,8 @@ return null; } - private static Segment findSegment(double km, List<Segment> segments) { - for (Segment segment: segments) { + private static Segment findSegment(final double km, final List<Segment> segments) { + for (final Segment segment : segments) { if (segment.inside(km)) { return segment; } @@ -612,70 +511,55 @@ return null; } - - private void writeRow4(CSVWriter writer, double wqkm[], D4EArtifact flys) { - NumberFormat kmf = getKmFormatter(); - NumberFormat wf = getWFormatter(); - NumberFormat qf = getQFormatter(); - writer.writeNext(new String[] { - kmf.format(wqkm[2]), - wf.format(wqkm[0]), - qf.format(RiverUtils.roundQ(wqkm[1])), - RiverUtils.getLocationDescription(flys, wqkm[2]) - }); + private void writeRow4(final CSVWriter writer, final double wqkm[], final D4EArtifact flys) { + final NumberFormat kmf = getKmFormatter(); + final NumberFormat wf = getWFormatter(); + final NumberFormat qf = getQFormatter(); + writer.writeNext(new String[] { kmf.format(wqkm[2]), wf.format(wqkm[0]), qf.format(RiverUtils.roundQ(wqkm[1])), + RiverUtils.getLocationDescription(flys, wqkm[2]) }); } /** Write an csv-row at gauge location. */ - private void writeRow6(CSVWriter writer, double wqkm[], String wOrQDesc, - D4EArtifact flys, String gaugeName) { - NumberFormat kmf = getKmFormatter(); - NumberFormat wf = getWFormatter(); - NumberFormat qf = getQFormatter(); + private void writeRow6(final CSVWriter writer, final double wqkm[], final String wOrQDesc, final D4EArtifact flys, final String gaugeName) { + final NumberFormat kmf = getKmFormatter(); + final NumberFormat wf = getWFormatter(); + final NumberFormat qf = getQFormatter(); - writer.writeNext(new String[] { - kmf.format(wqkm[2]), - wf.format(wqkm[0]), - qf.format(RiverUtils.roundQ(wqkm[1])), - wOrQDesc, - RiverUtils.getLocationDescription(flys, wqkm[2]), - gaugeName - }); + writer.writeNext(new String[] { kmf.format(wqkm[2]), wf.format(wqkm[0]), qf.format(RiverUtils.roundQ(wqkm[1])), wOrQDesc, + RiverUtils.getLocationDescription(flys, wqkm[2]), gaugeName }); } /** * @deprecated Use {@link WaterlevelDescriptionBuilder} instead. */ @Deprecated - private String getDesc(WQKms wqkms, boolean isQ) - { - D4EArtifact flys = (D4EArtifact) master; + private String getDesc(final WQKms wqkms, final boolean isQ) { + final D4EArtifact flys = (D4EArtifact) this.master; String colDesc = ""; if (flys instanceof WINFOArtifact && isQ) { - colDesc = getCSVRowTitle((WINFOArtifact)flys, wqkms); - } - else if (!isQ) { - Double value = RiverUtils.getValueFromWQ(wqkms); - colDesc = (value != null) ? - Formatter.getWaterlevelW(context).format(value) : null; + colDesc = getCSVRowTitle((WINFOArtifact) flys, wqkms); + } else if (!isQ) { + final Double value = RiverUtils.getValueFromWQ(wqkms); + colDesc = (value != null) ? Formatter.getWaterlevelW(this.context).format(value) : null; } if (flys instanceof WINFOArtifact) { if (wqkms != null && wqkms.getRawValue() != null) { - WINFOArtifact winfo = (WINFOArtifact) flys; - colDesc = RiverUtils.getNamedMainValue( - winfo, wqkms.getRawValue()); + final WINFOArtifact winfo = (WINFOArtifact) flys; + colDesc = RiverUtils.getNamedMainValue(winfo, wqkms.getRawValue()); // For 'W am Pegel' s if (colDesc == null) { - Double value = RiverUtils.getValueFromWQ(wqkms); - colDesc = (value != null) ? - Formatter.getWaterlevelW(context).format(value) : null; + final Double value = RiverUtils.getValueFromWQ(wqkms); + colDesc = (value != null) ? Formatter.getWaterlevelW(this.context).format(value) : null; } } } if (colDesc != null) { - /* Quick hack. Can be removed when database strings are - * adapted or left in here as it should never be harmful. */ + /* + * Quick hack. Can be removed when database strings are + * adapted or left in here as it should never be harmful. + */ colDesc = colDesc.replace("Amtl.Festlegung_", "Amtl. "); } @@ -685,12 +569,7 @@ /** * Write "rows" of csv data from wqkms with writer. */ - protected void wQKms2CSV( - CSVWriter writer, - WQKms wqkms, - boolean atGauge, - boolean isQ - ) { + protected void wQKms2CSV(final CSVWriter writer, final WQKms wqkms, final boolean atGauge, final boolean isQ) { log.debug("WaterlevelExporter.wQKms2CSV"); // Skip constant data. @@ -698,38 +577,35 @@ return; } - NumberFormat kmf = getKmFormatter(); - NumberFormat wf = getWFormatter(); - NumberFormat qf = getQFormatter(); + final NumberFormat kmf = getKmFormatter(); + final NumberFormat wf = getWFormatter(); + final NumberFormat qf = getQFormatter(); - int size = wqkms.size(); + final int size = wqkms.size(); double[] result = new double[3]; - D4EArtifact flys = (D4EArtifact) master; - RangeAccess rangeAccess = new RangeAccess(flys); - - List<Gauge> gauges = RiverUtils.getGauges(flys); + final D4EArtifact flys = (D4EArtifact) this.master; + final RangeAccess rangeAccess = new RangeAccess(flys); - Gauge gauge = rangeAccess.getRiver().determineRefGauge( - rangeAccess.getKmRange(), rangeAccess.isRange()); + final List<Gauge> gauges = RiverUtils.getGauges(flys); - String gaugeName = gauge.getName(); - String desc = ""; - String notinrange = msg( - CSV_NOT_IN_GAUGE_RANGE, - DEFAULT_CSV_NOT_IN_GAUGE_RANGE); + final Gauge gauge = rangeAccess.getRiver().determineRefGauge(rangeAccess.getKmRange(), rangeAccess.isRange()); + + final String gaugeName = gauge.getName(); + String desc = ""; + final String notinrange = msg(CSV_NOT_IN_GAUGE_RANGE, DEFAULT_CSV_NOT_IN_GAUGE_RANGE); List<Segment> segments = null; boolean isFixRealize = false; - double a = gauge.getRange().getA().doubleValue(); - double b = gauge.getRange().getB().doubleValue(); - long startTime = System.currentTimeMillis(); + final double a = gauge.getRange().getA().doubleValue(); + final double b = gauge.getRange().getB().doubleValue(); + final long startTime = System.currentTimeMillis(); desc = getDesc(wqkms, isQ); if (flys instanceof FixationArtifact) { // Get W/Q input per gauge for this case. - FixRealizingAccess fixAccess = new FixRealizingAccess(flys); + final FixRealizingAccess fixAccess = new FixRealizingAccess(flys); segments = fixAccess.getSegments(); if (segments != null && !segments.isEmpty()) { isFixRealize = true; @@ -741,20 +617,16 @@ // Kms tend to be close together so caching the last sector // is a good time saving heuristic. Segment lastSegment = null; - Gauge lastGauge = null; + Gauge lastGauge = null; - NumberFormat nf = - Formatter.getFormatter(context.getMeta(), 0, 0); + final NumberFormat nf = Formatter.getFormatter(this.context.getMeta(), 0, 0); for (int i = 0; i < size; ++i) { result = wqkms.get(i, result); - double km = result[2]; + final double km = result[2]; if (segments != null) { - Segment found = lastSegment != null - && lastSegment.inside(km) - ? lastSegment - : findSegment(km, segments); + final Segment found = lastSegment != null && lastSegment.inside(km) ? lastSegment : findSegment(km, segments); if (found != null) { desc = nf.format(found.getValues()[0]); @@ -764,67 +636,55 @@ String gaugeN; if (isFixRealize) { - Gauge found = lastGauge != null - && lastGauge.getRange().contains(km) - ? lastGauge - : findGauge(km, gauges); + final Gauge found = lastGauge != null && lastGauge.getRange().contains(km) ? lastGauge : findGauge(km, gauges); gaugeN = found != null ? found.getName() : notinrange; lastGauge = found; - } - else { + } else { // TODO issue1114: Take correct gauge - gaugeN = km >= a && km <= b - ? gaugeName - : notinrange; + gaugeN = km >= a && km <= b ? gaugeName : notinrange; } writeRow6(writer, result, desc, flys, gaugeN); } - } - else { // Not at gauge. + } else { // Not at gauge. for (int i = 0; i < size; ++i) { result = wqkms.get(i, result); writeRow4(writer, result, flys); } } - long stopTime = System.currentTimeMillis(); + final long stopTime = System.currentTimeMillis(); if (log.isDebugEnabled()) { - log.debug("Writing CSV took " + - (float)(stopTime-startTime)/1000f + " secs."); + log.debug("Writing CSV took " + (stopTime - startTime) / 1000f + " secs."); } } - /** * Generates the output in WST format. */ - protected void generateWST() - throws IOException - { + protected void generateWST() throws IOException { log.info("WaterlevelExporter.generateWST"); - int cols = data.get(0).length + officalFixings.size(); - WstWriter writer = new WstWriter(cols); + final int cols = this.data.get(0).length + this.officalFixings.size(); + final WstWriter writer = new WstWriter(cols); writeWSTData(writer); - writer.write(out); + writer.write(this.out); } - - protected void writeWSTData(WstWriter writer) { + protected void writeWSTData(final WstWriter writer) { log.debug("WaterlevelExporter.writeWSTData"); double[] result = new double[4]; - for (WQKms[] tmp: data) { - for (WQKms wqkms: tmp) { + for (final WQKms[] tmp : this.data) { + for (final WQKms wqkms : tmp) { if (wqkms instanceof ConstantWQKms) { continue; } - int size = wqkms != null ? wqkms.size() : 0; + final int size = wqkms != null ? wqkms.size() : 0; addWSTColumn(writer, wqkms); @@ -850,21 +710,21 @@ // // There was some confusion how to implement this. see flys/issue1620 // for details. - for (WQKms wqkms: officalFixings) { + for (final WQKms wqkms : this.officalFixings) { // To add some spaces here or to add them in the writer,.. writer.addColumn(getDesc(wqkms, true)); // Get all lines from the calculation - Map <Double, WstLine> calcLines = writer.getLines(); + final Map<Double, WstLine> calcLines = writer.getLines(); // All KM values where we have a point for - TDoubleArrayList officialKms = wqkms.allKms(); + final TDoubleArrayList officialKms = wqkms.allKms(); - for (Map.Entry<Double, WstLine> entry : calcLines.entrySet()) { + for (final Map.Entry<Double, WstLine> entry : calcLines.entrySet()) { // Bad for perfomance but the user can wait a bit for WST // so lets not spend time optimizing too much,.. *hides* - double km = entry.getKey().doubleValue(); - int idx = officialKms.indexOf(km); + final double km = entry.getKey().doubleValue(); + final int idx = officialKms.indexOf(km); if (idx != -1) { entry.getValue().add(wqkms.getW(idx), wqkms.getQ(idx)); } @@ -872,7 +732,6 @@ } } - /** * Register a new column at <i>writer</i>. The name / * title of the column depends on the Q or W value of <i>wqkms</i>. If a Q @@ -880,72 +739,68 @@ * the named main value. Otherwise, the name returned by * <i>WQKms.getName()</i> is set. * - * @param writer The WstWriter. - * @param wqkms The new WST column. + * @param writer + * The WstWriter. + * @param wqkms + * The new WST column. */ - protected void addWSTColumn(WstWriter writer, WQKms wqkms) { + protected void addWSTColumn(final WstWriter writer, final WQKms wqkms) { if (wqkms instanceof ConstantWQKms) { return; } - if (master instanceof WINFOArtifact) { - writer.addColumn(getColumnTitle((WINFOArtifact) master, wqkms)); - } - else { + if (this.master instanceof WINFOArtifact) { + writer.addColumn(getColumnTitle((WINFOArtifact) this.master, wqkms)); + } else { writer.addColumn(wqkms.getName()); } } - @Override - protected void writePDF(OutputStream out) { + protected void writePDF(final OutputStream out) { log.debug("write PDF"); - WKmsJRDataSource source = createJRData(); + final WKmsJRDataSource source = createJRData(); - String jasperFile = Resources.getMsg( - context.getMeta(), - JASPER_FILE, - "/jasper/waterlevel_en.jasper"); - String confPath = Config.getConfigDirectory().toString(); + final String jasperFile = // "/jasper/waterlevel_en.jasper"; + Resources.getMsg(this.context.getMeta(), JASPER_FILE, "/jasper/waterlevel_en.jasper"); + final String confPath = Config.getConfigDirectory().toString(); - - Map parameters = new HashMap(); + final Map parameters = new HashMap(); parameters.put("ReportTitle", "Exported Data"); try { - JasperPrint print = JasperFillManager.fillReport( - confPath + jasperFile, - parameters, - source); + final JasperPrint print = JasperFillManager.fillReport(confPath + jasperFile, parameters, source); JasperExportManager.exportReportToPdfStream(print, out); } - catch(JRException je) { + catch (final JRException je) { log.warn("Error generating PDF Report!", je); } } protected WKmsJRDataSource createJRData() { - WKmsJRDataSource source = new WKmsJRDataSource(); + final WKmsJRDataSource source = new WKmsJRDataSource(); - WQ_MODE mode = RiverUtils.getWQMode((D4EArtifact)master); - boolean atGauge = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.WGAUGE; - boolean isQ = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.QFREE; + final WQ_MODE mode = RiverUtils.getWQMode((D4EArtifact) this.master); + final boolean atGauge = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.WGAUGE; + final boolean isQ = mode == WQ_MODE.QGAUGE || mode == WQ_MODE.QFREE; Double first = Double.NaN; Double last = Double.NaN; addMetaData(source); - for (WQKms[] tmp: data) { - for (WQKms wqkms: tmp) { + for (final WQKms[] tmp : this.data) { + for (final WQKms wqkms : tmp) { addWKmsData(wqkms, atGauge, isQ, source); - double[] firstLast = wqkms.getFirstLastKM(); + final double[] firstLast = wqkms.getFirstLastKM(); if (first.isNaN()) { /* Initialize */ first = firstLast[0]; last = firstLast[1]; } if (firstLast[0] > firstLast[1]) { - /* Calculating upstream we assert that it is + /* + * Calculating upstream we assert that it is * impossible that the direction changes during this - * loop */ + * loop + */ first = Math.max(first, firstLast[0]); last = Math.min(last, firstLast[1]); } else if (firstLast[0] < firstLast[1]) { @@ -958,44 +813,35 @@ } /* Append the official fixing at the bottom */ - for (WQKms wqkms: officalFixings) { + for (final WQKms wqkms : this.officalFixings) { addWKmsData(filterWQKms(wqkms, first, last), atGauge, isQ, source); } return source; } - protected void addMetaData(WKmsJRDataSource source) { - CallMeta meta = context.getMeta(); - - D4EArtifact flys = (D4EArtifact) master; + protected void addMetaData(final WKmsJRDataSource source) { + final CallMeta meta = this.context.getMeta(); - source.addMetaData ("river", RiverUtils.getRivername(flys)); + final D4EArtifact flys = (D4EArtifact) this.master; - Locale locale = Resources.getLocale(meta); - DateFormat df = DateFormat.getDateInstance(DateFormat.SHORT, locale); - NumberFormat kmf = getKmFormatter(); + source.addMetaData("river", RiverUtils.getRivername(flys)); + + final Locale locale = Resources.getLocale(meta); + final DateFormat df = DateFormat.getDateInstance(DateFormat.SHORT, locale); + final NumberFormat kmf = getKmFormatter(); source.addMetaData("date", df.format(new Date())); - RangeAccess rangeAccess = new RangeAccess(flys); - double[] kms = rangeAccess.getKmRange(); - source.addMetaData("range", - kmf.format(kms[0]) + " - " + kmf.format(kms[kms.length-1])); + final RangeAccess rangeAccess = new RangeAccess(flys); + final double[] kms = rangeAccess.getKmRange(); + source.addMetaData("range", kmf.format(kms[0]) + " - " + kmf.format(kms[kms.length - 1])); source.addMetaData("gauge", RiverUtils.getGaugename(flys)); - source.addMetaData("calculation", Resources.getMsg( - locale, - PDF_HEADER_MODE, - "Waterlevel")); + source.addMetaData("calculation", Resources.getMsg(locale, PDF_HEADER_MODE, "Waterlevel")); } - protected void addWKmsData( - WQKms wqkms, - boolean atGauge, - boolean isQ, - WKmsJRDataSource source) - { + protected void addWKmsData(final WQKms wqkms, final boolean atGauge, final boolean isQ, final WKmsJRDataSource source) { log.debug("WaterlevelExporter.addWKmsData"); // Skip constant data. @@ -1003,65 +849,44 @@ return; } - NumberFormat kmf = getKmFormatter(); - NumberFormat wf = getWFormatter(); - NumberFormat qf = getQFormatter(); + final NumberFormat kmf = getKmFormatter(); + final NumberFormat wf = getWFormatter(); + final NumberFormat qf = getQFormatter(); - int size = wqkms.size(); + final int size = wqkms.size(); double[] result = new double[3]; - D4EArtifact flys = (D4EArtifact) master; - RangeAccess rangeAccess = new RangeAccess(flys); - - Gauge gauge = rangeAccess.getRiver().determineRefGauge( - rangeAccess.getKmRange(), rangeAccess.isRange()); + final D4EArtifact flys = (D4EArtifact) this.master; + final RangeAccess rangeAccess = new RangeAccess(flys); - String gaugeName = gauge.getName(); - String desc = ""; - String notinrange = msg( - CSV_NOT_IN_GAUGE_RANGE, - DEFAULT_CSV_NOT_IN_GAUGE_RANGE); + final Gauge gauge = rangeAccess.getRiver().determineRefGauge(rangeAccess.getKmRange(), rangeAccess.isRange()); - double a = gauge.getRange().getA().doubleValue(); - double b = gauge.getRange().getB().doubleValue(); + final String gaugeName = gauge.getName(); + String desc = ""; + final String notinrange = msg(CSV_NOT_IN_GAUGE_RANGE, DEFAULT_CSV_NOT_IN_GAUGE_RANGE); + + final double a = gauge.getRange().getA().doubleValue(); + final double b = gauge.getRange().getB().doubleValue(); desc = getDesc(wqkms, isQ); - long startTime = System.currentTimeMillis(); + final long startTime = System.currentTimeMillis(); - for (int i = 0; i < size; i ++) { + for (int i = 0; i < size; i++) { result = wqkms.get(i, result); if (atGauge) { - source.addData(new String[] { - kmf.format(result[2]), - wf.format(result[0]), - qf.format(RiverUtils.roundQ(result[1])), - desc, - RiverUtils.getLocationDescription(flys, result[2]), - result[2] >= a && result[2] <= b - ? gaugeName - : notinrange - }); - } - else { - source.addData(new String[] { - kmf.format(result[2]), - wf.format(result[0]), - qf.format(RiverUtils.roundQ(result[1])), - desc, - RiverUtils.getLocationDescription(flys, result[2]), - result[2] >= a && result[2] <= b - ? gaugeName - : notinrange - }); + source.addData(new String[] { kmf.format(result[2]), wf.format(result[0]), qf.format(RiverUtils.roundQ(result[1])), desc, + RiverUtils.getLocationDescription(flys, result[2]), result[2] >= a && result[2] <= b ? gaugeName : notinrange }); + } else { + source.addData(new String[] { kmf.format(result[2]), wf.format(result[0]), qf.format(RiverUtils.roundQ(result[1])), desc, + RiverUtils.getLocationDescription(flys, result[2]), result[2] >= a && result[2] <= b ? gaugeName : notinrange }); } } - long stopTime = System.currentTimeMillis(); + final long stopTime = System.currentTimeMillis(); if (log.isDebugEnabled()) { - log.debug("Writing PDF data took " + - (float)(stopTime-startTime)/1000f + " secs."); + log.debug("Writing PDF data took " + (stopTime - startTime) / 1000f + " secs."); } } }