midi-php/application/api/model/BlindBoxTurntableGift.php

<?php

namespace app\api\model;
use think\Model;
use think\Db;
use think\Session;
/*
 * 盲盒转盘
 * 2025-08-16
 */
class BlindBoxTurntableGift extends Model
{
    // 开启自动写入时间戳字段
    protected $autoWriteTimestamp = true;
    // 定义时间戳字段名
    protected $createTime = 'createtime';
    protected $updateTime = 'updatetime';
    protected $table = 'fa_vs_gift';

    //获取奖池礼物列表
    public function get_gift_list($gift_bag_id)
    {
        $box = db::name('vs_gift_bag')->where('id',$gift_bag_id)->find();
        $gifts = db::name('vs_gift_bag_detail')->where('gift_bag_id',$gift_bag_id)->order("id desc")->select();
        $gift_list = [];
        foreach ($gifts as $key => $value) {
            $gift_data = db::name('vs_gift')->where('gid',$value['foreign_id'])->where('delete_time',0)->find();
            if($gift_data){
                $gift_list[$key]['number'] = $key;
                $gift_list[$key]['gift_id'] = $gift_data['gid'];
                $gift_list[$key]['gift_name'] = $gift_data['gift_name'];
                $gift_list[$key]['base_image'] = $gift_data['base_image'];
                $gift_list[$key]['play_image'] = $gift_data['play_image'];
                $gift_list[$key]['gift_price'] = $gift_data['gift_price'];
            }
        }

        $ext = json_decode($box['ext'],true);
        $box_gift = Db::name('vs_gift')->where('gid',$ext['gift_id'])->find();
        $result_data = [
            'title' => $box['name'],
            'rule_url' => get_system_config_value('web_site')."/api/Page/get_gift_box_rule?box_id=".$box["id"],
            'rule' => $ext['introd'],
            'box_price' => $box_gift['gift_price'],
            'gift_list' => $gift_list,
        ];
        return ['code' => 1, 'msg' => '获取成功', 'data' => $result_data];
    }
    /*
     * 抽奖
     */
    public function draw_gift($gift_bag_id, $user_id, $gift_user_ids,$num=1,$room_id=0){
        //获取盲盒配置
        $bag_data = db::name("vs_gift_bag")->field('id,name,ext,periods')->where('id',$gift_bag_id)->find();
        $ext = json_decode($bag_data['ext'],true);
        $bag_gift = db::name("vs_gift")->where(['gid'=>$ext['gift_id']])->find();// 获取盲盒信息
        $toarray = explode(',',$gift_user_ids);
        //判断是否有足够的金币
        $user_waller = db::name('user_wallet')->where(['user_id'=>$user_id])->find();
        if ($user_waller['coin'] < $bag_gift['gift_price'] * $num) {
            return ['code' => 0, 'msg' => '用户金币不足', 'data' => null];
        }
        //盲盒转盘抽奖记录
        $box_turntable_log = db::name('vs_blind_box_turntable_log')->insertGetId([
            'user_id' => $user_id,
            'gift_bag_id' => $gift_bag_id,
            'num' => $num,
            'room_id' => $room_id,
            'bag_price' => $bag_gift['gift_price'],
            'createtime' => time()
        ]);
        foreach ($toarray as $gift_user_id){
            for($i = 0; $i < $num; $i++){
                $reslut_draw_gift_data = $this->draw_gift_one($gift_bag_id, $user_id, $gift_user_id,$bag_gift['gift_price'],$bag_data['periods'],$room_id,$box_turntable_log);
                $reslut_draw_gift[] = $reslut_draw_gift_data['data'];
            }
        }
        $reslut_gift = [];
        $reslut_data = [];
        foreach ($reslut_draw_gift as $key => $value) {
            $gift_user_id = $value['gift_user_id'];
            $gift_id = $value['gift_id'];

            // 以 gift_user_id 和 gift_id 作为键进行分组
            $group_key = $gift_user_id . '_' . $gift_id;

            if (!isset($reslut_gift[$group_key])) {
                $reslut_gift[$group_key] = [
                    'gift_user_id' => $gift_user_id,
                    'gift_id' => $gift_id,
                    'count' => 1,
                    'gift_price' => $value['gift_price']
                ];
            } else {
                $reslut_gift[$group_key]['count']++;
            }
            if (!isset($reslut_data[$gift_id])) {
                $reslut_data[$gift_id] = [
                    'gift_id' => $gift_id,
                    'count' => 1
                ];
             }else {
                $reslut_data[$gift_id]['count']++;
            }
        }
        $reslut_gift = array_values($reslut_gift);
        foreach ($reslut_gift as $key => $value) {
            db::name('vs_blind_box_turntable_results_log')->insert([
                'tid' => $box_turntable_log,
                'gift_user_id' => $value['gift_user_id'],
                'gift_id' => $value['gift_id'],
                'count' => $value['count'],
                'gift_price' => $value['gift_price'],
                'all_gift_price' => $value['gift_price'] * $value['count'],
                'createtime' => time()
            ]);
        }
        $reslut = [];
        $reslut['blind_box_turntable_id'] = $box_turntable_log;
        $reslut['reslut_list'] = array_values($reslut_data);
        return V(1,"成功", $reslut);
    }
    /*
     * 单人单次抽奖
     */
    public function draw_gift_one($gift_bag_id, $user_id, $gift_user_id,$gift_price,$periods,$room_id=0,$box_turntable_log=0){
        //随机获取一个礼物
        $where = [
            'gift_bag_id' => $gift_bag_id,
            'quantity' => ['>',0],
            'remaining_number' => ['>',0]
        ];
        // 优化：基于剩余数量的加权随机选择
        $gift_bag_details = db::name("vs_gift_bag_detail")->where($where)->select();
        if (empty($gift_bag_details)) {
            return ['code' => 0, 'msg' => '当前盲盒无可用礼物', 'data' => []];
        }
        //奖池总的抽奖次数
        $total_quantity  = db::name("vs_gift_bag_detail")->where(['gift_bag_id' => $gift_bag_id])->sum('quantity');
        // 实现加权随机算法：剩余数量越多，被抽中的概率越大
        $total_remaining = 0;
        foreach ($gift_bag_details as $gift) {
            $total_remaining += $gift['remaining_number'];
        }
        //本期当前第多少次后抽奖 总的抽奖次数- 剩余数量
        $total_draw_times = $total_quantity - $total_remaining;

        $rand_value = mt_rand(1, $total_remaining);
        $current_sum = 0;
        $gift_bag_detail = null;
        foreach ($gift_bag_details as $gift) {
            if($gift['remaining_number'] <= 0){
                continue;
            }
            if($total_draw_times < $gift['weight']){
                continue;
            }
            $current_sum += $gift['remaining_number'];
            if ($rand_value <= $current_sum) {
                $gift_bag_detail = $gift;
                break;
            }
        }
        if($gift_bag_detail){
            //获取开出礼物的信息
            $gift = db::name("vs_gift")->where(['gid'=>$gift_bag_detail['foreign_id']])->find();
            //处理礼包发放记录表
            $data = [];
            $data['user_id'] = $user_id;
            $data['gift_user_id'] = $gift_user_id;
            $data['parent_id'] = $box_turntable_log;
            $data['gift_bag_id'] = $gift_bag_id;
            $data['gift_id'] = $gift_bag_detail['foreign_id'];
            $data['periods'] = $periods;
            $data['room_id'] = $room_id;
            $data['gift_price'] = $gift['gift_price'];
            $data['bag_price'] = $gift_price;
            $data['createtime'] = time();
            $result = db::name("vs_gift_bag_receive_log")->insert($data);
            if(!$result){
                return ['code' => 0, 'msg' => '失败,', 'data' => []];
            }
            //减去盲盒包礼物数量
            $ret = db::name("vs_gift_bag_detail")->where('id',$gift_bag_detail['id'])->setDec('remaining_number');
            if(!$ret){
                return ['code' => 0, 'msg' => '失败.', 'data' => []];
            }
            //判断剩余数量是否为0 为0重置，进入下一期
            $gift_bag_num = db::name("vs_gift_bag_detail")->where('gift_bag_id',$gift_bag_id)->sum('remaining_number');
            if($gift_bag_num <= 0){
                db::name("vs_gift_bag")->where('id',$gift_bag_id)->setInc('periods');
                db::name("vs_gift_bag_detail")->where('gift_bag_id',$gift_bag_id)->update(['remaining_number'=>db::raw('quantity')]);
            }
        }else{
            return ['code' => 0, 'msg' => '失败!', 'data' => []];
        }
        $result_data = [
            'user_id' => $user_id,
            'gift_user_id'=>$gift_user_id,
            'gift_id'=>$gift_bag_detail['foreign_id'],
            'gift_price'=>$gift['gift_price'],
            'is_public_screen'=>$gift['is_public_screen'],
        ];
        return ['code' => 1, 'msg' => '成功', 'data' => $result_data];
    }

    /*
     * 礼物发放
     */
    public function gift_send($send_id){
        $blind_box_turntable = db('vs_blind_box_turntable_log')->where('id',$send_id)->find();
        if(!$blind_box_turntable){
            return ['code' => 0, 'msg' => '数据不存在'];
        }
        $blind_box_turntable_log = db('vs_blind_box_turntable_results_log')->where('tid',$send_id)->select();
        if(!$blind_box_turntable_log){
            return ['code' => 0, 'msg' => '开奖数据不存在'];
        }
        //获取盲盒配置
        $bag_data = db::name("vs_gift_bag")->field('id,name,ext,periods')->where('id',$blind_box_turntable['gift_bag_id'])->find();
        $ext = json_decode($bag_data['ext'],true);
        foreach ($blind_box_turntable_log as $key => $value) {
            $give_gift_ext['gift_id'] = $value['gift_id'];
            $give_gift_ext['count'] = $value['count'];
            $give_gift_ext['gift_price'] = $value['gift_price'];
            $give_gift_ext['all_gift_price'] = $value['all_gift_price'];
            $give_gift_ext['is_draw_gift'] = 1;
            $res = model('GiveGift')->give_gift($blind_box_turntable['user_id'], $value['gift_user_id'], $ext['gift_id'],  $value['count'],2,1, $blind_box_turntable['room_id'],0,0,$give_gift_ext);
            if (isset($res) && $res['code'] != 1) {
                return V(0, $res['msg']);
            }
            db('vs_blind_box_turntable_results_log')->where('id', $value['id'])->update(['is_sued' => 1, 'updatetime' => time()]);
        }
        return ['code' => 1, 'msg' => '成功', 'data' => null];
    }

    /*
     * 获取用户抽奖记录
     */
    public function get_user_record($gift_bag_id,$user_id=0,$page=1,$page_size=12){
        $where = [];
        $where['b.gift_bag_id'] = $gift_bag_id;
        if($user_id > 0){
            $where['b.user_id'] = $user_id;
        }
        $list = db('vs_blind_box_turntable_results_log')
            ->alias('a')
            ->join('vs_blind_box_turntable_log b','b.id = a.tid','left')
            ->join('user c','a.gift_user_id = c.id','left')
            ->join('vs_gift d','d.gid = a.gift_id','left')
            ->field('a.gift_id,a.count,a.gift_user_id,b.createtime,c.nickname,d.gift_name as gift_name,d.play_image')
            ->where($where)
            ->page($page,$page_size)
            ->select();
        foreach ($list as &$v){
            $v['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }
        return ['code' => 1, 'msg' => '成功', 'data' => $list];
    }
    /*
     * 获取全服抽奖记录
     */
    public function get_all_record($gift_bag_id,$page=1,$page_size=12){
        $where = [];
        $where['b.gift_bag_id'] = $gift_bag_id;
        $where['d.gift_bag_id'] = $gift_bag_id;
        $where['d.is_world_show'] = 1;
        $list = db('vs_blind_box_turntable_results_log')
            ->alias('a')
            ->join('vs_blind_box_turntable_log b','b.id = a.tid','left')
            ->join('user c','b.user_id = c.id','left')
            ->join('vs_gift_bag_detail d','d.foreign_id = a.gift_id','left')
            ->join('vs_gift e','e.gid = a.gift_id','left')
            ->field('a.gift_id,a.count,a.gift_user_id,b.createtime,c.nickname,d.name as gift_name,e.play_image')
            ->where($where)
            ->page($page,$page_size)
            ->select();
        foreach ($list as &$v){
            $v['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }
        return ['code' => 1, 'msg' => '成功', 'data' => $list];
    }
}