sascha@4075: package de.intevation.aft;
sascha@4075: 
sascha@4085: import java.util.List;
sascha@4085: import java.util.ArrayList;
sascha@4085: import java.util.HashMap;
sascha@4078: import java.util.Map;
sascha@4078: 
sascha@4076: import java.sql.ResultSet;
sascha@4075: import java.sql.SQLException;
sascha@4075: 
sascha@4075: import org.apache.log4j.Logger;
sascha@4075: 
sascha@4075: import de.intevation.db.ConnectedStatements;
sascha@4075: 
sascha@4075: public class River
sascha@4075: extends      IdPair
sascha@4075: {
sascha@4075:     private static Logger log = Logger.getLogger(River.class);
sascha@4075: 
sascha@4075:     protected String name;
sascha@4075: 
sascha@4075:     public River() {
sascha@4075:     }
sascha@4075: 
sascha@4075:     public River(int id1, int id2, String name) {
sascha@4075:         super(id1, id2);
sascha@4075:         this.name = name;
sascha@4075:     }
sascha@4075: 
sascha@4075:     public String getName() {
sascha@4075:         return name;
sascha@4075:     }
sascha@4075: 
sascha@4078: 
sascha@4077:     public void sync(SyncContext context) throws SQLException {
sascha@4075:         log.info("sync river: " + this);
sascha@4077: 
sascha@4084:         Map<Long, DIPSGauge> dipsGauges = context.getDIPSGauges();
sascha@4081: 
sascha@4077:         ConnectedStatements flysStatements = context.getFlysStatements();
sascha@4077:         ConnectedStatements aftStatements  = context.getAftStatements();
sascha@4077: 
sascha@4076:         ResultSet messstellenRs = aftStatements
sascha@4076:             .getStatement("select.messstelle")
sascha@4076:             .clearParameters()
sascha@4076:             .setInt("GEWAESSER_NR", id2).executeQuery();
sascha@4076: 
sascha@4085:         String riverName = getName();
sascha@4085: 
sascha@4085:         Map<Long, DIPSGauge> aftDIPSGauges = new HashMap<Long, DIPSGauge>();
sascha@4085: 
sascha@4076:         while (messstellenRs.next()) {
sascha@4076:             String name = messstellenRs.getString("NAME");
sascha@4076:             String num  = messstellenRs.getString("MESSSTELLE_NR");
sascha@4084:             Long number = SyncContext.numberToLong(num);
sascha@4081:             if (number == null) {
sascha@4081:                 log.warn("Invalid MESSSTELLE_NR for MESSSTELLE '"+name+"'");
sascha@4081:                 continue;
sascha@4081:             }
sascha@4081:             DIPSGauge dipsGauge = dipsGauges.get(number);
sascha@4085:             if (dipsGauge == null) {
sascha@4085:                 log.warn(
sascha@4085:                     "MESSSTELLE '" + name + "' not found in DIPS. " +
sascha@4085:                     "Gauge number used for lookup: " + number);
sascha@4081:                 continue;
sascha@4081:             }
sascha@4085:             String gaugeRiver = dipsGauge.getRiverName();
sascha@4085:             if (!gaugeRiver.equalsIgnoreCase(riverName)) {
sascha@4085:                 log.warn(
sascha@4085:                     "MESSSTELLE '" + name + 
sascha@4085:                     "' is assigned to river '" + gaugeRiver + 
sascha@4085:                     "'. Needs to be on '" + riverName + "'.");
sascha@4085:                 continue;
sascha@4085:             }
sascha@4085:             dipsGauge.setAftName(name);
sascha@4085:             aftDIPSGauges.put(number, dipsGauge);
sascha@4076:         }
sascha@4076: 
sascha@4076:         messstellenRs.close();
sascha@4076: 
sascha@4085: 
sascha@4085:         List<DIPSGauge> updateGauges = new ArrayList<DIPSGauge>();
sascha@4085: 
sascha@4076:         ResultSet gaugesRs = flysStatements
sascha@4076:             .getStatement("select.gauges")
sascha@4076:             .clearParameters()
sascha@4076:             .setInt("river_id", id1).executeQuery();
sascha@4076: 
sascha@4076:         while (gaugesRs.next()) {
sascha@4076:             int gaugeId = gaugesRs.getInt("id");
sascha@4076:             String name = gaugesRs.getString("name");
sascha@4085:             long   number = gaugesRs.getLong("official_number");
sascha@4085:             if (gaugesRs.wasNull()) {
sascha@4085:                 log.warn("FLYS: Gauge '" + name + 
sascha@4085:                     "' has no official number. Ignored.");
sascha@4085:                 continue;
sascha@4085:             }
sascha@4085:             Long key = Long.valueOf(number);
sascha@4085:             DIPSGauge aftDIPSGauge = aftDIPSGauges.remove(key);
sascha@4085:             if (aftDIPSGauge == null) {
sascha@4085:                 log.warn("FLYS: Gauge '" + name + "' number " + number +
sascha@4085:                     " is not found in AFT/DIPS.");
sascha@4085:                 continue;
sascha@4085:             }
sascha@4085:             aftDIPSGauge.setFlysId(gaugeId);
sascha@4085:             log.info("Gauge '" + name +
sascha@4085:                 "' found in FLYS, AFT and DIPS. -> Update");
sascha@4085:             updateGauges.add(aftDIPSGauge);
sascha@4076:         }
sascha@4076: 
sascha@4076:         gaugesRs.close();
sascha@4079: 
sascha@4085:         for (DIPSGauge gauge: aftDIPSGauges.values()) {
sascha@4085:             log.info("Gauge '" + gauge.getAftName() +
sascha@4085:                 "' not in FLYS but in AFT/DIPS. -> Create");
sascha@4085:         }
sascha@4075:     }
sascha@4075: 
sascha@4075:     public String toString() {
sascha@4075:         return "[River: name=" + name + ", " + super.toString() + "]";
sascha@4075:     }
sascha@4075: 
sascha@4075: }
sascha@4075: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :