<?php
/**
* This file is part of ProductHistory
*
* Copyright(c) Akira Kurozumi <info@a-zumi.net>
*
* https://a-zumi.net
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Customize\EventSubscriber;
use Customize\Service\ProductHistory\ProductCollection;
use Eccube\Common\EccubeConfig;
use Eccube\Event\TemplateEvent;
use Eccube\Repository\ProductRepository;
use Eccube\Request\Context;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\Cookie;
use Symfony\Component\HttpKernel\Event\FilterControllerArgumentsEvent;
use Symfony\Component\HttpKernel\Event\FilterResponseEvent;
use Symfony\Component\HttpKernel\Event\KernelEvent;
use Symfony\Component\HttpKernel\KernelEvents;
/**
* Class ProductHistoryEventSubscriber
* @package Customize\EventSubscriber
*/
class ProductHistoryEventSubscriber implements EventSubscriberInterface
{
const COOKIE_NAME = 'product_history';
/**
* @var ProductRepository
*/
private $productRepository;
/**
* @var EccubeConfig
*/
private $eccubeConfig;
/**
* @var Context
*/
private $context;
/**
* @var EventDispatcherInterface
*/
private $eventDispatcher;
public function __construct(
ProductRepository $productRepository,
EccubeConfig $eccubeConfig,
Context $context,
EventDispatcherInterface $eventDispatcher
)
{
$this->productRepository = $productRepository;
$this->eccubeConfig = $eccubeConfig;
$this->context = $context;
$this->eventDispatcher = $eventDispatcher;
}
/**
* @return array
*/
public static function getSubscribedEvents(): array
{
return [
KernelEvents::RESPONSE => 'onKernelResponse',
KernelEvents::CONTROLLER_ARGUMENTS => 'onKernelControllerArguments'
];
}
/**
* 商品詳細ページにアクセスしたら商品IDをCookieに保存
*
* @param FilterResponseEvent $event
* @throws \Exception
*/
public function onKernelResponse(FilterResponseEvent $event): void
{
if (false === $event->isMasterRequest()) {
return;
}
if ($event->getRequest()->get('_route') !== 'product_detail') {
return;
}
if ($product_id = $event->getRequest()->get('id')) {
$product = $this->productRepository->find($product_id);
if (null === $product) {
return;
}
$cookie = $this->getCookie($event);
// 商品IDを追加
$products = new ProductCollection($cookie, 5);
$products->addProduct($product);
// Cookie作成・更新
$cookie = $this->createCookie($products);
$response = $event->getResponse();
$response->headers->setCookie($cookie);
$event->setResponse($response);
}
}
/**
* チェックした商品をフロント側のすべてのTwigテンプレートにセット
*
* @param FilterControllerArgumentsEvent $event
*/
public function onKernelControllerArguments(FilterControllerArgumentsEvent $event): void
{
if ($this->context->isAdmin()) {
return;
}
if ($event->getRequest()->attributes->has('_template')) {
$cookie = $this->getCookie($event);
$template = $event->getRequest()->attributes->get('_template');
$this->eventDispatcher->addListener($template->getTemplate(), function (TemplateEvent $templateEvent) use ($cookie) {
$productHistory = [];
$products = new ProductCollection($cookie);
if ($products->count() > 0) {
foreach ($products as $product) {
if ($product = $this->productRepository->find($product)) {
$productHistory[] = $product;
}
}
}
$templateEvent->setParameter('productHistory', $productHistory);
});
}
}
/**
* Cookie取得
*
* @param KernelEvent $event
* @return array
*/
private function getCookie(KernelEvent $event): array
{
$cookie = $event->getRequest()->cookies->get(self::COOKIE_NAME);
return json_decode($cookie, true) ?? [];
}
/**
* Cookie作成・更新
*
* @param ProductCollection $productCollection
* @return Cookie
* @throws \Exception
*/
private function createCookie(ProductCollection $productCollection): Cookie
{
return new Cookie(
self::COOKIE_NAME,
json_encode($productCollection->toArray()),
(new \DateTime())->modify('1 month'),
$this->eccubeConfig['env(ECCUBE_COOKIE_PATH)']
);
}
}