NN2025031206/app/Http/Controllers/Api/v1/NotifyController.php

<?php

namespace App\Http\Controllers\Api\v1;

use App\Http\Controllers\Api\webApp;
use App\Services\Api\PaymentService;
use App\Services\RedisService;
use Yansongda\Pay\Pay;

/**
 * 回调处理
 * Class NotifyController
 * @package App\Http\Controllers\Api
 */
class NotifyController extends webApp
{

    /**
     * 支付回调
     * @param string $scene 场景，buy-购买服务，cost-店内消费，shop-商城购买，recharge-充值，chat-聊天服务付款，deliver-投递简历，download-下载简历
     * @param int $payType 支付方式：10-微信，20-支付宝
     * @return array|false|\Psr\Http\Message\ResponseInterface
     */
    public function callback($scene, $payType = 10)
    {
        $date = date('Y-m-d H:i:s');
        $result = request()->post();
        $key = date('YmdHis') . '_' . rand(1000, 9999);
        if (empty($result)) {
            $result = file_get_contents('php://input');
            $result = $result ? json_decode($result, true) : [];
        }

        try {
            RedisService::set("caches:payments:notify_{$scene}:result".date('YmdHis').rand(10,99), ['all' => request()->all(), 'scene' => $scene, 'payType' => $payType, 'data' => $result], 7200);
            $pay = PaymentService::make()->createPay($scene, $payType);
            if (empty($pay) || empty($scene) || empty($payType)) {
                if (env('APP_DEBUG')) {
                    logger()->error("【{$date} 支付回调】参数错误：" . json_encode(['scene' => $scene, 'payType' => $payType, 'data' => $result], 256));
                }

                RedisService::set("caches:payments:notify_{$scene}:error_" . $key, ['all' => request()->all(), 'scene' => $scene, 'payType' => $payType, 'data' => $result], 7200);
                return false;
            }

            // 验签和重组参数
            $data = $pay->callback();
            RedisService::set("caches:payments:notify_{$scene}:data_" . $key, ['all' => request()->all(),'all' => request()->all(), 'scene' => $scene, 'payType' => $payType, 'data' => $result], 7200);
            if (env('APP_DEBUG')) {
                logger()->info("【{$date} 支付回调】验证结果：" . json_encode(['data' => $data,'scene'=>$scene,'payType'=>$payType],256));
            }

            // 回调处理
            if (PaymentService::make()->catchNotify($scene, $payType, $data)) {
                logger()->info("【{$date} 支付回调】回调成功：" . json_encode(['data' => $data,'scene'=>$scene,'payType'=>$payType],256));
                return response('success');
            } else {
                $msg = PaymentService::make()->getError();
                logger()->info("【{$date} 支付回调】回调失败：" . json_encode(['data' => $data,'scene'=>$scene,'payType'=>$payType, 'error' => lang($msg)], 256));
                return message($msg ? $msg : 2635, false);
            }
        } catch (\Exception $exception) {
            logger()->error("【{$date} 支付回调】回调错误：" . json_encode(['data' => $result,'scene'=>$scene,'payType'=>$payType, 'error' => $exception->getMessage()], 256));
            return message(2635, false, ['error' => $exception->getMessage()]);
        }
    }


    /**
     * 退款回调
     * @param string $scene 场景，buy-购买服务，cost-店内消费，shop-商城购买，recharge-充值，chat-聊天服务付款，deliver-投递简历，download-下载简历
     * @param int $payType 支付方式：10-微信，20-支付宝
     * @return array|false
     * @throws \Yansongda\Pay\Exception\ContainerException
     * @throws \Yansongda\Pay\Exception\InvalidParamsException
     */
    public function refund($payType = 10)
    {
        $scene = 'refund';
        $date = date('Y-m-d H:i:s');
        $result = request()->post();
        $pay = PaymentService::make()->createPay('refund', $payType);

        if (empty($pay) || empty($scene) || empty($payType)) {
            if (env('APP_DEBUG')) {
                logger()->error("【{$date} 退款回调】验证错误：" . json_encode(['scene' => $scene, 'payType' => $payType, 'data' => $result], 256));
            }

            RedisService::set("caches:refunds:notify_error_" . date('YmdH'), ['all' => request()->all(), 'scene' => $scene, 'payType' => $payType, 'data' => $result], 7200);
            return false;
        }

        // 验签和重组参数
        $data = $pay->callback();
        RedisService::set("caches:refunds:notify_data_" . date('YmdH'), ['all' => request()->all(), 'scene' => $scene, 'payType' => $payType, 'data' => $result], 7200);
        if (env('APP_DEBUG')) {
            logger()->info("【{$date} 退款回调】验证结果：" . json_encode($data, 256));
        }
    }
}