|
|
|
@ -27,10 +27,9 @@ import java.math.RoundingMode; |
|
|
|
import java.time.LocalDate; |
|
|
|
import java.time.LocalDateTime; |
|
|
|
import java.time.format.DateTimeFormatter; |
|
|
|
import java.util.Date; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Random; |
|
|
|
import java.util.UUID; |
|
|
|
import java.util.*; |
|
|
|
import java.util.function.Function; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
/** |
|
|
|
* @program: gold-java |
|
|
|
@ -90,8 +89,42 @@ public class ConsumeServiceImpl implements ConsumeService { |
|
|
|
} |
|
|
|
consumeUser.setMarkets(markets); |
|
|
|
PageHelper.startPage(pageNum, pageSize); //必须要直接跟mapper |
|
|
|
List<ConsumeUser> consumeUsers = consumeMapper.selectBy(consumeUser); |
|
|
|
return new PageInfo<>(consumeUsers); |
|
|
|
List<ConsumeUser> list = consumeMapper.selectBy(consumeUser); |
|
|
|
// 构造退款订单号 |
|
|
|
List<String> refundOrderCodes = list.stream() |
|
|
|
.map(ConsumeUser::getOrderCode) |
|
|
|
.filter(Objects::nonNull) |
|
|
|
.map(code -> "TK_" + code) |
|
|
|
.collect(Collectors.toList()); |
|
|
|
|
|
|
|
// 查询退款订单 |
|
|
|
List<ConsumeUser> refundList = consumeMapper.selectRefund(refundOrderCodes); |
|
|
|
|
|
|
|
// 退款订单转 Map(order_code → refund) |
|
|
|
Map<String, ConsumeUser> refundMap = refundList.stream() |
|
|
|
.collect(Collectors.toMap( |
|
|
|
ConsumeUser::getOrderCode, |
|
|
|
Function.identity(), |
|
|
|
(a, b) -> a |
|
|
|
)); |
|
|
|
|
|
|
|
// 组装退款信息 |
|
|
|
for (ConsumeUser vo : list) { |
|
|
|
ConsumeUser refund = refundMap.get("TK_" + vo.getOrderCode()); |
|
|
|
if (refund != null) { |
|
|
|
vo.setRefundSumGold(refund.getSumGold()); |
|
|
|
vo.setRefundPermanentGold(refund.getPermanentGold()); |
|
|
|
BigDecimal refundFree = |
|
|
|
(refund.getFreeGold() == null ? BigDecimal.ZERO : refund.getFreeGold()); |
|
|
|
vo.setRefundFreeGold(refundFree); |
|
|
|
|
|
|
|
vo.setRefundTaskGold(refund.getTaskGold()); |
|
|
|
vo.setRefundModel(refund.getRefundModel()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return new PageInfo<>(list); |
|
|
|
} |
|
|
|
|
|
|
|
//新增消耗 |
|
|
|
|