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/notify")
|
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/notify")
|
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";
|
}
|
}
|
|
/**
|
* 第三方支付宝回调（GET请求）
|
* <p>
|
* 第三方支付宝通过GET方式回调，参数通过URL传递
|
* <p>
|
* 参数格式：
|
* method=xxx&APPID=xxx&PaidMoneyType=xxx&PaidMoney=xxx&PaidRemarks=xxx&UnixTime=xxx&Sign=xxx
|
* <p>
|
* 参数说明：
|
* - method: 方法名
|
* - APPID: 应用ID
|
* - PaidMoneyType: 支付类型
|
* - PaidMoney: 支付金额（单位：分）
|
* - PaidRemarks: 支付备注（包含订单号和交易号信息）
|
* - UnixTime: 时间戳
|
* - Sign: 签名
|
* <p>
|
* 示例：
|
* GET /api/pay/notify/alipay/thirdparty?method=alipay.pay&APPID=123456&PaidMoneyType=alipay&PaidMoney=100&PaidRemarks=1234567890&UnixTime=1638360000&Sign=abc123
|
*/
|
@Anonymous
|
@GetMapping("/alipay/thirdparty")
|
public String alipayThirdPartyNotify(HttpServletRequest request) {
|
try {
|
log.info("接收到第三方支付宝回调（GET请求）");
|
|
// 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. 第三方支付宝不需要验签，或者根据第三方平台的签名规则进行验证
|
// 这里直接处理，如果需要验签可以在Service层添加
|
|
// 3. 处理回调（更新订单状态、触发业务回调）
|
paymentNotifyService.processAlipayThirdPartyNotify(params);
|
|
// 4. 返回第三方支付宝要求的应答
|
return "success";
|
} catch (Exception e) {
|
log.error("处理第三方支付宝回调失败", e);
|
return "fail";
|
}
|
}
|
|
/**
|
* 第三方微信回调（GET请求）
|
* <p>
|
* 第三方微信通过GET方式回调，参数通过URL传递
|
* <p>
|
* 参数格式：
|
* method=xxx&APPID=xxx&PaidMoneyType=xxx&PaidMoney=xxx&PaidRemarks=xxx&UnixTime=xxx
|
* <p>
|
* 参数说明：
|
* - method: 方法名
|
* - APPID: 应用ID
|
* - PaidMoneyType: 支付类型
|
* - PaidMoney: 支付金额（单位：分）
|
* - PaidRemarks: 支付备注（包含订单号和交易号信息）
|
* - UnixTime: 时间戳
|
* <p>
|
* 示例：
|
* GET /api/pay/notify/wechat/thirdparty?method=wechat.pay&APPID=123456&PaidMoneyType=wechat&PaidMoney=100&PaidRemarks=1234567890&UnixTime=1638360000
|
*/
|
@Anonymous
|
@GetMapping("/wechat/thirdparty")
|
public String wechatThirdPartyNotify(HttpServletRequest request) {
|
try {
|
log.info("接收到第三方微信回调（GET请求）");
|
|
// 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. 第三方微信不需要验签，或者根据第三方平台的签名规则进行验证
|
// 这里直接处理，如枟需要验签可以在Service层添加
|
|
// 3. 处理回调（更新订单状态、触发业务回调）
|
paymentNotifyService.processWechatThirdPartyNotify(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();
|
}
|
}
|
