package com.ruoyi.payment.interfaces.controller; import com.ruoyi.common.annotation.Anonymous; import com.ruoyi.payment.application.service.PaymentService; import com.ruoyi.payment.common.AjaxResult; import com.ruoyi.payment.domain.model.PaymentOrder; import com.ruoyi.payment.domain.model.PaymentTransaction; import com.ruoyi.payment.interfaces.dto.PaymentRequest; import com.ruoyi.payment.interfaces.dto.PaymentResponse; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; /** * 支付接口控制器 * * @author ruoyi */ @Slf4j @RestController @RequestMapping("/api/pay/payment") public class PaymentController { @Autowired private PaymentService paymentService; @Anonymous() @GetMapping("/hello") public String hello() { return "Hello, World!"; } /** * 发起微信Native支付 */ @Anonymous() @PostMapping("/wechat/native") public AjaxResult createWechatNativePayment(@Validated @RequestBody PaymentRequest request) { try { PaymentResponse response = paymentService.createWechatNativePayment(request); return AjaxResult.success(response); } catch (Exception e) { log.error("发起微信Native支付失败", e); return AjaxResult.error("支付创建失败: " + e.getMessage()); } } /** * 发起支付宝当面付 */ @Anonymous() @PostMapping("/alipay/precreate") public AjaxResult createAlipayPrecreate(@Validated @RequestBody PaymentRequest request) { try { PaymentResponse response = paymentService.createAlipayPrecreate(request); return AjaxResult.success(response); } catch (Exception e) { log.error("发起支付宝当面付失败", e); return AjaxResult.error("支付创建失败: " + e.getMessage()); } } /** * 发起支付宝当面付(第三方接口) */ @Anonymous() @PostMapping("/alipay/thirdparty/precreate") public AjaxResult createAlipayThirdPartyPrecreate(@Validated @RequestBody PaymentRequest request) { try { PaymentResponse response = paymentService.createAlipayThirdPartyPrecreate(request); return AjaxResult.success(response); } catch (Exception e) { log.error("发起支付宝当面付(第三方接口)失败", e); return AjaxResult.error("支付创建失败: " + e.getMessage()); } } /** * 查询订单 */ @Anonymous() @GetMapping("/orders/{orderId}") public AjaxResult getOrder(@PathVariable Long orderId) { try { PaymentOrder order = paymentService.getOrder(orderId); if (order == null) { return AjaxResult.error("订单不存在"); } return AjaxResult.success(order); } catch (Exception e) { log.error("查询订单失败", e); return AjaxResult.error("查询失败: " + e.getMessage()); } } /** * 查询最新交易 */ @Anonymous() @GetMapping("/orders/{orderId}/transactions/latest") public AjaxResult getLatestTransaction(@PathVariable Long orderId) { try { PaymentTransaction transaction = paymentService.getLatestTransaction(orderId); if (transaction == null) { return AjaxResult.error("交易不存在"); } return AjaxResult.success(transaction); } catch (Exception e) { log.error("查询交易失败", e); return AjaxResult.error("查询失败: " + e.getMessage()); } } /** * 查询支付宝第三方交易状态 */ @Anonymous() @GetMapping("/alipay/thirdparty/query/{orderId}") public AjaxResult queryAlipayThirdPartyTradeStatus(@PathVariable Long orderId) { try { String tradeStatus = paymentService.queryAlipayThirdPartyTradeStatus(orderId); return AjaxResult.success(tradeStatus); } catch (Exception e) { log.error("查询支付宝第三方交易状态失败", e); return AjaxResult.error("查询失败: " + e.getMessage()); } } /** * 轮询查询支付状态(用于回调失败的补偿机制) *
* 这个接口用于在支付回调未成功时,主动轮询查询支付状态。 * 支持微信和支付宝(包括第三方支付宝)。 *
* 返回结果包含: * - orderStatus: 订单状态 * - transactionStatus: 交易状态 * - tradeStatus: 第三方交易状态 * - needPoll: 是否需要继续轮询 * - message: 提示信息 *
* 建议轮询策略:
* 1. 首次轮询:立即轮询
* 2. 后续轮询:间隔3-5秒
* 3. 最多轮询20次,约100秒后停止
* 4. 如果 needPoll=false,表示支付已完成或确认失败,无需继续轮询
*/
@Anonymous()
@GetMapping("/poll/{orderId}")
public AjaxResult pollPaymentStatus(@PathVariable Long orderId) {
try {
java.util.Map
* 该接口用于通过商户订单号(交易单号)直接查询微信支付状态。
*
* 返回结果包含:
* - success: 查询是否成功
* - isPaid: 是否已支付
* - tradeState: 交易状态(SUCCESS-支付成功,NOTPAY-未支付,CLOSED-已关闭等)
* - transactionId: 微信支付订单号
* - totalFee: 订单金额(分)
* - timeEnd: 支付完成时间
* - message: 提示信息
*
* @param outTradeNo 商户订单号(交易单号)
*/
@Anonymous()
@GetMapping("/wechat/query/{outTradeNo}")
public AjaxResult queryWechatTrade(@PathVariable String outTradeNo) {
try {
java.util.Map
* 该接口用于通过商户订单号(交易单号)直接查询支付宝支付状态。
*
* 返回结果包含:
* - success: 查询是否成功
* - isPaid: 是否已支付
* - tradeStatus: 交易状态(TRADE_SUCCESS-支付成功,WAIT_BUYER_PAY-等待付款,TRADE_CLOSED-已关闭等)
* - tradeNo: 支付宝交易号
* - totalAmount: 订单金额(元)
* - sendPayDate: 交易支付时间
* - buyerLogonId: 买家支付宝账号
* - message: 提示信息
*
* @param outTradeNo 商户订单号(交易单号)
*/
@Anonymous()
@GetMapping("/alipay/query/{outTradeNo}")
public AjaxResult queryAlipayTrade(@PathVariable String outTradeNo) {
try {
java.util.Map