session = $session; $this->events = $events; $this->extraCosts = new Collection(); $this->instance(self::DEFAULT_INSTANCE); } /** * Set the current cart instance. * * @param string|null $instance * @return Cart */ public function instance($instance = null) { $instance = $instance ?: self::DEFAULT_INSTANCE; $this->instance = sprintf('%s.%s', 'cart', $instance); return $this; } /** * Get the current cart instance. * * @return string */ public function currentInstance() { return str_replace('cart.', '', $this->instance); } /** * Add an item to the cart. * * @param mixed $id * @param mixed $name * @param int|float $qty * @param float $price * @param array $options * @return CartItem */ public function add($id, $name = null, $qty = null, $price = null, array $options = []) { if ($this->isMulti($id)) { return array_map(function ($item) { return $this->add($item); }, $id); } $cartItem = $this->createCartItem($id, $name, $qty, $price, $options); $content = $this->getContent(); if ($content->has($cartItem->rowId)) { $cartItem->qty += $content->get($cartItem->rowId)->qty; } $content->put($cartItem->rowId, $cartItem); $this->events->dispatch('cart.added', $cartItem); $this->session->put($this->instance, $content); return $cartItem; } /** * Sets/adds an additional cost on the cart. * * @param string $name * @param float $price * @todo add in session */ public function addCost($name, $price) { $oldCost = $this->extraCosts->pull($name, 0); $this->extraCosts->put($name, $price + $oldCost); } /** * Gets an additional cost by name * * @param $name * @param int|null $decimals * @param string|null $decimalPoint * @param string|null $thousandSeparator * @return string */ public function getCost($name) { $cost = $this->extraCosts->get($name, 0); return $this->numberFormat($cost); } /** * Update the cart item with the given rowId. * * @param string $rowId * @param mixed $qty * @return CartItem */ public function update($rowId, $qty) { $cartItem = $this->get($rowId); if ($qty instanceof Buyable) { $cartItem->updateFromBuyable($qty); } elseif (is_array($qty)) { $cartItem->updateFromArray($qty); } else { $cartItem->qty = $qty; } $content = $this->getContent(); if ($rowId !== $cartItem->rowId) { $content->pull($rowId); if ($content->has($cartItem->rowId)) { $existingCartItem = $this->get($cartItem->rowId); $cartItem->setQuantity($existingCartItem->qty + $cartItem->qty); } } if ($cartItem->qty <= 0) { $this->remove($cartItem->rowId); return; } else { $content->put($cartItem->rowId, $cartItem); } $this->events->dispatch('cart.updated', $cartItem); $this->session->put($this->instance, $content); return $cartItem; } /** * Remove the cart item with the given rowId from the cart. * * @param string $rowId * @return void */ public function remove($rowId) { $cartItem = $this->get($rowId); $content = $this->getContent(); $content->pull($cartItem->rowId); $this->events->dispatch('cart.removed', $cartItem); $this->session->put($this->instance, $content); } /** * Get a cart item from the cart by its rowId. * * @param string $rowId * @return CartItem */ public function get($rowId) { $content = $this->getContent(); if ( ! $content->has($rowId)) throw new InvalidRowIDException("The cart does not contain rowId {$rowId}."); return $content->get($rowId); } /** * Destroy the current cart instance. * * @return void */ public function destroy() { $this->session->remove($this->instance); } /** * Get the content of the cart. * * @return Collection */ public function content() { if (is_null($this->session->get($this->instance))) { return new Collection(); } return $this->session->get($this->instance); } /** * Get the number of items in the cart. * * @return int|float */ public function count() { $content = $this->getContent(); return $content->sum('qty'); } /** * Get the total price of the items in the cart. * * @param int $decimals * @param string $decimalPoint * @param string $thousandSeparator * @return string */ public function total() { $content = $this->getContent(); $total = $content->reduce(function ($total, CartItem $cartItem) { return $total + ($cartItem->qty * $cartItem->priceTax); }, 0); $totalCost = $this->extraCosts->reduce(function ($total, $cost) { return $total + $cost; }, 0); $total += $totalCost; return $this->numberFormat($total); } /** * Get the total tax of the items in the cart. * * @param int $decimals * @param string $decimalPoint * @param string $thousandSeparator * @return float */ public function tax() { $content = $this->getContent(); $tax = $content->reduce(function ($tax, CartItem $cartItem) { return $tax + ($cartItem->qty * $cartItem->tax); }, 0); return $this->numberFormat($tax); } /** * Get the subtotal (total - tax) of the items in the cart. * * @param int $decimals * @param string $decimalPoint * @param string $thousandSeparator * @return float */ public function subtotal() { $content = $this->getContent(); $subTotal = $content->reduce(function ($subTotal, CartItem $cartItem) { return $subTotal + ($cartItem->qty * $cartItem->price); }, 0); return $this->numberFormat($subTotal); } /** * Search the cart content for a cart item matching the given search closure. * * @param \Closure $search * @return Collection */ public function search(Closure $search) { $content = $this->getContent(); return $content->filter($search); } /** * Associate the cart item with the given rowId with the given model. * * @param string $rowId * @param mixed $model * @return void */ public function associate($rowId, $model) { if(is_string($model) && ! class_exists($model)) { throw new UnknownModelException("The supplied model {$model} does not exist."); } $cartItem = $this->get($rowId); $cartItem->associate($model); $content = $this->getContent(); $content->put($cartItem->rowId, $cartItem); $this->session->put($this->instance, $content); } /** * Set the tax rate for the cart item with the given rowId. * * @param string $rowId * @param int|float $taxRate * @return void */ public function setTax($rowId, $taxRate) { $cartItem = $this->get($rowId); $cartItem->setTaxRate($taxRate); $content = $this->getContent(); $content->put($cartItem->rowId, $cartItem); $this->session->put($this->instance, $content); } /** * Store an the current instance of the cart. * * @param mixed $identifier * @return void */ public function store($identifier) { $content = $this->getContent(); if ($identifier instanceof InstanceIdentifier) { $identifier = $identifier->getInstanceIdentifier(); } $instance = $this->currentInstance(); if ($this->storedCartInstanceWithIdentifierExists($instance, $identifier)) { throw new CartAlreadyStoredException("A cart with identifier {$identifier} was already stored."); } $this->getConnection()->table($this->getTableName())->insert([ 'identifier' => $identifier, 'instance' => $instance, 'content' => serialize($content), 'created_at' => $this->createdAt ?: Carbon::now(), 'updated_at' => Carbon::now(), ]); $this->events->dispatch('cart.stored'); } /** * @param $identifier * * @return bool */ private function storedCartInstanceWithIdentifierExists($instance, $identifier) { return $this->getConnection()->table($this->getTableName())->where(['identifier' => $identifier, 'instance'=> $instance])->exists(); } /** * Restore the cart with the given identifier. * * @param mixed $identifier * @return void */ public function restore($identifier) { if ($identifier instanceof InstanceIdentifier) { $identifier = $identifier->getInstanceIdentifier(); } $currentInstance = $this->currentInstance(); if (!$this->storedCartInstanceWithIdentifierExists($currentInstance, $identifier)) { return; } $stored = $this->getConnection()->table($this->getTableName()) ->where(['identifier'=> $identifier, 'instance' => $currentInstance])->first(); $storedContent = unserialize(data_get($stored, 'content')); $this->instance(data_get($stored, 'instance')); $content = $this->getContent(); foreach ($storedContent as $cartItem) { $content->put($cartItem->rowId, $cartItem); } $this->events->dispatch('cart.restored'); $this->session->put($this->instance, $content); $this->instance($currentInstance); $this->createdAt = Carbon::parse(data_get($stored, 'created_at')); $this->updatedAt = Carbon::parse(data_get($stored, 'updated_at')); $this->getConnection()->table($this->getTableName())->where(['identifier' => $identifier, 'instance' => $currentInstance])->delete(); } /** * Merges the contents of another cart into this cart. * * @param mixed $identifier Identifier of the Cart to merge with. * @param bool $keepDiscount Keep the discount of the CartItems. * @param bool $keepTax Keep the tax of the CartItems. * @param bool $dispatchAdd Flag to dispatch the add events. * * @return bool */ public function merge($identifier, $keepTax = false, $dispatchAdd = true, $instance = self::DEFAULT_INSTANCE) { if (!$this->storedCartInstanceWithIdentifierExists($instance, $identifier)) { return false; } $stored = $this->getConnection()->table($this->getTableName()) ->where(['identifier'=> $identifier, 'instance'=> $instance])->first(); $storedContent = unserialize($stored->content); foreach ($storedContent as $cartItem) { $this->addCartItem($cartItem, $keepTax, $dispatchAdd); } $this->events->dispatch('cart.merged'); return true; } /** * Add an item to the cart. * * @param \Gloudemans\Shoppingcart\CartItem $item Item to add to the Cart * @param bool $keepDiscount Keep the discount rate of the Item * @param bool $keepTax Keep the Tax rate of the Item * @param bool $dispatchEvent * * @return \Gloudemans\Shoppingcart\CartItem The CartItem */ public function addCartItem($item, $keepTax = false, $dispatchEvent = true) { if (!$keepTax) { $item->setTaxRate($this->taxRate); } $content = $this->getContent(); if ($content->has($item->rowId)) { $item->qty += $content->get($item->rowId)->qty; } $content->put($item->rowId, $item); if ($dispatchEvent) { $this->events->dispatch('cart.adding', $item); } $this->session->put($this->instance, $content); if ($dispatchEvent) { $this->events->dispatch('cart.added', $item); } return $item; } /** * Magic method to make accessing the total, tax and subtotal properties possible. * * @param string $attribute * @return float|null */ public function __get($attribute) { if($attribute === 'total') { return $this->total(); } if($attribute === 'tax') { return $this->tax(); } if($attribute === 'subtotal') { return $this->subtotal(); } return null; } /** * Get the carts content, if there is no cart content set yet, return a new empty Collection * * @return Collection */ protected function getContent() { $content = $this->session->has($this->instance) ? $this->session->get($this->instance) : new Collection; return $content; } /** * Create a new CartItem from the supplied attributes. * * @param mixed $id * @param mixed $name * @param int|float $qty * @param float $price * @param array $options * @return CartItem */ private function createCartItem($id, $name, $qty, $price, array $options) { if ($id instanceof Buyable) { $cartItem = CartItem::fromBuyable($id, $qty ?: []); $cartItem->setQuantity($name ?: 1); $cartItem->associate($id); } elseif (is_array($id)) { $cartItem = CartItem::fromArray($id); $cartItem->setQuantity($id['qty']); } else { $cartItem = CartItem::fromAttributes($id, $name, $price, $options); $cartItem->setQuantity($qty); } $cartItem->setTaxRate(config('cart.tax')); return $cartItem; } /** * Check if the item is a multidimensional array or an array of Buyables. * * @param mixed $item * @return bool */ private function isMulti($item) { if ( ! is_array($item)) return false; return is_array(head($item)) || head($item) instanceof Buyable; } /** * @param $identifier * @return bool */ private function storedCartWithIdentifierExists($identifier) { return $this->getConnection()->table($this->getTableName())->where('identifier', $identifier)->exists(); } /** * Get the database connection. * * @return Connection */ private function getConnection() { $connectionName = $this->getConnectionName(); return app(DatabaseManager::class)->connection($connectionName); } /** * Get the database table name. * * @return string */ private function getTableName() { return 'shopping_cart'; } /** * Get the database connection name. * * @return string */ private function getConnectionName() { $connection = config('cart.database.connection'); return is_null($connection) ? config('database.default') : $connection; } /** * Get the Formated number * * @param $value * @param $decimals * @param $decimalPoint * @param $thousandSeparator * @return string */ private function numberFormat($value) { $decimals = is_null(config('cart.format.decimals')) ? 2 : config('cart.format.decimals'); $decimalPoint = is_null(config('cart.format.decimal_point')) ? '.' : config('cart.format.decimal_point'); $thousandSeparator = ''; return number_format($value, $decimals, $decimalPoint, $thousandSeparator); } }