* @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\OrderDetailRepository; if (!defined('_PS_VERSION_')) { exit; } class OrderDetailsService extends ShopContentAbstractService implements ShopContentServiceInterface { /** @var OrderDetailRepository */ private $orderDetailRepository; public function __construct(OrderDetailRepository $orderDetailRepository) { $this->orderDetailRepository = $orderDetailRepository; } /** * @param int $offset * @param int $limit * @param string $langIso * * @return array */ public function getContentsForFull($offset, $limit, $langIso) { $result = $this->orderDetailRepository->retrieveContentsForFull($offset, $limit, $langIso); if (empty($result)) { return []; } $this->castOrderDetails($result); return array_map(function ($item) { return [ 'action' => Config::INCREMENTAL_TYPE_UPSERT, 'collection' => Config::COLLECTION_ORDER_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->orderDetailRepository->retrieveContentsForIncremental($limit, array_column($upsertedContents, 'id'), $langIso); if (!empty($result)) { $this->castOrderDetails($result); } return parent::formatIncrementalSyncResponse(Config::COLLECTION_ORDER_DETAILS, $result, $deletedContents); } /** * @param int $offset * @param int $limit * @param string $langIso * * @return int */ public function getFullSyncContentLeft($offset, $limit, $langIso) { return $this->orderDetailRepository->countFullSyncContentLeft($offset, $limit, $langIso); } /** * @param array $orderDetails * * @return void */ private function castOrderDetails(&$orderDetails) { foreach ($orderDetails as &$orderDetail) { $orderDetail['id_order_detail'] = (int) $orderDetail['id_order_detail']; $orderDetail['id_order'] = (int) $orderDetail['id_order']; $orderDetail['product_id'] = (int) $orderDetail['product_id']; $orderDetail['product_attribute_id'] = (int) $orderDetail['product_attribute_id']; $orderDetail['product_quantity'] = (int) $orderDetail['product_quantity']; $orderDetail['unit_price_tax_incl'] = (float) $orderDetail['unit_price_tax_incl']; $orderDetail['unit_price_tax_excl'] = (float) $orderDetail['unit_price_tax_excl']; $orderDetail['refund'] = (float) $orderDetail['refund'] > 0 ? -1 * (float) $orderDetail['refund'] : 0; $orderDetail['refund_tax_excl'] = (float) $orderDetail['refund_tax_excl'] > 0 ? -1 * (float) $orderDetail['refund_tax_excl'] : 0; $orderDetail['category'] = (int) $orderDetail['category']; $orderDetail['unique_product_id'] = "{$orderDetail['product_id']}-{$orderDetail['product_attribute_id']}-{$orderDetail['iso_code']}"; $orderDetail['conversion_rate'] = (float) $orderDetail['conversion_rate']; } } }