| | |
|---|
| | | ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement(); |
|---|
| | | shopBalanceStatement.setType(1); |
|---|
| | | |
|---|
| | | IPage<BalanceChangeRecord> balanceChangeRecordIPage = this.baseMapper.queryCommissionStatistics(page, balanceChangeRecord); |
|---|
| | | IPage<WalletStatisticsDetail> walletStatisticsDetailIPage = balanceChangeRecordIPage.convert(changeRecord -> { |
|---|
| | | List<BalanceChangeRecord> balanceChangeRecordList = this.baseMapper.selectBalanceChangeRecordList(balanceChangeRecord); |
|---|
| | | List<WalletStatisticsDetail> walletStatisticsDetailList = new ArrayList<>(); |
|---|
| | | for (BalanceChangeRecord changeRecord : balanceChangeRecordList) { |
|---|
| | | WalletStatisticsDetail walletStatisticsDetail = new WalletStatisticsDetail(); |
|---|
| | | BeanUtils.copyBeanProp(walletStatisticsDetail, changeRecord); |
|---|
| | | return walletStatisticsDetail; |
|---|
| | | }); |
|---|
| | | walletStatisticsDetailList.add(walletStatisticsDetail); |
|---|
| | | } |
|---|
| | | |
|---|
| | | Map<Integer, BigDecimal> shopCommissionMap = walletStatisticsDetailIPage.getRecords().stream() |
|---|
| | | |
|---|
| | | // 按时间排序（倒序） |
|---|
| | | 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("页面参数无效"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | Map<Integer, BigDecimal> shopCommissionMap = walletStatisticsDetailList.stream() |
|---|
| | | .collect(Collectors.groupingBy( |
|---|
| | | WalletStatisticsDetail::getChangeType, |
|---|
| | | Collectors.reducing( |
|---|
| | |
|---|
| | | BigDecimal totalWithdraw = shopCommissionMap.get(2); |
|---|
| | | BigDecimal totalShopWithdraw = shopCommissionMap.get(7); |
|---|
| | | |
|---|
| | | List<WalletStatisticsDetail> walletStatisticsDetailList2 = walletStatisticsDetailList.subList(fromIndex, toIndex); |
|---|
| | | |
|---|
| | | WalletStatistics walletStatistics = new WalletStatistics(); |
|---|
| | | walletStatistics.setPage(walletStatisticsDetailIPage); |
|---|
| | | Page<WalletStatisticsDetail> walletStatisticsDetailPage = new Page<>(); |
|---|
| | | walletStatisticsDetailPage.setCurrent(current); |
|---|
| | | walletStatisticsDetailPage.setSize(walletStatisticsDetailList.size()); |
|---|
| | | walletStatisticsDetailPage.setRecords(walletStatisticsDetailList2); |
|---|
| | | walletStatistics.setPage(walletStatisticsDetailPage); |
|---|
| | | walletStatistics.setTotalRecharge(totalRecharge); |
|---|
| | | walletStatistics.setTotalWithdraw(totalWithdraw); |
|---|
| | | walletStatistics.setTotalShopWithdraw(totalShopWithdraw); |
|---|
