diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java index e27f5b2aac..d5bfc27374 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java @@ -117,10 +117,4 @@ public interface PersonService { * @param userid 用户编号 */ void cancelVip(Integer userid); - - /** - * 批量处理过期VIP用户 - * 查询所有VIP到期时间已过的用户,并将其isvip字段设置为0 - */ - void processExpiredVipUsers(); } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java index 70c034c043..785da52ee6 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java @@ -191,36 +191,4 @@ public class PersonServiceImpl implements PersonService { .set(PersonDO::getVipstarttime, null) // 清空会员开始时间 .set(PersonDO::getVipendtime, null)); // 清空会员结束时间 } - - @Override - public void processExpiredVipUsers() { - // 获取当前时间 - String currentTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); - log.info("开始检查VIP过期用户,当前时间: {}", currentTime); - - // 查询所有过期的VIP用户 - List expiredVipUsers = personMapper.selectList(new LambdaQueryWrapper() - .eq(PersonDO::getIsvip, 1) // 当前是VIP用户 - .isNotNull(PersonDO::getVipendtime) // VIP结束时间不为空 - .lt(PersonDO::getVipendtime, currentTime)); // VIP结束时间小于当前时间 - - if (expiredVipUsers.isEmpty()) { - log.info("没有发现过期的VIP用户"); - return; // 没有过期用户,直接返回 - } - - log.info("发现 {} 个过期的VIP用户,开始批量处理", expiredVipUsers.size()); - - // 提取所有过期用户的ID - List expiredUserIds = expiredVipUsers.stream() - .map(PersonDO::getId) - .collect(java.util.stream.Collectors.toList()); - - // 批量更新过期VIP用户 - personMapper.update(null, new LambdaUpdateWrapper() - .in(PersonDO::getId, expiredUserIds) - .set(PersonDO::getIsvip, 0));// 设置为非会员状态 - - log.info("成功处理 {} 个过期VIP用户", expiredUserIds.size()); - } } \ No newline at end of file