package com.webmanage.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.webmanage.entity.UserPoints;
|
import com.webmanage.mapper.UserPointsMapper;
|
import com.webmanage.service.UserPointsService;
|
import com.webmanage.vo.PointsDetailVO;
|
import com.webmanage.vo.PointsStatsVO;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 用户积分Service实现类
|
*
|
* @author webmanage
|
* @date 2024-08-07
|
*/
|
@Service
|
public class UserPointsServiceImpl extends ServiceImpl<UserPointsMapper, UserPoints> implements UserPointsService {
|
|
@Override
|
public PointsStatsVO getPersonalPointsStats(Long userId) {
|
UserPoints userPoints = this.baseMapper.selectByUserId(userId);
|
|
PointsStatsVO statsVO = new PointsStatsVO();
|
if (userPoints != null) {
|
statsVO.setBalance(userPoints.getBalance());
|
statsVO.setTotalEarned(userPoints.getTotalEarned());
|
statsVO.setTotalConsumed(userPoints.getTotalConsumed());
|
statsVO.setTotalConverted(userPoints.getTotalConverted());
|
} else {
|
statsVO.setBalance(0);
|
statsVO.setTotalEarned(0);
|
statsVO.setTotalConsumed(0);
|
statsVO.setTotalConverted(0);
|
}
|
|
// 设置详情（这里可以根据实际需求查询数据库）
|
statsVO.setEarnedDetails(new ArrayList<>());
|
statsVO.setConsumedDetails(new ArrayList<>());
|
statsVO.setConvertedDetails(new ArrayList<>());
|
|
return statsVO;
|
}
|
|
@Override
|
public PointsStatsVO getUnitPointsStats(Long unitId) {
|
UserPoints userPoints = this.baseMapper.selectByUnitId(unitId);
|
|
PointsStatsVO statsVO = new PointsStatsVO();
|
if (userPoints != null) {
|
statsVO.setBalance(userPoints.getBalance());
|
statsVO.setTotalEarned(userPoints.getTotalEarned());
|
statsVO.setTotalConsumed(userPoints.getTotalConsumed());
|
statsVO.setTotalConverted(userPoints.getTotalConverted());
|
} else {
|
statsVO.setBalance(0);
|
statsVO.setTotalEarned(0);
|
statsVO.setTotalConsumed(0);
|
statsVO.setTotalConverted(0);
|
}
|
|
// 设置获取积分详情
|
List<PointsDetailVO> earnedDetails = new ArrayList<>();
|
earnedDetails.add(createDetailVO("resource_contribution", 10000, 50.0));
|
earnedDetails.add(createDetailVO("resource_transaction", 8000, 40.0));
|
earnedDetails.add(createDetailVO("resource_dissemination", 1900, 9.5));
|
earnedDetails.add(createDetailVO("other", 100, 0.5));
|
statsVO.setEarnedDetails(earnedDetails);
|
|
// 设置消耗积分详情
|
List<PointsDetailVO> consumedDetails = new ArrayList<>();
|
consumedDetails.add(createDetailVO("resource_transaction", 17500, 97.2));
|
consumedDetails.add(createDetailVO("resource_dissemination", 500, 2.8));
|
statsVO.setConsumedDetails(consumedDetails);
|
|
// 设置转换积分详情
|
statsVO.setConvertedDetails(new ArrayList<>());
|
|
return statsVO;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void updateUserPoints(Long userId, Long unitId, Integer points) {
|
// 查询用户积分记录
|
LambdaQueryWrapper<UserPoints> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(UserPoints::getUserId, userId);
|
UserPoints userPoints = this.getOne(wrapper);
|
|
if (userPoints == null) {
|
// 创建新的积分记录
|
userPoints = new UserPoints();
|
userPoints.setUserId(userId);
|
userPoints.setUnitId(unitId);
|
userPoints.setBalance(points > 0 ? points : 0);
|
userPoints.setTotalEarned(points > 0 ? points : 0);
|
userPoints.setTotalConsumed(points < 0 ? -points : 0);
|
userPoints.setTotalConverted(0);
|
this.save(userPoints);
|
} else {
|
// 更新积分记录
|
userPoints.setBalance(userPoints.getBalance() + points);
|
if (points > 0) {
|
userPoints.setTotalEarned(userPoints.getTotalEarned() + points);
|
} else {
|
userPoints.setTotalConsumed(userPoints.getTotalConsumed() - points);
|
}
|
this.updateById(userPoints);
|
}
|
}
|
|
/**
|
* 创建积分详情VO
|
*/
|
private PointsDetailVO createDetailVO(String category, Integer points, Double percentage) {
|
PointsDetailVO detailVO = new PointsDetailVO();
|
detailVO.setCategory(category);
|
detailVO.setPoints(points);
|
detailVO.setPercentage(percentage);
|
return detailVO;
|
}
|
}
|
