<?php

/**
 * @copyright Copyright (c) 2008, Ricardo Montañana Gómez
 * @license http://www.gnu.org/licenses/gpl-3.0.txt
 * This file is part of Inventario.
 * Inventario is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * Inventario is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with Inventario.  If not, see <http://www.gnu.org/licenses/>.
 */
class Csv
{
    /**
     * @var string Nombre del fichero csv
     */
    private $nombre;

    /**
     * @var FILE manejador del fichero
     */
    private $fichero = null;

    /**
     * @var xml conulta asociada a este fichero
     */
    private $consulta;

    /**
     * @var database Controlador de la base de datos
     */
    private $bdd;

    /**
     * @var int Número de registros en el fichero csv
     */
    private $numRegistros;

    /**
     * @var array Cabecera del archivo csv
     */
    private $cabecera;

    /**
     * @var array los datos del fichero csv en memoria
     */
    private $datosFichero;

    /**
     * Indices a los campos correspondientes.
     */
    private $idElemento;
    private $idArticulo;
    private $idUbicacion;
    private $fechaCompra;
    private $cantidad;
    private $cantidadReal;
    private $nSerie;

    /**
     * // El constructor necesita saber cuál es la opción actual.
     * /**
     * Constructor de la clase.
     *
     * @param BaseDatos $baseDatos Manejador de la base de datos
     */
    public function __construct($baseDatos)
    {
        $this->bdd = $baseDatos;
    }

    /**
     * Crea un fichero csv con el nombre especificado.
     *
     * @param string $fichero Nombre del fichero
     */
    public function crea($fichero)
    {
        $this->nombre = $fichero;
        $this->fichero = fopen($this->nombre, 'w') or die('No puedo abrir '.$this->nombre.' para escritura.');
    }

    /**
     * @param array $datos escribe la línea en el archivo
     */
    public function escribeLinea($datos)
    {
        fputcsv($this->fichero, $datos, ',', '"') or die('No puedo escribir en el fichero csv');
    }

    public function __destruct()
    {
        $this->cierra();
    }

    public function cierra()
    {
        fclose($this->fichero) or die('No puedo cerrar el archivo csv');
    }

    /**
     * @param string $fichero Archivo xml que contiene la definición de la consulta
     */
    public function ejecutaConsulta($fichero)
    {
        $consulta = simplexml_load_file($fichero) or die('No puedo cargar el fichero xml '.$fichero.' al csv');
        // Escribe la cabecera del fichero
        $this->escribeLinea([$consulta->Pagina->Cabecera, $consulta->Titulo['id'], $consulta->Titulo['Texto']]);
        foreach ($consulta->Pagina->Cuerpo->Col as $campo) {
            $campos[] = $campo['Titulo'];
        }
        $this->escribeLinea($campos);
        // Escribe los datos de los campos
        $this->bdd->ejecuta($consulta->Datos->Consulta);
        while ($fila = $this->bdd->procesaResultado()) {
            $campos = [];
            foreach ($consulta->Pagina->Cuerpo->Col as $campo) {
                $campos[] = $fila[(string) $campo['Nombre']];
            }
            $this->escribeLinea($campos);
        }
    }

    /**
     * @param string $ficheroCSV Nombre del archivo csv
     */
    public function cargaCSV($ficheroCSV)
    {
        $this->nombre = $ficheroCSV;
        $this->fichero = fopen($this->nombre, 'r') or die('No puedo abrir el archivo '.$this->nombre.' para lectura.');
        list($archivo, $idCabecera, $cabecera) = fgetcsv($this->fichero);
        while ($linea = fgetcsv($this->fichero)) {
            $datosFichero[] = $linea;
        }
        $this->cabecera[] = $archivo;
        $this->cabecera[] = $idCabecera;
        $this->cabecera[] = $cabecera;
        $this->datosFichero = $datosFichero;
    }

    /**
     * Muestra un resumen de los datos del fichero csv cargado por pantalla.
     */
    public function resumen()
    {
        //$mensaje .=
        $mensaje = '<center><h1>Archivo [inventario'.$this->cabecera[0].']</h1>';
        $mensaje .= '<h2>id=['.$this->cabecera[1].'] Descripci&oacute;n=['.$this->cabecera[2].']</h2><br>';
        $mensaje .= '<table border=1 class="table table-striped table-bordered table-condensed table-hover"><theader>';
        foreach ($this->datosFichero[0] as $campo) {
            $dato = $campo;
            $mensaje .= "<th><b>$dato</b></th>";
        }
        $mensaje .= '<th><b>Acci&oacute;n</b></th>';
        $mensaje .= '</theader><tbody>';
        $this->cargaIndices($this->datosFichero[0]);
        //echo "$mensaje contar Datosfichero=[".count($datosFichero)."]";
        for ($i = 1; $i < count($this->datosFichero); $i++) {
            $mensaje .= '<tr>';
            $primero = true;
            foreach ($this->datosFichero[$i] as $dato) {
                if ($primero) {
                    $primero = false;
                    switch ($dato) {
                        case 'S': $estado = '-Baja-';
                            $color = 'danger';
                            break;
                        case 'Alta': $estado = '-Alta-';
                            $color = 'primary';
                            break;
                        case 'N': $estado = $this->compruebaCantidades($i);
                            if ($estado != 0) {
                                $color = 'warning';
                                if ($estado > 0) {
                                    $estado = '+'.$estado;
                                }
                            } else {
                                $estado = 'igual';
                                $color = 'info';
                            }
                            break;
                        default: throw new Exception("El archivo csv tiene un formato incorrecto.<br>Bajas=[$dato]");
                    }
                }
                $mensaje .= '<td>'.$dato.'</td>';
            }
            $mensaje .= '<td align="center"><label class="label label-'.$color.'">'.$estado.'</label></td>';
            $mensaje .= '</tr>';
        }
        $mensaje .= '</tbody></table></p><br>';
        $mensaje .= $this->panelMensaje('Si se produce cualquier error en el procesamiento del fichero, no se aplicar&aacute; ning&uacute;n cambio en la base de datos.');

        $mensaje .= '<form method="post" name="Aceptar" action="index.php?importacion&opc=ejecutar">
                <button type="button" name="Cancelar" value="Cancelar" onClick="location.href='."'index.php'".'" class="btn btn-danger"><span class="glyphicon glyphicon-remove"></span> Cancelar</button>
                <button type="submit" name="Aceptar" class="btn btn-primary"><span class="glyphicon glyphicon-ok"></span> Aceptar</button>
                <input type="hidden" name="ficheroCSV" value="'.$this->nombre.'">
                </form></center>';

        return $mensaje;
    }

    /**
     * @param $array línea de datos del fichero csv para comprobar las cantidades si se han modificado o no
     *
     * @return string
     */
    private function compruebaCantidades($i)
    {
        //$ultimo = count($datos);
        return $this->datosFichero[$i][$this->cantidadReal] - $this->datosFichero[$i][$this->cantidad];
    }

    private function panelMensaje($info, $tipo = 'danger', $cabecera = '&iexcl;Atenci&oacute;n!')
    {
        $mensaje = '<div class="panel panel-'.$tipo.'"><div class="panel-heading">';
        $mensaje .= '<h3 class="panel-title">'.$cabecera.'</h3></div>';
        $mensaje .= '<div class="panel-body">';
        $mensaje .= $info;
        $mensaje .= '</div>';
        $mensaje .= '</div>';

        return $mensaje;
    }

    private function escribeLog($comando)
    {
        $fp = fopen($this->nombre.'.log', 'a');
        $linea = strftime('%Y/%m/%d').'|'.$this->nombre.'|'.$comando;
        fwrite($fp, $linea."\n");
        fclose($fp);
    }

    private function bajaElemento($i)
    {
        $id = $this->datosFichero[$i][$this->idElemento];
        $comando = 'delete from Elementos where id="'.$id.'";';
        $this->escribeLog($comando);
        if (!$this->bdd->ejecuta($comando)) {
            throw new Exception('Baja-'.$this->bdd->mensajeError, $this->bdd->error);
        }
    }

    private function modificaElemento($i)
    {
        $id = $this->datosFichero[$i][$this->idElemento];
        $comando = 'update Elementos set Cantidad='.$this->datosFichero[$i][$this->cantidadReal].' where id="'.$id.'";';
        $this->escribeLog($comando);
        if (!$this->bdd->ejecuta($comando)) {
            throw new Exception('Modifica-'.$this->bdd->mensajeError, $this->bdd->error);
        }
    }

    private function altaElemento($i)
    {
        if ($this->cabecera[0] == 'Articulo') {
            $idUbicacion = $this->datosFichero[$i][$this->idUbicacion];
            $idArticulo = $this->cabecera[1];
            $comando = 'select id from Ubicaciones where Descripcion="'.$this->datosFichero[$i][$this->desUbicacion].'";';
        } else {
            $idUbicacion = $this->cabecera[1];
            $idArticulo = $this->datosFichero[$i][$this->idArticulo];
        }
        $idArt = $datosFichero[$i];
        $comando = 'insert into Elementos () values (null,'.$idArticulo.','.$idUbicacion.',"'.$this->datosFichero[$i][$this->nSerie];
        $comando .= '",'.$this->datosFichero[$i][$this->cantidadReal].',"'.$this->datosFichero[$i][$this->fechaCompra].'");';
        $this->escribeLog($comando);
        if (!$this->bdd->ejecuta($comando)) {
            throw new Exception('Alta-'.$this->bdd->mensajeError, $this->bdd->error);
        }
    }

    private function cargaIndices($campos)
    {
        for ($i = 0; $i < count($campos); $i++) {
            switch ($campos[$i]) {
                case 'Cant. Real': $this->cantidadReal = $i;
                    break;
                case 'Fecha C.': $this->fechaCompra = $i;
                    break;
                case 'idUbic': $this->idUbicacion = $i;
                    break;
                case 'idArt': $this->idArticulo = $i;
                    break;
                case 'idElem': $this->idElemento = $i;
                    break;
                case 'Cantidad': $this->cantidad = $i;
                    break;
                case 'N Serie': $this->nSerie = $i;
                    break;
            }
        }
        //$this->EscribeFic("Cantreal=[$this->cantidadReal] fechacompra=[$this->fechaCompra] ubicacion=[$this->idUbicacion] articulo=[$this->idArticulo]");
        //$this->EscribeFic("idElemento=[$this->idElemento] Cantidad=[$this->cantidad] nserie=[$this->nserie]");
    }

    /**
     * Procesa contra la base de datos todas las acciones del archivo.
     */
    public function ejecutaFichero()
    {
        $this->cargaIndices($this->datosFichero[0]);
        //Realiza una transacción para que no se ejecute parcialmente una actualización
        try {
            $this->bdd->comienzaTransaccion();
            $acciones = 0;
            for ($i = 1; $i < count($this->datosFichero); $i++) {
                switch ($this->datosFichero[$i][0]) {
                    case 'S':
                        $this->bajaElemento($i);
                        $acciones++;
                        break;
                    case 'Alta':
                        $this->altaElemento($i);
                        $acciones++;
                        break;
                    case 'N':
                        if ($this->compruebaCantidades($i) != 0) {
                            $this->modificaElemento($i);
                            $acciones++;
                        }
                        break;
                    default: throw new Exception('Acci&oacute;n no reconocida en la importacion ['.$this->datosFichero[0].']');
                }
            }
            $mensaje = "Se han procesado correctamente $acciones acciones en la Base de Datos.";
            $this->bdd->confirmaTransaccion();

            return $this->panelMensaje($mensaje, 'success', 'Informaci&oacute;n');
        } catch (Exception $e) {
            $this->bdd->abortaTransaccion();
            $mensaje = 'Se ha producido el error ['.$e->getMessage().']<br>NO se ha realizado ning&uacute;n cambio en la Base de Datos.';

            return $this->panelMensaje($mensaje);
        }
    }

    private function ejecutaFichero2()
    {
        echo '<script>visualizaProgreso();</script>';
        for ($i = 1; $i < 80; $i++) {
            //sleep(1);
            $progreso = $i;
            echo '<script>actProgreso('.$progreso.');</script>';
            //echo str_repeat(' ',1024*64);
            flush();
            //echo '$(".bar").css("width", "'.$progreso.'");';
        }
    }
}