src/Controller/Api/Banner/V1/CpcClickController.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api\Banner\V1;
  5. use App\Controller\Api\ApiInterface;
  6. use App\Repository\CampaignRepository;
  7. use App\Repository\MediaRepository;
  8. use App\Repository\UserRepository;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use PhpParser\Node\Scalar\String_;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\Cache\Adapter\RedisAdapter;
  13. use Symfony\Component\HttpFoundation\RedirectResponse;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\Messenger\MessageBusInterface;
  16. use Symfony\Component\Routing\Annotation\Route;
  17. use App\Message\CpcClickMessage;
  18. use Symfony\Contracts\Cache\ItemInterface;
  22. class CpcClickController extends AbstractController implements ApiInterface
  23. {
  25.     private $em;
  26.     private $userRepository;
  27.     private $campaignRepository;
  29.     public function __construct(EntityManagerInterface $em,UserRepository $userRepository,CampaignRepository $campaignRepository)
  30.     {
  31.         $this->em = $em;
  32.         $this->userRepository = $userRepository;
  33.         $this->campaignRepository = $campaignRepository;
  34.     }
  36.     /**
  37.      * @param string $uid
  38.      * @param MediaRepository $mediaRepository
  39.      * @param MessageBusInterface $messageBus
  40.      * @param Request $request
  41.      * @return RedirectResponse
  42.      * @Route("api/banner/v1/click/{uid}",name="api.banner.v1.click",methods={"GET"})
  43.      */
  44.     public function index(string $uid,MediaRepository $mediaRepository,MessageBusInterface $messageBus,Request $request):RedirectResponse
  45.     {
  46.         $media = $mediaRepository->findOneBy(['uid'=>$uid]);
  47.         $campaign = $this->campaignRepository->find($media->getCampaign()->getId());
  48.         $cors = ['Access-Control-Allow-Origin'=>'*','Access-Control-Allow-Methods'=>'GET, POST, PATCH, PUT, DELETE, OPTIONS','Access-Control-Allow-Headers'=>'*','X-Robots-Tag'=>'noindex'];
  49.         if(empty($media)){
  50.             return $this->redirect($_ENV['base_aurl']);
  51.         }else{
  52.             /** Media exits */
  53.             if($_ENV['APP_ENV'] == 'prod') {
  54.                 $ip = $request->headers->get('ar-real-ip');
  55.             }else{
  56.                 $ip = str_ireplace($request->getClientIp(), ':', '.');
  57.             }
  58.             $cacheKey = "{$ip}-".$media->getId();
  60.             $cache = new RedisAdapter(
  61.                 RedisAdapter::createConnection('redis://localhost'),
  62.                 'cpc-click',
  63.                 $defaultLifetime = 60
  64.             );
  65.             $cache->get($cacheKey,function (ItemInterface $item) use ($media,$campaign,$messageBus,$request){
  66.                 $item->expiresAfter(1800);
  67.                 $messageBus->dispatch(new CpcClickMessage($media->getId()));
  68.             });
  70.             $utmParams = http_build_query(['utm_source'=> $campaign->getUtmSource(),'utm_medium'=>$campaign->getUtmMedium(),'utm_campaign'=>$campaign->getUtmCampaign()]);
  72.             if (parse_url($media->getUrl(), PHP_URL_QUERY)){
  73.                 return $this->redirect($media->getUrl().'&'.$utmParams);
  74.             }else{
  75.                 return $this->redirect($media->getUrl().'?'.$utmParams);
  76.             }
  77.         }
  79.     }
  82.     /**
  83.      * @param Request $request
  84.      * @Route("api/get-ip",name="get.ip",methods={"GET"})
  85.      */
  86.     public function getIp(Request $request){
  87.         $cors = ['Access-Control-Allow-Origin'=>'*','Access-Control-Allow-Methods'=>'GET, POST, PATCH, PUT, DELETE, OPTIONS','Access-Control-Allow-Headers'=>'*','X-Robots-Tag'=>'noindex'];
  88.         if($_ENV['APP_ENV'] == 'prod') {
  89.             $ip = $request->headers->get('ar-real-ip');
  90.         }else{
  91.             $ip = str_ireplace($request->getClientIp(), ':', '.');
  92.         }
  93.         return $this->json(['ip'=>$ip],200,$cors);
  94.     }
  95. }