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();

 	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;

     }

 }