對標(biāo)蘋果的靈動島 華為帶來實況窗功能
繼蘋果的靈動島之后，華為也在今天正式推出了“實況窗”功能。據(jù)今天鴻蒙OS 4.0的現(xiàn)場演示顯示，華為的實況窗可以更高效的展現(xiàn)出實時通知，比如鎖屏上就能看到外賣、打車、銀行
大家好，我是飄渺。在今天的DailyMart項目實戰(zhàn)中，我們將探討如何在領(lǐng)域驅(qū)動設(shè)計（DDD）開發(fā)中集成支付寶的網(wǎng)頁支付功能，以及相關(guān)的步驟和注意事項。
首先，我們需要申請阿里沙箱支付環(huán)境，以便于方便地進(jìn)行支付集成測試。以下是申請沙箱環(huán)境的簡要流程：
1.訪問支付寶沙箱環(huán)境，https://open.alipay.com/develop/sandbox/app，注冊并登錄。
圖片
2.設(shè)置接口加簽方式，并記錄對應(yī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)訪問，紅框部分就是對外的訪問地址。
完成上述操作后，我們可以借助Alipay提供的SDK，進(jìn)行支付單元測試。代碼位置：
com.jianzh5.dailymart.module.order.infrastructure.alipay.AliPayTest
@Testpublic 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);}運行單元測試后可以得到如下的 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中。
在集成支付功能之前，我們首先需要梳理訂單的創(chuàng)建與支付業(yè)務(wù)流程。主要包括以下步驟：
1.用戶從購物車發(fā)起結(jié)算后調(diào)用后臺接口生成訂單，訂單系統(tǒng)先對庫存進(jì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)。
整體流程圖如下所示：
圖片
根據(jù)訂單支付流程，我們需要在訂單上下文中創(chuàng)建三個領(lǐng)域?qū)ο螅?span style="display:none">Wzh28資訊網(wǎng)——每日最新資訊28at.com
圖片
1.在訂單基礎(chǔ)設(shè)施層創(chuàng)建屬性配置類，用于讀取alipay的配置數(shù)據(jù)
@Component@ConfigurationProperties(prefix = "alipay")@Datapublic 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))@Slf4jpublic 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端訂單支付")@Slf4jpublic 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ū)油瓿芍Ц侗韱芜壿?span style="display:none">Wzh28資訊網(wǎng)——每日最新資訊28at.com
@Service@RequiredArgsConstructor(onConstructor = @__(@Autowired))@Slf4jpublic 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)行庫存扣減，為了實現(xiàn)分布式事務(wù)，這里借住RocketMQ的事務(wù)消息實現(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"); //簽名驗證通過 if(checkSignature){ //更新訂單狀態(tài) return paymentService.updatePayment(params); } } catch (AlipayApiException e) { throw new RuntimeException(e); } } return "false";}@Overridepublic 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, -- 實際付款金額 gmt_payment varchar(20) null, -- 實際支付時間 create_time datetime null, update_time datetime null, del_flag int null);通過以上步驟，我們完成了在DDD開發(fā)中集成支付寶網(wǎng)頁支付功能的實踐。本文涉及的代碼都已經(jīng)上傳至Github，感興趣的可以通過文末方式獲取。
本文鏈接：http://m.www897cc.com/showinfo-26-75315-0.html在DDD集成支付寶支付，看這篇文章就夠了！
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號