diff --git a/app/Controller/CallBackController.php b/app/Controller/CallBackController.php index 0876caf..57ade7c 100644 --- a/app/Controller/CallBackController.php +++ b/app/Controller/CallBackController.php @@ -26,24 +26,13 @@ class CallBackController extends AbstractController $app = $WechatPay->createApp(); $server = $app->getServer(); - $server->handlePaid(function ($message) { - Log::getInstance()->info("微信患者端支付回调数据:" . json_encode($message,JSON_UNESCAPED_UNICODE)); - dump($message); - // $message 为微信推送的通知结果,详看微信官方文档 + $message = $server->getRequestMessage(); + if (empty($message)){ + return $this->response->withStatus(500)->withBody(new SwooleStream(strval(json_encode(['code' => 'ERROR', 'message' => "回调数据为空"], JSON_UNESCAPED_UNICODE)))); + } - // 微信支付订单号 $message['transaction_id'] - // 商户订单号 $message['out_trade_no'] - // 商户号 $message['mchid'] - // 具体看微信官方文档... - // 进行业务处理,如存数据库等... - }); + dump($message); - // 处理退款结果事件 - $server->handleRefunded(function ($message) { - Log::getInstance()->info("微信患者端退款回调数据:" . json_encode($message,JSON_UNESCAPED_UNICODE)); - // 同上,$message 详看微信官方文档 - // 进行业务处理,如存数据库等... - }); return $server->serve(); }catch (\Exception $e) {