From 9cf47e10044ecb29669dec48d8b649b4fb46898f Mon Sep 17 00:00:00 2001
From: Hentua <wangdoubleone@gmail.com>
Date: Sun, 04 Jun 2023 00:51:54 +0800
Subject: [PATCH] fix

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java |   44 ++++++++++++++++++++++++++++++++++++++------
 1 files changed, 38 insertions(+), 6 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java
index a4ac87a..e6ff8d5 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ScoreServiceImpl.java
@@ -18,6 +18,7 @@
 import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
 import cc.mrbird.febs.mall.service.IScoreService;
 import cc.mrbird.febs.mall.vo.*;
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateField;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUnit;
@@ -26,6 +27,7 @@
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -35,6 +37,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
@@ -59,6 +62,7 @@
     private final MallMemberBankMapper mallMemberBankMapper;
     private final MallMemberWithdrawMapper mallMemberWithdrawMapper;
     private final IApiMallMemberService mallMemberService;
+    private final MallMoneyFlowMapper mallMoneyFlowMapper;
 
     @Override
     public ScoreSignVo scoreSign() {
@@ -275,7 +279,6 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void withdrawal(WithdrawalDto withdrawalDto) {
-
         Long memberId = LoginUserUtil.getLoginUser().getId();
         MallMember mallMember = mallMemberMapper.selectById(memberId);
         if (StrUtil.isBlank(mallMember.getTradePassword())) {
@@ -293,7 +296,7 @@
         }
 
         if (withdrawalDto.getAmount().compareTo(cashOutSettingVo.getMinCashOut()) < 0) {
-            throw new FebsException("最小提现金额为"+cashOutSettingVo.getMinCashOut().setScale(2,BigDecimal.ROUND_DOWN));
+            throw new FebsException("最小提现金额为"+cashOutSettingVo.getMinCashOut().setScale(2, RoundingMode.DOWN));
         }
 
         MallMemberBank mallMemberBank = mallMemberBankMapper.selectById(withdrawalDto.getBankId());
@@ -302,14 +305,24 @@
         }
 
         MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
-        // 可提现
-        BigDecimal canMoney = wallet.getVoucherAmount();
+        BigDecimal profit = mallMoneyFlowMapper.selectProfitByDateAndMemberId(memberId);
+
+        BigDecimal canMoney = wallet.getCommission();
+        if (profit != null) {
+            if(canMoney.compareTo(BigDecimal.ZERO) > 0) {
+                canMoney = canMoney.subtract(profit);
+            }
+        }
 
         if(withdrawalDto.getAmount().compareTo(canMoney) > 0) {
             throw new FebsException("金额不足");
         }
 
-        walletService.reduce(withdrawalDto.getAmount(), memberId, "voucherAmount");
+        int flag = walletService.reduce(withdrawalDto.getAmount(), memberId, "commission");
+        if (flag == 2) {
+            throw new FebsException("请刷新页面后重新提现");
+        }
+
         String orderNo = MallUtils.getOrderNum("W");
 
         MallMemberWithdraw withdraw = new MallMemberWithdraw();
@@ -321,7 +334,7 @@
         withdraw.setWtihdrawTypeId(mallMemberBank.getId());
         mallMemberWithdrawMapper.insert(withdraw);
 
-        mallMemberService.addMoneyFlow(memberId, withdrawalDto.getAmount().negate(), MoneyFlowTypeEnum.WITHDRAWAL.getValue(), orderNo, null, null, null, 1, FlowTypeEnum.BALANCE.getValue());
+        mallMemberService.addMoneyFlow(memberId, withdrawalDto.getAmount().negate(), MoneyFlowTypeEnum.WITHDRAWAL.getValue(), orderNo, null, null, null, 1, FlowTypeEnum.COMMISSION.getValue());
     }
 
     @Override
@@ -403,6 +416,25 @@
                 break;
         }
 
+        MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(member.getId());
+        if (wallet.getPrizeScore().compareTo(new BigDecimal(scoreSetting.getMostSignIn())) > 0) {
+            throw new FebsException("积分达到上限");
+        }
+
+        LambdaQueryWrapper<MallScoreSignRecord> hasSignQuery = new LambdaQueryWrapper<>();
+        hasSignQuery.le(MallScoreSignRecord::getSignTime, DateUtil.endOfDay(DateUtil.endOfMonth(new Date())));
+        hasSignQuery.gt(MallScoreSignRecord::getSignTime, DateUtil.beginOfDay(DateUtil.beginOfMonth(new Date())));
+        hasSignQuery.eq(MallScoreSignRecord::getMemberId, member.getId());
+        List<MallScoreSignRecord> hasSignTotalList = mallScoreSignRecordMapper.selectList(hasSignQuery);
+        if (CollUtil.isNotEmpty(hasSignTotalList)) {
+            int totalScore = hasSignTotalList.stream().mapToInt(MallScoreSignRecord::getScore).sum();
+
+            if (totalScore + mallScoreSignRecord.getScore() > scoreSetting.getMostSignIn()) {
+//                throw new FebsException("达到当月积分上限");
+                mallScoreSignRecord.setScore(scoreSetting.getMostSignIn() - totalScore);
+            }
+        }
+
         mallScoreSignRecord.setMemberId(member.getId());
         mallScoreSignRecord.setTotalCnt(days);
         mallScoreSignRecord.setSignTime(new Date());

--
Gitblit v1.9.1