在DDD集成支付寶支付，看這篇文章就夠了！

作者：飄渺Jam 2024-02-28 08:59:47

開發前端

支付寶支付完成后，支付結果將通過回調通知到您的應用程序（在發起支付時通過NotifyUrl參數指定）。為了確保在開發時接口能夠在外網進行訪問，我們可以借助內網穿透工具，將本地IP與端口映射成外網可訪問地址。

大家好，我是飄渺。在今天的DailyMart項目實戰中，我們將探討如何在領域驅動設計（DDD）開發中集成支付寶的網頁支付功能，以及相關的步驟和注意事項。

一、申請阿里沙箱支付

首先，我們需要申請阿里沙箱支付環境，以便于方便地進行支付集成測試。以下是申請沙箱環境的簡要流程：

1.訪問支付寶沙箱環境，https://open.alipay.com/develop/sandbox/app，注冊并登錄。

圖片

2.設置接口加簽方式，并記錄對應的公鑰和私鑰。

圖片

二、準備內網穿透工具

作為示例，我選擇使用花生殼進行內網穿透。你也可以根據需求選擇其他工具。

注冊并登錄https://hsk.oray.com，下載最新客戶端。

圖片

登錄以后配置外網映射，如上所示，我將本地ip+端口9090 （網關服務）映射成了外網訪問，紅框部分就是對外的訪問地址。

三、支付Demo流程演示

完成上述操作后，我們可以借助Alipay提供的SDK，進行支付單元測試。代碼位置：

com.jianzh5.dailymart.module.order.infrastructure.alipay.AliPayTest

@Test
public void test_AliPay() throws AlipayApiException {
    AlipayConfig alipayConfig = new AlipayConfig();
    alipayConfig.setAppId(app_id);
    // 其他配置參數...
  ...
    // 創建AlipayClient
    AlipayClient alipayClient = new DefaultAlipayClient(alipayConfig);

    // 創建支付請求
    AlipayTradePagePayRequest request = new AlipayTradePagePayRequest(); 
    // 設置回調地址
    request.setNotifyUrl(notify_url);

    Map<String,Object> requestMap = Maps.newHashMap();
    requestMap.put("out_trade_no", "ddd20240221-001");  // 我們自己生成的訂單編號
  ...
    
    request.setBizContent(JsonUtils.obj2String(requestMap));

    //調用SDK生成表單
    String form = alipayClient.pageExecute(request).getBody();
    log.info("測試結果：{}", form);
}

運行單元測試后可以得到如下的 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>

將這份腳本復制到html文件中就可以直接在瀏覽器打開，效果如下：

圖片

然后從開發平臺沙箱賬號中拿到賬號密碼，進行支付。

圖片

支付成功后的結果

圖片

以上就是集成支付寶進行支付的一個流程，現在我們將支付流程集成到Dailymart中。

四、 DailyMart集成支付功能

4.1 訂單支付流程梳理

在集成支付功能之前，我們首先需要梳理訂單的創建與支付業務流程。主要包括以下步驟：

1.用戶從購物車發起結算后調用后臺接口生成訂單，訂單系統先對庫存進行校驗，在校驗通過后保存商品訂單，同時調用庫存系統進行庫存預扣。同時為了避免用戶創建訂單后不支付，在創建訂單的同時還會向RocketMQ發送一條延時消息，如果用戶不支付，30分鐘后會刪除對應的訂單返回相應的庫存。（此部分已經在之前的章節中完成）

2.用戶確認訂單后生成相應的交易流水記錄以供后期查賬使用，同時調用支付寶網關創建支付訂單，系統引導用戶跳轉到支付寶支付頁面。（即前文生成的HTML頁面）

3.用戶支付成功后，支付寶會通過配置好的NotifyUrl進行回調，在收到支付結果確認以后需要更新訂單狀態，調用庫存服務進行庫存扣減。

4.為了防止網絡問題導致系統沒收到支付寶的回調，還需要一個定時任務定時去檢索未支付成功的交易單，調用支付網關確認支付結果并同時更新對應狀態。

整體流程圖如下所示：

圖片

4.2 領域分析

根據訂單支付流程，我們需要在訂單上下文中創建三個領域對象：

PaymentOrder：支付單，作為聚合對象，用于后期查賬。
PaymentInfo：支付信息，用于構建支付所需的相關數據，作為值對象。
PaymentId：支付單的ID對象，也是值對象。

圖片

4.3 核心代碼示例

1.在訂單基礎設施層創建屬性配置類，用于讀取alipay的配置數據

@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.創建配置類，用于裝載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.需要與第三方交互，我們將交互的邏輯放在基礎設施層，同時提供接口供上層使用

@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Slf4j
public class AliPaymentFacadeImpl implements PaymentFacade {

    @Override
    public String triggerPayment(PaymentInfo paymentInfo) {
    // 發送請求的 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));

        //調用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("支付訂單創建異常");
        }

        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.由應用領域層完成支付表單邏輯

@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("訂單編號不存在"));

        // 確保訂單處于待支付狀態
        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("創建支付寶表單失敗,請檢查參數參數.");
            }

        } else {
            throw new BusinessException("訂單已支付，請勿重復提交...");
        }

    }
}

6.提供接口供alipay回調，在回調邏輯中完成訂單狀態和支付訂單的更新，同時還需要調用庫存服務進行庫存扣減，為了實現分布式事務，這里借住RocketMQ的事務消息實現最終一致性。

/**
 * 支付寶回調邏輯
 * 1. 將訂單狀態修改成已支付
 * 2. 占用庫存
 * 跨服務調用，基于RocketMQ來解決分布式事務
 */
@Operation(summary = "支付寶回調")
@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");
      //簽名驗證通過
      if(checkSignature){
        //更新訂單狀態
        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.支付單表結構

create table customer_payment
(
    payment_id       bigint auto_increment primary key, -- 主鍵
    order_no         varchar(32)   null,  -- 訂單編號
    user_id          bigint        null,  -- 系統用戶ID
    trade_status     varchar(50)   null,  -- 交易狀態
    trade_no         varchar(100)  null,  -- 外部交易號
    total_amount     varchar(20)   null,  -- 支付金額
    trade_subject    varchar(200)  null,  -- 支付標題
    payment_form     varchar(2000) null,  -- 支付表單
    buyer_id         varchar(100)  null,  -- 付款用戶ID
    buyer_pay_amount varchar(100)  null,  -- 實際付款金額
    gmt_payment      varchar(20)   null,  -- 實際支付時間
    create_time      datetime      null,
    update_time      datetime      null,
    del_flag         int           null
);

五、小結

通過以上步驟，我們完成了在DDD開發中集成支付寶網頁支付功能的實踐。本文涉及的代碼都已經上傳至Github，感興趣的可以通過文末方式獲取。

責任編輯：武曉燕來源： JAVA日知錄

支付寶支付開發