user = $user; $this->user_id = $user['user_id']; static::$cart = Cache::get('cart_' . $this->user_id) ?: []; } /** * 购物车列表 (含商品信息) */ public function getList($cartIds = null) { // 获取购物车商品列表 return $this->getOrderProductList($cartIds); } /** * 获取购物车列表 */ 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($cartIds) { // 购物车商品列表 $productList = []; // 获取购物车列表 $cartList = $this->getCartList($cartIds); if (empty($cartList)) { $this->setError('当前购物车没有商品'); return $productList; } // 购物车中所有商品id集 $productIds = array_unique(helper::getArrayColumn($cartList, 'product_id')); // 获取并格式化商品数据 $sourceData = (new ProductModel)->getListByIds($productIds, null); $sourceData = helper::arrayColumn2Key($sourceData, 'product_id'); // 供应商信息 $supplierData = []; // 格式化购物车数据列表 foreach ($cartList as $key => $item) { // 判断商品不存在则自动删除 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['product_sku_id']); $product['product_sku_id'] = $item['product_sku_id']; $product['spec_sku_id'] = $product['product_sku']['spec_sku_id']; // 商品sku不存在则自动删除 if ($product['spec_type'] == 20 && empty($product['product_sku'])) { $this->delete($key); continue; } // 商品单价 $product['product_price'] = $product['product_sku']['product_price']; // 购买数量 $product['total_num'] = $item['product_num']; // 商品总价 $product['total_price'] = bcmul($product['product_price'], $item['product_num'], 2); // 供应商 $product['shop_supplier_id'] = $item['shop_supplier_id']; $product['supplier_price'] = bcmul($product['supplier_price'], $item['product_num'], 2); $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; } /** * 获取购物车中所有商品列表 * @return array|mixed */ public function getCartProductList(){ $carts = Cache::get('cart_products_' . $this->user_id)? : []; if($carts){ return $carts; } $cartList = $this->getList([]); $carts = []; if($cartList){ foreach ($cartList as $item){ if($item['productList']){ foreach ($item['productList'] as $v){ $carts[$v['product_id']] = $v; } } } } if($carts){ Cache::set('cart_products_' . $this->user_id, $carts, rand(10, 30)); } return $carts; } 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($productId, $productNum, $productSkuId) { // 购物车商品索引 $index = "{$productId}_{$productSkuId}"; // 加入购物车后的商品数量 $cartProductNum = $productNum + (isset(static::$cart[$index]) ? static::$cart[$index]['product_num'] : 0); // 获取商品信息 $product = ProductModel::detail($productId); // 验证商品能否加入 if (!$this->checkProduct($product, $productSkuId, $cartProductNum)) { return false; } // 记录到购物车列表 static::$cart[$index] = [ 'product_id' => $productId, 'product_num' => $cartProductNum, 'product_sku_id' => $productSkuId, 'shop_supplier_id' => $product['shop_supplier_id'], 'create_time' => time() ]; Cache::delete('cart_products_' . $this->user_id); return static::$cart[$index]; } /** * 验证商品是否可以购买 */ private function checkProduct($product, $productSkuId, $cartProductNum) { // 判断商品是否下架 if (!$product || (isset($product['is_delete']) && $product['is_delete']) || (isset($product['product_status']) && $product['product_status']['value']) != 10) { $this->setError('很抱歉,商品信息不存在或已下架'); return false; } // 商品sku信息 $product['product_sku'] = ProductModel::getProductSku($product, $productSkuId); // 判断商品库存 if ($product['spec_type'] == 20 && $cartProductNum > $product['product_sku']['stock_num']) { $this->setError('很抱歉,商品库存不足'); return false; } if ($product['spec_type'] == 10 && $cartProductNum > $product['product_stock']) { $this->setError('很抱歉,商品库存不足'); return false; } // 是否是会员商品 if(count($product['grade_ids']) > 0 && $product['grade_ids'][0] != ''){ if(!in_array($this->user['grade_id'], $product['grade_ids'])){ $this->setError('很抱歉,此商品仅特定会员可购买'); return false; } } // 是否超过最大购买数 if($product['limit_num'] > 0){ $hasNum = OrderModel::getHasBuyOrderNum($this->user['user_id'], $product['product_id']); if($hasNum + $product['total_num'] > $product['limit_num']){ $this->error = "很抱歉,购买超过此商品最大限购数量"; return false; } } return true; } /** * 减少购物车中某商品数量 */ public function sub($productId, $productSkuId) { $index = "{$productId}_{$productSkuId}"; static::$cart[$index]['product_num'] > 1 && static::$cart[$index]['product_num']--; Cache::delete('cart_products_' . $this->user_id); } /** * 删除购物车中指定商品 * @param string $cartIds (支持字符串ID集) */ public function delete($cartIds) { $indexArr = array_filter(trim(strpos($cartIds, ','), ',') !== false ? explode(',', $cartIds) : [$cartIds]); foreach ($indexArr as $index) { if (isset(static::$cart[$index])) unset(static::$cart[$index]); } } /** * 获取当前用户购物车商品总数量(含件数) */ public function getTotalNum() { return helper::getArrayColumnSum(static::$cart, 'product_num'); } /** * 获取当前用户购物车商品总数量(不含件数) */ public function getProductNum() { return count(static::$cart); } /** * 析构方法 * 将cart数据保存到缓存文件 */ public function __destruct() { $this->clear !== true && Cache::set('cart_' . $this->user_id, static::$cart, 86400 * 15); } /** * 清空当前用户购物车 */ public function clearAll($cartIds = null) { if (empty($cartIds)) { $this->clear = true; Cache::delete('cart_' . $this->user_id); } else { $this->delete($cartIds); } } /** * 设置错误信息 */ private function setError($error) { empty($this->error) && $this->error = $error; } /** * 获取错误信息 */ public function getError() { return $this->error; } }