xiaoding-backend-php/app/Http/Services/Frontend/Client/Wechat/PaymentService.php

<?php
/**
 * @Name
 * @Description
 * @Author 刘学玺
 * @Date 2024/10/17 14:43
 */

namespace App\Http\Services\Frontend\Client\Wechat;

use App\Http\Services\Service;
use App\Models\Member\User;
use App\Models\Service\Order;
use EasyWeChat\Pay\Application;
use EasyWeChat\Pay\Message;
use Exception;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Log;
use Overtrue\LaravelWeChat\EasyWeChat;
use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
use Throwable;


class PaymentService extends Service
{
    /**
     * @throws TransportExceptionInterface
     */
    public function payment(array $params)
    {
        try {
            $order_id = $params['order_id'];
            !$order_id && self::error('订单异常');
            // 查询订单详情
            $order = Order::query()->find($order_id);
            !$order && self::error('订单错误');
            $order->status === 1 && self::error('订单已支付');
            $order->status && self::error('订单状态异常');

            // 获取用户Openid
            $openid = User::query()->where('id', Auth::id())->value('openid');
            $pay = EasyWeChat::pay();
            $merchant = $pay->getMerchant();

//            $app = EasyWeChat::officialAccount();
//            $client = $app->getClient();

            $config = EasyWeChat::pay()->getConfig();
            $app = new Application($config);

            $openid = 'oBxIn6qjN6YCjz1iElb5NDfBdYaM';

            $response = $app->getClient()->postJson("https://api.mch.weixin.qq.com/v3/pay/transactions/jsapi", [
                "mchid" => (string)$merchant->getMerchantId(), // <---- 请修改为您的商户号
                "out_trade_no" => $order->order_sn, //uniqid('native') . rand(1, 1000), // "native12177525012012070352333'.rand(1,1000).'",
                "appid" => $app->getConfig()->get('app_id'), // <---- 请修改为服务号的 appid
                "description" => $order->project_name,
                "notify_url" => env('BACKEND_URL') . env('WECHAT_PAYMENT_NOTIFY_URL'),
                "amount" => [
                    "total" => intval(round($order->pay_price * 100)),
                    "currency" => "CNY"
                ],
                "payer" => [
                    "openid" => $openid // <---- 请修改为服务号下单用户的 openid
                ]
            ]);

            $app->getValidator()->validate($response->toPsrResponse());
            // 验证通过
//            dd($response->toArray(false));
            $prepayId = $response['prepay_id'];
            $sign = [
                'appId' => $config['app_id'], // 公众号 appid
                'timeStamp' => (string)time(), // 时间戳
                'nonceStr' => uniqid(), // 随机字符串
                'package' => 'prepay_id=' . $prepayId, // prepay_id
//                'signType' => 'RSA', // 签名类型，默认为 MD5
            ];

            $privateKey = file_get_contents($config['private_key']); // 拼接 key


            // 对参数进行排序并拼接成字符串
//            ksort($sign);
            $stringA = implode('\n', array_values($sign)) . '\n';
            // 使用 OpenSSL 生成签名
//            openssl_sign($stringA, $signature, $privateKey, OPENSSL_ALGO_SHA256);
            $greeting = <<<EOD
{$sign['appId']}
{$sign['timeStamp']}
{$sign['nonceStr']}
{$sign['package']}

EOD;
            openssl_sign($greeting, $signature, $privateKey, OPENSSL_ALGO_SHA256);

            $sign['paySign'] = base64_encode($signature); // 生成签名
            $sign['signType'] = 'RSA'; // 签名类型，默认为 MD5

            return $sign;

        } catch (\Exception $e) {
            self::error($e->getMessage());
//            return response()->json(['error' => $e->getMessage()], 500);
        }
//        $app = EasyWeChat::pay();
//
//        $server = $app->getServer();
////        $server->prepend()
//        $server->handlePaid(function (Message $message, \Closure $next) use ($app) {
//            try {
//                $app->getValidator()->validate($app->getRequest());
//                // 验证通过，业务处理
//            } catch (Exception $e) {
//                // 验证失败
//            }
//            return $next($message);
//        });
//        return $server->serve();
    }

    /**
     * @throws Throwable
     */
    public function notify(): \Illuminate\Http\JsonResponse
    {
        try {
            $pay = EasyWeChat::pay();
            $server = $pay->getServer();
            $server->handlePaid(function (Message $message, \Closure $next) {
                $out_trade_no = $message['out_trade_no'];
                if ($message['trade_state'] === 'SUCCESS') {
                    $order = Order::query()->where('order_sn', $out_trade_no)->first();
                    Log::log('INFO', '$order', $order->toArray());

                    if ($order->status === 0) {
                        $order->status = 1;
                        $order->transaction_id = $message['transaction_id'];
                        $order->pay_time = Carbon::parse($message['success_time'])->timestamp;
                        $order->save();
                    }
                }
                // $message->out_trade_no 获取商户订单号
                // $message->payer['openid'] 获取支付者 openid
                // 🚨🚨🚨 注意：推送信息不一定靠谱哈，请务必验证
                // 建议是拿订单号调用微信支付查询接口，以查询到的订单状态为准
//                Log::log('INFO', 'payNotify', (array)$message);
                return $next($message);
            });

            // 默认返回 ['code' => 'SUCCESS', 'message' => '成功']
            $res = $server->serve();
            return response()->json(json_decode($res->getBody()->getContents(), true), $res->getStatusCode());
        } catch (Exception $e) {
            Log::log('error', $e->getMessage());
            return response()->json(['code' => 'FAIL', "message" => "失败"], 500);
        }

    }
}