xinglian/application/api/controller/Pay.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use addons\epay\library\Service;
use app\common\model\Wallet;
use think\Exception;
use app\utils\CurlUtil;

/**
 * 充值配置与充值订单
 */
class Pay extends Api
{
    protected $noNeedLogin = ['testpay'];
    protected $noNeedRight = ['*'];

    //vip用的
    public function vip_config(){
        $list = Db::name('payvip_config')->where('is_show',1)->order('weight asc,id asc')->select();
        foreach ($list as &$v) {
            $v['diff_price'] = $v['info'] - $v['money'];
        }

        $data['vipconfig'] = $list;
        $data['vip_endtime'] = model('wallet')->getWallet($this->auth->id,'vip_endtime');
        $this->success('success',$data);
    }

    //vip用的，创建订单
    /*public function vip_recharge(){

        $rc_id = input('rc_id',0);
        $pay_type = input('pay_type','wechat');
        $uid = $this->auth->id;

        if(!$rc_id){
            $this->error('请选择会员套餐');
        }


        //赋值money
        $recharge_config = Db::name('payvip_config')->where('id',$rc_id)->find();
        $money = $recharge_config['money'];

        if($money<=0)
        {
            $this->error('支付金额必须大于0');
        }
        if($money > 10000){
            $this->error('支付金额太大');
        }


        //会员等级冲突
        //当前是会员，但是却要向下级续费，直接提示报错
        //修改等级，向上立刻改，向下不允许
        $wallet_info = model('wallet')->getWallet($this->auth->id);
        if($wallet_info['vip_endtime'] > time() && $recharge_config['vip_level'] < $wallet_info['vip_level']){
            $this->error('当前会员没有过期，不能续费');
        }

        //创建订单
        $data = [];
        $data['status'] = 0;
        $pay_no = createUniqueNo('V',$uid);
        $data['pay_no'] = $pay_no;
        $data['money'] = $money;
        $data['payment_class'] = $pay_type;
        $data['user_id'] = $uid;
        $data['ext_info'] =  json_encode(['subject'=>'充值vip支付']);
        $data['memo'] =  '充值会员支付';
        $data['createtime'] = time();
        //$data['payment'] = 'miniapp';
        $data['payment'] = 'app';
        $orderid = Db::name('pay_order')->insertGetId($data);

        //创建回调
        $even_data = [];
        $even_data['event'] = 'success';
        $even_data['class'] = 'app\common\model\Recharge';
        $even_data['method'] = 'vippaysucc';
        $even_data['args'] = json_encode(['user_id'=>$uid,'days'=>$recharge_config['days'],'vip_level'=>$recharge_config['vip_level'],'gold_num'=>$recharge_config['gold_num'],'money'=>$money]);
        $even_data['pay_no'] = $pay_no;
        Db::name('pay_event')->insertGetId($even_data);

        //下单
        $params = [
            'type'         => $pay_type,
            'orderid'      => $pay_no,
            'title'        => $data['memo'],
            'amount'       => $data['money'],
            //'amount'       => 0.01,
            //'method'       => 'miniapp',
            'method'       => 'app',
            //'openid'       => $openid,
            'notifyurl' => $this->request->root(true) . '/notify.php/paytype/'.$pay_type,
            'returnurl' => '',
        ];
        $res = Service::submitOrder($params);

        if($pay_type == 'wechat'){
            $this->success('success',json_decode($res,true));
        }else{
            $this->success('success',$res);
        }
    }*/
    public function vip_recharge()
    {
        Db::startTrans();
        try {
            $rc_id = input('rc_id',0);
            $pay_type = input('pay_type','wechat');
            $uid = $this->auth->id;

            if(!$rc_id){
                throw new Exception('请选择会员套餐');
            }

            //赋值money
            $recharge_config = Db::name('payvip_config')->where('id',$rc_id)->find();
            $money = $recharge_config['money'];

            if($money <= 0) {
                throw new Exception('支付金额必须大于0');
            }
            if($money > 10000){
                throw new Exception('支付金额太大');
            }

            //会员等级冲突
            //当前是会员，但是却要向下级续费，直接提示报错
            //修改等级，向上立刻改，向下不允许
            $wallet_info = model('wallet')->getWallet($this->auth->id);
            if($wallet_info['vip_endtime'] > time() && $recharge_config['vip_level'] < $wallet_info['vip_level']){
                throw new Exception('当前会员没有过期，不能续费');
            }

            //创建订单
            $data = [];
            $data['status'] = 0;
            $pay_no = createUniqueNo('V',$uid);
            $data['pay_no'] = $pay_no;
            $data['money'] = $money;
            $data['payment_class'] = $pay_type;
            $data['user_id'] = $uid;
            $data['ext_info'] =  json_encode(['subject'=>'充值vip支付']);
            $data['memo'] =  '充值会员支付';
            $data['createtime'] = time();
            //$data['payment'] = 'miniapp';
            $data['payment'] = 'app';
            $orderid = Db::name('pay_order')->insertGetId($data);

            //创建回调
            $even_data = [];
            $even_data['event'] = 'success';
            $even_data['class'] = 'app\common\model\Recharge';
            $even_data['method'] = 'vippaysucc';
            $even_data['args'] = json_encode(['user_id'=>$uid,'days'=>$recharge_config['days'],'vip_level'=>$recharge_config['vip_level'],'gold_num'=>$recharge_config['gold_num'],'money'=>$money]);
            $even_data['pay_no'] = $pay_no;
            Db::name('pay_event')->insertGetId($even_data);

            if ($pay_type == 'wechat') {
                //$money = 0.01;
                $sandpay = new \app\common\library\Sandpay();
                $sandpayParams = [
                    'order_no' => $pay_no,
                    'goods_name' => '充值vip支付',
                    'money' => $money,
                    'type' => 'vip',
                ];
                $sandRes = $sandpay->wechath5($sandpayParams);
                if ($sandRes['status'] != 1) {
                    throw new Exception('失败');
                }
                $res = $sandRes['data'];
            } else {
                //下单
                $params = [
                    'type'         => $pay_type,
                    'orderid'      => $pay_no,
                    'title'        => $data['memo'],
                    'amount'       => $data['money'],
                    //'amount'       => 0.01,
                    'method'       => 'app',
                    'notifyurl' => CurlUtil::getHttp('/notify.php/paytype/'.$pay_type),
                    'returnurl' => '',
                ];
                $res = Service::submitOrder($params);
            }
            Db::commit();
            $this->success('success',$res);
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }


    //金币充值
    public function gold_config(){
        $list = Db::name('paygold_config')->where('is_show',1)->order('weight asc,id asc')->select();
        $data['goldconfig'] = $list;
        $data['gold'] = model('wallet')->getWallet($this->auth->id,'gold');
        $data['money_to_gold'] = config('site.money_to_gold');
        $data['is_first'] = Db::name('user_paygold_log')->where(['uid' => $this->auth->id])->count('id');

        if ($list) {
            $arr = [
                'id' => -1,
				'money' => 0,
				'gold' => 0,
				'title' => '自定义',
				'is_show' => 1,
				'weight' => 1,
				'first_gold' => 0,
				'first_vipdays' => 0
            ];

            array_push($data['goldconfig'], $arr);
            foreach ($data['goldconfig'] as &$v) {
                $v['is_first'] = $data['is_first'];
            }
        }
        $this->success('success',$data);
    }

    //充值金币 创建订单
    /*public function gold_recharge(){

        $rc_id     = input_post('rc_id',0);
        $pay_type  = input_post('pay_type','wechat');
        $freemoney = input_post('freemoney', 0, 'intval');
        $uid = $this->auth->id;

        if(!$rc_id && !$freemoney){
            $this->error('请选择或填写充值金额');
        }

        //赋值money
        if($rc_id){
            $recharge_config = Db::name('paygold_config')->where('id',$rc_id)->find();
            $money = $recharge_config ? $recharge_config['money']: 0;
            $gold  = $recharge_config ? $recharge_config['gold'] : 0;
            $first_gold     = $recharge_config ? $recharge_config['first_gold'] : 0;
            $first_vipdays  = $recharge_config ? $recharge_config['first_vipdays'] : 0;
            $vip_gold  = $recharge_config ? $recharge_config['vip_gold'] : 0;
        }

        //自由输入覆盖
        if(!empty($freemoney)){
            $rc_id = 0;
            $money = floatval($freemoney);
            $bili = config('site.money_to_gold') ?: 10;
            $gold  = bcmul($money,$bili,0);
            $first_gold = 0;
            $first_vipdays = 0;
            $vip_gold  = 0;
        }

        //
        if($money<=0)
        {
            $this->error('支付金额必须大于0');
        }
        if($money > 10000){
            $this->error('支付金额太大');
        }
        //查询是不是会员,若不是则不赠送金币
        $vip_endtime = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('vip_endtime');
        if ($vip_endtime < time()) {
            $vip_gold = 0;
        }

        //创建订单
        $data = [];
        $data['status'] = 0;
        $pay_no = createUniqueNo('P',$uid);
        $data['pay_no'] = $pay_no;
        $data['money'] = $money;
        $data['payment_class'] = $pay_type;
        $data['user_id'] = $uid;
        $data['ext_info'] =  json_encode(['subject'=>'充值金币支付']);
        $data['memo'] =  '充值金币支付';
        $data['createtime'] = time();
        $data['payment'] = 'app';
        $orderid = Db::name('pay_order')->insertGetId($data);

        //创建回调
        $even_data = [];
        $even_data['event'] = 'success';
        $even_data['class'] = 'app\common\model\Recharge';
        $even_data['method'] = 'goldpaysucc';
        $even_data['args'] = json_encode(['user_id'=>$uid,'gold'=>$gold,'money'=>$money,'pg_id'=>$rc_id,'first_gold'=>$first_gold,'first_vipdays'=>$first_vipdays, 'intro_uid' => $this->auth->intro_uid, 'vip_gold' => $vip_gold]);
        $even_data['pay_no'] = $pay_no;
        Db::name('pay_event')->insertGetId($even_data);

        //下单
        $params = [
            'type'         => $pay_type,
            'orderid'      => $pay_no,
            'title'        => $data['memo'],
            'amount'       => $data['money'],
//            'amount'       => 0.01,
            'method'       => 'app',
            'notifyurl' => $this->request->root(true) . '/notify.php/paytype/'.$pay_type,
            'returnurl' => '',
        ];
        $res = Service::submitOrder($params);
        if($pay_type == 'wechat'){
            $this->success('success',json_decode($res,true));
        }else{
            $this->success('success',$res);
        }
    }*/

    //充值金币 创建订单
    public function gold_recharge()
    {
        Db::startTrans();
        try {
            $rc_id     = input_post('rc_id',0);
            $pay_type  = input_post('pay_type','wechat');
            $freemoney = input_post('freemoney', 0, 'intval');
            $uid = $this->auth->id;

            if(!$rc_id && !$freemoney){
                throw new Exception('请选择或填写充值金额');
            }
            if (!in_array($pay_type,['wechat','alipay'])) {
                throw new Exception('错误的支付类型');
            }
            //赋值money
            if($rc_id){
                $recharge_config = Db::name('paygold_config')->where('id',$rc_id)->find();
                $money = $recharge_config ? $recharge_config['money']: 0;
                $gold  = $recharge_config ? $recharge_config['gold'] : 0;
                $first_gold     = $recharge_config ? $recharge_config['first_gold'] : 0;
                $first_vipdays  = $recharge_config ? $recharge_config['first_vipdays'] : 0;
                $vip_gold  = $recharge_config ? $recharge_config['vip_gold'] : 0;
            }

            //自由输入覆盖
            if(!empty($freemoney)){
                $rc_id = 0;
                $money = floatval($freemoney);
                $bili = config('site.money_to_gold') ?: 10;
                $gold  = bcmul($money,$bili,0);
                $first_gold = 0;
                $first_vipdays = 0;
                $vip_gold  = 0;
            }
            if($money <= 0) {
                throw new Exception('支付金额必须大于0');
            }
            if($money > 10000){
                throw new Exception('支付金额太大');
            }
            //查询是不是会员,若不是则不赠送金币
            $vip_endtime = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('vip_endtime');
            if ($vip_endtime < time()) {
                $vip_gold = 0;
            }

            //创建订单
            $data = [];
            $data['status'] = 0;
            $pay_no = createUniqueNo('P',$uid);
            $data['pay_no'] = $pay_no;
            $data['money'] = $money;
            $data['payment_class'] = $pay_type;
            $data['user_id'] = $uid;
            $data['ext_info'] =  json_encode(['subject'=>'充值金币支付']);
            $data['memo'] =  '充值金币支付';
            $data['createtime'] = time();
            $data['payment'] = 'app';
            $orderid = Db::name('pay_order')->insertGetId($data);

            //创建回调
            $even_data = [];
            $even_data['event'] = 'success';
            $even_data['class'] = 'app\common\model\Recharge';
            $even_data['method'] = 'goldpaysucc';
            $even_data['args'] = json_encode(['user_id'=>$uid,'gold'=>$gold,'money'=>$money,'pg_id'=>$rc_id,'first_gold'=>$first_gold,'first_vipdays'=>$first_vipdays, 'intro_uid' => $this->auth->intro_uid, 'vip_gold' => $vip_gold]);
            $even_data['pay_no'] = $pay_no;
            Db::name('pay_event')->insertGetId($even_data);

            if ($pay_type == 'wechat') {
                //$money = 0.01;
                $sandpay = new \app\common\library\Sandpay();
                $sandpayParams = [
                    'order_no' => $pay_no,
                    'goods_name' => '充值金币支付',
                    'money' => $money,
                    'type' => 'gold',
                ];
                $sandRes = $sandpay->wechath5($sandpayParams);
                if ($sandRes['status'] != 1) {
                    throw new Exception('失败');
                }
                $res = $sandRes['data'];
            } else {
                //下单
                $params = [
                    'type'         => $pay_type,
                    'orderid'      => $pay_no,
                    'title'        => $data['memo'],
                    'amount'       => $data['money'],
                    //'amount'       => 0.01,
                    'method'       => 'app',
                    'notifyurl' => CurlUtil::getHttp('/notify.php/paytype/'.$pay_type),
                    'returnurl' => '',
                ];
                $res = Service::submitOrder($params);
            }

            Db::commit();
            $this->success('成功', $res);
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }

    public function testpay(){
        $sandpay = new \app\common\library\Sandpay();
        $sandpayParams = [];
        $res = $sandpay->wechath5($sandpayParams);
        if ($res['status'] == 1) {
            $this->success('成功', $res['data']);
        }else {
            $this->error('失败', $res['data']);
        }

    }

    public function testsuningpay(){
        $suningpay = new \app\common\library\SuningPay();
        $suningpayParams = [];
        $res = $suningpay->wechat($suningpayParams);
        if ($res['status'] == 1) {
            $this->success('成功', $res['data']);
        }else {
            $this->error('失败', $res['data']);
        }

    }

    //vip用的，创建订单废弃
    public function sand_vip_recharge(){

        $rc_id = input('rc_id',0);
        $pay_type = input('pay_type','wechat');
        $uid = $this->auth->id;

        if(!$rc_id){
            $this->error('请选择会员套餐');
        }


        //赋值money
        $recharge_config = Db::name('payvip_config')->where('id',$rc_id)->find();
        $money = $recharge_config['money'];

        if($money<=0)
        {
            $this->error('支付金额必须大于0');
        }
        if($money > 10000){
            $this->error('支付金额太大');
        }


        //会员等级冲突
        //当前是会员，但是却要向下级续费，直接提示报错
        //修改等级，向上立刻改，向下不允许
        $wallet_info = model('wallet')->getWallet($this->auth->id);
        if($wallet_info['vip_endtime'] > time() && $recharge_config['vip_level'] < $wallet_info['vip_level']){
            $this->error('当前会员没有过期，不能续费');
        }

        //创建订单
        $data = [];
        $data['status'] = 0;
        $pay_no = createUniqueNo('V',$uid);
        $data['pay_no'] = $pay_no;
        $data['money'] = $money;
        $data['payment_class'] = $pay_type;
        $data['user_id'] = $uid;
        $data['ext_info'] =  json_encode(['subject'=>'充值vip支付']);
        $data['memo'] =  '充值会员支付';
        $data['createtime'] = time();
        //$data['payment'] = 'miniapp';
        $data['payment'] = 'app';
        $orderid = Db::name('pay_order')->insertGetId($data);

        //创建回调
        $even_data = [];
        $even_data['event'] = 'success';
        $even_data['class'] = 'app\common\model\Recharge';
        $even_data['method'] = 'sandvippaysucc';
        $even_data['args'] = json_encode(['user_id'=>$uid,'days'=>$recharge_config['days'],'vip_level'=>$recharge_config['vip_level'],'gold_num'=>$recharge_config['gold_num'],'money'=>$money]);
        $even_data['pay_no'] = $pay_no;
        Db::name('pay_event')->insertGetId($even_data);

        //下单
        $sandpay = new \app\common\library\Sandpay();
        $sandpayParams = [
            'order_no'   => $pay_no,//订单号
            'goods_name' => '充值会员',//商品名称
            'money'      => $money,//金额
            'type'       => 'vip',//会员
        ];
        $res = $sandpay->wechat($sandpayParams);
        if ($res['status'] == 1) {
            $this->success('成功', $res['data']);
        }else {
            $this->error('失败', $res['data']);
        }
    }

    //充值金币 创建订单废弃
    public function sand_gold_recharge(){

        $rc_id     = input_post('rc_id',0);
        $pay_type  = input_post('pay_type','wechat');
        $freemoney = input_post('freemoney', 0, 'intval');
        $uid = $this->auth->id;

        if(!$rc_id && !$freemoney){
            $this->error('请选择或填写充值金额');
        }
//        if(!$rc_id){
//            $this->error('请选择充值金额');
//        }

        //赋值money
        if($rc_id){
            $recharge_config = Db::name('paygold_config')->where('id',$rc_id)->find();
            $money = $recharge_config ? $recharge_config['money']: 0;
            $gold  = $recharge_config ? $recharge_config['gold'] : 0;
            $first_gold     = $recharge_config ? $recharge_config['first_gold'] : 0;
            $first_vipdays  = $recharge_config ? $recharge_config['first_vipdays'] : 0;
            $vip_gold  = $recharge_config ? $recharge_config['vip_gold'] : 0;
        }

        //自由输入覆盖
        if(!empty($freemoney)){
            $rc_id = 0;
            $money = floatval($freemoney);
            $bili = config('site.money_to_gold') ?: 10;
            $gold  = bcmul($money,$bili,0);
            $first_gold = 0;
            $first_vipdays = 0;
            $vip_gold  = 0;
        }

        //
        if($money<=0)
        {
            $this->error('支付金额必须大于0');
        }
        if($money > 10000){
            $this->error('支付金额太大');
        }
        //查询是不是会员,若不是则不赠送金币
        $vip_endtime = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('vip_endtime');
        if ($vip_endtime < time()) {
            $vip_gold = 0;
        }

        //创建订单
        $data = [];
        $data['status'] = 0;
        $pay_no = createUniqueNo('P',$uid);
        $data['pay_no'] = $pay_no;
        $data['money'] = $money;
        $data['payment_class'] = $pay_type;
        $data['user_id'] = $uid;
        $data['ext_info'] =  json_encode(['subject'=>'充值金币支付']);
        $data['memo'] =  '充值金币支付';
        $data['createtime'] = time();
        $data['payment'] = 'app';
        $orderid = Db::name('pay_order')->insertGetId($data);

        //创建回调
        $even_data = [];
        $even_data['event'] = 'success';
        $even_data['class'] = 'app\common\model\Recharge';
        $even_data['method'] = 'sandgoldpaysucc';
        $even_data['args'] = json_encode(['user_id'=>$uid,'gold'=>$gold,'money'=>$money,'pg_id'=>$rc_id,'first_gold'=>$first_gold,'first_vipdays'=>$first_vipdays, 'intro_uid' => $this->auth->intro_uid, 'vip_gold' => $vip_gold]);
        $even_data['pay_no'] = $pay_no;
        Db::name('pay_event')->insertGetId($even_data);

        //下单
        $sandpay = new \app\common\library\Sandpay();
        $sandpayParams = [
            'order_no'   => $pay_no,//订单号
            'goods_name' => '充值金币',//商品名称
            'money'      => $money,//金额
            'type'       => 'gold',//充值
        ];
        $res = $sandpay->wechat($sandpayParams);
        if ($res['status'] == 1) {
            $this->success('成功', $res['data']);
        }else {
            $this->error('失败', $res['data']);
        }
    }

    //开通会员(废弃)
    public function addvip() {
        $rc_id = input('id',0);
        $uid = $this->auth->id;
        if(!$rc_id){
            $this->error('请选择会员套餐');
        }
        //赋值money
        $recharge_config = Db::name('payvip_config')->where('id',$rc_id)->find();
        $money = $recharge_config['money'];

        if($money<=0) {
            $this->error('支付金额必须大于0');
        }
        if($money > 10000){
            $this->error('支付金额太大');
        }
        //验证余额
        $user_info = model('wallet')->getWallet($this->auth->id);
        if ($user_info['money'] < $money) {
            $this->success('您的余额不足', ['code' => 2]);
        }
        if($user_info['vip_endtime'] > time() && $recharge_config['vip_level'] < $user_info['vip_level']){
            $this->error('当前会员没有过期，不能续费');
        }

        if($user_info['vip_endtime'] < time()){
            //过期了
            $vip_endtime = time() + (intval($recharge_config['days']) * 86400);
        }else{
            //追加vip
            $vip_endtime = $user_info['vip_endtime'] + (intval($recharge_config['days']) * 86400);
        }

        //开启事务
        Db::startTrans();
        //修改会员时间
        $update_data = [
            'vip_endtime'=>$vip_endtime,
            'vip_level'  =>$recharge_config['vip_level'], //修改等级，同级不影响，向上立刻改，向下不允许
        ];

        $result = Db::name('user_wallet')->where('user_id',$uid)->update($update_data);
        if($result === false) {
            Db::rollback();
            $this->error('您的网络开小差啦~');
        }
        //扣费
        $wallet_rs = model('wallet')->lockChangeAccountRemain($uid,0,'money',-$money,16,'开通会员:'.$recharge_config["title"]);
        if($wallet_rs['status'] === false){
            Db::rollback();
            $this->error($wallet_rs['msg']);
        }
        //赠送金币
        $wallet_rs = model('wallet')->lockChangeAccountRemain($uid,0,'gold',$recharge_config['gold_num'],17,'开通会员赠送金币');
        if($wallet_rs['status'] === false){
            Db::rollback();
            $this->error($wallet_rs['msg']);
        }


        //tag任务赠送金币
        //开通VIP 50金币
//        $task_rs = \app\common\model\TaskLog::tofinish($uid,9);
//        if($task_rs === false){
//            Db::rollback();
//            $this->error('完成任务赠送奖励失败');
//        }
        Db::commit();

        $this->success('开通成功');
    }

}