Parametrizar tipo perfiles. No solapar varias instancias de cron

application/controllers/Parser.php

@@ -8,6 +8,7 @@ class Parser extends CI_Controller
     //TODO: PARAMETRIZAR BBDD -> SI EXISTE UN PROCESO EN MARCHA, NO INICIAR SIGUIENTE DESCARGA, AVISAR
     protected $rutaDiaria = FCPATH . "DOWNLOADS/DAILY/";
     protected $rutaDiariaFecha = "";
+
     protected $rutaMensual = FCPATH . "DOWNLOADS/MONTH/";
     protected $enlaceAtom = "";
 
@@ -17,16 +18,43 @@ class Parser extends CI_Controller
         $this->load->helper('file');
         $this->load->helper('xml');
         $this->load->library('parserfile');
+        $this->load->model("Parser_model");
     }
 
     public function index()
     {
-        $fechaCarpeta = date("Y-m-d_H-i-s");
-        if ($this->newFolder($this->rutaDiaria . $fechaCarpeta)) {
-            $this->rutaDiariaFecha = $this->rutaDiaria . $fechaCarpeta . "/";
-            $this->downloadProcess(URL_DIARIA_CONTRATOS_MENORES_PERFILES_CONTRATANES);
-            $this->parserfile->index($this->rutaDiariaFecha, $fechaCarpeta);
+        $existCronRun = $this->Parser_model->existCronRun();
+
+        if ($existCronRun['num_rows'] > 0) {
+            if ($existCronRun['datos']->cron_ejecucion == 0) {
+
+                $this->Parser_model->inicioParser();
+
+                $resultSetPerfiles = $this->Parser_model->getUrlArchivos();
+
+                foreach ($resultSetPerfiles['datos'] as $row) {
+                    $fechaCarpeta = date("Y-m-d_H-i-s");
+                    $rutaPerfil = $this->rutaDiaria . "/" . $row->prefijos_tablas;
+
+                    $this->newFolder($rutaPerfil);
+
+                    if ($this->newFolder($rutaPerfil . "/" . $fechaCarpeta)) {
+                        $this->rutaDiariaFecha = $rutaPerfil . "/" . $fechaCarpeta . "/";
+
+                        $this->downloadProcess($row->url_descarga);
+
+                        $this->parserfile->index($this->rutaDiariaFecha, $fechaCarpeta);
+                    }
+                }
+            } else {
+                echo "EXISTE UN CRON EN MARCHA.";
+            }
+        } else {
+            echo "No existe parametro que iniciar.";
         }
+
+        $this->Parser_model->stopParser();
+
     }
 
     private function downloadProcess($urlXML)
@@ -50,7 +78,7 @@ class Parser extends CI_Controller
         }
     }
 
-    private function getFile($url = URL_DIARIA, $fileName)
+    private function getFile($url, $fileName)
     {
 
         $feed = implode(file($url));

application/libraries/ParserDatabase.php

@@ -55,6 +55,8 @@ class ParserDatabase
                 }
             }
         }
+
+        return;
     }
 
     private function setInicioLicitacion($datosInicioLicitacion): array

application/libraries/ParserFile.php

@@ -71,6 +71,8 @@ class ParserFile
         }
 
         $this->CI->parserdatabase->setDatosParser($resultEntries, $fechaInicioParser);
+
+        return;
     }
 
     private function nodoEntry($xml)

application/models/Parser_model.php

@@ -26,21 +26,49 @@ class Parser_model extends CI_Model
         parent::__construct();
     }
 
-    public function setInicioLicitacion($licitacionArr)
+    public function inicioParser()
     {
-        $this->db->insert('BRUTO_datos_iniciales', $licitacionArr);
-        return $this->db->insert_id();
+        $data = array(
+            'cron_ejecucion' => 1,
+            "fecha_ejecucion" => date("Y-m-d h:i:s"),
+        );
+
+        $this->db->where('id', 0);
+        $this->db->update('parametros_cron', $data);
     }
 
-    public function setLocatedContractInfo($locatedContractArr)
+    public function stopParser()
     {
-        $this->db->insert('BRUTO_located_contracting_party', $locatedContractArr);
-        return $this->db->insert_id();
+        $data = array(
+            'cron_ejecucion' => 0,
+            "fecha_ejecucion" => date("Y-m-d h:i:s"),
+        );
+
+        $this->db->where('id', 0);
+        $this->db->update('parametros_cron', $data);
+    }
+
+    public function existCronRun()
+    {
+        $sql = "SELECT * FROM parametros_cron";
+        $result = $this->db->query($sql);
+        $datos['datos'] = $result->row();
+        $datos['num_rows'] = $result->num_rows();
+        return $datos;
     }
 
-    public function setParty($partyArr)
+    public function getUrlArchivos()
     {
-        $this->db->insert('BRUTO_party', $partyArr);
+        $sql = "SELECT * FROM tipo_licitacion_tablas";
+        $result = $this->db->query($sql);
+        $datos['datos'] = $result->result();
+        $datos['num_rows'] = $result->num_rows();
+        return $datos;
+    }
+
+    public function setInicioLicitacion($licitacionArr)
+    {
+        $this->db->insert('BRUTO_datos_iniciales', $licitacionArr);
         return $this->db->insert_id();
     }