| Line 940... |
Line 940... |
| 940 |
.stream().filter(x -> x.getValue().size() == 1).map(x -> x.getKey()).collect(Collectors.toList());
|
940 |
.stream().filter(x -> x.getValue().size() == 1).map(x -> x.getKey()).collect(Collectors.toList());
|
| 941 |
|
941 |
|
| 942 |
List<OfferPayout> partnerPayouts = offerPayouts.stream().filter(x -> x.getFofoId() == fofoId).collect(Collectors.toList());
|
942 |
List<OfferPayout> partnerPayouts = offerPayouts.stream().filter(x -> x.getFofoId() == fofoId).collect(Collectors.toList());
|
| 943 |
Set<String> serialNumbersRejected = partnerPayouts.stream().filter(x -> x.getStatus().equals(SchemePayoutStatus.REJECTED)).map(x -> x.getSerialNumber()).collect(Collectors.toSet());
|
943 |
Set<String> serialNumbersRejected = partnerPayouts.stream().filter(x -> x.getStatus().equals(SchemePayoutStatus.REJECTED)).map(x -> x.getSerialNumber()).collect(Collectors.toSet());
|
| 944 |
|
944 |
|
| 945 |
Set<String> serialNumbers;
|
945 |
Set<String> billedNotCancelledSerialNumbers;
|
| 946 |
LOGGER.info("warehouseInventoryItemIds {}", warehouseInventoryItemIds);
|
946 |
LOGGER.info("warehouseInventoryItemIds {}", warehouseInventoryItemIds);
|
| 947 |
if (warehouseInventoryItemIds.size() > 0) {
|
947 |
if (warehouseInventoryItemIds.size() > 0) {
|
| 948 |
List<WarehouseInventoryItem> warehouseInventoryItems = warehouseInventoryItemRepository.selectAllByIds(warehouseInventoryItemIds);
|
948 |
List<WarehouseInventoryItem> warehouseInventoryItems = warehouseInventoryItemRepository.selectAllByIds(warehouseInventoryItemIds);
|
| 949 |
serialNumbers = warehouseInventoryItems.stream().map(x -> x.getSerialNumber()).collect(Collectors.toSet());
|
949 |
billedNotCancelledSerialNumbers = warehouseInventoryItems.stream().map(x -> x.getSerialNumber()).collect(Collectors.toSet());
|
| 950 |
} else {
|
950 |
} else {
|
| 951 |
serialNumbers = new HashSet<>();
|
951 |
billedNotCancelledSerialNumbers = new HashSet<>();
|
| 952 |
}
|
952 |
}
|
| 953 |
LOGGER.info("SerialNumbers {}", serialNumbers);
|
953 |
LOGGER.info("billedNotCancelledSerialNumbers {}", billedNotCancelledSerialNumbers);
|
| 954 |
Map<String, Long> serialNumberCountMap = lineItemImeisRepository.selectByLineItemIds(new ArrayList<>(lineItemMap.keySet()))
|
- |
|
| 955 |
.stream().collect(Collectors.groupingBy(x -> x.getSerialNumber(), Collectors.counting()));
|
- |
|
| 956 |
LOGGER.info("SerialNumbers Count Map {}", serialNumberCountMap);
|
- |
|
| - |
|
954 |
|
| 957 |
Map<String, LineItem> serialNumberMap = lineItemImeisRepository.selectByLineItemIds(new ArrayList<>(lineItemMap.keySet()))
|
955 |
Map<String, LineItem> serialNumberMap = lineItemImeisRepository.selectByLineItemIds(new ArrayList<>(lineItemMap.keySet()))
|
| 958 |
.stream().filter(x -> !serialNumbersRejected.contains(x.getSerialNumber())).collect(Collectors.toMap(x -> x.getSerialNumber(), x -> lineItemMap.get(x.getLineItemId()), (x1, x2) -> x1.getId() > x2.getId() ? x1 : x2));
|
956 |
.stream().filter(x -> !serialNumbersRejected.contains(x.getSerialNumber())).collect(Collectors.toMap(x -> x.getSerialNumber(), x -> lineItemMap.get(x.getLineItemId()), (x1, x2) -> x1.getId() > x2.getId() ? x1 : x2));
|
| 959 |
|
957 |
|
| 960 |
|
958 |
|
| 961 |
serialNumberMap = serialNumberMap.entrySet().stream().filter(x -> serialNumbers.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
|
959 |
serialNumberMap = serialNumberMap.entrySet().stream().filter(x -> billedNotCancelledSerialNumbers.contains(x.getKey())).collect(Collectors.toMap(x -> x.getKey(), x -> x.getValue()));
|
| 962 |
LOGGER.info("serialNumberMap {}", serialNumberMap);
|
960 |
LOGGER.info("serialNumberMap {}", serialNumberMap);
|
| 963 |
if (serialNumberMap.size() == 0) continue;
|
961 |
if (serialNumberMap.size() == 0) continue;
|
| 964 |
Map<String, InventoryItem> serialNumberInventoryItemMap = this.getInventoryItemMap(fofoId, serialNumberMap);
|
962 |
Map<String, InventoryItem> serialNumberInventoryItemMap = this.getInventoryItemMap(fofoId, serialNumberMap);
|
| 965 |
//Continue if all imeis havent been grned
|
963 |
//Continue if all imeis havent been grned
|
| 966 |
if (serialNumberInventoryItemMap.size() < serialNumberCountMap.size()) continue;
|
964 |
if (serialNumberInventoryItemMap.size() < billedNotCancelledSerialNumbers.size()) continue;
|
| 967 |
|
965 |
|
| 968 |
|
966 |
|
| 969 |
float eligiblePayoutValue = eligibleSlab.getPayoutAmount();
|
967 |
float eligiblePayoutValue = eligibleSlab.getPayoutAmount();
|
| 970 |
double finalPayout;
|
968 |
double finalPayout;
|
| 971 |
if (AmountType.PERCENTAGE.equals(itemCriteriaPayout.getAmountType())) {
|
969 |
if (AmountType.PERCENTAGE.equals(itemCriteriaPayout.getAmountType())) {
|