package cz.frantovo.nekurak.dao;

import cz.frantovo.nekurak.dto.Podnik;

import cz.frantovo.nekurak.dto.VysledekHlasovani;

import cz.frantovo.superDAO.SuperDAO;

import java.math.BigInteger;

import java.util.Collection;

import java.util.Date;

import java.util.List;

import javax.ejb.LocalBean;

import javax.ejb.Stateless;

import javax.persistence.EntityManager;

import javax.persistence.PersistenceContext;

import javax.persistence.Query;

/**

 *

 * @author fiki

 */

@Stateless

@LocalBean

public class PodnikDAO extends SuperDAO {

    @PersistenceContext(unitName = DAO.PU)

    private EntityManager em;

    private enum SQL {

	HLASOVANI_INSERT,

	HLASOVANI_SELECT

    }

    public Collection<Podnik> getPodniky() {

	Query dotaz = em.createQuery("FROM " + DAO.t(Podnik.class) + " o ORDER BY datum DESC");

	return dotaz.getResultList();

    }

    /**

     * @return podniky, které nemají souřadnice (null, null)

     */

    public Collection<Podnik> getPodnikyBezSouradnic() {

	Query dotaz = em.createQuery("FROM " + DAO.t(Podnik.class) + " o WHERE sirka IS NULL AND delka IS NULL");

	return dotaz.getResultList();

    }

    public Podnik getPodnik(int id) {

	return em.find(Podnik.class, id);

    }

    public void zaloz(Podnik p) {

	if (p.getDatum() == null) {

	    p.setDatum(new Date());

	}

	em.persist(p);

    }

    public void uloz(Podnik p) {

	if (p.getDatum() == null) {

	    p.setDatum(new Date());

	}

	em.merge(p);

    }

    public void hlasuj(int podnik, boolean hlas, String ipAdresa) {

	Query insert = em.createNativeQuery(getSQL(SQL.HLASOVANI_INSERT));

	insert.setParameter("podnik", podnik);

	insert.setParameter("hlas", hlas);

	insert.setParameter("ip_adresa", ipAdresa);

	insert.executeUpdate();

    }

    public VysledekHlasovani getVysledekHlasovani(int podnik) {

	VysledekHlasovani vysledek = new VysledekHlasovani();

	Query select = em.createNativeQuery(getSQL(SQL.HLASOVANI_SELECT));

	select.setParameter("podnik", podnik);

	List<Object[]> vysledekDotazu = select.getResultList();

	log.severe("Vracím výsledky pro podnik: " + podnik);

	for (Object[] radek : vysledekDotazu) {

	    /** Transponujeme výsledek dotazu */

	    if ((Boolean) radek[0]) {

		vysledek.setHlasuAno((Integer) radek[1]);

	    } else {

		vysledek.setHlasuNe((Integer) radek[1]);

	    }

	}

	return vysledek;

    }

}