| | |
| | | } |
| | | } |
| | | |
| | | // @RabbitListener(queues = QueueConstants.AGENT_AUTO_LEVEL_UP) |
| | | @RabbitListener(queues = QueueConstants.AGENT_AUTO_LEVEL_UP) |
| | | public void agentAutoLevelUp(String id) { |
| | | log.info("收到代理自动升级消息:{}", id); |
| | | try { |
| | |
| | | select a.invite_id, count(1) |
| | | from mall_member a |
| | | inner join mall_order_info b on a.ID=b.member_id |
| | | where a.referrer_id=#{inviteId} and a.status in (2,3,4) |
| | | where a.referrer_id=#{inviteId} and b.status in (2,3,4) |
| | | group by a.invite_id |
| | | ) a |
| | | </select> |
| | |
| | | @Test |
| | | public void autoLevelUp() { |
| | | // agentService.autoUpAgentLevel(3L); |
| | | agentProducer.sendAutoLevelUpMsg(7L); |
| | | agentProducer.sendAutoLevelUpMsg(4L); |
| | | |
| | | // agentProducer.sendReturnMoneyMsg(24L); |
| | | } |