From 2bc35df79fca920ad584a82b5ea7b35b6ca7b8a0 Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期三, 15 一月 2025 10:12:57 +0800 Subject: [PATCH] 12.18 --- ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/BalanceChangeRecordServiceImpl.java | 47 ++++++++++++++++++++++++----------------------- 1 files changed, 24 insertions(+), 23 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 5b2d63d..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); } @@ -61,18 +74,6 @@ public WalletStatistics walletStatistics(Page<BalanceChangeRecord> page, BalanceChangeRecord balanceChangeRecord) { ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement(); shopBalanceStatement.setType(1); - - R<List<ShopBalanceStatement>> r; - try { - r = shopClient.getShopBalanceStatementList(shopBalanceStatement); - } catch (Exception e) { - log.error("获取店铺余额对账单列表时出错", e); - return null; - } - - if (R.isError(r)) { - return null; - } List<BalanceChangeRecord> balanceChangeRecordList = this.baseMapper.selectBalanceChangeRecordList(balanceChangeRecord); List<WalletStatisticsDetail> walletStatisticsDetailList = new ArrayList<>(); @@ -94,12 +95,13 @@ 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 = walletStatisticsDetailList.stream() .collect(Collectors.groupingBy( @@ -115,14 +117,13 @@ BigDecimal totalWithdraw = shopCommissionMap.get(2); BigDecimal totalShopWithdraw = shopCommissionMap.get(7); + List<WalletStatisticsDetail> walletStatisticsDetailList2 = walletStatisticsDetailList.subList(fromIndex, toIndex); - 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); + walletStatisticsDetailPage.setCurrent(current); + walletStatisticsDetailPage.setSize(size); + walletStatisticsDetailPage.setTotal(walletStatisticsDetailList.size()); + walletStatisticsDetailPage.setRecords(walletStatisticsDetailList2); + walletStatistics.setPage(walletStatisticsDetailPage); walletStatistics.setTotalRecharge(totalRecharge); walletStatistics.setTotalWithdraw(totalWithdraw); walletStatistics.setTotalShopWithdraw(totalShopWithdraw); -- Gitblit v1.7.1