X-Git-Url: https://git.llucax.com/mecon/yatta.git/blobdiff_plain/8d2616c309cde3dfbcf843ba66e0162f8d108920..0d8ee0dcc365fda25bd7723fa5e146706fddb191:/script/servidores/YATTA_Tacho.php diff --git a/script/servidores/YATTA_Tacho.php b/script/servidores/YATTA_Tacho.php index 1ed5f5c..cbfaf3b 100755 --- a/script/servidores/YATTA_Tacho.php +++ b/script/servidores/YATTA_Tacho.php @@ -25,6 +25,16 @@ Autor: Martin Marrese $Id$ -----------------------------------------------------------------------------*/ + +//============================================== +//TODO FIXME XXX +//============================================== +//SACAR TODO LO QUE SE PUEDA A LAS CLASES QUE +//CORRESPONDAN +//AGREGAR LAS LINEAS DEL LOG +//============================================== + + //YATTA LOG {{{ function yatta_log ($texto) { GLOBAL $YATTA_SERVER; @@ -35,27 +45,34 @@ function yatta_log ($texto) { } //}}} +//Leo el archivo de configuracion {{{ +$CONF = parse_ini_file(dirname(__FILE__) . '/configuracion.ini', true); +//}}} + //ABRO EL ARCHIVO DE LOG {{{ //Como root: //# touch /var/log/apache/YATTA_Tacho.log //# chown root.www-data /var/log/apache/YATTA_Tacho.log //# chmod 660 /var/log/apache/YATTA_Tacho.log -if (!($FH = fopen ("/var/log/apache/YATTA_Tacho.log", "a"))) { - die ("No se pudo abrir el archivo de log. Se detiene el script."); +if (!($FH = fopen ($CONF['tacho']['log'], "a"))) { + trigger_error("No se pudo abrir el archivo de log. Se detiene el script.", E_USER_ERROR); } //}}} //REQUIRE ONCE {{{ -require_once 'DB.php'; require_once 'PEAR.php'; +require_once 'YATTA/DB.php'; require_once 'YATTA/Controlador.php'; require_once 'YATTA/Servidor.php'; +require_once 'YATTA/Archivo.php'; +require_once 'Date.php'; +require_once 'Date/Span.php'; //}}} //CREO UNA CONEXION MYSQL{{{ -$db =& DB::connect('mysql://intranet:intranet@bal747f/yatta', true); +$db = YATTA_DB::connect($CONF['db']); if (DB::isError($db)) { - die ($db->getMessage()); + trigger_error($db->getMessage(), E_USER_ERROR); } //}}} @@ -65,38 +82,185 @@ $SERVIDOR =& new YATTA_Servidor; //}}} //OBTENGO LOS DATOS DEL SERVER {{{ -$YATTA_SERVER['tacho'] = '/var/www/yatta_tacho/'; +$YATTA_SERVER['path_tacho'] = $CONF['tacho']['repositorio']; $YATTA_SERVER['script'] = $argv[0]; $YATTA_SERVER['pid'] = getmypid(); $YATTA_SERVER['name'] = substr(file_get_contents('/etc/hostname'), 0, strpos (file_get_contents('/etc/hostname'), "\n")); $YATTA_SERVER['id'] = $SERVIDOR->obtenerId($db, $YATTA_SERVER['name']); if (PEAR::isError($YATTA_SERVER['id'])) { - die('Error: ' . $YATTA_SERVER['id']->getMessage() . "\n"); + trigger_error('Error: ' . $YATTA_SERVER['id']->getMessage() . "\n", E_USER_ERROR); } yatta_log ('*************** Comienzo Ejecución ***************'); //}}} -//BORRO LOS ARCHIVOS CON MAS DE 7 DIAS {{{ - +//BORRO LOS ARCHIVOS CON MAS DE N DIAS {{{ +if ($dh = opendir($YATTA_SERVER['path_tacho'])) { + yatta_log('Se borran los archivos antiguos.'); + while (false !== ($fh = readdir($dh))) { + if ($fh != '.' && $fh != '..' && !in_array($fh, split(',', + $CONF['tacho']['ignorar']))) { + $span =& new Date_Span ( + new Date (filemtime($YATTA_SERVER['path_tacho'].$fh)), + new Date ()); + if ($span->greater(new Date_Span ( + array ($CONF['tacho']['cantidad_dias'],0,0,0)))) { + + $archivo =& new YATTA_Archivo; + $archivo->archivo = $fh; + $res = $archivo->buscar($DB); + if (PEAR::isError($res)) { + trigger_error('Error: ' . $res->getMessage() . "\n", + E_USER_ERROR); + } + $archivo->cargar($res); + $res = $archivo->borrar($res); + if (PEAR::isError($res)) { + trigger_error('Error: ' . $res->getMessage() . "\n", + E_USER_ERROR); + } + } + } + } + closedir($dh); +} //}}} //VERIFICO LAS CUOTAS DE LOS USUARIOS{{{ - //WHILEO POR USUARIO {{{ - //HAY MAS DE LA CUOTA {{{ +//OBTENGO LA LISTA DE USUARIOS QUE TIENEN AL MENOS UNA ENTRADA EN EL MYSQL {{{ +$res = $CONTROLADOR->obtenerListaOwners($db, true); +if (PEAR::isError($res)) { + trigger_error('Error: ' . $res->getMessage() . "\n", E_USER_ERROR); +} +yatta_log('Se obtiene la lista de owners de los archivos.'); +//}}} +//OBTENGO LA LISTA DE USUARIOS CON CUOTAS EXCEPCIONALES {{{ +$cuotas = $CONTROLADOR->obtenerListaCuotas($db); +$cuotas = $cuotas->fetchRow(DB_FETCHMODE_ARRAY); +if (PEAR::isError($cuotas)) { + trigger_error('Error: ' . $cuotas->getMessage() . "\n", E_USER_ERROR); +} +yatta_log('Se obtienen las cuotas excepcionales.'); +//}}} + +//WHILEO POR USUARIO {{{ +yatta_log('Se verifica que los usuarios no superen la cuota asignada.'); +while ($usuario = $res->fetchRow(DB_FETCHMODE_ASSOC)) { + //VEO EL TIPO DE CUOTA DEL USUARIO {{{ + if (@in_array($usuario['owner'], $cuotas)) { + if (PEAR::isError($cuotas)) { + trigger_error('Error: ' . $cuotas->getMessage() . "\n", E_USER_ERROR); + } + } + else { + $cuota = $CONF['cuota_tamanio']; + } + //}}} + //BUSCO LOS ARCHIVOS, TAMANIO y FECHA DEL USUARIO{{{ + $archivo =& new YATTA_Archivo; + $archivo->owner = $usuario['owner']; + $res = $archivo->buscar($DB, MECON_DBO_OR, null, false); + if (PEAR::isError($res)) { + trigger_error('Error: ' . $res->getMessage() . "\n", E_USER_ERROR); + } + $tamanio = 0; + $contador = 0; + while ($archivo->cargar($res)) { + if (PEAR::isError($res)) { + trigger_error('Error: ' . $res->getMessage() . "\n", E_USER_ERROR); + } + //Obtengo la fecha, el tamanio de cada archivo. + if (file_exists($archivo->archivo)) { + $archivos[$contador]['nombre'] = $archivo->archivo; + $archivos[$contador]['resultado'] = $archivo->resultado; + $archivos[$contador]['tamanio'] = filesize($archivo->archivo); + $archivos[$contador]['fecha'] = filemtime($archivo->archivo); + $tamanio += $archivos[$archivo->archivo]['tamanio'] ; + $contador ++; + } + } + //}}} + //HAY MAS DE LA CUOTA {{{ + if ($cuota <= (($tamanio / 1024) / 1024)) { //BORRAR LOS ARCHIVOS MAS VIEJOS HASTA LLEGAR AL VALOR DE LA CUOTA. - //ENVIAR UN EMAIL AVISANDO DE ESTO. - //}}} - //HAY MENOS DE LA CUOTA PERO SUPERA EL 80%{{{ + //Ordeno los archivos por la fecha, y voy "borrando" los mas viejos + //hasta cumplir con el tamaño de la cuota. + yatta_log('El usuario '. $usuario['owner'] + .' ha excedido la cuota de su casilla'); + usort($archivos, 'usort_archivos_callback'); + $seguir = true; + while ($seguir == true) { + $archivo = array_shift($archivos); + $tamanio -= $archivo['tamanio']; + $borrar[] = $archivo['nombre']; + $borrar2[] = $archivo['resultado']; + if ((($tamanio / 1024) / 1024) < + ($CONF['cuota_warning'] * $cuota / 100)) { + $seguir = false; + } + } + //Borros los archivos correspondientes. + foreach ($borrar as $b) { + yatta_llog('Se borra el archivo '. $b .' perteneciente a '. + $usuario['owner']); + unlink($b); + } + //Envio el email + if (@$borrar2) { + array_unshift($borrar2, + "La capacidad maxima que usted tiene en el sistema YATTA fue", + "superada.", + "Los siguientes archivos han sido borrados del sistema:"); + array_push($borrar2, + "\n\nEste es un mensaje generado automaticamente por YATTA,". + " por favor no responder a este email\n"); + $body = implode ('\n', $borrar); + $to = $usuario['owner'].'.gov.ar'; + $headers = "From: Intranet - YATTA \r\n"; + $subject = "INTRANET - SAYONARA - Aviso cuota excedida."; + mail($to, $subject, $body, $headers); + } + } + //}}} + //HAY MENOS DE LA CUOTA PERO SUPERA LO ESTABLECIDO EN EL ARCHIVO DE CONFIGURAION{{{ + elseif (($CONF['cuota_warning'] * $cuota / 100) <= (($tamanio / 1024) / 1024)) { //ENVIAR EMAIL SOBRE LA SITUACION Y AVISANDO QUE SI SE SUPERA LA CUOTA //LOS ARCHIVOS MAS VIEJOS SERAN BORRADOS HASTA CUMPLIR EL REQUERIMIENTO //DE TAMAÑO - //}}} + //LEVANTAR DEL ARCHIVO DE CONFIGURACION EL HOST PARA EL LINK (ASI EL + //INFELIZ USUARIO VA A VER QUE MIERDA TIENE, QUE BORRA Y QUE NO) + yatta_log('El usuario '. $usuario['owner'] + .' ha superado el limite de aviso. Se envia email. '); + $body = + "Su cuota dentro del sistema YATTA esta por completarse, le \n". + "pedimos que libere espacio para futuros archivos.\n". + "\nhttp://intranet.mecon.ar/sistemas/intranet/login?redirect". + "=/sistemas/yatta\n\n". + "\n\nEste es un mensaje generado automaticamente por YATTA,". + " por favor no responder a este email\n"; + $to = $usuario['owner'].'.gov.ar'; + $headers = "From: Intranet - YATTA \r\n"; + $subject = "INTRANET - SAYONARA - Aviso cuota completa."; + mail($to, $subject, $body, $headers); + } //}}} +} +//}}} //}}} //CIERRO EL ARCHIVO DE LOG {{{ yatta_log ('*************** Finaliza Ejecución ***************'); fclose ($FH); //}}} + +//FUNCIONES AUXILIARES {{{ +//Ordena los archivos segun la "edad" +function usort_archivos_callback($arg1, $arg2) { + if ($arg1['fecha'] == $arg2['fecha']) { + return 0; + } + return ($arg1['fecha'] < $arg2['fecha']) ? -1 : 1; +} +//}}} + ?> \ No newline at end of file