YATTA_Proceso cuando asigna un servidor a un nuevo proceso lo hace ponderando.

[mecon/yatta.git] / lib / YATTA / Proceso.php

diff --git a/lib/YATTA/Proceso.php b/lib/YATTA/Proceso.php
index df7310ca550cc5a60b2cc28b6705ea27156de6fa..2c1e2fe3747c15f86d03d44342ea849da07711bc 100644 (file)
--- a/lib/YATTA/Proceso.php
+++ b/lib/YATTA/Proceso.php
@@ -105,10 +105,9 @@ class YATTA_Proceso extends MECON_DBO {
      * Estado del proceso.       
      * 0 = En Espera
      * 1 = Procesando
-     * 2 = Finalizado sin copiar el resultado al tacho
-     * 3 = Finalizado
-     * 4 = Error
-     * 5 = Abortado
+     * 2 = Finalizado
+     * 3 = Error
+     * 4 = Abortado
      *
      * @var    int $status
      * @access public
@@ -164,6 +163,14 @@ class YATTA_Proceso extends MECON_DBO {
      */
     var $resultado = null;
     
+    /**
+     * Nombre del archivo en el tacho
+     *
+     * @var    string $archivo
+     * @access public
+     */
+    var $archivo = null;
+    
     /**
      * Nota explicativa sobre el error producido o el motivo por el cual se
      * aborto el proceso.
@@ -219,6 +226,7 @@ class YATTA_Proceso extends MECON_DBO {
             $this->scheduling       = $res['scheduling'];
             $this->notificar        = $res['notificar'];
             $this->resultado        = $res['resultado'];
+            $this->archivo          = $res['archivo'];
             $this->nota             = $res['nota'];
             $this->icono            = $res['icono'];
             return true;
@@ -337,13 +345,15 @@ class YATTA_Proceso extends MECON_DBO {
             $orden = '';
         }
         
-        return $db->query("SELECT p.id AS id, p.fecha AS fecha, p.script AS
+        return $db->query("SELECT p.id AS id, 
+                DATE_FORMAT(p.fecha, '%d-%m-%Y') AS fecha, 
+                p.script AS
                 script, p.id_sistema AS id_sistema, s.nombre_sistema AS
                 nombre_sistema, p.descripcion AS descripcion, p.pid AS pid, 
                 p.server AS server, p.status AS status, p.owner AS owner, 
                 p.destinos AS destinos, p.prioridad AS prioridad, p.scheduling 
                 AS scheduling, p.notificar AS notificar, p.resultado AS 
-                resultado, p.nota AS nota,".
+                resultado, p.nota AS nota, p.archivo AS archivo, ".
                 "IF (p.status = 0, 'El proceso esta en cola. Aun no se ejecuto.".
                 "', ".
                 "IF(p.status = 1, 'El proceso se esta ejecutando en este momento.".
@@ -366,14 +376,31 @@ class YATTA_Proceso extends MECON_DBO {
     }
 
     /**
+     * Guarda los datos en la base.
+     *
      * @param  DB $db Conexion a la base de datos.
      * @param  bool $nuevo Indica si se trata de un nuevo registro en la base.
      *
      * @return mixed
      * @access public
      */
-    function guardar($db = null, $nuevo = false)
+    function guardar($db = null, $nuevo = true)
     {
+        //Busco el servidor
+        $res = $db->query('SELECT id, escala * procesos AS ponderacion
+                FROM yatta.servidores 
+                ORDER BY ponderacion, escala');
+        $res = $res->fetchRow(DB_FETCHMODE_ASSOC);
+        // Si hay error lo devuelve.
+        if (DB::isError($res)) {
+            return $res;
+        }
+        $this->server = $res['id'];
+        //Asigno la fecha
+        if (@is_null($this->fecha)) {
+            $this->fecha = date ('Y-m-d');
+        }
+        
         if ($nuevo) {
             $datos = array (
                         'fecha'         => $this->fecha,
@@ -389,6 +416,7 @@ class YATTA_Proceso extends MECON_DBO {
                         'scheduling'    => $this->scheduling,
                         'notificar'     => $this->notificar,
                         'resultado'     => $this->resultado,
+                        'archivo'       => $this->archivo,
                         'nota'          => $this->nota
                     );
 
@@ -410,6 +438,7 @@ class YATTA_Proceso extends MECON_DBO {
                         'scheduling'    => $this->scheduling,
                         'notificar'     => $this->notificar,
                         'resultado'     => $this->resultado,
+                        'archivo'       => $this->archivo,
                         'nota'          => $this->nota
                     );
 
@@ -417,6 +446,15 @@ class YATTA_Proceso extends MECON_DBO {
                     DB_AUTOQUERY_UPDATE, 'id = '.$this->id);
             
         }
+
+        if (DB::isError($res)) {
+            return $res;
+        }
+
+        $res = $db->query('
+                UPDATE yatta.servidores
+                SET procesos = procesos + 1
+                WHERE id = '. $this->server);
         return $res;
     }
 
@@ -442,6 +480,7 @@ class YATTA_Proceso extends MECON_DBO {
         $this->scheduling = null;
         $this->notificar = null;
         $this->resultado = null;
+        $this->archivo = null;
         $this->nota = null;
         $this->icono = null;
     }