Spring Boot + MyBatis 集成支付宝支付流程

Spring Boot + MyBatis 集成支付宝支付流程

核心流程

1. 商户系统生成订单
2. 调用支付宝创建预支付订单
3. 用户跳转支付宝完成支付
4. 支付宝异步通知支付结果
5. 商户处理支付结果更新订单状态
6. 支付宝同步跳转回商户页面

---

代码实现示例（电脑网站支付）

1. 添加依赖

<!-- pom.xml -->
<dependencies><!-- Spring Boot Web --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- MyBatis & MySQL --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.2.2</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!-- 支付宝SDK --><dependency><groupId>com.alipay.sdk</groupId><artifactId>alipay-sdk-java</artifactId><version>4.35.0.ALL</version></dependency><!-- Lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency>
</dependencies>

2. 支付宝配置类

@Configuration
public class AlipayConfig {@Value("${alipay.app_id}")private String appId;@Value("${alipay.merchant_private_key}")private String merchantPrivateKey;@Value("${alipay.alipay_public_key}")private String alipayPublicKey;@Value("${alipay.notify_url}")private String notifyUrl;@Value("${alipay.return_url}")private String returnUrl;@Value("${alipay.gateway_url}")private String gatewayUrl;@Value("${alipay.sign_type}")private String signType;@Value("${alipay.charset}")private String charset;@Beanpublic AlipayClient alipayClient() {return new DefaultAlipayClient(gatewayUrl,appId,merchantPrivateKey,"json",charset,alipayPublicKey,signType);}
}

3. 实体类和Mapper

// 订单实体
@Data
public class Order {private Long id;private String orderNo;   // 商户订单号private BigDecimal amount;// 支付金额private Integer status;   // 0-待支付, 1-已支付private LocalDateTime createTime;
}// MyBatis Mapper
@Mapper
public interface OrderMapper {@Insert("INSERT INTO orders(order_no, amount, status, create_time) " +"VALUES(#{orderNo}, #{amount}, 0, NOW())")@Options(useGeneratedKeys = true, keyProperty = "id")void insert(Order order);@Update("UPDATE orders SET status = #{status} WHERE order_no = #{orderNo}")void updateStatus(@Param("orderNo") String orderNo, @Param("status") int status);
}

4. 支付服务类

@Service
public class PayService {@Autowired private AlipayClient alipayClient;@Autowired private OrderMapper orderMapper;@Value("${alipay.return_url}") private String returnUrl;@Value("${alipay.notify_url}") private String notifyUrl;// 创建支付订单public String createPayOrder(Order order) throws AlipayApiException {orderMapper.insert(order); // 保存订单到数据库AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();request.setReturnUrl(returnUrl);request.setNotifyUrl(notifyUrl);// 构造业务参数JSONObject bizContent = new JSONObject();bizContent.put("out_trade_no", order.getOrderNo());bizContent.put("total_amount", order.getAmount());bizContent.put("subject", "商品支付");bizContent.put("product_code", "FAST_INSTANT_TRADE_PAY"); // 电脑网站支付request.setBizContent(bizContent.toString());return alipayClient.pageExecute(request).getBody();}// 处理异步通知public boolean handleNotify(Map<String, String> params) throws AlipayApiException {// 1. 验证签名boolean signVerified = AlipaySignature.rsaCheckV1(params,alipayPublicKey,  // 注入支付宝公钥charset,signType);if (!signVerified) return false;// 2. 验证交易状态String tradeStatus = params.get("trade_status");if (!"TRADE_SUCCESS".equals(tradeStatus)) return false;// 3. 更新订单状态String orderNo = params.get("out_trade_no");orderMapper.updateStatus(orderNo, 1); // 更新为已支付return true;}
}

5. 控制器

@RestController
@RequestMapping("/pay")
public class PayController {@Autowired private PayService payService;// 创建支付订单@PostMapping("/create")public String createOrder(@RequestParam BigDecimal amount) throws AlipayApiException {Order order = new Order();order.setOrderNo(UUID.randomUUID().toString().replace("-", ""));order.setAmount(amount);return payService.createPayOrder(order); // 返回支付页面表单}// 支付宝异步通知（需公网可访问）@PostMapping("/notify")public String alipayNotify(HttpServletRequest request) throws UnsupportedEncodingException, AlipayApiException {Map<String, String> params = parseRequestParams(request);boolean success = payService.handleNotify(params);return success ? "success" : "failure"; // 通知支付宝处理结果}// 支付宝同步跳转@GetMapping("/return")public String alipayReturn(HttpServletRequest request) {// 简单展示支付结果（实际需要验签和状态检查）return "支付完成！订单号：" + request.getParameter("out_trade_no");}// 解析请求参数private Map<String, String> parseRequestParams(HttpServletRequest request) {// 转换参数Map（参考支付宝示例代码）}
}

6. 配置文件

# application.properties
# 支付宝配置
alipay.app_id=2021000123456789
alipay.merchant_private_key=MIIEvQIBADANB...
alipay.alipay_public_key=MIIBIjANBgkq...
alipay.notify_url=http://your-domain.com/pay/notify
alipay.return_url=http://your-domain.com/pay/return
alipay.gateway_url=https://openapi.alipay.com/gateway.do
alipay.sign_type=RSA2
alipay.charset=UTF-8# MySQL配置
spring.datasource.url=jdbc:mysql://localhost:3306/alipay_demo
spring.datasource.username=root
spring.datasource.password=123456

---

关键流程说明

1. 生成商户订单

   • 生成唯一订单号（推荐雪花算法）
   • 保存订单到数据库（状态=待支付）

2. 调用支付宝接口

   • 使用 AlipayTradePagePayRequest 构建请求
   • 关键参数：订单号、金额、支付标题、回调地址

3. 接收异步通知

   • 必须验证签名（防止伪造请求）
   • 检查 trade_status 是否为 TRADE_SUCCESS
   • 更新订单状态（注意处理幂等性）

4. 安全注意事项

   • 支付金额需与订单金额比对（防止金额篡改）
   • 敏感操作记录日志
   • 异步通知处理需要保证幂等性

5. 扩展功能

   • 订单超时关闭：定时任务扫描未支付订单
   • 支付结果查询：通过 trade_no 调用支付宝查询接口
   • 退款功能：使用 AlipayTradeRefundRequest

提示：实际开发中需要：

1. 替换为正式支付宝账户
2. 配置公网可访问的域名
3. 添加完整的错误处理
4. 实现参数解析工具方法
5. 添加数据库事务管理