You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
729 lines
34 KiB
729 lines
34 KiB
<?php
|
|
// +----------------------------------------------------------------------
|
|
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
|
// +----------------------------------------------------------------------
|
|
// | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
|
|
// +----------------------------------------------------------------------
|
|
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
|
// +----------------------------------------------------------------------
|
|
// | Author: CRMEB Team <admin@crmeb.com>
|
|
// +----------------------------------------------------------------------
|
|
declare (strict_types=1);
|
|
|
|
namespace app\services\order;
|
|
|
|
use app\services\activity\advance\StoreAdvanceServices;
|
|
use app\services\BaseServices;
|
|
use app\dao\order\StoreCartDao;
|
|
use app\services\activity\coupon\StoreCouponIssueServices;
|
|
use app\services\product\shipping\ShippingTemplatesServices;
|
|
use app\services\shipping\ShippingTemplatesNoDeliveryServices;
|
|
use app\services\system\SystemUserLevelServices;
|
|
use app\services\user\member\MemberCardServices;
|
|
use app\services\user\UserServices;
|
|
use app\jobs\ProductLogJob;
|
|
use crmeb\exceptions\ApiException;
|
|
use crmeb\services\CacheService;
|
|
use app\services\activity\seckill\StoreSeckillServices;
|
|
use app\services\activity\bargain\StoreBargainServices;
|
|
use app\services\activity\combination\StoreCombinationServices;
|
|
use app\services\product\product\StoreProductServices;
|
|
use app\services\product\sku\StoreProductAttrValueServices;
|
|
|
|
/**
|
|
*
|
|
* Class StoreCartServices
|
|
* @package app\services\order
|
|
* @method updateCartStatus($cartIds) 修改购物车状态
|
|
* @method getUserCartNum(int $uid, string $type, int $numType) 购物车数量
|
|
* @method deleteCartStatus(array $cartIds) 修改购物车状态
|
|
* @method array productIdByCartNum(array $ids, int $uid) 根据商品id获取购物车数量
|
|
* @method getCartList(array $where, ?int $page = 0, ?int $limit = 0, ?array $with = []) 获取用户购物车
|
|
* @method getSum($where, $field) 求和
|
|
* @method getProductTrend($time, $timeType, $str) 购物车趋势
|
|
*/
|
|
class StoreCartServices extends BaseServices
|
|
{
|
|
|
|
/**
|
|
* StoreCartServices constructor.
|
|
* @param StoreCartDao $dao
|
|
*/
|
|
public function __construct(StoreCartDao $dao)
|
|
{
|
|
$this->dao = $dao;
|
|
}
|
|
|
|
/**
|
|
* 获取某个用户下的购物车数量
|
|
* @param array $unique
|
|
* @param int $productId
|
|
* @param int $uid
|
|
* @return array
|
|
*/
|
|
public function getUserCartNums(array $unique, int $productId, int $uid)
|
|
{
|
|
$where['is_pay'] = 0;
|
|
$where['is_del'] = 0;
|
|
$where['is_new'] = 0;
|
|
$where['product_id'] = $productId;
|
|
$where['uid'] = $uid;
|
|
return $this->dao->getUserCartNums($where, $unique);
|
|
}
|
|
|
|
/**
|
|
* 获取用户下的购物车列表
|
|
* @param $uid
|
|
* @param string $cartIds
|
|
* @param bool $new
|
|
* @param array $addr
|
|
* @return array
|
|
* @throws \Psr\SimpleCache\InvalidArgumentException
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function getUserProductCartListV1($uid, $cartIds = '', bool $new, $addr = [], int $shipping_type = 1)
|
|
{
|
|
if ($new) {
|
|
$cartIds = explode(',', $cartIds);
|
|
$cartInfo = [];
|
|
foreach ($cartIds as $key) {
|
|
$info = CacheService::get($key);
|
|
if ($info) {
|
|
$cartInfo[] = $info;
|
|
}
|
|
}
|
|
} else {
|
|
$cartInfo = $this->dao->getCartList(['uid' => $uid, 'status' => 1, 'id' => $cartIds], 0, 0, ['productInfo', 'attrInfo']);
|
|
}
|
|
if (!$cartInfo) {
|
|
throw new ApiException(410233);
|
|
}
|
|
[$cartInfo, $valid, $invalid] = $this->handleCartList($uid, $cartInfo, $addr, $shipping_type);
|
|
$seckillIds = array_unique(array_column($cartInfo, 'seckill_id'));
|
|
$bargainIds = array_unique(array_column($cartInfo, 'bargain_id'));
|
|
$combinationId = array_unique(array_column($cartInfo, 'combination_id'));
|
|
$advanceId = array_unique(array_column($cartInfo, 'advance_id'));
|
|
$deduction = ['seckill_id' => $seckillIds[0] ?? 0, 'bargain_id' => $bargainIds[0] ?? 0, 'combination_id' => $combinationId[0] ?? 0, 'advance_id' => $advanceId[0] ?? 0];
|
|
return ['cartInfo' => $cartInfo, 'valid' => $valid, 'invalid' => $invalid, 'deduction' => $deduction];
|
|
}
|
|
|
|
/**
|
|
* 使用雪花算法生成订单ID
|
|
* @return string
|
|
* @throws \Exception
|
|
*/
|
|
public function getCartId($prefix)
|
|
{
|
|
$snowflake = new \Godruoyi\Snowflake\Snowflake();
|
|
//32位
|
|
if (PHP_INT_SIZE == 4) {
|
|
$id = abs((int)$snowflake->id());
|
|
} else {
|
|
$id = $snowflake->setStartTimeStamp(strtotime('2020-06-05') * 1000)->id();
|
|
}
|
|
return $prefix . $id;
|
|
}
|
|
|
|
/**
|
|
* 验证库存
|
|
* @param int $uid
|
|
* @param int $cartNum
|
|
* @param string $unique
|
|
* @param int $type
|
|
* @param $productId
|
|
* @param int $seckillId
|
|
* @param int $bargainId
|
|
* @param int $combinationId
|
|
* @return array
|
|
* @throws \Psr\SimpleCache\InvalidArgumentException
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function checkProductStock(int $uid, int $cartNum, string $unique, int $type = 0, $productId, int $seckillId, int $bargainId, int $combinationId, int $advanceId)
|
|
{
|
|
/** @var StoreProductAttrValueServices $attrValueServices */
|
|
$attrValueServices = app()->make(StoreProductAttrValueServices::class);
|
|
switch ($type) {
|
|
case 0://普通
|
|
if ($unique == '') {
|
|
$unique = $attrValueServices->value(['product_id' => $productId, 'type' => 0], 'unique');
|
|
}
|
|
/** @var StoreProductServices $productServices */
|
|
$productServices = app()->make(StoreProductServices::class);
|
|
$productInfo = $productServices->isValidProduct($productId);
|
|
if (!$productInfo) {
|
|
throw new ApiException(410295);
|
|
}
|
|
$attrInfo = $attrValueServices->getOne(['unique' => $unique, 'type' => 0]);
|
|
if (!$unique || !$attrInfo || $attrInfo['product_id'] != $productId) {
|
|
throw new ApiException(410305);
|
|
}
|
|
$nowStock = $attrInfo['stock'];//现有库存
|
|
if ($cartNum > $nowStock) {
|
|
throw new ApiException(410297, ['num' => $cartNum]);
|
|
}
|
|
if ($productInfo['is_virtual'] == 1 && $productInfo['virtual_type'] == 2 && $attrInfo['coupon_id']) {
|
|
/** @var StoreCouponIssueServices $issueCoupon */
|
|
$issueCoupon = app()->make(StoreCouponIssueServices::class);
|
|
if (!$issueCoupon->getCount(['id' => $attrInfo['coupon_id'], 'status' => 1, 'is_del' => 0])) {
|
|
throw new ApiException(410234);
|
|
}
|
|
}
|
|
$stockNum = $this->dao->value(['product_id' => $productId, 'product_attr_unique' => $unique, 'uid' => $uid, 'status' => 1], 'cart_num') ?: 0;
|
|
if ($nowStock < ($cartNum + $stockNum)) {
|
|
$surplusStock = $nowStock - $cartNum;//剩余库存
|
|
if ($surplusStock < $stockNum) {
|
|
$this->dao->update(['product_id' => $productId, 'product_attr_unique' => $unique, 'uid' => $uid, 'status' => 1], ['cart_num' => $surplusStock]);
|
|
}
|
|
}
|
|
break;
|
|
case 1://秒杀
|
|
/** @var StoreSeckillServices $seckillService */
|
|
$seckillService = app()->make(StoreSeckillServices::class);
|
|
[$attrInfo, $unique, $productInfo] = $seckillService->checkSeckillStock($uid, $seckillId, $cartNum, $unique);
|
|
break;
|
|
case 2://砍价
|
|
/** @var StoreBargainServices $bargainService */
|
|
$bargainService = app()->make(StoreBargainServices::class);
|
|
[$attrInfo, $unique, $productInfo, $bargainUserInfo] = $bargainService->checkBargainStock($uid, $bargainId, $cartNum, $unique);
|
|
break;
|
|
case 3://拼团
|
|
/** @var StoreCombinationServices $combinationService */
|
|
$combinationService = app()->make(StoreCombinationServices::class);
|
|
[$attrInfo, $unique, $productInfo] = $combinationService->checkCombinationStock($uid, $combinationId, $cartNum, $unique);
|
|
break;
|
|
case 6://预售
|
|
/** @var StoreAdvanceServices $advanceService */
|
|
$advanceService = app()->make(StoreAdvanceServices::class);
|
|
[$attrInfo, $unique, $productInfo] = $advanceService->checkAdvanceStock($uid, $advanceId, $cartNum, $unique);
|
|
break;
|
|
default:
|
|
throw new ApiException(410236);
|
|
}
|
|
if ($type && $type != 6) {
|
|
//根商品规格库存
|
|
$product_stock = $attrValueServices->value(['product_id' => $productInfo['product_id'], 'suk' => $attrInfo['suk'], 'type' => 0], 'stock');
|
|
if ($product_stock < $cartNum) {
|
|
throw new ApiException(410297, ['num' => $cartNum]);
|
|
}
|
|
}
|
|
return [$attrInfo, $unique, $bargainUserInfo['bargain_price_min'] ?? 0, $cartNum, $productInfo];
|
|
}
|
|
|
|
/**
|
|
* 添加购物车
|
|
* @param int $uid 用户UID
|
|
* @param int $product_id 商品ID
|
|
* @param int $cart_num 商品数量
|
|
* @param string $product_attr_unique 商品SKU
|
|
* @param string $type 添加购物车类型
|
|
* @param bool $new true = 立即购买，false = 加入购物车
|
|
* @param int $combination_id 拼团商品ID
|
|
* @param int $seckill_id 秒杀商品ID
|
|
* @param int $bargain_id 砍价商品ID
|
|
* @return mixed|string
|
|
* @throws \Psr\SimpleCache\InvalidArgumentException
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function setCart(int $uid, int $product_id, int $cart_num = 1, string $product_attr_unique = '', int $type = 0, bool $new = true, int $combination_id = 0, int $seckill_id = 0, int $bargain_id = 0, int $advance_id = 0)
|
|
{
|
|
if ($cart_num < 1) $cart_num = 1;
|
|
if ($type == 0) {
|
|
//检查限购
|
|
$this->checkLimit($uid, $product_id, $cart_num, $new);
|
|
}
|
|
//检测库存限量
|
|
[$attrInfo, $product_attr_unique, $bargainPriceMin, $cart_num, $productInfo] = $this->checkProductStock($uid, $cart_num, $product_attr_unique, $type, $product_id, $seckill_id, $bargain_id, $combination_id, $advance_id);
|
|
if ($new) {
|
|
/** @var StoreOrderCreateServices $storeOrderCreateService */
|
|
$storeOrderCreateService = app()->make(StoreOrderCreateServices::class);
|
|
$key = $storeOrderCreateService->getNewOrderId((string)$uid);
|
|
$info['id'] = $key;
|
|
$info['type'] = $type;
|
|
$info['seckill_id'] = $seckill_id;
|
|
$info['bargain_id'] = $bargain_id;
|
|
$info['combination_id'] = $combination_id;
|
|
$info['advance_id'] = $advance_id;
|
|
$info['product_id'] = $product_id;
|
|
$info['product_attr_unique'] = $product_attr_unique;
|
|
$info['cart_num'] = $cart_num;
|
|
$info['productInfo'] = $productInfo ? $productInfo->toArray() : [];
|
|
$info['productInfo']['attrInfo'] = $attrInfo->toArray();
|
|
$info['attrInfo'] = $attrInfo->toArray();
|
|
$info['sum_price'] = $info['productInfo']['attrInfo']['price'];
|
|
//砍价
|
|
if ($bargain_id) {
|
|
$info['truePrice'] = $bargainPriceMin;
|
|
$info['productInfo']['attrInfo']['price'] = $bargainPriceMin;
|
|
} else {
|
|
$info['truePrice'] = $info['productInfo']['attrInfo']['price'] ?? $info['productInfo']['price'] ?? 0;
|
|
}
|
|
//拼团砍价秒杀不参与会员价
|
|
if ($bargain_id || $combination_id || $seckill_id || $advance_id) {
|
|
$info['truePrice'] = $info['productInfo']['attrInfo']['price'] ?? 0;
|
|
$info['vip_truePrice'] = 0;
|
|
}
|
|
$info['trueStock'] = $info['productInfo']['attrInfo']['stock'];
|
|
$info['costPrice'] = $info['productInfo']['attrInfo']['cost'];
|
|
try {
|
|
CacheService::set($key, $info, 3600);
|
|
} catch (\Throwable $e) {
|
|
throw new ApiException($e->getMessage());
|
|
}
|
|
return $key;
|
|
} else {//加入购物车记录
|
|
ProductLogJob::dispatch(['cart', ['uid' => $uid, 'product_id' => $product_id, 'cart_num' => $cart_num]]);
|
|
$cart = $this->dao->getOne(['type' => $type, 'uid' => $uid, 'product_id' => $product_id, 'product_attr_unique' => $product_attr_unique, 'is_del' => 0, 'is_new' => 0, 'is_pay' => 0, 'status' => 1]);
|
|
if ($cart) {
|
|
$cart->cart_num = $cart_num + $cart->cart_num;
|
|
$cart->add_time = time();
|
|
$cart->save();
|
|
return $cart->id;
|
|
} else {
|
|
$add_time = time();
|
|
return $this->dao->save(compact('uid', 'product_id', 'cart_num', 'product_attr_unique', 'type', 'add_time'))->id;
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
/**移除购物车商品
|
|
* @param int $uid
|
|
* @param array $ids
|
|
* @return StoreCartDao|bool
|
|
*/
|
|
public function removeUserCart(int $uid, array $ids)
|
|
{
|
|
if (!$uid || !$ids) return false;
|
|
return $this->dao->removeUserCart($uid, $ids);
|
|
}
|
|
|
|
/**购物车 修改商品数量
|
|
* @param $id
|
|
* @param $number
|
|
* @param $uid
|
|
* @return bool|\crmeb\basic\BaseModel
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function changeUserCartNum($id, $number, $uid)
|
|
{
|
|
if (!$id || !$number || !$uid) return false;
|
|
$where = ['uid' => $uid, 'id' => $id];
|
|
$carInfo = $this->dao->getOne($where, 'product_id,combination_id,seckill_id,bargain_id,product_attr_unique,cart_num');
|
|
|
|
//购物车修改数量检查限购
|
|
/** @var StoreProductServices $productServices */
|
|
$productServices = app()->make(StoreProductServices::class);
|
|
$limitInfo = $productServices->get($carInfo->product_id, ['is_limit', 'limit_type', 'limit_num', 'min_qty']);
|
|
if ($number < $limitInfo['min_qty']) {
|
|
throw new ApiException('不能小于起购数量');
|
|
}
|
|
if ($limitInfo['is_limit']) {
|
|
if ($limitInfo['limit_type'] == 1 && $number > $limitInfo['limit_num']) {
|
|
throw new ApiException(410239, ['limit' => $limitInfo['limit_num']]);
|
|
} else if ($limitInfo['limit_type'] == 2) {
|
|
/** @var StoreOrderCartInfoServices $orderCartServices */
|
|
$orderCartServices = app()->make(StoreOrderCartInfoServices::class);
|
|
$orderPayNum = $orderCartServices->sum(['uid' => $uid, 'product_id' => $carInfo->product_id], 'cart_num');
|
|
$orderRefundNum = $orderCartServices->sum(['uid' => $uid, 'product_id' => $carInfo->product_id], 'refund_num');
|
|
$orderNum = $orderPayNum - $orderRefundNum;
|
|
if (($number + $orderNum) > $limitInfo['limit_num']) {
|
|
throw new ApiException(410240, ['limit' => $limitInfo['limit_num'], 'pay_num' => $orderNum]);
|
|
}
|
|
}
|
|
}
|
|
|
|
$stock = $productServices->getProductStock($carInfo->product_id, $carInfo->product_attr_unique);
|
|
if (!$stock) throw new ApiException(410237);
|
|
if ($stock < $number) throw new ApiException(410297, ['num' => $number]);
|
|
if ($carInfo->cart_num == $number) return true;
|
|
return $this->dao->changeUserCartNum(['uid' => $uid, 'id' => $id], (int)$number);
|
|
}
|
|
|
|
/**
|
|
* 修改购物车状态
|
|
* @param int $productId
|
|
* @param int $status 0 商品下架
|
|
*/
|
|
public function changeStatus(int $productId, $status = 0)
|
|
{
|
|
$this->dao->update($productId, ['status' => $status], 'product_id');
|
|
}
|
|
|
|
/**
|
|
* 获取购物车列表
|
|
* @param int $uid
|
|
* @param int $status
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function getUserCartList(int $uid, int $status, string $cartIds = '')
|
|
{
|
|
[$page, $limit] = $this->getPageValue();
|
|
$list = $this->dao->getCartList(['uid' => $uid, 'status' => $status, 'id' => $cartIds], $page, $limit, ['productInfo', 'attrInfo']);
|
|
[$list, $valid, $invalid] = $this->handleCartList($uid, $list);
|
|
$seckillIds = array_unique(array_column($list, 'seckill_id'));
|
|
$bargainIds = array_unique(array_column($list, 'bargain_id'));
|
|
$combinationId = array_unique(array_column($list, 'combination_id'));
|
|
$discountId = array_unique(array_column($list, 'discount_id'));
|
|
$deduction = ['seckill_id' => $seckillIds[0] ?? 0, 'bargain_id' => $bargainIds[0] ?? 0, 'combination_id' => $combinationId[0] ?? 0, 'discount_id' => $discountId[0] ?? 0];
|
|
if ($status == 1) {
|
|
return ['valid' => $list, 'invalid' => [], 'deduction' => $deduction];
|
|
} else {
|
|
return ['valid' => [], 'invalid' => $list, 'deduction' => $deduction];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 购物车重选
|
|
* @param int $cart_id
|
|
* @param int $product_id
|
|
* @param string $unique
|
|
*/
|
|
public function modifyCart(int $cart_id, int $product_id, string $unique)
|
|
{
|
|
/** @var StoreProductAttrValueServices $attrService */
|
|
$attrService = app()->make(StoreProductAttrValueServices::class);
|
|
$stock = $attrService->value(['product_id' => $product_id, 'unique' => $unique, 'type' => 0], 'stock');
|
|
if ($stock > 0) {
|
|
$this->dao->update($cart_id, ['product_attr_unique' => $unique, 'cart_num' => 1]);
|
|
} else {
|
|
throw new ApiException(410238);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 重选购物车
|
|
* @param $id
|
|
* @param $uid
|
|
* @param $productId
|
|
* @param $unique
|
|
* @param $num
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function resetCart($id, $uid, $productId, $unique, $num)
|
|
{
|
|
$res = $this->dao->getOne(['uid' => $uid, 'product_id' => $productId, 'product_attr_unique' => $unique]);
|
|
if ($res) {
|
|
$res->cart_num = $res->cart_num + $num;
|
|
$res->save();
|
|
$this->dao->delete($id);
|
|
} else {
|
|
$this->dao->update($id, ['product_attr_unique' => $unique, 'cart_num' => $num]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 首页加入购物车
|
|
* @param $uid
|
|
* @param $productId
|
|
* @param $num
|
|
* @param $unique
|
|
* @param $type
|
|
* @return mixed
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function setCartNum($uid, $productId, $num, $unique, $type)
|
|
{
|
|
if ($type == 1) {
|
|
//检查限购
|
|
$this->checkLimit($uid, $productId, $num, 0);
|
|
}
|
|
|
|
/** @var StoreProductAttrValueServices $attrValueServices */
|
|
$attrValueServices = app()->make(StoreProductAttrValueServices::class);
|
|
|
|
if ($unique == '') {
|
|
$unique = $attrValueServices->value(['product_id' => $productId, 'type' => 0], 'unique');
|
|
}
|
|
/** @var StoreProductServices $productServices */
|
|
$productServices = app()->make(StoreProductServices::class);
|
|
|
|
if (!$productServices->isValidProduct((int)$productId, 'id')) {
|
|
throw new ApiException(410295);
|
|
}
|
|
if (!($unique && $attrValueServices->getAttrvalueCount($productId, $unique, 0))) {
|
|
throw new ApiException(410305);
|
|
}
|
|
if ($productServices->getProductStock((int)$productId, $unique) < $num) {
|
|
throw new ApiException(410297, ['num' => $num]);
|
|
}
|
|
|
|
$cart = $this->dao->getOne(['uid' => $uid, 'product_id' => $productId, 'product_attr_unique' => $unique]);
|
|
if ($cart) {
|
|
if ($type == -1) {
|
|
$cart->cart_num = $num;
|
|
} elseif ($type == 0) {
|
|
$cart->cart_num = $cart->cart_num - $num;
|
|
if ($cart->cart_num < $productServices->value(['id' => $productId], 'min_qty')) {
|
|
throw new ApiException('不能小于起购数量');
|
|
}
|
|
} elseif ($type == 1) {
|
|
$cart->cart_num = $cart->cart_num + $num;
|
|
}
|
|
if ($cart->cart_num === 0) {
|
|
return $this->dao->delete($cart->id);
|
|
} else {
|
|
$cart->add_time = time();
|
|
$cart->save();
|
|
return $cart->id;
|
|
}
|
|
} else {
|
|
$data = [
|
|
'uid' => $uid,
|
|
'product_id' => $productId,
|
|
'cart_num' => $num,
|
|
'product_attr_unique' => $unique,
|
|
'type' => 0,
|
|
'add_time' => time()
|
|
];
|
|
return $this->dao->save($data)->id;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取用户购物车数量 ids 统计金额
|
|
* @param int $uid
|
|
* @param string $numType
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function getUserCartCount(int $uid, string $numType)
|
|
{
|
|
$count = 0;
|
|
$ids = [];
|
|
$sum_price = 0;
|
|
$cartList = $this->dao->getUserCartList($uid, '*', ['productInfo', 'attrInfo']);
|
|
if ($cartList) {
|
|
/** @var StoreProductServices $productServices */
|
|
$productServices = app()->make(StoreProductServices::class);
|
|
/** @var MemberCardServices $memberCardService */
|
|
$memberCardService = app()->make(MemberCardServices::class);
|
|
$vipStatus = $memberCardService->isOpenMemberCard('vip_price', false);
|
|
/** @var UserServices $user */
|
|
$user = app()->make(UserServices::class);
|
|
$userInfo = $user->getUserInfo($uid);
|
|
$discount = 100;
|
|
if (sys_config('member_func_status', 1)) {
|
|
/** @var SystemUserLevelServices $systemLevel */
|
|
$systemLevel = app()->make(SystemUserLevelServices::class);
|
|
$discount = $systemLevel->value(['id' => $userInfo['level'], 'is_del' => 0, 'is_show' => 1], 'discount') ?: 100;
|
|
}
|
|
foreach ($cartList as &$item) {
|
|
$productInfo = $item['productInfo'];
|
|
if (isset($productInfo['attrInfo']['product_id']) && $item['product_attr_unique']) {
|
|
[$truePrice, $vip_truePrice, $type] = $productServices->setLevelPrice($productInfo['attrInfo']['price'] ?? 0, $uid, $userInfo, $vipStatus, $discount, $productInfo['attrInfo']['vip_price'] ?? 0, $productInfo['is_vip'] ?? 0, true);
|
|
$item['truePrice'] = $truePrice;
|
|
$item['price_type'] = $type;
|
|
} else {
|
|
[$truePrice, $vip_truePrice, $type] = $productServices->setLevelPrice($item['productInfo']['price'] ?? 0, $uid, $userInfo, $vipStatus, $discount, $item['productInfo']['vip_price'] ?? 0, $item['productInfo']['is_vip'] ?? 0, true);
|
|
$item['truePrice'] = $truePrice;
|
|
$item['price_type'] = $type;
|
|
}
|
|
$sum_price = bcadd((string)$sum_price, (string)bcmul((string)$item['cart_num'], (string)$item['truePrice'], 4), 2);
|
|
}
|
|
$ids = array_column($cartList, 'id');
|
|
if ($numType) {
|
|
$count = count($cartList);
|
|
} else {
|
|
$count = array_sum(array_column($cartList, 'cart_num'));
|
|
}
|
|
}
|
|
return compact('count', 'ids', 'sum_price');
|
|
}
|
|
|
|
/**
|
|
* 处理购物车数据
|
|
* @param int $uid
|
|
* @param array $cartList
|
|
* @param array $addr
|
|
* @param int $shipping_type
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @author 吴汐
|
|
* @email 442384644@qq.com
|
|
* @date 2023/02/16
|
|
*/
|
|
public function handleCartList(int $uid, array $cartList, array $addr = [], int $shipping_type = 1)
|
|
{
|
|
if (!$cartList) return [$cartList, [], []];
|
|
$tempIds = [];
|
|
$userInfo = [];
|
|
$discount = 100;
|
|
if ($uid) {
|
|
/** @var UserServices $user */
|
|
$user = app()->make(UserServices::class);
|
|
$userInfo = $user->getUserInfo($uid);
|
|
//用户等级是否开启
|
|
if (sys_config('member_func_status', 1)) {
|
|
/** @var SystemUserLevelServices $systemLevel */
|
|
$systemLevel = app()->make(SystemUserLevelServices::class);
|
|
$discount = $systemLevel->value(['id' => $userInfo['level'], 'is_del' => 0, 'is_show' => 1], 'discount') ?: 100;
|
|
}
|
|
}
|
|
|
|
//付费会员是否开启，用户是否是付费会员，两个都满足，订单计算金额才会按照付费会员计算。
|
|
/** @var MemberCardServices $memberCardService */
|
|
$memberCardService = app()->make(MemberCardServices::class);
|
|
$vipStatus = $memberCardService->isOpenMemberCard('vip_price', false) && $userInfo['is_money_level'] > 0;
|
|
|
|
//不送达运费模板
|
|
if ($shipping_type == 1 && $addr) {
|
|
$cityId = (int)($addr['city_id'] ?? 0);
|
|
if ($cityId) {
|
|
foreach ($cartList as $item) {
|
|
$tempIds[] = $item['productInfo']['temp_id'];
|
|
}
|
|
$tempIds = array_unique($tempIds);
|
|
$shippingService = app()->make(\app\services\shipping\ShippingTemplatesServices::class);
|
|
$tempIds = $shippingService->getColumn([['id', 'in', $tempIds], ['no_delivery', '=', 1]], 'id');
|
|
if ($tempIds) {
|
|
/** @var ShippingTemplatesNoDeliveryServices $noDeliveryServices */
|
|
$noDeliveryServices = app()->make(ShippingTemplatesNoDeliveryServices::class);
|
|
$tempIds = $noDeliveryServices->isNoDelivery(array_unique($tempIds), $cityId);
|
|
}
|
|
}
|
|
}
|
|
|
|
/** @var StoreProductServices $productServices */
|
|
$productServices = app()->make(StoreProductServices::class);
|
|
$valid = $invalid = [];
|
|
foreach ($cartList as &$item) {
|
|
$item['productInfo']['express_delivery'] = false;
|
|
$item['productInfo']['store_mention'] = false;
|
|
if (isset($item['productInfo']['logistics'])) {
|
|
if (in_array(1, explode(',', $item['productInfo']['logistics']))) {
|
|
$item['productInfo']['express_delivery'] = true;
|
|
}
|
|
if (in_array(2, explode(',', $item['productInfo']['logistics']))) {
|
|
$item['productInfo']['store_mention'] = true;
|
|
}
|
|
}
|
|
if (isset($item['attrInfo']) && $item['attrInfo'] && (!isset($item['productInfo']['attrInfo']) || !$item['productInfo']['attrInfo'])) {
|
|
$item['productInfo']['attrInfo'] = $item['attrInfo'] ?? [];
|
|
}
|
|
$item['attrStatus'] = isset($item['productInfo']['attrInfo']['stock']) && $item['productInfo']['attrInfo']['stock'];
|
|
$item['productInfo']['attrInfo']['image'] = $item['productInfo']['attrInfo']['image'] ?? $item['productInfo']['image'] ?? '';
|
|
$item['productInfo']['attrInfo']['suk'] = $item['productInfo']['attrInfo']['suk'] ?? '已失效';
|
|
if (isset($item['productInfo']['attrInfo'])) {
|
|
$item['productInfo']['attrInfo'] = get_thumb_water($item['productInfo']['attrInfo']);
|
|
}
|
|
$item['productInfo'] = get_thumb_water($item['productInfo']);
|
|
$productInfo = $item['productInfo'];
|
|
$item['vip_truePrice'] = 0;
|
|
$is_activity = $item['seckill_id'] || $item['bargain_id'] || $item['combination_id'] || $item['advance_id'];
|
|
if (isset($productInfo['attrInfo']['product_id']) && $item['product_attr_unique']) {
|
|
$item['costPrice'] = $productInfo['attrInfo']['cost'] ?? 0;
|
|
$item['trueStock'] = $productInfo['attrInfo']['stock'] ?? 0;
|
|
$item['truePrice'] = $productInfo['attrInfo']['price'] ?? 0;
|
|
$item['sum_price'] = $productInfo['attrInfo']['price'] ?? 0;
|
|
if (!$is_activity) {
|
|
[$truePrice, $vip_truePrice, $type] = $productServices->setLevelPrice($productInfo['attrInfo']['price'] ?? 0, $uid, $userInfo, $vipStatus, $discount, $productInfo['attrInfo']['vip_price'] ?? 0, $productInfo['is_vip'] ?? 0, true);
|
|
$item['truePrice'] = $truePrice;
|
|
$item['vip_truePrice'] = $vip_truePrice;
|
|
$item['price_type'] = $type;
|
|
} else {
|
|
$item['price_type'] = 'activity';
|
|
}
|
|
} else {
|
|
$item['costPrice'] = $item['productInfo']['cost'] ?? 0;
|
|
$item['trueStock'] = $item['productInfo']['stock'] ?? 0;
|
|
$item['truePrice'] = $item['productInfo']['price'] ?? 0;
|
|
$item['sum_price'] = $item['productInfo']['price'] ?? 0;
|
|
if (!$is_activity) {
|
|
[$truePrice, $vip_truePrice, $type] = $productServices->setLevelPrice($item['productInfo']['price'] ?? 0, $uid, $userInfo, $vipStatus, $discount, $item['productInfo']['vip_price'] ?? 0, $item['productInfo']['is_vip'] ?? 0, true);
|
|
$item['truePrice'] = $truePrice;
|
|
$item['vip_truePrice'] = $vip_truePrice;
|
|
$item['price_type'] = $type;
|
|
} else {
|
|
$item['price_type'] = 'activity';
|
|
}
|
|
}
|
|
if (isset($item['status']) && $item['status'] == 0) {
|
|
$item['is_valid'] = 0;
|
|
$invalid[] = $item;
|
|
} else {
|
|
switch ($shipping_type) {
|
|
case 1:
|
|
//不送达
|
|
if (in_array($item['productInfo']['temp_id'], $tempIds) || (isset($item['productInfo']['logistics']) && !in_array(1, explode(',', $item['productInfo']['logistics'])) && $item['productInfo']['logistics'] != 0)) {
|
|
$item['is_valid'] = 0;
|
|
$invalid[] = $item;
|
|
} else {
|
|
$item['is_valid'] = 1;
|
|
$valid[] = $item;
|
|
}
|
|
break;
|
|
case 2:
|
|
//不支持到店自提
|
|
if (isset($item['productInfo']['logistics']) && $item['productInfo']['logistics'] && !in_array(2, explode(',', $item['productInfo']['logistics'])) && $item['productInfo']['logistics'] != 0) {
|
|
$item['is_valid'] = 0;
|
|
$invalid[] = $item;
|
|
} else {
|
|
$item['is_valid'] = 1;
|
|
$valid[] = $item;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
unset($item['attrInfo']);
|
|
}
|
|
return [$cartList, $valid, $invalid];
|
|
}
|
|
|
|
/**
|
|
* 检查限购
|
|
* @param $uid
|
|
* @param $product_id
|
|
* @param $num
|
|
* @param $new
|
|
* @return bool
|
|
* @throws \ReflectionException
|
|
*/
|
|
public function checkLimit($uid, $product_id, $num, $new)
|
|
{
|
|
/** @var StoreProductServices $productServices */
|
|
$productServices = app()->make(StoreProductServices::class);
|
|
/** @var StoreOrderCartInfoServices $orderCartServices */
|
|
$orderCartServices = app()->make(StoreOrderCartInfoServices::class);
|
|
|
|
$limitInfo = $productServices->get($product_id, ['is_limit', 'limit_type', 'limit_num']);
|
|
if (!$limitInfo) throw new ApiException(410294);
|
|
$limitInfo = $limitInfo->toArray();
|
|
if (!$limitInfo['is_limit']) return true;
|
|
if ($limitInfo['limit_type'] == 1) {
|
|
$cartNum = 0;
|
|
if (!$new) {
|
|
$cartNum = $this->dao->sum(['uid' => $uid, 'product_id' => $product_id], 'cart_num');
|
|
}
|
|
if (($num + $cartNum) > $limitInfo['limit_num']) {
|
|
throw new ApiException(410239, ['limit' => $limitInfo['limit_num']]);
|
|
}
|
|
} else if ($limitInfo['limit_type'] == 2) {
|
|
$cartNum = $this->dao->sum(['uid' => $uid, 'product_id' => $product_id], 'cart_num');
|
|
$orderPayNum = $orderCartServices->sum(['uid' => $uid, 'product_id' => $product_id, 'split_status' => 0], 'cart_num');
|
|
$orderRefundNum = $orderCartServices->sum(['uid' => $uid, 'product_id' => $product_id, 'split_status' => 0], 'refund_num');
|
|
$orderNum = $orderPayNum - $orderRefundNum;
|
|
if (($num + $orderNum + $cartNum) > $limitInfo['limit_num']) {
|
|
throw new ApiException(410240, ['limit' => $limitInfo['limit_num'], 'pay_num' => $orderNum]);
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
}
|
|
|