3
0
Fork 0

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

This commit is contained in:
cabbage 2025-06-13 10:44:11 +08:00
parent 1f8d4a2b50
commit d2188ab2b0
1 changed files with 4 additions and 2 deletions

View File

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