| | |
| | | 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( |
| | |
| | | |
| | | |
| | | 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); |