kge/application/api/controller/Gift.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;

/**
 * 礼物接口
 */
class Gift extends Api
{
    protected $noNeedLogin = ['getGiftList','getGiftType'];
    protected $noNeedRight = '*';

    public function _initialize()
    {
        parent::_initialize();
        $this->giftModel = new \app\common\model\Gift();
        $this->gifttypeModel = new \app\common\model\GiftType();
    }

    //gift_id必须是爆币礼物才可以
    public function test($user_id,$gift_id = 0,$pay_total = 10000){

        //奖项参数
        $conf_arr = Db::name('gift_baobi_config')->where('gift_id',$gift_id)->select();
        if(empty($conf_arr)){
            return true;
        }

        //用户今天的爆币情况，与消费情况，不用区分具体哪个爆币礼物
        $today_start = strtotime(date('Y-m-d'));
        $today_end   = $today_start + 86399;
        $map = [
            'user_id' => $user_id,
            'createtime' => ['BETWEEN',[$today_start,$today_end]],
        ];
        $today_data = Db::name('gift_baobi_log')->field('sum(pay_total) as today_pay_total,sum(baobi_total) as today_baobi_total')->where($map)->find('pay_total');
        if($today_data['today_baobi_total'] > $today_data['today_pay_total']){
            //爆币比消费还高了，不用抽奖了，记录个日志，返回。这里的日志仅用来记录今日消费 sum(pay_total)
            $data = [];
            $data['user_id']   = $user_id;
            $data['gift_id'] = $gift_id;
            $data['baobi_id'] = 0;
            $data['beilv'] = 0;
            $data['rate'] = 0;
            $data['pay_total'] = $pay_total;
            $data['baobi_total'] = 0;
            $data['createtime'] = time();

            $log_id = Db::name('gift_baobi_log')->insertGetId($data);
            if(!$log_id){
                return false;
            }

            return true;
        }


        //概率新数组
        $gailv = [];
        $bei = 100; //小数变整数
        foreach ($conf_arr as $key=>$value)
        {
            $gailv[$value['id']] = $value['rate']*$bei;
        }
        //dump($gailv);

        //奖项新数组
        $conf_column = [];
        foreach ($conf_arr as $key=>$value)
        {
            $conf_column[$value['id']] = $value;
        }
        //dump($conf_column);

        //抽
        $rid = $this->getRand($gailv); //根据概率获取奖项id
        //dump($rid);

        //返回中奖结果
        $result = $conf_column[$rid];

        //爆币金额
        $baobi_total = bcdiv(bcmul($pay_total,$result['beilv'],0),100,0);

        //写入爆币记录，不论有没有钱。全都写入其实是为了方便查日志，比在money_log里找范围更小，而且可删除
        $data = [];
        $data['user_id']   = $user_id;
        $data['gift_id'] = $gift_id;
        $data['baobi_id'] = $result['id'];
        $data['beilv'] = $result['beilv'];
        $data['rate'] = $result['rate'];
        $data['pay_total'] = $pay_total;
        $data['baobi_total'] = $baobi_total;
        $data['createtime'] = time();

        $log_id = Db::name('gift_baobi_log')->insertGetId($data);
        if(!$log_id){
            return false;
        }

        //直接给用户钱
        if($baobi_total > 0){
            $rs_wallet = model('wallet')->lockChangeAccountRemain($user_id,$baobi_total,'+',0,'送礼物爆币'.$result['beilv'].'%',21,'jewel');
            if($rs_wallet['status'] === false){
                return false;
            }
        }

        //默认成功
        return true;
    }

    //概率获得算法
    private function getRand($proArr) {
        //概率数组的总概率精度
        $proSum = array_sum($proArr);

        $key = rand(1, $proSum);
//        echo $key;
        $result = 0;
        $now = 0;
        foreach ($proArr as $k=>$v)
        {
            $now = $now + $v;
            if($key<=$now)
            {
                $result = $k;
                break;
            }
        }
        unset ($proArr);
        return $result;
    }

    /**
     * 获取礼物列表
     */
    public function getGiftList() {
        $type = input('type',0);

        // 获取基本信息
        $where = ['is_show'=>1];
        if($type){
            $where['type'] = $type;
        }

        $giftList = Db::name('gift')->field('id,name,price,image,special')->where($where)->order("sort","asc")->select();
        $giftList = list_domain_image($giftList,['image','special']);
        $this->success("获取成功！",$giftList);
    }

    /**
     * 获取礼物类型
     */
    public function getGiftType() {
        // 获取基本信息
        $where = [];
        $where["is_show"] = 1;
        $giftList = $this->gifttypeModel->field("id,name")->where($where)->order("weight","desc")->select();
        $this->success("获取成功！",$giftList);
    }

    /**
     * 获取我的背包礼物
     */
    public function getMyBackGift() {

        $userid = input("user_id", $this->auth->id);
        // 分页搜索构建
        $list = \app\common\model\GiftBack::field("id,name,image,gif_image,value,sum(number) as number")
            ->where(["user_id"=>$userid,"is_use"=>0])
            ->group("name")
            ->select();
        $this->success("获取成功！",$list);
    }


    /**
     * 获取我的礼物墙
     */
    public function getMyGiftWall() {
        $user_id = input("user_id", 0);

        $userid = $user_id ? $user_id : $this->auth->id;

        $list = \app\common\model\GiftUserParty::alias('a')->join("hx_gift g", "g.id = a.gift_id", "inner")->field("gift_id,g.name,g.image,sum(number) as number")
            ->where(["user_to_id" => $userid,])
            ->group("gift_id")
            ->order('g.value desc')
            ->select();
        $this->success("获取成功！", $list);
    }

    /**
     * 获取我的礼物墙
     */
    public function getMyGiftWall_typing() {
        $user_id = input("user_id", 0);

        $userid = $user_id ? $user_id : $this->auth->id;

        $list = Db::name('gift_user_typing')->alias('log')
            ->join('gift', 'gift.id = log.gift_id', 'LEFT')->field('log.*,sum(number) as number,gift.name,gift.image,gift.special')
            ->where(['log.user_to_id' => $userid])
            ->group('log.gift_id')
            ->order('gift.price desc')
            ->select();
        $list = list_domain_image($list,['image','special']);
        $this->success("获取成功！", $list);
    }

    /**
     * 获取我的收送礼明细
     */
    public function my_gift_log(){
        $user_id = $this->auth->id;
        $type    = input('type',1);

        $where = [];
        if($type == 1){
            $where['user_id'] = $user_id;//我送出
            $joinstr = 'gup.user_to_id = user.id';
        }else{
            $where['user_to_id'] = $user_id;//我收到
            $joinstr = 'gup.user_id = user.id';
        }

        $list = Db::name('gift_user_party')->alias('gup')
            ->join('user',$joinstr,'LEFT')->field('gup.*,user.nickname')
            ->where($where)->order('id desc')->autopage()->select();
        $list = list_domain_image($list,['gift_gif_image']);

        $rs = [];
        if(empty($list)){
            $this->success(1,$rs);
        }

        foreach($list as $key => $val){
            if($type == 1){
                $remark = '赠送'.$val['nickname'].'，'.$val['gift_name'].'*'.$val['number'].'，价值'.$val['value'].'钻石';
            }else{
                $remark = $val['nickname'].'赠送，'.$val['gift_name'].'*'.$val['number'].'，价值'.$val['value'].'钻石';
            }
            $rs[] = [
                'id'         => $val['id'],
                'gift_image' => $val['gift_gif_image'],
                'createtime' => $val['createtime'],
                'remark'     => $remark
            ];
        }
        $this->success(1,$rs);
    }

    //聊天送礼物
    public function givegift_typing() {
        // 接口防并发
        if (!$this->apiLimit(1, 1000)) {
            $this->error(__('Operation frequently'));
        }

        $user_id = input('user_id');// 赠送对象
        $gift_id = input('gift_id');// 礼物ID
        $number  = input('number',1,'intval');//数量

        if (!$user_id || !$gift_id || $number < 1)
        {
            $this->error();
        }

        // 不可以赠送给自己
        if($this->auth->id == $user_id)
        {
            $this->error("不可以赠送给自己");
        }

        // 获取礼物信息
        $giftinfo = Db::name('gift')->where('id',$gift_id)->find();
        if (!$giftinfo)
        {
            $this->error("请选择礼物");
        }
        $giftvalue = bcmul($giftinfo['price'],$number);

        //被赠送人信息
        $touserinfo = Db::name('user')->where('id',$user_id)->find();
        if (!$touserinfo)
        {
            $this->error("不存在的用户");
        }

        // 判断当前用户余额
        $user_gold = model('wallet')->getWallet($this->auth->id,'gold');
        if($user_gold < $giftvalue)
        {
            $this->error("您的金币余额不足");
        }


        Db::startTrans();


        // 添加礼物赠送记录表
        $data = [
            'user_id'     => $this->auth->id,
            'user_to_id'  => $user_id,
            'gift_id'     => $giftinfo['id'],
            'gift_name'   => $giftinfo['name'],
            'number'      => $number,
            'price'       => $giftinfo['price'],
            'total_price' => $giftvalue,
            'createtime'  => time(),
        ];
        $log_id = Db::name('gift_user_typing')->insertGetId($data);
        if(!$log_id){
            Db::rollback();
            $this->error('赠送失败');
        }

        if($giftvalue > 0){

            // 扣除当前用户余额
            $wallet_rs = model('wallet')->lockChangeAccountRemain($this->auth->id,'gold',-$giftvalue,53,'赠送礼物:'.$giftinfo["name"],'gift_user_typing',$log_id);
            if($wallet_rs['status'] === false){
                Db::rollback();
                $this->error($wallet_rs['msg']);
            }

            // 添加赠送用户余额
            $money_to_gold = config('site.money_to_gold');
            $gift_plat_scale = config('site.gift_plat_scale');

            $giftmoney = bcdiv($giftvalue,$money_to_gold,2);

            $money = bcdiv(bcmul($giftmoney,100 - $gift_plat_scale,2),100,2);
            $wallet_rs = model('wallet')->lockChangeAccountRemain($user_id,'money',$money,54,'获得礼物:'.$giftinfo["name"],'gift_user_typing',$log_id);
            if($wallet_rs['status'] === false){
                Db::rollback();
                $this->error($wallet_rs['msg']);
            }
        }



        Db::commit();
        $this->success('赠送成功');

    }
}