| | |
| | | log.error("收到新增用户扫码:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.YWG_MEMBER_INFO) |
| | | public void getMemberInfoMsg(String str) { |
| | | log.info("收到用户信息:{}", str); |
| | | try { |
| | | agentService.updateMemberInfo(str); |
| | | } catch (Exception e) { |
| | | log.error("收到用户信息:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.YWG_ORDER_GET) |
| | | public void orderGetMsg(String str) { |
| | | log.info("支付后同意验证:{}", str); |
| | | try { |
| | | agentService.orderGetMsg(str); |
| | | } catch (Exception e) { |
| | | log.error("支付后同意验证:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.YWG_ROLL_SEND) |
| | | public void rollSendMsg(Long orderId) { |
| | | log.info("支付后生成我的课程或者我的民宿卷:{}", orderId); |
| | | try { |
| | | agentService.rollSendMsg(orderId); |
| | | } catch (Exception e) { |
| | | log.error("支付后生成我的课程或者我的民宿卷:", e); |
| | | } |
| | | } |
| | | } |