<?php Session::init(); ?>
<?php

require_once 'models/kardex_model.php';

class Ajuste_Model extends Model
{
    public function __construct()
    {
        parent::__construct();
    }

    private function extraerRucDesdeCertificado(array $certParsed): ?string
    {
        $candidatos = array();

        if (!empty($certParsed['subject']) && is_array($certParsed['subject'])) {
            foreach (array('serialNumber', 'SERIALNUMBER', 'organizationIdentifier', 'OU', 'CN') as $campo) {
                if (!empty($certParsed['subject'][$campo])) {
                    $candidatos[] = (string) $certParsed['subject'][$campo];
                }
            }
        }

        if (!empty($certParsed['name'])) {
            $candidatos[] = (string) $certParsed['name'];
        }

        if (!empty($certParsed['extensions']['subjectAltName'])) {
            $candidatos[] = (string) $certParsed['extensions']['subjectAltName'];
        }

        foreach ($candidatos as $texto) {
            if (preg_match('/(?:RUC[:\\s-]*)?([0-9]{11})/i', $texto, $m)) {
                return $m[1];
            }
        }

        return null;
    }

    private function validarCertificadoSubido(array $fileCertificado, string $claveCertificado, string $rucEmisor): void
    {
        if (empty($fileCertificado['tmp_name']) || !is_uploaded_file($fileCertificado['tmp_name'])) {
            throw new RuntimeException('No se pudo leer el archivo del certificado.');
        }

        $extension = strtolower((string) pathinfo((string) ($fileCertificado['name'] ?? ''), PATHINFO_EXTENSION));
        if (!in_array($extension, array('pfx', 'p12'), true)) {
            throw new RuntimeException('El certificado debe tener extension .pfx o .p12');
        }

        if (trim($claveCertificado) === '') {
            throw new RuntimeException('Ingrese la contrasena del certificado para validarlo.');
        }

        if (!function_exists('openssl_pkcs12_read')) {
            throw new RuntimeException('OpenSSL no esta disponible en el servidor para validar el certificado.');
        }

        $contenido = @file_get_contents($fileCertificado['tmp_name']);
        if ($contenido === false || $contenido === '') {
            throw new RuntimeException('No se pudo leer el contenido del certificado.');
        }

        $certs = array();
        $ok = @openssl_pkcs12_read($contenido, $certs, $claveCertificado);
        if (!$ok) {
            throw new RuntimeException('La contrasena del certificado es invalida o el archivo no corresponde a un certificado valido.');
        }

        if (empty($certs['cert'])) {
            throw new RuntimeException('No se pudo extraer el certificado publico del archivo subido.');
        }

        $rucEmisorLimpio = preg_replace('/\D+/', '', (string) $rucEmisor);
        if ($rucEmisorLimpio === '') {
            return;
        }

        $certParsed = @openssl_x509_parse($certs['cert']);
        if ($certParsed === false) {
            return;
        }

        $rucCertificado = $this->extraerRucDesdeCertificado($certParsed);
        if ($rucCertificado !== null && $rucCertificado !== $rucEmisorLimpio) {
            throw new RuntimeException('El certificado no corresponde al RUC emisor configurado (' . $rucEmisorLimpio . ').');
        }
    }

    public function AreaProduccion()
    {
        try
        {      
            return $this->db->selectAll('SELECT * FROM tm_area_prod WHERE estado = "a"');
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function Rol()
    {
        try
        {      
            return $this->db->selectAll('SELECT * FROM tm_rol WHERE id_rol <> 1');
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function UnidadMedida()
    {
        try
        {      
            return $this->db->selectAll('SELECT * FROM tm_tipo_medida');
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function Impresora()
    {
        try
        {      
            return $this->db->selectAll('SELECT * FROM tm_impresora WHERE estado = "a"');
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    /* INICIO MODULO EMPRESA */

    public function datosempresa_data()
    {
        try
        {    
            $stm = $this->db->prepare("SELECT * FROM tm_empresa");
            $stm->execute();
            $c = $stm->fetch(PDO::FETCH_OBJ);
            return $c;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function iconosRapidos()
    {
        try
        {      
            $data = $this->db->selectAll("SELECT * FROM tm_accesos_rapidos");
            Session::set('accesosrapido', $data);
            return $data;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function guardaricono($data)
    {
        try 
        {
            $stm = $this->db->prepare('UPDATE tm_accesos_rapidos SET icono = "'.$data['icono'].'", color = "'.$data['color'].'", titulo = "'.$data['titulo'].'", url = "'.$data['url'].'" WHERE id_acceso = '.$data['id_acceso'].'');
            $stm->execute();
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function datosempresa_crud($data)
    {
        try 
        {                 
            if($data['usuid'] == 1){

                if( !empty( $_FILES['imagen']['name'] ) ){
                    switch ($_FILES['imagen']['type']) 
                    { 
                        case 'image/jpeg': 
                        $ext = "jpg"; 
                        break;
                        case 'image/gif': 
                        $ext = "gif"; 
                        break; 
                        case 'image/png': 
                    }
                    $imagen = 'logoprint.'.$ext;
                    move_uploaded_file ($_FILES['imagen']['tmp_name'], 'public/images/'.$imagen);
                    $data['logo'] =  $imagen;
                    } else {
                        $imagen = $data['imagen'];
        
                    }
        
                    // subir certificado pfx/p12 con validacion de contrasena
                    if(!empty($_FILES['file_certificado']['name'])){

                        $this->validarCertificadoSubido(
                            $_FILES['file_certificado'],
                            (string) ($data['clavecertificado'] ?? ''),
                            (string) ($data['ruc'] ?? '')
                        );

                        $directoriobeta       = 'api_fact/UBL21/archivos_xml_sunat/certificados/beta/'.$data['ruc'];
                        $directorioproduccion = 'api_fact/UBL21/archivos_xml_sunat/certificados/produccion/'.$data['ruc'];
                        $urlsproduccion       = $directorioproduccion.'/'.$data['ruc'].'.pfx';
                        $urlsbeta             = $directoriobeta.'/'.$data['ruc'].'.pfx';
                        $cpeproduccion        = 'api_fact/UBL21/archivos_xml_sunat/cpe_xml/produccion/'.$data['ruc'];
                        $cpebeta              = 'api_fact/UBL21/archivos_xml_sunat/cpe_xml/beta/'.$data['ruc'];

                        if (!is_dir($directorioproduccion) && !mkdir($directorioproduccion, 0777, true) && !is_dir($directorioproduccion)) {
                            throw new RuntimeException('No se pudo crear la carpeta de certificado en produccion.');
                        }
                        if (!is_dir($directoriobeta) && !mkdir($directoriobeta, 0777, true) && !is_dir($directoriobeta)) {
                            throw new RuntimeException('No se pudo crear la carpeta de certificado en beta.');
                        }
                        if (!is_dir($cpeproduccion)) {
                            @mkdir($cpeproduccion, 0777, true);
                        }
                        if (!is_dir($cpebeta)) {
                            @mkdir($cpebeta, 0777, true);
                        }

                        if (!move_uploaded_file($_FILES['file_certificado']['tmp_name'], $urlsproduccion)) {
                            throw new RuntimeException('No se pudo guardar el certificado en produccion.');
                        }
                        if (!copy($urlsproduccion, $urlsbeta)) {
                            throw new RuntimeException('No se pudo copiar el certificado a beta.');
                        }
                    }

                $sql = "UPDATE tm_empresa SET ruc = ?,razon_social  = ?, nombre_comercial = ?, direccion_comercial = ?, direccion_fiscal = ?, celular = ?, ubigeo = ?, departamento = ?, provincia = ?, distrito = ?, usuariosol = ?, clavesol = ?, certpse = ?, clavecertificado = ?, client_id = ?, client_secret = ?, logo = ?, sunat = ?, modo = ?, ose = ?, ose_url = ?, amazonas = ?";
                $this->db->prepare($sql)->execute(array(
                    $data['ruc'],
                    $data['razon_social'],
                    $data['nombre_comercial'],
                    $data['direccion_comercial'],
                    $data['direccion_fiscal'],
                    $data['celular'],
                    $data['ubigeo'],
                    $data['departamento'],
                    $data['provincia'],
                    $data['distrito'],
                    $data['usuariosol'],
                    $data['clavesol'],
                    $data['certpse'],
                    $data['clavecertificado'],
                    $data['client_id'],
                    $data['client_secret'],
                    $imagen,
                    $data['sunat'],
                    $data['modo'],
                    $data['ose'], // Fixed: was hidden_ose
                    $data['ose_url'],
                    $data['amazonas'], // Fixed: was hidden_amazonas
                ));
                Session::set('sunat', $data['sunat']);
                Session::set('modo', $data['modo']);
                Session::set('ose', $data['ose']); // Fixed: was hidden_ose
                Session::set('ose_url', $data['ose_url']);


                // return $_FILES['file_certificado']['type'];
                return array('ok' => true, 'message' => 'Datos actualizados correctamente');
            } else {
                $sql = "UPDATE tm_empresa SET ruc = ?,razon_social  = ?, nombre_comercial = ?, direccion_comercial = ?, celular = ?";
                $this->db->prepare($sql)->execute(array(
                    $data['ruc'],
                    $data['razon_social'],
                    $data['nombre_comercial'],
                    $data['direccion_comercial'],
                    $data['celular']
                ));
                return array('ok' => true, 'message' => 'Datos actualizados correctamente');
            }

        } catch (Exception $e) 
        {
            return array('ok' => false, 'message' => $e->getMessage());
        }
    }

    public function tipodoc_list()
    {
        try
        {      
            $stm = $this->db->prepare("SELECT * FROM tm_tipo_doc");
            $stm->execute();            
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function tipodoc_crud($data)
    {
        try 
        {
            if($data['defecto'] == '1'){
                $sql = "UPDATE tm_tipo_doc SET defecto = '0' WHERE defecto = '1'";
                $this->db->prepare($sql)->execute();
            }

            $sql = "UPDATE tm_tipo_doc SET serie = ?, numero = ?, estado = ?, defecto = ? WHERE id_tipo_doc = ?";
            $this->db->prepare($sql)->execute(array($data['serie'],$data['numero'],$data['estado'],$data['defecto'],$data['id_tipo_doc']));


        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function usuario_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM v_usuarios WHERE id_rol <> 1");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json;  
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function usuario_data($id)
    {

        // INNER JOIN tm_usuario AS tmu ON vu.id_usu = tmu.id_usu 
        return $this->db->selectOne('SELECT vu.*, tmu.turno_ing, tmu.turno_sal FROM v_usuarios AS vu INNER JOIN tm_usuario AS tmu ON vu.id_usu = tmu.id_usu WHERE vu.id_usu = :id_usu', 
            array('id_usu' => $id));
    }

    public function usuario_crud_create($data)
    {
        error_reporting(0);
        try 
        {
            if( !empty( $_FILES['imagen']['name'] ) ){
                switch ($_FILES['imagen']['type']) 
                { 
                    case 'image/jpeg': 
                    $ext = "jpg"; 
                    break;
                    case 'image/gif': 
                    $ext = "gif"; 
                    break; 
                    case 'image/png': 
                    $ext = "png"; 
                    break;
                    case 'application/pdf':
                    $ext = "pdf";
                    break;
                }
                $imagen = date('ymdhis').'.'.$ext;
                move_uploaded_file ($_FILES['imagen']['tmp_name'], 'public/images/
                
                s/'.$imagen);
            } else {
                $imagen = $data['imagen'];
            }

            if($data['editarprecio']=="on"){
                $editarprecio = 1;
            }else{
                $editarprecio = 0;
            }

            $area = (isset($data['id_areap'])) ? $data['id_areap'] : 0;
            $turno_ing = (isset($data['start'])) ? date('H:i:s',strtotime($data['start'])) : null;
            $turno_sal = (isset($data['end'])) ? date('H:i:s',strtotime($data['end'])) : null;

            $consulta = "call usp_configUsuario( :flag, @a, :id_rol, :id_areap, :dni, :ape_paterno, :ape_materno, :nombres, :email, :usuario, :contrasena, :imagen, :editarprecio, :turno_ing, :turno_sal);";
            $arrayParam =  array(
                ':flag' => 1,
                ':id_rol' => $data['id_rol'],
                ':id_areap' => $area,
                ':dni' => $data['dni'],
                ':ape_paterno' => $data['ape_paterno'],
                ':ape_materno' => $data['ape_materno'],
                ':nombres' => $data['nombres'],
                ':email' => $data['email'],
                ':usuario' => $data['usuario'],
                ':contrasena' => base64_encode($data['contrasena']),
                ':imagen' => $imagen,
                ':editarprecio' => $editarprecio,
                ':turno_ing' => $turno_ing,
                ':turno_sal' => $turno_sal
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            $row = $st->fetch(PDO::FETCH_ASSOC);
            return $row;
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function usuario_crud_update($data)
    {
        error_reporting(0);
        try 
        {
            if( !empty( $_FILES['imagen']['name'] ) ){
                switch ($_FILES['imagen']['type']) 
                { 
                    case 'image/jpeg': 
                    $ext = "jpg"; 
                    break;
                    case 'image/gif': 
                    $ext = "gif"; 
                    break; 
                    case 'image/png': 
                    $ext = "png"; 
                    break;
                    case 'application/pdf':
                    $ext = "pdf";
                    break;
                }
                $imagen = date('ymdhis').'.'.$ext;
                move_uploaded_file ($_FILES['imagen']['tmp_name'], 'public/images/users/'.$imagen);
            } else {
                $imagen = $data['imagen'];
            }

            $area = (isset($data['id_areap'])) ? $data['id_areap'] : 0;

            $turno_ing = (isset($data['start'])) ? date('H:i:s',strtotime($data['start'])) : null;
            $turno_sal = (isset($data['end'])) ? date('H:i:s',strtotime($data['end'])) : null;

            if($data['editarprecio']=="on"){
                $editarprecio = 1;
            }else{
                $editarprecio = 0;
            }

        // echo $editarprecio;
         //return false;
            $consulta = "call usp_configUsuario( :flag, :id_usu, :id_rol, :id_areap, :dni, :ape_paterno, :ape_materno, :nombres, :email, :usuario, :contrasena, :imagen, :editarprecio, :turno_ing, :turno_sal);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_usu' => $data['id_usu'],
                ':id_rol' => $data['id_rol'],
                ':id_areap' => $area,
                ':dni' => $data['dni'],
                ':ape_paterno' => $data['ape_paterno'],
                ':ape_materno' => $data['ape_materno'],
                ':nombres' => $data['nombres'],
                ':email' => $data['email'],
                ':usuario' => $data['usuario'],
                ':contrasena' => base64_encode($data['contrasena']),
                ':imagen' => $imagen,
                ':editarprecio' => $editarprecio ?? 0,
                ':turno_ing' => $turno_ing,
                ':turno_sal' => $turno_sal
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function usuario_estado($data)
    {
        try 
        {
            $sql = "UPDATE tm_usuario SET estado = ? WHERE id_usu = ?";
            $this->db->prepare($sql)
                ->execute(array($data['estado'],$data['id_usu']));
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function usuario_delete($data)
    {
        try 
        {
        if($data['id_rol'] == 1 OR $data['id_rol'] == 2){
            $consulta = "SELECT count(*) AS total FROM tm_pedido WHERE id_usu = ?";
        } else {
            $consulta = "SELECT count(*) AS total FROM tm_pedido_mesa WHERE id_mozo = ?";
        }
        $result = $this->db->prepare($consulta);
        $result->execute(array($data['id_usu']));
        $result->execute();
            if($result->fetchColumn()==0){
                $stm = $this->db->prepare("DELETE FROM tm_usuario WHERE id_usu = ?");          
                $stm->execute(array($data['id_usu']));
                return 1;
            }else{
                return 0;
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    /* FIN MODULO EMPRESA */
    public function TipoPago()
    {
        try
        {      
            return $this->db->selectAll('SELECT * FROM tm_pago');
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }
    public function tipopago_list($data)
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_tipo_pago WHERE id_tipo_pago LIKE ? AND id_tipo_pago > 3");
            $stm->execute(array($data['id_pago']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            foreach($c as $k => $d)
            {
                $c[$k]->{'Tipo'} = $this->db->query("SELECT descripcion AS nombre FROM tm_pago WHERE id_pago = ".$d->id_pago)
                    ->fetch(PDO::FETCH_OBJ);
            }
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function tipopago_crud_create($data)
    {

        try
        {

            $sql = "INSERT INTO tm_tipo_pago SET id_pago = ? ,descripcion = ? ,estado = ?";
            $resultado = $this->db->prepare($sql)->execute(array($data['id_tipo_pago'],$data['nombre'],$data['estado']));


            if ($resultado){
                return '1';
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function tipopago_crud_update($data)
    {
        try 
        {
            $sql = "UPDATE tm_tipo_pago SET id_pago = ?, descripcion = ?, estado = ? WHERE tm_tipo_pago.id_tipo_pago = ?";
            $resultado = $this->db->prepare($sql)->execute(array($data['id_tipo_pago'],$data['nombre'],$data['estado'],$data['id_pago']));

            if ($resultado){
                return '2';
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    /* INICIO MODULO RESTAURANTE */

    public function caja_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_caja");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function caja_crud_create($data)
    {
        try
        {
            $consulta = "call usp_configCajas( :flag, @a, :descripcion, :estado);";
            $arrayParam =  array(
                ':flag' => 1,
                ':descripcion' => $data['descripcion'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function caja_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configCajas( :flag, :id_caja, :descripcion, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_caja' => $data['id_caja'],
                ':descripcion' => $data['descripcion'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function areaprod_list($data)
    {
        try
        {
           
            $stm = $this->db->prepare("SELECT * FROM tm_area_prod WHERE id_areap like ?");
            $stm->execute(array($data['id_areap']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            foreach($c as $k => $d)
            {
                $c[$k]->{'Impresora'} = $this->db->query("SELECT nombre FROM tm_impresora WHERE id_imp = ".$d->id_imp)
                    ->fetch(PDO::FETCH_OBJ);
            }
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function areaprod_crud_create($data)
    {
        try
        {
            $consulta = "call usp_configAreasProd( :flag, @a, :id_imp, :nombre, :estado);";
            $arrayParam =  array(
                ':flag' => 1,                
                ':id_imp' => $data['id_imp'],
                ':nombre' => $data['nombre'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function areaprod_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configAreasProd( :flag, :id_areap, :id_imp, :nombre, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_areap' => $data['id_areap'],
                ':id_imp' => $data['id_imp'],
                ':nombre' => $data['nombre'],
                ':estado' => $data['estado']                
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function salon_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_salon ORDER BY id_salon ASC");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            foreach($c as $k => $d)
            {
                $c[$k]->{'Mesas'} = $this->db->query("SELECT COUNT(id_mesa) AS total FROM tm_mesa WHERE id_salon = ".$d->id_salon)
                ->fetch(PDO::FETCH_OBJ);
            }
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function mesa_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_mesa WHERE id_salon like ? ORDER BY nro_mesa ");
            $stm->execute(array($_POST['id_salon']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            foreach($c as $k => $d)
            {
                $c[$k]->{'Salon'} = $this->db->query("SELECT descripcion FROM tm_salon WHERE id_salon = ".$d->id_salon)
                ->fetch(PDO::FETCH_OBJ);
            }
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function salon_crud_create($data)
    {
        try 
        {
            $consulta = "call usp_configSalones( :flag, @a, :descripcion, :estado);";
            $arrayParam =  array(
                ':flag' => 1,
                ':descripcion' => $data['descripcion'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function salon_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configSalones( :flag, :id_salon, :descripcion, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_salon' => $data['id_salon'],
                ':descripcion' => $data['descripcion'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function salon_crud_delete($data)
    {
        try 
        {
            $consulta = "call usp_configSalones( :flag, :id_salon, @a, @b);";
            $arrayParam =  array(
                ':flag' => 3,
                ':id_salon' => $data['id_salon']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function mesa_crud_create($data)
    {
        try 
        {
            $consulta = "call usp_configMesas( :flag, @a, :id_salon, :nro_mesa, :forma, @b);";
            $arrayParam =  array(
                ':flag' => 1,
                ':id_salon' => $data['id_salon'],
                ':nro_mesa' => $data['nro_mesa'],
                ':forma' => $data['forma'],
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function mesa_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configMesas( :flag, :id_mesa, :id_salon, :nro_mesa, :forma, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_mesa' => $data['id_mesa'],
                ':id_salon' => $data['id_salon'],
                ':nro_mesa' => $data['nro_mesa'],
                ':forma' => $data['forma'],
                ':estado' => $data['estado']                        
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function mesa_crud_delete($data)
    {
        try 
        {
            $consulta = "call usp_configMesas( :flag, :id_mesa, @a, @b, @c, @d);";
            $arrayParam =  array(
                ':flag' => 3,
                ':id_mesa' => $data['id_mesa']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    /*
    public function mesa_estado($data)
    {
        try 
        {
            $sql = "UPDATE tm_mesa SET estado = ? WHERE id_mesa = ?";
            $this->db->prepare($sql)->execute(array($data['est_mesa'],$data['codi_mesa']));    
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }
    */

    /* ===================================== PRODUCTO*/
    public function producto_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT tm_producto.*, tm_area_prod.nombre as areaprod FROM tm_producto
                INNER JOIN tm_area_prod ON tm_area_prod.id_areap=tm_producto.id_areap
                WHERE id_prod like ? AND id_catg like ? AND id_catg <> 1 ORDER BY id_prod DESC");
            // $stm = $this->db->prepare("SELECT * FROM tm_producto WHERE id_prod like ? AND id_catg like ? AND id_catg <> 1 ORDER BY id_prod DESC");
            $stm->execute(array($_POST['id_prod'],$_POST['id_catg']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function producto_pres_list()
    {
        try
        {
            // $stm = $this->db->prepare("SELECT id_prod,id_pres,presentacion,cod_prod,precio,precios,estado,imagen FROM tm_producto_pres WHERE id_prod LIKE ? AND id_pres LIKE ?");
            $stm = $this->db->prepare("SELECT * FROM tm_producto_pres WHERE id_prod LIKE ? AND id_pres LIKE ?");
            $stm->execute(array($_POST['id_prod'],$_POST['id_pres']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            foreach($c as $k => $d)
            {
                $c[$k]->{'TipoProd'} = $this->db->query("SELECT id_tipo FROM tm_producto WHERE id_prod = ".$d->id_prod)
                ->fetch(PDO::FETCH_OBJ);
            }
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function producto_cat_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_producto_catg WHERE id_catg <> 1 ORDER BY orden ASC");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function producto_pres_ing($data)
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_producto_ingr WHERE id_pres = ?");
            $stm->execute(array($data['id_pres']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            foreach($c as $k => $d)
            {
                $c[$k]->{'Insumo'} = $this->db->query("SELECT ins_med,ins_nom,ins_cat,precio_compra FROM v_insprod WHERE id_tipo_ins = ".$d->id_tipo_ins." AND id_ins = ".$d->id_ins)
                ->fetch(PDO::FETCH_OBJ);
            }
            foreach($c as $k => $d)
            {
                $c[$k]->{'Medida'} = $this->db->query("SELECT descripcion FROM tm_tipo_medida WHERE id_med = ".$d->id_med)
                ->fetch(PDO::FETCH_OBJ);
            }
            return $c;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function producto_buscar_ins($data)
{
    try
    {
        $cadena = "%{$data['cadena']}%";
        $tipo = $data['tipo'];

        $sql = "
            SELECT * FROM v_insprod
            WHERE (ins_nom LIKE ? OR ins_cod LIKE ?)
              AND est_b COLLATE utf8mb4_unicode_ci = 'a'
              AND est_c COLLATE utf8mb4_unicode_ci = 'a'
              AND id_tipo_ins <> ?
            ORDER BY ins_nom
            LIMIT 5
        ";

        $stm = $this->db->prepare($sql);
        $stm->execute([$cadena, $cadena, $tipo]);

        return $stm->fetchAll(PDO::FETCH_OBJ);
    }
    catch(Exception $e)
    {
        die("Error en producto_buscar_ins: " . $e->getMessage());
    }
}


    public function producto_cat_crud_create($data)
    {
        try 
        {
            if( !empty( $_FILES['imagen']['name'] ) ){
                switch ($_FILES['imagen']['type']) 
                { 
                    case 'image/jpeg': 
                    $ext = "jpg"; 
                    break;
                    case 'image/gif': 
                    $ext = "gif"; 
                    break; 
                    case 'image/png': 
                    $ext = "png"; 
                    break;
                    case 'application/pdf':
                    $ext = "pdf";
                    break;
                }
                $imagen = date('ymdhis').'.'.$ext;
                move_uploaded_file ($_FILES['imagen']['tmp_name'], 'public/images/productos/'.$imagen);
            } else {
                $imagen = $data['imagen'];
            }
            $consulta = "call usp_configProductoCatgs( :flag, @a, :descripcion, :delivery, :orden, :imagen, :estado);";
            $arrayParam =  array(
                ':flag' => 1,
                ':descripcion' => $data['descripcion_categoria'],
                ':delivery' => $data['hidden_delivery_categoria'],
                ':orden' => 100,
                ':imagen' => $imagen,
                ':estado' => $data['hidden_estado_categoria']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function producto_cat_crud_update($data)
    {
        try 
        {
            if( !empty( $_FILES['imagen']['name'] ) ){
                switch ($_FILES['imagen']['type']) 
                { 
                    case 'image/jpeg': 
                    $ext = "jpg"; 
                    break;
                    case 'image/gif': 
                    $ext = "gif"; 
                    break; 
                    case 'image/png': 
                    $ext = "png"; 
                    break;
                    case 'application/pdf':
                    $ext = "pdf";
                    break;
                }
                $imagen = date('ymdhis').'.'.$ext;
                move_uploaded_file ($_FILES['imagen']['tmp_name'], 'public/images/productos/'.$imagen);
            } else {
                $imagen = $data['imagen'];
            }
            $consulta = "call usp_configProductoCatgs( :flag, :id_catg, :descripcion, :delivery, :orden, :imagen, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_catg' => $data['id_catg_categoria'],
                ':descripcion' => $data['descripcion_categoria'],
                ':delivery' => $data['hidden_delivery_categoria'],
                ':orden' => $data['orden_categoria'],
                ':imagen' => $imagen,
                ':estado' => $data['hidden_estado_categoria']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function producto_crud_create($data)
    {
        try
        {
            $consulta = "call usp_configProducto( :flag, @a, :id_tipo, :id_catg, :id_areap, :nombre, :notas, :delivery, @b);";
            $arrayParam =  array(
                ':flag' => 1,
                ':id_tipo' => $data['id_tipo'],
                ':id_catg' => $data['id_catg'],
                ':id_areap' => $data['id_areap'],
                ':nombre' => $data['nombre'],
                ':notas' => $data['notas'],
                ':delivery' => $data['delivery']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function producto_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configProducto( :flag, :id_prod, :id_tipo, :id_catg, :id_areap, :nombre, :notas, :delivery, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_prod' => $data['id_prod'],
                ':id_tipo' => $data['id_tipo'],
                ':id_catg' => $data['id_catg'],
                ':id_areap' => $data['id_areap'],
                ':nombre' => $data['nombre'],
                ':notas' => $data['notas'],
                ':delivery' => $data['delivery'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function producto_pres_crud_create($data)
{

    try 
    {
        // Manejo de imagen
        if (!empty($_FILES['imagen']['name'])) {
            switch ($_FILES['imagen']['type']) {
                case 'image/jpeg': $ext = "jpg"; break;
                case 'image/gif':  $ext = "gif"; break;
                case 'image/png':  $ext = "png"; break;
                case 'application/pdf': $ext = "pdf"; break;
                default: $ext = "jpg";
            }
            $imagen = date('ymdhis') . '.' . $ext;
            move_uploaded_file($_FILES['imagen']['tmp_name'], 'public/images/productos/' . $imagen);
        } else {
            $imagen = $data['imagen'];
        }

        // Llamada al procedimiento
        $consulta = "CALL usp_configProductoPres(
            :flag, :id_pres, :id_prod, :cod_prod, :presentacion, :descripcion,
            :precio, :precio2, :precio_delivery, :receta, :stock_min, :stock_limit,
            :impuesto, :impuesto_icbper, :delivery, :margen, :igv, :imagen, :ordenins,
            :favorito, :estado
        );";

        $arrayParam = array(
            ':flag' => 1,
            ':id_pres' => $data['id_pres_presentacion'] != '' ? $data['id_pres_presentacion'] : '0',
            ':id_prod' => $data['id_prod_presentacion'],
            ':cod_prod' => $data['cod_prod_presentacion'],
            ':presentacion' => $data['presentacion_presentacion'],
            ':descripcion' => $data['descripcion_presentacion'],
            ':precio' => $data['precio_presentacion'],
            ':precio2' => $data['precio_presentacion2'] ? $data['precio_presentacion2'] : 0,
            ':precio_delivery' => $data['precio_delivery'] != '' ? $data['precio_delivery'] : '0',
            ':receta' => $data['hidden_receta_presentacion'],
            ':stock_min' => $data['stock_min_presentacion'] != '' ? $data['stock_min_presentacion'] : 0,
            ':stock_limit' => $data['hidden_stock_limit'] != '' ? $data['hidden_stock_limit'] : '0',
            ':impuesto' => $data['hidden_impuesto_presentacion'],
            ':impuesto_icbper' => $data['hidden_impuesto_icbper'] ? $data['hidden_impuesto_icbper'] : '0',
            ':delivery' => $data['hidden_delivery_presentacion'],
            ':margen' => $data['hidden_insumo_principal_presentacion'],
            ':igv' => Session::get('igv'),
            ':imagen' => $imagen,
            ':ordenins' => $data['ordenins'] ? $data['ordenins'] : 1,
            ':favorito' => $data['hidden_favorito'] ? $data['hidden_favorito'] : 0,
            ':estado' => $data['hidden_estado_presentacion']
        );

        $st = $this->db->prepare($consulta);

        if (!$st->execute($arrayParam)) {
            $errorInfo = $st->errorInfo();
            error_log("Error al ejecutar el procedimiento: " . $errorInfo[2]);
            return ["success" => false, "error" => $errorInfo[2]];
        }

        // Obtener resultado del procedimiento
        $result = $st->fetch(PDO::FETCH_ASSOC);
        $st->closeCursor();

        if (!$result) {
            error_log("No se obtuvo respuesta del procedimiento.");
            return ["success" => false, "error" => "No se obtuvo respuesta del procedimiento."];
        }

        // Obtener último ID insertado (solo si el procedure hace INSERT con AUTO_INCREMENT)
        //$id_registro = $this->db->lastInsertId();

        $sql = "SELECT * FROM tm_producto_pres ORDER BY id_pres DESC LIMIT 1";
        $stmt = $this->db->prepare($sql);
        $stmt->execute();
        $ultimoRegistro = $stmt->fetch(PDO::FETCH_ASSOC);
        $id_registro = $ultimoRegistro['id_pres'];

        // Actualizar precio de compra e impuesto (si aplica)
        $this->db_data = new Database(DB_TYPE, DB_HOST, DB_NAME, DB_USER, DB_PASS, DB_CHARSET);
        $sqldata = "UPDATE tm_producto_pres SET precio_compra = ?, impuesto_compra = ? WHERE id_pres = ?";
        $this->db_data->prepare($sqldata)->execute(array(
            $data['precio_presentacion_compra'],
            $data['hidden_impuesto_presentacion'],
            $id_registro
        ));


        if($data['hidden_stock_limit'] == "1"){

            $dataKardex = array(
                'presentacion_id' => $id_registro,   // ID de la presentación 
                'cantidad' => 0,         // Cantidad que ingresa
                'costo_unitario' => $data['precio_presentacion'],   // Costo por unidad
                'serie_documento' => "",
                'numero_documento' => "",
                'tipo_documento' => "",             // Tipo documento
                'estado' => 'activo'                    // Estado del registro
            );

            $this->registrarKardex($dataKardex);
        }

        // Devolver resultado
        return ["success" => true, "cod" => $result['cod']];

    } 
    catch (PDOException $e) {
        return ["success" => false, "error" => 'Error en procedimiento almacenado: ' . $e->getMessage()];
    } 
    catch (Exception $e) {
        return ["success" => false, "error" => 'Error general: ' . $e->getMessage()];
    }
}


public function registrarKardex(array $compra): array {
  $this->db->beginTransaction();

  // 2.1 Guardas tu cabecera/detalle de compra aquí...
  // $this->insertCabecera($compra);
  // $this->insertDetalle($compra['items']);

  // 2.2 Construyes el payload para kardex
  $payloadKardex = [
    'id_usuario'       => Session::get('usuid'),
    'tipo_kardex'      => 1,
    'tipo_envio_sunat' => 'prueba',
    'id_presentacion'  => (int)$compra['presentacion_id'],
    'cantidad_entrada' => $compra['cantidad'],
    'costo_unitario'   => $compra['costo_unitario'],
    'concepto'         => "primer registro del producto",
    'serie_documento'  => $compra['serie'] ?? null,
    'numero_documento' => $compra['numero'] ?? null,
    'tipo_documento'   => null,
    'stock'            => $compra['stock_final'] ?? '0',
    'estado'           => 'activo',
  ];

  $kardex = new Kardex(); // comparte el mismo PDO
  $out = $kardex->insert($payloadKardex);
  if (!$out['ok']) {
    $this->db->rollBack();
    return $out; // envelope con error (VALIDATION_ERROR / DB_ERROR, etc.)
  }
  $this->db->commit();

  return ['ok' => true];
}




    public function producto_pres_crud_update($data)
    {
        try 
        {
            if( !empty( $_FILES['imagen']['name'] ) ){
                switch ($_FILES['imagen']['type']) 
                { 
                    case 'image/jpeg': 
                    $ext = "jpg"; 
                    break;
                    case 'image/gif': 
                    $ext = "gif"; 
                    break; 
                    case 'image/png': 
                    $ext = "png"; 
                    break;
                    case 'application/pdf':
                    $ext = "pdf";
                    break;
                }
                $imagen = date('ymdhis').'.'.$ext;
                move_uploaded_file ($_FILES['imagen']['tmp_name'],'public/images/productos/'.$imagen);
            } else {
                $imagen = $data['imagen'];
            }
            $consulta = "call usp_configProductoPres( :flag, :id_pres, :id_prod, :cod_prod, :presentacion, :descripcion, :precio, :precio2, :precio_delivery, :receta, :stock_min,:stock_limit, :impuesto, :impuesto_icbper, :delivery, :margen, :igv, :imagen, :ordenins, :favorito, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_pres' => $data['id_pres_presentacion'],
                ':id_prod' => $data['id_prod_presentacion'],
                ':cod_prod' => $data['cod_prod_presentacion'],
                ':presentacion' => $data['presentacion_presentacion'],
                ':descripcion' => $data['descripcion_presentacion'],
                ':precio' => $data['precio_presentacion'],
                ':precio2' => $data['precio_presentacion2'] ? $data['precio_presentacion2'] : 0,
                ':precio_delivery' => $data['precio_delivery'],
                ':receta' => $data['hidden_receta_presentacion'],
                ':stock_min' => $data['stock_min_presentacion'] != '' ? $data['stock_min_presentacion'] : 0,
                ':stock_limit' => $data['hidden_stock_limit'],
                ':impuesto' => $data['hidden_impuesto_presentacion'],
                ':impuesto_icbper' => $data['hidden_impuesto_icbper'] ? $data['hidden_impuesto_icbper'] : '0',
                ':delivery' => $data['hidden_delivery_presentacion'],
                ':margen' => $data['hidden_insumo_principal_presentacion'],
                ':igv' => Session::get('igv'),
                ':imagen' => $imagen,
                ':ordenins' => $data['ordenins'] ? $data['ordenins'] : 1,
                ':favorito' => $data['hidden_favorito'] ? $data['hidden_favorito'] : 0,
                ':estado' => $data['hidden_estado_presentacion']
            );
            $st = $this->db->prepare($consulta);
            //$st->execute($arrayParam);

            if (!$st->execute($arrayParam)) {
                $errorInfo = $st->errorInfo();
                error_log("Error al ejecutar el procedure: " . $errorInfo[2]);
                return ["success" => false, "error" => $errorInfo[2]];
               
            }
            
            $result = $st->fetch(PDO::FETCH_ASSOC);
            $st->closeCursor();

            // insertar venta por consumo
            $this->db_data = new Database(DB_TYPE, DB_HOST, DB_NAME, DB_USER, DB_PASS, DB_CHARSET);
            $sqldata = "UPDATE tm_producto_pres SET precio_compra = ?, impuesto_compra = ? WHERE id_pres = ? ";
            $this->db_data->prepare($sqldata)->execute(array($data['precio_presentacion_compra'],$data['hidden_impuesto_presentacion'],$data['id_pres_presentacion']));

            //while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
            //    return $row['cod'];
            //}

            if($data['hidden_stock_limit'] == "1" && !$this->verificarKardexInicial($data['id_pres_presentacion'])){
                
                $dataKardex = array(
                    'usuario_id' => Session::get('id_usu'),  // ID del usuario actual
                    'presentacion_id' => $data['id_pres_presentacion'],   // ID de la presentación 
                    'cantidad' => 0,         // Cantidad que ingresa
                    'costo_unitario' => $data['precio_presentacion'],   // Costo por unidad
                    'serie_documento' => "",
                    'numero_documento' => "",
                    'tipo_documento' => "",             // Tipo documento
                    'estado' => 'activo'                    // Estado del registro
                );
                
                $this->registrarKardex($dataKardex);
            }
            
            return ["success" => true, "cod" => $result['cod']];
        }
        catch (PDOException $e) {
            return ["success" => false, "error" => 'Error en procedimiento almacenado: ' . $e->getMessage()];
        } 
        catch (Exception $e) {
            return ["success" => false, "error" => 'Error general: ' . $e->getMessage()];
        }
    }

    public function verificarKardexInicial($id_presentacion) {
        try {
            $sql = "SELECT COUNT(*) as total 
                    FROM tm_kardex 
                    WHERE tipo_kardex = 'inventario_inicial' 
                    AND id_presentacion = :id_presentacion";

            $stmt = $this->db->prepare($sql);
            $stmt->execute([
                ':id_presentacion' => $id_presentacion
            ]);

            $result = $stmt->fetch(PDO::FETCH_OBJ);
            
            // Retorna true si existe al menos un registro, false si no existe ninguno
            return ($result->total > 0);

        } catch (Exception $e) {
            error_log("Error en verificarKardexInicial: " . $e->getMessage());
            return false;
        }
    }

    public function producto_pres_precios_crud($data)
    {

        
        // echo ($data);
        // echo json_encode($data["data"][0]['id_pres']) ;
        // return ;
        // return $data[0]['id_pres'];
        try
        {
            $this->db_data = new Database(DB_TYPE, DB_HOST, DB_NAME, DB_USER, DB_PASS, DB_CHARSET);
            $sql = "UPDATE tm_producto_pres SET precios = ? WHERE id_pres = ?";
            $this->db_data->prepare($sql)->execute(array(json_encode($data["data"]),$data["data"][0]['id_pres']));
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function producto_combo_cat()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_producto_catg WHERE id_catg <> 1");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            return $c;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function producto_combo_unimed($data)
    {
        try
        {   
            $stmm = $this->db->prepare("SELECT * FROM tm_tipo_medida WHERE grupo = ? OR grupo = ?");
            $stmm->execute(array($data['va1'],$data['va2']));
            $var = $stmm->fetchAll(PDO::FETCH_ASSOC);
            // $key = 9;
            foreach($var as $v){
                // if ($data['cod'] =='4') {
                //     //onzas
                //     echo '<option value="'.$key++.'">'.$v['descripcion'].'</option>';
                // } else {
                    echo '<option value="'.$v['id_med'].'">'.$v['descripcion'].'</option>';
                // }
                
            }
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function producto_ingrediente_create($data)
    {
        try 
        {
           
            $consulta = "CALL usp_configProductoIngrs(:flag, :id_pi, :id_pres, :id_tipo_ins, :id_ins, :id_med, :cant, :principal);";
            $arrayParam = array(
                ':flag' => 1,
                ':id_pi' => null,
                ':id_pres' => $data['id_pres'],
                ':id_tipo_ins' => $data['id_tipo_ins'],
                ':id_ins' => $data['id_ins'],
                ':id_med' => $data['id_med'],
                ':cant' => $data['cant'],
                ':principal' => $data['principal']
            );

            $st = $this->db->prepare($consulta);
            if (!$st->execute($arrayParam)) {
                $error = $st->errorInfo();
                return "Error SQL: " . $error[2];
            }

            return true;
        }
        catch (Exception $e) 
        {
            return "Excepción: " . $e->getMessage();
        }
    }

    /*
    public function producto_ingrediente_update($data)
    {
        try 
        {
            $consulta = "call usp_configProductoIngrs( :flag, :idPres, :idIns, :cant, :idPi);";
            $arrayParam =  array(
                ':flag' => 2,
                ':idPres' => 1,
                ':idIns' => 1,
                ':cant' => $data['cant'],
                ':idPi' => $data['cod'],
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
        }
        catch (Exception $e) 
        {
            return false;
        }
    }
    */

    public function producto_ingrediente_delete($data)
    {
        try 
        {
            $consulta = "call usp_configProductoIngrs( :flag, :id_pi, @a, @b, @c, @d, @e, @f);";
            $arrayParam =  array(
                ':flag' => 3,
                ':id_pi' => $data['id_pi']
            );
            $st = $this->db->prepare($consulta);
            if (!$st->execute($arrayParam)) {
                $error = $st->errorInfo();
                return "Error SQL: " . $error[2];
            }

            return true;
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function producto_cat_delete($data)
    {
        try 
        {
            $consulta = "call usp_configEliminarCategoriaProd(:id_catg);";
            $arrayParam =  array(
                ':id_catg' => $data['id_catg']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function producto_prod_delete($data)
    {
        try 
        {
            $consulta = "DELETE FROM tm_producto WHERE id_prod = ?;";
            $st = $this->db->prepare($consulta);
            $st->execute(array($data['id_prod']));
            $st->fetch(PDO::FETCH_ASSOC);
            if($st->rowCount()){
                return 1;
            }else{
                return 0;
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function producto_pres_delete($data)
    {
        try 
        {
            // DELETE FROM tm_producto_pres WHERE tm_producto_pres.id_pres = 2
            $consulta = "DELETE FROM tm_producto_pres WHERE id_pres = ?";
            $st = $this->db->prepare($consulta);
            $st->execute(array($data['id_pres']));
            $st->fetch(PDO::FETCH_ASSOC);
            if($st->rowCount()){
                return 1;
            }else{
                return 0;
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }
    
    /* ======================= FIN PRODUCTO */

    /* ======================= INCIO COMBO */
    public function combo_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_producto WHERE id_prod like ? AND id_catg = 1 ORDER BY id_prod DESC");
            $stm->execute(array($_POST['id_prod']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    /* ======================= FIN COMBO */

    /* ======================= INICIO INSUMO */

    public function insumo_cat_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_insumo_catg");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function insumo_list()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM v_insumos WHERE id_ins like ? AND id_catg like ? ORDER BY id_ins DESC");
            $stm->execute(array($_POST['id_ins'],$_POST['id_catg']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function insumo_combo_cat()
    {
        try
        {
            $stm = $this->db->prepare("SELECT * FROM tm_insumo_catg");
            $stm->execute();
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            return $c;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function insumo_cat_crud_create($data)
    {
        try 
        {
            $consulta = "call usp_configInsumoCatgs( :flag, :descC, @a);";
            $arrayParam =  array(
                ':flag' => 1,
                ':descC' => $data['descripcion']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function insumo_cat_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configInsumoCatgs( :flag, :descC, :idCatg);";
            $arrayParam =  array(
                ':flag' => 2,
                ':descC' => $data['descripcion'],
                ':idCatg' => $data['id_catg']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        }
        catch (Exception $e) 
        {
            return false;
        }
    }

    public function insumo_crud_create($data)
    {
        try
        {
            $consulta = "call usp_configInsumo( :flag, :idCatg, :idMed, :cod, :nombre, :stock, :costo, @a, @b);";
            $arrayParam =  array(
                ':flag' => 1,
                ':idCatg' => $data['id_catg'],
                ':idMed' => $data['id_med'],
                ':cod' => $data['cod_ins'],
                ':nombre' => $data['nomb_ins'],
                ':stock' => $data['stock_min'],
                ':costo' => $data['cos_uni']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function insumo_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configInsumo( :flag, :idCatg, :idMed, :cod, :nombre, :stock, :costo, :estado, :idIns);";
            $arrayParam =  array(
                ':flag' => 2,
                ':idCatg' => $data['id_catg'],
                ':idMed' => $data['id_med'],
                ':cod' => $data['cod_ins'],
                ':nombre' => $data['nomb_ins'],
                ':stock' => $data['stock_min'],
                ':costo' => $data['cos_uni'],
                ':estado' => $data['estado'],
                ':idIns' => $data['id_ins']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function insumo_cat_delete($data)
    {
        try 
        {
            $consulta = "call usp_configEliminarCategoriaIns(:id_catg);";
            $arrayParam =  array(
                ':id_catg' => $data['id_catg']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function print_list($data)
    {
        try
        {
           
            $stm = $this->db->prepare("SELECT * FROM tm_impresora WHERE id_imp <> 1 AND id_imp LIKE ?");
            $stm->execute(array($data['id_imp']));
            $c = $stm->fetchAll(PDO::FETCH_OBJ);
            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json; 
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function print_crud_create($data)
    {
        try
        {
            $consulta = "call usp_configImpresoras( :flag, @a, :nombre, :estado);";
            $arrayParam =  array(
                ':flag' => 1,
                ':nombre' => $data['nombre'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function print_crud_update($data)
    {
        try 
        {
            $consulta = "call usp_configImpresoras( :flag, :id_imp, :nombre, :estado);";
            $arrayParam =  array(
                ':flag' => 2,
                ':id_imp' => $data['id_imp'],
                ':nombre' => $data['nombre'],
                ':estado' => $data['estado']
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    /* ======================= FIN INSUMO */

    /* FIN MODULO RESTAURANTE */

    public function optimizar_pedidos()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 1
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_ventas()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 2
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_productos()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 3
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_insumos()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 4
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_clientes()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 5
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_proveedores()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 6
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_mesas()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 7
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_inventario()
    {
        try
        {
            $consulta = "call usp_optPedidos(:flag);";
            $arrayParam =  array(
                ':flag' => 8
            );
            $st = $this->db->prepare($consulta);
            $st->execute($arrayParam);
            while ($row = $st->fetch(PDO::FETCH_ASSOC)) {
                return $row['cod'];
            }
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function optimizar_database()
    {
        try
        {
            $servername = DB_HOST;
            $username   = DB_USER;
            $password   = DB_PASS;
            $dbname     = DB_NAME;

            $conn = new mysqli($servername, $username, $password, $dbname);

            if ($conn->connect_error) {
                die("Conexión fallida: " . $conn->connect_error);
            }

            $filename = $dbname . '_backup_' . date("Y-m-d-H-i-s") . '.sql';

            $command = "mysqldump --routines --add-drop-database --single-transaction --host=$servername --user=$username --password=$password $dbname > $filename";

            system($command);

            header('Content-Type: application/octet-stream');
            header('Content-Disposition: attachment; filename="' . $filename . '"');
            readfile($filename);
            unlink($filename);

        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function datosistema_data()
    {
        try
        {    
            $stm = $this->db->prepare("SELECT * FROM tm_configuracion");
            $stm->execute();
            $c = $stm->fetch(PDO::FETCH_OBJ);
            return $c;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function datosistema_crud($data)
    {

        try 
        {
            $accesoaweb = !empty($data['mostrar_web_hidden']) ? 1 : 0;

            // (Opcional) normaliza también impresion_automatica si es checkbox
            $imp_automatica = !empty($data['impresion_automatica_comanda_hidden']) ? 1 : 0;


            $sql = "
            UPDATE tm_configuracion SET
                zona_hora            = :zona_hora,
                trib_acr             = :trib_acr,
                trib_car             = :trib_car,
                di_acr               = :di_acr,
                di_car               = :di_car,
                imp_acr              = :imp_acr,
                imp_val              = :imp_val,
                mon_acr              = :mon_acr,
                mon_val              = :mon_val,
                pc_name              = :pc_name,
                pc_ip                = :pc_ip,
                print_com            = :print_com,
                print_pre            = :print_pre,
                print_cpe            = :print_cpe,
                cod_seg              = :cod_seg,
                opc_01               = :opc_01,
                sep_items            = :sep_items,
                verpdf               = :verpdf,
                nota_ind             = :nota_ind,
                imp_bol              = :imp_bol,
                imp_val_bol          = :imp_val_bol,
                mostrarimagen        = :mostrarimagen,
                envios_auto          = :envios_auto,
                precio_comanda       = :precio_comanda,
                direccion_comanda    = :direccion_comanda,
                pedido_comanda       = :pedido_comanda,
                multiples_precios    = :multiples_precios,
                comision_tarjeta     = :comision_tarjeta,
                impresion_automatica = :impresion_automatica,
                accesoaweb           = :accesoaweb
            ";

            $stmt = $this->db->prepare($sql);
            $ok = $stmt->execute([
                ':zona_hora'            => $data['zona_hora'] ?? null,
                ':trib_acr'             => $data['trib_acr'] ?? null,
                ':trib_car'             => $data['trib_car'] ?? null,
                ':di_acr'               => $data['di_acr'] ?? null,
                ':di_car'               => $data['di_car'] ?? null,
                ':imp_acr'              => $data['imp_acr'] ?? null,
                ':imp_val'              => $data['imp_val'] ?? null,
                ':mon_acr'              => $data['mon_acr'] ?? null,
                ':mon_val'              => $data['mon_val'] ?? null,
                ':pc_name'              => $data['pc_name'] ?? null,
                ':pc_ip'                => $data['pc_ip'] ?? null,
                ':print_com'            => $data['print_com'] ?? null,
                ':print_pre'            => $data['print_pre'] ?? null,
                ':print_cpe'            => $data['print_cpe'] ?? null,
                ':cod_seg'              => $data['cod_seg'] ?? null,
                ':opc_01'               => $data['opc_01'] ?? null,
                ':sep_items'            => $data['sep_items'] ?? null,
                ':verpdf'               => $data['verpdf'] ?? null,
                ':nota_ind'             => $data['nota_ind'] ?? null,
                ':imp_bol'              => $data['imp_bol'] ?? null,
                ':imp_val_bol'          => $data['imp_val_bol'] ?? null,
                ':mostrarimagen'        => $data['mostrarimagen'] ?? null,
                ':envios_auto'          => $data['envios_auto'] ?? null,
                ':precio_comanda'       => $data['precio_comanda'] ?? null,
                ':direccion_comanda'    => $data['direccion_comanda'] ?? null,
                ':pedido_comanda'       => $data['pedido_comanda'] ?? null,
                ':multiples_precios'    => $data['multiples_precios'] ?? null,
                ':comision_tarjeta'     => $data['comision_tarjeta'] ?? null,
                ':impresion_automatica' => $imp_automatica,   // ← normalizado
                ':accesoaweb'           => $accesoaweb,       // ← normalizado
                // ':id_config'         => $data['id_config'] ?? 1,
            ]);

            // Debug útil
            if (!$ok) {
                $info = $stmt->errorInfo();
                error_log('UPDATE tm_configuracion error: ' . implode(' | ', $info));
            }
            // También puedes verificar cuántas filas actualizó:
            $filas = $stmt->rowCount();

            /* ACTUALIZAR DATOS */
            Session::set('moneda', $data['mon_val']);
            Session::set('igv', $data['imp_val']);
            Session::set('tribAcr', $data['trib_acr']);
            Session::set('tribCar', $data['trib_car']);
            Session::set('diAcr', $data['di_acr']);
            Session::set('diCar', $data['di_car']);
            Session::set('impAcr', $data['imp_acr']);
            Session::set('monAcr', $data['mon_acr']);
            Session::set('zona_hor', $data['zona_hora']);
            Session::set('pc_name', $data['pc_name']);
            Session::set('pc_ip', $data['pc_ip']);
            Session::set('print_com', $data['print_com']);
            Session::set('print_pre', $data['print_pre']);
            Session::set('print_cpe', $data['print_cpe']); //funcion impresion directa 
            Session::set('cod_seg', $data['cod_seg']); //funcion codigo de seguridad 
            Session::set('opc_01', $data['opc_01']); //funcion codigo de seguridad 
            Session::set('sep_items', $data['sep_items']); //funcion separa items al agregar
            Session::set('verpdf', $data['verpdf']); //para ver pdf despues de venta
            Session::set('nota_ind', $data['nota_ind']);
            Session::set('mostrarimagen', $data['mostrarimagen']);
            Session::set('envios_auto', $data['envios_auto']);
            Session::set('precio_comanda', $data['precio_comanda']);
            Session::set('direccion_comanda', $data['direccion_comanda']);
            Session::set('pedido_comanda', $data['pedido_comanda']);
            Session::set('multiples_precios', $data['multiples_precios']);
            Session::set('comision_tarjeta', $data['comision_tarjeta']);
            Session::set('impresion_automatica_comanda', $data['impresion_automatica_comanda_hidden']);
            Session::set('mostrar_web', $data['mostrar_web_hidden']);

            return 1;
            
        } catch (Exception $e) 
        {
            die($e->getMessage());
        }
    }

    public function anularlogo()
    {
        try
        {
            $stm = $this->db->prepare("UPDATE tm_empresa SET logo = NULL WHERE tm_empresa.id_de = 1");
            $stm->execute();
            // return $c;
            if($stm){
                return '1';
            }
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }

    public function bloqueoplataforma($data)
    {
        try
        {
            $stm = $this->db->prepare("UPDATE tm_configuracion SET bloqueo = ? WHERE id_cfg = '1' ");
            $stm->execute(array($data['tipo_bloqueo']));

            if($stm){
                Session::set('bloqueo_id', $data['tipo_bloqueo']); 
                return '1';
            }
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }
    // bloqueoplataforma

    public function importarexcel()
    {   
        try {
            error_reporting(0);
            include "libs/class.upload.php";
            if(isset($_FILES["file"])){
                $up = new Upload($_FILES["file"]);
                if($up->uploaded){
                    $up->Process("libs/uploads/");
                    if($up->processed){
                        /// leer el archivo excel
                        // require_once "../libs/PHPExcel/Classes/PHPExcel.php";
                        require_once "libs/PHPExcel/Classes/PHPExcel.php";

                        $archivo = "libs/uploads/".$up->file_dst_name;
                        $inputFileType = PHPExcel_IOFactory::identify($archivo);
                        $objReader = PHPExcel_IOFactory::createReader($inputFileType);
                        $objPHPExcel = $objReader->load($archivo);
                        $sheet = $objPHPExcel->getSheet(0); 
                        $highestRow = $sheet->getHighestRow(); 
                        $highestColumn = $sheet->getHighestColumn();
                        for ($row = 2; $row <= $highestRow; $row++){ 
                            $categoria      = $sheet->getCell("A".$row)->getValue();
                            $x_producto     = $sheet->getCell("B".$row)->getValue();
                            $x_cod_pro      = $sheet->getCell("C".$row)->getValue();
                            $x_area         = $sheet->getCell("D".$row)->getValue();
                            $x_trasformado  = $sheet->getCell("E".$row)->getValue();
                            $x_notas        = $sheet->getCell("F".$row)->getValue();
                            $x_desc         = $sheet->getCell("G".$row)->getValue();
                            $x_delivery     = $sheet->getCell("H".$row)->getValue();
            
                            if($categoria){

            
                                $sql_categoria = $this->db->selectOne("SELECT * FROM tm_producto_catg WHERE descripcion LIKE '".$categoria."' ");
                                       
                                if ($sql_categoria) {
                                    $id_catg = $sql_categoria['id_catg'];
                                }
                                else{
                                    $insert_categoria   = "INSERT INTO tm_producto_catg SET descripcion = ?";
                                    $result_categoria   = $this->db->prepare($insert_categoria)->execute(array($categoria));
                                    $id_catg            = $this->db->lastInsertId(); // se obtiene el id 
                                }                                
                                    $sql_areapro = $this->db->selectOne("SELECT * FROM tm_area_prod WHERE nombre LIKE '".$x_area."' ");

                                if ($sql_areapro) {
                                    $id_areap = $sql_areapro['id_areap'];
                                }
                                else{
                                    $id_areap = "";

                                }
                                $x_trasformado = ($x_trasformado == 'si') ? '2': '1';
                                $x_delivery = ($x_delivery == 'si' || $x_delivery == 'SI') ? '1': '0';
                                
                                $sql_producto1 = $this->db->selectOne("SELECT * FROM tm_producto WHERE cod_pro LIKE '".$x_cod_pro."'");
                                if(!$sql_producto1){
                                    $insert_producto = "INSERT INTO tm_producto SET id_tipo = ? ,id_catg = ?, id_areap = ?, nombre = ?, notas = ?, descripcion = ?, delivery = ?, cod_pro  = ?";
                                    $result_producto = $this->db->prepare($insert_producto)->execute(array($x_trasformado, $id_catg, $id_areap, $x_producto, $x_notas, $x_desc, $x_delivery, $x_cod_pro)); 
                                }
                            }
            
                        }
                        // presentacion se activa     
                        $sheetpre = $objPHPExcel->getSheet(1); 
                        $highestRowp = $sheetpre->getHighestRow(); 
                        $highestColumn = $sheetpre->getHighestColumn();
                        for ($row = 2; $row <= $highestRowp; $row++){ 
                            $p_cod_producto     = $sheetpre->getCell("A".$row)->getValue();
                            $p_presentacion     = $sheetpre->getCell("B".$row)->getValue();
                            $p_cod_presentacion = $sheetpre->getCell("C".$row)->getValue();
                            $p_descripcion      = $sheetpre->getCell("D".$row)->getValue();
                            $p_precio           = $sheetpre->getCell("E".$row)->getValue();
                            $p_precio_delivery  = $sheetpre->getCell("F".$row)->getValue();
                            $p_stock_min        = $sheetpre->getCell("G".$row)->getValue();
                            $p_control_stock    = $sheetpre->getCell("H".$row)->getValue();
                            $p_igv              = $sheetpre->getCell("I".$row)->getValue();
                            $p_delivery         = $sheetpre->getCell("J".$row)->getValue();
                            // REMPLAZAR 
                            $p_control_stock    = (strtoupper($p_control_stock) == 'SI') ? '1': '0';
                            $p_igv              = (strtoupper($p_igv)   == 'SI') ? '1': '0';
                            $p_delivery         = (strtoupper($p_delivery) == 'SI') ? '1': '0';

                            $p_igv_monto        = Session::get('igv');
                            // extraer id producto
                            $sql_producto = $this->db->selectOne("SELECT * FROM tm_producto WHERE cod_pro LIKE '".$p_cod_producto."'");
                                       
                            if ($sql_producto) {
                                $id_p_producto = $sql_producto['id_prod'];
                                $p_descripcion = (strlen($p_descripcion) >= 1)? $p_descripcion : '';
                                $sql_presentacion = $this->db->selectOne("SELECT * FROM tm_producto_pres WHERE cod_prod LIKE '".$p_cod_presentacion."'");
                                if(!$sql_presentacion){
                                    $insert_presentacion = "INSERT INTO tm_producto_pres SET id_prod = ?,cod_prod = ?,presentacion = ?,descripcion = ?,precio = ?,precio_delivery = ?,receta = ?,stock_min = ?,crt_stock = ?,impuesto = ?,delivery = ?,margen = ?,igv = ?";
                                    $result_presentacion = $this->db->prepare($insert_presentacion)->execute(array($id_p_producto, $p_cod_presentacion, $p_presentacion, $p_descripcion, $p_precio, $p_precio_delivery, '0',$p_stock_min,$p_control_stock,$p_igv, $p_delivery,'0', $p_igv_monto)); 
                                } 
                            }
                        }
                        return ($result_presentacion)? '1' : '0';


                    unlink($archivo);
                    }   
            
                }
            }
            



        } 
        catch (Exception $e) 
        {
            die($e->getMessage());
        }

    }

    public function importarexcelinsumos()
    {   
        try {
            error_reporting(0);
            include "libs/class.upload.php";
            if(isset($_FILES["file"])){
                $up = new Upload($_FILES["file"]);
                if($up->uploaded){
                    $up->Process("libs/uploads/");
                    if($up->processed){
                        /// leer el archivo excel
                        // require_once "../libs/PHPExcel/Classes/PHPExcel.php";
                        require_once "libs/PHPExcel/Classes/PHPExcel.php";

                        $archivo = "libs/uploads/".$up->file_dst_name;
                        $inputFileType = PHPExcel_IOFactory::identify($archivo);
                        $objReader = PHPExcel_IOFactory::createReader($inputFileType);
                        $objPHPExcel = $objReader->load($archivo);
                        $sheet = $objPHPExcel->getSheet(0); 
                        $highestRow = $sheet->getHighestRow(); 
                        $highestColumn = $sheet->getHighestColumn();
                        for ($row = 2; $row <= $highestRow; $row++){ 
                            $categoria      = $sheet->getCell("A".$row)->getValue();
                            $x_nombre       = $sheet->getCell("B".$row)->getValue();
                            $x_cod          = $sheet->getCell("C".$row)->getValue();
                            $x_medida       = $sheet->getCell("D".$row)->getValue();
                            $x_stock_min    = $sheet->getCell("E".$row)->getValue();
                            $x_costo_und    = $sheet->getCell("F".$row)->getValue();

            
                            if($categoria){

            
                                $sql_categoria = $this->db->selectOne("SELECT * FROM tm_insumo_catg WHERE descripcion LIKE '".$categoria."' ");
                                       
                                if ($sql_categoria) {
                                    $id_catg = $sql_categoria['id_catg'];
                                }
                                else{
                                    $insert_categoria   = "INSERT INTO tm_insumo_catg SET descripcion = ?";
                                    $result_categoria   = $this->db->prepare($insert_categoria)->execute(array($categoria));
                                    $id_catg            = $this->db->lastInsertId(); // se obtiene el id 
                                }                                
                                    $sql_medida = $this->db->selectOne("SELECT * FROM tm_tipo_medida WHERE descripcion LIKE '".$x_medida."' ");

                                if ($sql_medida) {
                                    $id_medida = $sql_medida['id_med'];
                                }
                                else{
                                    $id_medida = "";

                                }
                                
                                $sql_producto1 = $this->db->selectOne("SELECT * FROM tm_insumo WHERE cod_ins LIKE '".$x_cod."'");
                                if(!$sql_producto1){
                                    $insert_producto = "INSERT INTO tm_insumo SET id_catg = ?, id_med = ?,cod_ins = ?, nomb_ins = ?, stock_min = ?, cos_uni = ?";
                                    $result_producto = $this->db->prepare($insert_producto)->execute(array($id_catg,$id_medida,$x_cod,$x_nombre,$x_stock_min,$x_costo_und)); 
                                }
                            }            
                        }
                        return ($result_producto)? '1' : '0';


                    unlink($archivo);
                    }   
            
                }
            }
            



        } 
        catch (Exception $e) 
        {
            die($e->getMessage());
        }

    }

    public function limit($data)
    {
        try{
            if($data == 'user'){
                $usuarios   = $this->db->prepare('SELECT COUNT(*) total FROM tm_usuario WHERE id_rol != 1');
                $usuarios->execute();
                $plan       = $this->db->prepare('SELECT plan FROM tm_configuracion');
                $plan->execute();
                $plan           = json_decode($plan->fetch(PDO::FETCH_COLUMN));
                return [
                    'limits' => [
                        'total_users' => $plan->{'limit_users'},
                    ],
                    'current' => [
                        'total_users' => $usuarios->fetch(PDO::FETCH_COLUMN),
                    ],
                    'locked_users' => $plan->{'locked_users'},

                ];
            }elseif($data == 'invoices'){
                $plan       = $this->db->prepare('SELECT plan FROM tm_configuracion');
                $plan->execute();
                $plan           = json_decode($plan->fetch(PDO::FETCH_COLUMN));

                $date = date('Y-m-d', strtotime($plan->{'created_at'}));
                $day_start_billing  = date('d', strtotime($plan->{'created_at'}));
                $day_now            = (int)date('j');
                $end   = date('Y-m-d');
    
                $init   = date('Y').'-'.date('m').'-'.$day_start_billing;
                $end_date = date('Y-m-t', strtotime($date));
                if($day_now <= $day_start_billing){
                    if ($date == $end_date)
                    {

                        $init   = date('Y-m-t',strtotime("- 1 month")); 
                        $frist_date = date('Y-m-01', strtotime($init));
                        $last_date_nm = date('Y-m-t',strtotime($frist_date."+ 1 month")); 

                    }else {

                        $init   = date('Y').'-'.date('m').'-'.$day_start_billing;
                        $init   = date('Y-m-d',strtotime($init."- 1 month"));
                        $last_date_nm = date('Y-m-d',strtotime($init."+ 1 month")); 

                    }
                }else{
                    if ($date == $end_date)
                    {   

                        $init   = date('Y-m-t');    
                        $frist_date = date('Y-m-01', strtotime($init));
                        $last_date_nm = date('Y-m-t',strtotime($frist_date."+ 1 month")); 
                        
                    }else {
                        
                        $init   = date('Y').'-'.date('m').'-'.$day_start_billing;
                        $last_date_nm = date('Y-m-d',strtotime($init."+ 1 month")); 
                        
                    }
                }

                $comprobantes = $this->db->prepare("SELECT COUNT(*) total_comprobantes FROM tm_venta WHERE (date(fecha_venta) BETWEEN ? AND ?);");
                // $comprobantes = $this->db->prepare("SELECT COUNT(*) total_comprobantes FROM tm_venta WHERE id_tipo_doc != 3 AND (date(fecha_venta) BETWEEN ? AND ?);");
                $comprobantes->execute(array($init,$end)); 
                return [
                    'limits' => [
                        'total_invoices' => $plan->{'limit_documents'},
                    ],
                    'current' => [
                        'total_invoices'    => $comprobantes->fetch(PDO::FETCH_COLUMN),
                    ],
                    'locked_invoices' => $plan->{'locked_documents'},
                ];
                
            }

        }catch(Exception $e)
        {
            die($e->getMessage());
        }
    }
    public function contadorplan()
    {
        try
        {    

            $empresa    = $this->db->selectOne('SELECT nombre_comercial,ruc,logo FROM tm_empresa');
            $usuarios   = $this->db->prepare('SELECT COUNT(*) total FROM tm_usuario WHERE id_rol != 1');
            $usuarios->execute();
            $plan       = $this->db->prepare('SELECT plan FROM tm_configuracion');
            $plan->execute();

            $c{'empresa'}   = $empresa;
            $plan           = json_decode($plan->fetch(PDO::FETCH_COLUMN));
  
            $date = date('Y-m-d', strtotime($plan->{'created_at'}));
            $day_start_billing  = date('d', strtotime($plan->{'created_at'}));
            $day_now            = (int)date('j');
            $end   = date('Y-m-d');

            $init   = date('Y').'-'.date('m').'-'.$day_start_billing;
            $end_date = date('Y-m-t', strtotime($date));
            if($day_now <= $day_start_billing){
                if ($date == $end_date)
                {
                    
                    $init   = date('Y-m-t',strtotime("- 1 month")); 
                    $frist_date = date('Y-m-01', strtotime($init));
                    $last_date_nm = date('Y-m-t',strtotime($frist_date."+ 1 month")); 
                    
                }else {

                    $init   = date('Y').'-'.date('m').'-'.$day_start_billing;
                    $init   = date('Y-m-d',strtotime($init."- 1 month"));
                    $last_date_nm = date('Y-m-d',strtotime($init."+ 1 month")); 
                    
                }
            }else{
                if ($date == $end_date)
                {   

                    $init   = date('Y-m-t');    
                    $frist_date = date('Y-m-01', strtotime($init));
                    $last_date_nm = date('Y-m-t',strtotime($frist_date."+ 1 month")); 
                    
                }else {

                    $init   = date('Y').'-'.date('m').'-'.$day_start_billing;
                    $last_date_nm = date('Y-m-d',strtotime($init."+ 1 month")); 
                    
                }
            }

            $comprobantes = $this->db->prepare("SELECT COUNT(*) total_comprobantes FROM tm_venta WHERE (date(fecha_venta) BETWEEN ? AND ?);");
            // $comprobantes = $this->db->prepare("SELECT COUNT(*) total_comprobantes FROM tm_venta WHERE id_tipo_doc != 3 AND (date(fecha_venta) BETWEEN ? AND ?);");
            $comprobantes->execute(array($init,$end)); 
                
            $c{'intervals'} =[
                $init,
                $last_date_nm,
            ];

            $c{'current'} = [
                'total_invoices'    => $comprobantes->fetch(PDO::FETCH_COLUMN),
                'total_users'       => $usuarios->fetch(PDO::FETCH_COLUMN),
            ];

            $c{'limits'} = [
                'total_invoices' => $plan->{'limit_documents'},
                'total_users' => $plan->{'limit_users'},
            ];

            $data = array("data" => $c);
            $json = json_encode($data);
            echo $json;
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }
    public function datoplataforma_data()
    {
        try
        {    
            $plan       = $this->db->prepare('SELECT plan FROM tm_configuracion');
            $plan->execute();
            $plan       = json_decode($plan->fetch(PDO::FETCH_COLUMN));
            return $plan;

        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }
    public function datoplataforma_crud($data)
    {
        try
        {   
            $sql = "UPDATE tm_configuracion SET plan = ? WHERE id_cfg = 1";
            $df = [
                'created_at'      => $data['created_at'],
                'limit_users'     => $data['limit_users'],
                'locked_users'    => $data['locked_users'],
                'limit_documents' => $data['limit_documents'],
                'locked_documents'=> $data['locked_documents'],
                'wsp_token'       => $data['wsp_token'],
                'wsp_message'      => $data['wsp_message'],
                'api_wsp'         => $data['api_wsp'],
            ];
            
            $df = json_encode($df);
            $arrayParam =  array($df);
            $st = $this->db->prepare($sql);
            $st->execute($arrayParam);

            // Session::set('wsp_token', $data['wsp_token']);
            // Session::set('api_wsp', $data['api_wsp']);

            return ($st->rowCount())? '1' : '0';
            
        }
        catch(Exception $e)
        {
            die($e->getMessage());
        }
    }



}
