src/Controller/Cronjob/Usage/Open/UsageController.php line 21

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Cronjob\Usage\Open;
  5. use App\Entity\VPN\OpenVPN\Server;
  6. use App\Entity\VPN\Service\Service;
  7. use App\Entity\VPN\Service\ServiceUsage;
  8. use App\Repository\VPN\Service\ServiceUsageRepository;
  9. use App\Service\Util\Mikrotik;
  10. use App\Service\Util\NotificationService;
  11. use App\Service\Util\Telegram;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Exception;
  14. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  15. use Symfony\Component\HttpFoundation\JsonResponse;
  16. use Symfony\Component\Routing\Annotation\Route;
  18. class UsageController extends AbstractController
  19. {
  20.     #[Route('/cronjob/open', name: 'app_cronjob_usage_open')]
  21.     public function index(NotificationService $notificationService ,EntityManagerInterface $entityManager, Telegram $telegram , ServiceUsageRepository $serviceUsageRepository): JsonResponse
  22.     {
  23.         $calculationVolume = 1.5;
  24.         try {
  25.             foreach ($entityManager->getRepository(Server::class)->findBy(['active' => 1, 'deletedAt' => null]) as $server) {
  26.                 /**
  27.                  * @var Server $server
  28.                  */
  29.                 $serverContent = null;
  30.                 try {
  31.                     $apiObject = new Mikrotik($server->getUMEndpoint(), $server->getUMUsername(), $server->getUMPassword(), $server->getUMProfileName(), $server->getUMSSHPort());
  32.                     $serverContent = $apiObject->getUsersUsage();
  33.                 } catch (Exception $exception) {
  34.                     $notificationService->exception($exception);
  35.                     $telegram->exception($exception);
  36.                 }
  37.                 if ($serverContent) {
  38.                     foreach ($serverContent['data'] as $item) {
  39.                         $service = $entityManager->getRepository(Service::class)->findOneBy(['clientId' => (int)$item['name']]);
  40.                         if ($service && !$service->getExpireAt() && (((int)$item['total-download']) + ((int)$item['total-upload']))!== 0)
  41.                         {
  42.                             $now = new \DateTimeImmutable();
  43.                             $expiredAt =  $now->add(new \DateInterval("P{$service->getPlan()->getDays()}D"));
  44.                             $service->setExpireAt($expiredAt);
  45.                             $entityManager->flush();
  46.                         }
  47.                         if ($service) {
  48.                             $service->setOpenVpnUsage(
  49.                                 $calculationVolume * (
  50.                                 (((int)$item['total-download']) + ((int)$item['total-upload']))
  51.                                 )
  52.                             );
  53.                             $now = new \DateTime();
  54.                             $todayUsageObject = $serviceUsageRepository->findOneBy(['service' => $service , 'date' => $now]);
  55.                             if (!$todayUsageObject) {
  56.                                 $todayUsageObject = new ServiceUsage();
  57.                                 $todayUsageObject->setService($service);
  58.                                 $todayUsageObject->setDate(new \DateTime());
  59.                                 $entityManager->persist($todayUsageObject);
  60.                             }
  61.                             $yesterday = $now->modify('-1 day');
  62.                             $yesterdayUsageObject = $serviceUsageRepository->findOneBy(['service' => $service , 'date' => $yesterday]);
  63.                             if (!$yesterdayUsageObject) {
  64.                                 $yesterdayUsageObject = new ServiceUsage();
  65.                                 $yesterdayUsageObject->setService($service);
  66.                                 $yesterdayUsageObject->setDate($yesterday);
  67.                                 $entityManager->persist($todayUsageObject);
  68.                                 $entityManager->flush();
  69.                                 $yesterdayUsageWithCalculationVolume = 0;
  70.                             }else{
  71.                                 $yesterdayUsageWithCalculationVolume = $yesterdayUsageObject->getOpenUsage();
  72.                             }
  74.                             $add =  $calculationVolume * (
  75.                                 (((int)$item['total-download']) + ((int)$item['total-upload']))
  76.                                 ) - $yesterdayUsageWithCalculationVolume;
  77.                             $todayUsageObject->setOpenUsage($add);
  78.                             $entityManager->flush();
  79.                         }
  80.                     }
  81.                 }
  82.             }
  83.             $entityManager->clear();
  84.         } catch (Exception $exception) {
  85.             $notificationService->exception($exception);
  86. //            var_dump($exception->getMessage());die;
  87.             $telegram->exception($exception);
  88.         }
  89.         return $this->json(['res' => true]);
  90.     }
  93. }