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

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.         foreach ($botNotificationRepository->findBy(['active' => 1, 'isSent' => 0]) as $notification) {
  75.             $bot = $notification->getBot();
  76.             if ($bot->isActive()) {
  77.                 $users = $bot->getBotUsers();
  78.                 foreach ($users as $botUser) {
  79.                     /**
  80.                      * @var BotUser $botUser
  81.                      */
  82.                     try {
  83.                         $this->sendMessage($botUser->getUserId(), $notification->getMessage(), $bot->getToken());
  84.                     } catch (\Exception $exception) {
  85.                         $notificationService->exception($exception);
  86.                         if ($bot->isIsBotForWebsite()) {
  87.                             foreach ($userRepository->getOldExistTelegramUser($botUser->getUserId()) as $panelUser) {
  88.                                 /**
  89.                                  * @var User $panelUser
  90.                                  */
  91.                                 $panelUser->setConnectedTelegramUserId([]);
  92.                             }
  93.                         }
  94.                         $botUser->setActive(0);
  95.                     }
  96.                 }
  97.             }
  98.             $notification->setIsSent(1);
  99.             $this->entityManager->flush();
  100.         }
  103.         return $this->json(['res' => true]);
  104.     }
  107.     #[Route('/cronjob/telegram/agent-public-bot/cronjob-marketing', name: 'app_cronjob_telegram_agent_public_bot_cronjob_marketing')]
  108.     public function app_cronjob_telegram_agent_public_bot_cronjob_marketing(NotificationService $notificationService , BotRepository $botRepository, BotUserRepository $botUserRepository): JsonResponse
  109.     {
  110.         foreach ($botRepository->findBy(['active' => 1, 'sentAutoMessages' => 1]) as $bot) {
  111.             $testMessage = $bot->getAdsNotTestedMessage();
  112.             if ($testMessage) {
  113.                 $users = $botUserRepository->findBy(['bot' => $bot, 'gotTest' => 0]);
  114.                 foreach ($users as $user) {
  115.                     /**
  116.                      * @var BotUser $botUser
  117.                      */
  118.                     try {
  119.                         $this->sendInlineKeyboard($user->getUserId(), $testMessage, $bot->getToken(),
  120.                             [
  121.                                 [
  122.                                     [
  123.                                         "text" => "🎁 دریافت اکانت تست (رایگان)",
  124.                                         "callback_data" => "testService"
  125.                                     ]
  126.                                 ],
  127.                             ]
  128.                         );
  129.                     } catch (\Exception $exception) {
  130.                         $notificationService->exception($exception);
  131.                         $botUser->setActive(0);
  132.                     }
  133.                 }
  134.             }
  135.             $boughtMessage = $bot->getAdsNotBoughtMessage();
  136.             if ($boughtMessage) {
  137.                 $users = $botUserRepository->getNotBoughtUsers($bot);
  138.                 foreach ($users as $user) {
  139.                     /**
  140.                      * @var BotUser $botUser
  141.                      */
  142.                     try {
  143.                         $this->sendInlineKeyboard($user->getUserId(), $testMessage, $bot->getToken(),
  144.                             [
  145.                                 [
  146.                                     [
  147.                                         "text" => "🛒 خرید کانفیگ جدید",
  148.                                         "callback_data" => "buyService"
  149.                                     ]
  150.                                 ],
  151.                             ]
  152.                         );
  153.                     } catch (\Exception $exception) {
  154.                         $notificationService->exception($exception);
  155.                         $botUser->setActive(0);
  156.                     }
  157.                 }
  158.             }
  159.         }
  160.         $this->entityManager->flush();
  161.         return $this->json(['res' => true]);
  162.     }
  166.     #[Route('/cronjob/telegram/agent-public-bot/cronjob-analytics', name: 'app_cronjob_telegram_agent_public_bot_cronjob_analytics')]
  167.     public function app_cronjob_telegram_agent_public_bot_cronjob_analytics(NotificationService $notificationService , ServiceRepository $serviceRepository, BotRepository $botRepository , BotAnalyticsRepository $analyticsRepository , BotTransactionRepository $transactionRepository): JsonResponse
  168.     {
  169.         $haveError = false;
  170.         $now = new DateTime(); // Get the current date
  171.         foreach ($botRepository->findBy(['active' => 1 ]) as $bot) {
  172.             // Loop through the last 30 days
  173.             for ($i = 0; $i <=2; $i++) {
  174.                 // Subtract $i days from today
  175.                 $currentDate = clone $now; // Clone to avoid modifying the original $now
  176.                 $currentDate->modify('-' . $i . ' day'); // Modify the date by subtracting $i days
  177.                 // Check if an analytics record exists for the current date
  178.                 $analyticsObject = $analyticsRepository->findOneBy(['date' => $currentDate , 'bot' => $bot]);
  179.                 if (!$analyticsObject) {
  180.                     $analyticsObject = new BotAnalytics();
  181.                     $analyticsObject->setBot($bot);
  182.                     $analyticsObject->setDate($currentDate);
  183.                 }
  185. //                var_dump($analyticsObject->getId());die;
  186.                 // Get the required data for the current date
  187.                 $increaseValue = $transactionRepository->getIncreaseForDate($currentDate , $bot);
  188.                 $boughtVolume = $transactionRepository->getBoughtVolume($currentDate , $bot);
  189.                 $totalBought = 0;
  190.                 // Set the analytics data for the current date
  191.                 $analyticsObject->setVip($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'vip'));
  192.                 $analyticsObject->setOcServ($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'ocserv'));
  193.                 $analyticsObject->setOcServUnlimited($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'unlimited' , 'ocserv'));
  194.                 $analyticsObject->setV2ray($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'v2ray'));
  195.                 $analyticsObject->setV2rayUnlimited($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'unlimited' , 'v2ray'));
  196.                 $analyticsObject->setOpen($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'sized' , 'open'));
  197.                 $analyticsObject->setOpenUnlimited($serviceRepository->getTotalSellForDateCountTelegramBot($currentDate,$bot , 'unlimited' , 'open'));
  198.                 $analyticsObject->setTestService($serviceRepository->getTotalTestForDateCountTelegramBot($currentDate,$bot ));
  199.                 $analyticsObject->setBoughtVolume($boughtVolume);
  200.                 // Calculate total bought volume for the current date
  201.                 $totalBought += $analyticsObject->getVip();
  202.                 $totalBought += $analyticsObject->getV2ray();
  203.                 $totalBought += $analyticsObject->getV2rayUnlimited();
  204.                 $totalBought += $analyticsObject->getOpen();
  205.                 $totalBought += $analyticsObject->getOpenUnlimited();
  206.                 $totalBought += $analyticsObject->getOcServ();
  207.                 $totalBought += $analyticsObject->getOcServUnlimited();
  208.                 $analyticsObject->setBoughtService($totalBought);
  209.                 $analyticsObject->setWalletIncrease($increaseValue);
  210.                 // Persist the analytics data for the current date
  211.                 $this->entityManager->persist($analyticsObject);
  212.                 $analyticsObject->setUpdatedAt(new \DateTime());
  213.             $this->entityManager->flush();
  214.             }
  215.         }
  216.         // Flush all persisted data at once after the loop
  217.         $this->entityManager->flush();
  218.         $this->entityManager->clear(); // Clear to free memory after flush
  219.         return $this->json(['res' => true]);
  220.     }
  226.     public function checkTelegramBotToken($botToken)
  227.     {
  228.         $url = "https://api.telegram.org/bot{$botToken}/getMe";
  229.         $ch = curl_init();
  230.         curl_setopt($ch, CURLOPT_URL, $url);
  231.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  232.         $response = curl_exec($ch);
  233.         curl_close($ch);
  234.         $result = json_decode($response, true);
  235.         if (isset($result['ok']) && $result['ok']) {
  236.             return [
  237.                 'res' => true,
  238.                 'data' => $result
  239.             ];
  240.         } else {
  241.             return [
  242.                 'res' => false,
  243.                 'data' => null
  244.             ];
  245.         }
  246.     }
  248.     public function getChannelMemberCount($botToken, $channelUsername)
  249.     {
  250.         $url = "https://api.telegram.org/bot{$botToken}/getChatMembersCount";
  251.         $params = [
  252.             'chat_id' => '@' . $channelUsername
  253.         ];
  254.         $ch = curl_init();
  256.         curl_setopt($ch, CURLOPT_URL, $url);
  257.         curl_setopt($ch, CURLOPT_POST, 1);
  258.         curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($params));
  259.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  260.         $response = curl_exec($ch);
  261.         curl_close($ch);
  262.         $responseData = json_decode($response, true);
  264.         if (isset($responseData['ok']) && $responseData['ok']) {
  265.             return [
  266.                 'res' => true,
  267.                 'data' => $responseData['result']
  268.             ];
  269.         } else {
  270.             return [
  271.                 'res' => false,
  272.                 'data' => null
  273.             ];
  274.         }
  275.     }
  277.     public function setWebhook(Bot $bot)
  278.     {
  281.         try {
  282.             $webhookUrl = $_ENV['APP_URL'] . '/telegram/agent-public-bot/webhook/' . $bot->getId();
  283.             $webhookUrl = $_ENV['APP_URL'] . '/telegram/agent-public-bot/webhook-neo/' . $bot->getId();
  284. //            $webhookUrl = $_ENV['APP_URL'] . '/telegram/agent-public-bot/webhook-neo/{id}' . $bot->getId();
  285.             $telegramApiUrl = "https://api.telegram.org/bot{$bot->getToken()}/setWebhook";
  286.             $data = [
  287.                 'url' => $webhookUrl,
  288.                 'drop_pending_updates' => 'True',
  289.                 'max_connections' => '100'
  290.             ];
  291.             $ch = curl_init($telegramApiUrl);
  292.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  293.             curl_setopt($ch, CURLOPT_POST, true);
  294.             curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  295.             $response = curl_exec($ch);
  296.             if (curl_errno($ch)) {
  297.                 echo 'cURL error: ' . curl_error($ch);
  298.             } else {
  299.                 $responseData = json_decode($response, true);
  300.                 if ($responseData['ok']) {
  301.                     return true;
  302.                 } else {
  303.                     return false;
  304.                 }
  305.             }
  306.             curl_close($ch);
  307.             return false;
  308.         } catch (\Exception $exception) {
  311. //            $this->bot('sendMessage', [
  312. //                'chat_id' => $this->chatId,
  313. //                'text' =>
  314. //                    $exception->getMessage()
  315. //                ,
  316. ////                'reply_markup' => $mainMenuKeyboard
  317. //            ]);
  318.             return false;
  319.         }
  320.     }
  322.     private function sendMessage(string $chatId, string $text, $token, $markdown = null, bool $silent = false): void
  323.     {
  324.         $url = sprintf(
  325.             'https://api.telegram.org/bot%s/sendMessage',
  326.             $token // Replace with your bot token
  327.         );
  329.         $payload = [
  330.             'chat_id' => $chatId,
  331.             'text' => ($text),
  332.             'disable_notification' => $silent, // Set to true for silent messages
  333.         ];
  335.         if ($markdown) {
  336.             $payload['parse_mode'] = $markdown;
  337.         }
  339.         $this->sendRequest($url, $payload);
  340.     }
  342.     private function sendRequest(string $url, array $payload)
  343.     {
  344.         $ch = curl_init($url);
  346.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  347.         curl_setopt($ch, CURLOPT_POST, true);
  348.         curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
  350.         $response = curl_exec($ch);
  352.         if (curl_errno($ch)) {
  353.             // Log or handle the error
  354.             throw new \Exception('Curl error: ' . curl_error($ch));
  355.         }
  357.         curl_close($ch);
  359.         return $response; // Return the response for further processing
  360.     }
  362.     public function bot($method, $data, $token)
  363.     {
  364.         $setting = new SettingService($this->entityManager);
  365.         $telegramApiUrl = 'https://api.telegram.org/bot' . $token . '/';
  366.         return file_get_contents($telegramApiUrl . $method . '?' . str_replace('&amp;', '&', http_build_query($data)));
  367.     }
  369.     private function sendInlineKeyboard(string $chatId, string $text, $token, array $keyborad, $parseMode = null): void
  370.     {
  371.         $url = sprintf(
  372.             'https://api.telegram.org/bot%s/sendMessage',
  373.             $token
  374.         );
  375.         $payload = [
  376.             'chat_id' => $chatId,
  377.             'text' => ($text),
  378.             'parse_mode' => $parseMode,
  379.             'reply_markup' => json_encode([
  380.                 'inline_keyboard' =>
  381.                     $keyborad,
  382.             ]),
  383.         ];
  384.         if ($parseMode) {
  385.             $payload['parse_mode'] = $parseMode;
  386.         }
  388.         $this->sendRequest($url, $payload);
  389.     }
  391. }