src/Subscriber/Payment/Purchase/PurchaseMessengerSubscriber.php line 101

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Payment\Purchase;
  5. use App\Dictionary\ContentType;
  6. use App\Dictionary\ConversationMessageSource;
  7. use App\Dictionary\ConversationMessageType;
  8. use App\Event\Payment\PurchaseCreatedEvent;
  9. use App\Lib\Purchase\ContentPurchasable;
  10. use App\Lib\Purchase\ConversationMessageAttachmentPurchasable;
  11. use App\Lib\Purchase\ConversationMessagePurchasable;
  12. use App\Service\Content\ContentService;
  13. use App\Service\Messenger\MessengerCacheService;
  14. use App\Service\Messenger\MessengerService;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class PurchaseMessengerSubscriber implements EventSubscriberInterface
  18. {
  19.     protected MessengerService $messenger;
  21.     protected MessengerCacheService $cacheService;
  23.     protected ContentService $contentService;
  25.     public function __construct(MessengerService $messenger, ContentService $contentService,
  26.         MessengerCacheService $cacheService)
  27.     {
  28.         $this->messenger = $messenger;
  29.         $this->contentService = $contentService;
  30.         $this->cacheService = $cacheService;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             PurchaseCreatedEvent::class => [
  37.                 ['onContentPurchaseSendMessengerNotification', 0],
  38.                 ['onMessengerPurchaseUpdateConversationMessage', 1],
  39.                 ['onAttachmentPurchaseClearConversationCache', 2],
  40.             ],
  41.         ];
  42.     }
  44.     /**
  45.      * @return void
  46.      *
  47.      * @throws \Doctrine\ORM\ORMException
  48.      * @throws \Doctrine\ORM\OptimisticLockException
  49.      */
  50.     public function onContentPurchaseSendMessengerNotification(PurchaseCreatedEvent $event)
  51.     {
  52.         $purchasable = $event->getPurchasable();
  53.         if (!$purchasable instanceof ContentPurchasable) {
  54.             return;
  55.         }
  57.         $content = $purchasable->getContent();
  58.         $seller = $purchasable->getSeller();
  59.         $buyer = $event->getPurchase()->getBuyer();
  61.         $atDate = $this->getMessengerNotificationTextDate($event->getPurchase()->getCreatedAt());
  63.         $text = $this->getMessengerNotificationTextTemplate();
  64.         if (ContentType::IMAGESET === $content->getType()) {
  65.             $text = $this->getMessengerNotificationImagesetImageTextTemplate();
  66.         }
  67.         $provi = ($purchasable->getAmount() * 0.25) / 1.21;
  69.         $text = sprintf($text, $seller->getUsername(), $buyer->getUsername(), $content->getTitle(), $atDate, $provi);
  70.         $this->messenger->sendDirectMessage($buyer, $seller, $text,
  71.             ConversationMessageType::CONTENT_PURCHASE, ConversationMessageSource::SYSTEM);
  72.     }
  74.     protected function getMessengerNotificationTextDate(\DateTimeInterface $created): string
  75.     {
  76.         $date = $created->format('d.m.Y');
  77.         $time = $created->format('H:i');
  79.         return $date.', '.$time.' Uhr';
  80.     }
  82.     protected function getMessengerNotificationTextTemplate(): string
  83.     {
  84.         return 'Hallo %s, der User %s hat dein Video "%s" am %s gekauft. Dein Verdienst: %01.2f EUR.'.
  85.             "\n\nBitte reagiere: Bedanke dich mit einer Nachricht an den User und/oder bitte um eine Bewertung indem ".
  86.             'du direkt hier antwortest. So kannst du weitere Verkäufe generieren!'.
  87.             "\n\nHinweis: Diese Nachricht ist nur für dich sichtbar!";
  88.     }
  90.     protected function getMessengerNotificationImagesetImageTextTemplate(): string
  91.     {
  92.         return 'Hallo %s, der User %s hat EIN Bild aus dem Bilderset "%s" am %s gekauft. Dein Verdienst: %01.2f EUR.'.
  93.             "\n\nBitte reagiere: Bedanke dich mit einer Nachricht an den User und/oder bitte um eine Bewertung indem ".
  94.             'du direkt hier antwortest. So kannst du weitere Verkäufe generieren!'.
  95.             "\n\nHinweis: Diese Nachricht ist nur für dich sichtbar!";
  96.     }
  98.     /**
  99.      * @return void
  100.      */
  101.     public function onAttachmentPurchaseClearConversationCache(PurchaseCreatedEvent $event)
  102.     {
  103.         $purchasable = $event->getPurchasable();
  104.         if (!$purchasable instanceof ConversationMessageAttachmentPurchasable) {
  105.             return;
  106.         }
  108.         $message = $purchasable->getEntity();
  109.         if ($conversation = $message->getConversation()) {
  110.             $this->cacheService->clearMessagesCacheForConversation($conversation->getId());
  111.         }
  112.     }
  114.     /**
  115.      * @throws \Doctrine\ORM\ORMException
  116.      * @throws \Doctrine\ORM\OptimisticLockException
  117.      */
  118.     public function onMessengerPurchaseUpdateConversationMessage(PurchaseCreatedEvent $event)
  119.     {
  120.         $purchase = $event->getPurchasable();
  121.         if ($purchase instanceof ConversationMessagePurchasable || $purchase instanceof ConversationMessageAttachmentPurchasable) {
  122.             $message = $purchase->getEntity();
  123.             if ($message->getPurchase()) {
  124.                 // just in case: already purchased
  125.                 return;
  126.             }
  127.             $message->setPurchase($event->getPurchase());
  129.             $this->messenger->storeConversationMessage($message);
  130.         }
  131.     }
  132. }