package com.generali.eVP.dao._impl.akDAOImpl;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.math.NumberUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.dao.DataAccessException;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import com.generali.eVP.dao.akDAO.AkDAO;

import com.generali.eVP.model.ak.IzlazDohvatiPremiju;
import com.generali.eVP.model.ak.IzlazSteta;

import com.generali.eVP.model.ak.KaskoNovaPolica;
import com.generali.eVP.model.ak.KaskoStaraPolica;
import com.generali.eVP.model.ak.UlazDohvatiPremiju;
import com.generali.eVP.model.ak.UlazSteta;
import com.generali.eVP.model.ak.VoziloIzlaz;
import com.generali.eVP.model.ak.VoziloUlaz;

@Repository
public class AkDAOImpl implements AkDAO {

	private static final Logger LOGGER_AK = LoggerFactory.getLogger("ak");

	@Autowired
	@Qualifier("ins2JdbcTemplate")
	JdbcTemplate ins2jdbcTemplate;

	@Override
	public KaskoNovaPolica getForNovaPolica(KaskoStaraPolica staraPolica) {
		try {
		return ins2jdbcTemplate.queryForObject("SELECT * FROM EVP_V_KASKO_ZB WHERE SIFRA = ? ",new Object[] { staraPolica.getBrojPrethodnePolice() }, (rs, rowNum) -> {
							KaskoNovaPolica kaskoNew = new KaskoNovaPolica();
							if (StringUtils.isNotEmpty(rs.getString(3)))
								kaskoNew.setOsTipPrethodne(rs.getString(3));
							if (StringUtils.isNotEmpty(rs.getString(4)))
								kaskoNew.setBrojPrethodne(rs.getString(4));
							if (StringUtils.isNotEmpty(rs.getString(5)))
								kaskoNew.setOsTipMaster(rs.getString(5));
							if (StringUtils.isNotEmpty(rs.getString(6)))
								kaskoNew.setMaster(rs.getString(6));
							if (StringUtils.isNotEmpty(rs.getString(7)))
								kaskoNew.setPosrednik(rs.getString(7));
							if (StringUtils.isNotEmpty(rs.getString(8)))
								kaskoNew.setSatOsiguranja(rs.getString(8));
							if (StringUtils.isNotEmpty(rs.getString(9)))
								kaskoNew.setDatumOsiguranja(rs.getString(9));
							if (StringUtils.isNotEmpty(rs.getString(10)))
								kaskoNew.setStrankaUgovaratelj(rs.getString(10));
							if (StringUtils.isNotEmpty(rs.getString(11)))
								kaskoNew.setPosrednikObnove(rs.getString(11));
							if (StringUtils.isNotEmpty(rs.getString(12)))
								kaskoNew.setRegistarskaOznaka(rs.getString(12));
							if (StringUtils.isNotEmpty(rs.getString(13)))
								kaskoNew.setBrojSasije(rs.getString(13));
							if (StringUtils.isNotEmpty(rs.getString(14)))
								kaskoNew.setProizvodjac(rs.getString(14));
							if (StringUtils.isNotEmpty(rs.getString(15)))
								kaskoNew.setTipModelVozila(rs.getString(15));
							if (StringUtils.isNotEmpty(rs.getString(16)))
								kaskoNew.setPremijskaGrupa(rs.getString(16));
							if (NumberUtils.isNumber(rs.getString(17)))
								kaskoNew.setBrojMjesta(rs.getInt(17));
							if (StringUtils.isNotEmpty(rs.getString(18)))
								kaskoNew.setSnagaMotora(rs.getString(18));
							if (StringUtils.isNotEmpty(rs.getString(19)))
								kaskoNew.setNdm(rs.getString(19));
							if (StringUtils.isNotEmpty(rs.getString(20)))
								kaskoNew.setZapremninaMotora(rs.getString(20));
							if (StringUtils.isNotEmpty(rs.getString(21)))
								kaskoNew.setVoziloNosivost(rs.getString(21));
							if (StringUtils.isNotEmpty(rs.getString(22)))
								kaskoNew.setVoziloGodina(rs.getString(22));
							if (StringUtils.isNotEmpty(rs.getString(23)))
								kaskoNew.setStrankaOsiguranik(rs.getString(23));
							if (StringUtils.isNotEmpty(rs.getString(24)))
								kaskoNew.setObnovaNa(rs.getString(24));
							if (StringUtils.isNotEmpty(rs.getString(25)))
								kaskoNew.setMentorPosrednika(rs.getString(25));
							if (StringUtils.isNotEmpty(rs.getString(26)))
								kaskoNew.setOibUgovaratelj(rs.getString(26));
							if (StringUtils.isNotEmpty(rs.getString(27)))
								kaskoNew.setOibOsiguranik(rs.getString(27));
							return kaskoNew;
						});
			}
		catch (DataAccessException e) {
			e.printStackTrace();

		}
		return new KaskoNovaPolica();}





	@Override
	public IzlazSteta getIzlazSteta(UlazSteta ulazSteta) {
		try {
			return ins2jdbcTemplate.queryForObject("SELECT * from TABLE (DRAZEN.STETA_KASKO(?, ?))",
					new Object[] { ulazSteta.getOsTip(), ulazSteta.getOsSifra() }, (rs, rowNum) -> {
						IzlazSteta izlazSteta = new IzlazSteta();
						if(StringUtils.isNotEmpty(rs.getString(1)))
							izlazSteta.setsOsTip(rs.getString(1));
						if(StringUtils.isNotEmpty(rs.getString(2)))
							izlazSteta.setsOsSifra(rs.getString(2));
						if(StringUtils.isNotEmpty(rs.getString(3)))
							izlazSteta.setsSteta(rs.getString(3));
						if(StringUtils.isNotEmpty(rs.getString(4)))
							izlazSteta.setsBrojSteta(rs.getString(4));
						return izlazSteta;
					});
		} catch (EmptyResultDataAccessException e) {
			LOGGER_AK.info("Ne postoje podatci o šteti;"+ulazSteta.getOsTip()+";"+ulazSteta.getOsSifra());
			return new IzlazSteta(ulazSteta.getOsTip(), ulazSteta.getOsSifra(), "NE", "0");
		}
		catch(Exception e) {
			LOGGER_AK.error("Dogodila se greška kod dohvata šteta;"+ulazSteta.getOsTip()+";"+ulazSteta.getOsSifra(),e);
			return new IzlazSteta(ulazSteta.getOsTip(), ulazSteta.getOsSifra(), "NE", "0");
		}
	}


	@Override
	public VoziloIzlaz getVozilo(VoziloUlaz vozilo) {
		try {
			String sql = "SELECT e.model, e.v_godina, e.datum_osiguranja\r\n" +
					"  FROM evp_v_kasko_zb e\r\n" +
					" WHERE     e.oib_osiguranik = ?      --> guess what? A valid OIB :)\r\n" +
					"       AND TO_DATE (e.datum_osiguranja, 'dd.mm.yyyy') =\r\n" +
					"              (SELECT MAX (TO_DATE (e1.datum_osiguranja, 'dd.mm.yyyy'))\r\n" +
					"                 FROM evp_v_kasko_zb e1\r\n" +
					"                WHERE e1.oib_osiguranik = e.oib_osiguranik)";
			return ins2jdbcTemplate.queryForObject(sql, new Object[] {vozilo.getVozilo() }, (rs, rowNum) -> {
				VoziloIzlaz vozIzlaz = new VoziloIzlaz();
				vozIzlaz.setDatum(rs.getString("DATUM_OSIGURANJA"));
				vozIzlaz.setGodina(rs.getString("V_GODINA"));
				vozIzlaz.setModel(rs.getString("MODEL"));
				return vozIzlaz;
			});

		}catch(Exception e) {
				e.printStackTrace();
			}
		return new VoziloIzlaz();
		}



	@Override
	public IzlazDohvatiPremiju getIzlazDohvatiPremiju(UlazDohvatiPremiju ulazDohvatiPremiju) {
		try {
			return ins2jdbcTemplate.queryForObject("SELECT * FROM EVP_V_AUTOKASKO01 WHERE SIFRA = ?",
					new Object[] { ulazDohvatiPremiju.getSifra() }, (rs, rowNum) -> {
						IzlazDohvatiPremiju izlazDohvatiPremiju = new IzlazDohvatiPremiju();
						izlazDohvatiPremiju.setPremijaNeto(rs.getString("PREMIJA_NETO"));
						return izlazDohvatiPremiju;
					});
		} catch (EmptyResultDataAccessException e) {
			LOGGER_AK.info("Ne postoje podatci o premiji;"+ulazDohvatiPremiju.getSifra());
			return new IzlazDohvatiPremiju();
		}
		catch(Exception e) {
			LOGGER_AK.error("Dogodila se greška kod dohvata premije;"+ulazDohvatiPremiju.getSifra(),e);
			return new IzlazDohvatiPremiju();
		}
	}

}