From a04cc61a75c61025a4efcdd95b07d73b0f892ce9 Mon Sep 17 00:00:00 2001
From: luodangjia <luodangjia>
Date: 星期二, 14 一月 2025 13:50:41 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java |   27 +++++++++++++++++++++------
 1 files changed, 21 insertions(+), 6 deletions(-)

diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java
index 8f9ef27..0198cd8 100644
--- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java
+++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java
@@ -53,6 +53,19 @@
         IPage<BalanceChangeRecord> balanceChangeRecordIPage = this.baseMapper.queryCommissionStatistics(page, balanceChangeRecord);
         // 过滤商城购物
         List<BalanceChangeRecord> collect = balanceChangeRecordIPage.getRecords().stream().filter(e -> e.getChangeType() != 5).collect(Collectors.toList());
+        for (BalanceChangeRecord changeRecord : collect) {
+            if (changeRecord.getBeforeAmount()!=null && changeRecord.getAfterAmount()!=null){
+                BigDecimal subtract = changeRecord.getBeforeAmount().subtract(changeRecord.getAfterAmount());
+                if (subtract.compareTo(BigDecimal.ZERO)>0){
+                    // 减少
+                    changeRecord.setChangeAmountString("-¥"+changeRecord.getChangeAmount());
+                }else if (subtract.compareTo(BigDecimal.ZERO)<0){
+                    changeRecord.setChangeAmountString("+¥"+changeRecord.getChangeAmount());
+                }else{
+                    changeRecord.setChangeAmountString("¥"+changeRecord.getChangeAmount());
+                }
+            }
+        }
         balanceChangeRecordIPage.setRecords(collect);
         return new CommissionStatistics(totalCommission, balanceChangeRecordIPage);
     }
@@ -82,13 +95,15 @@
         int fromIndex = (int) ((current - 1) * size);
         int toIndex = (int) Math.min(fromIndex + size, walletStatisticsDetailList.size());
 
+
+        Page<WalletStatisticsDetail> walletStatisticsDetailPage = new Page<>();
+        WalletStatistics walletStatistics = new WalletStatistics();
         if (fromIndex >= walletStatisticsDetailList.size()) {
-            throw new ServiceException("页面参数无效");
+            walletStatistics.setPage(walletStatisticsDetailPage);
+            return walletStatistics;
         }
 
-        List<WalletStatisticsDetail> walletStatisticsDetailList2 = walletStatisticsDetailList.subList(fromIndex, toIndex);
-
-        Map<Integer, BigDecimal> shopCommissionMap = walletStatisticsDetailList2.stream()
+        Map<Integer, BigDecimal> shopCommissionMap = walletStatisticsDetailList.stream()
                 .collect(Collectors.groupingBy(
                         WalletStatisticsDetail::getChangeType,
                         Collectors.reducing(
@@ -102,11 +117,11 @@
         BigDecimal totalWithdraw = shopCommissionMap.get(2);
         BigDecimal totalShopWithdraw = shopCommissionMap.get(7);
 
+        List<WalletStatisticsDetail> walletStatisticsDetailList2 = walletStatisticsDetailList.subList(fromIndex, toIndex);
 
-        WalletStatistics walletStatistics = new WalletStatistics();
-        Page<WalletStatisticsDetail> walletStatisticsDetailPage = new Page<>();
         walletStatisticsDetailPage.setCurrent(current);
         walletStatisticsDetailPage.setSize(size);
+        walletStatisticsDetailPage.setTotal(walletStatisticsDetailList.size());
         walletStatisticsDetailPage.setRecords(walletStatisticsDetailList2);
         walletStatistics.setPage(walletStatisticsDetailPage);
         walletStatistics.setTotalRecharge(totalRecharge);

--
Gitblit v1.7.1