diff --git a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java index 5ffde3f7..abf82f0d 100644 --- a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java +++ b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java @@ -276,6 +276,9 @@ public class InviteServiceImpl extends ServiceImpl implements @Override public Map updateInvite(UserEntity userEntity, String format, Long userId, BigDecimal price) { + if(userEntity.getUserId().equals(1L)){ + return new HashMap<>(); + } Map result = new HashMap<>(); if (userEntity != null && userId != null && price != null) { Invite invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId, 1); 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 937c1818..843dcb6e 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -164,7 +164,7 @@ public class TempOrdersTask { UserEntity user = userService.selectUserById(order.getUserId()); UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode()); // UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode()); - if (byUser != null && !byUser.getUserId().equals(1L)) { + if (byUser != null) { InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId()); if (inviteAchievement == null) { inviteAchievement = new InviteAchievement(); @@ -177,6 +177,8 @@ public class TempOrdersTask { } else { inviteAchievementService.incrCount(inviteAchievement.getId(), inviteAchievement.getUserId(), 1); } + } + if (byUser != null && !byUser.getUserId().equals(1L)) { ThreadUtil.execAsync(() -> { ThreadUtil.sleep(1000); activities(user, byUser); @@ -186,7 +188,6 @@ public class TempOrdersTask { inviteService.updateInvite(byUser, DateUtil.now(), user.getUserId(), order.getPayMoney()); }); } - //增加剧集支付次数 ThreadUtil.execAsync(() -> { courseService.incrWeekPayCount(order.getCourseId()); @@ -266,7 +267,7 @@ public class TempOrdersTask { System.out.println(list.stream().map(UserInfo::getCertNo).collect(Collectors.toSet())); count = userInfoService.list(new LambdaQueryWrapper().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo)) .stream().map(UserInfo::getCertNo).collect(Collectors.toSet()).size(); - }else { + } else { return; } logger.info("邀请达标人员: {}", count);