jyblhdl_admin/application/api/controller/Secondary.php

<?php


namespace app\api\controller;

use think\Db;
use EasyWeChat\Factory;
use think\cache\driver\Redis;
use app\common\library\AliPay;
use app\common\library\Shande;
use app\api\service\CacheService;
use app\index\enum\SecondaryEnum;
use Alipay\EasySDK\Kernel\Util\ResponseChecker;
use function EasyWeChat\Kernel\Support\get_client_ip;



/**
 * @title 二级市场
 * @controller secondary
 * @package app\api\controller
 */
class Secondary extends Base
{

    public function initialize(){
        parent::initialize();
        parent::check_login();
    }

    /**
     * @title 藏品出售
     * @desc  藏品出售
     * @author  Gavin
     * @url /api/Secondary/sell
     * @method POST
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:id type:int require:1 default:1 desc:藏品ID
     * @param name:resale_price type:decimal require:1 default:1 desc:出售价格
     * @param name:second_password type:int require:1 default:-- desc:二级密码
     *
     */
    public function sell(){
        $this->checkSwitch(1);
        $id = input('id');
        $user = getMemberInfoHash($this->uid); //获取用户信息
        if ($user['is_auth']==0) $this->error('请先实名认证!');
        $resale_price = input('resale_price');
        $second_password = input('second_password');
        if (!$id || !$resale_price) $this->error('参数错误');
        if ($resale_price<'1') $this->error('最低1元');
        if ($resale_price>'99999') $this->error('最高99999元');
        $info = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('id',$id)
            ->find();
        if (!$info || $info['status']==2) $this->error('藏品不存在');
        if ($info['resale_status']!=1) $this->error('挂售状态错误');
        if ($user['second_password']!=md5($second_password)) $this->error('密码错误');
        $update_data = [
            'resale_status'=>2,
            'resale_time'=>date('Y-m-d H:i:s'),
            'resale_price'=>$resale_price
        ];
        if (Db::name('store_order_info')->where('id',$id)->update($update_data)){
            $this->success('成功');
        }
        $this->error('失败');
    }

    /**
     * @title 藏品取消出售
     * @desc  藏品取消出售
     * @author  Gavin
     * @url /api/Secondary/cancel_sell
     * @method POST
     * @header name:Authorization require:1 desc:Token
     *
     * @param name:id type:int require:1 default:1 desc:藏品ID
     */
    public function cancel_sell(){
        $this->checkSwitch(1);
        $id = input('id');
        if (!$id) $this->error('参数错误');
        $info = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('id',$id)
            ->find();
        if (!$info || $info['status']==2) $this->error('藏品不存在');
        if ($info['resale_status']!=2) $this->error('挂售状态错误');
        //判断是否有待支付订单
        $count = Db::name('store_order_info_order')->where('info_id',$id)->where('status',0)->count();
        if ($count) $this->error('支付中，无法取消');
        $update_data = [
            'resale_status'=>1,
        ];
        if (Db::name('store_order_info')->where('id',$id)->update($update_data)){
            $this->success('成功');
        }
        $this->error('失败');
    }


    /**
     * @title 标签列表
     * @desc  标签列表
     * @author  Gavin
     * @url /api/Secondary/label_list
     * @method POST
     * @header name:Authorization require:1 desc:Token
     */
    public function label_list(){
        $list = Db::name('store_collection')->whereNotIn('label','测试,测试勿拍')->group('label')->column('label');
        $list = array_merge(['全部'],$list);
        $this->success('成功',['label_list'=>$list]);
    }


    /**
     * @title 二级市场列表
     * @desc  二级市场列表
     * @author  Gavin
     * @url /api/Secondary/sell_list
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @param name:keyword type:string require:0 default: desc:关键词
     * @param name:label type:string require:0 default: desc:标签
     * @param name:time_order type:string require:0 default: desc:时间排序（asc：正序desc:倒序）
     * @param name:price_order type:string require:0 default: desc:价格排序（asc：正序desc:倒序）
     *
     * @return  name:name type:string require:0 default:0 desc:藏品名称
     * @return  name:cover type:string require:0 default:0 desc:图片
     * @return  name:member_name type:string require:0 default:0 desc:出售人名称
     * @return  name:member_headimg type:string require:0 default:0 desc:出售人头像
     * @return  name:resale_price type:string require:0 default:0 desc:出售价格
     */
    public function sell_list(){
        $keyword = input('keyword');
        $label = input('label');
        $time_order = input('time_order');
        $price_order = input('price_order');
        $count = Db::name('store_order_info')
            ->where('status','neq',2)
            ->where('resale_status',2)
            ->where('is_destruction',1)
            ->when($keyword,function ($query) use ($keyword){
                $query->whereLike('name','%'.$keyword.'%');
            })
            ->when($label,function ($query) use ($label){
                if ($label!='全部'){
                    $ids = Db::name('store_collection')->where('label',$label)->column('id');
                    $query->whereIn('c_id',$ids);
                }
            })
            ->count();
        $list = Db::name('store_order_info')
            ->where('status','neq',2)
            ->where('resale_status',2)
            ->where('is_destruction',1)
            ->when($keyword,function ($query) use ($keyword){
                $query->whereLike('name','%'.$keyword.'%');
            })
            ->when($label,function ($query) use ($label){
                if ($label!='全部'){
                    $ids = Db::name('store_collection')->where('label',$label)->column('id');
                    $query->whereIn('c_id',$ids);
                }
            })
            ->when($price_order,function ($query) use ($price_order){
                $query->order('resale_price '.$price_order);
            })
            ->when($time_order,function ($query) use ($time_order){
                $query->order('resale_time '.$time_order);
            })
            ->limit($this->off_set,$this->page_num)
            ->select();
        foreach ($list as &$v){
            $member = getMemberInfoHash($v['mid']); //获取用户信息
            $v['member_name'] = $member['name'];
            $v['member_headimg'] = $member['headimg'];
            $v['pro_info'] = json_decode($v['pro_info'],true);
            $count = Db::name('store_order_info_order')->where('info_id',$v['id'])->where('status',0)->count();
            $v['is_buy'] = $count>0 ? 1 : 0;
        }
        $this->success('成功',compact('count','list'));
    }


    /**
     * @title 二级市场详情
     * @desc  二级市场详情
     * @author  Gavin
     * @url /api/Secondary/sell_list_detail
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:id type:int  : default: desc:id
     */
    public function sell_list_detail(){
        $id = input('id');
        if (!$id) $this->error('参数错误');
        $info = Db::name('store_order_info')
            ->where('status','neq',2)
            ->where('resale_status',2)
            ->where('is_destruction',1)
            ->where('id',$id)
            ->find();
        if (!$info) $this->error('藏品不存在');
        $member = getMemberInfoHash($info['mid']); //获取用户信息
        $info['member_name'] = $member['name'];
        $info['member_headimg'] = $member['headimg'];
        $info['pro_info'] = json_decode($info['pro_info'],true);
        //判断是否有待支付订单
        $count = Db::name('store_order_info_order')->where('info_id',$id)->where('status',0)->count();
        $info['is_buy'] = $count>0 ? 1 : 0;
        $this->success('成功',$info);
    }



    /**
     * @title 购买
     * @desc  购买
     * @author  Gavin
     * @url /api/Secondary/createOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default: desc:主键ID
     * @param name:pay_type type:string require:1 default:wx desc:wx:微信zfb:支付宝sd:杉德h5
     * @param name:from type:string require:1 default:wx desc:wx:微信公众号h5:网页
     *
     * @return  name:order_no type:int require:0 default:0 desc:订单号
     * @return  name:pay type:string require:0 default:0 desc:支付信息
     */
    public function createOrder(){
        $this->checkSwitch(1);
        $redis = new Redis([ 'select'=> 2]);
        $redis_value = $redis->get('secondary_buy'.$this->uid);
        if ($redis_value){
            $this->error('请求过快,请稍后重试');
        }else{
            $redis->set('secondary_buy'.$this->uid,1,1);
        }

        $id = input('id');
        $pay_type = input('pay_type','wx');
        $from = input('from','wx');

        $this->checkSwitch(2,$pay_type);

        $user = getMemberInfoHash($this->uid); //获取用户信息
        if (!$id) $this->error('参数错误');
        if ($user['is_auth']==0) $this->error('请先实名认证!');
        $info = Db::name('store_order_info')->where('id',$id)->find();
        if (!$info) $this->error('藏品不存在');
        if ($info['resale_status']==3) $this->error('藏品已出售');

        if ($info['resale_status']==1) $this->error('藏品已撤销出售');
        if ($info['mid']==$this->uid) $this->error('不能购买自己出售的藏品');

        if (isset($user['buy_time']) && $user['buy_time']>date('Y-m-d H:i:s')) $this->error('一小时取消3次以上，4小时内禁止下单');

        //判断是否有未支付订单
        $order_count = Db::name('store_order_info_order')->where('mid',$this->uid)->where('status',0)->count();
        if ($order_count) $this->error('有未支付订单，无法下单');

        //判断是否有待支付订单
        $count = Db::name('store_order_info_order')->where('info_id',$id)->where('status',0)->count();
        if ($count) $this->error('支付中，无法下单');

        // 拿锁，防止超卖
        $lockKey = SecondaryEnum::CREATE_ORDER_KEY;
        $lock = CacheService::incr($lockKey);
        if ($lock > 1) {//没有拿到锁
            $this->error('藏品已出售');
        }
        CacheService::expire($lockKey, 5);

        $service_fee = getConfigValue('service_fee');
        $royalties = getConfigValue('royalties');
        $com = true;
        Db::startTrans();
        try {
            $order_no = get_order_sn();
            //获取价格
            $price = $info['resale_price'];
            $num = 1;
            $proportion = sprintf("%.2f",$price *($service_fee/100));    //四舍五入保留两位小数点
            $roya = sprintf("%.2f",$price *($royalties/100));    //四舍五入保留两位小数点
            $total_fee = bcmul($price,$num,2);
            $real_money = $price-$proportion-$roya;
            $data = [
                'order_no'=>$order_no,
                'mid'=>$this->uid,
                'info_id'=>$id,
                'num'=>$num,
                'pro_info'=>json_encode($info,true),
                'pay_price'=>$total_fee,
                'service_fee'=>$service_fee,
                'royalties'=>$royalties,
                'to_account'=>$real_money,
                'pay_type'=>$pay_type
            ];
            $id = Db::name('store_order_info_order')->insertGetId($data);
            $body = '纪元部落购买二级市场藏品';
            switch ($pay_type){
                case 'wx':
                    $config = retrunWxConfig();
                    $total_fee = $total_fee * 100;
                    $config['notify_url'] = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/SecondaryWxOrderNotify';
                    $app = Factory::payment($config);

                    $post_data = [
                        'body' => $body,
                        'out_trade_no' => $order_no,
                        'total_fee' => $total_fee,
                        'attach'=>$this->uid,     //自定义传值
                    ];
                    //trade_type   SAPI--JSAPI支付（或小程序支付）、NATIVE--Native支付、APP--app支付，MWEB--H5支付
                    if ($from=='wx'){
                        $post_data['openid'] = $user['openid'];
                        $post_data['trade_type'] = 'JSAPI';
                    }elseif ($from=='h5'){
                        $post_data['trade_type'] = 'MWEB';
                    }
                    $result = $app->order->unify($post_data);

                    if ($result['return_msg']=='OK'){
                        if ($result['result_code']=='FAIL'){
                            $com = false;
                            Db::rollback();
                        }else{
                            $order1 = $app->jssdk->bridgeConfig($result['prepay_id']);//执行二次签名返回参数
                            $retrun_data['order_no'] = $order_no;
                            $retrun_data['id'] = $id;
                            $retrun_data['pay'] = json_decode($order1,true);
                            Db::commit();
                        }
                    }else{
                        $com = false;
                        Db::rollback();
                    }
                    break;
                case 'zfb':
                    $zfb = new AliPay();
                    $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/alipaySecondaryNotify';//回调地址
                    $order = $zfb->ali_pay_pc($body, $total_fee, $order_no, $notify_url,'https://'.$_SERVER['SERVER_NAME'].'/web/h5/pages/shop/order');//调用支付宝支付的方法
                    $retrun_data['order_no'] = $order_no;
                    $retrun_data['id'] = $id;
                    $retrun_data['pay'] = $order;
                    Db::commit();
                    break;
                case 'sd':
                    $client = new Shande();
                    $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/shandeSecondaryNotify';//回调地址
                    $total_fee = $total_fee*100;
                    $lenth = strlen($total_fee);
                    $total_fee = get0number($lenth).$total_fee;
                    $result = $client->orderPay($order_no,$total_fee,$body,$notify_url,'https://'.$_SERVER['SERVER_NAME'].'/web/h5/pages/shop/order');
                    $retrun_data['order_no'] = $order_no;
                    $retrun_data['id'] = $id;
                    $retrun_data['pay'] = json_decode($result['data'],true);
                    Db::commit();
                    break;
            }
        }catch (\Exception $e){
            $com=false;
            Db::rollback();
        }
        if ($com){
            $this->success('成功',$retrun_data);
        }
        $this->error('失败，请稍后重试');
    }


        /**
     * @title 二级市场我的转售列表
     * @desc  二级市场我的转售列表
     * @author  Gavin
     * @url /api/Secondary/my_sell_list
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @param name:keyword type:string require:0 default: desc:关键词
     * @param name:time_order type:string require:0 default: desc:时间排序（asc：正序desc:倒序）
     * @param name:price_order type:string require:0 default: desc:价格排序（asc：正序desc:倒序）
     *
     * @return  name:name type:string require:0 default:0 desc:藏品名称
     * @return  name:cover type:string require:0 default:0 desc:图片
     * @return  name:member_name type:string require:0 default:0 desc:出售人名称
     * @return  name:member_headimg type:string require:0 default:0 desc:出售人头像
     * @return  name:resale_price type:string require:0 default:0 desc:出售价格
     */
    public function my_sell_list(){
        $keyword = input('keyword');
        $time_order = input('time_order');
        $price_order = input('price_order');
        $count = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('resale_status','neq',1)
            ->when($keyword,function ($query) use ($keyword){
                $query->whereLike('name','%'.$keyword.'%');
            })
            ->count();
        $list = Db::name('store_order_info')
            ->where('mid',$this->uid)
            ->where('resale_status','neq',1)
            ->when($keyword,function ($query) use ($keyword){
                $query->whereLike('name','%'.$keyword.'%');
            })

            ->when($price_order,function ($query) use ($price_order){
                $query->order('resale_price '.$price_order);
            })
            ->when($time_order,function ($query) use ($time_order){
                $query->order('resale_time '.$time_order);
            })
            ->order('resale_status asc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        foreach ($list as &$v){
            $member = getMemberInfoHash($v['mid']); //获取用户信息
            $v['member_name'] = $member['name'];
            $v['member_headimg'] = $member['headimg'];
            $v['pro_info'] = json_decode($v['pro_info'],true);
        }
        $this->success('成功',compact('count','list'));
    }





    /**
     * @title 二级市场订单
     * @desc  二级市场订单
     * @author  Gavin
     * @url /api/Secondary/secondaryOrderList
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @param name:status type:string require:0 default: desc:0:待支付1：已购买2：转售中3：已转售
     *
     * @return  name:name type:string require:0 default:0 desc:藏品名称
     * @return  name:cover type:string require:0 default:0 desc:图片
     * @return  name:member_name type:string require:0 default:0 desc:出售人名称
     * @return  name:member_headimg type:string require:0 default:0 desc:出售人头像
     * @return  name:pay_price type:string require:0 default:0 desc:出售价格（已购买、待支付使用）
     * @return  name:resale_price type:string require:0 default:0 desc:出售价格（转售中、已转售使用）
     */
    public function secondaryOrderList(){
        $status = input('status',0);
        switch ($status){
            case 0:case 1:
                $count =  Db::name('store_order_info_order')
                    ->where('mid',$this->uid)
                    ->where('status',$status)
                    ->count();
                $list = Db::name('store_order_info_order')
                    ->where('mid',$this->uid)
                    ->where('status',$status)
                    ->limit($this->off_set,$this->page_num)
                    ->select();
                //自动取消分钟数
                $cancel_time = getCancelTime();
                foreach ($list as &$v){
                    $v['pro_info'] = json_decode($v['pro_info'],true);
                    $member = getMemberInfoHash($v['mid']); //获取用户信息
                    $v['member_name'] = $member['name'];
                    $v['member_headimg'] = $member['headimg'];

                    if ($v['status']==0){
                        $v['cancel_time'] = date('Y-m-d H:i:s',strtotime($v['create_at'])+($cancel_time*60));
                    }
                }
                break;
            case 2:case 3:
                $count = Db::name('store_order_info')
                    ->where('mid',$this->uid)
                    ->where('resale_status',$status)
                    ->where('is_destruction',1)
                    ->count();
                $list = Db::name('store_order_info')
                    ->where('mid',$this->uid)
                    ->where('resale_status',$status)
                    ->where('is_destruction',1)
                    ->limit($this->off_set,$this->page_num)
                    ->select();
                foreach ($list as &$v){
                    $v['pro_info'] = json_decode($v['pro_info'],true);
                    $member = getMemberInfoHash($v['mid']); //获取用户信息
                    $v['member_name'] = $member['name'];
                    $v['member_headimg'] = $member['headimg'];
                }
                break;
        }
        $this->success('成功',compact('count','list'));
    }



    /**
     * @title 取消订单
     * @desc  取消订单
     * @author  Gavin
     * @url /api/Secondary/cancelOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:order_no type:string require:1 default:-- desc:订单号
     */
    public function cancelOrder(){
        $order_no = input('order_no');
        if (!$order_no) $this->error('参数错误');
        $order = Db::name('store_order_info_order')
            ->where('order_no',$order_no)
            ->where('mid',$this->uid)
            ->find();
        if (!$order) $this->error('订单不存在');
        if ($order['status']!=0) $this->error('订单已支付或已取消');
        $com = true;
        Db::startTrans();
        try {
            $up_data = [
                'status'=>2,
                'cancel_at'=>date('Y-m-d H:i:s'),
                'cancel_state'=>2
            ];
            Db::name('store_order_info_order')->where('order_no',$order_no)->update($up_data);

            $cancle = [
                'mid'=>$this->uid,
                'order_id'=>$order['id']
            ];
            Db::name('store_order_info_cancel_log')->insert($cancle);

            $time = date('Y-m-d H:i:s',time()-(60*60));
            $count = Db::name('store_order_info_cancel_log')->where('mid',$this->uid)->where('create_at','gt',$time)->count();
            if ($count>2){
                $buy_time = date('Y-m-d H:i:s',time()+(4*60*60));
                Db::name('store_member')->where('id',$this->uid)->update(['buy_time'=>$buy_time]);
            }

            Db::commit();
        }catch (\Exception $e){
            $com=false;
            Db::rollback();
        }
        if ($com){
            setMemberInfoHash($this->uid);
            $this->success('取消成功');
        }else{
            $this->error('取消失败，请稍后重试');
        }
    }

    /**
     * @title 待支付订单支付
     * @desc  待支付订单支付
     * @author  Gavin
     * @url /api/Secondary/payOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:order_no type:string require:1 default:-- desc:订单号
     * @param name:from type:string require:1 default:wx desc:wx:微信公众号h5:网页
     *
     * @return  name:order_no type:int require:0 default:0 desc:订单号
     * @return  name:pay type:string require:0 default:0 desc:支付信息
     */
    public function payOrder(){
        $this->checkSwitch(1);
        $user = getMemberInfoHash($this->uid); //获取用户信息
        $order_no = input('order_no');   //订单号
        $id = input('id');
        $from = input('from','wx');
        if (!$order_no) $this->error('参数错误');
        if (!$id) $this->error('参数错误');
        $order = Db::name('store_order_info_order')
            ->where('id',$id)
            ->where('mid',$this->uid)
            ->find();

        $order_no = $order['order_no'];

        $pay_type = $order['pay_type'];
        $this->checkSwitch(2,$pay_type);


        if (!$order) $this->error('订单不存在');
        if ($order['status']!=0) $this->error('订单已支付或已取消');
        $info = Db::name('store_order_info')->where('id',$order['info_id'])->find();
        if ($info['resale_status']!=2) $this->error('藏品已出售或已撤销出售');

        $com = true;
        Db::startTrans();
        try {
            //获取价格
            $total_fee = $order['pay_price'];
            $body = '纪元部落购买二级市场藏品';
            switch ($pay_type){
                case 'wx':
                    $config = retrunWxConfig();
                    $total_fee = $total_fee * 100;
                    $config['notify_url'] = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/SecondaryWxOrderNotify';
                    $app = Factory::payment($config);

                    $post_data = [
                        'body' => $body,
                        'out_trade_no' => $order_no,
                        'total_fee' => $total_fee,
                        'attach'=>$this->uid,     //自定义传值
                    ];
                    //trade_type   SAPI--JSAPI支付（或小程序支付）、NATIVE--Native支付、APP--app支付，MWEB--H5支付
                    if ($from=='wx'){
                        $post_data['openid'] = $user['openid'];
                        $post_data['trade_type'] = 'JSAPI';
                    }elseif ($from=='h5'){
                        $post_data['trade_type'] = 'MWEB';
                    }
                    $result = $app->order->unify($post_data);

                    if ($result['return_msg']=='OK'){
                        if ($result['result_code']=='FAIL'){
                            $com = false;
                            Db::rollback();
                        }else{
                            $order1 = $app->jssdk->bridgeConfig($result['prepay_id']);//执行二次签名返回参数
                            $retrun_data['order_no'] = $order_no;
                            $retrun_data['id'] = $order['id'];
                            $retrun_data['pay'] = json_decode($order1,true);
                            Db::commit();
                        }
                    }else{
                        $com = false;
                        Db::rollback();
                    }
                    break;
                case 'zfb':
                    $zfb = new AliPay();
                    $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/alipaySecondaryNotify';//回调地址
                    $order = $zfb->ali_pay_pc($body, $total_fee, $order_no, $notify_url,'https://'.$_SERVER['SERVER_NAME'].'/web/h5/pages/shop/order');//调用支付宝支付的方法
                    $retrun_data['order_no'] = $order_no;
                    $retrun_data['id'] = $order['id'];
                    $retrun_data['pay'] = $order;
                    Db::commit();
                    break;
                case 'sd':
                    $client = new Shande();
                    $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/api/Pay/shandeSecondaryNotify';//回调地址
                    $total_fee = $total_fee*100;
                    $lenth = strlen($total_fee);
                    $total_fee = get0number($lenth).$total_fee;
                    $order_nos = get_order_sn();
                    if (Db::name('store_order_info_order')
                        ->where('order_no',$order_no)
                        ->where('mid',$this->uid)
                        ->update(['order_no'=>$order_nos])){
                        $result = $client->orderPay($order_nos,$total_fee,$body,$notify_url,'https://'.$_SERVER['SERVER_NAME'].'/web/h5/pages/shop/order');
                        $retrun_data['order_no'] = $order_nos;
                        $retrun_data['id'] = $order['id'];
                        $retrun_data['pay'] = json_decode($result['data'],true);
                        Db::commit();
                    }else{
                        $com=false;
                        Db::rollback();
                    }
                    break;

            }
        }catch (\Exception $e){
            $com=false;
            Db::rollback();
        }
        if ($com){
            $this->success('成功',$retrun_data);
        }
        $this->error('失败，请稍后重试');
    }


    /**
     * @param 判断开关
     * @param string $pay_type
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function checkSwitch($type,$pay_type=''){
        if ($type==1){
            $v = getConfigValue('secondary_sell_switch');
            if (!$v) $this->error('维护中，暂时关闭');
        }elseif ($type==2){
            $nameArray = ['secondary_wx_switch','secondary_zfb_switch','secondary_sd_switch'];
            $values = getConfig($nameArray);
            if ($pay_type=='wx'){
                if (!$values['secondary_wx_switch']) $this->error('微信支付暂时关闭');
            }elseif ($pay_type=='zfb'){
                if (!$values['secondary_zfb_switch']) $this->error('支付宝支付暂时关闭');
            }elseif ($pay_type=='sd'){
                if (!$values['secondary_sd_switch']) $this->error('杉德支付暂时关闭');
            }
        }
        return true;
    }







}