From 9c3365943d32f7ceadb779567477bc81076e8c16 Mon Sep 17 00:00:00 2001 From: wuchunlei Date: Thu, 10 Apr 2025 13:30:57 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B9=96=E5=88=86=E5=85=91=E6=8D=A2=E7=A7=AF?= =?UTF-8?q?=E5=88=86=E5=AE=9A=E6=97=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/task/UserContributionTask.java | 23 +++++++++++++++---- 1 file changed, 18 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/peanut/modules/job/task/UserContributionTask.java b/src/main/java/com/peanut/modules/job/task/UserContributionTask.java index 3a6306a9..d73e890b 100644 --- a/src/main/java/com/peanut/modules/job/task/UserContributionTask.java +++ b/src/main/java/com/peanut/modules/job/task/UserContributionTask.java @@ -4,9 +4,11 @@ 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.JfTransactionDetails; 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.JfTransactionDetailsService; import com.peanut.modules.common.service.MyUserService; import com.peanut.modules.common.service.UserContributionExchangeService; import com.peanut.modules.common.service.UserContributionService; @@ -25,6 +27,8 @@ public class UserContributionTask implements ITask{ private UserContributionExchangeService userContributionExchangeService; @Autowired private MyUserService userService; + @Autowired + private JfTransactionDetailsService jfTransactionDetailsService; @Override public void run(String params) { @@ -45,12 +49,21 @@ public class UserContributionTask implements ITask{ exchange.setUserId(userContribution.getUserId()); } 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); + if(zhengshu>1){ + MyUserEntity user = userService.getById(userContribution.getUserId()); + if (user != null) { + user.setJf(user.getJf().add(new BigDecimal(100*zhengshu))); + userService.updateById(user); + JfTransactionDetails jfDetail = new JfTransactionDetails(); + jfDetail.setUserId(user.getId()); + jfDetail.setActType(0); + jfDetail.setChangeAmount(new BigDecimal(100*zhengshu)); + jfDetail.setUserBalance(user.getJf()); + jfDetail.setRemark("湖粉兑换"); + jfTransactionDetailsService.save(jfDetail); + } } + BigDecimal xiaoshu = userContribution.getScore().remainder(BigDecimal.ONE); exchange.setSurplus(xiaoshu); userContributionExchangeService.saveOrUpdate(exchange); userContributionService.update(new LambdaUpdateWrapper()