Compare commits

...

2 Commits

1 changed files with 4 additions and 2 deletions

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;