hhyykk/ipms-sjy
1
1
Fork 0
mirror of https://gitee.com/hhyykk/ipms-sjy.git synced 2025-08-11 00:31:52 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

【代码评审】SYSTEM：订阅消息

Browse Source
This commit is contained in:
YunaiV
2024-07-29 19:18:23 +08:00
parent f46d47a966
commit 345f41b153
5 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/message/subscribe/SubscribeMessageClient.java
View File

@@ -11,6 +11,7 @@ import java.util.Map;
import static cn.iocoder.yudao.module.pay.enums.MessageTemplateConstants.PAY_WALLET_CHANGE;
// TODO @puhui999：建议可以先直接调用，不要新建一个 client。
/**
* 订阅消息
*

2
yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletRechargeServiceImpl.java
View File

@@ -139,8 +139,10 @@ public class PayWalletRechargeServiceImpl implements PayWalletRechargeService {
sendPayWalletChangeMessage(payOrderId, walletRecharge);
}
// TODO @puhui999：发送，使用异步发送；@Async
private void sendPayWalletChangeMessage(Long payOrderId, PayWalletRechargeDO walletRecharge) {
PayWalletDO wallet = payWalletService.getWallet(walletRecharge.getWalletId());
// TODO @puhui999：可以使用 MapUtil.builder()；另外，不应该是并发 hashmap 哈
Map<String, String> messages = MapUtil.newConcurrentHashMap(4);
messages.put(MessageTemplateConstants.PayWalletChangeTemplateParams.NO, String.valueOf(payOrderId));
messages.put(MessageTemplateConstants.PayWalletChangeTemplateParams.PRICE,