src/Subscriber/Livecam/BalanceAmateurSubscriber.php line 33

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Livecam;
  5. use App\Dictionary\BalanceDetailUsageType;
  6. use App\Dictionary\BalanceType;
  7. use App\Event\Balance\BalanceAmateurProvisionCreatedEvent;
  8. use App\Event\RedisEventManager;
  9. use Frivol\Common\Service\Notification\LivecamProvisionNotification;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class BalanceAmateurSubscriber implements EventSubscriberInterface
  13. {
  14.     protected RedisEventManager $redisEventManager;
  16.     public function __construct(RedisEventManager $redisEventManager)
  17.     {
  18.         $this->redisEventManager = $redisEventManager;
  19.     }
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             BalanceAmateurProvisionCreatedEvent::class => [
  25.                 ['onLivecamProvisionSendNotification', 0],
  26.             ],
  27.         ];
  28.     }
  30.     /**
  31.      * @return void
  32.      */
  33.     public function onLivecamProvisionSendNotification(BalanceAmateurProvisionCreatedEvent $event)
  34.     {
  35.         $balance = $event->getBalance();
  36.         if (BalanceType::INCOME !== $balance->getType()) {
  37.             return;
  38.         }
  39.         if ($balance->isTypeCam()) { // of course, it is need to disable it temporarily
  40.             return;
  41.         }
  42.         $detail = $balance->getBalanceDetail();
  43.         if (!$detail || BalanceDetailUsageType::CAM !== $detail->getUsageType()) {
  44.             return;
  45.         }
  46.         if ($balance->getAmount() / 1.21 < 0.01) {
  47.             return;
  48.         }
  50.         $amateur = $balance->getMember();
  51.         $amount = number_format($balance->getAmount() / 1.21, 2, ',', '.');
  53.         $notification = new LivecamProvisionNotification();
  54.         $notification->setData([
  55.             'message' => 'Du hast eine Gutschrift über '.$amount.' EUR erhalten.',
  56.             'amount' => $amount,
  57.         ]);
  58.         $notification->setRecipientUsername($amateur->getUsername());
  59.         $notification->setRecipientId($amateur->getId());
  61.         $this->redisEventManager->publishToMember($amateur, $notification);
  62.     }
  63. }