Mercurial > dive4elements > river

comparison backend/src/main/java/org/dive4elements/river/importer/parsers/SedimentLoadParser.java @ 8412:17db08570637

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
SCHEMA CHANGE: removed superfluous columns station and river_id from measurement_stations and adapted other components accordingly.
author Tom Gottfried <tom@intevation.de>
date Wed, 15 Oct 2014 19:20:26 +0200
parents 3ae11daff343
children 9db1f48bfea9
comparison
equal deleted inserted replaced
8411:b8c6cb36607e 8412:17db08570637
17 17
18 import org.dive4elements.river.importer.ImporterSession; 18 import org.dive4elements.river.importer.ImporterSession;
19 import org.dive4elements.river.importer.ImportSedimentLoad; 19 import org.dive4elements.river.importer.ImportSedimentLoad;
20 import org.dive4elements.river.importer.ImportSedimentLoadValue; 20 import org.dive4elements.river.importer.ImportSedimentLoadValue;
21 21
22 import org.dive4elements.river.model.River;
22 import org.dive4elements.river.model.MeasurementStation; 23 import org.dive4elements.river.model.MeasurementStation;
23 24
24 /** Parses sediment load longitudinal section files. */ 25 /** Parses sediment load longitudinal section files. */
25 public class SedimentLoadParser extends AbstractSedimentLoadParser { 26 public class SedimentLoadParser extends AbstractSedimentLoadParser {
26 private static final Logger log = 27 private static final Logger log =
37 38
38 protected List<ImportSedimentLoad> sedimentLoads; 39 protected List<ImportSedimentLoad> sedimentLoads;
39 40
40 protected ImportSedimentLoad[] current; 41 protected ImportSedimentLoad[] current;
41 42
42 protected String rivername; 43 protected River river;
43 44
44 public SedimentLoadParser() { 45 public SedimentLoadParser() {
45 sedimentLoads = new ArrayList<ImportSedimentLoad>(); 46 sedimentLoads = new ArrayList<ImportSedimentLoad>();
46 } 47 }
47 48
48 public SedimentLoadParser(String rivername) { 49 public SedimentLoadParser(River river) {
49 sedimentLoads = new ArrayList<ImportSedimentLoad>(); 50 sedimentLoads = new ArrayList<ImportSedimentLoad>();
50 this.rivername = rivername; 51 this.river = river;
51 } 52 }
52 53
53 54
54 55
55 @Override 56 @Override
114 try { 115 try {
115 Double km = nf.parse(vals[0]).doubleValue(); 116 Double km = nf.parse(vals[0]).doubleValue();
116 117
117 List<MeasurementStation> ms = 118 List<MeasurementStation> ms =
118 ImporterSession.getInstance().getMeasurementStations( 119 ImporterSession.getInstance().getMeasurementStations(
119 rivername, km); 120 river, km);
120 121
121 String gfn = grainFraction.getPeer().getName(); 122 String gfn = grainFraction.getPeer().getName();
122 123
123 if (ms != null && !ms.isEmpty()) { 124 if (ms != null && !ms.isEmpty()) {
124 125
143 return; 144 return;
144 } 145 }
145 } 146 }
146 log.error("SLP: No measurement station at km " + km + 147 log.error("SLP: No measurement station at km " + km +
147 " fitting grain fraction " + gfn + 148 " fitting grain fraction " + gfn +
148 " on river " + rivername); 149 " on river " + river.getName());
149 return; 150 return;
150 } 151 }
151 else { 152 else {
152 log.error("SLP: No measurement station at km " + km + 153 log.error("SLP: No measurement station at km " + km +
153 " on river " + rivername); 154 " on river " + river.getName());
154 return; 155 return;
155 } 156 }
156 } 157 }
157 catch (ParseException pe) { 158 catch (ParseException pe) {
158 log.warn("SLP: unparseable number in data row '" + line + "':", pe); 159 log.warn("SLP: unparseable number in data row '" + line + "':", pe);
http://dive4elements.wald.intevation.org