1

app/Controller/CallBackController.php

@@ -136,7 +136,34 @@ class CallBackController extends AbstractController
             Db::rollBack();
             Log::getInstance()->error("微信支付回调数据验证失败:" . $e->getMessage());
             return $this->wxPayErrorReturn($e->getMessage());
+        }
+    }
+
+    public function wxPayRefundCallBack(): ResponseInterface
+    {
+        try {
+            // 处理支付结果事件
+            $WechatPay = new WechatPay(1);
+            $app = $WechatPay->createApp();
+            $server = $app->getServer();
+
+            $message = $server->getRequestMessage();
+            if (empty($message)){
+                Db::rollBack();
+                return $this->response->withStatus(500)->withBody(new SwooleStream(strval(json_encode(['code' => 'ERROR', 'message' => "回调数据为空"], JSON_UNESCAPED_UNICODE))));
             }
+
+            // 验证推送消息签名
+            $app->getValidator()->validate($app->getRequest());
+
+            Log::getInstance()->info("微信支付回调数据：" . json_encode($message,JSON_UNESCAPED_UNICODE));
+            return $server->serve();
+        }catch (\Exception $e) {
+            // 验证失败
+            Db::rollBack();
+            Log::getInstance()->error("微信支付回调数据验证失败:" . $e->getMessage());
+            return $this->wxPayErrorReturn($e->getMessage());
+        }
     }
 
     /**

config/routes.php

@@ -378,6 +378,9 @@ Router::addGroup('/callback', function () {
         Router::addGroup('/inquiry', function () {
             // 支付成功回调
             Router::post('/success', [CallBackController::class, 'wxPaySuccessCallBack']);
+
+            // 退款回调
+            Router::post('/refund', [CallBackController::class, 'wxPayRefundCallBack']);
         });
     });
 

extend/Wechat/WechatPay.php

@@ -178,9 +178,7 @@ class WechatPay
         try {
             $app = $this->createApp();
 
-            $options = [
+            $options['notify_url'] = env('DOMAIN_NAME_DEV') . $this->config['refund_notify_url'];
-                "notify_url	" => env('DOMAIN_NAME_DEV') . $this->config['refund_notify_url'],
-            ];
 
             $response = $app->getClient()->postJson("v3/refund/domestic/refunds", $options);
             if ($response->isFailed()) {