/* 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.importitem;

import java.util.Date;
import java.util.List;

import org.apache.log4j.Logger;
import org.dive4elements.river.importer.ImporterSession;
import org.dive4elements.river.importer.common.StoreMode;
import org.dive4elements.river.model.River;
import org.dive4elements.river.model.sinfo.Tkh;
import org.hibernate.Query;
import org.hibernate.Session;

/**
 * Imported Transportkörperhöhe data series group of a river
 *
 * @author Matthias Schäfer
 *
 */
public class TkhSeriesImport {

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

    private static Logger log = Logger.getLogger(TkhSeriesImport.class);

    /**
     * Name of the imported file without type extension
     */
    private final String filename;

    private String kmrange_info;

    private String comment;

    private Date day;

    private String sounding_info;

    private String evaluation_by;

    private Tkh peer;

    private StoreMode storeMode;


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

    public TkhSeriesImport(final String filename) {
        this.filename = filename;
    }


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

    public String getFilename() {
        return this.filename;
    }

    public String getKmrange_info() {
        return this.kmrange_info;
    }

    public void setKmrange_info(final String kmrange_info) {
        this.kmrange_info = kmrange_info;
    }

    public String getComment() {
        return this.comment;
    }

    public void setComment(final String comment) {
        this.comment = comment;
    }

    public Date getDay() {
        return this.day;
    }

    public void setDay(final Date day) {
        this.day = day;
    }

    public String getSounding_info() {
        return this.sounding_info;
    }

    public void setSounding_info(final String sounding_info) {
        this.sounding_info = sounding_info;
    }

    public String getEvaluation_by() {
        return this.evaluation_by;
    }

    public void setEvaluation_by(final String evaluation_by) {
        this.evaluation_by = evaluation_by;
    }

    public StoreMode getStoreMode() {
        return this.storeMode;
    }

    /**
     * Gets the model object of the data series group, inserting it into the database if not already existing
     */
    public Tkh getPeer(final River river) {
        if (this.peer != null) {
            this.storeMode = StoreMode.NONE;
            return this.peer;
        }
        final Session session = ImporterSession.getInstance().getDatabaseSession();
        final List<Tkh> rows = querySeriesItem(session, river);
        if (rows.isEmpty()) {
            log.info("Create new database instance");
            this.peer = createSeriesItem(river);
            session.save(this.peer);
            this.storeMode = StoreMode.INSERT;
        }
        else {
            this.peer = rows.get(0);
            this.storeMode = StoreMode.UPDATE;
        }
        return this.peer;
    }

    private List<Tkh> querySeriesItem(final Session session, final River river) {
        final Query query = session.createQuery("FROM Tkh WHERE river=:river AND lower(filename)=:filename");
        query.setParameter("river", river);
        query.setParameter("filename", this.filename.toLowerCase());
        return query.list();
    }

    private Tkh createSeriesItem(final River river) {
        return new Tkh(river, this.filename, this.kmrange_info, this.comment, this.day, this.sounding_info, this.evaluation_by);
    }
}