| | |
| | | log.info("新增用户扫码:{}", str); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.YWG_MEMBER_SUB_SCAN.getExchange(), RabbitQueueEnum.YWG_MEMBER_SUB_SCAN.getRoute(), str); |
| | | } |
| | | |
| | | public void sendMemberInfoMsg(String str) { |
| | | log.info("更新用户信息:{}", str); |
| | | /** |
| | | * String str:accessToken|openId |
| | | */ |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.YWG_MEMBER_INFO.getExchange(), RabbitQueueEnum.YWG_MEMBER_INFO.getRoute(), str); |
| | | } |
| | | |
| | | public void sendOrderGetMsg(String str) { |
| | | log.info("支付后同意验证:{}", str); |
| | | /** |
| | | * String str : orderId@amount |
| | | */ |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.YWG_ORDER_GET.getExchange(), RabbitQueueEnum.YWG_ORDER_GET.getRoute(), str); |
| | | } |
| | | } |