<?php
/**
 * Mirasvit
 *
 * This source file is subject to the Mirasvit Software License, which is available at https://mirasvit.com/license/.
 * Do not edit or add to this file if you wish to upgrade the to newer versions in the future.
 * If you wish to customize this module for your needs.
 * Please refer to http://www.magentocommerce.com for more information.
 *
 * @category  Mirasvit
 * @package   mirasvit/module-cache-warmer
 * @version   1.11.13
 * @copyright Copyright (C) 2026 Mirasvit (https://mirasvit.com/)
 */


namespace Mirasvit\CacheWarmer\Service\Rate;

use Magento\Framework\App\CacheInterface;
use Magento\Variable\Model\VariableFactory;
use Mirasvit\CacheWarmer\Api\Data\PageInterface;
use Mirasvit\CacheWarmer\Api\Repository\PageRepositoryInterface;
use Mirasvit\CacheWarmer\Model\Config;
use Mirasvit\CacheWarmer\Service\PageService;
use Mirasvit\Core\Service\SerializeService;

class CacheFillRateService extends AbstractRate
{
    const VARIABLE_CODE = 'mst_cache_warmer_cache_fill_rate_v2';

    /**
     * @var PageService
     */
    private $pageService;

    /**
     * @var PageRepositoryInterface
     */
    private $pageRepository;

    /**
     * @var CacheInterface
     */
    private $cache;

    /**
     * CacheFillRateService constructor.
     * @param PageService $pageService
     * @param PageRepositoryInterface $pageRepository
     * @param CacheInterface $cache
     * @param VariableFactory $variableFactory
     * @param Config $config
     */
    public function __construct(
        PageService $pageService,
        PageRepositoryInterface $pageRepository,
        CacheInterface $cache,
        VariableFactory $variableFactory,
        Config $config
    ) {
        $this->pageService    = $pageService;
        $this->pageRepository = $pageRepository;
        $this->cache          = $cache;

        parent::__construct($variableFactory, $config);
    }

    /**
     * {@inheritdoc}
     */
    public function getRate()
    {
        $cached = $this->getEffectiveRate(PageInterface::STATUS_CACHED)['rate'];
        $total  = $this->getEffectiveRate()['rate'];

        if (!$total) {
            return 0;
        }
        return round($cached / $total * 100);
    }

    /**
     * @return \Mirasvit\CacheWarmer\Model\ResourceModel\Page\Collection
     */
    public function getIndicatingPages()
    {
        $identifier = 'cache_warmer_fill_rate_indicating_ids';

        $ids = $this->cache->load($identifier);

        if ($ids) {
            $ids = SerializeService::decode($ids);
            if (!$ids) {
                $ids = [];
            }
        } else {
            $collection = $this->pageRepository->getCollection();
            $collection->getSelect()
                ->limit(2000)
                ->orderRand();

            $ids = $collection->getColumnValues(PageInterface::ID);

            $this->cache->save(SerializeService::encode($ids), $identifier, [], 600);
        }

        $ids[] = 0;

        $collection = $this->pageRepository->getCollection();
        $collection->getSelect()->where('page_id IN(' . implode(',', $ids) . ')');

        return $collection;
    }

    /**
     * {@inheritdoc}
     */
    public function saveToHistory($rate)
    {
        return parent::saveRateToHistory($rate, self::VARIABLE_CODE);
    }

    /**
     * {@inheritdoc}
     */
    public function getHistory()
    {
        return parent::getRateHistory(self::VARIABLE_CODE);
    }

    /**
     * @param string $status
     * @return int
     */
    public function getPagesCountByStatus($status)
    {
        return $this->pageRepository->getCollection()
            ->addFieldToFilter(PageInterface::STATUS, $status)
            ->getSize();
    }

    public function getEffectiveRate(?string $status = null)
    {
        $resource   = $this->pageRepository->getCollection()->getResource();
        $connection = $resource->getConnection();

        $select = $connection->select()->from(
            $resource->getTable(PageInterface::TABLE_NAME),
            [
                'rate'  => new \Zend_Db_Expr('SUM(' . PageInterface::POPULARITY . ' + 1)'),
                'count' => new \Zend_Db_Expr('COUNT(' . PageInterface::ID . ')')
            ]
        );

        if ($status) {
            $select->where(PageInterface::STATUS . ' = "' . $status . '"');
        }

        $result = $connection->fetchAssoc($select);

        return empty($result) ? ['rate' => 0, 'count' => 0] : array_values($result)[0];
    }
}