Subversion Repositories SmartDukaan

Rev

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

Rev 27439 Rev 27440
Line 912... Line 912...
912
		List<SchemeInOut> pendingPayouts = schemeInOutRepository.selectAllPending();
912
		List<SchemeInOut> pendingPayouts = schemeInOutRepository.selectAllPending();
913
		List<Integer> schemeIds = new ArrayList<>();
913
		List<Integer> schemeIds = new ArrayList<>();
914
		Set<Integer> inventoryIds = new HashSet<>();
914
		Set<Integer> inventoryIds = new HashSet<>();
915
		for (SchemeInOut pendingPayout: pendingPayouts) {
915
		for (SchemeInOut pendingPayout: pendingPayouts) {
916
			schemeIds.add(pendingPayout.getSchemeId());
916
			schemeIds.add(pendingPayout.getSchemeId());
-
 
917
		}
-
 
918
		Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, 0).stream()
-
 
919
				.filter(x->x.getType().equals(SchemeType.ACTIVATION)).collect(Collectors.toMap(x->x.getId(), x->x));
-
 
920
		pendingPayouts = pendingPayouts.stream().filter(x->schemesMap.get(x.getSchemeId())!=null).collect(Collectors.toList());
-
 
921
 
-
 
922
		for (SchemeInOut pendingPayout: pendingPayouts) {
917
			inventoryIds.add(pendingPayout.getInventoryItemId());
923
			inventoryIds.add(pendingPayout.getInventoryItemId());
918
		}
924
		}
919
		Map<Integer, InventoryItem> inventoryItemMap = inventoryItemRepository.selectByIds(inventoryIds).stream().collect(Collectors.toMap(x->x.getId(), x->x));
925
		Map<Integer, InventoryItem> inventoryItemMap = inventoryItemRepository.selectByIds(inventoryIds).stream().collect(Collectors.toMap(x->x.getId(), x->x));
920
		Map<String, InventoryItem> serialNumberMap = inventoryItemMap.values().stream(). collect(Collectors.toMap(x->x.getSerialNumber(), x->x));
926
		Map<String, InventoryItem> serialNumberMap = inventoryItemMap.values().stream(). collect(Collectors.toMap(x->x.getSerialNumber(), x->x));
921
		
927
		
922
		Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, 0).stream()
-
 
923
				.filter(x->x.getType().equals(x.getType())).collect(Collectors.toMap(x->x.getId(), x->x));
-
 
-
 
928
		
924
		List<ActivatedImei> activatedImeis = activatedImeiRepository.selectBySerialNumbers(new ArrayList<>(serialNumberMap.keySet()));
929
		List<ActivatedImei> activatedImeis = activatedImeiRepository.selectBySerialNumbers(new ArrayList<>(serialNumberMap.keySet()));
925
		
930
		
926
		Map<String, ActivatedImei> activatedImeiMap = activatedImeis.stream().collect(Collectors.toMap(x->x.getSerialNumber(), x->x));
931
		Map<String, ActivatedImei> activatedImeiMap = activatedImeis.stream().collect(Collectors.toMap(x->x.getSerialNumber(), x->x));
927
		for(SchemeInOut pendingPayout : pendingPayouts) {
932
		for(SchemeInOut pendingPayout : pendingPayouts) {
928
			InventoryItem ii = inventoryItemMap.get(pendingPayout.getInventoryItemId());
933
			InventoryItem ii = inventoryItemMap.get(pendingPayout.getInventoryItemId());