| | |
| | | /** |
| | | * 代理分红 |
| | | */ |
| | | // @Scheduled(cron = "0 0/1 * * * ? ") |
| | | // public void profitJob() { |
| | | // QueryWrapper<ChatGroup> objectQueryWrapper = new QueryWrapper<>(); |
| | | // objectQueryWrapper.eq("auto_send", 1); |
| | | // List<ChatGroup> chatGroups = chatGroupMapper.selectList(objectQueryWrapper); |
| | | // if(CollUtil.isNotEmpty(chatGroups)){ |
| | | // for(ChatGroup chatGroup : chatGroups){ |
| | | // agentProducer.sendAutoSendMsg(chatGroup.getId()); |
| | | // } |
| | | // } |
| | | // } |
| | | @Scheduled(cron = "0 0/1 * * * ? ") |
| | | public void profitJob() { |
| | | QueryWrapper<ChatGroup> objectQueryWrapper = new QueryWrapper<>(); |
| | | objectQueryWrapper.eq("auto_send", 1); |
| | | List<ChatGroup> chatGroups = chatGroupMapper.selectList(objectQueryWrapper); |
| | | if(CollUtil.isNotEmpty(chatGroups)){ |
| | | for(ChatGroup chatGroup : chatGroups){ |
| | | agentProducer.sendAutoSendMsg(chatGroup.getId()); |
| | | } |
| | | } |
| | | } |
| | | } |