| | |
| | | log.error("订单返利异常:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.YWG_MEMBER_SUB) |
| | | public void getMemberSubMsg(String memberOpenId) { |
| | | log.info("收到新增用户关注:{}", memberOpenId); |
| | | try { |
| | | agentService.addMember(memberOpenId); |
| | | } catch (Exception e) { |
| | | log.error("新增用户关注异常:", e); |
| | | } |
| | | } |
| | | |
| | | @RabbitListener(queues = QueueConstants.YWG_MEMBER_SUB_SCAN) |
| | | public void getMemberSubScanMsg(String str) { |
| | | log.info("收到新增用户扫码:{}", str); |
| | | try { |
| | | agentService.addMemberScan(str); |
| | | } catch (Exception e) { |
| | | log.error("收到新增用户扫码:", e); |
| | | } |
| | | } |
| | | } |