From 759b602542a22cbb93202e233c42ac4a466b586e Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 20 Dec 2024 10:54:51 +0800
Subject: [PATCH] feat(mall): 更新会员等级和积分
---
src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java | 83 ++++++++++++++++++++++++++++++++++-------
1 files changed, 69 insertions(+), 14 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
index d65136d..d6bdc83 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
@@ -500,23 +500,39 @@
}
}
+ /**
+ * 更新会员等级，将所有等级过期的会员等级重置为最低等级
+ * 查询 RunVip 表中按顺序号升序排列的第一条记录，获取最低会员等级。
+ * 构建查询条件，查询 MallMember 表中会员等级过期且当前等级不是最低等级的用户。
+ * 如果查询结果不为空，遍历每个用户，调用 updateLevel 方法将会员等级更新为最低等级。
+ * 处理完所有用户后，结束方法
+ */
@Override
public void updateMemberLevel() {
- mallMemberWalletMapper.updateScore();
- List<RunVip> runVips = runVipMapper.selectList(new LambdaQueryWrapper<RunVip>().orderByAsc(RunVip :: getOrderNumber));
- RunVip runVip = runVips.get(0);
- //获取过期时间小于等于当前时间，并且会员等级不是最小等级游客的所有用户
- LambdaQueryWrapper<MallMember> mallMemberLambdaQueryWrapper = new LambdaQueryWrapper<>();
- mallMemberLambdaQueryWrapper.le(MallMember :: getVipLevelTime,DateUtil.date());
- mallMemberLambdaQueryWrapper.ne(MallMember :: getLevel,runVip.getVipCode());
- List<MallMember> mallMembers = mallMemberMapper.selectList(mallMemberLambdaQueryWrapper);
- if(CollUtil.isNotEmpty(mallMembers)){
- mallMembers.forEach(
- item -> {
- mallMemberMapper.updateVipLevelTimeAndLevel(item.getId(),item.getVipLevelTime(),item.getLevel());
- }
- );
+ // 更新会员等级的逻辑
+ try {
+ List<RunVip> runVips = runVipMapper.selectList(new LambdaQueryWrapper<RunVip>().orderByAsc(RunVip::getOrderNumber));
+ RunVip runVip = runVips.get(0);
+
+ // 获取过期时间小于等于当前时间，并且会员等级不是最小等级游客的所有用户
+ LambdaQueryWrapper<MallMember> mallMemberLambdaQueryWrapper = new LambdaQueryWrapper<>();
+ mallMemberLambdaQueryWrapper.le(MallMember::getVipLevelTime, DateUtil.date());
+ mallMemberLambdaQueryWrapper.ne(MallMember::getLevel, runVip.getVipCode());
+ List<MallMember> mallMembers = mallMemberMapper.selectList(mallMemberLambdaQueryWrapper);
+ if (CollUtil.isNotEmpty(mallMembers)) {
+ mallMembers.forEach(
+ item -> {
+ try {
+ mallMemberMapper.updateLevel(item.getId(), runVip.getVipCode());
+ } catch (Exception e) {
+ log.error("Error updating member level for user {}: ", item.getId(), e);
+ }
+ }
+ );
+ }
+ } catch (Exception e) {
+ log.error("Error fetching or updating VIP levels: ", e);
}
}
@@ -614,7 +630,46 @@
}
}
+
public boolean isDivisibleByTwo(int number) {
return number % 2 == 0;
}
+
+
+ /**
+ * 更新会员钱包中的积分，将所有积分大于0的会员钱包积分清零
+ * 初始化最大尝试次数 maxAttempts 和当前尝试次数 attemptCount。
+ * 使用 while 循环，每次查询1000条积分大于0的会员钱包记录。
+ * 如果查询结果为空，设置标志位 flag 为 false，退出循环。
+ * 否则，提取记录ID并调用 updateScore 方法将积分更新为0。
+ * 增加尝试次数，继续下一次循环，直到达到最大尝试次数或查询结果为空。
+ */
+ @Override
+ public void updateMemberScore() {
+ // 更新会员钱包积分的逻辑
+ int maxAttempts = 100; // 最大尝试次数
+ int attemptCount = 0;
+ boolean flag = true;
+ while (flag && attemptCount < maxAttempts) {
+ try {
+ Page<MallMemberWallet> page = new Page<>(0, 1000);
+ IPage<MallMemberWallet> result = mallMemberWalletMapper.selectPage(
+ page,
+ new LambdaQueryWrapper<MallMemberWallet>()
+ .gt(MallMemberWallet::getScore, 0)
+ );
+ List<MallMemberWallet> mallMemberWallets = result.getRecords();
+ if (CollUtil.isEmpty(mallMemberWallets)) {
+ flag = false;
+ } else {
+ List<Long> ids = mallMemberWallets.stream().map(MallMemberWallet::getId).collect(Collectors.toList());
+ mallMemberWalletMapper.updateScore(ids);
+ }
+ attemptCount++;
+ } catch (Exception e) {
+ log.error("Error updating member level: ", e);
+ flag = false; // 发生异常时退出循环
+ }
+ }
+ }
}
--
Gitblit v1.9.1