package com.cdzy.payment.controller; import com.alibaba.fastjson2.JSONObject; import com.cdzy.common.model.JsonResult; import com.cdzy.payment.model.dto.*; import com.cdzy.payment.service.WxPayService; import com.mybatisflex.core.paginate.Page; import com.wechat.pay.java.service.payments.model.Transaction; import com.wechat.pay.java.service.refund.model.Refund; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import java.util.List; /** * 用户订单微信支付 控制层。 * * @author dingchao * @since 2025-04-24 */ @Slf4j @RestController @RequestMapping("/wxPayment") public class EbikeWxPaymentController { @Resource private WxPayService wxPayService; /** * 微信支付下单 * * @param orderId 骑行订单id * @return 下单成功返回true,否则返回false */ @GetMapping("/prepay") public JsonResult prepay(@RequestParam(name = "orderId") String orderId) { JSONObject r = wxPayService.prepay(orderId); return r.containsKey("error")?JsonResult.failed("下单失败: "+ r.getString("error")):JsonResult.success(r); } /** * 通过商户(骑行)订单号查询支付订单 * * @param orderId 商户(骑行)订单号 * @return 支付订单信息 */ @GetMapping("/queryOrder/{orderId}") public JsonResult queryOrderByOrderId(@PathVariable(name = "orderId") String orderId) { Transaction r = wxPayService.queryOrderByOrderId(orderId); return r == null?JsonResult.failed(String.format("骑行订单号{%s}查询支付订单失败", orderId)):JsonResult.success(r); } /** * 通过商户(骑行)订单订单号查询支付订单状态 * * @param orderId 微信支付订单号 * @return 订单信息支付状态 */ @GetMapping("/queryOrderStatus/{orderId}") public JsonResult queryOrderStatusById(@PathVariable(name = "orderId") String orderId) { HandleNotifyResult r = wxPayService.queryOrderStatusByOrderId(orderId); return JsonResult.success(r); } // 拆分为两个接口,一个是退款申请(生成退款记录),一个是提交退款(调用微信退款接口) /** * 退款申请 * * @param refundDto 退款信息 * @return 退款成功返回true,否则返回false */ @PostMapping("/refundApply") public JsonResult refundApply(@RequestBody EbikeRefundDto refundDto) { String r = wxPayService.refundApply(refundDto.getOrderId(), refundDto.getReason()); return r == null?JsonResult.failed("退款失败"):JsonResult.success(r); } /** * 调用退款接口 * * @param refundDto 退款请求参数 * @return 退款成功返回true,否则返回false */ @PostMapping("/refund") public JsonResult refund(@RequestBody ReqRefundDto refundDto) { boolean r = wxPayService.refund(refundDto); return r?JsonResult.failed("退款失败"):JsonResult.success(r); } /** * 审核退款申请 * * @param processDto 退款处理信息 * @return 退款成功返回true,否则返回false */ @PostMapping("/reviewRefund") public JsonResult rejectRefund(@RequestBody ReqRefundProcessDto processDto) { boolean r = wxPayService.refundReview(processDto); return r?JsonResult.failed("退款失败"):JsonResult.success(r); } /** * 通过退款单号查询退款信息 * * @param refundId 商户(骑行)退款单号 * @return 退款信息 */ @GetMapping("/queryRefund/{refundId}") public JsonResult refundQuery(@PathVariable(name = "refundId") String refundId) { Refund r = wxPayService.queryRefundByOutNo(refundId); return r == null?JsonResult.failed(String.format("退款单号{%s}查询退款失败", refundId)):JsonResult.success(r); } /** * 获取退款列表 * * @param refundDto 查询条件 * @return 退款列表 */ @PostMapping("/queryRefundList") public JsonResult queryRefundList(@RequestBody ReqRefundQueryDto refundDto) { Page list = wxPayService.queryRefundList(refundDto); return JsonResult.success(list); } }