<?php
|
|
namespace app\api\model\plus\repair;
|
|
use app\api\model\order\Order as OrderModel;
|
use think\facade\Cache;
|
use app\api\model\plus\repair\Project as ProjectModel;
|
use app\common\model\supplier\Supplier as SupplierModel;
|
use app\common\library\helper;
|
use app\common\model\plus\repair\Cart as CartModel;
|
|
/**
|
* 购物车管理
|
*/
|
class Cart extends CartModel
|
{
|
// 错误信息
|
public $error = '';
|
|
/**
|
* 购物车列表 (含商品信息)
|
*/
|
public function getList($user, $cart_ids = [])
|
{
|
// 获取购物车商品列表
|
return $this->getOrderProjectList($user, $cart_ids);
|
}
|
|
/**
|
* 获取购物车列表
|
*/
|
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 getOrderProjectList($user, $cart_ids = [])
|
{
|
// 购物车列表
|
$projectList = [];
|
// 获取购物车列表
|
$model = $this;
|
if ($cart_ids) {
|
$model = $model->where('cart_id', 'in', explode(',', $cart_ids));
|
}
|
$cartList = $model->where('user_id', '=', $user['user_id'])->select();
|
if (empty($cartList)) {
|
$this->setError('当前购物车没有项目');
|
return $projectList;
|
}
|
// 购物车中所有商品id集
|
$projectIds = array_unique(helper::getArrayColumn($cartList, 'project_id'));
|
// 获取并格式化商品数据
|
$sourceData = (new ProjectModel)->getListByIds($projectIds);
|
$sourceData = helper::arrayColumn2Key($sourceData, 'project_id');
|
// 供应商信息
|
$supplierData = [];
|
// 格式化购物车数据列表
|
foreach ($cartList as $key => $item) {
|
// 判断商品不存在则自动删除
|
if (!isset($sourceData[$item['project_id']])) {
|
$this->delete($key);
|
continue;
|
}
|
// 项目信息
|
$project = clone $sourceData[$item['project_id']];
|
// 判断商品是否已删除
|
if (empty($project)) {
|
$this->delete($key);
|
continue;
|
}
|
|
// 购买数量
|
$project['total_num'] = $item['total_num'];
|
// 总价
|
$project['total_price'] = bcmul($project['price'], $item['total_num'], 2);
|
// 总佣金
|
$project['total_money'] = bcmul($project['money'], $item['total_num'], 2);
|
// 供应商
|
$project['shop_supplier_id'] = $item['shop_supplier_id'];
|
//购物车id
|
$project['cart_id'] = $item['cart_id'];
|
$projectList[] = $project;
|
}
|
|
$supplierIds = array_unique(helper::getArrayColumn($projectList, 'shop_supplier_id'));
|
foreach($supplierIds as $supplierId){
|
$supplierData[] = [
|
'shop_supplier_id' => $supplierId,
|
'supplier' => SupplierModel::detail($supplierId),
|
'projectList' => $this->getProjectBySupplier($supplierId, $projectList)
|
];
|
}
|
return $supplierData;
|
}
|
|
private function getProjectBySupplier($supplierId, $projectList)
|
{
|
$result = [];
|
foreach ($projectList as $project){
|
if($project['shop_supplier_id'] == $supplierId){
|
array_push($result, $project);
|
}
|
}
|
return $result;
|
}
|
|
/**
|
* 加入购物车
|
*/
|
public function add($user, $projectId, $projectNum)
|
{
|
$model = $this;
|
// 获取信息
|
$project = ProjectModel::detail($projectId);
|
|
// 获取商品购物车信息
|
$cartDetail = $model->where('user_id', '=', $user['user_id'])
|
->where('project_id', '=', $projectId)
|
->find();
|
// 验证能否加入
|
if (!$project_price = $this->checkProject($project)) {
|
return false;
|
}
|
|
// 记录到购物车列表
|
if ($cartDetail) {
|
return $cartDetail->save(['total_num' => $cartDetail['total_num'] + $projectNum]);
|
} else {
|
return $this->save([
|
'user_id' => $user['user_id'],
|
'project_id' => $projectId,
|
'total_num' => $projectNum,
|
'join_price' => $project_price,
|
'shop_supplier_id' => $project['shop_supplier_id'],
|
'app_id' => self::$app_id,
|
]);
|
}
|
}
|
|
/**
|
* 验证是否可以下单
|
*/
|
private function checkProject($project)
|
{
|
// 判断项目
|
if (!$project) {
|
$this->setError('很抱歉，信息不存在');
|
return false;
|
}
|
|
return $project['price'];
|
}
|
|
/**
|
* 减少购物车中某商品数量
|
*/
|
public function sub($user, $projectId)
|
{
|
$cartDetail = $this->where('user_id', '=', $user['user_id'])
|
->where('project_id', '=', $projectId)
|
->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)
|
{
|
$num = $this->where('user_id', '=', $user['user_id'])->sum('total_num');
|
return $num ? $num : 0;
|
}
|
|
/**
|
* 获取当前用户购物车商品总数量(不含件数)
|
*/
|
public function getProductNum($user)
|
{
|
return $this->where('user_id', '=', $user['user_id'])->count();
|
}
|
|
/**
|
* 清空当前用户购物车
|
*/
|
public function clearAll($user, $cartIds)
|
{
|
return $this->where('user_id', '=', $user['user_id'])
|
->where('cart_id', 'in', explode(',', $cartIds))
|
->delete();
|
}
|
|
/**
|
* 设置错误信息
|
*/
|
private function setError($error)
|
{
|
empty($this->error) && $this->error = $error;
|
}
|
|
/**
|
* 获取错误信息
|
*/
|
public function getError()
|
{
|
return $this->error;
|
}
|
|
}
|
