src/Service/ActionMatrix.php line 105

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Controller\SystemActionsInterface;
  6. use App\Entity\Sms;
  7. use App\Entity\SmsSetup;
  8. use App\Entity\User;
  9. use App\Entity\WayBill;
  10. use App\Messages\SMSMessage;
  11. use DateTime;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Doctrine\Persistence\ObjectManager;
  14. use Symfony\Component\Messenger\MessageBusInterface;
  16. class ActionMatrix implements SystemActionsInterface {
  18.     private MessageBusInterface $messageBus;
  20.     private ObjectManager $em;
  22.     private BuildSMSMessage $buildSMSMessage;
  24.     private WayBill $waybill;
  26.     public function __construct(MessageBusInterface $messageBus,ObjectManager $objectManager, WayBill $waybill)
  27.     {
  28.         $this->messageBus = $messageBus;
  29.         $this->em = $objectManager;
  30.         $this->waybill = $waybill;
  32.     }
  34.     function registeringAction(User $user): void
  35.     {
  36.         $action = 'registering';
  37.         $this->buildHelper($user,$action);
  38.     }
  40.     function payingAction(User $user,string $paymentMode): void
  41.     {
  42.         $action = 'paying';
  43.         $this->buildHelper($user,$action);
  44.     }
  46.     function loadingAction(User $user): void
  47.     {
  48.         $action = 'loading';
  49.         $this->buildHelper($user,$action);
  50.     }
  52.     function receivingAction(User $user): void
  53.     {
  54.         $action = 'receiving';
  55.         $this->buildHelper($user,$action);
  57.     }
  59.     function collectingAction(User $user): void
  60.     {
  61.         $action = 'collecting';
  62.         $this->buildHelper($user,$action);
  63.     }
  65.     private function buildHelper(User $user,$action): void
  66.     {
  68.         $messageTemplates = $this->em->getRepository(SmsSetup::class)->findBy([
  69.             'action' => $action
  70.         ]);
  73.         $receiverPhone  = str_replace(' ', '', $this->waybill->getReceiverPhoneNumber());
  74.         $senderPhone  = str_replace(' ', '', $this->waybill->getSenderPhoneNumber());
  76.         $buildSms = new BuildSMSMessage($this->waybill);
  77.         foreach ($messageTemplates as $index => $messageTemplate) {
  79.             $smsMessage = $buildSms->build($messageTemplate->getSampleMessage());
  80.             $sendTo = '+254'.substr($senderPhone,1);
  82.             if($messageTemplate->getSendTo() == 'receiver'){
  83.                 $sendTo = '+254'.substr($receiverPhone,1);
  84.             }
  86.             $availableSms = $this->em->getRepository(Sms::class)->findBy([
  87.                 'transaction' => $this->waybill->getTransaction(),
  88.                 'recepient' => $sendTo,
  89.                 'action' => $action
  90.             ]);
  92.             if(!$availableSms){
  93.                 $sms = new Sms();
  94.                 $sms->setSms($smsMessage);
  95.                 $sms->setTransaction($this->waybill->getTransaction());
  96.                 $sms->setRecepient($sendTo);
  97.                 $sms->setCreatedAt(new DateTime());
  98.                 $sms->setCreatedBy($user);
  99.                 $sms->setAmount(0);
  100.                 $sms->setAction($action);
  102.                 $this->em->persist($sms);
  103.                 $this->em->flush();
  105.                 $this->messageBus->dispatch(new SMSMessage($sms->getId()));
  106.             }
  107.         }
  108.     }
  110.     function resendAction(): void {
  111.         $smses = $this->em->getRepository(WayBill::class)->findFailedSmsByInserficient();
  113.         foreach ($smses as $index => $sms) {
  114.             $this->messageBus->dispatch(new SMSMessage($sms['id']));
  115.        }
  116.     }
  117. }