mirror of
https://github.com/rmontanana/inventario2.git
synced 2025-08-15 07:25:57 +00:00
366 lines
13 KiB
PHP
366 lines
13 KiB
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ó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ó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á ningú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 = "¡Atenció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ó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ón");
|
|
} catch (Exception $e) {
|
|
$this->bdd->abortaTransaccion();
|
|
$mensaje = "Se ha producido el error [" . $e->getMessage() . "]<br>NO se ha realizado ningú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.'");';
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
?>
|