在DDD集成支付寶支付，看這篇文章就夠了！
大家好，我是飄渺。在今天的DailyMart項(xiàng)目實(shí)戰(zhàn)中，我們將探討如何在領(lǐng)域驅(qū)動設(shè)計(jì)（DDD）開發(fā)中集成支付寶的網(wǎng)頁支付功能，以及相關(guān)的步驟和注意事項(xiàng)。
一、申請阿里沙箱支付
首先，我們需要申請阿里沙箱支付環(huán)境，以便于方便地進(jìn)行支付集成測試。以下是申請沙箱環(huán)境的簡要流程：
1.訪問支付寶沙箱環(huán)境，https://open.alipay.com/develop/sandbox/app，注冊并登錄。
圖片
2.設(shè)置接口加簽方式，并記錄對應(yīng)的公鑰和私鑰。
圖片
二、準(zhǔn)備內(nèi)網(wǎng)穿透工具
支付寶支付完成后，支付結(jié)果將通過回調(diào)通知到您的應(yīng)用程序（在發(fā)起支付時通過NotifyUrl參數(shù)指定）。為了確保在開發(fā)時接口能夠在外網(wǎng)進(jìn)行訪問，我們可以借助內(nèi)網(wǎng)穿透工具，將本地IP與端口映射成外網(wǎng)可訪問地址。
作為示例，我選擇使用花生殼進(jìn)行內(nèi)網(wǎng)穿透。你也可以根據(jù)需求選擇其他工具。
注冊并登錄https://hsk.oray.com，下載最新客戶端。
圖片
登錄以后配置外網(wǎng)映射，如上所示，我將本地ip+端口9090 （網(wǎng)關(guān)服務(wù)）映射成了外網(wǎng)訪問，紅框部分就是對外的訪問地址。
三、支付Demo流程演示
完成上述操作后，我們可以借助Alipay提供的SDK，進(jìn)行支付單元測試。代碼位置：
com.jianzh5.dailymart.module.order.infrastructure.alipay.AliPayTest
@Test
public void test_AliPay() throws AlipayApiException {
AlipayConfig alipayConfig = new AlipayConfig();
alipayConfig.setAppId(app_id);
// 其他配置參數(shù)...
...
// 創(chuàng)建AlipayClient
AlipayClient alipayClient = new DefaultAlipayClient(alipayConfig);
// 創(chuàng)建支付請求
AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();
// 設(shè)置回調(diào)地址
request.setNotifyUrl(notify_url);
Map<String,Object> requestMap = Maps.newHashMap();
requestMap.put("out_trade_no", "ddd20240221-001"); // 我們自己生成的訂單編號
...
request.setBizContent(JsonUtils.obj2String(requestMap));
//調(diào)用SDK生成表單
String form = alipayClient.pageExecute(request).getBody();
log.info("測試結(jié)果：{}", form);
}運(yùn)行單元測試后可以得到如下的 HTML 腳本.
<form name="punchout_form" method="post" action="https://openapi-sandbox.dl.alipaydev.com/gateway.do?charset=UTF-8&method=alipay.trade.page.pay&sign=">
<input type="hidden" name="biz_content" value="{"out_trade_no":"2846741992449220601"DDD商城訂單2846741992449220601"product_code":"FAST_INSTANT_TRADE_PAY"}">
<input type="submit" value="立即支付" style="display:none" >
</form>
<script>document.forms[0].submit();</script>將這份腳本復(fù)制到html文件中就可以直接在瀏覽器打開，效果如下：
圖片
然后從開發(fā)平臺沙箱賬號中拿到賬號密碼，進(jìn)行支付。
圖片
支付成功后的結(jié)果
圖片
以上就是集成支付寶進(jìn)行支付的一個流程，現(xiàn)在我們將支付流程集成到Dailymart中。
四、 DailyMart集成支付功能
4.1 訂單支付流程梳理
在集成支付功能之前，我們首先需要梳理訂單的創(chuàng)建與支付業(yè)務(wù)流程。主要包括以下步驟：
1.用戶從購物車發(fā)起結(jié)算后調(diào)用后臺接口生成訂單，訂單系統(tǒng)先對庫存進(jìn)行校驗(yàn)，在校驗(yàn)通過后保存商品訂單，同時調(diào)用庫存系統(tǒng)進(jìn)行庫存預(yù)扣。同時為了避免用戶創(chuàng)建訂單后不支付，在創(chuàng)建訂單的同時還會向RocketMQ發(fā)送一條延時消息，如果用戶不支付，30分鐘后會刪除對應(yīng)的訂單返回相應(yīng)的庫存。（此部分已經(jīng)在之前的章節(jié)中完成）
2.用戶確認(rèn)訂單后生成相應(yīng)的交易流水記錄以供后期查賬使用，同時調(diào)用支付寶網(wǎng)關(guān)創(chuàng)建支付訂單，系統(tǒng)引導(dǎo)用戶跳轉(zhuǎn)到支付寶支付頁面。（即前文生成的HTML頁面）
3.用戶支付成功后，支付寶會通過配置好的NotifyUrl進(jìn)行回調(diào)，在收到支付結(jié)果確認(rèn)以后需要更新訂單狀態(tài)，調(diào)用庫存服務(wù)進(jìn)行庫存扣減。
4.為了防止網(wǎng)絡(luò)問題導(dǎo)致系統(tǒng)沒收到支付寶的回調(diào)，還需要一個定時任務(wù)定時去檢索未支付成功的交易單，調(diào)用支付網(wǎng)關(guān)確認(rèn)支付結(jié)果并同時更新對應(yīng)狀態(tài)。
整體流程圖如下所示：
圖片
4.2 領(lǐng)域分析
根據(jù)訂單支付流程，我們需要在訂單上下文中創(chuàng)建三個領(lǐng)域?qū)ο螅?/p>
- PaymentOrder：支付單，作為聚合對象，用于后期查賬。
- PaymentInfo：支付信息，用于構(gòu)建支付所需的相關(guān)數(shù)據(jù)，作為值對象。
- PaymentId：支付單的ID對象，也是值對象。
圖片
4.3 核心代碼示例
1.在訂單基礎(chǔ)設(shè)施層創(chuàng)建屬性配置類，用于讀取alipay的配置數(shù)據(jù)
@Component
@ConfigurationProperties(prefix = "alipay")
@Data
public class AliPayConfigProperties {
private String appId;
private String serverUrl;
private String privateKey;
private String alipayPublicKey;
private String notifyUrl;
private String format = "JSON";
private String charset = "UTF-8";
private String signType = "RSA2";
}2.創(chuàng)建配置類，用于裝載alipay的AlipayClient對象。
@Configuration
@EnableConfigurationProperties(AliPayConfigProperties.class)
public class AliPayConfig {
@Resource
private AliPayConfigProperties aliPayConfigProperties;
@Bean
@ConditionalOnClass(AlipayClient.class)
public AlipayClient alipayClient() {
return new DefaultAlipayClient(
aliPayConfigProperties.getServerUrl(),
aliPayConfigProperties.getAppId(),
aliPayConfigProperties.getPrivateKey(),
aliPayConfigProperties.getFormat(),
aliPayConfigProperties.getCharset(),
aliPayConfigProperties.getAlipayPublicKey(),
aliPayConfigProperties.getSignType()
) ;
}
}3.需要與第三方交互，我們將交互的邏輯放在基礎(chǔ)設(shè)施層，同時提供接口供上層使用
@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Slf4j
public class AliPaymentFacadeImpl implements PaymentFacade {
@Override
public String triggerPayment(PaymentInfo paymentInfo) {
// 發(fā)送請求的 Request類
AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();
request.setNotifyUrl(aliPayConfigProperties.getNotifyUrl());
Map<String,Object> requestMap = Maps.newHashMap();
requestMap.put("out_trade_no", paymentInfo.getOrderNo()); // 我們自己生成的訂單編號
requestMap.put("total_amount", paymentInfo.getTotalAmount()); // 訂單的總金額
requestMap.put("subject", paymentInfo.getSubject()); // 支付的名稱
requestMap.put("product_code", "FAST_INSTANT_TRADE_PAY"); // 固定配置
request.setBizContent(JsonUtils.obj2String(requestMap));
//調(diào)用SDK生成表單
String form = "";
try {
form = alipayClient.pageExecute(request).getBody();
log.info("訂單{}, 生成的表單地址為：{}", paymentInfo.getOrderNo(),form);
} catch (AlipayApiException e) {
log.error("訂單{}生成支付頁面異常," ,paymentInfo.getOrderNo(),e);
throw new BusinessException("支付訂單創(chuàng)建異常");
}
return form;
}
}4.對外提供接口，用于生成alipay支付表單
@RestController
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Tag(name = "AliPayController", description = "C端訂單支付")
@Slf4j
public class AliPayController {
@Operation(summary = "生成支付表單")
@GetMapping("/api/pd/alipay/form")
public PaymentInfoDTO pay(@RequestParam("orderSn") String orderSn) {
return paymentService.createPaymentOrder(orderSn);
}
}5.由應(yīng)用領(lǐng)域?qū)油瓿芍Ц侗韱芜壿?/p>
@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Slf4j
public class PaymentServiceImpl implements PaymentService {
...
@Override
public PaymentInfoDTO createPaymentOrder(String orderSn) {
TradeOrder tradeOrder = Optional.ofNullable(tradeOrderService.getByOrderSn(orderSn)).orElseThrow(() -> new BusinessException("訂單編號不存在"));
// 確保訂單處于待支付狀態(tài)
if (Objects.equals(tradeOrder.getStatus(), OrderStatusEnum.WAITING_PAYMENT.getStatus())) {
PaymentInfo paymentInfo = PaymentInfo.builder()
.orderNo(orderSn)
.totalAmount(String.valueOf(tradeOrder.getTotalAmount()))
.subject("DDD商城訂單" + tradeOrder.getOrderSn())
.build();
//獲取表單地址
String paymentForm = paymentFacade.triggerPayment(paymentInfo);
if(StringUtils.isNotEmpty(paymentForm)){
PaymentOrder paymentOrder = PaymentOrder.builder()
.orderNo(orderSn)
.userId(tradeOrder.getCustomerId())
.totalAmount(String.valueOf(tradeOrder.getTotalAmount()))
.tradeSubject("DDD商城訂單" + tradeOrder.getOrderSn())
.orderTime(tradeOrder.getCreateTime())
.paymentForm(paymentForm)
.build();
//保存支付訂單
paymentOrderService.save(paymentOrder);
return PaymentInfoDTO.builder()
.orderSn(tradeOrder.getOrderSn())
.payUrl(paymentForm)
.build();
}else{
throw new BusinessException("創(chuàng)建支付寶表單失敗,請檢查參數(shù)參數(shù).");
}
} else {
throw new BusinessException("訂單已支付，請勿重復(fù)提交...");
}
}
}6.提供接口供alipay回調(diào)，在回調(diào)邏輯中完成訂單狀態(tài)和支付訂單的更新，同時還需要調(diào)用庫存服務(wù)進(jìn)行庫存扣減，為了實(shí)現(xiàn)分布式事務(wù)，這里借住RocketMQ的事務(wù)消息實(shí)現(xiàn)最終一致性。
/**
* 支付寶回調(diào)邏輯
* 1. 將訂單狀態(tài)修改成已支付
* 2. 占用庫存
* 跨服務(wù)調(diào)用，基于RocketMQ來解決分布式事務(wù)
*/
@Operation(summary = "支付寶回調(diào)")
@PostMapping("/api/pd/alipay/notify")
public String payNotify(HttpServletRequest request){
String tradeStatus = request.getParameter("trade_status");
if (tradeStatus.equals("TRADE_SUCCESS")) {
Map<String, String> params = new HashMap<>();
Map<String, String[]> requestParams = request.getParameterMap();
for (String name : requestParams.keySet()) {
params.put(name, request.getParameter(name));
}
String sign = params.get("sign");
String aliPaySign = AlipaySignature.getSignCheckContentV1(params);
//支付寶公鑰
String alipayPublicKey = aliPayConfigProperties.getAlipayPublicKey();
try {
boolean checkSignature = AlipaySignature.rsa256CheckContent(aliPaySign, sign, alipayPublicKey, "UTF-8");
//簽名驗(yàn)證通過
if(checkSignature){
//更新訂單狀態(tài)
return paymentService.updatePayment(params);
}
} catch (AlipayApiException e) {
throw new RuntimeException(e);
}
}
return "false";
}@Override
public String updatePayment(Map<String, String> requestParams) {
PaymentInfo paymentInfo = PaymentInfo.builder()
.orderNo(requestParams.get("out_trade_no"))
.tradeNo(requestParams.get("trade_no"))
...
.build();
OrderPaidEvent orderPaidEvent = new OrderPaidEvent(paymentInfo);
TradeOrder tradeOrder = Optional.ofNullable(tradeOrderService.getByOrderSn(paymentInfo.getOrderNo())).orElseThrow(() -> new BusinessException("訂單編號不存在"));
if (Objects.equals(tradeOrder.getStatus(), OrderStatusEnum.WAITING_PAYMENT.getStatus())) {
TransactionSendResult sendResult = enhanceTemplate.sendTransaction("TRADE-ORDER", "ORDER-PAID", orderPaidEvent, OrderPaidTransactionConsumer.class);
if (SendStatus.SEND_OK == sendResult.getSendStatus() && sendResult.getLocalTransactionState() == LocalTransactionState.COMMIT_MESSAGE) {
return "success";
}
}
return "false";
}7.支付單表結(jié)構(gòu)
create table customer_payment
(
payment_id bigint auto_increment primary key, -- 主鍵
order_no varchar(32) null, -- 訂單編號
user_id bigint null, -- 系統(tǒng)用戶ID
trade_status varchar(50) null, -- 交易狀態(tài)
trade_no varchar(100) null, -- 外部交易號
total_amount varchar(20) null, -- 支付金額
trade_subject varchar(200) null, -- 支付標(biāo)題
payment_form varchar(2000) null, -- 支付表單
buyer_id varchar(100) null, -- 付款用戶ID
buyer_pay_amount varchar(100) null, -- 實(shí)際付款金額
gmt_payment varchar(20) null, -- 實(shí)際支付時間
create_time datetime null,
update_time datetime null,
del_flag int null
);五、小結(jié)
通過以上步驟，我們完成了在DDD開發(fā)中集成支付寶網(wǎng)頁支付功能的實(shí)踐。本文涉及的代碼都已經(jīng)上傳至Github，感興趣的可以通過文末方式獲取。
