| Line 884... |
Line 884... |
| 884 |
|
884 |
|
| 885 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
885 |
schemeTupleMap.entrySet().stream().filter(x->x.getValue().size()>1).forEach(x->{
|
| 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("{}\t{}\t{}\t{}", partnerTypeSchemeMap.keySet(), partnerTypeToRemove,
|
| 889 |
LOGGER.info("{}\t{}\t{}", partnerTypeSchemeMap.keySet(), partnerTypeToRemove, partnerTypeSchemeMap.get(partnerTypeToRemove).stream().collect(Collectors.summingDouble(SchemeInOut::getAmount)));
|
890 |
partnerTypeSchemeMap.get(partnerTypeToRemove).stream().collect(Collectors.summingDouble(SchemeInOut::getAmount))
|
| - |
|
891 |
,partnerTypeSchemeMap.get(partnerTypeToRemove).stream().map(y->y.getCreateTimestamp()).findFirst().get());
|
| 890 |
|
892 |
|
| 891 |
});
|
893 |
});
|
| 892 |
}
|
894 |
}
|
| 893 |
|
895 |
|
| 894 |
private class SioTuple {
|
896 |
private class SioTuple {
|