| Line 1263... |
Line 1263... |
| 1263 |
Map<Integer, List<WarehouseScan>> inventoryScansMap = scans.stream().collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));
|
1263 |
Map<Integer, List<WarehouseScan>> inventoryScansMap = scans.stream().collect(Collectors.groupingBy(WarehouseScan::getInventoryItemId));
|
| 1264 |
|
1264 |
|
| 1265 |
for(Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {
|
1265 |
for(Map.Entry<Integer, List<WarehouseScan>> mapEntry : inventoryScansMap.entrySet()) {
|
| 1266 |
int inventoryItemId = mapEntry.getKey();
|
1266 |
int inventoryItemId = mapEntry.getKey();
|
| 1267 |
List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(x->x.getOrderId() != null && x.getOrderId().equals(inventoryOrderMap.get(inventoryItemId))).collect(Collectors.toList());
|
1267 |
List<WarehouseScan> duplicateScans = mapEntry.getValue().stream().filter(x->x.getOrderId() != null && x.getOrderId().equals(inventoryOrderMap.get(inventoryItemId))).collect(Collectors.toList());
|
| 1268 |
WarehouseScan duplicateScan = duplicateScans.stream().findFirst().get();
|
1268 |
WarehouseScan duplicateScan = duplicateScans.stream().skip(1).findFirst().get();
|
| 1269 |
warehouseScanRepository.delete(duplicateScan);
|
1269 |
warehouseScanRepository.delete(duplicateScan);
|
| 1270 |
warehouseInventoryService.addQuantity(duplicateScan.getInventoryItemId(), duplicateScan.getQuantity());
|
1270 |
warehouseInventoryService.addQuantity(duplicateScan.getInventoryItemId(), duplicateScan.getQuantity());
|
| 1271 |
|
1271 |
|
| 1272 |
}
|
1272 |
}
|
| 1273 |
|
1273 |
|