src/Controller/DefaultController.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Service\{HTTPStatusProd,HTTPStatusDev,GarageStatus,CarStock, CebiaReportTable, OldNewCRM, XmlCheck, FileCheck};
  6. use DateTime;
  7. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Component\HttpFoundation\RedirectResponse;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\Routing\Annotation\Route;
  12. use Symfony\Component\Console\Input\ArrayInput;
  13. use Symfony\Component\Console\Output\BufferedOutput;
  14. use Symfony\Bundle\FrameworkBundle\Console\Application;
  15. use Symfony\Component\HttpKernel\KernelInterface;
  16. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  17. use Symfony\Contracts\Cache\CacheInterface;
  18. use Symfony\Contracts\Cache\ItemInterface;
  20. class DefaultController extends AbstractController
  21. {
  22.     private string $projectDir;
  24.     public function __construct(ParameterBagInterface $params)
  25.     {
  26.         $this->projectDir = $params->get('kernel.project_dir');
  27.     }
  29.     #[Route('/', name: 'default')]
  30.     public function index(): Response
  31.     {
  32.         return $this->render('default/index.html.twig', [
  33.             'oldvsnew' => OldNewCRM::getStatusCode($this->projectDir),
  34.             'xmlcheck' => XmlCheck::getStatusCode($this->projectDir),
  35.             'httpstatusprod' => HTTPStatusProd::getStatusCode($this->projectDir),
  36.             'httpstatusdev' => HTTPStatusDev::getStatusCode($this->projectDir),
  37.             'carstockstatus' => CarStock::getStatusCode($this->projectDir),
  38.             'garagestatus' => GarageStatus::getStatusCode($this->projectDir),
  39.             'filestatus' => FileCheck::getStatusCode($this->projectDir),
  40.             'xmlcheck_message' => XmlCheck::getStatusMessage($this->projectDir),
  41.             'carstockstatus_message' => CarStock::getStatusMessage($this->projectDir),
  42.             'garagestatus_message' => GarageStatus::getStatusMessage($this->projectDir)
  43.         ]);
  44.     }
  46.     #[Route('/file-check', name:'file_check')]
  47.     public function fileCheck(): Response
  48.     {
  49.         $file = $this->getParameter('kernel.project_dir'). '/var/status/file-check.json';
  50.         if(!file_exists($file)) { return $this->redirectToRoute('default'); }
  52.         return $this->render('default/file_check.html.twig', [
  53.             'data' => json_decode(file_get_contents($file), true),
  54.             'last_update' => date('Y-m-d H:i:s', filemtime($file)),
  55.         ]);
  56.     }
  58.     #[Route('/old-vs-new', name: 'old_vs_new')]
  59.     public function oldVsNew(): Response
  60.     {
  61.         $file = $this->getParameter('kernel.project_dir'). '/var/status/1_old_vs_new_crm.json';
  62.         if(!file_exists($file)) { return $this->redirectToRoute('default'); }
  64.         $oldvsnew = json_decode(file_get_contents($file));
  67.         return $this->render('default/old_vs_new.html.twig', [
  68.             'oldvsnew' => $oldvsnew,
  69.             'last_update' => date('Y-m-d H:i:s', filemtime($file)),
  70.         ]);
  71.     }
  73.     #[Route('/xml-monitor', name: 'xml_monitor')]
  74.     public function xmlMonitor(): Response
  75.     {
  76.         $file = $this->getParameter('kernel.project_dir'). '/var/status/2_xml_monitor.html';
  77.         if(!file_exists($file)){ return $this->redirectToRoute('default'); }
  78.         $data = file_get_contents($file);
  80.         return $this->render('default/xml_check.html.twig', [
  81.             'data' => $data,
  82.             'last_update' => date('Y-m-d H:i:s', filemtime($file)),
  83.             'message' => XmlCheck::getStatusMessage($this->projectDir)
  84.         ]);
  85.     }
  87.     #[Route('/xml-monitor-group', name: 'xml_group')]
  88.     public  function xmlGroup(): Response
  89.     {
  90.         $file = $this->getParameter('kernel.project_dir'). '/var/status/2_xml_monitor-group.html';
  91.         if(!file_exists($file)){ return $this->redirectToRoute('default'); }
  92.         $data = file_get_contents($file);
  94.         return $this->render('default/xml_check_group.html.twig', [
  95.             'data' => $data,
  96.             'last_update' => date('Y-m-d H:i:s', filemtime($file))
  97.         ]);
  98.     }
  100.     #[Route('/json-monitor-group', name: 'json_group')]
  101.     public  function jsonGroup(): Response
  102.     {
  103.         $file = $this->getParameter('kernel.project_dir'). '/var/status/2_json_monitor-group.html';
  104.         if(!file_exists($file)){ return $this->redirectToRoute('default'); }
  105.         $data = file_get_contents($file);
  107.         return $this->render('default/json_check_group.html.twig', [
  108.             'data' => $data,
  109.             'last_update' => date('Y-m-d H:i:s', filemtime($file))
  110.         ]);
  111.     }
  113.     #[Route('/json-monitor', name: 'json_monitor')]
  114.     public function jsonMonitor(): Response
  115.     {
  116.         $file = $this->getParameter('kernel.project_dir'). '/var/status/2_json_monitor.html';
  117.         if(!file_exists($file)){ return $this->redirectToRoute('default'); }
  118.         $data = file_get_contents($file);
  120.         return $this->render('default/json_check.html.twig', [
  121.             'data' => $data,
  122.             'last_update' => date('Y-m-d H:i:s', filemtime($file)),
  123.             'message' => null,
  124.         ]);
  125.     }
  127.     #[Route('/http-status/prod', name: 'http_status_prod')]
  128.     public function httpStatusProd(): Response
  129.     {
  130.         $file = $this->getParameter('kernel.project_dir'). '/var/status/http_status_prod.json';
  131.         if(!file_exists($file)){ return $this->redirectToRoute('default'); }
  132.         $jsonData = json_decode(file_get_contents($file), true);
  134.         return $this->render('default/httpstatus_prod.html.twig', [
  135.             'data' => $jsonData,
  136.             'last_update' => date("Y-m-d H:i:s", filemtime($file))
  137.         ]);
  138.     }
  140.     #[Route('/http-status/dev', name: 'http_status_dev')]
  141.     public function httpStatusDev(): Response
  142.     {
  143.         $file = $this->getParameter('kernel.project_dir'). '/var/status/http_status_dev.json';
  144.         if(!file_exists($file)){ return $this->redirectToRoute('default'); }
  145.         $jsonData = json_decode(file_get_contents($file), true);
  147.         return $this->render('default/httpstatus_dev.html.twig', [
  148.             'data' => $jsonData,
  149.             'last_update' => date("Y-m-d H:i:s", filemtime($file))
  150.         ]);
  151.     }
  153.     #[Route('/car-stock', name: 'car_stock')]
  154.     public function carStock(): Response
  155.     {
  156.         $data = $this->getParameter('kernel.project_dir') . '/var/status/car-stock.json';
  157.         $data2 = $this->getParameter('kernel.project_dir') . '/var/status/car-stock-2.json';
  158.         $status = $this->getParameter('kernel.project_dir') . '/var/status/car-stock-status.json';
  160.         if(!file_exists($data) OR !file_exists($status) OR !file_exists($data2)){ return $this->redirectToRoute('default'); }
  162.         return $this->render('default/car_stock.html.twig', [
  163.             'data' => json_decode(file_get_contents($data), true),
  164.             'data2' => json_decode(file_get_contents($data2), true),
  165.             'last_update' => date('Y-m-d H:i:s', filemtime($data)),
  166.             'message' => CarStock::getStatusMessage($this->projectDir)
  167.         ]);
  168.     }
  170.     #[Route('/garage-status', name: 'garage_status')]
  171.     public function garageStatus(): Response
  172.     {
  173.         $data = $this->getParameter('kernel.project_dir') . '/var/status/garage_status_all.json';
  175.         if(!file_exists($data)){ return $this->redirectToRoute('default'); }
  177.         return $this->render('default/garage_status.html.twig', [
  178.             'data' => json_decode(file_get_contents($data), true),
  179.             'last_update' => date('Y-m-d H:i:s', filemtime($data)),
  180.             'message' => GarageStatus::getStatusMessage($this->projectDir)
  181.         ]);
  182.     }
  184.     #[Route('/cebia-report', name: 'cebia_report')]
  185.     public function cerbiaReport(CebiaReportTable $cebiaReportTable, CacheInterface $cache): Response
  186.     {
  187.         /* $data = $this->getParameter('kernel.project_dir') . '/var/status/cebia-report.csv';
  189.         if(!file_exists($data)){ return $this->redirectToRoute('default'); }
  191.         $csvArray = [];
  192.         if(($handle = fopen($data, 'r')) !== false)
  193.         {
  194.             while (($data = fgetcsv($handle)) !== false)
  195.             {
  196.                 if (end($data) === '') {
  197.                     array_pop($data);
  198.                 }
  199.                 $csvArray[] = $data;
  200.             }
  201.             fclose($handle);
  202.         }
  204.         return $this->render('default/cebia_report.html.twig', [
  205.             'data' => $csvArray,
  206.             'last_update' => date('Y-m-d H:i:s', filemtime($data)),
  207.         ]); */
  209.         $htmlTable = $cache->get('cebia_report_table', function (ItemInterface $item) use ($cebiaReportTable) {
  210.             $item->expiresAfter(3600);
  211.             return $cebiaReportTable->execute();
  212.         });
  214.         return $this->render('default/cebia_report.html.twig', [
  215.             'htmlTable' => $htmlTable,
  216.         ]);
  217.     }
  219.     #[Route('/exponea', name: 'app_exponea')]
  220.     public function exponea(): Response
  221.     {
  222.         $dataPath = $this->getParameter('kernel.project_dir') . '/var/status/exponea.json';
  224.         if (!file_exists($dataPath)) { 
  225.             return $this->redirectToRoute('default'); 
  226.         }
  228.         $jsonData = json_decode(file_get_contents($dataPath), true);
  229.         
  230.         return $this->render('default/exponea.html.twig', [
  231.             'data' => $jsonData,
  232.             'last_update' => (new \DateTime())->setTimestamp(filemtime($dataPath))->format('Y-m-d H:i:s'),
  233.         ]);
  234.     }
  236.     #[Route('/api/getLastUpdate/{name}')]
  237.     public function apiGetLastUpdate(string $name): JsonResponse
  238.     {
  239.         $projectDir = $this->getParameter('kernel.project_dir');
  240.         $dataPath = '';
  242.         switch ($name) {
  243.             case 'exponea':
  244.                 $dataPath = $projectDir . '/var/status/exponea.json';
  245.                 break;
  246.             case 'cebia-report':
  247.                 $dataPath = $projectDir . '/var/status/cebia-report.csv';
  248.                 break;
  249.             case 'garage_status_all':
  250.                 $dataPath = $projectDir . '/var/status/garage_status_all.json';
  251.                 break;
  252.             case 'car-stock':
  253.                 $dataPath = $projectDir . '/var/status/car-stock.json';
  254.                 break;
  255.             case 'http_status_dev':
  256.                 $dataPath = $projectDir . '/var/status/http_status_dev.json';
  257.                 break;
  258.             case 'http_status_prod':
  259.                 $dataPath = $projectDir . '/var/status/http_status_prod.json';
  260.                 break;
  261.             case 'xml_monitor':
  262.                 $dataPath = $projectDir . '/var/status/2_xml_monitor.html';
  263.                 break;
  264.             case 'old_vs_new':
  265.                 $dataPath = $projectDir . '/var/status/1_old_vs_new_crm.json';
  266.                 break;
  267.             case 'file_check':
  268.                 $dataPath = $projectDir . '/var/status/file-check.json';
  269.                 break;
  270.             default:
  271.                 return new JsonResponse(['error' => 'invalid name'], 400);
  272.         }
  274.         if (!file_exists($dataPath)) {
  275.             return new JsonResponse(['error' => 'file not found'], 404);
  276.         }
  278.         $lastUpdate = date('Y-m-d H:i:s', filemtime($dataPath));
  279.         return new JsonResponse(['last_update' => $lastUpdate]);
  280.     }
  282.     #[Route('/database-sync', name: 'database_sync')]
  283.     public function databaseSync(): Response
  284.     {
  285.         $filePath = $this->getParameter('kernel.project_dir') . '/var/status/database-sync-stats.json';
  286.         if (!file_exists($filePath)) {
  287.             return $this->redirectToRoute('default');
  288.         }
  290.         $data = json_decode(file_get_contents($filePath), true);
  291.         $lastUpdate = date('Y-m-d H:i:s', filemtime($filePath));
  293.         $brandMapping = [
  294.             1 => 'aaaauto',
  295.             2 => 'mototechna',
  296.             3 => 'auto-diskont'
  297.         ];
  299.         $countryMapping = [
  300.             23 => 'cs',
  301.             81 => 'pl',
  302.             92 => 'sk'
  303.         ];
  305.         $comparisonData = [];
  306.         foreach ($brandMapping as $brandId => $company) {
  307.             foreach ($countryMapping as $countryId => $countryCode) {
  308.                 $comparisonData[] = [
  309.                     'brand_id' => $brandId,
  310.                     'company' => $company,
  311.                     'country_id' => $countryId,
  312.                     'country_code' => $countryCode,
  313.                     'production' => $this->findCount($data['production'], $brandId, $countryId),
  314.                     'resultmatic' => $this->findCount($data['resultmatic'], $brandId, $countryId),
  315.                     'exponea' => $this->findCountExponea($data['exponea'], $company, $countryCode)
  316.                 ];
  317.             }
  318.         }
  320.         return $this->render('default/database_sync.html.twig', [
  321.             'comparison_data' => $comparisonData,
  322.             'last_update' => $lastUpdate,
  323.         ]);
  324.     }
  326.     private function findCount(array $data, int $brandId, int $countryId): ?int
  327.     {
  328.         foreach ($data as $row) {
  329.             if ($row['brand_id'] == $brandId && $row['country_id'] == $countryId) {
  330.                 return (int) $row['count'];
  331.             }
  332.         }
  333.         return null;
  334.     }
  336.     private function findCountExponea(array $data, string $company, string $countryCode): ?int
  337.     {
  338.         foreach ($data as $row) {
  339.             if ($row['company'] == $company && $row['country_code'] == $countryCode) {
  340.                 return (int) $row['count'];
  341.             }
  342.         }
  343.         return null;
  344.     }
  345. }