// +---------------------------------------------------------------------- declare (strict_types=1); namespace app\api\model; use app\api\model\Coupon as CouponModel; use app\api\service\User as UserService; use app\common\enum\coupon\ApplyRange as ApplyRangeEnum; use app\common\enum\coupon\CouponType as CouponTypeEnum; use app\common\enum\coupon\TypeCase; use app\common\library\helper; use app\common\model\UserCoupon as UserCouponModel; use cores\exception\BaseException; use think\db\exception\DbException; /** * 用户优惠券模型 * Class UserCoupon * @package app\api\model */ class UserCoupon extends UserCouponModel { /** * 隐藏字段 * @var array */ protected $hidden = [ 'store_id', 'create_time', 'update_time' ]; /** * 获取用户优惠券列表 * @param int $userId * @param array $param * @return \think\Paginator * @throws DbException */ public function getList(int $userId, array $param): \think\Paginator { $filter = $this->getFilter($param); return $this->where($filter) ->where('user_id', '=', $userId) ->paginate(); } /** * 检索查询条件 * @param array $param * @return array */ private function getFilter(array $param = []): array { // 设置默认查询参数 $params = $this->setQueryDefaultValue($param, [ 'dataType' => 'all', // all:全部 isUsable:可用的 isExpire:已过期 isUse:已使用 'amount' => null, // 订单消费金额 ]); // 检索列表类型 $filter = []; // 可用的优惠券 if ($params['dataType'] === 'isUsable') { $filter[] = ['is_use', '=', 0]; $filter[] = ['is_expire', '=', 0]; $filter[] = ['start_time', '<=', time()]; $filter[] = ['end_time', '>', time()]; } // 未使用的优惠券 if ($params['dataType'] === 'isUnused') { $filter[] = ['is_use', '=', 0]; $filter[] = ['is_expire', '=', 0]; $filter[] = ['end_time', '>', time()]; } // 已过期的优惠券 if ($params['dataType'] === 'isExpire') { $filter[] = ['is_expire', '=', 1]; } // 已使用的优惠券 if ($params['dataType'] === 'isUse') { $filter[] = ['is_use', '=', 1]; } // 订单消费金额 $params['amount'] > 0 && $filter[] = ['min_price', '<=', $params['amount']]; return $filter; } /** * 获取用户优惠券总数量(可用) * @param int $userId * @return int */ public function getCount(int $userId): int { return $this->where('user_id', '=', $userId) ->where('is_use', '=', 0) ->where('is_expire', '=', 0) ->where('end_time', '>', time()) ->count(); } /** * 获取用户优惠券ID集 * @param int $userId * @return array */ public function getUserCouponIds(int $userId): array { return $this->where('user_id', '=', $userId)->column('coupon_id'); } /** * 领取优惠券 * @param int $couponId 优惠券ID * @return bool * @throws BaseException */ public function receive(int $couponId): bool { // 当前用户ID $userId = UserService::getCurrentLoginUserId(true); // 获取优惠券信息 $couponInfo = Coupon::detail($couponId); // 验证优惠券是否可领取 if (!$this->checkReceive($userId, $couponInfo)) { return false; } // 添加领取记录 return $this->add($userId, $couponInfo); } public function giveReceive(int $couponId, int $userId): bool { // 获取优惠券信息 $couponInfo = Coupon::detail($couponId); // 验证优惠券是否可领取 if (!$this->checkReceive($userId, $couponInfo)) { return false; } // 添加领取记录 return $this->add($userId, $couponInfo); } /** * 验证优惠券是否可领取 * @param int $userId 当前用户ID * @param CouponModel $couponInfo 优惠券详情 * @return bool */ private function checkReceive(int $userId, CouponModel $couponInfo): bool { if (empty($couponInfo)) { $this->error = '当前优惠券不存在'; return false; } // 验证优惠券状态是否可领取 $model = new CouponModel; if (!$model->checkReceive($couponInfo)) { $this->error = $model->getError() ?: '优惠券状态不可领取'; return false; } // 验证当前用户是否已领取 if (static::checktUserCoupon($couponInfo['coupon_id'], $userId)) { $this->error = '当前用户已领取该优惠券'; return false; } return true; } /** * 订单结算优惠券列表 * @param int $userId 用户id * @param float $orderPayPrice 订单商品总金额 * @param int $couponType * @return array * @throws DbException */ public static function getUserCouponList(int $userId, float $orderPayPrice, int $couponType = TypeCase::SHOP): array { // 判断订单商品总金额不能为1分 if ($orderPayPrice <= 0.01) { return []; } // 获取用户可用的优惠券列表 $list = (new static)->getList($userId, ['dataType' => 'isUsable', 'amount' => $orderPayPrice, 'coupon_case' => $couponType]); $data = $list->isEmpty() ? [] : $list->toArray()['data']; foreach ($data as &$item) { // 计算最大能折扣的金额 if ($item['coupon_type'] == CouponTypeEnum::DISCOUNT) { $reducePrice = helper::bcmul($orderPayPrice, $item['discount'] / 10); $item['reduced_price'] = helper::bcsub($orderPayPrice, $reducePrice); } else { $item['reduced_price'] = $item['reduce_price']; } } // 根据折扣金额排序并返回 return !empty($data) ? array_sort($data, 'reduced_price', true) : []; } /** * 判断当前优惠券是否满足订单使用条件 * @param array $couponList * @param array $orderGoodsIds 订单商品ID集 * @return array */ public static function couponListApplyRange(array $couponList, array $orderGoodsIds): array { // 名词解释(is_apply):允许用于抵扣当前订单 foreach ($couponList as &$item) { if ($item['apply_range'] == ApplyRangeEnum::ALL) { // 1. 全部商品 $item['is_apply'] = true; } elseif ($item['apply_range'] == ApplyRangeEnum::SOME) { // 2. 指定商品, 判断订单商品是否存在可用 $applyGoodsIds = array_intersect($item['apply_range_config']['applyGoodsIds'], $orderGoodsIds); $item['is_apply'] = !empty($applyGoodsIds); } elseif ($item['apply_range'] == ApplyRangeEnum::EXCLUDE) { // 2. 排除商品, 判断订单商品是否全部都在排除行列 $excludedGoodsIds = array_intersect($item['apply_range_config']['excludedGoodsIds'], $orderGoodsIds); $item['is_apply'] = count($excludedGoodsIds) != count($orderGoodsIds); } !$item['is_apply'] && $item['not_apply_info'] = '该优惠券不支持当前商品'; } return $couponList; } /** * @notes:判断当前优惠券是否满足服务订单使用条件 * @param array $couponList * @param array $serverIds * @return array * @author: wanghousheng */ public static function couponListApplyRangeServer(array $couponList, array $serverIds): array { // 名词解释(is_apply):允许用于抵扣当前订单 foreach ($couponList as &$item) { if ($item['apply_range'] == ApplyRangeEnum::ALL) { // 1. 全部服务 $item['is_apply'] = true; } elseif ($item['apply_range'] == ApplyRangeEnum::SOME) { // 2. 指定服务, 判断订单是否存在可用 if (!empty($item['apply_range_config']['applyServerIds'])) { $applyServerIds = array_intersect($item['apply_range_config']['applyServerIds'], $serverIds); $item['is_apply'] = !empty($applyServerIds); } } !$item['is_apply'] && $item['not_apply_info'] = '该优惠券不支持当前服务'; } return $couponList; } }