package com.ruoyi.payment.controller;
|
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.web.domain.AjaxResult;
|
import com.ruoyi.order.api.feignClient.ChargingOrderClient;
|
import com.ruoyi.order.api.feignClient.OrderClient;
|
import com.ruoyi.payment.ali.config.AliProperties;
|
import com.ruoyi.payment.ali.v2.AppletPayUtil;
|
import com.ruoyi.payment.api.model.*;
|
import com.ruoyi.payment.api.vo.AliPaymentReq;
|
import com.ruoyi.payment.api.vo.AliPaymentResp;
|
import com.ruoyi.payment.api.vo.AliQueryOrder;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.PrintWriter;
|
|
/**
|
* @author zhibing.pu
|
* @Date 2024/8/24 14:29
|
*/
|
@RestController
|
@RequestMapping("/ali")
|
public class AliPayController {
|
|
@Resource
|
private AppletPayUtil appletPayUtil;
|
|
@Resource
|
private AliProperties aliProperties;
|
|
|
/**
|
* 调起支付宝小程序支付
|
* @param req
|
* @return
|
*/
|
@ResponseBody
|
@PostMapping("/payment")
|
public R<AliPaymentResp> payment(@RequestBody AliPaymentReq req){
|
PaymentReq pojo = new PaymentReq();
|
BeanUtils.copyProperties(req, pojo);
|
PaymentResp payment = appletPayUtil.payment(pojo);
|
if(null != payment){
|
AliPaymentResp aliPaymentResp = new AliPaymentResp();
|
aliPaymentResp.setTradeNo(payment.getTradeNo());
|
return R.ok(aliPaymentResp);
|
}
|
return R.ok();
|
}
|
|
/**
|
* 查询订单
|
* @param outTradeNo
|
* @return
|
*/
|
@ResponseBody
|
@PostMapping("/query")
|
public R<AliQueryOrder> query(@RequestParam("outTradeNo") String outTradeNo){
|
QueryResp query = appletPayUtil.query(outTradeNo);
|
if(null != query){
|
AliQueryOrder aliQueryOrder = new AliQueryOrder();
|
BeanUtils.copyProperties(query, aliQueryOrder);
|
return R.ok(aliQueryOrder);
|
}
|
return R.ok();
|
}
|
|
/**
|
* 关闭订单
|
* @param outTradeNo
|
*/
|
@ResponseBody
|
@PostMapping("/close")
|
public void close(@RequestParam("outTradeNo") String outTradeNo){
|
boolean close = appletPayUtil.close(outTradeNo);
|
if(!close){
|
throw new RuntimeException("关闭支付宝订单失败");
|
}
|
}
|
/**
|
* 后台退款 远程调用
|
*/
|
@PostMapping("/refund")
|
public R<RefundResp> refund(@RequestBody RefundReq dto){
|
return R.ok(appletPayUtil.refund(dto));
|
}
|
|
|
@Resource
|
private OrderClient orderClient;
|
@Resource
|
private ChargingOrderClient chargingOrderClient;
|
@ResponseBody
|
@PostMapping(value = "/callBack")
|
public void chargingOrderALICallback(AliQueryOrder aliQueryOrder, HttpServletResponse response) {
|
try {
|
String out_trade_no = aliQueryOrder.getOutTradeNo();
|
String transaction_id = aliQueryOrder.getTradeNo();
|
String attach = aliQueryOrder.getPassbackParams();
|
String substring = out_trade_no.substring(0, 2);
|
switch (substring){
|
//购物订单
|
case "GW":
|
R r = orderClient.callBack(out_trade_no, transaction_id);
|
System.err.println("----收到购物回调");
|
break;
|
case "HY":
|
orderClient.vipCallBack(out_trade_no,transaction_id);
|
System.err.println("----收到会员回调");
|
break;
|
case "CD":
|
chargingOrderClient.chargingOrderALICallback(out_trade_no, transaction_id, attach);
|
System.err.println("----充电支付回调");
|
break;
|
}
|
PrintWriter writer = response.getWriter();
|
writer.println("success");
|
writer.flush();
|
writer.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
|
|
|
|
}
|
