verify_sign(); // 检查登录 $uid = $this->checkLogin(); // 获取客户信息 $custom = $Custom->getOne($uid); // 如果存在的话 if( !$custom ) return json_send(['code'=>'no_login','msg'=>'请登录','data'=>['error'=>'无对应客户']]); // 客户的城市ID $cityId = empty($custom['city_id']) ? 0 : $custom['city_id']; // 获取客户城市的数据 $data = $Model->getOneByCity($cityId); // 如果存在的话 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 = $ScoreReward->getListByLottery($data['id']); // 活动暂无奖品 if( !$reward ) return json_send(['code'=>'error','msg'=>'活动暂未配置奖品','data'=>$data]); // logo $data['logo'] = $data['logo'] ? path_compat($data['logo']) : ''; // 判断用户是不是活动期间注册的以判断新老用户,获取对应积分 $data['need_score'] = ($custom['insert_time'] >= $data['start_time'] && $custom['insert_time'] <= $data['end_time']) ? $data['need_score'] : $data['need_old_score']; // 通过活动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']]; } // 时间处理 $data['start_date'] = date('Y/m/d H:i',$data['start_time']); // 时间处理 $data['end_date'] = date('Y/m/d H:i',$data['end_time']); // 删除不必要的数据 unset($data['need_old_score'],$data['tag_scope'],$data['city_ids']); // 返回结果 return json_send(['code'=>'success','msg'=>'获取成功','data'=>$data]); } /** * 积分抽奖 /api/lottery_score/get_reward * * */ public function get_reward(Model $Model,Custom $Custom,ScoreReward $ScoreReward,WeiBanTags $WeiBanTags,CustomScore $CustomScore,CustomCoupon $CustomCoupon,ScoreRecord $ScoreRecord,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 = $ScoreReward->getListByLottery($data['id']); // 活动暂无奖品 if( !$reward ) return json_send(['code'=>'error','msg'=>'活动暂未配置奖品','data'=>$data]); // 判断用户是不是活动期间注册的以判断新老用户,获取对应积分 $data['need_score'] = ($custom['insert_time'] >= $data['start_time'] && $custom['insert_time'] <= $data['end_time']) ? $data['need_score'] : $data['need_old_score']; // 默认可以参加活动 $data['allow_join'] = 1; // 判断是不是可以参与 if( $data['tag_scope'] ) { // 解析数组 $data['tag_scope'] = explode(',',$data['tag_scope']); // 查询用户标签 $tags = $WeiBanTags->getListByWeibanExtid($custom['weiban_extid']); // 标签范围限定时,默认不能参与 $data['allow_join'] = 0; // 判断标签是不是存在 foreach ($tags as $value) { // 标签范围内,允许参加 if( in_array($value['name'],$data['tag_scope']) ) $data['allow_join'] = 1; } } // 如果不能参与 if( !$data['allow_join'] ) return json_send(['code'=>'error','msg'=>'不符合参与条件','data'=>['error'=>'不符合参与条件']]); // 获取奖励结果 $rewardResult = $ScoreReward->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 = $CustomScore->trade($uid,$lotteryId,($data['need_score']*-1),7,1); // 如果积分扣减失败 if( isset($result['error']) ){ // 回退数据 DB::rollBack(); return json_send(['code'=>'error','msg'=>$result['error'],'data'=>['error'=>$result['error']]]); } // 如果存在奖品 if( $rewardResult['id'] ){ // 奖品数量减少 $result = $ScoreReward->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,2); // 发放失败,改为未中奖 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'],5,1,'积分抽奖'); // 发放失败,改为未中奖 if( isset($result['error']) ) { // 回退数据 DB::rollBack(); // 通知重试 return json_send(['code'=>'error','msg'=>'出了点小差,请重新抽奖','data'=>$result]); } } } // 扣减数量 $result = $ScoreRecord->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']]; } // 获取积分信息 $customScore = $CustomScore->getCustomScore($uid); // 返回结果 return json_send(['code'=>'success','msg'=>'抽奖成功','data'=>['reward_list'=>$rewardList,'reward_index'=>$rewardIndex,'custom_score'=>$customScore]]); // 异常处理 } catch (\Throwable $th) { // 回退数据 DB::rollBack(); // 下单失败提示 return json_send(['code'=>'error','msg'=>'抽奖失败,请重试','data'=>['error'=>$th->getMessage().$th->getLine()]]); } } }