src/Controller/MeteoTosaController.php line 72

Open in your IDE?
  1. <?php
  2. namespace App\Controller;
  4. use App\Entity\General;
  5. use App\Entity\Sidebar;
  6. use App\Entity\Sponsors;
  7. use App\Entity\Usuari;
  8. use App\Util\Util;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  11. use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
  12. use Symfony\Component\HttpFoundation\RequestStack;
  13. use Symfony\Component\HttpFoundation\Response;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  16. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  17. use Symfony\Component\Mailer\MailerInterface;
  18. use Symfony\Component\Security\Core\SecurityContext;
  20. use App\Entity\Meteo;
  21. use DoctrineExtensions\Query\Mysql;
  22. use DoctrineExtensions\Query\Mysql\Day;
  23. use Doctrine\ORM\Query;
  24. use Symfony\Component\Validator\Constraints\DateTime;
  25. use Symfony\Contracts\Translation\TranslatorInterface;
  27. class MeteoTosaController extends AbstractController
  28. {
  30.     protected $enSidebar;
  31.     protected $enGeneral;
  32.     protected $enSponsors;
  34.     private $em;
  35.     private $objUtil;
  36.     private $requestStack;
  37.     private $session;
  38.     private $translator;
  39.     private $params;
  40.     private $correuController;
  41.     private $mailer;
  42.     private $sPathUploads;
  44.     public function __construct(EntityManagerInterface $em,RequestStack $requestStack,TranslatorInterface $translator, ContainerBagInterface $params, CorreuController $correuController,MailerInterface $mailer)
  45.     {
  47.         $this->em = $em;
  48.         $this->objUtil = new Util($this->em);
  49.         $this->requestStack = $requestStack;
  50.         $this->session = $this->requestStack->getSession();
  51.         $this->translator = $translator;
  52.         $this->params = $params;
  53.         $this->correuController = $correuController;
  54.         $this->mailer = $mailer;
  55.         $this->sPathUploads = dirname(__FILE__) . "/../../public/uploads/";
  56.         $this->enSidebar = $this->em->getRepository(Sidebar::class)->findBy(
  57.             array(   'general' => 1)
  58.         );
  59.         /////////////////////////
  60.         // Recoger dades generals
  61.         /////////////////////////
  62.         $this->enGeneral = $this->em->getRepository(General::class)->findAll();
  63.         ///////////
  64.         // Sponsors
  65.         ///////////
  66.         $this->enSponsors = $this->em->getRepository(Sponsors::class)->findBy(
  67.             array( 'visible'   => 1),
  68.             array('ordre' => 'ASC')
  69.         );
  70.     }
  72.     public function indexAction(Request $peticion)
  73.     {
  74.         $aRequest = $peticion->request;
  76.         $enMeteo = $this->em->getRepository(Meteo::class)->findAll();
  77.         
  78.         foreach ($enMeteo as $aMeteoPartial)
  79.         {
  80.             $aMeteo[$aMeteoPartial->getCodi()] = $aMeteoPartial; 
  81.             $sHora = ($aMeteoPartial->getDataExtrem() != ''?' ' . $this->translator->trans("a les") . ' ' . $aMeteoPartial->getDataExtrem()->format('H:i') . ' h ':'');
  82.             $aMeteo[$aMeteoPartial->getCodi()] = number_format( $aMeteoPartial->getValor(), $aMeteoPartial->getDecimals(), ",", ".") . ' ' . $aMeteoPartial->getUnitats() . $sHora;
  83.         }
  85.         return $this->render('meteo_tosa.html.twig', array(
  86.             'enSidebar' => $this->enSidebar[0],
  87.             'aMeteo'    => $aMeteo,
  88.             'enGeneral' => $this->enGeneral,
  89.             'enSponsors'=> $this->enSponsors
  90.         ));
  91.     }
  92.     
  93.     public function importarXmlAction(Request $peticion)
  94.     {
  95.         $aRequest = $peticion->request;
  96.         $enMeteoUpdate = new Meteo();
  97.         
  98.         $emConfig = $this->em->getConfiguration();
  99.         $emConfig->addCustomDatetimeFunction('YEAR', 'DoctrineExtensions\Query\Mysql\Year');
  100.         $emConfig->addCustomDatetimeFunction('MONTH', 'DoctrineExtensions\Query\Mysql\Month');
  101.         $emConfig->addCustomDatetimeFunction('DAY', 'DoctrineExtensions\Query\Mysql\Day');
  102.         
  103.         //phpinfo();
  104.         $bTest = false;
  106.         // Default parameters
  107.         $ftp_server = "ftp.meteo.cat";
  108.         $ftp_user_name = "masella";
  109.         $ftp_user_pass = "8utraTrU";
  111.         //$sDir = '/var/www/html/web/meteoXML/';
  112.         switch ($_SERVER['SERVER_NAME'])
  113.         {
  114.             case 'www.masella.com':
  115.             case 'beta.masella.com':
  116.                 $sDir = '/var/www/vhosts/masella.com/httpdocs/public/meteoXML/';
  117.                 break;
  118.             case 'dev22.masella.com':
  119.             case 'dev23.masella.com':
  120.                 $sDir = '/var/www/vhosts/' . $_SERVER['SERVER_NAME'] . '/httpdocs/web/meteoXML/';
  121.                 break;
  122.             case 'sf6.masella.com':
  123.             case 'new.masella.com':
  124.                 $sDir = '/var/www/vhosts/' . $_SERVER['SERVER_NAME'] . '/httpdocs/public/meteoXML/';
  125.                 break;
  126.             case 'masella015.developer.entorno.es':
  127.                 $sDir = '/home/jramon/projects/masella2015/web/meteoXML/';
  128.                 break;
  129.         }
  131.         $sDirTarget = '/Dades/XML/';
  132.         //echo __FILE__.'<br>';
  133.         // definir algunas variables
  134.         $local_file = 'local.zip';
  135.         
  136.         if (!$bTest)
  137.         {
  138.             // Conexión FTP para obtener el ultimo fichero
  139.             $conn_id = ftp_connect($ftp_server);
  140.             $login_result = ftp_login($conn_id, $ftp_user_name, $ftp_user_pass);
  141.             $aDirectori = ftp_nlist($conn_id, $sDirTarget);
  142.             rsort($aDirectori);
  143.             $server_file = $aDirectori[0];
  145.             // intenta descargar $server_file y guardarlo en $local_file
  146.             if (ftp_get($conn_id, $sDir.$local_file, $server_file, FTP_BINARY))
  147.             {
  148.                 //echo "Se ha guardado satisfactoriamente en $local_file\n";
  149.             } else {
  150.                 echo "Ha habido un problema\n";
  151.                 die();
  152.             }
  154.             // Borramos todos los ficheros del ftp excepto el que acabamos de coger
  155.             foreach ($aDirectori as $iKey=>$sFileDelete)
  156.             {
  157.                 if ($iKey==0) continue;
  158.                 ftp_delete($conn_id, $sFileDelete);
  159.             }
  160.             ftp_close($conn_id);
  161.     
  162.             $sShell = "unzip " . $sDir . $local_file . " -d " . $sDir;
  163.             //echo '<br>'.$sShell.'<br>';
  164.             shell_exec($sShell);
  165.             //$aXML = simplexml_load_file($sXmlFile);
  166.             $server_file = basename($server_file);
  167.             $local_fileXML = str_replace(".zip", "", $server_file);
  168.             //echo $sDir.$local_fileXML."<br>";
  169.         } else {
  170.             $sDir = '/home/jramon/projects/masella2015/meteoXML/';
  171.             //$sDir = '/meteoXML/';
  172.             $local_fileXML = "SMC_MES_11023_1823_20141215151100_0.xml";
  173.         }
  175.         $aXML = simplexml_load_file($sDir.$local_fileXML);
  176.         if (!$bTest)
  177.         {
  178.             unlink($sDir.$local_fileXML);
  179.             unlink($sDir.$local_file);
  180.         }
  182.         /*
  183.         echo '<pre>';
  184.         print_r($aXML->estacio);
  185.         echo '</pre>';
  186.         */
  187.         
  188.         $query = $this->em->createQuery('DELETE FROM App:Meteo p WHERE p.data_extrem IS NULL');
  189.         $enMeteo = $query->getResult();
  190.         $dateTime = new DateTime();
  191.         
  192.         foreach ($aXML->estacio->variable as $aXMLData)
  193.         {
  194.             /*
  195.             echo '<pre>';
  196.             print_r($aXMLData);
  197.             echo '</pre>';
  198.             */
  199.             echo 'codi: '.$aXMLData["codi"].'<br>';
  200.             /*
  201.             echo '<pre>';
  202.             print_r($aXMLData);
  203.             echo '</pre>';
  204.             */
  205.             // Agafem l'ultima lectura
  206.             foreach ($aXMLData->lectura as $aXMLLectura)
  207.             {
  208.                 // Agafem l'ultima lectura
  209.                 // només ens interen les últimes dades de l'estructura de Lectura
  210.             }
  212.             if ($aXMLLectura["data_extrem"] != '')
  213.             {
  214.                 $enMeteo = $this->em->getRepository(Meteo::class)->findBy(
  215.                     array(
  216.                         'acronim' => $aXMLData["acronim"]
  217.                     )
  218.                 );
  220.                 foreach ($enMeteo as $aMeteo)
  221.                 {
  222.                     ////////////////////////////////////////////////////////////////
  223.                     // Només updatejem si es diferent dia O el valor nou es superior
  224.                     ////////////////////////////////////////////////////////////////
  225.                     $bUpdate = false;
  226.                     if ($aXMLData["acronim"] == 'HRx'
  227.                         || $aXMLData["acronim"] == 'Tx'
  228.                         || $aXMLData["acronim"] == 'VVx10')
  229.                     {
  230. //                        . " AND (DAY(p.data_extrem) != :day"
  231. //                                . " OR p.valor< :valor)"
  232.                         //echo $aMeteo->getDataExtrem()->format('d') . '!= ' . substr($aXMLLectura["data_extrem"],0,2) . '<br>';
  233.                         if ($aMeteo->getDataExtrem()->format('d') != substr($aXMLLectura["data_extrem"],0,2)
  234.                                 || floatval($aMeteo->getValor()) < floatval($aXMLLectura["valor"]))
  235.                         {
  236.                             //echo '<br> Valor < <br>' . floatval($aMeteo->getValor()) . '<' . floatval($aXMLLectura["valor"]) . '<br>';
  237.                             $bUpdate = true;
  238.                         }
  239.                     } else {
  240. //                                . " AND (DAY(p.data_extrem) != :day"
  241. //                                . " OR p.valor > :valor)"  
  242.                         if ($aMeteo->getDataExtrem()->format('d') != substr($aXMLLectura["data_extrem"],0,2)
  243.                                 || floatval($aMeteo->getValor()) > floatval($aXMLLectura["valor"]))
  244.                         {
  245.                             //echo '<br> Valor > <br>' . floatval($aMeteo->getValor()) . '>' . floatval($aXMLLectura["valor"]) . '<br>';
  246.                             $bUpdate = true;
  247.                         }
  248.                     }
  249.                     
  250.                     if ($bUpdate)
  251.                     {
  252.                         echo '<br> Update<br>';
  253.                         $enMeteoUpdate = $this->em->getRepository(Meteo::class)->find($aMeteo->getId());
  254.                         $enMeteoUpdate->setDataExtrem(\DateTime::createFromFormat('d/m/Y H:i', $aXMLLectura["data_extrem"]));
  255.                         $enMeteoUpdate->setValor($aXMLLectura["valor"]);
  256.                         $this->em->persist($enMeteoUpdate);
  257.                         $this->em->flush();
  258.                         
  259. //                        $sQuery =   "UPDATE App:Meteo p SET "
  260. //                                . " p.data_extrem = :data_extrem"
  261. //                                . ", p.valor= :valor"
  262. //                                . " WHERE p.acronim = :acronim";
  263. //
  264. //                        $query = $this->em->createQuery($sQuery)
  265. //                            ->setParameter('data_extrem', \DateTime::createFromFormat('d/m/Y H:i', $aXMLLectura["data_extrem"]))
  266. //                            ->setParameter('valor', $aXMLLectura["valor"])
  267. //                            ->setParameter('acronim', $aXMLData["acronim"])
  268. //                        ;
  269. //                        $enMeteo = $query->getResult();
  270.                     }
  271.                 }
  272.             } else {
  273.                 $enMeteoInsert = new Meteo();
  275.                 $enMeteoInsert->setCodi($aXMLData["codi"]);
  276.                 $enMeteoInsert->setAcronim($aXMLData["acronim"]);
  277.                 $enMeteoInsert->setNom($aXMLData['nom']);
  278.                 $enMeteoInsert->setTipus($aXMLData['tipus']);
  279.                 $enMeteoInsert->setUnitats($aXMLData['unitats']);
  280.                 $enMeteoInsert->setDecimals($aXMLData['decimals']);
  282.                 //$enMeteoInsert->setData($dateTime->setTimestamp(strtotime(str_replace('/','-',$aXMLLectura["data"]))));
  283.                 $enMeteoInsert->setData(\DateTime::createFromFormat('d/m/Y H:i', $aXMLLectura["data"]));
  284.                 $enMeteoInsert->setValor($aXMLLectura["valor"]);
  285.                 
  286.                 echo '<br>data_extrem2<br>' . $aXMLLectura["data_extrem"] . '<br>';
  287.                 
  288.                 if (isset($aXMLLectura["data_extrem"]))
  289.                 {
  290.                     $enMeteoInsert->setDataExtrem(\DateTime::createFromFormat('d/m/Y H:i', $aXMLLectura["data_extrem"]));
  291.                 }
  292.                 $enMeteoInsert->setEstat($aXMLLectura["estat"]);
  293.                 $enMeteoInsert->setBase($aXMLLectura["base"]);
  294.                 
  295.                 $this->em->persist($enMeteoInsert);
  296.                 $this->em->flush();
  297.             }
  298.         }
  299.         return new Response('ok');
  300.     }
  301. }