wyyl/beike/Shop/Services/CheckoutService.php

134 lines
4.0 KiB
PHP

<?php
/**
* CheckoutService.php
*
* @copyright 2022 opencart.cn - All Rights Reserved
* @link http://www.guangdawangluo.com
* @author Edward Yang <yangjin@opencart.cn>
* @created 2022-06-30 19:37:05
* @modified 2022-06-30 19:37:05
*/
namespace Beike\Shop\Services;
use Beike\Models\Cart;
use Beike\Models\Customer;
use Beike\Repositories\CartRepo;
use Beike\Repositories\OrderRepo;
use Beike\Repositories\PluginRepo;
use Beike\Repositories\AddressRepo;
use Beike\Repositories\CountryRepo;
use Beike\Shop\Http\Resources\Checkout\PaymentMethodItem;
use Beike\Shop\Http\Resources\Checkout\ShippingMethodItem;
class CheckoutService
{
private $customer;
private $cart;
public function __construct($customer = null)
{
if (is_int($customer) || empty($customer)) {
$this->customer = current_customer();
}
if (empty($this->customer) || !($this->customer instanceof Customer)) {
throw new \Exception("购物车客户无效");
}
$this->cart = CartRepo::createCart($this->customer->id);
}
/**
* 更新结账页数据
*
* @param $requestData ['shipping_address_id'=>1, 'payment_address_id'=>2, 'shipping_method'=>'code', 'payment_method'=>'code']
* @return array
*/
public function update($requestData): array
{
$shippingAddressId = $requestData['shipping_address_id'] ?? 0;
$shippingMethodCode = $requestData['shipping_method_code'] ?? '';
$paymentAddressId = $requestData['payment_address_id'] ?? 0;
$paymentMethodCode = $requestData['payment_method_code'] ?? '';
if ($shippingAddressId) {
$this->updateShippingAddressId($shippingAddressId);
}
if ($shippingMethodCode) {
$this->updateShippingMethod($shippingMethodCode);
}
if ($paymentAddressId) {
$this->updatePaymentAddressId($shippingAddressId);
}
if ($paymentMethodCode) {
$this->updatePaymentMethod($paymentMethodCode);
}
return $this->checkoutData();
}
/**
* 确认提交订单
*/
public function confirm(): \Beike\Models\Order
{
$data = [];
return OrderRepo::createOrder($data);
}
private function updateShippingAddressId($shippingAddressId)
{
$this->cart->update(['shipping_address_id' => $shippingAddressId]);
}
private function updatePaymentAddressId($paymentAddressId)
{
$this->cart->update(['payment_address_id' => $paymentAddressId]);
}
private function updateShippingMethod($shippingMethodCode)
{
$this->cart->update(['shipping_method_code' => $shippingMethodCode]);
}
private function updatePaymentMethod($paymentMethodCode)
{
$this->cart->update(['payment_method_code' => $paymentMethodCode]);
}
/**
* 获取结账页数据
*
* @return array
*/
public function checkoutData(): array
{
$customer = $this->customer;
$addresses = AddressRepo::listByCustomer($customer);
$shipments = ShippingMethodItem::collection(PluginRepo::getShippingMethods())->jsonSerialize();
$payments = PaymentMethodItem::collection(PluginRepo::getPaymentMethods())->jsonSerialize();
$cartList = CartService::list($customer, true);
$carts = CartService::reloadData($cartList);
$data = [
'current' => [
'shipping_address_id' => $this->cart->shipping_address_id,
'shipping_method_code' => $this->cart->shipping_method_code,
'payment_address_id' => $this->cart->payment_address_id,
'payment_method_code' => $this->cart->payment_method_code,
],
'country_id' => (int)setting('system.country_id'),
'customer_id' => $customer->id ?? null,
'countries' => CountryRepo::all(),
'addresses' => $addresses,
'shipping_methods' => $shipments,
'payment_methods' => $payments,
'carts' => $carts
];
return $data;
}
}