当前位置：首页 > PHP教程 > php高级应用 > 列表

PHP实现抽奖功能实例代码

发布:smiling　来源: PHP粉丝网 　添加日期：2022-03-15 10:07:44　浏览: 评论：0　

在项目开发中经常会遇到花钱抽奖类型的需求。但是老板总是担心用户用小钱抽到大奖，这样会导致项目亏损。下边这段代码可以有效制止抽奖项目亏钱。

个人奖池：

语言：thinkphp redis mysql

表：desire抽奖商品表 desire_log用户抽奖奖品表 user_desire_log用户抽奖记录表   desire_risk抽奖风控表

需求：用户奖池分为进行中奖池 和已完成奖池 当用户抽到大奖后 用户个人奖池重置 否则将继续抽奖 最后一次抽奖必中大奖 通过风控金额来判断用户是否可以抽大奖

当所有用户已完成的抽奖 盈利大于风控金额的时候可以让用户抽大奖 否则用户抽不到大奖

  1. <?php  
  2.  
  3. 　　　//抽奖接口 
  4.  
  5.  public function desire() 
  6.  { 
  7.   $userData = $this->userSessionData();///用户的唯一标识 
  8.   $time = time(); 
  9.   $this->limit_reward_time($userData['id'], $time);///限制抽奖间隔时间 防止被恶意刷奖品 
  10.   //活动开启开关 
  11.   $num = input('num/d'); 
  12.   if (!$num) { 
  13.    output('1008', '参数错误'); 
  14.   } 
  15.   if ($num!=1){ 
  16.    if ($num !=10){ 
  17.     if ($num !=100){ 
  18.      output('1008', '参数错误'); 
  19.     }else{ 
  20.      $send = $this->draw($num); 
  21.     } 
  22.    }else{ 
  23.     $send = $this->draw($num); 
  24.    } 
  25.   }else{ 
  26.    $send = $this->draw($num); 
  27.   } 
  28.   if ($send != '金币不足') { 
  29.    output('200', '列表', $send); 
  30.   } else { 
  31.    output('1012', $send); 
  32.   } 
  33.  } 
  34.  
  35.  
  36.  
  37. 　　/////抽奖核心 
  38. 　　 
  39.  public function draw($num) 
  40.  { 
  41.   $userData = $this->userSessionData(); 
  42.   $resultSend = Cache::get('奖池名称加上用户的唯一标识，确保一人一奖池' . $userData['id']);//获取个人奖池 
  43.   if (!emptyempty($resultSend)) { 
  44.    $userRedis = unserialize(Cache::get('newdesiredraw' . $userData['id']));///将奖池序列化 
  45.   } else { 
  46.    $userRedis = '';///当前用户不存在奖池 
  47.   } 
  48. 　　　　 ///查询当前用户的金币 
  49.   $desireDiamonds = Db::connect('db_qmconfig')->name('user_money')->where(['uid' => $userData['id']])->field('diamonds')->find(); 
  50.   $sendNum = $num; 
  51.   if ($desireDiamonds['diamonds'] < $num) { 
  52.    return ['msg' => '金币不足'];///判断当前用户的金币是不是够抽奖 
  53.   } 
  54.   $gift_height = 0;///检测是否更新个人奖池和抽奖数量 
  55.   $newNum = 0;///检测下一轮抽奖数量 
  56.   $suiji = Db::connect('db_qmconfig')->name('desire')->order('num desc')->find();///随机小礼物 
  57.   if ($userRedis) {///如果用户奖池存在 
  58.    $joins = [ 
  59.     ['gift_info f', 'd.giftid = f.id'] 
  60.    ]; 
  61.    $gift = Db::connect('db_qmconfig')->name('desire') 
  62.     ->alias('d') 
  63.     ->join($joins) 
  64.     ->where(['d.state' => 1]) 
  65.     ->order('f.price desc') 
  66.     ->field('f.name,f.price,f.egif,d.num,f.id,d.position')->find(); 
  67. 　　　　　　　　///查询抽奖表的礼物 
  68.    if (!$gift){ 
  69.     return ['msg'=>'礼物查询错误']; 
  70.    } 
  71. 　　　　　　　///查询用户的总抽奖数量 
  72.    $user_all = Db::connect('db_qmconfig')->name('user_desire_log')->order('kind desc') 
  73.     ->where(['uid'=>$userData['id'],'state'=>0])->field('SUM(num) as kindNum')->find(); 
  74.    //十次抽奖 必中 
  75.    $count = count($userRedis); 
  76.    if ($num == 10) { 
  77.     $where[] = ['d.state', '=', 1]; 
  78.     $where[] = ['d.ten', '=', 1]; 
  79.     $giftId = $this->giftInfo($where); 
  80.     if ($giftId) { 
  81.      $result[] = $giftId[0]['id']; 
  82.     } 
  83.     $num = $num - 1; 
  84.    } 
  85.  
  86.    ///百次抽奖 必中 
  87.    if ($num == 100) { 
  88.     $where[] = ['d.state', '=', 1]; 
  89.     $where[] = ['d.hundred', '=', 1]; 
  90.     $giftId = $this->giftInfo($where); 
  91.  
  92.     $lwhere[] = ['d.state', '=', 1]; 
  93.     $lwhere[] = ['d.ten', '=', 1]; 
  94.     $lgiftId = $this->giftInfo($lwhere); 
  95.     if ($lgiftId) { 
  96.      for ($l=0;$l<10;$l++){ 
  97.       $result[] = $lgiftId[0]['id']; 
  98.      } 
  99.     } 
  100.  
  101.     if ($giftId) { 
  102.      $result[] = $giftId[0]['id']; 
  103.     } 
  104.     $num = $num - 11; 
  105.    } 
  106.    if ($num ==1){ 
  107.     if ($user_all){ 
  108.      $number1 = ''; 
  109.      $num1 = str_split($user_all['kindNum']); 
  110.      $number = $num1[count($num1) - 1]; 
  111.      if ($user_all['kindNum']>98){ 
  112.       $number1 = $num1[count($num1) - 2]; 
  113.      } 
  114.      if (($number==9)&& ($number1 !=9)){ //十抽必中 
  115.       $where[] = ['d.state', '=', 1]; 
  116.       $where[] = ['d.ten', '=', 1]; 
  117.       $giftId = $this->giftInfo($where); 
  118.       if ($giftId) { 
  119.        $result[] = $giftId[0]['id']; 
  120.       } 
  121.       $num = $num - 1; 
  122.      } 
  123.  
  124.      if (($number1==9) && ($number==9)){//百抽必中 
  125.       $where[] = ['d.state', '=', 1]; 
  126.       $where[] = ['d.hundred', '=', 1]; 
  127.       $giftId = $this->giftInfo($where); 
  128.       if ($giftId) { 
  129.        $result[] = $giftId[0]['id']; 
  130.       } 
  131.       $num = $num - 1; 
  132.      } 
  133.     } 
  134.    } 
  135. 　　　　　　　 ////判断当前奖池的奖品是否够此次抽奖 如果奖池奖品数量不够此次抽奖 将此次奖池抽完后 获取剩下要抽将的数量 重置奖池 并且递归此方法传入剩下要抽的数量 
  136.    if ($count < $num) { 
  137.     $newNum = $num - $count; 
  138.     $num = $count; 
  139.    } 
  140.    $user = Db::connect('db_qmconfig') 
  141.     ->name('desire_log')->where(['uid' => $userData['id']]) 
  142.     ->field('SUM(num) as num') 
  143.     ->find();///已抽数量 
  144.    if (!$user){ 
  145.     return ['msg'=>'已抽数量有误']; 
  146.    } 
  147.    $res['zongshu'] = Db::connect('db_qmconfig') 
  148.     ->name('desire')->where(['state' => 1]) 
  149.     ->field('SUM(num) as num,checksum') 
  150.     ->find();///总数量 
  151.    if (!$res['zongshu']){ 
  152.     return ['msg'=>'总数量有误']; 
  153.    } 
  154.    $resNum = 0; 
  155.    ////获取个人多少次抽奖 
  156.    if (($user['num']+$sendNum) > $res['zongshu']['checksum']) { 
  157.     $res['zongshu']['user_num'] = $user['num'] % $res['zongshu']['checksum']; ///获取余数 
  158.     if (($res['zongshu']['user_num'] + $sendNum) > $res['zongshu']['checksum']) { 
  159.      ///获取这次抽奖的数量 
  160.      $resNum = $sendNum - (($res['zongshu']['user_num'] + $sendNum) - $res['zongshu']['checksum']); 
  161.     } 
  162. //    return ['msg'=>$res['zongshu']['user_num']]; 
  163.    }else{ 
  164.     $res['zongshu']['user_num'] = $user['num']; 
  165.    } 
  166.    $cruuy = 0; 
  167.    ///随机选择奖池 
  168.    for ($i = 0; $i < $num; $i++) { 
  169.     $send = array_rand($userRedis); 
  170.     if ($resNum > 0) { 
  171.      ///如果本轮奖池抽完 并且没有抽到大奖 那么必中大奖 
  172.      $result[] = $gift['id']; 
  173.      $gift_height = 1;//抽到大奖后更改三个变量状态 
  174.      $resNum=0; 
  175.      $cruuy = 1; 
  176.     } else { 
  177.      if ($userRedis[$send]==$gift['id']){ 
  178.       $haveJoin = [ 
  179.        ['desire_log d', 'd.cid = u.id'], 
  180.        ['gift_info f', 'd.giftid = f.id'] 
  181.       ]; 
  182.       $all = Db::connect('db_qmconfig') 
  183.        ->name('user_desire_log') 
  184.        ->alias('u') 
  185.        ->where(['u.state'=>1]) 
  186.        ->field('SUM(u.num) as num')->find(); 
  187. //      var_dump($all); 
  188. 　　　　　　　　　　　　　　///如果抽到大奖 
  189.       if ($all['num']==null){ 
  190. 　　　　　　　　　　　　　　　　　///如果这是整个奖池第一轮抽奖 那么可以中大奖 
  191.        $result[] = $suiji['giftid']; 
  192.       }else{ 
  193. 　　　　　　　　　　　　　　　　　 
  194.        $alls = Db::connect('db_qmconfig')->name('user_desire_log') 
  195.         ->alias('u') 
  196.         ->where(['u.state'=>1]) 
  197.         ->join($haveJoin) 
  198.         ->field('SUM(f.price*d.num) as num')->find(); 
  199. 　　　　　　　　　　　　　　　　　///查询奖池风控金额 
  200.        $reskList = Db::connect('db_qmconfig')->name('desire_risk')->find(); 
  201.        $riskPrice = $all['num'] * 20 - $alls['num']; 
  202. 　　　　　　　　　　　　　　　　　///如果风控金额小于当前已完成抽奖的金额 那么代表软件处于盈利状态 可以中大奖 
  203.        if (($riskPrice >= $reskList['price'])&&($cruuy==0)){ 
  204.         $result[] = $userRedis[$send]; 
  205.         $gift_height = 1; 
  206.         $cruuy = 1; 
  207.        } else{ 
  208. 　　　　　　　　　　　　　　　　　　　///如果风控金额大于当前已完成抽奖金额 不能中大奖 随机选择一次小奖品 替换大奖 
  209.         $result[] = $suiji['giftid']; 
  210.        } 
  211.       } 
  212.  
  213.      }else{ 
  214.       $result[] = $userRedis[$send]; 
  215.      } 
  216.     } 
  217. 　　　　　　　　　　///清空个人奖池此次抽奖的礼物 
  218.     unset($userRedis[$send]); 
  219.    } 
  220. 　　　　　　　////新增用户抽奖次数  
  221.    $result = array_count_values($result); 
  222.    $user_desire_list = Db::connect('db_qmconfig')->name('user_desire_log')->order('id desc')->where(['uid'=>$userData['id']])->find(); 
  223.    if ($user_desire_list){ 
  224.     if ($user_desire_list['state']==0){ 
  225.      $user_desire_logData[ 'kind'] = $user_desire_list['kind']+1; 
  226.     }else{ 
  227.      $user_desire_logData[ 'kind'] = 1; 
  228.     } 
  229.    }else{ 
  230.     $user_desire_logData[ 'kind'] = 1; 
  231.  
  232.    } 
  233.    $user_desire_logData['uid'] =$userData['id']; 
  234.    $user_desire_logData['ctime'] =time(); 
  235.    $user_desire_logData['num'] =$sendNum; 
  236. 　　　　　　　////更改此轮抽奖后 用户奖池的状态 
  237.    if ($gift_height==1){ 
  238.     $user_desire_log_update = Db::connect('db_qmconfig')->name('user_desire_log') 
  239.      ->where(['uid'=>$userData['id'],'state'=>0])->update(['state'=>1]); 
  240.     $user_desire_logData[ 'state'] = 1; 
  241.    }else{ 
  242.     $user_desire_logData[ 'state'] = 0; 
  243.    } 
  244.    $user_desire_log = Db::connect('db_qmconfig')->name('user_desire_log')->insertGetId($user_desire_logData); 
  245.    foreach ($result as $k => $v) { 
  246.     if ($resNum == ($k + 1)) { 
  247.      ///如果这次抽奖大于奖池总数 那么更新奖池并且抽奖剩下的次数 
  248.      Cache::set('newdesiredraw' . $userData['id'], serialize([])); 
  249.      return $this->draw($sendNum - ($k + 1)); 
  250.     } 
  251.  
  252. 　　　　　　　　 ////礼物新增用户背包　　 
  253.     $data = [ 
  254.      'uid' => $userData['id'], 
  255.      'giftid' => $k, 
  256.      'num' => $v, 
  257.      'ctime' => time(), 
  258.      'cid' => $user_desire_log 
  259.     ]; 
  260.     $join = [ 
  261.      ['gift_info f', 'd.giftid = f.id'] 
  262.     ]; 
  263.     $gift_info = Db::connect('db_qmconfig')->name('desire') 
  264.      ->alias('d') 
  265.      ->join($join) 
  266.      ->where(['d.giftid' => $k]) 
  267.      ->field('f.name,f.egif,d.position')->find(); 
  268.     $gift_infonum['num'] = $v; 
  269.     $list['gift'][] = array_merge($gift_info, $gift_infonum); 
  270.     $desireLog = Db::connect('db_qmconfig')->name('desire_log')->insert($data); 
  271.     $userKnapsack = Db::connect('db_qmconfig')->name('gift_knapsack')->where(['uid' => $userData['id'], 'giftid' => $k])->field('id,num')->find(); 
  272.     if ($userKnapsack) { 
  273.      $userKnapsackData = [ 
  274.       'num' => $v + $userKnapsack['num'], 
  275.       'updatetime' => time() 
  276.      ]; 
  277.      $userKnapsackUpdate = Db::connect('db_qmconfig')->name('gift_knapsack')->where(['id' => $userKnapsack['id']])->update($userKnapsackData); 
  278.     } else { 
  279.      $userKnapsackData = [ 
  280.       'num' => $v, 
  281.       'giftid' => $k, 
  282.       'uid' => $userData['id'], 
  283.       'createtime' => time() 
  284.      ]; 
  285.      $userKnapsackInsert = Db::connect('db_qmconfig')->name('gift_knapsack')->insert($userKnapsackData); 
  286.     } 
  287.    } 
  288. 　　　　　　　 ///增加用户消费记录 
  289.    $userXfData = [ 
  290.     'uid' => $userData['id'], 
  291.     'xf_price' => $sendNum, 
  292.     'xf_method' => 5, 
  293.     'scene' => 19, 
  294.     'status' => 1, 
  295.     'ctime' => time() 
  296.    ]; 
  297.    $userXf = Db::connect('db_qmconfig')->name('xfprice')->insert($userXfData); 
  298.    if ($desireLog && $userXf) { 
  299. 　　　　　　　　　　///扣除用户金币 
  300.     $newDiamondsData = [ 
  301.      'diamonds' => $desireDiamonds['diamonds'] - $sendNum 
  302.     ]; 
  303.     $newDiamonds = Db::connect('db_qmconfig')->name('user_money')->where(['uid' => $userData['id']])->update($newDiamondsData); 
  304.    } 
  305. 　　　　　　　　 
  306.  
  307.    if ($userRedis) { 
  308.     Cache::set('用户奖池名称' . $userData['id'], serialize($userRedis)); 
  309. 　　　　　　　　　 ////如果此轮抽奖抽到大奖 重置用户个人奖池 
  310.     if ($gift_height == 1) { 
  311.      Cache::set('用户奖池名称' . $userData['id'], serialize([])); 
  312.      $userChecksum = $res['zongshu']['checksum'] - ($res['zongshu']['user_num'] + $sendNum); 
  313.      $desireLogUserWhere = [ 
  314.       'uid' => $userData['id'], 
  315.       'giftid' => 0, 
  316.       'num' => $userChecksum, 
  317.       'ctime' => time(), 
  318.       'cid' => $user_desire_log, 
  319.      ]; 
  320. 　　　　　　　　　　　　///添加礼物抽中记录 
  321.      $desireLogUser = Db::connect('db_qmconfig')->name('desire_log')->insert($desireLogUserWhere); 
  322.     } 
  323.     $swhere[] = ['d.state', '=', 1]; 
  324.     $swhere[] = ['d.kind', '=', 1]; 
  325.     $res['data'] = $this->giftInfo($swhere); 
  326.     if (emptyempty($res['data'])) { 
  327.      output('1008', '奖池更新中'); 
  328.     } 
  329. 　　　　　　　　　　////获取用户此轮抽奖数量 返回给前端 控制奖池动画百分比 
  330.     $res['zongshu'] = Db::connect('db_qmconfig') 
  331.      ->name('desire')->where(['state' => 1, 'kind' => 1]) 
  332.      ->field('checksum as num') 
  333.      ->find(); 
  334.     $user = Db::connect('db_qmconfig') 
  335.      ->name('desire_log')->where(['uid' => $userData['id']]) 
  336.      ->field('SUM(num) as num') 
  337.      ->find(); 
  338.     $res['diamonds'] = Db::connect('db_qmconfig') 
  339.      ->name('user_money')->where(['uid' => $userData['id']]) 
  340.      ->value('diamonds'); 
  341.  
  342.     if ($user) { 
  343.      if ($user['num'] > $res['zongshu']['num']) { 
  344.       $res['zongshu']['user_num'] = $user['num'] % $res['zongshu']['num']; 
  345.  
  346.      } else { 
  347.       $res['zongshu']['user_num'] = $user['num']; 
  348.      } 
  349.     } else { 
  350.      $res['zongshu']['user_num'] = 0; 
  351.     } 
  352.     $list['info'] = $res; 
  353.     return $list; 
  354. //    return ['msg'=>$res['zongshu']['user_num']]; 
  355.    } else { 
  356. 　　　　　　　　　　////如果当前用户奖池抽完奖了 那么重置此用户奖池 
  357.     $where[] = ['d.state', '=', 1]; 
  358.     $where[] = ['d.kind', '=', 1]; 
  359.     $res = $this->giftInfo($where); 
  360.     if (emptyempty($res)) { 
  361.      return ['msg' => '奖池更新中']; 
  362.     } 
  363.     $c = []; 
  364.     foreach ($res as $m => $n) { 
  365. 　　　　　　　　　　///十抽必中奖品 
  366.      if ($n['ten']==1){ 
  367.       $n['num'] = $n['num'] - $n['checksum']/10; 
  368.       $giftarr = array_fill(0, $n['num']+$n['checksum']/10, $suiji['giftid']); 
  369.       $c = array_merge($c, $giftarr); 
  370.       if ($n['num']<=0){ 
  371.        continue; 
  372.       } 
  373.      } 
  374. 　　　　　　　　　　　　///百抽必中奖品 
  375.      if ($n['hundred']==1){ 
  376.       $n['num'] = $n['num'] - $n['checksum']/100; 
  377.       $giftarr = array_fill(0, $n['num']+$n['checksum']/100, $suiji['giftid']); 
  378.       $c = array_merge($c, $giftarr); 
  379.       if ($n['num']<=0){ 
  380.        continue; 
  381.       } 
  382.      } 
  383.      $giftarr = array_fill(0, $n['num'], $n['id']); 
  384.      $c = array_merge($c, $giftarr); 
  385.     } 
  386. 　　　　　　　　　　///随机打乱奖池 
  387.     shuffle($c); 
  388.     Cache::set('用户奖池名称' . $userData['id'], serialize($c)); 
  389.     if ($newNum>0){ 
  390. 　　　　　　　　　　　　 ///递归此方法 抽剩下的奖品 
  391.      return $this->draw($newNum); 
  392.     } 
  393.    } 
  394.   } else { 
  395.    ///如果没有奖池 生成奖池 
  396.    $where[] = ['d.state', '=', 1]; 
  397.    $where[] = ['d.kind', '=', 1]; 
  398.    $res = $this->giftInfo($where); 
  399.    if (emptyempty($res)) { 
  400.     return ['msg' => '奖池更新中']; 
  401.    } 
  402.    $c = []; 
  403.    foreach ($res as $m => $n) { 
  404.     if ($n['ten']==1){ 
  405.      $n['num'] = $n['num'] - $n['checksum']/10; 
  406.      $giftarr = array_fill(0, $n['num']+$n['checksum']/10, $suiji['giftid']); 
  407.      $c = array_merge($c, $giftarr); 
  408.      if ($n['num']<=0){ 
  409.       continue; 
  410.      } 
  411.     } 
  412.     if ($n['hundred']==1){ 
  413.      $n['num'] = $n['num'] - $n['checksum']/100; 
  414.      $giftarr = array_fill(0, $n['num']+$n['checksum']/100, $suiji['giftid']); 
  415.      $c = array_merge($c, $giftarr); 
  416.      if ($n['num']<=0){ 
  417.       continue; 
  418.      } 
  419.     } 
  420.     $giftarr = array_fill(0, $n['num'], $n['id']); 
  421.     $c = array_merge($c, $giftarr); 
  422.    } 
  423.    shuffle($c); 
  424.    Cache::set('用户奖池名称' . $userData['id'], serialize($c)); 
  425. 　　　　　　　///递归此方法抽奖 
  426.    return $this->draw($num); 
  427.   } 
  428.  } 
  429. ?>

Tags: PHP抽奖功能

分享到：

推荐文章

热门文章

最新评论文章