Subversion Repositories SmartDukaan

Rev

Rev 26929 | Rev 26934 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 26929 Rev 26933
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
	}