custom/plugins/TomRocketsTheme/src/Subscriber/AccountOverviewLoadedSubscriber.php line 47

Open in your IDE?
  1. <?php
  4. namespace TomRockets\Subscriber;
  7. use Shopware\Core\Checkout\Customer\CustomerEvents;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\System\SystemConfig\SystemConfigService;
  14. use Shopware\Storefront\Page\Account\Overview\AccountOverviewPageLoadedEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class AccountOverviewLoadedSubscriber implements EventSubscriberInterface
  18. {
  19.     /** @var SystemConfigService */
  20.     private $config;
  21.     /** @var EntityRepository */
  22.     private $orderRepository;
  23.     /** @var EntityRepository */
  24.     private $groupRepository;
  26.     public function __construct(
  27.         SystemConfigService $config,
  28.         EntityRepository $orderRepository,
  29.         EntityRepository $groupRepository
  30.     )
  31.     {
  32.         $this->config = $config;
  33.         $this->orderRepository = $orderRepository;
  34.         $this->groupRepository = $groupRepository;
  35.     }
  37.     /**
  38.      * @inheritDoc
  39.      */
  40.     public static function getSubscribedEvents()
  41.     {
  42.         return [
  43.             AccountOverviewPageLoadedEvent::class => "accountLoaded",
  44.         ];
  45.     }
  47.     public function accountLoaded(AccountOverviewPageLoadedEvent $event){
  48.         $turnOver = self::getCustomerTurnOver($event->getPage()->getCustomer()->getId());
  49.         $amountOfOrders = self::getOrdersByCustomer($event->getPage()->getCustomer()->getId());
  50.         $categoryMore = $this->config->get("TomRockets.config.accountMore");
  53.         $result = [];
  54.         if ($turnOver['amount'] < 300){
  55.             $result['nextGroupTurnOver'] = 300 - $turnOver['amount'];
  56.         }elseif ($turnOver['amount'] >= 300 && $turnOver['amount'] < 600){
  57.             $result['nextGroupTurnOver'] = 600 - $turnOver['amount'];
  58.         }elseif ($turnOver['amount'] >= 600 && $turnOver['amount'] < 1200){
  59.             $result['nextGroupTurnOver'] = 1200 - $turnOver['amount'];
  60.         }elseif ($turnOver['amount'] >= 1200){
  61.             $result['nextGroupTurnOver'] = 0;
  62.         }
  64.         if ($amountOfOrders['amount'] < 12) {
  65.             $result['nextGroupAmountOfOrders'] = 12 - $amountOfOrders['amount'];
  66.         }elseif ($amountOfOrders['amount'] >= 12 && $amountOfOrders['amount'] < 24){
  67.             $result['nextGroupAmountOfOrders'] = 24 - $amountOfOrders['amount'];
  68.         }elseif ($amountOfOrders['amount'] >= 24 && $amountOfOrders['amount'] < 36){
  69.             $result['nextGroupAmountOfOrders'] = 36 - $amountOfOrders['amount'];
  70.         }elseif ($amountOfOrders['amount'] >= 36){
  71.             $result['nextGroupAmountOfOrders'] = 0;
  72.         }
  74.         $result['currentStatus'] = $turnOver['turnOver'];
  75.         $result['categoryMore'] = $categoryMore;
  77.         $result['currentGroup'] = self::getCustomerGroup($event->getPage()->getCustomer()->getGroupId());
  78.         $result['nextGroup'] = self::getNextGroup($result['currentStatus'], $result['currentGroup']);
  80.         $currentGroupStatus = '';
  81.         if ($result['currentStatus'] === 'bronze' && $result['currentGroup']->getId() !== $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  82.             if ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  83.                 $currentGroupStatus = 'silver';
  84.             }elseif ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.goldCustomerGroup")){
  85.                 $currentGroupStatus = 'gold';
  86.             }
  87.         }elseif ($result['currentStatus'] === 'silver' && $result['currentGroup']->getId() !== $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  88.             if ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  89.                 $currentGroupStatus = 'bronze';
  90.             }elseif ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.goldCustomerGroup")){
  91.                 $currentGroupStatus = 'gold';
  92.             }
  93.         }elseif ($result['currentStatus'] === 'gold' && $result['currentGroup']->getId() !== $this->config->get("TwigelBonusProgram.config.goldCustomerGroup")){
  94.             if ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  95.                 $currentGroupStatus = 'bronze';
  96.             }elseif ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  97.                 $currentGroupStatus = 'silver';
  98.             }
  99.         }elseif ($result['currentStatus'] === 0 && $result['currentGroup']->getId() !== $this->config->get("TwigelBonusProgram.config.goldCustomerGroup")){
  100.             if ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  101.                 $currentGroupStatus = 'bronze';
  102.             }elseif ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  103.                 $currentGroupStatus = 'silver';
  104.             }
  105.         }elseif ($result['currentStatus'] === 0 && $result['currentGroup']->getId() !== $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  106.             if ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  107.                 $currentGroupStatus = 'bronze';
  108.             }elseif ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.goldCustomerGroup")){
  109.                 $currentGroupStatus = 'gold';
  110.             }
  111.         }elseif($result['currentStatus'] === 'bronze' && $result['currentGroup']->getId() !== $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  112.             if ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  113.                 $currentGroupStatus = 'silver';
  114.             }elseif ($result['currentGroup']->getId() === $this->config->get("TwigelBonusProgram.config.goldCustomerGroup")){
  115.                 $currentGroupStatus = 'gold';
  116.             }
  117.         }
  119.         if ($currentGroupStatus === 'bronze'){
  120.             $result['nextGroupTurnOver'] = 600 - $turnOver['amount'];
  121.             $result['nextGroupAmountOfOrders'] = 24 - $amountOfOrders['amount'];
  122.         }elseif ($currentGroupStatus === 'silver'){
  123.             $result['nextGroupTurnOver'] = 1200 - $turnOver['amount'];
  124.             $result['nextGroupAmountOfOrders'] = 36 - $amountOfOrders['amount'];
  125.         }elseif ($currentGroupStatus === 'gold'){
  126.             $result['nextGroupTurnOver'] = $turnOver['amount'];
  127.             $result['nextGroupAmountOfOrders'] = $amountOfOrders['amount'];
  128.         }else{
  129.             $result['nextGroupTurnOver'] = 300 - $turnOver['amount'];
  130.             $result['nextGroupAmountOfOrders'] = 12 - $amountOfOrders['amount'];
  131.         }
  133.         $event->getPage()->assign(['customerAccountStatus' => $result]);
  134.     }
  136.     private function getCustomerGroup($groupId){
  137.         return $this->groupRepository->search(new Criteria([$groupId]), Context::createDefaultContext())->first();
  138.     }
  140.     private function getNextGroup($currentStatus, $currentGroup){
  141.         $groupId = $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup");
  143.         if($currentStatus === 'bronze'){
  144.             $groupId = $this->config->get("TwigelBonusProgram.config.silverCustomerGroup");
  145.         }elseif ($currentStatus === 'silver'){
  146.             $groupId = $this->config->get("TwigelBonusProgram.config.goldCustomerGroup");
  147.         }
  149.         if ($currentGroup->getId() === $this->config->get("TwigelBonusProgram.config.silverCustomerGroup")){
  150.             $groupId = $this->config->get("TwigelBonusProgram.config.goldCustomerGroup");
  151.         }elseif ($currentGroup->getId() === $this->config->get("TwigelBonusProgram.config.bronzeCustomerGroup")){
  152.             $groupId = $this->config->get("TwigelBonusProgram.config.silverCustomerGroup");
  153.         }
  155.         return $this->groupRepository->search(new Criteria([$groupId]), Context::createDefaultContext())->first();
  156.     }
  158.     private function getCustomerTurnOver($customerId){
  159.         $criteria = new Criteria();
  160.         $criteria->addFilter(new EqualsFilter('customerId', $customerId));
  161.         $criteria->addAssociations(['order']);
  162.         $orders = $this->orderRepository->search($criteria, Context::createDefaultContext())->getElements();
  164.         $turnOver = 0;
  166.         /** @var OrderCustomerEntity $order */
  167.         foreach ($orders as $order) {
  168.             $turnOver += $order->getOrder()->getAmountTotal();
  169.         }
  171.         $status = [
  172.             'turnOver' => 0,
  173.             'amount' => $turnOver
  174.         ];
  175.         if ($turnOver >= 300 && $turnOver < 600){
  176.             $status['turnOver'] = 'bronze';
  177.         }elseif ($turnOver >= 600 && $turnOver < 1200){
  178.             $status['turnOver'] = 'silver';
  179.         }elseif ($turnOver >= 1200){
  180.             $status['turnOver'] = 'gold';
  181.         }
  183.         return $status;
  184.     }
  186.     private function getOrdersByCustomer($customerId){
  187.         $criteria = new Criteria();
  188.         $criteria->addFilter(new EqualsFilter('customerId', $customerId));
  189.         $orders = $this->orderRepository->search($criteria, Context::createDefaultContext())->getElements();
  191.         $amountOfOrders = count($orders);
  193.         $status = [
  194.             'amountOfOrders' => 0,
  195.             'amount' => $amountOfOrders
  196.         ];
  197.         if ($amountOfOrders >= 12 && $amountOfOrders < 24){
  198.             $status['amountOfOrders'] = 'bronze';
  199.         }elseif ($amountOfOrders >= 24 && $amountOfOrders < 36){
  200.             $status['amountOfOrders'] = 'silver';
  201.         }elseif ($amountOfOrders >= 36){
  202.             $status['amountOfOrders'] = 'gold';
  203.         }
  205.         return $status;
  206.     }
  207. }