nk-lihaink-cn/app/api/controller/PayNotify.php

<?php
namespace app\api\controller;

use app\api\BaseController;
use EasyWeChat\Factory;
use EasyWeChat\Pay\Application;
use EasyWeChat\Pay\Message;
use think\facade\Db;
use think\facade\Log;
use think\facade\Request;

class PayNotify extends BaseController
{
    public function index(){
            $config = [
                'mch_id' => 1635725673,
                'app_id' => 'wx6e14cb98394e36bc',

                // 商户证书
                'private_key' => config_path() .'certs/apiclient_key.pem',
                'certificate' => config_path() .'certs/apiclient_cert.pem',

                // v3 API 秘钥
//            'secret_key' => '43A03299A3C3FED3D8CE7B820Fxxxxx',

                // v2 API 秘钥
                'v2_secret_key' => '95d195Dcf6ec66156dfeeb4E7435faef',

                // 平台证书：微信支付 APIv3 平台证书，需要使用工具下载
                // 下载工具：https://github.com/wechatpay-apiv3/CertificateDownloader
//            'platform_certs' => [
//                // '/path/to/wechatpay/cert.pem',
//            ],

                /**
                 * 接口请求相关配置，超时时间等，具体可用参数请参考：
                 * https://github.com/symfony/symfony/blob/5.3/src/Symfony/Contracts/HttpClient/HttpClientInterface.php
                 */
                'http' => [
                    'throw'  => true, // 状态码非 200、300 时是否抛出异常，默认为开启
                    'timeout' => 5.0,
                    // 'base_uri' => 'https://api.mch.weixin.qq.com/', // 如果你在国外想要覆盖默认的 url 的时候才使用，根据不同的模块配置不同的 uri
                ],
            ];

            $app= new Application($config);
            $server = $app->getServer();
            $server->handlePaid(function (Message $message, \Closure $next) {
                Log::error($message);
                // $message->out_trade_no 获取商户订单号
                // $message->payer['openid'] 获取支付者 openid
                // 🚨🚨🚨 注意：推送信息不一定靠谱哈，请务必验证
                // 建议是拿订单号调用微信支付查询接口，以查询到的订单状态为准
                return $next($message);
            });

// 默认返回 ['code' => 'SUCCESS', 'message' => '成功']
            return $server->serve();

    }


    // 接收微信支付状态的通知  商城后台采购商品回调
    public function notify()
    {
        // 配置信息
        $config = [
            'app_id' => 'wx0b3defb62f0f910b',//注意这个APPID只能是公众号的id，没有的话要去申请，并且在微信支付平台里绑定
            'mch_id' => '1635725673',//商户号
            'key' => '95d195Dcf6ec66156dfeeb4E7435faef',//支付秘钥
            'secret' => 'c02aa7ad9e4a5c423862e068b6cb4ad4',
            'notify_url' => Request::instance()->domain().'/api/PayNotify/notify',//异步回调通知地址
        ];
        // 这个就是 easywechat 封装的了, 一行代码搞定, 照着写就行了
        $app = Factory::payment($config);
        // 用 easywechat 封装的方法接收微信的信息, 根据 $message 的内容进行处理, 之后要告知微信服务器处理好了, 否则微信会一直请求这个 url, 发送信息
        $response = $app->handlePaidNotify(function($message, $fail){

            // 首先查看 order 表, 如果 order 表有记录, 表示已经支付过了
            $order = Db::table('cms_store_product_order')->where('order_sn', $message['out_trade_no'])->find();
            if ($order) {
                return true; // 如果已经生成订单, 表示已经处理完了, 告诉微信不用再通知了
            }

            // 查看支付日志
            $payLog = Db::table('cms_store_product_paylog')->where('out_trade_no', $message['out_trade_no'])->find();
            if (!$payLog || $payLog['time_end']) { // 如果订单不存在 或者 订单已经支付过了
                return true; // 告诉微信，我已经处理完了，订单没找到，别再通知我了
            }

            // 更新支付时间为当前时间
            $paid_at = time();
            // return_code 表示通信状态，不代表支付状态
            if ($message['return_code'] === 'SUCCESS') {
                // 用户是否支付成功
                if ($message['result_code'] === 'SUCCESS') {
                    $post_id = $payLog['product_id'];
                    // 创建订单记录
                    $order_arr = [
                        'order_sn' => $message['out_trade_no'],
                        'total_fee' => bcdiv($message['total_fee'],'100',2),
                        'pay_log_id' => $payLog['id'],
                        'status' => 1,
                        'admin_id' => $payLog['admin_id'],
                        'paid_at' => $paid_at,
                        'product_id' => $post_id,
                        'number' => $payLog['number'],
                    ];
                    Db::table('cms_store_product_order')->strict(false)->field(true)->insert($order_arr);
//                    减库存
                    Db::table('cms_store_product')->where('product_id', $post_id)->dec('stock',$payLog['number'])->update();

                    // 更新 PayLog, 这里的字段都是根据微信支付结果通知的字段设置的(https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=9_7&index=8)
                    $pay_log = [
                        'appid' => $message['appid'],
                        'bank_type' => $message['bank_type'],
                        'total_fee' => $message['total_fee'],
                        'trade_type' => $message['trade_type'],
                        'is_subscribe' => $message['is_subscribe'],
                        'mch_id' => $message['mch_id'],
                        'nonce_str' => $message['nonce_str'],
                        'openid' => $message['openid'],
                        'sign' => $message['sign'],
                        'cash_fee' => $message['cash_fee'],
                        'fee_type' => $message['fee_type'],
                        'transaction_id' => $message['transaction_id'],
                        'time_end' => $paid_at,
                        'result_code' => $message['result_code'],
                        'return_code' => $message['return_code'],
                    ];
                    Db::table('cms_store_product_paylog')->where('out_trade_no', $message['out_trade_no'])->update($pay_log);
                }
            } else {
                // 如果支付失败, 也更新 PayLog, 跟上面一样, 就是多了 error 信息
                $pay_log = [
                    'appid' => $message['appid'],
                    'bank_type' => $message['bank_type'],
                    'total_fee' => $message['total_fee'],
                    'trade_type' => $message['trade_type'],
                    'is_subscribe' => $message['is_subscribe'],
                    'mch_id' => $message['mch_id'],
                    'nonce_str' => $message['nonce_str'],
                    'openid' => $message['openid'],
                    'sign' => $message['sign'],
                    'cash_fee' => $message['cash_fee'],
                    'fee_type' => $message['fee_type'],
                    'transaction_id' => $message['transaction_id'],
                    'time_end' => $paid_at,
                    'result_code' => $message['result_code'],
                    'return_code' => $message['return_code'],
                    'err_code' => $message['err_code'],
                    'err_code_des' => $message['err_code_des'],
                ];
                Db::table('cms_store_product_paylog')->where('out_trade_no', $message['out_trade_no'])->update($pay_log);
                return $fail('通信失败，请稍后再通知我');
            }
            return true; // 返回处理完成
        });
        // 这里是必须这样返回的, 会发送给微信服务器处理结果
        return $response;
    }


}