src/Controller/MassiveNotificationController.php line 397

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. use App\Entity\Menu;
  9. use App\Entity\User;
  10. use App\Entity\UserToken;
  11. use App\Entity\Notification;
  12. use App\Entity\MassiveNotification;
  13. use Symfony\Component\HttpFoundation\JsonResponse;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  17. use App\Service\AppApiService;
  18. use App\Service\FirebaseService;
  19. use App\Service\NotificationService;
  20. use App\Entity\AppPersonalAccount;
  21. use App\Entity\MediaObject;
  22. use App\Entity\AppCounterReading;
  23. use App\Entity\DataReception;
  24. use App\Entity\Accounts;
  25. use App\Entity\ServiceOrderHistory;
  26. use Symfony\Component\HttpKernel\KernelInterface; 
  27. use Psr\Log\LoggerInterface;
  28. use Sentry;
  29. use App\Repository\NotificationRepository;
  31. use App\Message\NotificationMessage;
  32. use Symfony\Component\Messenger\MessageBusInterface;
  33. use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp;
  35. use Symfony\Component\Messenger\Stamp\SentStamp;
  36. use Symfony\Component\Messenger\Exception\TransportExceptionInterface;
  37. use Symfony\Component\Security\Core\Security;
  48. class MassiveNotificationController extends AbstractController
  49. {
  50.     public $datetime;
  51.     public $entityManager;
  52.     public $passwordEncoder;
  53.     public $appApiService;
  54.     public $firebaseService;
  55.     public $notificationService;
  56.     public $notifications;
  57.     private $kernel;
  58.     private LoggerInterface $logger;
  59.     private $bus;
  60.     private Security $security;
  61.     
  63.     public function __construct( 
  64.         ?\DateTimeInterface $datetime, 
  65.         EntityManagerInterface $entityManager, 
  66.         AppApiService $appApiService, 
  67.         KernelInterface $kernel, 
  68.         FirebaseService $firebaseService, 
  69.         NotificationService $notificationService, 
  70.         LoggerInterface $logger,  
  71.         NotificationRepository $notifications,
  72.         MessageBusInterface $bus,
  73.         Security $security
  74.     ){
  75.         $this->datetime = $datetime;
  76.         $this->entityManager = $entityManager;
  77.         $this->appApiService = $appApiService;
  78.         $this->firebaseService = $firebaseService;
  79.         $this->notificationService = $notificationService;
  80.         $this->kernel = $kernel;
  81.         $this->logger = $logger;
  82.         $this->notifications = $notifications;
  83.         $this->bus = $bus;
  84.         $this->security = $security;
  86.     }
  88.     public function valid($requestFilds, $requiredFilds){
  89.         $errors = '';
  90.         foreach($requiredFilds as $f){
  91.             if(!isset($requestFilds[$f]))
  92.                 $errors .= " $f"; 
  93.         }
  95.         return $errors;
  96.     }
  97.     
  98.     private function customAuth($request){
  99.         $validUser = $_ENV['MY_API_USER'];
  100.         $validPassword = $_ENV['MY_API_PASSWORD'];
  102.         $login = $request->server->get('PHP_AUTH_USER');
  103.         $password = $request->server->get('PHP_AUTH_PW');
  104.         if ($login !== $validUser || $password !== $validPassword) {
  105.             return false;
  106.         }
  108.         return true;
  109.     }
  111.     // #[Route('/api/massive/notification-create', name: 'massive_create_notfication', methods: ['POST'])]
  112.     // public function massive_create_notfication(Request $request)
  113.     // {
  114.     //     $user = $this->security->getUser();
  115.     //     $data = json_decode($request->getContent(), true);
  116.     //     // if( $this->)
  118.     //     echo '<pre>'; print_r($data);
  120.     //     $massiveNotification = new \App\Entity\MassiveNotification();
  121.     //     $massiveNotification->setName('Масове сповіщення '.date('Y-m-d H:i:s'));
  122.     //     $massiveNotification->setTitle($data['title']);
  123.     //     $massiveNotification->setBody($data['body']);
  124.     //     $massiveNotification->setType('i'));
  125.     //     echo 'ok'; die;
  126.     // }
  127.     
  128.     private function searchIdByToken( $targetToken, $data) {
  129.         $foundId = null; 
  130.         foreach ($data as $id => $tokens) {          // $data = твій великий Array
  131.             if (!is_array($tokens)) continue;
  133.             if (in_array($targetToken, $tokens, true)) { // true = строгe порівняння
  134.                 $foundId = $id;
  135.                 break;
  136.             }
  137.         }
  138.         return $foundId;
  139.     }
  142.     #[Route('/api/send-notfication-masive', name: 'send_notfication_masive', methods: ['GET'])]
  143.     public function send_notfication_masive(Request $request)
  144.     {
  146.         $send = 0;
  147.         $err = 0;
  148.         
  149.         /** Масовані розсилки розділені ns_msg_id, бо в них однакові тексти, тому шукаю перший ліпший і потім всі інші по ns_msg_id  */
  150.         $MassiveNotification = $this->entityManager->getRepository(MassiveNotification::class)->findOneBy(['status' => 'new']);
  151.         // $firstNotification = $this->entityManager->getRepository(Notification::class)->findOneBy(['status' => 'new_all', 'allUsers' => true, 'massiveNotification' => $MassiveNotification]);
  152.         if($MassiveNotification){
  153.             file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  $MassiveNotification->getId() . " NOTIFICATIONS Massive ************************" .  date('H:i:s') . "\n", FILE_APPEND);
  154.             $notifications = $this->entityManager->getRepository(Notification::class)->findBy(['status' => 'new_all', 'massiveNotification' => $MassiveNotification]);
  155.             
  156.             if(count($notifications) == 0){
  157.                 file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  $MassiveNotification->getId() .  date('H:i:s') . "Немає нових сповіщень для розсилки\n", FILE_APPEND);
  158.                 $MassiveNotification->setStatus('error');
  159.                 $MassiveNotification->setDescription('Немає нових сповіщень для розсилки');
  160.                 $this->entityManager->persist($MassiveNotification);
  161.                 $this->entityManager->flush();
  162.                 $response = new JsonResponse();
  163.                 $response->setData(['send' => 0, 'err' => 0, 'error' => 'Немає нових сповіщень для розсилки']); 
  164.                 return $response; 
  165.             }
  167.             file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Кількість сповіщень: " . count($notifications) . "\n", FILE_APPEND);
  170.             // echo count($notifications);
  171.             // die;
  172.             $unikTokensNotificationsId = [];
  173.             $unikTokens = [];
  174.                 if($notifications){
  175.                     // Витягуємо всі ID
  176.                         $notificationIds = array_map(fn($n) => $n->getId(), $notifications);
  178.                         // Масове оновлення статусу та дати
  179.                         $this->entityManager->createQuery(
  180.                             'UPDATE App\Entity\Notification n
  181.                             SET n.status = :newStatus, 
  182.                                 n.dateSend = :now 
  183.                             WHERE n.id IN (:ids)'
  184.                         )
  185.                         ->setParameter('newStatus', 'in_progress')
  186.                         ->setParameter('now', new \DateTime())
  187.                         ->setParameter('ids', $notificationIds)
  188.                         ->execute();
  189.                     file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Поставили статус in_progress: " . count($notificationIds) . "\n", FILE_APPEND);
  190.                     /** Шукаю ключі  Fcm */
  191.                     foreach($notifications as $notification){
  192.                         $send = 0;
  193.                         $user = $notification->getUsers();
  194.                         // $tokensArr = [];
  195.                         if($user){
  196.                             $device_id = $user->getDeviceId();
  197.                             $tokens = $this->entityManager->getRepository(UserToken::class)->findBy(['users' => $user, 'active' => true]);
  199.                             if(empty($tokens)){
  200.                                 $notification->setStatus('not_token');
  201.                                 $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . "Не вказані токени користувача");
  202.                                 $this->entityManager->persist($notification);
  203.                                 continue;
  205.                             }
  207.                             $search_dublicate_tokens = [];
  208.                             foreach($tokens as $token){
  209.                                 if(empty($token->getTokenFcm())){
  210.                                     $token->setActive(false);
  211.                                     $this->entityManager->persist($token);
  212.                                     continue;
  213.                                 }
  215.                                 $unikTokensNotificationsId[$notification->getId()][]= $token->getTokenFcm();
  216.                                 $unikTokens[]= $token->getTokenFcm();
  218.                                 // file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',  "st - " .  date('H:i:s') . "\n", FILE_APPEND);
  219.                             }
  220.                         }else{
  221.                             $notification->setStatus('error');
  222.                             $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . "Користувач не знайдений");
  223.                             $this->entityManager->persist($notification);
  224.                             continue;
  225.                         }
  227.                             
  228.                     }
  229.                     $this->entityManager->flush();
  230.                 }else{
  231.                     $rez = ['rez' => false, 'error' => "Незнайдено нових сповіщень!"];
  232.                 }
  233.                 
  234.             
  235.             /** Беру тільки унікальні ключі */
  236.             $unikTokens =  array_unique($unikTokens) ;
  237.             
  238.             if(count($unikTokens) > 0){
  239.                 file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Унікальних токенів для розсилки: " . count($unikTokens) . "\n", FILE_APPEND);
  240.                 /** Розділяю по чергах 450 бо там ліміт 500*/
  241.                 $chunks = array_chunk($unikTokens, 450);
  242.            
  243.                 /** йду почергах */
  244.                 foreach($chunks as $key => $chunkToken){
  245.                     file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Обробка черги номер: " . ($key + 1) . "\n", FILE_APPEND);
  246.                     $resultJson = $this->firebaseService->massiveTokensSendCurl([
  247.                         'tokens' => $chunkToken,
  248.                         'title' => $MassiveNotification->getTitle(),
  249.                         'body' => $MassiveNotification->getBody(),
  250.                         'type' => 'text',
  251.                     ]);
  252.                 
  253.                     // file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Результат розсилки: " . $resultJson . "\n", FILE_APPEND);
  255.                     $results = json_decode($resultJson, true);
  256.                     /** Обробка результатів */
  257.                     $errorsIds = [];
  258.                     $successIds = [];
  259.                         foreach($results['Responses'] as $i => $res){
  260.                             /** Шукаю id всіх відправлених і дані всіх не відправлених */
  261.                             if(!$res['Success']){
  262.                                 $t = $chunkToken[$i];
  263.                                 $idN = $this->searchIdByToken($t, $unikTokensNotificationsId);
  264.                                 $errorsIds[] = $idN;
  265.                                 $errors[$idN] = [
  266.                                     'id_notification' => $idN,
  267.                                     'token' => $t,
  268.                                     'error' => $res['Error']
  269.                                 ];
  270.                             }else{
  271.                                 $t = $chunkToken[$i];
  272.                                 $idN = $this->searchIdByToken($t, $unikTokensNotificationsId);
  273.                                 $successIds[] = $idN;
  274.                             }
  275.                         }
  276.                         if(count($successIds) > 0){
  277.                             /** Оновлю всі відправленні */
  278.                         
  279.                            // Масове оновлення статусу та дати
  280.                             $this->entityManager->createQuery(
  281.                                 'UPDATE App\Entity\Notification n
  282.                                 SET n.status = :newStatus
  283.                                 WHERE n.id IN (:ids)'
  284.                             )
  285.                             ->setParameter('newStatus', 'send')
  286.                             ->setParameter('ids', $successIds)
  287.                             ->execute();
  289.                         }
  290.                         if(count($errorsIds) > 0){
  291.                             /** Обробляю всі з помилками */
  292.                             foreach($notifications as $notification){
  293.                                 if(in_array($notification->getId(), $errorsIds)){
  294.                                     $notification->setStatus('error');
  295.                                     $errorInfo = $errors[$notification->getId()];
  296.                                     $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . $errorInfo['token'] . "\n" . $errorInfo['error']);
  297.                                     $this->entityManager->persist($notification);
  298.                                 }
  299.                             }
  300.                             $this->entityManager->flush();
  302.                         }
  304.                         file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Черга номер: " . ($key + 1) . " Відправлено: " . count($successIds) . " Помилок: " . count($errorsIds) . "\n", FILE_APPEND);
  306.                 }
  307.                 /** Оновлюю статус масового сповіщення */
  308.                 $MassiveNotification->setStatus('send');
  309.                 $MassiveNotification->setDescription('Розсилка завершена. Відправлено ' . count($successIds) . ' сповіщень, з помилками ' . count($errorsIds));
  310.                 $this->entityManager->persist($MassiveNotification);
  311.                 $this->entityManager->flush();
  312.                 file_put_contents('/var/www/symfony_docker/var/log/MassiveNotification.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Розсилка завершена. Відправлено: " . count($successIds) . " Помилок: " . count($errorsIds) . "\n", FILE_APPEND);
  313.             }else{
  314.                 $MassiveNotification->setStatus('error');
  315.                 $MassiveNotification->setDescription('Немає токенів для розсилки');
  316.                 $this->entityManager->persist($MassiveNotification);
  317.                 $this->entityManager->flush();
  318.             }
  321.          
  322.             $response = new JsonResponse();
  323.             $response->setData(['send' => count($successIds), 'err' => count($errorsIds)]);
  324.             file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',  "***********END*************" .  date('H:i:s') . "\n", FILE_APPEND);
  325.             return $response;
  326.         }else{
  327.             $response = new JsonResponse();
  328.             $response->setData(['send' => 0, 'err' => 0, 'error' => 'Нема масових сповіщень']);
  329.             return $response;
  330.         }
  331.     }
  333.     /**
  334.      * шукаю сповіщення які зависли в in_progress
  335.      */
  337.     #[Route('/api/check-notfication-masive', name: 'check_notfication_masive', methods: ['GET'])]
  338.     public function check_notfication_masive(Request $request)
  339.     {
  340.         $now = new \DateTime();
  341.         $interval = new \DateInterval('PT5M'); // 5 хвилин
  342.         $thresholdTime = (clone $now)->sub($interval);
  344.         /** шукаю масове сповіщення яке в процесі */
  345.         $notification = $this->entityManager->getRepository(Notification::class)->findOneBy(['status' => 'in_progress', 'allUsers' => true]);
  346.         if(! $notification) {
  347.             $response = new JsonResponse();
  348.             $response->setData(['status' => 'No in_progress notifications found']);
  349.             return $response;
  350.         }
  351.         /** Перевіряю чи дата відправки більше ніж 5 хвилин тому */
  352.         if($notification->getDateSend() > $thresholdTime) {
  353.             $response = new JsonResponse();
  354.             $response->setData(['status' => 'No stuck notifications found']);
  355.             return $response;
  356.         }
  358.         /** Оновлюю статус масового сповіщення */
  359.         $notificationMassive = $notification->getMassiveNotification();
  360.         $notificationMassive->setStatus('new');
  361.         
  362.         // $notifications = $this->entityManager->getRepository(Notification::class)->findBy(['status' => 'in_progress']);
  363.         $notifications = $this->entityManager->getRepository(Notification::class)->findBy(['status' => 'in_progress', 'massiveNotification' => $notificationMassive]);
  365.         if($notifications){
  366.                     // Витягуємо всі ID
  367.             $notificationIds = array_map(fn($n) => $n->getId(), $notifications);
  369.             // Масове оновлення статусу та дати
  370.             $this->entityManager->createQuery(
  371.                 'UPDATE App\Entity\Notification n
  372.                 SET n.status = :newStatus, 
  373.                     n.dateSend = :now,
  374.                     n.error = CONCAT(n.error, :now_str)
  375.                 WHERE n.id IN (:ids)'
  376.             )
  377.             ->setParameter('newStatus', 'new_all')
  378.             ->setParameter('now', new \DateTime())
  379.             ->setParameter('ids', $notificationIds)
  380.             ->setParameter('now_str', "\n" . date('Y-m-d H:i:s') . " - Перевідправлено через зависання")
  381.             ->execute();
  382.         }
  384.         $this->entityManager->persist($notificationMassive);
  385.         $this->entityManager->flush();
  387.         $response = new JsonResponse();
  388.         $response->setData(['status' => 'Check completed']);
  389.         return $response;
  390.     }
  393.     
  394.     /** Додавання масових сповіщень в чергу RABBIT з статусом "new_all" */
  396.     #[Route('/api/add-notification-massive-in-queue', name: 'add_notification_massive_in_queue', methods: ['GET'])]
  397.     public function add_notification_massive_in_queue(Request $request)
  398.     {
  399.         /** Перевірка чи не запущено крон  */
  400.         if(file_exists('/var/www/symfony_docker/var/log/notificationMassiveCron.log')){
  401.             $logCron = file_get_contents('/var/www/symfony_docker/var/log/notificationMassiveCron.log');
  402.             if(!empty( $logCron )){
  403.                 $fileContents = json_decode($logCron, true);
  404.                 $lastRunTime = isset($fileContents['start']) ? strtotime($fileContents['start']) : 0;
  405.                 $currentTime = time();
  406.                 if( $fileContents['cron'] == 'Start' ){
  407.                 
  408.                     // Якщо останній запуск був менше ніж 5 хвилин тому, завершуємо виконання
  409.                     echo "$currentTime - $lastRunTime = " . ($currentTime - $lastRunTime);
  410.                     if (($currentTime - $lastRunTime) > 300) {
  411.                         $logCron =  json_encode([
  412.                             'cron' => 'Stop',
  413.                             'stop' => date('Y-m-d H:i:s'),
  414.                             'info' => 'The cron job was run less than 5 minutes ago. Exiting to prevent overlap.'
  415.                         ]);
  416.                         file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveCron.log',  $logCron);
  419.                     }
  420.                     var_dump($logCron);
  421.                     die;
  422.                 }
  423.             }
  424.             
  425.         }
  427.         file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveCron.log',  json_encode([
  428.             'cron' => 'Start',
  429.             'start' => date('Y-m-d H:i:s'),
  430.             'info' => 'Start notification cron'
  431.         ]));
  432.         
  433.         
  434.         // file_put_contents('/var/www/symfony_docker/var/log/notificationCron.log');
  435.               $send = 0;
  436.         $err = 0;
  437.         
  438.         /** Масовані розсилки розділені ns_msg_id, бо в них однакові тексти, тому шукаю перший ліпший і потім всі інші по ns_msg_id  */
  439.         $MassiveNotification = $this->entityManager->getRepository(MassiveNotification::class)->findOneBy(['status' => 'new']);
  440.         // $firstNotification = $this->entityManager->getRepository(Notification::class)->findOneBy(['status' => 'new_all', 'allUsers' => true, 'massiveNotification' => $MassiveNotification]);
  441.         if($MassiveNotification){
  442.             file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log',  $MassiveNotification->getId() . " NOTIFICATIONS Massive ************************" .  date('H:i:s') . "\n", FILE_APPEND);
  443.             $notifications = $this->entityManager->createQueryBuilder()
  444.                     ->select('n.id')
  445.                     ->from(Notification::class, 'n')
  446.                     ->where('n.status = :status')
  447.                     ->andWhere('n.massiveNotification = :mn')
  448.                     ->setParameter('status', 'new_all')
  449.                     ->setParameter('mn', $MassiveNotification)
  450.                     ->getQuery()
  451.                     ->getSingleColumnResult();
  452.             
  453.             if(count($notifications) == 0){
  454.                 file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log',  $MassiveNotification->getId() .  date('H:i:s') . "Немає нових сповіщень для розсилки\n", FILE_APPEND);
  455.                 $MassiveNotification->setStatus('send');
  456.                 $MassiveNotification->setDescription('Немає нових сповіщень для розсилки');
  457.                 $this->entityManager->persist($MassiveNotification);
  458.                 $this->entityManager->flush();
  460.                     // $logCron =  json_encode([
  461.                     //     'cron' => 'Stop',
  462.                     //     'stop' => date('Y-m-d H:i:s'),
  463.                     //     'info' => 'Notification cron complete'
  464.                     // ]);
  465.                     // file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveCron.log',  $logCron);
  469.                 $response = new JsonResponse();
  470.                 $response->setData(['send' => 0, 'err' => 0, 'error' => 'Немає нових сповіщень для розсилки']); 
  471.                 return $response; 
  472.             }
  474.             file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log',  "MassiveNotification ID: " . $MassiveNotification->getId() .  date('H:i:s') . " Кількість сповіщень: " . count($notifications) . "\n", FILE_APPEND);
  477.             // $notifications = 
  478.             
  479.             $notificationsChunk = array_chunk($notifications, 1000);
  481.             // echo '<pre>';
  482.     
  483.                     
  484.             foreach($notificationsChunk as $notification){
  485.                 $send = 0;
  486.                 $priority = 1;
  487.                 file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log', "#{$MassiveNotification->getId()} add to 1000items rabbitmq - " . json_encode($notification) .  date('H:i:s.u') . "\n", FILE_APPEND);
  489.                 $queued = false;
  490.                 $error  = null;
  492.                 try {
  493.                     // print_r($notification);
  494.                     $env = $this->bus->dispatch(new NotificationMessage($MassiveNotification->getId(), $notification, 'send-notification-massive', $priority));
  496.                     // Якщо повідомлення надіслано у транспорт — з’являться SentStamp-и
  497.                     $sentStamps = $env->all(SentStamp::class);
  499.                     if (!empty($sentStamps)) {
  500.                         $send++;
  501.                         file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log', "#{$MassiveNotification->getId()} 1000items rabbitmq-success " .  date('H:i:s.u') . "\n", FILE_APPEND);
  502.                         $queued = true;
  503.                         // для логів можна подивитись куди саме:
  504.                         $targets = array_map(fn(SentStamp $s) => $s->getSenderAlias() ?? $s->getTransportName(), $sentStamps);
  505.                         file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log',  'Sent to: '.implode(', ', $targets).PHP_EOL, FILE_APPEND);
  506.                     } else {
  507.                         $err++;
  508.                         // це означає, що роутінг не відправив у транспорт (наприклад, sync bus)
  509.                         $queued = false;
  510.                         $error  = 'No SentStamp: message was not routed to a transport';
  511.                         file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log', "#{$MassiveNotification->getId()} rabbitmq-error " .  date('H:i:s.u') . " - No SentStamp: message was not routed to a transport\n", FILE_APPEND);
  512.                     }
  514.                 } catch (TransportExceptionInterface $e) {
  515.                     // Помилки транспорту/брокера (у т.ч. коли confirm_publish=true і брокер не підтвердив)
  516.                     $queued = false;
  517.                     $error  = $e->getMessage();
  518.                     $err++;
  519.                     file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log', "#{$MassiveNotification->getId()} rabbitmq-TransportExceptionInterface " .  date('H:i:s.u') . " - " . $e->getMessage() . "\n", FILE_APPEND);
  520.                 } catch (\Throwable $e) {
  521.                     // будь-яка інша помилка
  522.                     $queued = false;
  523.                     $error  = $e->getMessage();
  524.                     $err++;
  525.                     file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveAddInQueue.log', "#{$MassiveNotification->getId()} rabbitmq-Throwable " .  date('H:i:s.u') . " - " . $e->getMessage() . "\n", FILE_APPEND);
  526.                 }
  528.             }
  530.             $MassiveNotification->setStatus('send');
  531.             $MassiveNotification->setDescription('Розсилка в чергу завершена. Додано в чергу ' . ($send + $err) . ' сповіщень, з помилками ' . $err);
  532.             $this->entityManager->persist($MassiveNotification);
  533.             $this->entityManager->flush();
  534.             // die;
  536.         }
  537.     
  538.         $logCron =  json_encode([
  539.             'cron' => 'Stop',
  540.             'stop' => date('Y-m-d H:i:s'),
  541.             'info' => 'Notification cron complete'
  542.         ]);
  543.         file_put_contents('/var/www/symfony_docker/var/log/notificationMassiveCron.log',  $logCron);
  546.         $response = new JsonResponse();
  547.         $response->setData(['send' => $send, 'err' => $err]);
  548.         return $response;
  549.     }
  552. }