php抽獎功能

来源:https://www.cnblogs.com/phpclass/archive/2020/06/29/13210165.html

在項目開發中經常會遇到花錢抽獎類型的需求。但是老闆總是擔心用戶用小錢抽到大獎。這樣會導致項目虧損。下邊這段代碼可以有效制止抽獎項目虧錢。 個人獎池: 語言:thinkphp redis mysql 表:desire抽獎商品表 desire_log用戶抽獎獎品表 user_desire_log用戶抽獎 ...


在項目開發中經常會遇到花錢抽獎類型的需求。但是老闆總是擔心用戶用小錢抽到大獎。這樣會導致項目虧損。下邊這段代碼可以有效制止抽獎項目虧錢。

個人獎池:

語言:thinkphp redis mysql 

表:desire抽獎商品表 desire_log用戶抽獎獎品表 user_desire_log用戶抽獎記錄表   desire_risk抽獎風控表

需求:用戶獎池分為進行中獎池 和已完成獎池 當用戶抽到大獎後 用戶個人獎池重置 否則將繼續抽獎 最後一次抽獎必中大獎 通過風控金額來判斷用戶是否可以抽大獎

  當所有用戶已完成的抽獎 盈利大於風控金額的時候可以讓用戶抽大獎 否則用戶抽不到大獎

<?php  

   //抽獎介面

    public function desire()
    {
        $userData = $this->userSessionData();///用戶的唯一標識
        $time = time();
        $this->limit_reward_time($userData['id'], $time);///限制抽獎間隔時間 防止被惡意刷獎品
        //活動開啟開關
        $num = input('num/d');
        if (!$num) {
            output('1008', '參數錯誤');
        }
        if ($num!=1){
            if ($num !=10){
                if ($num !=100){
                    output('1008', '參數錯誤');
                }else{
                    $send = $this->draw($num);
                }
            }else{
                $send = $this->draw($num);
            }
        }else{
            $send = $this->draw($num);
        }
        if ($send != '金幣不足') {
            output('200', '列表', $send);
        } else {
            output('1012', $send);
        }
    }



  /////抽獎核心
  
    public function draw($num)
    {
        $userData = $this->userSessionData();
        $resultSend = Cache::get('獎池名稱加上用戶的唯一標識,確保一人一獎池' . $userData['id']);//獲取個人獎池
        if (!empty($resultSend)) {
            $userRedis = unserialize(Cache::get('newdesiredraw' . $userData['id']));///將獎池序列化
        } else {
            $userRedis = '';///當前用戶不存在獎池
        }
     ///查詢當前用戶的金幣
        $desireDiamonds = Db::connect('db_qmconfig')->name('user_money')->where(['uid' => $userData['id']])->field('diamonds')->find();
        $sendNum = $num;
        if ($desireDiamonds['diamonds'] < $num) {
            return ['msg' => '金幣不足'];///判斷當前用戶的金幣是不是夠抽獎
        }
        $gift_height = 0;///檢測是否更新個人獎池和抽獎數量
        $newNum = 0;///檢測下一輪抽獎數量
        $suiji = Db::connect('db_qmconfig')->name('desire')->order('num desc')->find();///隨機小禮物
        if ($userRedis) {///如果用戶獎池存在
            $joins = [
                ['gift_info f', 'd.giftid = f.id']
            ];
            $gift = Db::connect('db_qmconfig')->name('desire')
                ->alias('d')
                ->join($joins)
                ->where(['d.state' => 1])
                ->order('f.price desc')
                ->field('f.name,f.price,f.egif,d.num,f.id,d.position')->find();
        ///查詢抽獎表的禮物
            if (!$gift){
                return ['msg'=>'禮物查詢錯誤'];
            }
       ///查詢用戶的總抽獎數量
            $user_all = Db::connect('db_qmconfig')->name('user_desire_log')->order('kind desc')
                ->where(['uid'=>$userData['id'],'state'=>0])->field('SUM(num) as kindNum')->find();
            //十次抽獎 必中
            $count = count($userRedis);
            if ($num == 10) {
                $where[] = ['d.state', '=', 1];
                $where[] = ['d.ten', '=', 1];
                $giftId = $this->giftInfo($where);
                if ($giftId) {
                    $result[] = $giftId[0]['id'];
                }
                $num = $num - 1;
            }

            ///百次抽獎 必中
            if ($num == 100) {
                $where[] = ['d.state', '=', 1];
                $where[] = ['d.hundred', '=', 1];
                $giftId = $this->giftInfo($where);

                $lwhere[] = ['d.state', '=', 1];
                $lwhere[] = ['d.ten', '=', 1];
                $lgiftId = $this->giftInfo($lwhere);
                if ($lgiftId) {
                    for ($l=0;$l<10;$l++){
                        $result[] = $lgiftId[0]['id'];
                    }
                }

                if ($giftId) {
                    $result[] = $giftId[0]['id'];
                }
                $num = $num - 11;
            }
            if ($num ==1){
                if ($user_all){
                    $number1 = '';
                    $num1 = str_split($user_all['kindNum']);
                    $number = $num1[count($num1) - 1];
                    if ($user_all['kindNum']>98){
                        $number1 = $num1[count($num1) - 2];
                    }
                    if (($number==9)&& ($number1 !=9)){ //十抽必中
                        $where[] = ['d.state', '=', 1];
                        $where[] = ['d.ten', '=', 1];
                        $giftId = $this->giftInfo($where);
                        if ($giftId) {
                            $result[] = $giftId[0]['id'];
                        }
                        $num = $num - 1;
                    }

                    if (($number1==9) && ($number==9)){//百抽必中
                        $where[] = ['d.state', '=', 1];
                        $where[] = ['d.hundred', '=', 1];
                        $giftId = $this->giftInfo($where);
                        if ($giftId) {
                            $result[] = $giftId[0]['id'];
                        }
                        $num = $num - 1;
                    }
                }
            }
        ////判斷當前獎池的獎品是否夠此次抽獎 如果獎池獎品數量不夠此次抽獎 將此次獎池抽完後 獲取剩下要抽將的數量 重置獎池 並且遞歸此方法傳入剩下要抽的數量
            if ($count < $num) {
                $newNum = $num - $count;
                $num = $count;
            }
            $user = Db::connect('db_qmconfig')
                ->name('desire_log')->where(['uid' => $userData['id']])
                ->field('SUM(num) as num')
                ->find();///已抽數量
            if (!$user){
                return ['msg'=>'已抽數量有誤'];
            }
            $res['zongshu'] = Db::connect('db_qmconfig')
                ->name('desire')->where(['state' => 1])
                ->field('SUM(num) as num,checksum')
                ->find();///總數量
            if (!$res['zongshu']){
                return ['msg'=>'總數量有誤'];
            }
            $resNum = 0;
            ////獲取個人多少次抽獎
            if (($user['num']+$sendNum) > $res['zongshu']['checksum']) {
                $res['zongshu']['user_num'] = $user['num'] % $res['zongshu']['checksum']; ///獲取餘數
                if (($res['zongshu']['user_num'] + $sendNum) > $res['zongshu']['checksum']) {
                    ///獲取這次抽獎的數量
                    $resNum = $sendNum - (($res['zongshu']['user_num'] + $sendNum) - $res['zongshu']['checksum']);
                }
//                return ['msg'=>$res['zongshu']['user_num']];
            }else{
                $res['zongshu']['user_num'] = $user['num'];
            }
            $cruuy = 0;
            ///隨機選擇獎池
            for ($i = 0; $i < $num; $i++) {
                $send = array_rand($userRedis);
                if ($resNum > 0) {
                    ///如果本輪獎池抽完 並且沒有抽到大獎 那麼必中大獎
                    $result[] = $gift['id'];
                    $gift_height = 1;//抽到大獎後更改三個變數狀態
                    $resNum=0;
                    $cruuy = 1;
                } else {
                    if ($userRedis[$send]==$gift['id']){
                        $haveJoin = [
                            ['desire_log d', 'd.cid = u.id'],
                            ['gift_info f', 'd.giftid = f.id']
                        ];
                        $all  = Db::connect('db_qmconfig')
                            ->name('user_desire_log')
                            ->alias('u')
                            ->where(['u.state'=>1])
                            ->field('SUM(u.num) as num')->find();
//                        var_dump($all);
              ///如果抽到大獎
                        if ($all['num']==null){
                 ///如果這是整個獎池第一輪抽獎 那麼可以中大獎
                            $result[] = $suiji['giftid'];
                        }else{
                 
                            $alls  = Db::connect('db_qmconfig')->name('user_desire_log')
                                ->alias('u')
                                ->where(['u.state'=>1])
                                ->join($haveJoin)
                                ->field('SUM(f.price*d.num) as num')->find();
                 ///查詢獎池風控金額
                            $reskList = Db::connect('db_qmconfig')->name('desire_risk')->find();
                            $riskPrice = $all['num'] * 20 - $alls['num'];
                 ///如果風控金額小於當前已完成抽獎的金額 那麼代表軟體處於盈利狀態 可以中大獎
                            if (($riskPrice >= $reskList['price'])&&($cruuy==0)){
                                $result[] = $userRedis[$send];
                                $gift_height = 1;
                                $cruuy = 1;
                            } else{
                   ///如果風控金額大於當前已完成抽獎金額 不能中大獎 隨機選擇一次小獎品 替換大獎
                                $result[] = $suiji['giftid'];
                            }
                        }

                    }else{
                        $result[] = $userRedis[$send];
                    }
                }
          ///清空個人獎池此次抽獎的禮物
                unset($userRedis[$send]);
            }
       ////新增用戶抽獎次數 
            $result = array_count_values($result);
            $user_desire_list = Db::connect('db_qmconfig')->name('user_desire_log')->order('id desc')->where(['uid'=>$userData['id']])->find();
            if ($user_desire_list){
                if ($user_desire_list['state']==0){
                    $user_desire_logData[ 'kind'] = $user_desire_list['kind']+1;
                }else{
                    $user_desire_logData[ 'kind'] = 1;
                }
            }else{
                $user_desire_logData[ 'kind'] = 1;

            }
            $user_desire_logData['uid'] =$userData['id'];
            $user_desire_logData['ctime'] =time();
            $user_desire_logData['num'] =$sendNum;
       ////更改此輪抽獎後 用戶獎池的狀態
            if ($gift_height==1){
                $user_desire_log_update = Db::connect('db_qmconfig')->name('user_desire_log')
                    ->where(['uid'=>$userData['id'],'state'=>0])->update(['state'=>1]);
                $user_desire_logData[ 'state'] = 1;
            }else{
                $user_desire_logData[ 'state'] = 0;
            }
            $user_desire_log = Db::connect('db_qmconfig')->name('user_desire_log')->insertGetId($user_desire_logData);
            foreach ($result as $k => $v) {
                if ($resNum == ($k + 1)) {
                    ///如果這次抽獎大於獎池總數 那麼更新獎池並且抽獎剩下的次數
                    Cache::set('newdesiredraw' . $userData['id'], serialize([]));
                    return $this->draw($sendNum - ($k + 1));
                }

           ////禮物新增用戶背包  
                $data = [
                    'uid' => $userData['id'],
                    'giftid' => $k,
                    'num' => $v,
                    'ctime' => time(),
                    'cid' => $user_desire_log
                ];
                $join = [
                    ['gift_info f', 'd.giftid = f.id']
                ];
                $gift_info = Db::connect('db_qmconfig')->name('desire')
                    ->alias('d')
                    ->join($join)
                    ->where(['d.giftid' => $k])
                    ->field('f.name,f.egif,d.position')->find();
                $gift_infonum['num'] = $v;
                $list['gift'][] = array_merge($gift_info, $gift_infonum);
                $desireLog = Db::connect('db_qmconfig')->name('desire_log')->insert($data);
                $userKnapsack = Db::connect('db_qmconfig')->name('gift_knapsack')->where(['uid' => $userData['id'], 'giftid' => $k])->field('id,num')->find();
                if ($userKnapsack) {
                    $userKnapsackData = [
                        'num' => $v + $userKnapsack['num'],
                        'updatetime' => time()
                    ];
                    $userKnapsackUpdate = Db::connect('db_qmconfig')->name('gift_knapsack')->where(['id' => $userKnapsack['id']])->update($userKnapsackData);
                } else {
                    $userKnapsackData = [
                        'num' => $v,
                        'giftid' => $k,
                        'uid' => $userData['id'],
                        'createtime' => time()
                    ];
                    $userKnapsackInsert = Db::connect('db_qmconfig')->name('gift_knapsack')->insert($userKnapsackData);
                }
            }
        ///增加用戶消費記錄
            $userXfData = [
                'uid' => $userData['id'],
                'xf_price' => $sendNum,
                'xf_method' => 5,
                'scene' => 19,
                'status' => 1,
                'ctime' => time()
            ];
            $userXf = Db::connect('db_qmconfig')->name('xfprice')->insert($userXfData);
            if ($desireLog && $userXf) {
          ///扣除用戶金幣
                $newDiamondsData = [
                    'diamonds' => $desireDiamonds['diamonds'] - $sendNum
                ];
                $newDiamonds = Db::connect('db_qmconfig')->name('user_money')->where(['uid' => $userData['id']])->update($newDiamondsData);
            }
        

            if ($userRedis) {
                Cache::set('用戶獎池名稱' . $userData['id'], serialize($userRedis));
          ////如果此輪抽獎抽到大獎 重置用戶個人獎池
                if ($gift_height == 1) {
                    Cache::set('用戶獎池名稱' . $userData['id'], serialize([]));
                    $userChecksum = $res['zongshu']['checksum'] - ($res['zongshu']['user_num'] + $sendNum);
                    $desireLogUserWhere = [
                        'uid' => $userData['id'],
                        'giftid' => 0,
                        'num' => $userChecksum,
                        'ctime' => time(),
                        'cid' => $user_desire_log,
                    ];
            ///添加禮物抽中記錄
                    $desireLogUser = Db::connect('db_qmconfig')->name('desire_log')->insert($desireLogUserWhere);
                }
                $swhere[] = ['d.state', '=', 1];
                $swhere[] = ['d.kind', '=', 1];
                $res['data'] = $this->giftInfo($swhere);
                if (empty($res['data'])) {
                    output('1008', '獎池更新中');
                }
          ////獲取用戶此輪抽獎數量 返回給前端 控制獎池動畫百分比
                $res['zongshu'] = Db::connect('db_qmconfig')
                    ->name('desire')->where(['state' => 1, 'kind' => 1])
                    ->field('checksum as num')
                    ->find();
                $user = Db::connect('db_qmconfig')
                    ->name('desire_log')->where(['uid' => $userData['id']])
                    ->field('SUM(num) as num')
                    ->find();
                $res['diamonds'] = Db::connect('db_qmconfig')
                    ->name('user_money')->where(['uid' => $userData['id']])
                    ->value('diamonds');

                if ($user) {
                    if ($user['num'] > $res['zongshu']['num']) {
                        $res['zongshu']['user_num'] = $user['num'] % $res['zongshu']['num'];

                    } else {
                        $res['zongshu']['user_num'] = $user['num'];
                    }
                } else {
                    $res['zongshu']['user_num'] = 0;
                }
                $list['info'] = $res;
                return $list;
//                return ['msg'=>$res['zongshu']['user_num']];
            } else {
          ////如果當前用戶獎池抽完獎了  那麼重置此用戶獎池
                $where[] = ['d.state', '=', 1];
                $where[] = ['d.kind', '=', 1];
                $res = $this->giftInfo($where);
                if (empty($res)) {
                    return ['msg' => '獎池更新中'];
                }
                $c = [];
                foreach ($res as $m => $n) {
          ///十抽必中獎品
                    if ($n['ten']==1){
                        $n['num'] = $n['num'] - $n['checksum']/10;
                        $giftarr = array_fill(0, $n['num']+$n['checksum']/10, $suiji['giftid']);
                        $c = array_merge($c, $giftarr);
                        if ($n['num']<=0){
                            continue;
                        }
                    }
            ///百抽必中獎品
                    if ($n['hundred']==1){
                        $n['num'] = $n['num'] - $n['checksum']/100;
                        $giftarr = array_fill(0, $n['num']+$n['checksum']/100, $suiji['giftid']);
                        $c = array_merge($c, $giftarr);
                        if ($n['num']<=0){
                            continue;
                        }
                    }
                    $giftarr = array_fill(0, $n['num'], $n['id']);
                    $c = array_merge($c, $giftarr);
                }
          ///隨機打亂獎池
                shuffle($c);
                Cache::set('用戶獎池名稱' . $userData['id'], serialize($c));
                if ($newNum>0){
             ///遞歸此方法 抽剩下的獎品
                    return $this->draw($newNum);
                }
            }
        } else {
            ///如果沒有獎池 生成獎池
            $where[] = ['d.state', '=', 1];
            $where[] = ['d.kind', '=', 1];
            $res = $this->giftInfo($where);
            if (empty($res)) {
                return ['msg' => '獎池更新中'];
            }
            $c = [];
            foreach ($res as $m => $n) {
                if ($n['ten']==1){
                    $n['num'] = $n['num'] - $n['checksum']/10;
                    $giftarr = array_fill(0, $n['num']+$n['checksum']/10, $suiji['giftid']);
                    $c = array_merge($c, $giftarr);
                    if ($n['num']<=0){
                        continue;
                    }
                }
                if ($n['hundred']==1){
                    $n['num'] = $n['num'] - $n['checksum']/100;
                    $giftarr = array_fill(0, $n['num']+$n['checksum']/100, $suiji['giftid']);
                    $c = array_merge($c, $giftarr);
                    if ($n['num']<=0){
                        continue;
                    }
                }
                $giftarr = array_fill(0, $n['num'], $n['id']);
                $c = array_merge($c, $giftarr);
            }
            shuffle($c);
            Cache::set('用戶獎池名稱' . $userData['id'], serialize($c));
       ///遞歸此方法抽獎
            return $this->draw($num);
        }
    }
?>

 


您的分享是我們最大的動力!

更多相關文章
  • 介面 恰當的原則是優先使用類而不是介面。從類開始,如果使用介面的必要性變得很明確,那麼就重構。介面是一個偉大的工具,但它們容易被濫用。 介面中可添加靜態方法與預設方法 一個類實現一個介面的同時必須實現該介面的所有方法(可以不用實現預設方法即關鍵詞為為 default的方法) extends 只能用於 ...
  • 小白是一名.net程式員,之前小白介紹了過了自己的博客系統http://www.ttblog.site/,用.net寫厭了,所以想學下java嘗嘗鮮,於是小白準備用spring boot來實現一個博客內容管理系統。 因為管理系統要有自己的數據源,但是又要從博客系統獲取博客內容,所以第一反應是要弄一個 ...
  • 初次看到原文我是有一些震撼的,原來作為開發人員,閑暇時間還算可以做這麼多有趣程式的開發。閱讀時暫且拋棄你所使用的語言的限制,你是否也能夠在“無聊”之時找到一個開發者的樂趣。 閱讀以下內容時重點關註項目的創意性,並結合自己的獨特經歷進行拓展,你一定也能夠找到編程的樂趣所在。很多項目都可以通過不同的技術 ...
  • 前言 本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。 知識點 • 企業資產介紹 • 財務分析方法 • 企業資產數據爬取 • 企業資產數據展示 企業資產介紹 企業的資產包括流動資產、固定資產、無形資產、股東權益等等,本次給大家介紹 ...
  • 主要梳理一下SpringBoot2.x的依賴關係和依賴的版本管理,依賴版本管理是開發和管理一個SpringBoot項目的前提。 SpringBoot其實是通過starter的形式,對spring-framework進行裝箱,消除了(但是相容和保留)原來的XML配置,目的是更加便捷地集成其他框架,打造 ...
  • 1.迭代器 迭代器為我們提供了統一遍歷容器(List/Map/Set)的方式 1.遍歷List或Set 2.遍歷Map 2.Collections工具類 類java.util.Collections提供對Set、List、Map進行排序、填充、查找元素的輔助方法 1.void sort(List): ...
  • 為了方便大家理解我把之前方案的圖片複製過來了,如下: 上圖的方案存在一個問題,就是我們今天文章要聊的內容。 這個問題就是當 MQ Consumer 收到消息後,就直接發佈 Event 了,如果是同步的,沒有問題。如果某個 EventListener 中處理失敗了,那麼這條消息將不會 ACK。 如果是 ...
  • 帶你捅破窗戶紙 Bash Shell 30min 過家家.zip 備註 : @博客園 : 1. 為什麼不支持 pdf 上傳了呀 2. 網站分類不好用 3. 排版OA工具升級下, 例如 markdown 寫出來好醜. 嘗試升級下呢 ? ...
一周排行
  • C#6.0新特性 C#7.0新特性 C#8.0新特性 ...
  • out變數 可以直接在方法中使用out申明變數 int.TryParse("123", out var result); 元組 元組的申明 var alphaBetaStart = (alpha: "a", beta: "b"); Console.WriteLine($"{alphaBetaStar ...
  • 在我們的項目中,通常會把數據存儲到關係型資料庫中,比如Oracle,SQL Server,Mysql等,但是關係型資料庫對於併發的支持並不是很強大,這樣就會造成系統的性能不佳,而且存儲的數據多為結構化數據,對於非結構數據(比如文本)和半結構化數據(比如JSon) 就顯得不夠靈活,而非關係型資料庫則很 ...
  • 這幾天終於弄懂了async和await的模式,也搞明白了一直在心裡面積壓著的許多問題,所以寫一篇博客來和大家分享一下。 關於非同步機制我認為只要記住的以下幾點,就可以弄明白了: 1.我認為async和awwait兩個修飾符中最關鍵的是await,async是由於方法中包含await修飾符之後才在方法定 ...
  • 實現WCF的步驟如下: 設計服務協議 實現服務協議 配置服務 托管服務 生成客戶端(這步可有可無) 設計或定義服務協議要麼使用介面,要麼使用類。建議介面,使用介面好處一堆例如修改介面的實現,但是服務協定有無需改變。 設計服務協議,介面上使用 ServiceContractAttribute ,方法上 ...
  • 什麼鬼,我的CPF快寫好了,你居然也要搞跨平臺UI框架?什麼Maui? 之前怎麼不早說要搞跨平臺UI框架呢?看到谷歌搞flutter眼紅了?明年年底發佈?又搞這種追別人屁股的爛事情。 什麼MVU模式?模仿Dart?用C#代碼直接寫UI的模式和我的CPF很像啊。 當初我考慮過XML,Json來描述UI ...
  • 寫在前面 Docker作為開源的應用容器引擎,可以讓我們很輕鬆的構建一個輕量級、易移植的容器,通過Docker方式進行持續交付、測試和部署,都是極為方便的,並且對於我們開發來說,最直觀的優點還是解決了日常開發中的環境配置與部署環境配置上的差異所帶來的種種疑難雜症,從此推脫產品的措辭也少了——“我電腦 ...
  • 一、前言 回顧:認證授權方案之授權初識 從上一節中,我們在對授權系統已經有了初步的認識和使用,可以發現,asp.net core為我們提供的授權策略是一個非常強大豐富且靈活的認證授權方案,能夠滿足大部分的授權場景。 在ConfigureServices中配置服務:將授權服務添加到容器 public ...
  • 項目背景: 工作之餘兼職一家公司(方向是工業4.0)給做IM系統,主要功能包括:文字、 圖片、文件傳輸、遠程協助、視頻語音等等。這些功能都是基於群會話, 比如工廠操作工人遇到問題,請求遠程專家,這個初級專家不能解決問題,會邀請一個高級專家進來解決。開發過程中主要遇到的問題是視頻和語音這一塊,像其他的... ...
  • 基礎概念 Microsoft中間語言(MSIL),也成為通用中間語言(CIL),是一組與平臺無關的指令,由特定於語言的編譯器從源代碼生成。MSIL是獨立於平臺的,因此,他可以在任何公共語言基礎架構支持特定的環境上執行。 通過JIT編譯器將MSIL轉換為特定電腦環境的特定機器代碼。這是在執行MSIL ...