| Line 63... |
Line 63... |
| 63 |
Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream()
|
63 |
Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream()
|
| 64 |
.collect(Collectors.groupingBy(x -> x.getInventoryItemId()));
|
64 |
.collect(Collectors.groupingBy(x -> x.getInventoryItemId()));
|
| 65 |
List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());
|
65 |
List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());
|
| 66 |
Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream().collect(
|
66 |
Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream().collect(
|
| 67 |
Collectors.groupingBy(x -> x.getFofoId(), Collectors.mapping(x -> x.getId(), Collectors.toList())));
|
67 |
Collectors.groupingBy(x -> x.getFofoId(), Collectors.mapping(x -> x.getId(), Collectors.toList())));
|
| 68 |
System.out.println("Fofo Id\tInvestment Short Days\tEligible payout");
|
68 |
System.out.println("Fofo Id\tInvestment Maintained Days\tEligible payout");
|
| 69 |
for (Map.Entry<Integer, List<Integer>> retailerEntry : retailerInventoryItemIdMap.entrySet()) {
|
69 |
for (Map.Entry<Integer, List<Integer>> retailerEntry : retailerInventoryItemIdMap.entrySet()) {
|
| 70 |
int fofoId = retailerEntry.getKey();
|
70 |
int fofoId = retailerEntry.getKey();
|
| 71 |
long investmentMaintainedDays = investmentMaintainedDaysMap.get(fofoId) == null ? 0
|
71 |
long investmentMaintainedDays = investmentMaintainedDaysMap.get(fofoId) == null ? 0
|
| 72 |
: investmentMaintainedDaysMap.get(fofoId);
|
72 |
: investmentMaintainedDaysMap.get(fofoId);
|
| 73 |
|
73 |
|
| Line 118... |
Line 118... |
| 118 |
Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream()
|
118 |
Map<Integer, List<SchemeInOut>> inventoryItemIdSchemeMap = schemeInOuts.stream()
|
| 119 |
.collect(Collectors.groupingBy(x -> x.getInventoryItemId()));
|
119 |
.collect(Collectors.groupingBy(x -> x.getInventoryItemId()));
|
| 120 |
List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());
|
120 |
List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIdSchemeMap.keySet());
|
| 121 |
Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream().collect(
|
121 |
Map<Integer, List<Integer>> retailerInventoryItemIdMap = inventoryItems.stream().collect(
|
| 122 |
Collectors.groupingBy(x -> x.getFofoId(), Collectors.mapping(x -> x.getId(), Collectors.toList())));
|
122 |
Collectors.groupingBy(x -> x.getFofoId(), Collectors.mapping(x -> x.getId(), Collectors.toList())));
|
| 123 |
System.out.println("Fofo Id\tInvestment Short Days\tEligible payout");
|
123 |
System.out.println("Fofo Id\tInvestment Maintained Days\tEligible payout");
|
| 124 |
for (Map.Entry<Integer, List<Integer>> retailerEntry : retailerInventoryItemIdMap.entrySet()) {
|
124 |
for (Map.Entry<Integer, List<Integer>> retailerEntry : retailerInventoryItemIdMap.entrySet()) {
|
| 125 |
int fofoId = retailerEntry.getKey();
|
125 |
int fofoId = retailerEntry.getKey();
|
| 126 |
List<SchemeInOut> schemeInouts = retailerEntry.getValue().stream().map(x -> inventoryItemIdSchemeMap.get(x))
|
126 |
List<SchemeInOut> schemeInouts = retailerEntry.getValue().stream().map(x -> inventoryItemIdSchemeMap.get(x))
|
| 127 |
.flatMap(List::stream).collect(Collectors.toList());
|
127 |
.flatMap(List::stream).collect(Collectors.toList());
|
| 128 |
double totalAmount = schemeInouts.stream().filter(x -> x.getRolledBackTimestamp() == null)
|
128 |
double totalAmount = schemeInouts.stream().filter(x -> x.getRolledBackTimestamp() == null)
|