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,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,4); // 发放失败,改为未中奖 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( !$result ) { // 回退数据 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'],4,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()]]); } } }