src/Service/EventsService.php line 381

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Entity\Adverts;
  6. use App\Entity\Debit;
  7. use App\EntityOtpusk\Events;
  8. use App\Exception\EventsException;
  9. use App\Repository\AgencyRepository;
  10. use App\Repository\BlackListRepository;
  11. use App\Repository\DebitRepository;
  12. use App\Repository\EventsRepository;
  13. use App\Repository\TourRepository;
  14. use App\Repository\AdvertsRepository;
  15. use App\Repository\ManagerLogsRepository;
  16. use App\Service\Ipv6Service;
  17. use ClickHouseDB\Exception\ClickHouseException;
  18. use Doctrine\ORM\EntityManagerInterface;
  19. use Psr\Log\LoggerInterface;
  20. use Symfony\Component\Cache\Adapter\MemcachedAdapter;
  21. use Symfony\Component\HttpClient\HttpClient;
  22. use Symfony\Component\HttpKernel\KernelInterface;
  23. use Symfony\Contracts\HttpClient\HttpClientInterface;
  24. use Symfony\Component\HttpFoundation\RequestStack;
  27. /**
  28.  * Class EventsService
  29.  * @package App\Service
  30.  */
  31. class EventsService
  32. {
  33.     /**
  34.      * @var EntityManagerInterface
  35.      */
  36.     private $em;
  37.     /**
  38.      * @var TourRepository
  39.      */
  40.     private $tourRepository;
  41.     /**
  42.      * @var EventsRepository
  43.      */
  44.     private $eventsRepository;
  45.     /**
  46.      * @var KernelInterface
  47.      */
  48.     private $kernelInterface;
  49.     /**
  50.      * @var DebitRepository
  51.      */
  52.     private $debitRepository;
  53.     /**
  54.      * @var AgencyRepository
  55.      */
  56.     private $agencyRepository;
  57.     /**
  58.      * @var NotificationService
  59.      */
  60.     private $notificationService;
  61.     /**
  62.      * @var ManagerLogsRepository
  63.      */
  64.     private $managerLogsRepository;
  65.     /**
  66.      * @var AdvertsRepository
  67.      */
  68.     private $advertsRepository;
  69.     /**
  70.      * @var HttpClientInterface
  71.      */
  72.     private $client;
  73.     /**
  74.      * @var LoggerInterface
  75.      */
  76.     private $logger;
  77.     /**
  78.      * @var \App\Repository\BlackListRepository
  79.      */
  80.     private BlackListRepository $blackListRepository;
  81.     /**
  82.      * @var RequestStack
  83.      */
  84.     private $requestStack;
  86.     /**
  87.      * EventsService constructor.
  88.      *
  89.      * @param EntityManagerInterface $em
  90.      * @param TourRepository $tourRepository
  91.      * @param EventsRepository $eventsRepository
  92.      * @param BlackListRepository $blackListRepository
  93.      * @param DebitRepository $debitRepository
  94.      * @param AgencyRepository $agencyRepository
  95.      * @param NotificationService $notificationService
  96.      * @param ManagerLogsRepository $managerLogsRepository
  97.      * @param AdvertsRepository $advertsRepository
  98.      * @param KernelInterface $kernelInterface
  99.      * @param LoggerInterface $logger
  100.      * @param HttpClientInterface $client
  101.      * @param Request $request
  102.      */
  103.     public function __construct(
  104.         EntityManagerInterface $em,
  105.         TourRepository $tourRepository,
  106.         EventsRepository $eventsRepository,
  107.         BlackListRepository $blackListRepository,
  108.         DebitRepository $debitRepository,
  109.         AgencyRepository $agencyRepository,
  110.         NotificationService $notificationService,
  111.         ManagerLogsRepository $managerLogsRepository,
  112.         AdvertsRepository $advertsRepository,
  113.         KernelInterface $kernelInterface,
  114.         HttpClientInterface $client,
  115.         LoggerInterface $logger,
  116.         RequestStack $requestStack
  117.     ) {
  118.         $this->em                    = $em;
  119.         $this->tourRepository        = $tourRepository;
  120.         $this->eventsRepository      = $eventsRepository;
  121.         $this->blackListRepository   = $blackListRepository;
  122.         $this->kernelInterface       = $kernelInterface;
  123.         $this->debitRepository       = $debitRepository;
  124.         $this->agencyRepository      = $agencyRepository;
  125.         $this->managerLogsRepository = $managerLogsRepository;
  126.         $this->advertsRepository     = $advertsRepository;
  127.         $this->notificationService   = $notificationService;
  128.         $this->client                = $client;
  129.         $this->logger                = $logger;
  130.         $this->requestStack          = $requestStack;
  131.     }
  133.     public function getEvents(Events $event)
  134.     {
  135.         $this->eventsRepository->_connect();
  136.     }
  138.     public function saveEvent(Events $event, $getEvent=false)
  139.     {
  140.         $tourInfo = $this->tourRepository->getTourInfo(
  141.             $event->getOfferId(),
  142.             $event->getOperatorId(),
  143.             $event->getCruiseId()
  144.         );
  145.         if (isset($_COOKIE['DM'])) {
  146.             header('X-tourInfo: '.json_encode([
  147.                 'offerId' => $tourInfo->getOfferId(),
  148.                 'operatorId' => $tourInfo->getOperatorId(),
  149.                 'countryId' => $tourInfo->getCountryId(),
  150.                 'hotelId' => $tourInfo->getHotelId(),
  151.                 'fromCityId' => $tourInfo->getFromCityId(),
  152.                 'checkIn' => $tourInfo->getCheckIn() ? $tourInfo->getCheckIn()->format('Y-m-d') : null,
  153.                 'nights' => $tourInfo->getNights(),
  154.                 'adult' => $tourInfo->getAdult(),
  155.                 'child' => $tourInfo->getChild(),
  156.                 'food' => $tourInfo->getFood(),
  157.                 'transport' => $tourInfo->getTransport(),
  158.                 'roomId' => $tourInfo->getRoomId(),
  159.                 'price' => $tourInfo->getPrice(),
  160.                 'currency' => $tourInfo->getCurrency(),
  161.             ]));
  162.         }
  163.         if ($tourInfo && $tourInfo->getOfferId()) {
  164.             $event->setOperatorId($tourInfo->getOperatorId());
  165.             $event->setCountryId($tourInfo->getCountryId());
  166.             $event->setHotelId($tourInfo->getHotelId());
  167.             $event->setFromCityId($tourInfo->getFromCityId());
  168.             $event->setCheckIn($tourInfo->getCheckIn());
  169.             $event->setNights($tourInfo->getNights());
  170.             if (empty($tourInfo->getChild())) {
  171.                 $event->setPeople($tourInfo->getAdult());
  172.             } else {
  173.                 if (empty($event->getPeople())) {
  174.                     $child = $tourInfo->getChild();
  175.                     if ($child == 1) {
  176.                         $child = '06';
  177.                     } elseif ($child == 2) {
  178.                         $child = '0608';
  179.                     } elseif ($child == 3) {
  180.                         $child = '060810';
  181.                     } elseif ($child == 4) {
  182.                         $child = '05070911';
  183.                     }
  184.                     $event->setPeople($tourInfo->getAdult().$child);
  185.                 }
  186.             }
  187.             $event->setFood($tourInfo->getFood());
  188.             $event->setTransport($tourInfo->getTransport());
  189.             $event->setRoomId($tourInfo->getRoomId());
  190.             if ($tourInfo->getCurrency() == 'uah') {
  191.                 $priceUah = $tourInfo->getPrice();
  192.             } else {
  193.                 $priceUah = $tourInfo->getPriceUah();
  194.                 if (empty($priceUah)) {
  195.                     $priceUah = $tourInfo->getPrice() * $tourInfo->getCurrencyRate();
  196.                 }
  197.             }
  198.             $event->setPrice($priceUah);
  199.             $event->setCurrency($tourInfo->getCurrency());
  200.         }
  201.         if (empty($event->getHotelId()) && !empty($event->getOfferId())) {
  202.             $httpClient = HttpClient::create();
  203.             $offerId    = $event->getOfferId();
  204.             $response   = $httpClient->request(
  205.                 'GET',
  206.                 'https://api.otpusk.com/api/2.5/tours/offer?offerId='.$offerId.'&access_token=4b26a-e5237-9b0fa-bcc36-67732',
  207.                 ['headers' => ['User-Agent' => 'pro.otpusk.com']]
  208.             );
  209.             if (200 == $response->getStatusCode()) {
  210.                 $offer = $response->toArray();
  211.                 $content = $offer['offer'];
  212.                 if (empty($event->getCountryId()) && isset($content['countryId']))
  213.                     $event->setCountryId($content['countryId']);
  214.                 if (empty($event->getHotelId()) && isset($offer['hotelId']))
  215.                     $event->setHotelId($offer['hotelId']);
  216.                 if (empty($event->getHotelId()) && isset($content['hotelId']))
  217.                     $event->setHotelId($content['hotelId']);
  218.                 if (empty($event->getFromCityId()) && isset($content['fromCity']))
  219.                     $event->setFromCityId($content['fromCity']);
  220.                 if (empty($event->getRoomId()) && isset($content['roomId']))
  221.                     $event->setRoomId($content['roomId']);
  222.                 if (empty($event->getPrice()) && isset($content['priceUah']))
  223.                     $event->setPrice($content['priceUah']);
  224.             }
  225.         }
  226.         $event->setEventPrice(0);
  228.         // Ищем объявление
  229.         $advertsRepository = $this->em->getRepository(Adverts::class);
  230.         /** @var $advertInfo Adverts */
  231.         $advertInfo = $advertsRepository->find($event->getAdvertId());
  233.         $event->setEventPrice(0);
  234.         if ($advertInfo && $advertInfo->getAgency() &&
  235.             $advertInfo->getAgency()->getActive() > 0 &&
  236.             $advertInfo->getAgency()->getStatus() == 'premium')
  237.         {
  238.             $event->setAgencyId($advertInfo->getAgency()->getId());
  239.             $event->setEventPrice($advertInfo->getPrice() ?? 50);
  240.         } else {
  241.             $event->setEventPosition(22);
  242.         }
  243.         /*
  244.         if ($event->getEventPrice() > 0) {
  245.             if (!$tourInfo || !$tourInfo->getOfferId()) {
  246.                 // если не найден offer
  247.                 $event->setEventPrice(0);
  248.                 $event->setEventPosition(24);
  249.             }
  250.         }
  251.         */
  252.         // fixme: нужно как-то проверять относится ли officeId и advertId к одному агентству
  253.         if ($event->getEventPrice() > 0) {
  254.             try {
  255.                 $ip = $this->blackListRepository->getByIp(intval($event->getIp()));
  256.                 if ($ip) {
  257.                     // Ip в черном списке
  258.                     $event->setEventPrice(0);
  259.                     $event->setEventPosition(31);
  260.                 }
  261.             } catch (ClickHouseException $e) {
  262.                 $events = 'error: '.$e->getMessage();
  263.             }
  264.             if (isset($_COOKIE['DM'])) {
  265.                 header('X-31-blacklist: '.$ip);
  266.             }
  267.         }
  268.         if ($event->getEventPrice() > 0) {
  269.             // проверяем был ли уже такое событие сегодня у этого объявления
  270.             $option    = array(
  271.                 \Memcached::OPT_PREFIX_KEY => (getenv('MEMCACHED_PREFIX') ? getenv(
  272.                     'MEMCACHED_PREFIX'
  273.                 ) : ($_ENV['MEMCACHED_PREFIX'] ?? '')),
  274.             );
  275.             $client    = MemcachedAdapter::createConnection(
  276.                 getenv('MEMCACHED_SERV') ? getenv('MEMCACHED_SERV') : $_ENV['MEMCACHED_SERV'],
  277.                 $option
  278.             );
  279.             $cache_key = 'event_'.$event->getEventDate()->format('Ymd').'_'.$event->getAdvertId().'_'.$event->getIp();
  280.             if (isset($_COOKIE['DM'])) {
  281.                 $MEMCACHED_PREFIX = (getenv('MEMCACHED_PREFIX') ? getenv(
  282.                     'MEMCACHED_PREFIX'
  283.                 ) : ($_ENV['MEMCACHED_PREFIX'] ?? ''));
  284.                 $MEMCACHED_SERV   = (getenv('MEMCACHED_SERV') ? getenv('MEMCACHED_SERV') : $_ENV['MEMCACHED_SERV']);
  285.                 $client->set('test_'.$cache_key, time(), 24 * 60 * 60);
  286.                 header(
  287.                     'X-26-memTest: '.$MEMCACHED_SERV.'@'.$MEMCACHED_PREFIX.'&'.$cache_key.'='.$client->get(
  288.                         'test_'.$cache_key
  289.                     )
  290.                 );
  291.             }
  292.             if ($event_time = $client->get($cache_key)) {
  293.                 // уникальное событие, если сегодня уже было
  294.                 $event->setEventPrice(0);
  295.                 $event->setEventPosition(26);
  296.             } else {
  297.                 $client->set($cache_key, time(), time() + (24 * 60 * 60));
  298.             }
  299.         }
  301.         if ($event->getEventPrice() > 0) {
  302.             try {
  303.                 $log = $this->managerLogsRepository->findOneBy(['ip' => $event->getIp()]);
  304.                 if ($log && $log->getIp2Long() == $event->getIp()) {
  305.                     // игнорируем если это IP менеджера любого из агентства
  306.                     $event->setEventPrice(0);
  307.                     $event->setEventPosition(27);
  308.                 }
  309.             } catch (Exception $e) {
  310.             }
  311.             if (isset($_COOKIE['DM'])) {
  312.                 header('X-27-isManager: '.$event->getIp().'='.($log ? $log->getIp2Long() : -1));
  313.             }
  314.         }
  315.         if ($event->getEventPrice() > 0) {
  316.             if ($advertInfo->getDaybudget() > 0) {
  317.                 try {
  318.                     $dayCost = $this->debitRepository->findCostsForCurrentDay($advertInfo->getAgency()->getId());
  319.                     if ($dayCost > 0 && $dayCost >= $advertInfo->getDaybudget()) {
  320.                         // если превысили дневной бюджет
  321.                         $event->setEventPrice(0);
  322.                         $event->setEventPosition(28);
  323.                     }
  324.                 } catch (Exception $e) {
  325.                     $dayCost = 'error: '.$e->getMessage();
  326.                 }
  327.                 if (isset($_COOKIE['DM'])) {
  328.                     header('X-28-dayLimit: '.$dayCost.'>='.$advertInfo->getDaybudget());
  329.                 }
  330.             }
  331.         }
  333.         if ($event->getEventPrice() > 0) {
  334.             try {
  335.                 $events = $this->eventsRepository->getTotalEventsToDayByIp(intval($event->getIp()));
  336.                 if ($events >= 3) {
  337.                     // Не более 3-х платных взаимодействий в сутки с одного IP в не зависимости от объявлений
  338.                     $event->setEventPrice(0);
  339.                     $event->setEventPosition(29);
  340.                 }
  341.             } catch (ClickHouseException $e) {
  342.                 $events = 'error: '.$e->getMessage();
  343.             }
  344.             if (isset($_COOKIE['DM'])) {
  345.                 header('X-29-events: '.$events.'>='. 3);
  346.             }
  347.         }
  348.         // TODO return if didnt help
  349.         /*
  350.         if ($event->getEventPrice() > 0) {
  351.             if (isset($_COOKIE['DM'])) header('X-30-IP: ' . $event->getIp() .' = '. Ipv6Service::long2ip($event->getIp()));
  352.             try {
  353.                 $countryIso = $this->eventsRepository->checkCountryIp($event->getIp());
  354.                 if ($countryIso && $countryIso != 'UA') {
  355.                     //Если ip не из Украины
  356.                     $event->setEventPrice(0);
  357.                     $event->setEventPosition(30);
  358.                 }
  359.             } catch (ClickHouseException $e) {
  360.                 $countryIso = 'error: '.$e->getMessage();
  361.             }
  362.             if (isset($_COOKIE['DM'])) header('X-30-CountryCode: ' . $countryIso);
  363.         }
  364.         */
  365.         try {
  366.             $this->eventsRepository->save($event);
  367.         } catch (ClickHouseException $e) {
  368.             if (isset($_COOKIE['DM'])) {
  369.                 header('X-88-error: '.$e->getMessage());
  370.             }
  371.         }
  372.         if (false !== stripos($getEvent??$event->getEventTypeName(), 'showFormAd')) {
  373.             // для собитий show ціни немає
  374.             $event->setEventPrice(0);
  375.             $event->setEventPosition(32);
  376.         }
  378.         return $event->getEventPrice();
  379.     }
  381.     public function sendGA($clientId=false, $sessionId=false, Events $event, $getEvent=false)
  382.     {
  383.         $APP_ENV = (getenv('APP_ENV') ? getenv('APP_ENV') : $_ENV['APP_ENV']);
  384.         if ($APP_ENV != 'prod') {
  385.             $this->logger->info('Error Send GA env: '.$APP_ENV);
  386.             return false;
  387.         }
  389.         $account_id = (getenv('GA_ACCOUNT') ? getenv('GA_ACCOUNT') : ($_ENV['GA_ACCOUNT'] ?? ''));
  390.         if (isset($_COOKIE['DM'])) {
  391.             header('X-ACCOUNT-ID: '.$account_id);
  392.             header('X-Event-Price: '.$event->getEventPrice());
  393.             header('X-client: '.$clientId);
  394.         }
  396.         if ($event->getEventPrice() <= 0) {
  397.             $this->logger->info('Error Send GA price: '.$event->getEventPrice());
  398.             return false;
  399.         }
  401.         if (empty($account_id)) {
  402.             $this->logger->info('Error Send GA account: '.$account_id);
  403.             return null;
  404.         }
  406.         $trans_id = date('d0m').'0'
  407.                     .sprintf("%u", $event->getIp()).'_'
  408.                     .$event->getAdvertId().'_'
  409.                     .($event->getCruiseId() > 0 ? '' : $event->getCountryId().'_')
  410.                     .$event->getRegionId().'_'
  411.                     .($event->getCruiseId() > 0 ? 'excursion' : 'package');
  412.         if (isset($_COOKIE['DM'])) {
  413.             header('X-TRANS-ID: '.$trans_id);
  414.         }
  416.         if (!empty($clientId)) {
  417.             /*
  418.             // send GA #33394
  419.             $response = $this->client->request(
  420.                 'POST',
  421.                 'http://www.google-analytics.com/collect',
  422.                 [
  423.                     'body' => [
  424.                         'v' => '1', //версия протокола, походу второй нет, только первая
  425.                         'tid' => $account_id, //ид гугл аналитики.
  426.                         'cid' => $clientId, //Client ID – будет отдавать фронт
  428.                         't' => 'transaction', //тип хита в этом случае
  429.                         'ti' => $trans_id, //ид транзакции
  430.                         'tr' => $event->getEventPrice() // сумма транзакции
  431.                     ],
  432.                     'timeout' => 5,
  433.                     'max_duration' => 5,
  434.                     'buffer' => false,
  435.                     'verify_peer' => false,
  436.                     'verify_host' => false,
  437.                     'headers' => [
  438.                         'User-Agent' => 'www.otpusk.com',
  439.                     ],
  440.                 ]
  441.             );
  442.             $this->logger->info('Send GA1 ' . $response->getInfo('url') . ' status: ' . $response->getStatusCode());
  443.             if (isset($_COOKIE['DM'])) {
  444.                 header('X-SEND-GA1: ' . $response->getStatusCode());
  445.             }
  447.             $response = $this->client->request(
  448.                 'POST',
  449.                 'http://www.google-analytics.com/collect',
  450.                 [
  451.                     'body' => [
  452.                         'v' => '1', //версия протокола, походу второй нет, только первая
  453.                         'tid' => $account_id, //ид гугл аналитики.
  454.                         'cid' => $clientId, //Client ID – будет отдавать фронт
  456.                         't' => 'item', //тип хита в этом случае
  457.                         'ti' => $trans_id, //ид транзакции
  458.                         'in' => $event->getAgencyId(), // Название турфирмы
  459.                         'ip' => $event->getPrice(), // стоимость товара
  460.                         'iv' => ($event->getCruiseId() > 0 ? 'Excursion' : 'Package'),
  461.                     ],
  462.                     'timeout' => 5,
  463.                     'max_duration' => 5,
  464.                     'buffer' => false,
  465.                     'verify_peer' => false,
  466.                     'verify_host' => false,
  467.                     'headers' => [
  468.                         'User-Agent' => 'www.otpusk.com',
  469.                     ],
  470.                 ]
  471.             );
  472.             $this->logger->info('Send GA2 ' . $response->getInfo('url') . ' status: ' . $response->getStatusCode());
  473.             if (isset($_COOKIE['DM'])) {
  474.                 header('X-SEND-GA2: ' . $response->getStatusCode());
  475.             }
  476.             */
  478.             $post = [
  479.                 'client_id' => $clientId,
  480.                 'non_personalized_ads' => false,
  481.                 'events' => [
  482.                     [
  483.                         //'name' => 'purchase',
  484.                         'name' => 'api'.ucfirst($getEvent??$event->getEventTypeName()), // 'purchase',
  485.                         //'timestamp_micros' => microtime(true) * 1000000,
  486.                         'params' => [
  487.                             'eventCategory' => 'offerPageAds',
  488.                             'type' => ($event->getCruiseId() > 0 ? 'Excursion' : 'Package'),
  489.                             'value' => (float)$event->getEventPrice(),
  490.                             'lang' => 'UK',
  491.                             'currency' => 'UAH',
  492.                             'client_id' => $clientId,
  493.                             'session_id' => $sessionId,
  494.                             'debug_mode' => true,
  495.                             /*
  496.                             'transaction_id' => $trans_id,
  497.                             //'agency_id' => $event->getAgencyId(),
  498.                             'items' => [
  499.                                 [
  500.                                     'item_id' => (string)($event->getAdvertId() . $event->getRegionId()),
  501.                                     'item_name' => 'id: ' . ((string)$event->getAdvertId() . $event->getRegionId()),
  502.                                     //'item_name' => $event->getEventType(),
  503.                                     'item_category' => ($event->getCruiseId() > 0 ? 'Excursion' : 'Package'),
  504.                                     //'item_brand' => $event->getAgencyId(),
  505.                                     'price' => (float)$event->getEventPrice(),
  506.                                     'currency' => 'UAH',
  507.                                     'quantity' => 1,
  508.                                 ]
  509.                             ],
  510.                             */
  511.                         ]
  512.                     ]
  513.                 ],
  514.                 //'validationBehavior' => 'ENFORCE_RECOMMENDATIONS'
  515.             ];
  516.             $userAgent = 'www.otpusk.com';
  517.             $currentRequest = $this->requestStack->getCurrentRequest();
  518.             if ($currentRequest) {
  519.                 $userAgent = $currentRequest->headers->get('User-Agent', 'www.otpusk.com');
  520.             }
  521.             $headers = [
  522.                 'User-Agent' => $userAgent,
  523.                 'Content-Type' => 'application/json',
  524.                 //'Accept' => 'application/json',
  525.             ];
  526.             $response = $this->client->request(
  527.                 'POST',
  528.                 //'https://www.google-analytics.com/debug/mp/collect?api_secret=' . urlencode('X7iB6sPfTWqTIvOwjwqV7Q') . '&measurement_id=' . urlencode('G-V52QLQJ1C6'),
  529.                 'https://www.google-analytics.com/mp/collect?api_secret=' . urlencode('X7iB6sPfTWqTIvOwjwqV7Q') . '&measurement_id=' . urlencode('G-V52QLQJ1C6'),
  530.                 [
  531.                     'body' => json_encode($post),
  532.                     'timeout' => 5,
  533.                     'max_duration' => 5,
  534.                     'buffer' => false,
  535.                     'verify_peer' => false,
  536.                     'verify_host' => false,
  537.                     'headers' => $headers,
  538.                 ]
  539.             );
  540.             $this->logger->info('Send GA4 ' . $response->getInfo('url') . ' status: ' . $response->getStatusCode());
  541.             if (isset($_COOKIE['DM'])) {
  542.                 header('X-SEND-GA4: ' . $response->getInfo('url') . ' ' . $response->getStatusCode() . ' ' . json_encode($post) . ' ' . json_encode($headers));
  543.             }
  544.         }
  546.         return true;
  547.     }
  549.     public function gelLast($limit = 20)
  550.     {
  551.         return $this->eventsRepository->findAll(10);
  552.     }
  554.     public function updateDebitsByEvents($date = null)
  555.     {
  556.         $startTime = microtime(true);
  557.         $startMemory = memory_get_usage(true);
  558.         
  559.         if ($date) {
  560.             try {
  561.                 $now = new \DateTime($date);
  562.                 $now = $now->format('Y-m-d');
  563.             } catch (\Exception $e) {
  564.                 echo 'Invalid date format. Use YYYY-MM-DD'.PHP_EOL;
  565.                 return;
  566.             }
  567.         } else {
  568.             $now    = new \DateTime('now');
  569.             $now    = $now->format('Y-m-d');
  570.         }
  571.         
  572.         echo PHP_EOL.'========== DEBITS BY EVENTS PROCESSING =========='.PHP_EOL;
  573.         echo 'Start time: '.date('Y-m-d H:i:s').PHP_EOL;
  574.         echo 'Processing date: '.$now.PHP_EOL.PHP_EOL;
  575.         
  576.         $events = $this->eventsRepository->findToDayEvents($now);
  577.         echo '[INFO] Found '.count($events).' events/agencies'.PHP_EOL;
  578.         
  579.         $totalProcessed = 0;
  580.         $totalCreated = 0;
  581.         $totalUpdated = 0;
  582.         $totalErrors = 0;
  583.         $negativeBalanceAgencies = 0;
  584.         
  585.         foreach ($events as $event) {
  586.             $data = false;
  587.             if ($event['agencyId']) {
  588.                 $agency = $this->agencyRepository->findOneBy(['id' => $event['agencyId'], 'status' => 'premium']);
  589.                 if ($agency) {
  590.                     $debit = $this->debitRepository->findByAgencyAndEvent($agency, $now);
  591.                     $isNew = !$debit;
  592.                     
  593.                     if ( ! $debit) {
  594.                         $debit = new Debit();
  595.                         $debit->setAgency($agency);
  596.                         $debit->setDateType(3);
  597.                         $debit->setType('event');
  598.                         $debit->setStatus('paid');
  599.                         $debit->setDate(new \DateTime($now));
  600.                         $debit->setCreatedAt(new \DateTime($now.' 12:00:00'));
  601.                         $totalCreated++;
  602.                     } else {
  603.                         $totalUpdated++;
  604.                     }
  605.                     
  606.                     $debit->setSum($event['eventPrices']);
  607.                     $this->em->persist($debit);
  608.                     $this->em->flush();
  609.                     $totalProcessed++;
  610.                     
  611.                     echo '  [OK] Agency #'.$event['agencyId'].' - Sum: '.$event['eventPrices'].' ('.($isNew ? 'CREATED' : 'UPDATED').')'.PHP_EOL;
  612.                     
  613.                     $data = $this->debitRepository->checkingNegativeBalance($event['agencyId']);
  614.                 } else {
  615.                     $totalErrors++;
  616.                     echo '  [ERROR] Agency #'.$event['agencyId'].' is not premium or not found'.PHP_EOL;
  617.                 }
  618.             }
  619.             
  620.             if ($data) {
  621.                 $negativeBalanceAgencies++;
  622.                 if ($agency && $agency->getStatus() == 'premium') {
  623.                     echo '  [WARNING] Agency #'.$event['agencyId'].' has NEGATIVE BALANCE: '.$data['balance'].PHP_EOL;
  624.                     $handle = curl_init();
  625.                     $url    = 'https://control.otpusk.com/api/setagencynopaid?agencyId='.$event['agencyId'].'&access_token=4b26a-e5237-9b0fa-bcc36-67732';
  626.                     curl_setopt($handle, CURLOPT_USERAGENT, 'pro.otpusk.com');
  627.                     curl_setopt($handle, CURLOPT_SSL_VERIFYHOST, false);
  628.                     curl_setopt($handle, CURLOPT_SSL_VERIFYPEER, false);
  629.                     curl_setopt($handle, CURLOPT_URL, $url);
  630.                     curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
  631.                     curl_setopt($handle, CURLOPT_FAILONERROR, true);
  632.                     $curlResult = curl_exec($handle);
  633.                     $httpCode = curl_getinfo($handle, CURLINFO_HTTP_CODE);
  634.                     echo '    [CURL] HTTP Code: '.$httpCode.PHP_EOL;
  636.                     echo 'http code: '.var_export(curl_getinfo($handle, CURLINFO_HTTP_CODE), 1).PHP_EOL;
  637.                     echo 'agencyId: '.var_export($event['agencyId'], 1).PHP_EOL;
  638.                     echo 'curl error: '.var_export(curl_error($handle), 1).PHP_EOL;
  640.                     curl_close($handle);
  641.                     if ($data['email']) {
  642.                         echo '    [EMAIL] Notification sent to: '.$data['email'].PHP_EOL;
  643.                         $this->notificationService->negativeBalance($data);
  644.                     }
  645.                 }
  646.             }
  647.         }
  648.         
  649.         $endTime = microtime(true);
  650.         $endMemory = memory_get_usage(true);
  651.         $duration = round($endTime - $startTime, 2);
  652.         $memoryUsed = round(($endMemory - $startMemory) / 1024 / 1024, 2);
  653.         
  654.         echo PHP_EOL.'========== PROCESSING SUMMARY =========='.PHP_EOL;
  655.         echo 'Date processed: '.$now.PHP_EOL;
  656.         echo 'Total events found: '.count($events).PHP_EOL;
  657.         echo 'Total debits processed: '.$totalProcessed.PHP_EOL;
  658.         echo '  - Created: '.$totalCreated.PHP_EOL;
  659.         echo '  - Updated: '.$totalUpdated.PHP_EOL;
  660.         echo '  - Errors: '.$totalErrors.PHP_EOL;
  661.         echo 'Agencies with negative balance: '.$negativeBalanceAgencies.PHP_EOL;
  662.         echo 'Execution time: '.$duration.' sec'.PHP_EOL;
  663.         echo 'Memory used: '.$memoryUsed.' MB'.PHP_EOL;
  664.         echo 'End time: '.date('Y-m-d H:i:s').PHP_EOL;
  665.         echo '=========================================='.PHP_EOL.PHP_EOL;
  666.     }
  668.     public function updateDebitsByEventsAgencies($date = null)
  669.     {
  670.         $startTime = microtime(true);
  671.         $startMemory = memory_get_usage(true);
  672.         
  673.         if ($date) {
  674.             try {
  675.                 $now = new \DateTime($date);
  676.                 $now = $now->format('Y-m-d');
  677.             } catch (\Exception $e) {
  678.                 echo 'Invalid date format. Use YYYY-MM-DD'.PHP_EOL;
  679.                 return;
  680.             }
  681.         } else {
  682.             $now      = new \DateTime('now');
  683.             $now      = $now->format('Y-m-d');
  684.         }
  685.         
  686.         echo PHP_EOL.'========== DEBITS BY EVENTS AGENCIES PROCESSING =========='.PHP_EOL;
  687.         echo 'Start time: '.date('Y-m-d H:i:s').PHP_EOL;
  688.         echo 'Processing date: '.$now.PHP_EOL.PHP_EOL;
  689.         
  690.         $agencies = $this->eventsRepository->findAgenciesByEvents();
  691.         $agencies = array_column($agencies, 'agencyId');
  692.         
  693.         echo '[INFO] Found '.count($agencies).' active agencies (last 1 min)'.PHP_EOL;
  694.         
  695.         $totalProcessed = 0;
  696.         $totalCreated = 0;
  697.         $totalUpdated = 0;
  698.         $totalErrors = 0;
  699.         $negativeBalanceAgencies = 0;
  700.         
  701.         if ( ! empty($agencies)) {
  702.             $events = $this->eventsRepository->findToDayEvents($now, $agencies);
  703.             echo '[INFO] Found '.count($events).' events for these agencies'.PHP_EOL.PHP_EOL;
  704.             
  705.             foreach ($events as $event) {
  706.                 $data = false;
  707.                 if ($event['agencyId']) {
  708.                     $agency = $this->agencyRepository->findOneBy(['id' => $event['agencyId'], 'status' => 'premium']);
  709.                     if ($agency) {
  710.                         $debit = $this->debitRepository->findByAgencyAndEvent($agency, $now);
  711.                         $isNew = !$debit;
  712.                         
  713.                         if ( ! $debit) {
  714.                             $debit = new Debit();
  715.                             $debit->setAgency($agency);
  716.                             $debit->setDateType(3);
  717.                             $debit->setType('event');
  718.                             $debit->setStatus('paid');
  719.                             $debit->setDate(new \DateTime($now));
  720.                             $debit->setCreatedAt(new \DateTime($now.' 12:00:00'));
  721.                             $totalCreated++;
  722.                         } else {
  723.                             $totalUpdated++;
  724.                         }
  725.                         
  726.                         $debit->setSum($event['eventPrices']);
  727.                         $this->em->persist($debit);
  728.                         $this->em->flush();
  729.                         $totalProcessed++;
  730.                         
  731.                         echo '  [OK] Agency #'.$event['agencyId'].' - Sum: '.$event['eventPrices'].' ('.($isNew ? 'CREATED' : 'UPDATED').')'.PHP_EOL;
  732.                         
  733.                         $data = $this->debitRepository->checkingNegativeBalance($event['agencyId']);
  734.                     } else {
  735.                         $totalErrors++;
  736.                         echo '  [ERROR] Agency #'.$event['agencyId'].' is not premium or not found'.PHP_EOL;
  737.                     }
  738.                 }
  739.                 
  740.                 if ($data) {
  741.                     $negativeBalanceAgencies++;
  742.                     if ($agency && $agency->getStatus() == 'premium') {
  743.                         echo '  [WARNING] Agency #'.$event['agencyId'].' has NEGATIVE BALANCE: '.$data['balance'].PHP_EOL;
  744.                         $handle = curl_init();
  745.                         $url    = 'https://control.otpusk.com/api/setagencynopaid?agencyId='.$event['agencyId'].'&access_token=4b26a-e5237-9b0fa-bcc36-67732';
  746.                         curl_setopt($handle, CURLOPT_USERAGENT, 'pro.otpusk.com');
  747.                         curl_setopt($handle, CURLOPT_SSL_VERIFYHOST, false);
  748.                         curl_setopt($handle, CURLOPT_SSL_VERIFYPEER, false);
  749.                         curl_setopt($handle, CURLOPT_URL, $url);
  750.                         curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
  751.                         curl_setopt($handle, CURLOPT_FAILONERROR, true);
  752.                         $curlResult = curl_exec($handle);
  753.                         $httpCode = curl_getinfo($handle, CURLINFO_HTTP_CODE);
  754.                         echo '    [CURL] HTTP Code: '.$httpCode.PHP_EOL;
  755.                         
  756.                         curl_close($handle);
  757.                         if ($data['email']) {
  758.                             echo '    [EMAIL] Notification sent to: '.$data['email'].PHP_EOL;
  759.                             $this->notificationService->negativeBalance($data);
  760.                         }
  761.                     }
  762.                 }
  763.             }
  764.         } else {
  765.             echo '[INFO] No active agencies found'.PHP_EOL;
  766.         }
  767.         
  768.         $endTime = microtime(true);
  769.         $endMemory = memory_get_usage(true);
  770.         $duration = round($endTime - $startTime, 2);
  771.         $memoryUsed = round(($endMemory - $startMemory) / 1024 / 1024, 2);
  772.         
  773.         echo PHP_EOL.'========== PROCESSING SUMMARY =========='.PHP_EOL;
  774.         echo 'Date processed: '.$now.PHP_EOL;
  775.         echo 'Active agencies: '.count($agencies).PHP_EOL;
  776.         echo 'Total debits processed: '.$totalProcessed.PHP_EOL;
  777.         echo '  - Created: '.$totalCreated.PHP_EOL;
  778.         echo '  - Updated: '.$totalUpdated.PHP_EOL;
  779.         echo '  - Errors: '.$totalErrors.PHP_EOL;
  780.         echo 'Agencies with negative balance: '.$negativeBalanceAgencies.PHP_EOL;
  781.         echo 'Execution time: '.$duration.' sec'.PHP_EOL;
  782.         echo 'Memory used: '.$memoryUsed.' MB'.PHP_EOL;
  783.         echo 'End time: '.date('Y-m-d H:i:s').PHP_EOL;
  784.         echo '=========================================='.PHP_EOL.PHP_EOL;
  785.     }
  787.     public function fixDebitsByEvents()
  788.     {
  789.         $datesArray = [
  790.             '2021-04-12',
  791.             '2021-04-11',
  792.             '2021-04-10',
  793.             '2021-04-09',
  794.             '2021-04-08',
  795.             '2021-04-07',
  796.             '2021-04-06',
  797.             '2021-04-05',
  798.             '2021-04-04',
  799.             '2021-04-03',
  800.             '2021-04-02',
  801.         ];
  802.         foreach ($datesArray as $now) {
  803.             $events = $this->eventsRepository->findToDayEvents($now);
  804.             foreach ($events as $event) {
  805.                 if ($event['agencyId']) {
  806.                     $agency = $this->agencyRepository->findOneBy(['id' => $event['agencyId']]);
  807.                     if ($agency) {
  808.                         $debit = $this->debitRepository->findByAgencyAndEvent($agency, $now);
  809.                         if ( ! $debit) {
  810.                             $debit = new Debit();
  811.                             $debit->setAgency($agency);
  812.                             $debit->setDateType(3);
  813.                             $debit->setType('event');
  814.                             $debit->setStatus('paid');
  815.                             $debit->setDate(new \DateTime($now));
  816.                         }
  817.                         $debit->setSum($event['eventPrices']);
  818.                         $this->em->persist($debit);
  819.                         $this->em->flush();
  820.                     }
  821.                 }
  822.             }
  823.         }
  824.     }
  826.     public function updateEmptyEvents()
  827.     {
  828.         $events = $this->eventsRepository->findEventsUntillNow('2021-10-19');
  829.         foreach ($events as $event) {
  830.             $httpClient = HttpClient::create();
  831.             $offreId    = $event['offerId'];
  832.             $response   = $httpClient->request(
  833.                 'GET',
  834.                 'https://api.otpusk.com/api/2.5/tours/offer?offerId='.$offreId.'&access_token=4b26a-e5237-9b0fa-bcc36-67732',
  835.                 ['headers' => ['User-Agent' => 'pro.otpusk.com']]
  836.             );
  837.             if (200 == $response->getStatusCode()) {
  838.                 $content = $response->toArray()['offer'];
  839.                 if ($content) {
  840.                     var_dump($event['offerId']);
  841.                     $this->eventsRepository->updateEvent($event, $content);
  842.                     sleep(1);
  843.                 }
  844.             }
  845.         }
  846.     }
  847. }