diff --git a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletRechargeServiceImpl.java b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletRechargeServiceImpl.java index ca750ae94..6213b9078 100644 --- a/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletRechargeServiceImpl.java +++ b/yudao-module-pay/yudao-module-pay-biz/src/main/java/cn/iocoder/yudao/module/pay/service/wallet/PayWalletRechargeServiceImpl.java @@ -145,16 +145,16 @@ public class PayWalletRechargeServiceImpl implements PayWalletRechargeService { @Async public void sendPayWalletChangeMessage(Long payOrderId, PayWalletRechargeDO walletRecharge) { - // 1.1 获得会员钱包信息 + // 1. 获得会员钱包信息 PayWalletDO wallet = payWalletService.getWallet(walletRecharge.getWalletId()); - // 1.2 构建并发送模版消息 + // 2. 构建并发送模版消息 socialClientApi.sendSubscribeMessage(new SocialWxSubscribeMessageSendReqDTO().setPage(WALLET_MONEY_PATH) - .setUserId(wallet.getUserId()).setUserType(wallet.getUserType()).setTemplateTitle(PAY_WALLET_CHANGE) - .setSocialType(SocialTypeEnum.WECHAT_MINI_APP.getType()) - // 添加模版消息 - .addMessage("phrase4", "充值成功").addMessage("character_string1", String.valueOf(payOrderId)) + .setUserId(wallet.getUserId()).setUserType(wallet.getUserType()) + .setTemplateTitle(PAY_WALLET_CHANGE).setSocialType(SocialTypeEnum.WECHAT_MINI_APP.getType()) + .addMessage("character_string1", String.valueOf(payOrderId)) .addMessage("amount2", fenToYuanStr(walletRecharge.getTotalPrice())) - .addMessage("time3", LocalDateTimeUtil.formatNormal(LocalDateTime.now()))); + .addMessage("time3", LocalDateTimeUtil.formatNormal(LocalDateTime.now())) + .addMessage("phrase4", "充值成功")); } @Override diff --git a/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApi.java b/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApi.java index 03cbde57d..07aedd3ba 100644 --- a/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApi.java +++ b/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApi.java @@ -49,6 +49,7 @@ public interface SocialClientApi { */ byte[] getWxaQrcode(@Valid SocialWxQrcodeReqDTO reqVO); + // TODO @puhui999:要不是统一都叫 getWxaSubscribeTemplateList、SocialWxaSubscribeTemplateRespDTO /** * 获得微信小程订阅模板 * @@ -56,6 +57,7 @@ public interface SocialClientApi { */ List getSubscribeTemplateList(Integer userType); + // TODO @puhui999:sendWxaSubscribeMessage、SocialWxaSubscribeMessageSendReqDTO;然后不传递 socialType;就是专门给微信小程序的 /** * 发送微信小程序订阅消息 * diff --git a/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/dto/SocialWxSubscribeMessageSendReqDTO.java b/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/dto/SocialWxSubscribeMessageSendReqDTO.java index 9799d69bd..66ef781ef 100644 --- a/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/dto/SocialWxSubscribeMessageSendReqDTO.java +++ b/yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/api/social/dto/SocialWxSubscribeMessageSendReqDTO.java @@ -2,6 +2,8 @@ package cn.iocoder.yudao.module.system.api.social.dto; import cn.iocoder.yudao.framework.common.enums.UserTypeEnum; import cn.iocoder.yudao.module.system.enums.social.SocialTypeEnum; +import jakarta.validation.constraints.NotEmpty; +import jakarta.validation.constraints.NotNull; import lombok.Data; import java.util.HashMap; @@ -16,17 +18,19 @@ import java.util.Map; public class SocialWxSubscribeMessageSendReqDTO { /** - * 用户 id + * 用户编号 * * 关联 MemberUserDO 的 id 编号 * 关联 AdminUserDO 的 id 编号 */ + @NotNull(message = "用户编号不能为空") private Long userId; /** - * 用户类型, 预留 多商户转帐可能需要用到 + * 用户类型 * * 关联 {@link UserTypeEnum} */ + @NotNull(message = "用户类型不能为空") private Integer userType; /** @@ -34,11 +38,13 @@ public class SocialWxSubscribeMessageSendReqDTO { * * 枚举 {@link SocialTypeEnum} */ + @NotNull(message = "社交类型不能为空") private Integer socialType; /** * 消息模版标题 */ + @NotEmpty(message = "消息模版标题不能为空") private String templateTitle; /** diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApiImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApiImpl.java index 131381552..71af73f47 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApiImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/social/SocialClientApiImpl.java @@ -64,9 +64,8 @@ public class SocialClientApiImpl implements SocialClientApi { @Override public List getSubscribeTemplateList(Integer userType) { - List subscribeTemplate = socialClientService.getSubscribeTemplateList(userType); - return convertList(subscribeTemplate, item -> BeanUtils.toBean(item, SocialWxSubscribeTemplateRespDTO.class) - .setId(item.getPriTmplId())); + List list = socialClientService.getSubscribeTemplateList(userType); + return convertList(list, item -> BeanUtils.toBean(item, SocialWxSubscribeTemplateRespDTO.class).setId(item.getPriTmplId())); } @Override diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/social/SocialClientServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/social/SocialClientServiceImpl.java index 0b3a4bc8f..ac115448f 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/social/SocialClientServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/social/SocialClientServiceImpl.java @@ -297,13 +297,13 @@ public class SocialClientServiceImpl implements SocialClientService { */ private WxMaSubscribeMessage buildMessageSendReqDTO(SocialWxSubscribeMessageSendReqDTO reqDTO, String templateId, String openId) { - // 1.1 设置订阅消息基本参数 + // 设置订阅消息基本参数 WxMaSubscribeMessage subscribeMessage = new WxMaSubscribeMessage().setLang("zh_CN").setMiniprogramState(envVersion) .setTemplateId(templateId).setToUser(openId).setPage(reqDTO.getPage()); - // 1.2 设置具体消息参数 + // 设置具体消息参数 Map messages = reqDTO.getMessages(); if (CollUtil.isNotEmpty(messages)) { - messages.keySet().forEach(key -> findAndThen(messages, key, value -> + reqDTO.getMessages().keySet().forEach(key -> findAndThen(messages, key, value -> subscribeMessage.addData(new WxMaSubscribeMessage.MsgData(key, value)))); } return subscribeMessage;