|
@@ -187,7 +187,17 @@ public class ConsumptionErrorLogServiceImpl implements ConsumptionErrorLogServic
|
|
|
Long::sum
|
|
|
)
|
|
|
));
|
|
|
+
|
|
|
+ Map<Long, Long> refundMap = consumptionChangeLogService.selectListByStatus(ConsumptionEnum.REFUND_ORDER.getType()).stream()
|
|
|
+ .collect(Collectors.groupingBy(
|
|
|
+ ConsumptionChangeLogDO::getUserId,
|
|
|
+ Collectors.reducing(0L,
|
|
|
+ ConsumptionChangeLogDO::getConsumptionPoints,
|
|
|
+ Long::sum
|
|
|
+ )
|
|
|
+ ));
|
|
|
uesdMap.forEach((k, v) -> uesdMap.put(k, v * -1));
|
|
|
+ refundMap.forEach((k, v) -> uesdMap.put(k, uesdMap.get(k) - v));
|
|
|
|
|
|
|
|
|
Map<Long, Long> transferLogMap = consumptionTransferLogService.selectList().stream()
|