src/Controller/Client/OcServController.php line 38

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Client;
  5. use App\Entity\VPN\Service\Service;
  6. use App\Entity\VPN\Service\ServiceUsage;
  7. use App\Repository\VPN\OcServ\ServerRepository;
  8. use App\Repository\VPN\Service\ServiceRepository;
  9. use App\Repository\VPN\Service\ServiceUsageRepository;
  10. use App\Service\Util\NotificationService;
  11. use App\Service\Util\OcServSSHApi;
  12. use App\Service\Util\ServersAnalyticsUsageService;
  13. use App\Service\Util\Telegram;
  15. use DateTime;
  16. use DateTimeImmutable;
  17. use Doctrine\ORM\EntityManagerInterface;
  18. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  19. use Symfony\Component\HttpFoundation\JsonResponse;
  20. use Symfony\Component\HttpFoundation\Request;
  21. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  22. use Symfony\Component\Routing\Annotation\Route;
  24. class OcServController extends AbstractController
  25. {
  26.     public ServerRepository $serversRepository;
  27.     public ServiceRepository $servicesRepository;
  28.     public EntityManagerInterface $entityManager;
  29.     public Telegram $telegram;
  30.     public function __construct(Telegram $telegram, EntityManagerInterface $entityManager, ServerRepository $serversRepository, ServiceRepository $servicesRepository)
  31.     {
  32.         $this->serversRepository = $serversRepository;
  33.         $this->servicesRepository = $servicesRepository;
  34.         $this->entityManager = $entityManager;
  35.         $this->telegram = $telegram;
  36.     }
  37.     #[Route('/client/oc-serv/dc-script/{username}', name: 'app_client_oc_serv_script')]
  38.     public function index($username,NotificationService $notificationService, Telegram $telegram,ServiceUsageRepository $serviceUsageRepository , Request $request, EntityManagerInterface $entityManager): JsonResponse
  39.     {
  40.         try {
  41.             $ciscoServerIp = $_SERVER['REMOTE_ADDR'] ?: null;
  42.             $server = $this->serversRepository->findOneBy(['ip' => $ciscoServerIp]);
  43.             if (!$server && $ciscoServerIp!== '20.171.207.48') {
  44. //                $this->telegram->sendRawMessage($ciscoServerIp);
  45.                 return $this->json(['res' => false]  , 403);
  46.             }
  47.             $calculationVolume = 1.5;
  48.             $analytics = new ServersAnalyticsUsageService($ciscoServerIp, $entityManager);
  49.             $in = $request->request->get('STATS_BYTES_IN');
  50.             $out = $request->request->get('STATS_BYTES_OUT');
  51.             $totalServerUsage = $in + $out;
  52.             $analytics->addServerUsage($ciscoServerIp, $totalServerUsage);
  54.             /**
  55.              * @var OcServService $ocService
  56.              */
  57.             $clientId = substr($username, 1, -1);
  58.             $service = $this->entityManager->getRepository(Service::class)->findOneBy(['clientId' => $clientId]);
  59.             if ($service) {
  60.                 $in = $request->request->get('STATS_BYTES_IN');
  61.                 $out = $request->request->get('STATS_BYTES_OUT');
  62.                 $newSizeUsed = $out + $in;
  63.                 if (!$service->getExpireAt())
  64.                 {
  65.                     $now = new \DateTimeImmutable();
  66.                     $expiredAt =  $now->add(new \DateInterval("P{$service->getPlan()->getDays()}D"));
  67.                     $service->setExpireAt($expiredAt);
  68.                     $entityManager->flush();
  69.                 }
  70.                 $service->setOcServUsage(
  71.                     (int)$service->getOcServUsage()
  72.                     +
  73.                     (int)((float)$calculationVolume * (int)$newSizeUsed));
  74.                 if ($service->getPlan()->getServiceType() === 'unlimited' &&
  75.                     $service->getCountry() !==
  76.                     $server->getCountry()->getCode()){
  77. //                    TODO Remove Service
  78.                 }
  80.                 $now = new \DateTime();
  81.                 $todayUsageObject = $serviceUsageRepository->findOneBy(['service' => $service , 'date' => $now]);
  82.                 if (!$todayUsageObject) {
  83.                     $todayUsageObject = new ServiceUsage();
  84.                     $todayUsageObject->setService($service);
  85.                     $todayUsageObject->setDate(new \DateTime());
  86.                     $entityManager->persist($todayUsageObject);
  87.                 }
  88.                 $todayUsageObject->setOcUsage(
  89.                     $todayUsageObject->getOcUsage() +
  90.                     (int)((float)$calculationVolume * (int)$newSizeUsed)
  91.                 );
  92.                 $this->entityManager->flush();
  93.             }
  94.             $this->entityManager->flush();
  95.             $this->entityManager->clear();
  96.             return $this->json(['res' => true], 200);
  97.         } catch (\Exception $exception) {
  98.             $notificationService->exception($exception);
  99. //            $telegram->exception($exception, 'Error On OcServ Disconnect Usage', $ciscoServerIp ?: null);
  100.         }
  101.         return $this->json(['res' => true]);
  102.     }
  103. }