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

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