app/Customize/Entity/CacheTrait.php line 43

Open in your IDE?
  1. <?php
  3. namespace Customize\Entity;
  5. use Eccube\Common\Constant;
  6. use Symfony\Component\Cache\Adapter\AbstractAdapter;
  7. use Symfony\Component\Cache\CacheItem;
  8. use Symfony\Contracts\Cache\ItemInterface;
  9. use Symfony\Component\Cache\Adapter\MemcachedAdapter;
  11. trait CacheTrait
  12. {
  14.     /**
  15.      * @var bool
  16.      */
  17.     protected $cacheEnabled = true;
  19.     /**
  20.      * @return MemcachedAdapter
  21.      * @throws \ErrorException
  22.      */
  23.     private function getConfigCache()
  24.     {
  25.         $host = env('CACHE_HOST', '127.0.0.1');
  26.         $port = env('CACHE_PORT', '11211');
  27.         $cacheConnection = 'memcached://' . $host . ':' . $port;
  28.         $client = MemcachedAdapter::createConnection($cacheConnection);
  29.         if ($adapter = new MemcachedAdapter($client, $namespace = '', $defaultLifetime = Constant::ONE_HOUR)) {
  30.             // backofficeのキャッシュクリア／生成管理の仕様と合わせる
  31.             $adapter->enableVersioning(false);
  32.         }
  33.         return $adapter;
  34.     }
  36.     /***
  37.      * @param string $cacheKey
  38.      * @param callable $callback
  39.      * @param int $ttl
  40.      * @return mixed|null
  41.      * @throws \Psr\Cache\InvalidArgumentException
  42.      */
  43.     public function getCacheByKey(string $cacheKey, callable $callback, int $ttl = Constant::ONE_HOUR)
  44.     {
  45.         if (!$this->isCacheEnabled()) {
  46.             //
  47.             return $callback();
  48.         }
  49.         if (empty($cacheKey) || empty($callback)) return null;
  50.         $cache = self::getConfigCache();
  51.         return $cache->get($cacheKey, function (ItemInterface $item) use ($callback, $ttl) {
  52.             $data = call_user_func($callback);
  53.             $item->expiresAfter($ttl);
  54.             return $data;
  55.         });
  56.     }
  58.     /**
  59.      * @return bool
  60.      */
  61.     protected function isCacheEnabled()
  62.     {
  63.         return $this->cacheEnabled;
  64.     }
  66.     protected function enableCache()
  67.     {
  68.         $this->cacheEnabled = true;
  69.     }
  71.     protected function disableCache()
  72.     {
  73.         $this->cacheEnabled = false;
  74.     }
  76.     /**
  77.      * @param callable|string $masterCacheKey
  78.      * @param string $device
  79.      * @param string[] $cacheKeys
  80.      * @return AbstractAdapter
  81.      * @throws \ErrorException
  82.      * @throws \Psr\Cache\InvalidArgumentException
  83.      */
  84.     protected function handleMasterCache($masterCacheKey, $device, $cacheKeys)
  85.     {
  86.         //
  87.         $masterCache = $this->getConfigCache();
  88.         //
  89.         if (is_callable($masterCacheKey)) {
  90.             //
  91.             $masterCacheKey = $masterCacheKey();
  92.         }
  93.         /**
  94.          * @var CacheItem $masterCacheItem
  95.          */
  96.         if ($masterCacheItem = $masterCache->getItem($masterCacheKey)) {
  97.             //
  98.             $masterCacheData = unserialize(base64_decode($masterCacheItem->get()));
  99.         } else {
  100.             //
  101.             $masterCacheData = [];
  102.         }
  103.         //
  104.         if (!isset($masterCacheData[$device])) {
  105.             //
  106.             $masterCacheData[$device] = [];
  107.         }
  108.         //
  109.         foreach ($cacheKeys as $cacheKey) {
  110.             //
  111.             if (!in_array($cacheKey, $masterCacheData[$device])) {
  112.                 //
  113.                 $masterCacheData[$device][] = $cacheKey;
  114.             }
  115.         }
  116.         //
  117.         $masterCache->save($masterCacheItem->set(base64_encode(serialize($masterCacheData))));
  118.         //
  119.         return $masterCache;
  120.     }
  122. }