PACKAGE tca.manifiesto.impo.dao;

import JAVA.util.ArrayList;
import JAVA.util.List;

import javax.annotation.PostConstruct;
import javax.SQL.DataSource;

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.simple.SimpleJdbcDaoSupport;
import org.springframework.stereotype.Repository;

import tca.manifiesto.impo.domain.ManifiestoCabecera;
import tca.manifiesto.impo.domain.ManifiestoDTO;
import tca.manifiesto.impo.domain.ManifiestoDetalle;
import tca.manifiesto.impo.domain.StkAvisoCamara;
import tca.manifiesto.impo.domain.WitAduana;
import tca.manifiesto.impo.domain.WitLugareOperativo;
import tca.manifiesto.impo.mapper.ManifiestoCabeceraMapper;
import tca.manifiesto.impo.mapper.ManifiestoDTOMapper;
import tca.manifiesto.impo.mapper.ManifiestoDetalleMapper;
import tca.manifiesto.impo.mapper.StkAvisoCamaraMapper;
import tca.manifiesto.impo.mapper.WitAduanaMapper;
import tca.manifiesto.impo.mapper.WitLugareOperativoMapper;
import tca.manifiesto.impo.mapper.TCAParametrosMapper;
import tca.manifiesto.impo.domain.TCAParametros;

@SuppressWarnings("deprecation")
@Repository
PUBLIC class ManifiestoDaoJdbcImpl EXTENDS SimpleJdbcDaoSupport implements ManifiestoDaoJdbc {

    Logger logg = Logger.getLogger(ManifiestoDaoJdbcImpl.class);

    @Autowired
    PUBLIC ManifiestoDaoJdbcImpl(DataSource dataSource) {
        setDataSource(dataSource);
    }

    @PostConstruct
    void init() {
    }

    PRIVATE int getValorDiasManiTCAParametros(String parametro){
        logger.info("*** getValorDiasManiTCAParametros ***");

        try{
            String q="select * from tca_parametros_apps where parametro = '"+parametro+"'";
            List<TCAParametros> r = getSimpleJdbcTemplate().query(q,NEW TCAParametrosMapper());


            int ret = INTEGER.parseInt(r.get(0).getValor());
            logger.info("*** PARAMETRO ***"+parametro);
            logger.info("*** dias cargados correctamente. Valor: ***"+ret);
            RETURN ret;
        }
        catch(EXCEPTION e){
            //arbitrariamente en caso de error, retornamos 12 dias
            logger.info("***getValorDiasManiTCAParametros: NO SE PUDO OBTENER LOS DIAS DESDE LA DB ***");
            RETURN 12;
        }
    }

    PRIVATE BOOLEAN getValorOcultarTerrestres(String parametro){
        logger.info("*** getValorOcultarTerrestres ***");
        //1 = Habilitado (Oculta los vuelos)
        //0 = Deshabilitado (Muestra los vuelos)

        try{
            String q="select * from tca_parametros_apps where parametro = '"+parametro+"'";
            List<TCAParametros> r = getSimpleJdbcTemplate().query(q,NEW TCAParametrosMapper());

            int ret = INTEGER.parseInt(r.get(0).getValor());
            logger.info("*** PARAMETRO ***"+parametro);
            logger.info("*** valor oculto cargado correctamente. Valor: ***"+ret);

            RETURN ret == 1;
        }
        catch(EXCEPTION e){
            //arbitrariamente en caso de error, retornamos TRUE
            logger.info("***getValorOcultarTerrestres: NO SE PUDO OBTENER EL VALOR DESDE LA DB ***");
            RETURN TRUE;
        }
    }

    PRIVATE String getValorCodVuelosOcultar(String parametro){
        logger.info("*** getValorCodVuelosOcultar ***");
        try{
            String q="select * from tca_parametros_apps where parametro = '"+parametro+"'";
            List<TCAParametros> r = getSimpleJdbcTemplate().query(q,NEW TCAParametrosMapper());

            String ret = r.get(0).getValor();
            logger.info("*** PARAMETRO ***"+parametro);
            logger.info("*** Cod. Vuelos cargados correctamente. Valor: \n"+ret+"***");

            RETURN ret;
        }
        catch(EXCEPTION e){
            //arbitrariamente en caso de error, retornamos ""
            logger.info("***getValorCodVuelosOcultar: NO SE PUDO OBTENER EL VALOR DESDE LA DB ***");
            RETURN "";
        }
    }

    PUBLIC List<WitAduana> getAduanas() {

          logger.info("*** public List<WitAduana> getAduanas() ***");

          String queryAduanas = "SELECT * "
                + "FROM WIT_ADUANAS "
                + "WHERE NM_HABILITADO = 1";

          logger.info("query: "+ queryAduanas);

          List<WitAduana> aduanas = getSimpleJdbcTemplate().query(queryAduanas,NEW WitAduanaMapper());

          logger.info("*** Fin getAduanas() ***");

          RETURN aduanas;
    }

    PUBLIC BOOLEAN marcaImpreso(String manifiesto) {

        logger.info("*** public Boolean marcaImpreso(String manifiesto) ***");

        String SQL = "UPDATE SIDIN "
                + "SET MIMPRESION = 1 "
                + "WHERE SUBSTR(SIDIN.NANIO,3,2) || SIDIN.CADUANA || SIDIN.CTPDOCING || SIDIN.NREG || SIDIN.DLETRA = ?";

        logger.info("query: "+ SQL);

        int result = getSimpleJdbcTemplate().UPDATE(SQL, manifiesto);

        IF(result > 0){
            logger.info("*** Fin marcaImpreso() ***");
            RETURN TRUE;
        }ELSE{
            logger.info("*** Fin marcaImpreso() ***");
            RETURN FALSE;
        }

    }

    PUBLIC WitAduana getAduana(String codAduana) {

        logger.info("*** public WitAduana getAduana(String codAduana)***");

        String SQL = "SELECT * "
                + "FROM WIT_ADUANAS "
                + "WHERE NM_HABILITADO = 1 "
                + "AND COD_ADUANA = ?";

        logger.info("query: "+ SQL);

        WitAduana aduana = getSimpleJdbcTemplate().queryForObject(SQL,NEW WitAduanaMapper(),codAduana);

        logger.info("*** Fin getAduana() ***");
        RETURN aduana;
    }

    PUBLIC List<WitLugareOperativo> getLugarOperativo(String codAduana) {

        logger.info("*** public List<WitLugareOperativo> getLugarOperativo(String codAduana)***");

        String SQL = "SELECT DISTINCT SD_ADUANA_PAIS, SD_LUGAR_OPERATIVO, SD_DESCRIPCION, SD_CODIGO FROM  WIT_LUGAR_OPER_REFERENCIAL WHERE SD_ADUANA_PAIS = ? AND SD_LUGAR_OPERATIVO != '     '";

        logger.info("query: "+ SQL);

        List<WitLugareOperativo> lugaresOperativos = getSimpleJdbcTemplate().query(SQL,NEW WitLugareOperativoMapper(), codAduana);

        logger.info("*** Fin getLugarOperativo() ***");
        RETURN lugaresOperativos;
    }

    PUBLIC List<ManifiestoDTO> getManifiestos(String codAduana,String lugarOperativo) {

        logger.info("*** public List<WitLugareOperativo> getLugarOperativo(String codAduana)***");

        String SQL = "SELECT DISTINCT MAX(TO_CHAR(H_FECHA_ALTA,'yyyy/mm/dd hh24:mi:ss')) AS H_FECHA_ALTA,"
                + " WSUM.DS_INDICADORTRANSPORTEVACIO,"
                + " WSUM.DS_INDICADORMERCADERIABORDO,"
                + " WSUM.DS_CODIGOADUANAREGISTRO,"
                + " WSUM.DS_LUGAROPERATIVO,"
                + " DS_PAISTRANSPORTISTA,"
                + " PT.DPAIS AS PAIS_TRANSP,"
                + " DS_PAISMEDIOTRANSPORTE,"
                + " PM.DPAIS AS PAIS_MTRANSP,"
                + " DS_PAISPROCEDENCIA,"
                + " WSUM.DS_NOMBRETRANSPORTISTA,"
                + " DS_MATRICULAMEDIOTRANSPORTE,"
                + " WSUM.DS_NOMBRE_HABILITADO,"
                + " WSUM.DS_IDENTIFICADOR,"
                + " WVUE.NUMERO_VUELO,"
                + " DECODE(SIDIN.MIMPRESION,NULL,'NO',0,'NO',1,'SI') AS MIMPRESION"
                + " FROM WIT_SLSUMARIABASES WSUM, DOM_PAISES PT, DOM_PAISES PP , DOM_PAISES PM, SIDIN, WIT_SLSUMARIANROVUELO WVUE"
                + " WHERE WSUM.DS_PAISTRANSPORTISTA = PT.CPAISMARIA";

                BOOLEAN ocultarTerrestres = getValorOcultarTerrestres("parametro.ocultar.terrestres");
                String codVuelosOcultar = getValorCodVuelosOcultar("parametro.cod.vuelos.ocultar");

                IF (ocultarTerrestres && codVuelosOcultar != NULL && !codVuelosOcultar.isEmpty()) {
                    codVuelosOcultar = codVuelosOcultar.toUpperCase();
                    SQL += " AND (WVUE.NUMERO_VUELO NOT IN (" +codVuelosOcultar+ ") OR WVUE.NUMERO_VUELO IS NULL)";

                    logger.info("getValorOcultarTerrestres: Es true");
                }

                SQL += " AND WSUM.DS_IDENTIFICADOR = SUBSTR(SIDIN.NANIO,3,2) || SIDIN.CADUANA || SIDIN.CTPDOCING || SIDIN.NREG || SIDIN.DLETRA"
                + " AND DS_PAISMEDIOTRANSPORTE = PM.CPAISMARIA"
                + " AND WVUE.DS_IDENTIFICADOR(+) = WSUM.DS_IDENTIFICADOR"
                + " AND DS_PAISPROCEDENCIA = PP.CPAISMARIA"
                + " AND PP.CSTATUS = 'A' AND PM.CSTATUS = 'A' AND PT.CSTATUS = 'A'"
                + " AND WSUM.DS_LUGAROPERATIVO = ?"
                + " AND WSUM.DS_CODIGOADUANAREGISTRO = ?"
                + " AND WSUM.DS_IDENTIFICADOR IN"
                + " (SELECT SUBSTR(SIDIN.NANIO,3,2) || SIDIN.CADUANA || SIDIN.CTPDOCING || SIDIN.NREG || SIDIN.DLETRA"
                + " FROM SIING , SIDIN, SIGUI"
                + " WHERE SIING.CESTADO = 'S'"
                + " AND SIDIN.CREGISTRO = SIING.CREGISTRO"
                + " AND SIDIN.CREGISTRO = SIGUI.CREGISTRO"
                + " AND SIGUI.CINT_GUIA = SIING.CINT_ING"
                + " AND (SIGUI.CTRANS <> 'CCC' AND SIGUI.CTRANS <> 'XXX')"
                + " AND SIDIN.FHRECEPCION >= SYSDATE - " + getValorDiasManiTCAParametros("parametro.antiguedad.manifiestos") + ")"
                + " GROUP BY"
                + " WSUM.DS_INDICADORTRANSPORTEVACIO,"
                + " WSUM.DS_INDICADORMERCADERIABORDO,"
                + " WSUM.DS_CODIGOADUANAREGISTRO,"
                + " WSUM.DS_LUGAROPERATIVO,"
                + " DS_PAISTRANSPORTISTA,"
                + " PT.DPAIS,"
                + " DS_PAISMEDIOTRANSPORTE,"
                + " PM.DPAIS,"
                + " DS_PAISPROCEDENCIA,"
                + " WSUM.DS_NOMBRETRANSPORTISTA,"
                + " DS_MATRICULAMEDIOTRANSPORTE,"
                + " WSUM.DS_NOMBRE_HABILITADO,"
                + " WSUM.DS_IDENTIFICADOR,"
                + " WVUE.NUMERO_VUELO,"
                + " DECODE(SIDIN.MIMPRESION,NULL,'NO',0,'NO',1,'SI')"
                + " ORDER BY 1 DESC";

        logger.info("query: "+ SQL);

        List<ManifiestoDTO> manifiestoDTOList = NEW ArrayList<ManifiestoDTO>();
        try{
            manifiestoDTOList = getSimpleJdbcTemplate().query(SQL,NEW ManifiestoDTOMapper(), lugarOperativo,codAduana );
        }
        catch(EXCEPTION e){
            logger.info("***getManifiestos: Error al obtener la lista de manis ***");
        }
        logger.info("*** Fin getManifiestos() ***");

        RETURN manifiestoDTOList;
    }

    PUBLIC List<StkAvisoCamara> getListadoGuiasConAvisoCamara() {

        logger.info("*** public List<StkAvisoCamara> getListadoGuiasConAvisoCamara() ***");

        String sql_guias_camara = "SELECT ID, "
                + "NOMBRE, "
                + "NUMERO_GUIA, "
                + "FECHA_ESTIMADA_ARRIBO, "
                + "PREFIJO_GUIA, "
                + "USUARIO, "
                + "H_FECHA_MODIFICACION, "
                + "IMPORTADOR, "
                + "PREFIJO_GUIA_H, "
                + "NUMERO_GUIA_H, "
                + " H_FECHA_ALTA, "
                + "APELLIDO, "
                + "TELEFONO, "
                + "EMAIL, "
                + "BULTOS_GRADOS_ENTRE_15_25, "
                + "BULTOS_GRADOS_ENTRE_2_8, "
                + "BULTOS_GRADOS_MENOS_20, "
                + "BULTOS, "
                + "NOMBRE_IMPORTADOR, "
                + "BULTOS_AMBIENTE, "
                + "ESTADO, "
                + "SGUIA, "
                + "SDCTOING, "
                + "VUELO, "
                + "OBSERVACION "
                + "FROM STK_AVISO_CAMARA sac  "
                + "WHERE H_FECHA_ALTA >= SYSDATE - " + getValorDiasManiTCAParametros("parametro.antiguedad.manifiestos")
                + "AND ESTADO < 2 "
                + "AND H_FECHA_MODIFICACION = (select max(H_FECHA_MODIFICACION) from STK_AVISO_CAMARA sac1 "
                + "WHERE sac1.NUMERO_GUIA=sac.NUMERO_GUIA)";


        logger.info("query: "+ sql_guias_camara);
        List<StkAvisoCamara> stkAvisoCamaraList = getSimpleJdbcTemplate().query(sql_guias_camara,NEW StkAvisoCamaraMapper());

        RETURN stkAvisoCamaraList;
    }

    PUBLIC List<ManifiestoCabecera> getCabeceraDetalleManifiesto(String manifiesto){

        logger.info("*** public List<ManifiestoCabecera> getCabeceraDetalleManifiesto(String manifiesto)***");

        String sql_cabecera = "SELECT DISTINCT "
                + "WSUM.H_FECHA_ALTA AS FECHA, "
                + "WSUM.DS_INDICADORTRANSPORTEVACIO AS TRANSVACIO, "
                + "WSUM.DS_INDICADORMERCADERIABORDO AS MERCADERIABORDO, "
                + "DS_PAISTRANSPORTISTA AS COD_PAIS_TRANSP, "
                + "PT.DPAIS AS PAIS_TRANSP, "
                + "DS_PAISMEDIOTRANSPORTE COD_PAIS_NACIONALIDAD, "
                + "PM.DPAIS AS NACIONALIDAD, "
                + "DS_PAISPROCEDENCIA AS COD_PAIS_PROCEDENCIA, "
                + "NUMERO_VUELO AS NUMERO_VUELO, "
                + "PP.DPAIS AS PAIS_PROCEDENCIA, "
                + "WSUM.DS_NOMBRETRANSPORTISTA AS NOMBRE_TRANSP, "
                + "WSUM.DS_MATRICULAMEDIOTRANSPORTE AS MATRICULA, "
                + "WSUM.DS_NOMBRE_HABILITADO AS NOMBRE_HAB, "
                + "SUBSTR(wsum.DS_IDENTIFICADOR,0,2) AS ANIO, "
                + "SUBSTR(wsum.DS_IDENTIFICADOR,3,3) AS ADUANA, "
                + "SUBSTR(wsum.DS_IDENTIFICADOR,6,4) AS MANI, "
                + "SUBSTR(wsum.DS_IDENTIFICADOR,10,6) AS NUMERO, "
                + "SUBSTR(wsum.DS_IDENTIFICADOR,16,1) AS LETRA "
                + "FROM WIT_SLSUMARIABASES WSUM, "
                + "DOM_PAISES PT, "
                + "DOM_PAISES PP, "
                + "DOM_PAISES PM, "
                + "WIT_SLTITULOBASES STIT, "
                + "WIT_SLSUMARIANROVUELO WVUE "
                + "WHERE WSUM.DS_PAISTRANSPORTISTA = PT.CPAISMARIA "
                + "AND DS_PAISMEDIOTRANSPORTE = PM.CPAISMARIA "
                + "AND DS_PAISPROCEDENCIA = PP.CPAISMARIA "
                + "AND WVUE.DS_IDENTIFICADOR (+) = WSUM.DS_IDENTIFICADOR "
                + "AND PP.CSTATUS = 'A' "
                + "AND PM.CSTATUS = 'A' "
                + "AND PT.CSTATUS = 'A' "
                + "AND SUBSTR(STIT.IDS_IDENTIFICADORTITULO,-16) = WSUM.DS_IDENTIFICADOR "
                + "AND WSUM.DS_IDENTIFICADOR = ? ";

        logger.info("query: "+ sql_cabecera);

        List<ManifiestoCabecera> manifiestoCabList = getSimpleJdbcTemplate().query(sql_cabecera,NEW ManifiestoCabeceraMapper(), manifiesto );

        String sql_detalle = "SELECT DISTINCT "
                + "WSUM.DS_IDENTIFICADOR AS MANIFIESTO, "
                + "SMER.NQ_CANTIDADPARCIAL AS CANTIDAD_PARCIAL, "
                + "SMER.DS_COMENTARIO AS COMENTARIO, "
                + "SMER.DS_TIPOMERCADERIA AS NATURALEZA, "
                + "STIT.DS_PUERTO AS PREFIJO, "
                + "STIT.DS_CARTAPORTE AS NUMERO, "
                + "STIT.DS_DESTINATARIOMERCADERIA AS DESTINATARIO, "
                + "STIT.DS_INDICCONSOLIDADO AS MARCA_CONSOLIDADO, "
                + "STIT.DS_INDICTRANSITOTRANSBORDO AS TRANSITO, "
                + "SMER.NN_PESOVOLUMENMANIFIESTO AS PESO, "
                + "SMER.NQ_CANTIDADTOTALMERCADERIA AS CANTIDAD_TOTAL "
                + "FROM WIT_SLSUMARIABASES WSUM, "
                + "WIT_SLTITULOBASES STIT, "
                + "WIT_SLLINEAMERCADERIAS SMER "
                + "WHERE STIT.IDS_IDENTIFICADORTITULO = SMER.DS_IDENTIFICADORTITULO "
                + "AND SUBSTR(STIT.IDS_IDENTIFICADORTITULO,-16) = WSUM.DS_IDENTIFICADOR "
                + "AND WSUM.DS_IDENTIFICADOR = ? "
                + "ORDER BY  SUBSTR(STIT.DS_CARTAPORTE,LENGTH(STIT.DS_CARTAPORTE)) ";

        logger.info("query: "+ sql_detalle);

        List<ManifiestoDetalle> manifiestoDetList = getSimpleJdbcTemplate().query(sql_detalle,NEW ManifiestoDetalleMapper(), manifiesto );

        FOR(ManifiestoCabecera m : manifiestoCabList ){
            m.setManifiestoDetalleList(manifiestoDetList);
        }

        logger.info("*** Fin getCabeceraDetalleManifiesto() ***");
        RETURN manifiestoCabList;
    }
}