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,

         IP_ADRESY_OBDOBI,

         IP_PREKLAD

     }

     /**

      * 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 zacatek, Date konec) {

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

         Connection dbSouhrn = getSpojeni(null);

         if (konec == null) {

             konec = zacatek;

         }

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

             /** TODO: Chyba spojení */

         } else {

             PreparedStatement ps = null;

             PreparedStatement psSmazat = null;

             ResultSet rs = null;

             try {

                 /** 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, zacatek);

                 psSmazat.setDate(3, konec);

                 psSmazat.executeUpdate();

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

                 ps.setDate(1, zacatek);

                 ps.setDate(2, konec);

                 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, rs.getDate("den"));

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

                     psSouhrn.setString(3, null);

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

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

                     psSouhrn.executeUpdate();

                 }

                 zavri(null, psSouhrn, null);

                 /**

                  * Přeložíme všechny IP adresy daného období

                  * a aktualizujeme domény všude (i jiné cíle a jiná období).

                  */

                 PreparedStatement psIPselekt = dbSouhrn.prepareStatement(getSQL(SQL.IP_ADRESY_OBDOBI));

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

                 psIPselekt.setDate(2, zacatek);

                 psIPselekt.setDate(3, konec);

                 PreparedStatement psIPupdate = dbSouhrn.prepareStatement(getSQL(SQL.IP_PREKLAD));

                 ResultSet rsIP = psIPselekt.executeQuery();

                 while (rsIP.next()) {

                     String ip = rsIP.getString("ip");

                     String domena = prelozIP(ip);

                     psIPupdate.setString(1, domena);

                     psIPupdate.setString(2, ip);

                     psIPupdate.executeUpdate();

                 }

                 zavri(null, psIPselekt, null);

                 zavri(null, psIPupdate, null);

                 /**

                  * Pokud se všechno povedlo, commitujeme, jinak nedochází k žádným změnám.

                  * Dané období se buď vygeneruje úspěšně, nebo vůbec.

                  * Přepokládáme vypnutý autocommit (to zajišťuje aplikační server).

                  */

                 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 za dané období.

      * @param zacatek začátek období – včetně

      * @param konec konec období – včetně

      */

     public void generujSouhrny(Date zacatek, Date konec) {

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

         for (Cil c : cile) {

             generujSouhrn(c, zacatek, konec);

         }

     }

     /**

      * 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.";

         }

     }

 }