<?php
$oCaducidades = new Caducidades();

class Caducidades
{
	private $hosts_origen = array(
								'San Cristobal'	=> '10.5.0.10',
								'Oriente'		=> '10.5.0.17',
								'Centro'		=> '10.5.0.22',
								'Yucalpeten'	=> '10.5.0.19',
								'Fmontejo'		=> '10.5.0.23',
								'Itzaes'		=> '10.5.0.7',
								'Pensiones'		=> '10.5.0.8',
								'Chuburna'		=> '10.5.0.5',
								'Montecristo'	=> '10.5.0.9',
								'Maya'			=> '10.5.0.13',
								'Brisas'		=> '10.5.0.15',
								'Circuito'		=> '10.5.0.6',
								'Almacen'		=> '10.5.0.16'
							);
	private $host_destino = 'server.fcomercio';
	private $link_destino;
	private $link_origen;

	public function __construct()
	{
		$this->link_destino = mysql_connect("server.fcomercio","pdv", "pdv", TRUE);
		mysql_select_db("test", $this->link_destino);
		$this->saca_caducidades();
	}
	
	private function saca_caducidades()
	{
		foreach($this->hosts_origen as $host_name => $host_ip)
		{
			if($this->conectar($host_ip))
			{
				echo "\n\n";
				echo "Conectado al Origen: $host_name\n";
				echo "Base de datos seleccionada...\n";
				echo "Extrayendo datos...\n";
			}
			else
			{
				die("Error al conectar con $host_name \n\n");
			}
			
			$sql = "
					SELECT 
						amecop, 
						nombre, 
						fecha, 
						cantidad 
					FROM 
						CADUCIDADES
				";
				
			$result_origen = mysql_query($sql, $this->link_origen);
			$num_rows = mysql_num_rows($result_origen);
			
			echo "Fueron extraidos $num_rows registros de $host_name \n";
			echo "Guardando registros en el Servidor\n";
			echo "Hueva hacer lo de las rayitas del porcentaje! \n";
			
			while($row = mysql_fetch_assoc($result_origen))
			{
				$sql = "
						INSERT INTO 
							CADUCIDADES 
						SET
							amecop = '{$row['amecop']}',
							nombre = '{$row['nombre']}',
							fecha = '{$row['fecha']}',
							cantidad = '{$row['cantidad']}'
						";
				mysql_query($sql, $this->link_destino);
			}
			
			echo "Listo con $host_name \n";
		}
	}
	
	private function conectar($host)
	{
		if( $this->link_origen = mysql_connect($host, "pdv", "pdv", TRUE) and mysql_select_db("pdv", $this->link_origen) )
		{
			return TRUE;
		}
		else
		{
			return FALSE;
		}
	}
}

?>