anxinliao/application/api/controller/Gift.php

<?php

namespace app\api\controller;

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

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


    public function _initialize()
    {
        parent::_initialize();
    }

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

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


        // 获取基本信息
        $where = ['is_show'=>1];

        if(!empty($type_id)){
            $where['type_id'] = $type_id;
        }


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


    /**
     * 获取我的礼物墙
     */
    public function getMyGiftWall() {
        $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.id,log.gift_name,sum(log.number) as number,gift.image')
            ->where(['log.user_to_id' => $userid])
            ->group('log.gift_id')
            ->order('gift.price desc')
            ->select();
        $list = list_domain_image($list,['image']);
        $this->success("获取成功！", $list);
    }

    //聊天送礼物
    public function givegift_typing() {
        // 接口防并发
        if (!$this->apiLimit(1, 1000)) {
            $this->error('休息一下吧');
        }

        $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("不存在的用户");
        }

        //送礼物上限
        $limit_rs = $this->limit_gift($giftvalue);
        if($limit_rs !== true){
            $this->error($limit_rs);
        }


        Db::startTrans();

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


        // 添加礼物赠送记录表
        $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(),
        ];
        //每个礼物都要计算平台抽成和房主抽成
        $gift_plat_scale = config('site.gift_plat_scale');
        $data['platvalue']    = bcmul($gift_plat_scale/100  ,$data['total_price'],1);//平台抽成
        $data['getvalue']     = bcsub($data['total_price'] ,$data['platvalue'],1);//减去抽成剩余价值

        $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,14,'赠送给'.$touserinfo['username'].'礼物:'.$giftinfo['name'].'X'.$number,'gift_user_typing',$log_id);
            if($wallet_rs['status'] === false){
                Db::rollback();
                $this->error($wallet_rs['msg']);
            }
        }

        if($data['getvalue'] > 0){

            $wallet_rs = model('wallet')->lockChangeAccountRemain($user_id,'jewel',$data['getvalue'],24,$this->auth->username.'送给我礼物:'.$giftinfo['name'].'X'.$number,'gift_user_typing',$log_id);
            if($wallet_rs['status'] === false){
                Db::rollback();
                $this->error($wallet_rs['msg']);
            }
        }

        //增加送礼用户的财富等级
        $res_wealth = \app\common\model\User::add_wealth_level($this->auth->id,$giftvalue);
        //增加获赠用户的魅力等级
        $res_wealth = \app\common\model\User::add_charm_level($user_id,$giftvalue);
        //增加亲密度
        if ($this->auth->id > $user_id) { //大的在后
            \app\common\model\User::add_intimacy($user_id,$this->auth->id,$giftvalue);
        } else { //小的在前
            \app\common\model\User::add_intimacy($this->auth->id,$user_id,$giftvalue);
        }



        Db::commit();

        $rs = [
            'get_jewel_value' => $data['getvalue'],
        ];
        $this->success('赠送成功',$rs);

    }

    //送礼物上限
    private function limit_gift($giftvalue){
        $limit_info = Db::name('gift_limit')->where('level',$this->auth->wealth_level)->find();
        if(empty($limit_info)){
            return true;
        }

        //总共的
        if($this->auth->wealth_value + $giftvalue > $limit_info['gift_total']){
            return '您已经达到送礼物总上限';
        }

        //今日的
        $today = date('Y-m-d');
        $starttime = strtotime($today);
        $endtime   = $starttime + 86399;

        $today_sum = Db::name('gift_user_typing')->where('user_id',$this->auth->id)->where('createtime','BETWEEN',[$starttime,$endtime])->sum('total_price');
        if($today_sum + $giftvalue >= $limit_info['gift_day']){
            return '您今天已经达到送礼物上限';
        }

        return true;

    }









}