src/Controller/SmsController.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Sms;
  6. use App\Entity\WayBill;
  7. use App\Messages\SMSMessage;
  8. use Doctrine\Persistence\ManagerRegistry;
  9. use Doctrine\Persistence\ObjectManager;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\HttpFoundation\Request;
  13. use Symfony\Component\HttpFoundation\Response;
  14. use Symfony\Component\Messenger\MessageBusInterface;
  15. use Symfony\Component\Routing\Annotation\Route;
  17. class SmsController extends AbstractController {
  19. private ObjectManager $em;
  20. private LoggerInterface $logger;
  22. public function __construct(ManagerRegistry $managerRegistry, LoggerInterface $logger, MessageBusInterface $messageBus){
  23. $this->logger = $logger;
  24. $this->em = $managerRegistry->getManager();
  25. $this->messageBus = $messageBus;
  26. }
  29. #[Route('/sms/callback', name: 'app_sms_smscallback')]
  30. function smsCallback(Request $request): Response {
  32. $messageId = $request->get('id');
  33. $status = $request->get('status');
  35. if($messageId){
  36. $sms = $this->em->getRepository(Sms::class)->findOneBy([
  37. 'messageId' => $messageId
  38. ]);
  39. $sms->setStatus($status);
  40. $this->em->flush();
  41. }
  42. return new Response('OK', Response::HTTP_OK);
  43. }
  46. #[Route('/sms/send_unsent', name: 'app_sms_smscallback_')]
  47. function smsUnsent(Request $request): Response
  48. {
  50. $failedDeliveryNotifications = $this->em->getRepository(WayBill::class)->findFailedSmsByInserficient();
  52. $smses =[];
  54. foreach ($failedDeliveryNotifications as $index => $failedDeliveryNotification) {
  55. $this->messageBus->dispatch(new SMSMessage($failedDeliveryNotification['id']));
  56. }
  59. $smsMessages = json_encode($smses);
  61. return new Response($smsMessages, Response::HTTP_OK);
  62. }
  63. }