Mercurial > dive4elements > river
diff flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 2840:71175502d868
Added a parser for sediment yield files; started parsing and store values in db.
flys-backend/trunk@4277 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author | Ingo Weinzierl <ingo.weinzierl@intevation.de> |
---|---|
date | Thu, 19 Apr 2012 12:48:53 +0000 |
parents | 163c037f2c7e |
children | c4db0f75a94a |
line wrap: on
line diff
--- a/flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java Thu Apr 19 07:34:50 2012 +0000 +++ b/flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java Thu Apr 19 12:48:53 2012 +0000 @@ -34,6 +34,7 @@ import de.intevation.flys.importer.parsers.AnnotationClassifier; import de.intevation.flys.importer.parsers.PegelGltParser; import de.intevation.flys.importer.parsers.SedimentDensityParser; +import de.intevation.flys.importer.parsers.SedimentYieldParser; import de.intevation.flys.importer.parsers.WstParser; import org.hibernate.Session; @@ -410,19 +411,41 @@ File[] singles = singleDir.listFiles(); File[] epochs = epochDir.listFiles(); + SedimentYieldParser parser = new SedimentYieldParser(); + if (singles == null || singles.length == 0) { log.warn("Cannot parse directory '" + singleDir + "'"); } else { - // TODO + for (File file: singles) { + if (file.isDirectory()) { + for (File child: file.listFiles()) { + parser.parse(child); + } + } + else { + parser.parse(file); + } + } } if (epochs == null || epochs.length == 0) { log.warn("Cannot parse directory '" + epochDir + "'"); } else { - // TODO + for (File file: epochs) { + if (file.isDirectory()) { + for (File child: file.listFiles()) { + parser.parse(child); + } + } + else { + parser.parse(file); + } + } } + + sedimentYields = parser.getSedimentYields(); }