package com.kidgrow.oprationcenter.controller.alipay;
|
|
import com.alipay.api.AlipayClient;
|
import com.alipay.api.domain.AlipayTradeCancelModel;
|
import com.alipay.api.domain.AlipayTradePrecreateModel;
|
import com.alipay.api.internal.util.AlipaySignature;
|
import com.alipay.api.request.AlipayTradeCancelRequest;
|
import com.alipay.api.request.AlipayTradePrecreateRequest;
|
import com.alipay.api.response.AlipayTradeCancelResponse;
|
import com.alipay.api.response.AlipayTradePrecreateResponse;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.kidgrow.common.model.ResultBody;
|
import com.kidgrow.common.utils.DateUtils;
|
import com.kidgrow.common.utils.QRCodeUtil;
|
import com.kidgrow.common.utils.StringUtils;
|
import com.kidgrow.oprationcenter.alipay.AlipayProperties;
|
import com.kidgrow.oprationcenter.model.SaasClientPay;
|
import com.kidgrow.oprationcenter.service.AlipayService;
|
import com.kidgrow.oprationcenter.service.ISaasClientPayService;
|
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.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.time.Instant;
|
import java.util.*;
|
|
@Slf4j
|
@RestController
|
@RequestMapping("alipay")
|
@Api(tags = "支付宝的支付controller")
|
public class AlipayController {
|
|
@Resource
|
private AlipayClient alipayClient;
|
@Resource
|
private AlipayProperties alipayProperties;
|
@Autowired
|
private ISaasClientPayService saasClientPayService;
|
@Autowired
|
private AlipayService alipayService;
|
|
@ApiOperation(value = "调用预支付的接口，生成二维码")
|
@PostMapping("/precreate")
|
public ResultBody precreate(HttpServletResponse response) throws Exception { //商户预创建支付订单，生成二维码
|
|
String outTradeNo = UUID.randomUUID().toString().replaceAll("-", "");
|
QueryWrapper queryWrapper = new QueryWrapper();
|
queryWrapper.eq("dia_id", "1");
|
queryWrapper.eq("pay_status", 0);
|
AlipayTradePrecreateModel model = new AlipayTradePrecreateModel();
|
model.setProductCode("FACE_TO_FACE_PAYMENT"); //销售产品码
|
List<SaasClientPay> list = saasClientPayService.list(queryWrapper);
|
if (!list.isEmpty()) {
|
SaasClientPay saasClientPay = list.get(0);
|
model.setOutTradeNo(outTradeNo); //商户订单号
|
model.setSubject("海贼王"); //订单标题
|
model.setTotalAmount(Double.valueOf(saasClientPay.getPayPrice()) / 100 + ""); //订单总金额
|
} else {
|
model.setOutTradeNo(outTradeNo); //商户订单号
|
model.setSubject("海贼王"); //订单标题
|
model.setTotalAmount("0.01"); //订单总金额
|
SaasClientPay saasClientPay = this.fengData(model);
|
boolean b = saasClientPayService.saveOrUpdate(saasClientPay);
|
}
|
AlipayTradePrecreateRequest request = new AlipayTradePrecreateRequest();
|
request.setBizModel(model);
|
//兼容pkcs1 编码；
|
java.security.Security.addProvider(
|
new org.bouncycastle.jce.provider.BouncyCastleProvider()
|
);
|
request.setNotifyUrl(alipayProperties.getNotifyUrl());
|
request.setReturnUrl(alipayProperties.getReturnUrl());
|
AlipayTradePrecreateResponse alipayTradePrecreateResponse = alipayClient.execute(request);
|
if (StringUtils.isBlank(alipayTradePrecreateResponse.getQrCode())) {
|
return ResultBody.failed().data("生成二维码失败");
|
}
|
String content = alipayTradePrecreateResponse.getQrCode();
|
String base64 = QRCodeUtil.creatRrCode(content, 200, 200, 0).replaceAll("\n", "").replaceAll("\r", "");
|
System.out.println(base64);
|
return ResultBody.ok().data(base64);
|
}
|
|
//数据封装
|
public SaasClientPay fengData(AlipayTradePrecreateModel model) {
|
SaasClientPay saasClientPay = new SaasClientPay();
|
saasClientPay.setPayPrice(1);
|
saasClientPay.setOutTradeNo(model.getOutTradeNo());
|
saasClientPay.setPayStatus(0);
|
saasClientPay.setPayMethod(1);
|
saasClientPay.setDiaId("1");
|
saasClientPay.setId(UUID.randomUUID().toString().replaceAll("-", ""));
|
saasClientPay.setCreateTime(new Date());
|
return saasClientPay;
|
}
|
|
@ApiOperation(value = "取消订单，支付超时、支付结果未知是可撤销，超过24小时不可撤销-------暂时没有配置")
|
@PostMapping("/cancel")
|
public ResultBody cancel() throws Exception { //取消订单，支付超时、支付结果未知是可撤销，超过24小时不可撤销
|
AlipayTradeCancelModel model = new AlipayTradeCancelModel();
|
model.setOutTradeNo("300");
|
|
AlipayTradeCancelRequest request = new AlipayTradeCancelRequest();
|
request.setBizModel(model);
|
|
AlipayTradeCancelResponse response = alipayClient.execute(request);
|
return ResultBody.ok().data(response.getBody());
|
}
|
|
@ApiOperation(value = "trade_success状态下异步通知接口，目前用的这个回调")
|
@PostMapping("/notify")
|
public String notify(HttpServletRequest request) throws Exception { //trade_success状态下异步通知接口
|
if (check(request.getParameterMap())) {
|
System.out.println(request.getParameter("trade_status"));
|
Map<String, String> requestMap = this.getRequestMap(request.getParameterMap());
|
log.error("eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee");
|
log.error(requestMap.toString());
|
log.error("eeeeeeeeeeeeeeeewwwwwwwwwwww:");
|
if (requestMap.get("trade_status").equals("TRADE_SUCCESS")) {
|
log.error("wwwwwwwwwww");
|
//更新状态 out_trade_no
|
log.error("eeeeeeeeeeeeeeeeeeeeeeeeeeeeeee");
|
System.out.println("异步通知 " + Instant.now());
|
return alipayService.notify(requestMap);
|
}else {
|
return "fail";
|
}
|
} else {
|
System.out.println("验签失败");
|
return "fail";
|
}
|
}
|
|
@ApiOperation(value = "订单支付成功后同步返回地址")
|
@PostMapping("/return")
|
public ResultBody returnUrl(HttpServletRequest request, Map<String, Object> map) throws Exception { //订单支付成功后同步返回地址
|
if (check(request.getParameterMap())) {
|
Map<String, String> requestMap = this.getRequestMap(request.getParameterMap());
|
log.error("wwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwww");
|
log.error(request.toString());
|
log.error("wwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwwww");
|
log.error(map.toString());
|
log.error("eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee");
|
String trade_status = requestMap.get("trade_status");
|
if (StringUtils.isNotBlank(trade_status)) {
|
//支付成功
|
if (trade_status.equals("TRADE_SUCCESS")) {
|
//更新状态 out_trade_no
|
QueryWrapper queryWrapper = new QueryWrapper();
|
queryWrapper.eq("out_trade_no", requestMap.get("out_trade_no"));
|
queryWrapper.eq("pay_status", 0);
|
List<SaasClientPay> list = saasClientPayService.list(queryWrapper);
|
if (!list.isEmpty()) {
|
SaasClientPay saasClientPay = list.get(0);
|
saasClientPay.setPayTime(DateUtils.parseDate(requestMap.get("gmt_payment")));
|
saasClientPay.setPayStatus(2);
|
saasClientPay.setTradeNo(requestMap.get("trade_no"));
|
boolean b = saasClientPayService.saveOrUpdate(saasClientPay);
|
}
|
}
|
}
|
return ResultBody.ok().data("success");
|
} else {
|
return ResultBody.failed().data("false");
|
}
|
}
|
|
private Map<String, String> getRequestMap(Map<String, String[]> requestParams) {
|
Map<String, String> params = new HashMap<>();
|
for (String name : requestParams.keySet()) {
|
String[] values = requestParams.get(name);
|
String valueStr = "";
|
for (int i = 0; i < values.length; i++) {
|
valueStr = (i == values.length - 1) ? valueStr + values[i]
|
: valueStr + values[i] + ",";
|
}
|
params.put(name, valueStr);
|
System.out.println(name + " ==> " + valueStr);
|
}
|
return params;
|
}
|
|
private boolean check(Map<String, String[]> requestParams) throws Exception { //对return、notify参数进行验签
|
Map<String, String> requestMap = this.getRequestMap(requestParams);
|
return AlipaySignature.rsaCheckV1(requestMap, alipayProperties.getAlipayPublicKey(),
|
alipayProperties.getCharset(), alipayProperties.getSignType()); //调用SDK验证签名
|
}
|
}
|
