dive4elements/river: flys-backend/src/main/java/de/intevation/flys/importer/AtFileParser.java annotate

author	Ingo Weinzierl <ingo.weinzierl@intevation.de>
date	Tue, 22 Mar 2011 12:15:18 +0000
parents
children	6b231041dc18

rev	line source
198 d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	1 package de.intevation.flys.importer;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	2
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	3 import java.io.BufferedReader;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	4 import java.io.File;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	5 import java.io.FileInputStream;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	6 import java.io.InputStreamReader;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	7 import java.io.IOException;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	8 import java.math.BigDecimal;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	9 import java.text.NumberFormat;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	10 import java.text.ParseException;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	11
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	12 import org.apache.log4j.Logger;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	13
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	14 import de.intevation.flys.importer.ImportDischargeTable;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	15 import de.intevation.flys.importer.ImportDischargeTableValue;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	16
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	17
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	18 public class AtFileParser {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	19
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	20 public static final String ENCODING = "ISO-8859-1";
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	21
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	22 private static Logger logger = Logger.getLogger(AtFileParser.class);
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	23
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	24 private static NumberFormat nf = NumberFormat.getInstance();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	25
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	26
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	27 public AtFileParser() {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	28 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	29
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	30
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	31 public ImportDischargeTable parse(ImportGauge gauge) throws IOException {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	32
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	33 File file = gauge.getAtFile();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	34
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	35 logger.info("parsing AT file: " + file);
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	36
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	37 BufferedReader br = null;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	38
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	39 String line = null;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	40
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	41 boolean beginning = true;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	42
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	43 ImportDischargeTable dischargeTable = new ImportDischargeTable();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	44
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	45 try {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	46 br = new BufferedReader(
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	47 new InputStreamReader(
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	48 new FileInputStream(file), ENCODING));
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	49
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	50 while ((line = br.readLine()) != null) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	51 String tmp = line.trim();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	52
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	53 if (tmp.length() == 0) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	54 continue;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	55 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	56
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	57 if (tmp.startsWith("#! name=")) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	58 // XXX Skip the name, because we don't know where to save
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	59 // it at the moment
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	60
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	61 //String name = tmp.substring(8);
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	62 continue;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	63 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	64
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	65 if (tmp.startsWith("#") \|\| tmp.startsWith("*")) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	66 continue;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	67 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	68
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	69 String[] splits = tmp.replace(',', '.').split("\\s+");
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	70
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	71 if ((splits.length < 2) \|\| (splits.length > 11)) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	72 logger.warn("Found an invalid row in the AT file.");
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	73 continue;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	74 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	75
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	76 String strW = splits[0].trim();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	77 double W = nf.parse(strW).doubleValue();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	78
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	79 /* shift is used to differenciate between lines with
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	80 * exactly 10 Qs and lines with less than 10 Qs. The shift
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	81 * is only modified when it is the first line.
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	82 */
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	83 int shift = 0;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	84
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	85 if (splits.length != 11 && beginning) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	86 shift = 11 - splits.length;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	87 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	88
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	89
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	90 for (int i = 1; i < splits.length; i++) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	91 double iW = W + shift + i;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	92 double iQ = nf.parse(splits[i].trim()).doubleValue();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	93
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	94 dischargeTable.addDischargeTableValue(
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	95 new ImportDischargeTableValue(
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	96 new BigDecimal(iQ/100.0),
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	97 new BigDecimal(iW/100.0)));
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	98 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	99
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	100 beginning = false;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	101 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	102 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	103 catch (ParseException pe) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	104 logger.warn(pe.getMessage());
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	105 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	106 finally {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	107 if (br != null) {
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	108 br.close();
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	109 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	110 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	111
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	112 logger.info("Finished parsing AT file: " + file);
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	113
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	114 return dischargeTable;
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	115 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	116 }
d980e545ccab Added import code for importing discharge tables. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: diff changeset	117 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

198

d980e545ccab Added import code for importing discharge tables.