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

Open in your IDE?
  1. <?php
  3. namespace CioCustomerMailbox\Controller;
  5. use CioCustomerMailbox\Definition\Message\MessageEntity;
  6. use CioCustomerPermissionGroups\Service\CustomerPermissionService;
  7. use CioMasterdata\Definition\Masterdata\MasterdataEntity;
  8. use CioMasterdata\Service\MasterdataService;
  9. use Shopware\Core\Checkout\Cart\Exception\CustomerNotLoggedInException;
  10. use Shopware\Core\Checkout\Customer\CustomerEntity;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  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\System\SalesChannel\SalesChannelContext;
  22. use Shopware\Storefront\Controller\StorefrontController;
  23. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  24. use Shopware\Storefront\Page\GenericPageLoader;
  25. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  26. use Symfony\Component\Routing\Annotation\Route;
  27. use Symfony\Component\HttpFoundation\Request;
  28. use Symfony\Component\HttpFoundation\Response;
  30. /**
  31.  * @RouteScope(scopes={"storefront"})
  32.  */
  33. class MailboxController extends StorefrontController
  34. {
  35.     private GenericPageLoader $pageLoader;
  36.     private CustomerPermissionService $customerPermissionsService;
  38.     /**
  39.      * @var EntityRepository
  40.      */
  41.     protected EntityRepository $cioMessageRepository;
  43.     /**
  44.      * @var EntityRepository
  45.      */
  46.     protected EntityRepository $cioMessageContentRepository;
  48.     protected MasterdataService $masterdataService;
  50.     public function __construct(
  51.         GenericPageLoader         $pageLoader,
  52.         CustomerPermissionService $customerPermissionsService,
  53.         EntityRepository $cioMessageRepository,
  54.         EntityRepository $cioMessageContentRepository,
  55.         MasterdataService $masterdataService
  56.     )
  57.     {
  58.         $this->customerPermissionsService = $customerPermissionsService;
  59.         $this->pageLoader = $pageLoader;
  60.         $this->cioMessageRepository = $cioMessageRepository;
  61.         $this->cioMessageContentRepository = $cioMessageContentRepository;
  62.         $this->masterdataService = $masterdataService;
  63.     }
  65.     /**
  66.      * @Route("/account/mailbox", name="storefront.account.mailbox.home", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  67.      * @param Request $request
  68.      * @param SalesChannelContext $context
  69.      * @return Response
  70.      */
  71.     public function mailbox(Request $request, SalesChannelContext $context)
  72.     {
  73.         if (is_null($context->getCustomer())) {
  74.             throw new CustomerNotLoggedInException();
  75.         }
  77.         $page = $this->pageLoader->load($request, $context);
  79.         $criteria = new Criteria();
  80.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  82.         return $this->renderStorefront('@CioCustomerMailbox/storefront/page/account/mailbox.html.twig', ['page' => $page]);
  83.     }
  85.     /**
  86.      * @Route("/account/mailbox/overview", name="storefront.mailbox.overview", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  87.      * @param Request $request
  88.      * @param SalesChannelContext $context
  89.      * @return Response
  90.      */
  91.     public function overview(Request $request, SalesChannelContext $context)
  92.     {
  93.         if (is_null($context->getCustomer())) {
  94.             throw new CustomerNotLoggedInException();
  95.         }
  97.         $page = $this->pageLoader->load($request, $context);
  99.         /** @var EntityRepository $salesRepresentativeRepository */
  100.         $salesRepresentativeRepository = $this->container->get('cio_sales_representative.repository');
  102.         $criteria = new Criteria();
  103.         $criteria->addFilter(new EqualsFilter('email', $context->getCustomer()->getEmail()));
  105.         $salesRepresentativeId = $salesRepresentativeRepository->searchIds($criteria, $context->getContext())->firstId();
  107.         if ($salesRepresentativeId === null) {
  108.             throw new NotFoundHttpException();
  109.         }
  111.         $masterDataCollection = $this->masterdataService->getMasterdasByPartnerId($salesRepresentativeId);
  112.         $customers = [];
  114.         /** @var MasterdataEntity $masterData */
  115.         foreach ($masterDataCollection as $masterData) {
  117.             $allCustomers = $this->masterdataService->getCustomersByMasterdataId($masterData->getId(), false);
  119.             /** @var CustomerEntity $customer */
  120.             foreach ($allCustomers as $customer) {
  122.                 if (!$customer->getActive()) {
  123.                     continue;
  124.                 }
  126.                 if (array_search($customer->getId(), array_column($customers, 'id')) !== false) {
  127.                     continue;
  128.                 }
  130.                 $customer = $this->getCustomerMessages( $customer, $context, $masterData);
  131.                 $customers[$customer->getId()] = $customer;
  133.                 if(is_null($customer->getExtension('customerParent'))) {
  134.                     $subAccounts = $this->masterdataService->getSubaccounts($customer->getId(), $context->getContext());
  135.                     foreach ($subAccounts as $subAccount) {
  136.                         if (!key_exists($subAccount->getId(), $customers)) {
  137.                             $subAccount = $this->getCustomerMessages( $subAccount, $context, $masterData);
  138.                             $customers[$subAccount->getId()] = $subAccount;
  139.                         }
  140.                     }
  141.                 }
  143.             }
  145.         }
  147.         return $this->renderStorefront('@CioCustomerMailbox/storefront/page/overview/index.html.twig', ['page' => $page, 'customers' => $customers]);
  148.     }
  151.     protected function getCustomerMessages(CustomerEntity $customer, SalesChannelContext $context, MasterdataEntity $masterData): CustomerEntity
  152.     {
  153.         $criteria = new Criteria();
  154.         $criteria->addFilter(new EqualsFilter('customer_id', $customer->getId()));
  155.         $criteria->addSorting((new FieldSorting('message_content.number', FieldSorting::DESCENDING)));
  156.         $criteria->addFilter(new EqualsFilter('read_at', null));
  157.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  158.             new EqualsFilter('message_content.visible_from', null),
  159.             new RangeFilter('message_content.visible_from', [
  160.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  161.             ])
  162.         ]));
  163.         $criteria->addAssociation('message_content');
  164.         $messages = $this->cioMessageRepository->search($criteria, $context->getContext());
  166.         $customer->addExtension('runtime', new ArrayStruct([
  167.             'messages' => $messages->getEntities()->getElements(),
  168.             'countImportantMessages' => $messages->filter(function (MessageEntity $message) {
  169.                 return $message->getMessageContent()->getImportant() == true;
  170.             })->count(),
  171.             'countMessages' => $messages->filter(function (MessageEntity $message) {
  172.                 return $message->getMessageContent()->getImportant() == false;
  173.             })->count(),
  174.             'vpNumber' => $masterData->getVpNummer()
  175.         ]));
  177.         return $customer;
  178.     }
  181.     /**
  182.      * @Route("/account/mailbox/list", name="storefront.account.mailbox.list", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  183.      * @param Request $request
  184.      * @param SalesChannelContext $context
  185.      * @return Response
  186.      */
  187.     public function list(Request $request, SalesChannelContext $context)
  188.     {
  189.         if (is_null($context->getCustomer())) {
  190.             throw new CustomerNotLoggedInException();
  191.         }
  193.         $page = $request->query->getInt('page', 1);
  194.         $category = $request->query->get('category', 'inbox');
  195.         $search = $request->query->get('search');
  197.         $criteria = new Criteria();
  198.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  199.         $criteria->addSorting((new FieldSorting('message_content.number', FieldSorting::DESCENDING)));
  201.         $criteria->setLimit(20);
  202.         $criteria->setOffset(($page - 1) * 20);
  204.         $criteria->addAssociation('message_content');
  206.         if ($category === 'important') {
  207.             $criteria->addFilter(new EqualsFilter('message_content.important', 1));
  208.             $criteria->addFilter(new EqualsFilter('read_at', null));
  209.         } else if ($category === 'read') {
  210.             $criteria->addFilter(new NotFilter(NotFilter::CONNECTION_OR, [
  211.                 new EqualsFilter('read_at', null)
  212.             ]));
  213.         } else if ($category === 'bookmark') {
  214.             $criteria->addFilter(new EqualsFilter('bookmark', true));
  215.         } else {
  216.             $criteria->addFilter(new EqualsFilter('read_at', null));
  217.         }
  219.         if ($search) {
  220.             $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  221.                 new ContainsFilter('message_content.subject', $search),
  222.                 new ContainsFilter('message_content.content', $search)
  223.             ]));
  224.         }
  226.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  227.             new EqualsFilter('message_content.visible_from', null),
  228.             new RangeFilter('message_content.visible_from', [
  229.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  230.             ])
  231.         ]));
  233.         $messages = $this->cioMessageRepository->search($criteria, $context->getContext());
  235.         /** @var EntityRepositoryInterface $mediaRepository */
  236.         $mediaRepository = $this->container->get('media.repository');
  238.         /** @var MessageEntity $message */
  239.         foreach ($messages->getEntities() as $message) {
  240.             $shortMessage = html_entity_decode(strip_tags($message->getMessageContent()->getContent()));
  242.             $attachmentUrl = null;
  243.             if ($attachment = $mediaRepository->search(new Criteria([$message->getMessageContent()->getAttachment()]), $context->getContext())->first()) {
  244.                 // check if attachment is a pdf
  245.                 if (strpos($attachment->getMimeType(), 'pdf') !== false) {
  246.                     $attachmentUrl = $attachment->getUrl();
  247.                 }
  248.             }
  250.             $message->addExtension('runtime', new ArrayStruct([
  251.                 'shortMessage' => substr($shortMessage, 0, 75) . (strlen($shortMessage) > 75 ? '...' : ''),
  252.                 'attachmentUrl' => $attachmentUrl
  253.             ]));
  254.         }
  256.         return $this->json($messages);
  257.     }
  259.     /**
  260.      * @Route("/account/mailbox/list/count", name="storefront.account.mailbox.list.count", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  261.      * @param Request $request
  262.      * @param SalesChannelContext $context
  263.      * @return Response
  264.      */
  265.     public function countMessages(Request $request, SalesChannelContext $context)
  266.     {
  267.         if (is_null($context->getCustomer())) {
  268.             throw new CustomerNotLoggedInException();
  269.         }
  271.         $criteria = new Criteria();
  272.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  274.         $criteria->addFilter(new EqualsFilter('read_at', null));
  276.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  277.             new EqualsFilter('message_content.visible_from', null),
  278.             new RangeFilter('message_content.visible_from', [
  279.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  280.             ])
  281.         ]));
  283.         $inboxCount = $this->cioMessageRepository->search($criteria, $context->getContext())->getTotal();
  285.         $criteria = new Criteria();
  286.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  287.         $criteria->addFilter(new EqualsFilter('read_at', null));
  288.         $criteria->addFilter(new EqualsFilter('message_content.important', 1));
  290.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  291.             new EqualsFilter('message_content.visible_from', null),
  292.             new RangeFilter('message_content.visible_from', [
  293.                 RangeFilter::LTE => (new \DateTime())->setTimezone(new \DateTimeZone('Europe/Berlin'))->format('Y-m-d H:i:s')
  294.             ])
  295.         ]));
  297.         $importantCount = $this->cioMessageRepository->search($criteria, $context->getContext())->getTotal();
  299.         return $this->json(['inbox' => $inboxCount, 'important' => $importantCount]);
  300.     }
  302.     /**
  303.      * @Route("/account/mailbox/{id}/markasread", name="storefront.account.mailbox.markasread", methods={"GET"})
  304.      * @param Request $request
  305.      * @param SalesChannelContext $context
  306.      * @return Response
  307.      */
  308.     public function markAsRead(Request $request, SalesChannelContext $context)
  309.     {
  310.         if (is_null($context->getCustomer())) {
  311.             throw new CustomerNotLoggedInException();
  312.         }
  314.         $id = $request->get('id');
  316.         $criteria = new Criteria();
  317.         $criteria->addFilter(new EqualsFilter('id', $id));
  318.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  320.         $message = $this->cioMessageRepository->search($criteria, $context->getContext())->first();
  322.         if ($message instanceof MessageEntity) {
  324.             $this->cioMessageRepository->update([[
  325.                 'id' => $id,
  326.                 'read_at' => new \DateTime()
  327.             ]], $context->getContext());
  329.             return $this->json(['success' => true]);
  331.         }
  333.         return $this->json(['success' => false]);
  334.     }
  336.     /**
  337.      * @Route("/account/mailbox/{id}/togglebookmark", name="storefront.account.mailbox.togglebookmark", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  338.      * @param Request $request
  339.      * @param SalesChannelContext $context
  340.      * @return Response
  341.      */
  342.     public function toggleBookmark(Request $request, SalesChannelContext $context)
  343.     {
  344.         if (is_null($context->getCustomer())) {
  345.             throw new CustomerNotLoggedInException();
  346.         }
  348.         $id = $request->get('id');
  350.         $criteria = new Criteria();
  351.         $criteria->addFilter(new EqualsFilter('id', $id));
  352.         $criteria->addFilter(new EqualsFilter('customer_id', $context->getCustomer()->getId()));
  354.         $message = $this->cioMessageRepository->search($criteria, $context->getContext())->first();
  356.         if ($message instanceof MessageEntity) {
  358.             $this->cioMessageRepository->update([[
  359.                 'id' => $id,
  360.                 'bookmark' => !$message->getBookmark()
  361.             ]], $context->getContext());
  363.             return $this->json(['success' => true]);
  365.         }
  367.         return $this->json(['success' => false]);
  368.     }
  370.     /**
  371.      * @Route("/mailbox/remindlater", name="storefront.mailbox.remindlater", methods={"GET"}, defaults={"_routeScope"="storefront"})}}
  372.      * @param Request $request
  373.      * @param SalesChannelContext $context
  374.      * @return Response
  375.      */
  376.     public function remindLater(Request $request, SalesChannelContext $context): Response
  377.     {
  378.         if (is_null($context->getCustomer())) {
  379.             throw new CustomerNotLoggedInException();
  380.         }
  382.         $request->getSession()->set('mailbox_remind_later', (new \DateTime())->modify('+30 minutes'));
  384.         return $this->json(['success' => true]);
  385.     }
  387. }