Mercurial > dive4elements > river
comparison backend/src/main/java/org/dive4elements/river/importer/parsers/W80CSVParser.java @ 8200:9d2e69f971f5
sed -i src/**/*.java 's/logger/log/g'
author | Sascha L. Teichmann <teichmann@intevation.de> |
---|---|
date | Fri, 05 Sep 2014 12:50:33 +0200 |
parents | 3bb1c62ad732 |
children | 8ce2d749f0a7 |
comparison
equal
deleted
inserted
replaced
8199:42ac86ec19c7 | 8200:9d2e69f971f5 |
---|---|
34 * To create cross-sections, generate: Map<double,list<xy>> from files | 34 * To create cross-sections, generate: Map<double,list<xy>> from files |
35 * in w80/csv format. | 35 * in w80/csv format. |
36 */ | 36 */ |
37 public class W80CSVParser extends LineParser implements CrossSectionParser | 37 public class W80CSVParser extends LineParser implements CrossSectionParser |
38 { | 38 { |
39 /** Private logger. */ | 39 /** Private log. */ |
40 private static Logger logger = Logger.getLogger(W80CSVParser.class); | 40 private static Logger log = Logger.getLogger(W80CSVParser.class); |
41 | 41 |
42 | 42 |
43 /** The current line to which add points. */ | 43 /** The current line to which add points. */ |
44 private List<XY> currentLine; | 44 private List<XY> currentLine; |
45 | 45 |
140 && file.getName().toLowerCase().endsWith(".csv") | 140 && file.getName().toLowerCase().endsWith(".csv") |
141 && (callback == null || callback.accept(file))) { | 141 && (callback == null || callback.accept(file))) { |
142 reset(); | 142 reset(); |
143 try { | 143 try { |
144 parse(file); | 144 parse(file); |
145 logger.info("parsing done"); | 145 log.info("parsing done"); |
146 if (callback != null) { | 146 if (callback != null) { |
147 callback.parsed(W80CSVParser.this); | 147 callback.parsed(W80CSVParser.this); |
148 } | 148 } |
149 } | 149 } |
150 catch (IOException ioe) { | 150 catch (IOException ioe) { |
151 logger.error("IOException while parsing file"); | 151 log.error("IOException while parsing file"); |
152 return false; | 152 return false; |
153 } | 153 } |
154 } | 154 } |
155 return true; | 155 return true; |
156 } | 156 } |
261 gkRightKm = Double.parseDouble(gkRight.replace(",","."));//.substring(0,7)); | 261 gkRightKm = Double.parseDouble(gkRight.replace(",","."));//.substring(0,7)); |
262 gkHighKm = Double.parseDouble(gkHigh.replace(",","."));//.substring(0,7)); | 262 gkHighKm = Double.parseDouble(gkHigh.replace(",","."));//.substring(0,7)); |
263 heightM = Double.parseDouble(height.replace(",",".")); | 263 heightM = Double.parseDouble(height.replace(",",".")); |
264 } | 264 } |
265 catch (java.lang.NumberFormatException nfe) { | 265 catch (java.lang.NumberFormatException nfe) { |
266 logger.error("Skipping malformed w80csv line #" + lineNum); | 266 log.error("Skipping malformed w80csv line #" + lineNum); |
267 return; | 267 return; |
268 } | 268 } |
269 | 269 |
270 // New (or first) line. | 270 // New (or first) line. |
271 if (anchor == null || !anchor.sameStation(stationKm)) { | 271 if (anchor == null || !anchor.sameStation(stationKm)) { |
277 currentLine.add(new XY(0d, heightM, 0)); | 277 currentLine.add(new XY(0d, heightM, 0)); |
278 try { | 278 try { |
279 anchorDate = DateGuesser.guessDate(date); | 279 anchorDate = DateGuesser.guessDate(date); |
280 } | 280 } |
281 catch (IllegalArgumentException iae) { | 281 catch (IllegalArgumentException iae) { |
282 logger.warn("W80CSV: Invalid date '" + date + "'."); | 282 log.warn("W80CSV: Invalid date '" + date + "'."); |
283 } | 283 } |
284 } | 284 } |
285 else { | 285 else { |
286 addPoint(gkRightKm, gkHighKm, heightM, pointIndex); | 286 addPoint(gkRightKm, gkHighKm, heightM, pointIndex); |
287 } | 287 } |
289 | 289 |
290 | 290 |
291 /** Called when file is fully consumed. */ | 291 /** Called when file is fully consumed. */ |
292 @Override | 292 @Override |
293 protected void finish() { | 293 protected void finish() { |
294 logger.info("Parsed " + data.size() + " lines"); | 294 log.info("Parsed " + data.size() + " lines"); |
295 } | 295 } |
296 | 296 |
297 | 297 |
298 /** Parses files given as arguments. */ | 298 /** Parses files given as arguments. */ |
299 public static void main(String [] args) { | 299 public static void main(String [] args) { |
300 | 300 |
301 W80CSVParser parser = new W80CSVParser(); | 301 W80CSVParser parser = new W80CSVParser(); |
302 | 302 |
303 logger.warn("Start parsing files."); | 303 log.warn("Start parsing files."); |
304 for (String arg: args) { | 304 for (String arg: args) { |
305 logger.warn("Parsing a file."); | 305 log.warn("Parsing a file."); |
306 parser.parseW80CSVs(new File(arg), null); | 306 parser.parseW80CSVs(new File(arg), null); |
307 } | 307 } |
308 logger.error("Finished parsing files."); | 308 log.error("Finished parsing files."); |
309 } | 309 } |
310 } | 310 } |
311 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : | 311 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : |