sascha@4075: package de.intevation.aft;
sascha@4075: 
sascha@4078: import java.util.Map;
sascha@4078: import java.util.HashMap;
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@4078: import org.w3c.dom.Document;
sascha@4078: import org.w3c.dom.NodeList;
sascha@4078: import org.w3c.dom.Element;
sascha@4078: 
sascha@4075: import de.intevation.db.ConnectedStatements;
sascha@4075: 
sascha@4079: import java.util.regex.Matcher;
sascha@4079: import java.util.regex.Pattern;
sascha@4079: 
sascha@4075: public class River
sascha@4075: extends      IdPair
sascha@4075: {
sascha@4075:     private static Logger log = Logger.getLogger(River.class);
sascha@4075: 
sascha@4079:     public static final Pattern NUMBER = Pattern.compile("0*([0-9]+)");
sascha@4079: 
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@4079:     public static Long numberToLong(String s) {
sascha@4079:         Matcher m = NUMBER.matcher(s);
sascha@4079:         if (!m.matches()) return null;
sascha@4079:         String ns = m.group(1);
sascha@4079:         return Long.valueOf(ns.length() == 0 ? "0": ns);
sascha@4079:     }
sascha@4079: 
sascha@4079:     public static Map<Long, DIPSGauge> indexByNumber(Document document) {
sascha@4079:         Map<Long, DIPSGauge> map = new HashMap<Long, DIPSGauge>();
sascha@4078:         NodeList nodes = document.getElementsByTagName("PEGELSTATION");
sascha@4078:         for (int i = nodes.getLength()-1; i >= 0; --i) {
sascha@4078:             Element element = (Element)nodes.item(i);
sascha@4079:             Long number = numberToLong(element.getAttribute("NUMMER"));
sascha@4079:             if (number != null) {
sascha@4079:                 map.put(number, new DIPSGauge(element));
sascha@4079:             }
sascha@4078:         }
sascha@4078:         return map;
sascha@4078:     }
sascha@4078: 
sascha@4077:     public void sync(SyncContext context) throws SQLException {
sascha@4075:         log.info("sync river: " + this);
sascha@4077: 
sascha@4081:         Map<Long, DIPSGauge> dipsGauges = indexByNumber(context.getDips());
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@4076:         while (messstellenRs.next()) {
sascha@4076:             String name = messstellenRs.getString("NAME");
sascha@4076:             String num  = messstellenRs.getString("MESSSTELLE_NR");
sascha@4081:             Long number = 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@4081:             if (dipsGauges == null) {
sascha@4081:                 log.warn("MESSSTELLE '" + name + "' not found in DIPS.");
sascha@4081:                 continue;
sascha@4081:             }
sascha@4076:         }
sascha@4076: 
sascha@4076:         messstellenRs.close();
sascha@4076: 
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@4076:             System.err.println(name + ": " + gaugeId);
sascha@4076:         }
sascha@4076: 
sascha@4076:         gaugesRs.close();
sascha@4079: 
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 :