xinglian/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 $giftModel;
    public $gifttypeModel;

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


    /**
     * 获取礼物类型
     */
    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 givegift_typing() {
        // 接口防并发
        if (!$this->apiLimit(1, 1)) {
            $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['value'],$number);

        //被赠送人信息
        $touserinfo = Db::name('user')->where('id',$user_id)->find();
        if (!$touserinfo)
        {
            $this->error("不存在的用户");
        }
        $money = 0.00;
        Db::startTrans();
        //需要走计费的规则：男的 || 女的 需要收费的
        if ($this->auth->gender == 1 || ($this->auth->gender == 0 && $this->auth->is_cost == 1)) {
            // 判断当前用户余额
            $user_gold = model('wallet')->getWallet($this->auth->id,'gold');
            if($user_gold < $giftvalue)
            {
                $this->error("您的金币余额不足");
            }





            // 添加礼物赠送记录表
            $data = [
                'user_id' => $this->auth->id,
                'user_to_id' => $user_id,
                'gift_id' => $giftinfo['id'],
                'gift_name' => $giftinfo['name'],
                'number' => $number,
                '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,$user_id,'gold',-$giftvalue,53,'赠送礼物:'.$giftinfo["name"] . '*' . $number,'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,$this->auth->id,'money',$money,54,'获得礼物:'.$giftinfo["name"] . '*' . $number,'gift_user_typing',$log_id,2);
                if($wallet_rs['status'] === false){
                    Db::rollback();
                    $this->error($wallet_rs['msg']);
                }

               /* //增加赠送用户上级金币
                if ($touserinfo['intro_uid']) {
                    //获取返利比率
                    $intro_gift_rebate_rate = (int)config('site.intro_gift_rebate_rate'); //邀请人收礼物返利比率
                    if ($intro_gift_rebate_rate > 0 && $intro_gift_rebate_rate <= 100) {
                        //上级获得金币数量
                        $intro_uid_gold = floor($giftvalue * $intro_gift_rebate_rate / 100);
                        if ($intro_uid_gold > 0) {
                            $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$user_id,'gold',$intro_uid_gold,66, '聊天礼物获赠奖励','gift_user_typing',$log_id);
                            if($intro_result['status']===false)
                            {
                                Db::rollback();
                                $this->error($intro_result['msg']);
                            }
                        }
                    }
                }*/

                //增加赠送用户上级余额
                if ($touserinfo['intro_uid']) {
                    //获取返利比率
                    $is_agent = Db::name('user')->where(['id' => $touserinfo['intro_uid']])->value('is_agent');
                    $intro_income_rebate_rate = $is_agent ? (int)config('site.h_intro_income_rebate_rate') : (int)config('site.intro_income_rebate_rate'); //邀请人收礼物返利比率
                    if ($intro_income_rebate_rate > 0 && $intro_income_rebate_rate <= 100) {
                        //上级获得金额
                        $intro_uid_money = number_format($money * $intro_income_rebate_rate / 100, 2, '.', '');
                        if ($intro_uid_money > 0) {
                            $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$user_id,'money',$intro_uid_money,68, '邀请人聊天礼物获赠奖励','gift_user_typing',$log_id);
                            if($intro_result['status']===false)
                            {
                                Db::rollback();
                                $this->error($intro_result['msg']);
                            }
                        }
                    }
                }

                if ($this->auth->gender == 1 && $touserinfo['gender'] == 0) {
                    //增加亲密度
                    $user_intimacy_rs = addintimacy($this->auth->id, $user_id, $giftvalue);
                    if (!$user_intimacy_rs['status']) {
                        Db::rollback();
                        $this->error('您的网络开小差啦~');
                    }
                }
            }
        }

        //tag任务赠送金币
        //搭讪奖励
//        $task_rs = \app\common\model\TaskLog::tofinish($this->auth->id,15);
//        if($task_rs === false){
//            Db::rollback();
//            $this->error('完成任务赠送奖励失败');
//        }

        Db::commit();

        //发送消息
        if (isset($user_intimacy_rs) && $user_intimacy_rs['level_remark']) {
            $tenim = new \app\api\controller\Tenim;
            $tenim->sendMessageToUser($this->auth->id, $user_id, $user_intimacy_rs['level_remark'], 1);
        }

        $return_data['money'] = $money; //获得金额
        $return_data['level_remark'] = isset($user_intimacy_rs) ? $user_intimacy_rs['level_remark'] : ''; //亲密度等级提示语

        $this->success('赠送成功', $return_data);
    }

    //打招呼送礼物
    public function givechatgift() {
        exit; //作废
        // 接口防并发
        if (!$this->apiLimit(1, 1)) {
            $this->error(__('Operation frequently'));
        }

        $user_id = input('user_id');// 赠送对象
        if (!$user_id) {
            $this->error();
        }
        // 不可以赠送给自己
        if($this->auth->id == $user_id) {
            $this->error("不可以赠送给自己");
        }
        //查询是否打过招呼
        $count = Db::name('gift_user_greet')->where(['user_id' => $this->auth->id, 'user_to_id' => $user_id])->count('id');
        if ($count) {
            $this->error('已经打过招呼了');
        }
        // 获取礼物信息
        $giftinfo = Db::name('gift_greet')->find();
        if (!$giftinfo) {
            $this->error('打招呼礼物异常，请联系管理员');
        }
        $giftvalue = $giftinfo['value'];

        //被赠送人信息
        $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' => 1,
            'price' => $giftvalue,
            'createtime' => time(),
        ];
        $log_id = Db::name('gift_user_greet')->insertGetId($data);
        if(!$log_id){
            Db::rollback();
            $this->error('赠送失败');
        }

        if($giftvalue > 0){
            // 扣除当前用户余额
            $wallet_rs = model('wallet')->lockChangeAccountRemain($this->auth->id,$user_id,'gold',-$giftvalue,57,'赠送礼物:'.$giftinfo["name"],'gift_user_greet',$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,$this->auth->id,'money',$money,58,'获得礼物:'.$giftinfo["name"],'gift_user_greet',$log_id,2);
            if($wallet_rs['status'] === false){
                Db::rollback();
                $this->error($wallet_rs['msg']);
            }

            /*//增加赠送用户上级金币
            if ($touserinfo['intro_uid']) {
                //获取返利比率
                $intro_gift_rebate_rate = (int)config('site.intro_gift_rebate_rate'); //邀请人收礼物返利比率
                if ($intro_gift_rebate_rate > 0 && $intro_gift_rebate_rate <= 100) {
                    //上级获得金币数量
                    $intro_uid_gold = floor($giftvalue * $intro_gift_rebate_rate / 100);
                    if ($intro_uid_gold > 0) {
                        $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$user_id,'gold',$intro_uid_gold,66, '打招呼礼物获赠奖励','gift_user_greet',$log_id);
                        if($intro_result['status']===false)
                        {
                            Db::rollback();
                            $this->error($intro_result['msg']);
                        }
                    }
                }
            }*/

            if ($this->auth->gender == 1 && $touserinfo['gender'] == 0) {
                //增加亲密度
                $user_intimacy_rs = addintimacy($this->auth->id, $user_id, $giftvalue);
                if (!$user_intimacy_rs['status']) {
                    Db::rollback();
                    $this->error('您的网络开小差啦~');
                }
            }
        }

        //tag任务赠送金币
        //搭讪奖励
        $task_rs = \app\common\model\TaskLog::tofinish($this->auth->id,24);
        if($task_rs === false){
            Db::rollback();
            $this->error('完成任务赠送奖励失败');
        }

        Db::commit();

        //发送消息
        if (isset($user_intimacy_rs) && $user_intimacy_rs['level_remark']) {
            $tenim = new \app\api\controller\Tenim;
            $tenim->sendMessageToUser($this->auth->id, $user_id, $user_intimacy_rs['level_remark'], 1);
        }

        $return_data['money'] = $money; //获得金额
        $return_data['level_remark'] = isset($user_intimacy_rs) ? $user_intimacy_rs['level_remark'] : ''; //亲密度等级提示语
        $return_data['special'] = one_domain_image($giftinfo['special']);
        $this->success('赠送成功', $return_data);
    }

    //礼物列表
    public function giftlist() {
        $where['status'] = 1;
        $giftList = Db::name('gift')->field('id, name, value, image, special,md5_str')->where($where)->order("sort, value")->select();
        $giftList = list_domain_image($giftList,['image','special']);
        $this->success("获取成功！",$giftList);
    }





}