shrx/application/api/controller/Pay.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use blockchain\TronService;
use blockchain\Web3Service;
use fast\Random;
use GuzzleHttp\Exception\RequestException;
use think\Validate;
use think\Db;
use app\common\model\MoneyLog;

/**
 * 会员接口
 */
class Pay extends Api
{
    protected $noNeedLogin = ['notify', 'notifycz', 'notifydsf'];
    protected $noNeedRight = '*';

    public function _initialize()
    {
        parent::_initialize();
        $this->Usermodel = model('User');
    }

    public function index()
    {
        // // 启动事务
        // Db::startTrans();
        // try {

        if (input('id', 0) > 0) {
            $id = input('id');
            $data = Db::name('task')->where('id', $id)->find();
            if ($data) {
                $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
                Db::name('task')->where('id', $id)->update(['out_trade_no' => $number, 'buytype' => input('buytype')]);
                $data = Db::name('task')->where('id', $id)->find();
            } else {
                $this->error(__('订单数据不对'));
            }
        } else {
            $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
            if (!input('price')) {
                $this->error(__('金额不对'));
            }
            $datapost = input('param.');//订单数据
            $datapost['buzs'] = htmlspecialchars_decode($datapost['buzs']);
            if (input('endtime') == '数量完成自动结束') {
                $endtimesjc = 100000000000;
            } else {
                $endtimesjc = strtotime(input('endtime'));
            }
            $up = [
                'type' => input('type'),
                'uid' => input('uid'),
                'name' => input('name'),
                'rwurl' => input('rwurl'),
                'buz' => $datapost['buzs'],
                'price' => input('price'),
                'sum' => input('sum'),
                'sumsy' => input('sum'),
                'endtime' => input('endtime'),
                'subtime' => input('subtime'),
                'shetime' => input('shetime'),
                'endtimesjc' => $endtimesjc,
                'buytype' => input('buytype'),
                'zprice' => input('price') * input('sum'),
                'out_trade_no' => $number,
                'createtime' => time(),
            ];
            $id = Db::name('task')->insertGetId($up);
            $data = $up;
        }
        $site = config('site');
        $amount = $data['zprice'];
        if (!$amount) {
            $this->error(__('金额不对'));
        }
        // 异步通知地址
        $notify_url = $site['zfb']['notifyurl'];
        // 订单标题
        $subject = 'wool订单';
        // 订单详情
        $body = 'wool致力于打造最好的移动服务平台';
        // 订单号，示例代码使用时间值作为唯一的订单ID号
        if ($data['buytype'] == '支付宝') {
            $this->allpay($amount, $subject, $body, $number, $notify_url);
        } else if ($data['buytype'] == '余额') {
            $this->yuepay($amount, input('uid'), $id);
        }
        //     // 提交事务
        //     Db::commit();
        // } catch (\Exception $e) {
        //     // 回滚事务
        //     var_dump($e);
        //     Db::rollback();
        // }
    }

    public function videopay()
    {

        $datavideo_order = Db::name('video_order')->where(['sid' => input('id'), 'uid' => input('uid'), 'lx' => 2])->find();
        $datavideo_order1 = Db::name('video_order')->where(['sid' => input('id'), 'uid' => input('uid'), 'lx' => 1])->find();
        $sad = 1;
        $lx = input('lx');
        if ($datavideo_order1) {
            if ($datavideo_order1['type'] == 2) {
                $sad = 2;
                $this->error(__('已经全集购买'));
            }
        }
        if ($datavideo_order and $lx == 2) {
            if ($datavideo_order['type'] == 2) {
                $this->error(__('已经单集购买'));
            }
            $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
            $price = input('priceq');
            $pricebuy = input('pricebuy');
            if (input('lx') == 2) {
                $price = input('priced');
                $pricebuy = input('pricebuy');
            }
            $up = [
                'type' => 1,
                'lx' => $lx,//1 全章购买 2单集购买
                'uid' => input('uid'),
                'name' => input('namet'),
                'img' => input('img'),
                'price' => $price,
                'sum' => input('sum'),
                'sid' => input('pid'),
                'smid' => input('smid'),
                'paytype' => input('buytype'),
                'zprice' => $pricebuy * input('sum'),
                'out_trade_no' => $number,
            ];
            Db::name('video_order')->where(['id' => $datavideo_order['id']])->update($up);
            $id = $datavideo_order['id'];
            $data = $up;
        } else {
            $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
            if (!input('pricebuy')) {
                $this->error(__('金额不对'));
            }
            $price = input('priceq');
            $pricebuy = input('pricebuy');
            if (input('lx') == 2) {
                $price = input('priced');
                $pricebuy = input('pricebuy');
            }
            $up = [
                'type' => 1,
                'lx' => $lx,//1 全章购买 2单集购买
                'uid' => input('uid'),
                'name' => input('namet'),
                'img' => input('img'),
                'price' => $price,
                'sum' => input('sum'),
                'sid' => input('pid'),
                'smid' => input('smid'),
                'paytype' => input('buytype'),
                'zprice' => $pricebuy * input('sum'),
                'out_trade_no' => $number,
                'createtime' => time(),
                'updatetime' => time(),
            ];
            //$this->error($up);
            $id = Db::name('video_order')->insertGetId($up);
            $data = $up;
        }

        $site = config('site');
        $amount = $data['zprice'];
        if (!$amount) {
            $this->error(__('金额不对'));
        }
        // 异步通知地址
        $notify_url = $site['zfb']['notifyurl'];
        // 订单标题
        $subject = 'wool订单';
        // 订单详情
        $body = 'wool致力于打造最好的移动服务平台';
        // 订单号，示例代码使用时间值作为唯一的订单ID号
        //var_dump($data['paytype']);
        if ($data['paytype'] == '支付宝') {
            $this->allpay($amount, $subject, $body, $number, $notify_url);
        } else if ($data['paytype'] == '余额') {
            $this->videoyuepay($amount, input('uid'), $id);
        } else if ($data['paytype'] == '微信') {
            $wxlx = input('wxlx');
            if ($wxlx == 'wxxcx') {
                $openid = input('openid');
                if (!$openid) {
                    $this->error(__('openid不对'));
                }
                $this->paywxxcx($id, $number, $amount, $openid);
            } else if ($wxlx == 'wxh5') {
                $buytype = '微信h5';
                $this->paywxh5($id, $number, $amount, $buytype);
            } else if ($wxlx == 'wxgzh') {
                $buytype = '微信公众号';
                $this->paywxh5($id, $number, $amount, $buytype);
            }

        } else if ($data['paytype'] == '汇聚') {
            $paid_price = 0;
//            if ($recharId) {
//                $data = SystemGroupData::getDateValue($recharId);
//                if ($data === false) {
//                    return app('json')->fail('您选择的充值方式已下架!');
//                } else {
//                    $paid_price = $data['give_money'] ?? 0;
//                }
//            }
//            $rechargeOrder = UserRecharge::addRecharge($request->uid(), $price, 'huifu', $paid_price);
            $recharge = Huifu::wxJsPay(session('openid'), $number, $price, $paid_price, 'video_pay');
//            return app('json')->successful(['type' => $from, 'data' => $recharge]);
        }
    }

    public function paywxh5($oid, $number, $amount, $buytype)
    {
        $site = config('site');
        $user = $this->auth->getUser();
        if (!$user) {
            $this->error(__('user不对'));
        }
        if ($amount <= 0) {
            $this->error(__('金额不对'));
        }
        $up = [
            'type' => 1,
            'uid' => $user['id'],
            'tdnum' => input('tdnum'),//支付通道
            'amount' => $amount,
            'out_trade_no' => $number,
            'createtime' => time(),
            'buytype' => $buytype,
            'oid' => $oid,
        ];
        $id = Db::name('paylog')->insertGetId($up);
        $urls = $site['imgurl'] . '/index/paydsf/wxh5?out_trade_no=' . $number;
        if ($buytype == '微信公众号') {
            $urls = $site['imgurl'] . '/index/index/pay?id=' . $id;
        }
        $this->success('订单提交成功 正在跳转支付', $urls);
    }

    public function paywxxcx($oid, $number, $amount, $openid)
    {
        $site = config('site');
        $user = $this->auth->getUser();
        if (!$user) {
            $this->error(__('user不对'));
        }
        if ($amount <= 0) {
            $this->error(__('金额不对'));
        }
        $up = [
            'type' => 1,
            'uid' => $user['id'],
            'amount' => $amount,
            'out_trade_no' => $number,
            'createtime' => time(),
            'buytype' => '微信小程序',
            'oid' => $oid,
        ];
        $id = Db::name('paylog')->insertGetId($up);
        $modelxcx = new \app\api\controller\Paywx;
        $trs = $modelxcx->wxxcx($number, $amount, $openid);
        $this->success('提交成功', $trs);
    }

    public function videoyuepay($money, $user_id, $id)//余额支付
    {
        $user = $this->Usermodel::get($user_id);
        if ($user && $money != 0) {
            $data = Db::name('video_order')->where('id', $id)->find();
            if ($user->money < $money) {
                $this->error(__('余额不足'));
            }
            $before = $user->money;
            $after = $user->money - $money;
            if ($data['type'] == 1) {
                Db::startTrans();
                try {
                    //更新会员信息
                    $user->save(['money' => $after]);
                    //写入日志
                    MoneyLog::create(['user_id' => $user_id, 'money' => $money, 'before' => $before, 'after' => $after, 'memo' => '用户消费']);
                    Db::name('video_order')->where('id', $id)->update(['type' => 2, 'paytype' => '余额', 'ftime' => time()]);

                    $this->yongjin($id, $user_id, $money, '级消费佣金结算');//佣金结算
                    $this->dailiyongjin($id, $data['sid'], $data['smid'], $user_id, $money, '佣金结算');//后台代理佣金结算

                    Db::commit();
                    $this->success(__('操作成功'));
                } catch (Exception $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                }
            } else if ($data['type'] > 1) {
                $this->error(__('已经支付'));
            }

        } else {
            $this->error(__('金额不对'));
        }
    }

    public function yuepay($money, $user_id, $id)//余额支付
    {
        $user = $this->Usermodel::get($user_id);
        if ($user && $money != 0) {
            $data = Db::name('task')->where('id', $id)->find();
            if ($user->money < $money) {
                $this->error(__('余额不足'));
            }
            $before = $user->money;
            $after = $user->money - $money;
            //更新会员信息
            $user->save(['money' => $after]);
            //写入日志
            MoneyLog::create(['user_id' => $user_id, 'money' => $money, 'before' => $before, 'after' => $after, 'memo' => '用户消费']);
            if ($data['paytype'] == 1) {
                $up = [
                    'paytype' => 2,
                    'buytype' => '余额',
                    'ftime' => time()
                ];
                if (Db::name('task')->where('id', $id)->update($up)) {
                    $this->success(__('操作成功'));
                }
            } else if ($data['paytype'] > 1) {
                $this->error(__('已经支付'));
            }
        } else {
            $this->error(__('金额不对'));
        }
    }

    public function czpay()
    {
        $site = config('site');
        $user = $this->auth->getUser();
        if (!$user) {
            $this->error(__('user不对'));
        }
        $number = date('ymdh', time()) . rand(10000, 99999);//订单编
        $amount = input('total', 0);
        $notify_url = $site['zfb']['notifyurlcz'];
        // 订单标题
        $subject = 'wool充值';
        // 订单详情
        $body = 'wool致力于打造最好的移动服务平台';
        if ($amount <= 0) {
            $this->error(__('金额不对'));
        }
        $up = [
            'type' => 1,
            'uid' => $user['id'],
            'amount' => input('total'),
            'out_trade_no' => $number,
            'createtime' => time(),
        ];
        $id = Db::name('paylog')->insertGetId($up);
        if (input('type', 'allpay') == 'iap') {
            $this->success('请求成功', $number);
        } else {
            $this->allpay($amount, $subject, $body, $number, $notify_url);
        }
    }

    public function dsfczpay()
    {
        $site = config('site');
        $user = $this->auth->getUser();
        if (!$user) {
            $this->error(__('user不对'));
        }
        $number = date('ymdh', time()) . rand(10000, 99999);//订单编
        $amount = input('total', 0);
        if ($amount <= 0) {
            $this->error(__('金额不对'));
        }
        $up = [
            'type' => 1,
            'uid' => $user['id'],
            'tdnum' => input('tdnum'),
            'amount' => $amount,
            'out_trade_no' => $number,
            'createtime' => time(),
            'buytype' => isset($site['dsfzf']['zfname']) ? $site['dsfzf']['zfname'] : '',
        ];
        $id = Db::name('paylog')->insertGetId($up);
        $urls = $site['imgurl'] . '/index/paydsf?out_trade_no=' . $number;
        $this->success('订单提交成功 正在跳转支付', $urls);
    }

    public function czpayiaptz()
    {
        $out_trade_no = input('out_trade_no');
        $order = Db::name('paylog')->where('out_trade_no', $out_trade_no)->find();
        //$this->dingding_log($order);
        if ($order['type'] == 1) {
            $up = [
                'type' => 2,
                'payment' => null,
                'trade_no' => null,
                'buyer' => null,
                'buytype' => '苹果',
                'ftime' => time()
            ];
            Db::startTrans();
            try {
                $this->money($order['amount'], $order['uid'], 0, $sxf = 0);
                Db::name('paylog')->where('out_trade_no', $out_trade_no)->update($up);
                Db::commit();
                $this->success('支付成功');
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
        } else {
            $this->success('已经支付');
        }
    }

    public function allpay($amount, $subject, $body, $out_trade_no, $notify_url)//支付宝支付
    {
        $total = floatval($amount);
        if (!$total) {
            $this->error(__('金额不对'));
        }
        //require_once('/vendor/alipayrsa2/AopSdk.php');
        //Vendor('AopSdk.alipayrsa2');
        //  require_once './vendor/alipayrsa2/aop/AopClient.php';
        //  require_once './vendor/alipayrsa2/aop/request/AlipayTradeAppPayRequest.php';
        vendor('alipayrsa2.AopSdk');
        $site = config('site');
        $aop = new \AopClient;
        $aop->gatewayUrl = "https://openapi.alipay.com/gateway.do";
        $aop->appId = $site['zfb']['appId'];
        //开发者私钥去头去尾去回车，一行字符串
        $aop->rsaPrivateKey = $site['zfb']['rsaPrivateKey'];
        $aop->format = "json";
        $aop->charset = "UTF-8";
        $aop->signType = "RSA2";
        //请填写支付宝公钥，一行字符串
        $aop->alipayrsaPublicKey = $site['zfb']['alipayrsaPublicKey'];
        //实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
        $request = new \AlipayTradeAppPayRequest();
        //SDK已经封装掉了公共参数，这里只需要传入业务参数
        $bizcontent = "{\"body\":\"" . $body . "\","
            . "\"subject\": \"" . $subject . "\","
            . "\"out_trade_no\": \"" . $out_trade_no . "\","
            . "\"timeout_express\": \"30m\","
            . "\"total_amount\": \"" . $total . "\","
            . "\"product_code\":\"QUICK_MSECURITY_PAY\""
            . "}";
        $request->setNotifyUrl($notify_url);
        $request->setBizContent($bizcontent);
        //这里和普通的接口调用不同，使用的是sdkExecute
        $response = $aop->sdkExecute($request);

        // 注意：这里不需要使用htmlspecialchars进行转义，直接返回即可
        //$this->success(__('获取成功'),$response);
        echo $response;
    }

//支付宝回调
    public function notify()
    {
        if ($_POST) {
            //Db::transaction(function () {
            if ($_POST['trade_status'] == 'TRADE_SUCCESS' or $_POST['trade_status'] == 'TRADE_FINISHED') {//处理交易完成或者支付成功的通知 //获取订单号
                $out_trade_no = $_POST['out_trade_no'];//交易号
                $trade_no = $_POST['trade_no'];//订单支付时间
                $gmt_payment = $_POST['gmt_payment'];//转换为时间戳
                $order = Db::name('task')->where('out_trade_no', $out_trade_no)->find();
                if ($order['paytype'] == 1) {
                    $up = [
                        'paytype' => 2,
                        'payment' => $gmt_payment,
                        'trade_no' => $trade_no,
                        'buyer' => $_POST['buyer_logon_id'],
                        'buytype' => '支付宝',
                        'ftime' => time()
                    ];
                    if (Db::name('task')->where('out_trade_no', $out_trade_no)->update($up)) {
                        echo 'success';
                    }
                } else {
                    echo 'success';
                }
            }
            //});
        }
    }

    public function notifycz()
    {
        if ($_POST) {
            //$this->dingding_log($_POST);
            //Db::transaction(function () {
            if ($_POST['trade_status'] == 'TRADE_SUCCESS' or $_POST['trade_status'] == 'TRADE_FINISHED') {//处理交易完成或者支付成功的通知 //获取订单号
                $out_trade_no = $_POST['out_trade_no'];//交易号
                $trade_no = $_POST['trade_no'];//订单支付时间
                $gmt_payment = $_POST['gmt_payment'];//转换为时间戳
                $order = Db::name('paylog')->where('out_trade_no', $out_trade_no)->find();
                //$this->dingding_log($order);
                if ($order['type'] == 1) {
                    $up = [
                        'type' => 2,
                        'payment' => $gmt_payment,
                        'trade_no' => $trade_no,
                        'buyer' => $_POST['buyer_logon_id'],
                        'buytype' => '支付宝',
                        'ftime' => time()
                    ];
                    Db::startTrans();
                    try {
                        $this->money($order['amount'], $order['uid'], 0, $sxf = 0);
                        Db::name('paylog')->where('out_trade_no', $out_trade_no)->update($up);
                        Db::commit();
                        echo 'success';
                    } catch (Exception $e) {
                        Db::rollback();
                        $this->error($e->getMessage());
                    }
                } else {
                    echo 'success';
                }
            }
            //});
        }
    }

    public function notifydsf()//第三方充值回调
    {
        $this->dingding_log($_REQUEST);
        //Db::transaction(function () {
        $returncode = isset($_REQUEST["returncode"]) ? $_REQUEST["returncode"] : 1;
        if ($returncode == "00") {//处理交易完成或者支付成功的通知 //获取订单号
            $out_trade_no = isset($_REQUEST["orderid"]) ? $_REQUEST["orderid"] : '';
            $order = Db::name('paylog')->where('out_trade_no', $out_trade_no)->find();
            $this->dingding_log($order);
            if ($order['type'] == 1) {
                $up = [
                    'type' => 2,
                    'ftime' => time()
                ];
                Db::startTrans();
                try {
                    $this->money($order['amount'], $order['uid'], 0, $sxf = 0);
                    Db::name('paylog')->where('out_trade_no', $out_trade_no)->update($up);
                    Db::commit();
                    echo 'OK';
                } catch (Exception $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                }
            } else {
                echo 'OK';
            }
        }
        //});
    }

    public function money($money, $user_id, $id, $sxf = 0)
    {
        $user = $this->Usermodel::get($user_id);
        if ($user && $money != 0) {
            $before = $user->money;
            $after = $user->money + $money;
            //更新会员信息
            $user->save(['money' => $after]);
            //写入日志
            MoneyLog::create(['user_id' => $user_id, 'money' => $money, 'before' => $before, 'after' => $after, 'fid' => $id, 'sxf' => $sxf, 'memo' => '用户充值']);
        } else {
            $this->error(__('金额不对'));
        }
    }

    public function dingding_log($content)
    {
        $r = $_SERVER['DOCUMENT_ROOT'] . '/api_log/' . date('Y-m-d_H-i-s', time()) . '.txt';
        $fp = fopen($r, 'w+');
        fwrite($fp, "执行日期：" . date('Y-m-d H:i:s', time()) . ' ' . var_export($content, true));
        fclose($fp);
    }

    public function FromXml($xml)
    {
        //将XML转为array
        //禁止引用外部xml实体
        libxml_disable_entity_loader(true);
        $values = json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
        return $values;
    }

    public function sharepay()
    {

//        $datavideo_order=Db::name('video_share')->where(['vid'=>input('id'),'uid'=>input('uid')])->find();
//        $datavideo_order1=Db::name('video_share')->where(['sid'=>input('id'),'uid'=>input('uid'),'lx'=>1])->find();
        $sad = 1;
//        $lx=input('lx');
        $num = input('num'); //购买的版权数量
        $uid = input('uid');
        $vid = input('vid');
//        验证数量
        $user_num = Db::name('video_user')->where('uid', $uid)->where('vid', $vid)->find();
        if ($user_num) {
            $cs_num = $user_num['share'] + $num;
            if ($cs_num > 10 || $num > 10) {
                $this->error(__('单剧集购买版权不能超过10份'));
            }
        }
        $user_share = Db::name('videolist')->where('id', $vid)->value('share');
        $user_shares = $user_share - $num;
        if ($user_shares < 0) {
            $this->error(__('该局总版权只剩下' . $user_share . '份'));
        }
//        if($datavideo_order){
//            if($datavideo_order['type']==2){
//                $this->error(__('该订单已支付'));
//            }
//            $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
//            $price=input('priceq');
//            $pricebuy=input('pricebuy');
//            if(input('lx')==2){
//                $price=input('priced');
//                $pricebuy=input('pricebuy');
//            }
//            $up=[
//                'type'=>1,
//                'lx'=>$lx,//1 全章购买 2单集购买
//                'uid'=>input('uid'),
//                'name'=>input('namet'),
//                'img'=>input('img'),
//                'price'=>$price,
//                'sum'=>input('sum'),
//                'sid'=>input('pid'),
//                'smid'=>input('smid'),
//                'paytype'=>input('buytype'),
//                'zprice'=>$pricebuy*input('sum'),
//                'out_trade_no'=>$number,
//            ];
//            Db::name('video_order')->where(['id'=>$datavideo_order['id']])->update($up);
//            $id=$datavideo_order['id'];
//            $data=$up;
//        }else{
        $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
//        if (!input('pricebuy')) {
//            $this->error(__('金额不对'));
//        }
        $price = input('price');
//        $pricebuy = input('pricebuy');
//            if(input('lx')==2){
//                $price=input('priced');
//                $pricebuy=input('pricebuy');
//            }
        // 获取当前时间的时间戳
        $now = time();

// 计算三年后的时间戳
        $threeYearsLater = strtotime('+3 years', $now);
        $vname = Db::name('videolist')->where('id', input('vid'))->value('name');
        $total_price = $price * $num;
        $up = [
            'type' => 1,
            'uid' => input('uid'),
            'vid' => input('vid'),
            'vname' => $vname,
            'num' => input('num'),
            'price' => $price,
            'total_price' => $total_price,
            'paytype' => input('buytype'),
            'out_trade_no' => $number,
            'createtime' => time(),
            'endtime' => $threeYearsLater,
            'updatetime' => time(),
        ];
        //$this->error($up);
        $id = Db::name('video_share')->insertGetId($up);
        $data = $up;
//        }

        $site = config('site');
        $amount = $price;
//        $amount = $data['zprice'];
//        if (!$amount) {
//            $this->error(__('金额不对'));
//        }
        // 异步通知地址
        $notify_url = $site['zfb']['notifyurl'];
        // 订单标题
        $subject = 'wool订单';
        // 订单详情
        $body = 'wool致力于打造最好的移动服务平台';
        // 订单号，示例代码使用时间值作为唯一的订单ID号
        //var_dump($data['paytype']);
        if ($data['paytype'] == '支付宝') {
            $this->allpay($amount, $subject, $body, $number, $notify_url);

        } else if ($data['paytype'] == '余额') {
            $this->shareyuepay($amount, input('uid'), $id);
        } else if ($data['paytype'] == '微信') {
            $wxlx = input('wxlx');
            if ($wxlx == 'wxxcx') {
                $openid = input('openid');
                if (!$openid) {
                    $this->error(__('openid不对'));
                }
                $this->paywxxcx($id, $number, $amount, $openid);
            } else if ($wxlx == 'wxh5') {
                $buytype = '微信h5';
                $this->paywxh5($id, $number, $amount, $buytype);
            } else if ($wxlx == 'wxgzh') {
                $buytype = '微信公众号';
                $this->paywxh5($id, $number, $amount, $buytype);
            } else if ($data['paytype'] == '汇聚') {
                $paid_price = 0;
//            if ($recharId) {
//                $data = SystemGroupData::getDateValue($recharId);
//                if ($data === false) {
//                    return app('json')->fail('您选择的充值方式已下架!');
//                } else {
//                    $paid_price = $data['give_money'] ?? 0;
//                }
//            }
//            $rechargeOrder = UserRecharge::addRecharge($request->uid(), $price, 'huifu', $paid_price);
                $recharge = Huifu::wxJsPay(session('openid'), $number, $price, $paid_price, 'share_pay');
//            return app('json')->successful(['type' => $from, 'data' => $recharge]);
            }

        }
    }

//   判断订单的用户是否有上级以及判断推荐等级
    public function grade_sell($out_trade_no)
    {
        $order = Db::name('video_share')->where('out_trade_no', $out_trade_no)->find();
        if ($order) {
            $user = Db::name('user')->where('id', $order['uid'])->find();
            while ($user['pid'] != 1) {  //默认账号pid为1
                $user = Db::name('user')->where('id', $user['pid'])->find();  //上级用户信息
                $grade = $user['grade'];
                $video_user = Db::name('video_user')->where('uid', $user['id'])->where('vid', $order['vid'])->find();
                if (empty($video_user)) { //如果上级没有购买过该视频版权
                    $up = [
                        'vid' => $order['vid'],
                        'vname' => $order['vname'],
                        'uid' => $user['id'],
                        'share' => 0,
                        'contribution' => 0,
                        'income' => 0,
                        'createtime' => time(),
                    ];
                    $id = Db::name('VideoUser')->insertGetId($up);  //添加用户版权
                }
                $contribution = 0;
                $check = 0;
//                $sell = $video_user['sell'] + $order['num'];
                $sell = $user['sell'] + $order['num'];
//                switch ($video_user['grade']) {
                switch ($user['grade']) {
                    case 0:
                        $contribution = 0.5 * $order['num'];
                        if ($sell >= 30) {
                            $check = 1;
                            $sell = $sell - 30;
                        }
                        break;
                    case 1:
                        $contribution = 0.2 * $order['num'];
                        if ($sell >= 300) {
                            $check = 1;
                            $sell = $sell - 300;
                        }
                        break;
                    case 2:
                        $contribution = 0.1 * $order['num'];
                        if ($sell >= 3000) {
                            $check = 1;
                            $sell = $sell - 3000;
                        }
                        break;
                    case 3:
                        $contribution = 0.05 * $order['num'];
                    default:
                }
                if ($check == 1) {
//                    $grade = $video_user['grade'] + 1;
                    $grade = $user['grade'] + 1;
                }
                $after = $video_user['contribution'] + $contribution;
//                $res = Db::name('video_user')->where('uid', $user['id'])->where('vid', $order['vid'])->update(['sell' => $sell, 'contribution' => $after, 'grade' => $grade]);
                $res = Db::name('video_user')->where('uid', $user['id'])->where('vid', $order['vid'])->update(['contribution' => $after]);
                $res2 = Db::name('user')->where('id', $user['id'])->update(['grade' => $grade, 'sell' => $sell]);
                $up = [
                    'vid' => $order['vid'],
                    'vname' => $order['vname'],
                    'uid' => $user['id'],
                    'link_id' => $order['id'],
                    'num' => $contribution,
                    'after' => $contribution,
                    'content' => '下级用户购买版权，获得贡献值',
                    'createtime' => time(),
                    'pm' => 0,
                ];
                $id = Db::name('VideoContributionRecord')->insertGetId($up);
            }
        }

    }

//    添加贡献值记录                订单id
    public function share_record($id)
    {
        $order = Db::name('video_share')->where('id', $id)->find();
        if ($order) {
            $user = Db::name('video_user')->where('uid', $order['uid'])->where('vid', $order['vid'])->find();
            $contribution = $order['num'] + $user['contribution'];
            $up = [
                'vid' => $order['vid'],
                'vname' => $order['vname'],
                'uid' => $user['id'],
                'link_id' => $order['id'],
                'num' => $order['num'],
                'after' => $contribution,
                'content' => '用户购买版权，获得贡献值',
                'createtime' => time(),
                'pm' => 0,
            ];
            $id = Db::name('VideoContributionRecord')->insertGetId($up);
            $share = $user['share'] + $order['num'];
//          添加版权和贡献值
            $res = Db::name('video_user')->where('uid', $user['uid'])->where('vid', $order['vid'])->update(['contribution' => $contribution, 'share' => $share]);
        }
    }

    public function shareyuepay($money, $user_id, $id)//版权余额支付
    {
        $user = $this->Usermodel::get($user_id);
        if ($user && $money != 0) {
            $data = Db::name('video_share')->where('id', $id)->find();
            if ($user->money < $money) {
                $this->error(__('余额不足'));
            }
            $before = $user->money;
            $after = $user->money - $money;
            if ($data['type'] == 1) {
                Db::startTrans();
                try {
                    //更新会员信息
                    $user->save(['money' => $after]);
                    //写入日志
                    MoneyLog::create(['user_id' => $user_id, 'money' => $money, 'before' => $before, 'after' => $after, 'memo' => '用户消费']);
                    Db::name('video_share')->where('id', $id)->update(['type' => 2, 'paytype' => '余额', 'pay_time' => time()]);
                    $video_user = Db::name('video_user')->where('uid', $user_id)->where('vid', $data['vid'])->find();
                    if (empty($video_user)) { //判断用户是否购买过该视频版权
                        $up = [
                            'vid' => $data['vid'],
                            'vname' => $data['vname'],
                            'uid' => $data['uid'],
                            'share' => $data['num'],
                            'contribution' => $data['num'],
                            'income' => 0,
                            'createtime' => time(),
                        ];
                        $id = Db::name('VideoUser')->insertGetId($up);
                    }

                    $this->share_record($id);//添加贡献值记录
                    $this->yongjin($id, $user_id, $money, '级消费佣金结算');//佣金结算
                    $this->dailiyongjin($id, $data['vid'], 0, $user_id, $money, '佣金结算');//后台代理佣金结算
                    $this->grade_sell($data['out_trade_no']);//判断订单的用户是否有上级以及判断推荐等级)

//                    扣除短剧总版权
                    $shares = Db::name('videolist')->where('id', $data['vid'])->value('share');
                    $share = $shares - $data['num'];
                    Db::name('videolist')->where('id', $data['vid'])->update(['share' => $share]);

                    Db::commit();
                    $this->success(__('操作成功'));
                } catch (Exception $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                }
            } else if ($data['type'] > 1) {
                $this->error(__('已经支付'));
            }

        } else {
            $this->error(__('金额不对'));
        }
    }

//    u币充值(展示二维码)
    public function recharge()
    {
        $uid = input('uid');
        $recharge_type = input('type');
        $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
        $user = Db::name('user')->where('id', $uid)->find();
        if (empty($user)) {
            $this->error(__('用户不存在'));
        }
//        $data = [
//            'order_id'=> $number,
//            'uid' => $uid,
//            'paid' => 0,
//            'add_time' => time()
//        ];
        $return = [];
        $address = Db::name('user_usdt_address')->where('uid', $uid)->find();
        if ($recharge_type == 'trx') {
//            $data['recharge_type']='trx';
            $return['address'] = $address['trx_address'];
            $return['16_address'] = $address['trx_16_address'];
        } elseif ($recharge_type == 'bsc') {
//            $data['recharge_type']='bsc';
            $return['address'] = $address['bsc_address'];
        }
//        Db::name('user_recharge')->insert($data);
        Db::name('user_usdt_address')->where('uid', $uid)->update(['last_recharge' => time()]);
        $this->success($return);
    }

    // 查询u币转账记录
    public function search_recharge()
    {
        $time = strtotime("-1 hours", time());
        $user_address = Db::name('user_usdt_address')->where('last_recharge', '>', $time)->order('last_recharge desc')->select();
        foreach ($user_address as $k => $v) {

            $user_info = Db::name('user')->where('id', $v['uid'])->find();
//            trx部分
            $service = TronService::instance('usdt');
            $time =bcmul($v['last_time'], 1000, 0);
            $info = $service->getTransfer($v['trx_address'], $time);
            foreach ($info['data'] as $k2 => $v2){
                $transaction_id = $v2['transaction_id'];
                $value =bcmul($v2['value'], 1000000, 0);
                $be = DB::name('user_recharge')->where('hash', $transaction_id)->find();
                if ($be) {  //hash重复
                    continue;
                }
                $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
                $data = [
                    'order_id' => $number,
                    'uid' => $v['uid'],
                    'paid' => 1,
                    'price' => $value,
                    'transactionHash' => $transaction_id,
                    'pay_time' => time(),
                    'add_time' => time()
                ];
                Db::name('user_recharge')->insert($data);
                Db::name('user_usdt_address')->where('uid', $v['uid'])->update(['last_time' => time()]);
                $money = bcadd($user_info['money'], $value, 18);
                Db::name('user')->where('id', $v['uid'])->update(['money' => $money]);
                MoneyLog::create(['user_id' => $v['uid'], 'money' => $value, 'before' => $user_info['money'], 'after' => $money, 'memo' => '用户trx余额充值']);

            }
//                bsc部分
            $service = Web3Service::instance('bsc', 'usdt', '');
            $info = $service->getLastTransfer([], [$v['bsc_address']], $v['last_time']);

            foreach ($info as $k2 => $v2) {
                $value = $v2->params['value']->toString();  //金额
                $value2 = bcdiv($value, bcpow(10, get_token_info('bsc', 'USDT', 'decimal')), 12);
                $transactionHash = $v2->transactionHash;
                $be = DB::name('user_recharge')->where('hash', $transactionHash)->find();
                if ($be) {  //hash重复
                    continue;
                }
                $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
                $data = [
                    'order_id' => $number,
                    'uid' => $v['uid'],
                    'paid' => 1,
                    'price' => $value2,
                    'transactionHash' => $transactionHash,
                    'pay_time' => time(),
                    'add_time' => time()
                ];
                Db::name('user_recharge')->insert($data);
                Db::name('user_usdt_address')->where('uid', $v['uid'])->update(['last_time' => time()]);
                $money = bcadd($user_info['money'], $value2, 18);
                Db::name('user')->where('id', $v['uid'])->update(['money' => $money]);
                MoneyLog::create(['user_id' => $v['uid'], 'money' => $value2, 'before' => $user_info['money'], 'after' => $money, 'memo' => '用户bsc余额充值']);

            }
            sleep(60);
        }
    }

    public function test()
    {
//        $service = Web3Service::instance('bsc', 'usdt', '');
//        $info = $service->getLastTransfer([], ['0xbfc3b2193653ebf94bfa3fe586627b9c01f26db9'], 1748293200);
//
//
//
//
//        foreach ($info as $k => $v) {
//            $value = $v->params['value']->toString();
//            var_dump($value);
//            $transactionHash = $v->transactionHash;
//            var_dump($transactionHash);
//            $value = bcdiv($value, bcpow(10, get_token_info('bsc', 'TUSD', 'decimal')), 12);  //把后面的0去掉
//            var_dump($value);
//        }
//        var_dump($info);
//        die();

//        trx  TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t
        $service = TronService::instance('usdt');

        $info = $service->getTransfer('TFRpdAs4SP1uoWcq8Kkx4769QQnJJGyPUX', 1748293200000);
        $user_info = Db::name('user')->where('id', 1571)->find();
        foreach ($info['data'] as $k2 => $v2){
            $transaction_id = $v2['transaction_id'];
            $value =bcmul($v2['value'], 1000000, 0);
            $be = DB::name('user_recharge')->where('hash', $transaction_id)->find();
            if ($be) {  //hash重复
                continue;
            }
            $number = date('ymdh', time()) . rand(10000, 99999);//订单编号
            $data = [
                'order_id' => $number,
                'uid' => 1571,
                'paid' => 1,
                'price' => $value,
                'transactionHash' => $transaction_id,
                'pay_time' => time(),
                'add_time' => time()
            ];
            Db::name('user_recharge')->insert($data);
            Db::name('user_usdt_address')->where('uid', 1571)->update(['last_time' => time()]);
            $money = bcadd($user_info['money'], $value, 18);
            Db::name('user')->where('id', 1571)->update(['money' => $money]);
            MoneyLog::create(['user_id' => 1571, 'money' => $value, 'before' => $user_info['money'], 'after' => $money, 'memo' => '用户trx余额充值']);

        }
        var_dump($info);die();
    }
//    function paginatedTransferQuery($service, $toAddress, $targetTimestamp) {
//        $BPS = 3; // BSC每秒区块数
//        $currentBlock = intval(time() * $BPS);
//        $startBlock = intval($targetTimestamp * $BPS);
//        $pageSize = 500;
//        $results = [];
//        $attempts = 0;
//
//        while ($startBlock <= $currentBlock && $attempts < 50) {
//            $endBlock = min($startBlock + $pageSize - 1, $currentBlock);
//
//            try {
//                $transfers = $service->getLastTransfer(
//                    [],
//                    [$toAddress],
//                    0,
//                    $startBlock,
//                    $endBlock
//                );
//
//                // 只有当有结果时才处理
//                if (!empty($transfers)) {
//                    $results = array_merge($results, $transfers);
//
//                    // 检查是否达到目标时间
//                    $newest = end($transfers);
//                    reset($transfers); // 重置数组指针
//
//                    // 确保有 timestamp 属性再检查
//                    if (property_exists($newest, 'timestamp') && $newest->timestamp >= time() - 60) {
//                        break; // 已查询到最新区块
//                    }
//                }
//
//                // 成功时增加分页大小
//                $pageSize = min(5000, $pageSize * 2);
//                $startBlock = $endBlock + 1;
//
//            } catch (RequestException $e) {
//                if (strpos($e->getMessage(), '413') !== false) {
//                    $pageSize = max(100, $pageSize / 2);
//                    $attempts++;
//                    continue;
//                }
//                throw $e;
//            } catch (\Throwable $e) {
//                // 捕获所有类型错误
//                error_log("查询错误: " . $e->getMessage());
//                $pageSize = max(100, $pageSize / 2);
//                $attempts++;
//                continue;
//            }
//
//            usleep(100000);
//            $attempts++;
//        }
//
//        return array_filter($results, function($t) use ($targetTimestamp) {
//            return property_exists($t, 'timestamp') && $t->timestamp >= $targetTimestamp;
//        });
//    }
}