This commit is contained in:
GYJ
2025-01-04 16:10:10 +08:00
parent af4852a223
commit aa9502fdb6
2 changed files with 7 additions and 10 deletions

View File

@@ -87,7 +87,7 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
List<Long> userIds = list.stream().map(UserEntity::getUserId).collect(Collectors.toList()); List<Long> userIds = list.stream().map(UserEntity::getUserId).collect(Collectors.toList());
LambdaQueryWrapper<InviteAchievement> queryWrapper1 = new LambdaQueryWrapper<>(); LambdaQueryWrapper<InviteAchievement> queryWrapper1 = new LambdaQueryWrapper<>();
queryWrapper1.gt(InviteAchievement::getCount, 3); queryWrapper1.ge(InviteAchievement::getCount, 3);
queryWrapper1.eq(InviteAchievement::getUserId, userId); queryWrapper1.eq(InviteAchievement::getUserId, userId);
queryWrapper1.in(InviteAchievement::getTargetUserId, userIds); queryWrapper1.in(InviteAchievement::getTargetUserId, userIds);
List<InviteAchievement> achievementList = inviteAchievementService.list(queryWrapper1); List<InviteAchievement> achievementList = inviteAchievementService.list(queryWrapper1);

View File

@@ -61,17 +61,16 @@ public class Tets {
@Test @Test
public void test2() { public void test2() {
inviteAchievementService.remove(new LambdaQueryWrapper<>()); // inviteAchievementService.remove(new LambdaQueryWrapper<>());
List<UserEntity> userinfoList = userService.list(); List<UserEntity> userinfoList = userService.list();
for (UserEntity userEntity : userinfoList) { userinfoList.parallelStream().forEach((userEntity -> {
if (StrUtil.isBlank(userEntity.getInviterCode())) continue; if (StrUtil.isBlank(userEntity.getInviterCode())) return;
UserEntity byUser = userService.queryByInvitationCode(userEntity.getInviterCode()); UserEntity byUser = userService.queryByInvitationCode(userEntity.getInviterCode());
if (byUser == null) continue; if (byUser == null) return;
Integer count = payDetailsDao.selectCount(new LambdaQueryWrapper<PayDetails>() Integer count = payDetailsDao.selectCount(new LambdaQueryWrapper<PayDetails>()
.eq(PayDetails::getState, 1) .eq(PayDetails::getState, 1)
@@ -99,13 +98,11 @@ public class Tets {
inviteAchievement.setCreateTime(DateUtil.date()); inviteAchievement.setCreateTime(DateUtil.date());
inviteAchievement.setTargetUserId(userEntity.getUserId()); inviteAchievement.setTargetUserId(userEntity.getUserId());
inviteAchievement.setUserId(byUser.getUserId()); inviteAchievement.setUserId(byUser.getUserId());
inviteAchievementService.update(new LambdaQueryWrapper<InviteAchievement>() inviteAchievementService.update(inviteAchievement, new LambdaQueryWrapper<InviteAchievement>()
.eq(InviteAchievement::getUserId, inviteAchievement.getUserId()) .eq(InviteAchievement::getUserId, inviteAchievement.getUserId())
.eq(InviteAchievement::getId, inviteAchievement.getId())); .eq(InviteAchievement::getId, inviteAchievement.getId()));
} }
}));
}
} }
@Test @Test