package cz.frantovo.hrisniciSpameri.dao;

import cz.frantovo.hrisniciSpameri.dto.Cil;

import java.net.InetAddress;

import java.sql.Connection;

import java.sql.Date;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.util.Collection;

import java.util.logging.Level;

/**

 *

 * @author fiki

 */

public class GeneratorSouhrnuDAO extends HrisniciSuperDAO {

    private enum SQL {

        VLOZ_SOUHRN,

        SMAZ_SOUHRNY

    }

    /**

     * Vygeneruje souhrn pro daný cíl a datum a uloží ho do databáze

     * @param cil cíl, pro který generujeme souhrn

     * @param den den, pro který souhrn generujeme.

     */

    public void generujSouhrn(Cil cil, Date den) {

        Connection dbZdroj = getSpojeni(cil.getDatabaze());

        Connection dbSouhrn = getSpojeni(null);

        if (dbZdroj == null || dbSouhrn == null) {

            /** TODO: Chyba spojení */

        } else {

            PreparedStatement ps = null;

            PreparedStatement psSmazat = null;

            ResultSet rs = null;

            try {

                log.log(Level.SEVERE, "AUTOCOMIT: " + dbSouhrn.getAutoCommit());

                dbSouhrn.setAutoCommit(false);

                /** pokud už něco vygenerovaného pro daný den a cíl máme, smažeme to */

                psSmazat = dbSouhrn.prepareStatement(getSQL(SQL.SMAZ_SOUHRNY));

                psSmazat.setInt(1, cil.getId());

                psSmazat.setDate(2, den);

                psSmazat.executeUpdate();

                ps = dbZdroj.prepareStatement(cil.getSelekt());

                ps.setDate(1, den);

                rs = ps.executeQuery();

                PreparedStatement psSouhrn = dbSouhrn.prepareStatement(getSQL(SQL.VLOZ_SOUHRN));

                while (rs.next()) {

                    /**

                     * Souhrn bychom mohli vkládat pomocí SouhrnDAO,

                     * ale z výkonnostních důvodů to budeme dělat tady

                     * (jedno spojení a jeden předpřipravený příkaz).

                     */

                    psSouhrn.setDate(1, den);

                    psSouhrn.setString(2, rs.getString("ip"));

                    psSouhrn.setString(3, prelozIP(rs.getString("ip")));

                    psSouhrn.setInt(4, rs.getInt("pocet"));

                    psSouhrn.setInt(5, cil.getId());

                    psSouhrn.executeUpdate();

                }

                zavri(null, psSouhrn, null);

                dbSouhrn.commit();

            } catch (Exception e) {

                log.log(Level.SEVERE, "Chyba při generování souhrnu.", e);

            } finally {

                zavri(dbZdroj, ps, rs);

                zavri(dbSouhrn, psSmazat, null);

            }

        }

    }

    /**

     * Vygeneruje denní souhrny pro všechny cíle.

     * @param den den, pro který souhrny generujeme.

     */

    public void generujSouhrny(Date den) {

        if (den == null) {

            den = SouhrnDAO.getVychoziDen();

        }

        Collection<Cil> cile = new CilDAO().getCile();

        for (Cil c : cile) {

            generujSouhrn(c, den);

        }

    }

    /**

     * Přeloží IP adresu na doménu

     * @param ip IP adresa

     * @return doména

     */

    private static String prelozIP(String ip) {

        try {

            return InetAddress.getByName(ip).getHostName();

        } catch (Exception e) {

            return "Chyba: nepodařilo se přeložit.";

        }

    }

}