* @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\CarrierDetailRepository; if (!defined('_PS_VERSION_')) { exit; } class CarrierDetailsService extends ShopContentAbstractService implements ShopContentServiceInterface { /** @var CarrierDetailRepository */ private $carrierDetailRepository; public function __construct(CarrierDetailRepository $carrierDetailRepository) { $this->carrierDetailRepository = $carrierDetailRepository; } /** * @param int $offset * @param int $limit * @param string $langIso * * @return array */ public function getContentsForFull($offset, $limit, $langIso) { $result = $this->carrierDetailRepository->retrieveContentsForFull($offset, $limit, $langIso); if (empty($result)) { return []; } $this->castCarrierDetails($result); return array_map(function ($item) { return [ 'action' => Config::INCREMENTAL_TYPE_UPSERT, 'collection' => Config::COLLECTION_CARRIER_DETAILS, '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->carrierDetailRepository->retrieveContentsForIncremental($limit, array_column($upsertedContents, 'id'), $langIso); if (!empty($result)) { $this->castCarrierDetails($result); } return parent::formatIncrementalSyncResponse(Config::COLLECTION_CARRIER_DETAILS, $result, $deletedContents); } /** * @param int $offset * @param int $limit * @param string $langIso * * @return int */ public function getFullSyncContentLeft($offset, $limit, $langIso) { return $this->carrierDetailRepository->countFullSyncContentLeft($offset, $limit, $langIso); } /** * @param array $carrierDetails * * @return void */ private function castCarrierDetails(&$carrierDetails) { foreach ($carrierDetails as &$carrierDetail) { $carrierDetail['id_reference'] = (string) $carrierDetail['id_reference']; $carrierDetail['id_zone'] = (string) $carrierDetail['id_zone']; $carrierDetail['id_range'] = (string) $carrierDetail['id_range']; $carrierDetail['id_carrier_detail'] = (string) $carrierDetail['id_range']; // same value as id_range $carrierDetail['shipping_method'] = (string) $carrierDetail['shipping_method']; $carrierDetail['delimiter1'] = (float) $carrierDetail['delimiter1']; $carrierDetail['delimiter2'] = (float) $carrierDetail['delimiter2']; $carrierDetail['country_ids'] = (string) $carrierDetail['country_ids']; $carrierDetail['state_ids'] = (string) $carrierDetail['state_ids']; $carrierDetail['price'] = (float) $carrierDetail['price']; } } }