inventario2/Csv.php

<?php

/**
 * @package Inventario
 * @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(array($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 = array();
            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;
        fputs($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.'");';
        }
    }

}

?>