kailin/app/Http/Controllers/Api/Lottery/Riddle.php

<?php namespace App\Http\Controllers\Api\Lottery;

use App\Http\Controllers\Api\Api;
use App\Models\Lottery\Riddle as Model;
use App\Models\Lottery\RiddleUsable;
use App\Models\Custom;
use App\Models\CustomCoupon;
use App\Models\CustomScore;
use App\Models\CustomAmount;
use App\Models\Lottery\RiddleRecord;
use App\Models\Lottery\RiddleReward as RiddleReward;
use Illuminate\Support\Facades\DB;

/**
 * 积分抽奖
 * 
 * @author 刘相欣
 * 
 * */
class Riddle extends Api{

	/**
	 * 获取抽奖配置		/api/lottery_riddle/get_detail
	 * 
	 * 
	 * */
	public function get_detail(Model $Model,Custom $Custom,RiddleReward $RiddleReward,RiddleUsable $RiddleUsable){
		// 接口验签
		// $this->verify_sign();
		// 检查登录
		$uid							= $this->checkLogin();
		// 获取客户信息
		$custom							= $Custom->getOne($uid);
		// 如果存在的话
		if( !$custom )					return json_send(['code'=>'no_login','msg'=>'请登录','data'=>['error'=>'无对应客户']]);
		// 接收参数
		$id 							= request('id',0);
		// 获取活动
		$data			                = $Model->getOne($id);
		// 如果存在的话
		if( !$data )					return json_send(['code'=>'error','msg'=>'暂无活动','data'=>$data]);
		// 奖品
		$reward 						= $RiddleReward->getListByLottery($data['id']);
		// 活动暂无奖品
		if( !$reward )					return json_send(['code'=>'error','msg'=>'活动暂未配置奖品','data'=>$data]);
		// logo
		$data['logo']					= $data['logo'] ? path_compat($data['logo']) : '';
		// 通过活动ID，查询奖品
		$data['reward_list']			= [];
		// 奖品数据
		foreach ($reward as $value) 	{
			// 奖项
			$data['reward_list'][]		= ['id'=>$value['id'],'name'=>$value['reward_name'],'img'=>$value['reward_thumb'],'reward_type'=>$value['reward_type']];
		}
		// 查询用户可用抽奖次数
        $number							= $RiddleUsable->query()->where([['custom_uid','=',$uid],['lottery_id','=',$id]])->value('number');
		// 最少为0，避免显示异常
		$data['number']				    = $number < 0 ? 0 : $number;
		// 时间处理
		$data['start_date']				= date('Y/m/d H:i',$data['start_time']);
		// 时间处理
		$data['end_date']				= date('Y/m/d H:i',$data['end_time']);
		// 返回结果
		return							json_send(['code'=>'success','msg'=>'获取成功','data'=>$data]);
	}

	/**
	 * 抽奖		/api/lottery_riddle/get_reward
	 * 
	 * */
	public function get_reward(Model $Model,Custom $Custom,RiddleRecord $RiddleRecord,RiddleReward $RiddleReward,CustomCoupon $CustomCoupon,OrderRecord $OrderRecord,CustomScore $CustomScore,RiddleUsable $RiddleUsable,CustomAmount $CustomAmount){
		// 接口验签
		// $this->verify_sign();
		// 检查登录
		$uid							= $this->checkLogin();
		// 获取活动
		$lotteryId						= request('lottery_id',0);
		// 如果存在的话
		if( !$lotteryId )				return json_send(['code'=>'error','msg'=>'请选择参与的活动','data'=>['error'=>"抽奖活动ID有误"]]);
		// 获取客户信息
		$custom							= $Custom->getOne($uid);
		// 如果存在的话
		if( !$custom )					return json_send(['code'=>'no_login','msg'=>'请登录','data'=>['error'=>'无对应客户']]);
		// 通过活动ID，查询奖品
		$data							= $Model->getOne($lotteryId);
		// 如果存在的话
		if( !$data )					return json_send(['code'=>'error','msg'=>'活动不存在或未开始','data'=>$data]);
		// 活动时间判断
		if( $data['start_time'] > time() ) return json_send(['code'=>'error','msg'=>'活动暂未开始','data'=>$data]);
		// 活动时间判断
		if( $data['end_time'] < time() ) return json_send(['code'=>'error','msg'=>'活动已结束','data'=>$data]);
		// 奖品
		$reward 						= $RiddleReward->getListByLottery($lotteryId);
		// 活动暂无奖品
		if( !$reward )					return json_send(['code'=>'error','msg'=>'活动暂未配置奖品','data'=>$data]);
        // 查询用户可用抽奖次数
        $usable							= $RiddleUsable->query()->where([['custom_uid','=',$uid],['lottery_id','=',$lotteryId]])->first();
        if (!$usable)                   return json_send(['code'=>'error','msg'=>'抽奖次数已用完','data'=>['error'=>'抽奖次数已用完']]);
        // 最少为0，避免显示异常
        $data['join_num']				= $usable['number'] < 0 ? 0 : $usable['number'];
		// 如果次数不够
		if( $data['join_num'] <= 0 )	return json_send(['code'=>'error','msg'=>'抽奖次数已用完','data'=>['error'=>'抽奖次数已用完']]);
		// 查询条件
		$map							= [['insert_time','>=',$data['start_time']],['insert_time','<=',$data['end_time']]];
		// 判断周期
		if( !empty($data['freq']) )		{
			if( $data['freq'] == 1 )	$map = [['insert_time','>=',now()->startOfDay()->getTimestamp()],['insert_time','<=',now()->endOfDay()->getTimestamp()]];
			if( $data['freq'] == 2 )	$map = [['insert_time','>=',now()->startOfWeek()->getTimestamp()],['insert_time','<=',now()->endOfWeek()->getTimestamp()]];
			if( $data['freq'] == 3 )	$map = [['insert_time','>=',now()->startOfMonth()->getTimestamp()],['insert_time','<=',now()->endOfMonth()->getTimestamp()]];
		}
		// 限制中奖则获取中奖次数
		$rewarTotal						= $data['max_reward'] ? $RiddleRecord->query()->where([['lottery_id','=',$data['id']],['custom_uid','=',$uid],['reward_id','>',0]])->where($map)->count() : 0;
		// 中奖上限以后不再中奖, 默认获取未中奖
		$rewardResult                   = ($data['max_reward'] && $rewarTotal >= $data['max_reward']) ? ['reward_list'=>$reward,'index'=>0] : $RiddleReward->getRewardResult($lotteryId);
		// 未抽中
		if( !$rewardResult )			return json_send(['code'=>'error','msg'=>'谢谢参与','data'=>['error'=>'谢谢参与']]);
		// 奖品索引
		$rewardIndex					= $rewardResult['index'];
		// 奖品列表
		$reward							= $rewardResult['reward_list'];
		// 获取奖品信息
		$rewardResult 					= $reward[$rewardIndex];
		// 是否记录结果
		$record							= ['custom_uid'=>$uid,'lottery_id'=>$lotteryId,'reward_id'=>$rewardResult['id'],'reward_name'=>$rewardResult['reward_name'],'status'=>(in_array($rewardResult['reward_type'],[4,5,6]) ? 1 : 8)];
		// 实物状态需要填写地址
		if( $rewardResult['reward_type'] == 5 ) $record['status'] = 0;
		// 组合数据，写入订单表，子表
		DB::beginTransaction();
		try{
			// 扣减次数
			$result 					= $RiddleUsable->query()->where(['lottery_id'=>$data['id'],'custom_uid'=>$uid])->update(['number'=>$usable['number']-1,'use_number'=>$usable['use_number']+1]);
			// 如果积分扣减失败
			if( !$result )				{
				// 回退数据
				DB::rollBack();
				return 					json_send(['code'=>'error','msg'=>'抽奖次数扣减失败','data'=>['error'=>'抽奖次数扣减失败']]);
			}
			// 如果存在奖品
			if( $rewardResult['id'] )	{
				// 奖品数量减少
				$result 				= $RiddleReward->edit($rewardResult['id'],['reward_total'=>DB::raw('reward_total+-1'),'lottery_id'=>$rewardResult['lottery_id']]);
				// 如果奖品数量减少失败
				if( !$result )			{
					// 回退数据
					DB::rollBack();
					// 提醒重试
					return 				json_send(['code'=>'error','msg'=>'抽奖失败，请重试','data'=>['error'=>'奖品数量扣减失败']]);
				}
			}
			// 如果是积分
			if( $rewardResult['reward_type'] == 1 ){
				// 积分大于0
				if( $rewardResult['reward_info'] > 0 ){
					// 积分发放
					$result 			= $CustomScore->trade($uid,$lotteryId,$rewardResult['reward_info'],7,3);
					// 发放失败，改为未中奖
					if( isset($result['error']) ) {
						// 回退数据
						DB::rollBack();
						// 通知重试
						return 			json_send(['code'=>'error','msg'=>'出了点小差，请重新抽奖','data'=>$result]);
					}
				}
			}
			// 优惠券，先进行发放
			if( $rewardResult['reward_type'] == 2 ){
				// 优惠券存在ID
				if( $rewardResult['reward_info'] > 0 ){
					// 积分给与
					$result 			= $CustomCoupon->giveCoupon($rewardResult['reward_info'],$uid);
					// 发放失败，改为未中奖
					if( isset($result['error']) ) {
						// 回退数据
						DB::rollBack();
						// 通知重试
						return 			json_send(['code'=>'error','msg'=>'出了点小差，请重新抽奖','data'=>$result]);
					}
				}
			}
			// 红包
			if( $rewardResult['reward_type'] == 3 ){
				// 积分大于0
				if( $rewardResult['reward_info'] > 0 ){
					// 积分发放
					$result 			= $CustomAmount->trade($uid,$lotteryId,$rewardResult['reward_info'],6,1,'下单抽奖');
					// 发放失败，改为未中奖
					if( isset($result['error']) ) {
						// 回退数据
						DB::rollBack();
						// 通知重试
						return 			json_send(['code'=>'error','msg'=>'出了点小差，请重新抽奖','data'=>$result]);
					}
				}
			}
			// 扣减数量
			$result 					= $RiddleRecord->add($record);
			// 记录失败
			if( !$result )				{
				// 回退数据
				DB::rollBack();
				// 下单失败提示
				return					json_send(['code'=>'error','msg'=>'抽奖失败，请重试','data'=>['error'=>'奖品记录失败']]);
			}
			// 提交事务
			DB::commit();
			// 通过活动ID，查询奖品
			$rewardList						= [];
			// 奖品数据
			foreach ($reward as $value) 	{
				$rewardList[]				= ['id'=>$value['id'],'name'=>$value['reward_name'],'img'=>$value['reward_thumb'],'reward_type'=>$value['reward_type']];
			}
			// 返回结果
			return							json_send(['code'=>'success','msg'=>'抽奖成功','data'=>['reward_list'=>$rewardList,'reward_index'=>$rewardIndex,'join_num'=>$data['join_num']-1]]);
			// 异常处理
		} catch (\Throwable $th) {
			// 回退数据
			DB::rollBack();
			// 下单失败提示
			return							json_send(['code'=>'error','msg'=>'抽奖失败，请重试','data'=>['error'=>$th->getMessage().$th->getLine()]]);
		}	

	}
	
}