lanzu_api_2021-12-26/app/Service/CouponRebateService.php

<?php

namespace App\Service;

use Hyperf\Di\Annotation\Inject;
use Hyperf\DbConnection\Db;
use App\Model\Coupon;
use App\Model\CouponUserRecType;
use App\Model\CouponRec;
use App\Constants\LogLabel;
use App\Commons\Log;
use Exception;

class CouponRebateService implements CouponRebateServiceInterface
{
     /**
     * @Inject
     * @var Log
     */
    protected $log;

    /**
     * 领取优惠券
     */
    public function userReceiveCoupon($params)
    {
        $userId         = $params["user_id"];
        $receiveType    = $params["receive_type"];
        $id             = $params["id"];
        $sendUserId     = $params["send_user_id"];
        $phone          = $params["phone"];
        $now            = time();
        
        // status : 0 领取成功  >0 领取失败
        $result = [
            'status'        => 1,
            'data'          => [],
            'coupon_text'   => '继续努力~'
        ];

        // 错误日志记录
        $errorData = [
            'coupon_id'     =>$id,
            'user_id'       =>$userId,
            'receiveType'   =>$receiveType,
            'sendUserId'    =>$sendUserId,
            'phone'         =>$phone
        ];

        Db::transaction( function() use ($id,$receiveType,$userId,$sendUserId,$phone,$now,&$result,&$errorData) {

        try{
            //读写锁，完全控制，性能低
            $cp   = Coupon::where('id', $id)->lockForUpdate()
                    ->select('id','title','status','inventory','inventory_use','start_time','end_time','full_amount','discounts')
                    ->first();
    
            $couponReceiveType = CouponUserRecType::where('system_coupon_user_id',$cp->id)->select('one_receive_number');

            if (env('SUB_CHANNEL') == 1) {
                $couponReceiveType->where('receive_type',$receiveType);
            }
            // 查询一次能领取的数量
            $crt = $couponReceiveType->first();
  
            $cr                        = new CouponRec;
            $cr->user_id               = $userId;
            $cr->system_coupon_user_id = $cp->id;
            $cr->order_main_id         = 0;
            $cr->receive_time          = $now;
            $cr->number                = $crt->one_receive_number;
            $cr->number_remain         = $crt->one_receive_number;
            $cr->status                = 0;
            $cr->update_time           = $now;
            $cr->receive_type          = $receiveType;
            $cr->send_user_id          = $sendUserId;
            $cr->phone                 = $phone;
        
            //如果优惠卷库存小于等于已领取的数量 或者 未在活动时间内, 则返回领取失败的优惠券
            if ( 
                $cp->status != 1
                ||
                $cp->inventory <= $cp->inventory_use
                ||
                $cp->inventory < ($cp->inventory_use+$cr->number)
                ||
                $cp->start_time > $now
                ||
                $cp->end_time < $now
                )
            {
                $result['status'] = 2;
                $result['coupon_text'] = '红包已经领完~';

                $errorData['msg'] = '优惠券已经过期或者被禁用或者已领完';
                $this->log->event(
                    LogLabel::COUPON_LOG,
                    $errorData
                );
            }else{
                // 判断是否领取过 存在记录则领取过
                $isReceive = CouponRec::select('id')
                            ->where('system_coupon_user_id',$id)
                            ->where('user_id',$userId)
                            ->exists();

                if(!$isReceive){

                    $cp->inventory_use += $cr->number;//记录已领取的数量
                   
                    if ( $cr->save() && $cp->save() ) {
                        $result['status'] = 0;
                        // $result['data'] = $cp;
                        $result['coupon_text'] = $cp['discounts'].'元红包';
                    }
                }else{
                    $errorData['msg'] = '用户已经领取了此优惠券';
                    $this->log->event(
                        LogLabel::COUPON_LOG,
                        $errorData
                    ); 
                }
            }
        } catch (Exception $e){
            $errorData['msg'] = $e->getMessage();
            $this->log->event(
                LogLabel::COUPON_LOG,
                $errorData
            ); 
        }
        });

        return $result;
    }

    public function isCouponRebate($user_id)
    {
        $res = Db::table('ims_system_coupon_user as u')
            ->leftjoin('ims_system_coupon_user_receive as r','u.id','=','r.system_coupon_user_id')
            ->where([
                ['r.user_id','=',$user_id],
                ['r.receive_type','=',4],
                ['u.active_type','=',2],
            ])
            ->select('r.id')
            ->first();
        return $res;
    }

    public function getActiveInfo()
    {
        $time = time();
        $res = Db::table('ims_system_coupon_user')
            ->where([
                ['status','=',1],
                ['active_type','=',2],
                ['start_time','<=',$time],
                ['end_time','>',$time],
            ])
            ->whereRaw('inventory > inventory_use')
            ->orderBy('addtime','desc')
            ->get();
        return $res;
    }

}