* @copyright Since 2007 PrestaShop SA and Contributors * @license https://opensource.org/licenses/OSL-3.0 Open Software License (OSL 3.0) */ namespace PrestaShop\Module\PsEventbus\Service\ShopContent; use PrestaShop\Module\PsEventbus\Config\Config; use PrestaShop\Module\PsEventbus\Repository\StockRepository; if (!defined('_PS_VERSION_')) { exit; } class StocksService extends ShopContentAbstractService implements ShopContentServiceInterface { /** @var StockRepository */ private $stockRepository; public function __construct(StockRepository $stockRepository) { $this->stockRepository = $stockRepository; } /** * @param int $offset * @param int $limit * @param string $langIso * * @return array */ public function getContentsForFull($offset, $limit, $langIso) { $result = $this->stockRepository->retrieveContentsForFull($offset, $limit, $langIso); if (empty($result)) { return []; } $this->castStocks($result); return array_map(function ($item) { return [ 'action' => Config::INCREMENTAL_TYPE_UPSERT, 'collection' => Config::COLLECTION_STOCKS, 'properties' => $item, ]; }, $result); } /** * @param int $limit * @param array $upsertedContents * @param array $deletedContents * @param string $langIso * * @return array */ public function getContentsForIncremental($limit, $upsertedContents, $deletedContents, $langIso) { $result = $this->stockRepository->retrieveContentsForIncremental($limit, array_column($upsertedContents, 'id'), $langIso); if (!empty($result)) { $this->castStocks($result); } return parent::formatIncrementalSyncResponse(Config::COLLECTION_STOCKS, $result, $deletedContents); } /** * @param int $offset * @param int $limit * @param string $langIso * * @return int */ public function getFullSyncContentLeft($offset, $limit, $langIso) { return $this->stockRepository->countFullSyncContentLeft($offset, $limit, $langIso); } /** * @param array $stocks * * @return void */ private function castStocks(&$stocks) { foreach ($stocks as &$stock) { $stock['id_stock_available'] = (int) $stock['id_stock_available']; $stock['id_product'] = (int) $stock['id_product']; $stock['id_product_attribute'] = (int) $stock['id_product_attribute']; $stock['id_shop'] = (int) $stock['id_shop']; $stock['id_shop_group'] = (int) $stock['id_shop_group']; $stock['quantity'] = (int) $stock['quantity']; $stock['depends_on_stock'] = (bool) $stock['depends_on_stock']; $stock['out_of_stock'] = (bool) $stock['out_of_stock']; // https://github.com/PrestaShop/PrestaShop/commit/2a3269ad93b1985f2615d6604458061d4989f0ea#diff-e98d435095567c145b49744715fd575eaab7050328c211b33aa9a37158421ff4R2186 if (defined('_PS_VERSION_') && version_compare(_PS_VERSION_, '1.7.2.0', '>=')) { $stock['physical_quantity'] = (int) $stock['physical_quantity']; $stock['reserved_quantity'] = (int) $stock['reserved_quantity']; } } } }