Mercurial > dive4elements > river
comparison flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 5027:25c180fa6162
Use BWASTRParser to set official numbers on rivers.
| author | Felix Wolfsteller <felix.wolfsteller@intevation.de> |
|---|---|
| date | Tue, 19 Feb 2013 16:41:00 +0100 |
| parents | 443c173f043a |
| children | e6dc908297e8 |
comparison
equal
deleted
inserted
replaced
| 5021:bf22086747bc | 5027:25c180fa6162 |
|---|---|
| 295 parseSedimentYield(); | 295 parseSedimentYield(); |
| 296 parseWaterlevels(); | 296 parseWaterlevels(); |
| 297 parseWaterlevelDifferences(); | 297 parseWaterlevelDifferences(); |
| 298 parseMeasurementStations(); | 298 parseMeasurementStations(); |
| 299 parseSQRelation(); | 299 parseSQRelation(); |
| 300 storeOfficialNumber(); | |
| 300 } | 301 } |
| 301 | 302 |
| 302 public void parseFloodProtection() throws IOException { | 303 public void parseFloodProtection() throws IOException { |
| 303 if (Config.INSTANCE.skipFloodProtection()) { | 304 if (Config.INSTANCE.skipFloodProtection()) { |
| 304 log.info("skip parsing flood protection"); | 305 log.info("skip parsing flood protection"); |
| 339 iw.setDescription(FLOOD_PROTECTION + "/" + iw.getDescription()); | 340 iw.setDescription(FLOOD_PROTECTION + "/" + iw.getDescription()); |
| 340 floodProtection.add(iw); | 341 floodProtection.add(iw); |
| 341 } | 342 } |
| 342 } | 343 } |
| 343 | 344 |
| 345 public void storeOfficialNumber() { | |
| 346 if (Config.INSTANCE.skipBWASTR()) { | |
| 347 log.info("skip storing official number."); | |
| 348 return; | |
| 349 } | |
| 350 getPeer().setOfficialNumber(officialNumber); | |
| 351 } | |
| 344 | 352 |
| 345 public void parseBedHeight() throws IOException { | 353 public void parseBedHeight() throws IOException { |
| 346 File minfoDir = getMinfoDir(); | 354 File minfoDir = getMinfoDir(); |
| 347 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR); | 355 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR); |
| 348 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR); | 356 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR); |
| 1445 public River getPeer() { | 1453 public River getPeer() { |
| 1446 if (peer == null) { | 1454 if (peer == null) { |
| 1447 Session session = ImporterSession.getInstance().getDatabaseSession(); | 1455 Session session = ImporterSession.getInstance().getDatabaseSession(); |
| 1448 Query query = session.createQuery("from River where name=:name"); | 1456 Query query = session.createQuery("from River where name=:name"); |
| 1449 | 1457 |
| 1450 Unit u = wstUnit.getPeer(); | 1458 Unit u = null; |
| 1459 if (wstUnit != null) { | |
| 1460 u = wstUnit.getPeer(); | |
| 1461 } | |
| 1451 | 1462 |
| 1452 query.setString("name", name); | 1463 query.setString("name", name); |
| 1453 List<River> rivers = query.list(); | 1464 List<River> rivers = query.list(); |
| 1454 if (rivers.isEmpty()) { | 1465 if (rivers.isEmpty()) { |
| 1455 log.info("Store new river '" + name + "'"); | 1466 log.info("Store new river '" + name + "'"); |
| 1456 peer = new River(name, u); | 1467 peer = new River(name, u); |
| 1468 if (!Config.INSTANCE.skipBWASTR()) { | |
| 1469 peer.setOfficialNumber(officialNumber); | |
| 1470 } | |
| 1457 session.save(peer); | 1471 session.save(peer); |
| 1458 } | 1472 } |
| 1459 else { | 1473 else { |
| 1460 peer = rivers.get(0); | 1474 peer = rivers.get(0); |
| 1461 } | 1475 } |