| | |
| | | log.info("发送返利消息:{}", orderId); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.AGENT_REUTRN_MONEY.getExchange(), RabbitQueueEnum.AGENT_REUTRN_MONEY.getRoute(), orderId); |
| | | } |
| | | |
| | | public void sendMemberSubMsg(String memberOpenId) { |
| | | log.info("新增用户关注:{}", memberOpenId); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.YWG_MEMBER_SUB.getExchange(), RabbitQueueEnum.YWG_MEMBER_SUB.getRoute(), memberOpenId); |
| | | } |
| | | |
| | | public void sendMemberSubScanMsg(String str) { |
| | | log.info("新增用户扫码:{}", str); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.YWG_MEMBER_SUB_SCAN.getExchange(), RabbitQueueEnum.YWG_MEMBER_SUB_SCAN.getRoute(), str); |
| | | } |
| | | } |