| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public CommissionStatistics commissionStatistics(Page<BalanceChangeRecord> page, BalanceChangeRecord balanceChangeRecord) { |
|---|
| | | |
|---|
| | | List<AppUser> appUserList = appUserService.list(new LambdaQueryWrapper<AppUser>() |
|---|
| | | .like(StringUtils.isNotEmpty(balanceChangeRecord.getUserName()), AppUser::getName, balanceChangeRecord.getUserName()) |
|---|
| | | .like(StringUtils.isNotEmpty(balanceChangeRecord.getUserPhone()), AppUser::getPhone, balanceChangeRecord.getUserPhone())); |
|---|
| | | if (CollectionUtils.isEmpty(appUserList)){ |
|---|
| | | return new CommissionStatistics(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | List<Long> appUserIds = appUserList.stream().map(AppUser::getId).collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | BigDecimal totalCommission = appUserList.stream() |
|---|
| | | .map(AppUser::getTotalDistributionAmount) |
|---|
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
|---|
| | | |
|---|
| | | |
|---|
| | | Page<BalanceChangeRecord> changeRecordPage = page(page, new LambdaQueryWrapper<BalanceChangeRecord>() |
|---|
| | | .in(BalanceChangeRecord::getAppUserId, appUserIds) |
|---|
| | | .between(balanceChangeRecord.getStartTime() != null && balanceChangeRecord.getEndTime() != null, |
|---|
| | | BalanceChangeRecord::getCreateTime, balanceChangeRecord.getStartTime(), balanceChangeRecord.getEndTime())); |
|---|
| | | return new CommissionStatistics(totalCommission, changeRecordPage); |
|---|
| | | IPage<BalanceChangeRecord> balanceChangeRecordIPage = this.baseMapper.queryCommissionStatistics(page, balanceChangeRecord); |
|---|
| | | // return new CommissionStatistics(totalCommission, changeRecordPage); |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | } |
|---|
