lzq
/
njzscloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

发送消息修改

dev
ljw 2026-02-11 09:05:10 +08:00
parent 07864ba89a
commit 11e38b86c8
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
njzscloud-svr/src/main/java/com/njzscloud/supervisory/order/service/OrderInfoService.java
View File

@ -901,22 +901,23 @@ public class OrderInfoService extends ServiceImpl<OrderInfoMapper, OrderInfoEnti
if (null != roleEntity && null != roleEntity.getId()) { if (null != roleEntity && null != roleEntity.getId()) {
List<SysUserRoleEntity> userIds = userRoleService.list(Wrappers.lambdaQuery(SysUserRoleEntity.class) List<SysUserRoleEntity> userIds = userRoleService.list(Wrappers.lambdaQuery(SysUserRoleEntity.class)
.eq(SysUserRoleEntity::getRoleId, roleEntity.getId())); .eq(SysUserRoleEntity::getRoleId, roleEntity.getId()));
TemplateMessageParam param = new TemplateMessageParam();
param.setTempType(TempType.AUDIT_PENDING.getVal());
param.setSn(orderInfo.getSn());
UserEntity orderUserEntity = userService.getById(orderInfo.getUserId()); UserEntity orderUserEntity = userService.getById(orderInfo.getUserId());
param.setCfCompanyName(orderUserEntity.getNickname());
OrderGoodsEntity entity = orderGoodsService.getById(orderInfo.getGoodsId()); OrderGoodsEntity entity = orderGoodsService.getById(orderInfo.getGoodsId());
param.setGoodsName(entity.getGoodsName());
BizCompanyEntity companyEntity = bizCompanyService.getById(orderInfo.getTransCompanyId()); BizCompanyEntity companyEntity = bizCompanyService.getById(orderInfo.getTransCompanyId());
param.setCompanyName(companyEntity.getCompanyName());
param.setCreateTime(orderInfo.getCreateTime());
Set<String> openId = new HashSet<>(); Set<String> openId = new HashSet<>();
TemplateMessageParam param;
for (SysUserRoleEntity userRoleEntity : userIds) { for (SysUserRoleEntity userRoleEntity : userIds) {
UserEntity userEntity = userService.getById(userRoleEntity.getUserId()); UserEntity userEntity = userService.getById(userRoleEntity.getUserId());
if (null != userEntity && !Strings.isNullOrEmpty(userEntity.getOpenid())) { if (null != userEntity && !Strings.isNullOrEmpty(userEntity.getOpenid())) {
if (openId.add(userEntity.getOpenid())) { if (openId.add(userEntity.getOpenid())) {
param = new TemplateMessageParam();
param.setUserId(userRoleEntity.getUserId()); param.setUserId(userRoleEntity.getUserId());
param.setTempType(TempType.AUDIT_PENDING.getVal());
param.setSn(orderInfo.getSn());
param.setCfCompanyName(orderUserEntity.getNickname());
param.setGoodsName(entity.getGoodsName());
param.setCompanyName(companyEntity.getCompanyName());
param.setCreateTime(orderInfo.getCreateTime());
log.info("发送审核通知模板消息，参数：{}", param); log.info("发送审核通知模板消息，参数：{}", param);
wechatTemplateMessageService.sendTemplateMessage(param); wechatTemplateMessageService.sendTemplateMessage(param);
} }