custom/plugins/CioCustomerMailbox/src/Controller/MailboxController.php line 68

Open in your IDE?
  1. <?php
  3. namespace CioCustomerMailbox\Controller;
  5. use CioBudget\Service\BudgetHistoryService;
  6. use CioBudget\Service\BudgetInfoService;
  7. use CioBudget\Service\BudgetLoaderService;
  8. use CioCustomerMailbox\Definition\Message\MessageEntity;
  9. use CioCustomerPermissionGroups\Service\CustomerPermissionService;
  10. use Shopware\Core\Checkout\Cart\Exception\CustomerNotLoggedInException;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  20. use Shopware\Core\Framework\Struct\ArrayStruct;
  21. use Shopware\Core\Framework\Uuid\Uuid;
  22. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  23. use Shopware\Storefront\Controller\StorefrontController;
  24. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  25. use Shopware\Storefront\Page\GenericPageLoader;
  26. use Symfony\Component\HttpFoundation\Session\Flash\FlashBagInterface;
  27. use Symfony\Component\Routing\Annotation\Route;
  28. use Symfony\Component\HttpFoundation\Request;
  29. use Symfony\Component\HttpFoundation\Response;
  31. /**
  32.  * @RouteScope(scopes={"storefront"})
  33.  */
  34. class MailboxController extends StorefrontController
  35. {
  36.     private GenericPageLoader $pageLoader;
  37.     private CustomerPermissionService $customerPermissionsService;
  39.     /**
  40.      * @var EntityRepository
  41.      */
  42.     protected EntityRepository $cioMessageRepository;
  44.     /**
  45.      * @var EntityRepository
  46.      */
  47.     protected EntityRepository $cioMessageContentRepository;
  49.     public function __construct(
  50.         GenericPageLoader         $pageLoader,
  51.         CustomerPermissionService $customerPermissionsService,
  52.         EntityRepository $cioMessageRepository,
  53.         EntityRepository $cioMessageContentRepository
  54.     )
  55.     {
  56.         $this->customerPermissionsService = $customerPermissionsService;
  57.         $this->pageLoader = $pageLoader;
  58.         $this->cioMessageRepository = $cioMessageRepository;
  59.         $this->cioMessageContentRepository = $cioMessageContentRepository;
  60.     }
  62.     /**
  63.      * @Route("/account/mailbox", name="storefront.account.mailbox.home", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  64.      * @param Request $request
  65.      * @param SalesChannelContext $context
  66.      * @return Response
  67.      */
  68.     public function mailbox(Request $request, SalesChannelContext $context)
  69.     {
  70.         if (is_null($context->getCustomer())) {
  71.             throw new CustomerNotLoggedInException();
  72.         }
  74.         $page = $this->pageLoader->load($request, $context);
  76.         $criteria = new Criteria();
  77.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  79.         return $this->renderStorefront('@CioCustomerMailbox/storefront/page/account/mailbox.html.twig', ['page' => $page]);
  80.     }
  82.     /**
  83.      * @Route("/account/mailbox/list", name="storefront.account.mailbox.list", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  84.      * @param Request $request
  85.      * @param SalesChannelContext $context
  86.      * @return Response
  87.      */
  88.     public function list(Request $request, SalesChannelContext $context)
  89.     {
  90.         if (is_null($context->getCustomer())) {
  91.             throw new CustomerNotLoggedInException();
  92.         }
  94.         $page = $request->query->getInt('page', 1);
  95.         $category = $request->query->get('category', 'inbox');
  96.         $search = $request->query->get('search');
  98.         $criteria = new Criteria();
  99.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  100.         $criteria->addSorting((new FieldSorting('message_content.number', FieldSorting::DESCENDING)));
  102.         $criteria->setLimit(20);
  103.         $criteria->setOffset(($page - 1) * 20);
  105.         $criteria->addAssociation('message_content');
  107.         if ($category === 'important') {
  108.             $criteria->addFilter(new EqualsFilter('message_content.important', 1));
  109.             $criteria->addFilter(new EqualsFilter('read_at', null));
  110.         } else if ($category === 'read') {
  111.             $criteria->addFilter(new NotFilter(NotFilter::CONNECTION_OR, [
  112.                 new EqualsFilter('read_at', null)
  113.             ]));
  114.         } else if ($category === 'bookmark') {
  115.             $criteria->addFilter(new EqualsFilter('bookmark', true));
  116.         } else {
  117.             $criteria->addFilter(new EqualsFilter('read_at', null));
  118.         }
  120.         if ($search) {
  121.             $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  122.                 new ContainsFilter('message_content.subject', $search),
  123.                 new ContainsFilter('message_content.content', $search)
  124.             ]));
  125.         }
  127.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  128.             new EqualsFilter('message_content.visible_from', null),
  129.             new RangeFilter('message_content.visible_from', [
  130.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  131.             ])
  132.         ]));
  134.         $messages = $this->cioMessageRepository->search($criteria, $context->getContext());
  136.         /** @var MessageEntity $message */
  137.         foreach ($messages->getEntities() as $message) {
  138.             $shortMessage = html_entity_decode(strip_tags($message->getMessageContent()->getContent()));
  140.             $message->addExtension('runtime', new ArrayStruct([
  141.                 'shortMessage' => substr($shortMessage, 0, 75) . (strlen($shortMessage) > 75 ? '...' : ''),
  142.             ]));
  143.         }
  145.         return $this->json($messages);
  146.     }
  148.     /**
  149.      * @Route("/account/mailbox/list/count", name="storefront.account.mailbox.list.count", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  150.      * @param Request $request
  151.      * @param SalesChannelContext $context
  152.      * @return Response
  153.      */
  154.     public function countMessages(Request $request, SalesChannelContext $context)
  155.     {
  156.         if (is_null($context->getCustomer())) {
  157.             throw new CustomerNotLoggedInException();
  158.         }
  160.         $criteria = new Criteria();
  161.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  163.         $criteria->addFilter(new EqualsFilter('read_at', null));
  165.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  166.             new EqualsFilter('message_content.visible_from', null),
  167.             new RangeFilter('message_content.visible_from', [
  168.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  169.             ])
  170.         ]));
  172.         $inboxCount = $this->cioMessageRepository->search($criteria, $context->getContext())->getTotal();
  174.         $criteria = new Criteria();
  175.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  176.         $criteria->addFilter(new EqualsFilter('read_at', null));
  177.         $criteria->addFilter(new EqualsFilter('message_content.important', 1));
  179.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  180.             new EqualsFilter('message_content.visible_from', null),
  181.             new RangeFilter('message_content.visible_from', [
  182.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  183.             ])
  184.         ]));
  186.         $importantCount = $this->cioMessageRepository->search($criteria, $context->getContext())->getTotal();
  188.         return $this->json(['inbox' => $inboxCount, 'important' => $importantCount]);
  189.     }
  191.     /**
  192.      * @Route("/account/mailbox/{id}/markasread", name="storefront.account.mailbox.markasread", methods={"GET"})
  193.      * @param Request $request
  194.      * @param SalesChannelContext $context
  195.      * @return Response
  196.      */
  197.     public function markAsRead(Request $request, SalesChannelContext $context)
  198.     {
  199.         if (is_null($context->getCustomer())) {
  200.             throw new CustomerNotLoggedInException();
  201.         }
  203.         $id = $request->get('id');
  205.         $criteria = new Criteria();
  206.         $criteria->addFilter(new EqualsFilter('id', $id));
  207.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  209.         $message = $this->cioMessageRepository->search($criteria, $context->getContext())->first();
  211.         if ($message instanceof MessageEntity) {
  213.             $this->cioMessageRepository->update([[
  214.                 'id' => $id,
  215.                 'read_at' => new \DateTime()
  216.             ]], $context->getContext());
  218.             return $this->json(['success' => true]);
  220.         }
  222.         return $this->json(['success' => false]);
  223.     }
  225.     /**
  226.      * @Route("/account/mailbox/{id}/togglebookmark", name="storefront.account.mailbox.togglebookmark", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  227.      * @param Request $request
  228.      * @param SalesChannelContext $context
  229.      * @return Response
  230.      */
  231.     public function toggleBookmark(Request $request, SalesChannelContext $context)
  232.     {
  233.         if (is_null($context->getCustomer())) {
  234.             throw new CustomerNotLoggedInException();
  235.         }
  237.         $id = $request->get('id');
  239.         $criteria = new Criteria();
  240.         $criteria->addFilter(new EqualsFilter('id', $id));
  241.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  243.         $message = $this->cioMessageRepository->search($criteria, $context->getContext())->first();
  245.         if ($message instanceof MessageEntity) {
  247.             $this->cioMessageRepository->update([[
  248.                 'id' => $id,
  249.                 'bookmark' => !$message->getBookmark()
  250.             ]], $context->getContext());
  252.             return $this->json(['success' => true]);
  254.         }
  256.         return $this->json(['success' => false]);
  257.     }
  259. }