view backend/src/main/java/org/dive4elements/river/importer/sinfo/parsers/BedMobilityParser.java @ 9658:d86c7cb68b41

Importer (s/u-info) extensions: daily discharge: detecting, logging and skipping lines with missing date or q, or duplicate date, detecting wrong column titles and cancelling the import, specific error message if gauge not found
author mschaefer
date Mon, 23 Mar 2020 15:33:40 +0100
parents dd93bb84561d
children
line wrap: on
line source
/* Copyright (C) 2017 by Bundesanstalt für Gewässerkunde
 * Software engineering by
 *  Björnsen Beratende Ingenieure GmbH
 *  Dr. Schumacher Ingenieurbüro für Wasser und Umwelt
 *
 * This file is Free Software under the GNU AGPL (>=v3)
 * and comes with ABSOLUTELY NO WARRANTY! Check out the
 * documentation coming with Dive4Elements River for details.
 */

package org.dive4elements.river.importer.sinfo.parsers;

import java.io.File;
import java.util.ArrayList;
import java.util.List;

import org.apache.log4j.Logger;
import org.dive4elements.river.importer.Config;
import org.dive4elements.river.importer.ImportRiver;
import org.dive4elements.river.importer.common.AbstractParser;
import org.dive4elements.river.importer.common.ParsingState;
import org.dive4elements.river.importer.sinfo.importitem.BedMobilityKmLineImport;
import org.dive4elements.river.importer.sinfo.importitem.BedMobilitySeriesImport;
import org.dive4elements.river.model.sinfo.BedMobility;
import org.dive4elements.river.model.sinfo.BedMobilityValue;

/**
 * Reads and parses an bed mobility file
 *
 * @author Matthias Schäfer
 *
 */
public class BedMobilityParser extends AbstractParser<BedMobility, BedMobilityValue, BedMobilityKmLineImport, BedMobilitySeriesImport> {

    /***** FIELDS *****/

    private static final Logger log = Logger.getLogger(BedMobilityParser.class);

    private static final String MOBILE_KEYWORD = "mobil";

    private static final String STARR_KEYWORD = "starr";

    private static final String IMPORT_FILENAME = "Einteilung_der_Gewaessersohle.csv";


    /***** CONSTRUCTORS *****/

    public BedMobilityParser(final File importPath, final File rootRelativePath, final ImportRiver river) {
        super(importPath, rootRelativePath, river);
    }


    /***** METHODS *****/

    @Override
    protected Logger getLog() {
        return log;
    }

    /**
     * Whether this import type shall be skipped
     */
    public static boolean shallSkip() {
        return Config.INSTANCE.skipSInfoBedMobility();
    }

    /**
     * Creates a list of parsers for all bed mobility import files in a directory
     */
    public static List<BedMobilityParser> createParsers(final File importDir, final File relativeDir, final ImportRiver river) {
        final List<BedMobilityParser> parsers = new ArrayList<>();
        final File importFile = new File(importDir, IMPORT_FILENAME);
        if (importFile.exists())
            parsers.add(new BedMobilityParser(importFile, new File(relativeDir, IMPORT_FILENAME), river));
        return parsers;
    }

    @Override
    protected BedMobilitySeriesImport createSeriesImport(final String filename) {
        return new BedMobilitySeriesImport(filename);
    }

    @Override
    protected BedMobilityKmLineImport createKmLineImport(final Double km, final String[] values) {
        if (values[1].equalsIgnoreCase(STARR_KEYWORD))
            return new BedMobilityKmLineImport(km, false);
        else if (values[1].equalsIgnoreCase(MOBILE_KEYWORD))
            return new BedMobilityKmLineImport(km, values[1].equalsIgnoreCase(MOBILE_KEYWORD));
        logLineError("Invalid Gewässersohle value");
        this.headerParsingState = ParsingState.STOP;
        return null;
    }

    @Override
    protected boolean handleMetaOther() {
        return super.handleMetaOther();
    }
}

http://dive4elements.wald.intevation.org