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

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