src\Web\HomeController.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\Web;
  5. use App\Entity\BranchCampaign;
  6. use App\Entity\Contact;
  7. use App\Messages\SendWhatsAppMessage;
  8. use App\Messages\SmsMessage;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Doctrine\Persistence\ObjectManager;
  11. use FOS\RestBundle\Controller\Annotations as Rest;
  12. use JetBrains\PhpStorm\NoReturn;
  13. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpFoundation\Response;
  16. use Symfony\Component\Messenger\MessageBusInterface;
  17. use Symfony\Component\Routing\Annotation\Route;
  19. class HomeController extends AbstractController {
  22.     private STATIC string $SENDER = "NEEMA-OPTIC";
  24.     private ObjectManager $em;
  26.     public function __construct(ManagerRegistry $managerRegistry){
  27.         $this->em = $managerRegistry->getManager();
  28.     }
  30.     /**
  31.      * @Route("/",  name="homeRoute")
  32.      * @param Request $request
  33.      * @param MessageBusInterface $messageBus
  34.      * @return Response
  35.      */
  36.     public function homeAction(Request $request, MessageBusInterface $messageBus): Response
  37.     {
  40.         return $this->render('home.html.twig',[
  42.         ]);
  43.     }
  45.     /**
  46.      * @Route("/test/{campaignId}/{branchId}", name="test_paging")
  47.      */
  48.     public function test(Request $request, $campaignId, $branchId, MessageBusInterface $messageBus): Response
  49.     {
  51.         $pageSize = 5000;
  52.         $pages = 0;
  53.         $remainder = 0;
  55.         /** @var BranchCampaign $branchCampaign */
  56.         $branchCampaign = $this->em->getRepository(BranchCampaign::class)->findOneBy([
  57.             'campaign' => $campaignId,
  58.             'branch' => $branchId
  59.         ]);
  60.         $contactsCount = 2; //$branchCampaign->getContactsCount();
  62.         if ($contactsCount > 0) {
  63.             $pages = intval($contactsCount / $pageSize);
  64.             $remainder = $contactsCount - ($pageSize * $pages);
  65.         }
  67.         for ($x = 0; $x < $pages; $x++) {
  68.             $offset = $x == 0 ? $x : ($x * $pageSize);
  69.             $message = new SmsMessage($x, $offset, $pageSize, $branchCampaign->getId());
  70.             $messageBus->dispatch($message);
  71.         }
  73.         if ($remainder > 0) {
  74.             $offset = $pages * $pageSize;
  75.             $x = ($pages + 1);
  77.             $message = new SmsMessage($x, $offset, $remainder, $branchCampaign->getId());
  78.             $messageBus->dispatch($message);
  80.             dump("PAGE", $x);
  81.             dump("OFFSET", $offset);
  82.             dump("SIZE", $remainder);
  83.         }
  86.         return new Response("OK", Response::HTTP_OK);
  87.     }
  91. }