angelo
/
java-retail-app
3
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

## 后台办理业务手动激活推送秒结状态MQ；

This commit is contained in:
cabbage 2025-06-13 10:44:11 +08:00
parent f5b00b773e
commit ae81f09aa5
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bd-business/bd-business-member/src/main/java/com/hzs/member/handlebusiness/service/impl/CuHandleBusinessServiceImpl.java
View File

@ -696,8 +696,10 @@ public class CuHandleBusinessServiceImpl extends ServiceImpl<CuHandleBusinessMap
)
.map(BusinessMemberVO::getPkMember)
.collect(Collectors.toList());
// 推送会员激活处理
rabbitTemplate.convertAndSend(RabbitMqConstants.ORDER_SECOND_ACTIVATE_COMPENSATION_EXCHANGE, RabbitMqConstants.ORDER_SECOND_ACTIVATE_COMPENSATION_KEY, pkMemberList);
if (CollectionUtil.isNotEmpty(pkMemberList)) {
// 推送会员激活处理
rabbitTemplate.convertAndSend(RabbitMqConstants.ORDER_SECOND_ACTIVATE_COMPENSATION_EXCHANGE, RabbitMqConstants.ORDER_SECOND_ACTIVATE_COMPENSATION_KEY, pkMemberList);
}
}
return result;