shrx/application/api/controller/pay1.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use fast\Random;
use think\Validate;
use think\Db;
use app\common\model\MoneyLog;
/**
 * 会员接口
 */
class Pay extends Api
{
    protected $noNeedLogin = ['notify'];
    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 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);
        $this->allpay($amount,$subject,$body,$number,$notify_url);
    }
    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['type']==1){
                        $up=[
                            'paytype'=>2,
                            'payment'=>$gmt_payment,
                            'trade_no'=>$trade_no,
                            'buyer'=>$_POST['buyer_logon_id'],
                            'buytype'=>'支付宝',
                            'ftime'=>time()
                            ];
                            $rt=Db::name('task')->where('out_trade_no',$out_trade_no)->update($up);
                        if ($rt){
                            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();
                    if($order['paytype']==1){
                        $up=[
                            'paytype'=>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 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;
    }
}