lanzu_api_2021-12-26/app/Service/v3/Implementations/CouponRecService.php

<?php

namespace App\Service\v3\Implementations;

use App\Model\v3\Coupon;
use App\Model\v3\CouponRec;
use App\Model\v3\GoodsActivity;
use App\Service\v3\Interfaces\CouponRecServiceInterface;
use App\Service\v3\Interfaces\CouponServiceInterface;
use App\Service\v3\Interfaces\ShopCartServiceInterface;
use Hyperf\DbConnection\Db;
use Hyperf\Redis\Redis;
use Hyperf\Utils\ApplicationContext;
use Hyperf\Di\Annotation\Inject;

class CouponRecService implements CouponRecServiceInterface
{

    /**
     * @Inject
     * @var ShopCartServiceInterface
     */
    protected $shopCartService;

    /**
     * @Inject
     * @var CouponServiceInterface
     */
    protected $couponService;

    public function do()
    {
        // TODO: Implement do() method.
    }

    public function check()
    {
        // TODO: Implement check() method.
    }

    public function undo()
    {
        // TODO: Implement undo() method.
    }

    /**
     * 获取当前订单可使用的优惠券
     * @param $totalAmount
     * @param $userId
     * @param $marketId
     * @param $type
     * @param $storeTypeIds
     * @return array
     */
    public function allForOrderOlAvailable($totalAmount, $userId, $marketId, $type, $storeTypeIds = [])
    {
        // 用户今日使用过的优惠券
        $redis = ApplicationContext::getContainer()->get(Redis::class);
        $couponTodayUsedIds = $redis->sMembers('coupon_'.date('Ymd').'_used_'.$userId);
        $currentTime = time();

        $builder = Db::table('lanzu_coupon_receive as receive')
            ->join('lanzu_coupon as coupon', 'coupon.id', '=', 'receive.coupon_id', 'inner');

        if (is_array($couponTodayUsedIds)&&!empty($couponTodayUsedIds)) {
            $builder->whereNotIn('coupon.id', $couponTodayUsedIds);
        }

        foreach ($storeTypeIds as $key => &$item) {
            $item = (string)$item;
        }

        if (!empty($storeTypeIds)) {
            $builder->whereJsonContains('coupon.category_ids', $storeTypeIds);
        }

        $builder->where(['receive.user_id' => $userId])
            ->whereIn('receive.status', [0,1])
            ->where('receive.number_remain', '>', 0)
            ->whereIn('coupon.type', [1,$type])
            ->where('coupon.full_amount', '<=', $totalAmount)
            ->where('coupon.usable_start_time', '<=', $currentTime)
            ->where('coupon.usable_end_time', '>=', $currentTime)
            ->where('coupon.usable_number', '<=', Db::raw('receive.number_remain'));

        if ($marketId) {
            $builder->whereJsonContains('coupon.market_ids', [(string)$marketId]);
        }

        return $builder->orderByRaw('coupon.discounts DESC, coupon.full_amount DESC')
            ->get()
            ->toArray();
    }

    /**
     * 用户优惠券列表
     * @param $userId
     * @param $type
     * @param int $page
     * @param int $pagesize
     * @return array
     */
    public function getListByUser($userId,$type,$page = 1,$pagesize = 5)
    {
        //查询优惠券
        $builder = CouponRec::query()->join('lanzu_coupon', 'lanzu_coupon.id', '=', 'lanzu_coupon_receive.coupon_id')->with('coupon')
            ->where([
                ['lanzu_coupon_receive.user_id' ,'=', $userId],
            ]);
        /**
         * $type unused 未使用 used 已使用 expired 已失效
         */
        switch ($type){
            case 'unused':
                $builder = $builder->where([
                        ['lanzu_coupon.usable_end_time' ,'>', time()],
                        ['lanzu_coupon_receive.number_remain' ,'>', 0]
                    ])
                    ->whereIn('lanzu_coupon_receive.status',[0,1]);
                break;
            case 'used':
                $builder = $builder->whereIn('lanzu_coupon_receive.status',[1,2]);
                break;
            case 'expired':
                $builder = $builder->where(function ($query) {
                    $query->where('lanzu_coupon.usable_end_time', '<', time());
                });
                break;
        }
        $builder = $builder->select(
                'lanzu_coupon_receive.*'
                    )
                ->orderBy('lanzu_coupon.weigh','desc');
        $paginate = $builder->paginate($pagesize);
        $couponList = $paginate->toArray();
        return ['has_more_pages' => $paginate->hasMorePages(), 'list' => $couponList['data']];
    }

    /**
     * 获取用户当前线上订单可以使用的优惠券
     * 1、所有未过期额优惠券，并且满足订单的金额要求
     * 2、筛选出其中当日使用过的优惠券
     * 3、筛选出其中活动商品不可用的优惠券（订单中有活动商品且活动商品不可使用优惠券）
     * 4、筛选出其中活动商品可用但商品的活动类型不符合优惠券活动使用类型的要求（订单中有活动商品可以用优惠券，但是活动类型type和优惠券中的available活动类型不可用）
     * @param $userId
     * @param $marketId
     */
    public function allForOnlineOrderAvailable($userId, $marketId)
    {
        // 获取购物车数据
        $carts = $this->shopCartService->allForUser($userId, $marketId);
        $totalAmount = $carts['total'];

        // 获取购物车中商品和店铺的类别
        $storeCategoryIds = []; // 商户类型
        $goodsCategoryIds = []; // 商品类型
        $hasActivityGoodsCannotUse = false; // 购物车中是否有不可使用优惠券的活动商品
        $goodsActivityTypes = []; // 活动商品的类型集合
        foreach ($carts['store_lists'] as $key => &$cart) {

            // 商户类型
            if (isset($cart['store']['category_id']) && $cart['store']['category_id']) {
                array_push($storeCategoryIds, $cart['store']['category_id']);
            }

            if (isset($cart['shopping_cart']) && is_array($cart['shopping_cart'])) {
                foreach ($cart['shopping_cart'] as $key2 => &$goods) {
                    // 商品类型
                    if (isset($goods['goods']['category_id']) && $goods['goods']['category_id']) {
                        array_push($goodsCategoryIds, $goods['goods']['category_id']);
                    }
                    // 活动商品不可使用优惠券的情况
                    if ($goods['activity_type'] == 2 && $goods['goods']['can_use_coupon'] != 1) {
                        $hasActivityGoodsCannotUse = true;
                    }
                    // 活动商品类型集合
                    if ($goods['activity_type'] == 2) {
                        array_merge($goodsActivityTypes, [$goods['goods']['type']]);
                    }
                }
            }
        }
        $categoryIds = array_merge($storeCategoryIds, $goodsCategoryIds);

        $coupon = ApplicationContext::getContainer()->get(Coupon::class);
        $couponRec = ApplicationContext::getContainer()->get(CouponRec::class);
        $couponTable = $coupon->getTable();
        $receiveTable = $couponRec->getTable();

        $currentTime = time();

        // 获取用户已领取的优惠券，同时是在使用期内的优惠券
        $builder = $couponRec->with('coupon')
            ->select("{$receiveTable}.*")
            ->join($couponTable, "{$couponTable}.id", "=", "{$receiveTable}.coupon_id")
            ->where("{$receiveTable}.user_id", $userId)
            ->where("{$receiveTable}.number_remain", ">", 0)
            ->whereIn("{$receiveTable}.status", [0,1])
            ->where("{$couponTable}.usable_start_time", "<=", $currentTime)
            ->where("{$couponTable}.usable_end_time", ">=", $currentTime);

        if (!empty($marketId)) { # 市场限制
            $builder->where(function ($query) use ($marketId, $couponTable) {
                return $query->whereJsonContains("{$couponTable}.market_ids", [(string)$marketId])
                    ->orWhereJsonLength("{$couponTable}.market_ids", '=', 0);
            });
        }

        if (!empty($categoryIds)) { # 分类限制
            $builder->where(function ($query) use ($categoryIds, $couponTable) {
                return $query->whereJsonContains("{$couponTable}.category_ids", $categoryIds)
                    ->orWhereJsonLength("{$couponTable}.category_ids", '=', 0);
            });
        }

        $couponReceives = $builder->orderByRaw("{$couponTable}.usable_end_time ASC")->get();

        $available = [];
        $notAvailable = [];

        // 有活动商品不可用优惠券，全部都不可用了
        if ($hasActivityGoodsCannotUse) {
            $notAvailable = $couponReceives;
            foreach ($notAvailable as $key => &$item) {
                $item['not_available_reason'] = '活动不可用';
            }
            $couponReceives = [];
        }

        // 循环摘出失效不可用的优惠券
        foreach ($couponReceives as $key => &$item) {

            // 不满订单金额
            if ($item['coupon']['full_amount'] > $totalAmount) {
                $item['not_available_reason'] = '差'.bcsub($item['coupon']['full_amount'], $totalAmount, 2).'元';
                array_push($notAvailable, $item);
                continue;
            }

            // 今日已使用
            $todayUsedCouponIds = $this->couponService->allTodayCouponUsed($userId);
            if (in_array($item['coupon']['id'], $todayUsedCouponIds)) {
                $item['not_available_reason'] = '今日已使用';
                array_push($notAvailable, $item);
                continue;
            }

            // 活动商品可用，校验对应的优惠券可使用活动类型
            $intersects = array_intersect($goodsActivityTypes, (array)$item['activity_available']); # 所有活动商品的活动类型和优惠券的可用活动类型求交集
            $canUseByTypes = array_diff($goodsActivityTypes, $intersects); # 所有活动商品的活动类型和上述交集求差集，如果为空则是可以用的，否则说明前者中有后者不能用的活动类型
            if (!empty($canUseByTypes)) {
                $item['not_available_reason'] = '活动不可用';
                array_push($notAvailable, $item);
                continue;
            }

            $item['not_available_reason'] = '';
            array_push($available, $item);
        }

        return ['available' => $available, 'not_available' => $notAvailable];

    }

    /**
     * @param $userId
     * @return mixed
     */
    public function statistics($userId)
    {
        //未使用
        $res['unused'] = 0;
        //已使用
        $res['used'] = 0;
        //已过期
        $res['expired'] = 0;
        $coupons = CouponRec::query()
            ->with('coupon')
            ->where('user_id',$userId)
            ->get();
        foreach ($coupons as $coupon){
            if($coupon->coupon->usable_end_time < time()){
                $res['expired'] += $coupon->number_remain;
            }else{
                $res['unused'] += $coupon->number_remain;
            }
            $res['used'] += $coupon->used_num;
        }
        return $res;
    }
}