From 282b7724305d9a0b9723712125282fd6846c173d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Tue, 31 Dec 2024 14:19:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=B0=83=E8=AF=95=E6=97=A5?= =?UTF-8?q?=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/sqx/modules/job/task/TempOrdersTask.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java index 31690763..6e00f424 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -187,6 +187,7 @@ public class TempOrdersTask { } ThreadUtil.execAsync(() -> { + ThreadUtil.sleep(1000); activities(user, byUser); }); } @@ -200,6 +201,7 @@ public class TempOrdersTask { InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId()); // 首次达标 int signCount = Integer.parseInt(commonRepository.findOne(913).getValue()); + logger.info("{}签到次数: {}", user.getUserName(), inviteAchievement.getCount()); if (inviteAchievement.getState() == 0 && inviteAchievement.getCount() >= signCount) { //满3笔 String amount = commonRepository.findOne(912).getValue(); @@ -240,7 +242,7 @@ public class TempOrdersTask { new LambdaQueryWrapper() .eq(InviteAchievement::getSourceUserId, sourceUser.getUserId()) .eq(InviteAchievement::getState, 1)); - + logger.info("邀请人员: {}", count); //count 邀请的已达标人数 completAwardService.list(new QueryWrapper().eq("invite_count", count).eq("status", 1)).forEach(completAward -> { QueryWrapper moneyDetailsQuery = new QueryWrapper<>();