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. }