| Line 816... |
Line 816... |
| 816 |
.map(x -> x.getSchemeId()).collect(Collectors.toList());
|
816 |
.map(x -> x.getSchemeId()).collect(Collectors.toList());
|
| 817 |
List<Integer> schemeIdsToReject = schemeRepository.selectBySchemeIds(creditedSchemeIds).stream().filter(x -> SchemeType.OUT_TYPES.contains(x.getType())).map(x -> x.getId()).collect(Collectors.toList());
|
817 |
List<Integer> schemeIdsToReject = schemeRepository.selectBySchemeIds(creditedSchemeIds).stream().filter(x -> SchemeType.OUT_TYPES.contains(x.getType())).map(x -> x.getId()).collect(Collectors.toList());
|
| 818 |
|
818 |
|
| 819 |
//Reject invalid scheme payouts due to upgrade in Category or any change in schemes historically
|
819 |
//Reject invalid scheme payouts due to upgrade in Category or any change in schemes historically
|
| 820 |
for (SchemeInOut sio : sios) {
|
820 |
for (SchemeInOut sio : sios) {
|
| 821 |
if (schemeIdsToReject.contains(sio.getSchemeId())) {
|
821 |
if (schemeIdsToReject.contains(sio.getSchemeId()) && !schemeSummaryModelMap.containsKey(sio.getSchemeId())) {
|
| 822 |
sio.setStatusDescription("Rolledback due to Category upgrade/invalid scheme");
|
822 |
sio.setStatusDescription("Rolledback due to Category upgrade/invalid scheme");
|
| 823 |
sio.setStatus(SchemePayoutStatus.REJECTED);
|
823 |
sio.setStatus(SchemePayoutStatus.REJECTED);
|
| 824 |
sio.setRolledBackTimestamp(LocalDateTime.now());
|
824 |
sio.setRolledBackTimestamp(LocalDateTime.now());
|
| 825 |
totalCashback -= sio.getAmount();
|
825 |
totalCashback -= sio.getAmount();
|
| 826 |
}
|
826 |
}
|