package com.ruoyi.payment.interfaces.controller;
|
|
import com.ruoyi.common.annotation.Anonymous;
|
import com.ruoyi.payment.application.service.PaymentNotifyService;
|
import com.ruoyi.payment.infrastructure.channel.alipay.AlipayUtil;
|
import com.ruoyi.payment.infrastructure.channel.wechat.WxPayUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.BufferedReader;
|
import java.util.Enumeration;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 渠道回调接口控制器
|
*
|
* @author ruoyi
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/api/pay/notify")
|
public class PaymentNotifyController {
|
|
@Autowired
|
private WxPayUtil wxPayUtil;
|
|
@Autowired
|
private AlipayUtil alipayUtil;
|
|
@Autowired
|
private PaymentNotifyService paymentNotifyService;
|
|
/**
|
* 微信支付回调
|
*/
|
@Anonymous
|
@PostMapping("/wechat")
|
public String wechatNotify(HttpServletRequest request) {
|
try {
|
log.info("接收到微信支付回调");
|
|
// 1. 读取XML报文
|
String xmlData = readRequestBody(request);
|
log.info("微信回调报文: {}", xmlData);
|
|
// 2. 解析XML为Map
|
Map<String, String> params = wxPayUtil.xmlToMap(xmlData);
|
|
// 3. 验证签名
|
if (!wxPayUtil.verifySign(params)) {
|
log.error("微信回调签名验证失败");
|
return wxPayUtil.buildFailResponse("签名验证失败");
|
}
|
|
log.info("微信回调签名验证通过");
|
|
// 4. 处理回调（更新订单状态、触发业务回调）
|
paymentNotifyService.processWechatNotify(params, xmlData);
|
|
// 5. 返回微信要求的XML应答
|
return wxPayUtil.buildSuccessResponse();
|
} catch (Exception e) {
|
log.error("处理微信回调失败", e);
|
return wxPayUtil.buildFailResponse("处理失败");
|
}
|
}
|
|
@Anonymous
|
@GetMapping("/hello")
|
public String hello() {
|
return "hello";
|
}
|
|
/**
|
* 支付宝回调
|
*/
|
@Anonymous
|
@PostMapping("/alipay")
|
public String alipayNotify(HttpServletRequest request) {
|
try {
|
log.info("接收到支付宝回调");
|
|
// 1. 获取所有参数
|
Map<String, String> params = new HashMap<>();
|
Enumeration<String> parameterNames = request.getParameterNames();
|
while (parameterNames.hasMoreElements()) {
|
String name = parameterNames.nextElement();
|
params.put(name, request.getParameter(name));
|
}
|
|
log.info("支付宝回调参数: {}", params);
|
|
// 2. 验证签名
|
if (!alipayUtil.verifySign(params)) {
|
log.error("支付宝回调签名验证失败");
|
return "fail";
|
}
|
|
log.info("支付宝回调签名验证通过");
|
|
// 3. 处理回调（更新订单状态、触发业务回调）
|
paymentNotifyService.processAlipayNotify(params);
|
|
// 4. 返回支付宝要求的应答
|
return "success";
|
} catch (Exception e) {
|
log.error("处理支付宝回调失败", e);
|
return "fail";
|
}
|
}
|
|
/**
|
* 读取请求体
|
*/
|
private String readRequestBody(HttpServletRequest request) throws Exception {
|
StringBuilder sb = new StringBuilder();
|
try (BufferedReader reader = request.getReader()) {
|
String line;
|
while ((line = reader.readLine()) != null) {
|
sb.append(line);
|
}
|
}
|
return sb.toString();
|
}
|
}
|
