<?php

/**
 * no_retroactivo actions.
 *
 * @package    nomina
 * @subpackage no_retroactivo
 * @author     Your name here
 * @version    SVN: $Id: actions.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
 */
class no_retroactivoActions extends sfActions {

    /**
     * Executes list action
     *
     * @param sfRequest $request A request object
     */
    public function executeList(sfWebRequest $request) {

        //Revisar que sea post
        //$this->forward404Unless($request->isMethod('post'));
        //Guardar los parametros del request en el log
        $this->logMessage("---BEGIN Logging request");
        foreach ($request->getPostParameters() as $key => $value) {
            $this->logMessage("request[$key] = $value");
        }
        $this->logMessage("--------------------------------------------------* Ip: " . $_SERVER['REMOTE_ADDR']);
        foreach ($request->getGetParameters() as $key => $value) {
            $this->logMessage("request[$key] = $value");
        }
        $this->logMessage("---END Logging request");

        $records = array();
        $arrayConstantes = array();
        /*
         * Variable para optimizar consultas de formulas en las liquidaciones - 20140117
         */
        $vals_calc = array();

        /*
         * Abrir conexion transaccion
         */
        $this->conn = Doctrine_Manager::getInstance()->getCurrentConnection();
        $this->conn->beginTransaction();

        /*
         * Formato de fecha
         */
        //Sql
        $sql = <<<EOD
ALTER SESSION SET NLS_DATE_FORMAT = "YYYY-MM-DD" 
EOD;
        //Ejecutar SQL
        CN_TABLE::executeSQL($sql);

        /*
         * Manejar Errores
         */
        try {

            /**
             * Consultar salario minimo
             */
            $salario_minimo = 550000;
            //Sql
            $sql = <<<EOD
(select nvl(valor_mensual, 0) as valor_mensual from no_smdlv where vigencia = extract(year from sysdate))  
EOD;
            //Ejecutar SQL
            $record_smlv = CN_TABLE::executeSQL($sql);

            if (count($record_smlv) > 0) {
                $salario_minimo = $record_smlv[0]['valor_mensual'];
            }

            /*
             * Obtener consultas glodal
             */
            //Sql
            $sql = <<<EOD
select * from NO_CONSULTA 
EOD;
            //Ejecutar SQL
            $record_consul = CN_TABLE::executeSQL($sql);
            $record_consulta = array();

            if (count($record_consul) > 0) {
                foreach ($record_consul as $key => $value) {
                    $record_consulta[$value['caracter']] = $value;

//                    $this->logMessage("Caracter - " . $value['caracter']);
                }
            }
//            $this->logMessage("Consulta - " . $record_consulta['M']['consulta']);
//            die();


            /**
             * Cargar tabla constantes
             */
            $text = '$con_';
            //Constantes 
            $sql = <<<EOD
Select cons.*, '$text'|| cons.id_constante as reemplazo from no_constante cons 
EOD;
            //Ejecutar SQL
            $records = CN_TABLE::executeSQL($sql);

            //Agrega a un array todas las constantes
            foreach ($records as $value) {

//                foreach ($value as $key => $value2) {
//                    $this->logMessage($key . " - " . $value2);
//                }

                $arrayConstantes[$value['reemplazo']] = $value;
//                $this->logMessage($value['reemplazo'] . "------------------------" . $arrayConstantes[$value['reemplazo']]);
            }

            /*
             * Anexo de variables del request para reemplazo en constantes
             */
            $arrayConstantes['$WDIASV'] = '0';
            $arrayConstantes['$WDIAST'] = '0';

            /*
             * Iniciar en 0 dias de liquidacion y totales de vacaciones - 20131216
             */
            $dias_liq = 0;
            $wdiasv_tot = 0;


            //PARAMETROS
            $id_periodo = $periodo = $request['id_periodo_filtro']; //periodo de retroactivo
            $id_periodo_hasta = $request['id_periodo_hasta']; //periodo de confirmacion
            $id_periodo_aju_men = $id_periodo_ini = $request['id_periodo_ini'];
            $id_periodo_fin = $request['id_periodo_fin'];
            $progress_key = $request['progress_key'] . $request['username'];



            /*
             * Variables opcionales
             */
            //tag para buscar las vacaciones de periodos anteriores . solo para el primer periodo de retroactivo - 20140303
            $tag_rn = 0;
            if (isset($request['rownum_'])) {
                $tag_rn = $request['rownum_'];
            }

            //funcionario
            if (isset($request['num_doc'])) {
                $whereFuncionarioNumDoc = " AND tab0.num_doc = " . $request['num_doc'];
            } else {
                $whereFuncionarioNumDoc = ' ';
            }
            //funcionario
            if (isset($request['id_tipo_doc'])) {
                $whereFuncionarioTipoDoc = " AND tab0.id_tipo_doc = " . $request['id_tipo_doc'];
            } else {
                $whereFuncionarioTipoDoc = ' ';
            }

            $sql = <<<EOD
SELECT * FROM NO_PERIODO WHERE ID_PERIODO = $id_periodo 
EOD;
            $results = CN_TABLE::executeSQL($sql);

            $id_tipo_periodo = $results[0]['id_tipo_periodo'];

            //periodo hasta de personas retiradas - 20130711
            $sql = <<<EOD
SELECT * FROM NO_PERIODO WHERE ID_PERIODO = $id_periodo_hasta 
EOD;
            $results = CN_TABLE::executeSQL($sql);

            $fecha_desde_periodo = $results[0]['fecha_ini'];
            $fecha_desde_periodo = explode(' ', $fecha_desde_periodo);
            $fecha_desde_periodo = $fecha_desde_periodo[0];
            $fecha_hasta_periodo = $results[0]['fecha_fin'];
            $fecha_hasta_periodo = explode(' ', $fecha_hasta_periodo);
            $fecha_hasta_periodo = $fecha_hasta_periodo[0];

//BORRO LOS REGISTROS DE NO_ESTADO_FUNC PARA EL PERIODO RETROACTIVO           
            $sql = <<<EOD
DELETE FROM NO_ESTADO_FUNC tab0 where tab0.periodo = $periodo
$whereFuncionarioNumDoc
$whereFuncionarioTipoDoc                    
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);

            /*
             * CREO LOS REGISTROS EN LA TABLA NO_ESTADO_FUNC
             * id 6 - tipo periodo retroactivo activos
             * id 7 - tipo periodo retroactivo inactivos
             */
            if ($id_tipo_periodo == 6) {

                $sql = <<<EOD
INSERT INTO NO_ESTADO_FUNC (ID_TIPO_DOC,NUM_DOC,ID_DP,ID_ANHOS,ID_MESES,PERIODO,ACTUAL,ID_EA,ID_CEN_OP)

select tab1.id_tipo_doc, tab1.num_doc,tab1.id_dp,
(select id_anhos from no_periodo where id_periodo = $periodo) AS ID_ANHOS,
(select id_meses from no_periodo where id_periodo = $periodo) AS ID_MESES,
$periodo AS ID_PERIODO,1 AS ACTUAL, tab1.id_ea,tab1.id_cen_op

from no_nombramiento_v tab0

left join no_estado_func_v tab1 ON tab1.id_tipo_doc = tab0.id_tipo_doc and tab1.num_doc = tab0.num_doc

where tab1.periodo = (select max(tab3.periodo) from no_estado_func_v tab3 where tab3.id_tipo_doc = tab1.id_tipo_doc and tab3.num_doc = tab1.num_doc)
and tab0.estado = 1                    
$whereFuncionarioNumDoc
$whereFuncionarioTipoDoc                    
EOD;
            } else if ($id_tipo_periodo == 7) {

                $sql = <<<EOD
INSERT INTO NO_ESTADO_FUNC (ID_TIPO_DOC,NUM_DOC,ID_DP,ID_ANHOS,ID_MESES,PERIODO,ACTUAL,ID_EA,ID_CEN_OP)

select tab1.id_tipo_doc, tab1.num_doc,tab1.id_dp,
(select id_anhos from no_periodo where id_periodo = $periodo) AS ID_ANHOS,
(select id_meses from no_periodo where id_periodo = $periodo) AS ID_MESES,
$periodo AS ID_PERIODO,1 AS ACTUAL, tab1.id_ea,tab1.id_cen_op

from no_nombramiento_v tab0

left join no_estado_func_v tab1 ON tab1.id_tipo_doc = tab0.id_tipo_doc and tab1.num_doc = tab0.num_doc

where tab1.periodo = (select max(tab3.periodo) from no_estado_func_v tab3 where tab3.id_tipo_doc = tab1.id_tipo_doc and tab3.num_doc = tab1.num_doc)
and tab0.fecha_retiro <= to_date('$fecha_hasta_periodo','YYYY-MM-DD')               
$whereFuncionarioNumDoc
$whereFuncionarioTipoDoc                    
EOD;
            }

            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);

            /*
              DELETE FROM NO_CONCEPTO_PERIODO tab0
              where tab0.periodo = $periodo
              $whereFuncionarioNumDoc
              $whereFuncionarioTipoDoc
             */
            //Borrar NO_CONCEPTO_PERIODO el periodo de retroactivo para cada periodo de ajuste - 20130604
            $sql = <<<EOD
delete from ( 
    select tab0.* from NO_CONCEPTO_PERIODO tab0 
    join no_periodo per
    on tab0.id_periodo_ajuste = per.id_periodo
    where tab0.periodo = $id_periodo
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) >= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ini)  
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) <= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_fin)
    and per.id_tipo_periodo != 5
    $whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
)                   
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql); //Borrar NO_CONCEPTO_PERIODO el periodo de retroactivo para cada periodo de ajuste - 20130604
            //tag para buscar las vacaciones de periodos anteriores . solo para el primer periodo de retroactivo - 20140303
            if ($tag_rn == 1) {
                $sql = <<<EOD
delete from ( 
    select tab0.* from NO_CONCEPTO_PERIODO tab0 
    join no_periodo per
    on tab0.id_periodo_ajuste = per.id_periodo
    where tab0.periodo = $id_periodo
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) < (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ini)  
    and per.id_tipo_periodo != 5
    --and tab0.id_concep_nomina = 7
    $whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
)                   
EOD;
                //ejecuta y obtiene el resultado del sql
                CN_TABLE::executeSQL($sql);
            }

            /**
             * Borrar NO_CONCEPTO_PERIODO el periodo de retroactivo para cada periodo de ajuste - 20130604
             * Borra solo periodos de Nomina Adicional - 20140304
             */
            $sql = <<<EOD
delete from ( 
    select tab0.* from NO_CONCEPTO_PERIODO tab0 
    join no_periodo per
    on tab0.id_periodo_ajuste = per.id_periodo
    where tab0.periodo = $id_periodo
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) >= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ini)  
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) <= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_fin)
    and (select id_tipo_periodo from no_periodo where id_periodo = tab0.id_periodo_ajuste) = 2
    $whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
)                   
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);

            //TRAIGO LOS PERIODOS QUE SE AFECTAN CON LOS PERIODOS SELECCIONADOS

            $sql = <<<EOD
select tab0.*
from no_periodo tab0 
where tab0.id_tipo_periodo = 1 
    and tab0.id_periodo >= $id_periodo_ini  and tab0.id_periodo <= $id_periodo_fin
order by tab0.fecha_fin 
EOD;

            $results = CN_TABLE::executeSQL($sql);

            /*
             * Memcache
             */
            $i = 1;
            $nom_conceptos_a_procesar = count($results);

            // Antes de inicar el proceso largo
            $brecha = 1;
            if ($nom_conceptos_a_procesar > 100)
                $brecha = $nom_conceptos_a_procesar - (0.99 * $nom_conceptos_a_procesar);

            foreach ($results as $resul) {

                // Guardar un valor en el proceso largo
                if ($i % $brecha == 0) {
                    $por = round(($i / $nom_conceptos_a_procesar) * 100, 0);
                    MemcacheHandler::getInstance()->set($progress_key, $por / 10);
                }

                $i++;

                $id_periodo_ajuste = $resul['id_periodo']; //periodo de ajuste - mensual

                /*
                 * Inserta en NO_CONCEPTO_PERIODO los conceptos para cada periodo en el periodo de retroactivo
                 */
                $sql = <<<EOD
INSERT INTO NO_CONCEPTO_PERIODO 
(ID_ANHOS,ID_MESES,PERIODO,ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,FECHA_DESDE,
    FECHA_HASTA,VALOR,PORCENTAJE,NUM_DIAS,ID_PERIODO_AJUSTE)

select 
    
tab0.ID_ANHOS,
tab0.ID_MESES,
tab0.PERIODO,
tab0.ID_TIPO_DOC,
tab0.NUM_DOC,
tab0.ID_CONCEP_NOMINA,
tab0.FECHA_DESDE,
tab0.FECHA_HASTA,
tab0.VALOR,
tab0.PORCENTAJE,
tab0.NUM_DIAS,
tab0.ID_PERIODO_AJUSTE

from(

select tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,
    tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,
        tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,

case when tab0.id_concep_nomina = 1 or tab0.id_concep_nomina = 401 then (
select tab2.asignacion_basica

from no_estado_func_v tab1
left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp
where tab1.rn=1 and tab1.num_doc = tab0.num_doc 
--and tab1.actual = 1 
and tab1.periodo=$id_periodo_ajuste


)
else

tab0.valor end

AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0
left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  
left join no_periodo tab2 ON tab2.id_periodo = $periodo
left join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab3.id_agrup_deta IS NULL and tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)
AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad =1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)

UNION

select tab0.id_concepto_periodo, tab2.id_meses,tab2.id_anhos,tab2.id_periodo,tab0.id_tipo_doc,tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,

(
select tab2.asignacion_basica

from no_estado_func_v tab1
left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp
where tab1.rn=1 and tab1.num_doc = tab0.num_doc 
--and tab1.actual = 1 
and tab1.periodo=$id_periodo_ajuste


) * tab0.porcentaje / 100

AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0
left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  
left join no_periodo tab2 ON tab2.id_periodo = $periodo
join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)
AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad =1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)

UNION 

select tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,

case when tab0.id_concep_nomina=1 or tab0.id_concep_nomina = 401  then (
select tab2.asignacion_basica

from no_estado_func_v tab1
left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp
where tab1.rn=1 and tab1.num_doc = tab0.num_doc
--and tab1.actual = 1 
and tab1.periodo=$id_periodo_ajuste


)
else

tab0.valor end

AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0
left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  
left join no_periodo tab2 ON tab2.id_periodo = $periodo
left join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab3.id_agrup_deta IS NULL and tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)

and tab0.id_concepto_periodo IN(

select max(conc.id_concepto_periodo) ID_CONCEPTO_PERIODO

from no_concepto_periodo conc

where conc.num_doc=tab0.num_doc and conc.periodo = $id_periodo_ajuste

)

AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad >1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)

UNION 

select tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,

case when tab0.id_concep_nomina = 1  or tab0.id_concep_nomina = 401 then (
select tab2.asignacion_basica

from no_estado_func_v tab1
left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp
where tab1.rn=1 and tab1.num_doc = tab0.num_doc
--and tab1.actual = 1 
and tab1.periodo=$id_periodo_ajuste


)
else

tab0.valor end

AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0


left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  

left join no_periodo tab2 ON tab2.id_periodo = $periodo

left join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab3.id_agrup_deta IS NULL and tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)

and tab0.id_concepto_periodo IN(

select max(conc.id_concepto_periodo) ID_CONCEPTO_PERIODO

from no_concepto_periodo conc

where conc.num_doc=tab0.num_doc and conc.id_concep_nomina = tab0.id_concep_nomina and conc.periodo = $id_periodo_ajuste

)

AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad >1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)

UNION



select tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,

case when tab0.id_concep_nomina = 1  or tab0.id_concep_nomina = 401 then (
  select asignacion_basica from (
    
        select tab2.asignacion_basica, tab1.num_doc
        
        from no_novedad_personal tab1
        left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp_ini
        where  tab1.id_periodo = $id_periodo_ajuste
        order by tab1.num_doc, tab1.fecha_terminacion desc
    
    )tab12 where
    tab12.num_doc = tab0.num_doc
    and rownum = 1
)
else

tab0.valor end

AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0
left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  
left join no_periodo tab2 ON tab2.id_periodo = $periodo
left join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab3.id_agrup_deta IS NULL and tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)

and tab0.id_concepto_periodo IN(

select MIN(conc.id_concepto_periodo) ID_CONCEPTO_PERIODO

from no_concepto_periodo conc

where conc.num_doc=tab0.num_doc and conc.id_concep_nomina = tab0.id_concep_nomina and conc.periodo = $id_periodo_ajuste

)

AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad >1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)



UNION

select tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,

(
select tab2.asignacion_basica

from no_estado_func_v tab1
left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp
where tab1.rn=1 and tab1.num_doc = tab0.num_doc 
--and tab1.actual = 1 
and tab1.periodo=$id_periodo_ajuste


)*tab0.porcentaje / 100

AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0


left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  

left join no_periodo tab2 ON tab2.id_periodo = $periodo

join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)

and tab0.id_concepto_periodo IN(

select max(conc.id_concepto_periodo) ID_CONCEPTO_PERIODO

from no_concepto_periodo conc

where conc.num_doc=tab0.num_doc and conc.id_concep_nomina = tab0.id_concep_nomina and conc.periodo = $id_periodo_ajuste

)

AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad >1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)
                        
--order by tab0.id_concepto_periodo                        

UNION
    --vacaciones de un periodo anterior para el primer periodo de retroactivo - 20140303
    select 
    tab0.id_novedad_vac, 
    (select id_meses from no_periodo where id_periodo = $periodo) AS ID_MESES,
    (select id_anhos from no_periodo where id_periodo = $periodo) AS ID_ANHOS,
    $periodo as PERIODO,
    tab0.id_tipo_doc ID_TIPO_DOC,
    tab0.num_doc,
    tab0.id_concep_nomina,

    tab0.fecha_ini AS FECHA_DESDE, tab0.fecha_fin AS FECHA_HASTA,

    0 AS PORCENTAJE, 
    tab0.num_dias AS NUM_DIAS, 
    tab0.id_periodo AS ID_PERIODO_AJUSTE,
    0 AS VALOR,
    0 AS VALOR_ANTERIOR

    from(


        select 
        nov.*,
        convac.id_concep_nomina,
        nov.fecha_fin - (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) + 1 as num_dias

        from no_novedad_vac nov

        join no_periodo_v perv
        on perv.id_periodo = nov.id_periodo

        join no_concep_vac convac
        on nov.id_tipo_nov_vac = convac.id_tipo_nov_vac

        where nov.fecha_fin >= (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste)
        /*between (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) 
          and (select per.fecha_fin from no_periodo per where per.id_periodo = $id_periodo_ajuste)*/
        and nov.fecha_ini < (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) 
                        
        and perv.id_anhos != (select per.id_anhos from no_periodo per where per.id_periodo = $id_periodo_ajuste)
        and perv.id_meses != (select per.id_meses from no_periodo per where per.id_periodo = $id_periodo_ajuste)
        AND convac.id_concep_nomina = (select no_param_concep.id_concep_vacac from no_param_concep where no_param_concep.id_param_concep = 1)

    )tab0                        
                        
UNION
                        
    --vacaciones de un periodo anterior para el primer periodo de retroactivo. solo dias para 1007- 20140303
    select 
    tab0.id_novedad_vac, 
    (select id_meses from no_periodo where id_periodo = $periodo) AS ID_MESES,
    (select id_anhos from no_periodo where id_periodo = $periodo) AS ID_ANHOS,
    $periodo as PERIODO,
    tab0.id_tipo_doc ID_TIPO_DOC,
    tab0.num_doc,
    tab0.id_concep_nomina,

    tab0.fecha_ini AS FECHA_DESDE, tab0.fecha_fin AS FECHA_HASTA,

    0 AS PORCENTAJE, 
    case when tab0.id_concep_nomina = (select no_param_concep.id_concep_vacac from no_param_concep where no_param_concep.id_param_concep = 1) then tab0.num_dias else 0 end AS NUM_DIAS, 
    tab0.id_periodo AS ID_PERIODO_AJUSTE,
    0 AS VALOR,
    0 AS VALOR_ANTERIOR

    from(


        select 
        nov.*,
        convac.id_concep_nomina,
        nov.fecha_fin - nov.fecha_ini + 1 as num_dias

        from no_novedad_vac nov

        join no_periodo_v perv
        on perv.id_periodo = nov.id_periodo

        join no_concep_vac convac
        on nov.id_tipo_nov_vac = convac.id_tipo_nov_vac

        where nov.fecha_fin >= (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste)
        /*between (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) 
          and (select per.fecha_fin from no_periodo per where per.id_periodo = $id_periodo_ajuste)*/
        and nov.fecha_ini >= (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) 
                        
        and perv.id_anhos != (select per.id_anhos from no_periodo per where per.id_periodo = $id_periodo_ajuste)
        and perv.id_meses != (select per.id_meses from no_periodo per where per.id_periodo = $id_periodo_ajuste)
        --AND convac.id_concep_nomina = (select no_param_concep.id_concep_vacac from no_param_concep where no_param_concep.id_param_concep = 1)

    )tab0                        
                        
UNION



select tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,


(
  select asignacion_basica from (
    
        select tab2.asignacion_basica, tab1.num_doc
        
        from no_novedad_personal tab1
        left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp_ini
        where  tab1.id_periodo = $id_periodo_ajuste
        order by tab1.num_doc, tab1.fecha_terminacion desc
    
    )tab12 where
    tab12.num_doc = tab0.num_doc
    and rownum = 1

)*tab0.porcentaje / 100



AS VALOR,tab0.valor AS VALOR_ANTERIOR

from no_concepto_periodo tab0
left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  
left join no_periodo tab2 ON tab2.id_periodo = $periodo
join no_agrup_deta tab3 ON tab3.id_concep_nomina = tab0.id_concep_nomina and tab3.id_agrup_concepto = 122

where tab0.periodo = $id_periodo_ajuste AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)

and tab0.id_concepto_periodo IN(

select MIN(conc.id_concepto_periodo) ID_CONCEPTO_PERIODO

from no_concepto_periodo conc

where conc.num_doc=tab0.num_doc and conc.id_concep_nomina = tab0.id_concep_nomina and conc.periodo = $id_periodo_ajuste

)

AND exists 
(

select comp.num_doc

from(

select concep.num_doc,concep.periodo, count(concep.id_concepto_periodo) AS CANTIDAD

from no_concepto_periodo concep


where concep.id_concep_nomina = 1

group by concep.num_doc,concep.periodo
)
comp
where comp.cantidad >1 and comp.periodo = $id_periodo_ajuste and comp.num_doc = tab0.num_doc


)

--order by tab0.id_concepto_periodo

)tab0 
                        
                        
join no_estado_func tab3 ON tab3.id_tipo_doc = tab0.id_tipo_doc 
    and tab3.num_doc = tab0.num_doc and tab3.periodo = $periodo
                       
                        
where tab0.num_doc IS NOT NULL and tab0.id_concep_nomina!=(
    select tab2.id_concep_nomina     
    from no_param_concep tab1 
    left join no_concep_nomina tab2 ON tab2.id_concep_nomina = tab1.id_concep_rete
)
and tab0.num_dias >= 0                        
$whereFuncionarioNumDoc
$whereFuncionarioTipoDoc    
ORDER BY tab0.NUM_DOC, tab0.ID_CONCEP_NOMINA, tab0.id_periodo_ajuste, tab0.id_concepto_periodo         
                    
EOD;

                $results = CN_TABLE::executeSQL($sql);
            }


            /*
             * Traer valores nuevos para id_concep_nomina 14 horas extras           
             * Se pone en horas_mes en 240 para periodo 201304 - 20130606
             */
            $sql = <<<EOD
select 
nvl(tab1.valor,0) as valor_new,
tab0.*
from no_concepto_periodo tab0

join (      

      select 
      id_periodo,
      id_tipo_doc,
      num_doc,
      round(sum((valor / horas_mes) * factor * cantidad) , 2) as valor
      
      from(
      
          select 
          lot.id_periodo,
          lot.id_anhos,
          lot.id_meses,
          ext.*,
          tip.factor,
          (select sum(estado.valor)
                  from no_concepto_func estado
                  join no_param_concep parametros on parametros.id_concep_basica = estado.id_concep_nomina
                  where estado.estado=1 and estado.actual=1 and estado.id_tipo_doc = ext.id_tipo_doc and estado.num_doc = ext.num_doc ) as valor,
          
          case when lot.id_anhos = 2013 and lot.id_meses = 4 then 240 else (select sum(nvl(no_nombramiento_v.horas_mes,0)) 
          from no_nombramiento_v
          where
          id_tipo_doc = ext.id_tipo_doc
          and num_doc = ext.num_doc
          and rn = 1) end
          as horas_mes        
          
          from no_hr_extra ext
          
          join no_tipo_hr_extra tip
          on tip.id_tipo_hr_extra = ext.id_tipo_hr_extra
          
          join(
              select 
              lot.*,
              per.id_anhos,
              per.id_meses
              from no_lote_hr_extra lot
              left join no_periodo per
              on per.id_periodo = lot.id_periodo
              where 
              lot.id_periodo >= $id_periodo_ini  and lot.id_periodo <= $id_periodo_fin
          )lot
          on ext.id_lote_hr_extra = lot.id_lote_hr_extra
          
          /*
          where ext.id_lote_hr_extra in (
              select 
              lot.id_lote_hr_extra
              from no_lote_hr_extra lot
              where 
              lot.id_periodo >= $id_periodo_ini  and lot.id_periodo <= $id_periodo_fin
          )
          */
      )
      
      group by 
      id_tipo_doc,
      num_doc,
      id_periodo


)tab1
on tab1.id_tipo_doc = tab0.id_tipo_doc and tab1.num_doc = tab0.num_doc
and tab1.id_periodo = tab0.id_periodo_ajuste

where 
tab0.periodo = $periodo
and tab0.id_concep_nomina = 14                  
EOD;
            //ejecuta y obtiene el resultado del sql
            $records_hr = CN_TABLE::executeSQL($sql);

            /*
             * Actualizar concep_periodo horas
             */
            foreach ($records_hr as $value_hr) {

                $valor_new = $value_hr['valor_new'];
                $id_concepto_periodo = $value_hr['id_concepto_periodo'];

                //actualizar valores nuevos para id_concep_nomina 14 horas extras           
                $sql = <<<EOD
update NO_CONCEPTO_PERIODO set valor =  $valor_new
    where id_concepto_periodo = $id_concepto_periodo
EOD;
                //ejecuta y obtiene el resultado del sql
                CN_TABLE::executeSQL($sql);
            }

            // Borrar NO_CONCEPTO_PERIODO retefuente el periodo de retroactivo para cada periodo de ajuste - 20130604
            $sql = <<<EOD
delete from NO_CONCEPTO_PERIODO tab0 
                    
where 
tab0.id_concep_nomina=(
select tab2.id_concep_nomina     
from no_param_concep tab1 
left join no_concep_nomina tab2 ON tab2.id_concep_nomina = tab1.id_concep_rete
)     
and tab0.periodo = $periodo    
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc                        
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);

//RETENCION EN LA FUENTE - 20130604

            $sql = <<<EOD
INSERT INTO NO_CONCEPTO_PERIODO 
(ID_MESES,ID_ANHOS,PERIODO,ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,FECHA_DESDE,FECHA_HASTA,VALOR,PORCENTAJE,
    NUM_DIAS,ID_PERIODO_AJUSTE)        
select tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,
    tab0.num_doc,tab0.id_concep_nomina,tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
tab0.VALOR as VALOR, tab0.porcentaje AS PORCENTAJE, 30 AS NUM_DIAS, tab2.id_periodo AS ID_PERIODO_AJUSTE

from no_concepto_func tab0
left join no_periodo tab2 ON tab2.id_periodo = $periodo
where tab0.actual = 1 and tab0.estado = 1
and tab0.id_concep_nomina=(
select tab2.id_concep_nomina 
    
from no_param_concep tab1 
left join no_concep_nomina tab2 ON tab2.id_concep_nomina = tab1.id_concep_rete

)
and tab0.porcentaje>0
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
                  
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);




            /*
              DELETE FROM NO_LIQUIDA_NOMINA tab0 where tab0.id_periodo = $periodo
              $whereFuncionarioNumDoc
              $whereFuncionarioTipoDoc
             */
            // Borrar no_liquida_nomina el periodo de retroactivo para cada periodo de ajuste - 20130604
            $sql = <<<EOD
delete from ( 
    select tab0.* from no_liquida_nomina tab0 
    join no_periodo per
    on tab0.id_periodo_ajuste = per.id_periodo
    where tab0.id_periodo = $id_periodo
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) >= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ini)  
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) <= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_fin)
    and ( per.id_tipo_periodo != 5 and per.id_tipo_periodo != 2 )
    $whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
)                    
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);

            /*
             * OJO: ID quemado
             * tag para buscar las vacaciones - ajuste vacaciones de periodos anteriores 
             * solo para el primer periodo de retroactivo - 20140303
             */
            if ($tag_rn == 1) {
                $sql = <<<EOD
delete from ( 
    select tab0.* from no_liquida_nomina tab0 
    join no_periodo per
    on tab0.id_periodo_ajuste = per.id_periodo
    where tab0.id_periodo = $id_periodo
    and (select id_anhos || lpad(id_meses,2,'0') 
        from no_periodo where id_periodo = tab0.id_periodo_ajuste) < (select id_anhos || lpad(id_meses,2,'0') 
            from no_periodo where id_periodo = $id_periodo_ini)   and per.id_tipo_periodo != 5
    --and tab0.id_concep_nomina in (7,27)
    $whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
)                    
EOD;
                //ejecuta y obtiene el resultado del sql
                CN_TABLE::executeSQL($sql);
            }

            /**
             * Borrar no_liquida_nomina el periodo de retroactivo para cada periodo de ajuste - 20130604
             * Nomina Adicional - 20140304
             */
            $sql = <<<EOD
delete from ( 
    select tab0.* from no_liquida_nomina tab0 
    join no_periodo per
    on tab0.id_periodo_ajuste = per.id_periodo
    where tab0.id_periodo = $id_periodo
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) >= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ini)  
    and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo_ajuste) <= (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_fin)
    and (select id_tipo_periodo from no_periodo where id_periodo = tab0.id_periodo_ajuste) = 2
    $whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
)                    
EOD;
            //ejecuta y obtiene el resultado del sql
            CN_TABLE::executeSQL($sql);

            MemcacheHandler::getInstance()->set($progress_key, 10);

//MemcacheHandler::getInstance()->set($progress_key, 100);
//exit();
            /*
             * Liquida el periodo nuevo de retroactivo
             */
            $sql = <<<EOD
select tab0.*
from no_periodo tab0 
where tab0.id_tipo_periodo = 1 
and tab0.id_periodo>=$id_periodo_ini  and tab0.id_periodo<=$id_periodo_fin
order by tab0.fecha_fin 
EOD;

            $results = CN_TABLE::executeSQL($sql);

            $this->conn->commit();

            /*
             * Recorre los registros de funcionario - concepto nomina
             * para ser liquidados
             */
            $i = 1;
            $nom_conceptos_a_procesar = count($results);

            // Antes de inicar el proceso largo
            $brecha = 1;
            if ($nom_conceptos_a_procesar > 100)
                $brecha = $nom_conceptos_a_procesar - (0.99 * $nom_conceptos_a_procesar);

            $this->logMessage("[Liquidación Retroactivo] nom_conceptos_a_procesar: " . $nom_conceptos_a_procesar);
            $logPath = sfConfig::get('sf_log_dir') . '/liquidacion.log';
            $custom_logger = new sfFileLogger(new sfEventDispatcher(), array('file' => $logPath));

            //For de liquidar por cada periodo entre el rango
            foreach ($results as $resul) {


                $id_periodo_ajuste = $resul['id_periodo'];

                //llamar para cada periodo y liquidar
                $this->liquidarRetroactivo($id_periodo, $id_periodo_ajuste, $progress_key, $record_consulta, $arrayConstantes, $whereFuncionarioNumDoc, $whereFuncionarioTipoDoc, $tag_rn);
//MemcacheHandler::getInstance()->set($progress_key, 100);
//exit();
                // Guardar un valor en el proceso largo
                if ($i % $brecha == 0) {
                    $por = round(($i / $nom_conceptos_a_procesar) * 100, 0);
//                    MemcacheHandler::getInstance()->set($progress_key, 10 + $por);
                }

                $this->logMessage("[Liquidación Retroactivo] Existen liquidaciones.");

                $i++;
//                break;
            }


            MemcacheHandler::getInstance()->set($progress_key, 90);

            /*
             * Abrir conexion transaccion
             */
            $this->conn->beginTransaction();


            //Traer las diferencias de liquida nomina para rango de periodos
            //Se unen los registros de vacaciones para periodos anteriores . para el primer registro de periodo - 20140303
            $sql = <<<EOD

select id_liq, ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,$periodo AS ID_PERIODO,
   DIFERENCIA AS VALOR_LIQUIDADO,
       FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE

FROM(

    select id_liq, ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE,VALOR,VALOR_LIQUIDADO,
        (VALOR - VALOR_LIQUIDADO) AS DIFERENCIA

    FROM(

        select tab0.*,nvl(tab1.valor_liquidado,0) AS VALOR_LIQUIDADO

        from(

            select 
                to_char(wm_concat(tab0.id_liquida_nomina)) as id_liq, tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA,tab0.FECHA_DESDE,tab0.FECHA_HASTA,sum(tab0.NUM_DIAS)AS NUM_DIAS,
                tab0.ID_PERIODO_AJUSTE,sum(nvl(tab0.VALOR_LIQUIDADO,0)) AS VALOR,
                (select max(no_concep_nomina.id_concep_ajuste) as id_concep_ajuste from no_concep_nomina where tab0.id_concep_nomina = no_concep_nomina.id_concep_nomina) as id_concep_ajuste,
                (select max(no_concep_nomina.id_concep_rein) as id_concep_ajuste from no_concep_nomina where tab0.id_concep_nomina = no_concep_nomina.id_concep_nomina) as id_concep_rein

            from no_liquida_nomina tab0

            where tab0.id_periodo = $periodo  and tab0.id_periodo_ajuste = $id_periodo_ajuste 

            group by tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA,tab0.FECHA_DESDE,tab0.FECHA_HASTA,tab0.ID_PERIODO_AJUSTE

            order by tab0.ID_PERIODO_AJUSTE,tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA

            )tab0                 

            left join 
            (select tab1.ID_TIPO_DOC,tab1.NUM_DOC,tab1.ID_CONCEP_NOMINA,tab1.ID_PERIODO,sum(nvl(tab1.VALOR_LIQUIDADO,0)) AS VALOR_LIQUIDADO
            from no_liquida_nomina tab1
            group by tab1.id_tipo_doc,tab1.num_doc,tab1.id_concep_nomina,tab1.id_periodo               
            )tab1 ON tab1.id_tipo_doc = tab0.id_tipo_doc and tab1.num_doc = tab0.num_doc 
                and tab1.id_concep_nomina = tab0.id_concep_nomina and tab0.id_periodo_ajuste = tab1.id_periodo

            where tab0.num_doc IS NOT NULL
            AND tab0.ID_CONCEP_NOMINA!=(select tab2.id_concep_nomina from no_param_concep tab1 
            left join no_concep_nomina tab2 ON tab2.id_concep_nomina = tab1.id_concep_rete) 
            $whereFuncionarioNumDoc
            $whereFuncionarioTipoDoc   

    UNION                    
 
         select tab0.*,
           case when (select no_param_concep.id_concep_vacac from no_param_concep where no_param_concep.id_param_concep = 1) = tab0.ID_CONCEP_NOMINA 
           then round((nvl(tab1.valor_liquidado,0)+nvl(tab5.valor_ajuste,0)-nvl(tab6.valor_rein,0))/tab1.num_dias*tab0.NUM_DIAS)  
           else tab1.valor_liquidado -- + tab1.val_ajuste
           end AS VALOR_LIQUIDADO

        from(

            select 
                to_char(wm_concat(tab0.id_liquida_nomina)) as id_liq, tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA,
                max(tab0.FECHA_DESDE) as FECHA_DESDE,
                max(tab0.FECHA_HASTA) as FECHA_HASTA,
                sum(tab0.NUM_DIAS)AS NUM_DIAS,
                tab0.ID_PERIODO_AJUSTE,sum(nvl(tab0.VALOR_LIQUIDADO,0)) AS VALOR,
                (select max(no_concep_nomina.id_concep_ajuste) as id_concep_ajuste from no_concep_nomina where tab0.id_concep_nomina = no_concep_nomina.id_concep_nomina) as id_concep_ajuste,
                (select max(no_concep_nomina.id_concep_rein) as id_concep_ajuste from no_concep_nomina where tab0.id_concep_nomina = no_concep_nomina.id_concep_nomina) as id_concep_rein

            from no_liquida_nomina tab0

            where tab0.id_periodo = $periodo  --and tab0.id_periodo_ajuste = $id_periodo_ajuste 

            group by tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA,/*tab0.FECHA_DESDE,tab0.FECHA_HASTA,*/tab0.ID_PERIODO_AJUSTE

            order by tab0.ID_PERIODO_AJUSTE,tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA

            )tab0                 

             left join 
            (
          
              select tab1.ID_TIPO_DOC,tab1.NUM_DOC,tab1.ID_CONCEP_NOMINA,tab1.ID_PERIODO,
              sum(nvl(tab1.VALOR_LIQUIDADO,0)) AS VALOR_LIQUIDADO,
              sum(nvl(tab1.num_dias,0)) as num_dias/*,
              
              nvl((
                    select 
                    --tab1.ID_TIPO_DOC,tab1.NUM_DOC,tab1.ID_CONCEP_NOMINA,tab1.ID_PERIODO,
                    sum(nvl(tab2.VALOR_LIQUIDADO,0)) AS VALOR_LIQUIDADO
                    from no_liquida_nomina tab2
                     where  tab2.num_doc = tab1.num_doc
                     and tab2.id_periodo  in (28,499)
                     and tab2.id_concep_nomina =  (select max(no_concep_nomina.id_concep_ajuste) as id_concep_ajuste from no_concep_nomina where tab1.id_concep_nomina = no_concep_nomina.id_concep_nomina)
                    group by tab2.id_tipo_doc,tab2.num_doc,tab2.id_concep_nomina 
              ),0) as val_ajuste*/
              from no_liquida_nomina tab1
              group by tab1.id_tipo_doc,tab1.num_doc,tab1.id_concep_nomina,tab1.id_periodo         
           
            )tab1 ON tab1.id_tipo_doc = tab0.id_tipo_doc and tab1.num_doc = tab0.num_doc 
              and tab1.id_concep_nomina = tab0.id_concep_nomina and tab0.id_periodo_ajuste = tab1.id_periodo


         left join  (
              select 
                tab2.ID_TIPO_DOC,tab2.NUM_DOC,tab2.ID_CONCEP_NOMINA,
                --tab1.ID_PERIODO,
                sum(nvl(tab2.VALOR_LIQUIDADO,0)) AS valor_ajuste
                from no_liquida_nomina tab2
                where tab2.id_periodo  in (28,499)    
                group by tab2.id_tipo_doc,tab2.num_doc,tab2.id_concep_nomina 
          )tab5
          ON tab5.id_tipo_doc = tab0.id_tipo_doc and tab5.num_doc = tab0.num_doc 
              and tab5.id_concep_nomina = tab0.id_concep_ajuste


         left join  (
              select 
                tab2.ID_TIPO_DOC,tab2.NUM_DOC,tab2.ID_CONCEP_NOMINA,
                --tab1.ID_PERIODO,
                sum(nvl(tab2.VALOR_LIQUIDADO,0)) AS valor_rein
                from no_liquida_nomina tab2
                where tab2.id_periodo  in (28,499)    
                group by tab2.id_tipo_doc,tab2.num_doc,tab2.id_concep_nomina 
          )tab6
          ON tab6.id_tipo_doc = tab0.id_tipo_doc and tab6.num_doc = tab0.num_doc 
              and tab6.id_concep_nomina = tab0.id_concep_rein
                    

            where tab0.num_doc IS NOT NULL
            --AND tab0.ID_CONCEP_NOMINA = 7
            and $tag_rn = 1 
            $whereFuncionarioNumDoc
            $whereFuncionarioTipoDoc    
                    
        )           
)
                    
order by
NUM_DOC,
ID_CONCEP_NOMINA
               
EOD;
            //ejecuta y obtiene el resultado del sql
            $results = CN_TABLE::executeSQL($sql);

            /*
             * Memcache
             */
            $i = 1;
            $nom_conceptos_a_procesar = count($results);

            // Antes de inicar el proceso largo
            $brecha = 1;
            if ($nom_conceptos_a_procesar > 100)
                $brecha = $nom_conceptos_a_procesar - (0.99 * $nom_conceptos_a_procesar);

            $this->logMessage("[Liquidación Retroactivo] Liquidar diferencias de mensual.");

            foreach ($results as $resul) {

                // Guardar un valor en el proceso largo
                if ($i % $brecha == 0) {
                    $por = round(($i / $nom_conceptos_a_procesar) * 100, 0);
                    MemcacheHandler::getInstance()->set($progress_key, 90 + ($por / 10));
                }

                $i++;

                $id_liq = $resul['id_liq'];
                $id_periodo = $resul['id_periodo'];
                $id_tipo_doc = $resul['id_tipo_doc'];
                $num_doc = $resul['num_doc'];
                $id_concep_nomina = $resul['id_concep_nomina'];
                $valor = $resul['valor_liquidado'];
                $fecha_desde = $resul['fecha_desde'];
                $fecha_desde = explode(' ', $fecha_desde);
                $fecha_desde = $fecha_desde[0];
                $fecha_hasta = $resul['fecha_hasta'];
                $fecha_hasta = explode(' ', $fecha_hasta);
                $fecha_hasta = $fecha_hasta[0];
                $num_dias = 'null';
                if (!is_null($resul['num_dias'])) {
                    $num_dias = $resul['num_dias'];
                }
                $id_periodo_ajuste = $resul['id_periodo_ajuste'];

                $sql = <<<EOD
DELETE FROM NO_LIQUIDA_NOMINA tab0 
    where tab0.id_tipo_doc = $id_tipo_doc and tab0.num_doc = $num_doc  
    and tab0.id_concep_nomina = $id_concep_nomina 
    and tab0.id_periodo_ajuste =  $id_periodo_ajuste and tab0.id_periodo = $periodo
    and tab0.id_liquida_nomina in ($id_liq)
EOD;
                //ejecuta y obtiene el resultado del sql
                CN_TABLE::executeSQL($sql);

                /*
                 * Se trae el id de concepto nomina si tiene id de ajuste
                 */
                $sql = <<<EOD
select case when tab0.id_concep_ajuste is null then tab0.id_concep_nomina 
    else tab0.id_concep_ajuste end as id_concep_nomina
from no_concep_nomina tab0    
where tab0.id_concep_nomina = $id_concep_nomina   
EOD;

                $results = CN_TABLE::executeSQL($sql);

                $id_concep_nomina = $results[0]['id_concep_nomina'];

                //Validar registros mayores a cero
                if ($valor != 0) {
                    //Crea el nuevo registro en liquida nomina con la diferencia del valor y id de retroactivo
                    $sql = <<<EOD
INSERT INTO NO_LIQUIDA_NOMINA (ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,ID_PERIODO,VALOR_LIQUIDADO,FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE) 
             VALUES($id_tipo_doc,$num_doc,$id_concep_nomina,$id_periodo,$valor,TO_DATE('$fecha_desde','YYYY-MM-DD'),TO_DATE('$fecha_hasta','YYYY-MM-DD'),
             $num_dias,$id_periodo_ajuste)
EOD;
                    //ejecuta y obtiene el resultado del sql
                    CN_TABLE::executeSQL($sql);
                }
            }
            MemcacheHandler::getInstance()->set($progress_key, 99);

            //COMMIT DE TODAS LAS TRANSACCIONES
            $this->logMessage("[Liquidación Retroactivo] COMMIT DE TODAS LAS TRANSACCIONES - Liquidar diferencias de mensual.");
            $this->conn->commit();



            /**
             * **************************************************************
             * Nomina Adicional - 20140304
             * ************************************************************** 
             */
            /*
             * Abrir conexion transaccion
             */
            $this->conn->beginTransaction();

            $id_periodo_ajuste = $id_periodo_aju_men; //periodo de ajuste mensual periodo_ini
            //TRAIGO LOS PERIODOS QUE SE AFECTAN CON LOS PERIODOS SELECCIONADOS - nomina adicional

            $sql = <<<EOD
select tab0.*
from no_periodo tab0 
where tab0.id_tipo_periodo = 2 
and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo) = (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ajuste) 
order by tab0.fecha_fin 
EOD;

            $results = CN_TABLE::executeSQL($sql);

            foreach ($results as $resul) {

                $id_periodo_ajuste = $resul['id_periodo']; //periodo de ajuste - mensual

                /*
                 * Inserta en NO_CONCEPTO_PERIODO los conceptos para cada periodo en el periodo de retroactivo
                 */
                $sql = <<<EOD
INSERT INTO NO_CONCEPTO_PERIODO 
(ID_ANHOS,ID_MESES,PERIODO,ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,FECHA_DESDE,
    FECHA_HASTA,VALOR,PORCENTAJE,NUM_DIAS,ID_PERIODO_AJUSTE)

select 
    
tab0.ID_ANHOS,
tab0.ID_MESES,
tab0.PERIODO,
tab0.ID_TIPO_DOC,
tab0.NUM_DOC,
tab0.ID_CONCEP_NOMINA,
tab0.FECHA_DESDE,
tab0.FECHA_HASTA,
tab0.VALOR,
tab0.PORCENTAJE,
tab0.NUM_DIAS,
tab0.ID_PERIODO_AJUSTE

from(

      select 
      tab0.id_concepto_periodo, tab2.id_meses ID_MESES,tab2.id_anhos ID_ANHOS,
      tab2.id_periodo PERIODO,tab0.id_tipo_doc ID_TIPO_DOC,tab0.num_doc,tab0.id_concep_nomina,
      tab2.fecha_ini AS FECHA_DESDE, tab2.fecha_fin AS FECHA_HASTA,
      tab0.porcentaje AS PORCENTAJE, tab0.num_dias AS NUM_DIAS, tab0.periodo AS ID_PERIODO_AJUSTE,
      
      case when tab0.id_concep_nomina = 1 or tab0.id_concep_nomina = 401 then (
          select tab2.asignacion_basica
                from no_estado_func_v tab1
          left join no_dp_v tab2 ON tab2.id_dp = tab1.id_dp
          where tab1.rn=1 and tab1.num_doc = tab0.num_doc 
          --and tab1.actual = 1 
          and tab1.periodo = $id_periodo_ajuste
      )
      else
      
      tab0.valor end
      
      AS VALOR,tab0.valor AS VALOR_ANTERIOR
      
      from no_concepto_periodo tab0
      left join no_concep_nomina tab1 ON tab1.id_concep_nomina = tab0.id_concep_nomina  
      left join no_periodo tab2 ON tab2.id_periodo = $periodo
      
      where 
      tab0.periodo = $id_periodo_ajuste 
      AND(tab1.id_tipo_concepto=1 or tab1.id_tipo_concepto=2)

)tab0 
                        
                        
join no_estado_func tab3 ON tab3.id_tipo_doc = tab0.id_tipo_doc 
    and tab3.num_doc = tab0.num_doc and tab3.periodo = $periodo
                       
                        
where tab0.num_doc IS NOT NULL and tab0.id_concep_nomina!=(
    select tab2.id_concep_nomina     
    from no_param_concep tab1 
    left join no_concep_nomina tab2 ON tab2.id_concep_nomina = tab1.id_concep_rete
)
                        
$whereFuncionarioNumDoc
$whereFuncionarioTipoDoc    
ORDER BY tab0.NUM_DOC, tab0.ID_CONCEP_NOMINA, tab0.id_periodo_ajuste, tab0.id_concepto_periodo         
                    
EOD;

                $results = CN_TABLE::executeSQL($sql);
            }

            /*
             * Liquida el periodo nuevo de retroactivo - nomina adicional
             */
            $sql = <<<EOD
select tab0.*
from no_periodo tab0 
where tab0.id_tipo_periodo = 2 
and (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = tab0.id_periodo) = (select id_anhos || lpad(id_meses,2,'0') from no_periodo where id_periodo = $id_periodo_ajuste) 
order by tab0.fecha_fin 
EOD;

            $results = CN_TABLE::executeSQL($sql);

            $this->conn->commit();

            /*
             * Recorre los registros de funcionario - concepto nomina
             * para ser liquidados
             */
            $this->logMessage("[Liquidación Retroactivo Adicional] nom_conceptos_a_procesar: " . $nom_conceptos_a_procesar);
            $logPath = sfConfig::get('sf_log_dir') . '/liquidacion.log';
            $custom_logger = new sfFileLogger(new sfEventDispatcher(), array('file' => $logPath));

            $this->logMessage("[Liquidación Retroactivo] Liquidar diferencias de nomina adicional.");

            $si_nom_adic = false;

            //For de liquidar por cada periodo entre el rango
            foreach ($results as $resul) {

                $id_periodo_ajuste = $resul['id_periodo'];
                $si_nom_adic = true;

                //llamar para cada periodo y liquidar
                $this->liquidarRetroactivo($periodo, $id_periodo_ajuste, $progress_key, $record_consulta, $arrayConstantes, $whereFuncionarioNumDoc, $whereFuncionarioTipoDoc, 0);

                $this->logMessage("[Liquidación Retroactivo Adicional] Existen liquidaciones.");
            }

            /*
             * Validar si hay nomina adicional en el mes - 20140410
             */
            if ($si_nom_adic) {

                /*
                 * Abrir conexion transaccion
                 */
                $this->conn->beginTransaction();


                //Traer las diferencias de liquida nomina para rango de periodos
                //Se unen los registros de vacaciones para periodos anteriores . para el primer registro de periodo - 20140303
                $sql = <<<EOD

select ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,$periodo AS ID_PERIODO,
   DIFERENCIA AS VALOR_LIQUIDADO,
       FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE

FROM(

    select ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE,VALOR,VALOR_LIQUIDADO,
        (VALOR - VALOR_LIQUIDADO) AS DIFERENCIA

    FROM(

            select tab0.*,nvl(tab1.valor_liquidado,0) AS VALOR_LIQUIDADO

            from(

                select tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA,tab0.FECHA_DESDE,tab0.FECHA_HASTA,sum(tab0.NUM_DIAS)AS NUM_DIAS,
                    tab0.ID_PERIODO_AJUSTE,sum(nvl(tab0.VALOR_LIQUIDADO,0)) AS VALOR
    
                from no_liquida_nomina tab0
    
                where tab0.id_periodo = $periodo  and tab0.id_periodo_ajuste = $id_periodo_ajuste 
    
                group by tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA,tab0.FECHA_DESDE,tab0.FECHA_HASTA,tab0.ID_PERIODO_AJUSTE
    
                order by tab0.ID_PERIODO_AJUSTE,tab0.ID_TIPO_DOC,tab0.NUM_DOC,tab0.ID_CONCEP_NOMINA
    
            )tab0                 

            left join 
            (select tab1.ID_TIPO_DOC,tab1.NUM_DOC,tab1.ID_CONCEP_NOMINA,tab1.ID_PERIODO,sum(nvl(tab1.VALOR_LIQUIDADO,0)) AS VALOR_LIQUIDADO
            from no_liquida_nomina tab1
            group by tab1.id_tipo_doc,tab1.num_doc,tab1.id_concep_nomina,tab1.id_periodo               
            )tab1 ON tab1.id_tipo_doc = tab0.id_tipo_doc and tab1.num_doc = tab0.num_doc 
                and tab1.id_concep_nomina = tab0.id_concep_nomina and tab0.id_periodo_ajuste = tab1.id_periodo

            where tab0.num_doc IS NOT NULL
            AND tab0.ID_CONCEP_NOMINA!=(select tab2.id_concep_nomina from no_param_concep tab1 
            left join no_concep_nomina tab2 ON tab2.id_concep_nomina = tab1.id_concep_rete) 
            $whereFuncionarioNumDoc
            $whereFuncionarioTipoDoc 
                    
        )           
)
               
EOD;
                //ejecuta y obtiene el resultado del sql
                $results = CN_TABLE::executeSQL($sql);

                $this->logMessage("[Liquidación Retroactivo] Liquidar diferencias de nomina adicional.");

                foreach ($results as $resul) {

                    $id_periodo = $resul['id_periodo'];
                    $id_tipo_doc = $resul['id_tipo_doc'];
                    $num_doc = $resul['num_doc'];
                    $id_concep_nomina = $resul['id_concep_nomina'];
                    $valor = $resul['valor_liquidado'];
                    $fecha_desde = $resul['fecha_desde'];
                    $fecha_desde = explode(' ', $fecha_desde);
                    $fecha_desde = $fecha_desde[0];
                    $fecha_hasta = $resul['fecha_hasta'];
                    $fecha_hasta = explode(' ', $fecha_hasta);
                    $fecha_hasta = $fecha_hasta[0];
                    $num_dias = 'null';
                    if (!is_null($resul['num_dias'])) {
                        $num_dias = $resul['num_dias'];
                    }
                    $id_periodo_ajuste = $resul['id_periodo_ajuste'];

                    $sql = <<<EOD
DELETE FROM NO_LIQUIDA_NOMINA tab0 
    where tab0.id_tipo_doc = $id_tipo_doc and tab0.num_doc = $num_doc  
    and tab0.id_concep_nomina = $id_concep_nomina 
    and tab0.id_periodo_ajuste =  $id_periodo_ajuste and tab0.id_periodo = $periodo
EOD;
                    //ejecuta y obtiene el resultado del sql
                    CN_TABLE::executeSQL($sql);

                    /*
                     * Se trae el id de concepto nomina si tiene id de ajuste
                     */
                    $sql = <<<EOD
select case when tab0.id_concep_ajuste is null then tab0.id_concep_nomina 
    else tab0.id_concep_ajuste end as id_concep_nomina
from no_concep_nomina tab0    
where tab0.id_concep_nomina = $id_concep_nomina   
EOD;

                    $results = CN_TABLE::executeSQL($sql);

                    $id_concep_nomina = $results[0]['id_concep_nomina'];

                    //Validar registros mayores a cero
                    if ($valor != 0) {
                        //Crea el nuevo registro en liquida nomina con la diferencia del valor y id de retroactivo
                        $sql = <<<EOD
INSERT INTO NO_LIQUIDA_NOMINA (ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,ID_PERIODO,VALOR_LIQUIDADO,FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE) 
             VALUES($id_tipo_doc,$num_doc,$id_concep_nomina,$id_periodo,$valor,TO_DATE('$fecha_desde','YYYY-MM-DD'),TO_DATE('$fecha_hasta','YYYY-MM-DD'),
             $num_dias,$id_periodo_ajuste)
EOD;
                        //ejecuta y obtiene el resultado del sql
                        CN_TABLE::executeSQL($sql);
                    }
                }

                //COMMIT DE TODAS LAS TRANSACCIONES
                $this->logMessage("[Liquidación Retroactivo] COMMIT DE TODAS LAS TRANSACCIONES - Liquidar diferecias de nomina adicional.");
                $this->conn->commit();
            }

            $this->logMessage("[Liquidación Retroactivo] Fin - Liquidar diferecias de nomina adicional.");

            /*
             * Final mencache
             */
            MemcacheHandler::getInstance()->set($progress_key, 100);

            $records = array();

            $this->totalRows = 0;
            $this->startRow = 0;
            $this->endRow = 0;
            $this->list_data = $records;
            $this->logMessage("[Liquidación Retroactivo] Liquidación exitosa.");
        } catch (Exception $e) {
            MemcacheHandler::getInstance()->set($progress_key, 99);

            //ROLLBACK DE TODAS LAS TRANSACCIONES EN CASO DE QUE OCURRA ALGUN ERROR
            $this->conn->rollback();
            MemcacheHandler::getInstance()->set($progress_key, 100);

            $this->status = 1;
            $this->totalRows = 0;
            $this->startRow = 0;
            $this->endRow = 0;
            $this->mensajeError = "[Liquidación Retroactivo] Ocurrio un error: " . $e->getMessage();
            $this->list_data = array();
            $this->logMessage("[Liquidación Retroactivo] ERROR!!!");
            $this->logMessage($e->getMessage());
        }
    }

    /**
     * Calcular FSP aporte funcionario
     * @param type $valor_base
     * @param type $salario_minimo
     * @return int
     */
    private function valor_base_fsp($valor_base, $salario_minimo, $valor_base_vac = 0, $wdiasv = 0, $dias_liq, $num_doc, $id_periodo_ajuste) {

        $this->logMessage("[Liquidación] valor_base_fsp:: valor_base: " . $valor_base . " - valor_base_vac: " . $valor_base_vac);
        $this->logMessage("[Liquidación] valor_base_fsp:: wdiasv: " . $wdiasv . " - dias_liq: " . $dias_liq);


        /*
         * WBASE=   BASE TOTAL que ya estamos hayando
         * WVRBASE=(WBASE/(WDIAST+WDIASV))*30
         * Sobre WVRBASE  verifica si debe calcular FSP y sobre ella misma ubicar el porcentaje 
         * Si aplica y tiene el porcentaje,  aplica el porcentaje sobre WBASE
         * 20131216
         */
        $valor = 0;
        $valorfps1 = 0;
        $valorfps2 = 0;
        $porcentaje = 0;

        /*
         * Operaciones
         */
        $wvalor_base = ($valor_base / ($dias_liq + $wdiasv)) * 30;


        /**
         * Valida si la persona ingreso en el mes o se retira para tomar los dias en cuenta - 20140307
         */
        $this->logMessage("[Liquidación] Valida si la persona - wvalor_base :: " . $wvalor_base);
        //Sql
        $sql = <<<EOD
select 
nom.* 
from no_nombramiento_v nom
where 
nom.id_tipo_doc = 1
and nom.num_doc = $num_doc
and (
nom.fecha_ingreso between (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) and (select per.fecha_fin from no_periodo per where per.id_periodo = $id_periodo_ajuste)
or 
nom.fecha_termina between (select per.fecha_ini from no_periodo per where per.id_periodo = $id_periodo_ajuste) and (select per.fecha_fin from no_periodo per where per.id_periodo = $id_periodo_ajuste)
)                
EOD;
        //Ejecutar SQL
        $records = CN_TABLE::executeSQL($sql);

        /*
         * Valida si posee formula el concepto
         */
        if (count($records) > 0) {
            $wvalor_base = $valor_base + $valor_base_vac;
        }


        //Cambio de verificacion del valor base - 20131216
        if (($wvalor_base) > ($salario_minimo * 4) && ($wvalor_base) <= ($salario_minimo * 16)) {
            $porcentaje = 1;
        } elseif (($wvalor_base) > ($salario_minimo * 16) && ($wvalor_base) <= ($salario_minimo * 17)) {
            $porcentaje = 1.2;
        } elseif (($wvalor_base) > ($salario_minimo * 17) && ($wvalor_base) <= ($salario_minimo * 18)) {
            $porcentaje = 1.4;
        } elseif (($wvalor_base) > ($salario_minimo * 18) && ($wvalor_base) <= ($salario_minimo * 19)) {
            $porcentaje = 1.6;
        } elseif (($wvalor_base) > ($salario_minimo * 19) && ($wvalor_base) <= ($salario_minimo * 20)) {
            $porcentaje = 1.8;
        } elseif (($wvalor_base) > ($salario_minimo * 20)) {
            $porcentaje = 2;
        }

        /* INCI - 20140122
         * Patricia Montoya Falla, C.C. 35.462.698,
          Esperanza Verdugo, C.C.  46.662.659
          Yanerys Irina de la Hoz, C.C.  57.290.110
          Vladimir Yanken Cifuentes, C.C. 79.526.123
          Gustavo Pulido Casas, C.C. 93.288.443
         * 39773464
         */
        if ($num_doc == '35462698' || $num_doc == '46662659' || $num_doc == '57290110' || $num_doc == '79526123' || $num_doc == '93288443' || $num_doc == '51788859') {
            if (($valor_base + $valor_base_vac) > ($salario_minimo * 4) && ($valor_base + $valor_base_vac) <= ($salario_minimo * 16)) {
                $porcentaje = 1;
            } elseif (($valor_base + $valor_base_vac) > ($salario_minimo * 16) && ($valor_base + $valor_base_vac) <= ($salario_minimo * 17)) {
                $porcentaje = 1.2;
            } elseif (($valor_base + $valor_base_vac) > ($salario_minimo * 17) && ($valor_base + $valor_base_vac) <= ($salario_minimo * 18)) {
                $porcentaje = 1.4;
            } elseif (($valor_base + $valor_base_vac) > ($salario_minimo * 18) && ($valor_base + $valor_base_vac) <= ($salario_minimo * 19)) {
                $porcentaje = 1.6;
            } elseif (($valor_base + $valor_base_vac) > ($salario_minimo * 19) && ($valor_base + $valor_base_vac) <= ($salario_minimo * 20)) {
                $porcentaje = 1.8;
            } elseif (($valor_base + $valor_base_vac) > ($salario_minimo * 20)) {
                $porcentaje = 2;
            }
        }
        //num_doc in (13507148, 51653492 ,79250331 ,52779827 ,20404209)
        if ($num_doc == '51653492' || $num_doc == '79250331' || $num_doc == '6193881') {
            $porcentaje = 0;
        }

        $valorfps1 = round($valor_base * 0.5 / 100, -2);
        $valorfps2 = round($valor_base * ($porcentaje - 0.5) / 100, -2);

        $valor = $valorfps1 + $valorfps2;

        $array_fsp = array(
            'valor_fsp' => $valor,
            'porcentaje_fsp' => $porcentaje
        );

        return $array_fsp;
    }

    /**
     * Procesa la liquidacion para el periodo, funcionario y concepto nomina
     * @param type $id_periodo
     * @param type $num_doc
     * @param type $id_tipo_doc
     * @param type $id_concep_nomina
     * @param type $record_liq
     * @param type $arrayConstantes
     */
    private function liquidar($id_periodo, $num_doc, $id_tipo_doc, $id_concep_nomina, $record_liq, $arrayConstantes, $record_consulta, $id_periodo_ajuste) {
        $this->logMessage("[Liquidación Retroactivo] Liquidar: periodo " . $id_periodo .
                " - funcionario " . $num_doc . " - concepto nomina " . $id_concep_nomina);

        /**
         * Varibles
         */
        $arrayParametros = array();
        /*
         * Variable para optimizar consultas de formulas en las liquidaciones - 20140117
         */
        $vals_calc = array();
        $valor_liquidado = 0;
        $fecha_desde = $record_liq['fecha_desde'];
        $fecha_hasta = $record_liq['fecha_hasta'];
        $num_dias = $record_liq['num_dias'];
        $id_periodo_ajuste_conper = $record_liq['id_periodo_ajuste'];

        //Concepto Nomina 1009 Vacaciones
        if ($id_concep_nomina == 9) {
            $record_liq['vig_ini'] = $record_liq['id_anhos'];
            $record_liq['per_ini'] = 1;
            $record_liq['vig_fin'] = $record_liq['id_anhos'];
            $record_liq['per_fin'] = $record_liq['id_meses'];
        }

        /*
         * Valor Base y porcentaje
         */
        $porcentaje = 'null';
        $valor_base = 'null';

        /*
         * Cargar fórmulas por concepto
         * Se modifico formula Para aporte en salud, pensión y FSP  existe un tope máximo de aporte de 25 SMLV
         * se toma del id_concep_nomina asociado al descuento - 20130814
         */
        //Sql
        $sql = <<<EOD
select distinct * from no_formula 
   WHERE id_concep_nomina =   (    
   
  select distinct 
  nvl( id_concep_nomina_ss, ID_CONCEP_NOMINA) as ID_CONCEP_NOMINA 
  from
  (
  
      select 
      formula.ID_FORMULA,
      formula.ID_CONCEP_NOMINA,
      formula.FORMULA,
      formula.NOMBRE,
      formula.COD_TIPO,
      foncon.id_descuento_ss,
      des.id_concep_nomina as id_concep_nomina_ss
      from no_formula formula
      left join no_fondo_concepto foncon
      on formula.id_concep_nomina = foncon.id_concep_nomina
      left join no_descuento_ss des
      on foncon.id_descuento_ss = des.id_descuento_ss
      where formula.id_concep_nomina = $id_concep_nomina 
  
  )

)   
EOD;
        //Ejecutar SQL
        $records = CN_TABLE::executeSQL($sql);

        /*
         * Valida si posee formula el concepto
         */
        if (count($records) > 0) {
            $this->logMessage("[Liquidación Retroactivo] Entro a calcular Formula.");

            foreach ($records as $value) {

                $formula = $value['formula'];
                $this->logMessage("[Liquidación Retroactivo] Formula Inicial: " . $formula);


                /*
                 *  Buscar las constantes, variables, fórmulas(parametros) y agrupaciones que use la fórmula
                 */
                //Reemplazo de constantes            
                $formula = $this->reemplazoConstante($formula, $arrayConstantes);
                $this->logMessage("[Liquidación Retroactivo] Formula Constante: " . $formula);

                /*
                 * Reemplaza en la consulta los filtros y valores del SQL, que vienen en el record
                 * Ejemplo: select raz_soc from id_cia where id_cia = $id_cia
                 * Reemplaza $id_cia por el valor en el record
                 */
                $formula = CN_TABLE::reemplazoConsulta($formula, $record_liq);
                $this->logMessage("[Liquidación Retroactivo] Formula consulta los filtros: " . $formula);

                /*
                 * Cambio en la formula de A por (C1+C2)
                 */
                $vars = array();

                CN_TABLE::getVarsInFormula($vars, $formula);

//        var_dump($vars);

                foreach ($vars as $var) {
                    if (substr($var, 0, 1) == 'A') {
                        /*
                         * Cambio de A1 por relacion con los conceptos C1
                         * Ejemplo: 'A1' => '0'
                         */
                        $this->logMessage("[Liquidación] vals_calc: " . $var);
                        if (!isset($vals_calc[$var])) {
                            $formula_agrup = $this->reemplazoAgrupacion(substr($var, 1));
                            $this->logMessage("[$var] [Liquidación Agrupación] Agrupacion: " . $formula_agrup);

                            // $formula = str_replace('{' . $var . '}', $agrup, $formula);
                            $params_agrup = $this->parametrosFormula($formula_agrup);
                            $res_agrup = $this->resultadoParametros($params_agrup, $record_liq, $record_consulta, $vals_calc);
                            $formula_agrup = $this->reemplazoParametros($formula_agrup, $res_agrup);

                            $formula_agrup = str_replace('{', ' ', $formula_agrup);
                            $formula_agrup = str_replace('}', ' ', $formula_agrup);
                            $result_agrup = CN_TABLE::aplicarEval($formula_agrup);

                            /*
                             * No cumple con la condicion
                             */
                            //                if ($result === false) {
                            if ($result_agrup == '-9999' || $result_agrup == -9999) {
                                $this->logMessage("[$var] [Liquidación Agrupación] Formula No cumple con la condicion: " . $formula_agrup);
                                $result_agrup = 0;
                            }

                            $vals_calc[$var] = $result_agrup;
                        }

                        $formula = str_replace('{' . $var . '}', $vals_calc[$var], $formula);
                    }
                }
                $this->logMessage("[Liquidación Retroactivo] Formula parametrosFormula y reemplazoAgrupacion: " . $formula);


                /*
                 * Parser de la formula para obtener parametros(variables)
                 * Ejemplo: 'A1' => '0',
                 * 'C1' => '0'
                 */
                $arrayParametros = $this->parametrosFormula($formula);


                /*
                 * Obtener resultados de los parametros(variables)
                 * Ejemplo: $arrayParametros = array(
                 * 'C1' => '0',
                 * 'C2' => '0'
                 * );
                 */
                $arrayParametros2 = $this->resultadoParametros($arrayParametros, $record_liq, $record_consulta, $vals_calc);


                /*
                 * Reemplazo de parametros(variables) a la formula
                 * Ejemplo: $arrayParametros = array(
                 * 'C1' => '1100',
                 * 'C2' => '55'
                 * );
                 */
                $formula = $this->reemplazoParametros($formula, $arrayParametros2);
                $this->logMessage("[Liquidación Retroactivo] Formula Final: " . $formula);


                /*
                 * Ejecutar fórmula
                 * Ejemplo: ( 0 == 0 ? {C1} * $porcentaje : false )
                 * Retorna false  si no cumple con la condicion
                 */
                $formula = str_replace('{', ' ', $formula);
                $formula = str_replace('}', ' ', $formula);
                $result = CN_TABLE::aplicarEval($formula);


                /*
                 * No cumple con la condicion
                 */
                if ($result === false) {
                    $this->logMessage("[Liquidación Retroactivo] Formula No cumple con la condicion: " . $formula);
                    $result = 0;
                }


                /*
                 * Acumulan resultados de liquidacion
                 */
                if ($result !== -9999) // Validar al cumplir condicion -9999 - no cumplue con la condicion de la formula
                    $valor_liquidado += $result;

                /*
                 * Si es por porcentaje
                 */
                if ($record_liq['porcentaje'] != '' || $record_liq['porcentaje'] != null) {
                    /*
                     * Tipo de formula
                     * V - Valor base 
                     * R - Valor restado 
                     * F - Valor de la fórmula (Uso normal)
                     */
                    if ($value['cod_tipo'] == 'V') {
                        $this->logMessage("[Liquidación Retroactivo] Formula CodTipo: " . $value['cod_tipo']);

                        /*
                         * Valor Base y porcentaje
                         */
                        $porcentaje = $record_liq['porcentaje'];
                        $valor_base = ($result * 100) / $record_liq['porcentaje'];
                    }
                }
            }
        } else {

            /*
             * La liquidación se hacer por 2 espacios temporales:
             *
             * - Mensual
             * En cuyo caso, todos los meses tienen una duración de 30 días
             * - Por días calendario
             * En cuyo caso se hace por la cantidad de días especificada en no_concepto_periodo.num_dias
             * 
             * Esta especificación, si se hace mensual o usando los días, lo especifica la variable no_concep_nomina.dias_calendario
             * 
             * Si se hace una interrupción en un concepto, digamos algún cargo temporal, debe liquidarse el valor del concepto asÍ: 
             * Ejemplo: $valor = ($valor_liquidado_concepto_mes/30)*$num_dias
             */

            /*
             * Si es por porcentaje y diferente de 0
             */
            if (($record_liq['porcentaje'] != '' || $record_liq['porcentaje'] != null) && $record_liq['porcentaje'] != 0) {
                $this->logMessage("[Liquidación Retroactivo] Calcular porcentaje - " . $record_liq['porcentaje']);


                //Sql
                $sql = <<<EOD
select * from no_liquida_nomina 
where id_concep_nomina = (select id_concep_basica from no_param_concep where id_param_concep = 1)
and id_periodo = $id_periodo
and id_tipo_doc = $id_tipo_doc
and num_doc = '$num_doc' 
EOD;
                //Ejecutar SQL
                $records = CN_TABLE::executeSQL($sql);

                if (count($records) <= 0) {
                    $records[0]['valor_liquidado'] = 0;
                }

                //Resultado del calculo de porcentaje
                $result = ($records[0]['valor_liquidado'] * $record_liq['porcentaje']) / 100;

                /*
                 * Valor Base y porcentaje
                 */
                $porcentaje = $record_liq['porcentaje'];
                $valor_base = $records[0]['valor_liquidado'];
            } else {
                $this->logMessage("[Liquidación Retroactivo] Calcular valor - " . $record_liq['valor']);

                if (!is_null($record_liq['num_dias'])) {

                    /*
                     * usa_dias_calen
                     */
                    if ($record_liq['usa_dias_calen'] == 0) { //Mensual
                        $num_dias = 30;
                        $num_dias = $record_liq['num_dias']; // ? Revisar
                    } else { //Por días calendario
                        $num_dias = $record_liq['num_dias'];
                    }

                    $result = ($record_liq['valor'] / 30) * $num_dias;
                    $this->logMessage("[Liquidación Retroactivo] Num_dias - " . $num_dias);
                } else {
                    $num_dias = 'null';
                    $result = $record_liq['valor'];
                }
            }

            $valor_liquidado += $result;
        }

        /*
         * Valida creacion de registro
         */
        if ($valor_liquidado > 0) {

            $this->logMessage("[Liquidación Retroactivo] El valor liquidado es: " . $valor_liquidado);

            /*
             * Crear nueva liquidación
             * 
             * Asignar valores encontrados en persona
             */
            //insert into no_liquida_nomina (id_liquida_nomina,id_tipo_doc,num_doc,id_concep_nomina,
            //id_periodo,valor_liquidado,fecha_desde,fecha_hasta,num_dias) 
            //values ('9','1','17304849','1','13','257100',to_date('22/11/12','DD/MM/RR'),
            //to_date('22/11/12','DD/MM/RR'),'30');
            //Sql
            $sql = <<<EOD
insert into no_liquida_nomina (id_tipo_doc, num_doc, id_concep_nomina,
        id_periodo,valor_liquidado,fecha_desde,fecha_hasta,num_dias, valor_base, 
            porcentaje, id_periodo_ajuste ) 
        values ( $id_tipo_doc, '$num_doc', $id_concep_nomina, $id_periodo, round( $valor_liquidado, 0), 
        to_date('$fecha_desde','YYYY-MM-DD'), to_date('$fecha_hasta','YYYY-MM-DD'), $num_dias, round( $valor_base, 0), 
                    $porcentaje, $id_periodo_ajuste_conper ) 
EOD;
            //Ejecutar SQL
            CN_TABLE::executeSQL($sql);
        } else {

            $this->logMessage("[Liquidación Retroactivo] El valor_liquidado es menor a cero.");
        }
    }

    /**
     * Reemplaza en la formula las constantes por valores de la tabla NO_CONSTANTE
     * Ejemplo: $con_1
     * @param type $formula
     * @param type $arrayConstantes
     */
    private function reemplazoConstante($formula, $arrayConstantes) {

        /*
         * Recorrer array de Constantes
         */
        foreach ($arrayConstantes as $key => $value) {

            $formula = str_replace($key, $value['valor'], $formula);
        }

        return $formula;
    }

    /**
     * Reemplaza los parametros(variables) a la formula
     * Ejemplo: $key: {C1} / $value: valor - 2+5
     * @param type $formula
     * @param type $arrayParametros
     */
    private function reemplazoParametros($formula, $arrayParametros) {

        /*
         * Recorrer array de Parametros
         */
        foreach ($arrayParametros as $key => $value) {

            $formula = str_replace('{' . $key . '}', $value, $formula);
        }

        return $formula;
    }

    /**
     * Obtener resultados de los parametros(variables)
     * Ejemplo: 'C1' => '0'
     * @param type $arrayParametros
     * @param type $record_liq
     */
    private function resultadoParametros($arrayParametros, $record_liq, $record_consulta, $vals_calc) {

//        $logPath = sfConfig::get('sf_log_dir') . '/liquidacion.log';
//        $custom_logger = new sfFileLogger(new sfEventDispatcher(), array('file' => $logPath));
//
//        $custom_logger->info("[Liquidación] memory_get_usage ini resultadoParametros: " . CN_TABLE::convert(memory_get_usage()) . "\n");
        /*
         * Recorrer array de Parametros
         */
        foreach ($arrayParametros as $key => $value) {

            //Sacar caracter y numero(id_concep_nomina) para consulta
            $caracter = substr($key, 0, 1);
            $id_concep_nomina = substr($key, 1);
            $this->logMessage("[Liquidación Retroactivo] Caracter: " . $caracter . ", numero: " . $id_concep_nomina);

            /*
             * Obtener consulta por caracter
             */
//            //Sql
//            $sql = <<<EOD
//select * from NO_CONSULTA where caracter = '$caracter' 
//EOD;
//            //Ejecutar SQL
//            $record = CN_TABLE::executeSQL($sql);
            //Validar registros SQL
            if (count($record_consulta) > 0) {
//                $this->logMessage("[Liquidación] Caracter: " . $record_consulta[$caracter]['caracter'] . ", consulta: " . $record_consulta[$caracter]['consulta']);
//                die();
//                $consulta = $record[0]['consulta'];

                $this->logMessage("[Liquidación Retroactivo] Concat vals_calc: " . $caracter . $id_concep_nomina);
                if (!isset($vals_calc[$caracter . $id_concep_nomina])) {
                    $consulta = $record_consulta[$caracter]['consulta'];

                    /*
                     * Variables y estructura para manejo de consultas con variables bind - 20130829
                     */
                    //Reemplazo de $ por : para variables bind
//                $consulta = str_replace('$', ':', $consulta);
                    //Reemplazo de id_concep_nomina
                    $consulta = str_replace('$id_concep_nomina', $id_concep_nomina, $consulta);

                    /*
                     * Reemplaza en la consulta los filtros y valores del SQL, que vienen en el record
                     * Ejemplo: select raz_soc from id_cia where id_cia = $id_cia
                     * Reemplaza $id_cia por el valor en el record
                     */
                    $consulta = CN_TABLE::reemplazoConsulta($consulta, $record_liq);

                    /*
                     * Ejecutar SQL de consulta
                     * select nvl(sum(valor_liquidado),0) as valor from no_liquida_nomina where id_periodo = :periodo - ejemplo bind
                     */
                    //Sql
                    $sql = <<<EOD
$consulta  
EOD;
                    /*
                     * Variables y estructura para manejo de consultas con variables bind - 20130829
                     */
//                $record_var_bind = array(
//                    'id_tipo_doc' => 'id_tipo_doc',
//                    'num_doc' => 'num_doc',
//                    'id_concep_nomina' => 'id_concep_nomina',
//                    'id_periodo' => 'id_periodo'
//                );
                    //Get the variables within the consulta
//        $custom_logger->info("[Liquidación] memory_get_usage 1 resultadoParametros: " . CN_TABLE::convert(memory_get_usage()) . "\n");
//                $vars = array();
//                CN_TABLE::getVarsInConsulta($vars, $sql);
//                $record_var_bind = $vars;
////                var_dump($record_var_bind);
//                $record_bind = $record_liq;
//                $record_bind['id_concep_nomina'] = $id_concep_nomina;
                    //Ejecutar SQL
                    $record = CN_TABLE::executeSQL($sql);
//                $sql = str_replace("'", null, $sql);
//                $custom_logger->info("[Liquidación] memory_get_usage 2 resultadoParametros: " . CN_TABLE::convert(memory_get_usage()) . "\n");
//                $record = CN_TABLE::executeBindSQL($sql, null, $record_var_bind, $record_bind);
//                $custom_logger->info("[Liquidación] memory_get_usage 3 resultadoParametros: " . CN_TABLE::convert(memory_get_usage()) . "\n");
                    /*
                     * Validar registros SQL
                     */
                    if (count($record) > 0) {
                        $valor = $record[0]['valor'];
                    } else {
                        $valor = 0;
                    }
                    $vals_calc[$caracter . $id_concep_nomina] = $valor;
                }
                $valor = $vals_calc[$caracter . $id_concep_nomina];
            } else {
                $valor = 0;
            }

            $arrayParametros[$key] = $valor;

            $this->logMessage("[Liquidación Retroactivo] Valor por Caracter: " . $valor);
        }
        //Destruye una variable especificada
//        $custom_logger->info("[Liquidación] memory_get_usage pre resultadoParametros: " . CN_TABLE::convert(memory_get_usage()) . "\n");
//        unset($vars, $record_var_bind, $record_bind, $record_liq, $record, $key, $sql, $valor, $record_consulta, $consulta, $caracter);
//        $custom_logger->info("[Liquidación] memory_get_usage post resultadoParametros: " . CN_TABLE::convert(memory_get_usage()) . "\n");
        return $arrayParametros;
    }

    /**
     * Parser de la formula para obtener parametros(variables)
     * Ejemplo: 'C1' => '0'
     * @param type $formula
     * @param type $arrayParametros
     */
    private function parametrosFormula($formula) {

        $vars = array();
        $arrayParametros = array();
        CN_TABLE::getVarsInFormula($vars, $formula);

        foreach ($vars as $var) {
            $arrayParametros[$var] = 0;
        }

//        var_dump($arrayParametros);
//        exit();
//        $arrayParametros = array(
//            'C1' => '0',
//            'C2' => '0',
//            'T1' => '0',
//            'A1' => '0'
//        );

        return $arrayParametros;
    }

    /**
     * Reemplaza las agrupaciones por los parametros(variables)
     * Ejemplo: A1 -> (+C1-C2-T1)
     * @param type $id_agrup_var
     */
    private function reemplazoAgrupacion($id_agrup_var) {

        $agrup = '( ';

        /*
         * Ejecutar SQL de agrupciones
         */
        //Sql
        $sql = <<<EOD
select 
agru.*,
agru.tipo_valor as caracter
from
no_agrup_deta agru
where agru.id_agrup_concepto = $id_agrup_var  
EOD;
        //Ejecutar SQL
        $records = CN_TABLE::executeSQL($sql);

        /*
         * Recorrer registros 
         */
        foreach ($records as $value) {

            $operador = ($value['operador'] == 1 ? '+' : '-');

            //Concatenar todas las agrupaciones
            $agrup .= $operador . '{' . $value['caracter'] . $value['id_concep_nomina'] . '}';
        }

        $agrup .= ' )';

        return $agrup;
    }

    /**
     * Metodo para liquidar un periodo unicamente
     * 
     * @param type $id_periodo
     * @param type $id_periodo_ajuste
     * @param type $progress_key
     * @param type $record_consulta
     * @param type $arrayConstantes
     * @param type $whereFuncionarioNumDoc
     * @param type $whereFuncionarioTipoDoc
     */
    public function liquidarRetroactivo($id_periodo, $id_periodo_ajuste, $progress_key, $record_consulta, $arrayConstantes, $whereFuncionarioNumDoc, $whereFuncionarioTipoDoc, $tag_rn) {
        $this->logMessage("[Liquidación Retroactivo] Entro a liquidarRetroactivo");

        $i = 0;
        /*
         * Variable para optimizar consultas de formulas en las liquidaciones - 20140117
         */
        $vals_calc = array();

        /**
         * Manejador de errores
         */
        try {
            /*
             * Abrir conexion transaccion
             */
            $this->conn = Doctrine_Manager::getInstance()->getCurrentConnection();
            $this->conn->beginTransaction();

            /**
             * Consultar salario minimo
             */
            $salario_minimo = 550000;
            //Sql
            $sql = <<<EOD
(select nvl(valor_mensual, 0) as valor_mensual from no_smdlv where vigencia = extract(year from sysdate))  
EOD;
            //Ejecutar SQL
            $record_smlv = CN_TABLE::executeSQL($sql);

            if (count($record_smlv) > 0) {
                $salario_minimo = $record_smlv[0]['valor_mensual'];
            }

            /*
             * Tomar valores de NO_AJUSTE_NOMINA
             */
            if ($tag_rn == 1) {
                //Sql
                $sql = <<<EOD
Insert into NO_LIQUIDA_NOMINA (ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,ID_PERIODO,VALOR_LIQUIDADO,FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE) 

select 
tab0.id_tipo_doc,
tab0.num_doc,
tab0.id_concep_nomina,
tab0.id_periodo,
tab0.valor_ajuste,
 to_date( '01/' || per.id_meses || '/' || per.id_anhos, 'dd/mm/yyyy')  as fecha_desde,
TRUNC(LAST_DAY( to_date(per.id_meses || '/' || per.id_anhos, 'mm/yyyy')  )) as fecha_hasta,
tab0.num_dias,
tab0.ID_PERIODO_AJUSTE
from no_ajuste_nomina tab0
join no_periodo per
on per.id_periodo = tab0.id_periodo 
WHERE tab0.id_periodo = $id_periodo
and tab0.id_periodo_ajuste in (25, 28, $id_periodo_ajuste )
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
EOD;
            } else {
                //Sql
                $sql = <<<EOD
Insert into NO_LIQUIDA_NOMINA (ID_TIPO_DOC,NUM_DOC,ID_CONCEP_NOMINA,ID_PERIODO,VALOR_LIQUIDADO,FECHA_DESDE,FECHA_HASTA,NUM_DIAS,ID_PERIODO_AJUSTE) 

select 
tab0.id_tipo_doc,
tab0.num_doc,
tab0.id_concep_nomina,
tab0.id_periodo,
tab0.valor_ajuste,
 to_date( '01/' || per.id_meses || '/' || per.id_anhos, 'dd/mm/yyyy')  as fecha_desde,
TRUNC(LAST_DAY( to_date(per.id_meses || '/' || per.id_anhos, 'mm/yyyy')  )) as fecha_hasta,
tab0.num_dias,
tab0.ID_PERIODO_AJUSTE
from no_ajuste_nomina tab0
join no_periodo per
on per.id_periodo = tab0.id_periodo 
WHERE tab0.id_periodo = $id_periodo
and tab0.id_periodo_ajuste in ( $id_periodo_ajuste )
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
EOD;
            }

            //Ejecutar SQL
            CN_TABLE::executeSQL($sql);

            /*
             * Cargar Periodo-Funcionario-Concepto
             * 
             * Cargar Funcionarios
             * 
             * Para cada persona
             * 
             * Cargar conceptos que apliquen en periodo para la persona, en orden de ejecución
             */
            //No liquida conceptos entre 4000 y 4999 - 20130626
            //TODO: Revisar cantidad dias de vacaiones de periodos anteriores - 20130627
            /*
             * select 
              novvac.id_tipo_doc,
              novvac.num_doc,
              nvl(sum(dias_rango_mes(novvac.fecha_ini,novvac.fecha_fin,(select id_meses
              from NO_PERIODO where ID_PERIODO =  $id_periodo_ajuste))),0) as DIAS,
              NVL(SUM( NOVVAC.FECHA_FIN - NOVVAC.FECHA_INI + 1),0) as DIAS_VAC,
              --DIAS_RANGO_MES_SIN_TREINTAYUNO( NOVVAC.FECHA_INI, NOVVAC.FECHA_FIN, 1 ) as DIAS_vac_mes
              from no_novedad_vac novvac
              left join no_tipo_nov_vac tipnov on tipnov.id_tipo_nov_vac = novvac.id_tipo_nov_vac
              where TIPNOV.TIEMPO_LIQUI = 1

              and NOVVAC.ID_PERIODO = $id_periodo_ajuste
              /*
              and(
              NOVVAC.FECHA_INI between TO_DATE('01/'|| (select LPAD(ID_MESES,2,'0') ||'/'||ID_ANHOS from NO_PERIODO where ID_PERIODO = $id_periodo_ajuste) ,'dd/mm/yyyy')
              and TRUNC(LAST_DAY( TO_DATE('01/'|| (select LPAD(ID_MESES,2,'0') ||'/'||ID_ANHOS from NO_PERIODO where ID_PERIODO = $id_periodo_ajuste) ,'dd/mm/yyyy') ))
              or
              NOVVAC.FECHA_FIN between TO_DATE('01/'|| (select LPAD(ID_MESES,2,'0') ||'/'||ID_ANHOS from NO_PERIODO where ID_PERIODO = $id_periodo_ajuste) ,'dd/mm/yyyy')
              and TRUNC(LAST_DAY( TO_DATE('01/'|| (select LPAD(ID_MESES,2,'0') ||'/'||ID_ANHOS from NO_PERIODO where ID_PERIODO = $id_periodo_ajuste) ,'dd/mm/yyyy') ))
              or


              TO_DATE('01/'|| (select LPAD(ID_MESES,2,'0') ||'/'||ID_ANHOS from NO_PERIODO where ID_PERIODO = $id_periodo_ajuste) ,'dd/mm/yyyy') between novvac.fecha_ini and novvac.FECHA_FIN
              or
              TRUNC(LAST_DAY( TO_DATE('01/'|| (select LPAD(ID_MESES,2,'0') ||'/'||ID_ANHOS from NO_PERIODO where ID_PERIODO = $id_periodo_ajuste) ,'dd/mm/yyyy') )) between NOVVAC.FECHA_INI and NOVVAC.FECHA_FIN
              )
              group by NOVVAC.ID_TIPO_DOC, NOVVAC.NUM_DOC
              --, NOVVAC.FECHA_INI, novvac.FECHA_FIN
             */
            $filtro_per_aju = " and tab0.id_periodo_ajuste = $id_periodo_ajuste ";
            if ($tag_rn == 1) {
                $filtro_per_aju = " ";
            }
            //Sql
            /**
             * Se agrega dias de vac tambien de periodos adicionales - 20140311
             */
            $sql = <<<EOD
select 
row_number() over 
  ( partition by tab0.num_doc, tab0.id_concep_nomina order by tab0.id_concepto_periodo asc ) as rn, 
$salario_minimo as salario_minimo,
0 as tag,
tab0.*,
tab0.num_dias as dias_liq,
nvl(vac.dias_vac,0) as wdiasv,
tipcon.orden,
connom.codigo,
connom.usa_dias_calen
from no_concepto_periodo tab0

join no_concep_nomina connom
on connom.id_concep_nomina = tab0.id_concep_nomina

join no_tipo_concepto tipcon
on tipcon.id_tipo_concepto = connom.id_tipo_concepto
                    
left join (
    
    select 
 novvac.id_tipo_doc,                  
 novvac.num_doc,
 nvl(sum(dias_rango_mes(novvac.fecha_ini,novvac.fecha_fin,(select id_meses 
     from no_periodo where id_periodo =  $id_periodo_ajuste))),0) as dias,
 nvl(sum( novvac.fecha_fin - novvac.fecha_ini + 1),0) as num_dias_vac,
 nvl(sum(FECHA_RANGO_SIN_TREINTAYUNO(novvac.fecha_ini,novvac.fecha_fin)),0) as dias_vac
 from no_novedad_vac novvac
 left join no_tipo_nov_vac tipnov on tipnov.id_tipo_nov_vac = novvac.id_tipo_nov_vac
 where tipnov.tiempo_liqui = 1  and tipnov.operador = 1
     and novvac.id_periodo in (  select id_periodo from no_periodo
 where id_anhos = (select id_anhos from no_periodo where id_periodo = $id_periodo_ajuste)
 and id_meses = (select id_meses from no_periodo where id_periodo = $id_periodo_ajuste)
 and id_tipo_periodo in ( 1, 2) )
 group by novvac.id_tipo_doc, novvac.num_doc
     
)vac
on vac.id_tipo_doc = tab0.id_tipo_doc and vac.num_doc = tab0.num_doc

where tab0.periodo = $id_periodo
$filtro_per_aju                   
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
and tab0.id_concep_nomina != (select id_concep_rete from no_param_concep where id_param_concep = 1)
and (tipcon.id_tipo_concepto = 1 or tipcon.id_tipo_concepto = 2)
and ( connom.codigo <= 4000 or connom.codigo >= 4999 )
                    
order by 
tab0.id_anhos,
tab0.id_meses,
tab0.id_tipo_doc,
tab0.num_doc,
tipcon.orden,
case 
  when connom.codigo >= 4000  
      then '0000'
      else connom.codigo 
  end ,
tab0.id_concepto_periodo
--connom.codigo 
EOD;
            //Ejecutar SQL
            $records = CN_TABLE::executeSQL($sql);

            /*
             * Recorre los registros de funcionario - concepto nomina
             * para ser liquidados
             */
            $i = 1;
            $nom_conceptos_a_procesar = count($records);

            // Antes de inicar el proceso largo
            $brecha = 1;
            if ($nom_conceptos_a_procesar > 100)
                $brecha = $nom_conceptos_a_procesar - (0.99 * $nom_conceptos_a_procesar);

            /*
             * Log liquidacion.log registros uno a uno - Funcionarios
             */
            $logPath = sfConfig::get('sf_log_dir') . '/liquidacion.log';
            $custom_logger = new sfFileLogger(new sfEventDispatcher(), array('file' => $logPath));

            foreach ($records as $value) {

                // Guardar un valor en el proceso largo
                if ($i % $brecha == 0) {
                    $por = round(($i / $nom_conceptos_a_procesar) * 100, 0);
                    if ((10 + $por) <= 95) {
                        MemcacheHandler::getInstance()->set($progress_key, 10 + $por);
                    }
                }

                $this->logMessage("[Liquidación Retroactivo] Existen liquidaciones.");

                $id_periodo = $value['periodo'];
                $num_doc = $value['num_doc'];
                $id_tipo_doc = $value['id_tipo_doc'];
                $id_concep_nomina = $value['id_concep_nomina'];

                // Termina procesamiento de concepto
                $custom_logger->info("Procesado $i de $nom_conceptos_a_procesar conceptos. Documento: " . $num_doc . "\n");


                /*
                 * Liquidar periodo-funcionario-concepto nomina
                 */
                $this->liquidar($id_periodo, $num_doc, $id_tipo_doc, $id_concep_nomina, $value, $arrayConstantes, $record_consulta, $id_periodo_ajuste);

                // Termina procesamiento de concepto
//                file_put_contents('/home/lavila/Escritorio/liquidacion.log', "Procesado $i de $nom_conceptos_a_procesar conceptos.\n", FILE_APPEND);
                $i++;
            }


            /**
             * Reliquidar FSP
             * Se toman conceptos segun la Tabla NO_FONDO_CONCEPTO para el id_descuento_ss = 2 
             */
            $valor_base = 0;

            /*
             * Se toman conceptos segun la 
             * Tabla NO_FONDO_CONCEPTO para el id_descuento_ss = 2 
             * Se agrega tag y periodo para la consulta de R - 20131216
             */
            //Sql
            $sql = <<<EOD
select
$salario_minimo as salario_minimo,
1 as tag,
$id_periodo as periodo,  
tab0.* 
from no_liquida_nomina tab0
left join no_fondo_concepto foncon
on tab0.id_concep_nomina = foncon.id_concep_nomina
where foncon.id_descuento_ss = 2
and tab0.id_periodo = $id_periodo
and tab0.id_periodo_ajuste = $id_periodo_ajuste     
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc  
order by 
tab0.id_tipo_doc,
tab0.num_doc
EOD;

            //Ejecutar SQL
            $record_fsp = CN_TABLE::executeSQL($sql);

            foreach ($record_fsp as $value) {

                $id_liquida_nomina = $value['id_liquida_nomina'];
                $valor_base = $value['valor_liquidado'];
                $valor_base_vac = 0;
                $num_doc = $value['num_doc'];
                $id_tipo_doc = $value['id_tipo_doc'];
                $num_dias_fsp = $value['num_dias'];
                $id_concep_nomina = $value['id_concep_nomina'];
                $vals_calc = array();

                $custom_logger->info(MemcacheHandler::getInstance()->get($progress_key) . " - FSP - Procesado $i de $nom_conceptos_a_procesar conceptos. Funcionario: " . $num_doc . "\n");

                //Dias para vacaciones
                //Se habilita novedvac para el periodo a liquidar - filtro id_periodo - 20130722 Se deshablita - 20130723
                //Toma los dias de vacaciones para el mes a liquidar - 20130723
                //Sql
                $sql = <<<EOD
select  nvl(sum(num_dias_vac),0) as dias_vac from (       
   select 
     novvac.id_tipo_doc,                  
     novvac.num_doc,
     nvl(sum(dias_rango_mes(novvac.fecha_ini,novvac.fecha_fin,(select id_meses 
         from no_periodo where id_periodo =  $id_periodo_ajuste))),0) as dias,
     nvl(sum( novvac.fecha_fin - novvac.fecha_ini + 1),0) as dias_vac,
     
     case when TIPNOV.operador = 1
     then nvl(sum(DIAS_RANGO_MES_SIN_TREINTAYUNO(novvac.fecha_ini,novvac.fecha_fin,(select id_meses from no_periodo where id_periodo =  $id_periodo_ajuste))),0) 
     else 0
     end as num_dias_vac
   
     from no_novedad_vac novvac
     left join NO_TIPO_NOV_VAC TIPNOV on TIPNOV.ID_TIPO_NOV_VAC = NOVVAC.ID_TIPO_NOV_VAC
     where TIPNOV.TIEMPO_LIQUI = 1 
     --and NOVVAC.ID_PERIODO = $id_periodo_ajuste
     and novvac.NUM_DOC = $num_doc
     group by novvac.id_tipo_doc, novvac.num_doc, TIPNOV.operador
)
EOD;

                //Ejecutar SQL
                $record_vac = CN_TABLE::executeSQL($sql);
                /*
                 * Calcular IBC para vacaciones
                 */
                // Se agrega al calculo la formula (({A39}/30)*$wdiasv)) - 20130517
                // Toma los dias de vacaciones para el mes a liquidar
                $wdiasv = 0;
                if (count($record_vac) > 0) {
                    $wdiasv = $record_vac[0]['dias_vac'];
                }

                $formula = "(({A39}/30)*$wdiasv)";
                $this->logMessage("[Liquidación Vac] Formula Inicial: " . $formula);

                /*
                 * Cambio en la formula de A por (C1+C2)
                 */
                $vars = array();

                CN_TABLE::getVarsInFormula($vars, $formula);

//        var_dump($vars);

                foreach ($vars as $var) {
                    if (substr($var, 0, 1) == 'A') {
                        /*
                         * Cambio de A1 por relacion con los conceptos C1
                         * Ejemplo: 'A1' => '0'
                         */
                        $agrup = $this->reemplazoAgrupacion(substr($var, 1));
                        $this->logMessage("[Liquidación Vac] Agrupacion: " . $agrup);

                        $formula = str_replace('{' . $var . '}', $agrup, $formula);
                    }
                }
                $this->logMessage("[Liquidación Vac] Formula parametrosFormula y reemplazoAgrupacion: " . $formula);

                $arrayParametros = $this->parametrosFormula($formula);
                $arrayParametros = $this->resultadoParametros($arrayParametros, $value, $record_consulta, $vals_calc);

                $formula = $this->reemplazoParametros($formula, $arrayParametros);
                /*
                 * Ejecutar fórmula
                 * Ejemplo: ( 0 == 0 ? {C1} * $porcentaje : false )
                 * Retorna false  si no cumple con la condicion
                 */
                $formula = str_replace('{', ' ', $formula);
                $formula = str_replace('}', ' ', $formula);
                $result = CN_TABLE::aplicarEval($formula);

                /*
                 * No cumple con la condicion
                 */
//                if ($result === false) {
                if ($result == '-9999' || $result == -9999) {
                    $this->logMessage("[Liquidación Vac] Formula No cumple con la condicion: " . $formula);
                    $result = 0;
                }
                //Valor base de IBC vacaciones
                $valor_base_vac = round($result, -3);
                $this->logMessage("[Liquidación Vac] Valor base de IBC vacaciones: " . $valor_base_vac);

                /*
                 * Valor vase formula FSP
                 */
                $valor_base = round($valor_base, -3);
//                $valor_base = round($valor_base);
                //valor base no puede superar 25 salarios minimos
                if ($valor_base > ($salario_minimo * 25)) {
                    $valor_base = round(($salario_minimo * 25) - 1, -3);
//                    $valor_base = round(($salario_minimo * 25) - 1);
                }


                /*
                 * Variables del concepto 1 asignacion basica para los dias de liquidacion y totales de vacaciones - 20131216
                 * Anexo de conceptos de enfermedad por el tipo de novedad que causa liquidacion - 20131217
                 */
                //Sql
                $sql = <<<EOD
select 
tab0.id_tipo_doc,
tab0.num_doc,
--tab0.id_concep_nomina,
sum(tab0.num_dias) as dias_liq,
max(nvl(vac.dias_vac,0)) as wdiasv

from no_concepto_periodo tab0

join no_concep_nomina connom
on connom.id_concep_nomina = tab0.id_concep_nomina

join no_tipo_concepto tipcon
on tipcon.id_tipo_concepto = connom.id_tipo_concepto
                    
left join (
    
    select 
 novvac.id_tipo_doc,                  
 novvac.num_doc,
 nvl(sum(dias_rango_mes(novvac.fecha_ini,novvac.fecha_fin,(select id_meses 
     from no_periodo where id_periodo =  $id_periodo_ajuste))),0) as dias,
 nvl(sum( novvac.fecha_fin - novvac.fecha_ini + 1),0) as num_dias_vac,
 nvl(sum(FECHA_RANGO_SIN_TREINTAYUNO(novvac.fecha_ini,novvac.fecha_fin)),0) as dias_vac
 from no_novedad_vac novvac
 left join no_tipo_nov_vac tipnov on tipnov.id_tipo_nov_vac = novvac.id_tipo_nov_vac
 where tipnov.tiempo_liqui = 1  and tipnov.operador = 1
     and novvac.id_periodo in (  select id_periodo from no_periodo
 where id_anhos = (select id_anhos from no_periodo where id_periodo = $id_periodo_ajuste)
 and id_meses = (select id_meses from no_periodo where id_periodo = $id_periodo_ajuste)
 and id_tipo_periodo in ( 1, 2) )
 group by novvac.id_tipo_doc, novvac.num_doc
     
)vac
on vac.id_tipo_doc = tab0.id_tipo_doc and vac.num_doc = tab0.num_doc

where tab0.periodo = $id_periodo
and tab0.num_doc = $num_doc
and tab0.id_tipo_doc = $id_tipo_doc
and tab0.id_periodo_ajuste = $id_periodo_ajuste                        

and ( 
    tab0.id_concep_nomina = (select no_param_concep.ID_CONCEP_BASICA from no_param_concep where id_param_concep = 1) 
  or tab0.id_concep_nomina in (SELECT DISTINCT
    kar.ID_CONCEP_NOMINA 
    FROM NO_CONCEP_KA kar
    join NO_TIP_NOV_KA tipkar
    on tipkar.ID_TIP_NOV_KA = kar.ID_TIP_NOV_KA
    where tipkar.CAUSA_LIQUIDACION = 1) 
)
                        
and tipcon.id_tipo_concepto != 4
             
group by
tab0.id_tipo_doc,
tab0.num_doc
    --,tab0.id_concep_nomina  
EOD;
                //Ejecutar SQL
                $record_smlv = CN_TABLE::executeSQL($sql);

                if (count($record_smlv) > 0) {
                    $dias_liq = $record_smlv[0]['dias_liq'];
                    $wdiasv_tot = $record_smlv[0]['wdiasv'];
                }

                //Anexo dias totales y de vacaciones totales - 20131217
                $array_valor_base = $this->valor_base_fsp($valor_base, $salario_minimo, $valor_base_vac, $wdiasv_tot, $dias_liq, $num_doc, $id_periodo_ajuste);
                $valor_fsp = $array_valor_base['valor_fsp'];
                $porcentaje_fsp = $array_valor_base['porcentaje_fsp'];

                /**
                 * SQL de consulta para validar si el concepto de FSP es por ajuste - 20131129
                 */
                //Sql
                $sql = <<<EOD
select 
tab0.id_tipo_doc,
tab0.num_doc,
tab0.id_concep_nomina,
tab0.id_periodo,
tab0.valor_ajuste,
 to_date( '01/' || per.id_meses || '/' || per.id_anhos, 'dd/mm/yyyy')  as fecha_desde,
TRUNC(LAST_DAY( to_date(per.id_meses || '/' || per.id_anhos, 'mm/yyyy')  )) as fecha_hasta,
tab0.num_dias
from no_ajuste_nomina tab0
join no_periodo per
on per.id_periodo = tab0.id_periodo 
WHERE tab0.id_periodo = $id_periodo 
and tab0.id_periodo_ajuste = $id_periodo_ajuste                        
and tab0.NUM_DOC = $num_doc
and tab0.id_concep_nomina = $id_concep_nomina
EOD;

                //Ejecutar SQL
                $record_fsp_ver = CN_TABLE::executeSQL($sql);

                /*
                 * Validar si el FSP es por ajuste - 20131129
                 */
                $val_fsp_aju = 0;
                if (count($record_fsp_ver) != 0) {
                    $val_fsp_aju = $record_fsp_ver[0]['valor_ajuste'];
                }
                //if (count($record_fsp_ver) == 0) {
                if ($valor_fsp > 0) {

                    /*
                     * Actualizar valores de FSP
                     */
                    //sentencia sql
                    $sql = <<<EOD
update NO_LIQUIDA_NOMINA set valor_liquidado =  $valor_fsp + $val_fsp_aju
        , porcentaje = $porcentaje_fsp
            , valor_base = round( valor_liquidado, -3 ) 
    where id_liquida_nomina = $id_liquida_nomina 
        and id_periodo = $id_periodo
        and id_periodo_ajuste = $id_periodo_ajuste     
EOD;
                    //ejecuta y obtiene el resultado del sql
                    CN_TABLE::executeSQL($sql);
                } else {

                    /*
                     * Borrar del FSP
                     */
                    //sentencia sql
                    $sql = <<<EOD
delete from NO_LIQUIDA_NOMINA where id_liquida_nomina = $id_liquida_nomina 
and id_periodo = $id_periodo
and id_periodo_ajuste = $id_periodo_ajuste     
EOD;
                    //ejecuta y obtiene el resultado del sql
                    CN_TABLE::executeSQL($sql);
                }
                //}
            }

            /*
             * Inicio del proceso de calculo de Retencion en la fuente concepto 2001
             * Solo retefunte
             */
            //Sql
            $sql = <<<EOD
select 
1 as tag,
tab0.*,
tab0.num_dias as dias_liq,
tipcon.orden,
connom.codigo,
connom.usa_dias_calen
from no_concepto_periodo tab0

join no_concep_nomina connom
on connom.id_concep_nomina = tab0.id_concep_nomina

join no_tipo_concepto tipcon
on tipcon.id_tipo_concepto = connom.id_tipo_concepto

where tab0.periodo = $id_periodo
and tab0.id_periodo_ajuste = $id_periodo_ajuste     
$whereFuncionarioNumDoc $whereFuncionarioTipoDoc 
and tab0.id_concep_nomina = (select id_concep_rete from no_param_concep where id_param_concep = 1)
and tab0.porcentaje > 0

order by 
tab0.id_anhos,
tab0.id_meses,
tab0.id_tipo_doc,
tab0.num_doc,
tipcon.orden,
connom.codigo 
EOD;
            //Ejecutar SQL
            //$records = CN_TABLE::executeSQL($sql);

            /*
             * Recorre los registros de funcionario - concepto nomina
             * para ser liquidados
             */
//            $i = 0;
//            $nom_conceptos_a_procesar = count($records);
//            foreach ($records as $value) {
//                $this->logMessage("[Liquidación Retroactivo] Existen liquidaciones.");
//
//                $id_periodo = $value['periodo'];
//                $num_doc = $value['num_doc'];
//                $id_tipo_doc = $value['id_tipo_doc'];
//                $id_concep_nomina = $value['id_concep_nomina'];
//
//                /*
//                 * Liquidar periodo-funcionario-concepto nomina
//                 */
//                $this->liquidar($id_periodo, $num_doc, $id_tipo_doc, $id_concep_nomina, $value, $arrayConstantes, $record_consulta, $id_periodo_ajuste);
//
//                // Termina procesamiento de concepto
////                file_put_contents('/home/lavila/Escritorio/liquidacion.log', "RETE - Procesado $i de $nom_conceptos_a_procesar conceptos.\n", FILE_APPEND);
////                $i++;
////                $custom_logger->info(MemcacheHandler::getInstance()->get($progress_key) . " - RETE - Procesado $i de $nom_conceptos_a_procesar conceptos. Funcionario: " . $num_doc . "\n");
//            }
            //commit de las transacciones
            $this->conn->commit();
        } catch (Exception $exc) {
            $this->logMessage("[Liquidación Retroactivo] ERROR!!! liquidarRetroactivo");
            $this->conn->rollback();
        }
    }

}
