package com.ruoyi.account.service.impl;
|
|
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;
|
import com.ruoyi.account.enums.PointChangeType;
|
import com.ruoyi.account.mapper.UserPointMapper;
|
import com.ruoyi.account.service.AppUserService;
|
import com.ruoyi.account.service.PointSettingService;
|
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.security.service.TokenService;
|
import com.ruoyi.other.api.domain.PointSetting;
|
import com.ruoyi.other.api.domain.VipSetting;
|
import com.ruoyi.system.api.model.LoginUser;
|
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.stream.Collectors;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author luodangjia
|
* @since 2024-11-21
|
*/
|
@Service
|
@Slf4j
|
public class UserPointServiceImpl extends ServiceImpl<UserPointMapper, UserPoint> implements UserPointService {
|
@Resource
|
private AppUserService appUserService;
|
@Resource
|
private TokenService tokenService;
|
@Resource
|
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);
|
|
UserPointVO userPointVO = new UserPointVO();
|
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() == 1 && vipSetting.getId() == 1 ? 1 : 0);
|
return userPointVO;
|
}
|
|
@Override
|
public List<UserPointDetailVO> getUserPointDetail(Long userId, LocalDateTime startTime, LocalDateTime endTime, Integer type) {
|
List<UserPoint> userPointList = list(new LambdaQueryWrapper<UserPoint>()
|
.between(startTime != null, UserPoint::getCreateTime, startTime, endTime)
|
.eq(type != null, UserPoint::getType, type)
|
.eq(UserPoint::getAppUserId, userId));
|
if (CollectionUtil.isNotEmpty(userPointList)) {
|
return userPointList.stream().map(p -> {
|
UserPointDetailVO userPointDetailVO = new UserPointDetailVO();
|
userPointDetailVO.setType(p.getType());
|
userPointDetailVO.setVariablePoint(p.getVariablePoint());
|
userPointDetailVO.setCreateTime(p.getCreateTime());
|
return userPointDetailVO;
|
}).collect(Collectors.toList());
|
}
|
return Collections.emptyList();
|
}
|
|
|
@Override
|
@Transactional
|
public void transferPoint(BigDecimal point, String phone) {
|
if (!PhoneNumberValidator.isValidChinaPhoneNumber(phone)) {
|
throw new ServiceException("无效的电话号码");
|
}
|
|
LoginUser loginUserApplet = tokenService.getLoginUserApplet();
|
Long userid = loginUserApplet.getUserid();
|
|
VipSetting vipSetting = vipSettingService.getVipSettingByUserId(userid);
|
if (vipSetting == null) {
|
throw new ServiceException("VIP 设置未找到");
|
}
|
if (vipSetting.getId() == 0 && vipSetting.getVipGiftRole() == 0) {
|
throw new ServiceException("转赠积分权限未开启");
|
}
|
|
AppUser appUser = appUserService.getById(userid);
|
if (appUser == null) {
|
throw new ServiceException("用户未找到");
|
}
|
Integer totalPoint = appUser.getLavePoint();
|
|
PointSetting pointSetting = pointSettingService.getPointSettingByAppUserId(userid);
|
if (pointSetting == null) {
|
throw new ServiceException("积分设置未找到");
|
}
|
Integer buyPointOpen = pointSetting.getBuyPointOpen();
|
|
UserPoint userPoint = new UserPoint();
|
userPoint.setAppUserId(userid);
|
List<UserPoint> userPointList = userPointMapper.findLatestChangeByType(userPoint);
|
Map<Integer, Integer> userBalanceMap = userPointList.stream()
|
.collect(Collectors.toMap(UserPoint::getType, UserPoint::getBalance));
|
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.CONSUME.getCode(), buyPointOpen == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.COMMISSION_RETURN.getCode(), pointSetting.getSharePointOpen() == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.STORE_COMMISSION_RETURN.getCode(), pointSetting.getShopSharePointOpen() == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.STORE_PERFORMANCE.getCode(), pointSetting.getShopPointOpen() == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.TECHNICIAN_PERFORMANCE.getCode(), pointSetting.getPersonPointOpen() == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.NEW_USER_REFERRAL.getCode(), pointSetting.getGetNewPointOpen() == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.REGISTRATION.getCode(), pointSetting.getGetRegisPointOpen() == 0);
|
totalPoint -= getAdjustedPoint(userBalanceMap, PointChangeType.WORK_PERFORMANCE.getCode(), pointSetting.getWorkPointOpen() == 0);
|
|
if (point.compareTo(new BigDecimal(totalPoint)) > 0) {
|
throw new ServiceException("转赠积分不足");
|
}
|
|
AppUser appUserForPhoe = appUserService.getOne(new LambdaQueryWrapper<AppUser>()
|
.eq(AppUser::getPhone, phone));
|
if (appUserForPhoe == null) {
|
throw new ServiceException("目标用户未找到");
|
}
|
|
appUserForPhoe.setLavePoint(appUserForPhoe.getLavePoint() + point.intValue());
|
appUserForPhoe.setTotalPoint(appUserForPhoe.getTotalPoint() + point.intValue());
|
appUserService.updateById(appUserForPhoe);
|
|
log.info("积分转赠完成，用户ID: {}, 新积分: {}", appUserForPhoe.getId(), appUserForPhoe.getLavePoint());
|
}
|
|
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) {
|
List<AppUser> appUserList = appUserService.list(new LambdaQueryWrapper<AppUser>()
|
.eq(AppUser::getPhone, userPoint.getPhone())
|
.like(AppUser::getName, userPoint.getUserName()));
|
List<Long> userIds = appUserList.stream().map(AppUser::getId).collect(Collectors.toList());
|
|
list(new LambdaQueryWrapper<UserPoint>()
|
.in(!CollectionUtils.isEmpty(userIds), UserPoint::getAppUserId, userIds)
|
.eq(UserPoint::getType, userPoint.getType())
|
.between(UserPoint::getCreateTime, userPoint.getStartTime(), userPoint.getEndTime()));
|
|
|
return null;
|
}
|
|
@Override
|
public IPage<UserPoint> getUserPointPage(Page<UserPoint> page, UserPoint userPoint) {
|
List<AppUser> appUserList = appUserService.list(new LambdaQueryWrapper<AppUser>()
|
.eq(AppUser::getPhone, userPoint.getPhone())
|
.like(AppUser::getName, userPoint.getUserName()));
|
List<Long> userIds = appUserList.stream().map(AppUser::getId).collect(Collectors.toList());
|
|
Page<UserPoint> userPointPage = page(page, new LambdaQueryWrapper<UserPoint>()
|
.in(!CollectionUtils.isEmpty(userIds), UserPoint::getAppUserId, userIds)
|
.eq(UserPoint::getType, userPoint.getType())
|
.between(userPoint.getStartTime() !=null && userPoint.getEndTime() != null,
|
UserPoint::getCreateTime, userPoint.getStartTime(), userPoint.getEndTime())
|
.orderByDesc(UserPoint::getCreateTime));
|
|
userPointPage.getRecords().forEach(userPoint1 -> appUserList.stream()
|
.filter(appUser -> appUser.getId().equals(userPoint1.getAppUserId()))
|
.findFirst().ifPresent(appUser -> {
|
userPoint1.setUserName(appUser.getName());
|
userPoint1.setPhone(appUser.getPhone());
|
}));
|
return userPointPage;
|
}
|
}
|
