本文作者:程序员飞云
沙箱地址
https://open.alipay.com/develop/sandbox/app
启动公钥

引入依赖
<dependency> <groupId>com.alipay.sdk</groupId> <artifactId>alipay-sdk-java</artifactId> <version>4.22.110.ALL</version></dependency>
<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.8.18</version></dependency>添加yml配置
alipay: appId: xxx appPrivateKey: xxx alipayPublicKey: xxx notifyUrl: xxxnotifyUrl配置
内网穿透
注册
官网:https://natapp.cn/ 需要先注册账号,实名认证。
隧道
进入后需要购买我的隧道,使用free即可,里面的端口填写自己需要的端口即可。

客户端
下载客户端 https://natapp.cn/#download 解压
配置start.bat
创建start.bat,内容如下 natapp.exe -authtoken= xxx 这个authToken就是natapp里面隧道的authToken

notifyUrl配置
xxx/alipay/notify 注意这里的/alipay/notify是controller的接口地址,如果添加了servlet-contextPath,就需要加上这个前缀,例如我的是/api,所以正确配置是xxx/api/alipay/notify
编写配置类
import lombok.Data;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.stereotype.Component;
@Data@Component@ConfigurationProperties(prefix = "alipay")public class AliPayConfig { private String appId; private String appPrivateKey; private String alipayPublicKey; private String notifyUrl;}编写实体类
import lombok.Data;
@Datapublic class AliPay { private String traceNo; private double totalAmount; private String subject; private String alipayTraceNo;}编写Controller,前提需要Order,需要自己创建order表
import cn.hutool.json.JSONObject;import com.alipay.api.AlipayApiException;import com.alipay.api.AlipayClient;import com.alipay.api.DefaultAlipayClient;import com.alipay.api.internal.util.AlipaySignature;import com.alipay.api.request.AlipayTradePagePayRequest;import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;import com.fly.alipay.AliPay;import com.fly.alipay.AliPayConfig;import com.fly.mapper.OrderApiMapper;import com.flyCommon.model.entity.OrderApi;import org.springframework.web.bind.annotation.GetMapping;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.util.Date;import java.util.HashMap;import java.util.Map;
@RestController@RequestMapping( "/alipay" )public class AliPayController {
// 支付宝网关地址 private static final String GATEWAY_URL = "https://openapi-sandbox.dl.alipaydev.com/gateway.do"; private static final String FORMAT = "JSON"; private static final String CHARSET = "UTF-8"; //签名方式 private static final String SIGN_TYPE = "RSA2";
@Resource private AliPayConfig aliPayConfig;
@Resource private OrderApiMapper ordersMapper;
@GetMapping( "/pay" ) // &subject=xxx&traceNo=xxx&totalAmount=xxx public void pay(AliPay aliPay, HttpServletResponse httpResponse) throws Exception { // 1. 创建Client,通用SDK提供的Client,负责调用支付宝的API AlipayClient alipayClient = new DefaultAlipayClient(GATEWAY_URL, aliPayConfig.getAppId(), aliPayConfig.getAppPrivateKey(), FORMAT, CHARSET, aliPayConfig.getAlipayPublicKey(), SIGN_TYPE);
// 2. 创建 Request并设置Request参数 AlipayTradePagePayRequest request = new AlipayTradePagePayRequest(); // 发送请求的 Request类 request.setNotifyUrl(aliPayConfig.getNotifyUrl()); JSONObject bizContent = new JSONObject(); bizContent.set("out_trade_no", aliPay.getTraceNo()); // 我们自己生成的订单编号 bizContent.set("total_amount", aliPay.getTotalAmount()); // 订单的总金额 bizContent.set("subject", aliPay.getSubject()); // 支付的名称 bizContent.set("product_code", "FAST_INSTANT_TRADE_PAY"); // 固定配置 request.setBizContent(bizContent.toString());
// 执行请求,拿到响应的结果,返回给浏览器 String form = ""; try { form = alipayClient.pageExecute(request).getBody(); // 调用SDK生成表单 } catch (AlipayApiException e) { e.printStackTrace(); } httpResponse.setContentType("text/html;charset=" + CHARSET); httpResponse.getWriter().write(form);// 直接将完整的表单html输出到页面 httpResponse.getWriter().flush(); httpResponse.getWriter().close(); }
@PostMapping( "/notify" ) // 注意这里必须是POST接口 public String payNotify(HttpServletRequest request) throws Exception { if (request.getParameter("trade_status").equals("TRADE_SUCCESS")) { System.out.println("=========支付宝异步回调========");
Map<String, String> params = new HashMap<>(); Map<String, String[]> requestParams = request.getParameterMap(); for (String name : requestParams.keySet()) { params.put(name, request.getParameter(name)); // System.out.println(name + " = " + request.getParameter(name)); }
String outTradeNo = params.get("out_trade_no"); String gmtPayment = params.get("gmt_payment"); String alipayTradeNo = params.get("trade_no");
String sign = params.get("sign"); String content = AlipaySignature.getSignCheckContentV1(params); boolean checkSignature = AlipaySignature.rsa256CheckContent(content, sign, aliPayConfig.getAlipayPublicKey(), "UTF-8"); // 验证签名 // 支付宝验签 if (checkSignature) { // 验签通过 System.out.println("交易名称: " + params.get("subject")); System.out.println("交易状态: " + params.get("trade_status")); System.out.println("支付宝交易凭证号: " + params.get("trade_no")); System.out.println("商户订单号: " + params.get("out_trade_no")); System.out.println("交易金额: " + params.get("total_amount")); System.out.println("买家在支付宝唯一id: " + params.get("buyer_id")); System.out.println("买家付款时间: " + params.get("gmt_payment")); System.out.println("买家付款金额: " + params.get("buyer_pay_amount"));
// 查询订单,根据实际要求 // QueryWrapper<OrderApi> queryWrapper = new QueryWrapper<>(); // queryWrapper.eq("order_id", outTradeNo); // OrderApi orders = ordersMapper.selectOne(queryWrapper); // if (orders != null) { // orders.setOrderSn(alipayTradeNo); // orders.setCreateTime(new Date()); // orders.setStatus(1); // ordersMapper.updateById(orders); // } } } return "success"; }}启动项目
我的地址是,http://localhost:7529/api/alipay/pay?&subject=%E8%A5%BF%E7%93%9C&traceNo=2022123&totalAmount=12.1

支付账号可以从支付宝里面沙箱账号获取

界面回调
配置yml,alipay里面配置,这个地址是你的前端回调的地址
returnUrl: xxx实体类也要添加
private String alipayTraceNo;controller
request.setNotifyUrl(aliPayConfig.getNotifyUrl()); request.setReturnUrl(aliPayConfig.getReturnUrl());订单退款
@GetMapping("/return") public BaseResponse returnPay(String orderNo) throws AlipayApiException { // 7天无理由退款 String now = DateUtil.now(); TOrder orders = orderService.getById(orderNo); if (orders != null) { // hutool工具类,判断时间间隔 long between = DateUtil.between(DateUtil.parseDateTime((CharSequence) orders.getDelaytime()), DateUtil.parseDateTime(now), DateUnit.DAY); if (between > 7) { return ResultUtils.error(ErrorCode.PARAMS_ERROR, "该订单已超过7天,不支持退款"); } } // 1. 创建Client,通用SDK提供的Client,负责调用支付宝的API AlipayClient alipayClient = new DefaultAlipayClient(GATEWAY_URL, aliPayConfig.getAppId(), aliPayConfig.getAppPrivateKey(), FORMAT, CHARSET, aliPayConfig.getAlipayPublicKey(), SIGN_TYPE); // 2. 创建 Request,设置参数 AlipayTradeRefundRequest request = new AlipayTradeRefundRequest(); JSONObject bizContent = new JSONObject(); bizContent.set("trade_no", orders.getAlipaytradeno()); // 支付宝回调的订单流水号 bizContent.set("refund_amount", orders.getTotalamount()); // 订单的总金额 bizContent.set("out_request_no", orders.getOrderid()); // 我的订单编号
// 返回参数选项,按需传入 JSONArray queryOptions = new JSONArray(); queryOptions.add("refund_detail_item_list"); bizContent.put("query_options", queryOptions);
request.setBizContent(bizContent.toString());
// 3. 执行请求 AlipayTradeRefundResponse response = alipayClient.execute(request); if (response.isSuccess()) { // 退款成功,isSuccess 为true System.out.println("调用成功");
// 4. 更新数据库状态 orders.setOrderstatusid(6); boolean b = orderService.updateById(orders); return ResultUtils.success(b); } else { // 退款失败,isSuccess 为false System.out.println(response.getBody()); return ResultUtils.error(ErrorCode.PARAMS_ERROR, response.getBody()); } }
评论