dive4elements/river: flys-aft/src/main/java/de/intevation/aft/River.java annotate

annotate flys-aft/src/main/java/de/intevation/aft/River.java @ 4754:04377ccef10a

AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river.

author	Sascha L. Teichmann <teichmann@intevation.de>
date	Thu, 03 Jan 2013 14:39:48 +0100
parents	a310aceb2e51
children	f939e1e6cfa4

rev	line source
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 package de.intevation.aft;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	3 import java.util.List;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	4 import java.util.ArrayList;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	5 import java.util.HashMap;
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	6 import java.util.Map;
0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	7
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	8 import java.sql.ResultSet;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 import java.sql.SQLException;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 import org.apache.log4j.Logger;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	12
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	13 import de.intevation.db.ConnectedStatements;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	14 import de.intevation.db.SymbolicStatement;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	16 public class River
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	17 extends IdPair
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18 {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 private static Logger log = Logger.getLogger(River.class);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	20
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	21 protected String name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	22
4753 a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	23 protected double from;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	24 protected double to;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	25
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	26 public River() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28
4753 a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	29 public River(int id1, String name, double from, double to) {
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	30 super(id1);
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	31 this.name = name;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	32 this.from = from;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	33 this.to = to;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	34 }
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	35
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	36 public River(int id1, int id2, String name) {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37 super(id1, id2);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	38 this.name = name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	40
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	41 public String getName() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	42 return name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	43 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	44
4753 a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	45 public double getFrom() {
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	46 return from;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	47 }
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	48
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	49 public void setFrom(double from) {
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	50 this.from = from;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	51 }
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	52
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	53 public double getTo() {
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	54 return to;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	55 }
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	56
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	57 public void setTo(double to) {
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	58 this.to = to;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	59 }
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	60
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	61 public boolean inside(double x) {
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	62 return x >= from && x <= to;
a310aceb2e51 Fetch calculation range (Berechnungsstrecke) for FLYS rivers, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	63 }
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	64
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	65 public boolean sync(SyncContext context) throws SQLException {
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	66 log.info("sync river: " + this);
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	67
4084 9178beeb7b05 Moved DIPS gauge number -> DIPS gauge index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4083 diff changeset	68 Map<Long, DIPSGauge> dipsGauges = context.getDIPSGauges();
4081 7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	69
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	70 ConnectedStatements flysStatements = context.getFlysStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	71 ConnectedStatements aftStatements = context.getAftStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	72
4754 04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	73 String riverName = getName();
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	74
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	75 Map<Long, DIPSGauge> aftDIPSGauges = new HashMap<Long, DIPSGauge>();
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	76
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	77 ResultSet messstellenRs = aftStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	78 .getStatement("select.messstelle")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	79 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	80 .setInt("GEWAESSER_NR", id2).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	81
4754 04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	82 try {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	83 while (messstellenRs.next()) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	84 String name = messstellenRs.getString("NAME");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	85 String num = messstellenRs.getString("MESSSTELLE_NR");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	86 double station = messstellenRs.getDouble("STATIONIERUNG");
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	87
4754 04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	88 if (messstellenRs.wasNull()) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	89 log.warn("AFT: STATION of MESSSTELLE '"+name+"' is NULL -> ignored.");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	90 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	91 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	92
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	93 if (!inside(station)) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	94 log.warn("AFT: MESSSTELLE '"+name+"' out of calculation range -> ignored.");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	95 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	96 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	97
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	98 Long number = SyncContext.numberToLong(num);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	99 if (number == null) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	100 log.warn("AFT: Invalid MESSSTELLE_NR for MESSSTELLE '"+name+"'");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	101 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	102 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	103 DIPSGauge dipsGauge = dipsGauges.get(number);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	104 if (dipsGauge == null) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	105 log.warn(
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	106 "DIPS: MESSSTELLE '" + name + "' not found in DIPS. " +
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	107 "Gauge number used for lookup: " + number);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	108 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	109 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	110 String gaugeRiver = dipsGauge.getRiverName();
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	111 if (!gaugeRiver.equalsIgnoreCase(riverName)) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	112 log.warn(
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	113 "DIPS: MESSSTELLE '" + name +
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	114 "' is assigned to river '" + gaugeRiver +
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	115 "'. Needs to be on '" + riverName + "'.");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	116 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	117 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	118 dipsGauge.setAftName(name);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	119 dipsGauge.setOfficialNumber(number);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	120 aftDIPSGauges.put(number, dipsGauge);
4081 7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	121 }
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	122 }
4754 04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	123 finally {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	124 messstellenRs.close();
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	125 }
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	126
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	127 List<DIPSGauge> updateGauges = new ArrayList<DIPSGauge>();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	128
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	129 ResultSet gaugesRs = flysStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	130 .getStatement("select.gauges")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	131 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	132 .setInt("river_id", id1).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	133
4754 04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	134 try {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	135 while (gaugesRs.next()) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	136 int gaugeId = gaugesRs.getInt("id");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	137 String name = gaugesRs.getString("name");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	138 long number = gaugesRs.getLong("official_number");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	139 if (gaugesRs.wasNull()) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	140 log.warn("FLYS: Gauge '" + name +
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	141 "' has no official number. Ignored.");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	142 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	143 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	144 Long key = Long.valueOf(number);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	145 DIPSGauge aftDIPSGauge = aftDIPSGauges.remove(key);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	146 if (aftDIPSGauge == null) {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	147 log.warn("FLYS: Gauge '" + name + "' number " + number +
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	148 " is not found in AFT/DIPS.");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	149 continue;
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	150 }
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	151 aftDIPSGauge.setFlysId(gaugeId);
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	152 log.info("Gauge '" + name +
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	153 "' found in FLYS, AFT and DIPS. -> Update");
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	154 updateGauges.add(aftDIPSGauge);
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	155 }
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	156 }
4754 04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	157 finally {
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	158 gaugesRs.close();
04377ccef10a AFT: Reject AFT gauges which are not inside the calculation range of the corresponding FLYS river. Sascha L. Teichmann <teichmann@intevation.de> parents: 4753 diff changeset	159 }
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	160
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	161 boolean modified = createGauges(context, aftDIPSGauges);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	162
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	163 modified \|= updateGauges(context, updateGauges);
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	164
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	165 return modified;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	166 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	167
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	168 protected boolean updateGauges(
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	169 SyncContext context,
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	170 List<DIPSGauge> gauges
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	171 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	172 throws SQLException
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	173 {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	174 boolean modified = false;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	175
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	176 for (DIPSGauge gauge: gauges) {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	177 modified \|= updateGauge(context, gauge);
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	178 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	179
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	180 return modified;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	181 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	182
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	183 protected boolean updateGauge(
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	184 SyncContext context,
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	185 DIPSGauge gauge
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	186 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	187 throws SQLException
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	188 {
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	189 log.info("FLYS: Updating gauge '" + gauge.getAftName() + "'.");
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	190 // We need to load all discharge tables from both database
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	191 // of the gauge and do some pairing based on their descriptions.
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	192
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	193 boolean modified = false;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	194
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	195 ConnectedStatements flysStatements = context.getFlysStatements();
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	196
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	197 flysStatements.beginTransaction();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	198 try {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	199 List<DischargeTable> flysDTs =
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	200 DischargeTable.loadFlysDischargeTables(
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	201 context, gauge.getFlysId());
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	202
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	203 List<DischargeTable> aftDTs =
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	204 DischargeTable.loadAftDischargeTables(
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	205 context, gauge.getOfficialNumber());
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	206
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	207 Map<String, DischargeTable> desc2FlysDT =
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	208 new HashMap<String, DischargeTable>();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	209
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	210 for (DischargeTable dt: flysDTs) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	211 String description = dt.getDescription();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	212 if (description == null) {
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	213 log.warn("FLYS: discharge table " + dt.getId()
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	214 + " has no description. Ignored.");
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	215 continue;
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	216 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	217 desc2FlysDT.put(description, dt);
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	218 }
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	219
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	220 List<DischargeTable> createDTs = new ArrayList<DischargeTable>();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	221
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	222 for (DischargeTable aftDT: aftDTs) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	223 String description = aftDT.getDescription();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	224 DischargeTable flysDT = desc2FlysDT.remove(description);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	225 if (flysDT != null) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	226 // Found in AFT and FLYS.
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	227 log.info("FLYS: Discharge table '" + description
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	228 + "' found in AFT and FLYS. -> update");
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	229 // Create the W/Q diff.
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	230 modified \|= writeWQChanges(context, flysDT, aftDT);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	231 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	232 else {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	233 log.info("FLYS: Discharge table '" + description
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	234 + "' not found in FLYS. -> create");
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	235 createDTs.add(aftDT);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	236 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	237 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	238
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	239 for (String description: desc2FlysDT.keySet()) {
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	240 log.info("FLYS: Discharge table '" + description
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	241 + "' found in FLYS but not in AFT. -> ignore");
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	242 }
9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	243
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	244 log.info("FLYS: Copy " + createDTs.size() +
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	245 " discharge tables over from AFT.");
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	246
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	247 // Create the new discharge tables.
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	248 for (DischargeTable aftDT: createDTs) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	249 createDischargeTable(context, aftDT, gauge.getFlysId());
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	250 modified = true;
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	251 }
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	252
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	253 flysStatements.commitTransaction();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	254 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	255 catch (SQLException sqle) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	256 flysStatements.rollbackTransaction();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	257 log.error(sqle, sqle);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	258 modified = false;
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	259 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	260
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	261 return modified;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	262 }
4079 42094f01afa6 Added model for DIPS gauges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4078 diff changeset	263
4099 006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	264 protected boolean writeWQChanges(
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	265 SyncContext context,
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	266 DischargeTable flysDT,
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	267 DischargeTable aftDT
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	268 )
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	269 throws SQLException
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	270 {
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	271 flysDT.loadFlysValues(context);
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	272 aftDT.loadAftValues(context);
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	273 WQDiff diff = new WQDiff(flysDT.getValues(), aftDT.getValues());
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	274 if (diff.hasChanges()) {
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	275 diff.writeChanges(context, flysDT.getId());
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	276 return true;
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	277 }
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	278 return false;
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	279 }
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	280
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	281 protected boolean createGauges(
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	282 SyncContext context,
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	283 Map<Long, DIPSGauge> gauges
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	284 )
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	285 throws SQLException
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	286 {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	287 ConnectedStatements flysStatements = context.getFlysStatements();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	288
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	289 SymbolicStatement.Instance nextId =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	290 flysStatements.getStatement("next.gauge.id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	291
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	292 SymbolicStatement.Instance insertStmnt =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	293 flysStatements.getStatement("insert.gauge");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	294
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	295 boolean modified = false;
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	296
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	297 for (Map.Entry<Long, DIPSGauge> entry: gauges.entrySet()) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	298 Long officialNumber = entry.getKey();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	299 DIPSGauge gauge = entry.getValue();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	300
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	301 log.info("Gauge '" + gauge.getAftName() +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	302 "' not in FLYS but in AFT/DIPS. -> Create");
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	303
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	304 if (!gauge.hasDatums()) {
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	305 log.warn("DIPS: Gauge '" +
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	306 gauge.getAftName() + "' has no datum. Ignored.");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	307 continue;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	308 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	309
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	310 ResultSet rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	311 flysStatements.beginTransaction();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	312 try {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	313 (rs = nextId.executeQuery()).next();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	314 int gaugeId = rs.getInt("gauge_id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	315 rs.close(); rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	316
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	317 insertStmnt
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	318 .clearParameters()
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	319 .setInt("id", gaugeId)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	320 .setString("name", gauge.getAftName())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	321 .setInt("river_id", id1)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	322 .setDouble("station", gauge.getStation())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	323 .setDouble("aeo", gauge.getAeo())
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	324 .setLong("official_number", officialNumber)
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	325 .setDouble("datum", gauge.getLatestDatum().getValue());
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	326
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	327 insertStmnt.execute();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	328
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	329 log.info("FLYS: Created gauge '" + gauge.getAftName() +
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	330 "' with id " + gaugeId + ".");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	331
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	332 gauge.setFlysId(gaugeId);
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	333 createDischargeTables(context, gauge);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	334 flysStatements.commitTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	335 modified = true;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	336 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	337 catch (SQLException sqle) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	338 flysStatements.rollbackTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	339 log.error(sqle, sqle);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	340 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	341 finally {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	342 if (rs != null) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	343 rs.close();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	344 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	345 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	346 }
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	347
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	348 return modified;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	349 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	350
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	351 protected void createDischargeTable(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	352 SyncContext context,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	353 DischargeTable aftDT,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	354 int flysGaugeId
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	355 )
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	356 throws SQLException
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	357 {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	358 aftDT.persistFlysTimeInterval(context);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	359 int flysId = aftDT.persistFlysDischargeTable(context, flysGaugeId);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	360
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	361 aftDT.loadAftValues(context);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	362 aftDT.storeFlysValues(context, flysId);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	363 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	364
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	365 protected void createDischargeTables(
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	366 SyncContext context,
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	367 DIPSGauge gauge
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	368 )
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	369 throws SQLException
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	370 {
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	371 log.info("FLYS: Create discharge tables for '" +
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	372 gauge.getAftName() + "'.");
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	373
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	374 // Load the discharge tables from AFT.
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	375 List<DischargeTable> dts = loadAftDischargeTables(
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	376 context, gauge);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	377
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	378 // Persist the time intervals.
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	379 persistFlysTimeIntervals(context, dts);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	380
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	381 // Persist the discharge tables
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	382 int [] flysDTIds = persistFlysDischargeTables(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	383 context, dts, gauge.getFlysId());
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	384
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	385 // Copy over the W/Q values
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	386 copyWQsFromAftToFlys(context, dts, flysDTIds);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	387 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	388
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	389 protected List<DischargeTable> loadAftDischargeTables(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	390 SyncContext context,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	391 DIPSGauge gauge
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	392 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	393 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	394 {
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	395 return DischargeTable.loadAftDischargeTables(
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	396 context, gauge.getOfficialNumber(), gauge.getFlysId());
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	397 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	398
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	399 protected void persistFlysTimeIntervals(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	400 SyncContext context,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	401 List<DischargeTable> dts
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	402 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	403 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	404 {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	405 for (DischargeTable dt: dts) {
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	406 dt.persistFlysTimeInterval(context);
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	407 }
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	408 }
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	409
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	410 protected int [] persistFlysDischargeTables(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	411 SyncContext context,
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	412 List<DischargeTable> dts,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	413 int flysGaugeId
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	414 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	415 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	416 {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	417 int [] flysDTIds = new int[dts.size()];
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	418
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	419 for (int i = 0; i < flysDTIds.length; ++i) {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	420 flysDTIds[i] = dts.get(i)
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	421 .persistFlysDischargeTable(context, flysGaugeId);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	422 }
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	423
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	424 return flysDTIds;
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	425 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	426
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	427 protected void copyWQsFromAftToFlys(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	428 SyncContext context,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	429 List<DischargeTable> dts,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	430 int [] flysDTIds
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	431 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	432 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	433 {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	434 for (int i = 0; i < flysDTIds.length; ++i) {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	435 DischargeTable dt = dts.get(i);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	436 dt.loadAftValues(context);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	437 dt.storeFlysValues(context, flysDTIds[i]);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	438 dt.clearValues(); // To save memory.
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	439 }
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	440 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	441
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	442 public String toString() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	443 return "[River: name=" + name + ", " + super.toString() + "]";
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	444 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	445 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	446 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate flys-aft/src/main/java/de/intevation/aft/River.java @ 4754:04377ccef10a