src/Controller/BaseSite/Cronjobs/DomainCronjobsController.php line 18

Open in your IDE?
  1. <?php
  3. namespace App\Controller\BaseSite\Cronjobs;
  5. use App\Entity\Shop\Log\TrafficLog;
  6. use App\Repository\BaseSite\DomainRepository;
  7. use App\Repository\Shop\Log\TrafficLogRepository;
  8. use App\Repository\Shop\Shop\ShopRepository;
  9. use App\Service\Util\ArvanCDN;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\Routing\Annotation\Route;
  15. class DomainCronjobsController extends AbstractController
  16. {
  17.     #[Route('/base-site/cronjobs/domain/activation', name: 'app_base_site_cronjobs_domain_activation')]
  18.     public function app_base_site_cronjobs_domain_activation(ArvanCDN $arvanCDN, DomainRepository $domainRepository): JsonResponse
  19.     {
  20.         foreach ($arvanCDN->getDomains()['data'] as $datum) {
  21.             $domainObject = $domainRepository->findOneBy(['address' => $datum['domain']]);
  22.             if ($domainObject && $datum['status'] === 'active') {
  23.                 $domainObject->setIsConnected(1);
  24.                 $arvanCDN->setDomainDns($domainObject->getAddress());
  25.                 $arvanCDN->setEdgeServers($domainObject->getAddress());
  26.                 $arvanCDN->activateSSL($domainObject->getAddress());
  27.                 $this->getDoctrine()->getManager()->flush();
  28.             }
  29.         }
  30.         return $this->json(['res' => true]);
  31.     }
  33.     #[Route('/base-site/cronjobs/domain/traffics', name: 'app_base_site_cronjobs_domain_traffics')]
  34.     public function app_base_site_cronjobs_domain_traffics(ArvanCDN $arvanCDN, ShopRepository $shopRepository, EntityManagerInterface $entityManager, TrafficLogRepository $trafficLogRepository): JsonResponse
  35.     {
  36.         $now = new \DateTimeImmutable('now', new \DateTimeZone('Asia/Tehran'));
  37.         $end = $now->setTime((int)$now->format('H'), 0);
  38.         $start = $end->modify('-1 hour');
  39.         foreach ($shopRepository->findAll() as $shopObject) {
  40.             if (!$trafficLogRepository->findOneBy(['shop' => $shopObject, 'startHour' => $start, 'endHour' => $end])) {
  41.                 $log = new TrafficLog();
  42.             } else {
  43.                 $log = $trafficLogRepository->findOneBy(['shop' => $shopObject, 'startHour' => $start, 'endHour' => $end]);
  44.             }
  46.             $log->setShop($shopObject);
  47.             $log->setStartHour($start);
  48.             $log->setEndHour($end);
  49.             $inByte = 0;
  50.             $outByte = 0;
  51.             $totalByte = 0;
  52.             $data = $arvanCDN->collectHourlyTraffic('poooshe.com', $start, $end, $shopObject->getSubdomain());
  53.             if ($data['res']) {
  54.                 $totalByte = $totalByte + ($data['data']['statistics']['traffics']['total']);
  55.             }
  57.             foreach ($shopObject->getDomains() as $domainObject) {
  58.                 $data = $arvanCDN->collectHourlyTraffic($domainObject->getAddress(), $start, $end);
  59.                 if ($data['res']) {
  60.                     $totalByte = $totalByte + ($data['data']['statistics']['traffics']['total']);
  61.                 }
  62.             }
  63. //            $log->setInBytes((string) $data['data']['in']);
  64. //            var_dump($data['data']);die;
  65.             $log->setInBytes(0);
  66. //            $log->setOutBytes((string) $data['data']['out']);
  67.             $log->setOutBytes(0);
  68.             $log->setTotalBytes($totalByte);
  69.             $entityManager->persist($log);
  70.             $entityManager->flush();
  71. //            if ($shopObject->getId() === '1f068c36-03b6-60a4-ab8b-fb2ee65c3086'){
  72. //                var_dump($totalByte);die;
  73. //                var_dump($trafficLogRepository->getTotalByTime($shopObject->getPlanStartedAt() , $shopObject->getExpiredAt() , $shopObject));die;
  74. //            }
  75.             $shopObject->setTrafficUsage($trafficLogRepository->getTotalByTime($shopObject->getPlanStartedAt(), $shopObject->getExpiredAt(), $shopObject));
  76.             $entityManager->flush();
  77.         }
  78.         return $this->json(['res' => true]);
  79.     }
  80. }