src/Controller/Client/OcServController.php line 37

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\Routing\Annotation\Route;
  23. class OcServController extends AbstractController
  24. {
  25.     public ServerRepository $serversRepository;
  26.     public ServiceRepository $servicesRepository;
  27.     public EntityManagerInterface $entityManager;
  28.     public Telegram $telegram;
  29.     public function __construct(Telegram $telegram, EntityManagerInterface $entityManager, ServerRepository $serversRepository, ServiceRepository $servicesRepository)
  30.     {
  31.         $this->serversRepository = $serversRepository;
  32.         $this->servicesRepository = $servicesRepository;
  33.         $this->entityManager = $entityManager;
  34.         $this->telegram = $telegram;
  35.     }
  36.     #[Route('/client/oc-serv/dc-script/{username}', name: 'app_client_oc_serv_script')]
  37.     public function index($username,NotificationService $notificationService, Telegram $telegram,ServiceUsageRepository $serviceUsageRepository , Request $request, EntityManagerInterface $entityManager): JsonResponse
  38.     {
  39.         try {
  40. //                Request Get
  41. //            {"STATS_BYTES_IN":"12065","STATS_BYTES_OUT":"41501","STATS_DURATION":"59","REASON":"disconnect","I$":""}
  42. //            _SERVER
  43. //            {"USER":"www-data","HOME":"\/var\/www","HTTP_CONTENT_LENGTH":"80","HTTP_CONNECTION":"Keep-Alive","HTTP_CDN_LOOP":"cloudflare; loops=1","HTTP_USER_AGENT":"curl\/7.61.1","HTTP_CF_IPCOUNTRY":"FR","HTTP_CF_VISITOR":"{\"scheme\":\"https\"}","HTTP_ACCEPT":"*\/*","HTTP_CONTENT_TYPE":"application\/x-www-form-urlencoded","HTTP_X_FORWARDED_PROTO":"https","HTTP_ACCEPT_ENCODING":"gzip, br","HTTP_CF_CONNECTING_IP":"188.165.2.99","HTTP_HOST":"beta.tehrannet.org","HTTP_X_FORWARDED_FOR":"188.165.2.99","HTTP_CF_RAY":"92a921d59afb1cb0-AMS","SCRIPT_FILENAME":"\/var\/www\/html\/beta\/public\/index.php","REDIRECT_STATUS":"200","SERVER_NAME":"beta.tehrannet.org","SERVER_PORT":"80","SERVER_ADDR":"188.165.164.83","REMOTE_PORT":"40544","REMOTE_ADDR":"172.70.47.175","SERVER_SOFTWARE":"nginx\/1.18.0","GATEWAY_INTERFACE":"CGI\/1.1","REQUEST_SCHEME":"http","SERVER_PROTOCOL":"HTTP\/1.1","DOCUMENT_ROOT":"\/var\/www\/html\/beta\/public","DOCUMENT_URI":"\/index.php","REQUEST_URI":"\/client\/oc-serv\/dc-script\/hesam","SCRIPT_NAME":"\/index.php","CONTENT_LENGTH":"80","CONTENT_TYPE":"application\/x-www-form-urlencoded","REQUEST_METHOD":"POST","QUERY_STRING":"","FCGI_ROLE":"RESPONDER","PHP_SELF":"\/index.php","REQUEST_TIME_FLOAT":1743689245.082486,"REQUEST_TIME":1743689245,"APP_NAME":"TehranNetVPN","APP_ENV":"prod","APP_SECRET":"e852e3832856bcc5113b10163e6591df","APP_DOMAIN":"https:\/\/www.cheshmak.fun","MAILER_DSN":"gmail+smtp:\/\/tehrannetvpn:iuzaikwvqghktsqo@default","DATABASE_URL":"mysql:\/\/db:mast1391@localhost:3306\/appdev?serverVersion=mariadb-10.4.11","MAILER_ADDRESS":"","DATABASE_USERNAME":"db","DATABASE_PASSWORD":"mast1391","DATABASE_NAME":"app","APP_DOMAIN_V2":"https:\/\/tehrannet.org\/service\/login","APP_DOMAIN_V2UN":"https:\/\/tehrannet.org\/service\/login","APP_DOMAIN_OPEN":"https:\/\/tehrannet.org\/service\/login","APP_DOMAIN_OC":"https:\/\/tehrannet.org\/service\/login","APP_DOMAIN_STATIC":"https:\/\/tehrannet.org\/service\/login","APP_DOMAIN_ROUTER":"https:\/\/tehrannet.org\/service\/login","BOT_USERNAME":"http:\/\/t.me\/tehrannetbot","MAX_CHARGE":"50","APP_DEBUG":"1","SHELL_VERBOSITY":"3","SYMFONY_DOTENV_VARS":"APP_NAME,APP_ENV,APP_SECRET,APP_DOMAIN,MAILER_DSN,DATABASE_URL,MAILER_ADDRESS,DATABASE_USERNAME,DATABASE_PASSWORD,DATABASE_NAME,APP_DOMAIN_V2,APP_DOMAIN_V2UN,APP_DOMAIN_OPEN,APP_DOMAIN_OC,APP_DOMAIN_STATIC,APP_DOMAIN_ROUTER,BOT_USERNAME,MAX_CHARGE,APP_DEBUG,SHELL_VERBOSITY,APP_URL,V2RAY_RANGE,V2RAY_STATIC_RANGE,OC_RANGE,OC_VIP_RANGE,OPEN_RANGE,VIP_RANGE,CLIENTIDRANGE","APP_URL":"https:\/\/tehrannet.org","V2RAY_RANGE":"100000,200000","V2RAY_STATIC_RANGE":"300000000,400000000","OC_RANGE":"500000,600000","OC_VIP_RANGE":"700000,800000","OPEN_RANGE":"900000,1000000","VIP_RANGE":"2000000,3000000","CLIENTIDRANGE":"100000,1000000"}
  44.             $ciscoServerIp = $_SERVER['REMOTE_ADDR'] ?: null;
  45.             $calculationVolume = 1.5;
  46.             $analytics = new ServersAnalyticsUsageService($ciscoServerIp, $entityManager);
  47.             $in = $request->request->get('STATS_BYTES_IN');
  48.             $out = $request->request->get('STATS_BYTES_OUT');
  49.             $totalServerUsage = $in + $out;
  50.             $analytics->addServerUsage($ciscoServerIp, $totalServerUsage);
  51.             $server = $this->serversRepository->findOneBy(['ip' => $ciscoServerIp]);
  52.             /**
  53.              * @var OcServService $ocService
  54.              */
  55.             $clientId = substr($username, 1, -1);
  56.             $service = $this->entityManager->getRepository(Service::class)->findOneBy(['clientId' => $clientId]);
  57.             if ($service) {
  58.                 $in = $request->request->get('STATS_BYTES_IN');
  59.                 $out = $request->request->get('STATS_BYTES_OUT');
  60.                 $newSizeUsed = $out + $in;
  61.                 if (!$service->getExpireAt())
  62.                 {
  63.                     $now = new \DateTimeImmutable();
  64.                     $expiredAt =  $now->add(new \DateInterval("P{$service->getPlan()->getDays()}D"));
  65.                     $service->setExpireAt($expiredAt);
  66.                     $entityManager->flush();
  67.                 }
  68.                 $service->setOcServUsage(
  69.                     (int)$service->getOcServUsage()
  70.                     +
  71.                     (int)((float)$calculationVolume * (int)$newSizeUsed));
  72.                 if ($service->getPlan()->getServiceType() === 'unlimited' && $service->getCountry() !== $server->getCountry()->getCode()){
  73. //                    TODO Remove Service
  74.                 }
  76.                 $now = new \DateTime();
  77.                 $todayUsageObject = $serviceUsageRepository->findOneBy(['service' => $service , 'date' => $now]);
  78.                 if (!$todayUsageObject) {
  79.                     $todayUsageObject = new ServiceUsage();
  80.                     $todayUsageObject->setService($service);
  81.                     $todayUsageObject->setDate(new \DateTime());
  82.                     $entityManager->persist($todayUsageObject);
  83.                 }
  84.                 $todayUsageObject->setOcUsage(
  85.                     $todayUsageObject->getOcUsage() +
  86.                     (int)((float)$calculationVolume * (int)$newSizeUsed)
  87.                 );
  88.                 $this->entityManager->flush();
  89.             }
  90.             $this->entityManager->flush();
  91.             $this->entityManager->clear();
  92.             return $this->json(['res' => true], 200);
  93.         } catch (\Exception $exception) {
  94.             $notificationService->exception($exception);
  95. //            $telegram->exception($exception, 'Error On OcServ Disconnect Usage', $ciscoServerIp ?: null);
  96.         }
  97.         return $this->json(['res' => true]);
  98.     }
  99. }