src/Controller/Cronjob/Telegram/AgentPublicBot/CronjobController.php line 168

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Cronjob\Telegram\AgentPublicBot;
  5. use App\Entity\Generic\User;
  6. use App\Entity\Telegram\AgentPublicBot\Bot;
  7. use App\Entity\Telegram\AgentPublicBot\BotAnalytics;
  8. use App\Entity\Telegram\AgentPublicBot\BotUser;
  9. use App\Repository\Telegram\AgentPublicBot\BotAnalyticsRepository;
  10. use App\Repository\Telegram\AgentPublicBot\BotNotificationRepository;
  11. use App\Repository\Telegram\AgentPublicBot\BotRepository;
  12. use App\Repository\Telegram\AgentPublicBot\BotTransactionRepository;
  13. use App\Repository\Telegram\AgentPublicBot\BotUserRepository;
  14. use App\Repository\VPN\Service\ServiceRepository;
  15. use App\Service\SettingService;
  16. use App\Service\Util\NotificationService;
  17. use App\Service\Util\Telegram;
  18. use DateTime;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use phpDocumentor\Reflection\DocBlock\Tags\Return_;
  21. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  22. use Symfony\Component\HttpFoundation\JsonResponse;
  23. use Symfony\Component\Routing\Annotation\Route;
  25. class CronjobController extends AbstractController
  26. {
  27.     private EntityManagerInterface $entityManager;
  29.     public function __construct(EntityManagerInterface $entityManager)
  30.     {
  31.         $this->entityManager = $entityManager;
  32.     }
  34.     #[Route('/cronjob/telegram/agent-public-bot/cronjob', name: 'app_cronjob_telegram_agent_public_bot_cronjob')]
  35.     public function index(BotRepository $botRepository): JsonResponse
  36.     {
  37.         foreach ($botRepository->findBy([]) as $bot) {
  38.             $array = $this->checkTelegramBotToken($bot->getToken());
  39.             if ($array['res']) {
  40.                 $bot->setDescription($array['data']['result']['first_name']);
  41.                 $bot->setTitle($array['data']['result']['username']);
  42.                 $this->setWebhook($bot);
  43.             } else {
  44.                 $bot->setActive(false);
  45.             }
  46.             $this->getDoctrine()->getManager()->flush();
  47. //            ServicesCount
  48. //            $ocService = (int)count($ocServServiceRepository->findBy(['creatorBot' => $bot , 'active' => 1]));
  49. //            $v2ray = (int)count($v2rayMultiServiceRepository->findBy(['creatorBot' => $bot , 'active' => 1]));
  50. //            $open  = (int)count($openServiceRepository->findBy(['creatorBot' => $bot , 'active' => 1]));
  51. //            $totalService = $ocService + $v2ray +$open;
  52. //            $bot->setBotServices($totalService);
  53. //            $this->getDoctrine()->getManager()->flush();
  55. //            channelMember
  56. //            $count = $this->getChannelMemberCount($bot->getToken() , $bot->getChannelUserNAme());
  57. //            if ($count['res']){
  58. //                $bot->setChannelMembers($count['data']);
  59. //            }else{
  60. //                $bot->setChannelMembers(0);
  61. //            }
  62. //            $this->getDoctrine()->getManager()->flush();
  65.         }
  66.         return $this->json([
  67.             'res' => true
  68.         ]);
  69.     }
  71.     #[Route('/cronjob/telegram/agent-public-bot/cronjob-notifications', name: 'app_cronjob_telegram_agent_public_bot_cronjob_notifications')]
  72.     public function app_cronjob_telegram_agent_public_bot_cronjob_notifications(NotificationService $notificationService,BotNotificationRepository $botNotificationRepository, \App\Repository\Generic\UserRepository $userRepository): JsonResponse
  73.     {
  74.         die;
  75.         foreach ($botNotificationRepository->findBy(['active' => 1, 'isSent' => 0]) as $notification) {
  76.             $bot = $notification->getBot();
  77.             if ($bot->isActive()) {
  78.                 $users = $bot->getBotUsers();
  79.                 foreach ($users as $botUser) {
  80.                     /**
  81.                      * @var BotUser $botUser
  82.                      */
  83.                     try {
  84.                         $this->sendMessage($botUser->getUserId(), $notification->getMessage(), $bot->getToken());
  85.                     } catch (\Exception $exception) {
  86.                         $notificationService->exception($exception);
  87.                         if ($bot->isIsBotForWebsite()) {
  88.                             foreach ($userRepository->getOldExistTelegramUser($botUser->getUserId()) as $panelUser) {
  89.                                 /**
  90.                                  * @var User $panelUser
  91.                                  */
  92.                                 $panelUser->setConnectedTelegramUserId([]);
  93.                             }
  94.                         }
  95.                         $botUser->setActive(0);
  96.                     }
  97.                 }
  98.             }
  99.             $notification->setIsSent(1);
  100.             $this->entityManager->flush();
  101.         }
  104.         return $this->json(['res' => true]);
  105.     }
  108.     #[Route('/cronjob/telegram/agent-public-bot/cronjob-marketing', name: 'app_cronjob_telegram_agent_public_bot_cronjob_marketing')]
  109.     public function app_cronjob_telegram_agent_public_bot_cronjob_marketing(NotificationService $notificationService , BotRepository $botRepository, BotUserRepository $botUserRepository): JsonResponse
  110.     {
  111.         foreach ($botRepository->findBy(['active' => 1, 'sentAutoMessages' => 1]) as $bot) {
  112.             $testMessage = $bot->getAdsNotTestedMessage();
  113.             if ($testMessage) {
  114.                 $users = $botUserRepository->findBy(['bot' => $bot, 'gotTest' => 0]);
  115.                 foreach ($users as $user) {
  116.                     /**
  117.                      * @var BotUser $botUser
  118.                      */
  119.                     try {
  120.                         $this->sendInlineKeyboard($user->getUserId(), $testMessage, $bot->getToken(),
  121.                             [
  122.                                 [
  123.                                     [
  124.                                         "text" => "🎁 دریافت اکانت تست (رایگان)",
  125.                                         "callback_data" => "testService"
  126.                                     ]
  127.                                 ],
  128.                             ]
  129.                         );
  130.                     } catch (\Exception $exception) {
  131.                         $notificationService->exception($exception);
  132.                         $botUser->setActive(0);
  133.                     }
  134.                 }
  135.             }
  136.             $boughtMessage = $bot->getAdsNotBoughtMessage();
  137.             if ($boughtMessage) {
  138.                 $users = $botUserRepository->getNotBoughtUsers($bot);
  139.                 foreach ($users as $user) {
  140.                     /**
  141.                      * @var BotUser $botUser
  142.                      */
  143.                     try {
  144.                         $this->sendInlineKeyboard($user->getUserId(), $testMessage, $bot->getToken(),
  145.                             [
  146.                                 [
  147.                                     [
  148.                                         "text" => "🛒 خرید کانفیگ جدید",
  149.                                         "callback_data" => "buyService"
  150.                                     ]
  151.                                 ],
  152.                             ]
  153.                         );
  154.                     } catch (\Exception $exception) {
  155.                         $notificationService->exception($exception);
  156.                         $botUser->setActive(0);
  157.                     }
  158.                 }
  159.             }
  160.         }
  161.         $this->entityManager->flush();
  162.         return $this->json(['res' => true]);
  163.     }
  167.     #[Route('/cronjob/telegram/agent-public-bot/cronjob-analytics', name: 'app_cronjob_telegram_agent_public_bot_cronjob_analytics')]
  168.     public function app_cronjob_telegram_agent_public_bot_cronjob_analytics(NotificationService $notificationService , ServiceRepository $serviceRepository, BotRepository $botRepository , BotAnalyticsRepository $analyticsRepository , BotTransactionRepository $transactionRepository): JsonResponse
  169.     {
  170.         $haveError = false;
  171.         $now = new DateTime(); // Get the current date
  172.         foreach ($botRepository->findBy(['active' => 1 ]) as $bot) {
  173.             // Loop through the last 30 days
  174.             for ($i = 0; $i <=2; $i++) {
  175.                 // Subtract $i days from today
  176.                 $currentDate = clone $now; // Clone to avoid modifying the original $now
  177.                 $currentDate->modify('-' . $i . ' day'); // Modify the date by subtracting $i days
  178.                 // Check if an analytics record exists for the current date
  179.                 $analyticsObject = $analyticsRepository->findOneBy(['date' => $currentDate , 'bot' => $bot]);
  180.                 if (!$analyticsObject) {
  181.                     $analyticsObject = new BotAnalytics();
  182.                     $analyticsObject->setBot($bot);
  183.                     $analyticsObject->setDate($currentDate);
  184.                 }
  186. //                var_dump($analyticsObject->getId());die;
  187.                 // Get the required data for the current date
  188.                 $increaseValue = $transactionRepository->getIncreaseForDate($currentDate , $bot);
  189.                 $boughtVolume = $transactionRepository->getBoughtVolume($currentDate , $bot);
  190.                 $totalBought = 0;
  191.                 // Set the analytics data for the current date
  192.                 $analyticsObject->setVip($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'vip'));
  193.                 $analyticsObject->setOcServ($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'ocserv'));
  194.                 $analyticsObject->setOcServUnlimited($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'unlimited' , 'ocserv'));
  195.                 $analyticsObject->setV2ray($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'v2ray'));
  196.                 $analyticsObject->setV2rayUnlimited($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'unlimited' , 'v2ray'));
  197.                 $analyticsObject->setOpen($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'open'));
  198.                 $analyticsObject->setOpenUnlimited($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'unlimited' , 'open'));
  199.                 $analyticsObject->setTestService($serviceRepository->getTotalTestForDateCountTelegramBot($currentDate,$bot ));
  200.                 $analyticsObject->setBoughtVolume($boughtVolume);
  201.                 // Calculate total bought volume for the current date
  202.                 $totalBought += $analyticsObject->getVip();
  203.                 $totalBought += $analyticsObject->getV2ray();
  204.                 $totalBought += $analyticsObject->getV2rayUnlimited();
  205.                 $totalBought += $analyticsObject->getOpen();
  206.                 $totalBought += $analyticsObject->getOpenUnlimited();
  207.                 $totalBought += $analyticsObject->getOcServ();
  208.                 $totalBought += $analyticsObject->getOcServUnlimited();
  209.                 $analyticsObject->setBoughtService($totalBought);
  210.                 $analyticsObject->setWalletIncrease($increaseValue);
  211.                 // Persist the analytics data for the current date
  212.                 $this->entityManager->persist($analyticsObject);
  213.                 $analyticsObject->setUpdatedAt(new \DateTime());
  214.             $this->entityManager->flush();
  215.             }
  216.         }
  217.         // Flush all persisted data at once after the loop
  218.         $this->entityManager->flush();
  219.         $this->entityManager->clear(); // Clear to free memory after flush
  220.         return $this->json(['res' => true]);
  221.     }
  227.     public function checkTelegramBotToken($botToken)
  228.     {
  229.         $url = "https://api.telegram.org/bot{$botToken}/getMe";
  230.         $ch = curl_init();
  231.         curl_setopt($ch, CURLOPT_URL, $url);
  232.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  233.         $response = curl_exec($ch);
  234.         curl_close($ch);
  235.         $result = json_decode($response, true);
  236.         if (isset($result['ok']) && $result['ok']) {
  237.             return [
  238.                 'res' => true,
  239.                 'data' => $result
  240.             ];
  241.         } else {
  242.             return [
  243.                 'res' => false,
  244.                 'data' => null
  245.             ];
  246.         }
  247.     }
  249.     public function getChannelMemberCount($botToken, $channelUsername)
  250.     {
  251.         $url = "https://api.telegram.org/bot{$botToken}/getChatMembersCount";
  252.         $params = [
  253.             'chat_id' => '@' . $channelUsername
  254.         ];
  255.         $ch = curl_init();
  257.         curl_setopt($ch, CURLOPT_URL, $url);
  258.         curl_setopt($ch, CURLOPT_POST, 1);
  259.         curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($params));
  260.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  261.         $response = curl_exec($ch);
  262.         curl_close($ch);
  263.         $responseData = json_decode($response, true);
  265.         if (isset($responseData['ok']) && $responseData['ok']) {
  266.             return [
  267.                 'res' => true,
  268.                 'data' => $responseData['result']
  269.             ];
  270.         } else {
  271.             return [
  272.                 'res' => false,
  273.                 'data' => null
  274.             ];
  275.         }
  276.     }
  278.     public function setWebhook(Bot $bot)
  279.     {
  282.         try {
  283.             $webhookUrl = $_ENV['APP_URL'] . '/telegram/agent-public-bot/webhook/' . $bot->getId();
  284.             $webhookUrl = $_ENV['APP_URL'] . '/telegram/agent-public-bot/webhook-neo/' . $bot->getId();
  285. //            $webhookUrl = $_ENV['APP_URL'] . '/telegram/agent-public-bot/webhook-neo/{id}' . $bot->getId();
  286.             $telegramApiUrl = "https://api.telegram.org/bot{$bot->getToken()}/setWebhook";
  287.             $data = [
  288.                 'url' => $webhookUrl,
  289.                 'drop_pending_updates' => 'True',
  290.                 'max_connections' => '100'
  291.             ];
  292.             $ch = curl_init($telegramApiUrl);
  293.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  294.             curl_setopt($ch, CURLOPT_POST, true);
  295.             curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  296.             $response = curl_exec($ch);
  297.             if (curl_errno($ch)) {
  298.                 echo 'cURL error: ' . curl_error($ch);
  299.             } else {
  300.                 $responseData = json_decode($response, true);
  301.                 if ($responseData['ok']) {
  302.                     return true;
  303.                 } else {
  304.                     return false;
  305.                 }
  306.             }
  307.             curl_close($ch);
  308.             return false;
  309.         } catch (\Exception $exception) {
  312. //            $this->bot('sendMessage', [
  313. //                'chat_id' => $this->chatId,
  314. //                'text' =>
  315. //                    $exception->getMessage()
  316. //                ,
  317. ////                'reply_markup' => $mainMenuKeyboard
  318. //            ]);
  319.             return false;
  320.         }
  321.     }
  323.     private function sendMessage(string $chatId, string $text, $token, $markdown = null, bool $silent = false): void
  324.     {
  325.         $url = sprintf(
  326.             'https://api.telegram.org/bot%s/sendMessage',
  327.             $token // Replace with your bot token
  328.         );
  330.         $payload = [
  331.             'chat_id' => $chatId,
  332.             'text' => ($text),
  333.             'disable_notification' => $silent, // Set to true for silent messages
  334.         ];
  336.         if ($markdown) {
  337.             $payload['parse_mode'] = $markdown;
  338.         }
  340.         $this->sendRequest($url, $payload);
  341.     }
  343.     private function sendRequest(string $url, array $payload)
  344.     {
  345.         $ch = curl_init($url);
  347.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  348.         curl_setopt($ch, CURLOPT_POST, true);
  349.         curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
  351.         $response = curl_exec($ch);
  353.         if (curl_errno($ch)) {
  354.             // Log or handle the error
  355.             throw new \Exception('Curl error: ' . curl_error($ch));
  356.         }
  358.         curl_close($ch);
  360.         return $response; // Return the response for further processing
  361.     }
  363.     public function bot($method, $data, $token)
  364.     {
  365.         $setting = new SettingService($this->entityManager);
  366.         $telegramApiUrl = 'https://api.telegram.org/bot' . $token . '/';
  367.         return file_get_contents($telegramApiUrl . $method . '?' . str_replace('&amp;', '&', http_build_query($data)));
  368.     }
  370.     private function sendInlineKeyboard(string $chatId, string $text, $token, array $keyborad, $parseMode = null): void
  371.     {
  372.         $url = sprintf(
  373.             'https://api.telegram.org/bot%s/sendMessage',
  374.             $token
  375.         );
  376.         $payload = [
  377.             'chat_id' => $chatId,
  378.             'text' => ($text),
  379.             'parse_mode' => $parseMode,
  380.             'reply_markup' => json_encode([
  381.                 'inline_keyboard' =>
  382.                     $keyborad,
  383.             ]),
  384.         ];
  385.         if ($parseMode) {
  386.             $payload['parse_mode'] = $parseMode;
  387.         }
  389.         $this->sendRequest($url, $payload);
  390.     }
  392. }