From aac9fe67d35f98411d0e580ae07b3c10b9306245 Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期三, 18 十二月 2024 15:22:32 +0800 Subject: [PATCH] 合并代码 --- ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserPointServiceImpl.java | 44 ++++++++++++++++++++++++++++++-------------- 1 files changed, 30 insertions(+), 14 deletions(-) diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserPointServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserPointServiceImpl.java index db675e1..056f483 100644 --- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserPointServiceImpl.java +++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/UserPointServiceImpl.java @@ -2,6 +2,8 @@ import cn.hutool.core.collection.CollectionUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.account.api.model.AppUser; import com.ruoyi.account.api.model.UserPoint; @@ -12,9 +14,11 @@ import com.ruoyi.account.service.UserPointService; import com.ruoyi.account.service.VipSettingService; import com.ruoyi.account.vo.UserPointDetailVO; +import com.ruoyi.account.vo.UserPointStatistics; import com.ruoyi.account.vo.UserPointVO; import com.ruoyi.common.core.exception.ServiceException; import com.ruoyi.common.core.utils.PhoneNumberValidator; +import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.common.security.service.TokenService; import com.ruoyi.other.api.domain.PointSetting; import com.ruoyi.other.api.domain.VipSetting; @@ -22,14 +26,12 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.math.BigDecimal; import java.time.LocalDateTime; -import java.util.Collections; -import java.util.List; -import java.util.Map; -import java.util.Optional; +import java.util.*; import java.util.stream.Collectors; /** @@ -51,26 +53,26 @@ private VipSettingService vipSettingService; @Resource private PointSettingService pointSettingService; + @Resource + private UserPointMapper userPointMapper; @Override public UserPointVO getUserPoint(Long userId) { AppUser appUser = appUserService.getById(userId); List<UserPoint> userPointList = this.baseMapper.findLatestUserPointByTypeForUser(userId); - Map<Integer, Integer> userBalanceMap = userPointList.stream() .collect(Collectors.toMap(UserPoint::getType, UserPoint::getBalance)); VipSetting vipSetting = vipSettingService.getVipSettingByUserId(userId); - Integer lavePoint = appUser.getLavePoint(); UserPointVO userPointVO = new UserPointVO(); - userPointVO.setTotalPoint(lavePoint); -// userPointVO.setConsumePoint(lavePoint); - userPointVO.setShopPoint(userBalanceMap.get(PointChangeType.CONSUME.getCode())); - userPointVO.setSharePoint(userBalanceMap.get(PointChangeType.COMMISSION_RETURN.getCode())); + userPointVO.setTotalPoint(appUser.getTotalPoint()); + userPointVO.setConsumePoint(appUser.getLavePoint()); + userPointVO.setShopPoint(appUser.getShopPoint()); + userPointVO.setSharePoint(appUser.getSharePoint()); userPointVO.setPullNewPoint(userBalanceMap.get(PointChangeType.NEW_USER_REFERRAL.getCode())); userPointVO.setShopAchievementPoint(userBalanceMap.get(PointChangeType.STORE_PERFORMANCE.getCode())); userPointVO.setShopSharePoint(userBalanceMap.get(PointChangeType.STORE_COMMISSION_RETURN.getCode())); - userPointVO.setGiftPoint(vipSetting.getVipGiftRole()); + userPointVO.setGiftPoint(vipSetting.getVipGiftRole() == 1 && vipSetting.getId() == 1 ? 1 : 0); return userPointVO; } @@ -107,7 +109,7 @@ if (vipSetting == null) { throw new ServiceException("VIP 设置未找到"); } - if (vipSetting.getVipGiftRole() == 0) { + if (vipSetting.getId() == 0 && vipSetting.getVipGiftRole() == 0) { throw new ServiceException("转赠积分权限未开启"); } @@ -123,8 +125,11 @@ } Integer buyPointOpen = pointSetting.getBuyPointOpen(); - List<UserPoint> userPointList = list(new LambdaQueryWrapper<UserPoint>() - .eq(UserPoint::getAppUserId, userid)); + UserPoint userPoint = new UserPoint(); + userPoint.setAppUserId(userid); +// List<UserPoint> userPointList = userPointMapper.indLatestChangeByType(userPoint); + // TODO 完善 + List<UserPoint> userPointList = new ArrayList<>(); Map<Integer, Integer> userBalanceMap = userPointList.stream() .collect(Collectors.toMap(UserPoint::getType, UserPoint::getBalance)); @@ -157,4 +162,15 @@ private int getAdjustedPoint(Map<Integer, Integer> userBalanceMap, int pointTypeCode, boolean isOpen) { return isOpen ? 0 : Optional.ofNullable(userBalanceMap.get(pointTypeCode)).orElse(0); } + + @Override + public UserPointStatistics getStatistics(UserPoint userPoint) { + return null; + } + + + @Override + public IPage<UserPoint> getUserPointPage(Page<UserPoint> page, UserPoint userPoint) { + return this.baseMapper.queryUserPointPage(page, userPoint); + } } -- Gitblit v1.7.1