<?php
|
|
namespace app\api\model\branch;
|
|
use app\api\model\order\Order as OrderModel;
|
use think\facade\Cache;
|
use app\common\model\branch\ActivityProductPrice as ProductPriceModel;
|
use app\api\model\product\Product as ProductModel;
|
use app\common\model\supplier\Supplier as SupplierModel;
|
use app\common\library\helper;
|
use app\common\model\branch\ActivityCart as CartModel;
|
|
/**
|
* 购物车管理
|
*/
|
class ActivityCart extends CartModel
|
{
|
// 错误信息
|
public $error = '';
|
|
/**
|
* 购物车列表 (含商品信息)
|
*/
|
public function getList($user, $cart_ids = [],$activity_id=0)
|
{
|
// 获取购物车商品列表
|
return $this->getOrderProductList($user, $cart_ids,$activity_id);
|
}
|
|
/**
|
* 获取购物车列表
|
*/
|
public function getCartList($cartIds = null)
|
{
|
if (empty($cartIds)) return static::$cart;
|
$cartList = [];
|
$indexArr = (strpos($cartIds, ',') !== false) ? explode(',', $cartIds) : [$cartIds];
|
foreach ($indexArr as $index) {
|
isset(static::$cart[$index]) && $cartList[$index] = static::$cart[$index];
|
}
|
return $cartList;
|
}
|
|
/**
|
* 获取购物车中的商品列表
|
*/
|
public function getOrderProductList($user, $cart_ids = [], $activity_id)
|
{
|
$product_price_Model = new ProductPriceModel();
|
// 购物车商品列表
|
$productList = [];
|
// 获取购物车列表
|
$model = $this;
|
if ($cart_ids) {
|
$model = $model->where('cart_id', 'in', $cart_ids)->where('activity_id','=',$activity_id);
|
}
|
$cartList = $model->where(['user_id'=>$user['user_id'],'activity_id'=>$activity_id])->select();
|
if (empty($cartList)) {
|
$this->setError('当前购物车没有商品');
|
return $productList;
|
}
|
// 购物车中所有商品id集
|
$productIds = array_unique(helper::getArrayColumn($cartList, 'product_id'));
|
// 获取并格式化商品数据
|
$sourceData = (new ProductModel)->getListByIds($productIds, 10);
|
$sourceData = helper::arrayColumn2Key($sourceData, 'product_id');
|
// 供应商信息
|
$supplierData = [];
|
// 格式化购物车数据列表
|
foreach ($cartList as $key => $item) {
|
$productPrice = $product_price_Model->where(['activity_id'=>$activity_id,'product_id'=>$item['product_id'],'spec_sku_id'=>$item['spec_sku_id']])->where('is_delete', '=', 0)->find();
|
// 商品sku不存在则自动删除
|
if (empty($item['productPrice'])) {
|
$this->delete($key);
|
continue;
|
}
|
// 判断商品不存在则自动删除
|
if (!isset($sourceData[$item['product_id']])) {
|
$this->delete($key);
|
continue;
|
}
|
// 商品信息
|
$product = clone $sourceData[$item['product_id']];
|
// 判断商品是否已删除
|
if ($product['is_delete']) {
|
$this->delete($key);
|
continue;
|
}
|
// 商品sku信息
|
$product['product_sku'] = ProductModel::getProductSku($product, $item['spec_sku_id']);
|
$product['spec_sku_id'] = $item['spec_sku_id'];
|
// 商品sku不存在则自动删除
|
if (empty($product['product_sku'])) {
|
$this->delete($key);
|
continue;
|
}
|
// 商品单价
|
$product['product_price'] = $productPrice['product_new_price'];
|
// 购买数量
|
$product['total_num'] = $item['total_num'];
|
// 商品总价
|
$product['total_price'] = bcmul($product['product_price'], $item['total_num'], 2);
|
// 供应商
|
$product['shop_supplier_id'] = $item['shop_supplier_id'];
|
$product['supplier_price'] = bcmul($product['supplier_price'], $item['total_num'], 2);
|
//购物车id
|
$product['cart_id'] = $item['cart_id'];
|
$productList[] = $product->hidden(['category', 'content', 'image']);
|
}
|
$supplierIds = array_unique(helper::getArrayColumn($productList, 'shop_supplier_id'));
|
foreach($supplierIds as $supplierId){
|
$supplierData[] = [
|
'shop_supplier_id' => $supplierId,
|
'supplier' => SupplierModel::detail($supplierId),
|
'productList' => $this->getProductBySupplier($supplierId, $productList)
|
];
|
}
|
return $supplierData;
|
}
|
|
private function getProductBySupplier($supplierId, $productList)
|
{
|
$result = [];
|
foreach ($productList as $product){
|
if($product['shop_supplier_id'] == $supplierId){
|
array_push($result, $product);
|
}
|
}
|
return $result;
|
}
|
|
/**
|
* 加入购物车
|
*/
|
public function add($user, $productId, $productNum, $spec_sku_id, $activity_id=0)
|
{
|
$model = $this;
|
// 获取商品购物车信息
|
$cartDetail = $model
|
->with(['productPrice'=>function($query) use($activity_id,$spec_sku_id,$productId){
|
$query->where(['activity_id'=>$activity_id,'product_id'=>$productId,'spec_sku_id'=>$spec_sku_id,'is_delete'=>0]);
|
}])
|
->where('user_id', '=', $user['user_id'])
|
->where('activity_id', '=', $activity_id)
|
->where('product_id', '=', $productId)
|
->where('spec_sku_id', '=', $spec_sku_id)
|
->find();
|
$cartProductNum = $cartDetail ? $cartDetail['total_num'] + $productNum : $productNum;
|
// 验证商品能否加入
|
// 获取商品信息
|
$product = ProductModel::detail($productId);
|
$check = $this->checkProduct($user,$product, $spec_sku_id, $cartProductNum);
|
if (!$check) {
|
return false;
|
}
|
// 记录到购物车列表
|
if ($cartDetail) {
|
return $cartDetail->save(['total_num' => $cartDetail['total_num'] + $productNum]);
|
} else {
|
$productPrice = (new ProductPriceModel())
|
->where('activity_id', '=', $activity_id)
|
->where('product_id', '=', $productId)
|
->where('spec_sku_id', '=', $spec_sku_id)
|
->find();
|
return $this->save([
|
'user_id' => $user['user_id'],
|
'product_id' => $productId,
|
'activity_id' => $activity_id,
|
'spec_sku_id' => $spec_sku_id,
|
'total_num' => $productNum,
|
'join_price' => $productPrice['product_new_price'],
|
'shop_supplier_id' => $product['shop_supplier_id'],
|
'app_id' => self::$app_id,
|
]);
|
}
|
}
|
|
/**
|
* 验证商品是否可以购买
|
*/
|
private function checkProduct($user, $product, $spec_sku_id, $cartProductNum)
|
{
|
// 判断商品是否下架
|
if (!$product || $product['is_delete'] || $product['product_status']['value'] != 10) {
|
$this->setError('很抱歉，商品信息不存在或已下架');
|
return false;
|
}
|
// 商品sku信息
|
$product['product_sku'] = ProductModel::getProductSku($product, $spec_sku_id);
|
// 判断商品库存
|
if ($cartProductNum > $product['product_sku']['stock_num']) {
|
$this->setError('很抱歉，商品库存不足');
|
return false;
|
}
|
// 是否超过最大购买数
|
if ($product['limit_num'] > 0) {
|
$hasNum = OrderModel::getHasBuyOrderNum($user['user_id'], $product['product_id']);
|
if ($hasNum + $product['total_num'] > $product['limit_num']) {
|
$this->error = "很抱歉，购买超过此商品最大限购数量";
|
return false;
|
}
|
}
|
return true;
|
}
|
|
/**
|
* 减少购物车中某商品数量
|
*/
|
public function sub($user, $productId, $spec_sku_id, $activity_id=0)
|
{
|
$cartDetail = $this->where('user_id', '=', $user['user_id'])
|
->where('product_id', '=', $productId)
|
->where('spec_sku_id', '=', $spec_sku_id)
|
->where('activity_id', '=', $activity_id)
|
->find();
|
if ($cartDetail['total_num'] <= 1) {
|
return $cartDetail->delete();
|
} else {
|
$cartDetail->save(['total_num' => $cartDetail['total_num'] - 1]);
|
}
|
}
|
|
/**
|
* 删除购物车中指定商品
|
* @param string $cartIds (支持字符串ID集)
|
*/
|
public function setDelete($user, $cart_id)
|
{
|
return $this->where('user_id', '=', $user['user_id'])->where('cart_id', 'in', explode(',', $cart_id))->delete();
|
}
|
|
/**
|
* 获取当前用户购物车商品总数量(含件数)
|
*/
|
public function getTotalNum($user,$activity_id=0)
|
{
|
$num = $this->where(['user_id'=>$user['user_id'],'activity_id'=>$activity_id])->sum('total_num');
|
return $num ? $num : 0;
|
}
|
|
/**
|
* 获取当前用户购物车商品总数量(不含件数)
|
*/
|
public function getProductNum($user,$activity_id=0)
|
{
|
return $this->where(['user_id'=>$user['user_id'],'activity_id'=>$activity_id])->count();
|
}
|
|
/**
|
* 清空当前用户购物车
|
*/
|
public function clearAll($user, $cartIds,$activity_id)
|
{
|
return $this->where(['user_id'=>$user['user_id'],'activity_id'=>$activity_id])
|
->where('cart_id', 'in', explode(',', $cartIds))
|
->delete();
|
}
|
|
/**
|
* 设置错误信息
|
*/
|
private function setError($error)
|
{
|
empty($this->error) && $this->error = $error;
|
}
|
|
/**
|
* 获取错误信息
|
*/
|
public function getError()
|
{
|
return $this->error;
|
}
|
|
}
|
