345 lines
15 KiB
PHP
345 lines
15 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace app\notify\controller;
|
|||
|
|
|
|||
|
|
use app\common\model\Requirement;
|
|||
|
|
use app\common\model\RequirementOrder;
|
|||
|
|
use app\common\service\Channel\wechat\WechatConstants;
|
|||
|
|
use support\Request;
|
|||
|
|
use think\Exception;
|
|||
|
|
use WeChatPay\Crypto\AesGcm;
|
|||
|
|
use WeChatPay\Crypto\Rsa;
|
|||
|
|
use WeChatPay\Formatter;
|
|||
|
|
|
|||
|
|
class WechatPayNotifyController
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
* @desc 需求订单支付回调
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function requirement_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
$post_data = $request->post();
|
|||
|
|
$header = $request->header();
|
|||
|
|
raw_log('wechat_pay/requirement_notify', ['post' => $post_data, 'header' => $header]);
|
|||
|
|
|
|||
|
|
$inWechatpaySignature = $header['wechatpay-signature'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayTimestamp = $header['wechatpay-timestamp'];// 请根据实际情况获取
|
|||
|
|
$inWechatpaySerial = $header['wechatpay-serial'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayNonce = $header['wechatpay-nonce'];// 请根据实际情况获取
|
|||
|
|
|
|||
|
|
$mch_id = getenv('MERCHANT_ID');
|
|||
|
|
|
|||
|
|
// 根据通知的平台证书序列号，查询本地平台证书文件，
|
|||
|
|
$platformCertificateFilePath = 'file://' . base_path() . '/certificate/wechatpay_660FAD2D6E804E37BE9D77EF5882718CC1E3399F.pem';
|
|||
|
|
$platformPublicKeyInstance = Rsa::from($platformCertificateFilePath, Rsa::KEY_TYPE_PUBLIC);
|
|||
|
|
|
|||
|
|
// 检查通知时间偏移量，允许5分钟之内的偏移
|
|||
|
|
$timeOffsetStatus = 300 >= abs(Formatter::timestamp() - (int)$inWechatpayTimestamp);
|
|||
|
|
$verifiedStatus = Rsa::verify(
|
|||
|
|
// 构造验签名串
|
|||
|
|
Formatter::joinedByLineFeed($inWechatpayTimestamp, $inWechatpayNonce, json_encode($post_data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES)),
|
|||
|
|
$inWechatpaySignature,
|
|||
|
|
$platformPublicKeyInstance
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
// 验签
|
|||
|
|
if ($timeOffsetStatus && $verifiedStatus) {
|
|||
|
|
// 使用PHP7的数据解构语法，从Array中解构并赋值变量
|
|||
|
|
['resource' => [
|
|||
|
|
'ciphertext' => $ciphertext,
|
|||
|
|
'nonce' => $nonce,
|
|||
|
|
'associated_data' => $aad
|
|||
|
|
]] = $post_data;
|
|||
|
|
// 加密文本消息解密
|
|||
|
|
$inBodyResource = AesGcm::decrypt($ciphertext, getenv('API_V3'), $nonce, $aad);
|
|||
|
|
// 把解密后的文本转换为PHP Array数组
|
|||
|
|
$pay_result = json_decode($inBodyResource, true);
|
|||
|
|
|
|||
|
|
if ($pay_result['trade_state'] == 'SUCCESS') {
|
|||
|
|
|
|||
|
|
$order = RequirementOrder::where(['out_trade_no' => $pay_result['out_trade_no']])->findOrEmpty();
|
|||
|
|
|
|||
|
|
if ($order->isEmpty()) {
|
|||
|
|
throw new Exception('未找到订单' . $pay_result['out_trade_no']);
|
|||
|
|
}
|
|||
|
|
if ($order->amount * 100 != $pay_result['amount']['total']) {
|
|||
|
|
throw new Exception('订单金额不一致-' . $pay_result['out_trade_no']);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($order->pay_status == 0) {
|
|||
|
|
$res = $order->save([
|
|||
|
|
'pay_status' => 1,
|
|||
|
|
'transaction_id' => $pay_result['transaction_id'],
|
|||
|
|
'pay_time' => date('Y-m-d H:i:s', strtotime($pay_result['success_time'])),
|
|||
|
|
]);
|
|||
|
|
|
|||
|
|
$requirement = Requirement::where(['id' => $order->requirement_id])->findOrEmpty();
|
|||
|
|
$requirement->save([
|
|||
|
|
'requirement_pay_order_status' => 1
|
|||
|
|
]);
|
|||
|
|
if ($requirement->deposit_pay_status == 1) {
|
|||
|
|
//保证金已支付，进入服务中状态
|
|||
|
|
$requirement->save([
|
|||
|
|
'status' => 3
|
|||
|
|
]);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($res) {
|
|||
|
|
return json('success');
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return json('success');
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
throw new Exception('验签失败');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
var_dump($e->getMessage());
|
|||
|
|
raw_log('wechat_pay/requirement_notify_error', ['exception' => $e->getMessage()]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @desc 需求退款
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return \support\Response|void
|
|||
|
|
*/
|
|||
|
|
public function requirement_refund_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
$post_data = $request->post();
|
|||
|
|
$header = $request->header();
|
|||
|
|
|
|||
|
|
$post_data = '{"id":"ce358553-a4ae-5ecd-bab0-c4a31292989d","create_time":"2024-07-04T17:40:35+08:00","resource_type":"encrypt-resource","event_type":"REFUND.SUCCESS","summary":"退款成功","resource":{"original_type":"refund","algorithm":"AEAD_AES_256_GCM","ciphertext":"uc/STAVhRAgsEn+Wcl7ZDq4JiXh5KxLyX3c6WKtnZPLKq/ch1JGFKMR2Fbdvk5W5p5qcd2NJLwaUEmPjopV3n5aAD/r7DGsn+wUhiUwk71YIRhSZyrIrOTNXFLZ/yIu5cr7qkBnEP1YCD/oeSmNy6cz2uq8kag90M6RtOgJO4KFsJ0tOqW/OWs3h4eBoWxyRzKVZHY/FyNSeOgKN8ZodkRlP0Tjm2oPqtaxJcvE3O8TG5jkKlCopk/q8pd/lYUP8k0W1R+LYc2njh6NMc+plmH/6qrI7Ep5AzuU89PhDoQY8WemqogyABqtnXQ+8yMIWkmQSHHB3I1WKegqGFNSXHoUyViONoy7FKdWmstpUfAtjPjXJl23g3WYkjeaKO4bPKZakKj2KUscPQUs8dOa0eggA0mxqLMHgZl9+UKqoC4e/7a+CdR3DMKlJjYFC/Zisfjxy++1gPC4Oh5BIP7QVT3atsgNkZynXAY+3qmF9/lyeWONzrPXdukanEZMwLi2UXIELHEQvPUv7aKgI","associated_data":"refund","nonce":"xaAOLXTSOskU"}}';
|
|||
|
|
$header = '{"x-real-ip":"175.24.211.24","host":"sypt.lingruikj.com","x-forwarded-proto":"https","content-length":"840","user-agent":"Mozilla/4.0","content-type":"application/json","wechatpay-nonce":"gSSvoVuO1PPtuPtdFvvugy99YI1leUMF","wechatpay-timestamp":"1720086041","wechatpay-serial":"660FAD2D6E804E37BE9D77EF5882718CC1E3399F","wechatpay-signature":"Vatqwnzb0cYGMT1nOnpp086CUV8URBgWVeqPJW1tw/tt/w1htnnTs1lk0v+Z/i3cqpnkfr1XErzMQZ1yZXA7qH7nloRdjBYWLwJiwTrnrLDMLU//Oz1sUve4Mt910zIPGkMTbg2Zr+b6YXqPNVBYvFtjjRnBlqRpyVz07lsVDKA4Ygfslw+sZur4qC/yZy6d3fKwxIRy6S/GHBd+/kRnuagyjheuU+JZ32ScozXdt6AQF05S3VGzohiNvrIu48v9imlf3K6NdzGnSJPeiKQ9BSoOw0CkSl9idEYIIFfdbhbu9kc5l4V8bNQc45W8EUylXLT7cFa6B63+TZts5KOosw==","wechatpay-signature-type":"WECHATPAY2-SHA256-RSA2048","pragma":"no-cache","accept":"*/*"}';
|
|||
|
|
|
|||
|
|
$post_data = json_decode($post_data, true);
|
|||
|
|
$header = json_decode($header, true);
|
|||
|
|
|
|||
|
|
raw_log('wechat_pay/requirement_refund_notify', ['post' => $post_data, 'header' => $header]);
|
|||
|
|
|
|||
|
|
$inWechatpaySignature = $header['wechatpay-signature'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayTimestamp = $header['wechatpay-timestamp'];// 请根据实际情况获取
|
|||
|
|
$inWechatpaySerial = $header['wechatpay-serial'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayNonce = $header['wechatpay-nonce'];// 请根据实际情况获取
|
|||
|
|
|
|||
|
|
$mch_id = getenv('MERCHANT_ID');
|
|||
|
|
|
|||
|
|
// 根据通知的平台证书序列号，查询本地平台证书文件，
|
|||
|
|
$platformCertificateFilePath = 'file://' . base_path() . '/certificate/wechatpay_660FAD2D6E804E37BE9D77EF5882718CC1E3399F.pem';
|
|||
|
|
$platformPublicKeyInstance = Rsa::from($platformCertificateFilePath, Rsa::KEY_TYPE_PUBLIC);
|
|||
|
|
|
|||
|
|
// 检查通知时间偏移量，允许5分钟之内的偏移
|
|||
|
|
$timeOffsetStatus = 300 >= abs(Formatter::timestamp() - (int)$inWechatpayTimestamp);
|
|||
|
|
$verifiedStatus = Rsa::verify(
|
|||
|
|
// 构造验签名串
|
|||
|
|
Formatter::joinedByLineFeed($inWechatpayTimestamp, $inWechatpayNonce, json_encode($post_data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES)),
|
|||
|
|
$inWechatpaySignature,
|
|||
|
|
$platformPublicKeyInstance
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
// 验签
|
|||
|
|
if ($timeOffsetStatus && $verifiedStatus) {
|
|||
|
|
// 使用PHP7的数据解构语法，从Array中解构并赋值变量
|
|||
|
|
['resource' => [
|
|||
|
|
'ciphertext' => $ciphertext,
|
|||
|
|
'nonce' => $nonce,
|
|||
|
|
'associated_data' => $aad
|
|||
|
|
]] = $post_data;
|
|||
|
|
// 加密文本消息解密
|
|||
|
|
$inBodyResource = AesGcm::decrypt($ciphertext, getenv('API_V3'), $nonce, $aad);
|
|||
|
|
// 把解密后的文本转换为PHP Array数组
|
|||
|
|
$pay_result = json_decode($inBodyResource, true);
|
|||
|
|
|
|||
|
|
if ($pay_result['refund_status'] == 'SUCCESS') {
|
|||
|
|
$order = RequirementOrder::where(['out_trade_no' => $pay_result['out_trade_no']])->findOrEmpty();
|
|||
|
|
|
|||
|
|
if ($order->isEmpty()) {
|
|||
|
|
throw new Exception('未找到订单' . $pay_result['out_trade_no']);
|
|||
|
|
}
|
|||
|
|
if ($order->pay_status != 1) {
|
|||
|
|
throw new Exception('订单状态错误-' . $order->pay_status . $pay_result['out_trade_no']);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($order->is_refund != 0) {
|
|||
|
|
throw new Exception('订单退款状态错误-' . $order->is_refund . $pay_result['out_trade_no']);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($order->refund_amount * 100 != $pay_result['amount']['total']) {
|
|||
|
|
throw new Exception('退款金额不一致-' . $pay_result['out_trade_no']);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$order->save([
|
|||
|
|
'refund_transaction_id' => $pay_result['refund_id'],
|
|||
|
|
'is_refund' => 1,
|
|||
|
|
'refund_time' => date('Y-m-d H:i:s', strtotime($pay_result['success_time'])),
|
|||
|
|
]);
|
|||
|
|
|
|||
|
|
$requirement = Requirement::where(['id' => $order->requirement_id])->findOrEmpty();
|
|||
|
|
if (!$requirement->isEmpty()) {
|
|||
|
|
$requirement->save([
|
|||
|
|
'requirement_pay_order_status' => 3
|
|||
|
|
]);
|
|||
|
|
if ($order->deposit_pay_status == 3) {
|
|||
|
|
//保证金已退款，更新需求状态为已退款
|
|||
|
|
$requirement->save([
|
|||
|
|
'status' => 5
|
|||
|
|
]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return json('success');
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
throw new Exception('验签失败');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
var_dump($e->getMessage());
|
|||
|
|
raw_log('wechat_pay/requirement_refund_notify_error', ['exception' => $e->getMessage()]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @desc 保证金订单回调
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function requirement_deposit_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
$post_data = $request->post();
|
|||
|
|
$header = $request->header();
|
|||
|
|
raw_log('wechat_pay/requirement_notify', ['post' => $post_data, 'header' => $header]);
|
|||
|
|
|
|||
|
|
$inWechatpaySignature = $header['wechatpay-signature'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayTimestamp = $header['wechatpay-timestamp'];// 请根据实际情况获取
|
|||
|
|
$inWechatpaySerial = $header['wechatpay-serial'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayNonce = $header['wechatpay-nonce'];// 请根据实际情况获取
|
|||
|
|
|
|||
|
|
$mch_id = getenv('MERCHANT_ID');
|
|||
|
|
|
|||
|
|
// 根据通知的平台证书序列号，查询本地平台证书文件，
|
|||
|
|
$platformCertificateFilePath = 'file://' . base_path() . '/certificate/wechatpay_660FAD2D6E804E37BE9D77EF5882718CC1E3399F.pem';
|
|||
|
|
$platformPublicKeyInstance = Rsa::from($platformCertificateFilePath, Rsa::KEY_TYPE_PUBLIC);
|
|||
|
|
|
|||
|
|
// 检查通知时间偏移量，允许5分钟之内的偏移
|
|||
|
|
$timeOffsetStatus = 300 >= abs(Formatter::timestamp() - (int)$inWechatpayTimestamp);
|
|||
|
|
$verifiedStatus = Rsa::verify(
|
|||
|
|
// 构造验签名串
|
|||
|
|
Formatter::joinedByLineFeed($inWechatpayTimestamp, $inWechatpayNonce, json_encode($post_data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES)),
|
|||
|
|
$inWechatpaySignature,
|
|||
|
|
$platformPublicKeyInstance
|
|||
|
|
);
|
|||
|
|
// 验签
|
|||
|
|
if ($timeOffsetStatus && $verifiedStatus) {
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @desc 拍照服务支付回调
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function photo_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
$post_data = $request->post();
|
|||
|
|
$header = $request->header();
|
|||
|
|
raw_log('wechat_pay/photo_notify', ['post' => $post_data, 'header' => $header]);
|
|||
|
|
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @desc 支付保证金回调
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function photo_deposit_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
$post_data = $request->post();
|
|||
|
|
$header = $request->header();
|
|||
|
|
raw_log('wechat_pay/photo_deposit_notify', ['post' => $post_data, 'header' => $header]);
|
|||
|
|
|
|||
|
|
//@todo:支付成功更新拍照服务中保证金状态
|
|||
|
|
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @desc 拍照退款
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function photo_refund_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
$post_data = $request->post();
|
|||
|
|
$header = $request->header();
|
|||
|
|
raw_log('wechat_pay/refund_notify', ['post' => $post_data, 'header' => $header]);
|
|||
|
|
|
|||
|
|
$inWechatpaySignature = $header['wechatpay-signature'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayTimestamp = $header['wechatpay-timestamp'];// 请根据实际情况获取
|
|||
|
|
$inWechatpaySerial = $header['wechatpay-serial'];// 请根据实际情况获取
|
|||
|
|
$inWechatpayNonce = $header['wechatpay-nonce'];// 请根据实际情况获取
|
|||
|
|
|
|||
|
|
$mch_id = getenv('MERCHANT_ID');
|
|||
|
|
|
|||
|
|
// 根据通知的平台证书序列号，查询本地平台证书文件，
|
|||
|
|
$platformCertificateFilePath = 'file://' . base_path() . '/certificate/wechatpay_660FAD2D6E804E37BE9D77EF5882718CC1E3399F.pem';
|
|||
|
|
$platformPublicKeyInstance = Rsa::from($platformCertificateFilePath, Rsa::KEY_TYPE_PUBLIC);
|
|||
|
|
|
|||
|
|
// 检查通知时间偏移量，允许5分钟之内的偏移
|
|||
|
|
$timeOffsetStatus = 300 >= abs(Formatter::timestamp() - (int)$inWechatpayTimestamp);
|
|||
|
|
$verifiedStatus = Rsa::verify(
|
|||
|
|
// 构造验签名串
|
|||
|
|
Formatter::joinedByLineFeed($inWechatpayTimestamp, $inWechatpayNonce, json_encode($post_data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES)),
|
|||
|
|
$inWechatpaySignature,
|
|||
|
|
$platformPublicKeyInstance
|
|||
|
|
);
|
|||
|
|
// 验签
|
|||
|
|
if ($timeOffsetStatus && $verifiedStatus) {
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @desc 拍照订单保证金退款回调
|
|||
|
|
* @param Request $request
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function photo_deposit_refund_notify(Request $request)
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
|
|||
|
|
}catch (Exception $e){
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|