controlador de archivos totales, paquetes 500

application/controllers/ParserCompleto.php

@@ -0,0 +1,198 @@
+<?php
+defined('BASEPATH') or exit('No direct script access allowed');
+
+/**
+ *
+ * Controller ParserCompleto
+ *
+ * This controller for ...
+ *
+ * @package   CodeIgniter
+ * @category  Controller CI
+ * @author    Setiawan Jodi <jodisetiawan@fisip-untirta.ac.id>
+ * @author    Raul Guerrero <r.g.c@me.com>
+ * @link      https://github.com/setdjod/myci-extension/
+ * @param     ...
+ * @return    ...
+ *
+ */
+
+class ParserCompleto 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 = "";
+    protected $fechaCreacionLog = "";
+
+    public function __construct()
+    {
+        parent::__construct();
+        $this->load->helper('file');
+        $this->load->helper('xml');
+        $this->load->library('parserfile');
+
+        $this->load->model("Parser_model");
+    }
+
+    public function index()
+    {
+        $existCronRun = $this->Parser_model->existCronRun();
+        $fechaCarpeta = "";
+        if ($existCronRun['num_rows'] > 0) {
+            if ($existCronRun['datos']->cron_ejecucion == 0) {
+
+                $this->Parser_model->inicioParser();
+
+                $resultSetPerfiles = $this->Parser_model->getUrlArchivos();
+                $fechaCarpeta = date("Y-m-d_H-i-s");
+                $fechaImportacionLog = date("Y-m-d H:i:s");
+
+                foreach ($resultSetPerfiles['datos'] as $row) {
+
+                    $idUltimaImportacion = $this->Parser_model->setFechaNuevaImportacion($fechaImportacionLog);
+                    $this->fechaCreacionLog = $fechaCarpeta;
+                    $rutaPerfil = $this->rutaDiaria . "/" . $row->prefijos_tablas;
+
+                    $this->newFolder($rutaPerfil);
+
+                    if ($this->newFolder($rutaPerfil . "/" . $fechaCarpeta)) {
+                        $this->rutaDiariaFecha = $rutaPerfil . "/" . $fechaCarpeta . "/";
+                        $this->downloadProcess($row->url_descarga . ".atom");
+                    }
+
+                    $files = get_filenames($this->rutaDiariaFecha . "/format");
+                    emailInicioProcesoDescarga($fechaImportacionLog, $files);
+
+                    $this->parserfile->index($this->rutaDiariaFecha, $fechaCarpeta, $row, $idUltimaImportacion);
+                }
+
+                $this->tablasCalculadas($idUltimaImportacion);
+
+                emailFinProcesoDescarga($fechaImportacionLog);
+
+            } else {
+                echo "EXISTE UN CRON EN MARCHA.";
+            }
+        } else {
+            echo "No existe parametro que iniciar.";
+        }
+
+        $this->Parser_model->stopParser();
+
+        /* $resultSetPerfiles = $this->Parser_model->getUrlArchivos();
+    foreach ($resultSetPerfiles['datos'] as $row) {
+    $this->parserfile->index($this->rutaDiaria . "PER_PCSP_EX/2022-02-17_20-38-16", date("Y-m-d"), $row);
+    } */
+    }
+
+    private function downloadProcess($urlXML)
+    {
+
+        $fileName = basename($urlXML);
+        $this->downloadFile($fileName, $urlXML, $this->rutaDiariaFecha);
+        $archivoAtom = $this->getFile($this->rutaDiariaFecha . $fileName, $fileName);
+        $nuevoAtomAttrNext = $this->readNextAttribute($archivoAtom);
+
+        while ($nuevoAtomAttrNext !== "") {
+
+            $fileName = basename($nuevoAtomAttrNext);
+            $this->downloadFile($fileName, $nuevoAtomAttrNext, $this->rutaDiariaFecha);
+            $archivoAtom = $this->getFile($this->rutaDiariaFecha . $fileName, $fileName);
+
+            $nuevoAtomAttrNext = $this->readNextAttribute($archivoAtom);
+        }
+    }
+
+    private function readNextAttribute($archivo)
+    {
+        $enlace = "";
+        foreach ($archivo['link'] as $row) {
+            $attrNext = $row['@attributes']['rel'];
+            $attrHref = $row['@attributes']['href'];
+
+            if ($attrNext === "next") {
+                if (!strpos($attrHref, "licitacionesPerfilesContratanteCompleto3_2021")) { //"20220127_")) {
+                    $enlace = $attrHref;
+                } else {
+                    $enlace = "";
+                }
+                //$enlace = $attrHref;
+            }
+        }
+
+        return $enlace;
+    }
+
+    private function getFile($url, $fileName)
+    {
+
+        $feed = implode(file($url));
+        $xml = simplexml_load_string($feed);
+        $json = json_encode($xml);
+        $array = json_decode($json, true);
+
+        $this->formatXml($feed, $fileName);
+        return $array;
+    }
+
+    private function newFolder($rutaFinal)
+    {
+        $result = false;
+        if (!is_dir($rutaFinal)) {
+            $result = mkdir($rutaFinal);
+            mkdir($rutaFinal . "/format");
+        }
+
+        return $result;
+    }
+
+    private function formatXml($xml, $fileName)
+    {
+        $openingFormat = $this->regExIniciosEsquema($xml);
+        $closureFormat = $this->regExFinalesEsquema($openingFormat);
+        file_put_contents($this->rutaDiariaFecha . "/format/" . $fileName, $closureFormat);
+    }
+
+    private function downloadFile($fileName, $url, $ruta)
+    {
+        if (file_put_contents($ruta . $fileName, file_get_contents($url))) {
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+    private function regExIniciosEsquema($xml)
+    {
+        $pattern = "/(<cac:)|(<cbc:)|(<cac-place-ext:)|(<cbc-place-ext:)/";
+        $result = preg_replace($pattern, "<", $xml);
+
+        return $result;
+    }
+
+    private function regExFinalesEsquema($xml)
+    {
+        $pattern = "/(<\/cac:)|(<\/cbc:)|(<\/cac-place-ext:)|(<\/cbc-place-ext:)/";
+        $result = preg_replace($pattern, "</", $xml);
+
+        return $result;
+    }
+
+    private function tablasCalculadas($idUltimaImportacion)
+    {
+        $this->Parser_model->truncateTables("vista_datos_licitacion");
+
+        $licitaciones = $this->Xlsexport_model->getLicitaciones($idUltimaImportacion);
+
+        insertBucleDuplicateOnKey($licitaciones['datos'], "vista_datos_licitacion", "");
+
+    }
+
+}
+
+/* End of file ParserCompleto.php */
+/* Location: ./application/controllers/ParserCompleto.php */