From 3de79cb08809a47a91d354331ab166ab7cc87dc6 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期一, 13 一月 2025 11:02:43 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java |   23 +++++++----------------
 1 files changed, 7 insertions(+), 16 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 943a5f1..5b2d63d 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
@@ -12,6 +12,7 @@
 import com.ruoyi.account.vo.WalletStatisticsDetail;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.exception.ServiceException;
+import com.ruoyi.common.core.utils.StringUtils;
 import com.ruoyi.common.core.utils.bean.BeanUtils;
 import com.ruoyi.other.api.domain.ShopBalanceStatement;
 import com.ruoyi.other.api.feignClient.ShopClient;
@@ -36,13 +37,13 @@
         Page<BalanceChangeRecord> page = new Page<>();
         page.setCurrent(agentQuery.getPageNum());
         page.setSize(agentQuery.getPageSize());
-        IPage<BalanceChangeRecord> shopIPage = this.baseMapper.pageList(page, agentQuery);
-        return shopIPage;
+        return this.baseMapper.pageList(page, agentQuery);
     }
 
     @Override
     public CommissionStatistics commissionStatistics(Page<BalanceChangeRecord> page, BalanceChangeRecord balanceChangeRecord) {
         List<BalanceChangeRecord> balanceChangeRecordList = this.baseMapper.selectBalanceChangeRecordList(balanceChangeRecord);
+
         BigDecimal totalCommission = balanceChangeRecordList.stream()
                 .filter(item -> !(item.getChangeType().equals(2) && item.getChangeType().equals(5)))
                 .map(BalanceChangeRecord::getChangeAmount)
@@ -50,13 +51,16 @@
                 .setScale(2, RoundingMode.HALF_UP);
 
         IPage<BalanceChangeRecord> balanceChangeRecordIPage = this.baseMapper.queryCommissionStatistics(page, balanceChangeRecord);
+        // 过滤商城购物
+        List<BalanceChangeRecord> collect = balanceChangeRecordIPage.getRecords().stream().filter(e -> e.getChangeType() != 5).collect(Collectors.toList());
+        balanceChangeRecordIPage.setRecords(collect);
         return new CommissionStatistics(totalCommission, balanceChangeRecordIPage);
     }
 
     @Override
     public WalletStatistics walletStatistics(Page<BalanceChangeRecord> page, BalanceChangeRecord balanceChangeRecord) {
         ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement();
-        shopBalanceStatement.setType(4);
+        shopBalanceStatement.setType(1);
 
         R<List<ShopBalanceStatement>> r;
         try {
@@ -71,7 +75,6 @@
         }
 
         List<BalanceChangeRecord> balanceChangeRecordList = this.baseMapper.selectBalanceChangeRecordList(balanceChangeRecord);
-
         List<WalletStatisticsDetail> walletStatisticsDetailList = new ArrayList<>();
         for (BalanceChangeRecord changeRecord : balanceChangeRecordList) {
             WalletStatisticsDetail walletStatisticsDetail = new WalletStatisticsDetail();
@@ -79,7 +82,6 @@
             walletStatisticsDetailList.add(walletStatisticsDetail);
         }
 
-        walletStatisticsDetailList.addAll(r.getData().stream().map(this::createWalletStatisticsDetail).collect(Collectors.toList()));
 
         // 按时间排序(倒序)
         walletStatisticsDetailList.sort(Comparator.comparing(WalletStatisticsDetail::getCreateTime).reversed());
@@ -125,17 +127,6 @@
         walletStatistics.setTotalWithdraw(totalWithdraw);
         walletStatistics.setTotalShopWithdraw(totalShopWithdraw);
         return walletStatistics;
-    }
-
-    private WalletStatisticsDetail createWalletStatisticsDetail(ShopBalanceStatement item) {
-        WalletStatisticsDetail walletStatisticsDetail = new WalletStatisticsDetail();
-        walletStatisticsDetail.setShopName(item.getShopName());
-        walletStatisticsDetail.setUserName(item.getShopManagerName());
-        walletStatisticsDetail.setUserPhone(item.getPhone());
-        walletStatisticsDetail.setChangeType(4);
-        walletStatisticsDetail.setCreateTime(item.getCreateTime());
-        walletStatisticsDetail.setChangeAmount(item.getVariableAmount());
-        return walletStatisticsDetail;
     }
 
 }

--
Gitblit v1.7.1