Mercurial > dive4elements > river
comparison flys-aft/src/main/java/de/intevation/aft/River.java @ 5188:2b7f44c80857
Stations are now filtered by DiPS not AFT.
author | Sascha L. Teichmann <teichmann@intevation.de> |
---|---|
date | Thu, 07 Mar 2013 12:46:37 +0100 |
parents | d9f1202cef78 |
children | da1e897c7224 |
comparison
equal
deleted
inserted
replaced
5187:eec78b9f73b8 | 5188:2b7f44c80857 |
---|---|
63 } | 63 } |
64 | 64 |
65 public boolean sync(SyncContext context) throws SQLException { | 65 public boolean sync(SyncContext context) throws SQLException { |
66 log.info("sync river: " + this); | 66 log.info("sync river: " + this); |
67 | 67 |
68 Map<Long, DIPSGauge> dipsGauges = context.getDIPSGauges(); | 68 // Only take relevant gauges into account. |
69 Map<Long, DIPSGauge> dipsGauges = context.getDIPSGauges(name, from, to); | |
69 | 70 |
70 ConnectedStatements flysStatements = context.getFlysStatements(); | 71 ConnectedStatements flysStatements = context.getFlysStatements(); |
71 ConnectedStatements aftStatements = context.getAftStatements(); | 72 ConnectedStatements aftStatements = context.getAftStatements(); |
72 | 73 |
73 String riverName = getName(); | 74 String riverName = getName(); |
76 | 77 |
77 ResultSet messstellenRs = aftStatements | 78 ResultSet messstellenRs = aftStatements |
78 .getStatement("select.messstelle") | 79 .getStatement("select.messstelle") |
79 .clearParameters() | 80 .clearParameters() |
80 .setInt("GEWAESSER_NR", id2) | 81 .setInt("GEWAESSER_NR", id2) |
81 .setDouble("START_KM", from) | |
82 .setDouble("END_KM", to) | |
83 .executeQuery(); | 82 .executeQuery(); |
84 | 83 |
85 try { | 84 try { |
86 while (messstellenRs.next()) { | 85 while (messstellenRs.next()) { |
87 String name = messstellenRs.getString("NAME"); | 86 String name = messstellenRs.getString("NAME"); |
88 String num = messstellenRs.getString("MESSSTELLE_NR"); | 87 String num = messstellenRs.getString("MESSSTELLE_NR"); |
88 double station = messstellenRs.getDouble("STATIONIERUNG"); | |
89 | |
90 if (!messstellenRs.wasNull() && station < from && station > to) { | |
91 log.warn("Station found in AFT but in range: " + station); | |
92 continue; | |
93 } | |
89 | 94 |
90 Long number = SyncContext.numberToLong(num); | 95 Long number = SyncContext.numberToLong(num); |
91 if (number == null) { | 96 if (number == null) { |
92 log.warn("AFT: Invalid MESSSTELLE_NR for MESSSTELLE '"+name+"'"); | 97 log.warn("AFT: Invalid MESSSTELLE_NR for MESSSTELLE '"+name+"'"); |
93 continue; | 98 continue; |