sarga/packages/Webkul/Checkout/src/Cart.php

<?php

namespace Webkul\Checkout;

use Carbon\Carbon;
use Webkul\Checkout\Repositories\CartRepository;
use Webkul\Checkout\Repositories\CartItemRepository;
use Webkul\Checkout\Repositories\CartAddressRepository;
use Webkul\Customer\Repositories\CustomerRepository;
use Webkul\Product\Repositories\ProductRepository;
use Webkul\Checkout\Models\CartPayment;

/**
 * Facade for all the methods to be implemented in Cart.
 *
 * @author    Prashant Singh <prashant.singh852@webkul.com>
 * @author    Jitendra Singh <jitendra@webkul.com>
 * @copyright 2018 Webkul Software Pvt Ltd (http://www.webkul.com)
 */
class Cart {

    /**
     * CartRepository model
     *
     * @var mixed
     */
    protected $cart;

    /**
     * CartItemRepository model
     *
     * @var mixed
     */
    protected $cartItem;

    /**
     * CustomerRepository model
     *
     * @var mixed
     */
    protected $customer;

    /**
     * CartAddressRepository model
     *
     * @var mixed
     */
    protected $cartAddress;

    /**
     * ProductRepository model
     *
     * @var mixed
     */
    protected $product;

    /**
     * Create a new controller instance.
     *
     * @param  Webkul\Checkout\Repositories\CartRepository $cart
     * @param  Webkul\Checkout\Repositories\CartItemRepository $cartItem
     * @param  Webkul\Checkout\Repositories\CartAddressRepository $cartAddress
     * @param  Webkul\Customer\Repositories\CustomerRepository $customer
     * @param  Webkul\Product\Repositories\ProductRepository $product
     * @return void
     */
    public function __construct(
        CartRepository $cart,
        CartItemRepository $cartItem,
        CartAddressRepository $cartAddress,
        CustomerRepository $customer,
        ProductRepository $product)
    {
        $this->customer = $customer;

        $this->cart = $cart;

        $this->cartItem = $cartItem;

        $this->cartAddress = $cartAddress;

        $this->product = $product;
    }

    /**
     * Prepare the other data for the product to be added.
     *
     * @param integer $id
     * @param array $data
     *
     * @return array
     */
    public function prepareItemData($productId, $data)
    {
        $product = $this->product->findOneByField('id', $productId);

        unset($data['_token']);

        //Check if the product is salable
        if(!isset($data['product']) ||!isset($data['quantity'])) {
            session()->flash('error', 'Cart System Integrity Violation, Some Required Fields Missing.');

            return redirect()->back();
        } else {
            if($product->type == 'configurable' && !isset($data['super_attribute'])) {
                session()->flash('error', 'Cart System Integrity Violation, Configurable Options Not Found In Request.');

                return redirect()->back();
            }
        }

        if($product->type == 'configurable') {
            //Check if the product is salable
            $child = $this->product->findOneByField('id', $data['selected_configurable_option']);

            $parentData = [
                'sku' => $product->sku,
                'product_id' => $productId,
                'quantity' => $data['quantity'],
                'type' => 'configurable',
                'name' => $product->name,
                'price' => ($price = $child->price), //This should be price from the price helper
                'base_price' => $price,
                'total' => $price * $data['quantity'],
                'base_total' => $price * $data['quantity'],
                'weight' => ($weight = $child->weight),
                'total_weight' => $weight * $data['quantity'],
                'base_total_weight' => $weight * $data['quantity'],
            ];

            //child row data
            $childData = [
                'product_id' => $data['selected_configurable_option'],
                'quantity' => 1,
                'sku' => $child->sku,
                'type' => $child->type,
                'name' => $child->name
            ];

            return ['parent' => $parentData, 'child' => $childData];
        } else {
            $parentData = [
                'sku' => $product->sku,
                'product_id' => $productId,
                'quantity' => $data['quantity'],
                'type' => 'simple',
                'name' => $product->name,
                'price' => $product->price,
                'base_price' => $product->price,
                'total' => $product->price * $data['quantity'],
                'base_total' => $product->price * $data['quantity'],
                'weight' => $product->weight,
                'total_weight' => $product->weight * $data['quantity'],
                'base_total_weight' => $product->weight * $data['quantity'],
            ];

            // dd(['parent' => $parentData, 'child' => null]);

            return ['parent' => $parentData, 'child' => null];
        }
    }

    /**
     * Create new cart instance with the current item added.
     *
     * @param integer $id
     * @param array $data
     *
     * @return Response
     */
    public function createNewCart($id, $data)
    {
        $itemData = $this->prepareItemData($id, $data);

        $cartData['channel_id'] = core()->getCurrentChannel()->id;

        // this will auto set the customer id for the cart instances if customer is authenticated
        if(auth()->guard('customer')->check()) {
            $cartData['customer_id'] = auth()->guard('customer')->user()->id;

            $cartData['is_guest'] = 0;

            $cartData['customer_full_name'] = auth()->guard('customer')->user()->first_name .' '. auth()->guard('customer')->user()->last_name;
        } else {
            $cartData['is_guest'] = 1;
        }

        $cartData['items_count'] = 1;

        $cartData['items_qty'] = $data['quantity'];

        if($cart = $this->cart->create($cartData)) {
            $itemData['parent']['cart_id'] = $cart->id;

            if ($data['is_configurable'] == "true") {
                //parent product entry
                $itemData['parent']['additional'] = json_encode($data);
                if($parent = $this->cartItem->create($itemData['parent'])) {

                    $itemData['child']['parent_id'] = $parent->id;
                    $itemData['child']['cart_id'] = $cart->id;
                    if($child = $this->cartItem->create($itemData['child'])) {
                        session()->put('cart', $cart);

                        session()->flash('success', 'Item Added To Cart Successfully');

                        return redirect()->back();
                    }
                }

                // $cart->update(['subtotal' => $itemData['parent']['price'], 'base_sub_total' => $itemData['parent']['price']]);
                $this->collectQuantities();

                $this->collectTotals();
            } else if($data['is_configurable'] == "false") {
                if($result = $this->cartItem->create($itemData['parent'])) {
                    session()->put('cart', $cart);

                    session()->flash('success', 'Item Added To Cart Successfully');

                    return redirect()->back();
                }

                // $cart->update(['subtotal' => $itemData['parent']['price'], 'base_sub_total' => $itemData['parent']['price']]);
                $this->collectQuantities();

                $this->collectTotals();
            }
        }

        session()->flash('error', 'Some Error Occured');

        return redirect()->back();
    }

    /**
     * Returns cart
     *
     * @return Mixed
     */
    public function getCart()
    {
        if(!$cart = session()->get('cart'))
            return false;

        return $this->cart->find($cart->id);
    }

    /**
     * Method to check if the product is available and its required quantity
     * is available or not in the inventory sources.
     *
     * @param integer $id
     *
     * @return Array
     */
    public function canAddOrUpdate($itemId, $quantity)
    {
        $item = $this->cartItem->findOneByField('id', $itemId);

        $inventories = $item->product->inventories;

        $inventory_sources = $item->product->inventory_sources;

        $totalQty = 0;

        foreach($inventory_sources as $inventory_source) {
            if($inventory_source->status && $inventory_source->toArray()['pivot']['qty']) {
                $totalQty = $totalQty + $inventory_source->toArray()['pivot']['qty'];
            }
        }

        if ($quantity < 1) {
            session()->flash('warning', 'Cannot Add Or Update Lesser than 1');

            return redirect()->back();
        }

        if($quantity < $totalQty) {
            return true;
        } else {
            return false;
        }
    }

    /**
     * Add Items in a cart with some cart and item details.
     *
     * @param @id
     * @param $data
     *
     * @return void
     */
    public function add($id, $data)
    {
        $itemData = $this->prepareItemData($id, $data);

        if(session()->has('cart')) {
            $cart = session()->get('cart');

            $cartItems = $cart->items()->get();

            if(isset($cartItems)) {
                foreach($cartItems as $cartItem) {
                    if($data['is_configurable'] == "false") {

                        if($cartItem->product_id == $id) {
                            $prevQty = $cartItem->quantity;
                            $newQty = $data['quantity'];

                            $canBe = $this->canAddOrUpdate($cartItem->id, $prevQty + $newQty);

                            if($canBe == false) {
                                session()->flash('warning', 'The requested quantity is not available, please try back later.');

                                return redirect()->back();
                            }

                            $cartItem->update([
                                'quantity' => $prevQty + $newQty,
                                'total' => $cartItem->price * ($prevQty + $newQty),
                                'base_total' => $cartItem->price * ($prevQty + $newQty)
                            ]);

                            $this->collectQuantities();

                            $this->collectTotals();

                            session()->flash('success', "Product Quantity Successfully Updated");

                            return redirect()->back();
                        }
                    } else if($data['is_configurable'] == "true") {
                        if($cartItem->type == "configurable") {
                            $temp = $this->cartItem->findOneByField('parent_id', $cartItem->id);
                            if($temp->product_id == $data['selected_configurable_option']) {
                                $child = $temp->child;

                                $parent = $cartItem;
                                $parentPrice = $parent->price;

                                $prevQty = $parent->quantity;
                                $newQty = $data['quantity'];

                                $canBe = $this->canAddOrUpdate($cartItem->child->id, $prevQty + $newQty);

                                if($canBe == false) {
                                    session()->flash('warning', 'The requested quantity is not available, please try back later.');

                                    return redirect()->back();
                                }

                                $parent->update([
                                    'quantity' => $prevQty + $newQty,
                                    'total' => $parentPrice * ($prevQty + $newQty),
                                    'base_total' => $parentPrice * ($prevQty + $newQty)
                                ]);

                                $this->collectQuantities();

                                $this->collectTotals();

                                session()->flash('success', "Product Quantity Successfully Updated");

                                return redirect()->back();
                            }
                        }
                    }
                }

                if($data['is_configurable'] == "true") {
                    $parent = $cart->items()->create($itemData['parent']);

                    $itemData['child']['parent_id'] = $parent->id;

                    // $this->canAddOrUpdate($parent->child->id, $parent->quantity);

                    $cart->items()->create($itemData['child']);
                } else if($data['is_configurable'] == "false"){
                    // $this->canAddOrUpdate($parent->id, $parent->quantity);

                    $parent = $cart->items()->create($itemData['parent']);
                }

                $this->collectQuantities();

                $this->collectTotals();

                session()->flash('success', 'Item Successfully Added To Cart');

                return redirect()->back();
            } else {
                if(isset($cart)) {
                    $this->cart->delete($cart->id);
                } else {
                    $this->createNewCart($id, $data);
                }
            }
        } else {
            $this->createNewCart($id, $data);
        }
    }

    /**
     * Update the cart on
     * cart checkout page
     */
    public function update($itemIds)
    {
        if(session()->has('cart')) {
            $cart = session()->get('cart');

            $items = $cart->items;

            foreach($items as $item) {
                foreach($itemIds['qty'] as $id => $quantity) {
                    if($id == $item->id) {
                        if($item->type == "configurable") {
                            $canBe = $this->canAddOrUpdate($item->child->id, $quantity);
                        } else {
                            $canBe = $this->canAddOrUpdate($id, $quantity);
                        }

                        if($canBe == false) {
                            session()->flash('warning', 'The requested quantity is not available, please try back later.');

                            return redirect()->back();
                        }

                        $item->update(['quantity' => $quantity]);
                    }
                }
            }

            $items = $cart->items;

            session()->flash('success', 'Cart Updated Successfully');

            return redirect()->back();
        }
    }

    /**
     * Remove the item from the cart
     *
     * @return response
     */
    public function removeItem($itemId)
    {
        if(session()->has('cart')) {
            $cart = session()->get('cart');

            $items = $cart->items;

            foreach($items as $item) {
                if($item->id == $itemId) {
                    if($item->type == "configurable") {
                        $child = $item->child;

                        //delete the child first
                        $result = $this->cartItem->delete($child->id);
                        if($result)
                            $result = $this->cartItem->delete($item->id);

                        $this->collectQuantities();
                        $this->collectTotals();
                    } else if($item->type == "simple" && $item->parent_id == null){
                        $result = $this->cartItem->delete($item->id);

                        $this->collectQuantities();
                        $this->collectTotals();
                    }
                }
            }
            $countItems = $this->cart->findOneByField('id', $cart->id)->items->count();

            //delete the cart instance if no items are there
            if($countItems == 0) {
                $result = $this->cart->delete($cart->id);

                session()->forget('cart');
            } else {
                session()->forget('cart');

                session()->put('cart', $this->cart->findOneByField('id', $cart->id));
            }

            if ($result) {
                session()->flash('sucess', 'Item Successfully Removed From Cart');
            } else {
                session()->flash('error', 'Item Cannot Be Removed From Cart');
            }
        }
        return redirect()->back();
    }

    /**
     * Returns cart
     *
     * @return Mixed
     */
    public function getItemAttributeOptionDetails($item)
    {
        $data = [];

        foreach($item->product->super_attributes as $attribute) {
            $option = $attribute->options()->where('id', $item->child->{$attribute->code})->first();
            $data['attributes'][$attribute->code] = [
                'attribute_name' => $attribute->name,
                'option_label' => $option->label,
            ];
        }

        return $data;
    }

    /**
     * Save customer address
     *
     * @return Mixed
     */
    public function saveCustomerAddress($data)
    {
        if(!$cart = $this->getCart())
            return false;

        $billingAddress = $data['billing'];
        $shippingAddress = $data['shipping'];
        $billingAddress['cart_id'] = $shippingAddress['cart_id'] = $cart->id;

        if($billingAddressModel = $cart->biling_address) {
            $this->cartAddress->update($billingAddress, $billingAddressModel->id);

            if($shippingAddress = $cart->shipping_address) {
                if(isset($billingAddress['use_for_shipping']) && $billingAddress['use_for_shipping']) {
                    $this->cartAddress->update($billingAddress, $shippingAddress->id);
                } else {
                    $this->cartAddress->update($shippingAddress, $shippingAddress->id);
                }
            } else {
                if(isset($billingAddress['use_for_shipping']) && $billingAddress['use_for_shipping']) {
                    $this->cartAddress->create(array_merge($billingAddress, ['address_type' => 'shipping']));
                } else {
                    $this->cartAddress->create(array_merge($shippingAddress, ['address_type' => 'shipping']));
                }
            }
        } else {
            $this->cartAddress->create(array_merge($billingAddress, ['address_type' => 'billing']));

            if(isset($billingAddress['use_for_shipping']) && $billingAddress['use_for_shipping']) {
                $this->cartAddress->create(array_merge($billingAddress, ['address_type' => 'shipping']));
            } else {
                $this->cartAddress->create(array_merge($shippingAddress, ['address_type' => 'shipping']));
            }
        }

        return true;
    }

    /**
     * Save shipping method for cart
     *
     * @param string $shippingMethodCode
     * @return Mixed
     */
    public function saveShippingMethod($shippingMethodCode)
    {
        if(!$cart = $this->getCart())
            return false;

        $cart->shipping_method = $shippingMethodCode;
        $cart->save();

        // foreach($cart->shipping_rates as $rate) {
        //     if($rate->method != $shippingMethodCode) {
        //         $rate->delete();
        //     }
        // }

        return true;
    }

    /**
     * Save payment method for cart
     *
     * @param string $payment
     * @return Mixed
     */
    public function savePaymentMethod($payment)
    {
        if(!$cart = $this->getCart())
            return false;

        if($cartPayment = $cart->payment)
            $cartPayment->delete();

        $cartPayment = new CartPayment;

        $cartPayment->method = $payment['method'];
        $cartPayment->cart_id = $cart->id;
        $cartPayment->save();

        return $cartPayment;
    }

    /**
     * Update Cart Quantities, Weight
     *
     * @return void
     */
    public function collectQuantities()
    {
        if(!$cart = $this->getCart())
            return false;

        $quantities = 0;

        foreach($cart->items as $item) {
            $quantities = $quantities + $item->quantity;
        }

        $itemCount = $cart->items->count();

        $cart->update(['items_count' => $itemCount, 'items_qty' => $quantities]);

    }

    /**
     * Updates cart totals
     *
     * @return void
     */
    public function collectTotals()
    {
        if(!$cart = $this->getCart())
            return false;

        $cart->grand_total = 0;
        $cart->base_grand_total = 0;
        $cart->sub_total = 0;
        $cart->base_sub_total = 0;
        $cart->sub_total_with_discount = 0;
        $cart->base_sub_total_with_discount = 0;

        foreach ($cart->items()->get() as $item) {
            $cart->grand_total = (float) $cart->grand_total + $item->price * $item->quantity;
            $cart->base_grand_total = (float) $cart->base_grand_total + $item->base_price * $item->quantity;

            $cart->sub_total = (float) $cart->sub_total + $item->price * $item->quantity;
            $cart->base_sub_total = (float) $cart->base_sub_total + $item->base_price * $item->quantity;
        }

        if($shipping = $cart->selected_shipping_rate) {
            $cart->grand_total = (float) $cart->grand_total + $shipping->price;
            $cart->base_grand_total = (float) $cart->base_grand_total + $shipping->base_price;
        }

        $cart->save();
    }

    /**
     * This function handles when guest has some of cart products and then logs in.
     *
     * @return Response
     */
    public function mergeCart()
    {
        if(session()->has('cart')) {
            $cart = $this->cart->findOneByField('customer_id', auth()->guard('customer')->user()->id);

            $guestCart = session()->get('cart');

            if(!isset($cart)) {
                $guestCart->update(['customer_id' => auth()->guard('customer')->user()->id]);

                session()->forget('cart');

                session()->put('cart', $guestCart);

                return redirect()->back();
            }

            $cartItems = $cart->items;

            $guestCartId = $guestCart->id;

            $guestCartItems = $this->cart->findOneByField('id', $guestCartId)->items;

            foreach($guestCartItems as $key => $guestCartItem) {
                foreach($cartItems as $cartItem) {

                    if($guestCartItem->type == "simple") {
                        if($cartItem->product_id == $guestCartItem->product_id) {
                            $prevQty = $cartItem->quantity;

                            $newQty = $guestCartItem->quantity;

                            $canBe = $this->canAddOrUpdate($cartItem->id, $prevQty + $newQty);

                            if($canBe == false) {
                                session()->flash('warning', 'The requested quantity is not available, please try back later.');

                                return redirect()->back();
                            }

                            $cartItem->update([
                                'quantity' => $prevQty + $newQty,
                                'total' => $cartItem->price * ($prevQty + $newQty),
                                'base_total' => $cartItem->price * ($prevQty + $newQty),
                                'total_weight' => $cartItem->weight * ($prevQty + $newQty),
                                'base_total_weight' => $cartItem->weight * ($prevQty + $newQty)
                            ]);

                            $guestCartItems->forget($key);
                            $this->cartItem->delete($guestCartItem->id);
                        }
                    } else if($guestCartItem->type == "configurable" && $cartItem->type == "configurable") {
                        $guestCartItemChild = $guestCartItem->child;

                        $cartItemChild = $cartItem->child;

                        if($guestCartItemChild->product_id == $cartItemChild->product_id) {
                            $prevQty = $guestCartItem->quantity;
                            $newQty = $cartItem->quantity;

                            $canBe = $this->canAddOrUpdate($cartItem->child->id, $prevQty + $newQty);

                            if($canBe == false) {
                                session()->flash('warning', 'The requested quantity is not available, please try back later.');

                                return redirect()->back();
                            }

                            $cartItem->update([
                                'quantity' => $prevQty + $newQty,
                                'total' => $cartItem->price * ($prevQty + $newQty),
                                'base_total' => $cartItem->price * ($prevQty + $newQty),
                                'total_weight' => $cartItem->weight * ($prevQty + $newQty),
                                'base_total_weight' => $cartItem->weight * ($prevQty + $newQty)
                            ]);

                            $guestCartItems->forget($key);

                            //child will be deleted first
                            $this->cartItem->delete($guestCartItemChild->id);

                            //then parent will get deleted
                            $this->cartItem->delete($guestCartItem->id);
                        }
                    }
                }
            }

            //now handle the products that are not deleted.
            foreach($guestCartItems as $guestCartItem) {

                if($guestCartItem->type == "configurable") {
                    $guestCartItem->update(['cart_id' => $cart->id]);

                    $guestCartItem->child->update(['cart_id' => $cart->id]);
                } else{
                    $guestCartItem->update(['cart_id' => $cart->id]);
                }
            }

            //delete the guest cart instance.
            $this->cart->delete($guestCartId);

            //forget the guest cart instance
            session()->forget('cart');

            //put the customer cart instance
            session()->put('cart', $cart);

            $this->collectQuantities();

            $this->collectTotals();

            return redirect()->back();
        } else {
            return redirect()->back();
        }
    }

    /**
     * Destroys the session
     * maintained for cart
     * on customer logout.
     *
     * @return response
     */
    public function destroyCart()
    {
        if(session()->has('cart')) {
            session()->forget('cart');

            return redirect()->back();
        } else {
            return redirect()->back();
        }
    }
}