firstsy/application/api/controller/Pay.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\api\controller;
use EasyWeChat\Factory;
use think\Controller;
use think\Db;
use think\Exception;
use app\api\controller\Evaluate;


use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
/**
 * 支付管理类
 * Class Refund
 * @package app\api\controller\Refund
 */
class Pay extends Controller
{
    //小程序微信支付(type为1时是货主端微信配置，type为2时是接单端微信配置)
    public static function wxPay($name='订单支付',$out_trade_no,$total_fee,$notify_url,$trade_type = 'JSAPI',$openid,$type = 1){
        try{
            if(empty($out_trade_no) || empty($total_fee) || empty($notify_url)) return false;
            if($type == 1){
                $app = Factory::payment(config('app.wx_pay'));
            }else{
                $app = Factory::payment(config('app.worker_wx_pay'));
            }
            $parameter = array(
                'body' => $name,
                'out_trade_no' => $out_trade_no,
                'total_fee' => $total_fee*100,
                'notify_url' => $notify_url, // 支付结果通知网址，如果不设置则会使用配置里的默认地址
                'trade_type' => $trade_type, // 请对应换成你的支付方式对应的值类型
            );
            if($trade_type != 'APP'){
                $parameter['openid'] = $openid;
            }
            $result = $app->order->unify($parameter);
            $jssdk = $app->jssdk;
            $config = $jssdk->sdkConfig($result['prepay_id']);
            return $config;
        }catch (Exception $e){
            return false;
        }
    }
    //订单支付回调
    public function payNotify(){
        $app = Factory::payment(config('app.wx_pay'));
        $response = $app->handlePaidNotify(function ($message, $fail) {
            // 回调记录
            $ret_arr = [];
            $ret_arr['transaction_id'] =    isset($message['transaction_id']) ?$message['transaction_id']: '';
            $ret_arr['trade_no'] =          isset($message['out_trade_no']) ?$message['out_trade_no']: '';
            $ret_arr['return_code'] =       isset($message['return_code']) ?$message['return_code']: '';
            $ret_arr['result_code'] =       isset($message['result_code']) ?$message['result_code']: '';
            $ret_arr['create_at'] =         date('Y-m-d H:i:s');
            $ret_arr['result'] =            json_encode($message);
            Db::table('order_pay_result')->insert($ret_arr);
            // 使用通知里的 "微信支付订单号" 或者 "商户订单号" 去自己的数据库找到订单
            $pay_no = $message['out_trade_no'];
            $order_info = Db::name('store_order')->where('pay_no',$pay_no)->find();
            // 如果订单不存在 或者 订单已经支付过了  告诉微信，我已经处理完了，订单没找到，别再通知我了
            if ($message['result_code'] == 'SUCCESS') { // return_code 表示通信状态，不代表支付状态
                Db::startTrans();
                // 销量
                $sell_data = [];
                foreach (json_decode($order_info['pro_info'],true) as $pv){
                    $sell_data[] =[
                        'goods_id' => $pv['goods_id'],
                        'goods_no' => $pv['goods_no'],
                        'num' => $pv['num'],
                        'user_id' => $order_info['uid'],
                        'order_id' => $order_info['id'],
                        'create_at' => date('Y-m-d H:i:s'),
                        'year' => date('Y'),
                        'month' => date('m'),
                        'day' => date('d'),
                    ];
                }
                Db::table('goods_sell_info')->insertAll($sell_data);
                // 更新订单状态
                $res = Db::table('store_order')->where('id',$order_info['id'])
                    ->update(['pay_at'=>date('Y-m-d H:i:s'),'pay_state'=>1,'status'=>1]);
                // 积分 处理 （积赠送）

                // 会员等级处理

                if(!$res){
                    Db::rollback();
                }else{
                    Db::commit();
                }
                return true; // 返回处理完成
            } else if ($message['return_code'] != 'SUCCESS'){
                return $fail('通信失败，请稍后再通知我');
            }
        });
        $response->send();
    }


    public function qrtest()
    {
        $qrCode=new \Endroid\QrCode\QrCode();
        $qrCode->setText(1);
        $qrCode->setSize(200);
        $dir = dirname(realpath(dirname($_SERVER['SCRIPT_FILENAME']))) . '/public/code';
        $filename = $dir.'/1.png';
        $qrCode->writeFile($filename);
        $url='http://'.$_SERVER['SERVER_NAME']."/code/1.png";
          $res = Db::table('ticket_order')->where('id',1)
              ->update(['pay_at'=>date('Y-m-d H:i:s'),'qrcode'=>$url,'pay_state'=>1,'status'=>1]);

    }


    public function sendMsg()
    {
        $tel = input('tel');
        if(!$tel || strlen($tel) != 11) return false;
        $result = AlibabaCloud::rpc()->product('Dysmsapi')->version('2017-05-25')
            ->action('SendSms')->method('POST')->host('dysmsapi.aliyuncs.com')
            ->options([
                'query' => [
                    'RegionId' => "cn-hangzhou",
                    'PhoneNumbers' => $tel,
                    'SignName' => "慧雅",
                    'TemplateCode' => "SMS_223197414",
                    'TemplateParam' => json_encode(['film_name'=>'一剑霜寒','show_time'=>date("Y-m-d H:i:s")]),
                ],
            ])->request();
        $result = $result->toArray();
        var_dump($result);;
    }


}