Mercurial > dive4elements > river

comparison backend/src/main/java/org/dive4elements/river/importer/uinfo/parsers/SalixParser.java @ 8971:50416a0df385

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Importer for the Schifffahrt (S-INFO) and Oekologie (U-INFO) files
author mschaefer
date Tue, 03 Apr 2018 10:18:30 +0200
parents
children ae76f618d990
comparison
equal deleted inserted replaced
8970:da5dc7446652 8971:50416a0df385
1 /* Copyright (C) 2017 by Bundesanstalt für Gewässerkunde
2 * Software engineering by
3 * Björnsen Beratende Ingenieure GmbH
4 * Dr. Schumacher Ingenieurbüro für Wasser und Umwelt
5 *
6 * This file is Free Software under the GNU AGPL (>=v3)
7 * and comes with ABSOLUTELY NO WARRANTY! Check out the
8 * documentation coming with Dive4Elements River for details.
9 */
10
11 package org.dive4elements.river.importer.uinfo.parsers;
12
13 import java.io.File;
14 import java.util.ArrayList;
15 import java.util.EnumMap;
16 import java.util.List;
17 import java.util.regex.Matcher;
18 import java.util.regex.Pattern;
19
20 import org.apache.log4j.Logger;
21 import org.dive4elements.river.importer.Config;
22 import org.dive4elements.river.importer.ImportRiver;
23 import org.dive4elements.river.importer.common.AbstractParser;
24 import org.dive4elements.river.importer.common.ParsingState;
25 import org.dive4elements.river.importer.uinfo.importitem.SalixKmLineImport;
26 import org.dive4elements.river.importer.uinfo.importitem.SalixSeriesImport;
27 import org.dive4elements.river.model.uinfo.Salix;
28 import org.dive4elements.river.model.uinfo.SalixValue;
29
30 /**
31 * Reads and parses a salix file
32 *
33 * @author Matthias Schäfer
34 *
35 */
36 public class SalixParser extends AbstractParser<Salix, SalixValue, SalixKmLineImport, SalixSeriesImport> {
37
38 /***** FIELDS *****/
39
40 private static final Logger log = Logger.getLogger(SalixParser.class);
41
42 private static final String IMPORT_FILENAME = "Salix-Linie.csv";
43
44 private static final Pattern META_EVALUATOR = Pattern.compile("^#\\sAuswerter:\\s*([^;]*).*", Pattern.CASE_INSENSITIVE);
45
46 private enum ColTitlePattern {
47 FACTOR("Salix.Fa.tor\\s*\\[(.*)\\].*"), //
48 MWMNW("\\(MW-MNW\\).*\\[(.*)\\].*");
49
50 private final Pattern pattern;
51
52 ColTitlePattern(final String regexp) {
53 this.pattern = Pattern.compile(regexp, Pattern.CASE_INSENSITIVE);
54 }
55
56 public Pattern getPattern() {
57 return this.pattern;
58 }
59 }
60
61 private final EnumMap<ColTitlePattern, Integer> cols = new EnumMap<>(ColTitlePattern.class);
62
63
64 /***** CONSTRUCTORS *****/
65
66 public SalixParser(final File importPath, final File rootRelativePath, final ImportRiver river) {
67 super(importPath, rootRelativePath, river);
68 }
69
70
71 /***** METHODS *****/
72
73 @Override
74 protected Logger getLog() {
75 return log;
76 }
77
78 /**
79 * Whether this import type shall be skipped
80 */
81 public static boolean shallSkip() {
82 return Config.INSTANCE.skipUInfoSalix();
83 }
84
85 /**
86 * Creates a list of parsers for all salix import files in a directory
87 */
88 public static List<SalixParser> createParsers(final File importDir, final File relativeDir, final ImportRiver river) {
89 final List<SalixParser> parsers = new ArrayList<>();
90 parsers.add(new SalixParser(new File(importDir, IMPORT_FILENAME), new File(relativeDir, IMPORT_FILENAME), river));
91 return parsers;
92 }
93
94 @Override
95 protected SalixSeriesImport createSeriesImport(final String filename) {
96 return new SalixSeriesImport(filename);
97 }
98
99 @Override
100 protected boolean handleMetaOther() {
101 if (handleMetaEvaluator())
102 return true;
103 else
104 return false;
105 }
106
107 private boolean handleMetaEvaluator() {
108 final Matcher m = META_EVALUATOR.matcher(this.currentLine);
109 if (m.matches()) {
110 this.metaPatternsMatched.add(META_EVALUATOR);
111 this.seriesHeader.setEvaluationBy(parseMetaInfo(m.group(1).trim()));
112 return true;
113 }
114 return false;
115 }
116
117 @Override
118 protected boolean handleMetaColumnTitles() {
119 if (!super.handleMetaColumnTitles())
120 return false;
121 for (final ColTitlePattern col : ColTitlePattern.values())
122 this.cols.put(col, -1);
123 for (int i = 1; i <= this.columnTitles.size() - 1; i++) {
124 for (final ColTitlePattern col : ColTitlePattern.values()) {
125 if (col.getPattern().matcher(this.columnTitles.get(i)).matches()) {
126 this.cols.put(col, i);
127 break;
128 }
129 }
130 }
131 if ((this.cols.get(ColTitlePattern.FACTOR) < 0) || (this.cols.get(ColTitlePattern.MWMNW) < 0)) {
132 logError("Column of the salix factor and/or mnw-mw-diff could not be identified");
133 this.headerParsingState = ParsingState.STOP;
134 return false;
135 }
136 return true;
137 }
138
139 @Override
140 protected SalixKmLineImport createKmLineImport(final Double km, final String[] values) {
141 if (Double.isNaN(parseDoubleWithNull(values[this.cols.get(ColTitlePattern.FACTOR)]).doubleValue())) {
142 logError("Salix factor not found in line " + this.in.getLineNumber());
143 return null;
144 }
145 if (Double.isNaN(parseDoubleWithNull(values[this.cols.get(ColTitlePattern.MWMNW)]).doubleValue())) {
146 logError("MNW-MW-diff not found in line " + this.in.getLineNumber());
147 return null;
148 }
149 return new SalixKmLineImport(km, parseDoubleWithNull(values[this.cols.get(ColTitlePattern.FACTOR)]).doubleValue(),
150 parseDoubleWithNull(values[this.cols.get(ColTitlePattern.MWMNW)]).doubleValue());
151 }
152 }
http://dive4elements.wald.intevation.org