package com.ruoyi.payment.wx.controller;
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
import com.ruoyi.common.core.web.domain.AjaxResult;
|
import com.ruoyi.payment.wx.enums.RefundEnum;
|
import com.ruoyi.payment.wx.model.WxPaymentRefundModel;
|
import com.ruoyi.payment.wx.utils.WxV3Pay;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
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.IOException;
|
import java.util.Map;
|
import java.util.Objects;
|
|
/**
|
* 微信相关接口
|
*/
|
@Slf4j
|
@RestController
|
@CrossOrigin
|
@RequestMapping("/wx/")
|
@Api(tags = {"微信支付相关接口"})
|
public class WxPayController {
|
@Autowired
|
private WxV3Pay wxV3Pay;
|
|
|
/**
|
* 按实际修改
|
*/
|
@PostMapping("order")
|
@ApiOperation("订单支付")
|
public AjaxResult<Map<String, Object>> orderPay(@RequestParam Long orderId) {
|
// 查询订单
|
// 0元订单不走支付
|
// 价格
|
Integer totalPrice = 0;
|
// 生成订单号
|
String orderNo = "";
|
// 查询用户信息 用户openid
|
String openId = "";
|
// 订单做修改
|
// 调用支付方法
|
Map<String, Object> result = wxV3Pay.jsApi(orderNo, totalPrice, openId,"");
|
log.info("支付参数：{}", result);
|
return AjaxResult.ok(result);
|
}
|
|
/**
|
* 微信v3支付-订单退款
|
*
|
* @return
|
*/
|
@ApiOperation("订单退款")
|
@PostMapping(value = "refund-order")
|
public AjaxResult<String> refundOrder() {
|
Map<String, Object> result = wxV3Pay.refund(new WxPaymentRefundModel());
|
log.info("退款结果：{}", result);
|
// 微信支付退款单号
|
String refund_id = result.get("refund_id").toString();
|
// 商户退款单号
|
String out_refund_no = result.get("out_refund_no").toString();
|
// 微信支付订单号
|
String transaction_id = result.get("transaction_id").toString();
|
// 商户订单号 tradeNo
|
String out_trade_no = result.get("out_trade_no").toString();
|
// 退款成功时间
|
String success_time = Objects.nonNull(result.get("success_time")) ? result.get("success_time").toString() : null;
|
// 退款状态 RefundEnum
|
String status = result.get("status").toString();
|
// TODO 退款业务处理
|
return AjaxResult.success();
|
}
|
|
/**
|
* 支付回调
|
*/
|
@PostMapping("pay/notify")
|
public void payNotify(HttpServletRequest request) throws IOException {
|
try {
|
Map<String, Object> params = wxV3Pay.verifyNotify(request, new TypeReference<Map<String, Object>>() {
|
});
|
log.info("支付回调：{}", params);
|
// 商户订单号
|
String tradeNo = params.get("out_trade_no").toString();
|
// 交易状态
|
String trade_state = params.get("trade_state").toString();
|
// 交易状态描述
|
String trade_state_desc = params.get("trade_state_desc").toString();
|
// 微信支付订单号
|
String transaction_id = params.get("transaction_id").toString();
|
// 支付完成时间
|
// 时间不对的话，可以调用 WxTimeUtils.toRfc3339Date(success_time)转换一下
|
String success_time = params.get("success_time").toString();
|
// 附加数据
|
Integer attach = Integer.parseInt(params.get("attach").toString());
|
// TODO 业务处理
|
} catch (Exception e) {
|
log.error("支付回调异常：{}", e, e);
|
wxV3Pay.ack(false, e.getMessage());
|
}
|
|
}
|
|
/**
|
* 退款回调
|
*/
|
@PostMapping("refund/notify")
|
public void refundNotify(HttpServletRequest request) throws IOException {
|
try {
|
Map<String, Object> params = wxV3Pay.verifyNotify(request, new TypeReference<Map<String, Object>>() {
|
});
|
// 商户订单号
|
String tradeNo = params.get("out_trade_no").toString();
|
// 商户退款单号
|
String out_refund_no = params.get("out_refund_no").toString();
|
// 微信支付订单号
|
String transaction_id = params.get("transaction_id").toString();
|
// 微信支付退款单号
|
String refund_id = params.get("refund_id").toString();
|
// 退款状态
|
String tradeState = params.get("refund_status").toString();
|
// 退款成功时间
|
// 时间不对的话，可以调用 WxTimeUtils.toRfc3339Date(success_time)转换一下
|
String success_time = params.get("success_time").toString();
|
if (tradeState.equals(RefundEnum.SUCCESS.name())) {
|
// TODO 退款成功处理
|
wxV3Pay.ack();
|
} else {
|
wxV3Pay.ack(false, "不是成功的退款状态");
|
}
|
} catch (Exception e) {
|
wxV3Pay.ack(false, e.getMessage());
|
}
|
|
}
|
|
}
|
