From 60f4c22dd718ade34d90ead67d02c8852729bf09 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Fri, 13 Oct 2023 16:01:02 +0800 Subject: [PATCH] redbagprod --- src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java | 22 +++++++++++----------- 1 files changed, 11 insertions(+), 11 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java index a92dacd..511ceae 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java @@ -52,15 +52,15 @@ /** * 代理分红 */ -// @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()); + } + } + } } -- Gitblit v1.9.1