// +---------------------------------------------------------------------- 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; } /** * 判断是否非付费会员购买会员专属商品 * @param $user * @param $pid * @return bool * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/10/30 */ public function checkVipGoodsBuy($user, $pid) { $is_vip_product = app()->make(StoreProductServices::class)->value(['id' => $pid], 'vip_product'); if ($is_vip_product == 1 && $user['is_money_level'] == 0) throw new ApiException('此商品为付费会员专属,您无权购买'); return true; } }