zm/nuttyreading-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

湖分定时转换成积分

Browse Source
This commit is contained in:
wuchunlei
2025-04-08 13:16:09 +08:00
parent 2e7a0829df
commit 5e69866c1e
3 changed files with 79 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/peanut/modules/common/service/UserContributionExchangeService.java Normal file
View File

@@ -0,0 +1,7 @@
package com.peanut.modules.common.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.peanut.modules.common.entity.UserContributionExchange;
public interface UserContributionExchangeService extends IService<UserContributionExchange> {
}

13
src/main/java/com/peanut/modules/common/service/impl/UserContributionExchangeServiceImpl.java Normal file
View File

@@ -0,0 +1,13 @@
package com.peanut.modules.common.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.peanut.modules.common.dao.UserContributionExchangeDao;
import com.peanut.modules.common.entity.UserContributionExchange;
import com.peanut.modules.common.service.UserContributionExchangeService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
@Slf4j
@Service("commonUserContributionExchangeService")
public class UserContributionExchangeServiceImpl extends ServiceImpl<UserContributionExchangeDao, UserContributionExchange> implements UserContributionExchangeService {
}

59
src/main/java/com/peanut/modules/job/task/UserContributionTask.java Normal file
View File

@@ -0,0 +1,59 @@
package com.peanut.modules.job.task;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.peanut.modules.common.entity.MyUserEntity;
import com.peanut.modules.common.entity.UserContribution;
import com.peanut.modules.common.entity.UserContributionExchange;
import com.peanut.modules.common.service.MyUserService;
import com.peanut.modules.common.service.UserContributionExchangeService;
import com.peanut.modules.common.service.UserContributionService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.util.List;
@Component("userContributionTask")
public class UserContributionTask implements ITask{
@Autowired
private UserContributionService userContributionService;
@Autowired
private UserContributionExchangeService userContributionExchangeService;
@Autowired
private MyUserService userService;
@Override
public void run(String params) {
MPJLambdaWrapper<UserContribution> wrapper = new MPJLambdaWrapper();
wrapper.select(UserContribution::getUserId);
wrapper.select("SUM(score) as score ");
wrapper.eq(UserContribution::getConversionFlag,"0");
wrapper.groupBy(UserContribution::getUserId);
List<UserContribution> list = userContributionService.list(wrapper);
for (UserContribution userContribution:list){
UserContributionExchange exchange = userContributionExchangeService.getOne(
new LambdaQueryWrapper<UserContributionExchange>()
.eq(UserContributionExchange::getUserId,userContribution.getUserId()));
if (exchange!=null) {
userContribution.setScore(userContribution.getScore().add(exchange.getSurplus()));
}
int zhengshu = userContribution.getScore().intValue();
BigDecimal xiaoshu = userContribution.getScore().remainder(BigDecimal.ONE);
MyUserEntity user = userService.getById(userContribution.getUserId());
if (user != null) {
user.setJf(user.getJf().add(new BigDecimal(100*zhengshu)));
userService.updateById(user);
}
exchange.setSurplus(xiaoshu);
userContributionExchangeService.updateById(exchange);
userContributionService.update(new LambdaUpdateWrapper<UserContribution>()
.eq(UserContribution::getConversionFlag,0)
.set(UserContribution::getConversionFlag,1));
}
}
}