From fc21ab0f288823a22a05b13d33f07362b5c6b91c Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期一, 13 一月 2025 13:13:11 +0800
Subject: [PATCH] 修改bug

---
 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java |   37 ++++++-------------------------------
 1 files changed, 6 insertions(+), 31 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 30e60fd..147d78f 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
@@ -62,34 +62,14 @@
         ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement();
         shopBalanceStatement.setType(1);
 
-        List<BalanceChangeRecord> balanceChangeRecordList = this.baseMapper.selectBalanceChangeRecordList(balanceChangeRecord);
-        List<WalletStatisticsDetail> walletStatisticsDetailList = new ArrayList<>();
-        for (BalanceChangeRecord changeRecord : balanceChangeRecordList) {
+        IPage<BalanceChangeRecord> balanceChangeRecordIPage = this.baseMapper.queryCommissionStatistics(page, balanceChangeRecord);
+        IPage<WalletStatisticsDetail> walletStatisticsDetailIPage = balanceChangeRecordIPage.convert(changeRecord -> {
             WalletStatisticsDetail walletStatisticsDetail = new WalletStatisticsDetail();
             BeanUtils.copyBeanProp(walletStatisticsDetail, changeRecord);
-            walletStatisticsDetailList.add(walletStatisticsDetail);
-        }
+            return walletStatisticsDetail;
+        });
 
-
-        // 按时间排序(倒序)
-        walletStatisticsDetailList.sort(Comparator.comparing(WalletStatisticsDetail::getCreateTime).reversed());
-
-        long current = page.getCurrent();
-        long size = page.getSize();
-        if (current < 1) {
-            current = 1;
-        }
-        int fromIndex = (int) ((current - 1) * size);
-        int toIndex = (int) Math.min(fromIndex + size, walletStatisticsDetailList.size());
-
-        if (fromIndex >= walletStatisticsDetailList.size()) {
-            throw new ServiceException("页面参数无效");
-        }
-
-        List<WalletStatisticsDetail> walletStatisticsDetailList2 = walletStatisticsDetailList.subList(fromIndex, toIndex);
-
-
-        Map<Integer, BigDecimal> shopCommissionMap = walletStatisticsDetailList.stream()
+        Map<Integer, BigDecimal> shopCommissionMap = walletStatisticsDetailIPage.getRecords().stream()
                 .collect(Collectors.groupingBy(
                         WalletStatisticsDetail::getChangeType,
                         Collectors.reducing(
@@ -105,12 +85,7 @@
 
 
         WalletStatistics walletStatistics = new WalletStatistics();
-        Page<WalletStatisticsDetail> page1 = new Page<>();
-        page1.setRecords(walletStatisticsDetailList2);
-        page1.setTotal(walletStatisticsDetailList.size());
-        page1.setCurrent(current);
-        page1.setSize(size);
-        walletStatistics.setPage(page1);
+        walletStatistics.setPage(walletStatisticsDetailIPage);
         walletStatistics.setTotalRecharge(totalRecharge);
         walletStatistics.setTotalWithdraw(totalWithdraw);
         walletStatistics.setTotalShopWithdraw(totalShopWithdraw);

--
Gitblit v1.7.1