| Line 879... |
Line 879... |
| 879 |
.collect(Collectors.groupingBy(
|
879 |
.collect(Collectors.groupingBy(
|
| 880 |
x -> new SioTuple(x.getInventoryItemId(), schemesMap.get(x.getSchemeId()).getType()),
|
880 |
x -> new SioTuple(x.getInventoryItemId(), schemesMap.get(x.getSchemeId()).getType()),
|
| 881 |
Collectors.groupingBy(x->schemesMap.get(x.getSchemeId()).getPartnerType(),
|
881 |
Collectors.groupingBy(x->schemesMap.get(x.getSchemeId()).getPartnerType(),
|
| 882 |
Collectors.mapping(x->x, Collectors.toList()))));
|
882 |
Collectors.mapping(x->x, Collectors.toList()))));
|
| 883 |
|
883 |
|
| - |
|
884 |
LOGGER.info("Partner Types found\tPartnerType To Remove\tAmout to Rollback");
|
| 884 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
885 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
| 885 |
LOGGER.info("Partner Types found\tPartnerType To Remove\tAmout to Rollback");
|
- |
|
| 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 Type to remove {}", partnerTypeToRemove);
|
889 |
LOGGER.info("Partner Type to remove {}", partnerTypeToRemove);
|
| 890 |
LOGGER.info("{}\t{}\t{}", partnerTypeSchemeMap.keySet(), partnerTypeToRemove, partnerTypeSchemeMap.get(partnerTypeToRemove).stream().collect(Collectors.summingDouble(SchemeInOut::getAmount)));
|
890 |
LOGGER.info("{}\t{}\t{}", partnerTypeSchemeMap.keySet(), partnerTypeToRemove, partnerTypeSchemeMap.get(partnerTypeToRemove).stream().collect(Collectors.summingDouble(SchemeInOut::getAmount)));
|