| Line 884... |
Line 884... |
| 884 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
884 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
| 885 |
LOGGER.info("Partner Types found {}", x.getValue());
|
885 |
LOGGER.info("Partner Types found {}", x.getValue());
|
| 886 |
Map<PartnerType, List<SchemeInOut>> partnerTypeSchemeMap = x.getValue();
|
886 |
Map<PartnerType, List<SchemeInOut>> partnerTypeSchemeMap = x.getValue();
|
| 887 |
PartnerType partnerTypeToRemove = partnerTypeSchemeMap.keySet().stream().min(
|
887 |
PartnerType partnerTypeToRemove = partnerTypeSchemeMap.keySet().stream().min(
|
| 888 |
Comparator.comparing(y->PartnerType.PartnerTypeRankMap.get(y))).get();
|
888 |
Comparator.comparing(y->PartnerType.PartnerTypeRankMap.get(y))).get();
|
| 889 |
LOGGER.info("Partner Types to remove", partnerTypeToRemove);
|
889 |
LOGGER.info("Partner Type to remove {}", partnerTypeToRemove);
|
| 890 |
LOGGER.info("Amout to be rollback {}",
|
890 |
LOGGER.info("Amout to be rollback {}",
|
| 891 |
partnerTypeSchemeMap.get(partnerTypeToRemove).stream().collect(Collectors.summingDouble(SchemeInOut::getAmount)));
|
891 |
partnerTypeSchemeMap.get(partnerTypeToRemove).stream().collect(Collectors.summingDouble(SchemeInOut::getAmount)));
|
| 892 |
|
892 |
|
| 893 |
});
|
893 |
});
|
| 894 |
}
|
894 |
}
|